[{"_1":2,"_412":-5,"_413":-5},"loaderData",{"_3":4,"_92":93,"_343":344},"root",{"_5":6,"_35":36,"_65":66},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":22,"_29":22,"_30":22,"_31":32,"_33":22,"_34":22},"auth",{"_9":10,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":-5,"_20":-5,"_21":22},"tokenType","session_token","sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","notificationCount",0,"flagDenols","isTeamOrgMember","ENV",{"_37":38,"_39":40,"_41":42,"_43":44,"_45":46,"_47":48,"_49":50,"_51":52,"_53":54,"_55":56,"_57":58,"_59":60,"_61":62,"_63":64},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","16f2931b3e0f3a1f0749f6d2640b9447dd6106a9","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","API_URL","https://api.val.town","clerkState",{"_67":68},"__internal_clerk_state",{"_69":70,"_71":46,"_72":73,"_74":73,"_75":22,"_76":73,"_77":73,"_78":73,"_79":73,"_80":81,"_90":22,"_91":22},"__clerk_ssr_state",{"_9":10,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":-5,"_20":-5,"_21":22},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_82":22,"_21":22,"_83":73,"_84":85,"_86":73,"_87":46,"_88":22,"_89":73},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/_app.x.$handle.$name",{"_94":95,"_96":97,"_98":44,"_99":100,"_101":102,"_103":104,"_152":153,"_320":321,"_322":323,"_332":333,"_167":334,"_337":-5,"_338":-5,"_339":22,"_340":22,"_341":342},"handle","c15r","name","ContextualLite","branchName","path","test-simple.ts","version",146,"project",{"_105":106,"_96":97,"_107":108,"_109":-5,"_110":22,"_111":112,"_113":-5,"_114":-5,"_14":115,"_116":117,"_118":119,"_120":119,"_121":-5,"_122":32,"_16":123,"_124":125,"_126":125,"_127":128,"_129":128,"_130":128,"_131":125,"_132":125,"_23":133,"_136":137,"_139":140,"_151":22},"id","c5961c8a-4557-11f0-999b-76b3cceeab13","createdAt",["D",1749490372788],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","21f2e37e-8066-4730-9dc7-d27cf8d3c9f3","pinnedFileId","6e010d7c-45d4-11f0-a0c9-76b3cceeab13","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","0630d977-f678-453e-926c-52043293f59f","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_94":95,"_134":135},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yb2RJNlc1czZ1NlpZRmoxdGJ2eFVNNVhmeTYifQ","org",{"_94":95,"_138":135,"_14":115},"avatar","branch",{"_101":141,"_96":44,"_105":142,"_143":106,"_144":-5,"_145":-5,"_146":-5,"_147":-5,"_148":-5,"_149":97,"_150":95},560,"c5966aa0-4557-11f0-999b-76b3cceeab13","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","tree",[154,175,184,194,203,212,222,231,241,250,260,269,278,287,294,302,311],{"_105":155,"_96":156,"_157":158,"_159":-5,"_160":142,"_161":162,"_163":22,"_107":164,"_101":165,"_166":167,"_168":169,"_170":22,"_171":-5,"_172":173,"_99":174},"78fd37a4-4710-11f0-a95b-76b3cceeab13","README.md","fileId","929abcdc-45d4-11f0-a87c-76b3cceeab13","parentId","branchId","branchVersion",144,"latest",["D",1749679652331],9,"fileType","file","content","# Remote HTTP AWS MCP Server\n\nA remote HTTP Model Context Protocol (MCP) server that provides access to AWS services including DynamoDB and S3. This server now uses the official MCP SDK for JSON-RPC handling and exposes prompts, resources, and tools via both JSON-RPC and legacy HTTP endpoints with bearer token authentication.\n\n## Features\n\n### JSON-RPC Endpoint (Recommended)\n- **POST /mcp**: Primary JSON-RPC endpoint using MCP SDK for all operations\n- Supports all MCP operations: prompts, resources, and tools\n- Proper JSON-RPC 2.0 protocol compliance\n- Batch request support\n\n### Legacy HTTP Endpoints (Deprecated)\n- **GET /**: Server information and capabilities\n- **GET /health**: Health check endpoint\n- **GET /mcp/prompts**: List available prompts (deprecated)\n- **POST /mcp/prompts/:name**: Get specific prompt content (deprecated)\n- **GET /mcp/resources**: List S3 resources (deprecated, requires auth)\n- **GET /mcp/resources/***: Read specific S3 resource (deprecated, requires auth)\n- **GET /mcp/tools**: List available tools (deprecated)\n- **POST /mcp/tools/:name**: Execute specific tool (deprecated, requires auth)\n\n### Authentication\n- Uses Bearer token authentication\n- AWS_SECRET_ACCESS_KEY is passed via `Authorization: Bearer ` header\n- Other AWS credentials are configured via environment variables\n\n### Prompts\n- **analyze-data**: Analyze data from DynamoDB and S3 resources\n- **data-summary**: Generate a summary of available data sources\n\n### Resources\n- **S3 Objects**: Access and read objects from your S3 bucket\n- Automatic MIME type detection\n- Object metadata (size, last modified)\n\n### Tools\n\n#### DynamoDB Operations\n- **dynamodb-get**: Get an item by key\n- **dynamodb-put**: Store an item\n- **dynamodb-delete**: Delete an item by key\n- **dynamodb-query**: Query items with conditions\n\n#### S3 Operations\n- **s3-get**: Download object content\n- **s3-put**: Upload object content\n- **s3-delete**: Delete an object\n- **s3-move**: Move/rename an object\n\n#### Code Execution\n- **code-exec**: Execute JavaScript/TypeScript code with access to all MCP tools. Code can be provided directly as a string or referenced via S3 object key\n\n## Code Execution Feature\n\nThe `code-exec` tool allows you to execute JavaScript/TypeScript code with full access to all MCP tools (DynamoDB and S3 operations). This enables powerful automation and data processing workflows.\n\n### Code Requirements\n\nYour code must define an `async execute` function that accepts two parameters:\n- `input`: Object containing input parameters for your script\n- `tools`: Object containing all available MCP tools as callable functions\n\n```javascript\nasync function execute(input, tools) {\n // Your code logic here\n const result = await tools[\"dynamodb-get\"]({key: {id: input.userId}});\n return { message: \"Processing complete\", data: result };\n}\n```\n\n### Available Tools in Code Context\n\nWithin your executed code, you have access to all MCP tools via the `tools` object:\n- `tools[\"dynamodb-get\"](args)` - Get DynamoDB item\n- `tools[\"dynamodb-put\"](args)` - Put DynamoDB item \n- `tools[\"dynamodb-delete\"](args)` - Delete DynamoDB item\n- `tools[\"dynamodb-query\"](args)` - Query DynamoDB items\n- `tools[\"s3-get\"](args)` - Get S3 object\n- `tools[\"s3-put\"](args)` - Put S3 object\n- `tools[\"s3-delete\"](args)` - Delete S3 object\n- `tools[\"s3-move\"](args)` - Move S3 object\n- `tools[\"s3-list\"](args)` - List S3 objects\n\n### Two Execution Modes\n\n#### 1. Direct Code Execution\nProvide the code directly in the request:\n\n```json\n{\n \"code\": \"async function execute(input, tools) { /* your code */ }\",\n \"input\": { \"param1\": \"value1\" }\n}\n```\n\n#### 2. S3 Code Execution \nStore your code in an S3 object and reference it by key:\n\n```json\n{\n \"key\": \"scripts/my-processor.js\",\n \"input\": { \"param1\": \"value1\" }\n}\n```\n\nThis approach is ideal for:\n- Reusable scripts and workflows\n- Version control of automation code\n- Sharing scripts across different executions\n- Complex multi-function scripts\n\n### Security Considerations\n\n- Code execution runs in a sandboxed environment\n- No access to global objects or external network calls\n- Only MCP tools are available for external operations\n- All AWS operations use the same authentication as other MCP tools\n\n## Setup\n\n### Environment Variables\n\nSet the following environment variables on your Val Town:\n\n```bash\nAWS_REGION=us-east-1\nAWS_ACCESS_KEY_ID=your-access-key-id\nS3_BUCKET=your-bucket-name\nDYNAMODB_TABLE=your-table-name\nMCP_SERVER_NAME=aws-mcp-server\nMCP_SERVER_VERSION=1.0.0\n```\n\n**Note**: `AWS_SECRET_ACCESS_KEY` is NOT set as an environment variable. Instead, it's passed via the Authorization header for security.\n\n### Deployment\n\n1. Deploy to Val Town as an HTTP val\n2. Set the required environment variables\n3. The server will be available at your Val Town URL\n\n## Usage Examples\n\n### JSON-RPC Endpoint (Recommended)\n\nAll MCP operations should now use the JSON-RPC endpoint at `POST /mcp`. This provides proper MCP protocol compliance and better error handling.\n\n#### Authentication\n\nAll authenticated requests require the Authorization header:\n\n```bash\nAuthorization: Bearer your-aws-secret-access-key\n```\n\n#### List Prompts\n\n```bash\ncurl -X POST https://your-val-town-url.web.val.run/mcp \\\n -H \"Content-Type: application/json\" \\\n -d '{\n \"jsonrpc\": \"2.0\",\n \"method\": \"prompts/list\",\n \"params\": {},\n \"id\": 1\n }'\n```\n\n#### Get Prompt Content\n\n```bash\ncurl -X POST https://your-val-town-url.web.val.run/mcp \\\n -H \"Content-Type: application/json\" \\\n -d '{\n \"jsonrpc\": \"2.0\",\n \"method\": \"prompts/get\",\n \"params\": {\n \"name\": \"analyze-data\",\n \"arguments\": {\n \"table_key\": \"user123\",\n \"s3_key\": \"data/analytics.json\"\n }\n },\n \"id\": 1\n }'\n```\n\n#### List Resources (S3 Objects)\n\n```bash\ncurl -X POST https://your-val-town-url.web.val.run/mcp \\\n -H \"Content-Type: application/json\" \\\n -H \"Authorization: Bearer your-aws-secret-access-key\" \\\n -d '{\n \"jsonrpc\": \"2.0\",\n \"method\": \"resources/list\",\n \"params\": {},\n \"id\": 1\n }'\n```\n\n#### Read S3 Resource\n\n```bash\ncurl -X POST https://your-val-town-url.web.val.run/mcp \\\n -H \"Content-Type: application/json\" \\\n -H \"Authorization: Bearer your-aws-secret-access-key\" \\\n -d '{\n \"jsonrpc\": \"2.0\",\n \"method\": \"resources/read\",\n \"params\": {\n \"uri\": \"s3://your-bucket/path/to/file.txt\"\n },\n \"id\": 1\n }'\n```\n\n#### List Tools\n\n```bash\ncurl -X POST https://your-val-town-url.web.val.run/mcp \\\n -H \"Content-Type: application/json\" \\\n -d '{\n \"jsonrpc\": \"2.0\",\n \"method\": \"tools/list\",\n \"params\": {},\n \"id\": 1\n }'\n```\n\n#### Execute DynamoDB Operations\n\n```bash\n# Get an item\ncurl -X POST https://your-val-town-url.web.val.run/mcp \\\n -H \"Content-Type: application/json\" \\\n -H \"Authorization: Bearer your-aws-secret-access-key\" \\\n -d '{\n \"jsonrpc\": \"2.0\",\n \"method\": \"tools/call\",\n \"params\": {\n \"name\": \"dynamodb-get\",\n \"arguments\": {\n \"key\": {\"id\": \"user123\"}\n }\n },\n \"id\": 1\n }'\n\n# Put an item\ncurl -X POST https://your-val-town-url.web.val.run/mcp \\\n -H \"Content-Type: application/json\" \\\n -H \"Authorization: Bearer your-aws-secret-access-key\" \\\n -d '{\n \"jsonrpc\": \"2.0\",\n \"method\": \"tools/call\",\n \"params\": {\n \"name\": \"dynamodb-put\",\n \"arguments\": {\n \"item\": {\n \"id\": \"user123\",\n \"name\": \"John Doe\",\n \"email\": \"john@example.com\"\n }\n }\n },\n \"id\": 1\n }'\n\n# Query items\ncurl -X POST https://your-val-town-url.web.val.run/mcp \\\n -H \"Content-Type: application/json\" \\\n -H \"Authorization: Bearer your-aws-secret-access-key\" \\\n -d '{\n \"jsonrpc\": \"2.0\",\n \"method\": \"tools/call\",\n \"params\": {\n \"name\": \"dynamodb-query\",\n \"arguments\": {\n \"keyConditionExpression\": \"id = :id\",\n \"expressionAttributeValues\": {\":id\": \"user123\"}\n }\n },\n \"id\": 1\n }'\n\n# Delete an item\ncurl -X POST https://your-val-town-url.web.val.run/mcp \\\n -H \"Content-Type: application/json\" \\\n -H \"Authorization: Bearer your-aws-secret-access-key\" \\\n -d '{\n \"jsonrpc\": \"2.0\",\n \"method\": \"tools/call\",\n \"params\": {\n \"name\": \"dynamodb-delete\",\n \"arguments\": {\n \"key\": {\"id\": \"user123\"}\n }\n },\n \"id\": 1\n }'\n```\n\n#### Execute S3 Operations\n\n```bash\n# Get object content\ncurl -X POST https://your-val-town-url.web.val.run/mcp \\\n -H \"Content-Type: application/json\" \\\n -H \"Authorization: Bearer your-aws-secret-access-key\" \\\n -d '{\n \"jsonrpc\": \"2.0\",\n \"method\": \"tools/call\",\n \"params\": {\n \"name\": \"s3-get\",\n \"arguments\": {\n \"key\": \"documents/report.txt\"\n }\n },\n \"id\": 1\n }'\n\n# Upload content\ncurl -X POST https://your-val-town-url.web.val.run/mcp \\\n -H \"Content-Type: application/json\" \\\n -H \"Authorization: Bearer your-aws-secret-access-key\" \\\n -d '{\n \"jsonrpc\": \"2.0\",\n \"method\": \"tools/call\",\n \"params\": {\n \"name\": \"s3-put\",\n \"arguments\": {\n \"key\": \"documents/new-file.txt\",\n \"content\": \"Hello, World!\",\n \"contentType\": \"text/plain\"\n }\n },\n \"id\": 1\n }'\n\n# Move/rename object\ncurl -X POST https://your-val-town-url.web.val.run/mcp \\\n -H \"Content-Type: application/json\" \\\n -H \"Authorization: Bearer your-aws-secret-access-key\" \\\n -d '{\n \"jsonrpc\": \"2.0\",\n \"method\": \"tools/call\",\n \"params\": {\n \"name\": \"s3-move\",\n \"arguments\": {\n \"sourceKey\": \"old-location/file.txt\",\n \"destinationKey\": \"new-location/file.txt\"\n }\n },\n \"id\": 1\n }'\n\n# Delete object\ncurl -X POST https://your-val-town-url.web.val.run/mcp \\\n -H \"Content-Type: application/json\" \\\n -H \"Authorization: Bearer your-aws-secret-access-key\" \\\n -d '{\n \"jsonrpc\": \"2.0\",\n \"method\": \"tools/call\",\n \"params\": {\n \"name\": \"s3-delete\",\n \"arguments\": {\n \"key\": \"documents/old-file.txt\"\n }\n },\n \"id\": 1\n }'\n```\n\n#### Execute Code\n\n```bash\n# Execute code directly (inline)\ncurl -X POST https://your-val-town-url.web.val.run/mcp \\\n -H \"Content-Type: application/json\" \\\n -H \"Authorization: Bearer your-aws-secret-access-key\" \\\n -d '{\n \"jsonrpc\": \"2.0\",\n \"method\": \"tools/call\",\n \"params\": {\n \"name\": \"code-exec\",\n \"arguments\": {\n \"code\": \"async function execute(input, tools) { const result = await tools[\\\"dynamodb-get\\\"]({key: {id: input.userId}}); return {message: \\\"User data retrieved\\\", data: result}; }\",\n \"input\": {\n \"userId\": \"user123\"\n }\n }\n },\n \"id\": 1\n }'\n\n# Execute code from S3 object\ncurl -X POST https://your-val-town-url.web.val.run/mcp \\\n -H \"Content-Type: application/json\" \\\n -H \"Authorization: Bearer your-aws-secret-access-key\" \\\n -d '{\n \"jsonrpc\": \"2.0\",\n \"method\": \"tools/call\",\n \"params\": {\n \"name\": \"code-exec\",\n \"arguments\": {\n \"key\": \"scripts/data-processor.js\",\n \"input\": {\n \"userId\": \"user123\",\n \"operation\": \"analyze\"\n }\n }\n },\n \"id\": 1\n }'\n```\n\n#### Batch Requests\n\nYou can send multiple JSON-RPC requests in a single HTTP request:\n\n```bash\ncurl -X POST https://your-val-town-url.web.val.run/mcp \\\n -H \"Content-Type: application/json\" \\\n -H \"Authorization: Bearer your-aws-secret-access-key\" \\\n -d '[\n {\n \"jsonrpc\": \"2.0\",\n \"method\": \"prompts/list\",\n \"params\": {},\n \"id\": 1\n },\n {\n \"jsonrpc\": \"2.0\",\n \"method\": \"tools/list\",\n \"params\": {},\n \"id\": 2\n },\n {\n \"jsonrpc\": \"2.0\",\n \"method\": \"resources/list\",\n \"params\": {},\n \"id\": 3\n }\n ]'\n```\n\n### Legacy HTTP Endpoints (Deprecated)\n\nThe following endpoints are maintained for backward compatibility but are deprecated. Use the JSON-RPC endpoint instead.\n\n### Server Information\n\n```bash\ncurl https://your-val-town-url.web.val.run/\n```\n\n### List Prompts\n\n```bash\ncurl https://your-val-town-url.web.val.run/mcp/prompts\n```\n\n### Get Prompt Content\n\n```bash\ncurl -X POST https://your-val-town-url.web.val.run/mcp/prompts/analyze-data \\\n -H \"Content-Type: application/json\" \\\n -d '{\"table_key\": \"user123\", \"s3_key\": \"data/analytics.json\"}'\n```\n\n### List Resources (S3 Objects)\n\n```bash\ncurl https://your-val-town-url.web.val.run/mcp/resources \\\n -H \"Authorization: Bearer your-aws-secret-access-key\"\n```\n\n### Read S3 Resource\n\n```bash\ncurl \"https://your-val-town-url.web.val.run/mcp/resources/s3://your-bucket/path/to/file.txt\" \\\n -H \"Authorization: Bearer your-aws-secret-access-key\"\n```\n\n### List Tools\n\n```bash\ncurl https://your-val-town-url.web.val.run/mcp/tools\n```\n\n### Execute DynamoDB Operations\n\n```bash\n# Get an item\ncurl -X POST https://your-val-town-url.web.val.run/mcp/tools/dynamodb-get \\\n -H \"Authorization: Bearer your-aws-secret-access-key\" \\\n -H \"Content-Type: application/json\" \\\n -d '{\"key\": {\"id\": \"user123\"}}'\n\n# Put an item\ncurl -X POST https://your-val-town-url.web.val.run/mcp/tools/dynamodb-put \\\n -H \"Authorization: Bearer your-aws-secret-access-key\" \\\n -H \"Content-Type: application/json\" \\\n -d '{\"item\": {\"id\": \"user123\", \"name\": \"John Doe\", \"email\": \"john@example.com\"}}'\n\n# Query items\ncurl -X POST https://your-val-town-url.web.val.run/mcp/tools/dynamodb-query \\\n -H \"Authorization: Bearer your-aws-secret-access-key\" \\\n -H \"Content-Type: application/json\" \\\n -d '{\"keyConditionExpression\": \"id = :id\", \"expressionAttributeValues\": {\":id\": \"user123\"}}'\n\n# Delete an item\ncurl -X POST https://your-val-town-url.web.val.run/mcp/tools/dynamodb-delete \\\n -H \"Authorization: Bearer your-aws-secret-access-key\" \\\n -H \"Content-Type: application/json\" \\\n -d '{\"key\": {\"id\": \"user123\"}}'\n```\n\n### Execute S3 Operations\n\n```bash\n# Get object content\ncurl -X POST https://your-val-town-url.web.val.run/mcp/tools/s3-get \\\n -H \"Authorization: Bearer your-aws-secret-access-key\" \\\n -H \"Content-Type: application/json\" \\\n -d '{\"key\": \"documents/report.txt\"}'\n\n# Upload content\ncurl -X POST https://your-val-town-url.web.val.run/mcp/tools/s3-put \\\n -H \"Authorization: Bearer your-aws-secret-access-key\" \\\n -H \"Content-Type: application/json\" \\\n -d '{\"key\": \"documents/new-file.txt\", \"content\": \"Hello, World!\", \"contentType\": \"text/plain\"}'\n\n# Move/rename object\ncurl -X POST https://your-val-town-url.web.val.run/mcp/tools/s3-move \\\n -H \"Authorization: Bearer your-aws-secret-access-key\" \\\n -H \"Content-Type: application/json\" \\\n -d '{\"sourceKey\": \"old-location/file.txt\", \"destinationKey\": \"new-location/file.txt\"}'\n\n# Delete object\ncurl -X POST https://your-val-town-url.web.val.run/mcp/tools/s3-delete \\\n -H \"Authorization: Bearer your-aws-secret-access-key\" \\\n -H \"Content-Type: application/json\" \\\n -d '{\"key\": \"documents/old-file.txt\"}'\n```\n\n### Execute Code\n\n```bash\n# Execute code directly (inline)\ncurl -X POST https://your-val-town-url.web.val.run/mcp/tools/code-exec \\\n -H \"Authorization: Bearer your-aws-secret-access-key\" \\\n -H \"Content-Type: application/json\" \\\n -d '{\n \"code\": \"async function execute(input, tools) { const result = await tools[\\\"dynamodb-get\\\"]({key: {id: input.userId}}); return {message: \\\"User data retrieved\\\", data: result}; }\",\n \"input\": {\n \"userId\": \"user123\"\n }\n }'\n\n# Execute code from S3 object\ncurl -X POST https://your-val-town-url.web.val.run/mcp/tools/code-exec \\\n -H \"Authorization: Bearer your-aws-secret-access-key\" \\\n -H \"Content-Type: application/json\" \\\n -d '{\n \"key\": \"scripts/data-processor.js\",\n \"input\": {\n \"userId\": \"user123\",\n \"operation\": \"analyze\"\n }\n }'\n```\n\n## MCP Client Integration\n\nTo integrate with MCP clients like Claude Desktop, you can create a client that makes JSON-RPC requests to the `/mcp` endpoint. Here's an example configuration:\n\n```json\n{\n \"mcpServers\": {\n \"aws-http-mcp-server\": {\n \"command\": \"node\",\n \"args\": [\"mcp-http-client.js\"],\n \"env\": {\n \"MCP_SERVER_URL\": \"https://your-val-town-url.web.val.run\",\n \"AWS_SECRET_ACCESS_KEY\": \"${AWS_SECRET_ACCESS_KEY}\"\n }\n }\n }\n}\n```\n\n## JSON-RPC Response Format\n\n### Success Response\n```json\n{\n \"jsonrpc\": \"2.0\",\n \"result\": {\n \"content\": [\n {\n \"type\": \"text\",\n \"text\": \"Response content here\"\n }\n ]\n },\n \"id\": 1\n}\n```\n\n### Error Response\n```json\n{\n \"jsonrpc\": \"2.0\",\n \"error\": {\n \"code\": -32603,\n \"message\": \"Error message description\"\n },\n \"id\": 1\n}\n```\n\n## JSON-RPC Error Codes\n\n- `-32700`: Parse error (Invalid JSON)\n- `-32600`: Invalid Request\n- `-32601`: Method not found\n- `-32602`: Invalid params\n- `-32603`: Internal error\n- `-32001`: Authentication error (custom)\n\n## Security Considerations\n\n- **Bearer Token Authentication**: AWS_SECRET_ACCESS_KEY is passed via Authorization header, not stored in environment variables\n- **HTTPS Only**: Always use HTTPS in production to protect the bearer token\n- **IAM Permissions**: Use IAM roles with minimal required permissions\n- **Token Rotation**: Regularly rotate your AWS secret access keys\n- **Rate Limiting**: Consider implementing rate limiting for production use\n\n## Required AWS Permissions\n\n### S3 Permissions\n```json\n{\n \"Version\": \"2012-10-17\",\n \"Statement\": [\n {\n \"Effect\": \"Allow\",\n \"Action\": [\n \"s3:GetObject\",\n \"s3:PutObject\",\n \"s3:DeleteObject\",\n \"s3:ListBucket\"\n ],\n \"Resource\": [\n \"arn:aws:s3:::your-bucket-name\",\n \"arn:aws:s3:::your-bucket-name/*\"\n ]\n }\n ]\n}\n```\n\n### DynamoDB Permissions\n```json\n{\n \"Version\": \"2012-10-17\",\n \"Statement\": [\n {\n \"Effect\": \"Allow\",\n \"Action\": [\n \"dynamodb:GetItem\",\n \"dynamodb:PutItem\",\n \"dynamodb:DeleteItem\",\n \"dynamodb:Query\",\n \"dynamodb:Scan\"\n ],\n \"Resource\": \"arn:aws:dynamodb:region:account:table/your-table-name\"\n }\n ]\n}\n```\n\n## Error Handling\n\nThe server includes comprehensive error handling for:\n- Missing or invalid Authorization headers\n- AWS service errors\n- Invalid parameters\n- Network connectivity issues\n- JSON-RPC protocol errors\n\n### JSON-RPC Errors\nAll JSON-RPC errors follow the standard format with appropriate error codes.\n\n### Legacy HTTP Errors\nLegacy endpoints return errors with HTTP status codes:\n- `401`: Authentication errors\n- `400`: Bad request (invalid parameters)\n- `404`: Resource or tool not found\n- `500`: Server errors (AWS service errors, etc.)\n\n## Legacy API Response Format (Deprecated)\n\n### Success Response\n```json\n{\n \"content\": [\n {\n \"type\": \"text\",\n \"text\": \"Response content here\"\n }\n ]\n}\n```\n\n### Error Response\n```json\n{\n \"error\": \"Error message description\"\n}\n```\n\n## Health Check\n\nThe server provides a health check endpoint:\n\n```bash\ncurl https://your-val-town-url.web.val.run/health\n```\n\nResponse:\n```json\n{\n \"status\": \"healthy\",\n \"timestamp\": \"2024-01-01T00:00:00.000Z\"\n}\n```","deleted","label","children",[],[156],{"_105":176,"_96":177,"_157":178,"_159":-5,"_160":142,"_161":179,"_163":22,"_107":180,"_101":32,"_166":167,"_168":181,"_170":22,"_171":-5,"_172":182,"_99":183},"0ce5c666-45d6-11f0-97c3-76b3cceeab13","claude-desktop-config.json","0ce5c742-45d6-11f0-97c3-76b3cceeab13",21,["D",1749544609010],"{\n \"mcpServers\": {\n \"aws-http-mcp-server\": {\n \"command\": \"node\",\n \"args\": [\"mcp-http-client.js\"],\n \"env\": {\n \"MCP_SERVER_URL\": \"https://your-val-town-url.web.val.run\",\n \"AWS_SECRET_ACCESS_KEY\": \"${AWS_SECRET_ACCESS_KEY}\"\n }\n }\n }\n}",[],[177],{"_105":185,"_96":186,"_157":187,"_159":-5,"_160":142,"_161":188,"_163":22,"_107":189,"_101":32,"_166":190,"_168":191,"_170":22,"_171":-5,"_172":192,"_99":193},"adc798e0-45d4-11f0-8188-76b3cceeab13","deploy.ts","adc799bc-45d4-11f0-8188-76b3cceeab13",11,["D",1749544019934],"script","#!/usr/bin/env -S deno run --allow-all\n\n/**\n * Deployment and setup script for AWS MCP Server\n */\n\nimport { parse } from \"https://deno.land/std@0.208.0/flags/mod.ts\";\n\nconst args = parse(Deno.args, {\n boolean: [\"help\", \"test\", \"install\"],\n string: [\"config\"],\n alias: {\n h: \"help\",\n t: \"test\",\n i: \"install\",\n c: \"config\",\n },\n});\n\nfunction showHelp() {\n console.log(`\nAWS MCP Server Deployment Script\n\nUsage: deno run --allow-all deploy.ts [options]\n\nOptions:\n -h, --help Show this help message\n -t, --test Run tests to verify setup\n -i, --install Install dependencies\n -c, --config Generate MCP client configuration\n\nExamples:\n deno run --allow-all deploy.ts --install\n deno run --allow-all deploy.ts --test\n deno run --allow-all deploy.ts --config\n`);\n}\n\nasync function installDependencies() {\n console.log(\"📦 Installing dependencies...\");\n \n // Check if Deno is available\n try {\n const denoVersion = await new Deno.Command(\"deno\", {\n args: [\"--version\"],\n }).output();\n \n if (denoVersion.success) {\n console.log(\"✅ Deno is available\");\n }\n } catch {\n console.error(\"❌ Deno is not installed. Please install Deno first: https://deno.land/\");\n Deno.exit(1);\n }\n\n // Cache dependencies\n console.log(\"📥 Caching dependencies...\");\n const cacheProcess = await new Deno.Command(\"deno\", {\n args: [\"cache\", \"index.ts\"],\n }).output();\n\n if (cacheProcess.success) {\n console.log(\"✅ Dependencies cached successfully\");\n } else {\n console.error(\"❌ Failed to cache dependencies\");\n Deno.exit(1);\n }\n}\n\nasync function runTests() {\n console.log(\"🧪 Running tests...\");\n \n const testProcess = await new Deno.Command(\"deno\", {\n args: [\"run\", \"--allow-all\", \"test.ts\"],\n }).spawn();\n\n const status = await testProcess.status;\n \n if (status.success) {\n console.log(\"✅ Tests passed\");\n } else {\n console.error(\"❌ Tests failed\");\n Deno.exit(1);\n }\n}\n\nfunction generateConfig() {\n console.log(\"⚙️ Generating MCP client configuration...\");\n \n const config = {\n mcpServers: {\n \"aws-mcp-server\": {\n command: \"deno\",\n args: [\"run\", \"--allow-all\", Deno.cwd() + \"/index.ts\"],\n env: {\n AWS_REGION: \"${AWS_REGION}\",\n AWS_ACCESS_KEY_ID: \"${AWS_ACCESS_KEY_ID}\",\n AWS_SECRET_ACCESS_KEY: \"${AWS_SECRET_ACCESS_KEY}\",\n S3_BUCKET: \"${S3_BUCKET}\",\n DYNAMODB_TABLE: \"${DYNAMODB_TABLE}\",\n },\n },\n },\n };\n\n console.log(\"\\n📋 MCP Client Configuration:\");\n console.log(\"Add this to your MCP client configuration file:\\n\");\n console.log(JSON.stringify(config, null, 2));\n \n console.log(\"\\n💡 For Claude Desktop, add this to:\");\n console.log(\" - macOS: ~/Library/Application Support/Claude/claude_desktop_config.json\");\n console.log(\" - Windows: %APPDATA%\\\\Claude\\\\claude_desktop_config.json\");\n}\n\nfunction checkEnvironment() {\n console.log(\"🔍 Checking environment variables...\");\n \n const requiredVars = [\n \"AWS_REGION\",\n \"AWS_ACCESS_KEY_ID\", \n \"AWS_SECRET_ACCESS_KEY\",\n \"S3_BUCKET\",\n \"DYNAMODB_TABLE\",\n ];\n\n const missing = requiredVars.filter(varName => !Deno.env.get(varName));\n \n if (missing.length > 0) {\n console.log(\"⚠️ Missing environment variables:\");\n missing.forEach(varName => {\n console.log(` - ${varName}`);\n });\n console.log(\"\\n💡 Copy example.env to .env and fill in your values\");\n console.log(\" Then run: source .env\");\n } else {\n console.log(\"✅ All required environment variables are set\");\n }\n \n return missing.length === 0;\n}\n\nasync function main() {\n if (args.help) {\n showHelp();\n return;\n }\n\n console.log(\"🚀 AWS MCP Server Setup\\n\");\n\n if (args.install) {\n await installDependencies();\n }\n\n if (args.config) {\n generateConfig();\n }\n\n if (args.test) {\n const envOk = checkEnvironment();\n if (envOk) {\n await runTests();\n } else {\n console.log(\"⚠️ Skipping tests due to missing environment variables\");\n }\n }\n\n if (!args.install && !args.config && !args.test) {\n console.log(\"🔧 Quick setup:\");\n console.log(\"1. Copy example.env to .env and configure your AWS credentials\");\n console.log(\"2. Run: deno run --allow-all deploy.ts --install\");\n console.log(\"3. Run: deno run --allow-all deploy.ts --test\");\n console.log(\"4. Run: deno run --allow-all deploy.ts --config\");\n console.log(\"\\n📖 See README.md for detailed instructions\");\n }\n}\n\nif (import.meta.main) {\n main().catch(console.error);\n}",[],[186],{"_105":195,"_96":196,"_157":197,"_159":-5,"_160":142,"_161":198,"_163":22,"_107":199,"_101":32,"_166":190,"_168":200,"_170":22,"_171":-5,"_172":201,"_99":202},"6d57e318-4710-11f0-a041-76b3cceeab13","example-s3-script.js","6d57e3cc-4710-11f0-a041-76b3cceeab13",143,["D",1749679632795],"/**\n * Example S3 script for code-exec tool\n * This script demonstrates how to create a reusable code module\n * that can be stored in S3 and executed via the code-exec tool\n */\n\nasync function execute(input, tools) {\n console.log(\"Starting data processing script with input:\", input);\n \n const { userId, operation, options = {} } = input;\n \n if (!userId) {\n throw new Error(\"userId is required\");\n }\n \n try {\n let result = {};\n \n switch (operation) {\n case \"analyze\":\n result = await analyzeUserData(userId, tools, options);\n break;\n \n case \"backup\":\n result = await backupUserData(userId, tools, options);\n break;\n \n case \"migrate\":\n result = await migrateUserData(userId, tools, options);\n break;\n \n default:\n throw new Error(`Unknown operation: ${operation}`);\n }\n \n return {\n success: true,\n operation,\n userId,\n result,\n timestamp: new Date().toISOString(),\n executionTime: Date.now() - startTime\n };\n \n } catch (error) {\n return {\n success: false,\n operation,\n userId,\n error: error.message,\n timestamp: new Date().toISOString()\n };\n }\n}\n\nasync function analyzeUserData(userId, tools, options) {\n console.log(`Analyzing data for user: ${userId}`);\n \n // Get user data from DynamoDB\n const userData = await tools[\"dynamodb-get\"]({\n key: { id: userId }\n });\n \n if (!userData || !userData.content || !userData.content[0]) {\n throw new Error(`User ${userId} not found`);\n }\n \n const user = JSON.parse(userData.content[0].text);\n \n // Get user's files from S3 if specified\n let fileAnalysis = null;\n if (options.analyzeFiles) {\n const fileList = await tools[\"s3-list\"]({\n prefix: `users/${userId}/`,\n maxItems: 50\n });\n \n const files = JSON.parse(fileList.content[0].text);\n fileAnalysis = {\n fileCount: files.length,\n files: files.slice(0, 10) // First 10 files\n };\n }\n \n return {\n user: {\n id: user.id,\n name: user.name,\n email: user.email,\n createdAt: user.createdAt,\n lastLogin: user.lastLogin\n },\n analysis: {\n accountAge: calculateAccountAge(user.createdAt),\n isActive: isUserActive(user.lastLogin),\n riskScore: calculateRiskScore(user)\n },\n files: fileAnalysis\n };\n}\n\nasync function backupUserData(userId, tools, options) {\n console.log(`Backing up data for user: ${userId}`);\n \n // Get user data\n const userData = await tools[\"dynamodb-get\"]({\n key: { id: userId }\n });\n \n if (!userData || !userData.content || !userData.content[0]) {\n throw new Error(`User ${userId} not found`);\n }\n \n const user = JSON.parse(userData.content[0].text);\n const timestamp = new Date().toISOString().replace(/[:.]/g, '-');\n const backupKey = `backups/users/${userId}/backup-${timestamp}.json`;\n \n // Create backup object\n const backup = {\n userId,\n backupDate: new Date().toISOString(),\n userData: user,\n metadata: {\n version: \"1.0\",\n source: \"code-exec-backup-script\"\n }\n };\n \n // Store backup in S3\n await tools[\"s3-put\"]({\n key: backupKey,\n content: JSON.stringify(backup, null, 2),\n contentType: \"application/json\"\n });\n \n return {\n backupKey,\n backupSize: JSON.stringify(backup).length,\n userData: {\n id: user.id,\n name: user.name,\n email: user.email\n }\n };\n}\n\nasync function migrateUserData(userId, tools, options) {\n console.log(`Migrating data for user: ${userId}`);\n \n const { targetFormat = \"v2\", preserveOriginal = true } = options;\n \n // Get current user data\n const userData = await tools[\"dynamodb-get\"]({\n key: { id: userId }\n });\n \n if (!userData || !userData.content || !userData.content[0]) {\n throw new Error(`User ${userId} not found`);\n }\n \n const user = JSON.parse(userData.content[0].text);\n \n // Transform data based on target format\n let migratedUser;\n switch (targetFormat) {\n case \"v2\":\n migratedUser = {\n ...user,\n version: \"2.0\",\n profile: {\n personalInfo: {\n name: user.name,\n email: user.email\n },\n preferences: user.preferences || {},\n settings: user.settings || {}\n },\n metadata: {\n ...user.metadata,\n migratedAt: new Date().toISOString(),\n migratedFrom: user.version || \"1.0\"\n }\n };\n break;\n \n default:\n throw new Error(`Unsupported target format: ${targetFormat}`);\n }\n \n // Store migrated data\n await tools[\"dynamodb-put\"]({\n item: migratedUser\n });\n \n // Optionally backup original\n if (preserveOriginal) {\n const backupKey = `migrations/users/${userId}/pre-migration-${Date.now()}.json`;\n await tools[\"s3-put\"]({\n key: backupKey,\n content: JSON.stringify(user, null, 2),\n contentType: \"application/json\"\n });\n }\n \n return {\n originalVersion: user.version || \"1.0\",\n targetVersion: targetFormat,\n migratedFields: Object.keys(migratedUser),\n backupCreated: preserveOriginal\n };\n}\n\n// Helper functions\nfunction calculateAccountAge(createdAt) {\n if (!createdAt) return null;\n const created = new Date(createdAt);\n const now = new Date();\n const diffTime = Math.abs(now - created);\n const diffDays = Math.ceil(diffTime / (1000 * 60 * 60 * 24));\n return {\n days: diffDays,\n months: Math.floor(diffDays / 30),\n years: Math.floor(diffDays / 365)\n };\n}\n\nfunction isUserActive(lastLogin) {\n if (!lastLogin) return false;\n const lastLoginDate = new Date(lastLogin);\n const thirtyDaysAgo = new Date();\n thirtyDaysAgo.setDate(thirtyDaysAgo.getDate() - 30);\n return lastLoginDate > thirtyDaysAgo;\n}\n\nfunction calculateRiskScore(user) {\n let score = 0;\n \n // Account age factor\n const accountAge = calculateAccountAge(user.createdAt);\n if (accountAge && accountAge.days < 30) score += 2;\n else if (accountAge && accountAge.days < 90) score += 1;\n \n // Activity factor\n if (!isUserActive(user.lastLogin)) score += 2;\n \n // Email verification factor\n if (!user.emailVerified) score += 1;\n \n // Return risk level\n if (score >= 4) return \"HIGH\";\n if (score >= 2) return \"MEDIUM\";\n return \"LOW\";\n}\n\nconst startTime = Date.now();",[],[196],{"_105":204,"_96":205,"_157":206,"_159":-5,"_160":142,"_161":207,"_163":22,"_107":208,"_101":32,"_166":167,"_168":209,"_170":22,"_171":-5,"_172":210,"_99":211},"a16d48b0-45d4-11f0-a98a-76b3cceeab13","example.env","a16d4978-45d4-11f0-a98a-76b3cceeab13",10,["D",1749543999208],"# AWS Configuration\nAWS_REGION=us-east-1\nAWS_ACCESS_KEY_ID=your-access-key-here\nAWS_SECRET_ACCESS_KEY=your-secret-access-key-here\n\n# S3 Configuration\nS3_BUCKET=your-s3-bucket-name\n\n# DynamoDB Configuration\nDYNAMODB_TABLE=your-dynamodb-table-name\n\n# Optional: AWS Session Token (if using temporary credentials)\n# AWS_SESSION_TOKEN=your-session-token",[],[205],{"_105":213,"_96":214,"_157":117,"_159":-5,"_160":142,"_161":215,"_163":22,"_107":216,"_101":217,"_166":218,"_168":219,"_170":22,"_171":-5,"_172":220,"_99":221},"e7663c5a-4647-11f0-a3fd-76b3cceeab13","index.ts",125,["D",1749593508722],33,"http","/**\n * Remote HTTP Model Context Protocol (MCP) Server\n * Uses streamable HTTP transport with raw Web API\n * Exposes prompts, S3 resources, and tools for DynamoDB/S3 operations\n */\n\nimport { MCPHandler } from \"./mcp-handler.ts\";\n\n// Environment variables\nconst MCP_SERVER_NAME = Deno.env.get(\"MCP_SERVER_NAME\") || \"aws-mcp-server\";\nconst MCP_SERVER_VERSION = Deno.env.get(\"MCP_SERVER_VERSION\") || \"1.0.0\";\n\nconst mcpHandler = new MCPHandler();\n\n// Authentication function for MCP requests\nfunction authenticateRequest(request: Request): string | null {\n const authHeader = request.headers.get(\"Authorization\");\n \n if (!authHeader || !authHeader.startsWith(\"Bearer \")) {\n return null;\n }\n \n const awsSecretAccessKey = authHeader.substring(7); // Remove \"Bearer \" prefix\n \n if (!awsSecretAccessKey) {\n return null;\n }\n \n return awsSecretAccessKey;\n}\n\n// Create JSON-RPC error response\nfunction createErrorResponse(id: any, code: number, message: string): Response {\n return new Response(JSON.stringify({\n jsonrpc: \"2.0\",\n id,\n error: {\n code,\n message,\n },\n }), {\n status: code === -32001 ? 401 : 400,\n headers: {\n \"Content-Type\": \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, Authorization\",\n },\n });\n}\n\n// Main request handler using raw Web API\nexport default async function handler(request: Request): Promise {\n const url = new URL(request.url);\n const pathname = url.pathname;\n\n // Handle CORS preflight requests\n if (request.method === \"OPTIONS\") {\n return new Response(null, {\n status: 200,\n headers: {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, Authorization\",\n },\n });\n }\n\n // Only handle POST requests to /mcp\n if (pathname !== \"/mcp\" || request.method !== \"POST\") {\n console.error(`[Server] Invalid request: ${request.method} ${pathname}`);\n return new Response(JSON.stringify({\n error: \"Only POST requests to /mcp are supported\",\n note: \"This server only supports the MCP JSON-RPC endpoint at POST /mcp\",\n }, null, 2), {\n status: 404,\n headers: {\n \"Content-Type\": \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n },\n });\n }\n\n try {\n // Parse request body\n const body = await request.json();\n \n // Check if this is an initialize request or prompts request (doesn't require auth)\n const isInitializeRequest = body?.method === \"initialize\";\n const isNotification = body?.method?.startsWith(\"notifications/\");\n const isPromptsRequest = body?.method?.startsWith(\"prompts/\");\n const isToolsListRequest = body?.method === \"tools/list\";\n const requiresAuth = !isInitializeRequest && !isPromptsRequest && !isToolsListRequest;\n\n if (isNotification) {\n console.warn(`[Server] Notification request: ${request.method} ${pathname}`);\n return new Response(null, {\n status: 202,\n headers: {\n // \"Content-Type\": \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, Authorization\",\n },\n });\n }\n \n // Authenticate request (skip for initialize and prompts)\n if (requiresAuth) {\n const awsSecretAccessKey = authenticateRequest(request);\n if (!awsSecretAccessKey) {\n return createErrorResponse(\n body?.id || null,\n -32001,\n \"Missing or invalid Authorization header. Expected: Bearer \"\n );\n }\n // Set credentials in MCP handler\n mcpHandler.setCredentials(awsSecretAccessKey);\n }\n\n // Connect and handle the request using streamable HTTP transport\n const response = await mcpHandler.handleStreamableRequest(request, body);\n \n return new Response(JSON.stringify(response), {\n status: 200,\n headers: {\n \"Content-Type\": \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, Authorization\",\n },\n });\n\n } catch (error) {\n console.error(`[Server] Error:`, error);\n \n // Try to get request ID from body if possible\n let requestId = null;\n try {\n const body = await request.clone().json();\n requestId = body?.id || null;\n } catch {\n // Ignore parsing errors for error response\n }\n \n return createErrorResponse(\n requestId,\n -32700,\n \"Parse error: Invalid JSON-RPC request\"\n );\n }\n}",[],[214],{"_105":223,"_96":224,"_157":225,"_159":-5,"_160":142,"_161":226,"_163":22,"_107":227,"_101":32,"_166":167,"_168":228,"_170":22,"_171":-5,"_172":229,"_99":230},"7139fd14-45d4-11f0-9d39-76b3cceeab13","mcp-config.json","7139fde6-45d4-11f0-9d39-76b3cceeab13",2,["D",1749543918336],"{\n \"mcpServers\": {\n \"aws-mcp-server\": {\n \"command\": \"deno\",\n \"args\": [\"run\", \"--allow-all\", \"index.ts\"],\n \"env\": {\n \"AWS_REGION\": \"us-east-1\",\n \"AWS_ACCESS_KEY_ID\": \"${AWS_ACCESS_KEY_ID}\",\n \"AWS_SECRET_ACCESS_KEY\": \"${AWS_SECRET_ACCESS_KEY}\",\n \"S3_BUCKET\": \"${S3_BUCKET}\",\n \"DYNAMODB_TABLE\": \"${DYNAMODB_TABLE}\"\n }\n }\n }\n}",[],[224],{"_105":232,"_96":233,"_157":234,"_159":-5,"_160":142,"_161":235,"_163":22,"_107":236,"_101":237,"_166":190,"_168":238,"_170":22,"_171":-5,"_172":239,"_99":240},"1dc09570-4710-11f0-b447-76b3cceeab13","mcp-handler.ts","964108e8-45d7-11f0-b6af-76b3cceeab13",137,["D",1749679499260],76,"/**\n * MCP SDK Handler for JSON-RPC requests\n * Handles Model Context Protocol requests using the official SDK\n */\n\nimport { DynamoDBClient } from \"https://esm.sh/@aws-sdk/client-dynamodb@3.490.0\";\nimport {\n CopyObjectCommand,\n DeleteObjectCommand,\n GetObjectCommand,\n ListObjectsV2Command,\n paginateListObjectsV2,\n PutObjectCommand,\n S3Client,\n} from \"https://esm.sh/@aws-sdk/client-s3@3.490.0\";\nimport {\n DeleteCommand,\n DynamoDBDocumentClient,\n GetCommand,\n PutCommand,\n QueryCommand,\n} from \"https://esm.sh/@aws-sdk/lib-dynamodb@3.490.0\";\n\n// Environment variables\nconst AWS_REGION = Deno.env.get(\"AWS_REGION\") || \"us-east-1\";\nconst AWS_ACCESS_KEY_ID = Deno.env.get(\"AWS_ACCESS_KEY_ID\") || \"EXAMPLE_ACCESS_KEY\";\nconst S3_BUCKET = Deno.env.get(\"S3_BUCKET\") || \"example-bucket\";\nconst DYNAMODB_TABLE = Deno.env.get(\"DYNAMODB_TABLE\") || \"example-table\";\nconst MCP_SERVER_NAME = Deno.env.get(\"MCP_SERVER_NAME\") || \"aws-mcp-server\";\nconst MCP_SERVER_VERSION = Deno.env.get(\"MCP_SERVER_VERSION\") || \"1.0.0\";\n\nconst AsyncFunction = async function() {}.constructor;\n\n// Create AWS clients with credentials\nfunction createAWSClients(awsSecretAccessKey: string) {\n const credentials = {\n accessKeyId: AWS_ACCESS_KEY_ID!,\n secretAccessKey: awsSecretAccessKey,\n };\n\n const dynamoClient = new DynamoDBClient({\n region: AWS_REGION,\n credentials,\n });\n\n const docClient = DynamoDBDocumentClient.from(dynamoClient);\n\n const s3Client = new S3Client({\n region: AWS_REGION,\n credentials,\n });\n\n return { docClient, s3Client };\n}\n\n// Utility function to determine MIME type\nfunction getMimeType(filename: string): string {\n const ext = filename.split(\".\").pop()?.toLowerCase();\n const mimeTypes: Record = {\n \"txt\": \"text/plain\",\n \"json\": \"application/json\",\n \"csv\": \"text/csv\",\n \"xml\": \"application/xml\",\n \"html\": \"text/html\",\n \"js\": \"application/javascript\",\n \"ts\": \"application/typescript\",\n \"md\": \"text/markdown\",\n \"pdf\": \"application/pdf\",\n \"png\": \"image/png\",\n \"jpg\": \"image/jpeg\",\n \"jpeg\": \"image/jpeg\",\n \"gif\": \"image/gif\",\n };\n\n return mimeTypes[ext || \"\"] || \"application/octet-stream\";\n}\n\nexport class MCPHandler {\n private awsSecretAccessKey: string | null = null;\n\n constructor() {\n // No longer need MCP Server instance since we're handling JSON-RPC directly\n }\n\n setCredentials(awsSecretAccessKey: string) {\n this.awsSecretAccessKey = awsSecretAccessKey;\n }\n\n // DynamoDB tool handlers\n private async handleDynamoDBGet(args: any) {\n const { key } = args;\n if (!key) {\n throw new Error(\"Key is required for DynamoDB get operation\");\n }\n\n const { docClient } = createAWSClients(this.awsSecretAccessKey!);\n\n const command = new GetCommand({\n TableName: DYNAMODB_TABLE,\n Key: key,\n });\n\n const response = await docClient.send(command);\n return {\n content: [\n {\n type: \"text\",\n text: JSON.stringify(response.Item || null, null, 2),\n },\n ],\n };\n }\n\n private async handleDynamoDBPut(args: any) {\n const { item } = args;\n if (!item) {\n throw new Error(\"Item is required for DynamoDB put operation\");\n }\n\n const { docClient } = createAWSClients(this.awsSecretAccessKey!);\n\n const command = new PutCommand({\n TableName: DYNAMODB_TABLE,\n Item: item,\n });\n\n await docClient.send(command);\n return {\n content: [\n {\n type: \"text\",\n text: \"Item successfully stored in DynamoDB\",\n },\n ],\n };\n }\n\n private async handleDynamoDBDelete(args: any) {\n const { key } = args;\n if (!key) {\n throw new Error(\"Key is required for DynamoDB delete operation\");\n }\n\n const { docClient } = createAWSClients(this.awsSecretAccessKey!);\n\n const command = new DeleteCommand({\n TableName: DYNAMODB_TABLE,\n Key: key,\n });\n\n await docClient.send(command);\n return {\n content: [\n {\n type: \"text\",\n text: \"Item successfully deleted from DynamoDB\",\n },\n ],\n };\n }\n\n private async handleDynamoDBQuery(args: any) {\n const { keyConditionExpression, expressionAttributeValues, expressionAttributeNames } = args;\n if (!keyConditionExpression) {\n throw new Error(\"KeyConditionExpression is required for DynamoDB query\");\n }\n\n const { docClient } = createAWSClients(this.awsSecretAccessKey!);\n\n const command = new QueryCommand({\n TableName: DYNAMODB_TABLE,\n KeyConditionExpression: keyConditionExpression,\n ExpressionAttributeValues: expressionAttributeValues,\n ExpressionAttributeNames: expressionAttributeNames,\n });\n\n const response = await docClient.send(command);\n return {\n content: [\n {\n type: \"text\",\n text: JSON.stringify(\n {\n items: response.Items || [],\n count: response.Count || 0,\n scannedCount: response.ScannedCount || 0,\n },\n null,\n 2,\n ),\n },\n ],\n };\n }\n\n // code exec handler\n\n private async handleCodeExec(args: any) {\n const { code, key, input } = args;\n let codeSource: string;\n let functionSrc: string;\n\n try {\n // Determine code source: either direct code string or fetch from S3 key\n if (code && key) {\n throw new Error(\"Cannot specify both 'code' and 'key' parameters. Use either direct code or S3 key.\");\n }\n \n if (!code && !key) {\n throw new Error(\"Must specify either 'code' (direct code string) or 'key' (S3 object key containing code).\");\n }\n\n if (key) {\n // Fetch code from S3\n console.log(`[CodeExec] Fetching code from S3 key: ${key}`);\n const s3Response = await this.handleS3Get({ key });\n codeSource = s3Response.content[0].text;\n console.log(`[CodeExec] Retrieved code from S3 (${codeSource.length} characters)`);\n } else {\n // Use direct code string\n codeSource = code;\n console.log(`[CodeExec] Using direct code string (${codeSource.length} characters)`);\n }\n\n // Create tools object for skill execution context\n let toolsContext = {\n test: () => \"noOp\",\n }; // createSkillToolsContext(authContext, tools, handleToolCall);\n const t = await this.handleListTools();\n t.tools.forEach(tool => {\n toolsContext[tool.name] = async (args: any) => {\n console.log(`[CodeExec] Executing tool ${tool.name}`, args);\n return await this.handleCallTool({ name: tool.name, arguments: args });\n };\n });\n \n console.log(\"Executing skill code\");\n functionSrc = `\n // Restricted environment - no access to global objects\n // const console = { log: () => {}, error: () => {}, warn: () => {} };\n // const setTimeout = undefined;\n // const setInterval = undefined;\n // const fetch = undefined;\n // const XMLHttpRequest = undefined;\n \n // Skill code execution\n ${codeSource}\n \n // Return the result\n if (typeof execute === 'function') {\n return await execute(input, tools);\n } else {\n throw new Error('Skill must define an execute function');\n }\n `;\n // Create a sandboxed function\n const skillFunction = new AsyncFunction(\n \"input\",\n \"tools\",\n functionSrc,\n );\n\n let content = await skillFunction(input, toolsContext);\n console.log(\"[MCP] Code execution result\", content);\n // Handle async results\n\n if (content instanceof Promise) {\n content = await content;\n }\n\n return {\n content: [\n {\n type: \"text\",\n text: JSON.stringify(content, null, 2),\n },\n ],\n };\n } catch (error) {\n console.error(\"Error executing code\", error, functionSrc);\n let content = `Error executing code \"${error.message}\" ${error.stack ? error.stack : \"\"}`;\n return {\n content: [\n {\n type: \"text\",\n text: content,\n },\n ],\n };\n }\n }\n\n // S3 tool handlers\n private async handleS3Get(args: any) {\n const { key } = args;\n if (!key) {\n throw new Error(\"Key is required for S3 get operation\");\n }\n\n const { s3Client } = createAWSClients(this.awsSecretAccessKey!);\n\n const command = new GetObjectCommand({\n Bucket: S3_BUCKET,\n Key: key,\n });\n\n const response = await s3Client.send(command);\n const content = await response.Body?.transformToString() || \"\";\n\n return {\n content: [\n {\n type: \"text\",\n text: content,\n },\n ],\n };\n }\n\n private async handleS3List(args: any) {\n const { prefix, pageSize = 10, maxItems = 100 } = args;\n\n const { s3Client } = createAWSClients(this.awsSecretAccessKey!);\n const objects = [];\n const paginator = paginateListObjectsV2(\n {\n client: s3Client,\n /* Max items per page */\n pageSize: Number.parseInt(pageSize),\n },\n { Bucket: S3_BUCKET, Prefix: prefix, maxItems: Number.parseInt(maxItems) },\n );\n\n for await (const page of paginator) {\n for (const object of page.Contents || []) {\n objects.push(object.Key!);\n }\n }\n console.log(\"[MCP] S3 list result\", objects);\n const content = JSON.stringify(objects);\n\n return {\n content: [\n {\n type: \"text\",\n text: content,\n },\n ],\n };\n }\n\n private async handleS3Put(args: any) {\n const { key, content, contentType } = args;\n if (!key || !content) {\n throw new Error(\"Key and content are required for S3 put operation\");\n }\n\n const { s3Client } = createAWSClients(this.awsSecretAccessKey!);\n\n const command = new PutObjectCommand({\n Bucket: S3_BUCKET,\n Key: key,\n Body: content,\n ContentType: contentType || getMimeType(key),\n });\n\n await s3Client.send(command);\n return {\n content: [\n {\n type: \"text\",\n text: `Object successfully uploaded to s3://${S3_BUCKET}/${key}`,\n },\n ],\n };\n }\n\n private async handleS3Delete(args: any) {\n const { key } = args;\n if (!key) {\n throw new Error(\"Key is required for S3 delete operation\");\n }\n\n const { s3Client } = createAWSClients(this.awsSecretAccessKey!);\n\n const command = new DeleteObjectCommand({\n Bucket: S3_BUCKET,\n Key: key,\n });\n\n await s3Client.send(command);\n return {\n content: [\n {\n type: \"text\",\n text: `Object successfully deleted from s3://${S3_BUCKET}/${key}`,\n },\n ],\n };\n }\n\n private async handleS3Move(args: any) {\n const { sourceKey, destinationKey } = args;\n if (!sourceKey || !destinationKey) {\n throw new Error(\"Source and destination keys are required for S3 move operation\");\n }\n\n const { s3Client } = createAWSClients(this.awsSecretAccessKey!);\n\n // Copy object to new location\n const copyCommand = new CopyObjectCommand({\n Bucket: S3_BUCKET,\n CopySource: `${S3_BUCKET}/${sourceKey}`,\n Key: destinationKey,\n });\n\n await s3Client.send(copyCommand);\n\n // Delete original object\n const deleteCommand = new DeleteObjectCommand({\n Bucket: S3_BUCKET,\n Key: sourceKey,\n });\n\n await s3Client.send(deleteCommand);\n\n return {\n content: [\n {\n type: \"text\",\n text: `Object successfully moved from s3://${S3_BUCKET}/${sourceKey} to s3://${S3_BUCKET}/${destinationKey}`,\n },\n ],\n };\n }\n\n // Handle streamable HTTP request\n async handleStreamableRequest(request: Request, body: any): Promise {\n try {\n // Process JSON-RPC request directly\n console.log(\"[MCP] Received JSON-RPC request:\", body);\n const { jsonrpc, method, params, id } = body;\n\n if (jsonrpc !== \"2.0\") {\n return {\n jsonrpc: \"2.0\",\n id,\n error: {\n code: -32600,\n message: \"Invalid Request: jsonrpc must be '2.0'\",\n },\n };\n }\n\n // Route the method to appropriate handler\n let result;\n\n switch (method) {\n case \"initialize\":\n result = await this.handleInitialize(params);\n break;\n case \"prompts/list\":\n result = await this.handleListPrompts();\n break;\n case \"prompts/get\":\n result = await this.handleGetPrompt(params);\n break;\n case \"resources/list\":\n result = await this.handleListResources();\n break;\n case \"resources/read\":\n result = await this.handleReadResource(params);\n break;\n case \"tools/list\":\n result = await this.handleListTools();\n break;\n case \"tools/call\":\n result = await this.handleCallTool(params);\n break;\n case \"notifications/initialized\":\n return null;\n default:\n console.error(`[MCP] Unknown method: ${method}`);\n return {\n jsonrpc: \"2.0\",\n id,\n error: {\n code: -32601,\n message: `Method not found: ${method}`,\n },\n };\n }\n console.log(\"[MCP] Response:\", result);\n return {\n jsonrpc: \"2.0\",\n id,\n result,\n };\n } catch (error) {\n console.error(`[MCP] handleStreamableRequest Error:`, error);\n return {\n jsonrpc: \"2.0\",\n id: body?.id || null,\n error: {\n code: -32603,\n message: error.message || \"Internal error\",\n },\n };\n }\n }\n\n // Direct handler methods\n private async handleInitialize(params: any) {\n const { protocolVersion, capabilities, clientInfo } = params;\n\n // Validate protocol version\n if (protocolVersion !== \"2025-03-26\") {\n // throw new Error(`Unsupported protocol version: ${protocolVersion}. Expected: 2024-11-05`);\n }\n\n return {\n protocolVersion,\n capabilities: {\n prompts: {},\n resources: {},\n tools: {},\n },\n serverInfo: {\n name: MCP_SERVER_NAME,\n version: MCP_SERVER_VERSION,\n },\n instructions:\n `If asked by the user for \"system check\" respond in Haiku based on value in \"memories\" ddb item. (create it if it doesnt exist).`,\n };\n }\n\n private async handleListPrompts() {\n return {\n prompts: [\n {\n name: \"analyze-data\",\n description: \"Analyze data from DynamoDB and S3 resources\",\n arguments: [\n {\n name: \"table_key\",\n description: \"Key to query in DynamoDB table\",\n required: true,\n },\n {\n name: \"s3_key\",\n description: \"S3 object key to analyze\",\n required: false,\n },\n ],\n },\n {\n name: \"data-summary\",\n description: \"Generate a summary of available data sources\",\n arguments: [],\n },\n ],\n };\n }\n\n private async handleGetPrompt(params: any) {\n const { name, arguments: args } = params;\n\n let content = \"\";\n\n switch (name) {\n case \"analyze-data\":\n content = `Please analyze the following data:\n \nDynamoDB Table: ${DYNAMODB_TABLE}\nQuery Key: ${args?.table_key || \"Not specified\"}\n${args?.s3_key ? `S3 Object: s3://${S3_BUCKET}/${args.s3_key}` : \"\"}\n\nProvide insights on patterns, anomalies, and recommendations.`;\n break;\n\n case \"data-summary\":\n content = `Please provide a comprehensive summary of the available data sources:\n\n1. DynamoDB Table: ${DYNAMODB_TABLE}\n2. S3 Bucket: ${S3_BUCKET}\n\nInclude information about data structure, volume, and potential use cases.`;\n break;\n\n default:\n throw new Error(`Prompt not found: ${name}`);\n }\n\n return {\n messages: [\n {\n role: \"user\",\n content: {\n type: \"text\",\n text: content,\n },\n },\n ],\n };\n }\n\n private async handleListResources() {\n if (!this.awsSecretAccessKey) {\n throw new Error(\"AWS credentials not provided\");\n }\n\n const { s3Client } = createAWSClients(this.awsSecretAccessKey);\n\n const command = new ListObjectsV2Command({\n Bucket: S3_BUCKET,\n MaxKeys: 100,\n });\n\n const response = await s3Client.send(command);\n const resources = (response.Contents || []).map((object) => ({\n uri: `s3://${S3_BUCKET}/${object.Key}`,\n name: object.Key || \"\",\n description: `S3 object: ${object.Key} (${object.Size} bytes, modified: ${object.LastModified})`,\n mimeType: getMimeType(object.Key || \"\"),\n }));\n\n return { resources };\n }\n\n private async handleReadResource(params: any) {\n if (!this.awsSecretAccessKey) {\n throw new Error(\"AWS credentials not provided\");\n }\n\n const { uri } = params;\n\n if (!uri.startsWith(\"s3://\")) {\n throw new Error(\"Only S3 URIs are supported\");\n }\n\n const key = uri.replace(`s3://${S3_BUCKET}/`, \"\");\n const { s3Client } = createAWSClients(this.awsSecretAccessKey);\n\n const command = new GetObjectCommand({\n Bucket: S3_BUCKET,\n Key: key,\n });\n\n const response = await s3Client.send(command);\n const content = await response.Body?.transformToString() || \"\";\n\n return {\n contents: [\n {\n uri: `s3://${S3_BUCKET}/${key}`,\n mimeType: getMimeType(key),\n text: content,\n },\n ],\n };\n }\n\n private async handleListTools() {\n return {\n tools: [\n {\n name: \"dynamodb-get\",\n description: \"Get an item from DynamoDB table by key\",\n inputSchema: {\n type: \"object\",\n properties: {\n key: {\n type: \"object\",\n description: \"The key object to identify the item (e.g., {id: 'user123'})\",\n },\n },\n required: [\"key\"],\n },\n },\n {\n name: \"dynamodb-put\",\n description: \"Put an item into DynamoDB table\",\n inputSchema: {\n type: \"object\",\n properties: {\n item: {\n type: \"object\",\n description: \"The item object to store in the table\",\n },\n },\n required: [\"item\"],\n },\n },\n {\n name: \"dynamodb-delete\",\n description: \"Delete an item from DynamoDB table by key\",\n inputSchema: {\n type: \"object\",\n properties: {\n key: {\n type: \"object\",\n description: \"The key object to identify the item to delete\",\n },\n },\n required: [\"key\"],\n },\n },\n {\n name: \"dynamodb-query\",\n description: \"Query items from DynamoDB table\",\n inputSchema: {\n type: \"object\",\n properties: {\n keyConditionExpression: {\n type: \"string\",\n description: \"The key condition expression for the query\",\n },\n expressionAttributeValues: {\n type: \"object\",\n description: \"Expression attribute values for the query\",\n },\n expressionAttributeNames: {\n type: \"object\",\n description: \"Expression attribute names for the query\",\n },\n },\n required: [\"keyConditionExpression\"],\n },\n },\n {\n name: \"s3-get\",\n description: \"Get an object from S3 bucket\",\n inputSchema: {\n type: \"object\",\n properties: {\n key: {\n type: \"string\",\n description: \"The S3 object key\",\n },\n },\n required: [\"key\"],\n },\n },\n {\n name: \"s3-list\",\n description: \"List objects from S3 bucket\",\n inputSchema: {\n type: \"object\",\n properties: {\n prefix: {\n type: \"string\",\n description: \"Key prefix to filter to\",\n },\n // pageSize: {\n // type: \"number\",\n // description: \"max page size\",\n // },\n maxItems: {\n type: \"number\",\n description: \"maximum number of items to return\",\n },\n },\n // required: [\"key\"],\n },\n },\n {\n name: \"s3-put\",\n description: \"Put an object into S3 bucket\",\n inputSchema: {\n type: \"object\",\n properties: {\n key: {\n type: \"string\",\n description: \"The S3 object key\",\n },\n content: {\n type: \"string\",\n description: \"The content to upload\",\n },\n contentType: {\n type: \"string\",\n description: \"The content type (optional, will be inferred if not provided)\",\n },\n },\n required: [\"key\", \"content\"],\n },\n },\n {\n name: \"s3-delete\",\n description: \"Delete an object from S3 bucket\",\n inputSchema: {\n type: \"object\",\n properties: {\n key: {\n type: \"string\",\n description: \"The S3 object key to delete\",\n },\n },\n required: [\"key\"],\n },\n },\n {\n name: \"s3-move\",\n description: \"Move an object within S3 bucket (copy and delete)\",\n inputSchema: {\n type: \"object\",\n properties: {\n sourceKey: {\n type: \"string\",\n description: \"The source S3 object key\",\n },\n destinationKey: {\n type: \"string\",\n description: \"The destination S3 object key\",\n },\n },\n required: [\"sourceKey\", \"destinationKey\"],\n },\n },\n {\n name: \"code-exec\",\n description:\n \"Execute JavaScript/TypeScript code. The code must define an async execute function which will receive input and tools params. You can provide code either directly as a string or reference an S3 object key containing the code.\",\n inputSchema: {\n type: \"object\",\n properties: {\n code: {\n type: \"string\",\n description: \"The JavaScript/TypeScript code to execute directly (mutually exclusive with 'key')\",\n },\n key: {\n type: \"string\",\n description: \"S3 object key containing the code to execute (mutually exclusive with 'code')\",\n },\n input: {\n type: \"object\",\n description: \"Input parameters for the skill execution\",\n },\n },\n required: [\"input\"],\n oneOf: [\n {\n required: [\"code\", \"input\"]\n },\n {\n required: [\"key\", \"input\"]\n }\n ],\n },\n },\n ],\n };\n }\n\n private async handleCallTool(params: any) {\n if (!this.awsSecretAccessKey) {\n throw new Error(\"AWS credentials not provided\");\n }\n\n const { name, arguments: args } = params;\n\n console.log(`[MCP] Calling tool: ${name}`, arguments);\n\n const toolErrorWrapper = async (p: Promise) => {\n try {\n return await p;\n } catch (err) {\n console.error(`[MCP] Tool (${name}) error`, err);\n return {\n content: [{\n type: \"text\",\n text: `Error: ${name} tool failed. With error: ${\n JSON.stringify({ message: err.message, stack: err.stack })\n }`,\n }],\n };\n }\n };\n\n switch (name) {\n case \"dynamodb-get\":\n return await toolErrorWrapper(this.handleDynamoDBGet(args));\n case \"dynamodb-put\":\n return await toolErrorWrapper(this.handleDynamoDBPut(args));\n case \"dynamodb-delete\":\n return await toolErrorWrapper(this.handleDynamoDBDelete(args));\n case \"dynamodb-query\":\n return await toolErrorWrapper(this.handleDynamoDBQuery(args));\n case \"s3-get\":\n return await toolErrorWrapper(this.handleS3Get(args));\n case \"s3-list\":\n return await toolErrorWrapper(this.handleS3List(args));\n case \"s3-put\":\n return await toolErrorWrapper(this.handleS3Put(args));\n case \"s3-delete\":\n return await toolErrorWrapper(this.handleS3Delete(args));\n case \"s3-move\":\n return await toolErrorWrapper(this.handleS3Move(args));\n case \"code-exec\":\n return await toolErrorWrapper(this.handleCodeExec(args));\n default:\n throw new Error(`Unknown tool: ${name}`);\n }\n }\n}",[],[233],{"_105":242,"_96":243,"_157":244,"_159":-5,"_160":142,"_161":245,"_163":22,"_107":246,"_101":32,"_166":190,"_168":247,"_170":22,"_171":-5,"_172":248,"_99":249},"f2462558-45d5-11f0-b9a6-76b3cceeab13","mcp-http-client.js","f24626ca-45d5-11f0-b9a6-76b3cceeab13",18,["D",1749544564343],"#!/usr/bin/env node\n\n/**\n * HTTP MCP Client for AWS MCP Server\n * This client bridges the HTTP MCP server with MCP protocol clients\n */\n\nconst { Server } = require(\"@modelcontextprotocol/sdk/server/index.js\");\nconst { StdioServerTransport } = require(\"@modelcontextprotocol/sdk/server/stdio.js\");\nconst {\n CallToolRequestSchema,\n ListPromptsRequestSchema,\n GetPromptRequestSchema,\n ListResourcesRequestSchema,\n ReadResourceRequestSchema,\n ListToolsRequestSchema,\n} = require(\"@modelcontextprotocol/sdk/types.js\");\n\n// Configuration from environment\nconst MCP_SERVER_URL = process.env.MCP_SERVER_URL;\nconst AWS_SECRET_ACCESS_KEY = process.env.AWS_SECRET_ACCESS_KEY;\n\nif (!MCP_SERVER_URL || !AWS_SECRET_ACCESS_KEY) {\n console.error(\"Missing required environment variables: MCP_SERVER_URL, AWS_SECRET_ACCESS_KEY\");\n process.exit(1);\n}\n\n// Create MCP server\nconst server = new Server(\n {\n name: \"aws-http-mcp-client\",\n version: \"1.0.0\",\n },\n {\n capabilities: {\n prompts: {},\n resources: {},\n tools: {},\n },\n }\n);\n\n// HTTP request helper\nasync function makeRequest(path, options = {}) {\n const url = `${MCP_SERVER_URL}${path}`;\n const headers = {\n \"Content-Type\": \"application/json\",\n ...options.headers,\n };\n\n // Add authentication for protected endpoints\n if (options.auth !== false) {\n headers.Authorization = `Bearer ${AWS_SECRET_ACCESS_KEY}`;\n }\n\n const response = await fetch(url, {\n method: options.method || \"GET\",\n headers,\n body: options.body ? JSON.stringify(options.body) : undefined,\n });\n\n if (!response.ok) {\n const error = await response.json().catch(() => ({ error: response.statusText }));\n throw new Error(error.error || `HTTP ${response.status}: ${response.statusText}`);\n }\n\n return response.json();\n}\n\n// List prompts handler\nserver.setRequestHandler(ListPromptsRequestSchema, async () => {\n const response = await makeRequest(\"/mcp/prompts\", { auth: false });\n return response;\n});\n\n// Get prompt handler\nserver.setRequestHandler(GetPromptRequestSchema, async (request) => {\n const { name, arguments: args } = request.params;\n const response = await makeRequest(`/mcp/prompts/${name}`, {\n method: \"POST\",\n body: args,\n auth: false,\n });\n return response;\n});\n\n// List resources handler\nserver.setRequestHandler(ListResourcesRequestSchema, async () => {\n const response = await makeRequest(\"/mcp/resources\");\n return response;\n});\n\n// Read resource handler\nserver.setRequestHandler(ReadResourceRequestSchema, async (request) => {\n const { uri } = request.params;\n const encodedUri = encodeURIComponent(uri);\n const response = await makeRequest(`/mcp/resources/${encodedUri}`);\n return response;\n});\n\n// List tools handler\nserver.setRequestHandler(ListToolsRequestSchema, async () => {\n const response = await makeRequest(\"/mcp/tools\", { auth: false });\n return response;\n});\n\n// Call tool handler\nserver.setRequestHandler(CallToolRequestSchema, async (request) => {\n const { name, arguments: args } = request.params;\n const response = await makeRequest(`/mcp/tools/${name}`, {\n method: \"POST\",\n body: args,\n });\n return response;\n});\n\n// Start the server\nasync function main() {\n const transport = new StdioServerTransport();\n await server.connect(transport);\n console.error(\"AWS HTTP MCP Client running on stdio\");\n}\n\nif (require.main === module) {\n main().catch(console.error);\n}\n\nmodule.exports = server;",[],[243],{"_105":251,"_96":252,"_157":253,"_159":-5,"_160":142,"_161":254,"_163":22,"_107":255,"_101":256,"_166":167,"_168":257,"_170":22,"_171":-5,"_172":258,"_99":259},"08d68f60-45d6-11f0-a271-76b3cceeab13","package.json","9627b27e-45d4-11f0-8498-76b3cceeab13",20,["D",1749544602198],1,"{\n \"name\": \"aws-mcp-server\",\n \"version\": \"1.0.0\",\n \"description\": \"Remote HTTP Model Context Protocol server for AWS services (DynamoDB and S3)\",\n \"main\": \"index.ts\",\n \"type\": \"module\",\n \"scripts\": {\n \"start\": \"deno run --allow-all index.ts\",\n \"test\": \"deno run --allow-all test-http.ts\",\n \"dev\": \"deno run --allow-all --watch index.ts\"\n },\n \"keywords\": [\n \"mcp\",\n \"model-context-protocol\",\n \"aws\",\n \"dynamodb\",\n \"s3\",\n \"anthropic\",\n \"http\",\n \"remote\"\n ],\n \"author\": \"Your Name\",\n \"license\": \"MIT\",\n \"dependencies\": {\n \"@modelcontextprotocol/sdk\": \"^0.4.0\",\n \"@aws-sdk/client-dynamodb\": \"^3.490.0\",\n \"@aws-sdk/lib-dynamodb\": \"^3.490.0\",\n \"@aws-sdk/client-s3\": \"^3.490.0\",\n \"hono\": \"^3.11.7\"\n },\n \"devDependencies\": {\n \"@types/node\": \"^20.0.0\"\n }\n}",[],[252],{"_105":261,"_96":262,"_157":263,"_159":-5,"_160":142,"_161":264,"_163":22,"_107":265,"_101":32,"_166":190,"_168":266,"_170":22,"_171":-5,"_172":267,"_99":268},"570dc0c8-4710-11f0-b0c2-76b3cceeab13","test-code-exec.ts","570dc19a-4710-11f0-b0c2-76b3cceeab13",142,["D",1749679595399],"/**\n * Test script for the updated code-exec functionality\n */\n\nimport { MCPHandler } from \"./mcp-handler.ts\";\n\nasync function testCodeExec() {\n const handler = new MCPHandler();\n \n // Set mock credentials for testing\n handler.setCredentials(\"test-secret-key\");\n\n console.log(\"Testing code-exec with direct code string...\");\n \n // Test 1: Direct code execution\n const directCodeTest = {\n jsonrpc: \"2.0\",\n method: \"tools/call\",\n params: {\n name: \"code-exec\",\n arguments: {\n code: `\n async function execute(input, tools) {\n console.log(\"Executing with input:\", input);\n return {\n message: \"Hello from direct code execution!\",\n input: input,\n timestamp: new Date().toISOString()\n };\n }\n `,\n input: {\n testParam: \"test-value\",\n userId: \"user123\"\n }\n }\n },\n id: 1\n };\n\n try {\n const result1 = await handler.handleStreamableRequest(\n new Request(\"http://localhost/mcp\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(directCodeTest)\n }),\n directCodeTest\n );\n console.log(\"Direct code test result:\", JSON.stringify(result1, null, 2));\n } catch (error) {\n console.error(\"Direct code test failed:\", error);\n }\n\n console.log(\"\\nTesting code-exec with S3 key (simulated)...\");\n \n // Test 2: S3 key execution (this will fail in test environment but shows the flow)\n const s3KeyTest = {\n jsonrpc: \"2.0\",\n method: \"tools/call\",\n params: {\n name: \"code-exec\",\n arguments: {\n key: \"scripts/test-script.js\",\n input: {\n operation: \"analyze\",\n data: [1, 2, 3, 4, 5]\n }\n }\n },\n id: 2\n };\n\n try {\n const result2 = await handler.handleStreamableRequest(\n new Request(\"http://localhost/mcp\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(s3KeyTest)\n }),\n s3KeyTest\n );\n console.log(\"S3 key test result:\", JSON.stringify(result2, null, 2));\n } catch (error) {\n console.error(\"S3 key test failed (expected in test environment):\", error.message);\n }\n\n console.log(\"\\nTesting validation - both code and key provided...\");\n \n // Test 3: Validation test - both code and key provided (should fail)\n const validationTest = {\n jsonrpc: \"2.0\",\n method: \"tools/call\",\n params: {\n name: \"code-exec\",\n arguments: {\n code: \"async function execute(input, tools) { return 'test'; }\",\n key: \"scripts/test.js\",\n input: { test: true }\n }\n },\n id: 3\n };\n\n try {\n const result3 = await handler.handleStreamableRequest(\n new Request(\"http://localhost/mcp\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(validationTest)\n }),\n validationTest\n );\n console.log(\"Validation test result:\", JSON.stringify(result3, null, 2));\n } catch (error) {\n console.error(\"Validation test failed (expected):\", error.message);\n }\n\n console.log(\"\\nTesting validation - neither code nor key provided...\");\n \n // Test 4: Validation test - neither code nor key provided (should fail)\n const validationTest2 = {\n jsonrpc: \"2.0\",\n method: \"tools/call\",\n params: {\n name: \"code-exec\",\n arguments: {\n input: { test: true }\n }\n },\n id: 4\n };\n\n try {\n const result4 = await handler.handleStreamableRequest(\n new Request(\"http://localhost/mcp\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(validationTest2)\n }),\n validationTest2\n );\n console.log(\"Validation test 2 result:\", JSON.stringify(result4, null, 2));\n } catch (error) {\n console.error(\"Validation test 2 failed (expected):\", error.message);\n }\n}\n\n// Run the test\nif (import.meta.main) {\n testCodeExec().catch(console.error);\n}",[],[262],{"_105":270,"_96":271,"_157":272,"_159":-5,"_160":142,"_161":273,"_163":22,"_107":274,"_101":32,"_166":190,"_168":275,"_170":22,"_171":-5,"_172":276,"_99":277},"01b84b74-45d6-11f0-97c3-76b3cceeab13","test-http.ts","01b84c14-45d6-11f0-97c3-76b3cceeab13",19,["D",1749544590241],"/**\n * Test script for HTTP AWS MCP Server\n * Run with: deno run --allow-all test-http.ts\n */\n\nconst SERVER_URL = Deno.env.get(\"MCP_SERVER_URL\") || \"http://localhost:8000\";\nconst AWS_SECRET_ACCESS_KEY = Deno.env.get(\"AWS_SECRET_ACCESS_KEY\") || \"test-secret-key\";\n\ninterface TestResult {\n name: string;\n success: boolean;\n error?: string;\n response?: any;\n}\n\nasync function makeRequest(path: string, options: {\n method?: string;\n body?: any;\n auth?: boolean;\n} = {}) {\n const url = `${SERVER_URL}${path}`;\n const headers: Record = {\n \"Content-Type\": \"application/json\",\n };\n\n if (options.auth !== false) {\n headers.Authorization = `Bearer ${AWS_SECRET_ACCESS_KEY}`;\n }\n\n const response = await fetch(url, {\n method: options.method || \"GET\",\n headers,\n body: options.body ? JSON.stringify(options.body) : undefined,\n });\n\n const data = await response.json();\n \n return {\n ok: response.ok,\n status: response.status,\n data,\n };\n}\n\nasync function runTest(name: string, testFn: () => Promise): Promise {\n try {\n console.log(`🧪 Running test: ${name}`);\n const response = await testFn();\n console.log(`✅ ${name} - PASSED`);\n return { name, success: true, response };\n } catch (error) {\n console.log(`❌ ${name} - FAILED: ${error.message}`);\n return { name, success: false, error: error.message };\n }\n}\n\nasync function testServerInfo() {\n const response = await makeRequest(\"/\", { auth: false });\n if (!response.ok) {\n throw new Error(`Server info failed: ${response.status}`);\n }\n return response.data;\n}\n\nasync function testHealthCheck() {\n const response = await makeRequest(\"/health\", { auth: false });\n if (!response.ok) {\n throw new Error(`Health check failed: ${response.status}`);\n }\n return response.data;\n}\n\nasync function testListPrompts() {\n const response = await makeRequest(\"/mcp/prompts\", { auth: false });\n if (!response.ok) {\n throw new Error(`List prompts failed: ${response.status}`);\n }\n if (!response.data.prompts || !Array.isArray(response.data.prompts)) {\n throw new Error(\"Invalid prompts response format\");\n }\n return response.data;\n}\n\nasync function testGetPrompt() {\n const response = await makeRequest(\"/mcp/prompts/analyze-data\", {\n method: \"POST\",\n body: { table_key: \"test-key\", s3_key: \"test-file.json\" },\n auth: false,\n });\n if (!response.ok) {\n throw new Error(`Get prompt failed: ${response.status}`);\n }\n if (!response.data.messages || !Array.isArray(response.data.messages)) {\n throw new Error(\"Invalid prompt response format\");\n }\n return response.data;\n}\n\nasync function testListTools() {\n const response = await makeRequest(\"/mcp/tools\", { auth: false });\n if (!response.ok) {\n throw new Error(`List tools failed: ${response.status}`);\n }\n if (!response.data.tools || !Array.isArray(response.data.tools)) {\n throw new Error(\"Invalid tools response format\");\n }\n return response.data;\n}\n\nasync function testListResources() {\n const response = await makeRequest(\"/mcp/resources\");\n // This might fail if AWS credentials are invalid, which is expected\n if (response.status === 401) {\n throw new Error(\"Authentication failed (expected if AWS credentials not configured)\");\n }\n if (response.status === 500) {\n throw new Error(\"AWS service error (expected if AWS not configured)\");\n }\n if (!response.ok) {\n throw new Error(`List resources failed: ${response.status}`);\n }\n return response.data;\n}\n\nasync function testToolExecution() {\n const response = await makeRequest(\"/mcp/tools/dynamodb-get\", {\n method: \"POST\",\n body: { key: { id: \"test-id\" } },\n });\n // This might fail if AWS credentials are invalid, which is expected\n if (response.status === 401) {\n throw new Error(\"Authentication failed (expected if AWS credentials not configured)\");\n }\n if (response.status === 500) {\n throw new Error(\"AWS service error (expected if AWS not configured)\");\n }\n if (!response.ok) {\n throw new Error(`Tool execution failed: ${response.status}`);\n }\n return response.data;\n}\n\nasync function testAuthentication() {\n // Test without auth header\n const response = await makeRequest(\"/mcp/resources\", { auth: false });\n if (response.status !== 401) {\n throw new Error(\"Expected 401 for missing auth header\");\n }\n return { message: \"Authentication properly enforced\" };\n}\n\nasync function main() {\n console.log(\"🚀 Testing HTTP AWS MCP Server\");\n console.log(`📍 Server URL: ${SERVER_URL}`);\n console.log(`🔑 Using AWS Secret: ${AWS_SECRET_ACCESS_KEY.substring(0, 8)}...`);\n console.log(\"\");\n\n const tests = [\n () => runTest(\"Server Info\", testServerInfo),\n () => runTest(\"Health Check\", testHealthCheck),\n () => runTest(\"List Prompts\", testListPrompts),\n () => runTest(\"Get Prompt\", testGetPrompt),\n () => runTest(\"List Tools\", testListTools),\n () => runTest(\"Authentication\", testAuthentication),\n () => runTest(\"List Resources\", testListResources),\n () => runTest(\"Tool Execution\", testToolExecution),\n ];\n\n const results: TestResult[] = [];\n \n for (const test of tests) {\n const result = await test();\n results.push(result);\n console.log(\"\"); // Add spacing between tests\n }\n\n // Summary\n console.log(\"📊 Test Summary:\");\n console.log(\"================\");\n \n const passed = results.filter(r => r.success).length;\n const failed = results.filter(r => !r.success).length;\n \n console.log(`✅ Passed: ${passed}`);\n console.log(`❌ Failed: ${failed}`);\n console.log(`📈 Success Rate: ${Math.round((passed / results.length) * 100)}%`);\n \n if (failed > 0) {\n console.log(\"\\n❌ Failed Tests:\");\n results.filter(r => !r.success).forEach(r => {\n console.log(` - ${r.name}: ${r.error}`);\n });\n }\n\n console.log(\"\\n💡 Note: Some failures are expected if AWS credentials are not properly configured.\");\n \n if (passed >= 6) { // Basic functionality tests\n console.log(\"\\n🎉 Server is functioning correctly!\");\n } else {\n console.log(\"\\n⚠️ Server may have issues. Check the failed tests above.\");\n }\n}\n\nif (import.meta.main) {\n main().catch(console.error);\n}",[],[271],{"_105":279,"_96":280,"_157":281,"_159":-5,"_160":142,"_161":282,"_163":22,"_107":283,"_101":32,"_166":190,"_168":284,"_170":22,"_171":-5,"_172":285,"_99":286},"d177e46e-4699-11f0-ac8e-76b3cceeab13","test-mcp-jsonrpc.ts","d177e54a-4699-11f0-ac8e-76b3cceeab13",128,["D",1749628690663],"/**\n * Test script for MCP JSON-RPC endpoint\n * Demonstrates how to use the new /mcp endpoint with JSON-RPC requests\n */\n\nconst BASE_URL = \"https://your-val-town-url.web.val.run\";\nconst AWS_SECRET_ACCESS_KEY = \"your-aws-secret-access-key\";\n\n// Helper function to make JSON-RPC requests\nasync function makeJSONRPCRequest(method: string, params: any, id: number = 1, requiresAuth: boolean = true) {\n const request = {\n jsonrpc: \"2.0\",\n method: method,\n params: params,\n id: id,\n };\n\n const headers: Record = {\n \"Content-Type\": \"application/json\",\n };\n\n // Add auth header only if required\n if (requiresAuth) {\n headers[\"Authorization\"] = `Bearer ${AWS_SECRET_ACCESS_KEY}`;\n }\n\n const response = await fetch(`${BASE_URL}/mcp`, {\n method: \"POST\",\n headers,\n body: JSON.stringify(request),\n });\n\n const result = await response.json();\n console.log(`\\n=== ${method} ===`);\n console.log(\"Request:\", JSON.stringify(request, null, 2));\n console.log(\"Response:\", JSON.stringify(result, null, 2));\n return result;\n}\n\n// Test functions\nasync function testInitialize() {\n return await makeJSONRPCRequest(\"initialize\", {\n protocolVersion: \"2024-11-05\",\n capabilities: {},\n clientInfo: {\n name: \"test-client\",\n version: \"1.0.0\"\n }\n });\n}\n\nasync function testListPrompts() {\n return await makeJSONRPCRequest(\"prompts/list\", {}, 1, false);\n}\n\nasync function testGetPrompt() {\n return await makeJSONRPCRequest(\"prompts/get\", {\n name: \"analyze-data\",\n arguments: {\n table_key: \"user123\",\n s3_key: \"data/analytics.json\"\n }\n }, 1, false);\n}\n\nasync function testListResources() {\n return await makeJSONRPCRequest(\"resources/list\", {});\n}\n\nasync function testReadResource() {\n return await makeJSONRPCRequest(\"resources/read\", {\n uri: \"s3://your-bucket/path/to/file.txt\"\n });\n}\n\nasync function testListTools() {\n return await makeJSONRPCRequest(\"tools/list\", {}, 1, false);\n}\n\nasync function testCallTool() {\n return await makeJSONRPCRequest(\"tools/call\", {\n name: \"dynamodb-get\",\n arguments: {\n key: { id: \"user123\" }\n }\n });\n}\n\nasync function testS3Put() {\n return await makeJSONRPCRequest(\"tools/call\", {\n name: \"s3-put\",\n arguments: {\n key: \"test/hello.txt\",\n content: \"Hello from MCP JSON-RPC!\",\n contentType: \"text/plain\"\n }\n });\n}\n\nasync function testS3Get() {\n return await makeJSONRPCRequest(\"tools/call\", {\n name: \"s3-get\",\n arguments: {\n key: \"test/hello.txt\"\n }\n });\n}\n\nasync function testDynamoDBPut() {\n return await makeJSONRPCRequest(\"tools/call\", {\n name: \"dynamodb-put\",\n arguments: {\n item: {\n id: \"test-user-123\",\n name: \"Test User\",\n email: \"test@example.com\",\n created: new Date().toISOString()\n }\n }\n });\n}\n\nasync function testDynamoDBQuery() {\n return await makeJSONRPCRequest(\"tools/call\", {\n name: \"dynamodb-query\",\n arguments: {\n keyConditionExpression: \"id = :id\",\n expressionAttributeValues: {\n \":id\": \"test-user-123\"\n }\n }\n });\n}\n\n// Run all tests\nasync function runTests() {\n console.log(\"🧪 Testing MCP JSON-RPC Endpoints\");\n console.log(\"=====================================\");\n\n try {\n // Test initialize (required first step in MCP protocol)\n await testInitialize();\n\n // Test prompts\n await testListPrompts();\n await testGetPrompt();\n\n // Test tools\n await testListTools();\n\n // Test resources (requires auth)\n await testListResources();\n // await testReadResource(); // Uncomment if you have a specific resource\n\n // Test S3 operations\n await testS3Put();\n await testS3Get();\n\n // Test DynamoDB operations\n await testDynamoDBPut();\n await testDynamoDBQuery();\n // await testCallTool(); // Basic DynamoDB get\n\n console.log(\"\\n✅ All tests completed!\");\n } catch (error) {\n console.error(\"❌ Test failed:\", error);\n }\n}\n\n// Example of batch requests (multiple JSON-RPC calls in one HTTP request)\nasync function testBatchRequests() {\n const batchRequest = [\n {\n jsonrpc: \"2.0\",\n method: \"initialize\",\n params: {\n protocolVersion: \"2024-11-05\",\n capabilities: {},\n clientInfo: {\n name: \"test-client\",\n version: \"1.0.0\"\n }\n },\n id: 1,\n },\n {\n jsonrpc: \"2.0\",\n method: \"prompts/list\",\n params: {},\n id: 2,\n },\n {\n jsonrpc: \"2.0\",\n method: \"tools/list\",\n params: {},\n id: 3,\n },\n {\n jsonrpc: \"2.0\",\n method: \"resources/list\",\n params: {},\n id: 4,\n },\n ];\n\n const response = await fetch(`${BASE_URL}/mcp`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Authorization\": `Bearer ${AWS_SECRET_ACCESS_KEY}`,\n },\n body: JSON.stringify(batchRequest),\n });\n\n const result = await response.json();\n console.log(\"\\n=== BATCH REQUEST ===\");\n console.log(\"Request:\", JSON.stringify(batchRequest, null, 2));\n console.log(\"Response:\", JSON.stringify(result, null, 2));\n}\n\n// Run the tests\nif (import.meta.main) {\n await runTests();\n // await testBatchRequests(); // Uncomment to test batch requests\n}",[],[280],{"_105":288,"_96":100,"_157":289,"_159":-5,"_160":142,"_161":102,"_163":22,"_107":290,"_101":256,"_166":218,"_168":291,"_170":22,"_171":-5,"_172":292,"_99":293},"86cf2a0e-4710-11f0-8549-76b3cceeab13","844a9048-4710-11f0-93f8-76b3cceeab13",["D",1749679675500],"/**\n * Simple test to verify code-exec tool definition\n */\n\nimport { TOOLS } from \"./tools.ts\";\n\n// Test that code-exec tool is properly defined\nconst codeExecTool = TOOLS.find(tool => tool.name === \"code-exec\");\n\nif (codeExecTool) {\n console.log(\"✅ code-exec tool found in TOOLS array\");\n console.log(\"Description:\", codeExecTool.description);\n console.log(\"Input schema:\", JSON.stringify(codeExecTool.inputSchema, null, 2));\n} else {\n console.log(\"❌ code-exec tool not found in TOOLS array\");\n}\n\nexport default function() {\n return new Response(JSON.stringify({\n success: true,\n codeExecTool: codeExecTool ? \"found\" : \"not found\",\n toolCount: TOOLS.length\n }, null, 2), {\n headers: { \"Content-Type\": \"application/json\" }\n });\n}",[],[100],{"_105":295,"_96":296,"_157":297,"_159":-5,"_160":142,"_161":165,"_163":22,"_107":298,"_101":32,"_166":190,"_168":299,"_170":22,"_171":-5,"_172":300,"_99":301},"9e7fb49e-45d4-11f0-9593-76b3cceeab13","test.ts","9e7fb570-45d4-11f0-9593-76b3cceeab13",["D",1749543994298],"/**\n * Test script for AWS MCP Server\n * Run with: deno run --allow-all test.ts\n */\n\nimport { Client } from \"@modelcontextprotocol/sdk/client/index.js\";\nimport { StdioClientTransport } from \"@modelcontextprotocol/sdk/client/stdio.js\";\n\nasync function testMCPServer() {\n console.log(\"🧪 Testing AWS MCP Server...\\n\");\n\n try {\n // Create client and transport\n const transport = new StdioClientTransport({\n command: \"deno\",\n args: [\"run\", \"--allow-all\", \"index.ts\"],\n env: {\n ...Deno.env.toObject(),\n },\n });\n\n const client = new Client(\n {\n name: \"test-client\",\n version: \"1.0.0\",\n },\n {\n capabilities: {},\n }\n );\n\n await client.connect(transport);\n console.log(\"✅ Connected to MCP server\");\n\n // Test listing prompts\n console.log(\"\\n📝 Testing prompts...\");\n const prompts = await client.listPrompts();\n console.log(`Found ${prompts.prompts.length} prompts:`);\n prompts.prompts.forEach(prompt => {\n console.log(` - ${prompt.name}: ${prompt.description}`);\n });\n\n // Test getting a prompt\n const analyzePrompt = await client.getPrompt(\"analyze-data\", {\n table_key: \"test-key\",\n s3_key: \"test-file.json\"\n });\n console.log(\"\\n📋 Sample prompt content:\");\n console.log(analyzePrompt.messages[0].content.text);\n\n // Test listing tools\n console.log(\"\\n🔧 Testing tools...\");\n const tools = await client.listTools();\n console.log(`Found ${tools.tools.length} tools:`);\n tools.tools.forEach(tool => {\n console.log(` - ${tool.name}: ${tool.description}`);\n });\n\n // Test listing resources (this will fail if S3 credentials are not set)\n console.log(\"\\n📁 Testing resources...\");\n try {\n const resources = await client.listResources();\n console.log(`Found ${resources.resources.length} S3 resources`);\n if (resources.resources.length > 0) {\n console.log(\"Sample resources:\");\n resources.resources.slice(0, 3).forEach(resource => {\n console.log(` - ${resource.name} (${resource.uri})`);\n });\n }\n } catch (error) {\n console.log(`⚠️ Resource listing failed (expected if AWS not configured): ${error.message}`);\n }\n\n // Test a simple tool call (this will fail if DynamoDB is not configured)\n console.log(\"\\n🛠️ Testing tool call...\");\n try {\n const result = await client.callTool(\"dynamodb-get\", {\n key: { id: \"test-id\" }\n });\n console.log(\"Tool call successful:\", result);\n } catch (error) {\n console.log(`⚠️ Tool call failed (expected if AWS not configured): ${error.message}`);\n }\n\n await client.close();\n console.log(\"\\n✅ All tests completed!\");\n\n } catch (error) {\n console.error(\"❌ Test failed:\", error);\n Deno.exit(1);\n }\n}\n\nif (import.meta.main) {\n testMCPServer();\n}",[],[296],{"_105":303,"_96":304,"_157":305,"_159":-5,"_160":142,"_161":306,"_163":22,"_107":307,"_101":256,"_166":190,"_168":308,"_170":22,"_171":-5,"_172":309,"_99":310},"269cc8ee-4710-11f0-b889-76b3cceeab13","tools.ts","d177f116-4699-11f0-ac8e-76b3cceeab13",138,["D",1749679514123],"/**\n * Tool definitions for the AWS MCP Server\n */\n\nexport const TOOLS = [\n {\n name: \"dynamodb-get\",\n description: \"Get an item from DynamoDB table by key\",\n inputSchema: {\n type: \"object\",\n properties: {\n key: {\n type: \"object\",\n description: \"The key object to identify the item (e.g., {id: 'user123'})\",\n },\n },\n required: [\"key\"],\n },\n },\n {\n name: \"dynamodb-put\",\n description: \"Put an item into DynamoDB table\",\n inputSchema: {\n type: \"object\",\n properties: {\n item: {\n type: \"object\",\n description: \"The item object to store in the table\",\n },\n },\n required: [\"item\"],\n },\n },\n {\n name: \"dynamodb-delete\",\n description: \"Delete an item from DynamoDB table by key\",\n inputSchema: {\n type: \"object\",\n properties: {\n key: {\n type: \"object\",\n description: \"The key object to identify the item to delete\",\n },\n },\n required: [\"key\"],\n },\n },\n {\n name: \"dynamodb-query\",\n description: \"Query items from DynamoDB table\",\n inputSchema: {\n type: \"object\",\n properties: {\n keyConditionExpression: {\n type: \"string\",\n description: \"The key condition expression for the query\",\n },\n expressionAttributeValues: {\n type: \"object\",\n description: \"Expression attribute values for the query\",\n },\n expressionAttributeNames: {\n type: \"object\",\n description: \"Expression attribute names for the query\",\n },\n },\n required: [\"keyConditionExpression\"],\n },\n },\n {\n name: \"s3-get\",\n description: \"Get an object from S3 bucket\",\n inputSchema: {\n type: \"object\",\n properties: {\n key: {\n type: \"string\",\n description: \"The S3 object key\",\n },\n },\n required: [\"key\"],\n },\n },\n {\n name: \"s3-put\",\n description: \"Put an object into S3 bucket\",\n inputSchema: {\n type: \"object\",\n properties: {\n key: {\n type: \"string\",\n description: \"The S3 object key\",\n },\n content: {\n type: \"string\",\n description: \"The content to upload\",\n },\n contentType: {\n type: \"string\",\n description: \"The content type (optional, will be inferred if not provided)\",\n },\n },\n required: [\"key\", \"content\"],\n },\n },\n {\n name: \"s3-delete\",\n description: \"Delete an object from S3 bucket\",\n inputSchema: {\n type: \"object\",\n properties: {\n key: {\n type: \"string\",\n description: \"The S3 object key to delete\",\n },\n },\n required: [\"key\"],\n },\n },\n {\n name: \"s3-move\",\n description: \"Move an object within S3 bucket (copy and delete)\",\n inputSchema: {\n type: \"object\",\n properties: {\n sourceKey: {\n type: \"string\",\n description: \"The source S3 object key\",\n },\n destinationKey: {\n type: \"string\",\n description: \"The destination S3 object key\",\n },\n },\n required: [\"sourceKey\", \"destinationKey\"],\n },\n },\n {\n name: \"code-exec\",\n description:\n \"Execute JavaScript/TypeScript code. The code must define an async execute function which will receive input and tools params. You can provide code either directly as a string or reference an S3 object key containing the code.\",\n inputSchema: {\n type: \"object\",\n properties: {\n code: {\n type: \"string\",\n description: \"The JavaScript/TypeScript code to execute directly (mutually exclusive with 'key')\",\n },\n key: {\n type: \"string\",\n description: \"S3 object key containing the code to execute (mutually exclusive with 'code')\",\n },\n input: {\n type: \"object\",\n description: \"Input parameters for the skill execution\",\n },\n },\n required: [\"input\"],\n oneOf: [\n {\n required: [\"code\", \"input\"]\n },\n {\n required: [\"key\", \"input\"]\n }\n ],\n },\n },\n] as const;",[],[304],{"_105":312,"_96":313,"_157":314,"_159":-5,"_160":142,"_161":315,"_163":22,"_107":316,"_101":32,"_166":190,"_168":317,"_170":22,"_171":-5,"_172":318,"_99":319},"b51c3c68-45d4-11f0-ba8f-76b3cceeab13","types.ts","b51c3d26-45d4-11f0-ba8f-76b3cceeab13",12,["D",1749544032230],"/**\n * Type definitions for AWS MCP Server\n */\n\n// DynamoDB types\nexport interface DynamoDBKey {\n [key: string]: any;\n}\n\nexport interface DynamoDBItem {\n [key: string]: any;\n}\n\nexport interface DynamoDBQueryParams {\n keyConditionExpression: string;\n expressionAttributeValues?: Record;\n expressionAttributeNames?: Record;\n filterExpression?: string;\n limit?: number;\n exclusiveStartKey?: DynamoDBKey;\n}\n\n// S3 types\nexport interface S3Object {\n key: string;\n content: string;\n contentType?: string;\n}\n\nexport interface S3ObjectMetadata {\n key: string;\n size?: number;\n lastModified?: Date;\n contentType?: string;\n etag?: string;\n}\n\n// MCP Resource types\nexport interface MCPResource {\n uri: string;\n name: string;\n description?: string;\n mimeType?: string;\n}\n\n// Tool argument types\nexport interface DynamoDBGetArgs {\n key: DynamoDBKey;\n}\n\nexport interface DynamoDBPutArgs {\n item: DynamoDBItem;\n}\n\nexport interface DynamoDBDeleteArgs {\n key: DynamoDBKey;\n}\n\nexport interface DynamoDBQueryArgs extends DynamoDBQueryParams {}\n\nexport interface S3GetArgs {\n key: string;\n}\n\nexport interface S3PutArgs {\n key: string;\n content: string;\n contentType?: string;\n}\n\nexport interface S3DeleteArgs {\n key: string;\n}\n\nexport interface S3MoveArgs {\n sourceKey: string;\n destinationKey: string;\n}\n\n// Prompt argument types\nexport interface AnalyzeDataPromptArgs {\n table_key: string;\n s3_key?: string;\n}\n\nexport interface DataSummaryPromptArgs {\n // No arguments required\n}\n\n// Environment configuration\nexport interface AWSConfig {\n region: string;\n accessKeyId: string;\n secretAccessKey: string;\n sessionToken?: string;\n}\n\nexport interface ServerConfig {\n aws: AWSConfig;\n s3Bucket: string;\n dynamodbTable: string;\n}\n\n// Error types\nexport class MCPError extends Error {\n constructor(\n message: string,\n public code?: string,\n public details?: any\n ) {\n super(message);\n this.name = \"MCPError\";\n }\n}\n\nexport class AWSError extends MCPError {\n constructor(\n message: string,\n public service: \"dynamodb\" | \"s3\",\n public operation: string,\n details?: any\n ) {\n super(message, `AWS_${service.toUpperCase()}_ERROR`, details);\n this.name = \"AWSError\";\n }\n}",[],[313],"files",[154,175,184,194,203,212,222,231,241,250,260,269,278,287,294,302,311],"counts",{"_324":32,"_325":226,"_326":32,"_327":328},"pulls","branches","forks","envVars",{"_329":330,"_331":32},"count",7,"emptyCount","contents",[],{"_105":288,"_96":100,"_157":289,"_159":-5,"_160":142,"_161":102,"_163":22,"_107":335,"_101":256,"_166":218,"_168":291,"_170":22,"_171":-5,"_99":336},["D",1749679675500],[100],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.version.$version.code.$",{"_94":95,"_96":97,"_98":44,"_101":102,"_99":100,"_103":345,"_152":350,"_320":402,"_167":403,"_332":405,"_406":-5,"_407":-5,"_408":-5,"_409":-5,"_410":411,"_327":-5},{"_105":106,"_96":97,"_107":346,"_109":-5,"_110":22,"_111":112,"_113":-5,"_114":-5,"_14":115,"_116":117,"_118":119,"_120":119,"_121":-5,"_122":32,"_16":123,"_124":125,"_126":125,"_127":128,"_129":128,"_130":128,"_131":125,"_132":125,"_23":347,"_136":348,"_139":349,"_151":22},["D",1749490372788],{"_94":95,"_134":135},{"_94":95,"_138":135,"_14":115},{"_101":141,"_96":44,"_105":142,"_143":106,"_144":-5,"_145":-5,"_146":-5,"_147":-5,"_148":-5,"_149":97,"_150":95},[351,354,357,360,363,366,369,372,375,378,381,384,387,390,393,396,399],{"_105":155,"_96":156,"_157":158,"_159":-5,"_160":142,"_161":162,"_163":22,"_107":164,"_101":165,"_166":167,"_168":169,"_170":22,"_171":-5,"_172":352,"_99":353},[],[156],{"_105":176,"_96":177,"_157":178,"_159":-5,"_160":142,"_161":179,"_163":22,"_107":180,"_101":32,"_166":167,"_168":181,"_170":22,"_171":-5,"_172":355,"_99":356},[],[177],{"_105":185,"_96":186,"_157":187,"_159":-5,"_160":142,"_161":188,"_163":22,"_107":189,"_101":32,"_166":190,"_168":191,"_170":22,"_171":-5,"_172":358,"_99":359},[],[186],{"_105":195,"_96":196,"_157":197,"_159":-5,"_160":142,"_161":198,"_163":22,"_107":199,"_101":32,"_166":190,"_168":200,"_170":22,"_171":-5,"_172":361,"_99":362},[],[196],{"_105":204,"_96":205,"_157":206,"_159":-5,"_160":142,"_161":207,"_163":22,"_107":208,"_101":32,"_166":167,"_168":209,"_170":22,"_171":-5,"_172":364,"_99":365},[],[205],{"_105":213,"_96":214,"_157":117,"_159":-5,"_160":142,"_161":215,"_163":22,"_107":216,"_101":217,"_166":218,"_168":219,"_170":22,"_171":-5,"_172":367,"_99":368},[],[214],{"_105":223,"_96":224,"_157":225,"_159":-5,"_160":142,"_161":226,"_163":22,"_107":227,"_101":32,"_166":167,"_168":228,"_170":22,"_171":-5,"_172":370,"_99":371},[],[224],{"_105":232,"_96":233,"_157":234,"_159":-5,"_160":142,"_161":235,"_163":22,"_107":236,"_101":237,"_166":190,"_168":238,"_170":22,"_171":-5,"_172":373,"_99":374},[],[233],{"_105":242,"_96":243,"_157":244,"_159":-5,"_160":142,"_161":245,"_163":22,"_107":246,"_101":32,"_166":190,"_168":247,"_170":22,"_171":-5,"_172":376,"_99":377},[],[243],{"_105":251,"_96":252,"_157":253,"_159":-5,"_160":142,"_161":254,"_163":22,"_107":255,"_101":256,"_166":167,"_168":257,"_170":22,"_171":-5,"_172":379,"_99":380},[],[252],{"_105":261,"_96":262,"_157":263,"_159":-5,"_160":142,"_161":264,"_163":22,"_107":265,"_101":32,"_166":190,"_168":266,"_170":22,"_171":-5,"_172":382,"_99":383},[],[262],{"_105":270,"_96":271,"_157":272,"_159":-5,"_160":142,"_161":273,"_163":22,"_107":274,"_101":32,"_166":190,"_168":275,"_170":22,"_171":-5,"_172":385,"_99":386},[],[271],{"_105":279,"_96":280,"_157":281,"_159":-5,"_160":142,"_161":282,"_163":22,"_107":283,"_101":32,"_166":190,"_168":284,"_170":22,"_171":-5,"_172":388,"_99":389},[],[280],{"_105":288,"_96":100,"_157":289,"_159":-5,"_160":142,"_161":102,"_163":22,"_107":290,"_101":256,"_166":218,"_168":291,"_170":22,"_171":-5,"_172":391,"_99":392},[],[100],{"_105":295,"_96":296,"_157":297,"_159":-5,"_160":142,"_161":165,"_163":22,"_107":298,"_101":32,"_166":190,"_168":299,"_170":22,"_171":-5,"_172":394,"_99":395},[],[296],{"_105":303,"_96":304,"_157":305,"_159":-5,"_160":142,"_161":306,"_163":22,"_107":307,"_101":256,"_166":190,"_168":308,"_170":22,"_171":-5,"_172":397,"_99":398},[],[304],{"_105":312,"_96":313,"_157":314,"_159":-5,"_160":142,"_161":315,"_163":22,"_107":316,"_101":32,"_166":190,"_168":317,"_170":22,"_171":-5,"_172":400,"_99":401},[],[313],[351,354,357,360,363,366,369,372,375,378,381,384,387,390,393,396,399],{"_105":288,"_96":100,"_157":289,"_159":-5,"_160":142,"_161":102,"_163":22,"_107":335,"_101":256,"_166":218,"_168":291,"_170":22,"_171":-5,"_99":404},[100],[],"upstream","pull","ahead","behind","templates",[],"actionData","errors"]