fix logs

Enterprise-CMCS · Jan 23, 2025 · 1236a60 · 1236a60
1 parent e42cb53
commit 1236a60
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/lib/lambda/processEmails.ts b/lib/lambda/processEmails.ts
@@ -123,9 +123,9 @@ export async function processRecord(kafkaRecord: KafkaRecord, config: ProcessEma
         };
         console.log("beforeww")
         const safeSeatoolRecord = opensearch.main.seatool.transform(id).safeParse(seatoolRecord);
-    console.log('inside process record', seatoolRecord)
+    console.log('inside process record', seatoolRecord.)
     console.log('seatool safe record', safeSeatoolRecord)
-    if(safeSeatoolRecord.data?.cmsStatus === SEATOOL_STATUS.WITHDRAWN) {
+    if(safeSeatoolRecord.data?.seatoolStatus === SEATOOL_STATUS.WITHDRAWN) {
       //send email
       console.log(safeSeatoolRecord.data?.cmsStatus, "seatool status is withdrawn")
 

diff --git a/lib/stacks/email.ts b/lib/stacks/email.ts
@@ -222,7 +222,7 @@ export class Email extends cdk.NestedStack {
 
     alarm.addAlarmAction(new cdk.aws_cloudwatch_actions.SnsAction(alarmTopic));
 
-    new CfnEventSourceMapping(this, "SinkSESTrigger7", {
+    new CfnEventSourceMapping(this, "SinkSESTrigger9", {
       batchSize: 1,
       enabled: true,
       selfManagedEventSource: {
@@ -250,7 +250,7 @@ export class Email extends cdk.NestedStack {
       },
     });
 
-    new CfnEventSourceMapping(this, "SinkSESTrigger8", {
+    new CfnEventSourceMapping(this, "SinkSESTrigger10", {
       batchSize: 1,
       enabled: true,
       selfManagedEventSource: {