feat (compute): subscribe var update

harena-lab · Jan 31, 2022 · 89fec10 · 89fec10
1 parent 254923d
commit 89fec10
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 3 deletions.
diff --git a/src/adonisjs/public/dccs/components/cell/rule-dcc-cell-neighbor.js b/src/adonisjs/public/dccs/components/cell/rule-dcc-cell-neighbor.js
@@ -76,7 +76,10 @@ class RuleDCCCellNeighbor extends RuleDCCTransition {
 
   notify (topic, message) {
     switch (topic.toLowerCase()) {
-      case 'probability': this.probability = message.value; break
+      case 'probability':
+        this.probability =
+          (message.value != null) ? message.value : message.body;
+        break
     }
   }
 }

diff --git a/src/adonisjs/public/dccs/components/control/dcc-compute.js b/src/adonisjs/public/dccs/components/control/dcc-compute.js
@@ -148,9 +148,15 @@ class DCCCompute extends DCCBase {
     this.setAttribute('dependency', newValue)
   }
 
-  notify (topic, message) {
-    if (topic.toLowerCase() == 'update')
+  async notify (topic, message) {
+    const tp = topic.toLowerCase()
+    if (tp == 'update')
       this.update()
+    else if (tp.startsWith('var/')) {
+      await this._request('var/set/' + tp.substring(4).replace(/\./g, '/'),
+                          message.value)
+      this.update()
+    }
   }
 
   async update () {