[{"_1":2,"_181":-5,"_182":-5},"loaderData",{"_3":4,"_96":97},"root",{"_5":6,"_37":38,"_69":70},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":20,"_36":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","preferencesChatPanelState","notificationCount",0,"flagDenols","isBusinessOrgMember","isHigherTownieTier","ENV",{"_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":64,"_65":66,"_67":68},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","7d99597163ee6d2ecd75e0020d9771df6719deb7","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","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","API_URL","https://api.val.town","clerkState",{"_71":72},"__internal_clerk_state",{"_73":74,"_75":48,"_76":77,"_78":77,"_79":20,"_80":77,"_81":77,"_82":77,"_83":77,"_84":85,"_94":20,"_95":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",{"_86":20,"_19":20,"_87":77,"_88":89,"_90":77,"_91":48,"_92":20,"_93":77},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_98":99,"_100":101,"_102":103,"_104":105,"_162":163,"_178":179,"_180":-5},"handle","MadeiInGermany","name","Z-Image-LoRA","path","main.tsx","project",{"_106":107,"_100":101,"_108":109,"_110":-5,"_111":20,"_112":113,"_114":115,"_116":117,"_12":118,"_119":120,"_121":122,"_123":-5,"_124":-5,"_125":33,"_14":126,"_127":-5,"_128":-5,"_129":-5,"_130":-5,"_131":132,"_133":132,"_134":135,"_136":135,"_137":135,"_138":132,"_139":132,"_23":140,"_143":144,"_148":149,"_161":20},"id","deddad54-2a92-11f1-a6a9-42dde27851f2","createdAt",["D",1774694571740],"deletedAt","legacyEnvVars","privacy","public","description","https://poe.com/Z-Image-LoRA","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/bb91608e-f58c-4503-108a-c5778c6c2400/square512","01995b22-1b41-771e-a0ac-a4cfc92d3606","pinnedFileId","019d340a-1f31-76c7-bdda-a7c4497219f7","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","01995b22-1b41-771e-a0ac-a96f3508eae1","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_98":99,"_141":142},"profileImageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/a46b91d4-4b2a-48c3-0c37-9c04ea652a00/square512","org",{"_98":99,"_145":142,"_12":118,"_146":147},"avatar","tier","free","branch",{"_150":151,"_100":46,"_106":152,"_153":107,"_154":-5,"_155":-5,"_156":-5,"_157":-5,"_158":-5,"_159":101,"_160":99},"version",1,"dee2ddd8-2a92-11f1-a6a9-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_106":164,"_100":103,"_165":120,"_166":-5,"_167":152,"_168":151,"_169":122,"_108":170,"_150":33,"_171":172,"_173":174,"_175":20,"_176":-5,"_102":177},"dee680a0-2a92-11f1-a6a9-42dde27851f2","fileId","parentId","branchId","branchVersion","latest",["D",1774694571740],"fileType","http","content","import { NextRequest } from \"npm:next/server\";\n\n// === Type definitions ========================================================\n\ntype PoeAttachment = {\n url: string;\n name?: string;\n content_type?: string;\n};\n\ntype PoeMessage = {\n role: \"user\" | \"system\" | \"bot\";\n content: string;\n attachments?: PoeAttachment[];\n};\n\ntype Query = {\n type: string;\n query?: PoeMessage[];\n conversation_id?: string;\n message_id?: string;\n};\n\ntype Events = {\n meta: { content_type: string; suggested_replies?: boolean };\n text: { text: string };\n replace_response: { text: string };\n suggested_reply: { text: string };\n error: { allow_retry?: boolean; text: string };\n done: Record;\n};\n\ntype SendEventFn = (\n eventName: EventName,\n data: Events[EventName]\n) => void;\n\n// === Env =====================================================================\n\nconst NOVITA_API_KEY =\n typeof process !== \"undefined\" ? process.env.NOVITA_API_KEY : \"\";\nconst BOT_ACCESS_KEY =\n typeof process !== \"undefined\" ? process.env.BOT_ACCESS_KEY : \"\";\n\n// === Novita config ===========================================================\n\nconst NOVITA_ASYNC_BASE = \"https://api.novita.ai/v3/async\";\n\n// === Image helpers ============================================================\n\nasync function fetchAttachment(\n url: string,\n): Promise<{ base64: string; contentType: string }> {\n const r = await fetch(url);\n if (!r.ok) throw new Error(`Failed to fetch attachment (${r.status}): ${url}`);\n const ab = await r.arrayBuffer();\n const buf = new Uint8Array(ab);\n const ct = r.headers.get(\"content-type\") ?? \"application/octet-stream\";\n const b64 = btoa(String.fromCharCode(...buf));\n return { base64: b64, contentType: ct.split(\";\")[0].trim() };\n}\n\n// === Novita async generation =================================================\n\nasync function submitGenerationTask(\n prompt: string,\n imageBase64?: string,\n): Promise {\n const payload: Record = {\n seed: -1,\n size: \"1024*1024\",\n prompt,\n strength: imageBase64 ? 0.7 : 0,\n output_format: \"webp\",\n enable_base64_output: false,\n };\n if (imageBase64) payload.image_base64 = imageBase64;\n\n const res = await fetch(`${NOVITA_ASYNC_BASE}/z-image-turbo`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Authorization\": `Bearer ${NOVITA_API_KEY}`,\n },\n body: JSON.stringify(payload),\n });\n\n if (!res.ok) {\n const err = await res.text();\n throw new Error(`Novita submit failed (${res.status}): ${err}`);\n }\n\n const { task_id } = await res.json() as { task_id?: string };\n if (!task_id) throw new Error(\"Novita returned no task_id\");\n return task_id;\n}\n\nasync function pollTaskResult(\n taskId: string,\n maxAttempts = 40,\n intervalMs = 2_500,\n): Promise {\n for (let i = 0; i < maxAttempts; i++) {\n await new Promise((r) => setTimeout(r, intervalMs));\n\n const res = await fetch(\n `${NOVITA_ASYNC_BASE}/task-result?task_id=${encodeURIComponent(taskId)}`,\n { headers: { Authorization: `Bearer ${NOVITA_API_KEY}` } },\n );\n\n if (!res.ok) throw new Error(`Novita poll failed (${res.status})`);\n\n const data = await res.json() as {\n task?: { status?: string; reason?: string };\n images?: Array<{ image_url?: string }>;\n };\n\n const status = data?.task?.status ?? \"\";\n\n if (status === \"TASK_STATUS_SUCCEED\") {\n const url = data?.images?.[0]?.image_url;\n if (!url) throw new Error(\"Task succeeded but no image URL in response\");\n return url;\n }\n\n if (status === \"TASK_STATUS_FAILED\") {\n throw new Error(`Novita task failed: ${data?.task?.reason ?? \"unknown\"}`);\n }\n }\n\n throw new Error(\"Novita task timed out after polling\");\n}\n\n// === Bot Settings ============================================================\n\ntype BotSettings = {\n allow_attachments?: boolean;\n expand_text_attachments?: boolean;\n enable_multi_bot_chat_prompting?: boolean;\n enable_suggested_replies?: boolean;\n rate_card?: string;\n supports_system_messages?: boolean;\n suggested_replies?: boolean;\n};\n\nasync function getBotSettings(): Promise {\n const rateCard =\n \"| Type | Rate (USD) | Rate (Points) |\\n\" +\n \"|------|------------|---------------|\\n\" +\n \"| Total Cost | $0.015/image | 500 points/image |\\n\";\n\n return {\n allow_attachments: true, \n expand_text_attachments: false,\n enable_multi_bot_chat_prompting: true,\n enable_suggested_replies: true,\n rate_card: rateCard,\n supports_system_messages: true,\n suggested_replies: true,\n };\n}\n\n// === SSE Helpers =============================================================\n\nfunction encodeEvent(event: string, data: object = {}) {\n return new TextEncoder().encode(`event: ${event}\\ndata: ${JSON.stringify(data)}\\n\\n`);\n}\n\nasync function getResponse(body: Query, send: SendEventFn) {\n // Send the meta event immediately to signal that the bot supports suggested replies.\n // This is required by Poe to display the suggestions block immediately.\n send(\"meta\", {\n content_type: \"text/markdown\",\n suggested_replies: true,\n });\n\n const lastMsg = (body.query ??[]).at(-1);\n const prompt = (lastMsg?.content ?? \"\").trim();\n const attachments = lastMsg?.attachments ??[];\n\n if (!prompt) {\n send(\"text\", { text: \"Please include a text prompt describing the image you want to generate.\" });\n send(\"done\", {});\n return;\n }\n\n let imageBase64: string | undefined;\n\n if (attachments.length > 0) {\n let attachment: { base64: string; contentType: string };\n try {\n attachment = await fetchAttachment(attachments[0].url);\n } catch (err: unknown) {\n const message = err instanceof Error ? err.message : String(err);\n send(\"error\", { text: `Failed to fetch attachment: ${message}` });\n send(\"done\", {});\n return;\n }\n\n if (!attachment.contentType.startsWith(\"image/\")) {\n send(\"error\", { \n text: `Unsupported attachment type \"${attachment.contentType}\". Only image files (JPEG, PNG, WebP, etc.) are accepted.`\n });\n send(\"done\", {});\n return;\n }\n\n imageBase64 = attachment.base64;\n }\n\n try {\n const mode = imageBase64 ? \"image-to-image\" : \"text-to-image\";\n \n // Output a quick status message first so the connection isn't idle during long polling periods.\n send(\"text\", { text: `Generating image _(${mode})_...` });\n \n const taskId = await submitGenerationTask(prompt, imageBase64);\n const imgUrl = await pollTaskResult(taskId);\n\n // Replace the text generation placeholder with the actual image using the `replace_response` event type\n send(\"replace_response\", { \n text: `Here is your generated image _(${mode})_:\\n\\n![result](${imgUrl})` \n });\n } catch (err: unknown) {\n const message = err instanceof Error ? err.message : String(err);\n send(\"error\", { text: `Generation failed: ${message}` });\n }\n\n send(\"done\", {});\n}\n\n// === Main handler ============================================================\n\nexport default async function handler(\n req: NextRequest,\n): Promise {\n // Auth check\n if (BOT_ACCESS_KEY) {\n const auth = req.headers.get(\"Authorization\");\n if (auth !== `Bearer ${BOT_ACCESS_KEY}`) {\n return new Response(\"Unauthorized\", { status: 401 });\n }\n }\n\n // Method check\n if (req.method !== \"POST\") {\n return new Response(\n \"Novita Image Generation Bot -- send a POST request to interact.\",\n );\n }\n\n const reqBody = await req.json().catch((e) => {\n console.error(\"body parse error\", e);\n return {};\n });\n \n const body = reqBody as Query;\n\n // --- Settings ---------------------------------------------------------------\n if (body.type === \"settings\") {\n return new Response(JSON.stringify(await getBotSettings()), {\n status: 200,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n\n // --- Query ------------------------------------------------------------------\n if (body.type === \"query\") {\n // Return standard SSE instead of JSON response so that advanced events like \"meta\" can be used\n const stream = new ReadableStream({\n start(controller) {\n const send: SendEventFn = (event, data) => {\n controller.enqueue(encodeEvent(event, data));\n };\n \n return getResponse(body, send)\n .catch((e) => {\n console.error(\"get response error\", e);\n send(\"error\", { text: \"An internal error occurred.\" });\n send(\"done\", {});\n })\n .finally(() => controller.close());\n },\n });\n\n return new Response(stream, {\n status: 200,\n headers: {\n \"Content-Type\": \"text/event-stream\",\n \"Cache-Control\": \"no-cache\",\n \"Connection\": \"keep-alive\",\n },\n });\n }\n\n return new Response(\"Unknown request type.\", { status: 400 });\n}","deleted","label",[103],"permalink","https://www.val.town/x/MadeiInGermany/Z-Image-LoRA/code/main.tsx","extension","actionData","errors"]