Update app.py

app.py

@@ -312,7 +312,13 @@ def api_verify_code():
             try: await client.disconnect()
             except: pass
             
-            await db_query(lambda: supabase.table('user_sessions').insert({"user_id": user_id, "session_string": session_string}).execute())
+            # 📌 UPDATE: Added 'phone' field to be saved in DB
+            await db_query(lambda: supabase.table('user_sessions').insert({
+                "user_id": user_id, 
+                "phone": phone, 
+                "session_string": session_string
+            }).execute())
+            
             if phone in temp_clients: del temp_clients[phone]
             return {"status": "ok"}
             
@@ -398,7 +404,7 @@ async def save_progress(source_id, dest_id, msg_id):
             await db_query(lambda: supabase.table('clone_progress').insert({'source_id': source_id, 'dest_id': dest_id, 'last_copied_id': msg_id}).execute())
     except Exception as e: print(f"Error saving progress: {e}")
 
-# ================= FIXED: AUTO BROADCAST TO NEW GROUPS =================
+# ================= AUTO BROADCAST TO NEW GROUPS =================
 @bot.on_message(filters.new_chat_members)
 async def bot_added_to_group(client, message):
     me = client.me
@@ -421,7 +427,6 @@ async def bot_added_to_group(client, message):
                     try: await client.send_message(chat_id=admin_id, text=admin_msg, parse_mode=enums.ParseMode.HTML)
                     except: pass
 
-                # Fetching the latest broadcasted video stored with marker dest_id = 0
                 progress_res = await db_query(lambda: supabase.table('clone_progress').select('source_id', 'last_copied_id').eq('dest_id', 0).execute())
                 
                 if progress_res.data: