apply changes

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

@@ -23,6 +23,9 @@ export async function POST(request: NextRequest) {
             return NextResponse.json({ error: "GitHub access token not found" }, { status: 400 });
         }
 
+        // TODO: Uncomment after Turso migration
+        // Circuit breaker logic commented out until sync_status column exists in production
+        /*
         // Get current user record to check sync status
         const userRecord = await db.select()
             .from(users)
@@ -61,6 +64,7 @@ export async function POST(request: NextRequest) {
                 syncError: null
             })
             .where(eq(users.id, user.id));
+        */
 
         console.log(`[SyncRun] Starting sync for user ${user.id}`);
 
@@ -85,14 +89,15 @@ export async function POST(request: NextRequest) {
             // Always reconcile the critical openTriage#1 issue to ensure immediate state sync
             const reconcileResult = await reconcileOpenTriageIssue1(user.githubAccessToken);
 
+            // TODO: Uncomment after Turso migration
+            /*
             // Mark sync as COMPLETED
-            await db.update(users)
-                .set({
-                    syncStatus: 'COMPLETED',
-                    lastSyncAt: new Date().toISOString(),
-                    syncError: null
-                })
-                .where(eq(users.id, user.id));
+            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}`);
 
@@ -109,13 +114,16 @@ export async function POST(request: NextRequest) {
             });
 
         } catch (syncError: any) {
-            // 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));
+            console.error(`[SyncRun] Error syncing for user ${user.id}:`, syncError);
+
+            // TODO: Uncomment after Turso migration
+            /*
+            // Mark sync as FAILED
+            await db.update(users).set({
+                syncStatus: 'FAILED',
+                syncError: syncError.message || 'Unknown error'
+            }).where(eq(users.id, user.id));
+            */
 
             console.error(`[SyncRun] Sync failed for user ${user.id}:`, syncError);
 

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

@@ -1,51 +1,25 @@
 /**
- * Sync Status API Route
+ * TODO: Re-enable after Turso migration
  * 
- * GET /api/sync/status - Check current sync status for the authenticated user
- * Used by frontend to poll sync progress without triggering new syncs
+ * This endpoint is temporarily disabled because it queries sync_status columns  
+ * that don't exist in the production Turso database yet.
+ * 
+ * To re-enable:
+ * 1. Run migration: add_sync_status.sql on Turso
+ * 2. Uncomment the code below
+ * 3. Deploy
  */
 
-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";
-
-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 });
+// Endpoint disabled until migration
+export function GET() {
+    return new Response(
+        JSON.stringify({
+            error: "Endpoint temporarily disabled",
+            message: "Sync status tracking not yet available"
+        }),
+        {
+            status: 503,
+            headers: { 'Content-Type': 'application/json' }
         }
-
-        const { syncStatus, lastSyncAt, syncError } = userRecord[0];
-
-        return NextResponse.json({
-            status: syncStatus || 'IDLE',
-            lastSyncAt: lastSyncAt || null,
-            error: syncError || null,
-            isIdl: 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 });
-    }
+    );
 }

src/db/schema.ts

@@ -36,11 +36,15 @@ export const users = sqliteTable("users", {
     githubId: integer("github_id").unique().notNull(),
     username: text("username").notNull(),
     avatarUrl: text("avatar_url").notNull(),
-    role: text("role"),  // UserRole enum
+    role: text("role"),  // email: text("email"),
     githubAccessToken: text("github_access_token"),
-    syncStatus: text("sync_status").default("IDLE"),  // IDLE, PENDING, SYNCING, COMPLETED, FAILED
-    lastSyncAt: text("last_sync_at"),  // Timestamp of last successful sync
-    syncError: text("sync_error"),  // Error message if sync failed
+
+    // TODO: Uncomment after running Turso migration (add_sync_status.sql)
+    // Sync status tracking (Phase 2)
+    // 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

@@ -38,7 +38,7 @@ export function verifyJwtToken(token: string): { user_id: string; role: string |
  */
 export async function getCurrentUser(request: NextRequest) {
     let token: string | null = null;
-    
+
     // Try Authorization header first
     const authHeader = request.headers.get("Authorization");
     console.log("[getCurrentUser] Authorization header:", authHeader ? "Present" : "Missing");
@@ -46,7 +46,7 @@ export async function getCurrentUser(request: NextRequest) {
         token = authHeader.substring(7);
         console.log("[getCurrentUser] Found token in Authorization header");
     }
-    
+
     // Fallback to query param for SSE connections
     if (!token) {
         const url = new URL(request.url);
@@ -66,8 +66,18 @@ export async function getCurrentUser(request: NextRequest) {
         console.log("[getCurrentUser] Token verified, user_id:", payload.user_id);
 
         // Fetch full user from database
+        // TODO: After Turso migration, re-add syncStatus, lastSyncAt, syncError to this select
         const userRecords = await db
-            .select()
+            .select({
+                id: users.id,
+                githubId: users.githubId,
+                username: users.username,
+                avatarUrl: users.avatarUrl,
+                role: users.role,
+                githubAccessToken: users.githubAccessToken,
+                createdAt: users.createdAt,
+                updatedAt: users.updatedAt,
+            })
             .from(users)
             .where(eq(users.id, payload.user_id))
             .limit(1);