Merge pull request #126 from dolencd/master

Fixed gRPC state.set with plain JS object

Author: XavierGeerinck

src/implementation/Client/GRPCClient/state.ts

@@ -21,10 +21,10 @@ export default class GRPCClientState implements IClientState {
     for (const stateObject of stateObjects) {
       const si = new StateItem();
       si.setKey(stateObject.key);
-      si.setValue(Buffer.from(stateObject.value, "utf-8"));
+      si.setValue(Buffer.from(typeof stateObject.value === "object" ? JSON.stringify(stateObject.value) : stateObject.value.toString(), "utf-8"));
       stateList.push(si);
     }
-
+    
     const msgService = new SaveStateRequest();
     msgService.setStoreName(storeName);
     msgService.setStatesList(stateList);
@@ -47,6 +47,7 @@ export default class GRPCClientState implements IClientState {
     msgService.setStoreName(storeName);
     msgService.setKey(key)
 
+    
     // @todo: https://docs.dapr.io/reference/api/state_api/#optional-behaviors
     // msgService.setConsistency()
 
@@ -76,7 +77,6 @@ export default class GRPCClientState implements IClientState {
     msgService.setStoreName(storeName);
     msgService.setKeysList(keys);
     msgService.setParallelism(parallelism);
-
     // @todo: https://docs.dapr.io/reference/api/state_api/#optional-behaviors
     // msgService.setConsistency()
 
@@ -90,11 +90,20 @@ export default class GRPCClientState implements IClientState {
         // https://docs.dapr.io/reference/api/state_api/#http-response-2
         const items = res.getItemsList();
 
-        return resolve(items.map(i => ({
-          key: i.getKey(),
-          data: Buffer.from(i.getData()).toString(),
-          etag: i.getEtag()
-        })));
+        return resolve(items.map(i => {
+          const resDataStr = Buffer.from(i.getData()).toString()
+          let data: string;
+          try {
+            data = JSON.parse(resDataStr);
+          } catch(e) {
+            data = resDataStr;
+          }
+          return {
+            key: i.getKey(),
+            data,
+            etag: i.getEtag()
+          }
+        }));
       });
     })
   }

src/types/KeyValuePair.type.ts

@@ -1,4 +1,4 @@
 export type KeyValuePairType= {
   key: string;
-  value: string;
+  value: any;
 }