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",[],[270],{"_105":278,"_96":279,"_156":280,"_158":-5,"_159":142,"_160":102,"_162":119,"_107":281,"_101":282,"_164":193,"_166":283,"_167":22,"_168":-5,"_169":284,"_99":285},"47c40406-97e2-11f0-b527-0224a6c84d84",".vtignore","24b8c9b8-93f2-11f0-be8c-0224a6c84d84",["D",1758565857075],4,".git\n.vscode\n.cursorrules\n.DS_Store\nnode_modules\nvendor\n\nprint_transcripts_demo",[],[279],{"_105":287,"_96":288,"_156":289,"_158":-5,"_159":142,"_160":290,"_162":119,"_107":291,"_101":32,"_164":193,"_166":292,"_167":22,"_168":-5,"_169":293,"_99":294},"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",[],[288],{"_105":296,"_96":297,"_156":298,"_158":-5,"_159":142,"_160":299,"_162":22,"_107":300,"_101":32,"_164":193,"_166":301,"_167":22,"_168":-5,"_169":302,"_99":303},"7942168e-94e1-11f0-81a7-0224a6c84d84","deno-output.md","7942174c-94e1-11f0-81a7-0224a6c84d84",52,["D",1758235657134],"^C% \njanzheng@Jans-BlackBook-Pro zoom-test % \njanzheng@Jans-BlackBook-Pro zoom-test % \njanzheng@Jans-BlackBook-Pro zoom-test % ls\ndeno.json main_backup.js real-time_transcript_analysis_js\ndeno.lock main_backup_2.js save_transcript_js\nmain.js print_transcripts\njanzheng@Jans-BlackBook-Pro zoom-test % ls\njanzheng@Jans-BlackBook-Pro zoom-test % \njanzheng@Jans-BlackBook-Pro zoom-test % deno task print\nWarning \"exports\" field should be specified when specifying a \"name\".\n at file:///Users/janzheng/localhost/smallweb/zoom-test/deno.json\nTask print deno serve --port 9999 --watch --allow-read --allow-env --allow-write --allow-net ./main.js\nWatcher Process started.\nWarning \"exports\" field should be specified when specifying a \"name\".\n at file:///Users/janzheng/localhost/smallweb/zoom-test/deno.json\nServer running at http://localhost:9999\nWebhook endpoint available at http://localhost:9999/webhook\nListening on http://0.0.0.0:9999/ (http://localhost:9999/)\nerror: Uncaught (in promise) AddrInUse: Address already in use (os error 48)\n at listen (ext:deno_net/01_net.js:594:35)\n at serveInner (ext:deno_http/00_serve.ts:710:16)\n at Object.serve (ext:deno_http/00_serve.ts:627:10)\n at ext:deno_http/00_serve.ts:854:10\n at ext:runtime_main/js/99_main.js:886:13\nWatcher Process failed. Restarting on file change...\nps aux | grep \"deno.*serve\"^C% \njanzheng@Jans-BlackBook-Pro zoom-test % \njanzheng@Jans-BlackBook-Pro zoom-test % \njanzheng@Jans-BlackBook-Pro zoom-test % \njanzheng@Jans-BlackBook-Pro zoom-test % ps aux | grep \"deno.*serve\"\njanzheng 59930 0.0 0.0 408114912 1408 s029 S+ 2:24PM 0:00.00 grep deno.*serve\njanzheng@Jans-BlackBook-Pro zoom-test % \njanzheng@Jans-BlackBook-Pro zoom-test % \njanzheng@Jans-BlackBook-Pro zoom-test % \njanzheng@Jans-BlackBook-Pro zoom-test % deno task serve \nWarning \"exports\" field should be specified when specifying a \"name\".\n at file:///Users/janzheng/localhost/smallweb/zoom-test/deno.json\nTask not found: serve\nAvailable tasks:\n- print\n deno serve --port 9999 --watch --allow-read --allow-env --allow-write --allow-net ./main.js\n- prod\n deployctl deploy --prod\njanzheng@Jans-BlackBook-Pro zoom-test % deno task print\nWarning \"exports\" field should be specified when specifying a \"name\".\n at file:///Users/janzheng/localhost/smallweb/zoom-test/deno.json\nTask print deno serve --port 9999 --watch --allow-read --allow-env --allow-write --allow-net ./main.js\nWatcher Process started.\nWarning \"exports\" field should be specified when specifying a \"name\".\n at file:///Users/janzheng/localhost/smallweb/zoom-test/deno.json\nServer running at http://localhost:9999\nWebhook endpoint available at http://localhost:9999/webhook\nListening on http://0.0.0.0:9999/ (http://localhost:9999/)\nerror: Uncaught (in promise) AddrInUse: Address already in use (os error 48)\n at listen (ext:deno_net/01_net.js:594:35)\n at serveInner (ext:deno_http/00_serve.ts:710:16)\n at Object.serve (ext:deno_http/00_serve.ts:627:10)\n at ext:deno_http/00_serve.ts:854:10\n at ext:runtime_main/js/99_main.js:886:13\nWatcher Process failed. Restarting on file change...\nzsh: killed deno task print\njanzheng@Jans-BlackBook-Pro zoom-test % deno task print\nWarning \"exports\" field should be specified when specifying a \"name\".\n at file:///Users/janzheng/localhost/smallweb/zoom-test/deno.json\nTask print deno serve --port 9998 --watch --allow-read --allow-env --allow-write --allow-net ./main.js\nWatcher Process started.\nWarning \"exports\" field should be specified when specifying a \"name\".\n at file:///Users/janzheng/localhost/smallweb/zoom-test/deno.json\nServer running at http://localhost:9999\nWebhook endpoint available at http://localhost:9999/webhook\nListening on http://0.0.0.0:9999/ (http://localhost:9999/)\ndeno serve: Listening on http://0.0.0.0:9998/\nRTMS Webhook received: {\n \"event\": \"meeting.started\",\n \"payload\": {\n \"account_id\": \"6qOL12OcTwiPar1cV0rCOQ\",\n \"object\": {\n \"duration\": 0,\n \"start_time\": \"2025-09-18T21:31:46Z\",\n \"timezone\": \"\",\n \"topic\": \"Jan Zheng's Zoom Meeting\",\n \"id\": \"72922396626\",\n \"type\": 1,\n \"uuid\": \"MnRr97N5RwmUC4I+yJ1okQ==\",\n \"host_id\": \"0Al6aUdLSeCOFquEI6lE0Q\"\n }\n },\n \"event_ts\": 1758231106931\n}\nRTMS Webhook received: {\n \"event\": \"meeting.rtms_started\",\n \"payload\": {\n \"meeting_uuid\": \"MnRr97N5RwmUC4I+yJ1okQ==\",\n \"operator_id\": \"0Al6aUdLSeCOFquEI6lE0Q\",\n \"rtms_stream_id\": \"04175c7e626e4767b6181913749ed596\",\n \"server_urls\": \"wss://zoomsjc144-195-46-178zssgw.sjc.zoom.us:443\"\n },\n \"event_ts\": 1758231107199\n}\nRTMS Started event received\nConnecting to signaling WebSocket for meeting MnRr97N5RwmUC4I+yJ1okQ==\nSignaling WebSocket connection opened for meeting MnRr97N5RwmUC4I+yJ1okQ==\nGenerating signature with parameters:\nmeetingUuid: MnRr97N5RwmUC4I+yJ1okQ==\nstreamId: 04175c7e626e4767b6181913749ed596\nSent handshake to signaling server\nSignaling Message: {\n \"media_server\": {\n \"server_urls\": {\n \"all\": \"wss://zoomsjc144-195-46-178zssgw.sjc.zoom.us:443\",\n \"audio\": \"wss://zoomsjc144-195-46-178zssgw.sjc.zoom.us:443\",\n \"chat\": \"wss://zoomsjc144-195-46-178zssgw.sjc.zoom.us:443\",\n \"deskshare\": \"wss://zoomsjc144-195-46-178zssgw.sjc.zoom.us:443\",\n \"transcript\": \"wss://zoomsjc144-195-46-178zssgw.sjc.zoom.us:443\",\n \"video\": \"wss://zoomsjc144-195-46-178zssgw.sjc.zoom.us:443\"\n }\n },\n \"msg_type\": 2,\n \"protocol_version\": 1,\n \"sequence\": 794645963,\n \"status_code\": 0\n}\nConnecting to media WebSocket at wss://zoomsjc144-195-46-178zssgw.sjc.zoom.us:443\nGenerating signature with parameters:\nmeetingUuid: MnRr97N5RwmUC4I+yJ1okQ==\nstreamId: 04175c7e626e4767b6181913749ed596\nRaw WebSocket data type: object [object Blob]\n📨 MSG_TYPE 4 received (OTHER)\nMedia JSON Message: {\n \"media_params\": {\n \"transcript\": {\n \"content_type\": 5\n }\n },\n \"msg_type\": 4,\n \"payload_encrypted\": false,\n \"protocol_version\": 1,\n \"status_code\": 0\n}\nMedia handshake successful, sent start streaming request\nSignaling Message: {\n \"msg_type\": 8,\n \"state\": 1,\n \"timestamp\": 1758231108041\n}\nSignaling Message: {\n \"msg_type\": 9,\n \"rtms_session_id\": \"7E4FCB7C-0025-B28F-2D83-590985EA2A84\",\n \"state\": 2,\n \"timestamp\": 1758231108041\n}\nRTMS Webhook received: {\n \"event\": \"meeting.created\",\n \"payload\": {\n \"account_id\": \"6qOL12OcTwiPar1cV0rCOQ\",\n \"operator\": \"janeazy@gmail.com\",\n \"operator_id\": \"0Al6aUdLSeCOFquEI6lE0Q\",\n \"object\": {\n \"uuid\": \"MnRr97N5RwmUC4I+yJ1okQ==\",\n \"id\": 72922396626,\n \"host_id\": \"0Al6aUdLSeCOFquEI6lE0Q\",\n \"topic\": \"Jan Zheng's Zoom Meeting\",\n \"type\": 1,\n \"duration\": 0,\n \"join_url\": \"https://us04web.zoom.us/j/72922396626?pwd=6QjGWhnXjanfT7RbsaRVXhRcaT4Ola.1\",\n \"password\": \"042260\",\n \"settings\": {\n \"join_before_host\": true,\n \"jbh_time\": 0,\n \"use_pmi\": false,\n \"alternative_hosts\": \"\",\n \"meeting_invitees\": []\n },\n \"creation_source\": \"other\"\n }\n },\n \"event_ts\": 1758231109158\n}\nRTMS Webhook received: {\n \"payload\": {\n \"account_id\": \"6qOL12OcTwiPar1cV0rCOQ\",\n \"object\": {\n \"uuid\": \"MnRr97N5RwmUC4I+yJ1okQ==\",\n \"participant\": {\n \"public_ip\": \"50.202.219.97\",\n \"user_id\": \"16778240\",\n \"user_name\": \"Jan Zheng\",\n \"participant_user_id\": \"0Al6aUdLSeCOFquEI6lE0Q\",\n \"id\": \"0Al6aUdLSeCOFquEI6lE0Q\",\n \"join_time\": \"2025-09-18T21:31:46Z\",\n \"email\": \"janeazy@gmail.com\",\n \"participant_uuid\": \"D1F383C5-4867-46DF-B5FA-30C5E81D0ECC\"\n },\n \"id\": \"72922396626\",\n \"type\": 1,\n \"topic\": \"Jan Zheng's Zoom Meeting\",\n \"host_id\": \"0Al6aUdLSeCOFquEI6lE0Q\",\n \"duration\": 0,\n \"start_time\": \"2025-09-18T21:31:46Z\",\n \"timezone\": \"\"\n }\n },\n \"event_ts\": 1758231110080,\n \"event\": \"meeting.participant_joined\"\n}\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 0,\n \"timestamp\": 1758231117827\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231117827 }\nRaw WebSocket data type: object [object Blob]\n📨 MSG_TYPE 12 received (KEEP_ALIVE)\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 0,\n \"timestamp\": 1758231118027\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 1,\n \"timestamp\": 1758231127827\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231127827 }\nRaw WebSocket data type: object [object Blob]\n📨 MSG_TYPE 12 received (KEEP_ALIVE)\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 1,\n \"timestamp\": 1758231128028\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 2,\n \"timestamp\": 1758231137827\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231137827 }\nRaw WebSocket data type: object [object Blob]\n📨 MSG_TYPE 12 received (KEEP_ALIVE)\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 2,\n \"timestamp\": 1758231138027\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 8,\n \"reason\": 6,\n \"state\": 4,\n \"timestamp\": 1758231139481\n}\nSignaling socket closed\nMedia socket closed\nRTMS Webhook received: {\n \"event\": \"meeting.rtms_stopped\",\n \"payload\": {\n \"meeting_uuid\": \"MnRr97N5RwmUC4I+yJ1okQ==\",\n \"rtms_stream_id\": \"04175c7e626e4767b6181913749ed596\",\n \"stop_reason\": 6\n },\n \"event_ts\": 1758231142484\n}\nRTMS Stopped event received\nRTMS Webhook received: {\n \"payload\": {\n \"account_id\": \"6qOL12OcTwiPar1cV0rCOQ\",\n \"object\": {\n \"uuid\": \"MnRr97N5RwmUC4I+yJ1okQ==\",\n \"participant\": {\n \"leave_time\": \"2025-09-18T21:32:19Z\",\n \"public_ip\": \"50.202.219.97\",\n \"user_id\": \"16778240\",\n \"user_name\": \"Jan Zheng\",\n \"registrant_id\": \"\",\n \"participant_user_id\": \"0Al6aUdLSeCOFquEI6lE0Q\",\n \"id\": \"0Al6aUdLSeCOFquEI6lE0Q\",\n \"leave_reason\": \"left the meeting. Reason : Host ended the meeting.\",\n \"email\": \"janeazy@gmail.com\",\n \"private_ip\": \"10.253.1.124\",\n \"participant_uuid\": \"D1F383C5-4867-46DF-B5FA-30C5E81D0ECC\"\n },\n \"id\": \"72922396626\",\n \"type\": 1,\n \"topic\": \"Jan Zheng's Zoom Meeting\",\n \"host_id\": \"0Al6aUdLSeCOFquEI6lE0Q\",\n \"duration\": 0,\n \"start_time\": \"2025-09-18T21:31:46Z\",\n \"timezone\": \"\"\n }\n },\n \"event_ts\": 1758231142940,\n \"event\": \"meeting.participant_left\"\n}\nRTMS Webhook received: {\n \"event\": \"meeting.started\",\n \"payload\": {\n \"account_id\": \"6qOL12OcTwiPar1cV0rCOQ\",\n \"object\": {\n \"duration\": 0,\n \"start_time\": \"2025-09-18T21:32:27Z\",\n \"timezone\": \"\",\n \"topic\": \"Jan Zheng's Zoom Meeting\",\n \"id\": \"73559547278\",\n \"type\": 1,\n \"uuid\": \"snKXOpdaSKymWSPuVINTcA==\",\n \"host_id\": \"0Al6aUdLSeCOFquEI6lE0Q\"\n }\n },\n \"event_ts\": 1758231148217\n}\nRTMS Webhook received: {\n \"event\": \"meeting.rtms_started\",\n \"payload\": {\n \"meeting_uuid\": \"snKXOpdaSKymWSPuVINTcA==\",\n \"operator_id\": \"0Al6aUdLSeCOFquEI6lE0Q\",\n \"rtms_stream_id\": \"341fa0cbd54d4ecd863fbf9e08b8ea46\",\n \"server_urls\": \"wss://zoomsjc144-195-46-181zssgw.sjc.zoom.us:443\"\n },\n \"event_ts\": 1758231148375\n}\nRTMS Started event received\nConnecting to signaling WebSocket for meeting snKXOpdaSKymWSPuVINTcA==\nSignaling WebSocket connection opened for meeting snKXOpdaSKymWSPuVINTcA==\nGenerating signature with parameters:\nmeetingUuid: snKXOpdaSKymWSPuVINTcA==\nstreamId: 341fa0cbd54d4ecd863fbf9e08b8ea46\nSent handshake to signaling server\nSignaling Message: {\n \"media_server\": {\n \"server_urls\": {\n \"all\": \"wss://zoomsjc144-195-46-181zssgw.sjc.zoom.us:443\",\n \"audio\": \"wss://zoomsjc144-195-46-181zssgw.sjc.zoom.us:443\",\n \"chat\": \"wss://zoomsjc144-195-46-181zssgw.sjc.zoom.us:443\",\n \"deskshare\": \"wss://zoomsjc144-195-46-181zssgw.sjc.zoom.us:443\",\n \"transcript\": \"wss://zoomsjc144-195-46-181zssgw.sjc.zoom.us:443\",\n \"video\": \"wss://zoomsjc144-195-46-181zssgw.sjc.zoom.us:443\"\n }\n },\n \"msg_type\": 2,\n \"protocol_version\": 1,\n \"sequence\": 201359864,\n \"status_code\": 0\n}\nConnecting to media WebSocket at wss://zoomsjc144-195-46-181zssgw.sjc.zoom.us:443\nGenerating signature with parameters:\nmeetingUuid: snKXOpdaSKymWSPuVINTcA==\nstreamId: 341fa0cbd54d4ecd863fbf9e08b8ea46\nRaw WebSocket data type: object [object Blob]\n📨 MSG_TYPE 4 received (OTHER)\nMedia JSON Message: {\n \"media_params\": {\n \"transcript\": {\n \"content_type\": 5\n }\n },\n \"msg_type\": 4,\n \"payload_encrypted\": false,\n \"protocol_version\": 1,\n \"status_code\": 0\n}\nMedia handshake successful, sent start streaming request\nSignaling Message: {\n \"msg_type\": 8,\n \"state\": 1,\n \"timestamp\": 1758231149060\n}\nSignaling Message: {\n \"msg_type\": 9,\n \"rtms_session_id\": \"834838FD-C1D8-8F60-0DE5-CD018DC63CBA\",\n \"state\": 2,\n \"timestamp\": 1758231149060\n}\nRTMS Webhook received: {\n \"event\": \"meeting.created\",\n \"payload\": {\n \"account_id\": \"6qOL12OcTwiPar1cV0rCOQ\",\n \"operator\": \"janeazy@gmail.com\",\n \"operator_id\": \"0Al6aUdLSeCOFquEI6lE0Q\",\n \"object\": {\n \"uuid\": \"snKXOpdaSKymWSPuVINTcA==\",\n \"id\": 73559547278,\n \"host_id\": \"0Al6aUdLSeCOFquEI6lE0Q\",\n \"topic\": \"Jan Zheng's Zoom Meeting\",\n \"type\": 1,\n \"duration\": 0,\n \"join_url\": \"https://us04web.zoom.us/j/73559547278?pwd=6OkK5Nqea5xHQEbb5yJZMqhNfBz0XC.1\",\n \"password\": \"755537\",\n \"settings\": {\n \"join_before_host\": true,\n \"jbh_time\": 0,\n \"use_pmi\": false,\n \"alternative_hosts\": \"\",\n \"meeting_invitees\": []\n },\n \"creation_source\": \"other\"\n }\n },\n \"event_ts\": 1758231150212\n}\nRTMS Webhook received: {\n \"payload\": {\n \"account_id\": \"6qOL12OcTwiPar1cV0rCOQ\",\n \"object\": {\n \"uuid\": \"snKXOpdaSKymWSPuVINTcA==\",\n \"participant\": {\n \"public_ip\": \"50.202.219.97\",\n \"user_id\": \"16778240\",\n \"user_name\": \"Jan Zheng\",\n \"participant_user_id\": \"0Al6aUdLSeCOFquEI6lE0Q\",\n \"id\": \"0Al6aUdLSeCOFquEI6lE0Q\",\n \"join_time\": \"2025-09-18T21:32:27Z\",\n \"email\": \"janeazy@gmail.com\",\n \"participant_uuid\": \"5D736BA8-D82C-7587-5AEF-6DF5A70F3333\"\n },\n \"id\": \"73559547278\",\n \"type\": 1,\n \"topic\": \"Jan Zheng's Zoom Meeting\",\n \"host_id\": \"0Al6aUdLSeCOFquEI6lE0Q\",\n \"duration\": 0,\n \"start_time\": \"2025-09-18T21:32:27Z\",\n \"timezone\": \"\"\n }\n },\n \"event_ts\": 1758231150996,\n \"event\": \"meeting.participant_joined\"\n}\nRTMS Webhook received: {\n \"event\": \"meeting.ended\",\n \"payload\": {\n \"account_id\": \"6qOL12OcTwiPar1cV0rCOQ\",\n \"object\": {\n \"duration\": 0,\n \"start_time\": \"2025-09-18T21:31:46Z\",\n \"timezone\": \"\",\n \"end_time\": \"2025-09-18T21:32:19Z\",\n \"topic\": \"Jan Zheng's Zoom Meeting\",\n \"id\": \"72922396626\",\n \"type\": 1,\n \"uuid\": \"MnRr97N5RwmUC4I+yJ1okQ==\",\n \"host_id\": \"0Al6aUdLSeCOFquEI6lE0Q\"\n }\n },\n \"event_ts\": 1758231139921\n}\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 0,\n \"timestamp\": 1758231158938\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231158938 }\nRaw WebSocket data type: object [object Blob]\n📨 MSG_TYPE 12 received (KEEP_ALIVE)\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 0,\n \"timestamp\": 1758231159045\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 1,\n \"timestamp\": 1758231168939\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231168939 }\nRaw WebSocket data type: object [object Blob]\n📨 MSG_TYPE 12 received (KEEP_ALIVE)\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 1,\n \"timestamp\": 1758231169046\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 2,\n \"timestamp\": 1758231178943\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231178943 }\nRaw WebSocket data type: object [object Blob]\n📨 MSG_TYPE 12 received (KEEP_ALIVE)\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 2,\n \"timestamp\": 1758231179038\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 3,\n \"timestamp\": 1758231188939\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231188939 }\nRaw WebSocket data type: object [object Blob]\n📨 MSG_TYPE 12 received (KEEP_ALIVE)\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 3,\n \"timestamp\": 1758231189045\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 4,\n \"timestamp\": 1758231198940\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231198940 }\nRaw WebSocket data type: object [object Blob]\n📨 MSG_TYPE 12 received (KEEP_ALIVE)\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 4,\n \"timestamp\": 1758231199048\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 8,\n \"reason\": 6,\n \"state\": 4,\n \"timestamp\": 1758231207695\n}\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 5,\n \"timestamp\": 1758231208940\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231208940 }\nRaw WebSocket data type: object [object Blob]\n📨 MSG_TYPE 12 received (KEEP_ALIVE)\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 5,\n \"timestamp\": 1758231209046\n}\nResponded to Media KEEP_ALIVE_REQ\nRTMS Webhook received: {\n \"payload\": {\n \"account_id\": \"6qOL12OcTwiPar1cV0rCOQ\",\n \"object\": {\n \"uuid\": \"snKXOpdaSKymWSPuVINTcA==\",\n \"participant\": {\n \"leave_time\": \"2025-09-18T21:33:27Z\",\n \"public_ip\": \"50.202.219.97\",\n \"user_id\": \"16778240\",\n \"user_name\": \"Jan Zheng\",\n \"registrant_id\": \"\",\n \"participant_user_id\": \"0Al6aUdLSeCOFquEI6lE0Q\",\n \"id\": \"0Al6aUdLSeCOFquEI6lE0Q\",\n \"leave_reason\": \"left the meeting. Reason : Host ended the meeting.\",\n \"email\": \"janeazy@gmail.com\",\n \"private_ip\": \"10.253.1.124\",\n \"participant_uuid\": \"5D736BA8-D82C-7587-5AEF-6DF5A70F3333\"\n },\n \"id\": \"73559547278\",\n \"type\": 1,\n \"topic\": \"Jan Zheng's Zoom Meeting\",\n \"host_id\": \"0Al6aUdLSeCOFquEI6lE0Q\",\n \"duration\": 0,\n \"start_time\": \"2025-09-18T21:32:27Z\",\n \"timezone\": \"\"\n }\n },\n \"event_ts\": 1758231209868,\n \"event\": \"meeting.participant_left\"\n}\nSignaling socket closed\nMedia socket closed\nRTMS Webhook received: {\n \"event\": \"meeting.rtms_stopped\",\n \"payload\": {\n \"meeting_uuid\": \"snKXOpdaSKymWSPuVINTcA==\",\n \"rtms_stream_id\": \"341fa0cbd54d4ecd863fbf9e08b8ea46\",\n \"stop_reason\": 6\n },\n \"event_ts\": 1758231211693\n}\nRTMS Stopped event received\nRTMS Webhook received: {\n \"event\": \"meeting.started\",\n \"payload\": {\n \"account_id\": \"6qOL12OcTwiPar1cV0rCOQ\",\n \"object\": {\n \"duration\": 0,\n \"start_time\": \"2025-09-18T21:33:35Z\",\n \"timezone\": \"\",\n \"topic\": \"Jan Zheng's Zoom Meeting\",\n \"id\": \"73698935901\",\n \"type\": 1,\n \"uuid\": \"XgkbyULRQUevlWTxk0SE4w==\",\n \"host_id\": \"0Al6aUdLSeCOFquEI6lE0Q\"\n }\n },\n \"event_ts\": 1758231216007\n}\nRTMS Webhook received: {\n \"event\": \"meeting.rtms_started\",\n \"payload\": {\n \"meeting_uuid\": \"XgkbyULRQUevlWTxk0SE4w==\",\n \"operator_id\": \"0Al6aUdLSeCOFquEI6lE0Q\",\n \"rtms_stream_id\": \"cac593efb5ff4d689870a12dd030dd1c\",\n \"server_urls\": \"wss://zoomsjc144-195-49-104zssgw.sjc.zoom.us:443\"\n },\n \"event_ts\": 1758231216323\n}\nRTMS Started event received\nConnecting to signaling WebSocket for meeting XgkbyULRQUevlWTxk0SE4w==\nSignaling WebSocket connection opened for meeting XgkbyULRQUevlWTxk0SE4w==\nGenerating signature with parameters:\nmeetingUuid: XgkbyULRQUevlWTxk0SE4w==\nstreamId: cac593efb5ff4d689870a12dd030dd1c\nSent handshake to signaling server\nSignaling Message: {\n \"media_server\": {\n \"server_urls\": {\n \"all\": \"wss://zoomsjc144-195-49-104zssgw.sjc.zoom.us:443\",\n \"audio\": \"wss://zoomsjc144-195-49-104zssgw.sjc.zoom.us:443\",\n \"chat\": \"wss://zoomsjc144-195-49-104zssgw.sjc.zoom.us:443\",\n \"deskshare\": \"wss://zoomsjc144-195-49-104zssgw.sjc.zoom.us:443\",\n \"transcript\": \"wss://zoomsjc144-195-49-104zssgw.sjc.zoom.us:443\",\n \"video\": \"wss://zoomsjc144-195-49-104zssgw.sjc.zoom.us:443\"\n }\n },\n \"msg_type\": 2,\n \"protocol_version\": 1,\n \"sequence\": 487741770,\n \"status_code\": 0\n}\nConnecting to media WebSocket at wss://zoomsjc144-195-49-104zssgw.sjc.zoom.us:443\nGenerating signature with parameters:\nmeetingUuid: XgkbyULRQUevlWTxk0SE4w==\nstreamId: cac593efb5ff4d689870a12dd030dd1c\nRaw WebSocket data type: object [object Blob]\n📨 MSG_TYPE 4 received (OTHER)\nMedia JSON Message: {\n \"media_params\": {\n \"transcript\": {\n \"content_type\": 5\n }\n },\n \"msg_type\": 4,\n \"payload_encrypted\": false,\n \"protocol_version\": 1,\n \"status_code\": 0\n}\nMedia handshake successful, sent start streaming request\nSignaling Message: {\n \"msg_type\": 8,\n \"state\": 1,\n \"timestamp\": 1758231216945\n}\nSignaling Message: {\n \"msg_type\": 9,\n \"rtms_session_id\": \"FC485C25-B37B-BADA-D470-BC1A20AAEF9F\",\n \"state\": 2,\n \"timestamp\": 1758231216945\n}\nRTMS Webhook received: {\n \"event\": \"meeting.created\",\n \"payload\": {\n \"account_id\": \"6qOL12OcTwiPar1cV0rCOQ\",\n \"operator\": \"janeazy@gmail.com\",\n \"operator_id\": \"0Al6aUdLSeCOFquEI6lE0Q\",\n \"object\": {\n \"uuid\": \"XgkbyULRQUevlWTxk0SE4w==\",\n \"id\": 73698935901,\n \"host_id\": \"0Al6aUdLSeCOFquEI6lE0Q\",\n \"topic\": \"Jan Zheng's Zoom Meeting\",\n \"type\": 1,\n \"duration\": 0,\n \"join_url\": \"https://us04web.zoom.us/j/73698935901?pwd=jFMiduHvGAsqeelqfoRPOTVVyWk7m5.1\",\n \"password\": \"117449\",\n \"settings\": {\n \"join_before_host\": true,\n \"jbh_time\": 0,\n \"use_pmi\": false,\n \"alternative_hosts\": \"\",\n \"meeting_invitees\": []\n },\n \"creation_source\": \"other\"\n }\n },\n \"event_ts\": 1758231218271\n}\nRTMS Webhook received: {\n \"payload\": {\n \"account_id\": \"6qOL12OcTwiPar1cV0rCOQ\",\n \"object\": {\n \"uuid\": \"XgkbyULRQUevlWTxk0SE4w==\",\n \"participant\": {\n \"public_ip\": \"50.202.219.97\",\n \"user_id\": \"16778240\",\n \"user_name\": \"Jan Zheng\",\n \"participant_user_id\": \"0Al6aUdLSeCOFquEI6lE0Q\",\n \"id\": \"0Al6aUdLSeCOFquEI6lE0Q\",\n \"join_time\": \"2025-09-18T21:33:35Z\",\n \"email\": \"janeazy@gmail.com\",\n \"participant_uuid\": \"47EB2455-599D-87B5-1E9B-0D0207E2A843\"\n },\n \"id\": \"73698935901\",\n \"type\": 1,\n \"topic\": \"Jan Zheng's Zoom Meeting\",\n \"host_id\": \"0Al6aUdLSeCOFquEI6lE0Q\",\n \"duration\": 0,\n \"start_time\": \"2025-09-18T21:33:35Z\",\n \"timezone\": \"\"\n }\n },\n \"event_ts\": 1758231217985,\n \"event\": \"meeting.participant_joined\"\n}\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 0,\n \"timestamp\": 1758231226809\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231226809 }\nRaw WebSocket data type: object [object Blob]\n📨 MSG_TYPE 12 received (KEEP_ALIVE)\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 0,\n \"timestamp\": 1758231226925\n}\nResponded to Media KEEP_ALIVE_REQ\nRTMS Webhook received: {\n \"event\": \"meeting.ended\",\n \"payload\": {\n \"account_id\": \"6qOL12OcTwiPar1cV0rCOQ\",\n \"object\": {\n \"duration\": 0,\n \"start_time\": \"2025-09-18T21:32:27Z\",\n \"timezone\": \"\",\n \"end_time\": \"2025-09-18T21:33:27Z\",\n \"topic\": \"Jan Zheng's Zoom Meeting\",\n \"id\": \"73559547278\",\n \"type\": 1,\n \"uuid\": \"snKXOpdaSKymWSPuVINTcA==\",\n \"host_id\": \"0Al6aUdLSeCOFquEI6lE0Q\"\n }\n },\n \"event_ts\": 1758231208130\n}\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 1,\n \"timestamp\": 1758231236814\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231236814 }\nRaw WebSocket data type: object [object Blob]\n📨 MSG_TYPE 12 received (KEEP_ALIVE)\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 1,\n \"timestamp\": 1758231236930\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 2,\n \"timestamp\": 1758231246808\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231246808 }\nRaw WebSocket data type: object [object Blob]\n📨 MSG_TYPE 12 received (KEEP_ALIVE)\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 2,\n \"timestamp\": 1758231246924\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 3,\n \"timestamp\": 1758231256809\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231256809 }\nRaw WebSocket data type: object [object Blob]\n📨 MSG_TYPE 12 received (KEEP_ALIVE)\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 3,\n \"timestamp\": 1758231256925\n}\nResponded to Media KEEP_ALIVE_REQ\n",[],[297],{"_105":305,"_96":306,"_156":307,"_158":-5,"_159":142,"_160":308,"_162":119,"_107":309,"_101":184,"_164":193,"_166":310,"_167":22,"_168":-5,"_169":311,"_99":312},"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}",[],[306],{"_105":314,"_96":315,"_156":316,"_158":-5,"_159":142,"_160":317,"_162":119,"_107":318,"_101":32,"_164":193,"_166":319,"_167":22,"_168":-5,"_169":320,"_99":321},"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",[],[315],{"_105":323,"_96":324,"_156":117,"_158":-5,"_159":142,"_160":325,"_162":119,"_107":326,"_101":327,"_164":328,"_166":329,"_167":22,"_168":97,"_169":330,"_99":331},"47aecaa0-97e2-11f0-a41f-0224a6c84d84","main.js",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",[],[324],{"_105":333,"_96":334,"_156":335,"_158":-5,"_159":142,"_160":336,"_162":22,"_107":337,"_101":32,"_164":245,"_166":338,"_167":22,"_168":-5,"_169":339,"_99":340},"7977953e-94e1-11f0-81a7-0224a6c84d84","main_backup_2.js","79779638-94e1-11f0-81a7-0224a6c84d84",55,["D",1758235657486],"import { Hono } from \"https://deno.land/x/hono@v3.11.7/mod.ts\";\nimport { get_encoding } from \"npm:tiktoken\";\nimport \"jsr:@std/dotenv/load\";\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// Optional: override frontend WebSocket URL (e.g., point to Node server)\nconst FRONTEND_WS_URL = Deno.env.get(\"FRONTEND_WS_URL\") || \"\";\n\n\nconst app = new Hono();\n\n// Security headers middleware for OWASP compliance\nfunction addSecurityHeaders(c, next) {\n c.header('Strict-Transport-Security', 'max-age=31536000; includeSubDomains');\n c.header('X-Content-Type-Options', 'nosniff');\n c.header('Content-Security-Policy',\n \"default-src 'self'; \" +\n \"script-src 'self' 'unsafe-inline' https://cdn.tailwindcss.com https://esm.town https://code.iconify.design; \" +\n \"style-src 'self' 'unsafe-inline' https://cdn.tailwindcss.com https://fonts.googleapis.com; \" +\n \"img-src 'self' data: https: blob:; \" +\n \"font-src 'self' https://fonts.gstatic.com; \" +\n \"connect-src 'self' wss: ws: https://zoom.us; \" +\n \"frame-src 'self' https://zoom.us; \" +\n \"object-src 'none'; \" +\n \"base-uri 'self'; \" +\n \"form-action 'self' https://zoom.us\"\n );\n c.header('Referrer-Policy', 'strict-origin-when-cross-origin');\n c.header('X-Frame-Options', 'SAMEORIGIN');\n c.header('X-XSS-Protection', '1; mode=block');\n return next();\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\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 console.log('Generating signature with parameters:');\n console.log('meetingUuid:', meetingUuid);\n console.log('streamId:', streamId);\n\n const message = `${ZOOM_CLIENT_ID},${meetingUuid},${streamId}`;\n return await createHmacSha256(ZOOM_CLIENT_SECRET, message);\n}\n\n\n// API endpoint to get RTMS status\napp.get(\"/rtms/status\", (c) => {\n return c.json({\n configured: !!(ZOOM_CLIENT_ID && ZOOM_CLIENT_SECRET && ZOOM_SECRET_TOKEN),\n has_client_id: !!ZOOM_CLIENT_ID,\n has_client_secret: !!ZOOM_CLIENT_SECRET,\n has_secret_token: !!ZOOM_SECRET_TOKEN,\n webhook_path: WEBHOOK_PATH,\n active_connections: activeConnections.size,\n server_time: new Date().toISOString(),\n troubleshooting: {\n check_meeting_host: \"You must be the meeting HOST for RTMS to work\",\n check_cloud_recording: \"Cloud recording must be ENABLED\",\n check_rtms_permissions: \"RTMS permissions must be enabled in Zoom App\",\n check_zoom_plan: \"RTMS requires a paid Zoom plan\",\n check_transcript_settings: \"In-meeting transcripts must be enabled\"\n }\n });\n});\n\n// Test endpoint to simulate transcript data\napp.get(\"/rtms/test\", async (c) => {\n try {\n console.log('🧪 Testing transcript broadcast...');\n\n const testMessage = \"Hello everyone! I'm curious about this new feature. It looks really creative and I appreciate the analytical approach.\";\n const testTranscript = {\n content: testMessage,\n user: 'Test User',\n timestamp: Date.now()\n };\n recentTranscripts.push(testTranscript);\n\n broadcastToAnalysisClients({\n type: 'transcript',\n content: testMessage,\n user: 'Test User',\n timestamp: Date.now()\n });\n\n return c.json({\n success: true,\n message: \"Test transcript broadcasted\",\n clientCount: analysisClients.size\n });\n } catch (error) {\n console.error('❌ Test error:', error);\n return c.json({ error: error.message }, 500);\n }\n});\n\n// RTMS diagnostics endpoint\napp.get(\"/rtms/diagnostics\", (c) => {\n const diagnostics = {\n timestamp: new Date().toISOString(),\n server_config: {\n has_client_id: !!ZOOM_CLIENT_ID,\n has_client_secret: !!ZOOM_CLIENT_SECRET,\n has_secret_token: !!ZOOM_SECRET_TOKEN,\n webhook_path: WEBHOOK_PATH\n },\n connections: {\n active_count: activeConnections.size,\n details: Object.keys(activeConnections).map(meetingUuid => ({\n meeting_uuid: meetingUuid,\n has_signaling: !!activeConnections[meetingUuid].signaling,\n has_media: !!activeConnections[meetingUuid].media\n }))\n },\n recent_activity: {\n transcript_count: recentTranscripts.length,\n last_transcript: recentTranscripts.length > 0 ? {\n user: recentTranscripts[recentTranscripts.length - 1].user,\n timestamp: new Date(recentTranscripts[recentTranscripts.length - 1].timestamp).toISOString(),\n preview: recentTranscripts[recentTranscripts.length - 1].content.substring(0, 50) + \"...\"\n } : null\n },\n common_issues: [\n \"Not the meeting host - RTMS requires host privileges\",\n \"Cloud recording not enabled - RTMS needs cloud recording\",\n \"RTMS permissions not granted in Zoom App settings\",\n \"In-meeting transcripts not enabled in meeting settings\",\n \"Using free Zoom account - RTMS requires paid plan\"\n ]\n };\n\n return c.json(diagnostics);\n});\n\n// RTMS Webhook endpoint\n// ✅ Improved webhook handling following Express.js best practices:\n// - Respond immediately with 200 to acknowledge receipt\n// - Process events asynchronously to prevent timeouts\n// - Validate webhook format and required fields\n// - Handle URL validation synchronously for immediate response\napp.post(WEBHOOK_PATH, async (c) => {\n // Respond immediately with 200 to acknowledge receipt (like Express)\n console.log('🔗 RTMS Webhook received at:', new Date().toISOString());\n\n try {\n const body = await c.req.json();\n console.log('RTMS Webhook event:', body.event);\n\n const { event, payload } = body;\n\n // Basic webhook validation - ensure required fields exist\n if (!event || !payload) {\n console.log('❌ Invalid webhook format - missing event or payload');\n return c.json({ error: 'Invalid webhook format' }, 400);\n }\n\n // Handle URL validation event - respond immediately\n if (event === 'endpoint.url_validation' && payload?.plainToken) {\n if (!ZOOM_SECRET_TOKEN) {\n console.error('ZOOM_SECRET_TOKEN not configured');\n return c.json({ error: 'Secret token not configured' }, 500);\n }\n\n const hash = await createHmacSha256(ZOOM_SECRET_TOKEN, payload.plainToken);\n console.log('Responding to URL validation challenge');\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 console.log('🎯 RTMS Started event received!');\n console.log('Meeting UUID:', payload.meeting_uuid);\n console.log('Stream ID:', payload.rtms_stream_id);\n console.log('Server URLs:', payload.server_urls);\n\n const { meeting_uuid, rtms_stream_id, server_urls } = payload;\n const signalingUrl = resolveWsUrl(server_urls);\n if (!signalingUrl) {\n console.error('❌ Could not resolve signaling WebSocket URL from server_urls');\n return;\n }\n \n // Process asynchronously but don't block response\n setTimeout(() => {\n connectToSignalingWebSocket(meeting_uuid, rtms_stream_id, signalingUrl);\n }, 0);\n }\n\n // Handle RTMS stopped event\n else if (event === 'meeting.rtms_stopped') {\n console.log('🛑 RTMS Stopped event received');\n console.log('Meeting UUID:', payload.meeting_uuid);\n\n const { meeting_uuid } = payload;\n\n // Close all active WebSocket connections for the given meeting UUID\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 // For all other events, respond immediately\n return c.json({ status: 'Event received' });\n } catch (error) {\n console.error('❌ Webhook error:', error);\n console.error('Error details:', error.message);\n return c.json({ error: error.message }, 500);\n }\n});\n\n// WebSocket connection functions for RTMS\nasync function connectToSignalingWebSocket(meetingUuid, streamId, serverUrl) {\n console.log(`Connecting to signaling WebSocket for meeting ${meetingUuid}`);\n\n try {\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 for meeting ${meetingUuid}`);\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('Sent handshake to signaling server');\n };\n\n ws.onmessage = async (event) => {\n try {\n const msg = await parseWsJson(event.data);\n console.log('Signaling Message:', JSON.stringify(msg, null, 2));\n\n // Handle successful handshake response\n if (msg.msg_type === 2 && msg.status_code === 0) { // SIGNALING_HAND_SHAKE_RESP\n const mediaUrl = msg.media_server?.server_urls?.all;\n if (mediaUrl) {\n // Connect to the media WebSocket server using the media URL\n connectToMediaWebSocket(mediaUrl, meetingUuid, streamId, ws);\n }\n }\n\n // Respond to keep-alive requests\n if (msg.msg_type === 12) { // KEEP_ALIVE_REQ\n const keepAliveResponse = {\n msg_type: 13, // KEEP_ALIVE_RESP\n timestamp: msg.timestamp,\n };\n console.log('Responding to Signaling KEEP_ALIVE_REQ:', keepAliveResponse);\n ws.send(JSON.stringify(keepAliveResponse));\n }\n } catch (error) {\n console.error('❌ Error processing signaling message:', error.message);\n // Get summary without blocking the main flow\n summarizeWsData(event.data).then(summary => {\n console.error('Raw data summary:', summary);\n }).catch(() => {\n console.error('Could not summarize raw data');\n });\n // Don't rethrow - we want to keep the WebSocket alive for other messages\n }\n };\n\n ws.onerror = (error) => {\n console.error('Signaling socket error:', error);\n };\n\n ws.onclose = () => {\n console.log('Signaling socket closed');\n if (activeConnections.has(meetingUuid)) {\n delete activeConnections.get(meetingUuid).signaling;\n }\n };\n\n } catch (error) {\n console.error('Failed to connect to signaling WebSocket:', error);\n }\n}\n\nasync function connectToMediaWebSocket(mediaUrl, meetingUuid, streamId, signalingSocket) {\n console.log(`Connecting to media WebSocket at ${mediaUrl}`);\n\n try {\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 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: 16, // TRANSCRIPT only (trying same value as audio but with transcript params)\n payload_encryption: false,\n media_params: {\n transcript: {\n content_type: 6,\n data_opt: 1\n },\n chat: {\n content_type: 5,\n data_opt: 1\n }\n }\n };\n console.log('📤 Sending media handshake (transcript + chat):', JSON.stringify(handshake, null, 2));\n mediaWs.send(JSON.stringify(handshake));\n };\n\n mediaWs.onmessage = async (event) => {\n try {\n console.log('📦 Media WebSocket message received, parsing...');\n const msg = await parseWsJson(event.data);\n\n // Only log non-keep-alive messages (muted keep-alive spam)\n if (msg.msg_type !== 12 && msg.msg_type !== 13) {\n console.log('📨 Message type:', msg.msg_type, 'Status:', msg.status_code);\n }\n\n // Log any unrecognized message types\n if (msg.msg_type !== 4 && msg.msg_type !== 12 && msg.msg_type !== 13 && msg.msg_type !== 14 && msg.msg_type !== 15 && msg.msg_type !== 16 && msg.msg_type !== 17 && msg.msg_type !== 18) {\n console.log('⚠️ Unrecognized message type:', msg.msg_type, 'Full message:', JSON.stringify(msg, null, 2));\n }\n\n // Debug: Log transcript messages specifically\n if (msg.msg_type === 17) {\n console.log('📨 TRANSCRIPT MESSAGE RECEIVED!');\n console.log('Raw transcript message:', JSON.stringify(msg, null, 2));\n }\n // console.log('Media JSON Message:', JSON.stringify(msg, null, 2));\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!');\n console.log('📋 Media handshake response:', JSON.stringify(msg, null, 2));\n signalingSocket.send(\n JSON.stringify({\n msg_type: 7, // CLIENT_READY_ACK\n rtms_stream_id: streamId,\n })\n );\n console.log('📤 Sent CLIENT_READY_ACK - transcript + chat streaming should start now!');\n } else if (msg.msg_type === 4 && msg.status_code !== 0) {\n console.log('❌ Media handshake failed! Status code:', msg.status_code);\n console.log('❌ Full handshake response:', JSON.stringify(msg, null, 2));\n }\n\n // Respond to keep-alive requests (muted logging)\n if (msg.msg_type === 12) { // KEEP_ALIVE_REQ\n mediaWs.send(\n JSON.stringify({\n msg_type: 13, // KEEP_ALIVE_RESP\n timestamp: msg.timestamp,\n })\n );\n // console.log('Responded to Media KEEP_ALIVE_REQ'); // Muted keep-alive logs\n }\n\n // Audio data disabled - user only wants transcripts\n // if (msg.msg_type === 14 && msg.content && msg.content.data) {\n // let { user_id, user_name, data: audioData } = msg.content;\n // // Handle audio data if needed\n // console.log('Audio data received from:', user_name);\n // }\n\n // Video and deskshare data disabled - user only wants transcripts\n // if (msg.msg_type === 15 && msg.content && msg.content.data) {\n // let { user_id, user_name, data: videoData, timestamp } = msg.content;\n // // Handle video data if needed\n // console.log('Video data received from:', user_name);\n // }\n\n // if (msg.msg_type === 16 && msg.content && msg.content.data) {\n // let { user_id, user_name, data: shareData, timestamp } = msg.content;\n // // Handle deskshare data if needed\n // console.log('Deskshare data received from:', user_name);\n // }\n\n // Handle transcript data\n if (msg.msg_type === 17 && msg.content && msg.content.data) {\n console.log('🎯 TRANSCRIPT DATA FOUND!');\n console.log('Processing transcript...');\n let { user_id, user_name, data, timestamp } = msg.content;\n console.log('👤 SPEAKER:', user_name || 'Unknown Speaker');\n console.log('💬 TRANSCRIPT:', data);\n console.log('⏰ TIME:', new Date(timestamp / 1000).toLocaleTimeString());\n console.log('━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━');\n\n // Store transcript for polling (NO FILE WRITING)\n const transcriptEntry = {\n content: data,\n user: user_name,\n timestamp: Date.now()\n };\n recentTranscripts.push(transcriptEntry);\n console.log('✅ Transcript stored. Total transcripts:', recentTranscripts.length);\n\n if (recentTranscripts.length > 100) {\n recentTranscripts.shift();\n }\n\n // Broadcast to analysis clients\n console.log('📡 Broadcasting transcript to clients...');\n broadcastToAnalysisClients({\n type: 'transcript',\n content: data,\n user: user_name,\n timestamp: Date.now()\n });\n console.log('✅ Transcript broadcast complete!');\n }\n\n // Handle chat data\n if (msg.msg_type === 18 && msg.content && msg.content.data) {\n console.log('💬 CHAT MESSAGE RECEIVED!');\n console.log('👤 CHATTER:', msg.content.user_name || 'Unknown User');\n console.log('💬 MESSAGE:', msg.content.data);\n console.log('━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━');\n\n // Broadcast chat to analysis clients\n broadcastToAnalysisClients({\n type: 'chat',\n content: msg.content.data,\n user: msg.content.user_name,\n timestamp: Date.now()\n });\n }\n\n } catch (error) {\n console.error('❌ Error processing media message:', error.message);\n // Get summary without blocking the main flow\n summarizeWsData(event.data).then(summary => {\n console.error('Raw data summary:', summary);\n }).catch(() => {\n console.error('Could not summarize raw data');\n });\n // Don't rethrow - we want to keep the WebSocket alive for other messages\n }\n };\n\n mediaWs.onerror = (error) => {\n console.error('Media socket error:', error);\n };\n\n mediaWs.onclose = () => {\n console.log('Media socket closed');\n if (activeConnections.has(meetingUuid)) {\n delete activeConnections.get(meetingUuid).media;\n }\n };\n\n } catch (error) {\n console.error('Failed to connect to media WebSocket:', error);\n }\n}\n\n// Transcript writing functions (Deno-compatible version)\nlet srtIndex = 1;\nlet startTimestamp = null; // Will hold first transcript timestamp\n\n// Set session start (optional external call)\nexport function setTranscriptStartTimestamp(ts) {\n startTimestamp = ts;\n console.log(`⏱️ Transcript start time set to: ${startTimestamp}`);\n}\n\nfunction formatVttTimestamp(ms) {\n const date = new Date(ms);\n if (isNaN(date.getTime())) return '00:00:00.000';\n\n const h = String(date.getUTCHours()).padStart(2, '0');\n const m = String(date.getUTCMinutes()).padStart(2, '0');\n const s = String(date.getUTCSeconds()).padStart(2, '0');\n const msPart = String(date.getUTCMilliseconds()).padStart(3, '0');\n return `${h}:${m}:${s}.${msPart}`;\n}\n\nfunction formatSrtTimestamp(ms) {\n const date = new Date(ms);\n if (isNaN(date.getTime())) return '00:00:00,000';\n\n const h = String(date.getUTCHours()).padStart(2, '0');\n const m = String(date.getUTCMinutes()).padStart(2, '0');\n const s = String(date.getUTCSeconds()).padStart(2, '0');\n const msPart = String(date.getUTCMilliseconds()).padStart(3, '0');\n return `${h}:${m}:${s},${msPart}`;\n}\n\nasync function writeTranscriptToVtt(user_name, timestamp, data, meetingUuid) {\n const safeMeetingUuid = sanitizeFileName(meetingUuid);\n const meetingFolder = `./recordings/${safeMeetingUuid}`;\n\n // Ensure the meeting folder exists\n try {\n await Deno.mkdir(meetingFolder, { recursive: true });\n } catch (error) {\n if (!(error instanceof Deno.errors.AlreadyExists)) {\n console.error('Error creating meeting folder:', error);\n return;\n }\n }\n\n if (!startTimestamp) {\n startTimestamp = timestamp; // fallback if not manually set\n console.log(`⚠️ startTimestamp not set — defaulting to first transcript line: ${startTimestamp}`);\n }\n\n // Build output file paths inside the meeting folder\n const vttFilePath = `${meetingFolder}/transcript.vtt`;\n const srtFilePath = `${meetingFolder}/transcript.srt`;\n const txtFilePath = `${meetingFolder}/transcript.txt`;\n\n const relative = timestamp - startTimestamp;\n const start = formatVttTimestamp(relative);\n const end = formatVttTimestamp(relative + 2000);\n const vttLine = `${start} --> ${end}\\n${user_name}: ${data}\\n\\n`;\n\n // Write VTT file\n try {\n const vttExists = await Deno.stat(vttFilePath).catch(() => null);\n if (!vttExists) {\n await Deno.writeTextFile(vttFilePath, 'WEBVTT\\n\\n');\n }\n await Deno.writeTextFile(vttFilePath, vttLine, { append: true });\n // console.log(`📝 VTT saved to ${vttFilePath}`);\n } catch (error) {\n console.error('Error writing VTT file:', error);\n }\n\n // Write SRT file\n try {\n const srtStart = formatSrtTimestamp(relative);\n const srtEnd = formatSrtTimestamp(relative + 2000);\n const srtLine = `${srtIndex++}\\n${srtStart} --> ${srtEnd}\\n${user_name}: ${data}\\n\\n`;\n await Deno.writeTextFile(srtFilePath, srtLine, { append: true });\n // console.log(`🎞️ SRT saved to ${srtFilePath}`);\n } catch (error) {\n console.error('Error writing SRT file:', error);\n }\n\n // Write TXT file\n try {\n const readableTime = new Date(timestamp).toISOString();\n const txtLine = `[${readableTime}] ${user_name}: ${data}\\n`;\n await Deno.writeTextFile(txtFilePath, txtLine, { append: true });\n // console.log(`📄 TXT saved to ${txtFilePath}`);\n } catch (error) {\n console.error('Error writing TXT file:', error);\n }\n}\n\nfunction sanitizeFileName(name) {\n return name.replace(/[<>:\"\\/\\\\|?*=\\s]/g, '_');\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 // Some payloads nest under media_server.server_urls; callers pass only server_urls, so bail\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 console.log('[parseWsJson]', data);\n if (typeof data === 'string') {\n // Skip if it looks like a stringified object (common error case)\n if (data.startsWith('[object ') && data.endsWith(']')) {\n throw new Error('Received stringified object instead of actual data: ' + data);\n }\n return JSON.parse(data);\n }\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 try {\n // Add timeout to prevent hanging on corrupted blobs\n const text = await Promise.race([\n data.text(),\n new Promise((_, reject) =>\n setTimeout(() => reject(new Error('Blob text() timeout')), 5000)\n )\n ]);\n if (!text || text.trim().length === 0) {\n throw new Error('Blob contains no text data');\n }\n return JSON.parse(text);\n } catch (blobError) {\n throw new Error('Failed to read Blob data: ' + blobError.message);\n }\n }\n throw new Error('Unsupported WebSocket data type: ' + Object.prototype.toString.call(data));\n } catch (err) {\n // Enhanced error reporting\n const errorMsg = 'WebSocket parse error: ' + err.message + ' | Data type: ' + typeof data + ' | Data preview: ' + String(data).slice(0, 100);\n throw new Error(errorMsg);\n }\n}\n\nasync function summarizeWsData(data) {\n try {\n if (typeof data === 'string') {\n return {\n kind: 'string',\n length: data.length,\n preview: data.slice(0, 512)\n };\n }\n if (data instanceof Uint8Array) {\n const text = new TextDecoder().decode(data);\n return {\n kind: 'Uint8Array',\n length: data.byteLength,\n preview: text.slice(0, 512)\n };\n }\n if (data instanceof ArrayBuffer) {\n const view = new Uint8Array(data);\n const text = new TextDecoder().decode(view);\n return {\n kind: 'ArrayBuffer',\n length: view.byteLength,\n preview: text.slice(0, 512)\n };\n }\n if (typeof Blob !== 'undefined' && data instanceof Blob) {\n const size = data.size;\n const text = await data.text();\n return {\n kind: 'Blob',\n length: size,\n preview: text.slice(0, 512)\n };\n }\n return { kind: typeof data, preview: String(data).slice(0, 512) };\n } catch (e) {\n return { kind: 'unknown', error: String(e?.message || e) };\n }\n}\n\nlet html = `\n\n\n\n \n \n Zoom RTMS - Live Transcripts\n \n\n\n

