updateNodeFromPatch

Author: odeimaiz

services/static-webserver/client/source/class/osparc/data/model/Node.js

@@ -238,6 +238,10 @@ qx.Class.define("osparc.data.model.Node", {
      "progress", // !! not a property but goes into the model
     ],
 
+    getProperties: function() {
+      return Object.keys(qx.util.PropertyUtil.getProperties(osparc.data.model.Node));
+    },
+
     isFrontend: function(metadata) {
       return (metadata && metadata.key && metadata.key.includes("/frontend/"));
     },
@@ -1306,7 +1310,7 @@ qx.Class.define("osparc.data.model.Node", {
 
     listenToChanges: function() {
       const nodeId = this.getNodeId();
-      const propertyKeys = Object.keys(qx.util.PropertyUtil.getProperties(osparc.data.model.Node));
+      const nodePropertyKeys = this.self().getProperties();
       this.self().ListenChangesProps.forEach(key => {
         switch (key) {
           case "inputs":
@@ -1400,7 +1404,7 @@ qx.Class.define("osparc.data.model.Node", {
             }
             break;
           default:
-            if (propertyKeys.includes(key)) {
+            if (nodePropertyKeys.includes(key)) {
               this.addListener("change" + qx.lang.String.firstUp(key), e => {
                 const data = e.getData();
                 this.fireDataEvent("projectDocumentChanged", {
@@ -1418,6 +1422,36 @@ qx.Class.define("osparc.data.model.Node", {
       });
     },
 
+    updateNodeFromPatch: function(nodePatches) {
+      console.log(nodePatches);
+      const nodePropertyKeys = this.self().getProperties();
+      nodePatches.forEach(patch => {
+        const op = patch.op;
+        const path = patch.path;
+        const value = patch.value;
+        const nodeProperty = path.split("/")[3];
+        switch (nodeProperty) {
+          case "inputs":
+          case "inputsUnits":
+          case "inputNodes":
+          case "inputsRequired":
+          case "outputs":
+          case "progress":
+            console.warn(`To be implemented: patching ${nodeProperty} is not supported yet`);
+          default:
+            if (nodePropertyKeys.includes(nodeProperty)) {
+              const setter = "set" + qx.lang.String.firstUp(nodeProperty);
+              if (this[setter]) {
+                this[setter](value);
+              } else {
+                console.warn(`Property "${nodeProperty}" does not have a setter in osparc.data.model.Node`);
+              }
+            }
+            break;
+        }
+      });
+    },
+
     serialize: function() {
       // node generic
       let nodeEntry = {

services/static-webserver/client/source/class/osparc/data/model/Workbench.js

@@ -830,7 +830,6 @@ qx.Class.define("osparc.data.model.Workbench", {
     },
 
     updateWorkbenchFromPatches: function(workbenchPatches) {
-      console.log(workbenchPatches);
       // group the patches by nodeId
       const workbenchPatchesByNode = {};
       workbenchPatches.forEach(workbenchPatch => {
@@ -840,7 +839,16 @@ qx.Class.define("osparc.data.model.Workbench", {
         }
         workbenchPatchesByNode[nodeId].push(workbenchPatch);
       });
-      console.log(workbenchPatchesByNode);
+      Object.keys(workbenchPatchesByNode).forEach(nodeId => {
+        const node = this.getNode(nodeId);
+        if (node === null) {
+          console.warn(`Node with id ${nodeId} not found, skipping patch application.`);
+          return;
+        }
+        const nodePatches = workbenchPatchesByNode[nodeId];
+        node.updateNodeFromPatch(nodePatches);
+      });
+      this.getNode()
     },
   }
 });