Response key change integrated (#69)

* Response key change integrated * version changed * Update CHANGELOG.md --------- Co-authored-by: vivek-gofynd <[email protected]>
gofynd · Oct 24, 2024 · e0ad2eb · e0ad2eb
1 parent 841dcf2
commit e0ad2eb
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 5 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -4,6 +4,10 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [v0.7.11] - 2024-09-23
+### Changed
+- Kafka config response key change in api.
+
 ## [v0.7.10] - 2024-09-23
 ### Changed
 - Bugfix in process webhook

diff --git a/express/webhook.js b/express/webhook.js
@@ -201,7 +201,7 @@ class WebhookRegistry {
             existingEvents = event_configs.map(event => {
                 return {
                     'slug': `${event.event_category}/${event.event_name}/${event.event_type}/v${event.version}`,
-                    'topic': event.subscriber_event_mapping.topic
+                    'topic': event?.subscriber_event_mapping?.broadcaster_config?.topic
                 }
             });
             // Checking Configuration Updates
@@ -299,7 +299,7 @@ class WebhookRegistry {
                         slug: `${event.event_category}/${event.event_name}/${event.event_type}/v${event.version}`
                     }
                     if(subscriberConfig.provider === 'kafka'){
-                        eventObj['topic'] = event.subscriber_event_mapping.topic
+                        eventObj['topic'] = event?.subscriber_event_mapping?.broadcaster_config?.topic
                     }
                     return eventObj;
                 });
@@ -340,7 +340,7 @@ class WebhookRegistry {
                         slug: `${event.event_category}/${event.event_name}/${event.event_type}/v${event.version}`
                     }
                     if(subscriberConfig.provider === 'kafka'){
-                        eventObj['topic'] = event.subscriber_event_mapping.topic
+                        eventObj['topic'] = event?.subscriber_event_mapping?.broadcaster_config?.topic
                     }
                     return eventObj;
                 });

diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -56,7 +56,7 @@
   },
   "name": "@gofynd/fdk-extension-javascript",
   "description": "FDK Extension Helper Library",
-  "version": "0.7.10",
+  "version": "0.7.11",
   "main": "index.js",
   "directories": {
     "example": "examples"