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

auto-update oauth connect state in ui

Browse source
This commit is contained in:
Ramnique Singh 2026-01-20 15:18:47 +05:30
parent 24837f867b
commit bdaca80d59
5 changed files with 86 additions and 20 deletions
Download patch file Download diff file Expand all files Collapse all files

9
apps/x/apps/main/src/ipc.ts
View file

@ -210,6 +210,15 @@ function emitRunEvent(event: z.infer<typeof RunEvent>): void {
}
}
export function emitOAuthEvent(event: { provider: string; success: boolean; error?: string }): void {
const windows = BrowserWindow.getAllWindows();
for (const win of windows) {
if (!win.isDestroyed() && win.webContents) {
win.webContents.send('oauth:didConnect', event);
}
}
}
let runsWatcher: (() => void) | null = null;
export async function startRunsWatcher(): Promise<void> {
if (runsWatcher) {

7
apps/x/apps/main/src/oauth-handler.ts
View file

@ -9,6 +9,7 @@ import { IClientRegistrationRepo } from '@x/core/dist/auth/client-repo.js';
import { triggerSync as triggerGmailSync } from '@x/core/dist/knowledge/sync_gmail.js';
import { triggerSync as triggerCalendarSync } from '@x/core/dist/knowledge/sync_calendar.js';
import { triggerSync as triggerFirefliesSync } from '@x/core/dist/knowledge/sync_fireflies.js';
import { emitOAuthEvent } from './ipc.js';
const REDIRECT_URI = 'http://localhost:8080/oauth/callback';
@ -160,8 +161,13 @@ export async function connectProvider(provider: string): Promise<{ success: bool
} else if (provider === 'fireflies-ai') {
triggerFirefliesSync();
}
// Emit success event to renderer
emitOAuthEvent({ provider, success: true });
} catch (error) {
console.error('OAuth token exchange failed:', error);
const errorMessage = error instanceof Error ? error.message : 'Unknown error';
emitOAuthEvent({ provider, success: false, error: errorMessage });
throw error;
} finally {
// Clean up
@ -178,6 +184,7 @@ export async function connectProvider(provider: string): Promise<{ success: bool
console.log(`[OAuth] Cleaning up abandoned OAuth flow for ${provider} (timeout)`);
activeFlows.delete(state);
server.close();
emitOAuthEvent({ provider, success: false, error: 'OAuth flow timed out' });
}
}, 5 * 60 * 1000); // 5 minutes