import { generateMerchantTransactionData } from "https://esm.town/v/mjweaver01/generateMerchantTransactionData"; import { prompt } from "https://esm.town/v/mjweaver01/merchantAnalysisPrompt"; import { Hono } from "npm:hono"; import { OpenAI } from "npm:openai"; const trendGPT = async (data, onData) => { const openai = new OpenAI(); const chatStream = await openai.chat.completions.create({ messages: [ { role: "system", content: prompt.replaceAll("\n", "") }, { role: "user", content: JSON.stringify(data) }, ], model: "chatgpt-4o-latest", max_tokens: 4000, temperature: 0, stream: true, }); let result = ""; try { for await (const chunk of chatStream) { const content = chunk.choices?.[0]?.delta?.content || ""; result += content; if (onData) onData(result); } } catch (err) { console.error("Error during stream processing:", err); throw new Error("An error occurred while streaming the response."); } return result; }; const trendsData = generateMerchantTransactionData(); const app = new Hono(); app.get("/", async (c) => { const { readable, writable } = new TransformStream(); const writer = writable.getWriter(); const encoder = new TextEncoder(); writer.write(encoder.encode(`

`)); let previousContent = ""; trendGPT(JSON.stringify(trendsData), (streamedData) => { const newContent = streamedData.slice(previousContent.length); previousContent = streamedData; writer.write(encoder.encode(` `)); }).then(() => { writer.close(); }).catch((error) => { console.error("Error while rendering:", error); writer.write(encoder.encode("

An error occurred while rendering the response.

")); writer.close(); }); return new Response(readable, { headers: { "Content-Type": "text/html; charset=utf-8", "Transfer-Encoding": "chunked", }, }); }); app.post("/ask", async (c) => { const body = await c.req.parseBody() ?? trendsData; let responseText = ""; try { await trendGPT(JSON.stringify(body), (streamedData) => { responseText = streamedData; }); } catch (error) { console.error("Error while processing request:", error); return c.text("An error occurred while processing your request.", 500); } return c.text(responseText); }); export default app.fetch;

FindFraudTrendsUsingGPT