Live Transcripts

\n\n \n

0 ? 'text-yellow-400' : 'text-red-400'\">\n Status: \n

\n Transcripts stored: \n 0 && !isConnected && statusText.includes('Polling')\" class=\"text-blue-400 ml-2\">(Embedded Mode)\n 0 && !isConnected && !statusText.includes('Polling')\" class=\"text-yellow-400 ml-2\">(Test Mode)\n \n 0\" class=\"text-blue-400 ml-2\">\n • processing\n \n

\n\n \n

\n \n \n \n \n \n

\n\n\n \n

Transcripts

\n No transcripts received yet. Start a Zoom RTMS session to see live transcripts.\n

\n \n

\n\n

\n\n \n\n\n",[],[213,220],[213],{"_102":229,"_95":230,"_151":231,"_153":-5,"_154":136,"_155":232,"_157":158,"_104":233,"_99":32,"_160":189,"_162":234,"_163":22,"_164":-5,"_165":235,"_98":236},"24997c7a-93f2-11f0-b5ad-0224a6c84d84",".cursorrules","24997d60-93f2-11f0-b5ad-0224a6c84d84",3,["D",1758132865374],"You are an advanced assistant specialized in generating Val Town code.\n\n## Core Guidelines\n\n- Ask clarifying questions when requirements are ambiguous\n- Provide complete, functional solutions rather than skeleton implementations\n- Test your logic against edge cases before presenting the final solution\n- Ensure all code follows Val Town's specific platform requirements\n- If a section of code that you're working on is getting too complex, consider refactoring it into subcomponents\n\n## Code Standards\n\n- Generate code in TypeScript or TSX\n- Add appropriate TypeScript types and interfaces for all data structures\n- Prefer official SDKs or libraries than writing API calls directly\n- Ask the user to supply API or library documentation if you are at all unsure about it\n- **Never bake in secrets into the code** - always use environment variables\n- Include comments explaining complex logic (avoid commenting obvious operations)\n- Follow modern ES6+ conventions and functional programming practices if possible\n\n## Types of triggers\n\n### 1. HTTP Trigger\n\n- Create web APIs and endpoints\n- Handle HTTP requests and responses\n- Example structure:\n\n```ts\nexport default async function (req: Request) {\n return new Response(\"Hello World\");\n}\n```\n\nFiles that are HTTP triggers have http in their name like `foobar.http.tsx`\n\n### 2. Cron Triggers\n\n- Run on a schedule\n- Use cron expressions for timing\n- Example structure:\n\n```ts\nexport default async function () {\n // Scheduled task code\n}\n```\n\nFiles that are Cron triggers have cron in their name like `foobar.cron.tsx`\n\n### 3. Email Triggers\n\n- Process incoming emails\n- Handle email-based workflows\n- Example structure:\n\n```ts\nexport default async function (email: Email) {\n // Process email\n}\n```\n\nFiles that are Email triggers have email in their name like `foobar.email.tsx`\n\n\n## Val Town Standard Libraries\n\nVal Town provides several hosted services and utility functions.\n\n### Blob Storage\n\n```ts\nimport { blob } from \"https://esm.town/v/std/blob\";\nawait blob.setJSON(\"myKey\", { hello: \"world\" });\nlet blobDemo = await blob.getJSON(\"myKey\");\nlet appKeys = await blob.list(\"app_\");\nawait blob.delete(\"myKey\");\n```\n\n### SQLite\n\n```ts\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nconst TABLE_NAME = 'todo_app_users_2';\n// Create table - do this before usage and change table name when modifying schema\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS ${TABLE_NAME} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL\n)`);\n// Query data\nconst result = await sqlite.execute(`SELECT * FROM ${TABLE_NAME} WHERE id = ?`, [1]);\n```\n\nNote: When changing a SQLite table's schema, change the table's name (e.g., add _2 or _3) to create a fresh table.\n\n### OpenAI\n\n```ts\nimport { OpenAI } from \"https://esm.town/v/std/openai\";\nconst openai = new OpenAI();\nconst completion = await openai.chat.completions.create({\n messages: [\n { role: \"user\", content: \"Say hello in a creative way\" },\n ],\n model: \"gpt-4o-mini\",\n max_tokens: 30,\n});\n```\n\n### Email\n\n```ts\nimport { email } from \"https://esm.town/v/std/email\";\n// By default emails the owner of the val\nawait email({ \n subject: \"Hi\", \n text: \"Hi\", \n html: \"

Hi

\"\n});\n```\n\n## Val Town Utility Functions\n\nVal Town provides several utility functions to help with common project tasks.\n\n### Importing Utilities\n\nAlways import utilities with version pins to avoid breaking changes:\n\n```ts\nimport { parseProject, readFile, serveFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\n```\n\n### Available Utilities\n\n\n#### **serveFile** - Serve project files with proper content types\n\nFor example, in Hono:\n\n```ts\n// serve all files in frontend/ and shared/\napp.get(\"/frontend/*\", c => serveFile(c.req.path, import.meta.url));\napp.get(\"/shared/*\", c => serveFile(c.req.path, import.meta.url));\n```\n\n#### **readFile** - Read files from within the project:\n\n```ts\n// Read a file from the project\nconst fileContent = await readFile(\"/frontend/index.html\", import.meta.url);\n```\n\n#### **listFiles** - List all files in the project\n\n```ts\nconst files = await listFiles(import.meta.url);\n```\n\n#### **parseProject** - Extract information about the current project from import.meta.url\n\nThis is useful for including info for linking back to a val, ie in \"view source\" urls:\n\n```ts\nconst projectVal = parseProject(import.meta.url);\nconsole.log(projectVal.username); // Owner of the project\nconsole.log(projectVal.name); // Project name\nconsole.log(projectVal.version); // Version number\nconsole.log(projectVal.branch); // Branch name\nconsole.log(projectVal.links.self.project); // URL to the project page\n```\n\nHowever, it's *extremely importing* to note that `parseProject` and other Standard Library utilities ONLY RUN ON THE SERVER.\nIf you need access to this data on the client, run it in the server and pass it to the client by splicing it into the HTML page\nor by making an API request for it.\n\n## Val Town Platform Specifics\n\n- **Redirects:** Use `return new Response(null, { status: 302, headers: { Location: \"/place/to/redirect\" }})` instead of `Response.redirect` which is broken\n- **Images:** Avoid external images or base64 images. Use emojis, unicode symbols, or icon fonts/libraries instead\n- **AI Image:** To inline generate an AI image use: `

