wkdhkr/dedupper

File ProcessStateDbService.js has 263 lines of code (exceeds 250 allowed). Consider refactoring.

Open

// @flow
import typeof { Logger } from "log4js";
import type { Database } from "./SQLiteService";
import DeepLearningHelper from "../../helpers/DeepLearningHelper";
import DbHelper from "../../helpers/DbHelper";

Function queryByValue has 34 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  queryByValue(
    column: string,
    $value: number | string
  ): Promise<ProcessStateRow[]> {
    return new Promise((resolve, reject) => {

Function deleteByHash has 31 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  deleteByHash($hash: string): Promise<?ProcessStateRow> {
    return new Promise((resolve, reject) => {
      if (!$hash) {
        resolve();
        return;

Similar blocks of code found in 2 locations. Consider refactoring.

Open

              db.run(
                `insert${replaceStatement} into ${this.config.processStateDbName} (${columns}) values (${values})`,
                this.createRowBind(row),
                err => {
                  if (err) {

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

  createRowBind: (row: ProcessStateRow) => { ... } = (row: ProcessStateRow) => {
    const newRow = {};

    Object.keys(row).forEach(key => {
      newRow[`$${key}`] = row[key] !== undefined ? row[key] : null;

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

          (err, rows: ProcessStateRow[]) => {
            db.close();
            if (!this.ss.handleEachError(db, err, reject)) {
              return;
            }

• Read up
  Read up

Similar blocks of code found in 9 locations. Consider refactoring.

Open

  constructor(config: Config) {
    this.log = config.getLogger(this);
    this.config = config;
    this.ss = new SQLiteService(config);
  }

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

  async init() {
    const db = this.ss.spawn(this.ss.detectDbFilePath(TYPE_IMAGE));
    await this.prepareTable(db);
  }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

            (err, row: ProcessStateRow) => {
              db.close();
              this.ss.handleEachError<ProcessStateRow>(
                db,
                err,

• Read up
  Read up