fix: issues in core

Author: danielpeintner

packages/core/test/client-test.ts

@@ -358,9 +358,14 @@ class WoTClientTest {
         this.clientFactory = new TrapClientFactory();
         this.servient.addClientFactory(this.clientFactory);
         this.servient.addClientFactory(new TDClientFactory());
-        this.servient.start().then((myWoT) => {
-            this.WoT = myWoT;
-        });
+        this.servient
+            .start()
+            .then((myWoT) => {
+                this.WoT = myWoT;
+            })
+            .catch((error) => {
+                throw error;
+            });
         debug("started test suite");
     }
 
@@ -570,11 +575,17 @@ class WoTClientTest {
         expect(thing).to.have.property("title").that.equals("aThing");
         expect(thing).to.have.property("events").that.has.property("anEvent");
         return new Promise((resolve) => {
-            thing.subscribeEvent("anEvent", async (x) => {
-                const value = await x.value();
-                expect(value).to.equal("triggered");
-                resolve(true);
-            });
+            thing
+                .subscribeEvent("anEvent", async (x) => {
+                    const value = await x.value();
+                    expect(value).to.equal("triggered");
+                    resolve(true);
+                })
+                .catch((error) => {
+                    throw error;
+                });
+        }).catch((error) => {
+            throw error;
         });
     }
 
@@ -626,17 +637,25 @@ class WoTClientTest {
         expect(thing).to.have.property("title").that.equals("aThing");
         expect(thing).to.have.property("events").that.has.property("anEvent");
 
-        const subscription = await thing.subscribeEvent("anEvent", () => {
-            /** */
-        });
+        const subscription = await thing
+            .subscribeEvent("anEvent", () => {
+                /** */
+            })
+            .catch((error) => {
+                throw error;
+            });
         await subscription.stop();
 
         return new Promise((resolve) => {
-            thing.subscribeEvent("anEvent", async (x) => {
-                const value = await x.value();
-                expect(value).to.equal("triggered");
-                resolve(true);
-            });
+            thing
+                .subscribeEvent("anEvent", async (x) => {
+                    const value = await x.value();
+                    expect(value).to.equal("triggered");
+                    resolve(true);
+                })
+                .catch((error) => {
+                    throw error;
+                });
         });
     }
 
@@ -649,11 +668,15 @@ class WoTClientTest {
         expect(thing).to.have.property("title").that.equals("aThing");
         expect(thing).to.have.property("properties").that.has.property("aPropertyToObserve");
         return new Promise((resolve) => {
-            thing.observeProperty("aPropertyToObserve", async (data) => {
-                const value = await data.value();
-                expect(value).to.equal(12);
-                resolve(true);
-            });
+            thing
+                .observeProperty("aPropertyToObserve", async (data) => {
+                    const value = await data.value();
+                    expect(value).to.equal(12);
+                    resolve(true);
+                })
+                .catch((error) => {
+                    throw error;
+                });
         });
     }
 

packages/core/test/server-test.ts

@@ -68,9 +68,14 @@ class WoTServerTest {
         this.servient = new Servient();
         this.server = new TestProtocolServer();
         this.servient.addServer(this.server);
-        this.servient.start().then((WoTruntime) => {
-            this.WoT = WoTruntime;
-        });
+        this.servient
+            .start()
+            .then((WoTruntime) => {
+                this.WoT = WoTruntime;
+            })
+            .catch((error) => {
+                throw error;
+            });
         debug("started test suite");
     }
 
@@ -889,7 +894,9 @@ class WoTServerTest {
 
         thing.setPropertyReadHandler("test", callback);
 
-        (thing as ExposedThing).handleObserveProperty("test", protocolListener, { formIndex: 0 });
+        (thing as ExposedThing).handleObserveProperty("test", protocolListener, { formIndex: 0 }).catch((error) => {
+            throw error;
+        });
 
         await (<ExposedThing>thing).emitPropertyChange("test");
 
@@ -964,7 +971,9 @@ class WoTServerTest {
         thing.setEventSubscribeHandler("test", handler);
         await (<ExposedThing>thing).handleSubscribeEvent("test", callback, { formIndex: 0 });
         (<ExposedThing>thing).emitEvent("test", null);
-        (<ExposedThing>thing).handleUnsubscribeEvent("test", callback, { formIndex: 0 });
+        (<ExposedThing>thing).handleUnsubscribeEvent("test", callback, { formIndex: 0 }).catch((error) => {
+            throw error;
+        });
         (<ExposedThing>thing).emitEvent("test", null);
 
         return expect(callback).to.have.been.called.once;