[{"_1":2,"_460":-5,"_461":-5},"loaderData",{"_3":4,"_91":92,"_378":379},"root",{"_5":6,"_34":35,"_64":65},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":22,"_29":22,"_30":22,"_31":32,"_33":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","ENV",{"_36":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},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","2f607f7b74b4e52529fb75176d403d8b5b284eb1","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",{"_66":67},"__internal_clerk_state",{"_68":69,"_70":45,"_71":72,"_73":72,"_74":22,"_75":72,"_76":72,"_77":72,"_78":72,"_79":80,"_89":22,"_90":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",{"_81":22,"_21":22,"_82":72,"_83":84,"_85":72,"_86":45,"_87":22,"_88":72},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/_app.x.$handle.$name",{"_93":94,"_95":96,"_97":43,"_98":99,"_100":101,"_102":103,"_148":149,"_356":357,"_358":359,"_367":368,"_162":369,"_372":-5,"_373":-5,"_374":22,"_375":22,"_376":377},"handle","c15r","name","ContextualLite","branchName","path","test-simple.ts","version",226,"project",{"_104":105,"_95":96,"_106":107,"_108":-5,"_109":22,"_110":111,"_112":-5,"_113":-5,"_14":114,"_115":-5,"_116":22,"_117":-5,"_118":32,"_16":119,"_120":121,"_122":121,"_123":124,"_125":124,"_126":124,"_127":121,"_128":121,"_23":129,"_132":133,"_135":136,"_147":22},"id","c5961c8a-4557-11f0-999b-76b3cceeab13","createdAt",["D",1749490372788],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","21f2e37e-8066-4730-9dc7-d27cf8d3c9f3","pinnedFileId","pinPreview","screenshotVersion","likeCount","0630d977-f678-453e-926c-52043293f59f","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_130":131},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yb2RJNlc1czZ1NlpZRmoxdGJ2eFVNNVhmeTYifQ","org",{"_93":94,"_134":131},"avatar","branch",{"_100":137,"_95":43,"_104":138,"_139":105,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":96,"_146":94},560,"c5966aa0-4557-11f0-999b-76b3cceeab13","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","tree",[150,170,179,189,198,207,216,225,234,245,255,264,274,283,293,302,311,320,328,337,347],{"_104":151,"_95":152,"_153":154,"_155":-5,"_156":138,"_157":158,"_159":22,"_106":160,"_100":32,"_161":162,"_163":164,"_165":22,"_166":-5,"_167":168,"_98":169},"964ed1b4-4710-11f0-a2fa-76b3cceeab13","CHANGELOG.md","fileId","964ed254-4710-11f0-a2fa-76b3cceeab13","parentId","branchId","branchVersion",147,"latest",["D",1749679701520],"fileType","file","content","# Changelog - Code-Exec Tool Enhancement\n\n## Summary\n\nUpdated the `code-exec` tool to accept either direct code strings or S3 object keys containing code, providing more flexibility for code execution workflows.\n\n## Changes Made\n\n### 1. Enhanced `handleCodeExec` method in `mcp-handler.ts`\n\n**Before:**\n- Only accepted `code` parameter (direct code string)\n- Required both `code` and `input` parameters\n\n**After:**\n- Accepts either `code` (direct string) OR `key` (S3 object key)\n- Validates that only one of `code` or `key` is provided\n- Fetches code from S3 when `key` is specified\n- Improved error handling and logging\n\n### 2. Updated Tool Definition\n\n**Before:**\n```json\n{\n \"name\": \"code-exec\",\n \"description\": \"Execute code javscript/ts (must define an async execute function which will recive input, and tools params)\",\n \"inputSchema\": {\n \"type\": \"object\",\n \"properties\": {\n \"code\": { \"type\": \"string\", \"description\": \"The code to execute\" },\n \"input\": { \"type\": \"object\", \"description\": \"Input parameters for the skill\" }\n },\n \"required\": [\"code\", \"input\"]\n }\n}\n```\n\n**After:**\n```json\n{\n \"name\": \"code-exec\",\n \"description\": \"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\": { \"type\": \"string\", \"description\": \"The JavaScript/TypeScript code to execute directly (mutually exclusive with 'key')\" },\n \"key\": { \"type\": \"string\", \"description\": \"S3 object key containing the code to execute (mutually exclusive with 'code')\" },\n \"input\": { \"type\": \"object\", \"description\": \"Input parameters for the skill execution\" }\n },\n \"required\": [\"input\"],\n \"oneOf\": [\n { \"required\": [\"code\", \"input\"] },\n { \"required\": [\"key\", \"input\"] }\n ]\n }\n}\n```\n\n### 3. Updated Documentation\n\n- Added comprehensive documentation in README.md\n- Included examples for both execution modes\n- Added security considerations\n- Created example S3 script demonstrating best practices\n\n### 4. Added Example Files\n\n- `example-s3-script.js`: Comprehensive example showing how to create reusable code modules\n- `test-code-exec.ts`: Test suite for the new functionality\n- `test-simple.ts`: Simple validation test\n\n## Usage Examples\n\n### Direct Code Execution\n```bash\ncurl -X POST https://your-server/mcp \\\n -H \"Content-Type: application/json\" \\\n -H \"Authorization: Bearer your-aws-secret\" \\\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) { return {message: \\\"Hello\\\", input}; }\",\n \"input\": {\"userId\": \"user123\"}\n }\n },\n \"id\": 1\n }'\n```\n\n### S3 Code Execution\n```bash\ncurl -X POST https://your-server/mcp \\\n -H \"Content-Type: application/json\" \\\n -H \"Authorization: Bearer your-aws-secret\" \\\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\": {\"userId\": \"user123\", \"operation\": \"analyze\"}\n }\n },\n \"id\": 1\n }'\n```\n\n## Benefits\n\n1. **Reusability**: Store commonly used scripts in S3 for reuse across multiple executions\n2. **Version Control**: Manage script versions by updating S3 objects\n3. **Collaboration**: Share scripts across different users and systems\n4. **Maintainability**: Separate complex logic into dedicated script files\n5. **Flexibility**: Choose between inline code for simple operations or S3 scripts for complex workflows\n\n## Validation\n\n- Ensures mutual exclusivity between `code` and `key` parameters\n- Validates that at least one code source is provided\n- Proper error handling for S3 fetch failures\n- Maintains backward compatibility with existing direct code usage\n\n## Security\n\n- Same sandboxed execution environment\n- No additional security risks introduced\n- S3 access uses existing AWS authentication\n- Code execution remains restricted to available MCP tools","deleted","label","children",[],[152],{"_104":171,"_95":172,"_153":173,"_155":-5,"_156":138,"_157":101,"_159":22,"_106":174,"_100":175,"_161":162,"_163":176,"_165":22,"_166":-5,"_167":177,"_98":178},"f7d51642-4782-11f0-8594-76b3cceeab13","README.md","929abcdc-45d4-11f0-a87c-76b3cceeab13",["D",1749728827751],25,"# 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\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- **User Isolation**: Each bearer token creates an isolated namespace for data storage\n - KV Store operations are automatically namespaced per user\n - Files Store operations are automatically namespaced per user\n - Resources (file listings) are automatically filtered per user namespace\n- **Demo Mode**: Requests without valid authentication use a shared \"demo\" namespace with limited capabilities\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- **Files**: Access and read files from your personal file store\n- Automatic MIME type detection\n- File metadata (size, last modified, version information)\n- Namespace isolation per user\n\n### Tools\n\n#### Key-Value Store Operations (Namespaced)\n- **kv-get**: Get a value by key from your personal key-value store\n- **kv-put**: Store a key-value pair in your personal key-value store\n- **kv-delete**: Delete a key-value pair from your personal key-value store\n- **kv-list**: List keys in your personal key-value store with optional prefix filter\n- **kv-query**: Query key-value pairs by key pattern from your personal key-value store\n\n#### Files Store Operations (Namespaced)\n- **files-get**: Get a file by key from your personal file store (supports versioning)\n- **files-put**: Store a file in your personal file store\n- **files-delete**: Delete a file from your personal file store (supports version-specific deletion)\n- **files-list**: List files in your personal file store with optional prefix filter\n- **files-list-versions**: List all versions of files in your personal file store\n- **files-move**: Move/rename a file within your personal file store\n- **files-copy**: Copy a file within your personal file store\n- **files-exists**: Check if a file exists in your personal file store\n- **files-metadata**: Get metadata for a file in your personal file store (supports versioning)\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 files store 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 (KV store and Files store 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[\"kv-get\"]({key: input.key});\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[\"kv-get\"](args)` - Get from your personal key-value store\n- `tools[\"kv-put\"](args)` - Put to your personal key-value store \n- `tools[\"kv-delete\"](args)` - Delete from your personal key-value store\n- `tools[\"kv-list\"](args)` - List keys in your personal key-value store\n- `tools[\"kv-query\"](args)` - Query your personal key-value store\n- `tools[\"files-get\"](args)` - Get file from your personal file store\n- `tools[\"files-put\"](args)` - Put file to your personal file store\n- `tools[\"files-delete\"](args)` - Delete file from your personal file store\n- `tools[\"files-list\"](args)` - List files in your personal file store\n- `tools[\"files-list-versions\"](args)` - List file versions in your personal file store\n- `tools[\"files-move\"](args)` - Move file in your personal file store\n- `tools[\"files-copy\"](args)` - Copy file in your personal file store\n- `tools[\"files-exists\"](args)` - Check if file exists in your personal file store\n- `tools[\"files-metadata\"](args)` - Get file metadata from your personal file store\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. Files Store Code Execution \nStore your code in your personal file store 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 (files store supports versioning)\n- Sharing scripts across different executions\n- Complex multi-function scripts\n- Personal script libraries isolated per user\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### DynamoDB Table Schema\n\nThe KV Store requires a DynamoDB table with the following schema:\n\n**Table Configuration:**\n- **Partition Key**: `pk` (String) - Contains the user namespace\n- **Sort Key**: `sk` (String) - Contains the user's key\n- **Billing Mode**: On-demand or Provisioned (your choice)\n- **TTL**: Optional - Set TTL attribute to `ttl` if you want automatic expiration\n\n**Example AWS CLI command to create the table:**\n```bash\naws dynamodb create-table \\\n --table-name your-table-name \\\n --attribute-definitions \\\n AttributeName=pk,AttributeType=S \\\n AttributeName=sk,AttributeType=S \\\n --key-schema \\\n AttributeName=pk,KeyType=HASH \\\n AttributeName=sk,KeyType=RANGE \\\n --billing-mode PAY_PER_REQUEST\n```\n\n**Example CloudFormation template:**\n```yaml\nDynamoDBTable:\n Type: AWS::DynamoDB::Table\n Properties:\n TableName: your-table-name\n AttributeDefinitions:\n - AttributeName: pk\n AttributeType: S\n - AttributeName: sk\n AttributeType: S\n KeySchema:\n - AttributeName: pk\n KeyType: HASH\n - AttributeName: sk\n KeyType: RANGE\n BillingMode: PAY_PER_REQUEST\n TimeToLiveSpecification:\n AttributeName: ttl\n Enabled: true\n```\n\n**Data Structure:**\nEach item in the table has the following structure:\n- `pk` (String): User namespace (e.g., \"user123\", \"demo\")\n- `sk` (String): User's key (e.g., \"settings\", \"config-app\")\n- `data` (Any): The actual value stored by the user\n- `created` (String): ISO timestamp when item was created\n- `updated` (String): ISO timestamp when item was last updated\n- `ttl` (Number, Optional): Unix timestamp for automatic expiration\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 (Files)\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 Files 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\": \"files://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 Files Operations\n\n```bash\n# Store a file in your personal file store\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\": \"files-put\",\n \"arguments\": {\n \"key\": \"documents/my-file.txt\",\n \"content\": \"Hello, World!\",\n \"contentType\": \"text/plain\"\n }\n },\n \"id\": 1\n }'\n\n# Get a file from your personal file store\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\": \"files-get\",\n \"arguments\": {\n \"key\": \"documents/my-file.txt\"\n }\n },\n \"id\": 1\n }'\n\n# List files in your personal file store\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\": \"files-list\",\n \"arguments\": {\n \"prefix\": \"documents/\"\n }\n },\n \"id\": 1\n }'\n\n# List all versions of a file\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\": \"files-list-versions\",\n \"arguments\": {\n \"key\": \"documents/my-file.txt\"\n }\n },\n \"id\": 1\n }'\n\n# Get a specific version of a file\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\": \"files-get\",\n \"arguments\": {\n \"key\": \"documents/my-file.txt\",\n \"versionId\": \"specific-version-id\"\n }\n },\n \"id\": 1\n }'\n\n# Copy a file within your personal file store\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\": \"files-copy\",\n \"arguments\": {\n \"sourceKey\": \"documents/my-file.txt\",\n \"destinationKey\": \"backup/my-file-backup.txt\"\n }\n },\n \"id\": 1\n }'\n\n# Check if a file exists\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\": \"files-exists\",\n \"arguments\": {\n \"key\": \"documents/my-file.txt\"\n }\n },\n \"id\": 1\n }'\n\n# Get file metadata\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\": \"files-metadata\",\n \"arguments\": {\n \"key\": \"documents/my-file.txt\"\n }\n },\n \"id\": 1\n }'\n\n# Delete a file\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\": \"files-delete\",\n \"arguments\": {\n \"key\": \"documents/my-file.txt\"\n }\n },\n \"id\": 1\n }'\n```\n\n#### Execute KV Store Operations\n\n```bash\n# Store a key-value pair in your personal store\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\": \"kv-put\",\n \"arguments\": {\n \"key\": \"user-settings\",\n \"value\": {\"theme\": \"dark\", \"language\": \"en\"},\n \"ttl\": 3600\n }\n },\n \"id\": 1\n }'\n\n# Get a value from your personal store\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\": \"kv-get\",\n \"arguments\": {\n \"key\": \"user-settings\"\n }\n },\n \"id\": 1\n }'\n\n# List keys in your personal store\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\": \"kv-list\",\n \"arguments\": {\n \"prefix\": \"user-\"\n }\n },\n \"id\": 1\n }'\n\n# Query key-value pairs by pattern\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\": \"kv-query\",\n \"arguments\": {\n \"keyPattern\": \"config*\"\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[\\\"kv-get\\\"]({key: input.key}); return {message: \\\"Data retrieved\\\", data: result}; }\",\n \"input\": {\n \"key\": \"user-settings\"\n }\n }\n },\n \"id\": 1\n }'\n\n# Execute code from files store\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 \"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 ],\n \"Resource\": \"arn:aws:dynamodb:region:account:table/your-table-name\"\n }\n ]\n}\n```\n\n**Note**: The KV Store uses DynamoDB Query operations with a composite key structure (partition key + sort key) for efficient namespace isolation and prefix matching. Scan operations are not required.\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```",[],[172],{"_104":180,"_95":181,"_153":182,"_155":-5,"_156":138,"_157":183,"_159":22,"_106":184,"_100":32,"_161":185,"_163":186,"_165":22,"_166":-5,"_167":187,"_98":188},"6b3913da-4766-11f0-a9a3-76b3cceeab13","auth-manager.ts","6b3914c0-4766-11f0-a9a3-76b3cceeab13",149,["D",1749716565956],"script","/**\n * Authentication and namespace management\n * Handles token-to-namespace resolution and access control\n */\n\nimport { AuthContext } from \"./kv-store.ts\";\n\nexport class AuthManager {\n /**\n * Resolve authentication context from request\n * Returns namespace and authentication status\n */\n resolveAuthContext(request: Request): AuthContext {\n const authHeader = request.headers.get(\"Authorization\");\n \n if (!authHeader?.startsWith(\"Bearer \")) {\n return { namespace: \"demo\", isDemo: true };\n }\n \n const token = authHeader.substring(7).trim();\n \n if (!token) {\n return { namespace: \"demo\", isDemo: true };\n }\n \n // Generate namespace from token\n const namespace = this.tokenToNamespace(token);\n \n return { namespace, isDemo: false };\n }\n\n /**\n * Extract AWS secret key from request for AWS operations\n * Returns null if not authenticated or invalid format\n */\n extractAWSCredentials(request: Request): string | null {\n const authHeader = request.headers.get(\"Authorization\");\n \n if (!authHeader?.startsWith(\"Bearer \")) {\n return null;\n }\n \n const token = authHeader.substring(7).trim();\n \n if (!token) {\n return null;\n }\n \n return token;\n }\n\n /**\n * Convert token to namespace identifier\n * Uses a simple hash for now, can be enhanced with lookup tables\n */\n private tokenToNamespace(token: string): string {\n // Simple hash function for namespace generation\n let hash = 0;\n for (let i = 0; i < token.length; i++) {\n const char = token.charCodeAt(i);\n hash = ((hash << 5) - hash) + char;\n hash = hash & hash; // Convert to 32-bit integer\n }\n \n // Create a readable namespace identifier\n const hashStr = Math.abs(hash).toString(36);\n return `ns_${hashStr}`;\n }\n\n /**\n * Validate if a namespace has access to perform operations\n * For now, all authenticated namespaces have full access to their own data\n */\n validateAccess(namespace: string, operation: string): boolean {\n // Demo namespace has limited access (could add restrictions here)\n if (namespace === \"demo\") {\n return true; // Allow demo operations for now\n }\n \n // All other namespaces have full access to their own data\n return true;\n }\n}",[],[181],{"_104":190,"_95":191,"_153":192,"_155":-5,"_156":138,"_157":193,"_159":22,"_106":194,"_100":32,"_161":162,"_163":195,"_165":22,"_166":-5,"_167":196,"_98":197},"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}",[],[191],{"_104":199,"_95":200,"_153":201,"_155":-5,"_156":138,"_157":202,"_159":22,"_106":203,"_100":32,"_161":185,"_163":204,"_165":22,"_166":-5,"_167":205,"_98":206},"adc798e0-45d4-11f0-8188-76b3cceeab13","deploy.ts","adc799bc-45d4-11f0-8188-76b3cceeab13",11,["D",1749544019934],"#!/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}",[],[200],{"_104":208,"_95":209,"_153":210,"_155":-5,"_156":138,"_157":211,"_159":22,"_106":212,"_100":32,"_161":185,"_163":213,"_165":22,"_166":-5,"_167":214,"_98":215},"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();",[],[209],{"_104":217,"_95":218,"_153":219,"_155":-5,"_156":138,"_157":220,"_159":22,"_106":221,"_100":32,"_161":162,"_163":222,"_165":22,"_166":-5,"_167":223,"_98":224},"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",[],[218],{"_104":226,"_95":227,"_153":228,"_155":-5,"_156":138,"_157":229,"_159":22,"_106":230,"_100":32,"_161":185,"_163":231,"_165":22,"_166":-5,"_167":232,"_98":233},"46968dbe-477f-11f0-a471-76b3cceeab13","files-store.ts","46968eae-477f-11f0-a471-76b3cceeab13",187,["D",1749727241911],"/**\n * Namespaced Files Store abstraction over S3\n * Provides transparent multi-tenancy with namespace isolation and versioning support\n */\n\nimport {\n CopyObjectCommand,\n DeleteObjectCommand,\n GetObjectCommand,\n ListObjectsV2Command,\n ListObjectVersionsCommand,\n PutObjectCommand,\n S3Client,\n HeadObjectCommand,\n} from \"https://esm.sh/@aws-sdk/client-s3@3.490.0\";\n\nexport interface AuthContext {\n namespace: string;\n isDemo: boolean;\n}\n\nexport interface FileItem {\n key: string;\n content: string;\n contentType?: string;\n size?: number;\n lastModified?: Date;\n versionId?: string;\n isLatest?: boolean;\n}\n\nexport interface FileMetadata {\n key: string;\n size: number;\n lastModified: Date;\n contentType: string;\n versionId?: string;\n isLatest?: boolean;\n etag?: string;\n}\n\nexport interface NamespacedFileItem {\n key: string; // Namespaced key: `${namespace}/${userKey}`\n content: string;\n contentType: string;\n metadata?: Record;\n versionId?: string;\n}\n\nexport class NamespacedFilesStore {\n private namespace: string;\n private s3Client: S3Client;\n private bucketName: string;\n private isDemo: boolean;\n\n constructor(authContext: AuthContext, s3Client: S3Client, bucketName: string) {\n this.namespace = authContext.namespace;\n this.s3Client = s3Client;\n this.bucketName = bucketName;\n this.isDemo = authContext.isDemo;\n }\n\n // Convert user key to namespaced key\n private namespacedKey(userKey: string): string {\n // Remove leading slash if present to avoid double slashes\n const cleanKey = userKey.startsWith('/') ? userKey.substring(1) : userKey;\n return `${this.namespace}/${cleanKey}`;\n }\n\n // Strip namespace from key to return to user\n private stripNamespace(namespacedKey: string): string {\n const prefix = `${this.namespace}/`;\n return namespacedKey.startsWith(prefix) \n ? namespacedKey.substring(prefix.length)\n : namespacedKey;\n }\n\n // Utility function to determine MIME type\n private 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 \"svg\": \"image/svg+xml\",\n \"css\": \"text/css\",\n \"yaml\": \"application/x-yaml\",\n \"yml\": \"application/x-yaml\",\n };\n\n return mimeTypes[ext || \"\"] || \"application/octet-stream\";\n }\n\n async get(key: string, versionId?: string): Promise {\n if (!key) {\n throw new Error(\"Key is required\");\n }\n\n const command = new GetObjectCommand({\n Bucket: this.bucketName,\n Key: this.namespacedKey(key),\n VersionId: versionId,\n });\n\n try {\n const response = await this.s3Client.send(command);\n const content = await response.Body?.transformToString() || \"\";\n\n return {\n key,\n content,\n contentType: response.ContentType || this.getMimeType(key),\n size: response.ContentLength,\n lastModified: response.LastModified,\n versionId: response.VersionId,\n };\n } catch (error: any) {\n if (error.name === 'NoSuchKey') {\n return null;\n }\n throw error;\n }\n }\n\n async put(key: string, content: string, contentType?: string, metadata?: Record): Promise<{ versionId?: string }> {\n if (!key || content === undefined) {\n throw new Error(\"Key and content are required\");\n }\n\n // Demo namespace restrictions\n if (this.isDemo) {\n const maxSize = 10 * 1024; // 10KB limit for demo\n if (content.length > maxSize) {\n throw new Error(`Demo accounts are limited to ${maxSize} bytes per file`);\n }\n }\n\n const command = new PutObjectCommand({\n Bucket: this.bucketName,\n Key: this.namespacedKey(key),\n Body: content,\n ContentType: contentType || this.getMimeType(key),\n Metadata: {\n ...metadata,\n namespace: this.namespace,\n originalKey: key,\n uploadedAt: new Date().toISOString(),\n },\n });\n\n const response = await this.s3Client.send(command);\n return {\n versionId: response.VersionId,\n };\n }\n\n async delete(key: string, versionId?: string): Promise {\n if (!key) {\n throw new Error(\"Key is required\");\n }\n\n const command = new DeleteObjectCommand({\n Bucket: this.bucketName,\n Key: this.namespacedKey(key),\n VersionId: versionId,\n });\n\n await this.s3Client.send(command);\n }\n\n async list(prefix?: string, limit: number = 100): Promise {\n if (limit <= 0 || limit > 1000) {\n throw new Error(\"Limit must be between 1 and 1000\");\n }\n\n const keyPrefix = prefix \n ? this.namespacedKey(prefix)\n : `${this.namespace}/`;\n\n const command = new ListObjectsV2Command({\n Bucket: this.bucketName,\n Prefix: keyPrefix,\n MaxKeys: limit,\n });\n\n const response = await this.s3Client.send(command);\n \n return (response.Contents || []).map(object => ({\n key: this.stripNamespace(object.Key || \"\"),\n size: object.Size || 0,\n lastModified: object.LastModified || new Date(),\n contentType: this.getMimeType(object.Key || \"\"),\n etag: object.ETag,\n }));\n }\n\n async listVersions(key?: string, limit: number = 100): Promise {\n if (limit <= 0 || limit > 1000) {\n throw new Error(\"Limit must be between 1 and 1000\");\n }\n\n const keyPrefix = key \n ? this.namespacedKey(key)\n : `${this.namespace}/`;\n\n const command = new ListObjectVersionsCommand({\n Bucket: this.bucketName,\n Prefix: keyPrefix,\n MaxKeys: limit,\n });\n\n const response = await this.s3Client.send(command);\n \n const versions: FileMetadata[] = [];\n \n // Add object versions\n if (response.Versions) {\n versions.push(...response.Versions.map(version => ({\n key: this.stripNamespace(version.Key || \"\"),\n size: version.Size || 0,\n lastModified: version.LastModified || new Date(),\n contentType: this.getMimeType(version.Key || \"\"),\n versionId: version.VersionId,\n isLatest: version.IsLatest,\n etag: version.ETag,\n })));\n }\n\n // Add delete markers (if any)\n if (response.DeleteMarkers) {\n versions.push(...response.DeleteMarkers.map(marker => ({\n key: this.stripNamespace(marker.Key || \"\"),\n size: 0,\n lastModified: marker.LastModified || new Date(),\n contentType: \"application/x-delete-marker\",\n versionId: marker.VersionId,\n isLatest: marker.IsLatest,\n })));\n }\n\n // Sort by last modified date (newest first)\n return versions.sort((a, b) => b.lastModified.getTime() - a.lastModified.getTime());\n }\n\n async move(sourceKey: string, destinationKey: string): Promise {\n if (!sourceKey || !destinationKey) {\n throw new Error(\"Source and destination keys are required\");\n }\n\n // Copy object to new location\n const copyCommand = new CopyObjectCommand({\n Bucket: this.bucketName,\n CopySource: `${this.bucketName}/${this.namespacedKey(sourceKey)}`,\n Key: this.namespacedKey(destinationKey),\n });\n\n await this.s3Client.send(copyCommand);\n\n // Delete original object\n await this.delete(sourceKey);\n }\n\n async copy(sourceKey: string, destinationKey: string): Promise<{ versionId?: string }> {\n if (!sourceKey || !destinationKey) {\n throw new Error(\"Source and destination keys are required\");\n }\n\n const copyCommand = new CopyObjectCommand({\n Bucket: this.bucketName,\n CopySource: `${this.bucketName}/${this.namespacedKey(sourceKey)}`,\n Key: this.namespacedKey(destinationKey),\n });\n\n const response = await this.s3Client.send(copyCommand);\n return {\n versionId: response.VersionId,\n };\n }\n\n async exists(key: string): Promise {\n if (!key) {\n throw new Error(\"Key is required\");\n }\n\n try {\n const command = new HeadObjectCommand({\n Bucket: this.bucketName,\n Key: this.namespacedKey(key),\n });\n\n await this.s3Client.send(command);\n return true;\n } catch (error: any) {\n if (error.name === 'NotFound' || error.name === 'NoSuchKey') {\n return false;\n }\n throw error;\n }\n }\n\n async getMetadata(key: string, versionId?: string): Promise {\n if (!key) {\n throw new Error(\"Key is required\");\n }\n\n try {\n const command = new HeadObjectCommand({\n Bucket: this.bucketName,\n Key: this.namespacedKey(key),\n VersionId: versionId,\n });\n\n const response = await this.s3Client.send(command);\n \n return {\n key,\n size: response.ContentLength || 0,\n lastModified: response.LastModified || new Date(),\n contentType: response.ContentType || this.getMimeType(key),\n versionId: response.VersionId,\n etag: response.ETag,\n };\n } catch (error: any) {\n if (error.name === 'NotFound' || error.name === 'NoSuchKey') {\n return null;\n }\n throw error;\n }\n }\n\n // Utility method to get namespace info (for debugging/admin)\n getNamespaceInfo(): { namespace: string; isDemo: boolean } {\n return {\n namespace: this.namespace,\n isDemo: this.isDemo,\n };\n }\n}",[],[227],{"_104":235,"_95":236,"_153":237,"_155":-5,"_156":138,"_157":238,"_159":22,"_106":239,"_100":240,"_161":241,"_163":242,"_165":22,"_166":-5,"_167":243,"_98":244},"6b021a72-476d-11f0-8906-76b3cceeab13","index.ts","6e010d7c-45d4-11f0-a0c9-76b3cceeab13",186,["D",1749719572070],37,"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 { AuthManager } from \"./auth-manager.ts\";\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();\nconst authManager = new AuthManager();\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(\n JSON.stringify({\n jsonrpc: \"2.0\",\n id,\n error: {\n code,\n message,\n },\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\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(\n JSON.stringify(\n {\n error: \"Only POST requests to /mcp are supported\",\n note: \"This server only supports the MCP JSON-RPC endpoint at POST /mcp\",\n },\n null,\n 2,\n ),\n {\n status: 404,\n headers: {\n \"Content-Type\": \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n },\n },\n );\n }\n\n try {\n // Parse request body\n const body = await request.json();\n\n // Resolve authentication context\n const authContext = authManager.resolveAuthContext(request);\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 = authManager.extractAWSCredentials(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, authContext);\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 } 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}",[],[236],{"_104":246,"_95":247,"_153":248,"_155":-5,"_156":138,"_157":249,"_159":22,"_106":250,"_100":251,"_161":185,"_163":252,"_165":22,"_166":-5,"_167":253,"_98":254},"e4978aec-4782-11f0-af2a-76b3cceeab13","kv-store.ts","63946dc8-4766-11f0-8b3a-76b3cceeab13",224,["D",1749728795482],7,"/**\n * Namespaced Key-Value Store abstraction over DynamoDB\n * Provides transparent multi-tenancy with namespace isolation\n */\n\nimport {\n DeleteCommand,\n DynamoDBDocumentClient,\n GetCommand,\n PutCommand,\n QueryCommand,\n} from \"https://esm.sh/@aws-sdk/lib-dynamodb@3.490.0\";\n\nexport interface AuthContext {\n namespace: string;\n isDemo: boolean;\n}\n\nexport interface KVItem {\n key: string;\n value: any;\n}\n\nexport interface NamespacedKVItem {\n pk: string; // Partition key: namespace\n sk: string; // Sort key: user key\n data: any; // User's value\n ttl?: number; // Optional TTL\n created: string; // Timestamp\n updated: string; // Timestamp\n}\n\nexport class NamespacedKVStore {\n private namespace: string;\n private docClient: DynamoDBDocumentClient;\n private tableName: string;\n\n constructor(authContext: AuthContext, docClient: DynamoDBDocumentClient, tableName: string) {\n this.namespace = authContext.namespace;\n this.docClient = docClient;\n this.tableName = tableName;\n }\n\n // Convert user key to partition and sort keys\n private getKeys(userKey: string): { pk: string; sk: string } {\n return {\n pk: this.namespace,\n sk: userKey\n };\n }\n\n async get(key: string): Promise {\n if (!key) {\n throw new Error(\"Key is required\");\n }\n\n const { pk, sk } = this.getKeys(key);\n const response = await this.docClient.send(new GetCommand({\n TableName: this.tableName,\n Key: { pk, sk }\n }));\n\n return response.Item?.data || null;\n }\n\n async put(key: string, value: any, ttl?: number): Promise {\n if (!key || value === undefined) {\n throw new Error(\"Key and value are required\");\n }\n\n const now = new Date().toISOString();\n const { pk, sk } = this.getKeys(key);\n const item: NamespacedKVItem = {\n pk,\n sk,\n data: value,\n created: now,\n updated: now\n };\n\n if (ttl && ttl > 0) {\n item.ttl = Math.floor(Date.now() / 1000) + ttl;\n }\n\n await this.docClient.send(new PutCommand({\n TableName: this.tableName,\n Item: item\n }));\n }\n\n async delete(key: string): Promise {\n if (!key) {\n throw new Error(\"Key is required\");\n }\n\n const { pk, sk } = this.getKeys(key);\n await this.docClient.send(new DeleteCommand({\n TableName: this.tableName,\n Key: { pk, sk }\n }));\n }\n\n async list(prefix?: string, limit: number = 100): Promise {\n if (limit <= 0 || limit > 1000) {\n throw new Error(\"Limit must be between 1 and 1000\");\n }\n\n const queryParams: any = {\n TableName: this.tableName,\n KeyConditionExpression: 'pk = :pk',\n ExpressionAttributeValues: {\n ':pk': this.namespace\n },\n Limit: limit,\n ProjectionExpression: 'sk'\n };\n\n // If prefix is provided, add begins_with condition on sort key\n if (prefix) {\n queryParams.KeyConditionExpression += ' AND begins_with(sk, :prefix)';\n queryParams.ExpressionAttributeValues[':prefix'] = prefix;\n }\n\n const response = await this.docClient.send(new QueryCommand(queryParams));\n\n return (response.Items || []).map(item => item.sk);\n }\n\n async query(keyPattern: string, limit: number = 100): Promise {\n if (!keyPattern) {\n throw new Error(\"Key pattern is required\");\n }\n \n if (limit <= 0 || limit > 1000) {\n throw new Error(\"Limit must be between 1 and 1000\");\n }\n\n // For now, treat pattern as prefix (can be enhanced later for wildcards)\n const cleanPattern = keyPattern.replace(/\\*+$/, ''); // Remove trailing wildcards\n\n const queryParams: any = {\n TableName: this.tableName,\n KeyConditionExpression: 'pk = :pk AND begins_with(sk, :pattern)',\n ExpressionAttributeValues: {\n ':pk': this.namespace,\n ':pattern': cleanPattern\n },\n Limit: limit\n };\n\n const response = await this.docClient.send(new QueryCommand(queryParams));\n\n return (response.Items || []).map(item => ({\n key: item.sk,\n value: item.data\n }));\n }\n}",[],[247],{"_104":256,"_95":257,"_153":258,"_155":-5,"_156":138,"_157":259,"_159":22,"_106":260,"_100":32,"_161":162,"_163":261,"_165":22,"_166":-5,"_167":262,"_98":263},"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}",[],[257],{"_104":265,"_95":266,"_153":267,"_155":-5,"_156":138,"_157":268,"_159":22,"_106":269,"_100":270,"_161":185,"_163":271,"_165":22,"_166":-5,"_167":272,"_98":273},"1dd2d5c6-4780-11f0-acf7-76b3cceeab13","mcp-handler.ts","964108e8-45d7-11f0-b6af-76b3cceeab13",208,["D",1749727603012],117,"/**\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 S3Client,\n} from \"https://esm.sh/@aws-sdk/client-s3@3.490.0\";\nimport {\n DynamoDBDocumentClient,\n} from \"https://esm.sh/@aws-sdk/lib-dynamodb@3.490.0\";\n\nimport { NamespacedKVStore, AuthContext } from \"./kv-store.ts\";\nimport { NamespacedFilesStore } from \"./files-store.ts\";\nimport { AuthManager } from \"./auth-manager.ts\";\nimport { ALL_TOOLS } from \"./tools.ts\";\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 AWS_SECRET_ACCESS_KEY = Deno.env.get(\"AWS_SECRET_ACCESS_KEY\") || \"EXAMPLE_SECRET_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 from environment\nfunction createAWSClients() {\n const credentials = {\n accessKeyId: AWS_ACCESS_KEY_ID!,\n secretAccessKey: AWS_SECRET_ACCESS_KEY!,\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\nexport class MCPHandler {\n private authManager: AuthManager;\n\n constructor() {\n this.authManager = new AuthManager();\n }\n\n // KV Store tool handlers\n private async handleKVGet(args: any, authContext: AuthContext) {\n const { key } = args;\n if (!key) {\n throw new Error(\"Key is required for KV get operation\");\n }\n\n const { docClient } = createAWSClients();\n const kvStore = new NamespacedKVStore(authContext, docClient, DYNAMODB_TABLE);\n \n const value = await kvStore.get(key);\n \n return {\n content: [\n {\n type: \"text\",\n text: JSON.stringify(value, null, 2),\n },\n ],\n };\n }\n\n private async handleKVPut(args: any, authContext: AuthContext) {\n const { key, value, ttl } = args;\n if (!key || value === undefined) {\n throw new Error(\"Key and value are required for KV put operation\");\n }\n\n const { docClient } = createAWSClients();\n const kvStore = new NamespacedKVStore(authContext, docClient, DYNAMODB_TABLE);\n \n await kvStore.put(key, value, ttl);\n \n return {\n content: [\n {\n type: \"text\",\n text: `Successfully stored key: ${key}${ttl ? ` (TTL: ${ttl}s)` : ''}`,\n },\n ],\n };\n }\n\n private async handleKVDelete(args: any, authContext: AuthContext) {\n const { key } = args;\n if (!key) {\n throw new Error(\"Key is required for KV delete operation\");\n }\n\n const { docClient } = createAWSClients();\n const kvStore = new NamespacedKVStore(authContext, docClient, DYNAMODB_TABLE);\n \n await kvStore.delete(key);\n \n return {\n content: [\n {\n type: \"text\",\n text: `Successfully deleted key: ${key}`,\n },\n ],\n };\n }\n\n private async handleKVList(args: any, authContext: AuthContext) {\n const { prefix, limit = 100 } = args;\n\n const { docClient } = createAWSClients();\n const kvStore = new NamespacedKVStore(authContext, docClient, DYNAMODB_TABLE);\n \n const keys = await kvStore.list(prefix, limit);\n \n return {\n content: [\n {\n type: \"text\",\n text: JSON.stringify(keys, null, 2),\n },\n ],\n };\n }\n\n private async handleKVQuery(args: any, authContext: AuthContext) {\n const { keyPattern, limit = 100 } = args;\n if (!keyPattern) {\n throw new Error(\"Key pattern is required for KV query operation\");\n }\n\n const { docClient } = createAWSClients();\n const kvStore = new NamespacedKVStore(authContext, docClient, DYNAMODB_TABLE);\n \n const items = await kvStore.query(keyPattern, limit);\n \n return {\n content: [\n {\n type: \"text\",\n text: JSON.stringify(items, null, 2),\n },\n ],\n };\n }\n\n // Files Store tool handlers\n private async handleFilesGet(args: any, authContext: AuthContext) {\n const { key, versionId } = args;\n if (!key) {\n throw new Error(\"Key is required for files get operation\");\n }\n\n const { s3Client } = createAWSClients();\n const filesStore = new NamespacedFilesStore(authContext, s3Client, S3_BUCKET);\n \n const file = await filesStore.get(key, versionId);\n \n if (!file) {\n return {\n content: [\n {\n type: \"text\",\n text: \"File not found\",\n },\n ],\n };\n }\n \n return {\n content: [\n {\n type: \"text\",\n text: file.content,\n },\n ],\n };\n }\n\n private async handleFilesPut(args: any, authContext: AuthContext) {\n const { key, content, contentType, metadata } = args;\n if (!key || content === undefined) {\n throw new Error(\"Key and content are required for files put operation\");\n }\n\n const { s3Client } = createAWSClients();\n const filesStore = new NamespacedFilesStore(authContext, s3Client, S3_BUCKET);\n \n const result = await filesStore.put(key, content, contentType, metadata);\n \n return {\n content: [\n {\n type: \"text\",\n text: `Successfully stored file: ${key}${result.versionId ? ` (Version: ${result.versionId})` : ''}`,\n },\n ],\n };\n }\n\n private async handleFilesDelete(args: any, authContext: AuthContext) {\n const { key, versionId } = args;\n if (!key) {\n throw new Error(\"Key is required for files delete operation\");\n }\n\n const { s3Client } = createAWSClients();\n const filesStore = new NamespacedFilesStore(authContext, s3Client, S3_BUCKET);\n \n await filesStore.delete(key, versionId);\n \n return {\n content: [\n {\n type: \"text\",\n text: `Successfully deleted file: ${key}${versionId ? ` (Version: ${versionId})` : ''}`,\n },\n ],\n };\n }\n\n private async handleFilesList(args: any, authContext: AuthContext) {\n const { prefix, limit = 100 } = args;\n\n const { s3Client } = createAWSClients();\n const filesStore = new NamespacedFilesStore(authContext, s3Client, S3_BUCKET);\n \n const files = await filesStore.list(prefix, limit);\n \n return {\n content: [\n {\n type: \"text\",\n text: JSON.stringify(files, null, 2),\n },\n ],\n };\n }\n\n private async handleFilesListVersions(args: any, authContext: AuthContext) {\n const { key, limit = 100 } = args;\n\n const { s3Client } = createAWSClients();\n const filesStore = new NamespacedFilesStore(authContext, s3Client, S3_BUCKET);\n \n const versions = await filesStore.listVersions(key, limit);\n \n return {\n content: [\n {\n type: \"text\",\n text: JSON.stringify(versions, null, 2),\n },\n ],\n };\n }\n\n private async handleFilesMove(args: any, authContext: AuthContext) {\n const { sourceKey, destinationKey } = args;\n if (!sourceKey || !destinationKey) {\n throw new Error(\"Source and destination keys are required for files move operation\");\n }\n\n const { s3Client } = createAWSClients();\n const filesStore = new NamespacedFilesStore(authContext, s3Client, S3_BUCKET);\n \n await filesStore.move(sourceKey, destinationKey);\n \n return {\n content: [\n {\n type: \"text\",\n text: `Successfully moved file from ${sourceKey} to ${destinationKey}`,\n },\n ],\n };\n }\n\n private async handleFilesCopy(args: any, authContext: AuthContext) {\n const { sourceKey, destinationKey } = args;\n if (!sourceKey || !destinationKey) {\n throw new Error(\"Source and destination keys are required for files copy operation\");\n }\n\n const { s3Client } = createAWSClients();\n const filesStore = new NamespacedFilesStore(authContext, s3Client, S3_BUCKET);\n \n const result = await filesStore.copy(sourceKey, destinationKey);\n \n return {\n content: [\n {\n type: \"text\",\n text: `Successfully copied file from ${sourceKey} to ${destinationKey}${result.versionId ? ` (Version: ${result.versionId})` : ''}`,\n },\n ],\n };\n }\n\n private async handleFilesExists(args: any, authContext: AuthContext) {\n const { key } = args;\n if (!key) {\n throw new Error(\"Key is required for files exists operation\");\n }\n\n const { s3Client } = createAWSClients();\n const filesStore = new NamespacedFilesStore(authContext, s3Client, S3_BUCKET);\n \n const exists = await filesStore.exists(key);\n \n return {\n content: [\n {\n type: \"text\",\n text: JSON.stringify({ key, exists }, null, 2),\n },\n ],\n };\n }\n\n private async handleFilesMetadata(args: any, authContext: AuthContext) {\n const { key, versionId } = args;\n if (!key) {\n throw new Error(\"Key is required for files metadata operation\");\n }\n\n const { s3Client } = createAWSClients();\n const filesStore = new NamespacedFilesStore(authContext, s3Client, S3_BUCKET);\n \n const metadata = await filesStore.getMetadata(key, versionId);\n \n if (!metadata) {\n return {\n content: [\n {\n type: \"text\",\n text: \"File not found\",\n },\n ],\n };\n }\n \n return {\n content: [\n {\n type: \"text\",\n text: JSON.stringify(metadata, null, 2),\n },\n ],\n };\n }\n\n // code exec handler\n\n private async handleCodeExec(args: any, authContext: AuthContext) {\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 Files Store (namespaced)\n console.log(`[CodeExec] Fetching code from files key: ${key}`);\n const filesResponse = await this.handleFilesGet({ key }, authContext);\n codeSource = filesResponse.content[0].text;\n console.log(`[CodeExec] Retrieved code from files store (${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 // For KV and Files tools, we need to pass the authContext\n if (tool.name.startsWith('kv-') || tool.name.startsWith('files-')) {\n return await this.handleCallTool({ name: tool.name, arguments: args }, authContext);\n } else {\n return await this.handleCallTool({ name: tool.name, arguments: args }, authContext);\n }\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 // Handle streamable HTTP request\n async handleStreamableRequest(request: Request, body: any, authContext: AuthContext): 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(authContext);\n break;\n case \"resources/read\":\n result = await this.handleReadResource(params, authContext);\n break;\n case \"tools/list\":\n result = await this.handleListTools();\n break;\n case \"tools/call\":\n result = await this.handleCallTool(params, authContext);\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(authContext: AuthContext) {\n const { s3Client } = createAWSClients();\n const filesStore = new NamespacedFilesStore(authContext, s3Client, S3_BUCKET);\n\n const files = await filesStore.list(undefined, 100);\n const resources = files.map((file) => ({\n uri: `files://${file.key}`,\n name: file.key,\n description: `File: ${file.key} (${file.size} bytes, modified: ${file.lastModified})`,\n mimeType: file.contentType,\n }));\n\n return { resources };\n }\n\n private async handleReadResource(params: any, authContext: AuthContext) {\n const { uri } = params;\n\n if (!uri.startsWith(\"files://\")) {\n throw new Error(\"Only files:// URIs are supported\");\n }\n\n const key = uri.replace(\"files://\", \"\");\n const { s3Client } = createAWSClients();\n const filesStore = new NamespacedFilesStore(authContext, s3Client, S3_BUCKET);\n\n const file = await filesStore.get(key);\n \n if (!file) {\n throw new Error(`File not found: ${key}`);\n }\n\n return {\n contents: [\n {\n uri: `files://${key}`,\n mimeType: file.contentType || \"text/plain\",\n text: file.content,\n },\n ],\n };\n }\n\n private async handleListTools() {\n return {\n tools: ALL_TOOLS,\n };\n }\n\n private async handleCallTool(params: any, authContext: AuthContext) {\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 // KV Store tools\n case \"kv-get\":\n return await toolErrorWrapper(this.handleKVGet(args, authContext));\n case \"kv-put\":\n return await toolErrorWrapper(this.handleKVPut(args, authContext));\n case \"kv-delete\":\n return await toolErrorWrapper(this.handleKVDelete(args, authContext));\n case \"kv-list\":\n return await toolErrorWrapper(this.handleKVList(args, authContext));\n case \"kv-query\":\n return await toolErrorWrapper(this.handleKVQuery(args, authContext));\n \n // Files Store tools\n case \"files-get\":\n return await toolErrorWrapper(this.handleFilesGet(args, authContext));\n case \"files-put\":\n return await toolErrorWrapper(this.handleFilesPut(args, authContext));\n case \"files-delete\":\n return await toolErrorWrapper(this.handleFilesDelete(args, authContext));\n case \"files-list\":\n return await toolErrorWrapper(this.handleFilesList(args, authContext));\n case \"files-list-versions\":\n return await toolErrorWrapper(this.handleFilesListVersions(args, authContext));\n case \"files-move\":\n return await toolErrorWrapper(this.handleFilesMove(args, authContext));\n case \"files-copy\":\n return await toolErrorWrapper(this.handleFilesCopy(args, authContext));\n case \"files-exists\":\n return await toolErrorWrapper(this.handleFilesExists(args, authContext));\n case \"files-metadata\":\n return await toolErrorWrapper(this.handleFilesMetadata(args, authContext));\n \n // Code execution\n case \"code-exec\":\n return await toolErrorWrapper(this.handleCodeExec(args, authContext));\n \n default:\n throw new Error(`Unknown tool: ${name}`);\n }\n }\n}",[],[266],{"_104":275,"_95":276,"_153":277,"_155":-5,"_156":138,"_157":278,"_159":22,"_106":279,"_100":32,"_161":185,"_163":280,"_165":22,"_166":-5,"_167":281,"_98":282},"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;",[],[276],{"_104":284,"_95":285,"_153":286,"_155":-5,"_156":138,"_157":287,"_159":22,"_106":288,"_100":289,"_161":162,"_163":290,"_165":22,"_166":-5,"_167":291,"_98":292},"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}",[],[285],{"_104":294,"_95":295,"_153":296,"_155":-5,"_156":138,"_157":297,"_159":22,"_106":298,"_100":32,"_161":185,"_163":299,"_165":22,"_166":-5,"_167":300,"_98":301},"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}",[],[295],{"_104":303,"_95":304,"_153":305,"_155":-5,"_156":138,"_157":306,"_159":22,"_106":307,"_100":32,"_161":185,"_163":308,"_165":22,"_166":-5,"_167":309,"_98":310},"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}",[],[304],{"_104":312,"_95":313,"_153":314,"_155":-5,"_156":138,"_157":315,"_159":22,"_106":316,"_100":32,"_161":185,"_163":317,"_165":22,"_166":-5,"_167":318,"_98":319},"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}",[],[313],{"_104":321,"_95":99,"_153":322,"_155":-5,"_156":138,"_157":323,"_159":22,"_106":324,"_100":289,"_161":241,"_163":325,"_165":22,"_166":-5,"_167":326,"_98":327},"86cf2a0e-4710-11f0-8549-76b3cceeab13","844a9048-4710-11f0-93f8-76b3cceeab13",146,["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}",[],[99],{"_104":329,"_95":330,"_153":331,"_155":-5,"_156":138,"_157":332,"_159":22,"_106":333,"_100":32,"_161":185,"_163":334,"_165":22,"_166":-5,"_167":335,"_98":336},"9e7fb49e-45d4-11f0-9593-76b3cceeab13","test.ts","9e7fb570-45d4-11f0-9593-76b3cceeab13",9,["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}",[],[330],{"_104":338,"_95":339,"_153":340,"_155":-5,"_156":138,"_157":341,"_159":22,"_106":342,"_100":343,"_161":185,"_163":344,"_165":22,"_166":-5,"_167":345,"_98":346},"f0a418d0-477f-11f0-b795-76b3cceeab13","tools.ts","d177f116-4699-11f0-ac8e-76b3cceeab13",201,["D",1749727527210],8,"/**\n * Tool definitions for the AWS MCP Server\n */\n\n// Key-Value Store Tools (Namespaced)\nexport const KV_TOOLS = [\n {\n name: \"kv-get\",\n description: \"Get a value by key from your personal key-value store\",\n inputSchema: {\n type: \"object\",\n properties: {\n key: {\n type: \"string\",\n description: \"The key to retrieve\"\n }\n },\n required: [\"key\"]\n }\n },\n {\n name: \"kv-put\",\n description: \"Store a key-value pair in your personal key-value store\",\n inputSchema: {\n type: \"object\",\n properties: {\n key: {\n type: \"string\",\n description: \"The key to store\"\n },\n value: {\n description: \"The value to store (can be any JSON-serializable data)\"\n },\n ttl: {\n type: \"number\",\n description: \"Optional time-to-live in seconds (data will be automatically deleted after this time)\"\n }\n },\n required: [\"key\", \"value\"]\n }\n },\n {\n name: \"kv-delete\",\n description: \"Delete a key-value pair from your personal key-value store\",\n inputSchema: {\n type: \"object\",\n properties: {\n key: {\n type: \"string\",\n description: \"The key to delete\"\n }\n },\n required: [\"key\"]\n }\n },\n {\n name: \"kv-list\",\n description: \"List keys in your personal key-value store with optional prefix filter\",\n inputSchema: {\n type: \"object\",\n properties: {\n prefix: {\n type: \"string\",\n description: \"Optional key prefix to filter by (e.g., 'user-' to list all keys starting with 'user-')\"\n },\n limit: {\n type: \"number\",\n description: \"Maximum number of keys to return (1-1000)\",\n default: 100,\n minimum: 1,\n maximum: 1000\n }\n }\n }\n },\n {\n name: \"kv-query\",\n description: \"Query key-value pairs by key pattern from your personal key-value store\",\n inputSchema: {\n type: \"object\",\n properties: {\n keyPattern: {\n type: \"string\",\n description: \"Key pattern to match (supports prefix matching, e.g., 'config*' matches all keys starting with 'config')\"\n },\n limit: {\n type: \"number\",\n description: \"Maximum number of items to return (1-1000)\",\n default: 100,\n minimum: 1,\n maximum: 1000\n }\n },\n required: [\"keyPattern\"]\n }\n }\n] as const;\n\n// Files Store Tools (Namespaced)\nexport const FILES_TOOLS = [\n {\n name: \"files-get\",\n description: \"Get a file by key from your personal file store\",\n inputSchema: {\n type: \"object\",\n properties: {\n key: {\n type: \"string\",\n description: \"The file key to retrieve\"\n },\n versionId: {\n type: \"string\",\n description: \"Optional version ID to retrieve a specific version\"\n }\n },\n required: [\"key\"]\n }\n },\n {\n name: \"files-put\",\n description: \"Store a file in your personal file store\",\n inputSchema: {\n type: \"object\",\n properties: {\n key: {\n type: \"string\",\n description: \"The file key to store\"\n },\n content: {\n type: \"string\",\n description: \"The file content to store\"\n },\n contentType: {\n type: \"string\",\n description: \"Optional content type (will be inferred from file extension if not provided)\"\n },\n metadata: {\n type: \"object\",\n description: \"Optional metadata key-value pairs to store with the file\"\n }\n },\n required: [\"key\", \"content\"]\n }\n },\n {\n name: \"files-delete\",\n description: \"Delete a file from your personal file store\",\n inputSchema: {\n type: \"object\",\n properties: {\n key: {\n type: \"string\",\n description: \"The file key to delete\"\n },\n versionId: {\n type: \"string\",\n description: \"Optional version ID to delete a specific version\"\n }\n },\n required: [\"key\"]\n }\n },\n {\n name: \"files-list\",\n description: \"List files in your personal file store with optional prefix filter\",\n inputSchema: {\n type: \"object\",\n properties: {\n prefix: {\n type: \"string\",\n description: \"Optional key prefix to filter by (e.g., 'documents/' to list all files in documents folder)\"\n },\n limit: {\n type: \"number\",\n description: \"Maximum number of files to return (1-1000)\",\n default: 100,\n minimum: 1,\n maximum: 1000\n }\n }\n }\n },\n {\n name: \"files-list-versions\",\n description: \"List all versions of files in your personal file store\",\n inputSchema: {\n type: \"object\",\n properties: {\n key: {\n type: \"string\",\n description: \"Optional specific file key to list versions for (if not provided, lists versions for all files)\"\n },\n limit: {\n type: \"number\",\n description: \"Maximum number of versions to return (1-1000)\",\n default: 100,\n minimum: 1,\n maximum: 1000\n }\n }\n }\n },\n {\n name: \"files-move\",\n description: \"Move/rename a file within your personal file store\",\n inputSchema: {\n type: \"object\",\n properties: {\n sourceKey: {\n type: \"string\",\n description: \"The source file key\"\n },\n destinationKey: {\n type: \"string\",\n description: \"The destination file key\"\n }\n },\n required: [\"sourceKey\", \"destinationKey\"]\n }\n },\n {\n name: \"files-copy\",\n description: \"Copy a file within your personal file store\",\n inputSchema: {\n type: \"object\",\n properties: {\n sourceKey: {\n type: \"string\",\n description: \"The source file key\"\n },\n destinationKey: {\n type: \"string\",\n description: \"The destination file key\"\n }\n },\n required: [\"sourceKey\", \"destinationKey\"]\n }\n },\n {\n name: \"files-exists\",\n description: \"Check if a file exists in your personal file store\",\n inputSchema: {\n type: \"object\",\n properties: {\n key: {\n type: \"string\",\n description: \"The file key to check\"\n }\n },\n required: [\"key\"]\n }\n },\n {\n name: \"files-metadata\",\n description: \"Get metadata for a file in your personal file store\",\n inputSchema: {\n type: \"object\",\n properties: {\n key: {\n type: \"string\",\n description: \"The file key to get metadata for\"\n },\n versionId: {\n type: \"string\",\n description: \"Optional version ID to get metadata for a specific version\"\n }\n },\n required: [\"key\"]\n }\n }\n] as const;\n\n// Code Execution Tools\nexport const CODE_TOOLS = [\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 a files store 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: \"Files store 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;\n\n// All tools combined\nexport const ALL_TOOLS = [\n ...KV_TOOLS,\n ...FILES_TOOLS,\n ...CODE_TOOLS\n] as const;",[],[339],{"_104":348,"_95":349,"_153":350,"_155":-5,"_156":138,"_157":351,"_159":22,"_106":352,"_100":289,"_161":185,"_163":353,"_165":22,"_166":-5,"_167":354,"_98":355},"6f66108e-4766-11f0-8bf0-76b3cceeab13","types.ts","b51c3d26-45d4-11f0-ba8f-76b3cceeab13",150,["D",1749716572959],"/**\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\n// KV Store argument types\nexport interface KVGetArgs {\n key: string;\n}\n\nexport interface KVPutArgs {\n key: string;\n value: any;\n ttl?: number;\n}\n\nexport interface KVDeleteArgs {\n key: string;\n}\n\nexport interface KVListArgs {\n prefix?: string;\n limit?: number;\n}\n\nexport interface KVQueryArgs {\n keyPattern: string;\n limit?: number;\n}\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}",[],[349],"files",[150,170,179,189,198,207,216,225,234,245,255,264,274,283,293,302,311,320,328,337,347],"counts",{"_360":32,"_361":259,"_362":32,"_363":364},"pulls","branches","forks","envVars",{"_365":251,"_366":32},"count","emptyCount","contents",[],{"_104":321,"_95":99,"_153":322,"_155":-5,"_156":138,"_157":323,"_159":22,"_106":370,"_100":289,"_161":241,"_163":325,"_165":22,"_166":-5,"_98":371},["D",1749679675500],[99],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.version.$version.code.$",{"_93":94,"_95":96,"_97":43,"_100":101,"_98":99,"_102":380,"_148":385,"_356":449,"_162":450,"_367":452,"_453":-5,"_454":22,"_455":-5,"_456":-5,"_457":-5,"_458":459},{"_104":105,"_95":96,"_106":381,"_108":-5,"_109":22,"_110":111,"_112":-5,"_113":-5,"_14":114,"_115":-5,"_116":22,"_117":-5,"_118":32,"_16":119,"_120":121,"_122":121,"_123":124,"_125":124,"_126":124,"_127":121,"_128":121,"_23":382,"_132":383,"_135":384,"_147":22},["D",1749490372788],{"_93":94,"_130":131},{"_93":94,"_134":131},{"_100":137,"_95":43,"_104":138,"_139":105,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":96,"_146":94},[386,389,392,395,398,401,404,407,410,413,416,419,422,425,428,431,434,437,440,443,446],{"_104":151,"_95":152,"_153":154,"_155":-5,"_156":138,"_157":158,"_159":22,"_106":160,"_100":32,"_161":162,"_163":164,"_165":22,"_166":-5,"_167":387,"_98":388},[],[152],{"_104":171,"_95":172,"_153":173,"_155":-5,"_156":138,"_157":101,"_159":22,"_106":174,"_100":175,"_161":162,"_163":176,"_165":22,"_166":-5,"_167":390,"_98":391},[],[172],{"_104":180,"_95":181,"_153":182,"_155":-5,"_156":138,"_157":183,"_159":22,"_106":184,"_100":32,"_161":185,"_163":186,"_165":22,"_166":-5,"_167":393,"_98":394},[],[181],{"_104":190,"_95":191,"_153":192,"_155":-5,"_156":138,"_157":193,"_159":22,"_106":194,"_100":32,"_161":162,"_163":195,"_165":22,"_166":-5,"_167":396,"_98":397},[],[191],{"_104":199,"_95":200,"_153":201,"_155":-5,"_156":138,"_157":202,"_159":22,"_106":203,"_100":32,"_161":185,"_163":204,"_165":22,"_166":-5,"_167":399,"_98":400},[],[200],{"_104":208,"_95":209,"_153":210,"_155":-5,"_156":138,"_157":211,"_159":22,"_106":212,"_100":32,"_161":185,"_163":213,"_165":22,"_166":-5,"_167":402,"_98":403},[],[209],{"_104":217,"_95":218,"_153":219,"_155":-5,"_156":138,"_157":220,"_159":22,"_106":221,"_100":32,"_161":162,"_163":222,"_165":22,"_166":-5,"_167":405,"_98":406},[],[218],{"_104":226,"_95":227,"_153":228,"_155":-5,"_156":138,"_157":229,"_159":22,"_106":230,"_100":32,"_161":185,"_163":231,"_165":22,"_166":-5,"_167":408,"_98":409},[],[227],{"_104":235,"_95":236,"_153":237,"_155":-5,"_156":138,"_157":238,"_159":22,"_106":239,"_100":240,"_161":241,"_163":242,"_165":22,"_166":-5,"_167":411,"_98":412},[],[236],{"_104":246,"_95":247,"_153":248,"_155":-5,"_156":138,"_157":249,"_159":22,"_106":250,"_100":251,"_161":185,"_163":252,"_165":22,"_166":-5,"_167":414,"_98":415},[],[247],{"_104":256,"_95":257,"_153":258,"_155":-5,"_156":138,"_157":259,"_159":22,"_106":260,"_100":32,"_161":162,"_163":261,"_165":22,"_166":-5,"_167":417,"_98":418},[],[257],{"_104":265,"_95":266,"_153":267,"_155":-5,"_156":138,"_157":268,"_159":22,"_106":269,"_100":270,"_161":185,"_163":271,"_165":22,"_166":-5,"_167":420,"_98":421},[],[266],{"_104":275,"_95":276,"_153":277,"_155":-5,"_156":138,"_157":278,"_159":22,"_106":279,"_100":32,"_161":185,"_163":280,"_165":22,"_166":-5,"_167":423,"_98":424},[],[276],{"_104":284,"_95":285,"_153":286,"_155":-5,"_156":138,"_157":287,"_159":22,"_106":288,"_100":289,"_161":162,"_163":290,"_165":22,"_166":-5,"_167":426,"_98":427},[],[285],{"_104":294,"_95":295,"_153":296,"_155":-5,"_156":138,"_157":297,"_159":22,"_106":298,"_100":32,"_161":185,"_163":299,"_165":22,"_166":-5,"_167":429,"_98":430},[],[295],{"_104":303,"_95":304,"_153":305,"_155":-5,"_156":138,"_157":306,"_159":22,"_106":307,"_100":32,"_161":185,"_163":308,"_165":22,"_166":-5,"_167":432,"_98":433},[],[304],{"_104":312,"_95":313,"_153":314,"_155":-5,"_156":138,"_157":315,"_159":22,"_106":316,"_100":32,"_161":185,"_163":317,"_165":22,"_166":-5,"_167":435,"_98":436},[],[313],{"_104":321,"_95":99,"_153":322,"_155":-5,"_156":138,"_157":323,"_159":22,"_106":324,"_100":289,"_161":241,"_163":325,"_165":22,"_166":-5,"_167":438,"_98":439},[],[99],{"_104":329,"_95":330,"_153":331,"_155":-5,"_156":138,"_157":332,"_159":22,"_106":333,"_100":32,"_161":185,"_163":334,"_165":22,"_166":-5,"_167":441,"_98":442},[],[330],{"_104":338,"_95":339,"_153":340,"_155":-5,"_156":138,"_157":341,"_159":22,"_106":342,"_100":343,"_161":185,"_163":344,"_165":22,"_166":-5,"_167":444,"_98":445},[],[339],{"_104":348,"_95":349,"_153":350,"_155":-5,"_156":138,"_157":351,"_159":22,"_106":352,"_100":289,"_161":185,"_163":353,"_165":22,"_166":-5,"_167":447,"_98":448},[],[349],[386,389,392,395,398,401,404,407,410,413,416,419,422,425,428,431,434,437,440,443,446],{"_104":321,"_95":99,"_153":322,"_155":-5,"_156":138,"_157":323,"_159":22,"_106":370,"_100":289,"_161":241,"_163":325,"_165":22,"_166":-5,"_98":451},[99],[],"upstream","showCompareCallout","pull","ahead","behind","templates",[],"actionData","errors"]