X402

examples/x402/package.json

@@ -0,0 +1,33 @@
+{
+  "name": "@atxp/x402-example",
+  "version": "1.0.0",
+  "type": "module",
+  "private": true,
+  "scripts": {
+    "dev": "tsx watch src/server.ts",
+    "start": "tsx src/server.ts",
+    "test-client": "tsx src/test-client.ts"
+  },
+  "dependencies": {
+    "@atxp/client": "file:../../packages/atxp-client",
+    "@atxp/common": "file:../../packages/atxp-common",
+    "@atxp/x402": "file:../../packages/atxp-x402",
+    "@coinbase/x402": "^0.3.8",
+    "@modelcontextprotocol/sdk": "^1.18.1",
+    "bignumber.js": "^9.1.2",
+    "cors": "^2.8.5",
+    "dotenv": "^16.0.3",
+    "express": "^4.18.2",
+    "x402": "^0.6.1",
+    "x402-express": "^0.6.1",
+    "x402-fetch": "^0.6.0",
+    "zod": "^3.25.76"
+  },
+  "devDependencies": {
+    "@types/cors": "^2.8.13",
+    "@types/express": "^4.17.17",
+    "@types/node": "^20.0.0",
+    "tsx": "^4.0.0",
+    "typescript": "^5.0.0"
+  }
+}

examples/x402/src/server.ts

@@ -0,0 +1,131 @@
+/* eslint-disable no-console */
+import express, { Request, Response } from 'express';
+import { McpServer } from '@modelcontextprotocol/sdk/server/mcp.js';
+import { StreamableHTTPServerTransport } from '@modelcontextprotocol/sdk/server/streamableHttp.js';
+import { z } from 'zod';
+import { CallToolResult } from '@modelcontextprotocol/sdk/types.js';
+import { paymentMiddleware } from 'x402-express';
+import { facilitator } from '@coinbase/x402';
+import dotenv from "dotenv";
+import path from "path";
+import { fileURLToPath } from 'url';
+
+const __dirname = path.dirname(fileURLToPath(import.meta.url));
+dotenv.config();
+dotenv.config({ path: path.resolve(__dirname, '../../../.env') });
+
+const PORT = 3001;
+
+const getServer = () => {
+  // Create an MCP server with implementation details
+  const server = new McpServer({
+    name: 'stateless-streamable-http-server',
+    version: '1.0.0',
+  }, { capabilities: { logging: {} } });
+
+  // Register a tool specifically for testing resumability
+  server.tool(
+    'secure-data',
+    'Secure data',
+    {
+      message: z.string().optional().describe('Message to secure'),
+    },
+    async ({ message }: { message?: string }): Promise<CallToolResult> => {
+      // X402 payment will be enforced by middleware
+      return {
+        content: [
+          {
+            type: 'text',
+            text: `Secure data: ${message || 'No message provided'}`,
+          }
+        ],
+      };
+    }
+  );
+
+  return server;
+}
+
+const app = express();
+app.use(express.json());
+
+const destinationAddress = process.env.ATXP_DESTINATION!;
+const network = 'base';
+console.log('Starting MCP server with destination', destinationAddress);
+
+// Add X402 payment middleware
+app.use(paymentMiddleware(
+  destinationAddress,
+  { "POST /*": { price: "$0.01", network } },
+  process.env.CDP_API_KEY_ID ? facilitator : { url: "https://x402.org/facilitator" }
+));
+
+
+app.post('/', async (req: Request, res: Response) => {
+  const server = getServer();
+  try {
+    const transport: StreamableHTTPServerTransport = new StreamableHTTPServerTransport({
+      sessionIdGenerator: undefined,
+      enableJsonResponse: true
+    });
+    await server.connect(transport);
+    await transport.handleRequest(req, res, req.body);
+    res.on('close', () => {
+      console.log('Request closed');
+      transport.close();
+      server.close();
+    });
+  } catch (error) {
+    console.error('Error handling MCP request:', error);
+    if (!res.headersSent) {
+      res.status(500).json({
+        jsonrpc: '2.0',
+        error: {
+          code: -32603,
+          message: 'Internal server error',
+        },
+        id: null,
+      });
+    }
+  }
+});
+
+app.get('/', async (req: Request, res: Response) => {
+  console.log('Received GET MCP request');
+  res.writeHead(405).end(JSON.stringify({
+    jsonrpc: "2.0",
+    error: {
+      code: -32000,
+      message: "Method not allowed."
+    },
+    id: null
+  }));
+});
+
+app.delete('/', async (req: Request, res: Response) => {
+  console.log('Received DELETE MCP request');
+  res.writeHead(405).end(JSON.stringify({
+    jsonrpc: "2.0",
+    error: {
+      code: -32000,
+      message: "Method not allowed."
+    },
+    id: null
+  }));
+});
+
+
+// Start the server
+app.listen(PORT, (error) => {
+  if (error) {
+    console.error('Failed to start server:', error);
+    process.exit(1);
+  }
+  console.log(`MCP Stateless Streamable HTTP Server listening on port ${PORT}`);
+});
+
+// Handle server shutdown
+process.on('SIGINT', async () => {
+  console.log('Shutting down server...');
+  process.exit(0);
+});

examples/x402/src/test-client.ts

@@ -0,0 +1,40 @@
+#!/usr/bin/env node
+import { atxpClient, ATXPAccount } from "@atxp/client";
+import { wrapWithX402 } from "@atxp/x402";
+import { ConsoleLogger, LogLevel } from '@atxp/common';
+import dotenv from "dotenv";
+import path from "path";
+import { fileURLToPath } from 'url';
+
+const __dirname = path.dirname(fileURLToPath(import.meta.url));
+dotenv.config();
+dotenv.config({ path: path.resolve(__dirname, '../../../.env') });
+
+async function main() {
+  const serverUrl = process.env.X402_SERVER_URL || "http://localhost:3001";
+
+  console.log("X402 Test Client (without payments)");
+  console.log(`Server: ${serverUrl}`);
+
+  const account = new ATXPAccount(process.env.ATXP_CONNECTION_STRING!);
+  const config = {
+    account, 
+    logger: new ConsoleLogger({level: LogLevel.DEBUG}),
+    mcpServer: serverUrl,
+    allowHttp: true
+  };
+  const mcpClient = await atxpClient({
+    ...config,
+    fetchFn: wrapWithX402(config)
+
+  });
+  const res = await mcpClient.callTool({
+    name: "secure-data",
+    arguments: { message: "blockchain metrics" }
+  });
+
+  console.log('Result:', res);
+
+}
+
+main().catch(console.error);

examples/x402/tsconfig.json

@@ -0,0 +1,11 @@
+{
+  "extends": "../../tsconfig.json",
+  "compilerOptions": {
+    "rootDir": "./src",
+    "outDir": "./dist",
+    "declaration": false,
+    "declarationMap": false
+  },
+  "include": ["src/**/*"],
+  "exclude": ["node_modules", "dist"]
+}