DVC-7342 add setClientCustomData() (#58)

* adding new setClientCustomData() function call for the WASM

* Update to latest WASM version

Author: chris-hoefgen

build.gradle

@@ -86,7 +86,7 @@ repositories {
 sourceCompatibility = JavaVersion.VERSION_1_8
 
 def wasmResourcePath = "$projectDir/src/main/resources"
-def wasmVersion = "1.3.3"
+def wasmVersion = "1.6.7"
 def wasmUrl = "https://unpkg.com/@devcycle/bucketing-assembly-script@$wasmVersion/build/bucketing-lib.release.wasm"
 task downloadDVCBucketingWASM(type: Download) {
     src wasmUrl

src/main/java/com/devcycle/sdk/server/local/api/DVCLocalClient.java

@@ -12,6 +12,7 @@
 import com.devcycle.sdk.server.local.model.BucketedUserConfig;
 import com.devcycle.sdk.server.local.model.DVCLocalOptions;
 import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
 
 public final class DVCLocalClient {
 
@@ -193,6 +194,24 @@ public void track(User user, Event event) {
     }
   }
 
+  public void setClientCustomData(Map<String,Object> customData) {
+    if (!isInitialized || !configManager.isConfigInitialized())
+    {
+     System.out.println("SetClientCustomData called before DVCClient has initialized");
+     return;
+    }
+
+    if (customData != null && !customData.isEmpty()) {
+      try {
+        ObjectMapper mapper = new ObjectMapper();
+        String customDataJSON = mapper.writeValueAsString(customData);
+        localBucketing.setClientCustomData(this.sdkKey, customDataJSON);
+      } catch(Exception e) {
+        System.out.printf("Failed to set custom data: %s%n", e.getMessage());
+      }
+    }
+  }
+
   /**
    * Gracefully close the client
    * 

src/main/java/com/devcycle/sdk/server/local/bucketing/LocalBucketing.java

@@ -147,6 +147,16 @@ public void setPlatformData(String platformData) {
         fn.accept(platformDataAddress);
     }
 
+    public void setClientCustomData(String sdkKey, String customData) {
+        unpinAll();
+        int sdkKeyAddress = getSDKKeyAddress(sdkKey);
+        int customDataAddress = newWasmString(customData);
+
+        Func setCustomClientDataPtr = linker.get(store, "", "setClientCustomData").get().func();
+        WasmFunctions.Consumer2<Integer, Integer> fn = WasmFunctions.consumer(store, setCustomClientDataPtr, I32, I32);
+        fn.accept(sdkKeyAddress, customDataAddress);
+    }
+
     public BucketedUserConfig generateBucketedConfig(String sdkKey, User user) throws JsonProcessingException {
         unpinAll();
         String userString = OBJECT_MAPPER.writeValueAsString(user);

src/main/resources/bucketing-lib.release.wasm

@@ -1,5 +1,6 @@
 package com.devcycle.sdk.server.local;
 
+import java.util.HashMap;
 import java.util.Map;
 import java.util.UUID;
 
@@ -78,6 +79,16 @@ public void allVariablesTest() {
         Assert.assertEquals(variables.size(), 2);
     }
 
+    @Test
+    public void setClientCustomDataWithBadMap(){
+        // should be a no-op
+        client.setClientCustomData(null);
+
+        // should be a no-op
+        Map<String, Object> testData = new HashMap();
+        client.setClientCustomData(testData);
+    }
+
     private User getUser() {
         return User.builder()
                 .userId("j_test")

src/test/java/com/devcycle/sdk/server/local/DVCLocalClientTest.java

@@ -1,5 +1,7 @@
 package com.devcycle.sdk.server.local;
 
+import java.util.HashMap;
+import java.util.Map;
 import java.util.UUID;
 
 import org.junit.Assert;
@@ -34,6 +36,21 @@ public void setup(){
         localBucketing.storeConfig(apiKey, testConfigString);
     }
 
+    @Test
+    public void testSetClientCustomData() {
+        Map<String,Object> testData = new HashMap();
+        testData.put("stringProp", "test");
+        testData.put("intProp", 1);
+        testData.put("booleanProp", true);
+
+        try {
+            String customData = mapper.writeValueAsString(testData);
+            localBucketing.setClientCustomData(apiKey, customData);
+        } catch (JsonProcessingException e) {
+            throw new RuntimeException(e);
+        }
+    }
+
     @Test
     public void testEventQueue() throws JsonProcessingException {
         Event event = Event.builder().type("test").target("target").build();