Atualização de logs de oportunidade (#2)

squidit · Jun 14, 2024 · 303612d · 303612d
1 parent daddc9a
commit 303612d
Show file tree

Hide file tree

Showing 6 changed files with 37 additions and 14 deletions.
diff --git a/.vscode/tasks.json b/.vscode/tasks.json
@@ -0,0 +1,17 @@
+{
+  "version": "2.0.0",
+  "tasks": [
+    {
+      "label": "build",
+      "type": "shell",
+      "command": "npm run build",
+      "group": {
+        "kind": "build",
+        "isDefault": true
+      },
+      "presentation": {
+        "reveal": "always"
+      },
+    }
+  ]
+}
diff --git a/dist/index.d.mts b/dist/index.d.mts
@@ -69,7 +69,7 @@ declare class CrmClient {
     static getInstance(): CrmClient;
     static init(projectId: string, keyFilename: string, loggerInstance: Logger, errorConverter: ErrorConverter, customTopicName?: string): void;
     sendNotification(recipientInfo: CrmRecipientInfo, templateName: string, templateValues: Record<string, unknown>, settings?: CrmNotificationSettings): Promise<void>;
-    processOpportunity(opportunityId: string): Promise<void>;
+    processOpportunity(opportunityId: string, tracerMessageId: string): Promise<void>;
 }
 
 export { CrmClient, type CrmMessage, type CrmNotificationSettings, type CrmRecipientInfo, type NotificationChannel };
diff --git a/dist/index.d.ts b/dist/index.d.ts
@@ -69,7 +69,7 @@ declare class CrmClient {
     static getInstance(): CrmClient;
     static init(projectId: string, keyFilename: string, loggerInstance: Logger, errorConverter: ErrorConverter, customTopicName?: string): void;
     sendNotification(recipientInfo: CrmRecipientInfo, templateName: string, templateValues: Record<string, unknown>, settings?: CrmNotificationSettings): Promise<void>;
-    processOpportunity(opportunityId: string): Promise<void>;
+    processOpportunity(opportunityId: string, tracerMessageId: string): Promise<void>;
 }
 
 export { CrmClient, type CrmMessage, type CrmNotificationSettings, type CrmRecipientInfo, type NotificationChannel };
diff --git a/dist/index.js b/dist/index.js
@@ -155,16 +155,17 @@ var CrmClient = class _CrmClient {
       }
     });
   }
-  processOpportunity(opportunityId) {
+  processOpportunity(opportunityId, tracerMessageId) {
     return __async(this, null, function* () {
       if (!this.opportunityTopicName) {
         throw new Error("CRM opportunity topic name not provided. Add the CRM_OPPORTUNITY_TOPIC environment variable.");
       }
-      const message = { opportunityId, tracerMessageId: (0, import_uuid.v4)() };
+      const message = { opportunityId, tracerMessageId };
       try {
         const messageId = yield this.pubsubInstance.topic(this.opportunityTopicName).publishMessage({ json: message });
         this.loggerInstance.Info({
-          event: "publish-opportunity-processing",
+          event: "opportunity-processing",
+          step: "message-publishing",
           status: "success",
           stage: "emitter",
           topic: this.opportunityTopicName,
@@ -174,7 +175,8 @@ var CrmClient = class _CrmClient {
         });
       } catch (error) {
         this.loggerInstance.Info({
-          event: "publish-message",
+          event: "opportunity-processing",
+          step: "message-publishing",
           status: "failure",
           stage: "emitter",
           // destination,

diff --git a/dist/index.mjs b/dist/index.mjs
@@ -134,16 +134,17 @@ var CrmClient = class _CrmClient {
       }
     });
   }
-  processOpportunity(opportunityId) {
+  processOpportunity(opportunityId, tracerMessageId) {
     return __async(this, null, function* () {
       if (!this.opportunityTopicName) {
         throw new Error("CRM opportunity topic name not provided. Add the CRM_OPPORTUNITY_TOPIC environment variable.");
       }
-      const message = { opportunityId, tracerMessageId: uuidv4() };
+      const message = { opportunityId, tracerMessageId };
       try {
         const messageId = yield this.pubsubInstance.topic(this.opportunityTopicName).publishMessage({ json: message });
         this.loggerInstance.Info({
-          event: "publish-opportunity-processing",
+          event: "opportunity-processing",
+          step: "message-publishing",
           status: "success",
           stage: "emitter",
           topic: this.opportunityTopicName,
@@ -153,7 +154,8 @@ var CrmClient = class _CrmClient {
         });
       } catch (error) {
         this.loggerInstance.Info({
-          event: "publish-message",
+          event: "opportunity-processing",
+          step: "message-publishing",
           status: "failure",
           stage: "emitter",
           // destination,

diff --git a/src/index.ts b/src/index.ts
@@ -130,18 +130,19 @@ export class CrmClient {
     }
   }
 
-  public async processOpportunity (opportunityId: string): Promise<void> {
+  public async processOpportunity (opportunityId: string, tracerMessageId: string): Promise<void> {
     if (!this.opportunityTopicName) {
       throw new Error('CRM opportunity topic name not provided. Add the CRM_OPPORTUNITY_TOPIC environment variable.')
     }
-    const message = { opportunityId, tracerMessageId: uuidv4() }
+    const message = { opportunityId, tracerMessageId }
     try {
       const messageId = await this.pubsubInstance
         .topic(this.opportunityTopicName)
         .publishMessage({ json: message })
 
       this.loggerInstance.Info({
-        event: 'publish-opportunity-processing',
+        event: 'opportunity-processing',
+        step: 'message-publishing',
         status: 'success',
         stage: 'emitter',
         topic: this.opportunityTopicName,
@@ -152,7 +153,8 @@ export class CrmClient {
     } catch (error) {
       // trace logging
       this.loggerInstance.Info({
-        event: 'publish-message',
+        event: 'opportunity-processing',
+        step: 'message-publishing',
         status: 'failure',
         stage: 'emitter',
         // destination,