MCP-I Integration

1
const mcpiServer = new MCPIServer({
2
  idaApiUrl: 'http://localhost:8080',
3
  serverDid: 'did:adi:service:freshmart...',
4
});
5
6
mcpiServer.registerTool({
7
  name: 'create_order',
8
  description: 'Create a new grocery order',
9
  requiredScope: ['purchase-groceries'],
10
  requiredTrustScore: 60,
11
  requiredAutonomyLevel: 'Junior',
12
  inputSchema: {
13
    type: 'object',
14
    properties: {
15
      items: { type: 'array' },
16
      merchant: { type: 'string' }
17
    }
18
  },
19
  handler: async (params, agentContext) => {
20
    // agentContext contains verified agent info
21
    console.log(`Agent ${agentContext.agentDid} creating order`);
22
    console.log(`Operator: ${agentContext.operatorDid}`);
23
    console.log(`Trust score: ${agentContext.trustScore}`);
24
25
    return { orderId: 'ORD-12345', total: 8.47 };
26
  }
27
});

1
mcpiServer.use(async (request, next) => {
2
  const { agentDid, ibct, delegationChain } = request.ida;
3
4
  // 1. Verify IBCT
5
  const ibctResult = await idaClient.verifyIBCT(ibct, {
6
    expectedAudience: serverDid,
7
    expectedAction: {
8
      type: 'tool-call',
9
      resource: request.params.name
10
    }
11
  });
12
13
  if (!ibctResult.valid) {
14
    throw new Error(`IBCT verification failed: ${ibctResult.reason}`);
15
  }
16
17
  // 2. Check trust score meets tool requirements
18
  const tool = mcpiServer.getTool(request.params.name);
19
  if (ibctResult.agent.trustScore < tool.requiredTrustScore) {
20
    throw new Error(`Trust score ${ibctResult.agent.trustScore} below required ${tool.requiredTrustScore}`);
21
  }
22
23
  // 3. Verify scope covers this tool
24
  if (!ibctResult.effectiveScope.includes(tool.requiredScope)) {
25
    throw new Error('Agent scope does not cover this tool');
26
  }
27
28
  // Attach verified context
29
  request.agentContext = ibctResult;
30
  return next(request);
31
});

1
mcpiServer.registerTool({
2
  name: 'process_payment',
3
  requiredScope: ['payment'],
4
  hitlRequired: true,  // Requires human approval
5
  hitlThreshold: 100,  // HITL for amounts > $100
6
  handler: async (params, agentContext) => {
7
    if (params.amount > 100) {
8
      // Block until human approves via wallet notification
9
      const approval = await idaClient.requestHITL({
10
        operatorDid: agentContext.operatorDid,
11
        agentDid: agentContext.agentDid,
12
        action: `Pay $${params.amount} to ${params.merchant}`,
13
        timeout: 300 // 5 minutes
14
      });
15
16
      if (!approval.approved) {
17
        throw new Error('Human approval denied');
18
      }
19
    }
20
21
    return processPayment(params);
22
  }
23
});

1
import { createMCPIMiddleware } from '@ida/mcp-i';
2
3
const mcpServer = existingMCPServer;
4
mcpServer.use(createMCPIMiddleware({
5
  idaApiUrl: 'http://localhost:8080',
6
  serverDid: 'did:adi:service:myservice...',
7
  auditEnabled: true
8
}));