[{"_1":2,"_173":-5,"_174":-5},"loaderData",{"_3":4,"_91":92},"root",{"_5":6,"_34":35,"_64":65},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","notificationCount",0,"flagDenols","ENV",{"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","5f86047c78fbcbbdc94436f811a86add7eaf8c7a","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","API_URL","https://api.val.town","clerkState",{"_66":67},"__internal_clerk_state",{"_68":69,"_70":45,"_71":72,"_73":72,"_74":20,"_75":72,"_76":72,"_77":72,"_78":72,"_79":80,"_89":20,"_90":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_81":20,"_19":20,"_82":72,"_83":84,"_85":72,"_86":45,"_87":20,"_88":72},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_93":94,"_95":96,"_97":98,"_99":100,"_146":147,"_170":171,"_172":-5},"handle","yawnxyz","name","chatter","path","backend/routes/jobs.ts","project",{"_101":102,"_95":96,"_103":104,"_105":-5,"_106":20,"_107":108,"_109":72,"_110":-5,"_12":111,"_112":-5,"_113":20,"_114":-5,"_115":32,"_14":116,"_117":118,"_119":118,"_120":121,"_122":121,"_123":121,"_124":118,"_125":118,"_23":126,"_129":130,"_132":133,"_145":20},"id","b9276202-7616-11f0-8fe4-0224a6c84d84","createdAt",["D",1754850041617],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","a8270e74-6479-475a-8025-9b69544ee0e7","pinnedFileId","pinPreview","screenshotVersion","likeCount","8319defa-6e1a-46d4-ba66-2114ffd3360b","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_127":128},"profileImageUrl","https://images.clerk.dev/oauth_github/img_2NnaHhpxNuH1xWRIRjQNoo16TVc.jpeg","org",{"_93":94,"_131":128},"avatar","branch",{"_134":135,"_95":43,"_101":136,"_137":102,"_138":-5,"_139":-5,"_140":-5,"_141":-5,"_142":-5,"_143":96,"_144":94},"version",269,"b927b48c-7616-11f0-8fe4-0224a6c84d84","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_101":148,"_95":149,"_150":151,"_152":153,"_154":136,"_155":156,"_157":158,"_103":159,"_134":160,"_161":162,"_163":164,"_165":20,"_166":-5,"_97":167},"33fa7994-a432-11f0-a697-0224a6c84d84","jobs.ts","fileId","b72cc6b2-86b1-11f0-9627-0224a6c84d84","parentId","03e5ad66-7758-11f0-a4e6-0224a6c84d84","branchId","branchVersion",212,"latest",true,["D",1759919597521],2,"fileType","script","content","// Generic Jobs API with SSE updates\nimport type { Context } from \"https://deno.land/x/hono@v3.11.12/mod.ts\";\nimport { serverApiKey } from \"../config.ts\";\n\n// Job types\ntype JobStatus = 'pending' | 'running' | 'completed' | 'error' | 'cancelled';\ntype JobType = 'chat' | string; // Extensible for future job types\n\ninterface ChatJobInput {\n userApiKey?: string;\n messages?: Array<{ role: string; content: string }>;\n query?: string;\n dateRange?: string;\n source?: string;\n language?: string;\n offset?: number;\n model?: string;\n reasoning_effort?: string;\n tools?: Array<{ type: string }>;\n temperature?: number;\n top_p?: number;\n stop?: string | string[];\n max_tokens?: number;\n response_format?: { type: string };\n base_url?: string;\n}\n\ninterface Job {\n id: string;\n type: JobType;\n status: JobStatus;\n createdAt: number;\n updatedAt: number;\n input: ChatJobInput | Record;\n result: unknown;\n error: string | null;\n progress: number | null;\n data: Record;\n subscribers: Set;\n abortController?: AbortController;\n}\n\n// In-memory job store. Suitable for single-process dev/local usage.\nconst jobs = new Map();\nlet jobCounter = 0;\n\nfunction now(): number {\n return Date.now();\n}\n\nfunction newJobId(): string {\n jobCounter += 1;\n return `${now()}-${jobCounter}`;\n}\n\nfunction createJob(type: JobType, input: ChatJobInput | Record): Job {\n const id = newJobId();\n const job: Job = {\n id,\n type,\n status: \"pending\",\n createdAt: now(),\n updatedAt: now(),\n input: input || {},\n result: null,\n error: null,\n progress: null,\n data: {},\n subscribers: new Set(),\n abortController: undefined,\n };\n jobs.set(id, job);\n return job;\n}\n\nfunction getJob(id: string): Job | undefined {\n return jobs.get(String(id));\n}\n\nfunction publish(job: Job, eventName: string, payload?: unknown): void {\n const encoder = new TextEncoder();\n const data = (payload === undefined) ? \"\" : JSON.stringify(payload);\n const chunk = (eventName ? (`event: ${eventName}\\n`) : \"\") + `data: ${data}\\n\\n`;\n for (const sub of job.subscribers) {\n try {\n sub.enqueue(encoder.encode(chunk));\n } catch (_) {\n /* ignore */\n }\n }\n}\n\nfunction completeJob(job: Job, result: unknown): void {\n job.status = \"completed\";\n job.updatedAt = now();\n job.result = result || null;\n publish(job, \"job\", { id: job.id, status: job.status, result: job.result });\n // Best-effort close subscribers\n for (const sub of job.subscribers) {\n try {\n sub.close();\n } catch (_) {\n /* ignore */\n }\n }\n job.subscribers.clear();\n}\n\nfunction failJob(job: Job, message: string): void {\n job.status = \"error\";\n job.updatedAt = now();\n job.error = String(message || \"error\");\n publish(job, \"job\", { id: job.id, status: job.status, error: job.error });\n for (const sub of job.subscribers) {\n try {\n sub.close();\n } catch (_) {\n /* ignore */\n }\n }\n job.subscribers.clear();\n}\n\nfunction cancelJob(job: Job): void {\n try {\n job.abortController?.abort();\n } catch (_) {\n /* ignore */\n }\n job.status = \"cancelled\";\n job.updatedAt = now();\n publish(job, \"job\", { id: job.id, status: job.status });\n for (const sub of job.subscribers) {\n try {\n sub.close();\n } catch (_) {\n /* ignore */\n }\n }\n job.subscribers.clear();\n}\n\nasync function runChatJob(job: Job): Promise {\n const input = job.input as ChatJobInput;\n const {\n userApiKey,\n messages,\n query,\n dateRange,\n source,\n language,\n offset = 0,\n model = \"openai/gpt-oss-120b\",\n reasoning_effort = \"medium\",\n tools = [],\n temperature,\n top_p,\n stop,\n max_tokens,\n response_format,\n base_url,\n } = input;\n\n const apiKey = serverApiKey || userApiKey || Deno.env.get(\"GROQ_API_KEY\") || null;\n if (!apiKey && !base_url) {\n failJob(job, \"No API key (or base_url) provided\");\n return;\n }\n\n const isGptOss = typeof model === \"string\" && model.startsWith(\"openai/gpt-oss\");\n const supportsReasoning = isGptOss;\n const supportsTools = isGptOss;\n\n let finalMessages = Array.isArray(messages) && messages.length > 0\n ? messages\n : null;\n\n // Legacy search routing disabled; use plain chat mode\n const selectedRoute = \"text\";\n if (typeof query === \"string\" && query.trim()) {\n finalMessages = [\n { role: \"system\", content: \"If the user is asking for an explanation or summary rather than a list of links, respond with a concise plain-text answer in the requested language (no JSON). Do not use markdown fences.\" },\n { role: \"user\", content: query }\n ];\n } else if (!finalMessages) {\n finalMessages = [{ role: \"user\", content: \"go to https://news.ycombinator.com/ and give me the first 5 stories\" }];\n }\n\n if (supportsTools && Array.isArray(messages) && messages.length > 0 && Array.isArray(finalMessages) && Array.isArray(tools) && tools.length > 0) {\n const toolPreamble = {\n role: \"system\",\n content: \"You have access to a web browsing tool named \\\"browser_search\\\". Use it for real-time information, for finding additional sources when the user says things like \\\"continue\\\" or \\\"find more\\\", and for verification. Prefer calling the tool rather than guessing. Answer concisely and include relevant markdown links.\"\n };\n finalMessages = [toolPreamble, ...finalMessages];\n }\n\n const payload: Record = {\n model,\n messages: finalMessages,\n stream: true,\n ...(supportsReasoning ? { reasoning_effort } : {}),\n ...(supportsTools && Array.isArray(tools) && tools.length > 0 ? { tools, tool_choice: \"auto\" } : {}),\n ...(temperature !== undefined ? { temperature } : {}),\n ...(top_p !== undefined ? { top_p } : {}),\n ...(stop !== undefined ? { stop } : {}),\n ...(max_tokens !== undefined ? { max_tokens } : {}),\n ...(response_format ? { response_format } : {}),\n };\n\n const baseUrl = (typeof base_url === \"string\" && base_url.trim()) ? base_url.trim().replace(/\\/$/, \"\") : \"\";\n let endpoint = \"https://api.groq.com/openai/v1/chat/completions\";\n if (baseUrl) {\n if (/(\\/v\\d+)?\\/(chat\\/)?completions$/i.test(baseUrl)) {\n endpoint = baseUrl;\n } else if (/\\/v\\d+$/i.test(baseUrl)) {\n endpoint = baseUrl + \"/chat/completions\";\n } else {\n endpoint = baseUrl + \"/v1/chat/completions\";\n }\n }\n\n const headers: Record = {\n \"Content-Type\": \"application/json\",\n ...(apiKey ? { \"Authorization\": \"Bearer \" + apiKey } : {}),\n };\n\n const decoder = new TextDecoder();\n const encoder = new TextEncoder();\n job.status = \"running\";\n job.updatedAt = now();\n publish(job, \"job\", { id: job.id, status: job.status });\n\n let collapsedContent = \"\";\n let collapsedReasoning = \"\";\n const collectedTools: unknown[] = [];\n\n const abortController = new AbortController();\n job.abortController = abortController;\n\n try {\n const upstream = await fetch(endpoint, {\n method: \"POST\",\n headers,\n body: JSON.stringify(payload),\n signal: abortController.signal,\n });\n\n if (!upstream.ok || !upstream.body) {\n let txt = \"\";\n try {\n txt = await upstream.text();\n } catch (_) {\n /* ignore */\n }\n failJob(job, `Upstream error ${upstream.status}: ${txt}`);\n return;\n }\n\n const ct = upstream.headers.get(\"content-type\") || \"\";\n const isSse = /text\\/event-stream/i.test(ct);\n\n if (!isSse) {\n try {\n const nonStream = await upstream.json();\n const choice0 = Array.isArray(nonStream.choices) ? nonStream.choices[0] : null;\n const finalContent = (choice0?.message?.content || choice0?.delta?.content || '') || '';\n if (finalContent) {\n collapsedContent += finalContent;\n publish(job, \"data\", { choices: [{ delta: { content: finalContent } }] });\n }\n // results disabled for plain chat\n completeJob(job, { content: collapsedContent, reasoning: collapsedReasoning, tools: collectedTools });\n } catch (e) {\n failJob(job, (e as Error)?.message || String(e));\n }\n return;\n }\n\n const reader = upstream.body.getReader();\n let buffer = '';\n // route event disabled\n\n const keepAlive = setInterval(() => {\n try {\n publish(job, \"ping\", {});\n } catch (_) {\n /* ignore */\n }\n }, 15000);\n\n try {\n while (true) {\n const { done, value } = await reader.read();\n if (done) break;\n buffer += decoder.decode(value, { stream: true });\n const events = buffer.split('\\n\\n');\n buffer = events.pop() || '';\n for (const evt of events) {\n if (!evt.trim()) continue;\n const lines = evt.split('\\n');\n for (const line of lines) {\n if (!line.startsWith('data: ')) continue;\n const data = line.slice(6);\n publish(job, \"data\", tryParseJson(data));\n try {\n const parsed = JSON.parse(data);\n const choice = Array.isArray(parsed.choices) ? parsed.choices[0] : null;\n const delta = choice?.delta || {};\n if (delta.reasoning) collapsedReasoning += delta.reasoning;\n if (delta.content) collapsedContent += delta.content;\n if (Array.isArray(delta.executed_tools)) collectedTools.push(...delta.executed_tools);\n if (Array.isArray(delta.tool_calls)) collectedTools.push(...delta.tool_calls);\n } catch (_) {\n /* ignore */\n }\n }\n }\n }\n // results disabled for plain chat\n try {\n /* no-op */\n } catch (_) {\n /* ignore */\n }\n } finally {\n try {\n clearInterval(keepAlive);\n } catch (_) {\n /* ignore */\n }\n }\n\n completeJob(job, { content: collapsedContent, reasoning: collapsedReasoning, tools: collectedTools });\n } catch (err) {\n if (job.status === 'cancelled') return;\n failJob(job, (err as Error)?.message || String(err));\n }\n}\n\nfunction tryParseJson(s: string): unknown {\n try {\n return JSON.parse(s);\n } catch (_) {\n return { raw: s };\n }\n}\n\nfunction collectToolTextFromArray(toolArray: unknown[]): string {\n if (!Array.isArray(toolArray)) return '';\n const parts: string[] = [];\n for (const t of toolArray) {\n try {\n const tool = t as Record;\n const name = tool?.name || tool?.tool || (tool?.function as Record)?.name || tool?.id || '';\n const args = tool?.arguments || tool?.input || tool?.params || null;\n const output = tool?.output || tool?.result || tool?.content || null;\n const searchResults = tool?.search_results || tool?.results || null;\n if (name) parts.push('name: ' + String(name));\n if (args) parts.push('arguments: ' + (typeof args === 'string' ? args : JSON.stringify(args)));\n if (output) parts.push('output: ' + (typeof output === 'string' ? output : JSON.stringify(output)));\n if (searchResults) parts.push('search_results: ' + (typeof searchResults === 'string' ? searchResults : JSON.stringify(searchResults)));\n } catch (_) {\n /* ignore */\n }\n }\n return parts.join('\\n');\n}\n\nexport function registerJobsRoutes(app: { get: (path: string, handler: (c: Context) => unknown) => void; post: (path: string, handler: (c: Context) => unknown) => void }): void {\n // Create job\n app.post('/api/jobs', async (c: Context) => {\n try {\n let body: Record = {};\n try {\n body = await c.req.json();\n } catch (_) {\n body = {};\n }\n const { type, input } = body;\n if (!type || typeof type !== 'string') return c.json({ error: 'Missing job type' }, 400);\n const job = createJob(type, input as ChatJobInput | Record);\n // Fire and forget runner based on type\n queueMicrotask(() => {\n if (type === 'chat') runChatJob(job);\n else {\n failJob(job, `Unknown job type: ${type}`);\n }\n });\n return c.json({ id: job.id, status: job.status, createdAt: job.createdAt });\n } catch (err) {\n return c.json({ error: (err as Error)?.message || String(err) }, 500);\n }\n });\n\n // Get job\n app.get('/api/jobs/:id', (c: Context) => {\n const id = c.req.param('id');\n const job = getJob(id);\n if (!job) return c.json({ error: 'Not found' }, 404);\n return c.json({ id: job.id, type: job.type, status: job.status, createdAt: job.createdAt, updatedAt: job.updatedAt, result: job.result, error: job.error, progress: job.progress });\n });\n\n // List jobs (optionally filter by status)\n app.get('/api/jobs', (c: Context) => {\n const status = c.req.query('status');\n const out: Array> = [];\n for (const job of jobs.values()) {\n if (status && job.status !== status) continue;\n out.push({ id: job.id, type: job.type, status: job.status, createdAt: job.createdAt, updatedAt: job.updatedAt });\n }\n return c.json({ jobs: out });\n });\n\n // Cancel job\n app.post('/api/jobs/:id/cancel', (c: Context) => {\n const id = c.req.param('id');\n const job = getJob(id);\n if (!job) return c.json({ error: 'Not found' }, 404);\n if (job.status === 'completed' || job.status === 'error' || job.status === 'cancelled') return c.json({ id: job.id, status: job.status });\n cancelJob(job);\n return c.json({ id: job.id, status: job.status });\n });\n\n // Stream job updates via SSE\n app.get('/api/jobs/:id/stream', (c: Context) => {\n const id = c.req.param('id');\n const job = getJob(id);\n if (!job) return c.json({ error: 'Not found' }, 404);\n const stream = new ReadableStream({\n start: (controller: ReadableStreamDefaultController) => {\n // track controller for cancellation\n try {\n (stream as unknown as { _controller: ReadableStreamDefaultController })._controller = controller;\n } catch (_) {\n /* ignore */\n }\n job.subscribers.add(controller);\n // Send initial state\n try {\n publish(job, 'job', { id: job.id, status: job.status, createdAt: job.createdAt, updatedAt: job.updatedAt });\n } catch (_) {\n /* ignore */\n }\n },\n cancel: () => {\n try {\n const ctrl = (stream as unknown as { _controller?: ReadableStreamDefaultController })._controller;\n if (ctrl) job.subscribers.delete(ctrl);\n } catch (_) {\n /* ignore */\n }\n }\n });\n return new Response(stream, {\n headers: {\n 'Content-Type': 'text/event-stream',\n 'Cache-Control': 'no-cache, no-transform',\n 'Connection': 'keep-alive',\n },\n });\n });\n}\n\n","deleted","label",[168,169,149],"backend","routes","permalink","https://www.val.town/x/yawnxyz/chatter/code/backend/routes/jobs.ts","extension","actionData","errors"]