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

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

@@ -51,41 +51,67 @@ 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();
+      const [legacyUser] = await db
+        .select({
+          id: usersTable.id,
+          email: usersTable.email,
+        })
+        .from(usersTable)
+        .where(eq(usersTable.email, userEmail.toLowerCase()))
+        .limit(1);
 
       if (legacyUser) {
-        console.log(`🔗 ربط المستخدم ${userEmail}: القديم=${legacyUser.id} ← الجديد=${userId}`);
-        
-        // تحديث المستخدم القديم ليرتبط بالجديد
-        await supabase
-          .from('users')
-          .update({ 
-            supabase_id: userId,
-            updated_at: now.toISOString()
-          })
-          .eq('id', legacyUser.id);
-
-        // 🎯 استخدم اشتراك المستخدم القديم
+        console.log(`🔗 ربط: ${userEmail} | القديم=${legacyUser.id} | الجديد=${userId}`);
+
+        // جلب اشتراك المستخدم القديم
         const [existingSub] = await db
           .select()
           .from(subscriptionsTable)
           .where(eq(subscriptionsTable.userId, legacyUser.id));
 
         if (existingSub) {
-          // تحديث معرف المستخدم في الاشتراك للجديد
+          // إذا كان userId مختلف، نحذف الاشتراك الجديد أولاً ثم ننقل القديم
+          if (legacyUser.id !== userId) {
+            // حذف الاشتراك الجديد (التجريبي الذي أنشئ عند أول دخول)
+            await db
+              .delete(subscriptionsTable)
+              .where(eq(subscriptionsTable.userId, userId));
+
+            // نقل الاشتراك القديم للمستخدم الجديد
+            await db
+              .update(subscriptionsTable)
+              .set({ userId })
+              .where(eq(subscriptionsTable.userId, legacyUser.id));
+          }
+
+          // تحديث بيانات المستخدم
           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;
+            .insert(usersTable)
+            .values({
+              id: userId,
+              email: userEmail.toLowerCase(),
+              isBanned: false,
+              lastSeenAt: now
+            })
+            .onConflictDoUpdate({
+              target: usersTable.id,
+              set: {
+                email: userEmail.toLowerCase(),
+                lastSeenAt: now,
+              },
+            });
+
+          let status: string = existingSub?.status ?? "none";
+          let hasAccess = false;
+
+          if (status === "trialing") {
+            hasAccess = existingSub.trialEnd ? existingSub.trialEnd > now : false;
+            if (!hasAccess) status = "trial_expired";
+          } else if (status === "trial_expired" || status === "expired") {
+            hasAccess = false;
+          } else if (status === "active") {
+            hasAccess = !existingSub.currentPeriodEnd || existingSub.currentPeriodEnd > now;
+          }
 
           return res.json({
             userId, email: userEmail,
@@ -96,7 +122,7 @@ router.get("/", async (req: Request, res: Response) => {
               paypalSubscriptionId: null,
               hasAccess
             },
-            isReturningUser: true  // 🆕
+            isReturningUser: true,
           });
         }
       }
@@ -124,8 +150,14 @@ router.get("/", async (req: Request, res: Response) => {
     }
 
     let status: string = sub?.status ?? "none";
-    let hasAccess = status === "trialing" && sub?.trialEnd && new Date(sub.trialEnd) > now
-      ? true : status === "active" ? true : false;
+    let hasAccess = false;
+
+    if (status === "trialing") {
+      hasAccess = sub?.trialEnd ? new Date(sub.trialEnd) > now : false;
+      if (!hasAccess) status = "trial_expired";
+    } else if (status === "active") {
+      hasAccess = !sub?.currentPeriodEnd || new Date(sub.currentPeriodEnd) > now;
+    }
 
     return res.json({
       userId, email: userEmail,
@@ -136,9 +168,10 @@ router.get("/", async (req: Request, res: Response) => {
         paypalSubscriptionId: null,
         hasAccess
       },
-      isReturningUser: false  // 🆕
+      isReturningUser: false,
     });
   } catch (error) {
+    console.error("[me] خطأ:", error);
     return res.json({
       userId, email: userEmail,
       subscription: { status: "trialing", trialEnd: buildTrialEnd().toISOString(), currentPeriodEnd: null, paypalSubscriptionId: null, hasAccess: true }