alma/Neah
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

courrier multi account restore compose

Browse Source
This commit is contained in:
alma 2025-04-30 13:12:23 +02:00
parent 445c90e852
commit f306d94729
1 changed files with 28 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
app/api/courrier/refresh/route.ts
View File

@ -21,18 +21,38 @@ export async function POST(request: Request) {
);
}
// Extract folder from request body
const { folder = 'INBOX' } = await request.json();
// Extract folder and account ID from request body
const { folder = 'INBOX', accountId } = await request.json();
// First invalidate the cache for this folder
await invalidateFolderCache(session.user.id, folder);
// CRITICAL FIX: Proper folder and account ID handling
let normalizedFolder: string;
let effectiveAccountId: string;
// Then trigger a background refresh
refreshEmailsInBackground(session.user.id, folder, 1, 20);
if (folder.includes(':')) {
// Extract parts if folder already has a prefix
const parts = folder.split(':');
const folderAccountId = parts[0];
normalizedFolder = parts[1];
// If explicit accountId is provided, it takes precedence
effectiveAccountId = accountId || folderAccountId;
} else {
// No prefix in folder name
normalizedFolder = folder;
effectiveAccountId = accountId || 'default';
}
console.log(`[API] Refreshing folder=${normalizedFolder}, accountId=${effectiveAccountId}`);
// First invalidate the cache for this folder with the effective account ID
await invalidateFolderCache(session.user.id, effectiveAccountId, normalizedFolder);
// Then trigger a background refresh with explicit account ID
refreshEmailsInBackground(session.user.id, normalizedFolder, 1, 20, effectiveAccountId);
// Also prefetch page 2 if this is the inbox
if (folder === 'INBOX') {
refreshEmailsInBackground(session.user.id, folder, 2, 20);
if (normalizedFolder === 'INBOX') {
refreshEmailsInBackground(session.user.id, normalizedFolder, 2, 20, effectiveAccountId);
}
return NextResponse.json({