diff --git a/docs/sim-api/Order by id.bru b/docs/sim-api/Order by id.bru index 9940c4a..80104c0 100644 --- a/docs/sim-api/Order by id.bru +++ b/docs/sim-api/Order by id.bru @@ -5,7 +5,7 @@ meta { } get { - url: {{baseurl}}/orders/4 + url: {{baseurl}}/orders/ body: none auth: inherit } diff --git a/packages/sim-entrada-eventos/aplication/Sim.usecases.ts b/packages/sim-entrada-eventos/aplication/Sim.usecases.ts index 1321047..41f3d10 100644 --- a/packages/sim-entrada-eventos/aplication/Sim.usecases.ts +++ b/packages/sim-entrada-eventos/aplication/Sim.usecases.ts @@ -111,7 +111,7 @@ export class SimUsecases { const activationWithId = this.addMessage_id(activationEvent) console.log("[d] Activation ", activationWithId) await this.eventBus.publish([activationWithId]) - this.saveOrder(activationWithId) + await this.saveOrder(activationWithId) } async preActivation(args: { iccid: string, compañia: string }) { @@ -131,14 +131,18 @@ export class SimUsecases { */ async cancelation(args: { iccid: string, compañia: string }) { - const activationEvent = { + const cancelationEvent = { key: `sim.${args.compañia}.cancel`, payload: { iccid: args.iccid } } - console.log("[d] Cancelation ", activationEvent) - return this.eventBus.publish([activationEvent]) + + const cancelationWithId = this.addMessage_id(cancelationEvent) + console.log("[d] Cancelation ", cancelationWithId) + await this.eventBus.publish([cancelationWithId]) + await this.saveOrder(cancelationWithId) + return cancelationWithId } // alias por si acaso public terminate = this.cancelation; @@ -147,15 +151,18 @@ export class SimUsecases { * alias de bloquear / suspender en objenious */ async pause(args: { iccid: string, compañia: string }) { - const cancelationEvent = { + const pauseEvent = { key: `sim.${args.compañia}.pause`, payload: { iccid: args.iccid } } - - return this.eventBus.publish([cancelationEvent]) + const pauseWithId = this.addMessage_id(pauseEvent) + await this.eventBus.publish([pauseWithId]) + await this.saveOrder(pauseWithId) + return pauseWithId } + async free(args: { iccid: string, compañia: string }) { const cancelationEvent = { key: `sim.${args.compañia}.free`, diff --git a/packages/sim-entrada-eventos/infrastructure/orderRoutes.http.ts b/packages/sim-entrada-eventos/infrastructure/orderRoutes.http.ts index f8cf3fd..2c1fbfb 100644 --- a/packages/sim-entrada-eventos/infrastructure/orderRoutes.http.ts +++ b/packages/sim-entrada-eventos/infrastructure/orderRoutes.http.ts @@ -28,9 +28,9 @@ const orderController = new OrderController({ * */ orderRoutes.get("/", (req, res) => { res.send("ok") }) - orderRoutes.get("/message_id/:correlation_id", orderController.getByQueueId()) +/** Operaciones pendientes */ orderRoutes.get("/pending", orderController.getPending()) /** Order por id (uuid del mensaje) */ @@ -38,4 +38,3 @@ orderRoutes.get("/:id", orderController.getById()) export { orderRoutes } -