\n \n \n \n\n",[120,111],"98bcfde0b370c659af7309201b4a849b375f3665e3baf133ba3cacc2ac0c12f8","frontend","5c059140-3996-11f1-a04c-42b51c65c3df","5404b440-f52b-11ef-99f0-569c3dd06744","a59cbf44-f528-11ef-ae42-569c3dd06744",74,["D",1776345337676],8,"\n\n \n \n \n React Hono Val Town Starter\n \n \n \n \n

\n \n \n \n",[120,111],"1ea8b3da4e18d579298229ba24af91b14b14ae02565f57c996f9acaa1f8333bc","frontend/components/App.tsx",{"_32":143,"_13":134,"_81":144,"_83":145,"_84":33,"_85":146,"_87":26,"_34":147,"_40":148,"_90":138,"_92":149,"_66":48,"_94":-5,"_95":-7,"_74":150,"_97":151},{"_32":133,"_13":134,"_81":135,"_83":136,"_84":58,"_85":20,"_87":26,"_34":137,"_40":89,"_90":138,"_92":139,"_66":48,"_94":-5,"_95":-7,"_74":140,"_97":141},"1f418b37-abb8-471c-bb7c-00b98d4dc98b","App.tsx","019ecafe-e737-71ee-bbe3-991b0d31de70","019ecafe-e739-75a6-b00e-77a2586588ed",["D",1781522385557],"script","/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { useEffect, useState } from \"https://esm.sh/react@18.2.0\";\nimport { type CallResult, callTool, fetchTools, loadConfig, saveConfig, type ToolDef, type UiConfig } from \"../lib.ts\";\nimport { ConfigPanel } from \"./ConfigPanel.tsx\";\nimport { ToolRunner } from \"./ToolRunner.tsx\";\nimport { ResultView } from \"./ResultView.tsx\";\n\nexport function App() {\n const [config, setConfig] = useState(loadConfig());\n const [tools, setTools] = useState([]);\n const [selected, setSelected] = useState(null);\n const [result, setResult] = useState(null);\n const [running, setRunning] = useState(false);\n const [mcpUrl, setMcpUrl] = useState(\"\");\n const [copied, setCopied] = useState(false);\n\n useEffect(() => {\n setMcpUrl(`${location.origin}/mcp`);\n fetchTools().then((t) => {\n setTools(t);\n if (t.length) setSelected(t[0].name);\n });\n }, []);\n\n function updateConfig(cfg: UiConfig) {\n setConfig(cfg);\n saveConfig(cfg);\n }\n\n async function run(name: string, args: Record) {\n setRunning(true);\n try {\n setResult(await callTool(name, args, config));\n } finally {\n setRunning(false);\n }\n }\n\n function copyUrl() {\n navigator.clipboard?.writeText(mcpUrl);\n setCopied(true);\n setTimeout(() => setCopied(false), 1500);\n }\n\n return (\n

\n {/* Header */}\n

\n 📡\n

CDP MCP — Remote Server

SAP Customer Data Platform ingestion, exposed as a remote MCP server with a live tester.

\n\n

MCP Streamable HTTP endpoint

\n {mcpUrl || \"…\"}\n

\n \n {copied ? \"✓ Copied\" : \"Copy URL\"}\n \n

\n\n \n\n {/* Tester */}\n

🧪 Test the tools

\n \n

\n\n {/* Results */}\n

📥 Result

\n \n

\n\n {/* Connect instructions */}\n

🔗 Connect an MCP client (Claude / Cursor)

Add this to your MCP client config. Credentials are passed via headers:

{`{\n  \"mcpServers\": {\n    \"cdp-ingest\": {\n      \"url\": \"${mcpUrl}\",\n      \"headers\": {\n        \"X-CDP-userKey\": \"YOUR_USER_KEY\",\n        \"X-CDP-secret\": \"YOUR_SECRET\",\n        \"X-CDP-baseUrl\": \"https://universe.cdp.gigya.com\",\n        \"X-CDP-businessUnitId\": \"YOUR_BU_ID\"\n      }\n    }\n  }\n}`}

\n Alternatively, set userKey, secret,\n baseUrl, and businessUnitId as env vars on this val\n (defaults used when headers are absent).\n

\n\n \n

\n );\n}\n",[120,142,134],"4e0e10513c4d94544629d6603b433f0d4ca7d44b1880614ff2f78f4fba1372db","components","5d7e5e30-3996-11f1-bbdd-42b51c65c3df","6e585892-f52b-11ef-a8e1-569c3dd06744","69ed66bc-f52b-11ef-9dac-569c3dd06744",75,["D",1776345339930],5,"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { Counter } from \"./Counter.tsx\";\n\nexport function App() {\n return (\n

React + Hono Starter

\n \n

\n View source\n

