Update bot_core.py

bot_core.py

@@ -38,12 +38,12 @@ RETRY_OVERALL_TIMEOUT = float(os.environ.get("RETRY_OVERALL_TIMEOUT", "60"))
 DEDUP_TTL_MINUTES     = int(os.environ.get("DEDUP_TTL_MINUTES", "600"))  # 10 jam
 MIN_MCAP_USD          = float(os.environ.get("MIN_MCAP_USD", "70000"))   # batas minimal MC
 
-# 2) BLACKLIST CALLER DI ISI PESAN (contoh: SKIP_CALLERS="@joko,@spamcaller")
+# Blacklist caller di isi pesan (contoh: SKIP_CALLERS="@joko,@spamcaller")
 SKIP_CALLERS_ENV = os.environ.get("SKIP_CALLERS", "")
 _SKIP_CALLERS = [h.lstrip("@").strip().lower() for h in SKIP_CALLERS_ENV.split(",") if h.strip()]
 
-# (Opsional) BLACKLIST SUMBER CHAT (skip kalau pesan berasal dari channel/grup tertentu)
-# Bisa isi campuran @username, t.me/username, t.me/c/<id>, atau -100...
+# (Opsional) blacklist sumber chat (channel/grup) → skip semua pesan dari sumber ini
+# Bisa campur @username, t.me/username, t.me/c/<id>, atau -100...
 SKIP_SOURCES_ENV = os.environ.get("SKIP_SOURCES", "")
 _SKIP_SOURCES_RAW = [s.strip() for s in SKIP_SOURCES_ENV.split(",") if s.strip()]
 
@@ -236,31 +236,28 @@ def _accept_ca(addr: str, current_source: str) -> bool:
 # ========= Siapkan daftar chats untuk decorator (harus normalisasi dulu) =========
 SOURCE_CHATS = [_normalize_chat(s) for s in SOURCE_CHATS_RAW]
 
-# (Opsional) normalisasi SKIP_SOURCES untuk dibandingkan dengan username sumber
+# (Opsional) normalisasi SKIP_SOURCES untuk dibandingkan cepat
 _SKIP_SOURCES = set()
 for s in _SKIP_SOURCES_RAW:
     ns = _normalize_chat(s)
-    # hanya handle username atau ID; untuk perbandingan cepat, kita simpan username lower
     if isinstance(ns, str):
-        _SKIP_SOURCES.add(_normalize_handle(ns))
+        _SKIP_SOURCES.add(_normalize_handle(ns))  # username lower
     else:
-        # kalau ID numerik, kita simpan sebagai string 'id:-100123...' agar bisa dibedakan
-        _SKIP_SOURCES.add(f"id:{ns}")
+        _SKIP_SOURCES.add(f"id:{ns}")             # ID numerik sebagai 'id:-100...'
 
-# ========= EVENT HANDLER =========
-@events.register(events.NewMessage(chats=SOURCE_CHATS))
+# ========= EVENT HANDLER (TERDAFTAR KE CLIENT) =========
+@client.on(events.NewMessage(chats=SOURCE_CHATS))
 async def on_message_from_sources(event: events.NewMessage.Event):
     src_label = _label_chat_from_event(event)
     txt = (event.raw_text or "").strip()
     logger.info("EVNT| pesan baru dari %s", src_label)
 
-    # (Opsional) Skip berdasarkan sumber chat
+    # (Opsional) Skip berdasarkan sumber chat (channel/grup)
     if _SKIP_SOURCES:
         src_user = _event_source_username(event)  # '' kalau tidak ada username
         if src_user and _normalize_handle(src_user) in _SKIP_SOURCES:
             logger.info("SKIP| sumber @%s ter-blacklist via SKIP_SOURCES", src_user)
             return
-        # Kalau sumber berupa ID numerik:
         if not src_user:
             try:
                 if f"id:{event.chat_id}" in _SKIP_SOURCES: