import { plugin } from "../../modules/plugin";
import { ImportOps } from "../../modules/ops/import";
import { config } from "actionhero";
import { CLSTask } from "../../classes/tasks/clsTask";
import { CLS } from "../../modules/cls";

export class ImportAssociateRecords extends CLSTask {
  name = "import:associateRecords";
  description = "ensure that imports are associated to records";
  frequency = 1000 * 10;
  queue = "imports";
  inputs = {} as const;

  async runWithinTransaction() {
    const limit: number = config.batchSize.imports;
    const delayMs =
      parseInt(
        (await plugin.readSetting("core", "imports-retry-delay-seconds")).value
      ) * 1000;

    const imports = await ImportOps.processPendingImportsForAssociation(
      limit,
      delayMs
    );

    // re-enqueue if there is more to do
    if (imports.length > 0) await CLS.enqueueTask(this.name, {});

    return imports.length;
  }
}