Ling0925
/
suna
mirror of https://github.com/kortix-ai/suna.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix(api): implement pagination for message retrieval to handle large datasets

This commit is contained in:
sharath 2025-06-18 04:40:35 +00:00
parent a085c556df
commit 34ea675b31
No known key found for this signature in database
1 changed files with 29 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
frontend/src/lib/api.ts
View File

@ -511,23 +511,39 @@ export const addUserMessage = async (
export const getMessages = async (threadId: string): Promise<Message[]> => {
const supabase = createClient();
const { data, error } = await supabase
.from('messages')
.select('*')
.eq('thread_id', threadId)
.neq('type', 'cost')
.neq('type', 'summary')
.order('created_at', { ascending: true });
let allMessages: Message[] = [];
let from = 0;
const batchSize = 1000;
let hasMore = true;
if (error) {
console.error('Error fetching messages:', error);
handleApiError(error, { operation: 'load messages', resource: `messages for thread ${threadId}` });
throw new Error(`Error getting messages: ${error.message}`);
while (hasMore) {
const { data, error } = await supabase
.from('messages')
.select('*')
.eq('thread_id', threadId)
.neq('type', 'cost')
.neq('type', 'summary')
.order('created_at', { ascending: true })
.range(from, from + batchSize - 1);
if (error) {
console.error('Error fetching messages:', error);
handleApiError(error, { operation: 'load messages', resource: `messages for thread ${threadId}` });
throw new Error(`Error getting messages: ${error.message}`);
}
if (data && data.length > 0) {
allMessages = allMessages.concat(data);
from += batchSize;
hasMore = data.length === batchSize;
} else {
hasMore = false;
}
}
console.log('[API] Messages fetched:', data);
console.log('[API] Messages fetched count:', allMessages.length);
return data || [];
return allMessages;
};
// Agent APIs