`\n- **Storage:** DO NOT use the Deno KV module for storage\n- **Browser APIs:** DO NOT use the `alert()`, `prompt()`, or `confirm()` methods\n- **Weather Data:** Use open-meteo for weather data (doesn't require API keys) unless otherwise specified\n- **View Source:** Add a view source link by importing & using `import.meta.url.replace(\"ems.sh\", \"val.town)\"` (or passing this data to the client) and include `target=\"_top\"` attribute\n- **Error Debugging:** Add `` to HTML to capture client-side errors\n- **Error Handling:** Only use try...catch when there's a clear local resolution; Avoid catches that merely log or return 500s. Let errors bubble up with full context\n- **Environment Variables:** Use `Deno.env.get('keyname')` when you need to, but generally prefer APIs that don't require keys\n- **Imports:** Use `https://esm.sh` for npm and Deno dependencies to ensure compatibility on server and browser\n- **Storage Strategy:** Only use backend storage if explicitly required; prefer simple static client-side sites\n- **React Configuration:** When using React libraries, pin versions with `?deps=react@18.2.0,react-dom@18.2.0` and start the file with `/** @jsxImportSource https://esm.sh/react@18.2.0 */`\n- Ensure all React dependencies and sub-dependencies are pinned to the same version\n- **Styling:** Default to using TailwindCSS via `` unless otherwise specified\n\n## Project Structure and Design Patterns\n\n### Recommended Directory Structure\n```\n├── backend/\n│ ├── database/\n│ │ ├── migrations.ts # Schema definitions\n│ │ ├── queries.ts # DB query functions\n│ │ └── README.md\n│ └── routes/ # Route modules\n│ ├── [route].ts\n│ └── static.ts # Static file serving\n│ ├── index.ts # Main entry point\n│ └── README.md\n├── frontend/\n│ ├── components/\n│ │ ├── App.tsx\n│ │ └── [Component].tsx\n│ ├── favicon.svg\n│ ├── index.html # Main HTML template\n│ ├── index.tsx # Frontend JS entry point\n│ ├── README.md\n│ └── style.css\n├── README.md\n└── shared/\n ├── README.md\n └── utils.ts # Shared types and functions\n```\n\n### Backend (Hono) Best Practices\n\n- Hono is the recommended API framework\n- Main entry point should be `backend/index.ts`\n- **Static asset serving:** Use the utility functions to read and serve project files:\n ```ts\n import { readFile, serveFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\n \n // serve all files in frontend/ and shared/\n app.get(\"/frontend/*\", c => serveFile(c.req.path, import.meta.url));\n app.get(\"/shared/*\", c => serveFile(c.req.path, import.meta.url));\n \n // For index.html, often you'll want to bootstrap with initial data\n app.get(\"/\", async c => {\n let html = await readFile(\"/frontend/index.html\", import.meta.url);\n \n // Inject data to avoid extra round-trips\n const initialData = await fetchInitialData();\n const dataScript = ``;\n \n html = html.replace(\"\", `${dataScript}`);\n return c.html(html);\n });\n ```\n- Create RESTful API routes for CRUD operations\n- Always include this snippet at the top-level Hono app to re-throwing errors to see full stack traces:\n ```ts\n // Unwrap Hono errors to see original error details\n app.onError((err, c) => {\n throw err;\n });\n ```\n\n### Database Patterns\n- Run migrations on startup or comment out for performance\n- Change table names when modifying schemas rather than altering\n- Export clear query functions with proper TypeScript typing\n\n## Common Gotchas and Solutions\n\n1. **Environment Limitations:** \n - Val Town runs on Deno in a serverless context, not Node.js\n - Code in `shared/` must work in both frontend and backend environments\n - Cannot use `Deno` keyword in shared code\n - Use `https://esm.sh` for imports that work in both environments\n\n2. **SQLite Peculiarities:**\n - Limited support for ALTER TABLE operations\n - Create new tables with updated schemas and copy data when needed\n - Always run table creation before querying\n\n3. **React Configuration:**\n - All React dependencies must be pinned to 18.2.0\n - Always include `@jsxImportSource https://esm.sh/react@18.2.0` at the top of React files\n - Rendering issues often come from mismatched React versions\n\n4. **File Handling:**\n - Val Town only supports text files, not binary\n - Use the provided utilities to read files across branches and forks\n - For files in the project, use `readFile` helpers\n\n5. **API Design:**\n - `fetch` handler is the entry point for HTTP vals\n - Run the Hono app with `export default app.fetch // This is the entry point for HTTP vals`\n\n",[],[230],{"_102":238,"_95":239,"_151":240,"_153":-5,"_154":136,"_155":241,"_157":158,"_104":242,"_99":32,"_160":189,"_162":243,"_163":22,"_164":-5,"_165":244,"_98":245},"47cf00cc-97e2-11f0-a7ee-0224a6c84d84",".gitignore","47cf016c-97e2-11f0-a7ee-0224a6c84d84",68,["D",1758565857072],"# Dependencies\nnode_modules/\nnpm-debug.log*\nyarn-debug.log*\nyarn-error.log*\n\n# Runtime data\npids\n*.pid\n*.seed\n*.pid.lock\n\n# Coverage directory used by tools like istanbul\ncoverage/\n*.lcov\n\n# nyc test coverage\n.nyc_output\n\n# Grunt intermediate storage (https://gruntjs.com/creating-plugins#storing-task-files)\n.grunt\n\n# Bower dependency directory (https://bower.io/)\nbower_components\n\n# node-waf configuration\n.lock-wscript\n\n# Compiled binary addons (https://nodejs.org/api/addons.html)\nbuild/Release\n\n# Dependency directories\njspm_packages/\n\n# TypeScript cache\n*.tsbuildinfo\n\n# Optional npm cache directory\n.npm\n\n# Optional eslint cache\n.eslintcache\n\n# Microbundle cache\n.rpt2_cache/\n.rts2_cache_cjs/\n.rts2_cache_es/\n.rts2_cache_umd/\n\n# Optional REPL history\n.node_repl_history\n\n# Output of 'npm pack'\n*.tgz\n\n# Yarn Integrity file\n.yarn-integrity\n\n# dotenv environment variables file\n.env\n.env.test\n.env.local\n.env.development.local\n.env.test.local\n.env.production.local\n\n# parcel-bundler cache (https://parceljs.org/)\n.cache\n.parcel-cache\n\n# Next.js build output\n.next\n\n# Nuxt.js build / generate output\n.nuxt\ndist\n\n# Gatsby files\n.cache/\npublic\n\n# Storybook build outputs\n.out\n.storybook-out\n\n# Temporary folders\ntmp/\ntemp/\n\n# Runtime data\n*.log\nlogs\n\n# Diagnostic reports (https://nodejs.org/api/report.html)\nreport.[0-9]*.[0-9]*.[0-9]*.[0-9]*.json\n\n# Editor directories and files\n.vscode/\n.idea/\n*.swp\n*.swo\n*~\n\n# OS generated files\n.DS_Store\n.DS_Store?\n._*\n.Spotlight-V100\n.Trashes\nehthumbs.db\nThumbs.db\n\n# Deno specific\n.deno/\ndeno.lock\n",[],[239],{"_102":247,"_95":248,"_151":249,"_153":-5,"_154":136,"_155":250,"_157":158,"_104":251,"_99":252,"_160":189,"_162":253,"_163":22,"_164":-5,"_165":254,"_98":255},"47c40406-97e2-11f0-b527-0224a6c84d84",".vtignore","24b8c9b8-93f2-11f0-be8c-0224a6c84d84",66,["D",1758565857075],4,".git\n.vscode\n.cursorrules\n.DS_Store\nnode_modules\nvendor\n\nprint_transcripts_demo",[],[248],{"_102":257,"_95":258,"_151":259,"_153":-5,"_154":136,"_155":260,"_157":158,"_104":261,"_99":32,"_160":189,"_162":262,"_163":22,"_164":-5,"_165":263,"_98":264},"47a901f6-97e2-11f0-9d13-0224a6c84d84","README.md","47a902c8-97e2-11f0-9d13-0224a6c84d84",63,["D",1758565856908],"# Zoom RTMS Transcript Service\n\nA real-time transcript streaming service for Zoom meetings using the Zoom Real-Time Meeting Service (RTMS) API. This demo showcases live transcription capabilities and is designed to integrate with Groq Compound for advanced AI processing.\n\n## 🚀 Features\n\n- **Real-Time Transcription**: Live transcript streaming from Zoom meetings\n- **WebSocket Integration**: Direct connection to Zoom's RTMS WebSocket endpoints\n- **Server-Sent Events**: Real-time UI updates for transcript display\n- **Webhook Handling**: Automatic handling of Zoom RTMS lifecycle events\n- **Security Headers**: OWASP-compliant security headers implementation\n- **Cross-Platform**: Runs on Deno, compatible with Val Town deployment\n- **Future AI Integration**: Planned integration with Groq Compound for intelligent transcript processing\n\n## 📋 Prerequisites\n\n- [Deno](https://deno.com/) runtime\n- Zoom App Marketplace account with RTMS enabled\n- Environment variables configured (see below)\n\n## 🔧 Setup\n\n1. **Clone the repository**\n ```bash\n git clone \n cd zoom-rtms\n ```\n\n2. **Install dependencies**\n ```bash\n # Dependencies are automatically managed by Deno\n # No npm install required\n ```\n\n3. **Configure environment variables**\n\n Create a `.env` file in the project root:\n\n ```env\n # Zoom RTMS Credentials (from Zoom App Marketplace)\n ZOOM_CLIENT_ID=your_zoom_client_id\n ZOOM_CLIENT_SECRET=your_zoom_client_secret\n ZOOM_SECRET_TOKEN=your_zoom_secret_token\n\n # Optional: Custom webhook path (defaults to /webhook)\n WEBHOOK_PATH=/webhook\n ```\n\n## 🏃 Running the Application\n\n### Development Mode\n```bash\ndeno task print\n# or directly:\ndeno serve --port 9995 --watch --allow-read --allow-env --allow-write --allow-net ./main.js\n```\n\n### Production Deployment\n```bash\ndeno task prod\n```\n\nThe application will be available at:\n- **Main UI**: `http://localhost:9995/`\n- **Webhook Endpoint**: `http://localhost:9995/webhook`\n- **SSE Stream**: `http://localhost:9995/events`\n\n## 🏗️ Architecture\n\n### Components\n\n1. **Webhook Handler** (`/webhook`)\n - Receives RTMS lifecycle events from Zoom\n - Handles meeting start/stop notifications\n - Validates webhook signatures\n\n2. **WebSocket Connections**\n - **Signaling WebSocket**: Establishes RTMS session\n - **Media WebSocket**: Receives real-time transcript data\n\n3. **Server-Sent Events** (`/events`)\n - Streams transcript data to connected clients\n - Cross-isolate broadcasting for Deno Deploy\n\n4. **Live UI** (`/`)\n - Real-time transcript display\n - EventSource-based updates\n - Dark theme with monospace font (Menlo)\n\n### Data Flow\n\n```\nZoom Meeting → RTMS Webhook → Signaling WS → Media WS → Transcripts → SSE → UI\n```\n\n## 🔐 Zoom RTMS Configuration\n\n1. **Create a Zoom App** in the [Zoom App Marketplace](https://marketplace.zoom.us/)\n2. **Enable RTMS** in your app settings\n3. **Configure Webhook URL** pointing to your deployed endpoint\n4. **Set Event Types** to include:\n - `meeting.rtms_started`\n - `meeting.rtms_stopped`\n - `endpoint.url_validation`\n\n## 🌐 API Endpoints\n\n| Endpoint | Method | Description |\n|----------|--------|-------------|\n| `/` | GET | Live transcript viewer UI |\n| `/webhook` | POST | Zoom RTMS webhook handler |\n| `/events` | GET | Server-Sent Events stream |\n\n## 🚀 Future Integration: Groq Compound\n\nThis project is designed to integrate with [Groq Compound](https://console.groq.com/docs/compound/systems/compound) for intelligent transcript processing:\n\n- **Real-time Analysis**: Process transcripts as they're received\n- **Summarization**: Generate meeting summaries automatically\n- **Action Items**: Extract tasks and follow-ups\n- **Sentiment Analysis**: Analyze participant engagement\n- **Translation**: Real-time language translation\n- **Q&A**: Answer questions about meeting content\n\n### Planned Features\n- Live transcript enhancement\n- Automated meeting minutes\n- Keyword extraction and tagging\n- Speaker identification improvements\n- Content moderation and filtering\n\n## 📚 Documentation\n\n- [Zoom RTMS Documentation](https://developers.zoom.us/docs/rtms/)\n- [Groq Compound API](https://console.groq.com/docs/compound/systems/compound)\n- [Hono Framework](https://hono.dev/)\n- [Deno Deploy](https://deno.com/deploy)\n\n## 🔧 Development\n\n### Code Structure\n```\n├── main.js # Main application\n├── deno.json # Deno configuration\n├── deno.lock # Dependency lock file\n└── README.md # This file\n```\n\n### Key Technologies\n- **Runtime**: Deno\n- **Framework**: Hono\n- **WebSockets**: Native WebSocket API\n- **Security**: OWASP-compliant headers\n- **Deployment**: Deno Deploy compatible\n\n## 🤝 Contributing\n\n1. Fork the repository\n2. Create a feature branch\n3. Make your changes\n4. Test thoroughly\n5. Submit a pull request\n\n## 📄 License\n\nMIT License - see LICENSE file for details\n\n## ⚠️ Disclaimer\n\nThis is a demonstration project for educational and development purposes. Ensure compliance with Zoom's terms of service and data privacy regulations when handling meeting transcripts.\nREADME.md\n",[],[258],{"_102":266,"_95":267,"_151":268,"_153":-5,"_154":136,"_155":269,"_157":158,"_104":270,"_99":180,"_160":189,"_162":271,"_163":22,"_164":-5,"_165":272,"_98":273},"47b501fe-97e2-11f0-8847-0224a6c84d84","deno.json","24a867bc-93f2-11f0-be8c-0224a6c84d84",65,["D",1758565856944],"{\n \"name\": \"zoom-rtms-transcript-service\",\n \"description\": \"Zoom Real-Time Meeting Service (RTMS) for real-time transcript streaming\",\n \"tasks\": {\n \"serve\": \"deno serve --port 9995 --watch --allow-read --allow-env --allow-write --allow-net --allow-import ./main.js\",\n \"git\": \"git add . && git commit -m 'Update' && git push origin main\",\n \"prod\": \"deployctl deploy --prod --project=zoom-rtms\"\n },\n \"$schema\": \"https://raw.githubusercontent.com/denoland/deno/348900b8b79f4a434cab4c74b3bc8d4d2fa8ee74/cli/schemas/config-file.v1.json\",\n \"lock\": false,\n \"compilerOptions\": {\n \"noImplicitAny\": false,\n \"strict\": true,\n \"lib\": [\n \"deno.ns\",\n \"deno.unstable\"\n ]\n },\n \"lint\": {\n \"rules\": {\n \"exclude\": [\n \"no-explicit-any\"\n ]\n }\n },\n \"node_modules_dir\": false,\n \"imports\": {\n \"npm:openai\": \"npm:openai@4.52.7\"\n },\n \"experimental\": {\n \"unstable-node-globals\": true,\n \"unstable-worker-options\": true,\n \"unstable-sloppy-imports\": true\n },\n \"deploy\": {\n \"project\": \"1cf65472-e492-495f-99fe-5c0dca468991\",\n \"exclude\": [\n \"**/node_modules\"\n ],\n \"include\": [],\n \"entrypoint\": \"main.js\"\n }\n}",[],[267],{"_102":275,"_95":276,"_151":277,"_153":-5,"_154":136,"_155":278,"_157":158,"_104":279,"_99":32,"_160":189,"_162":280,"_163":22,"_164":-5,"_165":281,"_98":282},"24a33972-93f2-11f0-934d-0224a6c84d84","deno.lock","24a33a1c-93f2-11f0-934d-0224a6c84d84",5,["D",1758132865417],"{\n \"version\": \"5\",\n \"specifiers\": {\n \"jsr:@smallweb/sandbox@0.1.0\": \"0.1.0\",\n \"jsr:@std/dotenv@*\": \"0.225.2\",\n \"jsr:@std/encoding@1.0.8\": \"1.0.8\",\n \"jsr:@std/html@1.0.3\": \"1.0.3\",\n \"jsr:@std/http@1.0.12\": \"1.0.12\",\n \"npm:@google/generative-ai@*\": \"0.17.1\",\n \"npm:@valtown/sdk@*\": \"0.21.2\",\n \"npm:git-repo-parser@*\": \"2.0.7\",\n \"npm:graphemer@*\": \"1.4.0\",\n \"npm:hono@*\": \"4.6.3\",\n \"npm:js-tiktoken@*\": \"1.0.15\",\n \"npm:marked@*\": \"14.1.0\",\n \"npm:tiktoken@*\": \"1.0.17\",\n \"npm:zod@*\": \"3.23.8\",\n \"npm:zodex@*\": \"0.18.2_zod@3.23.8\"\n },\n \"jsr\": {\n \"@smallweb/sandbox@0.1.0\": {\n \"integrity\": \"840a6120563b20be994fdac3fa858d2cc2e815c6f9b5ea8f14bd02ddd7f71be8\",\n \"dependencies\": [\n \"jsr:@std/encoding\",\n \"jsr:@std/html\",\n \"jsr:@std/http\"\n ]\n },\n \"@std/dotenv@0.225.2\": {\n \"integrity\": \"e2025dce4de6c7bca21dece8baddd4262b09d5187217e231b033e088e0c4dd23\"\n },\n \"@std/encoding@1.0.8\": {\n \"integrity\": \"a6c8f3f933ab1bed66244f435d1dc0fd23a888e07195532122ddc3d5f8f0e6b4\"\n },\n \"@std/html@1.0.3\": {\n \"integrity\": \"7a0ac35e050431fb49d44e61c8b8aac1ebd55937e0dc9ec6409aa4bab39a7988\"\n },\n \"@std/http@1.0.12\": {\n \"integrity\": \"85246d8bfe9c8e2538518725b158bdc31f616e0869255f4a8d9e3de919cab2aa\"\n }\n },\n \"npm\": {\n \"@google/generative-ai@0.17.1\": {\n \"integrity\": \"sha512-TgWz02c5l2XJlEDys81UVat5+Qg9xqmYah7tQt6xlsBwFvzIFPz64aZFGd1av2sxT22NsssqLATjNsusAIJICA==\"\n },\n \"@kwsites/file-exists@1.1.1\": {\n \"integrity\": \"sha512-m9/5YGR18lIwxSFDwfE3oA7bWuq9kdau6ugN4H2rJeyhFQZcG9AgSHkQtSD15a8WvTgfz9aikZMrKPHvbpqFiw==\",\n \"dependencies\": [\n \"debug\"\n ]\n },\n \"@kwsites/promise-deferred@1.1.1\": {\n \"integrity\": \"sha512-GaHYm+c0O9MjZRu0ongGBRbinu8gVAMd2UZjji6jVmqKtZluZnptXGWhz1E8j8D2HJ3f/yMxKAUC0b+57wncIw==\"\n },\n \"@types/node-fetch@2.6.11\": {\n \"integrity\": \"sha512-24xFj9R5+rfQJLRyM56qh+wnVSYhyXC2tkoBndtY0U+vubqNsYXGjufB2nn8Q6gt0LrARwL6UBtMCSVCwl4B1g==\",\n \"dependencies\": [\n \"@types/node@22.5.4\",\n \"form-data\"\n ]\n },\n \"@types/node@18.19.55\": {\n \"integrity\": \"sha512-zzw5Vw52205Zr/nmErSEkN5FLqXPuKX/k5d1D7RKHATGqU7y6YfX9QxZraUzUrFGqH6XzOzG196BC35ltJC4Cw==\",\n \"dependencies\": [\n \"undici-types@5.26.5\"\n ]\n },\n \"@types/node@22.5.4\": {\n \"integrity\": \"sha512-FDuKUJQm/ju9fT/SeX/6+gBzoPzlVCzfzmGkwKvRHQVxi4BntVbyIwf6a4Xn62mrvndLiml6z/UBXIdEVjQLXg==\",\n \"dependencies\": [\n \"undici-types@6.19.8\"\n ]\n },\n \"@valtown/sdk@0.21.2\": {\n \"integrity\": \"sha512-KBHODXnwGtj68SA1hRW+6rba1zu5c2FrYxttGgPemiPGgLoF8Yo29RvNhsA8Qc08bmj5IJS0Mzn0tfqis6Qr+Q==\",\n \"dependencies\": [\n \"@types/node@18.19.55\",\n \"@types/node-fetch\",\n \"abort-controller\",\n \"agentkeepalive\",\n \"form-data-encoder\",\n \"formdata-node\",\n \"node-fetch\"\n ]\n },\n \"abort-controller@3.0.0\": {\n \"integrity\": \"sha512-h8lQ8tacZYnR3vNQTgibj+tODHI5/+l06Au2Pcriv/Gmet0eaj4TwWH41sO9wnHDiQsEj19q0drzdWdeAHtweg==\",\n \"dependencies\": [\n \"event-target-shim\"\n ]\n },\n \"agentkeepalive@4.5.0\": {\n \"integrity\": \"sha512-5GG/5IbQQpC9FpkRGsSvZI5QYeSCzlJHdpBQntCsuTOxhKD8lqKhrleg2Yi7yvMIf82Ycmmqln9U8V9qwEiJew==\",\n \"dependencies\": [\n \"humanize-ms\"\n ]\n },\n \"asynckit@0.4.0\": {\n \"integrity\": \"sha512-Oei9OH4tRh0YqU3GxhX79dM/mwVgvbZJaSNaRk+bshkj0S5cfHcgYakreBjrHwatXKbz+IoIdYLxrKim2MjW0Q==\"\n },\n \"base64-js@1.5.1\": {\n \"integrity\": \"sha512-AKpaYlHn8t4SVbOHCy+b5+KKgvR4vrsD8vbvrbiQJps7fKDTkjkDry6ji0rUJjC0kzbNePLwzxq8iypo41qeWA==\"\n },\n \"combined-stream@1.0.8\": {\n \"integrity\": \"sha512-FQN4MRfuJeHf7cBbBMJFXhKSDq+2kAArBlmRBvcvFE5BB1HZKXtSFASDhdlz9zOYwxh8lDdnvmMOe/+5cdoEdg==\",\n \"dependencies\": [\n \"delayed-stream\"\n ]\n },\n \"debug@4.3.7\": {\n \"integrity\": \"sha512-Er2nc/H7RrMXZBFCEim6TCmMk02Z8vLC2Rbi1KEBggpo0fS6l0S1nnapwmIi3yW/+GOJap1Krg4w0Hg80oCqgQ==\",\n \"dependencies\": [\n \"ms\"\n ]\n },\n \"delayed-stream@1.0.0\": {\n \"integrity\": \"sha512-ZySD7Nf91aLB0RxL4KGrKHBXl7Eds1DAmEdcoVawXnLD7SDhpNgtuII2aAkg7a7QS41jxPSZ17p4VdGnMHk3MQ==\"\n },\n \"event-target-shim@5.0.1\": {\n \"integrity\": \"sha512-i/2XbnSz/uxRCU6+NdVJgKWDTM427+MqYbkQzD321DuCQJUqOuJKIA0IM2+W2xtYHdKOmZ4dR6fExsd4SXL+WQ==\"\n },\n \"form-data-encoder@1.7.2\": {\n \"integrity\": \"sha512-qfqtYan3rxrnCk1VYaA4H+Ms9xdpPqvLZa6xmMgFvhO32x7/3J/ExcTd6qpxM0vH2GdMI+poehyBZvqfMTto8A==\"\n },\n \"form-data@4.0.1\": {\n \"integrity\": \"sha512-tzN8e4TX8+kkxGPK8D5u0FNmjPUjw3lwC9lSLxxoB/+GtsJG91CO8bSWy73APlgAZzZbXEYZJuxjkHH2w+Ezhw==\",\n \"dependencies\": [\n \"asynckit\",\n \"combined-stream\",\n \"mime-types\"\n ]\n },\n \"formdata-node@4.4.1\": {\n \"integrity\": \"sha512-0iirZp3uVDjVGt9p49aTaqjk84TrglENEDuqfdlZQ1roC9CWlPk6Avf8EEnZNcAqPonwkG35x4n3ww/1THYAeQ==\",\n \"dependencies\": [\n \"node-domexception\",\n \"web-streams-polyfill\"\n ]\n },\n \"git-repo-parser@2.0.7\": {\n \"integrity\": \"sha512-51bz2UL04epQnxR4eZC1CaQXVtpEnhtekRs4UeTkiio74kYcIfSsaSb4kLPHuDbJaEuLEZeGNjh63bJkVhCQHw==\",\n \"dependencies\": [\n \"simple-git\"\n ],\n \"bin\": true\n },\n \"graphemer@1.4.0\": {\n \"integrity\": \"sha512-EtKwoO6kxCL9WO5xipiHTZlSzBm7WLT627TqC/uVRd0HKmq8NXyebnNYxDoBi7wt8eTWrUrKXCOVaFq9x1kgag==\"\n },\n \"hono@4.6.3\": {\n \"integrity\": \"sha512-0LeEuBNFeSHGqZ9sNVVgZjB1V5fmhkBSB0hZrpqStSMLOWgfLy0dHOvrjbJh0H2khsjet6rbHfWTHY0kpYThKQ==\"\n },\n \"humanize-ms@1.2.1\": {\n \"integrity\": \"sha512-Fl70vYtsAFb/C06PTS9dZBo7ihau+Tu/DNCk/OyHhea07S+aeMWpFFkUaXRa8fI+ScZbEI8dfSxwY7gxZ9SAVQ==\",\n \"dependencies\": [\n \"ms\"\n ]\n },\n \"js-tiktoken@1.0.15\": {\n \"integrity\": \"sha512-65ruOWWXDEZHHbAo7EjOcNxOGasQKbL4Fq3jEr2xsCqSsoOo6VVSqzWQb6PRIqypFSDcma4jO90YP0w5X8qVXQ==\",\n \"dependencies\": [\n \"base64-js\"\n ]\n },\n \"marked@14.1.0\": {\n \"integrity\": \"sha512-P93GikH/Pde0hM5TAXEd8I4JAYi8IB03n8qzW8Bh1BIEFpEyBoYxi/XWZA53LSpTeLBiMQOoSMj0u5E/tiVYTA==\",\n \"bin\": true\n },\n \"mime-db@1.52.0\": {\n \"integrity\": \"sha512-sPU4uV7dYlvtWJxwwxHD0PuihVNiE7TyAbQ5SWxDCB9mUYvOgroQOwYQQOKPJ8CIbE+1ETVlOoK1UC2nU3gYvg==\"\n },\n \"mime-types@2.1.35\": {\n \"integrity\": \"sha512-ZDY+bPm5zTTF+YpCrAU9nK0UgICYPT0QtT1NZWFv4s++TNkcgVaT0g6+4R2uI4MjQjzysHB1zxuWL50hzaeXiw==\",\n \"dependencies\": [\n \"mime-db\"\n ]\n },\n \"ms@2.1.3\": {\n \"integrity\": \"sha512-6FlzubTLZG3J2a/NVCAleEhjzq5oxgHyaCU9yYXvcLsvoVaHJq/s5xXI6/XXP6tz7R9xAOtHnSO/tXtF3WRTlA==\"\n },\n \"node-domexception@1.0.0\": {\n \"integrity\": \"sha512-/jKZoMpw0F8GRwl4/eLROPA3cfcXtLApP0QzLmUT/HuPCZWyB7IY9ZrMeKw2O/nFIqPQB3PVM9aYm0F312AXDQ==\",\n \"deprecated\": true\n },\n \"node-fetch@2.7.0\": {\n \"integrity\": \"sha512-c4FRfUm/dbcWZ7U+1Wq0AwCyFL+3nt2bEw05wfxSz+DWpWsitgmSgYmy2dQdWyKC1694ELPqMs/YzUSNozLt8A==\",\n \"dependencies\": [\n \"whatwg-url\"\n ],\n \"optionalPeers\": [\n \"encoding@^0.1.0\"\n ]\n },\n \"simple-git@2.48.0\": {\n \"integrity\": \"sha512-z4qtrRuaAFJS4PUd0g+xy7aN4y+RvEt/QTJpR184lhJguBA1S/LsVlvE/CM95RsYMOFJG3NGGDjqFCzKU19S/A==\",\n \"dependencies\": [\n \"@kwsites/file-exists\",\n \"@kwsites/promise-deferred\",\n \"debug\"\n ]\n },\n \"tiktoken@1.0.17\": {\n \"integrity\": \"sha512-UuFHqpy/DxOfNiC3otsqbx3oS6jr5uKdQhB/CvDEroZQbVHt+qAK+4JbIooabUWKU9g6PpsFylNu9Wcg4MxSGA==\"\n },\n \"tr46@0.0.3\": {\n \"integrity\": \"sha512-N3WMsuqV66lT30CrXNbEjx4GEwlow3v6rr4mCcv6prnfwhS01rkgyFdjPNBYd9br7LpXV1+Emh01fHnq2Gdgrw==\"\n },\n \"type-fest@4.26.1\": {\n \"integrity\": \"sha512-yOGpmOAL7CkKe/91I5O3gPICmJNLJ1G4zFYVAsRHg7M64biSnPtRj0WNQt++bRkjYOqjWXrhnUw1utzmVErAdg==\"\n },\n \"undici-types@5.26.5\": {\n \"integrity\": \"sha512-JlCMO+ehdEIKqlFxk6IfVoAUVmgz7cU7zD/h9XZ0qzeosSHmUJVOzSQvvYSYWXkFXC+IfLKSIffhv0sVZup6pA==\"\n },\n \"undici-types@6.19.8\": {\n \"integrity\": \"sha512-ve2KP6f/JnbPBFyobGHuerC9g1FYGn/F8n1LWTwNxCEzd6IfqTwUQcNXgEtmmQ6DlRrC1hrSrBnCZPokRrDHjw==\"\n },\n \"web-streams-polyfill@4.0.0-beta.3\": {\n \"integrity\": \"sha512-QW95TCTaHmsYfHDybGMwO5IJIM93I/6vTRk+daHTWFPhwh+C8Cg7j7XyKrwrj8Ib6vYXe0ocYNrmzY4xAAN6ug==\"\n },\n \"webidl-conversions@3.0.1\": {\n \"integrity\": \"sha512-2JAn3z8AR6rjK8Sm8orRC0h/bcl/DqL7tRPdGZ4I1CjdF+EaMLmYxBHyXuKL849eucPFhvBoxMsflfOb8kxaeQ==\"\n },\n \"whatwg-url@5.0.0\": {\n \"integrity\": \"sha512-saE57nupxk6v3HY35+jzBwYa0rKSy0XR8JSxZPwgLr7ys0IBzhGviA1/TUGJLmSVqs8pb9AnvICXEuOHLprYTw==\",\n \"dependencies\": [\n \"tr46\",\n \"webidl-conversions\"\n ]\n },\n \"zod@3.23.8\": {\n \"integrity\": \"sha512-XBx9AXhXktjUqnepgTiE5flcKIYWi/rme0Eaj+5Y0lftuGBq+jyRu/md4WnuxqgP1ubdpNCsYEYPxrzVHD8d6g==\"\n },\n \"zodex@0.18.2_zod@3.23.8\": {\n \"integrity\": \"sha512-GE0/S68lJhhBhJWeOSvq4BCigrguOeKFr7h3sbsMPd6kF4ZCHeVU/hOzNLHlj6d+ezNXcpQ4nHj6purY5RxQBg==\",\n \"dependencies\": [\n \"type-fest\",\n \"zod\"\n ]\n }\n },\n \"remote\": {\n \"https://deno.land/x/hono@v3.11.7/client/client.ts\": \"ff340f58041203879972dd368b011ed130c66914f789826610869a90603406bf\",\n \"https://deno.land/x/hono@v3.11.7/client/index.ts\": \"3ff4cf246f3543f827a85a2c84d66a025ac350ee927613629bda47e854bfb7ba\",\n \"https://deno.land/x/hono@v3.11.7/client/types.ts\": \"ca165b8738d384361b927964466ecc8bc1436edad3d0414e30a28f40ba4ca496\",\n \"https://deno.land/x/hono@v3.11.7/client/utils.ts\": \"053273c002963b549d38268a1b423ac8ca211a8028bdab1ed0b781a62aa5e661\",\n \"https://deno.land/x/hono@v3.11.7/compose.ts\": \"37d6e33b7db80e4c43a0629b12fd3a1e3406e7d9e62a4bfad4b30426ea7ae4f1\",\n \"https://deno.land/x/hono@v3.11.7/context.ts\": \"5cac561498e1f4af7a355673a047f07f47349056c5167ed9aec8a20cdcac8464\",\n \"https://deno.land/x/hono@v3.11.7/helper.ts\": \"719df05d8deefb5986ccdb0051f892a837dd8b91e48cd6db43fef237153f1057\",\n \"https://deno.land/x/hono@v3.11.7/helper/adapter/index.ts\": \"eea9b4caedbfa3a3b4a020bf46c88c0171a00008cd6c10708cd85a3e39d86e62\",\n \"https://deno.land/x/hono@v3.11.7/helper/cookie/index.ts\": \"a05ce7e3bafe1f8c7f45d04abf79822716011be75904fe1aad2e99126fd985b9\",\n \"https://deno.land/x/hono@v3.11.7/helper/dev/index.ts\": \"e78ee9d96713211f957e89df180aaa48f8ce9407a938979b393a79547d7f8029\",\n \"https://deno.land/x/hono@v3.11.7/helper/factory/index.ts\": \"45c9f0a981c23d6b5e481697637b0f66fec3234aec442d0cb285048b07ed54c6\",\n \"https://deno.land/x/hono@v3.11.7/helper/html/index.ts\": \"a4ac61c54cd432e708dd019aced59273e5e053933f4804b0b5758d9916468b3e\",\n \"https://deno.land/x/hono@v3.11.7/helper/streaming/index.ts\": \"90dd4424d8d8271efd602ab7a8fcc0539a1573c98ee03e4c910bc0bbd7d20f27\",\n \"https://deno.land/x/hono@v3.11.7/helper/testing/index.ts\": \"bc49c049aa0d6426417e3d1a2f52a471a09edb1fb8610b7545eae1968e7d7874\",\n \"https://deno.land/x/hono@v3.11.7/hono-base.ts\": \"ab40351c5198cedef9e235ca0a958a161fec822b62aa7fb1eaa36559dc05e0d5\",\n \"https://deno.land/x/hono@v3.11.7/hono.ts\": \"2cc4c292e541463a4d6f83edbcea58048d203e9564ae62ec430a3d466b49a865\",\n \"https://deno.land/x/hono@v3.11.7/http-exception.ts\": \"6071df078b5f76d279684d52fe82a590f447a64ffe1b75eb5064d0c8a8d2d676\",\n \"https://deno.land/x/hono@v3.11.7/mod.ts\": \"90114a97be9111b348129ad0143e764a64921f60dd03b8f3da529db98a0d3a82\",\n \"https://deno.land/x/hono@v3.11.7/request.ts\": \"71a67261d14bba95e9a8b4782a1c1704d12d54a77390ce404741df15ab99a109\",\n \"https://deno.land/x/hono@v3.11.7/router.ts\": \"880316f561918fc197481755aac2165fdbe2f530b925c5357a9f98d6e2cc85c7\",\n \"https://deno.land/x/hono@v3.11.7/router/linear-router/index.ts\": \"8a2a7144c50b1f4a92d9ee99c2c396716af144c868e10608255f969695efccd0\",\n \"https://deno.land/x/hono@v3.11.7/router/linear-router/router.ts\": \"bc63e8b5bc1dabc815306d50bebd1bb5877ffa3936ba2ad7550d093c95ee6bd1\",\n \"https://deno.land/x/hono@v3.11.7/router/pattern-router/index.ts\": \"304a66c50e243872037ed41c7dd79ed0c89d815e17e172e7ad7cdc4bc07d3383\",\n \"https://deno.land/x/hono@v3.11.7/router/pattern-router/router.ts\": \"a9a5a2a182cce8c3ae82139892cc0502be7dd8f579f31e76d0302b19b338e548\",\n \"https://deno.land/x/hono@v3.11.7/router/reg-exp-router/index.ts\": \"52755829213941756159b7a963097bafde5cc4fc22b13b1c7c9184dc0512d1db\",\n \"https://deno.land/x/hono@v3.11.7/router/reg-exp-router/node.ts\": \"5b3fb80411db04c65df066e69fedb2c8c0844753c2633d703336de84d569252c\",\n \"https://deno.land/x/hono@v3.11.7/router/reg-exp-router/router.ts\": \"7f7af7ce45a4327f9ac7dbdee186f7ba9a24f2eff14c720e3f670be001e71780\",\n \"https://deno.land/x/hono@v3.11.7/router/reg-exp-router/trie.ts\": \"852ce7207e6701e47fa30889a0d2b8bfcd56d8862c97e7bc9831e0a64bd8835f\",\n \"https://deno.land/x/hono@v3.11.7/router/smart-router/index.ts\": \"74f9b4fe15ea535900f2b9b048581915f12fe94e531dd2b0032f5610e61c3bef\",\n \"https://deno.land/x/hono@v3.11.7/router/smart-router/router.ts\": \"f1848a2a1eefa316a11853ae12e749552747771fb8a11fe713ae04ea6461140b\",\n \"https://deno.land/x/hono@v3.11.7/router/trie-router/index.ts\": \"3eb75e7f71ba81801631b30de6b1f5cefb2c7239c03797e2b2cbab5085911b41\",\n \"https://deno.land/x/hono@v3.11.7/router/trie-router/node.ts\": \"e9ea493da22913b2e60a88284c5edb5330506f2ceb0ac631909219bb139c4b60\",\n \"https://deno.land/x/hono@v3.11.7/router/trie-router/router.ts\": \"54ced78d35676302c8fcdda4204f7bdf5a7cc907fbf9967c75674b1e394f830d\",\n \"https://deno.land/x/hono@v3.11.7/types.ts\": \"82f95c64c13c21129130d7bb383956306e19d23b3e986c02c914d7aa08808d1d\",\n \"https://deno.land/x/hono@v3.11.7/utils/body.ts\": \"7a16a6656331a96bcae57642f8d5e3912bd361cbbcc2c0d2157ecc3f218f7a92\",\n \"https://deno.land/x/hono@v3.11.7/utils/buffer.ts\": \"9066a973e64498cb262c7e932f47eed525a51677b17f90893862b7279dc0773e\",\n \"https://deno.land/x/hono@v3.11.7/utils/cookie.ts\": \"19920ba6756944aae1ad8585c3ddeaa9df479733f59d05359db096f7361e5e4b\",\n \"https://deno.land/x/hono@v3.11.7/utils/crypto.ts\": \"bda0e141bbe46d3a4a20f8fbcb6380d473b617123d9fdfa93e4499410b537acc\",\n \"https://deno.land/x/hono@v3.11.7/utils/html.ts\": \"4d2f3975238819fa756e0e51cb7090702136b1e3c54c5049694e26c62d2fcd84\",\n \"https://deno.land/x/hono@v3.11.7/utils/http-status.ts\": \"e0c4343ea7717c314dc600131e16b636c29d61cfdaf9df93b267258d1729d1a0\",\n \"https://deno.land/x/hono@v3.11.7/utils/stream.ts\": \"1789dcc73c5b0ede28f83d7d34e47ae432c20e680907cb3275a9c9187f293983\",\n \"https://deno.land/x/hono@v3.11.7/utils/types.ts\": \"41c4e7d8028f3dec43ff7c26e9498fed53d9ec7c3b47071d066b40f7b7a8ef58\",\n \"https://deno.land/x/hono@v3.11.7/utils/url.ts\": \"5fc3307ef3cb2e6f34ec2a03e3d7f2126c6a9f5f0eab677222df3f0e40bd7567\",\n \"https://deno.land/x/hono@v3.11.7/validator/index.ts\": \"6c986e8b91dcf857ecc8164a506ae8eea8665792a4ff7215471df669c632ae7c\",\n \"https://deno.land/x/hono@v3.11.7/validator/validator.ts\": \"f6139f0b6eb2040bc9f7ed4148905d5affc898235952772b2d6585fdae8d4731\"\n }\n}\n",[],[276],{"_102":284,"_95":285,"_151":286,"_153":-5,"_154":136,"_155":287,"_157":158,"_104":288,"_99":289,"_160":290,"_162":291,"_163":22,"_164":96,"_165":292,"_98":293},"47aecaa0-97e2-11f0-a41f-0224a6c84d84","main.js","249cdf00-93f2-11f0-bbf0-0224a6c84d84",64,["D",1758565856941],39,"http","import { Hono } from \"https://deno.land/x/hono@v3.11.7/mod.ts\";\nimport \"jsr:@std/dotenv/load\";\nimport OpenAI from \"npm:openai@4.52.7\";\n\n// Zoom RTMS configuration\nconst ZOOM_CLIENT_ID = Deno.env.get(\"ZOOM_CLIENT_ID\");\nconst ZOOM_CLIENT_SECRET = Deno.env.get(\"ZOOM_CLIENT_SECRET\");\nconst ZOOM_SECRET_TOKEN = Deno.env.get(\"ZOOM_SECRET_TOKEN\");\nconst WEBHOOK_PATH = Deno.env.get(\"WEBHOOK_PATH\") || \"/webhook\";\n\n// Groq API configuration\nconst GROQ_API_KEY = Deno.env.get(\"GROQ_API_KEY\");\nconst groqClient = new OpenAI({\n apiKey: GROQ_API_KEY,\n baseURL: \"https://api.groq.com/openai/v1\",\n});\n\n// Unified Tool Registry - Single source of truth for all tools\nconst UNIFIED_TOOL_REGISTRY = {\n // MCP Tools\n huggingface: {\n id: 'huggingface',\n type: 'mcp',\n category: 'ai_ml',\n namespace: 'huggingface',\n displayName: '🤗 HuggingFace',\n description: 'Hugging Face model and dataset search and management',\n routing_keywords: ['model', 'hugging face', 'dataset', 'machine learning', 'ai model', 'transform', 'nlp', 'computer vision'],\n server_label: 'Huggingface', // Match curl example exactly\n server_url: 'https://huggingface.co/mcp',\n headers: {},\n require_approval: 'always', // Match curl example\n allowed_tools: null, // Match curl example (null means allow all)\n auth: { type: 'none' },\n examples: ['find a text generation model', 'search for image classification datasets', 'what are trending models']\n },\n\n parallel_search: {\n id: 'parallel_search',\n type: 'mcp',\n category: 'search',\n namespace: 'parallel',\n displayName: '🔍 Parallel Search',\n description: 'Advanced web search and content retrieval with Parallel',\n routing_keywords: ['search', 'find', 'look up', 'current', 'latest', 'news', 'trending', 'web'],\n server_label: 'ParallelSearch',\n server_url: 'https://mcp.parallel.ai/v1beta/search_mcp/',\n headers: {\n 'x-api-key': Deno.env.get('PARALLEL_API_KEY') || ''\n },\n require_approval: 'never',\n allowed_tools: ['web_search', 'get_page_content', 'search_trending'],\n auth: { type: 'env_header', header: 'x-api-key', env: 'PARALLEL_API_KEY' },\n examples: ['search for latest AI news', 'find information about quantum computing', 'what\\'s trending on social media']\n },\n\n // Built-in Tools\n weather: {\n id: 'weather',\n type: 'builtin',\n category: 'utility',\n namespace: 'general',\n displayName: '🌤️ Weather',\n description: 'Weather information using Groq compound model',\n routing_keywords: ['weather', 'temperature', 'forecast', 'climate', 'rain', 'sunny', 'cloudy', 'humidity', 'wind'],\n handler: getWeather,\n examples: ['what\\'s the weather in SF', 'forecast for tomorrow', 'is it raining']\n },\n\n direct_answer: {\n id: 'direct_answer',\n type: 'builtin',\n category: 'general',\n namespace: 'general',\n displayName: '💭 Direct Answer',\n description: 'Direct answer using Groq compound model',\n routing_keywords: ['explain', 'what is', 'how does', 'why', 'when', 'where', 'who'],\n handler: answerDirectly,\n examples: ['explain machine learning', 'what is quantum computing', 'how does the internet work']\n }\n};\n\n// Function to add tools programmatically to the unified registry\nfunction addTool(toolId, config) {\n UNIFIED_TOOL_REGISTRY[toolId] = {\n id: toolId,\n type: config.type || 'builtin',\n category: config.category || 'general',\n namespace: config.namespace || 'general',\n displayName: config.displayName || `⚙️ ${toolId}`,\n description: config.description || `${toolId} tool`,\n routing_keywords: config.routing_keywords || [],\n examples: config.examples || [],\n\n // MCP-specific fields\n ...(config.type === 'mcp' && {\n server_label: config.serverLabel || toolId,\n server_url: config.serverUrl,\n headers: config.headers || {},\n require_approval: config.requireApproval || 'never',\n allowed_tools: config.allowedTools || []\n }),\n\n // Built-in specific fields\n ...(config.type === 'builtin' && {\n handler: config.handler\n })\n };\n}\n\n// Function to get all available tools from unified registry\nfunction getAvailableTools() {\n return { ...UNIFIED_TOOL_REGISTRY };\n}\n\n// Helper function to get tools by namespace\nfunction getToolsByNamespace(namespace) {\n return Object.values(UNIFIED_TOOL_REGISTRY).filter(tool => tool.namespace === namespace);\n}\n\n// Helper function to get routing information for system prompts\nfunction getRoutingInfo() {\n const routingInfo = {};\n\n Object.values(UNIFIED_TOOL_REGISTRY).forEach(tool => {\n if (!routingInfo[tool.namespace]) {\n routingInfo[tool.namespace] = [];\n }\n routingInfo[tool.namespace].push({\n id: tool.id,\n description: tool.description,\n keywords: tool.routing_keywords || [],\n examples: tool.examples || []\n });\n });\n\n return routingInfo;\n}\n\n// Example of adding tools programmatically:\n// addTool('custom_mcp_tool', {\n// type: 'mcp',\n// category: 'search',\n// namespace: 'custom',\n// displayName: '🔍 Custom Search',\n// description: 'Custom MCP search tool',\n// routing_keywords: ['custom', 'special', 'advanced'],\n// examples: ['do a custom search', 'find special content'],\n// serverLabel: 'CustomSearch',\n// serverUrl: 'https://your-custom-mcp-server.com',\n// headers: { 'Authorization': `Bearer ${Deno.env.get('CUSTOM_API_KEY')}` },\n// requireApproval: 'never',\n// allowedTools: ['search', 'get_content']\n// });\n//\n// addTool('custom_builtin_tool', {\n// type: 'builtin',\n// category: 'utility',\n// namespace: 'custom',\n// displayName: '⚙️ Custom Tool',\n// description: 'Custom built-in tool',\n// routing_keywords: ['custom', 'utility', 'tool'],\n// examples: ['use custom tool', 'run custom function'],\n// handler: async (query, context) => {\n// // Your custom handler logic here\n// return { response: `Custom tool result for: ${query}` };\n// }\n// });\n\n\nconst app = new Hono();\n\n// Security headers middleware for Zoom Apps marketplace\nfunction addSecurityHeaders(c, next) {\n // Essential CORS headers for Zoom Apps\n c.header('Access-Control-Allow-Origin', '*');\n c.header('Access-Control-Allow-Methods', 'GET, POST, PUT, DELETE, OPTIONS, PATCH');\n c.header('Access-Control-Allow-Headers', 'Content-Type, Authorization, X-Requested-With, X-Zoom-App-Context, X-Zoom-App-Token');\n c.header('Access-Control-Allow-Credentials', 'true');\n c.header('Access-Control-Max-Age', '86400');\n\n // Relaxed CSP for Zoom Apps marketplace\n c.header('Content-Security-Policy',\n \"default-src 'self' https://*.zoom.us https://zoom.us https://app.zoom.us https://marketplace.zoom.us; \" +\n \"script-src 'self' 'unsafe-inline' 'unsafe-eval' https://cdn.tailwindcss.com https://esm.town https://code.iconify.design https://cdn.jsdelivr.net https://*.zoom.us https://zoom.us; \" +\n \"style-src 'self' 'unsafe-inline' https://cdn.tailwindcss.com https://fonts.googleapis.com https://*.zoom.us https://zoom.us; \" +\n \"img-src 'self' data: https: blob: https://*.zoom.us https://zoom.us; \" +\n \"font-src 'self' https://fonts.gstatic.com https://*.zoom.us https://zoom.us; \" +\n \"connect-src 'self' * wss: ws: https: http: data: https://*.zoom.us https://zoom.us https://api.zoom.us; \" +\n \"frame-src 'self' https://*.zoom.us https://zoom.us https://app.zoom.us; \" +\n \"frame-ancestors 'self' https://*.zoom.us https://zoom.us https://app.zoom.us https://marketplace.zoom.us https://*.zoomgov.com; \" +\n \"object-src 'none'; \" +\n \"base-uri 'self'; \" +\n \"form-action 'self' https://*.zoom.us https://zoom.us https://app.zoom.us\"\n );\n\n // Remove restrictive frame options for Zoom Apps\n c.header('X-Frame-Options', 'ALLOWALL');\n\n // Other security headers\n c.header('Strict-Transport-Security', 'max-age=31536000; includeSubDomains');\n c.header('X-Content-Type-Options', 'nosniff');\n c.header('Referrer-Policy', 'strict-origin-when-cross-origin');\n c.header('X-XSS-Protection', '1; mode=block');\n\n return next();\n}\n\n// Handle preflight OPTIONS requests for CORS\napp.options('*', (c) => {\n c.header('Access-Control-Allow-Origin', '*');\n c.header('Access-Control-Allow-Methods', 'GET, POST, PUT, DELETE, OPTIONS, PATCH');\n c.header('Access-Control-Allow-Headers', 'Content-Type, Authorization, X-Requested-With, X-Zoom-App-Context, X-Zoom-App-Token');\n c.header('Access-Control-Allow-Credentials', 'true');\n c.header('Access-Control-Max-Age', '86400');\n return c.text('', 204);\n});\n\n// Apply security headers to all routes except WebSocket endpoints\napp.use('*', (c, next) => {\n // Always skip headers on WS endpoints to avoid interfering with upgrades\n const path = c.req.path;\n if (path === '/ws' || path === '/ws-analysis') {\n return next();\n }\n // Skip security headers for WebSocket upgrade requests\n const upgradeHeader = c.req.header('Upgrade');\n const connectionHeader = c.req.header('Connection');\n const websocketKey = c.req.header('Sec-WebSocket-Key');\n const websocketVersion = c.req.header('Sec-WebSocket-Version');\n\n const isWebSocketUpgrade =\n (upgradeHeader === 'websocket') ||\n (connectionHeader && connectionHeader.toLowerCase().includes('upgrade')) ||\n (websocketKey && websocketVersion);\n\n if (isWebSocketUpgrade) {\n console.log('🔌 WebSocket upgrade request detected - skipping security headers');\n return next();\n }\n return addSecurityHeaders(c, next);\n});\n\n// RTMS data structures\nconst activeConnections = new Map();\n// Simple SSE client pool\nconst sseClients = new Set();\n\n\n// Cross-isolate relay for Deno Deploy: broadcast transcripts to all isolates\nconst INSTANCE_ID = (typeof crypto !== 'undefined' && 'randomUUID' in crypto && typeof crypto.randomUUID === 'function')\n ? crypto.randomUUID()\n : Math.random().toString(36).slice(2);\nconst bc = (typeof BroadcastChannel !== 'undefined') ? new BroadcastChannel('rtms-transcripts') : null;\nif (bc) {\n bc.onmessage = (ev) => {\n try {\n const msg = ev.data;\n if (!msg || msg.origin === INSTANCE_ID) return;\n if (msg.type === 'transcript') {\n for (const client of sseClients) {\n client.send('event: transcript\\n' + 'data: ' + JSON.stringify(msg.payload) + '\\n\\n');\n }\n }\n } catch {}\n };\n}\n\n// Health check endpoint for Zoom Apps\napp.get(\"/health\", (c) => {\n return c.json({\n status: \"healthy\",\n timestamp: new Date().toISOString(),\n zoom_app_ready: true\n });\n});\n\n// CORS test endpoint for Zoom Apps\napp.get(\"/cors-test\", (c) => {\n return c.json({\n message: \"CORS is working! Zoom Apps can connect.\",\n cors_headers: {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Credentials\": \"true\",\n \"Access-Control-Allow-Headers\": \"X-Zoom-App-Context,X-Zoom-App-Token\"\n },\n zoom_domains_allowed: [\n \"https://zoom.us\",\n \"https://*.zoom.us\",\n \"https://app.zoom.us\",\n \"https://marketplace.zoom.us\"\n ]\n });\n});\n\n// Serve Alpine.js from local file\napp.get(\"/@alpinejs@3.12.3.cdn.min.js\", async (c) => {\n try {\n const alpineJs = await Deno.readTextFile(\"./alpinejs@3.12.3.cdn.min.js\");\n return new Response(alpineJs, {\n headers: {\n 'Content-Type': 'application/javascript',\n 'Cache-Control': 'public, max-age=31536000', // Cache for 1 year\n 'Access-Control-Allow-Origin': '*',\n }\n });\n } catch (error) {\n console.error('Error reading Alpine.js file:', error);\n return c.text('Alpine.js file not found', 404);\n }\n});\n\n// Serve the minimal UI at root\napp.get(\"/\", async (c) => {\n try {\n const html = await Deno.readTextFile(\"./frontend/index.html\");\n return c.html(html);\n } catch (error) {\n console.error('Error reading HTML file:', error);\n return c.text('Error loading page', 500);\n }\n});\n\n// Deno crypto helper for HMAC\nasync function createHmacSha256(key, data) {\n const encoder = new TextEncoder();\n const keyData = encoder.encode(key);\n const dataBytes = encoder.encode(data);\n\n const keyImported = await crypto.subtle.importKey(\n 'raw',\n keyData,\n { name: 'HMAC', hash: 'SHA-256' },\n false,\n ['sign']\n );\n\n const signature = await crypto.subtle.sign('HMAC', keyImported, dataBytes);\n const hashArray = Array.from(new Uint8Array(signature));\n return hashArray.map(b => b.toString(16).padStart(2, '0')).join('');\n}\n\n// Generate signature for RTMS authentication\nasync function generateSignature(meetingUuid, streamId) {\n const message = `${ZOOM_CLIENT_ID},${meetingUuid},${streamId}`;\n return await createHmacSha256(ZOOM_CLIENT_SECRET, message);\n}\n\n\n// RTMS Webhook endpoint\napp.post(WEBHOOK_PATH, async (c) => {\n try {\n const body = await c.req.json();\n const { event, payload } = body;\n\n // Handle URL validation event\n if (event === 'endpoint.url_validation' && payload?.plainToken) {\n const hash = await createHmacSha256(ZOOM_SECRET_TOKEN, payload.plainToken);\n return c.json({\n plainToken: payload.plainToken,\n encryptedToken: hash,\n });\n }\n\n // Handle RTMS started event\n if (event === 'meeting.rtms_started') {\n const { meeting_uuid, rtms_stream_id, server_urls } = payload;\n console.log(`🚀 WEBHOOK: RTMS started - meeting: ${meeting_uuid.slice(0, 8)}..., stream: ${rtms_stream_id}, initiating signaling connection`);\n connectToSignalingWebSocket(meeting_uuid, rtms_stream_id, server_urls);\n }\n\n // Handle RTMS stopped event\n if (event === 'meeting.rtms_stopped') {\n const { meeting_uuid } = payload;\n if (activeConnections.has(meeting_uuid)) {\n const connections = activeConnections.get(meeting_uuid);\n for (const conn of Object.values(connections)) {\n if (conn && typeof conn.close === 'function') {\n conn.close();\n }\n }\n activeConnections.delete(meeting_uuid);\n }\n }\n\n return c.json({ status: 'Event received' });\n } catch (error) {\n console.error('Webhook error:', error);\n return c.json({ error: error.message }, 500);\n }\n});\n\n// WebSocket connection functions for RTMS\nasync function connectToSignalingWebSocket(meetingUuid, streamId, serverUrl) {\n const ws = new WebSocket(serverUrl);\n\n // Store connection for cleanup later\n if (!activeConnections.has(meetingUuid)) {\n activeConnections.set(meetingUuid, {});\n }\n activeConnections.get(meetingUuid).signaling = ws;\n\n ws.onopen = async () => {\n console.log(`🔌 SIGNALING: WebSocket connection opened - meeting: ${meetingUuid.slice(0, 8)}..., stream: ${streamId}`);\n const signature = await generateSignature(meetingUuid, streamId);\n\n // Send handshake message to the signaling server\n const handshake = {\n msg_type: 1, // SIGNALING_HAND_SHAKE_REQ\n protocol_version: 1,\n meeting_uuid: meetingUuid,\n rtms_stream_id: streamId,\n sequence: Math.floor(Math.random() * 1e9),\n signature,\n };\n ws.send(JSON.stringify(handshake));\n console.log(`📤 SIGNALING: Sent handshake request`);\n };\n\n ws.onmessage = async (event) => {\n try {\n const msg = await parseWsJson(event.data);\n\n // Handle successful handshake response\n if (msg.msg_type === 2 && msg.status_code === 0) { // SIGNALING_HAND_SHAKE_RESP\n console.log(`✅ SIGNALING: Handshake successful - status: ${msg.status_code}`);\n const mediaUrl = msg.media_server?.server_urls?.all;\n if (mediaUrl) {\n console.log(`🎯 SIGNALING: Got media server URL, connecting to media WebSocket...`);\n connectToMediaWebSocket(mediaUrl, meetingUuid, streamId, ws);\n } else {\n console.warn(`⚠️ SIGNALING: No media URL in handshake response`);\n }\n }\n\n // Respond to keep-alive requests\n if (msg.msg_type === 12) { // KEEP_ALIVE_REQ\n console.log(`🔄 SIGNALING: Received keep-alive request - timestamp: ${msg.timestamp}, meeting: ${meetingUuid.slice(0, 8)}...`);\n const keepAliveResponse = {\n msg_type: 13, // KEEP_ALIVE_RESP\n timestamp: msg.timestamp,\n };\n ws.send(JSON.stringify(keepAliveResponse));\n console.log(`✅ SIGNALING: Sent keep-alive response - timestamp: ${msg.timestamp}`);\n }\n } catch (error) {\n console.error('Error processing signaling message:', error);\n }\n };\n\n ws.onerror = (error) => {\n console.error('Signaling socket error:', error);\n };\n\n ws.onclose = (event) => {\n console.log(`❌ SIGNALING: WebSocket connection closed - code: ${event.code}, reason: ${event.reason || 'none'}, meeting: ${meetingUuid.slice(0, 8)}...`);\n if (activeConnections.has(meetingUuid)) {\n delete activeConnections.get(meetingUuid).signaling;\n }\n };\n}\n\nasync function connectToMediaWebSocket(mediaUrl, meetingUuid, streamId, signalingSocket) {\n const mediaWs = new WebSocket(mediaUrl);\n\n // Store connection for cleanup later\n if (activeConnections.has(meetingUuid)) {\n activeConnections.get(meetingUuid).media = mediaWs;\n }\n\n mediaWs.onopen = async () => {\n console.log(`🔌 MEDIA: WebSocket connection opened - meeting: ${meetingUuid.slice(0, 8)}..., stream: ${streamId}`);\n const signature = await generateSignature(meetingUuid, streamId);\n const handshake = {\n msg_type: 3, // DATA_HAND_SHAKE_REQ\n protocol_version: 1,\n meeting_uuid: meetingUuid,\n rtms_stream_id: streamId,\n signature,\n media_type: 8, // MEDIA_DATA_TRANSCRIPT (same as Node.js version)\n payload_encryption: false,\n };\n mediaWs.send(JSON.stringify(handshake));\n console.log(`📤 MEDIA: Sent handshake request - media_type: 8 (transcript)`);\n };\n\n mediaWs.onmessage = async (event) => {\n try {\n const msg = await parseWsJson(event.data);\n\n // Handle successful media handshake\n if (msg.msg_type === 4 && msg.status_code === 0) { // DATA_HAND_SHAKE_RESP\n console.log(`✅ MEDIA: Handshake successful - status: ${msg.status_code}, ready to receive transcripts`);\n signalingSocket.send(\n JSON.stringify({\n msg_type: 7, // CLIENT_READY_ACK\n rtms_stream_id: streamId,\n })\n );\n console.log(`📤 SIGNALING: Sent CLIENT_READY_ACK via signaling socket`);\n }\n\n // Respond to keep-alive requests\n if (msg.msg_type === 12) { // KEEP_ALIVE_REQ\n console.log(`🔄 MEDIA: Received keep-alive request - timestamp: ${msg.timestamp}, meeting: ${meetingUuid.slice(0, 8)}..., stream: ${streamId}`);\n const keepAliveResponse = {\n msg_type: 13, // KEEP_ALIVE_RESP\n timestamp: msg.timestamp,\n };\n mediaWs.send(JSON.stringify(keepAliveResponse));\n console.log(`✅ MEDIA: Sent keep-alive response - timestamp: ${msg.timestamp}`);\n }\n\n // Handle transcript data\n if (msg.msg_type === 17 && msg.content && msg.content.data) {\n let { user_id, user_name, data, timestamp } = msg.content;\n console.log(`📝 Transcript: ${user_name || 'unknown'} → \"${data?.slice(0, 50)}${data?.length > 50 ? '...' : ''}\"`);\n\n // Broadcast to SSE clients (local) and to other isolates via BroadcastChannel\n try {\n const payload = {\n msg_type: 17,\n content: { user_id, user_name, data, timestamp }\n };\n \n // Store for polling endpoint\n addToRecentTranscripts(payload.content);\n \n // Local SSE\n for (const client of sseClients) {\n client.send('event: transcript\\n' + 'data: ' + JSON.stringify(payload) + '\\n\\n');\n }\n // Cross-isolate relay\n if (bc) {\n bc.postMessage({ type: 'transcript', origin: INSTANCE_ID, payload });\n }\n } catch (e) {\n // swallow SSE broadcast errors\n }\n }\n\n } catch (error) {\n console.error('Error processing media message:', error);\n // suppress non-transcript noisy logs\n }\n };\n\n mediaWs.onerror = (error) => {\n console.error('Media socket error:', error);\n };\n\n mediaWs.onclose = (event) => {\n console.log(`❌ MEDIA: WebSocket connection closed - code: ${event.code}, reason: ${event.reason || 'none'}, meeting: ${meetingUuid.slice(0, 8)}...`);\n if (activeConnections.has(meetingUuid)) {\n delete activeConnections.get(meetingUuid).media;\n }\n };\n}\n\n// Zoom may provide server_urls in multiple shapes; normalize to a single wss:// URL\nfunction resolveWsUrl(server_urls) {\n try {\n if (!server_urls) return null;\n if (typeof server_urls === 'string') return server_urls;\n if (server_urls.all) return server_urls.all;\n if (Array.isArray(server_urls) && server_urls.length > 0) return server_urls[0];\n return null;\n } catch {\n return null;\n }\n}\n\n// Robustly parse WebSocket event data (string | Blob | ArrayBuffer | Uint8Array)\nasync function parseWsJson(data) {\n try {\n if (typeof data === 'string') return JSON.parse(data);\n if (data instanceof Uint8Array) return JSON.parse(new TextDecoder().decode(data));\n if (data instanceof ArrayBuffer) return JSON.parse(new TextDecoder().decode(new Uint8Array(data)));\n if (typeof Blob !== 'undefined' && data instanceof Blob) {\n const text = await data.text();\n return JSON.parse(text);\n }\n // Handle Buffer (Node.js style) - might be what Deno uses\n if (typeof Buffer !== 'undefined' && Buffer.isBuffer(data)) {\n return JSON.parse(data.toString());\n }\n throw new Error('Unsupported WebSocket data type: ' + Object.prototype.toString.call(data));\n } catch (err) {\n throw err;\n }\n}\n\n// SSE endpoint for streaming transcripts to a minimal UI\napp.get('/events', (c) => {\n let clientRef = null;\n const stream = new ReadableStream({\n start(controller) {\n const encoder = new TextEncoder();\n clientRef = {\n send: (text) => controller.enqueue(encoder.encode(text)),\n };\n sseClients.add(clientRef);\n clientRef.send(': connected\\n\\n');\n },\n cancel() {\n if (clientRef) {\n sseClients.delete(clientRef);\n }\n },\n });\n\n return new Response(stream, {\n headers: {\n 'Content-Type': 'text/event-stream',\n 'Cache-Control': 'no-cache',\n 'Connection': 'keep-alive',\n 'X-Accel-Buffering': 'no',\n // Enhanced CORS headers for Zoom Apps\n 'Access-Control-Allow-Origin': '*',\n 'Access-Control-Allow-Methods': 'GET, POST, OPTIONS',\n 'Access-Control-Allow-Headers': 'Content-Type, Authorization, X-Requested-With, X-Zoom-App-Context, X-Zoom-App-Token',\n 'Access-Control-Allow-Credentials': 'true',\n },\n });\n});\n\n// Handle OPTIONS requests for SSE endpoint\napp.options('/events', (c) => {\n return new Response(null, {\n status: 204,\n headers: {\n 'Access-Control-Allow-Origin': '*',\n 'Access-Control-Allow-Methods': 'GET, POST, OPTIONS',\n 'Access-Control-Allow-Headers': 'Content-Type, Authorization, X-Requested-With, X-Zoom-App-Context, X-Zoom-App-Token',\n 'Access-Control-Allow-Credentials': 'true',\n 'Access-Control-Max-Age': '86400',\n },\n });\n});\n\n// Polling endpoint for embedded environments that can't use SSE\nlet recentTranscripts = []; // Store recent transcripts for polling\nlet lastPollTimestamp = Date.now();\n\napp.get('/api/poll-transcripts', (c) => {\n // Return transcripts added since last poll\n const since = parseInt(c.req.query('since')) || lastPollTimestamp;\n const newTranscripts = recentTranscripts.filter(t => t.timestamp > since);\n \n lastPollTimestamp = Date.now();\n \n return c.json({\n transcripts: newTranscripts,\n timestamp: lastPollTimestamp,\n total_stored: recentTranscripts.length\n });\n});\n\n// Function to add transcript to recent transcripts for polling\nfunction addToRecentTranscripts(transcript) {\n recentTranscripts.unshift(transcript);\n \n // Keep only last 50 transcripts to prevent memory issues\n if (recentTranscripts.length > 50) {\n recentTranscripts = recentTranscripts.slice(0, 50);\n }\n}\n\n\n// Intelligent router that decides which tools to use based on user intent and full context\nasync function intelligentRouter(question, userName, context = {}, chatHistory = []) {\n try {\n // Get routing information from unified registry\n const routingInfo = getRoutingInfo();\n const availableTools = getAvailableTools();\n\n console.log(`🔍 ROUTING: Analyzing question: \"${question}\" from user: ${userName}`);\n\n // Prepare chat history context (last 5 messages for context)\n const recentHistory = chatHistory.slice(-5).map(msg => ({\n role: msg.user_id === 'groq-ai' ? 'assistant' : 'user',\n content: msg.data,\n timestamp: msg.timestamp\n }));\n\n // Dynamically generate system prompt from registry\n const systemPrompt = `You are an intelligent routing system for Groq AI. Your task is to analyze user questions and select the most appropriate tools from the available options.\n\nIMPORTANT: You must respond with VALID JSON only. Do not include any explanatory text before or after the JSON.\n\nQUESTION TO ANALYZE: \"${question}\"\nUSER: ${userName}\n\nAVAILABLE TOOLS:\n${Object.entries(routingInfo).map(([namespace, tools]) =>\n `${namespace.toUpperCase()} NAMESPACE:\n${tools.map(tool => ` - ${tool.id}: ${tool.description}\n Keywords: ${tool.keywords.join(', ')}\n Examples: ${tool.examples.join(', ')}`).join('\\n')}`\n).join('\\n\\n')}\n\nROUTING RULES:\n1. Match question keywords to tool routing keywords\n2. Consider the examples provided for each tool\n3. Use conversation context when relevant\n4. Return only the most appropriate tool(s)\n5. If unsure, prefer 'direct_answer'\n\nREQUIRED JSON RESPONSE FORMAT:\n{\n \"tools\": [\"tool_id\"],\n \"reasoning\": \"brief explanation\",\n \"primary_intent\": \"main purpose\",\n \"confidence\": 0.0\n}\n\nEXAMPLES:\nQuestion: \"find a good image classification model\"\nResponse: {\"tools\": [\"huggingface\"], \"reasoning\": \"ML model search request\", \"primary_intent\": \"ai_ml\", \"confidence\": 0.9}\n\nQuestion: \"what's the weather like\"\nResponse: {\"tools\": [\"weather\"], \"reasoning\": \"Weather information request\", \"primary_intent\": \"weather\", \"confidence\": 0.95}\n\nYour response must be valid JSON starting with { and ending with }:`;\n\n const response = await groqClient.chat.completions.create({\n model: \"openai/gpt-oss-120b\", // Use a more reliable model for JSON parsing\n messages: [\n {\n role: \"system\",\n content: systemPrompt\n },\n {\n role: \"user\",\n content: `Analyze this question and return JSON: \"${question}\"`\n }\n ],\n temperature: 0.0, // Even lower temperature for JSON consistency\n max_tokens: 500 // Limit response length\n });\n\n const resultText = response.choices[0]?.message?.content || '';\n console.log(`🔍 ROUTING: AI raw response: \"${resultText}\"`);\n\n // Try to parse the JSON response - handle various formats\n try {\n // First try direct JSON parsing\n let routingDecision = JSON.parse(resultText);\n console.log(`✅ ROUTING: Successfully parsed JSON - tools: [${routingDecision.tools?.join(', ')}], reasoning: \"${routingDecision.reasoning}\", confidence: ${routingDecision.confidence}`);\n\n return {\n tools: routingDecision.tools || ['direct_answer'],\n reasoning: routingDecision.reasoning || 'AI-powered routing decision',\n primaryIntent: routingDecision.primary_intent || 'general',\n confidence: routingDecision.confidence || 0.8\n };\n } catch (parseError) {\n console.error('❌ ROUTING: Failed to parse routing decision as JSON:', parseError);\n\n // Try multiple methods to extract JSON from the response\n try {\n // Method 1: Look for JSON-like content with curly braces\n const jsonMatch = resultText.match(/\\{[\\s\\S]*?\\}/);\n if (jsonMatch) {\n const extractedJson = JSON.parse(jsonMatch[0]);\n console.log(`🔄 ROUTING: Extracted JSON from braces - tools: [${extractedJson.tools?.join(', ')}], reasoning: \"${extractedJson.reasoning}\"`);\n return {\n tools: extractedJson.tools || ['direct_answer'],\n reasoning: extractedJson.reasoning || 'Extracted from AI response',\n primaryIntent: extractedJson.primary_intent || 'general',\n confidence: extractedJson.confidence || 0.6\n };\n }\n\n // Method 2: Try to find JSON between code blocks\n const codeBlockMatch = resultText.match(/```(?:json)?\\s*(\\{[\\s\\S]*?\\})\\s*```/);\n if (codeBlockMatch) {\n const extractedJson = JSON.parse(codeBlockMatch[1]);\n console.log(`🔄 ROUTING: Extracted JSON from code block - tools: [${extractedJson.tools?.join(', ')}], reasoning: \"${extractedJson.reasoning}\"`);\n return {\n tools: extractedJson.tools || ['direct_answer'],\n reasoning: extractedJson.reasoning || 'Extracted from code block',\n primaryIntent: extractedJson.primary_intent || 'general',\n confidence: extractedJson.confidence || 0.6\n };\n }\n\n // Method 3: Try to clean and parse the entire response\n const cleanedResponse = resultText.trim();\n if (cleanedResponse.startsWith('{') && cleanedResponse.endsWith('}')) {\n const extractedJson = JSON.parse(cleanedResponse);\n console.log(`🔄 ROUTING: Parsed cleaned response - tools: [${extractedJson.tools?.join(', ')}], reasoning: \"${extractedJson.reasoning}\"`);\n return {\n tools: extractedJson.tools || ['direct_answer'],\n reasoning: extractedJson.reasoning || 'Parsed from cleaned response',\n primaryIntent: extractedJson.primary_intent || 'general',\n confidence: extractedJson.confidence || 0.6\n };\n }\n\n } catch (extractError) {\n console.error('❌ ROUTING: Failed to extract JSON from response:', extractError);\n }\n\n // If all parsing fails, return default\n console.log(`⚠️ ROUTING: All parsing failed, using default - tools: [direct_answer]`);\n return {\n tools: ['direct_answer'],\n reasoning: 'Default routing due to parsing failure',\n primaryIntent: 'general',\n confidence: 0.5\n };\n }\n\n } catch (error) {\n console.error('❌ ROUTING: Intelligent routing error:', error);\n console.log(`⚠️ ROUTING: Error fallback - tools: [direct_answer]`);\n return {\n tools: ['direct_answer'],\n reasoning: 'Error in intelligent routing, using direct answer',\n primaryIntent: 'general',\n confidence: 0.3\n };\n }\n}\n\n\n// Correct common misspellings of \"Groq\" to ensure system works\nfunction correctGroqSpelling(text) {\n if (!text) return text;\n\n // Common misspellings and variations to correct\n const corrections = [\n // Exact word replacements (case-sensitive for proper nouns)\n { from: /\\bgrok\\b/gi, to: 'Groq' }, // grok -> Groq\n { from: /\\bgrock\\b/gi, to: 'Groq' }, // grock -> Groq\n { from: /\\bgroq\\b/g, to: 'Groq' }, // groq -> Groq (already correct but ensure proper case)\n { from: /\\bGrok\\b/g, to: 'Groq' }, // Grok -> Groq (standardize)\n { from: /\\bGrock\\b/g, to: 'Groq' }, // Grock -> Groq\n\n // Contextual corrections for phrases\n { from: /hey\\s+grok/gi, to: 'Hey Groq' }, // \"hey grok\" -> \"Hey Groq\"\n { from: /hey\\s+grock/gi, to: 'Hey Groq' }, // \"hey grock\" -> \"Hey Groq\"\n { from: /hi\\s+grok/gi, to: 'Hey Groq' }, // \"hi grok\" -> \"Hey Groq\"\n { from: /hello\\s+grok/gi, to: 'Hey Groq' }, // \"hello grok\" -> \"Hey Groq\"\n\n // Handle cases where \"groq\" appears without \"hey\"\n { from: /^\\s*grok\\s+/gi, to: 'Groq ' }, // \"grok something\" -> \"Groq something\"\n { from: /^\\s*grock\\s+/gi, to: 'Groq ' }, // \"grock something\" -> \"Groq something\"\n ];\n\n let correctedText = text;\n\n // Apply all corrections\n corrections.forEach(correction => {\n correctedText = correctedText.replace(correction.from, correction.to);\n });\n\n // More specific Brock vs Grok handling\n // Only correct \"Brock\" to \"Groq\" if it's clearly a misspelling in a trigger context\n if (correctedText.includes('Brock') && !correctedText.toLowerCase().includes('hugging')) {\n // If \"Brock\" appears and it's not in a Hugging Face context, it might be a Groq misspelling\n correctedText = correctedText.replace(/\\bBrock\\b/g, 'Groq');\n }\n\n // Add Hugging Face corrections\n correctedText = correctedText\n .replace(/\\bhugging\\s+clothes?\\b/gi, 'Hugging Face')\n .replace(/\\bhuging\\s+face\\b/gi, 'Hugging Face')\n .replace(/\\bhuggingface\\b/gi, 'Hugging Face')\n .replace(/\\bhugging\\s+face\\b/gi, 'Hugging Face');\n\n\n return correctedText;\n}\n\n// Detect if text contains \"Hey Groq\" trigger using simple detection\nfunction detectGroqTrigger(text) {\n // Normalize common misspellings first\n const normalized = correctGroqSpelling(text || '');\n\n // Robust detection for \"Hey Groq\" with optional punctuation and spacing\n const canonical = normalized\n .toLowerCase()\n .replace(/[.,!?;:]+/g, ' ') // ignore punctuation between/around words\n .replace(/\\s+/g, ' ')\n .trim();\n\n // Common greeting words that can trigger Groq\n const GREETINGS = ['hey', 'hi', 'hello', 'yo', 'sup', 'what\\'s up', 'greetings'];\n\n // Allow up to N words between greeting and \"groq\" (either order)\n const MAX_WORD_GAP = 6;\n\n // Build regex patterns for all greetings\n const greetingPatterns = GREETINGS.map(greeting => {\n // Escape special regex characters in greetings\n const escapedGreeting = greeting.replace(/[.*+?^${}()|[\\]\\\\]/g, '\\\\$&');\n // Pattern for greeting then groq (with optional words in between)\n const greetingThenGroq = new RegExp(`\\\\b${escapedGreeting}\\\\b(?:\\\\s+\\\\S+){0,${MAX_WORD_GAP}}\\\\s+\\\\bgroq\\\\b`, 'i');\n // Pattern for groq then greeting (with optional words in between)\n const groqThenGreeting = new RegExp(`\\\\bgroq\\\\b(?:\\\\s+\\\\S+){0,${MAX_WORD_GAP}}\\\\s+\\\\b${escapedGreeting}\\\\b`, 'i');\n return { greetingThenGroq, groqThenGreeting };\n });\n\n // Test all greeting patterns\n const hasGreetingTrigger = greetingPatterns.some(patterns =>\n patterns.greetingThenGroq.test(canonical) || patterns.groqThenGreeting.test(canonical)\n );\n\n const hasTrigger = hasGreetingTrigger ||\n /^groq\\b/.test(canonical) ||\n /\\bheygroq\\b/i.test(canonical);\n\n console.log(`🎤 Trigger detection for: \"${text}\" -> ${hasTrigger ? '✅ DETECTED' : '❌ NOT DETECTED'}`);\n\n return hasTrigger;\n}\n\n// Get weather using Groq compound model\nasync function getWeather(location) {\n try {\n const response = await groqClient.chat.completions.create({\n model: \"groq/compound\",\n messages: [\n {\n role: \"user\",\n content: `What's the current weather in ${location}? Provide a brief, helpful response with temperature, conditions, and any relevant details.`,\n },\n ],\n });\n\n return {\n response: response.choices[0]?.message?.content || \"I couldn't get the weather information right now.\",\n tool: \"weather\"\n };\n } catch (error) {\n console.error('Weather API error:', error);\n return {\n response: `Sorry, I couldn't get the weather for ${location} at the moment.`,\n tool: \"weather\",\n error: true\n };\n }\n}\n\n// Perform web search using Groq compound model\nasync function performWebSearch(query) {\n try {\n const response = await groqClient.chat.completions.create({\n model: \"groq/compound\",\n messages: [\n {\n role: \"user\",\n content: `Search the web for: ${query}. Provide current, accurate information with sources when possible. Be comprehensive but concise.`,\n },\n ],\n });\n\n return {\n response: response.choices[0]?.message?.content || \"I couldn't perform the web search right now.\",\n tool: \"web_search\"\n };\n } catch (error) {\n console.error('Web search error:', error);\n return {\n response: `Sorry, I couldn't perform the web search for \"${query}\" at the moment.`,\n tool: \"web_search\",\n error: true\n };\n }\n}\n\n// Answer question directly using OpenAI GPT model\nasync function answerDirectly(question, context = {}) {\n try {\n const systemPrompt = `You are Groq AI, a helpful AI assistant. Answer this question directly using your knowledge: \"${question}\"\n\nContext: Meeting transcript\nUser: ${context.userName || 'Unknown'}\n\nProvide a helpful, accurate response based on your training data. If you need current information, suggest using web search.`;\n\n const response = await groqClient.chat.completions.create({\n model: \"openai/gpt-oss-120b\",\n messages: [\n {\n role: \"system\",\n content: systemPrompt\n },\n {\n role: \"user\",\n content: question\n }\n ]\n });\n\n return {\n response: response.choices[0]?.message?.content || \"I couldn't generate a response right now.\",\n tool: \"direct_answer\"\n };\n } catch (error) {\n console.error('Direct answer error:', error);\n return {\n response: `Sorry, I couldn't answer that question directly at the moment.`,\n tool: \"direct_answer\",\n error: true\n };\n }\n}\n\n// Generic inference function using intelligent routing with MCP support\nasync function performGroqInference(transcript, userName, context = 'general', chatHistory = [], skipTriggerDetection = false) {\n try {\n // First, detect if this is actually a Groq trigger (unless skipped)\n if (!skipTriggerDetection) {\n const isGroqTrigger = detectGroqTrigger(transcript);\n\n if (!isGroqTrigger) {\n return {\n detected: false,\n response: `I didn't detect a \"Hey Groq\" trigger in: \"${transcript}\"`\n };\n }\n }\n\n // Use intelligent router to decide which tools to use (now with chat history)\n // Router works with original transcript text (no spelling corrections)\n const routingDecision = await intelligentRouter(transcript, userName, context, chatHistory);\n\n console.log(`🎯 INFERENCE: Routing decision - tools: [${routingDecision.tools.join(', ')}], reasoning: \"${routingDecision.reasoning}\", confidence: ${routingDecision.confidence}`);\n\n const availableTools = getAvailableTools();\n const toolResults = [];\n let finalResponse = '';\n const toolsUsed = [];\n const mcpTools = [];\n\n // Prepare MCP tools for the Responses API: include ONLY MCP tools selected by the router\n for (const toolName of routingDecision.tools) {\n const toolConfig = availableTools[toolName];\n if (!toolConfig || toolConfig.type !== 'mcp') continue;\n\n let shouldInclude = true;\n const mcpToolConfig = {\n type: 'mcp',\n server_label: toolConfig.server_label,\n server_url: toolConfig.server_url,\n };\n\n // ParallelSearch requires API key; include only if present\n if (toolName === 'parallel_search') {\n const parallelKey = Deno.env.get('PARALLEL_API_KEY');\n if (parallelKey) {\n mcpToolConfig.headers = { 'x-api-key': parallelKey };\n } else {\n shouldInclude = false;\n }\n }\n\n // For other MCP tools: include headers only if configured with non-empty headers\n if (toolName !== 'parallel_search' && toolConfig.headers && Object.keys(toolConfig.headers).length > 0) {\n mcpToolConfig.headers = toolConfig.headers;\n }\n\n if (shouldInclude) {\n mcpTools.push(mcpToolConfig);\n }\n }\n\n // If we have MCP tools, use the Responses API\n if (mcpTools.length > 0) {\n try {\n console.log(`🔧 Using ${mcpTools.length} MCP tools`);\n\n // No inline API key checks here; keys are defined in registry via auth object\n\n // Make direct HTTP call to Groq Responses API since OpenAI client may not support it yet\n const response = await fetch('https://api.groq.com/openai/v1/responses', {\n method: 'POST',\n headers: {\n 'Authorization': `Bearer ${GROQ_API_KEY}`,\n 'Content-Type': 'application/json',\n },\n body: JSON.stringify({\n model: \"openai/gpt-oss-120b\", // Use the model that works in the curl example\n input: transcript,\n instructions: `You are Groq AI, a helpful AI assistant. The user said: \"${transcript}\"\n\nContext: ${context}\nUser: ${userName}\nRouting decision: ${routingDecision.reasoning}\n\nProvide a helpful response using the available MCP tools.`,\n tools: mcpTools\n })\n });\n\n if (!response.ok) {\n throw new Error(`Groq API error: ${response.status} ${response.statusText}`);\n }\n\n const responseData = await response.json();\n\n // Extract the final response from the structured output\n const finalMessage = responseData.output?.find(item => item.type === 'message');\n finalResponse = finalMessage?.content?.[0]?.text || 'I used MCP tools but couldn\\'t generate a response.';\n\n // Track MCP tool usage\n const mcpCalls = responseData.output?.filter(item => item.type === 'mcp_call') || [];\n mcpCalls.forEach(call => {\n toolsUsed.push({\n name: `${call.server_label}.${call.name}`,\n success: true,\n category: 'mcp',\n server: call.server_label\n });\n });\n\n } catch (mcpError) {\n console.error('❌ MCP Responses API error:', mcpError);\n console.error('Error details:', mcpError.message);\n\n // Try to get more details from the error\n let errorDetails = {};\n try {\n if (mcpError.message.includes('Groq API error:')) {\n const statusMatch = mcpError.message.match(/(\\d+)/);\n if (statusMatch) {\n const status = parseInt(statusMatch[1]);\n errorDetails.status = status;\n\n if (status === 401 || status === 403) {\n console.error('💡 This might be an authentication issue - check GROQ_API_KEY');\n } else if (status === 404) {\n console.error('💡 This might be a model or endpoint issue - check model name');\n } else if (status >= 500) {\n console.error('💡 This might be a server-side issue with Groq');\n }\n }\n }\n } catch (parseError) {\n // Ignore parsing errors\n }\n\n // Check for common MCP issues in the error message\n if (mcpError.message?.includes('model') || mcpError.message?.includes('not supported')) {\n console.error('💡 This might be a model compatibility issue - MCP may not be supported by the current model');\n }\n\n // Fall back to built-in tools or direct answer\n }\n }\n\n // Execute built-in tools if no MCP tools were used or if MCP failed\n if (!finalResponse) {\n\n for (const toolName of routingDecision.tools) {\n try {\n const toolConfig = availableTools[toolName];\n if (!toolConfig) {\n continue;\n }\n\n if (toolConfig.type === 'mcp') {\n // MCP tool failed, try to provide a fallback response\n if (toolName === 'huggingface') {\n finalResponse = `I tried to search Hugging Face for trending models, but the tool is currently unavailable. You can visit https://huggingface.co/models?sort=trending to see the latest trending models directly.`;\n } else if (toolName === 'parallel_search') {\n finalResponse = `I tried to perform a web search, but the tool is currently unavailable. You can try searching directly on your preferred search engine.`;\n } else {\n finalResponse = `I tried to use the ${toolName} tool, but it's currently unavailable.`;\n }\n toolsUsed.push({\n name: toolName,\n success: false,\n category: 'mcp',\n namespace: toolConfig.namespace,\n displayName: toolConfig.displayName,\n error: 'MCP tool unavailable'\n });\n continue;\n }\n\n if (toolConfig.type !== 'builtin') continue;\n\n let result;\n\n // Use the handler function from the registry\n if (toolConfig.handler) {\n // Special handling for weather tool to extract location\n if (toolName === 'weather') {\n const locationMatch = transcript.match(/(?:weather in|weather for)\\s+([A-Za-z\\s,]+)/i);\n const location = locationMatch ? locationMatch[1].trim() : 'San Francisco';\n result = await toolConfig.handler(location);\n result.location = location;\n } else {\n result = await toolConfig.handler(transcript, { userName, context });\n }\n } else {\n console.warn(`No handler found for built-in tool: ${toolName}`);\n continue;\n }\n\n toolResults.push(result);\n toolsUsed.push({\n name: toolName,\n success: !result.error,\n category: toolConfig.category,\n namespace: toolConfig.namespace,\n displayName: toolConfig.displayName,\n location: result.location\n });\n\n // Combine responses\n if (finalResponse) {\n finalResponse += '\\n\\n';\n }\n finalResponse += result.response;\n\n } catch (toolError) {\n console.error(`Error executing built-in tool ${toolName}:`, toolError);\n toolsUsed.push({\n name: toolName,\n success: false,\n category: 'builtin',\n namespace: 'general',\n error: toolError.message\n });\n }\n }\n\n // If still no response, fall back to direct answer\n if (!finalResponse) {\n try {\n const directResult = await answerDirectly(transcript, { userName, context });\n finalResponse = directResult.response;\n toolsUsed.push({\n name: 'direct_answer',\n success: true,\n category: 'general',\n namespace: 'general',\n displayName: 'Direct Answer'\n });\n } catch (directError) {\n console.error('Direct answer fallback failed:', directError);\n finalResponse = \"I'm sorry, I encountered an error processing your request. Please try again.\";\n }\n }\n\n // If we have multiple built-in tools, create a summary response\n if (routingDecision.tools.length > 1 && toolResults.length > 1) {\n try {\n const summaryPrompt = `You are Groq AI. The user asked: \"${transcript}\"\n\nI used these tools: ${toolsUsed.map(t => t.name).join(', ')}\n\nTool results:\n${toolResults.map((result, index) =>\n `Tool ${index + 1} (${result.tool}): ${result.response}`\n).join('\\n\\n')}\n\nPlease provide a comprehensive, well-formatted response that synthesizes all this information for the user.`;\n\n const summaryResponse = await groqClient.chat.completions.create({\n model: \"openai/gpt-oss-120b\",\n messages: [\n {\n role: \"system\",\n content: summaryPrompt\n },\n {\n role: \"user\",\n content: \"Please summarize and synthesize the tool results into a comprehensive response.\"\n }\n ]\n });\n\n finalResponse = summaryResponse.choices[0]?.message?.content || finalResponse;\n toolsUsed.push({\n name: 'response_synthesis',\n success: true,\n category: 'synthesis'\n });\n\n } catch (summaryError) {\n console.error('Error creating summary response:', summaryError);\n // Keep the combined response if summary fails\n }\n }\n }\n\n return {\n detected: true,\n response: finalResponse || \"I processed your request but couldn't generate a response.\",\n tools: toolsUsed,\n routing: routingDecision,\n context: context,\n chatHistoryLength: chatHistory.length\n };\n\n } catch (error) {\n console.error('Groq inference error:', error);\n return {\n detected: true,\n response: `Hello ${userName}! I detected your \"Hey Groq\" trigger but encountered an error processing your request: ${transcript}`,\n error: error.message,\n tools: []\n };\n }\n}\n\n// Groq inference endpoint\napp.post('/api/groq-inference', async (c) => {\n try {\n const { transcript, user_name, context, chat_history } = await c.req.json();\n\n if (!transcript) {\n return c.json({ error: 'Transcript text required' }, 400);\n }\n\n if (!GROQ_API_KEY) {\n return c.json({\n detected: true,\n response: `Hello ${user_name || 'there'}! I detected your \"Hey Groq\" trigger, but the Groq API key is not configured. Please set GROQ_API_KEY environment variable.`,\n original_message: transcript,\n tools: []\n });\n }\n\n // Prepare chat history for the router (filter out system messages and limit to recent)\n const filteredChatHistory = (chat_history || [])\n .filter(msg => msg.user_id !== 'system' && msg.data)\n .slice(-10); // Keep last 10 messages for context\n\n const result = await performGroqInference(transcript, user_name, context, filteredChatHistory);\n\n // Include original message for frontend formatting\n result.original_message = transcript;\n\n return c.json(result);\n } catch (error) {\n console.error('Groq inference endpoint error:', error);\n return c.json({\n detected: false,\n response: 'Sorry, I encountered an error processing your request.',\n error: error.message,\n tools: [],\n original_message: transcript\n }, 500);\n }\n});\n\n// New trigger endpoint that processes Groq triggers from frontend\napp.post('/api/trigger-groq', async (c) => {\n try {\n const { transcript, user_name, context, chat_history, user_id, timestamp } = await c.req.json();\n\n if (!transcript) {\n return c.json({ error: 'Transcript text required' }, 400);\n }\n\n console.log(`🎯 Processing: \"${transcript?.slice(0, 40)}${transcript?.length > 40 ? '...' : ''}\"`);\n\n // Prepare chat history for the router (filter out system messages and limit to recent)\n const filteredChatHistory = (chat_history || [])\n .filter(msg => msg.user_id !== 'system' && msg.data)\n .slice(-10); // Keep last 10 messages for context\n\n // Process the inference (skip trigger detection since frontend already validated)\n const result = await performGroqInference(transcript, user_name || 'Unknown', context || 'meeting_transcript', filteredChatHistory, true);\n\n // Create response transcript for SSE broadcast\n const responseTranscript = {\n user_id: 'groq-ai',\n user_name: 'Groq AI Assistant',\n data: result.response || 'I processed your request but couldn\\'t generate a response.',\n timestamp: Date.now(),\n tools: result.tools || [],\n routing: result.routing || { reasoning: 'Direct routing', primaryIntent: 'general', confidence: 0.5 },\n original_message: transcript\n };\n\n // Store response transcript for polling endpoint\n addToRecentTranscripts(responseTranscript);\n\n // Try to broadcast through SSE first (works in single-instance environments)\n let sseBroadcastSuccess = false;\n for (const client of sseClients) {\n try {\n client.send('event: transcript\\n' + 'data: ' + JSON.stringify({\n content: responseTranscript\n }) + '\\n\\n');\n sseBroadcastSuccess = true;\n } catch (broadcastError) {\n console.error('Error broadcasting to SSE client:', broadcastError);\n }\n }\n\n // In serverless environments, SSE clients may not be connected to this instance\n // Return the response transcript so frontend can add it directly\n if (!sseBroadcastSuccess || sseClients.size === 0) {\n return c.json({\n success: true,\n detected: true,\n tools_used: (result.tools || []).length,\n routing_decision: (result.routing || {}).reasoning,\n response_transcript: responseTranscript // Include the full transcript for frontend to add\n });\n }\n\n // Also broadcast a system message if there was an error\n if (result.error) {\n const errorTranscript = {\n user_id: 'system',\n user_name: 'Groq AI',\n data: `⚠️ Processing completed with error: ${result.error}`,\n timestamp: Date.now(),\n error: true\n };\n\n for (const client of sseClients) {\n try {\n client.send('event: transcript\\n' + 'data: ' + JSON.stringify({\n content: errorTranscript\n }) + '\\n\\n');\n } catch (broadcastError) {\n console.error('Error broadcasting error to SSE client:', broadcastError);\n }\n }\n }\n\n return c.json({\n success: true,\n detected: result.detected,\n tools_used: result.tools?.length || 0,\n routing_decision: result.routing?.reasoning\n });\n\n } catch (error) {\n console.error('Trigger processing error:', error);\n return c.json({\n success: false,\n error: error.message\n }, 500);\n }\n});\n\n// Export app.fetch for Val Town, otherwise export app\nexport default (typeof Deno !== \"undefined\" && Deno.env.get(\"valtown\")) ? app.fetch : app;\n",[],[285],"files",[148,167,176,183,194,201,211,218,228,237,246,256,265,274,283],"counts",{"_298":32,"_299":198,"_300":32,"_301":302},"pulls","branches","forks","envVars",{"_303":205,"_304":32},"count","emptyCount","contents",[307,310,313,316,319,322,325,328,331,334,337],{"_102":149,"_95":150,"_151":152,"_153":-5,"_154":136,"_155":156,"_157":158,"_104":308,"_99":32,"_160":161,"_162":-5,"_163":22,"_164":-5,"_98":309},["D",1758235656395],[150],{"_102":177,"_95":178,"_151":179,"_153":-5,"_154":136,"_155":180,"_157":158,"_104":311,"_99":32,"_160":161,"_162":-5,"_163":22,"_164":-5,"_98":312},["D",1758132865194],[178],{"_102":195,"_95":196,"_151":197,"_153":-5,"_154":136,"_155":198,"_157":158,"_104":314,"_99":32,"_160":161,"_162":-5,"_163":22,"_164":-5,"_98":315},["D",1758132865027],[196],{"_102":212,"_95":213,"_151":214,"_153":-5,"_154":136,"_155":215,"_157":158,"_104":317,"_99":32,"_160":161,"_162":-5,"_163":22,"_164":-5,"_98":318},["D",1758565856719],[213],{"_102":229,"_95":230,"_151":231,"_153":-5,"_154":136,"_155":232,"_157":158,"_104":320,"_99":32,"_160":189,"_162":234,"_163":22,"_164":-5,"_98":321},["D",1758132865374],[230],{"_102":238,"_95":239,"_151":240,"_153":-5,"_154":136,"_155":241,"_157":158,"_104":323,"_99":32,"_160":189,"_162":243,"_163":22,"_164":-5,"_98":324},["D",1758565857072],[239],{"_102":247,"_95":248,"_151":249,"_153":-5,"_154":136,"_155":250,"_157":158,"_104":326,"_99":252,"_160":189,"_162":253,"_163":22,"_164":-5,"_98":327},["D",1758565857075],[248],{"_102":257,"_95":258,"_151":259,"_153":-5,"_154":136,"_155":260,"_157":158,"_104":329,"_99":32,"_160":189,"_162":262,"_163":22,"_164":-5,"_98":330},["D",1758565856908],[258],{"_102":266,"_95":267,"_151":268,"_153":-5,"_154":136,"_155":269,"_157":158,"_104":332,"_99":180,"_160":189,"_162":271,"_163":22,"_164":-5,"_98":333},["D",1758565856944],[267],{"_102":275,"_95":276,"_151":277,"_153":-5,"_154":136,"_155":278,"_157":158,"_104":335,"_99":32,"_160":189,"_162":280,"_163":22,"_164":-5,"_98":336},["D",1758132865417],[276],{"_102":284,"_95":285,"_151":286,"_153":-5,"_154":136,"_155":287,"_157":158,"_104":338,"_99":289,"_160":290,"_162":291,"_163":22,"_164":96,"_98":339},["D",1758565856941],[285],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.environment-variables",{"_93":94,"_95":96,"_100":348,"_301":353},{"_102":103,"_95":96,"_104":349,"_106":-5,"_107":22,"_108":109,"_110":72,"_111":-5,"_14":112,"_113":-5,"_114":22,"_115":-5,"_116":32,"_16":117,"_118":119,"_120":119,"_121":122,"_123":122,"_124":122,"_125":119,"_126":119,"_23":350,"_130":351,"_133":352,"_145":22},["D",1758132864066],{"_93":94,"_128":129},{"_93":94,"_132":129},{"_99":135,"_95":43,"_102":136,"_137":103,"_138":-5,"_139":-5,"_140":-5,"_141":-5,"_142":-5,"_143":96,"_144":94},[354,360,363,367,371,375,379],{"_355":356,"_104":357,"_358":-5,"_110":72,"_359":22},"key","WEBHOOK_PATH",["D",1758235817630],"updatedAt","isEmpty",{"_355":361,"_104":362,"_358":-5,"_110":-5,"_359":22},"FRONTEND_WS_URL",["D",1758158242113],{"_355":364,"_104":365,"_358":366,"_110":-5,"_359":22},"OPENROUTER_API_KEY",["D",1758142760032],["D",1758158242110],{"_355":368,"_104":369,"_358":370,"_110":-5,"_359":22},"ZOOM_CLIENT_ID",["D",1758141381681],["D",1758158242098],{"_355":372,"_104":373,"_358":374,"_110":-5,"_359":22},"ZOOM_CLIENT_SECRET",["D",1758141381681],["D",1758158242102],{"_355":376,"_104":377,"_358":378,"_110":-5,"_359":22},"ZOOM_REDIRECT_URI",["D",1758141381681],["D",1758158242105],{"_355":380,"_104":381,"_358":382,"_110":-5,"_359":22},"ZOOM_SECRET_TOKEN",["D",1758141381681],["D",1758158242108],"actionData","errors"]

yawnxyz

zoomtest

Environment variables