Update autotrack.py

autotrack.py

@@ -1,4 +1,4 @@
-# autotrack.py — Unlimited milestones + auto-delete on drawdown + video ≥3× (fixed)
+# autotrack.py — Unlimited milestones + auto-delete on drawdown + video ≥3× + daily summary hooks
 import os
 import re
 import time
@@ -36,7 +36,7 @@ BACKFILL_BUFFER_MINUTES = int(os.environ.get("BACKFILL_BUFFER_MINUTES", "3"))
 # Marker antirecursive: ditambahkan ke semua pengumuman bot (milestone)
 BOT_MARKER = "【MT-AUTOTRACK】"
 
-# Lokasi DB milik botsignal (untuk ambil msg_id pesan awal)
+# Lokasi DB milik botsignal (untuk ambil msg_id pesan awal + summary hooks)
 BOTSIGNAL_DB = os.environ.get("BOTSIGNAL_DB", "/tmp/botsignal.db")
 
 # NEW: Auto-delete bila drawdown >= threshold (rasio relatif terhadap entry)
@@ -145,6 +145,59 @@ def lookup_origin_msg_id(keyword: str) -> Optional[int]:
         print(f"[TRACK][DB] lookup error: {e}")
         return None
 
+# =========================
+# SUMMARY HOOKS (harian)
+# =========================
+def _summary_db():
+    conn = sqlite3.connect(BOTSIGNAL_DB)
+    conn.execute("PRAGMA journal_mode=WAL;")
+    return conn
+
+def summary_init_tables():
+    try:
+        conn = _summary_db()
+        conn.executescript("""
+        CREATE TABLE IF NOT EXISTS summary_milestones (
+            keyword TEXT NOT NULL,
+            reply_msg_id INTEGER,
+            multiple REAL,
+            replied_at INTEGER NOT NULL
+        );
+        CREATE TABLE IF NOT EXISTS summary_outcomes (
+            keyword TEXT PRIMARY KEY,
+            is_deleted INTEGER DEFAULT 0
+        );
+        """)
+        conn.commit()
+        conn.close()
+    except Exception as e:
+        print(f"[SUMMARY] init tables failed: {e}")
+
+def _summary_log_milestone(keyword: str, reply_msg_id: Optional[int], multiple: float, ts_utc: int):
+    try:
+        conn = _summary_db()
+        conn.execute(
+            "INSERT INTO summary_milestones(keyword, reply_msg_id, multiple, replied_at) VALUES(?,?,?,?)",
+            (keyword, reply_msg_id, float(multiple), int(ts_utc))
+        )
+        conn.commit()
+        conn.close()
+    except Exception as e:
+        print(f"[SUMMARY] log milestone failed: {e}")
+
+def _summary_mark_deleted(keyword: str):
+    try:
+        conn = _summary_db()
+        conn.execute(
+            "INSERT INTO summary_outcomes(keyword, is_deleted) VALUES(?,1) "
+            "ON CONFLICT(keyword) DO UPDATE SET is_deleted=1",
+            (keyword,)
+        )
+        conn.commit()
+        conn.close()
+    except Exception as e:
+        print(f"[SUMMARY] mark deleted failed: {e}")
+
 # =========================
 # Tracker core (UNLIMITED)
 # =========================
@@ -154,7 +207,7 @@ class TrackItem:
     basis: str = "mcap"  # "mcap" or "price"
     entry_price: Optional[float] = None
     entry_mcap: Optional[float] = None
-    symbol_hint: Optional[str] = None
+    symbol_hint: Optional[float] = None
     source_link: Optional[str] = None
     poll_secs: int = 20
     next_milestone: float = field(default_factory=lambda: REPLY_FROM_MULTIPLE)
@@ -266,6 +319,13 @@ class PriceTracker:
             await self.client.delete_messages(self.announce_chat, msg_id)
             print(f"[TRACK] Deleted origin message for {ca}")
 
+            # === Summary: mark lose
+            try:
+                if key:
+                    _summary_mark_deleted(key)
+            except Exception as e:
+                print(f"[SUMMARY] mark deleted hook err: {e}")
+
             if DELETE_THREAD_REPLIES:
                 try:
                     async for m in self.client.iter_messages(self.announce_chat, limit=100, reply_to=msg_id):
@@ -327,9 +387,11 @@ class PriceTracker:
                         text = self._milestone_text(item, item.next_milestone, ratio, cur_price, cur_mcap)
                         key = ca_key_for_db(item.ca)
                         reply_to_id = lookup_origin_msg_id(key) if key else None
+
+                        sent_msg = None
                         if item.next_milestone >= VIDEO_MIN_MULTIPLE and os.path.isfile(VIDEO_PATH):
                             try:
-                                await self.client.send_file(
+                                sent_msg = await self.client.send_file(
                                     self.announce_chat,
                                     VIDEO_PATH,
                                     caption=f"{text}\n\n{BOT_MARKER}",
@@ -339,12 +401,22 @@ class PriceTracker:
                             except Exception as e:
                                 print(f"[TRACK] gagal kirim video: {e}")
                         else:
-                            await self.client.send_message(
+                            sent_msg = await self.client.send_message(
                                 self.announce_chat,
                                 f"{text}\n\n{BOT_MARKER}",
                                 reply_to=reply_to_id if reply_to_id else None,
                                 link_preview=False
                             )
+
+                        # === Summary: log milestone (win signal)
+                        try:
+                            if key:
+                                ts_utc = int(time.time())
+                                rep_id = getattr(sent_msg, "id", None) if sent_msg else None
+                                _summary_log_milestone(key, rep_id, item.next_milestone, ts_utc)
+                        except Exception as e:
+                            print(f"[SUMMARY] milestone hook err: {e}")
+
                         item.next_milestone = self._next_target_after(item.next_milestone)
 
                     await asyncio.sleep(item.poll_secs)
@@ -435,6 +507,7 @@ def setup_autotrack(shared_client: TelegramClient, announce_chat: str | None = N
     global client, tracker, startup_time_utc
     client = shared_client
     ensure_db()
+    summary_init_tables()  # <<< summary tables
     ac = announce_chat or TARGET_CHAT
     tracker = PriceTracker(client, announce_chat=ac)
     startup_time_utc = datetime.now(timezone.utc)