Val Town Code SearchReturn to Val Town

2import querystring from "node:querystring";
3import Anthropic from "npm:@anthropic-ai/sdk@0.24.3";
4import { RestClient } from "npm:@signalwire/compatibility-api";
5import chunk from "npm:chunk-text";
6import { backstory } from "../backstory.ts";
86
87/**
88 * Format chat history for Anthropic API
89 */
90function formatChatHistoryForAI(history) {
325  };
326  try {
327    // Get Anthropic API key from environment
328    const apiKey = Deno.env.get("ANTHROPIC_API_KEY");
329    if (!apiKey) {
330      console.error("Anthropic API key is not configured.");
331      await reply(
332        "I apologize, but I'm not properly configured at the moment. Please inform the household administrator.",
336
337    // Initialize Anthropic client
338    const anthropic = new Anthropic({ apiKey });
339
340    // Get message text and user info

267
268            try {
269                // Include sequence in API call URL
270                const apiUrl = \`\${window.location.pathname}?query=\${encodeURIComponent(query)}&sequence=\${encodeURIComponent(sequence)}&format=json\`;
271                const response = await fetch(apiUrl, {
272                    method: 'GET',
273                    headers: { 'Accept': 'application/json' }
337  const { OpenAI } = await import("https://esm.town/v/std/openai");
338
339  // --- OpenAI API Call Helper (Reused) ---
340  async function callOpenAI(
341    systemPrompt: string,
356
357      if (!response.choices?.[0]?.message?.content) {
358        console.error("OpenAI API returned unexpected structure:", JSON.stringify(response));
359        throw new Error("Received invalid or empty response from AI model.");
360      }
361      return { role: "assistant", content: response.choices[0].message.content };
362    } catch (error) {
363      console.error(`OpenAI API call failed for model ${model}. Error:`, error.message, error.response?.data);
364      let errorMessage = `Error with AI model (${model}).`;
365      let statusCode = error.status || error.response?.status;
512  const sourceUrl = `https://val.town/v/${Deno.env.get("val_owner")}.${Deno.env.get("val_slug")}`;
513
514  // API Request (format=json)
515  if (format === "json") {
516    if (!userQuery || userQuery.trim().length === 0) {

31---------------------
32
33<a href="mailto:serviceclient@labellenergie.fr?subject=LBE437298%20-%20Demande%20d'application%20des%20nouvelles%20conditions%20tarifaires&body=Bonjour%2C%0A%0APuis-je%20b%C3%A9n%C3%A9ficier%20des%20nouvelles%20conditions%20tarifaires%20de%20%7Bdate%7D%20pour%20mes%202%20contrats%20(LBE437298%20et%20LBE435565)%2C%20svp%20%3F%0A%0AMon%20n%C2%B0%20de%20client%20est%20le%20LBE437298.%0A%0ABien%20cordialement%2C%0APierre-Olivier%20Mauguet">
34  Envoyer la demande à La Belle Énergie
35</a>

81            <ul>
82              <li>
83                <a href="mailto:serviceclient@labellenergie.fr?subject=${numClient}%20-%20Demande%20d'application%20des%20nouvelles%20conditions%20tarifaires&body=Bonjour%2C%0A%0APuis-je%20b%C3%A9n%C3%A9ficier%20des%20nouvelles%20conditions%20tarifaires%20${date}pour%20${wordingContrat}%2C%20svp%20%3F%0A%0AMon%20n%C2%B0%20de%20client%20est%20le%20${numClient}.%0A%0ABien%20cordialement%2C%0APierre-Olivier%20Mauguet">
84                  Envoyer la demande à La Belle Énergie
85                </a>

262
263          try {
264            const apiUrl = \`\${window.location.pathname}?query=\${encodeURIComponent(query)}&format=json\`;
265            const response = await fetch(apiUrl, {
266              method: 'GET', // Keep using GET for simplicity here
267              headers: { 'Accept': 'application/json' }
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(
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
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      );
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
632  const sourceUrl = import.meta.url.replace("esm.town", "val.town"); // Link to Val Town editor
633
634  // --- API Request Branch (format=json) ---
635  if (format === "json") {
636    if (!userQuery || userQuery.trim().length === 0) {

97
98export async function sendDailyBriefing(chatId?: string, today?: DateTime) {
99  // Get API keys from environment
100  const apiKey = Deno.env.get("ANTHROPIC_API_KEY");
101  const telegramToken = Deno.env.get("TELEGRAM_TOKEN");
102
106  }
107
108  if (!apiKey) {
109    console.error("Anthropic API key is not configured.");
110    return;
111  }
122
123  // Initialize Anthropic client
124  const anthropic = new Anthropic({ apiKey });
125
126  // Initialize Telegram bot
162
163  // disabled title for now, it seemes unnecessary...
164  // await bot.api.sendMessage(chatId, `*${title}*`, { parse_mode: "Markdown" });
165
166  // Then send the main content
169
170  if (content.length <= MAX_LENGTH) {
171    await bot.api.sendMessage(chatId, content, { parse_mode: "Markdown" });
172    // Store the briefing in chat history
173    await storeChatMessage(
198    // Send each chunk as a separate message and store in chat history
199    for (const chunk of chunks) {
200      await bot.api.sendMessage(chatId, chunk, { parse_mode: "Markdown" });
201      // Store each chunk in chat history
202      await storeChatMessage(

53You'll need to set up some environment variables to make it run.
54
55- `ANTHROPIC_API_KEY` for LLM calls
56- You'll need to follow [these instructions](https://docs.val.town/integrations/telegram/) to make a telegram bot, and set `TELEGRAM_TOKEN`. You'll also need to get a `TELEGRAM_CHAT_ID` in order to have the bot remember chat contents.
57- For the Google Calendar integration you'll need `GOOGLE_CALENDAR_ACCOUNT_ID` and `GOOGLE_CALENDAR_CALENDAR_ID`. See [these instuctions](https://www.val.town/v/stevekrouse/pipedream) for details.

8## Hono
9
10This app uses [Hono](https://hono.dev/) as the API framework. You can think of Hono as a replacement for [ExpressJS](https://expressjs.com/) that works in serverless environments like Val Town or Cloudflare Workers. If you come from Python or Ruby, Hono is also a lot like [Flask](https://github.com/pallets/flask) or [Sinatra](https://github.com/sinatra/sinatra), respectively.
11
12## Serving assets to the frontend
20### `index.html`
21
22The most complicated part of this backend API is serving index.html. In this app (like most apps) we serve it at the root, ie `GET /`. 
23
24We *bootstrap* `index.html` with some initial data from the server, so that it gets dynamically injected JSON data without having to make another round-trip request to the server to get that data on the frontend. This is a common pattern for client-side rendered apps.
25
26## CRUD API Routes
27
28This app has two CRUD API routes: for reading and inserting into the messages table. They both speak JSON, which is standard. They import their functions from `/backend/database/queries.ts`. These routes are called from the React app to refresh and update data.
29
30## Errors
31
32Hono and other API frameworks have a habit of swallowing up Errors. We turn off this default behavior by re-throwing errors, because we think most of the time you'll want to see the full stack trace instead of merely "Internal Server Error". You can customize how you want errors to appear.

8import { type Memory } from "../../shared/types.ts";
9
10const API_BASE = "/api/memories";
11const MEMORIES_PER_PAGE = 20;
12
71    setError(null);
72    try {
73      const response = await fetch(API_BASE);
74      if (!response.ok) {
75        throw new Error(`HTTP error! status: ${response.status}`);
100
101    try {
102      const response = await fetch(API_BASE, {
103        method: "POST",
104        headers: { "Content-Type": "application/json" },
123
124    try {
125      const response = await fetch(`${API_BASE}/${id}`, {
126        method: "DELETE",
127      });
155
156    try {
157      const response = await fetch(`${API_BASE}/${editingMemory.id}`, {
158        method: "PUT",
159        headers: { "Content-Type": "application/json" },

26});
27
28// --- API Routes for Memories ---
29
30// GET /api/memories - Retrieve all memories
31app.get("/api/memories", async (c) => {
32  const memories = await getAllMemories();
33  return c.json(memories);
34});
35
36// POST /api/memories - Create a new memory
37app.post("/api/memories", async (c) => {
38  const body = await c.req.json<Omit<Memory, "id">>();
39  if (!body.text) {
44});
45
46// PUT /api/memories/:id - Update an existing memory
47app.put("/api/memories/:id", async (c) => {
48  const id = c.req.param("id");
49  const body = await c.req.json<Partial<Omit<Memory, "id">>>();
66});
67
68// DELETE /api/memories/:id - Delete a memory
69app.delete("/api/memories/:id", async (c) => {
70  const id = c.req.param("id");
71  try {
83// --- Blob Image Serving Routes ---
84
85// GET /api/images/:filename - Serve images from blob storage
86app.get("/api/images/:filename", async (c) => {
87  const filename = c.req.param("filename");
88