diff --git a/packages/sim-objenious-cron/index.ts b/packages/sim-objenious-cron/index.ts index 7829811..b624356 100644 --- a/packages/sim-objenious-cron/index.ts +++ b/packages/sim-objenious-cron/index.ts @@ -81,7 +81,6 @@ async function startCron() { } }, PERIODO_VOLCADO) - await pauseTask.run() const PERIODO_CANCELACIONES = 60 * 60 * 1000; const clacelacionesInterval = setInterval(async () => { diff --git a/packages/sim-shared/infrastructure/ObjeniousOperationRepository.test.ts b/packages/sim-shared/infrastructure/ObjeniousOperationRepository.test.ts index 18458d0..8ab56d3 100644 --- a/packages/sim-shared/infrastructure/ObjeniousOperationRepository.test.ts +++ b/packages/sim-shared/infrastructure/ObjeniousOperationRepository.test.ts @@ -8,7 +8,7 @@ describe("[Integration] Test API requests", () => { postgresClient ) - it("Read /lines with multiple iccids", () => { + it("Read last sucessfull operation by line", () => { }) }) diff --git a/packages/sim-shared/infrastructure/ObjeniousOperationRepository.ts b/packages/sim-shared/infrastructure/ObjeniousOperationRepository.ts index 5010326..6dc51fd 100644 --- a/packages/sim-shared/infrastructure/ObjeniousOperationRepository.ts +++ b/packages/sim-shared/infrastructure/ObjeniousOperationRepository.ts @@ -146,6 +146,20 @@ export class ObjeniousOperationsRepository implements IOperationsRepository { } } + + async getLastOperationOfLine(iccid: string) { + const query = ` + SELECT * FROM public.objenious_operation + WHERE iccids = $1 + ORDER BY id asc limit 1 + ` + const values = [iccid]; + const { rows } = await this.pgClient.query(query, values); + return >{ + data: rows[0] + } + } + async updateOperation(data: ObjeniousOperationChange): Promise> { const client = await this.pgClient.connect(); const {