diff --git a/app/api/internal/shared-sync/[board_name]/route.ts b/app/api/internal/shared-sync/[board_name]/route.ts index cc8a3552..8f311995 100644 --- a/app/api/internal/shared-sync/[board_name]/route.ts +++ b/app/api/internal/shared-sync/[board_name]/route.ts @@ -20,7 +20,7 @@ export async function GET(request: Request, { params }: { params: BoardRoutePara } console.log(`Passed auth for ${board_name}`); - const result = syncSharedData(board_name); + const result = await syncSharedData(board_name); return NextResponse.json({ success: true, diff --git a/app/lib/data-sync/aurora/shared-sync.ts b/app/lib/data-sync/aurora/shared-sync.ts index 4de615af..1c974701 100644 --- a/app/lib/data-sync/aurora/shared-sync.ts +++ b/app/lib/data-sync/aurora/shared-sync.ts @@ -296,7 +296,7 @@ async function updateSharedSyncs( } } -export async function getLastSharedSyncTimes(boardName: BoardName, tableNames = SHARED_SYNC_TABLES) { +export async function getLastSharedSyncTimes(boardName: BoardName) { const sharedSyncsSchema = getTable('sharedSyncs', boardName); const result = await db @@ -304,8 +304,7 @@ export async function getLastSharedSyncTimes(boardName: BoardName, tableNames = table_name: sharedSyncsSchema.tableName, last_synchronized_at: sharedSyncsSchema.lastSynchronizedAt, }) - .from(sharedSyncsSchema) - .where(inArray(sharedSyncsSchema.tableName, tableNames as unknown as Array)); + .from(sharedSyncsSchema); return result; } @@ -313,8 +312,9 @@ export async function getLastSharedSyncTimes(boardName: BoardName, tableNames = export async function syncSharedData( board: BoardName, ): Promise> { - const allSyncTimes = await getLastSharedSyncTimes(board, SHARED_SYNC_TABLES); - + console.log('Entered sync shared data'); + const allSyncTimes = await getLastSharedSyncTimes(board); + console.log('Fetched previous sync times'); const syncParams: SyncOptions = { tables: [...SHARED_SYNC_TABLES], sharedSyncs: allSyncTimes.map((syncTime) => ({ @@ -326,6 +326,7 @@ export async function syncSharedData( const syncResults = await sharedSync(board, syncParams); console.log(`Received ${syncResults.PUT.climbs.length} climbs and ${syncResults.PUT.climb_stats.length} climb_stats`); + return upsertAllSharedTableData(board, syncResults); }