sf-sim/packages/sim-objenious-cron/index.ts

import { pgPool } from "./config/postgreConfig.js"
import { PgClient } from "sim-shared/infrastructure/PgClient.js"
import { httpInstance } from "./config/httpClient.config.js"
import { CheckObjeniousRequests } from "./tasks/check_objenious_request.js"
import { ObjeniousOperationsRepository } from "sim-shared/infrastructure/ObjeniousOperationRepository.js"
import { OrderRepository } from "sim-shared/infrastructure/OrderRepository.js"

async function startCron() {
  const commonSettings = {
    maxRandomDelay: 1000,
    noOverlap: true
  }

  const httpClient = httpInstance
  const pgClient = new PgClient({ pool: pgPool })
  await pgClient.checkDatabaseConnection()
  await pgClient.checkDatabaseConnection()
  const operationRepository = new ObjeniousOperationsRepository(pgClient)
  const orderRepository = new OrderRepository(pgClient)

  const objTask = new CheckObjeniousRequests(
    operationRepository,
    orderRepository,
    httpClient,
  )

  await objTask.getPendingOperations()

  const interval = setInterval(async () => {
    console.log("Updating...")
    await objTask.getPendingOperations()
    console.log("Update finished")
  }, 10 * 60 * 1000)
  /*
  const task = cron.createTask("* * * * *", async () => {
  }
    , {
      ...commonSettings,
      name: "Test"
    })
*/

  //await objTask.getPendingOperations()

}

startCron().then(e => console.log).catch(e => console.error)