fix(didcomm): Add didcomm packages as dependencies (hyperledger-ident…

…us#60)

Signed-off-by: Francisco Javier Ribó Labrador <[email protected]>

package.json

@@ -56,7 +56,6 @@
     "@rollup/plugin-terser": "^0.4.3",
     "@rollup/plugin-typescript": "^11.1.1",
     "@rollup/plugin-wasm": "^6.1.3",
-    "@scure/bip32": "^1.3.0",
     "@semantic-release/changelog": "^6.0.3",
     "@semantic-release/commit-analyzer": "^9.0.2",
     "@semantic-release/exec": "^6.0.3",
@@ -92,7 +91,6 @@
     "copy-webpack-plugin": "^11.0.0",
     "css-loader": "^6.7.3",
     "css-minimizer-webpack-plugin": "^4.2.2",
-    "didcomm-node": "^0.4.0",
     "eslint": "^8.36.0",
     "eslint-config-standard-with-typescript": "^34.0.1",
     "eslint-plugin-import": "^2.27.5",
@@ -122,7 +120,6 @@
     "semantic-release-slack-bot": "^3.5.3",
     "sinon": "^15.0.1",
     "sinon-chai": "^3.7.0",
-    "sql.js": "^1.8.0",
     "sqlite3": "^5.1.6",
     "stream-browserify": "^3.0.0",
     "style-loader": "^3.3.1",
@@ -143,7 +140,9 @@
     ]
   },
   "dependencies": {
+    "sql.js": "^1.8.0",
     "@scure/bip39": "^1.1.1",
+    "@scure/bip32": "^1.3.0",
     "@stablelib/base64": "^1.0.1",
     "@stablelib/sha256": "^1.0.1",
     "@stablelib/uuid": "^1.0.2",
@@ -155,7 +154,8 @@
     "core-js": "^3.29.1",
     "did-jwt": "^6.11.5",
     "did-resolver": "^4.1.0",
-    "didcomm": "^0.4.0",
+    "didcomm": "^0.4.1",
+    "didcomm-node": "^0.4.1",
     "elliptic": "^6.5.4",
     "google-protobuf": "^3.21.2",
     "hash.js": "1.1.7",

src/prism-agent/connectionsManager/ConnectionsManager.ts

@@ -131,6 +131,12 @@ export class ConnectionsManager implements ConnectionsManagerClass {
         this.events.emit(ListenerKey.MESSAGE, unreadMessages);
       }
     }, timeInterval);
+
+    this.cancellable.then().catch((err) => {
+      if (err instanceof Error) {
+        if (err.message !== "Task was cancelled") throw err;
+      } else throw err;
+    });
   }
 
   stopFetchingMessages(): void {

src/prism-agent/helpers/Task.ts

@@ -9,9 +9,11 @@ export class CancellableTask<T> {
   constructor(task: Task<T>, repeatEvery?: number) {
     this.controller = new AbortController();
     this.cancellationToken = new Promise<T>((resolve, reject) => {
-      this.controller.signal.addEventListener("abort", () => {
+      const onAbort = () => {
+        this.controller.signal.removeEventListener("abort", onAbort);
         reject(new Error("Task was cancelled"));
-      });
+      };
+      this.controller.signal.addEventListener("abort", onAbort);
       if (repeatEvery !== undefined) {
         this.period = Math.max(repeatEvery, 10);
         this.loopOnTaskEvery(task, reject);