Val Town Code SearchReturn to Val Town

2import { nanoid } from "https://esm.sh/nanoid@5.0.5";
3import { sqlite } from "https://esm.town/v/stevekrouse/sqlite";
4import { OpenAI } from "npm:openai";
5
6const TABLE_NAME = `memories`;
63
64// -----------------------------------------------------------------------------
65// LLM: generate seven new fun‑facts (OpenAI)
66// -----------------------------------------------------------------------------
67async function generateFunFacts(previousFacts: { date: string; text: string }[]) {
68  const apiKey = Deno.env.get("OPENAI_API_KEY");
69  if (!apiKey) {
70    console.error("OPENAI_API_KEY is not configured.");
71    return [];
72  }
73
74  const openai = new OpenAI({ apiKey });
75
76  // Build auxiliary strings for the prompt
113
114  try {
115    const completion = await openai.chat.completions.create({
116      model: "gpt-4o-mini", // inexpensive; change if needed
117      max_tokens: 800,
145    }
146  } catch (err) {
147    console.error("OpenAI error while generating fun facts:", err);
148    return [];
149  }
211
212// -----------------------------------------------------------------------------
213// Manual test run (deno run funFactsOpenAI.ts)
214// -----------------------------------------------------------------------------
215if (import.meta.main) {

1import { getWeather, WeatherResponse } from "https://esm.town/v/geoffreylitt/getWeather";
2import { sqlite } from "https://esm.town/v/stevekrouse/sqlite";
3import { OpenAI } from "npm:openai";
4
5const TABLE_NAME = `memories`;
22
23/**
24 * Call OpenAI Chat Completions to compress a single day's forecast
25 * into a <25‑word sentence.
26 */
27async function generateConciseWeatherSummary(weatherDay: ReturnType<typeof summarizeWeather>[number]) {
28  const apiKey = Deno.env.get("OPENAI_API_KEY");
29  if (!apiKey) {
30    console.error("OPENAI_API_KEY is not configured.");
31    return null;
32  }
33
34  const openai = new OpenAI({ apiKey });
35
36  const systemPrompt = `You are a weather forecaster. Create a very concise summary of a day's forecast.`;
41
42  try {
43    const completion = await openai.chat.completions.create({
44      model: "gpt-4o-mini", // cheap & fast; change if desired
45      max_tokens: 100,

1import { Bot } from "https://deno.land/x/grammy@v1.35.0/mod.ts";
2import { DateTime } from "https://esm.sh/luxon@3.4.4";
3import { OpenAI } from "npm:openai";
4import { backstory } from "../backstory.ts";
5import { BOT_SENDER_ID, BOT_SENDER_NAME, storeChatMessage } from "../importers/handleTelegramMessage.ts";
9
10/**
11 * Generate the daily briefing using OpenAI Chat Completions
12 */
13async function generateBriefingContent(
14  openai: OpenAI,
15  memories: Awaited<ReturnType<typeof getRelevantMemories>>,
16  today: DateTime,
77  };
78
79  // --------------- OPENAI CALL ----------------- //
80  const completion = await openai.chat.completions.create({
81    model: "gpt-4o", // adjust as desired
82    max_tokens: 3000,
97) {
98  // Get API keys from environment
99  const apiKey = Deno.env.get("OPENAI_API_KEY");
100  const telegramToken = Deno.env.get("TELEGRAM_TOKEN");
101
106
107  if (!apiKey) {
108    console.error("OPENAI_API_KEY is not configured.");
109    return;
110  }
120  }
121
122  // Initialize OpenAI client
123  const openai = new OpenAI({ apiKey });
124
125  // Initialize Telegram bot
140  // Generate briefing content
141  const content = await generateBriefingContent(
142    openai,
143    memories,
144    today,

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" },

177    }
178
179    const { OpenAI } = await import("https://esm.town/v/std/openai");
180    const openai = new OpenAI();
181
182    const valTownClient = new ValTown({
197
198          try {
199            const completion = await openai.chat.completions.create({
200              model: "gpt-4o",
201              messages: [

43- **Deno:** The server-side environment.
44- **ValTown SDK:** Integrated to fetch Val details.
45- **OpenAI GPT-4:** To generate natural language README content.
46- **JavaScript Modules (ESM):** For seamless module imports.
47

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" },

1import { OpenAI } from "https://esm.town/v/std/openai";
2import { sqlite } from "https://esm.town/v/stevekrouse/sqlite";
3import * as ta from "npm:technicalindicators";
362}
363
364async function callOpenAI(
365 systemPrompt: string,
366 userMessage: string,
372): Promise<{ role: "assistant" | "system"; content: string }> {
373 const callId = Math.random().toString(36).substring(2, 8);
374 const logPfx = `OpenAI Call [${agentName} ${taskId.split("-")[1] || taskId} ${callId}]`;
375 try {
376  log("DEBUG", agentName, `${logPfx}: Initiating (${model}, JSON: ${isJsonOutputRequired})...`);
377  const openai = new OpenAI();
378  const res = await openai.chat.completions.create({
379   model,
380   messages: [{ role: "system", content: systemPrompt }, { role: "user", content: userMessage }],
384  const content = res.choices?.[0]?.message?.content;
385  if (!content) {
386   log("ERROR", agentName, `${logPfx}: OpenAI returned empty/invalid response.`);
387   throw new Error("Invalid/empty AI response.");
388  }
394  let code = err.status || (err.response ? err.response.status : null);
395  const errData = err.response?.data || err.error || err.response || err;
396  if (errData?.message) { errMsg = `OpenAI Err (${code || "?"}) via ${agentName}: ${errData.message}`; }
397  else if (errData?.error?.message) { errMsg = `OpenAI Err (${code || "?"}) via ${agentName}: ${errData.error.message}`; }
398  else if (err.message) { errMsg += ` Details: ${err.message}`; }
399  else { try { errMsg += ` Unknown err: ${JSON.stringify(errData)}`; } catch { errMsg += " Unknown non-serializable err."; }}
402  else if (code === 400) errMsg += " (ACTION: Bad request/prompt issue)";
403  else if (err.code === "ENOTFOUND" || err.code === "ECONNREFUSED" || err.cause?.code === "UND_ERR_CONNECT_TIMEOUT") errMsg += " (ACTION: Network error)";
404  else if (code >= 500) errMsg += " (ACTION: OpenAI server issue)";
405  const escapedErr = errMsg.replace(/\\/g, "\\\\").replace(/"/g, "\\\"").replace(/\n/g, "\\n");
406  if (isJsonOutputRequired) {
659 const taskId = task.taskId;
660 log("INFO", agentName, `Task ${taskId}. Processing goals. Hash: ${hashCode(JSON.stringify(task.payload))}`);
661 const result = await callOpenAI(
662  tickerSuggestionAgentSystemPrompt,
663  JSON.stringify(task.payload),
999  },
1000 });
1001 const result = await callOpenAI(
1002  tickerInterpretationAgentSystemPrompt,
1003  input,
1111  pastPerformanceContext: pastPerformanceContext ?? "N/A",
1112 });
1113 const result = await callOpenAI(
1114  synthesisChartingDataAgentSystemPrompt,
1115  input,