apply changes

src/app/api/auth/github/callback/route.ts

@@ -57,6 +57,7 @@ export async function GET(request: NextRequest) {
         const githubUser = await userResponse.json();
 
         // Check if user exists
+        // NOTE: sync_status columns excluded until Turso migration is applied
         const existingUsers = await db
             .select({
                 id: users.id,
@@ -65,9 +66,6 @@ export async function GET(request: NextRequest) {
                 avatarUrl: users.avatarUrl,
                 role: users.role,
                 githubAccessToken: users.githubAccessToken,
-                syncStatus: users.syncStatus,
-                lastSyncAt: users.lastSyncAt,
-                syncError: users.syncError,
                 createdAt: users.createdAt,
                 updatedAt: users.updatedAt,
             })

src/app/api/sync/run/route.ts

@@ -7,9 +7,6 @@
 
 import { NextRequest, NextResponse } from "next/server";
 import { getCurrentUser } from "@/lib/auth";
-import { db } from "@/db";
-import { users } from "@/db/schema";
-import { eq } from "drizzle-orm";
 import { runMaintainerSync, runContributorSync, syncContributorPRsDirect, reconcileOpenTriageIssue1 } from "@/lib/sync/github-sync";
 
 const SYNC_INTERVAL_MS = 5 * 60 * 1000; // 5 minutes
@@ -29,7 +26,7 @@ export async function POST(request: NextRequest) {
             return NextResponse.json({ error: "GitHub access token not found" }, { status: 400 });
         }
 
-        // Layer 2 Defense: In-memory check (FAST - prevents race conditions)
+        // Circuit Breaker: In-memory check (prevents concurrent syncs per user)
         if (activeSyncs.has(user.id)) {
             console.log(`[SyncRun] User ${user.id} sync blocked by in-memory guard`);
             return NextResponse.json({
@@ -39,56 +36,13 @@ export async function POST(request: NextRequest) {
             }, { status: 429 });
         }
 
-        // Layer 1 Defense: Database check (PERSISTENT - survives restarts)
-        const userRecord = await db.select({
-            id: users.id,
-            syncStatus: users.syncStatus,
-            lastSyncAt: users.lastSyncAt,
-        })
-            .from(users)
-            .where(eq(users.id, user.id))
-            .limit(1);
-
-        if (!userRecord || userRecord.length === 0) {
-            return NextResponse.json({ error: "User not found" }, { status: 404 });
-        }
-
-        const currentSyncStatus = userRecord[0].syncStatus;
-
-        // Circuit breaker: Check if sync already in progress
-        if (currentSyncStatus === 'SYNCING') {
-            console.log(`[SyncRun] User ${user.id} sync already in progress (DB status)`);
-            return NextResponse.json({
-                error: "Sync already in progress",
-                status: "SYNCING",
-                message: "Please wait for the current sync to complete"
-            }, { status: 429 });
-        }
-
-        if (currentSyncStatus === 'PENDING') {
-            console.log(`[SyncRun] User ${user.id} sync is pending`);
-            return NextResponse.json({
-                error: "Sync is queued",
-                status: "PENDING",
-                message: "Sync request is queued and will start shortly"
-            }, { status: 202 });
-        }
-
-        // Add to in-memory set FIRST (before DB update)
+        // Add to in-memory set BEFORE starting sync
         activeSyncs.add(user.id);
         console.log(`[SyncRun] Added user ${user.id} to activeSyncs. Size: ${activeSyncs.size}`);
 
-        // Set database status to SYNCING
-        await db.update(users)
-            .set({
-                syncStatus: 'SYNCING',
-                syncError: null
-            })
-            .where(eq(users.id, user.id));
-
-        console.log(`[SyncRun] Starting sync for user ${user.id}`);
-
         try {
+            console.log(`[SyncRun] Starting sync for user ${user.id}`);
+
             // Determine sync type based on user role
             const userRole = user.role?.toUpperCase();
             let stats;
@@ -109,13 +63,6 @@ export async function POST(request: NextRequest) {
             // Always reconcile the critical openTriage#1 issue to ensure immediate state sync
             const reconcileResult = await reconcileOpenTriageIssue1(user.githubAccessToken);
 
-            // Mark sync as COMPLETED
-            await db.update(users).set({
-                syncStatus: 'COMPLETED',
-                lastSyncAt: new Date().toISOString(),
-                syncError: null
-            }).where(eq(users.id, user.id));
-
             console.log(`[SyncRun] Sync completed for user ${user.id}`);
 
             return NextResponse.json({
@@ -133,12 +80,6 @@ export async function POST(request: NextRequest) {
         } catch (syncError: any) {
             console.error(`[SyncRun] Error syncing for user ${user.id}:`, syncError);
 
-            // Mark sync as FAILED with error message
-            await db.update(users).set({
-                syncStatus: 'FAILED',
-                syncError: syncError.message || 'Unknown error'
-            }).where(eq(users.id, user.id));
-
             return NextResponse.json({
                 error: "Sync failed",
                 message: syncError.message || "Internal server error"

src/app/api/sync/status/route.ts

@@ -2,50 +2,22 @@
  * Sync Status API Route
  * 
  * GET /api/sync/status - Check current sync status for the authenticated user
- * Used by frontend to poll sync progress without triggering new syncs
+ * DISABLED: sync_status columns not yet migrated in Turso database
+ * Re-enable after running: turso db shell <db-name> < src/db/migrations/add_sync_status.sql
  */
 
-import { NextRequest, NextResponse } from "next/server";
-import { getCurrentUser } from "@/lib/auth";
-import { db } from "@/db";
-import { users } from "@/db/schema";
-import { eq } from "drizzle-orm";
+import { NextResponse } from "next/server";
 
-export async function GET(request: NextRequest) {
-    try {
-        const user = await getCurrentUser(request);
-        if (!user) {
-            return NextResponse.json({ error: "Unauthorized" }, { status: 401 });
-        }
-
-        // Get user's sync status
-        const userRecord = await db.select({
-            syncStatus: users.syncStatus,
-            lastSyncAt: users.lastSyncAt,
-            syncError: users.syncError,
-        })
-            .from(users)
-            .where(eq(users.id, user.id))
-            .limit(1);
-
-        if (!userRecord || userRecord.length === 0) {
-            return NextResponse.json({ error: "User not found" }, { status: 404 });
-        }
-
-        const { syncStatus, lastSyncAt, syncError } = userRecord[0];
-
-        return NextResponse.json({
-            status: syncStatus || 'IDLE',
-            lastSyncAt: lastSyncAt || null,
-            error: syncError || null,
-            isIdle: syncStatus === 'IDLE' || syncStatus === 'COMPLETED',
-            isSyncing: syncStatus === 'SYNCING',
-            isPending: syncStatus === 'PENDING',
-            hasFailed: syncStatus === 'FAILED',
-        });
-
-    } catch (error) {
-        console.error("GET /api/sync/status error:", error);
-        return NextResponse.json({ error: "Internal server error" }, { status: 500 });
-    }
+export async function GET() {
+    // Temporarily return IDLE since sync_status columns don't exist in DB yet
+    return NextResponse.json({
+        status: 'IDLE',
+        lastSyncAt: null,
+        error: null,
+        isIdle: true,
+        isSyncing: false,
+        isPending: false,
+        hasFailed: false,
+        message: 'Sync status tracking will be available after database migration'
+    });
 }

src/db/schema.ts

@@ -39,10 +39,11 @@ export const users = sqliteTable("users", {
     role: text("role"),  // email: text("email"),
     githubAccessToken: text("github_access_token"),
 
-    // Sync status tracking (Phase 2) - Re-enabled after Turso migration
-    syncStatus: text("sync_status").default("IDLE"),  // IDLE | PENDING | SYNCING | COMPLETED | FAILED
-    lastSyncAt: text("last_sync_at"),                 // ISO timestamp
-    syncError: text("sync_error"),                     // Error message if failed
+    // Sync status tracking (Phase 2) - DISABLED until Turso migration is applied
+    // Run: turso db shell <db-name> < src/db/migrations/add_sync_status.sql
+    // syncStatus: text("sync_status").default("IDLE"),  // IDLE | PENDING | SYNCING | COMPLETED | FAILED
+    // lastSyncAt: text("last_sync_at"),                 // ISO timestamp
+    // syncError: text("sync_error"),                     // Error message if failed
 
     createdAt: text("created_at").notNull(),
     updatedAt: text("updated_at").notNull(),

src/lib/auth.ts

@@ -66,6 +66,7 @@ export async function getCurrentUser(request: NextRequest) {
         console.log("[getCurrentUser] Token verified, user_id:", payload.user_id);
 
         // Fetch full user from database
+        // NOTE: sync_status columns excluded until Turso migration is applied
         const userRecords = await db
             .select({
                 id: users.id,
@@ -74,9 +75,6 @@ export async function getCurrentUser(request: NextRequest) {
                 avatarUrl: users.avatarUrl,
                 role: users.role,
                 githubAccessToken: users.githubAccessToken,
-                syncStatus: users.syncStatus,
-                lastSyncAt: users.lastSyncAt,
-                syncError: users.syncError,
                 createdAt: users.createdAt,
                 updatedAt: users.updatedAt,
             })