wip

src/nodes/NodeManager.ts

@@ -48,6 +48,7 @@ import { MDNS, events as mdnsEvents, utils as mdnsUtils } from '@matrixai/mdns';
 import * as nodesUtils from './utils';
 import * as nodesEvents from './events';
 import * as nodesErrors from './errors';
+import * as agentErrors from './agent/errors';
 import NodeConnectionQueue from './NodeConnectionQueue';
 import Token from '../tokens/Token';
 import * as keysUtils from '../keys/utils';
@@ -1552,7 +1553,7 @@ class NodeManager {
     requestingNodeId: NodeId,
     input: AgentRPCRequestParams<AgentClaimMessage>,
     tran?: DBTransaction,
-  ): Promise<AgentRPCResponseResult<{ success: boolean }>> {
+  ): Promise<AgentRPCResponseResult<{ success: true }>> {
     if (tran == null) {
       return this.db.withTransactionF((tran) =>
         this.handleVerifyClaimNetwork(requestingNodeId, input, tran),
@@ -1620,8 +1621,12 @@ class NodeManager {
       }
     }
 
+    if (!success) {
+      throw new agentErrors.ErrorNodesClaimNetworkVerificationFailed();
+    }
+
     return {
-      success: success,
+      success: true,
     }
   }
 

src/nodes/agent/handlers/NodesClaimNetworkVerify.ts

@@ -19,13 +19,13 @@ class NodesClaimNetworkVerify extends UnaryHandler<
     nodeManager: NodeManager;
   },
   AgentRPCRequestParams<AgentClaimMessage>,
-  AgentRPCResponseResult<{ success: boolean }>
+  AgentRPCResponseResult<{ success: true }>
 > {
   public handle = async (
     input: AgentRPCRequestParams<AgentClaimMessage>,
     _cancel,
     meta: Record<string, JSONValue> | undefined,
-  ): Promise<AgentRPCResponseResult<{ success: boolean }>> => {
+  ): Promise<AgentRPCResponseResult<{ success: true }>> => {
     const requestingNodeId = agentUtils.nodeIdFromMeta(meta);
     if (requestingNodeId == null) {
       throw new agentErrors.ErrorAgentNodeIdMissing();