ci: merge staging to master

package.json

@@ -1,6 +1,6 @@
 {
   "name": "polykey",
-  "version": "2.3.4",
+  "version": "2.3.5",
   "homepage": "https://polykey.com",
   "author": "Matrix AI",
   "contributors": [

src/nodes/NodeManager.ts

@@ -310,7 +310,7 @@ class NodeManager<Manifest extends AgentClientManifestNodeManager> {
         connectedTime: Date.now(),
         scopes: ['global'],
       },
-      true,
+      false,
       false,
     );
   };
@@ -707,7 +707,6 @@ class NodeManager<Manifest extends AgentClientManifestNodeManager> {
     }
 
     while (true) {
-      ctx.signal.throwIfAborted();
       const isDone = await nodeConnectionsQueue.withNodeSignal(
         async (nodeIdTarget, nodeIdSignaller) => {
           let nodeConnection: NodeConnection<Manifest> | undefined;
@@ -849,7 +848,6 @@ class NodeManager<Manifest extends AgentClientManifestNodeManager> {
     }
 
     while (true) {
-      ctx.signal.throwIfAborted();
       const isDone = await nodeConnectionsQueue.withNodeDirect(
         async (nodeIdTarget, nodeContact) => {
           if (!this.nodeConnectionManager.hasConnection(nodeIdTarget)) {
@@ -924,7 +922,6 @@ class NodeManager<Manifest extends AgentClientManifestNodeManager> {
         throw e;
       });
     }
-
     if (!connectionMade) {
       throw new nodesErrors.ErrorNodeManagerFindNodeFailed(
         'failed to find node via direct',
@@ -1312,8 +1309,8 @@ class NodeManager<Manifest extends AgentClientManifestNodeManager> {
     @decorators.context ctx: ContextTimed,
   ): Promise<void> {
     if (tran == null) {
-      return this.db.withTransactionF((tran) => {
-        return this.claimNode(targetNodeId, tran);
+      return await this.db.withTransactionF(async (tran) => {
+        return await this.claimNode(targetNodeId, tran);
       });
     }
     const [, claim] = await this.sigchain.addClaim(
@@ -1515,8 +1512,9 @@ class NodeManager<Manifest extends AgentClientManifestNodeManager> {
     tran?: DBTransaction,
   ): Promise<AgentRPCResponseResult<AgentClaimMessage>> {
     if (tran == null) {
-      return this.db.withTransactionF((tran) =>
-        this.handleClaimNetwork(requestingNodeId, input, tran),
+      return await this.db.withTransactionF(
+        async (tran) =>
+          await this.handleClaimNetwork(requestingNodeId, input, tran),
       );
     }
     const signedClaim = claimsUtils.parseSignedClaim(input.signedTokenEncoded);
@@ -1546,8 +1544,9 @@ class NodeManager<Manifest extends AgentClientManifestNodeManager> {
     tran?: DBTransaction,
   ): Promise<AgentRPCResponseResult<{ success: true }>> {
     if (tran == null) {
-      return this.db.withTransactionF((tran) =>
-        this.handleVerifyClaimNetwork(requestingNodeId, input, tran),
+      return await this.db.withTransactionF(
+        async (tran) =>
+          await this.handleVerifyClaimNetwork(requestingNodeId, input, tran),
       );
     }
     const signedClaim = claimsUtils.parseSignedClaim(input.signedTokenEncoded);
@@ -1680,17 +1679,18 @@ class NodeManager<Manifest extends AgentClientManifestNodeManager> {
     }
 
     if (tran == null) {
-      return this.db.withTransactionF((tran) =>
-        this.setNode(
-          nodeId,
-          nodeAddress,
-          nodeContactAddressData,
-          block,
-          force,
-          connectionConnectTimeoutTime,
-          tran,
-          ctx,
-        ),
+      return await this.db.withTransactionF(
+        async (tran) =>
+          await this.setNode(
+            nodeId,
+            nodeAddress,
+            nodeContactAddressData,
+            block,
+            force,
+            connectionConnectTimeoutTime,
+            tran,
+            ctx,
+          ),
       );
     }
 
@@ -1824,13 +1824,14 @@ class NodeManager<Manifest extends AgentClientManifestNodeManager> {
     tran?: DBTransaction,
   ): Promise<void> {
     if (tran == null) {
-      return this.db.withTransactionF((tran) =>
-        this.garbageCollectBucket(
-          bucketIndex,
-          connectionConnectTimeoutTime,
-          ctx,
-          tran,
-        ),
+      return await this.db.withTransactionF(
+        async (tran) =>
+          await this.garbageCollectBucket(
+            bucketIndex,
+            connectionConnectTimeoutTime,
+            ctx,
+            tran,
+          ),
       );
     }
 
@@ -2041,8 +2042,8 @@ class NodeManager<Manifest extends AgentClientManifestNodeManager> {
 
   protected async setupRefreshBucketTasks(tran?: DBTransaction) {
     if (tran == null) {
-      return this.db.withTransactionF((tran) =>
-        this.setupRefreshBucketTasks(tran),
+      return await this.db.withTransactionF(
+        async (tran) => await this.setupRefreshBucketTasks(tran),
       );
     }
 
@@ -2149,8 +2150,15 @@ class NodeManager<Manifest extends AgentClientManifestNodeManager> {
     @decorators.context ctx: ContextTimed,
   ): Promise<Task> {
     if (tran == null) {
-      return this.db.withTransactionF((tran) =>
-        this.updateRefreshBucketDelay(bucketIndex, delay, lazy, tran, ctx),
+      return await this.db.withTransactionF(
+        async (tran) =>
+          await this.updateRefreshBucketDelay(
+            bucketIndex,
+            delay,
+            lazy,
+            tran,
+            ctx,
+          ),
       );
     }