wkdhkr/dedupper

File NsfwJsDbService.js has 291 lines of code (exceeds 250 allowed). Consider refactoring.

Open

// @flow
import typeof { Logger } from "log4js";
import { STATE_ACCEPTED, STATE_KEEPING } from "../../types/FileStates";
import SQLiteService from "./SQLiteService";
import { TYPE_IMAGE } from "../../types/ClassifyTypes";

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

Open

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

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

Open

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

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

Open

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

• Read up
  Read up

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

Open

      db.serialize(async () => {
        try {
          await this.prepareTable(db);
          db.all(
            `select * from ${this.config.deepLearningConfig.nsfwJsDbTableName}`,

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

  prepareTable: (db: Database<NsfwJsHashRow>) => Promise<void> = async (
    db: Database<NsfwJsHashRow>
  ) =>
    this.ss.prepareTable(
      db,

• Read up
  Read up

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

Open

          (err, rows: NsfwJsHashRow[]) => {
            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 2 locations. Consider refactoring.

Open

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

• Read up
  Read up