\n );\n}\n",[120,142,134],"de0a7e5fc76c6fd6135aff964af1a5835e04e2758b23f3d0c7d9fabffe514df7","README.md",{"_32":161,"_13":152,"_81":162,"_83":-5,"_84":33,"_85":60,"_87":48,"_34":163,"_40":164,"_90":116,"_92":165,"_66":48,"_94":-5,"_95":-7,"_74":166,"_97":167},{"_32":155,"_13":152,"_81":156,"_83":-5,"_84":58,"_85":57,"_87":26,"_34":157,"_40":89,"_90":116,"_92":158,"_66":48,"_94":-5,"_95":-7,"_74":159,"_97":160},"0b22466e-e64e-445e-9fd9-58ed5bb9779b","019ecafe-e739-75a6-b00e-8a7527af6c13",["D",1781522424009],"# CDP MCP — Remote Server + Tester\n\nA **remote MCP server** for SAP Customer Data Platform (CDP) data ingestion,\nplus a built-in web UI to test the tools and inspect results. This is the\nVal Town port of the original stdio MCP implementation — same logic, exposed\nover HTTP (Streamable HTTP transport) so any MCP client can connect remotely.\n\n## What you get\n\n- **`POST /mcp`** — a spec-compliant MCP endpoint (JSON-RPC 2.0). Connect\n Claude, Cursor, or any MCP client. Handles `initialize`, `tools/list`,\n `tools/call`.\n- **A nice tester UI** at `/` — pick a tool, fill in args, run it, and see\n results rendered as tables / JSON payloads (not just raw text).\n- **4 stateless tools**: `list_business_units`, `list_sources`, `list_events`,\n `ingest_profile`.\n\n## Tools\n\n| Tool | Params | Purpose |\n| --- | --- | --- |\n| `list_business_units` | – | Discover business units (with tenant/workspace) and their IDs. |\n| `list_sources` | – | List data sources (applications) for the configured business unit. |\n| `list_events` | `sourceId` | List events available for a source. |\n| `ingest_profile` | `sourceId`, `eventId`, `confirm?`, `customData?` | Generate schema-aware mock data; preview (`confirm:false`) or ingest (`confirm:true`). |\n\n## Configuration\n\nCredentials are resolved per-request, in this order: **request headers → env vars**.\n\n- **From the UI**: enter `userKey`, `secret`, `baseUrl`, `businessUnitId` in the\n Connection panel (stored only in your browser's localStorage).\n- **From an MCP client**: pass headers `X-CDP-userKey`, `X-CDP-secret`,\n `X-CDP-baseUrl`, `X-CDP-businessUnitId`.\n- **As val env vars** (defaults): `userKey`, `secret`, `baseUrl`, `businessUnitId`.\n\n### Connect an MCP client\n\n```json\n{\n \"mcpServers\": {\n \"cdp-ingest\": {\n \"url\": \"https://.web.val.run/mcp\",\n \"headers\": {\n \"X-CDP-userKey\": \"YOUR_USER_KEY\",\n \"X-CDP-secret\": \"YOUR_SECRET\",\n \"X-CDP-baseUrl\": \"https://universe.cdp.gigya.com\",\n \"X-CDP-businessUnitId\": \"YOUR_BU_ID\"\n }\n }\n }\n}\n```\n\n## Architecture\n\n```mermaid\ngraph TD\n Client[\"MCP client
(Claude / Cursor)\"] -->|JSON-RPC POST| MCP[\"/mcp
(server/mcp.ts)\"]\n Browser[\"Tester UI
(React)\"] -->|POST /api/call| API[\"index.ts
(Hono)\"]\n MCP --> Tools[\"server/tools.ts
(tool handlers)\"]\n API --> Tools\n Tools --> CDP[\"server/cdp.ts
(authenticated client + services)\"]\n Tools --> Mock[\"server/mock.ts
(schema-aware data gen)\"]\n CDP -->|\"?userKey&secret\"| SAP[\"SAP CDP API\"]\n```\n\nBoth the MCP layer and the UI API call the **exact same tool handlers**, so the\ntester reflects precisely what an MCP client sees. The UI additionally renders a\n`structured` payload that MCP clients ignore.\n\n## File structure\n\n```\nindex.ts ← Hono entry: /mcp, /api/*, serves UI\nserver/\n mcp.ts ← MCP JSON-RPC over Streamable HTTP\n tools.ts ← tool definitions + handlers (shared)\n cdp.ts ← authenticated CDP client + services\n mock.ts ← schema-aware mock data generator\nfrontend/\n index.html / index.tsx ← UI shell + React entry\n lib.ts ← client API + config store\n components/\n App.tsx ← layout + MCP URL + connect docs\n ConfigPanel.tsx ← credentials form\n ToolRunner.tsx ← tool picker + dynamic args form\n ResultView.tsx ← table / JSON result rendering\n```\n\n## Differences from the stdio implementation\n\n- **Transport**: stdio → HTTP (Streamable HTTP / JSON-RPC). Same tool contract.\n- **Config persistence**: no filesystem on Val Town, so config is passed per\n request (headers / UI / env) instead of `~/.cdp-mcp/config.json`.\n- **Tenant/workspace selection**: collapsed into `list_business_units`, which\n returns business unit IDs directly (tenant + workspace shown for context).\n- **Mock data**: deterministic schema-aware generator (no LLM dependency).\n",[152],"41ddd2db68e6e32a592799457eb9ea059fc9767ef31ca6564f9c22c20f719ec9","b9c749c0-59e1-11f1-bb5f-ee650bb23af1","a50c3760-f53e-11ef-bd6d-569c3dd06744",["D",1779896144390],31,"# React + Hono Starter\n\nA minimal starter template for building client-side React apps with a Hono\nbackend on Val Town. Click **Remix** to get your own copy.\n\n## Picking a starter\n\n| Starter | When to pick it |\n| --- | --- |\n| [`basic-html-starter`](https://www.val.town/x/templates/basic-html-starter) | Static HTML pages. Sprinkle of vanilla JS. No server-side rendering. |\n| [`hono-jsx-starter`](https://www.val.town/x/templates/hono-jsx-starter) | Dynamic server-rendered HTML with JSX. API routes. No React, no SPA. |\n| **[`react-hono-starter`](https://www.val.town/x/templates/react-hono-starter)** *(you're here)* | Client-side React SPA with a Hono API backend. |\n\n**Want to build UI?** Start writing React components in\n[`frontend/components/`](/frontend/components/). Import them into `App.tsx` and\nyou're good to go. Styling is [Twind](https://twind.style/) — just use Tailwind\nutility classes, zero config.\n\n**Want to add an API?** Add routes in [`index.ts`](/index.ts) (there's a\ncommented-out example). Fetch them from your React components.\n\n## Architecture\n\n```mermaid\ngraph LR\n Browser -->|\"GET /\"| Hono[\"index.ts
(Hono server)\"]\n Hono -->|serves| HTML[\"index.html\"]\n HTML -->|loads| Entry[\"index.tsx\"]\n Entry -->|renders| App[\"App.tsx\"]\n App -->|renders| Counter[\"Counter.tsx\"]\n```\n\n## File structure\n\n```\nindex.ts ← Hono backend (serves frontend + API routes)\nfrontend/\n index.html ← HTML shell (loads Twind + React)\n index.tsx ← React entrypoint (mounts )\n favicon.svg ← App icon\n components/\n App.tsx ← Root component (layout + view source link)\n Counter.tsx ← Example component with state\n```\n\n## How it works\n\n1. **`index.ts`** is the HTTP entrypoint — a Hono server that serves the\n frontend and any API routes you add.\n2. **`frontend/index.html`** loads Twind and the React entrypoint.\n3. **`frontend/index.tsx`** mounts the React app.\n4. **`frontend/components/App.tsx`** is the root layout — add new components\n alongside it.\n5. **`frontend/components/Counter.tsx`** is an example stateful component —\n replace it with your own!\n\n## Next steps\n\n- Add API routes in `index.ts`\n- Add new components in `frontend/components/`\n- Add a SQLite database — see the\n [React Hono Example](https://www.val.town/x/stevekrouse/reactHonoExample) for\n a full-stack example with database, queries, and shared types\n",[152],"aaa4f5cc8e5bd01528335cdd2066e164bf95353ce2fe37c616b3e6406f49331e",{"_74":169,"_76":170,"_78":-7},"frontend/components/Counter.tsx",{"_32":171,"_13":172,"_81":173,"_83":145,"_84":33,"_85":174,"_87":26,"_34":175,"_40":176,"_90":138,"_92":177,"_66":48,"_94":-5,"_95":-7,"_74":178,"_97":179},"57a8cc52-3996-11f1-8db6-42b51c65c3df","Counter.tsx","57a8cd2e-3996-11f1-8db6-42b51c65c3df",73,["D",1776345330366],0,"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { useState } from \"https://esm.sh/react@18.2.0\";\n\nexport function Counter() {\n const [count, setCount] = useState(0);\n return (\n

\n Clicked\n setCount((c) => c + 1)}\n class=\"bg-blue-500 hover:bg-blue-600 text-white font-medium px-4 py-2 rounded-lg transition-colors cursor-pointer\"\n >\n {count}\n \n times\n

