iterate

Author: serefyarar

agent.js

@@ -242,7 +242,7 @@ async function handleAlreadyConnected({senderFid, messages, response}) {
 
     await farcaster.sendDirectMessage(senderFid, response.message);
 
-    // Check if the other user had already accepted
+    // Get both users' information
     const otherFid = parseInt(match.user1_fid) === senderFid 
         ? match.user2_fid 
         : match.user1_fid;
@@ -251,14 +251,42 @@ async function handleAlreadyConnected({senderFid, messages, response}) {
         ? match.user2_status
         : match.user1_status;
 
+    const currentUser = await findUserByFid(senderFid);
+    const otherUser = await findUserByFid(otherFid);
+
+    // Find new matches for the current user
+    await handleFindMatches({
+        senderFid, 
+        name: currentUser.name, 
+        messages, 
+        response: {
+            ...response,
+            message: "Let's find you another match!"
+        }
+    });
+
+    // If the other user had accepted, inform them and find them new matches too
     if (otherUserStatus === 'accepted') {
-        const currentUser = await findUserByFid(senderFid);
         const alreadyConnectedMessage = await prepareAlreadyConnectedMessage(currentUser);
         await farcaster.sendDirectMessage(otherFid, alreadyConnectedMessage);
+        
+        // Find new matches for the other user
+        const otherUserMessages = await farcaster.getMessages(`${otherFid}-${agentFID}`);
+        const lastResponse = await runAgent(otherUserMessages);
+        
+        await handleFindMatches({
+            senderFid: otherFid,
+            name: otherUser.name,
+            messages: otherUserMessages,
+            response: {
+                ...lastResponse,
+                message: "Let's find you another match!"
+            }
+        });
     }
 }
 
-export const agentLogic = async ({messages, conversationId, senderFid, name}) => {
+export const agentLogic = async ({messages, conversationId, senderFid, name, username}) => {
     const response = await runAgent(messages);
 
     console.log(response, 'response');
@@ -272,6 +300,7 @@ export const agentLogic = async ({messages, conversationId, senderFid, name}) =>
         await indexUser({
             fid: senderFid,
             name,
+            username,
             profile: response.user_profile,
             intent: response.user_intent
         });

db.js

@@ -12,7 +12,7 @@ const openai = new OpenAI({
   apiKey: process.env.OPENAI_API_KEY
 });
 
-export async function indexUser({ fid, name, profile, intent }) {
+export async function indexUser({ fid, name, username, profile, intent }) {
     try {
 
     const openrank = await getOpenRank(fid);
@@ -30,11 +30,12 @@ export async function indexUser({ fid, name, profile, intent }) {
 
       // Upsert user data with both vector embeddings
       await db.raw(
-        `INSERT INTO users (fid, name, openrank, profile, intent, profile_vector, intent_vector, created_at) 
-         VALUES (?, ?, ?, ?, ?, ?, ?, NOW()) 
+        `INSERT INTO users (fid, name, username, openrank, profile, intent, profile_vector, intent_vector, created_at) 
+         VALUES (?, ?, ?, ?, ?, ?, ?, ?, NOW()) 
          ON CONFLICT (fid) 
          DO UPDATE SET 
            name = EXCLUDED.name,
+           username = EXCLUDED.username,
            openrank = EXCLUDED.openrank,
            profile = EXCLUDED.profile,
            intent = EXCLUDED.intent,
@@ -44,6 +45,7 @@ export async function indexUser({ fid, name, profile, intent }) {
         [
           fid,
           name,
+          username,
           openrank,
           profile,
           intent,
@@ -70,9 +72,7 @@ export async function findUsers({ fid, profile, intent }, limit = 50) {
          END AS fid
          FROM matches m
          WHERE (m.user1_fid = ? OR m.user2_fid = ?)
-         AND (m.status = 'declined' OR 
-              m.user1_status = 'declined' OR 
-              m.user2_status = 'declined')
+         AND (m.status = 'accepted')
 
          UNION
          
@@ -114,6 +114,7 @@ export async function findUsers({ fid, profile, intent }, limit = 50) {
       `SELECT 
         fid, 
         name, 
+        username,
         profile, 
         intent,
         (1 - (profile_vector <=> ?)) * 0.5 + 

find_matches.js

@@ -184,7 +184,7 @@ export async function prepareAlreadyConnectedMessage(user) {
     let agentPromptText = agentPrompt.promptMessages[0].prompt.template;
 
     const alreadyConnectedSchema = z.object({
-        message: z.string().describe("A message informing about already being connected and finding new matches")
+        message: z.string().describe("A message informing about already being connected with suggested user and finding new matches")
     });
 
     const prompt = `Create a message for a user who indicated they are already connected with the suggested match.

index.js

@@ -35,6 +35,9 @@ async function checkMessages() {
                    payload.message.senderContext?.username || 
                    'Unknown';
 
+                const username = payload.message.senderContext?.username;
+
+                
                 const messages = await farcaster.getMessages(conversationId);
 
 
@@ -43,7 +46,8 @@ async function checkMessages() {
                     messages,
                     conversationId,
                     senderFid,
-                    name
+                    name,
+                    username
                 });