Working await but no returns

Author: IsabelParedes

ipynao/nao_robot.py

@@ -19,12 +19,14 @@
 class NaoRobotService():
     name = None
     widget = None
+    output = None
 
-    def __init__(self, widget, service_name):
+    def __init__(self, widget, output, service_name):
         self.name = service_name
         self.widget = widget
+        self.output = output
 
-    def create_service_msg(self, method_name, *args, **kwargs):
+    async def create_service_msg(self, method_name, *args, **kwargs):
         self.widget._response = None
         data = {}
         data["command"] = "callService"
@@ -36,6 +38,14 @@ def create_service_msg(self, method_name, *args, **kwargs):
 
         self.widget.send(data)
 
+        try:
+            self.output.append_stdout("Trying this thing\n")
+            await self.widget.wait_for_change('counter')
+            self.output.append_stdout("done waiting\n")
+        except Exception as e:
+            print('Something wrong: ', e)
+            self.output.append_stdout("wrong wrong: " + str(e) + '\n')
+
     def __getattr__(self, method_name):
         return lambda *x, **y: self.create_service_msg(method_name, *x, **y)
 
@@ -123,9 +133,9 @@ def connect(self, ip_address="nao.local", port="80"):
         self.send(data)
 
 
-    def service(self, service_name):
+    def service(self, output, service_name):
         data = {}
         data["command"] = str("createService")
         data["service"] = str(service_name)
         self.send(data)
-        return NaoRobotService(self, service_name)
+        return NaoRobotService(self, output, service_name)

src/widget.ts

@@ -150,6 +150,7 @@ export class NaoRobotModel extends DOMWidgetModel {
     serviceResponse = await servicePromise.then(
       (resolution: any) => {
         this.changeStatus('Task completed');
+        this.set('counter', this.get('counter') + 1);
         return resolution;
       }
     ).catch(
@@ -158,10 +159,14 @@ export class NaoRobotModel extends DOMWidgetModel {
       }
     );
 
-    console.log("OOO received response ", serviceResponse);
+    
     if (serviceResponse !== undefined) {
-      this.send(serviceResponse);
+      console.log("OOO received response ", serviceResponse);
+      // this.send(serviceResponse);
+      this.set('status', serviceResponse.toString());
     }
+
+    this.save_changes();
   }
 
   async goSleep() {