\n );\n}\n",[120,142,172],"10ce4fbd7e41af337e504c3877201698031249b437d941845f0f7cdc52a79e66",{"_74":264,"_76":-7,"_78":265},{"_74":254,"_76":-7,"_78":255},{"_74":244,"_76":-7,"_78":245},{"_74":234,"_76":-7,"_78":235},{"_74":200,"_76":-7,"_78":229},{"_74":220,"_76":-7,"_78":221},{"_74":211,"_76":-7,"_78":212},{"_74":201,"_76":-7,"_78":202},{"_74":189,"_76":-7,"_78":190},"server/tools.ts",{"_32":191,"_13":192,"_81":193,"_83":194,"_84":58,"_85":195,"_87":26,"_34":196,"_40":176,"_90":138,"_92":197,"_66":48,"_94":-5,"_95":-7,"_74":198,"_97":199},"439d57ea-96c5-4c79-8f9c-8b6a0a7ec4b6","tools.ts","c75b21aa-68ab-11f1-8cc5-1607ee4eb77e","b8ec4e3e-7457-49e4-8e4d-bddf11c6f2bb",4,["D",1781522241844],"// Tool definitions shared by the MCP JSON-RPC layer and the UI test API.\n// Each tool is a pure async function (config, args) => MCP tool result.\n\nimport {\n CdpApiError,\n CdpClient,\n type CdpConfig,\n getBusinessUnits,\n getEvents,\n getEventMapping,\n getEventSchema,\n getSource,\n getSources,\n ingestProfile,\n} from \"./cdp.ts\";\nimport { generateMockData } from \"./mock.ts\";\n\nexport interface ToolResult {\n content: { type: \"text\"; text: string }[];\n isError?: boolean;\n // Structured payload used by the UI to render nicer views; ignored by MCP clients.\n structured?: any;\n}\n\nexport interface ToolDef {\n name: string;\n description: string;\n inputSchema: Record; // JSON Schema\n handler: (config: CdpConfig, args: any) => Promise;\n}\n\nfunction text(s: string, extra: Partial = {}): ToolResult {\n return { content: [{ type: \"text\", text: s }], ...extra };\n}\n\nfunction formatError(e: any, message: string): ToolResult {\n if (e instanceof CdpApiError) {\n const parts = [`❌ ${message}`];\n if (e.url) parts.push(`URL: ${e.url}`);\n if (e.callId) parts.push(`callId: ${e.callId}`);\n return text(parts.join(\"\\n\"), { isError: true, structured: { error: message, url: e.url, callId: e.callId, status: e.status } });\n }\n return text(`❌ ${message}: ${e?.message ?? e}`, { isError: true, structured: { error: String(e?.message ?? e) } });\n}\n\nfunction requireBusinessUnit(config: CdpConfig): string | null {\n return config.businessUnitId ? null : \"❌ businessUnitId is required. Configure it first (use list_business_units).\";\n}\n\nexport const tools: ToolDef[] = [\n {\n name: \"list_business_units\",\n description: \"List all business units (with tenant/workspace info) available to the credentials. Use the returned business unit ID as businessUnitId for the other tools.\",\n inputSchema: { type: \"object\", properties: {}, additionalProperties: false },\n handler: async (config) => {\n try {\n const client = new CdpClient(config);\n const all = await getBusinessUnits(client);\n if (!all.length) return text(\"❌ No business units found. Check your credentials.\", { isError: true });\n const rows = all\n .map((bu) => ({\n id: bu.id,\n name: bu.name,\n description: bu.description,\n tenantId: bu.tenantId,\n tenantName: bu.tenantName,\n workspaceId: bu.workspaceId,\n workspaceName: bu.workspaceName,\n }))\n .sort((a, b) => (a.name || \"\").localeCompare(b.name || \"\"));\n let t = `📋 Business Units (${rows.length})\\n\\n`;\n rows.forEach((bu, i) => {\n t += `${i + 1}. ${bu.name} (ID: ${bu.id})\\n`;\n if (bu.tenantName || bu.workspaceName) t += ` tenant: ${bu.tenantName ?? bu.tenantId} | workspace: ${bu.workspaceName ?? bu.workspaceId}\\n`;\n });\n t += \"\\n📌 Next: call list_sources with this businessUnitId.\";\n return text(t, { structured: { businessUnits: rows } });\n } catch (e) {\n return formatError(e, \"Failed to list business units\");\n }\n },\n },\n\n {\n name: \"list_sources\",\n description: \"List all data sources (applications) for the configured business unit.\",\n inputSchema: { type: \"object\", properties: {}, additionalProperties: false },\n handler: async (config) => {\n const err = requireBusinessUnit(config);\n if (err) return text(err, { isError: true });\n try {\n const client = new CdpClient(config);\n const sources = await getSources(client, config.businessUnitId!);\n if (!sources.length) return text(\"❌ No sources available.\", { isError: true });\n let t = `📋 Data Sources (${sources.length})\\n\\n`;\n sources.forEach((s, i) => {\n t += `${i + 1}. ${s.name} — ID: ${s.id} | Type: ${s.type || \"N/A\"}\\n`;\n if (s.description) t += ` ${s.description}\\n`;\n });\n t += \"\\n📌 Next: call list_events with a sourceId.\";\n return text(t, { structured: { sources } });\n } catch (e) {\n return formatError(e, \"Failed to list sources\");\n }\n },\n },\n\n {\n name: \"list_events\",\n description: \"List all available events for a data source.\",\n inputSchema: {\n type: \"object\",\n properties: { sourceId: { type: \"string\", description: \"The data source ID (from list_sources).\" } },\n required: [\"sourceId\"],\n additionalProperties: false,\n },\n handler: async (config, { sourceId }) => {\n const err = requireBusinessUnit(config);\n if (err) return text(err, { isError: true });\n try {\n const client = new CdpClient(config);\n const [events, source] = await Promise.all([\n getEvents(client, config.businessUnitId!, sourceId),\n getSource(client, config.businessUnitId!, sourceId).catch(() => ({ name: sourceId } as any)),\n ]);\n if (!events.length) return text(`❌ No events for source \"${source.name}\".`, { isError: true });\n let t = `📋 Events for \"${source.name}\" (${events.length})\\n\\n`;\n events.forEach((e, i) => {\n t += `${i + 1}. ${e.name} — ID: ${e.id}\\n`;\n if (e.description) t += ` ${e.description}\\n`;\n });\n t += \"\\n📌 Next: call ingest_profile with sourceId and eventId.\";\n return text(t, { structured: { source, events } });\n } catch (e) {\n return formatError(e, \"Failed to list events\");\n }\n },\n },\n\n {\n name: \"ingest_profile\",\n description:\n \"Generate mock profile data from the event schema and ingest it into CDP. \" +\n \"Omit confirm or set to false to preview generated data first.\",\n inputSchema: {\n type: \"object\",\n properties: {\n sourceId: { type: \"string\", description: \"Data source ID.\" },\n eventId: { type: \"string\", description: \"Event ID.\" },\n customData: { type: \"object\", description: \"Fields to override in generated data.\", additionalProperties: true },\n confirm: { type: \"boolean\", description: \"Set true to execute ingestion. Default: preview only.\" },\n },\n required: [\"sourceId\", \"eventId\"],\n additionalProperties: false,\n },\n handler: async (config, { sourceId, eventId, customData, confirm }) => {\n const err = requireBusinessUnit(config);\n if (err) return text(err, { isError: true });\n try {\n const client = new CdpClient(config);\n const buId = config.businessUnitId!;\n const [source, events, schema, mapping] = await Promise.all([\n getSource(client, buId, sourceId),\n getEvents(client, buId, sourceId),\n getEventSchema(client, buId, sourceId, eventId),\n getEventMapping(client, buId, sourceId, eventId).catch(() => undefined),\n ]);\n const event = events.find((e) => e.id === eventId);\n if (!event) return text(`❌ Event \"${eventId}\" not found in \"${source.name}\".`, { isError: true });\n\n let data = generateMockData(schema, mapping);\n if (customData && typeof customData === \"object\") data = { ...data, ...customData };\n\n if (!confirm) {\n return text(\n `📊 Preview\\nSource: ${source.name} | Event: ${event.name}\\n\\n` +\n \"```json\\n\" + JSON.stringify(data, null, 2) + \"\\n```\\n\\nCall again with confirm: true to ingest.\",\n { structured: { mode: \"preview\", source, event, schemaFields: schema.fields, data } },\n );\n }\n\n const response = await ingestProfile(client, buId, sourceId, eventId, data);\n return text(\n `🚀 Ingested\\nSource: ${source.name} | Event: ${event.name}` +\n (response?.callId ? `\\ncallId: ${response.callId}` : \"\") +\n \"\\n\\n```json\\n\" + JSON.stringify(data, null, 2) + \"\\n```\",\n { structured: { mode: \"ingested\", source, event, data, response } },\n );\n } catch (e: any) {\n const code = e instanceof CdpApiError ? e.status : e?.status;\n if (code === 404) return formatError(e, \"Source or event not found.\");\n if (code === 403) return formatError(e, \"Permission denied.\");\n if (code === 400) return formatError(e, `Bad request: ${e?.message ?? \"\"}`);\n return formatError(e, `Ingestion failed: ${e?.message ?? e}`);\n }\n },\n },\n];\n\nexport const toolMap: Record = Object.fromEntries(tools.map((t) => [t.name, t]));\n",[200,192],"3cc157ba871bf921f400927b4e330041a7e97005403a53c0acad0a0e521b6bf6","server","server/mock.ts",{"_32":203,"_13":204,"_81":205,"_83":194,"_84":58,"_85":206,"_87":26,"_34":207,"_40":176,"_90":138,"_92":208,"_66":48,"_94":-5,"_95":-7,"_74":209,"_97":210},"ad137e67-21a0-4a16-9d66-8adcc2f3bd25","mock.ts","b54b1e16-68ab-11f1-9ab7-1607ee4eb77e",3,["D",1781522211538],"// Schema-aware synthetic data generator.\n// Produces realistic-looking values based on field name / type / format,\n// mirroring the intent of the original mock-data-generator (without the LLM call).\n\nimport type { EventSchema, EventMapping, SchemaField } from \"./cdp.ts\";\n\nconst FIRST_NAMES = [\n \"Jennifer\", \"Michael\", \"Sarah\", \"David\", \"Emily\", \"James\", \"Jessica\",\n \"Daniel\", \"Ashley\", \"Matthew\", \"Amanda\", \"Christopher\", \"Olivia\", \"Noah\",\n];\nconst LAST_NAMES = [\n \"Smith\", \"Johnson\", \"Williams\", \"Brown\", \"Jones\", \"Garcia\", \"Miller\",\n \"Davis\", \"Martinez\", \"Rodriguez\", \"Wilson\", \"Anderson\", \"Taylor\",\n];\nconst DOMAINS = [\"gmail.com\", \"outlook.com\", \"yahoo.com\", \"example.com\", \"company.com\"];\nconst CITIES = [\"New York\", \"London\", \"Berlin\", \"Paris\", \"Tokyo\", \"Madrid\", \"Toronto\"];\nconst COUNTRIES = [\"US\", \"GB\", \"DE\", \"FR\", \"JP\", \"ES\", \"CA\"];\n\nfunction pick(arr: T[]): T {\n return arr[Math.floor(Math.random() * arr.length)];\n}\nfunction num(min: number, max: number): number {\n return Math.floor(Math.random() * (max - min + 1)) + min;\n}\n\nfunction valueForField(field: SchemaField): any {\n const name = field.name.toLowerCase();\n const leaf = name.split(\".\").pop() || name;\n\n if (field.enum?.length) return pick(field.enum);\n\n // Format-driven\n if (field.format === \"email\" || leaf.includes(\"email\")) {\n const f = pick(FIRST_NAMES).toLowerCase();\n const l = pick(LAST_NAMES).toLowerCase();\n return `${f}.${l}${num(1, 999)}@${pick(DOMAINS)}`;\n }\n if (field.format === \"date-time\" || leaf.includes(\"timestamp\") || leaf.endsWith(\"at\") || leaf.includes(\"date\")) {\n return new Date(Date.now() - num(0, 1000 * 60 * 60 * 24 * 365)).toISOString();\n }\n if (field.format === \"uuid\" || leaf === \"id\" || leaf.endsWith(\"id\")) {\n return crypto.randomUUID();\n }\n\n // Name-driven\n if (leaf.includes(\"firstname\") || leaf === \"first\" || leaf === \"givenname\") return pick(FIRST_NAMES);\n if (leaf.includes(\"lastname\") || leaf === \"last\" || leaf === \"familyname\" || leaf === \"surname\") return pick(LAST_NAMES);\n if (leaf.includes(\"phone\") || leaf.includes(\"mobile\")) return `+1${num(200, 999)}${num(200, 999)}${num(1000, 9999)}`;\n if (leaf.includes(\"city\")) return pick(CITIES);\n if (leaf.includes(\"country\")) return pick(COUNTRIES);\n if (leaf.includes(\"zip\") || leaf.includes(\"postal\")) return String(num(10000, 99999));\n if (leaf.includes(\"address\") || leaf.includes(\"street\")) return `${num(1, 9999)} ${pick(LAST_NAMES)} St`;\n if (leaf.includes(\"age\")) return num(18, 80);\n if (leaf.includes(\"gender\")) return pick([\"m\", \"f\", \"u\"]);\n if (leaf.includes(\"company\") || leaf.includes(\"organization\")) return `${pick(LAST_NAMES)} Inc`;\n if (leaf.includes(\"url\") || leaf.includes(\"website\")) return `https://${pick(DOMAINS)}`;\n\n // Type-driven fallback\n switch (field.type) {\n case \"integer\":\n case \"number\":\n return num(1, 1000);\n case \"boolean\":\n return Math.random() > 0.5;\n case \"array\":\n return [];\n case \"object\":\n return {};\n default:\n return `${leaf}_${num(100, 999)}`;\n }\n}\n\n/**\n * Build a nested object out of dot-delimited field names.\n */\nfunction setNested(target: Record, path: string, value: any): void {\n const parts = path.split(\".\");\n let cur = target;\n for (let i = 0; i < parts.length - 1; i++) {\n cur[parts[i]] ??= {};\n cur = cur[parts[i]];\n }\n cur[parts[parts.length - 1]] = value;\n}\n\nexport function generateMockData(\n schema: EventSchema,\n _mapping?: EventMapping,\n): Record {\n const out: Record = {};\n const fields = schema.fields || [];\n\n if (fields.length === 0) {\n // No schema info — produce a minimal sensible profile.\n const first = pick(FIRST_NAMES);\n const last = pick(LAST_NAMES);\n return {\n FirstName: first,\n LastName: last,\n Email: `${first.toLowerCase()}.${last.toLowerCase()}${num(1, 999)}@${pick(DOMAINS)}`,\n };\n }\n\n for (const field of fields) {\n // Prefer required fields and a sampling of optional ones for a realistic payload.\n if (field.required || Math.random() > 0.3) {\n setNested(out, field.name, valueForField(field));\n }\n }\n return out;\n}\n",[200,204],"97b83d281af124aa87bb92e971f9621c1357a99a4a36205455e578b038eba567","server/mcp.ts",{"_32":213,"_13":214,"_81":215,"_83":194,"_84":58,"_85":148,"_87":26,"_34":216,"_40":176,"_90":138,"_92":217,"_66":48,"_94":-5,"_95":-7,"_74":218,"_97":219},"595c9830-9f21-4775-8fde-b385bd4009a3","mcp.ts","d29940f6-68ab-11f1-9410-1607ee4eb77e",["D",1781522260706],"// Minimal MCP server over the Streamable HTTP transport (JSON-RPC 2.0).\n// Implements: initialize, notifications/initialized, tools/list, tools/call.\n// Spec: https://modelcontextprotocol.io/specification/2025-03-26/basic/transports\n//\n// Config resolution order (per request): X-CDP-* headers > env vars.\n// This lets one deployed server serve different credentials per MCP client.\n\nimport type { CdpConfig } from \"./cdp.ts\";\nimport { toolMap, tools } from \"./tools.ts\";\n\nconst PROTOCOL_VERSION = \"2025-03-26\";\nconst SERVER_INFO = { name: \"cdp-ingest\", version: \"1.0.0\" };\n\ninterface JsonRpcRequest {\n jsonrpc: \"2.0\";\n id?: string | number | null;\n method: string;\n params?: any;\n}\n\nfunction rpcResult(id: any, result: any) {\n return { jsonrpc: \"2.0\", id, result };\n}\nfunction rpcError(id: any, code: number, message: string, data?: any) {\n return { jsonrpc: \"2.0\", id, error: { code, message, ...(data !== undefined ? { data } : {}) } };\n}\n\nexport function resolveConfig(req: Request): CdpConfig {\n const h = req.headers;\n const env = (k: string) => Deno.env.get(k) || undefined;\n return {\n userKey: h.get(\"x-cdp-userkey\") || env(\"userKey\") || \"\",\n secret: h.get(\"x-cdp-secret\") || env(\"secret\") || \"\",\n baseUrl: h.get(\"x-cdp-baseurl\") || env(\"baseUrl\") || \"https://universe.cdp.gigya.com\",\n businessUnitId: h.get(\"x-cdp-businessunitid\") || env(\"businessUnitId\") || undefined,\n };\n}\n\nasync function handleRpc(rpc: JsonRpcRequest, config: CdpConfig): Promise {\n const { id, method, params } = rpc;\n\n switch (method) {\n case \"initialize\":\n return rpcResult(id, {\n protocolVersion: PROTOCOL_VERSION,\n capabilities: { tools: { listChanged: false } },\n serverInfo: SERVER_INFO,\n });\n\n // Notifications have no id and expect no response.\n case \"notifications/initialized\":\n case \"notifications/cancelled\":\n return null;\n\n case \"ping\":\n return rpcResult(id, {});\n\n case \"tools/list\":\n return rpcResult(id, {\n tools: tools.map((t) => ({\n name: t.name,\n description: t.description,\n inputSchema: t.inputSchema,\n })),\n });\n\n case \"tools/call\": {\n const name = params?.name;\n const args = params?.arguments ?? {};\n const tool = toolMap[name];\n if (!tool) return rpcError(id, -32602, `Unknown tool: ${name}`);\n try {\n const result = await tool.handler(config, args);\n return rpcResult(id, {\n content: result.content,\n isError: result.isError ?? false,\n });\n } catch (e: any) {\n return rpcResult(id, {\n content: [{ type: \"text\", text: `❌ Tool execution error: ${e?.message ?? e}` }],\n isError: true,\n });\n }\n }\n\n default:\n return rpcError(id, -32601, `Method not found: ${method}`);\n }\n}\n\n/**\n * Handle a POST to the /mcp endpoint. Accepts a single JSON-RPC request or a batch.\n * Returns a Response (JSON). Notifications produce 202 Accepted with no body.\n */\nexport async function handleMcpRequest(req: Request): Promise {\n let body: any;\n try {\n body = await req.json();\n } catch {\n return Response.json(rpcError(null, -32700, \"Parse error\"), { status: 400 });\n }\n\n const config = resolveConfig(req);\n\n if (Array.isArray(body)) {\n const responses = (await Promise.all(body.map((r) => handleRpc(r, config)))).filter((r) => r !== null);\n if (responses.length === 0) return new Response(null, { status: 202 });\n return Response.json(responses);\n }\n\n const response = await handleRpc(body, config);\n if (response === null) return new Response(null, { status: 202 });\n return Response.json(response);\n}\n",[200,214],"15ceb2877c8e22e9fa9bff028b2de786cef77cd21ac1f4b8511bc7f965fc2ebe","server/cdp.ts",{"_32":222,"_13":223,"_81":224,"_83":194,"_84":58,"_85":22,"_87":26,"_34":225,"_40":176,"_90":138,"_92":226,"_66":48,"_94":-5,"_95":-7,"_74":227,"_97":228},"c1ce2e5f-c59c-4830-b8e5-ce4c8da65048","cdp.ts","a8e26576-68ab-11f1-a0ba-1607ee4eb77e",["D",1781522190720],"// CDP API client + services, ported from the stdio implementation for Deno/Val Town.\n// No filesystem: configuration is passed explicitly per-request instead of read from ~/.cdp-mcp.\n\nexport interface CdpConfig {\n userKey: string;\n secret: string;\n baseUrl: string;\n businessUnitId?: string;\n}\n\nexport interface DataSource {\n id: string;\n name: string;\n type?: string;\n description?: string;\n}\n\nexport interface DataEvent {\n id: string;\n name: string;\n description?: string;\n hasDynamicSchema?: boolean;\n schema?: any;\n}\n\nexport interface SchemaField {\n name: string;\n type: string;\n required: boolean;\n description?: string;\n format?: string;\n enum?: any[];\n}\n\nexport interface EventSchema {\n eventId: string;\n fields: SchemaField[];\n raw?: any;\n}\n\nexport type EventMapping = any;\n\nexport class CdpApiError extends Error {\n status?: number;\n url?: string;\n callId?: string;\n body?: any;\n constructor(message: string, opts: { status?: number; url?: string; callId?: string; body?: any } = {}) {\n super(message);\n this.name = \"CdpApiError\";\n Object.assign(this, opts);\n }\n}\n\n/**\n * Authenticated CDP API client. Every request automatically injects\n * ?userKey=...&secret=... as query params, mirroring the original axios interceptor.\n */\nexport class CdpClient {\n constructor(private config: CdpConfig) {}\n\n private buildUrl(endpoint: string, params: Record = {}): string {\n const url = new URL(endpoint, this.config.baseUrl);\n const all = { ...params, userKey: this.config.userKey, secret: this.config.secret };\n for (const [k, v] of Object.entries(all)) {\n if (v !== undefined && v !== null) url.searchParams.set(k, String(v));\n }\n return url.toString();\n }\n\n async request(opts: {\n endpoint: string;\n method?: string;\n params?: Record;\n data?: any;\n }): Promise {\n const { endpoint, method = \"GET\", params = {}, data } = opts;\n const url = this.buildUrl(endpoint, params);\n\n const res = await fetch(url, {\n method,\n headers: { \"Content-Type\": \"application/json\" },\n body: data !== undefined ? JSON.stringify(data) : undefined,\n });\n\n const callIdHeader = res.headers.get(\"x-callid\") || res.headers.get(\"callid\") ||\n res.headers.get(\"x-gigya-callid\") || undefined;\n\n let json: any = null;\n const text = await res.text();\n if (text) {\n try {\n json = JSON.parse(text);\n } catch {\n json = text;\n }\n }\n\n // Mirror the original error handling: gigya returns errorCode in body even on HTTP 200.\n if (json && typeof json === \"object\" && json.errorCode && json.errorCode !== 0) {\n const msg = json.errorMessage || json.errorDetails || \"API request failed\";\n throw new CdpApiError(msg, {\n status: res.status,\n url,\n callId: json.callId || callIdHeader,\n body: json,\n });\n }\n\n if (!res.ok) {\n const msg = (json && (json.errorMessage || json.message)) || `HTTP ${res.status}`;\n throw new CdpApiError(msg, { status: res.status, url, callId: callIdHeader, body: json });\n }\n\n if (json && typeof json === \"object\" && callIdHeader && !json.callId) {\n json.callId = callIdHeader;\n }\n\n return json as T;\n }\n\n get(endpoint: string, params?: Record) {\n return this.request({ endpoint, method: \"GET\", params });\n }\n post(endpoint: string, data?: any, params?: Record) {\n return this.request({ endpoint, method: \"POST\", data, params });\n }\n}\n\n// ---------------------------------------------------------------------------\n// Services (mirror the mono-repo ApplicationService / SchemaService / IngestService)\n// ---------------------------------------------------------------------------\n\nexport async function getBusinessUnits(client: CdpClient): Promise {\n const all = await client.get(\"/api/businessunits\");\n return Array.isArray(all) ? all : [];\n}\n\nexport async function getSources(client: CdpClient, businessUnitId: string): Promise {\n const res = await client.get(`/api/businessunits/${businessUnitId}/applications`);\n return res || [];\n}\n\nexport async function getSource(client: CdpClient, businessUnitId: string, sourceId: string): Promise {\n return client.get(`/api/businessunits/${businessUnitId}/applications/${sourceId}`);\n}\n\nexport async function getEvents(client: CdpClient, businessUnitId: string, sourceId: string): Promise {\n const res = await client.get(\n `/api/businessunits/${businessUnitId}/applications/${sourceId}/dataevents`,\n );\n return res || [];\n}\n\nexport async function getEventSchema(\n client: CdpClient,\n businessUnitId: string,\n sourceId: string,\n eventId: string,\n): Promise {\n const event = await client.get(\n `/api/businessunits/${businessUnitId}/applications/${sourceId}/dataevents/${eventId}`,\n );\n\n if (event.hasDynamicSchema) {\n const response = await client.get(\n `/api/businessunits/${businessUnitId}/applications/${sourceId}/dataevents/${eventId}/schemas/dynamic`,\n );\n const rootSchema = response.dynamicSchemas?.[\"/\"] || {};\n return { eventId, fields: extractSchemaFields(rootSchema), raw: response };\n }\n\n const fields = event.schema ? extractSchemaFields(event.schema) : [];\n return { eventId, fields };\n}\n\nexport async function getEventMapping(\n client: CdpClient,\n businessUnitId: string,\n sourceId: string,\n eventId: string,\n): Promise {\n return client.get(\n `/api/businessunits/${businessUnitId}/applications/${sourceId}/dataevents/${eventId}/mappingsV2`,\n );\n}\n\nexport async function ingestProfile(\n client: CdpClient,\n businessUnitId: string,\n applicationId: string,\n dataEventId: string,\n data: any,\n): Promise {\n return client.post(\n `/api/businessunits/${businessUnitId}/applications/${applicationId}/dataevents/${dataEventId}/event?isTraceMode=true`,\n data,\n );\n}\n\nexport function extractSchemaFields(schema: any, prefix = \"\"): SchemaField[] {\n const fields: SchemaField[] = [];\n if (schema?.type === \"object\" && schema.properties) {\n const required = new Set(schema.required || []);\n for (const [key, value] of Object.entries(schema.properties)) {\n const fullName = prefix ? `${prefix}.${key}` : key;\n if (value.type === \"object\" && value.properties) {\n fields.push(...extractSchemaFields(value, fullName));\n } else {\n const type = Array.isArray(value.type) ? value.type[0] : (value.type || \"string\");\n const enumValues = value.enum || (value.oneOf?.map((o: any) => o.const).filter(Boolean));\n fields.push({\n name: fullName,\n type: type as string,\n required: required.has(key),\n description: value.description,\n format: value.format,\n ...(enumValues?.length ? { enum: enumValues } : {}),\n });\n }\n }\n }\n return fields;\n}\n",[200,223],"e278f9186710e39a91c02845b0c0175cf805791ea0fc76a98919b5d84179ae51",{"_32":230,"_13":200,"_81":194,"_83":-5,"_84":58,"_85":22,"_87":26,"_34":231,"_40":176,"_90":232,"_92":-5,"_66":48,"_94":-5,"_95":-7,"_74":233,"_97":-5},"92f2b639-db36-472d-be54-5253cfb092c6",["D",1781522190720],"directory",[200],"frontend/lib.ts",{"_32":236,"_13":237,"_81":238,"_83":113,"_84":58,"_85":239,"_87":26,"_34":240,"_40":176,"_90":138,"_92":241,"_66":48,"_94":-5,"_95":-7,"_74":242,"_97":243},"a86e0a40-7923-4499-ac18-69a13320d5c7","lib.ts","eceb8dc4-68ab-11f1-be0c-1607ee4eb77e",9,["D",1781522304846],"// Shared client-side types + a tiny localStorage-backed config store.\n\nexport interface ToolDef {\n name: string;\n description: string;\n inputSchema: {\n type: string;\n properties?: Record;\n required?: string[];\n };\n}\n\nexport interface CallResult {\n tool: string;\n args: Record;\n durationMs: number;\n isError: boolean;\n content: { type: string; text: string }[];\n structured: any;\n}\n\nexport interface UiConfig {\n userKey: string;\n secret: string;\n baseUrl: string;\n businessUnitId: string;\n}\n\nconst KEY = \"cdp-mcp-config\";\n\nexport const defaultConfig: UiConfig = {\n userKey: \"\",\n secret: \"\",\n baseUrl: \"https://universe.cdp.gigya.com\",\n businessUnitId: \"\",\n};\n\nexport function loadConfig(): UiConfig {\n try {\n const raw = localStorage.getItem(KEY);\n if (raw) return { ...defaultConfig, ...JSON.parse(raw) };\n } catch {\n // ignore\n }\n return { ...defaultConfig };\n}\n\nexport function saveConfig(cfg: UiConfig): void {\n try {\n localStorage.setItem(KEY, JSON.stringify(cfg));\n } catch {\n // ignore\n }\n}\n\nexport async function callTool(tool: string, args: Record, config: UiConfig): Promise {\n const res = await fetch(\"/api/call\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ tool, args, config }),\n });\n const data = await res.json();\n if (!res.ok) {\n return {\n tool,\n args,\n durationMs: 0,\n isError: true,\n content: [{ type: \"text\", text: data.error || `HTTP ${res.status}` }],\n structured: null,\n };\n }\n return data as CallResult;\n}\n\nexport async function fetchTools(): Promise {\n const res = await fetch(\"/api/tools\");\n const data = await res.json();\n return data.tools as ToolDef[];\n}\n",[120,237],"e0aa6c6a62655688d5bb0c7104e33425f3c05933cf4e03200b5c4cf4905ed009","frontend/components/ToolRunner.tsx",{"_32":246,"_13":247,"_81":248,"_83":136,"_84":58,"_85":249,"_87":26,"_34":250,"_40":176,"_90":138,"_92":251,"_66":48,"_94":-5,"_95":-7,"_74":252,"_97":253},"0843d791-1b13-4d7b-a531-60c4a91624d4","ToolRunner.tsx","0f73e8fa-68ac-11f1-a168-1607ee4eb77e",12,["D",1781522362800],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { useState } from \"https://esm.sh/react@18.2.0\";\nimport type { ToolDef } from \"../lib.ts\";\n\nconst TOOL_ICON: Record = {\n list_business_units: \"🏢\",\n list_sources: \"🔌\",\n list_events: \"⚡\",\n ingest_profile: \"👤\",\n};\n\ninterface Props {\n tools: ToolDef[];\n selected: string | null;\n onSelect: (name: string) => void;\n running: boolean;\n onRun: (name: string, args: Record) => void;\n}\n\nexport function ToolRunner({ tools, selected, onSelect, running, onRun }: Props) {\n const [args, setArgs] = useState>({});\n const tool = tools.find((t) => t.name === selected) || null;\n\n function select(name: string) {\n setArgs({});\n onSelect(name);\n }\n\n function field(name: string, schema: { type?: string; description?: string }, required: boolean) {\n const val = args[name] ?? \"\";\n if (schema.type === \"boolean\") {\n return (\n \n setArgs({ ...args, [name]: (e.target as HTMLInputElement).checked })}\n />\n {name}\n {schema.description}\n \n );\n }\n const isObject = schema.type === \"object\";\n return (\n \n \n {name}{required && *}\n {schema.description && — {schema.description}}\n \n {isObject\n ? (\n setArgs({ ...args, [name]: (e.target as HTMLTextAreaElement).value })}\n class=\"mt-1 w-full px-3 py-2 rounded-lg border border-slate-300 outline-none focus:border-blue-500 text-sm font-mono h-24\"\n />\n )\n : (\n setArgs({ ...args, [name]: (e.target as HTMLInputElement).value })}\n class=\"mt-1 w-full px-3 py-2 rounded-lg border border-slate-300 outline-none focus:border-blue-500 text-sm font-mono\"\n />\n )}\n \n );\n }\n\n function run() {\n if (!tool) return;\n const props = tool.inputSchema.properties || {};\n const finalArgs: Record = {};\n for (const [name, schema] of Object.entries(props)) {\n const v = args[name];\n if (v === undefined || v === \"\") continue;\n if (schema.type === \"object\" && typeof v === \"string\") {\n try {\n finalArgs[name] = JSON.parse(v);\n } catch {\n finalArgs[name] = v; // server will validate\n }\n } else {\n finalArgs[name] = v;\n }\n }\n onRun(tool.name, finalArgs);\n }\n\n return (\n

