ACME Customs | Custom Miata Shop

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_154":155,"_156":157},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_18":19,"_17":-7,"_116":-5,"_20":117,"_22":118,"_119":120,"_121":122,"_25":123,"_24":-5,"_124":-5,"_125":-5,"_126":53,"_127":128,"_129":44,"_130":-5,"_131":-5,"_132":133},"routes/_app.x.$handle.$name.branch.$branch.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":-7,"_25":26,"_27":-5,"_28":-5,"_29":-5,"_30":-5,"_31":-5},"handle","yawnxyz","name","acme-customs","branchName","main","version","path","","project",{"_33":62,"_13":14,"_45":63,"_64":-5,"_65":53,"_66":67,"_68":67,"_69":-5,"_70":-5,"_71":72,"_73":37,"_74":44,"_75":-5,"_76":42,"_77":78,"_79":80,"_81":-5,"_82":-5,"_83":-5,"_84":-5,"_85":86,"_87":86,"_88":89,"_90":89,"_91":89,"_92":86,"_93":86,"_94":95,"_96":97,"_98":99,"_100":53},"tree",[57],"file","contents",[32],"upstream","pull","ahead","behind","envVars",{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_17":47,"_48":49,"_50":51,"_52":53,"_54":55,"_18":56},"id","8549929c-3152-11f0-97b3-569c3dd06744","index.tsx","fileId","259fdf92-2d27-11f0-821b-569c3dd06744","parentId","branchId","14195244-2d27-11f0-9f00-569c3dd06744","branchVersion",30,"latest",true,"createdAt",["D",1747289094165],29,"fileType","http","content","import \"jsr:@std/dotenv/load\"; // needed for deno run; not req for smallweb or valtown\nimport { Hono } from \"https://deno.land/x/hono@v3.11.7/mod.ts\";\n// No streamSSE needed for client-side only VAPI handling\n// import { streamSSE } from \"https://deno.land/x/hono@v3.11.7/helper/streaming/index.ts\";\nimport Groq from \"npm:groq-sdk\";\n\nconst app = new Hono();\n\nconst groq = new Groq({ apiKey: Deno.env.get(\"GROQ_API_KEY\") });\n\n// Add a simple in-memory rate limiter (per IP)\nconst extractDataRateLimit = new Map();\n\n// Define the VAPI browser code as a string that will be injected\nconst vapiCode = `\n// Create a simple EventEmitter implementation\nclass EventEmitter {\n constructor() {\n this.events = {};\n }\n on(event, listener) {\n if (!this.events[event]) this.events[event] = [];\n this.events[event].push(listener);\n return this;\n }\n once(event, listener) {\n const onceWrapper = (...args) => {\n listener.apply(this, args);\n this.removeListener(event, onceWrapper);\n };\n return this.on(event, onceWrapper);\n }\n emit(event, ...args) {\n if (!this.events[event]) return false;\n this.events[event].forEach(listener => listener.apply(this, args));\n return true;\n }\n removeListener(event, listener) {\n if (!this.events[event]) return this;\n this.events[event] = this.events[event].filter(l => l !== listener);\n return this;\n }\n removeAllListeners(event) {\n if (event) delete this.events[event];\n else this.events = {};\n return this;\n }\n}\n\n// VapiEventEmitter extends our custom EventEmitter\nclass VapiEventEmitter extends EventEmitter {\n constructor() {\n super();\n }\n}\n\n// Main Vapi class\nclass Vapi extends VapiEventEmitter {\n constructor(apiKey, baseUrl = \"https://api.vapi.ai\", callConfig = {}, callObject = {}) {\n super();\n this.apiKey = apiKey;\n this.baseUrl = baseUrl;\n this.started = false;\n this.call = null;\n this.speakingTimeout = null;\n this.hasEmittedCallEndedStatus = false;\n }\n\n async createWebCall(params) {\n const response = await fetch(\\`\\${this.baseUrl}/call/web\\`, {\n method: 'POST',\n headers: {\n 'Authorization': \\`Bearer \\${this.apiKey}\\`,\n 'Content-Type': 'application/json',\n },\n body: JSON.stringify(params)\n });\n \n if (!response.ok) {\n throw new Error(\\`HTTP error! status: \\${response.status}\\`);\n }\n return await response.json();\n }\n\n cleanup() {\n this.started = false;\n this.hasEmittedCallEndedStatus = false;\n if (this.call) {\n this.call.destroy();\n this.call = null;\n }\n this.speakingTimeout = null;\n }\n\n isMobileDevice() {\n if (typeof navigator === \"undefined\") return false;\n const ua = navigator.userAgent;\n return /android|iphone|ipad|ipod|iemobile|blackberry|bada/i.test(ua.toLowerCase());\n }\n\n async sleep(ms) {\n return new Promise(resolve => setTimeout(resolve, ms));\n }\n\n async start(assistantId, assistantOverrides) {\n if (!assistantId) throw new Error(\"Assistant ID must be provided.\");\n if (this.started) return null;\n this.started = true;\n\n try {\n // 1. Get the room URL from VAPI API\n const callData = await this.createWebCall({\n assistantId: assistantId,\n assistantOverrides: assistantOverrides\n });\n \n console.log('VAPI_DEBUG: Call data:', callData);\n console.log('VAPI_DEBUG: webCallUrl:', callData.webCallUrl);\n \n if (this.call) this.cleanup();\n \n // 2. Completely isolate the Daily call creation and joining\n // Instead of trying to pass things through our class,\n // create a completely fresh approach that mimics our minimal test\n \n // Create a function that will be run in the global context\n const joinVapiRoom = (url) => {\n return new Promise((resolve, reject) => {\n try {\n // Create a fresh call object\n const freshCall = window.DailyIframe.createCallObject({\n audioSource: true,\n videoSource: false\n });\n \n // Set up basic event handlers directly\n freshCall.on('left-meeting', () => {\n console.log('ISOLATED: Call ended');\n // Clean up after the call ends\n freshCall.destroy();\n resolve(null);\n });\n \n freshCall.on('error', (error) => {\n console.error('ISOLATED: Call error', error);\n reject(error);\n });\n \n // Join with minimal options\n freshCall.join({ url: url })\n .then(() => {\n console.log('ISOLATED: Join successful');\n resolve(freshCall);\n })\n .catch((error) => {\n console.error('ISOLATED: Join failed', error);\n reject(error);\n });\n } catch (error) {\n console.error('ISOLATED: Setup failed', error);\n reject(error);\n }\n });\n };\n \n // Run the isolated function and get back the call object\n try {\n this.call = await joinVapiRoom(callData.webCallUrl);\n \n // If we get here, the join was successful\n if (this.call) {\n // Now set up our more complex event handlers\n this.setupCallEventHandlers(false, false);\n }\n \n return callData;\n } catch (error) {\n console.error('VAPI_DEBUG: Isolated join failed', error);\n this.emit('error', error);\n this.cleanup();\n return null;\n }\n } catch (error) {\n console.error('Error starting call:', error);\n this.emit('error', error);\n this.cleanup();\n return null;\n }\n }\n\n setupCallEventHandlers(videoEnabled, isTavusVoice) {\n if (!this.call) return;\n\n this.call.on('left-meeting', () => {\n this.emit('call-end');\n if (!this.hasEmittedCallEndedStatus) {\n this.emit('message', {\n type: 'status-update',\n status: 'ended',\n endedReason: 'customer-ended-call'\n });\n this.hasEmittedCallEndedStatus = true;\n }\n this.cleanup();\n });\n\n this.call.on('error', (error) => {\n this.emit('error', error);\n });\n\n this.call.on('camera-error', (error) => {\n this.emit('error', error);\n });\n\n this.call.on('track-started', async (event) => {\n if (!event || !event.participant) return;\n \n if (!event.participant.local && event.participant.user_name === 'Vapi Speaker') {\n if (event.track.kind === 'video') {\n this.emit('video', event.track);\n }\n if (event.track.kind === 'audio') {\n const audio = document.createElement('audio');\n audio.dataset.participantId = event.participant.session_id;\n document.body.appendChild(audio);\n audio.muted = false;\n audio.autoplay = true;\n audio.srcObject = new MediaStream([event.track]);\n await audio.play();\n }\n this.call?.sendAppMessage('playable');\n }\n });\n\n this.call.on('app-message', (event) => {\n if (!event) return;\n \n try {\n if (event.data === 'listening') {\n this.emit('call-start');\n return;\n }\n\n try {\n const message = JSON.parse(event.data);\n this.emit('message', message);\n \n if (message && \n 'type' in message && \n 'status' in message && \n message.type === 'status-update' && \n message.status === 'ended') {\n this.hasEmittedCallEndedStatus = true;\n }\n } catch (e) {\n console.log('Error parsing message data:', e);\n }\n } catch (error) {\n console.error(error);\n }\n });\n }\n\n stop() {\n this.started = false;\n if (this.call) {\n this.call.destroy();\n this.call = null;\n }\n }\n\n send(message) {\n if (this.call) {\n this.call.sendAppMessage(JSON.stringify(message));\n }\n }\n\n setMuted(muted) {\n if (!this.call) throw new Error(\"Call object is not available.\");\n this.call.setLocalAudio(!muted);\n }\n\n isMuted() {\n return this.call ? !this.call.localAudio() : true;\n }\n}\n\n// Make Vapi available globally\nwindow.Vapi = Vapi;\n`;\n\napp.get(\"/\", (c) => {\n return c.html(\n `\n\n\n \n \n ACME Customs | Custom Miata Shop\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n\n\n

\n ASK US ABOUT OUR MIATA COLLECTION //\n ASK US ABOUT OUR MIATA COLLECTION //\n ASK US ABOUT OUR MIATA COLLECTION //\n ASK US ABOUT OUR MIATA COLLECTION //\n

\n $\"ACME$ \n

Precision Performance & Custom Builds.
Your vision, our engineering.

\n SPEC CLASSIFICATION: // TRACK-READY // AERO-OPTIMIZED\n

\n \n

\n COMMAND INTERFACE // V2.5 REV.3\n

\n \n \n \n

System Interface

\n \n \n

\n CONNECTION STATUS:\n

\n Status: Idle\n

\n \n

\n AUDIO LOG // ENCRYPTION: AES-256\n

Communication Log

') || 'Awaiting connection... Stand by for vehicle consultation.'\">

\n \n

\n TELEMETRY DATA // LIVE STREAM\n

Extracted Data

0\">\n

\n█\n

No extracted data identified in current session.

Data matrix will populate post-consultation analysis.

\n \n \n\n \n \n\n`\n );\n});\n\n// Add a route to serve the vapi-browser.js file\napp.get('/vapi-browser.js', async (c) => {\n return c.text(await Deno.readTextFile('./vapi-browser.js'), {\n headers: {\n 'Content-Type': 'application/javascript',\n },\n });\n});\n\napp.post(\"/extract-data\", async (c) => {\n // Get client IP (works for most Deno/Hono deployments)\n const ip = c.req.header(\"x-forwarded-for\") || c.req.header(\"x-real-ip\") || c.req.raw.conn?.remoteAddr?.hostname || \"unknown\";\n const now = Date.now();\n const last = extractDataRateLimit.get(ip) || 0;\n if (now - last < 4000) {\n return c.json({ error: \"Rate limit exceeded. Please wait 4 seconds between requests.\" }, 429);\n }\n extractDataRateLimit.set(ip, now);\n\n // Accept both transcript and extractedDataSoFar from the client\n const { transcript, extractedDataSoFar } = await c.req.json();\n\n // Prompt Groq to extract structured vehicle specs as a JSON object, grounded in the full log and data so far\n const prompt = `\nYou are an expert data extraction assistant. Given the following full communication log and the extracted data so far, extract all structured facts, specifications, or key information mentioned as a JSON object.\n\n- Each key should be a generic property (e.g. \"model\", \"engine\", \"year\", \"color\", \"issue\", \"location\", etc.), and the value should be the extracted value.\n- Only include actual facts or structured data, not conversational text.\n- If you see a typo or misspelling, correct it to the most likely intended value.\n- Standardize names and values to their correct forms if possible.\n- Use the extracted data so far as context, but update or add new data if the log contains new or corrected information.\n\nCOMMUNICATION LOG:\n${transcript}\n\nEXTRACTED DATA SO FAR:\n${JSON.stringify(extractedDataSoFar || {}, null, 2)}\n\nRespond ONLY with a JSON object, e.g.:\n{\n \"model\": \"RX-7\",\n \"engine\": \"13B-REW\"\n}\n`;\n\n const chatCompletion = await groq.chat.completions.create({\n messages: [\n { role: \"user\", content: prompt }\n ],\n model: \"llama-3.3-70b-versatile\",\n response_format: { type: \"json_object\" }\n });\n\n // Try to parse the JSON from the LLM response\n let specs = {};\n try {\n console.log('LLM response:', chatCompletion.choices[0]?.message?.content);\n const content = chatCompletion.choices[0]?.message?.content || \"{}\";\n specs = JSON.parse(content);\n if (specs && typeof specs === \"object\" && specs.specs && typeof specs.specs === \"object\") {\n specs = specs.specs;\n }\n } catch (e) {\n specs = {};\n }\n return c.json({ specs });\n});\n\n// Export app.fetch for Val Town, otherwise export app\nexport default (typeof Deno !== \"undefined\" && Deno.env.get(\"valtown\"))\n ? app.fetch\n : app;","deleted",false,"label","acmecustoms",[35],{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":58,"_17":47,"_48":49,"_50":51,"_52":53,"_54":55,"_59":60,"_18":61},["D",1747289094165],"children",[],[35],"1418e138-2d27-11f0-9f00-569c3dd06744",["D",1746830631261],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","userId","a8270e74-6479-475a-8025-9b69544ee0e7","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","8319defa-6e1a-46d4-ba66-2114ffd3360b","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_115":111},"org",{"_11":12,"_109":-5,"_110":111,"_71":72,"_112":113,"_114":53},"branch",{"_17":42,"_13":16,"_33":40,"_101":62,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":-5,"_107":14,"_108":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://images.clerk.dev/oauth_github/img_2NnaHhpxNuH1xWRIRjQNoo16TVc.jpeg","tier","pro","canRestrictVals","profileImageUrl","adoptOrgId",{"_33":62,"_13":14,"_45":150,"_64":-5,"_65":53,"_66":67,"_68":67,"_69":-5,"_70":-5,"_71":72,"_73":37,"_74":44,"_75":-5,"_76":42,"_77":78,"_79":80,"_81":-5,"_82":-5,"_83":-5,"_84":-5,"_85":86,"_87":86,"_88":89,"_90":89,"_91":89,"_92":86,"_93":86,"_94":151,"_96":152,"_98":153,"_100":53},[147],"files",[147],"counts",{"_136":78,"_137":138,"_139":78,"_31":140,"_141":142},[134],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_17":47,"_48":49,"_50":51,"_52":53,"_54":55,"_18":135},[35],"pulls","branches",1,"forks",{"_143":145,"_146":78},"connections",{"_143":78,"_144":78},"count","unfilledCount",2,"emptyCount",{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":58,"_17":47,"_48":49,"_50":51,"_52":53,"_54":55,"_59":148,"_18":149},[],[35],["D",1746830631261],{"_11":12,"_115":111},{"_11":12,"_109":-5,"_110":111,"_71":72,"_112":113,"_114":53},{"_17":42,"_13":16,"_33":40,"_101":62,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":-5,"_107":14,"_108":12},"ctx",{"_94":-5,"_131":187,"_188":189,"_190":191,"_192":53,"_193":53,"_194":53,"_195":44,"_196":-5,"_197":-7,"_198":-7,"_199":78,"_200":53,"_201":53,"_202":-5,"_203":53,"_204":53,"_205":53,"_206":-5},"ENV",{"_158":159,"_160":161,"_162":16,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]