iterate

Author: serefyarar

agent.js

@@ -10,13 +10,12 @@ const farcaster = new Farcaster(agentFID, token);
 
 const openai = new OpenAI({ apiKey: process.env.OPENAI_API_KEY });
 
-import { findUsers, indexUser, createMatch, updateMatchStatus, findUserByFid, findPendingMatch, findExpiredMatches } from './db.js';
+import { findUsers, indexUser, createMatch, updateMatchStatus, findUserByFid, findPendingMatch, findExpiredMatches, getUserState } from './db.js';
 import { evaluatePossibleMatches, prepareDeclineMessage, prepareIntroMessage, prepareMatchSuccessMessage, prepareAlreadyConnectedMessage } from './find_matches.js';
 
 export const runAgent = async (messages) => {
 
-    messages = messages.slice(-100);
-
+    //messages = messages.slice(-100);
 
     // Response schema focused on actions
     const responseSchema = z.object({
@@ -53,8 +52,8 @@ export const runAgent = async (messages) => {
     let agentPromptText = agentPrompt.promptMessages[0].prompt.template;
 
     const aiResponse = await openai.chat.completions.create({
-        model: "gpt-4o",
-        //reasoning_effort: "medium",
+        model: "o3-mini",
+        reasoning_effort: "medium",
         messages: [{ role: "system", content: agentPromptText }, ...messages],
         response_format: zodResponseFormat(responseSchema, "response"),
         stream: false,
@@ -329,6 +328,16 @@ export const handleExpiredMatches = async () => {
 }
 
 export const agentLogic = async ({messages, conversationId, senderFid, name, username}) => {
+
+    const matches = await getUserState(senderFid);
+
+    messages.unshift({
+        role: `system`,
+        content: `Here are the matching states for the user. : ${matches.map(match => 
+            Object.entries(match).map(([key, value]) => `${key}: ${value}`).join('\n')
+        ).join('\n----\n')}`
+    });
+
     const response = await runAgent(messages);
 
     console.log(response, 'response');

cast.js

@@ -0,0 +1 @@
+            "\n- Key skills and expertise" +

db.js

@@ -288,3 +288,55 @@ export async function findExpiredMatches() {
         throw error;
     }
 }
+
+export async function getUserState(fid) {
+  try {
+    // First get the user's basic information
+    const user = await db('users')
+      .where({ fid })
+      .first();
+
+    if (!user) {
+      throw new Error(`User with FID ${fid} not found`);
+    }
+
+    // Get all matches for the user with related usernames and specific fields
+    const matches = await db.raw(
+      `SELECT 
+        m.created_at,
+        CASE 
+          WHEN m.user1_fid = ? THEN m.user1_status
+          ELSE m.user2_status
+        END as chatting_user_status,
+        CASE 
+          WHEN m.user1_fid = ? THEN m.user2_status
+          ELSE m.user1_status
+        END as their_status,
+        CASE 
+          WHEN m.user1_fid = ? THEN u2.username
+          ELSE u1.username
+        END as their_username,
+        CASE 
+          WHEN m.user1_fid = ? THEN u2.profile
+          ELSE u1.profile
+        END as their_profile,
+        CASE 
+          WHEN m.user1_fid = ? THEN u2.intent
+          ELSE u1.intent
+        END as their_intent
+      FROM matches m
+      JOIN users u1 ON m.user1_fid = u1.fid
+      JOIN users u2 ON m.user2_fid = u2.fid
+      WHERE m.user1_fid = ? OR m.user2_fid = ?
+      ORDER BY m.created_at ASC`,
+      [fid, fid, fid, fid, fid, fid, fid]
+    );
+
+    return matches.rows;
+
+
+  } catch (error) {
+    console.error('Error getting user state:', error);
+    throw error;
+  }
+}

farcaster.js

@@ -9,13 +9,9 @@ export const formatMessage = (message) => {
     if (message.serverTimestamp < 1740239068884) {
         return false;
     }
-    //console.log(message);
-    const name = message.senderContext?.displayName || 
-                   message.senderContext?.username || 
-                   'Unknown';
     return {
-        role: `user`, 
-        content: `${name}: ${message.message}`
+        role: message.senderFid === parseInt(process.env.AGENT_FID) ? `assistant` : `user`, 
+        content: `${message.senderContext?.username}: ${message.message}`
     };
 };