update functionref params to jsonnode

Signed-off-by: Tihomir Surdilovic <tsurdilo@redhat.com>

Author: Tihomir Surdilovic

api/src/main/java/io/serverlessworkflow/api/deserializers/FunctionRefDeserializer.java

@@ -28,7 +28,6 @@
 
 import java.io.IOException;
 import java.util.HashMap;
-import java.util.Map;
 
 public class FunctionRefDeserializer extends StdDeserializer<FunctionRef> {
 
@@ -61,11 +60,12 @@ public FunctionRef deserialize(JsonParser jp,
 
         if (!node.isObject()) {
             functionRef.setRefName(node.asText());
-            functionRef.setParameters(new HashMap<>());
+            ObjectMapper objectMapper = new ObjectMapper();
+            functionRef.setParameters(objectMapper.readTree("{}"));
             return functionRef;
         } else {
             if(node.get("parameters") != null) {
-                functionRef.setParameters(mapper.treeToValue(node.get("parameters"), Map.class));
+                functionRef.setParameters(mapper.treeToValue(node.get("parameters"), JsonNode.class));
             }
 
             if(node.get("refName") != null) {

api/src/main/java/io/serverlessworkflow/api/serializers/FunctionRefSerializer.java

@@ -54,7 +54,6 @@ public void serialize(FunctionRef functionRef,
                     gen.writeObjectField("parameters", functionRef.getParameters());
                 }
 
-
                 gen.writeEndObject();
             }
         }

api/src/main/resources/schema/functions/functionref.json

@@ -10,7 +10,7 @@
     "parameters": {
       "type": "object",
       "description": "Function parameters",
-      "existingJavaType": "java.util.Map<String, String>"
+      "existingJavaType": "com.fasterxml.jackson.databind.JsonNode"
     }
   },
   "required": [

api/src/test/java/io/serverlessworkflow/api/test/MarkupToWorkflowTest.java

@@ -16,6 +16,7 @@
  */
 package io.serverlessworkflow.api.test;
 
+import com.fasterxml.jackson.databind.JsonNode;
 import io.serverlessworkflow.api.Workflow;
 import io.serverlessworkflow.api.actions.Action;
 import io.serverlessworkflow.api.defaultdef.DefaultDefinition;
@@ -33,6 +34,7 @@
 import org.junit.jupiter.params.provider.ValueSource;
 
 import java.util.List;
+import java.util.Map;
 
 import static org.junit.jupiter.api.Assertions.*;
 
@@ -238,7 +240,7 @@ public void testFunctionRefs(String workflowLocation) {
         FunctionRef functionRef2 = action2.getFunctionRef();
         assertEquals("sendRejectionEmailFunction", functionRef2.getRefName());
         assertEquals(1, functionRef2.getParameters().size());
-        assertEquals("{{ $.customer }}", functionRef2.getParameters().get("applicant"));
+        assertEquals("{{ $.customer }}", functionRef2.getParameters().get("applicant").asText());
     }
 
     @ParameterizedTest
@@ -283,4 +285,35 @@ public void testSubflowStateRepeat(String workflowLocation) {
         assertEquals(1, subflowState.getRepeat().getStopOnEvents().size());
         assertEquals("CarTurnedOffEvent", subflowState.getRepeat().getStopOnEvents().get(0));
     }
+
+    @ParameterizedTest
+    @ValueSource(strings = {"/features/functionrefjsonparams.json", "/features/functionrefjsonparams.yml"})
+    public void testFunctionRefJsonParams(String workflowLocation) {
+        Workflow workflow = Workflow.fromSource(WorkflowTestUtils.readWorkflowFile(workflowLocation));
+
+        assertNotNull(workflow);
+        assertNotNull(workflow.getId());
+        assertNotNull(workflow.getName());
+        assertNotNull(workflow.getStates());
+
+        assertNotNull(workflow.getStates());
+        assertTrue(workflow.getStates().size() == 1);
+        assertTrue(workflow.getStates().get(0) instanceof OperationState);
+
+        OperationState operationState = (OperationState) workflow.getStates().get(0);
+        assertNotNull(operationState.getActions());
+        assertEquals(1, operationState.getActions().size());
+        List<Action> actions = operationState.getActions();
+        assertNotNull(actions.get(0).getFunctionRef());
+        assertEquals("addPet", actions.get(0).getFunctionRef().getRefName());
+
+        JsonNode params = actions.get(0).getFunctionRef().getParameters();
+        assertNotNull(params);
+        assertEquals(4, params.size());
+        assertEquals(123, params.get("id").intValue());
+        assertEquals("My Address, 123 MyCity, MyCountry", params.get("address").asText());
+        assertEquals("${ .owner.name }", params.get("owner").asText());
+        assertEquals("Pluto", params.get("body").get("name").asText());
+        assertEquals("${ .pet.tagnumber }", params.get("body").get("tag").asText());
+    }
 }

api/src/test/resources/features/functionrefjsonparams.json

@@ -0,0 +1,29 @@
+{
+  "id": "functionrefparams",
+  "version": "1.0",
+  "name": "Function Ref Params Test",
+  "states": [
+    {
+      "name": "AddPluto",
+      "type": "operation",
+      "start": true,
+      "actions": [
+        {
+          "functionRef": {
+            "refName": "addPet",
+            "parameters": {
+              "body": {
+                "name": "Pluto",
+                "tag": "${ .pet.tagnumber }"
+              },
+              "id": 123,
+              "address": "My Address, 123 MyCity, MyCountry",
+              "owner": "${ .owner.name }"
+            }
+          }
+        }
+      ],
+      "end": true
+    }
+  ]
+}

api/src/test/resources/features/functionrefjsonparams.yml

@@ -0,0 +1,18 @@
+id: functionrefparams
+version: '1.0'
+name: Function Ref Params Test
+states:
+  - name: AddPluto
+    type: operation
+    start: true
+    actions:
+      - functionRef:
+          refName: addPet
+          parameters:
+            body:
+              name: Pluto
+              tag: "${ .pet.tagnumber }"
+            id: 123
+            address: My Address, 123 MyCity, MyCountry
+            owner: "${ .owner.name }"
+    end: true