diff --git a/docs/sim-api/Pause.bru b/docs/sim-api/Pause.bru index cfb5e5e..68c7375 100644 --- a/docs/sim-api/Pause.bru +++ b/docs/sim-api/Pause.bru @@ -15,7 +15,7 @@ params:query { } body:form-urlencoded { - iccid: 8935103196306448300 + iccid: 8933201125065160331 } settings { diff --git a/package.json b/package.json index 785b2cf..bb54b8f 100644 --- a/package.json +++ b/package.json @@ -11,7 +11,7 @@ "setup:runtime": "mkdir -p dist/packages/node_modules && ln -sf ../sim-shared dist/packages/node_modules/sim-shared && ln -sf ../sf-consumidor-objenious dist/packages/node_modules/sim-consumidor-objenious", "start": "yarn setup:runtime && yarn workspaces foreach -Apiv run start", "typecheck": "npx tsc --noEmit", - "dev": "yarn workspaces foreach -Apiv --exclude sim-objenious-cron run dev", + "dev": "yarn workspaces foreach -Apiv run dev", "lint": "eslint .", "lint:fix": "eslint --fix .", "format": "prettier --write .", diff --git a/packages/sim-consumidor-objenious/aplication/Sim.usecases.ts b/packages/sim-consumidor-objenious/aplication/Sim.usecases.ts index 76b289b..36e744b 100644 --- a/packages/sim-consumidor-objenious/aplication/Sim.usecases.ts +++ b/packages/sim-consumidor-objenious/aplication/Sim.usecases.ts @@ -321,13 +321,14 @@ export class SimUseCases { } // TODO REGISTRAR EL ORDER + /* if (correlation_id != undefined) { await this.orderRepository.createOrder({ correlation_id: correlation_id, order_type: "pause" }) } - +*/ let activationDate; try { activationDate = await this.findActivationDate(suspendData) diff --git a/packages/sim-objenious-cron/index.ts b/packages/sim-objenious-cron/index.ts index 59430b5..5ae82f8 100644 --- a/packages/sim-objenious-cron/index.ts +++ b/packages/sim-objenious-cron/index.ts @@ -62,7 +62,7 @@ async function startCron() { orderRepository ) - await objTask.getPendingOperations() + //await objTask.getPendingOperations() const PERIODO_PETICIONES = 10 * 60 * 1000 const interval = setInterval(async () => { try { diff --git a/packages/sim-objenious-cron/tasks/check_objenious_request.ts b/packages/sim-objenious-cron/tasks/check_objenious_request.ts index a8b9f3a..c75c04d 100644 --- a/packages/sim-objenious-cron/tasks/check_objenious_request.ts +++ b/packages/sim-objenious-cron/tasks/check_objenious_request.ts @@ -37,6 +37,11 @@ export class CheckObjeniousRequests { // Todas las validas const operacionesValidas = pendingOperations.data .filter((e) => e.request_id != undefined) + .filter((e) => e.operation != "terminate" && e.operation != "suspend") + + // Filtrar suspension / terminacion + + // Validas sin MassId const solicitarMassId = operacionesValidas .filter((e) => e.mass_action_id == undefined) diff --git a/packages/sim-objenious-cron/tasks/check_pause_terminate.ts b/packages/sim-objenious-cron/tasks/check_pause_terminate.ts index 6cd53a8..7773171 100644 --- a/packages/sim-objenious-cron/tasks/check_pause_terminate.ts +++ b/packages/sim-objenious-cron/tasks/check_pause_terminate.ts @@ -66,6 +66,7 @@ export class PauseTerminateTask { } while (!lines.done) { + lines = await lineGenerator.next() if (lines.value.error != undefined || lines.value.data == undefined) { logger.error("Error cargando las lineas", lines.value.error) finError(lines.value.error) @@ -74,7 +75,6 @@ export class PauseTerminateTask { lineasActualizadas.push(...lines.value.data) } - lines = await lineGenerator.next() } console.log("Cargado: ", lineasActualizadas) @@ -126,6 +126,7 @@ export class PauseTerminateTask { switch (operacionTipo) { case "suspend": result = await this.simUsecases.suspend(actionData)() + console.log("SUSPENDED", result) break; case "terminate": result = await this.simUsecases.terminate(actionData)()