🎙️ Zoom RTMS Live Transcripts

\n \n

\n Status: Connecting...
\n Webhook URL:
\n Active Meetings: 0 | \n Connected Clients: 0\n

\n\n

\n \n \n \n

\n\n

\n Waiting for live transcripts...\n

\n\n\n

\nNo transcripts yet. Start a Zoom meeting with RTMS enabled to see live transcripts here.\n\nTo enable RTMS:\n1. Set up your Zoom app with RTMS permissions\n2. Configure the webhook URL above in your Zoom app\n3. Start a meeting and enable RTMS\n4. Transcripts will appear here in real-time!\n

\n\n \n\n\n`;\n\n// Simple favicon handler to prevent 404 errors\napp.get(\"/favicon.ico\", (c) => {\n return new Response(null, { status: 204 }); // No content response\n});\n\n// Inject optional WS override into the HTML (so we can point to an external WS server if needed)\napp.get(\"/\", (c) => {\n const injected = html.replace(\"__WS_ENV_OVERRIDE__\", FRONTEND_WS_URL);\n return c.html(injected);\n});\n\n\n// API endpoint for polling latest transcripts\napp.get(\"/api/latest-transcripts\", (c) => {\n return c.json({\n transcripts: recentTranscripts,\n timestamp: Date.now()\n });\n});\n\n\n// RTMS Analysis Configuration\n\n\n// Store connected WebSocket clients for broadcasting\nconst analysisClients = new Set();\n\n// Store recent transcripts for polling\nconst recentTranscripts = [];\n\n\n// Broadcast updates to all connected clients\nfunction broadcastToAnalysisClients(message) {\n const json = typeof message === 'string' ? message : JSON.stringify(message);\n for (const client of analysisClients) {\n if (client.readyState === WebSocket.OPEN) {\n try {\n client.send(json);\n } catch (error) {\n console.error('❌ Broadcast error:', error);\n analysisClients.delete(client);\n }\n }\n }\n}\n\n// Broadcast client count updates to all clients\nfunction broadcastClientCount() {\n const clientCount = analysisClients.size;\n broadcastToAnalysisClients({\n type: 'client_count_update',\n clientCount: clientCount\n });\n console.log(`📊 Broadcasting client count: ${clientCount}`);\n}\n\n// Register frontend WebSocket client (shared between Hono route and top-level handler)\nfunction registerFrontendSocket(socket) {\n analysisClients.add(socket);\n console.log('🌐 Frontend client connected. Total clients:', analysisClients.size);\n\n socket.onopen = () => {\n try {\n socket.send(JSON.stringify({\n type: 'connected',\n message: 'Connected to RTMS server',\n clientCount: analysisClients.size\n }));\n } catch {}\n };\n\n socket.onmessage = (event) => {\n try { JSON.parse(event.data); } catch {}\n };\n\n socket.onclose = () => {\n analysisClients.delete(socket);\n broadcastClientCount();\n };\n\n socket.onerror = () => {\n analysisClients.delete(socket);\n };\n}\n\n// WebSocket handler for frontend connections (fixed version)\napp.get('/ws-analysis', async (c) => {\n console.log('🔌 WebSocket upgrade request received at /ws-analysis');\n\n try {\n const { socket, response } = Deno.upgradeWebSocket(c.req.raw);\n console.log('✅ WebSocket upgrade successful');\n\n registerFrontendSocket(socket);\n\n return response;\n } catch (error) {\n console.error('❌ WebSocket upgrade failed:', error);\n return c.json({ error: 'WebSocket upgrade failed', details: error.message }, 500);\n }\n});\n\n// Alias WebSocket endpoint to match other examples\napp.get('/ws', async (c) => {\n console.log('🔌 WebSocket upgrade request received at /ws');\n\n try {\n const { socket, response } = Deno.upgradeWebSocket(c.req.raw);\n console.log('✅ WebSocket upgrade successful (/ws)');\n registerFrontendSocket(socket);\n\n return response;\n } catch (error) {\n console.error('❌ WebSocket upgrade failed (/ws):', error);\n return c.json({ error: 'WebSocket upgrade failed', details: error.message }, 500);\n }\n});\n\n// Redirect /analysis to main page since everything is integrated now\napp.get('/analysis', (c) => {\n return c.redirect('/');\n});\n\n// Export app.fetch for Val Town, otherwise export app — this is only for hono apps\nexport default (typeof Deno !== \"undefined\" && Deno.env.get(\"valtown\")) ? app.fetch : app;\n",[],[334],{"_105":342,"_96":343,"_156":344,"_158":-5,"_159":142,"_160":345,"_162":22,"_107":346,"_101":32,"_164":193,"_166":347,"_167":22,"_168":-5,"_169":348,"_99":349},"7935f818-94e1-11f0-96d2-0224a6c84d84","node-output.json","7935f8c2-94e1-11f0-96d2-0224a6c84d84",51,["D",1758235657053]," \"timestamp\": 1758231660095\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 22,\n \"timestamp\": 1758231670058\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231670058 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 22,\n \"timestamp\": 1758231670100\n}\nResponded to Media KEEP_ALIVE_REQ\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"Unfortunately, Vercel what it is. They just approved, and then it actually works. That's true, I'm surprised that works, but yeah, Vercel seems like the best way to do most things. They also have Python, so…\",\n \"language\": 9,\n \"timestamp\": 1758231672411770,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"But here, I can show you the cloud front then.\",\n \"language\": 9,\n \"timestamp\": 1758231674074440,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 23,\n \"timestamp\": 1758231680053\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231680053 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 23,\n \"timestamp\": 1758231680096\n}\nResponded to Media KEEP_ALIVE_REQ\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"Yeah, poor repo. Should be easy.\",\n \"language\": 9,\n \"timestamp\": 1758231680347092,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"Build with Frog is not here.\",\n \"language\": 9,\n \"timestamp\": 1758231682593501,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"It should be here. GitHub connection.\",\n \"language\": 9,\n \"timestamp\": 1758231686168857,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 24,\n \"timestamp\": 1758231690061\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231690061 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 24,\n \"timestamp\": 1758231690093\n}\nResponded to Media KEEP_ALIVE_REQ\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"Yeah, this one is fake, Victor.\",\n \"language\": 9,\n \"timestamp\": 1758231694408202,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 25,\n \"timestamp\": 1758231700059\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231700059 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 25,\n \"timestamp\": 1758231700091\n}\nResponded to Media KEEP_ALIVE_REQ\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"We just created a clone on Brock without Terraform, which is kind of sus.\",\n \"language\": 9,\n \"timestamp\": 1758231701809398,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"Anyway, uh… I got.\",\n \"language\": 9,\n \"timestamp\": 1758231707193649,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"The voice is installed.\",\n \"language\": 9,\n \"timestamp\": 1758231709663309,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 26,\n \"timestamp\": 1758231710057\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231710057 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 26,\n \"timestamp\": 1758231710100\n}\nResponded to Media KEEP_ALIVE_REQ\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"I don't know if that means.\",\n \"language\": 9,\n \"timestamp\": 1758231713307047,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"I mean, you can't do update access.\",\n \"language\": 9,\n \"timestamp\": 1758231716271032,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"That's good.\",\n \"language\": 9,\n \"timestamp\": 1758231718689947,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 27,\n \"timestamp\": 1758231720056\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231720056 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 27,\n \"timestamp\": 1758231720098\n}\nResponded to Media KEEP_ALIVE_REQ\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"Anything that I lost, just like…\",\n \"language\": 9,\n \"timestamp\": 1758231721629546,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"Nice. Well, it's the same process for Vercel, but then…\",\n \"language\": 9,\n \"timestamp\": 1758231725503974,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"Maybe it's a collaborator.\",\n \"language\": 9,\n \"timestamp\": 1758231728815538,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 28,\n \"timestamp\": 1758231730060\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231730060 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 28,\n \"timestamp\": 1758231730092\n}\nResponded to Media KEEP_ALIVE_REQ\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"Anyway, it works now.\",\n \"language\": 9,\n \"timestamp\": 1758231732725232,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 29,\n \"timestamp\": 1758231740053\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231740053 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 29,\n \"timestamp\": 1758231740096\n}\nResponded to Media KEEP_ALIVE_REQ\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"Oh.\",\n \"language\": 9,\n \"timestamp\": 1758231748003514,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 30,\n \"timestamp\": 1758231750059\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231750059 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 30,\n \"timestamp\": 1758231750091\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 31,\n \"timestamp\": 1758231760060\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231760060 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 31,\n \"timestamp\": 1758231760092\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 32,\n \"timestamp\": 1758231770055\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231770055 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 32,\n \"timestamp\": 1758231770098\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 33,\n \"timestamp\": 1758231780053\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231780053 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 33,\n \"timestamp\": 1758231780096\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 34,\n \"timestamp\": 1758231790058\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231790058 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 34,\n \"timestamp\": 1758231790100\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 35,\n \"timestamp\": 1758231800059\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231800059 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 35,\n \"timestamp\": 1758231800091\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 36,\n \"timestamp\": 1758231810051\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231810051 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 36,\n \"timestamp\": 1758231810093\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 37,\n \"timestamp\": 1758231820060\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231820060 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 37,\n \"timestamp\": 1758231820092\n}\nResponded to Media KEEP_ALIVE_REQ\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"That is wild.\",\n \"language\": 9,\n \"timestamp\": 1758231828000350,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 38,\n \"timestamp\": 1758231830058\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231830058 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 38,\n \"timestamp\": 1758231830100\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 39,\n \"timestamp\": 1758231840061\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231840061 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 39,\n \"timestamp\": 1758231840092\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 40,\n \"timestamp\": 1758231850052\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231850052 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 40,\n \"timestamp\": 1758231850095\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 41,\n \"timestamp\": 1758231860053\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231860053 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 41,\n \"timestamp\": 1758231860096\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 42,\n \"timestamp\": 1758231870051\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231870051 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 42,\n \"timestamp\": 1758231870093\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 43,\n \"timestamp\": 1758231880056\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231880056 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 43,\n \"timestamp\": 1758231880099\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 44,\n \"timestamp\": 1758231890058\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231890058 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 44,\n \"timestamp\": 1758231890100\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 45,\n \"timestamp\": 1758231900054\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231900054 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 45,\n \"timestamp\": 1758231900097\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 46,\n \"timestamp\": 1758231910061\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231910061 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 46,\n \"timestamp\": 1758231910093\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 47,\n \"timestamp\": 1758231920051\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231920051 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 47,\n \"timestamp\": 1758231920093\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 48,\n \"timestamp\": 1758231930060\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231930060 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 48,\n \"timestamp\": 1758231930092\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 49,\n \"timestamp\": 1758231940054\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231940054 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 49,\n \"timestamp\": 1758231940097\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 50,\n \"timestamp\": 1758231950053\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231950053 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 50,\n \"timestamp\": 1758231950095\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 51,\n \"timestamp\": 1758231960057\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231960057 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 51,\n \"timestamp\": 1758231960100\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 52,\n \"timestamp\": 1758231970052\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231970052 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 52,\n \"timestamp\": 1758231970095\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 53,\n \"timestamp\": 1758231980059\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231980059 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 53,\n \"timestamp\": 1758231980091\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 54,\n \"timestamp\": 1758231990052\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758231990052 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 54,\n \"timestamp\": 1758231990095\n}\nResponded to Media KEEP_ALIVE_REQ\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"Oh, no.\",\n \"language\": 9,\n \"timestamp\": 1758231999702051,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 55,\n \"timestamp\": 1758232000055\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758232000055 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 55,\n \"timestamp\": 1758232000097\n}\nResponded to Media KEEP_ALIVE_REQ\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"The link in the About section.\",\n \"language\": 9,\n \"timestamp\": 1758232002473930,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"The link in the About section?\",\n \"language\": 9,\n \"timestamp\": 1758232005195545,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 56,\n \"timestamp\": 1758232010053\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758232010053 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 56,\n \"timestamp\": 1758232010096\n}\nResponded to Media KEEP_ALIVE_REQ\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"Yeah, I can't update that one. What? Just like I… just top-down.\",\n \"language\": 9,\n \"timestamp\": 1758232012458628,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"Cisco Payton, I'm sure they'll be very happy to hear from you.\",\n \"language\": 9,\n \"timestamp\": 1758232019203740,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 57,\n \"timestamp\": 1758232020056\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758232020056 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 57,\n \"timestamp\": 1758232020098\n}\nResponded to Media KEEP_ALIVE_REQ\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"Maybe… maybe this is what's preventing us from having constrained encoding.\",\n \"language\": 9,\n \"timestamp\": 1758232024487114,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"Maybe it ain't?\",\n \"language\": 9,\n \"timestamp\": 1758232026604508,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 58,\n \"timestamp\": 1758232030051\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758232030051 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 58,\n \"timestamp\": 1758232030093\n}\nResponded to Media KEEP_ALIVE_REQ\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"Oh, that's so funny.\",\n \"language\": 9,\n \"timestamp\": 1758232031795109,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"I'll… I'll just keep Slack open in case anyone.\",\n \"language\": 9,\n \"timestamp\": 1758232036386372,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"I have a few more comments.\",\n \"language\": 9,\n \"timestamp\": 1758232039877916,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 59,\n \"timestamp\": 1758232040052\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758232040052 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 59,\n \"timestamp\": 1758232040095\n}\nResponded to Media KEEP_ALIVE_REQ\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"Um, so this young one was just super Zoom shit.\",\n \"language\": 9,\n \"timestamp\": 1758232043554504,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"That ain't Zoom shows down and shit like that.\",\n \"language\": 9,\n \"timestamp\": 1758232047518343,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 60,\n \"timestamp\": 1758232050057\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758232050057 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 60,\n \"timestamp\": 1758232050100\n}\nResponded to Media KEEP_ALIVE_REQ\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"Bye.\",\n \"language\": 9,\n \"timestamp\": 1758232051024005,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"I'm not serving properly.\",\n \"language\": 9,\n \"timestamp\": 1758232054410492,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"I think I will be.\",\n \"language\": 9,\n \"timestamp\": 1758232059981868,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 61,\n \"timestamp\": 1758232060055\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758232060055 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 61,\n \"timestamp\": 1758232060098\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 62,\n \"timestamp\": 1758232070058\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758232070058 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 62,\n \"timestamp\": 1758232070101\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 63,\n \"timestamp\": 1758232080052\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758232080052 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 63,\n \"timestamp\": 1758232080094\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 64,\n \"timestamp\": 1758232090057\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758232090057 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 64,\n \"timestamp\": 1758232090100\n}\nResponded to Media KEEP_ALIVE_REQ\n^C\njanzheng@Jans-BlackBook-Pro print_transcripts % \njanzheng@Jans-BlackBook-Pro print_transcripts % \njanzheng@Jans-BlackBook-Pro print_transcripts % \njanzheng@Jans-BlackBook-Pro print_transcripts % \njanzheng@Jans-BlackBook-Pro print_transcripts % \njanzheng@Jans-BlackBook-Pro print_transcripts % \njanzheng@Jans-BlackBook-Pro print_transcripts % \njanzheng@Jans-BlackBook-Pro print_transcripts % \njanzheng@Jans-BlackBook-Pro print_transcripts % yarn print\nyarn run v1.22.22\nwarning package.json: No license field\n$ node print.js --port 9999\nServer running at http://localhost:9999\nWebhook endpoint available at http://localhost:9999/webhook\nRTMS Webhook received: {\n \"event\": \"meeting.rtms_stopped\",\n \"payload\": {\n \"meeting_uuid\": \"388At4JsRhaGOZBz0kvVhg==\",\n \"rtms_stream_id\": \"a646196a95b049109b006277ecf5aff6\",\n \"stop_reason\": 6\n },\n \"event_ts\": 1758232182110\n}\nRTMS Stopped event received\nRTMS Webhook received: {\n \"event\": \"meeting.rtms_stopped\",\n \"payload\": {\n \"meeting_uuid\": \"388At4JsRhaGOZBz0kvVhg==\",\n \"rtms_stream_id\": \"a646196a95b049109b006277ecf5aff6\",\n \"stop_reason\": 11\n },\n \"event_ts\": 1758232183013\n}\nRTMS Stopped event received\nRTMS Webhook received: {\n \"event\": \"meeting.rtms_started\",\n \"payload\": {\n \"meeting_uuid\": \"fJ4VWy4wTXeJOMNnL5kRZA==\",\n \"operator_id\": \"0Al6aUdLSeCOFquEI6lE0Q\",\n \"rtms_stream_id\": \"875cdb5b61ba4ff2ac187458d9337eae\",\n \"server_urls\": \"wss://zoomsjc144-195-46-178zssgw.sjc.zoom.us:443\"\n },\n \"event_ts\": 1758232188725\n}\nRTMS Started event received\nConnecting to signaling WebSocket for meeting fJ4VWy4wTXeJOMNnL5kRZA==\nSignaling WebSocket connection opened for meeting fJ4VWy4wTXeJOMNnL5kRZA==\nGenerating signature with parameters:\nmeetingUuid: fJ4VWy4wTXeJOMNnL5kRZA==\nstreamId: 875cdb5b61ba4ff2ac187458d9337eae\nSent handshake to signaling server\nSignaling Message: {\n \"media_server\": {\n \"server_urls\": {\n \"all\": \"wss://zoomsjc144-195-46-178zssgw.sjc.zoom.us:443\",\n \"audio\": \"wss://zoomsjc144-195-46-178zssgw.sjc.zoom.us:443\",\n \"chat\": \"wss://zoomsjc144-195-46-178zssgw.sjc.zoom.us:443\",\n \"deskshare\": \"wss://zoomsjc144-195-46-178zssgw.sjc.zoom.us:443\",\n \"transcript\": \"wss://zoomsjc144-195-46-178zssgw.sjc.zoom.us:443\",\n \"video\": \"wss://zoomsjc144-195-46-178zssgw.sjc.zoom.us:443\"\n }\n },\n \"msg_type\": 2,\n \"protocol_version\": 1,\n \"sequence\": 237054312,\n \"status_code\": 0\n}\nConnecting to media WebSocket at wss://zoomsjc144-195-46-178zssgw.sjc.zoom.us:443\nGenerating signature with parameters:\nmeetingUuid: fJ4VWy4wTXeJOMNnL5kRZA==\nstreamId: 875cdb5b61ba4ff2ac187458d9337eae\nMedia JSON Message: {\n \"media_params\": {\n \"transcript\": {\n \"content_type\": 5\n }\n },\n \"msg_type\": 4,\n \"payload_encrypted\": false,\n \"protocol_version\": 1,\n \"status_code\": 0\n}\nMedia handshake successful, sent start streaming request\nSignaling Message: {\n \"msg_type\": 8,\n \"state\": 1,\n \"timestamp\": 1758232189429\n}\nSignaling Message: {\n \"msg_type\": 9,\n \"rtms_session_id\": \"6F42835E-8BC4-EE35-3596-FA895F144ABA\",\n \"state\": 2,\n \"timestamp\": 1758232189429\n}\nSignaling Message: {\n \"event\": {\n \"event_type\": 1,\n \"media_type\": 8,\n \"timestamp\": 1758232197682759\n },\n \"msg_type\": 6\n}\nMedia JSON Message: {\n \"content\": {\n \"attribute\": 1,\n \"data\": \"Hello, testing…\",\n \"language\": 9,\n \"timestamp\": 1758232197682759,\n \"user_id\": 16778240,\n \"user_name\": \"Jan Zheng\"\n },\n \"msg_type\": 17\n}\nSignaling Message: {\n \"msg_type\": 12,\n \"sequence\": 0,\n \"timestamp\": 1758232199348\n}\nResponding to Signaling KEEP_ALIVE_REQ: { msg_type: 13, timestamp: 1758232199348 }\nMedia JSON Message: {\n \"msg_type\": 12,\n \"sequence\": 0,\n \"timestamp\": 1758232199411\n}\nResponded to Media KEEP_ALIVE_REQ\nSignaling Message: {\n \"msg_type\": 8,\n \"reason\": 6,\n \"state\": 4,\n \"timestamp\": 1758232202431\n}\nSignaling socket closed\nMedia socket closed\nRTMS Webhook received: {\n \"event\": \"meeting.rtms_stopped\",\n \"payload\": {\n \"meeting_uuid\": \"fJ4VWy4wTXeJOMNnL5kRZA==\",\n \"rtms_stream_id\": \"875cdb5b61ba4ff2ac187458d9337eae\",\n \"stop_reason\": 6\n },\n \"event_ts\": 1758232205437\n}\nRTMS Stopped event received\n",[],[343],"files",[154,171,180,187,198,205,215,223,230,239,249,258,268,277,286,295,304,313,322,332,341],"counts",{"_354":32,"_355":202,"_356":32,"_357":358},"pulls","branches","forks","envVars",{"_359":209,"_360":32},"count","emptyCount","contents",[363],{"_105":172,"_96":173,"_156":174,"_158":157,"_159":142,"_160":175,"_162":119,"_107":364,"_101":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_99":365},["D",1758235656742],[100,173],{"_105":155,"_96":100,"_156":157,"_158":-5,"_159":142,"_160":161,"_162":119,"_107":367,"_101":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_99":368},["D",1758235656395],[100],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.version.$version.code.$",{"_94":95,"_96":97,"_98":44,"_101":102,"_99":100,"_103":377,"_152":382,"_350":446,"_193":447,"_361":449,"_452":-5,"_453":-5,"_454":-5,"_455":-5,"_456":457},{"_105":106,"_96":97,"_107":378,"_109":-5,"_110":22,"_111":112,"_113":73,"_114":-5,"_14":115,"_116":117,"_118":119,"_120":119,"_121":-5,"_122":32,"_16":123,"_124":125,"_126":125,"_127":128,"_129":128,"_130":128,"_131":125,"_132":125,"_23":379,"_136":380,"_139":381,"_151":22},["D",1758132864066],{"_94":95,"_134":135},{"_94":95,"_138":135,"_14":115},{"_101":141,"_96":44,"_105":142,"_143":106,"_144":-5,"_145":-5,"_146":-5,"_147":-5,"_148":-5,"_149":97,"_150":95},[383,389,395,401,404,419,422,425,428,431,434,437,440,443],{"_105":155,"_96":100,"_156":157,"_158":-5,"_159":142,"_160":161,"_162":119,"_107":163,"_101":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":384,"_99":388},[385],{"_105":172,"_96":173,"_156":174,"_158":157,"_159":142,"_160":175,"_162":119,"_107":176,"_101":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":386,"_99":387},[],[100,173],[100],{"_105":181,"_96":182,"_156":183,"_158":-5,"_159":142,"_160":184,"_162":119,"_107":185,"_101":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":390,"_99":394},[391],{"_105":188,"_96":189,"_156":190,"_158":183,"_159":142,"_160":191,"_162":119,"_107":192,"_101":32,"_164":193,"_166":194,"_167":22,"_168":-5,"_169":392,"_99":393},[],[182,189],[182],{"_105":199,"_96":200,"_156":201,"_158":-5,"_159":142,"_160":202,"_162":119,"_107":203,"_101":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":396,"_99":400},[397],{"_105":206,"_96":207,"_156":208,"_158":201,"_159":142,"_160":209,"_162":119,"_107":210,"_101":32,"_164":193,"_166":211,"_167":22,"_168":-5,"_169":398,"_99":399},[],[200,207],[200],{"_105":216,"_96":217,"_156":218,"_158":-5,"_159":142,"_160":219,"_162":119,"_107":220,"_101":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":402,"_99":403},[],[217],{"_105":224,"_96":225,"_156":226,"_158":-5,"_159":142,"_160":227,"_162":22,"_107":228,"_101":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":405,"_99":418},[406,409,412,415],{"_105":231,"_96":232,"_156":233,"_158":226,"_159":142,"_160":234,"_162":22,"_107":235,"_101":32,"_164":193,"_166":236,"_167":22,"_168":-5,"_169":407,"_99":408},[],[225,232],{"_105":240,"_96":241,"_156":242,"_158":226,"_159":142,"_160":243,"_162":22,"_107":244,"_101":32,"_164":245,"_166":246,"_167":22,"_168":-5,"_169":410,"_99":411},[],[225,241],{"_105":250,"_96":251,"_156":252,"_158":226,"_159":142,"_160":253,"_162":22,"_107":254,"_101":32,"_164":245,"_166":255,"_167":22,"_168":-5,"_169":413,"_99":414},[],[225,251],{"_105":259,"_96":260,"_156":261,"_158":226,"_159":142,"_160":262,"_162":22,"_107":263,"_101":32,"_164":193,"_166":264,"_167":22,"_168":-5,"_169":416,"_99":417},[],[225,260],[225],{"_105":269,"_96":270,"_156":271,"_158":-5,"_159":142,"_160":272,"_162":119,"_107":273,"_101":32,"_164":193,"_166":274,"_167":22,"_168":-5,"_169":420,"_99":421},[],[270],{"_105":278,"_96":279,"_156":280,"_158":-5,"_159":142,"_160":102,"_162":119,"_107":281,"_101":282,"_164":193,"_166":283,"_167":22,"_168":-5,"_169":423,"_99":424},[],[279],{"_105":287,"_96":288,"_156":289,"_158":-5,"_159":142,"_160":290,"_162":119,"_107":291,"_101":32,"_164":193,"_166":292,"_167":22,"_168":-5,"_169":426,"_99":427},[],[288],{"_105":296,"_96":297,"_156":298,"_158":-5,"_159":142,"_160":299,"_162":22,"_107":300,"_101":32,"_164":193,"_166":301,"_167":22,"_168":-5,"_169":429,"_99":430},[],[297],{"_105":305,"_96":306,"_156":307,"_158":-5,"_159":142,"_160":308,"_162":119,"_107":309,"_101":184,"_164":193,"_166":310,"_167":22,"_168":-5,"_169":432,"_99":433},[],[306],{"_105":314,"_96":315,"_156":316,"_158":-5,"_159":142,"_160":317,"_162":119,"_107":318,"_101":32,"_164":193,"_166":319,"_167":22,"_168":-5,"_169":435,"_99":436},[],[315],{"_105":323,"_96":324,"_156":117,"_158":-5,"_159":142,"_160":325,"_162":119,"_107":326,"_101":327,"_164":328,"_166":329,"_167":22,"_168":97,"_169":438,"_99":439},[],[324],{"_105":333,"_96":334,"_156":335,"_158":-5,"_159":142,"_160":336,"_162":22,"_107":337,"_101":32,"_164":245,"_166":338,"_167":22,"_168":-5,"_169":441,"_99":442},[],[334],{"_105":342,"_96":343,"_156":344,"_158":-5,"_159":142,"_160":345,"_162":22,"_107":346,"_101":32,"_164":193,"_166":347,"_167":22,"_168":-5,"_169":444,"_99":445},[],[343],[383,385,389,391,395,397,401,404,406,409,412,415,419,422,425,428,431,434,437,440,443],{"_105":155,"_96":100,"_156":157,"_158":-5,"_159":142,"_160":161,"_162":119,"_107":367,"_101":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_99":448},[100],[450],{"_105":172,"_96":173,"_156":174,"_158":157,"_159":142,"_160":175,"_162":119,"_107":364,"_101":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_99":451},[100,173],"upstream","pull","ahead","behind","templates",[],"actionData","errors"]

yawnxyz

zoomtest