apunkt/rowboat
1
0
Fork 0
mirror of https://github.com/rowboatlabs/rowboat.git synced 2026-05-02 11:52:38 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix composio related sync scripts (#484)

Browse source
This commit is contained in:
arkml 2026-04-11 09:08:26 +05:30 • committed by GitHub
parent 80d134568c
commit 884b5d0414
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
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; const MAX_PAGES = 20;
for (let page = 0; page < MAX_PAGES; page++) { 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> = { const args: Record<string, unknown> = {
calendar_id: 'primary', calendar_id: 'primary',
time_min: timeMin, 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 highWaterMark: string | null = state?.last_sync ?? null;
let processedCount = 0; let processedCount = 0;
for (const threadId of allThreadIds) { 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 { try {
const newestInThread = await processThreadComposio(connectedAccountId, threadId, SYNC_DIR); const newestInThread = await processThreadComposio(connectedAccountId, threadId, SYNC_DIR);
processedCount++; processedCount++;