fix(kafka): set correct event names

Author: Gerald Baulig

cfg/config.json

@@ -168,22 +168,22 @@
       "fulfillmentDeleted": {
         "messageObject": "io.restorecommerce.resourcebase.Deleted"
       },
-      "fulfillmentCourierCreated": {
+      "fulfillment_courierCreated": {
         "messageObject": "io.restorecommerce.fulfillment_courier.FulfillmentCourier"
       },
-      "fulfillmentCourierModified": {
+      "fulfillment_courierModified": {
         "messageObject": "io.restorecommerce.fulfillment_courier.FulfillmentCourier"
       },
-      "fulfillmentCourierDeleted": {
+      "fulfillment_courierDeleted": {
         "messageObject": "io.restorecommerce.resourcebase.Deleted"
       },
-      "fulfillmentProductCreated": {
+      "fulfillment_productCreated": {
         "messageObject": "io.restorecommerce.fulfillment_product.FulfillmentProduct"
       },
-      "fulfillmentProductModified": {
+      "fulfillment_productModified": {
         "messageObject": "io.restorecommerce.fulfillment_product.FulfillmentProduct"
       },
-      "fulfillmentProductDeleted": {
+      "fulfillment_productDeleted": {
         "messageObject": "io.restorecommerce.resourcebase.Deleted"
       },
 

cfg/config_test.json

@@ -22,6 +22,24 @@
       "groupId": "restore-fulfillment-srv-test",
       "kafka": {
         "clientId": "restore-fulfillment-srv-test"
+      },
+      "fulfillmentCourierCreated": {
+        "messageObject": "io.restorecommerce.fulfillment_courier.FulfillmentCourier"
+      },
+      "fulfillmentCourierModified": {
+        "messageObject": "io.restorecommerce.fulfillment_courier.FulfillmentCourier"
+      },
+      "fulfillmentCourierDeleted": {
+        "messageObject": "io.restorecommerce.resourcebase.Deleted"
+      },
+      "fulfillmentProductCreated": {
+        "messageObject": "io.restorecommerce.fulfillment_product.FulfillmentProduct"
+      },
+      "fulfillmentProductModified": {
+        "messageObject": "io.restorecommerce.fulfillment_product.FulfillmentProduct"
+      },
+      "fulfillmentProductDeleted": {
+        "messageObject": "io.restorecommerce.resourcebase.Deleted"
       }
     }
   },

package-lock.json

@@ -14,16 +14,17 @@
     "@restorecommerce/cart": "^1.0.9",
     "@restorecommerce/chassis-srv": "^1.6.5",
     "@restorecommerce/grpc-client": "^2.2.4",
-    "@restorecommerce/logger": "^1.3.1",
+    "@restorecommerce/kafka-client": "1.2.22",
+    "@restorecommerce/logger": "^1.3.2",
     "@restorecommerce/rc-grpc-clients": "^5.1.44",
     "@restorecommerce/resource-base-interface": "^1.6.5",
-    "@restorecommerce/service-config": "^1.0.15",
+    "@restorecommerce/service-config": "^1.0.16",
     "@types/soap": "0.18.0",
     "@types/xml-js": "0.9.0",
     "bignumber.js": "^9.1.2",
     "csv-parse": "^5.6.0",
     "dayjs": "^1.11.10",
-    "redis": "^4.6.14",
+    "redis": "^4.7.0",
     "soap": "1.1.6",
     "xml-js": "^1.6.11"
   },

package.json

@@ -283,7 +283,7 @@ export class AccessControlledServiceBase<O extends ResourceListResponse, I exten
   @resolves_subject()
   @injects_meta_data()
   @access_controlled_function({
-    action: AuthZAction.CREATE,
+    action: AuthZAction.MODIFY,
     operation: Operation.isAllowed,
     context: ACSContextFactory<O, I>,
     resource: DefaultResourceFactory(),