Update periodic_tuner.py

periodic_tuner.py

@@ -1,5 +1,5 @@
 # ============================================================
-# 🗓️ periodic_tuner.py (V4.2 - GEM-Architect: Status Metrics)
+# 🗓️ periodic_tuner.py (V4.3 - GEM-Architect: Timer Persistence)
 # ============================================================
 
 import asyncio
@@ -164,7 +164,7 @@ class AutoTunerScheduler:
         self.trade_manager = trade_manager
         self.state_file = "scheduler_state.json"
         
-        # التوقيتات
+        # التوقيتات (ستيم تحميلها من R2)
         self.last_weekly_run = None
         self.last_monthly_run = None
         
@@ -176,7 +176,7 @@ class AutoTunerScheduler:
         logger.info("🕰️ [Scheduler] Auto-Tuner Armed & Ready.")
 
     async def start_loop(self):
-        await self._load_state()
+        await self._load_state() # Force Load on Start
         while True:
             try:
                 await asyncio.sleep(3600) 
@@ -204,11 +204,15 @@ class AutoTunerScheduler:
                     if state.get('last_monthly'):
                         self.last_monthly_run = datetime.fromisoformat(state['last_monthly'])
                     
-                    # استرجاع العدادات
                     self.weekly_count = state.get('weekly_count', 0)
                     self.monthly_count = state.get('monthly_count', 0)
-                    
                     logger.info(f"   🕰️ [Scheduler] State Restored (W:{self.weekly_count} | M:{self.monthly_count}).")
+                else:
+                    # ✅ FIX: إذا كان الملف جديداً، نبدأ التوقيت من "الآن" بدلاً من الانتظار
+                    logger.info("   🕰️ [Scheduler] New Instance. Initializing Clocks...")
+                    self.last_weekly_run = datetime.now()
+                    self.last_monthly_run = datetime.now()
+                    await self._save_state()
         except Exception: pass
 
     async def _save_state(self):
@@ -221,7 +225,6 @@ class AutoTunerScheduler:
             }
             if self.trade_manager.r2:
                 await self.trade_manager.r2.upload_json_async(state, self.state_file)
-                logger.info("   💾 [Scheduler] State Saved.")
         except Exception: pass
 
     def _needs_run(self, period_type):
@@ -266,7 +269,7 @@ class AutoTunerScheduler:
         finally:
             self.is_running = False
 
-    # ✅ دالة جلب المقاييس للواجهة
+    # ✅ دالة جلب المقاييس للواجهة (محسنة)
     def get_status_metrics(self):
         def _fmt_time(last_dt):
             if not last_dt: return "Pending"
@@ -275,10 +278,14 @@ class AutoTunerScheduler:
             h = diff.seconds // 3600
             return f"{d}d {h}h"
 
+        # إذا كانت None (لم يتم التحميل بعد)، نعيد Init
+        w_time = _fmt_time(self.last_weekly_run) if self.last_weekly_run else "Init..."
+        m_time = _fmt_time(self.last_monthly_run) if self.last_monthly_run else "Init..."
+
         return {
-            "weekly_timer": _fmt_time(self.last_weekly_run),
+            "weekly_timer": w_time,
             "weekly_count": self.weekly_count,
-            "monthly_timer": _fmt_time(self.last_monthly_run),
+            "monthly_timer": m_time,
             "monthly_count": self.monthly_count,
             "is_running": self.is_running
         }