apunkt/rowboat
1
0
Fork 0
mirror of https://github.com/rowboatlabs/rowboat.git synced 2026-04-25 00:16:29 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix composio related sync scripts

Browse source
This commit is contained in:
Arjun 2026-04-11 08:53:55 +05:30
parent 80d134568c
commit c91f45f440
2 changed files with 11 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

6
apps/x/packages/core/src/knowledge/sync_calendar.ts
View file

@ -442,6 +442,12 @@ async function performSyncComposio() {
const MAX_PAGES = 20;
for (let page = 0; page < MAX_PAGES; page++) {
// Re-check connection in case user disconnected mid-sync
if (!composioAccountsRepo.isConnected('googlecalendar')) {
console.log('[Calendar] Account disconnected during sync. Stopping.');
return;
}
const args: Record<string, unknown> = {
calendar_id: 'primary',
time_min: timeMin,

5
apps/x/packages/core/src/knowledge/sync_gmail.ts
View file

@ -732,6 +732,11 @@ async function performSyncComposio() {
let highWaterMark: string | null = state?.last_sync ?? null;
let processedCount = 0;
for (const threadId of allThreadIds) {
// Re-check connection in case user disconnected mid-sync
if (!composioAccountsRepo.isConnected('gmail')) {
console.log('[Gmail] Account disconnected during sync. Stopping.');
return;
}
try {
const newestInThread = await processThreadComposio(connectedAccountId, threadId, SYNC_DIR);
processedCount++;