Ticket #2 : Can call the operation /clients

Author: habarthierry-hue

FaasNetDoc.txt

@@ -1,6 +1,14 @@
 Avant de commencer, lancer le container "registry" :
 docker run -d -p 5000:5000 --restart=always --name registry registry:2
 
+# Comment déployer SQLSERVER
+
+kubectl apply -f ./kubernetes/run-mssql.yml --namespace=faas
+kubectl apply -f ./kubernetes/mssql-external-svc.yml --namespace=faas
+kubectl apply -f ./kubernetes/mssql-internal-svc.yml --namespace=faas
+
+Il est possible ensuite de se connecter à la BDD avec : 127.0.0.1, 30002
+
 # Construire l'image du runtime
 
 Construire l'image et la nommer "localhost:5000/getsql" && "localhost:5000/transform" :

kubernetes/mssql-external-svc.yml

@@ -0,0 +1,13 @@
+apiVersion: v1
+kind: Service
+metadata:
+  name: mssql-service
+spec:
+  type: NodePort
+  selector:
+    app: mssql
+  ports:
+  - port: 1433
+    protocol: TCP
+    targetPort: 1433
+    nodePort: 30002

kubernetes/mssql-internal-svc.yml

@@ -0,0 +1,12 @@
+apiVersion: v1
+kind: Service
+metadata:
+  name: mssql-entry
+spec:
+  type: ClusterIP
+  selector:
+    app: mssql
+  ports:
+  - port: 1433
+    protocol: TCP
+    targetPort: 1433

kubernetes/run-mssql.yml

@@ -0,0 +1,27 @@
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  name: mssql-deployment
+spec:
+  replicas: 1
+  selector:
+    matchLabels:
+      app: mssql
+  strategy:
+    type: Recreate
+  template:
+    metadata:
+      labels:
+        app: mssql
+    spec:
+      terminationGracePeriodSeconds: 10
+      securityContext:
+        fsGroup: 1000
+      containers:
+      - name: mssql
+        image: mcr.microsoft.com/mssql/server
+        env:
+        - name: ACCEPT_EULA
+          value: "Y"
+        - name: SA_PASSWORD
+          value: "D54DE7hHpkG9"

src/FaasNet.Gateway.Startup/DefaultConfiguration.cs

@@ -21,12 +21,12 @@ public class DefaultConfiguration
                             new ApiDefinitionFunction
                             {
                                 Function = "getsql",
-                                SerializedConfiguration = "{\r\n  \"ConnectionString\": \"Data Source=DESKTOP-F641MIJ\\\\SQLEXPRESS;Initial Catalog=OpenID;Integrated Security=True\",\r\n  \"SqlQuery\": \"SELECT * FROM [dbo].[Acrs]\"\r\n}"
+                                SerializedConfiguration = "{\r\n  \"ConnectionString\": \"Data Source=mssql-entry.faas.svc.cluster.local;Initial Catalog=OpenID;User ID=sa;Password=D54DE7hHpkG9\",\r\n  \"SqlQuery\": \"SELECT * FROM [dbo].[Acrs]\"\r\n}"
                             },
                             new ApiDefinitionFunction
                             {
                                 Function = "transform",
-                                SerializedConfiguration = "{ \"mappings\": [ { \"input\": \"content.name\", \"output\": \"name\" } ] }"
+                                SerializedConfiguration = "{ \"mappings\": [ { \"input\": \"content[*].Name\", \"output\": \"name\" } ] }"
                             }
                         },
                         SequenceFlows = new List<ApiDefinitionSequenceFlow>

src/FaasNet.Runtime.Transform/FunctionHandler.cs

@@ -1,5 +1,6 @@
 using FaasNet.Runtime.Parameters;
 using Newtonsoft.Json.Linq;
+using System.Linq;
 using System.Threading.Tasks;
 
 namespace FaasNet.Runtime.Transform
@@ -11,12 +12,18 @@ public Task<JObject> Handle(FunctionParameter<TransformConfiguration> parameter)
             var result = new JObject();
             foreach(var mapping in parameter.Configuration.Mappings)
             {
-                var token = parameter.Input.SelectToken(mapping.Input);
-                if (token != null)
+                var tokens = parameter.Input.SelectTokens(mapping.Input);
+                if (tokens.Count() == 1)
                 {
-                    result.Add(mapping.Output, token);
+                    result.Add(mapping.Output, tokens.First());
+                }
+                else if (tokens.Count() > 1)
+                {
+                    var jArr = new JArray(tokens);
+                    result.Add(mapping.Output, jArr);
                 }
             }
+
             return Task.FromResult(result);
         }
     }