Autonomous Sui/Walrus Agent

\n \n

Stored Aphorism

\n Verification:
\n Blob ID: \n

AI Transaction Analysis

\n View Transaction on Sui Explorer\n

\n\n\n`;\n}\n\n// --- API ROUTING & MAIN EXPORT ---\nconst app = new Hono();\n\napp.get(\"/\", (c) => {\n const sourceUrl = new URL(c.req.url).origin;\n return c.html(generateHtml(sourceUrl));\n});\n\napp.post(\"/execute\", async (c) => {\n const openai = new OpenAI();\n\n // Create a streaming response\n const { readable, writable } = new TransformStream();\n const writer = writable.getWriter();\n const encoder = new TextEncoder();\n\n const sendEvent = (data) => {\n writer.write(encoder.encode(JSON.stringify(data) + \"\\n\"));\n };\n\n (async () => {\n try {\n // 1. Generate the aphorism\n sendEvent({\n events: [{\n status: \"pending\",\n message: \"Querying AI for philosophical aphorism...\",\n }],\n });\n const aphorismCompletion = await openai.chat.completions.create({\n model: \"gpt-4o\",\n messages: [{ role: \"system\", content: APHORISM_GENERATOR_PROMPT }],\n response_format: { type: \"json_object\" },\n });\n const aphorismJson = extractJson(\n aphorismCompletion.choices[0].message.content,\n );\n if (!aphorismJson?.aphorism) {\n throw new Error(\"AI failed to generate a valid aphorism.\");\n }\n const aphorism = aphorismJson.aphorism;\n sendEvent({\n events: [{\n status: \"complete\",\n message: \"AI has provided the data to be stored.\",\n }],\n });\n\n // 2. Execute the main on-chain storage logic\n const agentResult = await executeAutonomousStorage(aphorism);\n sendEvent({ events: agentResult.events });\n if (!agentResult.success) {\n throw new Error(\"Autonomous agent workflow failed.\");\n }\n\n // 3. Get AI explanation for the transaction\n sendEvent({\n events: [\n ...agentResult.events,\n {\n status: \"pending\",\n message: \"Querying AI to analyze and explain transaction...\",\n },\n ],\n });\n const { txDetails, ...finalData } = agentResult.result;\n const explainerCompletion = await openai.chat.completions.create({\n model: \"gpt-4o\",\n messages: [\n { role: \"system\", content: TRANSACTION_EXPLAINER_PROMPT },\n {\n role: \"user\",\n content: `Transaction Details: ${JSON.stringify(txDetails)}`,\n },\n ],\n response_format: { type: \"json_object\" },\n });\n const explanationJson = extractJson(\n explainerCompletion.choices[0].message.content,\n );\n if (!explanationJson?.explanation) {\n throw new Error(\"AI failed to generate a valid explanation.\");\n }\n finalData.aiExplanation = explanationJson.explanation;\n\n // 4. Send final result payload and close stream\n sendEvent({\n events: [\n ...agentResult.events,\n {\n status: \"complete\",\n message: \"AI analysis complete. Mission successful.\",\n },\n ],\n finalResult: finalData,\n });\n } catch (error) {\n console.error(\"Execution error:\", error);\n sendEvent({\n events: [{\n status: \"error\",\n message: `Critical failure: ${error.message}`,\n }],\n });\n } finally {\n writer.close();\n }\n })();\n\n return new Response(readable, {\n headers: {\n \"Content-Type\": \"text/event-stream\",\n \"Cache-Control\": \"no-cache\",\n \"Connection\": \"keep-alive\",\n },\n });\n});\n\nexport default app.fetch;","deleted","label",[99],"permalink","https://www.val.town/x/volt/walrus-test/code/main.ts","extension","actionData","errors"]