\n {/* Tool list */}\n

\n {tools.map((t) => (\n select(t.name)}\n class={`w-full text-left px-3 py-2 rounded-lg border transition-colors ${\n selected === t.name\n ? \"border-blue-500 bg-blue-50\"\n : \"border-slate-200 bg-white hover:border-slate-300\"\n }`}\n >\n

\n {TOOL_ICON[t.name] ?? \"🛠️\"}\n {t.name}\n

{t.description}

\n \n ))}\n

\n\n {/* Args form */}\n

\n {!tool\n ?

Select a tool to configure and run it.

\n : (\n

{tool.name}

{tool.description}

\n {Object.keys(tool.inputSchema.properties || {}).length === 0\n ?

No parameters.

\n : (\n

\n {Object.entries(tool.inputSchema.properties || {}).map(([name, schema]) =>\n field(name, schema, (tool.inputSchema.required || []).includes(name))\n )}\n

\n )}\n \n {running ? \"Running…\" : \"▶ Run tool\"}\n \n

\n )}\n

\n );\n}\n",[120,142,247],"95568b8a6d9752ee07d93cfdc5efbaae8b0a679c5e4ac999c06d8bab7839e568","frontend/components/ResultView.tsx",{"_32":256,"_13":257,"_81":258,"_83":136,"_84":58,"_85":259,"_87":26,"_34":260,"_40":176,"_90":138,"_92":261,"_66":48,"_94":-5,"_95":-7,"_74":262,"_97":263},"54c0a5c0-cdb0-4048-9801-23129fa0a59a","ResultView.tsx","038a6ffa-68ac-11f1-b0cd-1607ee4eb77e",11,["D",1781522342817],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport type { CallResult } from \"../lib.ts\";\n\nfunction Json({ data }: { data: any }) {\n return (\n

