fix(offset): use latest

restorecommerce · Feb 20, 2025 · b8073c8 · b8073c8
1 parent 8b6c056
commit b8073c8
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 13 deletions.
diff --git a/cfg/config.json b/cfg/config.json
@@ -66,7 +66,7 @@
           "localhost:29092"
         ]
       },
-      "latestOffset": false,
+      "latestOffset": true,
       "orderCreated": {
         "messageObject": "io.restorecommerce.order.Order"
       },

diff --git a/src/service.ts b/src/service.ts
@@ -1722,17 +1722,6 @@ export class OrderingService
             }
           );
         }
-
-        Object.values(response_map).forEach(
-          item => {
-            if (item.status?.code !== 200 && 'INVALID' in this.emitters) {
-              this.orderingTopic.emit(this.emitters['INVALID'], item);
-            }
-            else if (item.payload?.order_state in this.emitters) {
-              this.orderingTopic.emit(this.emitters[item.payload.order_state], item.payload);
-            }
-          }
-        );
 
         if (this.notification_service) {
           this.logger?.debug('Send notifications on submit...');
@@ -1783,6 +1772,17 @@ export class OrderingService
             }
           ));
         }
+
+        await Promise.all(Object.values(response_map).map(
+          async item => {
+            if (item.status?.code !== 200 && 'INVALID' in this.emitters) {
+              await this.orderingTopic.emit(this.emitters['INVALID'], item);
+            }
+            else if (item.payload?.order_state in this.emitters) {
+              await this.orderingTopic.emit(this.emitters[item.payload.order_state], item.payload);
+            }
+          }
+        ));
       }
       catch (error: any) {
         response.operation_status = this.catchOperationError(error)?.operation_status;

diff --git a/test/ordering-srv.spec.ts b/test/ordering-srv.spec.ts
@@ -216,7 +216,7 @@ describe('The Ordering Service:', () => {
 
   for (let [sample_name, sample] of Object.entries(samples.orders.valid)) {
     it(`should submit valid orders by sample: ${sample_name}`, async function() {
-      this.timeout(5000);
+      this.timeout(30000);
       const response = await client.submit(sample);
       should.equal(
         response.operationStatus?.code,