Handle service errors

Author: IsabelParedes

css/widget.css

@@ -1,4 +1,5 @@
 .custom-widget {
-  background-color: lightseagreen;
+  color: var(--jp-widgets-color) !important;
+  font-family: monospace;
   padding: 0px 2px;
 }

ipynao/nao_robot.py

@@ -92,4 +92,8 @@ def connect(self, ip_address="nao.local", port="80"):
 
 
     def service(self, service_name):
+        data = {}
+        data["command"] = str("createService")
+        data["service"] = str(service_name)
+        self.send(data)
         return NaoRobotService(self, service_name)

src/widget.ts

@@ -14,10 +14,17 @@ import '../css/widget.css';
 
 import { QiSession } from './qimessaging';
 
+interface serviceDict {
+  [key: string]: {
+    [key: string]: any;
+  };
+}
+
 export class NaoRobotModel extends DOMWidgetModel {
   qiSession: QiSession;
   connected = 'Disconnected';
   status = 'Not busy';
+  _services: serviceDict = {};
   synco: string;
 
   defaults() {
@@ -107,19 +114,28 @@ export class NaoRobotModel extends DOMWidgetModel {
     console.log('JS sent something');
   }
 
-  async goSleep(tSeconds: number) {
-    console.log('IN THE SLEEPING SESH');
-    const sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));
-
-    await sleep(tSeconds * 1000);
-
-    console.log('WAKING UP');
+  private async createService(
+    serviceName: string,
+  ) {
+    this.changeStatus('Creating service ' + serviceName);
+    const servicePromise = this.qiSession.service(serviceName);
 
-    this.set('synco', 'something else');
-    this.save_changes();
+    const naoService = await servicePromise.then(
+      (resolution: object) => {
+        return resolution;
+      }
+    ).catch(
+      (rejection: string) => {
+        this.changeStatus(rejection);
+        return rejection;
+      }
+    );
 
-    this.send({ data: 'purple' });
-    console.log('SETTED THE VALUE');
+    // Store service only when successfully created
+    if (typeof(naoService) === 'object') {
+      this._services[serviceName] = naoService;
+      this.changeStatus(serviceName + ' available');
+    }
   }
 
   private async callService(
@@ -128,12 +144,24 @@ export class NaoRobotModel extends DOMWidgetModel {
     args: any,
     _kwargs: any
   ) {
-    const naoService = await this.qiSession.service(serviceName);
+    if (this._services[serviceName][methodName] === undefined) {
+      this.changeStatus(methodName + ' does not exist for ' + serviceName);
+      return;
+    }
 
-    this.changeStatus('Running method' + methodName);
-    await naoService[methodName](...args);
+    this.changeStatus('Running method ' + methodName);
+
+    const servicePromise = this._services[serviceName][methodName](...args);
+    await servicePromise.then(
+      () => {
+        this.changeStatus('Task completed');
+      }
+    ).catch(
+      (rejection: string) => {
+        this.changeStatus(rejection);
+      }
+    );
 
-    this.changeStatus('Task completed');
   }
 
   private async onCommand(commandData: any, buffers: any) {
@@ -149,6 +177,10 @@ export class NaoRobotModel extends DOMWidgetModel {
         this.disconnect();
         break;
 
+      case 'createService':
+        this.createService(commandData['service']);
+        break;
+
       case 'callService':
         console.log('RECEIVING COMMAND FOR SERVICE');
         await this.callService(