listenToChanges Node

Author: odeimaiz

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

@@ -1241,6 +1241,23 @@ qx.Class.define("osparc.data.model.Node", {
       }
     },
 
+    listenToChanges: function() {
+      const propertyKeys = Object.keys(qx.util.PropertyUtil.getProperties(osparc.data.model.Node))
+      propertyKeys.forEach(key => {
+        this.addListener("change" + qx.lang.String.firstUp(key), e => {
+          const nodeId = this.getNodeId();
+          const data = e.getData();
+          this.fireDataEvent("updateStudyDocument", {
+            "op": "replace",
+            "path": `/workbench/${nodeId}/` + key,
+            "value": data
+          });
+        }, this);
+      });
+
+      this.getWorkbench().addListener("updateStudyDocument", e => this.fireDataEvent("updateStudyDocument", e.getData()), this);
+    },
+
     serialize: function(clean = true) {
       // node generic
       let nodeEntry = {

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

@@ -304,8 +304,8 @@ qx.Class.define("osparc.data.model.Study", {
 
     // deep clones object with study-only properties
     deepCloneStudyObject: function(obj, ignoreExtra = false) {
-      const studyObject = osparc.utils.Utils.deepCloneObject(obj);
       const studyPropKeys = osparc.data.model.Study.getProperties();
+      const studyObject = osparc.utils.Utils.deepCloneObject(obj);
       Object.keys(studyObject).forEach(key => {
         if (!studyPropKeys.includes(key)) {
           delete studyObject[key];
@@ -379,7 +379,7 @@ qx.Class.define("osparc.data.model.Study", {
   },
 
   members: {
-    listenToStudyChanges: function() {
+    listenToChanges: function() {
       const propertyKeys = this.self().getProperties();
       propertyKeys.forEach(key => {
         if (!this.self().IgnoreSerializationProps.includes(key)) {
@@ -393,6 +393,8 @@ qx.Class.define("osparc.data.model.Study", {
           }, this);
         }
       });
+
+      this.getWorkbench().addListener("updateStudyDocument", e => this.fireDataEvent("updateStudyDocument", e.getData()), this);
     },
 
     serialize: function(clean = true) {

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

@@ -272,6 +272,7 @@ qx.Class.define("osparc.data.model.Workbench", {
 
     __createNode: function(study, metadata, uuid) {
       const node = new osparc.data.model.Node(study, metadata, uuid);
+      node.listenToChanges();
       node.addListener("keyChanged", () => this.fireEvent("reloadModel"), this);
       node.addListener("changeInputNodes", () => this.fireDataEvent("pipelineChanged"), this);
       node.addListener("reloadModel", () => this.fireEvent("reloadModel"), this);

services/static-webserver/client/source/class/osparc/desktop/StudyEditor.js

@@ -146,10 +146,11 @@ qx.Class.define("osparc.desktop.StudyEditor", {
 
       study.openStudy()
         .then(studyData => {
-          study.listenToStudyChanges();
-
           this.__setStudyDataInBackend(studyData);
 
+          study.listenToChanges();
+          study.addListener("updateStudyDocument", e => this.updateStudyDocument(e.getData()), this);
+
           this.__workbenchView.setStudy(study);
           this.__slideshowView.setStudy(study);
 
@@ -833,13 +834,15 @@ qx.Class.define("osparc.desktop.StudyEditor", {
       return changed;
     },
 
-    updateStudyDocument: function() {
+    updateStudyDocument: function(data = null) {
       if (!osparc.data.model.Study.canIWrite(this.getStudy().getAccessRights())) {
         return new Promise(resolve => {
           resolve();
         });
       }
 
+      console.log("updateStudyDocument", data);
+
       this.__updatingStudy++;
       const studyDiffs = this.__getStudyDiffs();
       return this.getStudy().patchStudyDelayed(studyDiffs.delta, studyDiffs.sourceStudy)