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

sync immediately on account connect

Browse source
This commit is contained in:
Ramnique Singh 2026-01-20 14:04:10 +05:30
parent 752c537892
commit dc21596e8e
6 changed files with 126 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

30
apps/x/packages/core/src/knowledge/granola/sync.ts
View file

@ -23,6 +23,30 @@ const RATE_LIMIT_RETRY_DELAY_MS = 60 * 1000; // Wait 1 minute on rate limit
const MAX_RETRIES = 3; // Maximum retries for rate-limited requests
const MAX_BATCH_SIZE = 10; // Process max 10 documents per folder per sync
// --- Wake Signal for Immediate Sync Trigger ---
let wakeResolve: (() => void) | null = null;
export function triggerSync(): void {
if (wakeResolve) {
console.log('[Granola] Triggered - waking up immediately');
wakeResolve();
wakeResolve = null;
}
}
function interruptibleSleep(ms: number): Promise<void> {
return new Promise(resolve => {
const timeout = setTimeout(() => {
wakeResolve = null;
resolve();
}, ms);
wakeResolve = () => {
clearTimeout(timeout);
resolve();
};
});
}
// --- Token Extraction ---
interface WorkosTokens {
@ -404,7 +428,7 @@ async function syncNotes(): Promise<void> {
export async function init(): Promise<void> {
console.log('[Granola] Starting Granola Sync...');
console.log(`[Granola] Will check every ${SYNC_INTERVAL_MS / 60000} minutes.`);
console.log(`[Granola] Will sync every ${SYNC_INTERVAL_MS / 60000} minutes.`);
console.log(`[Granola] Notes will be saved to: ${SYNC_DIR}`);
while (true) {
@ -414,9 +438,9 @@ export async function init(): Promise<void> {
console.error('[Granola] Error in sync loop:', error);
}
// Sleep before next check
// Sleep before next check (can be interrupted by triggerSync)
console.log(`[Granola] Sleeping for ${SYNC_INTERVAL_MS / 60000} minutes...`);
await new Promise(resolve => setTimeout(resolve, SYNC_INTERVAL_MS));
await interruptibleSleep(SYNC_INTERVAL_MS);
}
}

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

@ -17,6 +17,30 @@ const REQUIRED_SCOPES = [
const nhm = new NodeHtmlMarkdown();
// --- Wake Signal for Immediate Sync Trigger ---
let wakeResolve: (() => void) | null = null;
export function triggerSync(): void {
if (wakeResolve) {
console.log('[Calendar] Triggered - waking up immediately');
wakeResolve();
wakeResolve = null;
}
}
function interruptibleSleep(ms: number): Promise<void> {
return new Promise(resolve => {
const timeout = setTimeout(() => {
wakeResolve = null;
resolve();
}, ms);
wakeResolve = () => {
clearTimeout(timeout);
resolve();
};
});
}
// --- Helper Functions ---
function cleanFilename(name: string): string {
@ -211,7 +235,7 @@ async function performSync(syncDir: string, lookbackDays: number) {
export async function init() {
console.log("Starting Google Calendar & Notes Sync (TS)...");
console.log(`Will check for credentials every ${SYNC_INTERVAL_MS / 1000} seconds.`);
console.log(`Will sync every ${SYNC_INTERVAL_MS / 1000} seconds.`);
while (true) {
try {
@ -228,8 +252,8 @@ export async function init() {
console.error("Error in main loop:", error);
}
// Sleep for N minutes before next check
// Sleep for N minutes before next check (can be interrupted by triggerSync)
console.log(`Sleeping for ${SYNC_INTERVAL_MS / 1000} seconds...`);
await new Promise(resolve => setTimeout(resolve, SYNC_INTERVAL_MS));
await interruptibleSleep(SYNC_INTERVAL_MS);
}
}

30
apps/x/packages/core/src/knowledge/sync_fireflies.ts
View file

@ -12,6 +12,30 @@ const API_DELAY_MS = 2000; // 2 second delay between API calls
const RATE_LIMIT_RETRY_DELAY_MS = 60 * 1000; // Wait 1 minute on rate limit
const MAX_RETRIES = 3; // Maximum retries for rate-limited requests
// --- Wake Signal for Immediate Sync Trigger ---
let wakeResolve: (() => void) | null = null;
export function triggerSync(): void {
if (wakeResolve) {
console.log('[Fireflies] Triggered - waking up immediately');
wakeResolve();
wakeResolve = null;
}
}
function interruptibleSleep(ms: number): Promise<void> {
return new Promise(resolve => {
const timeout = setTimeout(() => {
wakeResolve = null;
resolve();
}, ms);
wakeResolve = () => {
clearTimeout(timeout);
resolve();
};
});
}
// --- Types for Fireflies API responses ---
interface FirefliesMeeting {
@ -553,7 +577,7 @@ async function syncMeetings() {
*/
export async function init() {
console.log('[Fireflies] Starting Fireflies Sync...');
console.log(`[Fireflies] Will check for credentials every ${SYNC_INTERVAL_MS / 1000} seconds.`);
console.log(`[Fireflies] Will sync every ${SYNC_INTERVAL_MS / 1000} seconds.`);
console.log(`[Fireflies] Syncing transcripts from the last ${LOOKBACK_DAYS} days.`);
while (true) {
@ -571,9 +595,9 @@ export async function init() {
console.error('[Fireflies] Error in main loop:', error);
}
// Sleep before next check
// Sleep before next check (can be interrupted by triggerSync)
console.log(`[Fireflies] Sleeping for ${SYNC_INTERVAL_MS / 1000} seconds...`);
await new Promise(resolve => setTimeout(resolve, SYNC_INTERVAL_MS));
await interruptibleSleep(SYNC_INTERVAL_MS);
}
}

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

@ -13,6 +13,30 @@ const REQUIRED_SCOPE = 'https://www.googleapis.com/auth/gmail.readonly';
const nhm = new NodeHtmlMarkdown();
// --- Wake Signal for Immediate Sync Trigger ---
let wakeResolve: (() => void) | null = null;
export function triggerSync(): void {
if (wakeResolve) {
console.log('[Gmail] Triggered - waking up immediately');
wakeResolve();
wakeResolve = null;
}
}
function interruptibleSleep(ms: number): Promise<void> {
return new Promise(resolve => {
const timeout = setTimeout(() => {
wakeResolve = null;
resolve();
}, ms);
wakeResolve = () => {
clearTimeout(timeout);
resolve();
};
});
}
// --- Helper Functions ---
function cleanFilename(name: string): string {
@ -287,7 +311,7 @@ async function performSync() {
export async function init() {
console.log("Starting Gmail Sync (TS)...");
console.log(`Will check for credentials every ${SYNC_INTERVAL_MS / 1000} seconds.`);
console.log(`Will sync every ${SYNC_INTERVAL_MS / 1000} seconds.`);
while (true) {
try {
@ -304,8 +328,8 @@ export async function init() {
console.error("Error in main loop:", error);
}
// Sleep for N minutes before next check
// Sleep for N minutes before next check (can be interrupted by triggerSync)
console.log(`Sleeping for ${SYNC_INTERVAL_MS / 1000} seconds...`);
await new Promise(resolve => setTimeout(resolve, SYNC_INTERVAL_MS));
await interruptibleSleep(SYNC_INTERVAL_MS);
}
}