fix: add pagination to unpaginated Supabase queries to bypass 1000 row limit

server/db.js

@@ -886,20 +886,38 @@ export async function getChatMessages(streamId = null) {
       return sqliteDb.prepare('SELECT message, username, display_name, timestamp FROM messages WHERE username NOT IN (?, ?)').all(...bots);
     }
   } else {
-    let query = supabase
-      .from('messages')
-      .select('message, username, display_name, timestamp')
-      .not('username', 'in', `(${bots.map(b => `"${b}"`).join(',')})`);
-
-    if (streamId) {
-      query = query.eq('stream_id', streamId);
-    }
-    const { data, error } = await query;
-    if (error) {
-      console.error('[Supabase] Error getting chat messages:', error);
-      return [];
+    let allData = [];
+    let from = 0;
+    const limit = 1000;
+    
+    while(true) {
+      let query = supabase
+        .from('messages')
+        .select('message, username, display_name, timestamp')
+        .not('username', 'in', `(${bots.map(b => `"${b}"`).join(',')})`)
+        .range(from, from + limit - 1);
+
+      if (streamId) {
+        query = query.eq('stream_id', streamId);
+      }
+      
+      const { data, error } = await query;
+      
+      if (error) {
+        console.error('[Supabase] Error getting chat messages:', error);
+        break;
+      }
+      
+      if (data && data.length > 0) {
+        allData = allData.concat(data);
+        if (data.length < limit) break; // Fetched the last incomplete page
+        from += limit;
+      } else {
+        break; // Empty page
+      }
     }
-    return data || [];
+    
+    return allData;
   }
 }
 
@@ -978,17 +996,32 @@ export async function getStreamMessageTimestamps(streamId) {
   if (dbMode === 'sqlite') {
     return sqliteDb.prepare('SELECT timestamp FROM messages WHERE stream_id = ? ORDER BY timestamp ASC').all(streamId);
   } else {
-    const { data, error } = await supabase
-      .from('messages')
-      .select('timestamp')
-      .eq('stream_id', streamId)
-      .order('timestamp', { ascending: true });
+    let allData = [];
+    let from = 0;
+    const limit = 1000;
     
-    if (error) {
-      console.error('[Supabase] Error fetching message timestamps:', error);
-      return [];
+    while(true) {
+      const { data, error } = await supabase
+        .from('messages')
+        .select('timestamp')
+        .eq('stream_id', streamId)
+        .order('timestamp', { ascending: true })
+        .range(from, from + limit - 1);
+      
+      if (error) {
+        console.error('[Supabase] Error fetching message timestamps:', error);
+        break;
+      }
+      
+      if (data && data.length > 0) {
+        allData = allData.concat(data);
+        if (data.length < limit) break;
+        from += limit;
+      } else {
+        break;
+      }
     }
-    return data || [];
+    return allData;
   }
 }
 
@@ -1003,20 +1036,31 @@ export async function getModActionsSummaryRaw(streamId = null) {
       return sqliteDb.prepare('SELECT moderator, action_type FROM mod_actions').all();
     }
   } else {
-    let query = supabase
-      .from('mod_actions')
-      .select('moderator, action_type');
-
-    if (streamId) {
-      query = query.eq('stream_id', streamId);
-    }
-
-    const { data, error } = await query;
-    if (error) {
-      console.error('[Supabase] Error fetching mod actions summary:', error);
-      return [];
+    let allData = [];
+    let from = 0;
+    const limit = 1000;
+    
+    while(true) {
+      let query = supabase.from('mod_actions').select('moderator, action_type').range(from, from + limit - 1);
+      if (streamId) {
+        query = query.eq('stream_id', streamId);
+      }
+      
+      const { data, error } = await query;
+      if (error) {
+        console.error('[Supabase] Error getting mod actions summary:', error);
+        break;
+      }
+      
+      if (data && data.length > 0) {
+        allData = allData.concat(data);
+        if (data.length < limit) break;
+        from += limit;
+      } else {
+        break;
+      }
     }
-    return data || [];
+    return allData;
   }
 }