\n      {JSON.stringify(data, null, 2)}\n

\n );\n}\n\nfunction CopyButton({ value }: { value: string }) {\n return (\n navigator.clipboard?.writeText(value)}\n class=\"text-xs text-slate-500 hover:text-slate-800 border border-slate-200 rounded px-2 py-1\"\n title=\"Copy ID\"\n >\n 📋 copy\n \n );\n}\n\nfunction EntityTable(\n { title, rows, columns }: {\n title: string;\n rows: any[];\n columns: { key: string; label: string; mono?: boolean }[];\n },\n) {\n return (\n

{title} ({rows.length})

\n \n \n \n {columns.map((c) => )}\n \n \n \n \n {rows.map((r, i) => (\n \n {columns.map((c) => (\n \n ))}\n \n \n ))}\n \n

{c.label}
\n {r[c.key] ?? —}\n	\n {r.id && }\n

\n );\n}\n\nfunction StructuredView({ s }: { s: any }) {\n if (!s) return null;\n\n if (s.businessUnits) {\n return (\n \n );\n }\n\n if (s.sources) {\n return (\n \n );\n }\n\n if (s.events) {\n return (\n

\n {s.source &&

Source: {s.source.name}

}\n \n

\n );\n }\n\n if (s.mode === \"preview\" || s.mode === \"ingested\") {\n return (\n

\n \n {s.mode === \"ingested\" ? \"🚀 Ingested\" : \"📊 Preview\"}\n \n {s.source && {s.source.name} · {s.event?.name}}\n {s.response?.callId && (\n callId: {s.response.callId}\n )}\n

\n {s.schemaFields && s.schemaFields.length > 0 && (\n

Schema fields ({s.schemaFields.length})

\n {s.schemaFields.map((f: any) => (\n \n {f.name}: {f.type}{f.required ? \"*\" : \"\"}\n \n ))}\n

\n )}\n

Generated payload

\n \n

\n );\n }\n\n if (s.error) {\n return (\n

{s.error}

\n {s.url &&

{s.url}

}\n {s.callId &&

callId: {s.callId}

}\n

\n );\n }\n\n return ;\n}\n\nexport function ResultView({ result }: { result: CallResult | null }) {\n if (!result) {\n return (\n

\n Run a tool to see results here.\n

\n );\n }\n\n const rawText = result.content.map((c) => c.text).join(\"\\n\");\n\n return (\n

\n {result.tool}\n {result.isError\n ? error\n : success}\n {result.durationMs} ms\n

\n\n {result.structured\n ? \n :

{rawText}

}\n\n

Raw MCP text content

{rawText}

\n );\n}\n",[120,142,257],"3ed5ecc142b09828aba1fa0d4095ade7fea00a74f74c87f4de9770a1069cac9e","frontend/components/ConfigPanel.tsx",{"_32":266,"_13":267,"_81":268,"_83":136,"_84":58,"_85":269,"_87":26,"_34":270,"_40":176,"_90":138,"_92":271,"_66":48,"_94":-5,"_95":-7,"_74":272,"_97":273},"61548b58-37d6-4fcd-8a69-0f976dd579f3","ConfigPanel.tsx","f4b13c3e-68ab-11f1-917a-1607ee4eb77e",10,["D",1781522317888],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { useState } from \"https://esm.sh/react@18.2.0\";\nimport type { UiConfig } from \"../lib.ts\";\n\ninterface Props {\n config: UiConfig;\n onChange: (cfg: UiConfig) => void;\n}\n\nfunction Field(\n { label, value, onChange, type = \"text\", placeholder }: {\n label: string;\n value: string;\n onChange: (v: string) => void;\n type?: string;\n placeholder?: string;\n },\n) {\n return (\n \n {label}\n onChange((e.target as HTMLInputElement).value)}\n class=\"mt-1 w-full px-3 py-2 rounded-lg border border-slate-300 focus:border-blue-500 focus:ring-1 focus:ring-blue-500 outline-none text-sm font-mono\"\n />\n \n );\n}\n\nexport function ConfigPanel({ config, onChange }: Props) {\n const [open, setOpen] = useState(true);\n const set = (k: keyof UiConfig) => (v: string) => onChange({ ...config, [k]: v });\n const ready = config.userKey && config.secret;\n\n return (\n

\n setOpen((o) => !o)}\n class=\"w-full flex items-center justify-between px-5 py-4 text-left\"\n >\n

\n 🔐\n

Connection & Credentials

\n \n {ready ? \"ready\" : \"needs credentials\"}\n \n

\n {open ? \"▲\" : \"▼\"}\n \n\n {open && (\n

\n \n \n \n \n

\n Stored only in your browser (localStorage) and sent per-request. Use list_business_units to discover a businessUnitId.\n

\n )}\n

\n );\n}\n",[120,142,267],"2d8dcac04a059b8baecc01a3787ad209a66d68f3e429d3d5134f36d44fc95405",["D",1781522163344],"legacyEnvVars","httpPrivacy","description","Remote MCP server for SAP CDP ingestion + a web tester UI","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/64dc00cc-94d9-47dd-81b1-dde02610d900/square512?exp=1789559999&sig=919739a563bb9acb90fc6bc4f6c1789207958a7e1bd397d82b192d76e7e11de2","userId","c5506c00-2fdd-42b7-a285-6b73e4a74058","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","019ecaea-f50a-777f-90f7-048d908ec985","tursoName","88280eeb5b7549a59c027f5038efbc0a","tursoHostname","88280eeb5b7549a59c027f5038efbc0a-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789522836959],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_317":313},"org",{"_11":12,"_310":311,"_312":313,"_281":282,"_314":315,"_316":48},"branch","displayName","רבקי וקסלר-וינטר","avatar","https://lh3.googleusercontent.com/a/ACg8ocKIftIw8s8xWcs-yy31Pl1xsAsEfhdyvfcuMRQYJ_CM_buNQUs=s96-c","tier","free","canRestrictVals","profileImageUrl","","adoptOrgId",{"_32":59,"_13":14,"_34":433,"_46":-5,"_275":48,"_49":50,"_276":50,"_277":278,"_279":280,"_281":282,"_283":82,"_284":26,"_285":-5,"_286":-5,"_287":176,"_53":288,"_289":290,"_291":292,"_293":434,"_295":-5,"_296":297,"_298":297,"_299":300,"_301":300,"_302":300,"_303":297,"_304":297,"_305":435,"_307":436,"_309":437,"_47":48},"tree",[369,379,384,385],"files",[369,370,371,372,373,374,375,376,377,378,379,380,381,382,383,384,385],"counts",{"_359":176,"_360":89,"_361":176,"_362":363,"_364":365},"contents",[346,347,348,349],"upstreamProject",{"_32":39,"_13":56,"_277":343,"_279":280,"_49":50,"_305":344},"upstreamBranch",{"_32":33,"_34":341,"_36":342,"_13":16,"_38":39,"_40":41,"_42":-5,"_43":-5,"_44":45,"_46":-5,"_47":48,"_49":50,"_51":52,"_53":54,"_55":56},"emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1740674013689],["D",1785420707976],"Starter template with client-side React & Hono server",{"_11":52,"_317":345},"https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/129cab32-3bd7-4c3e-f39b-f12900c76100/square512?exp=1789559999&sig=5c07b77d973a9a7831cc1779f4bd4ec152796753863d0aeae4088e1e0ae03921",{"_32":356,"_13":120,"_81":113,"_83":-5,"_84":58,"_85":89,"_87":26,"_34":357,"_40":176,"_90":232,"_92":-5,"_66":48,"_94":-5,"_74":358},{"_32":230,"_13":200,"_81":194,"_83":-5,"_84":58,"_85":22,"_87":26,"_34":354,"_40":176,"_90":232,"_92":-5,"_66":48,"_94":-5,"_74":355},{"_32":155,"_13":152,"_81":156,"_83":-5,"_84":58,"_85":57,"_87":26,"_34":352,"_40":89,"_90":116,"_92":158,"_66":48,"_94":-5,"_74":353},{"_32":80,"_13":75,"_81":82,"_83":-5,"_84":58,"_85":86,"_87":26,"_34":350,"_40":89,"_90":91,"_92":93,"_66":48,"_94":-5,"_74":351},["D",1781522276790],[75],["D",1781522424009],[152],["D",1781522190720],[200],"b34b6501-b9b3-4b98-b939-af359c16705a",["D",1781522163344],[120],"pulls","branches","forks","envVars",{"_366":176,"_368":176},"connections",{"_366":176,"_367":176},"count","unfilledCount","emptyCount",{"_32":356,"_13":120,"_81":113,"_83":-5,"_84":58,"_85":89,"_87":26,"_34":430,"_40":176,"_90":232,"_92":-5,"_66":48,"_94":-5,"_95":431,"_74":432},{"_32":426,"_13":142,"_81":136,"_83":113,"_84":58,"_85":89,"_87":26,"_34":427,"_40":176,"_90":232,"_92":-5,"_66":48,"_94":-5,"_95":428,"_74":429},{"_32":133,"_13":134,"_81":135,"_83":136,"_84":58,"_85":20,"_87":26,"_34":137,"_40":89,"_90":138,"_92":139,"_66":48,"_94":-5,"_95":424,"_74":425},{"_32":266,"_13":267,"_81":268,"_83":136,"_84":58,"_85":269,"_87":26,"_34":270,"_40":176,"_90":138,"_92":271,"_66":48,"_94":-5,"_95":422,"_74":423},{"_32":256,"_13":257,"_81":258,"_83":136,"_84":58,"_85":259,"_87":26,"_34":260,"_40":176,"_90":138,"_92":261,"_66":48,"_94":-5,"_95":420,"_74":421},{"_32":246,"_13":247,"_81":248,"_83":136,"_84":58,"_85":249,"_87":26,"_34":250,"_40":176,"_90":138,"_92":251,"_66":48,"_94":-5,"_95":418,"_74":419},{"_32":411,"_13":412,"_81":413,"_83":113,"_84":58,"_85":89,"_87":26,"_34":414,"_40":176,"_90":116,"_92":415,"_66":48,"_94":-5,"_95":416,"_74":417},{"_32":110,"_13":111,"_81":112,"_83":113,"_84":58,"_85":114,"_87":26,"_34":115,"_40":89,"_90":116,"_92":117,"_66":48,"_94":-5,"_95":409,"_74":410},{"_32":402,"_13":403,"_81":404,"_83":113,"_84":58,"_85":89,"_87":26,"_34":405,"_40":176,"_90":138,"_92":406,"_66":48,"_94":-5,"_95":407,"_74":408},{"_32":236,"_13":237,"_81":238,"_83":113,"_84":58,"_85":239,"_87":26,"_34":240,"_40":176,"_90":138,"_92":241,"_66":48,"_94":-5,"_95":400,"_74":401},{"_32":230,"_13":200,"_81":194,"_83":-5,"_84":58,"_85":22,"_87":26,"_34":231,"_40":176,"_90":232,"_92":-5,"_66":48,"_94":-5,"_95":398,"_74":399},{"_32":222,"_13":223,"_81":224,"_83":194,"_84":58,"_85":22,"_87":26,"_34":225,"_40":176,"_90":138,"_92":226,"_66":48,"_94":-5,"_95":396,"_74":397},{"_32":213,"_13":214,"_81":215,"_83":194,"_84":58,"_85":148,"_87":26,"_34":216,"_40":176,"_90":138,"_92":217,"_66":48,"_94":-5,"_95":394,"_74":395},{"_32":203,"_13":204,"_81":205,"_83":194,"_84":58,"_85":206,"_87":26,"_34":207,"_40":176,"_90":138,"_92":208,"_66":48,"_94":-5,"_95":392,"_74":393},{"_32":191,"_13":192,"_81":193,"_83":194,"_84":58,"_85":195,"_87":26,"_34":196,"_40":176,"_90":138,"_92":197,"_66":48,"_94":-5,"_95":390,"_74":391},{"_32":155,"_13":152,"_81":156,"_83":-5,"_84":58,"_85":57,"_87":26,"_34":157,"_40":89,"_90":116,"_92":158,"_66":48,"_94":-5,"_95":388,"_74":389},{"_32":80,"_13":75,"_81":82,"_83":-5,"_84":58,"_85":86,"_87":26,"_34":88,"_40":89,"_90":91,"_92":93,"_66":48,"_94":-5,"_95":386,"_74":387},[],[75],[],[152],[],[200,192],[],[200,204],[],[200,214],[],[200,223],[380,381,382,383],[200],[],[120,237],"8c6d330a-67ad-441f-86d5-6b7354e41f60","index.tsx","019ecafe-e739-75a6-b00e-808bd3800975",["D",1781522163344],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { createRoot } from \"https://esm.sh/react-dom@18.2.0/client\";\nimport { App } from \"./components/App.tsx\";\n\nconst root = document.getElementById(\"root\");\nif (!root) {\n throw new Error(\"No root element found\");\n}\n\ncreateRoot(root).render();",[],[120,403],[],[120,111],"642a44a6-7a18-4be5-b75c-b8194deb5e2a","favicon.svg","019ecafe-e739-75a6-b00e-7a11522a7d03",["D",1781522163344],"\n",[],[120,412],[],[120,142,247],[],[120,142,257],[],[120,142,267],[],[120,142,134],"89578580-c286-43a5-bbb9-ba5b7e42c42a",["D",1781522163344],[371,372,373,374],[120,142],["D",1781522163344],[370,375,376,377,378],[120],["D",1781522163344],["D",1789522836959],{"_11":12,"_317":313},{"_11":12,"_310":311,"_312":313,"_281":282,"_314":315,"_316":48},{"_40":57,"_13":16,"_32":58,"_38":59,"_42":33,"_43":60,"_61":50,"_62":39,"_63":54,"_55":14,"_51":12},"ctx",{"_305":-5,"_338":471,"_472":473,"_474":475,"_476":48,"_477":48,"_478":48,"_479":26,"_480":-5,"_481":-7,"_482":-7,"_483":176,"_484":48,"_485":48,"_486":-5,"_487":48,"_488":48,"_489":48,"_490":-5},"ENV",{"_442":443,"_444":445,"_446":16,"_447":448,"_449":450,"_451":452,"_453":454,"_455":456,"_457":458,"_459":460,"_461":462,"_463":464,"_465":466,"_467":468,"_469":470},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","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","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Compare

Mergerivkivinter/mainintotemplates/main

README.md+79-44

frontend/components/App.tsx+109-7

frontend/index.html+3-3

Hindex.ts+79-11

frontend/components/ConfigPanel.tsx+76-0

frontend/components/ResultView.tsx+191-0

frontend/components/ToolRunner.tsx+145-0

frontend/lib.ts+80-0

server

server/cdp.ts+224-0

server/mcp.ts+114-0

server/mock.ts+112-0

server/tools.ts+200-0

frontend/components/Counter.tsx+0-18