Update farcaster.js

Author: serefyarar

farcaster.js

@@ -7,7 +7,7 @@ const WS_URL = 'wss://ws.warpcast.com/stream';
 
 export const formatMessage = (message) => {
     if (message.serverTimestamp < 1740239068884) {
-        return false;
+        // return false;
     }
     const isAgent = message.senderFid === parseInt(process.env.AGENT_FID);
     return {
@@ -34,12 +34,14 @@ class Farcaster {
             });
 
             if (!response.ok) {
-                throw new Error(`API call failed with status ${response.status}: ${await response.text()}`);
+                const error = new Error(`API call failed with status ${response.status}: ${await response.text()}`);
+                error.statusCode = response.status;
+                throw error;
             }
 
             return await response.json();
         } catch (error) {
-            console.error(`Error making API call to ${endpoint}:`, error);
+            //console.error(`Error making API call to ${endpoint}:`, error);
             throw error;
         }
     }
@@ -159,7 +161,24 @@ class Farcaster {
         if (!conversationId) {
             conversationId = [p1, p2].sort((a, b) => a - b).join('-');
         }
-        const messages = await this.fetchMessages(conversationId);
+        let messages;
+        try {
+            messages = await this.fetchMessages(conversationId);
+        } catch (error) {
+            if (error.statusCode && error.statusCode === 403) {
+                console.log('403 error encountered, reverting conversationId and trying again');
+                conversationId = [p2, p1].sort((a, b) => b - a).join('-');
+                try {
+                    messages = await this.fetchMessages(conversationId);
+                } catch (retryError) {
+                    console.error('Retry failed:', retryError);
+                    throw retryError;
+                }
+            } else {
+                console.error('Failed to fetch messages:', error);
+                throw error;
+            }
+        }
         return messages.map(message => formatMessage(message)).filter(Boolean);
     }