Val Town Code SearchReturn to Val Town

5 * User queries are routed, analyzed collaboratively, and synthesized into holistic advice.
6 * Based on the Multi-Agent AI Support Simulation structure.
7 * Uses OpenAI via /v/std/openai.
8 *
9 * Last Updated: 2025-04-18
171      <p class="description">
172          Your Personal Life Operating System. Integrate goals, wellness, career, finances, relationships, and creativity.
173          <br>How can LifeSync help you synchronize your life today? (Using OpenAI via <code>/v/std/openai</code>)
174          <br>Current Date: ${currentDate}
175      </p>
322// Includes LifeSync agent flow
323export default async function(req: Request) {
324  const { OpenAI } = await import("https://esm.town/v/std/openai");
325
326  // --- Helper Function: Call OpenAI API ---
327  // (Mostly unchanged, but updated the JSON mode check)
328  async function callOpenAI(
329    systemPrompt: string,
330    userMessage: string,
332  ): Promise<{ role: "assistant" | "system"; content: string }> {
333    try {
334      // Ensure OPENAI_API_KEY is set in Val Town secrets (environment variable)
335      const openai = new OpenAI();
336
337      const response = await openai.chat.completions.create({
338        model: model,
339        messages: [
347
348      if (!response.choices?.[0]?.message?.content) {
349        console.error("OpenAI API returned an unexpected or empty response structure:", JSON.stringify(response));
350        throw new Error("Received invalid or empty response from AI model.");
351      }
357    } catch (error) {
358      console.error(
359        `OpenAI API call failed for model ${model}. System Prompt: ${systemPrompt.substring(0, 80)}... Error:`,
360        error,
361      );
365      let statusCode = error.status || (error.response ? error.response.status : null);
366      if (error.response && error.response.data && error.response.data.error) {
367        errorMessage = `OpenAI Error (${statusCode || "unknown status"}): ${
368          error.response.data.error.message || JSON.stringify(error.response.data.error)
369        }`;
372      }
373      if (statusCode === 401)
374        errorMessage = "OpenAI API Error (401): Authentication failed. Verify API key secret ('openai').";
375      else if (statusCode === 429) errorMessage = "OpenAI API Error (429): Rate limit or quota exceeded.";
376      else if (statusCode === 400) errorMessage = `OpenAI API Error (400): Bad Request. ${error.message || ""}`;
377      else if (statusCode >= 500) errorMessage = `OpenAI Server Error (${statusCode}): Issue on OpenAI's side.`;
378      else if (error.code === "ENOTFOUND" || error.code === "ECONNREFUSED")
379        errorMessage = `Network Error (${error.code}): Cannot connect to OpenAI API.`;
380
381      // Return error: JSON for Routing agent, plain text for others
442    // --- 1. Routing Step ---
443    conversationLog.push({ agent: "⚙️ System", message: "Contacting Query Routing Agent..." });
444    const routingResponse = await callOpenAI(routingAgentSystemPrompt, trimmedQuery);
445
446    let relevantDomains: string[] = ["GENERAL"]; // Default
449    let routingLogMessage = "";
450
451    if (routingResponse.role === "system") { // Error from callOpenAI
452      routingLogMessage = routingResponse.content; // Log the system error
453      routingFailed = true;
525
526        // Pass the summary from the routing agent to the specialist agent
527        const specialistResponse = await callOpenAI(agentDetails.prompt, summary);
528
529        if (specialistResponse.role === "system") {
573
574        // Use a potentially stronger model for synthesis if needed
575        const synthesisResponse = await callOpenAI(
576          synthesisInput,
577          "Synthesize the above into a cohesive response for the user.",

100Note: When changing a SQLite table's schema, change the table's name (e.g., add _2 or _3) to create a fresh table.
101
102### OpenAI
103```ts
104import { OpenAI } from "https://esm.town/v/std/openai";
105const openai = new OpenAI();
106const completion = await openai.chat.completions.create({
107  messages: [
108    { role: "user", content: "Say hello in a creative way" },

100Note: When changing a SQLite table's schema, change the table's name (e.g., add _2 or _3) to create a fresh table.
101
102### OpenAI
103```ts
104import { OpenAI } from "https://esm.town/v/std/openai";
105const openai = new OpenAI();
106const completion = await openai.chat.completions.create({
107  messages: [
108    { role: "user", content: "Say hello in a creative way" },

6
7// ———————— Val.town/Backend Imports ———————— //
8import { OpenAI } from "https://esm.town/v/std/openai"; // For backend API call
9import { html } from "https://esm.town/v/stevekrouse/html"; // For serving HTML
10
444async function runImprovementPipeline(
445  originalText: string,
446  openai: OpenAI,
447): Promise<{ improvedText: string; coreIntentSummary: string }> {
448  console.log("Pipeline Step 1: Starting Intent Extraction for text length:", originalText.length);
450  try {
451    const intentPrompt = createIntentExtractionPrompt(originalText);
452    const intentCompletion = await openai.chat.completions.create({
453      model: AI_MODEL,
454      messages: [{ role: "user", content: intentPrompt }],
467  let improvedText = originalText;
468  try {
469    const mainCompletion = await openai.chat.completions.create({
470      model: AI_MODEL,
471      messages: [{ role: "user", content: mainImprovementPrompt }],
488export default async function server(req: Request): Promise<Response> {
489  const url = new URL(req.url);
490  const apiKey = Deno.env.get("OPENAI_API_KEY");
491
492  if (!apiKey) {
493    // ... (API key error handling remains the same) ...
494    const errorMsg = "Server configuration error: OPENAI_API_KEY secret not set.";
495    console.error(errorMsg);
496    if (req.method === "POST") return Response.json({ error: errorMsg }, { status: 500 });
497    return html(`<html><body><h1>Configuration Error</h1><p>${errorMsg}</p></body></html>`, { status: 500 });
498  }
499  const openai = new OpenAI({ apiKey: apiKey });
500
501  // --- API Endpoint (POST) ---
508
509      // Run the pipeline
510      const { improvedText, coreIntentSummary } = await runImprovementPipeline(text, openai);
511
512      // Return results

100Note: When changing a SQLite table's schema, change the table's name (e.g., add _2 or _3) to create a fresh table.
101
102### OpenAI
103```ts
104import { OpenAI } from "https://esm.town/v/std/openai";
105const openai = new OpenAI();
106const completion = await openai.chat.completions.create({
107  messages: [
108    { role: "user", content: "Say hello in a creative way" },

100Note: When changing a SQLite table's schema, change the table's name (e.g., add _2 or _3) to create a fresh table.
101
102### OpenAI
103```ts
104import { OpenAI } from "https://esm.town/v/std/openai";
105const openai = new OpenAI();
106const completion = await openai.chat.completions.create({
107  messages: [
108    { role: "user", content: "Say hello in a creative way" },

100Note: When changing a SQLite table's schema, change the table's name (e.g., add _2 or _3) to create a fresh table.
101
102### OpenAI
103```ts
104import { OpenAI } from "https://esm.town/v/std/openai";
105const openai = new OpenAI();
106const completion = await openai.chat.completions.create({
107  messages: [
108    { role: "user", content: "Say hello in a creative way" },

100Note: When changing a SQLite table's schema, change the table's name (e.g., add _2 or _3) to create a fresh table.
101
102### OpenAI
103```ts
104import { OpenAI } from "https://esm.town/v/std/openai";
105const openai = new OpenAI();
106const completion = await openai.chat.completions.create({
107  messages: [
108    { role: "user", content: "Say hello in a creative way" },

6import React from "https://esm.sh/react@18.2.0";
7import { blob } from "https://esm.town/v/std/blob";
8import { OpenAI } from "https://esm.town/v/std/openai";
9import { sqlite } from "https://esm.town/v/stevekrouse/sqlite";
10
305export default async function server(request: Request): Promise<Response> {
306  const KEY = "fortuitousSalmonFox";
307  const openai = new OpenAI();
308  const url = new URL(request.url);
309

6import React from "https://esm.sh/react@18.2.0";
7import { blob } from "https://esm.town/v/std/blob";
8import { OpenAI } from "https://esm.town/v/std/openai";
9import { sqlite } from "https://esm.town/v/stevekrouse/sqlite";
10
305export default async function server(request: Request): Promise<Response> {
306  const KEY = "Girlswithjuice";
307  const openai = new OpenAI();
308  const url = new URL(request.url);
309