Response key change integrated (#47)

* Response key change integrated * version change
gofynd · Oct 25, 2024 · fa7c616 · fa7c616
1 parent 1852858
commit fa7c616
Show file tree

Hide file tree

Showing 4 changed files with 41 additions and 12 deletions.
diff --git a/pom.xml b/pom.xml
@@ -9,7 +9,7 @@
 	</parent>
 	<groupId>com.fynd</groupId>
 	<artifactId>fynd-extension-java</artifactId>
-	<version>0.6.5</version>
+	<version>0.6.6</version>
 	<name>fynd-extension-java</name>
 	<description>Java Fynd Extension Library</description>
 	<properties>

diff --git a/src/main/java/com/fynd/extension/model/webhookmodel/BroadcasterConfig.java b/src/main/java/com/fynd/extension/model/webhookmodel/BroadcasterConfig.java
@@ -0,0 +1,33 @@
+package com.fynd.extension.model.webhookmodel;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.AllArgsConstructor;
+import lombok.NoArgsConstructor;
+import lombok.Getter;
+import lombok.Setter;
+
+@AllArgsConstructor
+@NoArgsConstructor
+@Getter
+@Setter
+@JsonIgnoreProperties(ignoreUnknown = true)
+@JsonInclude(JsonInclude.Include.NON_NULL)
+public class BroadcasterConfig {
+
+    @JsonProperty("topic")
+    private String topic;
+
+    @JsonProperty("queue")
+    private String queue;
+
+    @JsonProperty("workflow_name")
+    private String workflowName;
+
+    @JsonProperty("event_bridge_name")
+    private String eventBridgeName;
+
+    @JsonProperty("created_on")
+    private String createdOn;
+}
diff --git a/src/main/java/com/fynd/extension/model/webhookmodel/SubscriberEventMapping.java b/src/main/java/com/fynd/extension/model/webhookmodel/SubscriberEventMapping.java
@@ -38,17 +38,13 @@ public class SubscriberEventMapping{
     private Double subscriberId;
 
 
-
-
-    @JsonProperty("topic")
-    private String topic;
-
-
-
-
     @JsonProperty("created_on")
     private String createdOn;
 
 
+    @JsonProperty("broadcaster_config")
+    private BroadcasterConfig BroadcasterConfig;
+
+
 
 }
diff --git a/src/main/java/com/fynd/extension/service/WebhookService.java b/src/main/java/com/fynd/extension/service/WebhookService.java
@@ -367,7 +367,7 @@ private boolean isEventDiff(SubscriberResponse existingEvents,
                         .filter(e -> event.getSlug().equals(e.getEventCategory() + "/" + e.getEventName() + "/" + e.getEventType() + "/v" + e.getVersion()))
                         .findFirst()
                         .orElse(null);
-                if (existingEvent != null && !event.getTopic().equals(existingEvent.getSubscriberEventMapping().getTopic())) {
+                if (existingEvent != null && !event.getTopic().equals(existingEvent.getSubscriberEventMapping().getBroadcasterConfig().getTopic())) {
                     return true; // Topics do not match
                 }
             }
@@ -579,7 +579,7 @@ public void disableSalesChannelWebhook(PlatformClient platformClient, String app
                             Events event = new Events();
                             event.setSlug(eventConfig.getEventCategory() + "/" + eventConfig.getEventName() + "/" + eventConfig.getEventType() + "/v" + eventConfig.getVersion());
                             if(configType.equals("kafka")){
-                                event.setTopic(eventConfig.getSubscriberEventMapping().getTopic());
+                                event.setTopic(eventConfig.getSubscriberEventMapping().getBroadcasterConfig().getTopic());
                             }
                             events.add(event);
                         });
@@ -642,7 +642,7 @@ public void enableSalesChannelWebhook(PlatformClient platformClient, String appl
                             Events event = new Events();
                             event.setSlug(eventConfig.getEventCategory() + "/" + eventConfig.getEventName() + "/" + eventConfig.getEventType() + "/v" + eventConfig.getVersion());
                             if(configType.equals("kafka")){
-                                event.setTopic(eventConfig.getSubscriberEventMapping().getTopic());
+                                event.setTopic(eventConfig.getSubscriberEventMapping().getBroadcasterConfig().getTopic());
                             }
                             events.add(event);
                         });