Aligned consumers events with oubound-model 1.2.0 (#82)

pagopa · Jan 20, 2025 · ce74313 · ce74313
1 parent 45827b3
commit ce74313
Show file tree

Hide file tree

Showing 8 changed files with 39 additions and 10 deletions.
diff --git a/packages/commons/src/logging/logger.ts b/packages/commons/src/logging/logger.ts
@@ -30,7 +30,7 @@ if (!parsedLoggerConfig.success) {
 
 const logFormat = (
   msg: string,
-  timestamp: string,
+  timestamp: unknown,
   level: string,
   { serviceName, correlationId, messageId }: LoggerMetadata,
 ) => {
@@ -54,11 +54,16 @@ const logFormat = (
 
 export const customFormat = () =>
   winston.format.printf(({ level, message, timestamp, ...meta }) => {
-    const lines = message
+    const lines = `${message}`
       .toString()
       .split("\n")
       .map((line: string) =>
-        logFormat(line, timestamp, level, meta.loggerMetadata),
+        logFormat(
+          line,
+          timestamp,
+          level,
+          meta.loggerMetadata as LoggerMetadata,
+        ),
       );
     return lines.join("\n");
   });

diff --git a/packages/eservice-event-consumer/package.json b/packages/eservice-event-consumer/package.json
@@ -18,7 +18,7 @@
   "author": "",
   "license": "Apache-2.0",
   "dependencies": {
-    "@pagopa/interop-outbound-models": "1.0.4",
+    "@pagopa/interop-outbound-models": "1.2.0",
     "@tsconfig/node-lts": "20.1.1",
     "@zodios/core": "10.9.6",
     "axios": "1.7.4",

diff --git a/packages/eservice-event-consumer/src/handlers/messageHandlerV2.ts b/packages/eservice-event-consumer/src/handlers/messageHandlerV2.ts
@@ -27,6 +27,7 @@ export async function handleMessageV2(
           "EServiceAdded",
           "EServiceCloned",
           "EServiceDescriptionUpdated",
+          "EServiceNameUpdated",
         ),
       },
       async (evt) => {
@@ -95,6 +96,10 @@ export async function handleMessageV2(
           "EServiceDescriptorPublished",
           "EServiceDescriptorSuspended",
           "EServiceDraftDescriptorUpdated",
+          "EServiceDescriptorAttributesUpdated",
+          "EServiceDescriptorSubmittedByDelegate",
+          "EServiceDescriptorApprovedByDelegator",
+          "EServiceDescriptorRejectedByDelegator",
         ),
       },
       async (evt) => {

diff --git a/packages/eservice-event-consumer/test/utils.ts b/packages/eservice-event-consumer/test/utils.ts
@@ -121,6 +121,7 @@ export const getDescriptorV2 = (
   createdAt: 1n,
   dailyCallsPerConsumer: 100,
   dailyCallsTotal: 100,
+  rejectionReasons: [],
   docs: [],
   serverUrls: ["http://test.com"],
   state: EServiceDescriptorStateV2.DRAFT,

diff --git a/packages/tenant-event-consumer/package.json b/packages/tenant-event-consumer/package.json
@@ -18,7 +18,7 @@
   "author": "",
   "license": "Apache-2.0",
   "dependencies": {
-    "@pagopa/interop-outbound-models": "1.0.4",
+    "@pagopa/interop-outbound-models": "1.2.0",
     "@tsconfig/node-lts": "20.1.1",
     "@zodios/core": "10.9.6",
     "axios": "1.7.4",

diff --git a/packages/tenant-event-consumer/src/handlers/messageHandlerV2.ts b/packages/tenant-event-consumer/src/handlers/messageHandlerV2.ts
@@ -17,7 +17,11 @@ export async function handleMessageV2(
   await match(event)
     .with(
       {
-        type: P.union("TenantOnboarded", "TenantOnboardDetailsUpdated"),
+        type: P.union(
+          "TenantOnboarded",
+          "TenantOnboardDetailsUpdated",
+          "MaintenanceTenantUpdated",
+        ),
       },
       async (evt) => {
         const { tenant } = evt.data;
@@ -65,6 +69,9 @@ export async function handleMessageV2(
           "TenantVerifiedAttributeExtensionUpdated",
           "TenantKindUpdated",
           "MaintenanceTenantPromotedToCertifier",
+          "TenantDelegatedProducerFeatureAdded",
+          "TenantDelegatedProducerFeatureRemoved",
+          "TenantCertifiedAttributeAssigned",
         ),
       },
       async (evt) => {

diff --git a/packages/tenant-event-consumer/test/utils.ts b/packages/tenant-event-consumer/test/utils.ts
@@ -139,6 +139,7 @@ export const getDescriptorV2 = (
   createdAt: 1n,
   dailyCallsPerConsumer: 100,
   dailyCallsTotal: 100,
+  rejectionReasons: [],
   docs: [],
   serverUrls: ["http://test.com"],
   state: EServiceDescriptorStateV2.DRAFT,

diff --git a/pnpm-lock.yaml b/pnpm-lock.yaml