Update artifacts/api-server/src/routes/me/index.ts

artifacts/api-server/src/routes/me/index.ts

@@ -49,6 +49,60 @@ router.get("/", async (req: Request, res: Response) => {
   }
 
   try {
+    // ========== 🆕 البحث عن مستخدم قديم بنفس البريد ==========
+    if (userEmail) {
+      const { data: legacyUser } = await supabase
+        .from('users')
+        .select('id, clerk_id, supabase_id')
+        .eq('email', userEmail.toLowerCase())
+        .not('clerk_id', 'is', null)
+        .maybeSingle();
+
+      if (legacyUser) {
+        console.log(`🔗 ربط المستخدم ${userEmail}: القديم=${legacyUser.id} ← الجديد=${userId}`);
+        
+        // تحديث المستخدم القديم ليرتبط بالجديد
+        await supabase
+          .from('users')
+          .update({ 
+            supabase_id: userId,
+            updated_at: now.toISOString()
+          })
+          .eq('id', legacyUser.id);
+
+        // 🎯 استخدم اشتراك المستخدم القديم
+        const [existingSub] = await db
+          .select()
+          .from(subscriptionsTable)
+          .where(eq(subscriptionsTable.userId, legacyUser.id));
+
+        if (existingSub) {
+          // تحديث معرف المستخدم في الاشتراك للجديد
+          await db
+            .update(subscriptionsTable)
+            .set({ userId })
+            .where(eq(subscriptionsTable.userId, legacyUser.id));
+
+          const status: string = existingSub?.status ?? "none";
+          const hasAccess = status === "trialing" && existingSub?.trialEnd && new Date(existingSub.trialEnd) > now
+            ? true : status === "active" ? true : false;
+
+          return res.json({
+            userId, email: userEmail,
+            subscription: {
+              status,
+              trialEnd: existingSub?.trialEnd?.toISOString() ?? null,
+              currentPeriodEnd: existingSub?.currentPeriodEnd?.toISOString() ?? null,
+              paypalSubscriptionId: null,
+              hasAccess
+            },
+            isReturningUser: true  // 🆕
+          });
+        }
+      }
+    }
+
+    // ========== مستخدم جديد (لا يوجد له حساب قديم) ==========
     await db.insert(usersTable).values({
       id: userId,
       email: userEmail?.toLowerCase() ?? null,
@@ -81,7 +135,8 @@ router.get("/", async (req: Request, res: Response) => {
         currentPeriodEnd: sub?.currentPeriodEnd?.toISOString() ?? null,
         paypalSubscriptionId: null,
         hasAccess
-      }
+      },
+      isReturningUser: false  // 🆕
     });
   } catch (error) {
     return res.json({