Val Town Code SearchReturn to Val Town

1import { email } from "https://esm.town/v/std/email";
2import { OpenAI } from "https://esm.town/v/std/openai";
3import { JSDOM } from "npm:jsdom";
4import { NodeHtmlMarkdown, NodeHtmlMarkdownOptions } from "npm:node-html-markdown";
16);
17
18const openai = new OpenAI();
19console.log(trendingMarkdown);
20
21const completion = await openai.chat.completions.create({
22  messages: [
23    {

125  if (request.method === "POST") {
126    try {
127      const { OpenAI } = await import("https://esm.town/v/std/openai");
128      const openai = new OpenAI();
129
130      const formData = await request.formData();
138      const cvText = new TextDecoder().decode(cvBuffer);
139
140      const completion = await openai.chat.completions.create({
141        messages: [
142          {

1import express from 'express';
2import { getMessages, getLinks, getCategories, updateLinkCategory } from './database.js';
3import { Configuration, OpenAIApi } from 'openai';
4import 'dotenv/config';
5
8app.use(express.json());
9
10// Initialize OpenAI for AI-powered queries
11const configuration = new Configuration({
12  apiKey: process.env.OPENAI_API_KEY,
13});
14const openai = new OpenAIApi(configuration);
15
16/**
17 * Function to analyze messages with OpenAI
18 * @param {Array} messages - Array of message objects
19 * @param {string} query - User query to analyze messages with
20 * @returns {Object} - OpenAI response
21 */
22async function analyzeMessagesWithAI(messages, query) {
23  try {
24    // Format messages for OpenAI
25    const formattedConversation = messages.map(msg => {
26      const author = msg.author_id === process.env.DISCORD_USER_ID ? 'You' : 'Partner';
37    `;
38    
39    // Call OpenAI API
40    const response = await openai.createCompletion({
41      model: "gpt-3.5-turbo-instruct",
42      prompt: prompt,

115  const links = getLinks(linkFilters);
116  
117  // If no specific categories, use OpenAI to help filter relevant links
118  if ((!categories || categories.length === 0) && links.length > 0) {
119    const relevantLinks = await filterRelevantLinks(links, query);

5SPOUSE_USER_ID=spouse_user_id_here
6
7# OpenAI API key (for AI-powered querying)
8OPENAI_API_KEY=your_openai_api_key_here
9
10# Val.town settings

25- Node.js 16+ and npm
26- Discord account with Bot token
27- OpenAI API key (for AI-powered queries)
28- Val.town account (for deployment)
29
51   - `DISCORD_USER_ID`: Your Discord user ID
52   - `SPOUSE_USER_ID`: Your partner's Discord user ID
53   - `OPENAI_API_KEY`: Your OpenAI API key
54
555. Initialize the database
146
147- Discord.js for Discord API integration
148- OpenAI for AI-powered querying
149- Val.town for hosting and scheduling
150- Better-SQLite3 for database management

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

57   ```
58
59## 7. Get OpenAI API Key
60
611. Go to [OpenAI's website](https://platform.openai.com/)
622. Sign up or log in
633. Navigate to the API keys section
666. Add it to your `.env` file:
67   ```
68   OPENAI_API_KEY=your_openai_api_key_here
69   ```
70

6 * Uses 'npm:pdf.js-extract' for direct PDF text extraction.
7 * Serves HTML UI & API endpoint from the same Val.
8 * OpenAI import is dynamically done inside the main server function.
9 *
10 * Based on structure from multi-agent support simulation example.
11 * Assumes 'openai' secret is set in Val Town environment variables.
12 *
13 * Last Updated: 2025-05-01 (Dashboard UI, Localization, Animation Integration)
950export default async function(req: Request) {
951  // --- Dynamic Imports (Inside Handler) ---
952  const { OpenAI } = await import("https://esm.town/v/std/openai");
953  const { z } = await import("npm:zod");
954  const { fetch } = await import("https://esm.town/v/std/fetch");
990  }
991
992  // --- Helper Function: Call OpenAI API (Unchanged) ---
993  async function callOpenAI(
994    openai: OpenAI,
995    systemPrompt: string,
996    userMessage: string,
999  ): Promise<{ role: "assistant" | "system"; content: string | object }> {
1000    try {
1001      const response = await openai.chat.completions.create({
1002        model: model,
1003        messages: [{ role: "system", content: systemPrompt }, { role: "user", content: userMessage }],
1011          return { role: "assistant", content: JSON.parse(content) };
1012        } catch (parseError) {
1013          console.error("OpenAI JSON Parse Error:", parseError, "Raw Content:", content);
1014          throw new Error(`AI response was not valid JSON. Raw: ${content.substring(0, 150)}...`);
1015        }
1016      } else { return { role: "assistant", content: content }; }
1017    } catch (error) {
1018      console.error(`OpenAI API call failed. ExpectJSON: ${expectJson}. Error:`, error);
1019      let errorMessage = "Error communicating with AI model.";
1020      if (error.message) { errorMessage += ` Details: ${error.message}`; }
1021       // Check for specific error types if needed (e.g., rate limits, auth)
1022      if (error.status === 401) errorMessage = "Authentication error with OpenAI API. Check your secret key.";
1023      if (error.status === 429) errorMessage = "OpenAI API rate limit exceeded. Please try again later.";
1024
1025      return { role: "system", content: errorMessage };
1112    log: LogEntry[],
1113  ): Promise<LogEntry[]> { // Returns the completed log array
1114    const openai = new OpenAI(); // Assumes API key is in environment variables
1115
1116    log.push({ agent: "System", type: "step", message: "Starting analysis workflow." });
1217    // --- 2. Content Analysis ---
1218    log.push({ agent: "System", type: "step", message: "Starting Content Analysis..." });
1219    const analysisResponse = await callOpenAI(openai, contentAnalysisSystemPrompt, truncatedText, "gpt-4o", true); // Use gpt-4o
1220    let analysisResult: AnalysisResult | null = null;
1221    if (analysisResponse.role === "assistant" && typeof analysisResponse.content === "object") {
1237    // --- 3. Citation Extraction ---
1238    log.push({ agent: "System", type: "step", message: "Starting Citation Extraction..." });
1239    const citationResponse = await callOpenAI(openai, citationExtractionSystemPrompt, truncatedText, "gpt-4o", true); // Use gpt-4o
1240    let extractedCitations: Citation[] = [];
1241    if (
1267        message: \`AI response was not the expected JSON format. Received: \${JSON.stringify(citationResponse.content).substring(0, 200)}...\`,
1268      });
1269    } else { // System error from callOpenAI
1270        log.push({ agent: "Citation Extraction Agent", type: "error", message: citationResponse.content });
1271    }

125  if (request.method === 'POST') {
126    try {
127      const { OpenAI } = await import("https://esm.town/v/std/openai");
128      const openai = new OpenAI();
129
130      const formData = await request.formData();
138      const cvText = new TextDecoder().decode(cvBuffer);
139
140      const completion = await openai.chat.completions.create({
141        messages: [
142          {