Reducer and filter support added (#50)

* V3 api integrated and readme updated

* unused variable removed

* Type marketplace changes added

* readme updated

* filters and reducer support added

* Readme Updated

* Issue with key fixed

* Readme Updated

* version changed

Author: divyanshusinghh

README.md

@@ -278,20 +278,39 @@ ext :
       api_path: "/webhook" #<POST API URL>
       notification_email: <EMAIL_ID>
       subscribe_on_install: false, #optional. Default true
-      subscribed_saleschannel: 'all' #Can be 'SPECIFIC'/'EMPTY'
+      subscribed_saleschannel: 'specific' #Optional. Default all
+      marketplace: true, # to receive marketplace saleschannel events. Only allowed when subscribed_saleschannel is set to specific
       event_map:
-         - name: 'product/create'
+         - name: 'product/update'
            handler: productCreateHandler #Make sure this matches the Component Bean name
            category: 'company'
            version: '1'
            provider: 'rest' # If not provided, Default is 'rest'
-         -
-           name: 'product/delete'
+         - name: 'product/delete'
            handler: productDeleteHandler
            category: 'company'
            version: '1'
            provider: 'kafka'
-
+         - name: "brand/create"
+           topic: "company-brand-create"
+           category: "company"
+           version: 1
+           provider: "pub_sub"
+         - name: "extension/install"
+           queue: "extension-install"
+           workflow_name: "extension"
+           version: 1
+           provider: "temporal"
+         - name: "location/create"
+           queue: "company-location-create"
+           category: "company"
+           version: 1
+           provider: "sqs"
+         - name: "product-size/create"
+           event_bridge_name: "company-product-size-create"
+           category: "company"
+           version: 1
+           provider: "event_bridge"
 ```
 
 2. Create Handlers for each event which is mentioned in the Event Map (as specified above)
@@ -342,6 +361,68 @@ public class WebhookController {
 >
 > To disable receiving events for a saleschannel use function `disableSalesChannelWebhook`.
 
+
+```java
+   import com.fynd.extension.model.Extension;
+   import com.sdk.platform.PlatformClient;
+   import com.fynd.extension.service.WebhookService;
+   import jakarta.servlet.http.HttpServletRequest;
+   import lombok.extern.slf4j.Slf4j;
+   import org.springframework.web.bind.annotation.GetMapping;
+   import org.springframework.web.bind.annotation.RequestMapping;
+   import org.springframework.web.bind.annotation.RestController;
+   
+   @RestController
+   @RequestMapping("/api")
+   @Slf4j
+   public class PlatformController extends BasePlatformController {
+      @GetMapping(value = "/enableSalesChannelWebhook", produces = "application/json")
+      public String getProducts(HttpServletRequest request) {
+         try {
+            PlatformClient platformClient = (PlatformClient) request.getAttribute("platformClient");
+            Extension extension = (Extension) request.getAttribute("extension");
+            WebhookService webhookService = extension.getWebhookService();
+            webhookService.enableSalesChannelWebhook(platformClient,"66e3b32eca4335d0feff486c");
+            return "Webhook enabled successfully!";
+         } catch (Exception e) {
+            System.out.println(e.getMessage());
+            throw new RuntimeException(e);
+         }
+
+      }
+    }
+
+```
+
+#### How to register for Webhook Events?
+
+A filter and reducer can be provided to refine the data delivered for each subscribed event. The Filter functionality allows selective delivery of data by specifying conditions based on JSONPath queries and logical operators. Reducer allow customization of the payload structure by specifying only the fields needed by the subscriber. The reducer extracts fields from the event’s data and restructures them as needed.
+
+```yaml
+ext :
+   api_key : <API_KEY>
+   api_secret : <API_SECRET>
+   scope : ""
+   base_url : "https://test.extension.com"
+   access_mode : "offline"
+   webhook:
+      api_path: "/webhook" #<POST API URL>
+      notification_email: <EMAIL_ID>
+      subscribe_on_install: false, #optional. Default true
+      subscribed_saleschannel: 'specific' #Optional. Default all
+      marketplace: true, # to receive marketplace saleschannel events. Only allowed when subscribed_saleschannel is set to specific
+      event_map:
+         - name: 'product/update'
+           handler: productCreateHandler #Make sure this matches the Component Bean name
+           category: 'company'
+           version: 1
+           filters:
+            query: "$.brand.uid"
+            condition: "(uid) => uid === 130"
+           reducer:
+            brand_name: "$.brand.name"
+```
+
 ##### How webhook registry subscribes to webhooks on Fynd Platform?
 
 After webhook config is passed to initialize whenever extension is launched to any of companies where extension is installed or to be installed, webhook config data is used to create webhook subscriber on Fynd Platform for that company.

pom.xml

@@ -9,7 +9,7 @@
 	</parent>
 	<groupId>com.fynd</groupId>
 	<artifactId>fynd-extension-java</artifactId>
-	<version>0.6.6</version>
+	<version>0.6.7</version>
 	<name>fynd-extension-java</name>
 	<description>Java Fynd Extension Library</description>
 	<properties>

src/main/java/com/fynd/extension/middleware/PlatformClientCall.java

@@ -3,12 +3,17 @@
 import com.fynd.extension.model.webhookmodel.SubscriberConfig;
 import com.fynd.extension.model.webhookmodel.SubscriberConfigList;
 import com.fynd.extension.model.webhookmodel.SubscriberConfigRequestV2;
+import com.fynd.extension.model.webhookmodel.SubscriberConfigRequestV3;
 import com.fynd.extension.model.webhookmodel.SubscriberConfigResponse;
+import com.fynd.extension.model.webhookmodel.SubscriberConfigResponseV3;
 
 import retrofit2.Call;
 import retrofit2.http.*;
 
 public interface PlatformClientCall {
+    @PUT("/service/platform/webhook/v3.0/company/{company_id}/subscriber/")
+    Call<SubscriberConfigResponseV3> registerSubscriberToEventV3(@Path("company_id") String companyId, @Body SubscriberConfigRequestV3 payload);
+
     @POST("/service/platform/webhook/v2.0/company/{company_id}/subscriber/")
     Call<SubscriberConfigResponse> registerSubscriberToEventV2(@Path("company_id") String companyId, @Body SubscriberConfigRequestV2 payload);
 
@@ -23,5 +28,5 @@ public interface PlatformClientCall {
 
     @PUT ("/service/platform/webhook/v1.0/company/{company_id}/subscriber/")
     Call<SubscriberConfigResponse> updateSubscriberConfig(@Path("company_id") String companyId, @Body SubscriberConfig payload);
-    
+
 }

src/main/java/com/fynd/extension/model/EventMapProperties.java

@@ -3,6 +3,8 @@
 import lombok.Getter;
 import lombok.Setter;
 
+import java.util.Map;
+
 @Getter
 @Setter
 public class EventMapProperties {
@@ -19,4 +21,16 @@ public class EventMapProperties {
 
     private String topic;
 
+    private String queue;
+
+    private String workflowName;
+
+    private String accountId;
+
+    private String eventBridgeName;
+
+    private Map<String, Object> filters;
+
+    private Map<String, Object> reducer;
+
 }

src/main/java/com/fynd/extension/model/WebhookProperties.java

@@ -20,6 +20,8 @@ public class WebhookProperties {
 
     private Boolean subscribeOnInstall;
 
+    private Boolean marketplace;
+
     public String getSubscribedSalesChannel() {
         return subscribedSalesChannel;
     }

src/main/java/com/fynd/extension/model/webhookmodel/Association.java

@@ -20,33 +20,16 @@
 @JsonInclude(JsonInclude.Include.NON_NULL)
 public class Association{
 
-
-
-
-
-
-
     @JsonProperty("company_id")
     private Integer companyId;
 
-
-
-
     @JsonProperty("application_id")
     private List<String> applicationId;
 
-
-
-
     @JsonProperty("extension_id")
     private String extensionId;
 
-
-
-
     @JsonProperty("criteria")
     private String criteria;
 
-
-
 }

src/main/java/com/fynd/extension/model/webhookmodel/BroadcasterConfig.java

@@ -30,4 +30,4 @@ public class BroadcasterConfig {
 
     @JsonProperty("created_on")
     private String createdOn;
-}
+}

src/main/java/com/fynd/extension/model/webhookmodel/EventConfig.java

@@ -83,7 +83,6 @@ public class EventConfig{
 
 
 
-
     @JsonProperty("created_on")
     private String createdOn;
 

src/main/java/com/fynd/extension/model/webhookmodel/EventMap.java

@@ -0,0 +1,31 @@
+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.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+
+import java.util.List;
+
+@AllArgsConstructor
+@NoArgsConstructor
+@Getter
+@Setter
+@JsonIgnoreProperties(ignoreUnknown = true)
+@JsonInclude(JsonInclude.Include.NON_NULL)
+public class EventMap {
+    @JsonProperty("webhook_url")
+    private String webhookUrl;
+
+    @JsonProperty("type")
+    private String type;
+
+    @JsonProperty("auth_meta")
+    private AuthMeta authMeta;
+
+    @JsonProperty("events")
+    private List<EventV3> events;
+}

src/main/java/com/fynd/extension/model/webhookmodel/EventV3.java

@@ -0,0 +1,51 @@
+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.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+
+import java.util.Map;
+
+@AllArgsConstructor
+@NoArgsConstructor
+@Getter
+@Setter
+@JsonIgnoreProperties(ignoreUnknown = true)
+@JsonInclude(JsonInclude.Include.NON_NULL)
+public class EventV3 {
+
+    @JsonProperty("event_category")
+    private String eventCategory;
+
+    @JsonProperty("event_name")
+    private String eventName;
+
+    @JsonProperty("event_type")
+    private String eventType;
+
+    @JsonProperty("version")
+    private String version;
+
+    @JsonProperty("topic")
+    private String topic;
+
+    @JsonProperty("queue")
+    private String queue;
+
+    @JsonProperty("workflow_name")
+    private String workflowName;
+
+    @JsonProperty("event_bridge_name")
+    private String eventBridgeName;
+
+    @JsonProperty("filters")
+    private Map<String, Object> filters;
+
+    @JsonProperty("reducer")
+    private Map<String, Object> reducer;
+
+}