fix(deps): upgrade deps

package.json

@@ -10,14 +10,13 @@
   },
   "type": "module",
   "dependencies": {
-    "@restorecommerce/acs-client": "3.0.7",
+    "@restorecommerce/acs-client": "3.0.8",
     "@restorecommerce/cart": "^1.0.9",
-    "@restorecommerce/chassis-srv": "1.6.4",
+    "@restorecommerce/chassis-srv": "^1.6.4",
     "@restorecommerce/grpc-client": "^2.2.4",
-    "@restorecommerce/kafka-client": "1.2.20",
     "@restorecommerce/logger": "^1.3.1",
-    "@restorecommerce/rc-grpc-clients": "^5.1.42",
-    "@restorecommerce/resource-base-interface": "1.6.4",
+    "@restorecommerce/rc-grpc-clients": "^5.1.43",
+    "@restorecommerce/resource-base-interface": "^1.6.4",
     "@restorecommerce/service-config": "^1.0.15",
     "@types/soap": "0.18.0",
     "@types/xml-js": "0.9.0",

src/services/fulfillment.ts

@@ -1056,7 +1056,7 @@ export class FulfillmentService
   ): Promise<FulfillmentListResponse> {
     try {
       await this.getFulfillmentsByIds(
-        request.items.map(item => item.id),
+        request.items?.map(item => item.id),
         request.subject,
         context,
       ).then(
@@ -1065,8 +1065,8 @@ export class FulfillmentService
             throw response.operation_status;
           }
           else {
-            const result_map = new Map(response.items.map(item => [item.payload.id, item]));
-            request.items = request.items.map(
+            const result_map = new Map(response.items?.map(item => [item.payload.id, item]));
+            request.items = request.items?.map(
               item => ({
                 ...result_map.get(item.id)?.payload,
                 ...item

src/services/fulfillment_courier.ts

@@ -66,7 +66,7 @@ export class FulfillmentCourierService
         cfg.get('database:main:collections:1') ?? 'fulfillment_couriers',
         cfg.get('fieldHandlers:fulfillment_courier')
       ),
-      cfg.get('events:enableEvents')?.toString() === 'true'
+      cfg.get('events:enableEvents')?.toString() === 'true',
     );
   }
 

src/services/fulfillment_product.ts

@@ -225,7 +225,7 @@ export class FulfillmentProductService
         cfg.get('database:main:collections:2') ?? 'fulfillment_products',
         cfg.get('fieldHandlers:fulfillment_product')
       ),
-      cfg.get('events:enableEvents')?.toString() === 'true'
+      cfg.get('events:enableEvents')?.toString() === 'true',
     );
 
     this.status_codes = {
@@ -559,7 +559,7 @@ export class FulfillmentProductService
     }
 
     const ids = [...new Set(
-      query.preferences?.courier_ids?.map(id => id) ?? []
+      query.preferences?.fulfillment_product_ids?.map(id => id) ?? []
     ).values()];
     const call = ReadRequest.fromPartial({
       filters: [{

src/utils.ts

@@ -56,6 +56,7 @@ import {
   Status
 } from '@restorecommerce/rc-grpc-clients/dist/generated-server/io/restorecommerce/status.js';
 import { Attribute } from '@restorecommerce/rc-grpc-clients/dist/generated-server/io/restorecommerce/attribute.js';
+import { PhysicalProduct, PhysicalVariant } from '@restorecommerce/rc-grpc-clients/dist/generated-server/io/restorecommerce/product.js';
 
 export type CRUDClient = Client<TaxServiceDefinition>
 | Client<UserServiceDefinition>

src/worker.ts

@@ -287,8 +287,9 @@ export class Worker {
     });
 
     // start server
+    this.logger.info('Server starting...');
     await this.server.start();
-    this.logger.info('server started successfully');
+    this.logger.info('Server started and ready to use.');
   }
 
   async stop(): Promise<any> {