Update botsignal.py

botsignal.py

@@ -4,6 +4,7 @@ import re
 import io
 import sqlite3
 import hashlib
+import random
 from collections import deque, defaultdict
 from datetime import datetime, timedelta, timezone
 from mimetypes import guess_extension
@@ -69,6 +70,10 @@ LB_TRIGGER = os.environ.get("LB_TRIGGER", "/lb")
 LEADERBOARD_BOT = os.environ.get("LEADERBOARD_BOT", "@PhanesGreenBot")
 LB_REQUIRE_MIN_RANKS = int(os.environ.get("LB_REQUIRE_MIN_RANKS", "0"))  # set 3 jika mau minimal 3 peringkat
 
+# ====== Scheduler interval (acak per JAM) ======
+LB_INTERVAL_MIN_HOURS = int(os.environ.get("LB_INTERVAL_MIN_HOURS", "3"))
+LB_INTERVAL_MAX_HOURS = int(os.environ.get("LB_INTERVAL_MAX_HOURS", "6"))
+
 # ====== Anti-spam Leaderboard (cooldown + dedup) ======
 LEADERBOARD_COOLDOWN_SEC = int(os.environ.get("LEADERBOARD_COOLDOWN_SEC", "600"))  # default 10 menit
 _last_lb_hash: Optional[str] = None
@@ -101,7 +106,6 @@ def _is_true_leaderboard(text: str) -> bool:
         return False
     if not re.search(r"📊\s*Group\s*Stats", text):
         return False
-    # opsional: pastikan ada minimal N baris ranking
     if LB_REQUIRE_MIN_RANKS > 0:
         ranks = re.findall(r"(?m)^\s*[\W\s]*\d{1,2}\s+.+\[[\d\.]+x\]\s*$", text)
         if len(ranks) < LB_REQUIRE_MIN_RANKS:
@@ -130,12 +134,12 @@ BACKFILL_BUFFER_MINUTES = int(os.environ.get("BACKFILL_BUFFER_MINUTES", "3"))
 UPDATE_STRATEGY = os.environ.get("UPDATE_STRATEGY", "reply").lower()
 UPDATE_COOLDOWN_SEC = int(os.environ.get("UPDATE_COOLDOWN_SEC", "5"))
 
-# Media flags (gunakan default aman; sesuaikan kalau kamu sudah punya env-nya)
+# Media flags
 INCLUDE_MEDIA = os.environ.get("INCLUDE_MEDIA", "0") == "1"
 ALLOW_GIFS_VIDEOS = os.environ.get("ALLOW_GIFS_VIDEOS", "0") == "1"
 MAX_MEDIA_MB = int(os.environ.get("MAX_MEDIA_MB", "8"))
 
-# Thematic keywords + relevance threshold (sesuaikan kalau sudah ada env)
+# Thematic keywords + relevance threshold
 THEME_KEYWORDS = [kw.strip().lower() for kw in os.environ.get(
     "THEME_KEYWORDS",
     "pump,call,entry,entries,sl,tp,launch,airdrop,gem,moon,ath,breakout"
@@ -161,8 +165,7 @@ def build_client() -> TelegramClient:
 client = build_client()
 recent_hashes: deque[str] = deque(maxlen=DEDUP_BUFFER_SIZE)
 recent_content_hashes: deque[str] = deque(maxlen=DEDUP_BUFFER_SIZE)  # content-only dedup
-# entity-based dedup (CA/$ticker)
-recent_entity_keys: deque[str] = deque(maxlen=DEDUP_BUFFER_SIZE)
+recent_entity_keys: deque[str] = deque(maxlen=DEDUP_BUFFER_SIZE)  # entity-based dedup
 
 # Peta id_chat -> "core" / "support"
 chat_roles: Dict[int, str] = {}  # diisi saat startup setelah resolve entity
@@ -198,7 +201,6 @@ def _init_db():
     conn.close()
 
 def db_load_state():
-    """Load last_posted & kw_group_seen into memory on startup."""
     conn = _db()
     last = {}
     for kw, mid, tier in conn.execute("SELECT keyword, msg_id, tier FROM last_posted"):
@@ -255,10 +257,10 @@ def _windows(tokens: List[str], size: int = 20):
     for i in range(0, len(tokens), size):
         yield " ".join(tokens[i : i + size])
 
-# --- Bersihkan URL/CA untuk kepentingan SCORING relevansi ---
+# --- Bersihkan URL/CA untuk skor relevansi ---
 CA_SOL_RE = re.compile(r"\b[1-9A-HJ-NP-Za-km-z]{32,48}\b")  # Solana base58 (perkiraan)
 CA_EVM_RE = re.compile(r"\b0x[a-fA-F0-9]{40}\b")  # EVM address
-CA_LABEL_RE = re.compile(r"\bCA\s*[:=]\s*\S+", re.IGNORECASE)  # "CA: ..." potong tokennya
+CA_LABEL_RE = re.compile(r"\bCA\s*[:=]\s*\S+", re.IGNORECASE)
 
 def _strip_urls_and_mentions(s: str) -> str:
     s = re.sub(r"https?://\S+", "", s)
@@ -267,10 +269,6 @@ def _strip_urls_and_mentions(s: str) -> str:
     return re.sub(r"\s+", " ", s).strip()
 
 def strip_contracts_for_scoring(s: str) -> str:
-    """
-    Hilangkan URL/mention, alamat kontrak, dan token setelah 'CA:'
-    agar kata 'pump' pada CA/URL (mis. pump.fun) tidak memengaruhi skor.
-    """
     s0 = _strip_urls_and_mentions(s)
     s1 = CA_LABEL_RE.sub(" ", s0)
     s2 = CA_EVM_RE.sub(" ", s1)
@@ -278,21 +276,14 @@ def strip_contracts_for_scoring(s: str) -> str:
     return re.sub(r"\s+", " ", s3).strip()
 
 def score_relevance(text: str, keywords: List[str]) -> float:
-    """Skor: exact keyword + fuzzy windowed (top-3 rata-rata) agar adil untuk teks panjang."""
     if not text:
         return 0.0
-
-    # Gunakan versi yang TIDAK mengandung URL/CA agar 'pump' di CA tidak ikut dihitung
     t = strip_contracts_for_scoring(text).lower()
-
-    # exact hits (unik)
     exact_hits = 0
     for kw in set(keywords):
         if kw in t or re.search(rf"\b{re.escape(kw)}\b", t):
             exact_hits += 1
     exact_score = exact_hits * KEYWORD_WEIGHT
-
-    # fuzzy windowed: ambil top-3 skor di antara jendela 20 token
     tokens = _tokenize_words(t)
     if not tokens:
         return exact_score
@@ -306,11 +297,9 @@ def score_relevance(text: str, keywords: List[str]) -> float:
         scores.append(best)
     fuzzy_top3 = sorted(scores, reverse=True)[:3]
     fuzzy_score = (sum(fuzzy_top3) / max(1, len(fuzzy_top3))) * FUZZ_WEIGHT if fuzzy_top3 else 0.0
-
     return exact_score + fuzzy_score
 
 def hash_for_dedup(text: str, msg) -> str:
-    """Hash campuran (lama) – menahan duplikat per pesan+media."""
     parts = [text or ""]
     if getattr(msg, "id", None) is not None:
         parts.append(str(msg.id))
@@ -326,7 +315,6 @@ def hash_for_dedup(text: str, msg) -> str:
     return hashlib.sha1(raw).hexdigest()
 
 def content_only_hash(text: str) -> str:
-    """Hash berbasis isi saja (untuk lintas-grup crosspost)."""
     norm = _strip_urls_and_mentions(normalize_for_filter(text))
     return hashlib.sha1(norm.encode("utf-8", errors="ignore")).hexdigest()
 
@@ -337,14 +325,12 @@ keyword_group_last_seen: defaultdict[str, dict[str, datetime]] = defaultdict(dic
 def _prune_expired(now: datetime) -> None:
     window = timedelta(minutes=CLASS_WINDOW_MINUTES)
     cutoff = now - window
-    # in-memory prune
     for kw, m in list(keyword_group_last_seen.items()):
         for gk, ts in list(m.items()):
             if ts < cutoff:
                 del m[gk]
         if not m:
             del keyword_group_last_seen[kw]
-    # db prune
     db_prune_expired(cutoff)
 
 def _classify_by_unique(unique_groups: int) -> Tuple[str, int]:
@@ -359,27 +345,18 @@ def _classify_by_unique(unique_groups: int) -> Tuple[str, int]:
 
 
 def update_and_classify(keyword: str, group_key: str, now: Optional[datetime] = None) -> Tuple[str, int, bool]:
-    """
-    Update 'last seen' untuk (keyword, group_key) dalam window.
-    Return: (class_label, unique_groups, is_new_group)
-    is_new_group = True hanya jika group_key BELUM tercatat di window aktif.
-    """
     if not now:
         now = datetime.now(timezone.utc)
     _prune_expired(now)
-
     bucket = keyword_group_last_seen[keyword]
     is_new_group = group_key not in bucket
-
-    # tulis/refresh timestamp (meski bukan grup baru, hanya memperbarui waktu)
     bucket[group_key] = now
     db_upsert_kw_seen(keyword, group_key, now)
-
     class_label, unique_groups = _classify_by_unique(len(bucket))
     return class_label, unique_groups, is_new_group
 
 
-# ========= Sentence-level invite filter (smarter) =========
+# ========= Sentence-level invite filter =========
 INVITE_PATTERNS = [
     r"\bjoin\b", r"\bjoin (us|our|channel|group)\b",
     r"\bdm\b", r"\bdm (me|gw|gue|gua|saya|admin)\b",
@@ -387,18 +364,14 @@ INVITE_PATTERNS = [
     r"\bvip\b", r"\bpremium\b", r"\bberbayar\b", r"\bpaid\b", r"\bexclusive\b",
     r"\bwhitelist\b", r"\bprivate( group| channel)?\b", r"\bmembership?\b",
     r"\bsubscribe\b", r"\blangganan\b",
-    # kata kunci promo/iklan
     r"\bpromo\b", r"\bpromosi\b", r"\biklan\b",
-    r"\badvert\b", r"\badvertise\b", r"\badvertisement\b",
-    # tautan undangan/shortener
     r"(t\.me\/joinchat|t\.me\/\+|telegram\.me\/|discord\.gg\/|wa\.me\/|whatsapp\.com\/)",
     r"(bit\.ly|tinyurl\.com|linktr\.ee)",
 ]
 INVITE_REGEXES = [re.compile(p, re.IGNORECASE) for p in INVITE_PATTERNS]
 
-# whitelist: kalimat yang nampak "sinyal asli", jangan dihapus
 WHITELIST_STRONG_SIGNAL = [
-    r"\$[a-z0-9]{2,10}",   # $TICKER
+    r"\$[a-z0-9]{2,10}",
     r"\b(entry|entries|buy|sell)\b",
     r"\bsl\b", r"\btp\b", r"\btp\d\b",
 ]
@@ -408,10 +381,8 @@ def _is_invite_sentence(s: str) -> bool:
     t = s.strip()
     if not t:
         return False
-    # Jika kalimat memuat sinyal kuat, jangan dibuang walau ada kata invite
     if any(r.search(t) for r in WHITELIST_REGEXES):
         return False
-    # Jika ada 1+ pola ajakan, buang
     return any(r.search(t) for r in INVITE_REGEXES)
 
 def filter_invite_sentences(text: str) -> str:
@@ -426,34 +397,21 @@ def filter_invite_sentences(text: str) -> str:
 
 # ========= Media helpers =========
 def is_image_message(msg) -> bool:
-    """
-    True untuk:
-      - Photo bawaan Telegram
-      - Image (image/*). Jika 'image/webp' (sticker), hormati SKIP_STICKERS
-      - GIF/Video hanya jika ALLOW_GIFS_VIDEOS=True
-    """
     if getattr(msg, "photo", None):
         return True
     doc = getattr(msg, "document", None)
     if not doc:
         return False
     mt = (getattr(doc, "mime_type", "") or "").lower()
-
-    # Skip sticker (sering berupa image/webp)
     SKIP_STICKERS = True
     if mt == "image/webp" and SKIP_STICKERS:
         return False
-
     if mt.startswith("image/"):
-        # GIF diizinkan hanya jika ALLOW_GIFS_VIDEOS=True
         if mt == "image/gif":
             return ALLOW_GIFS_VIDEOS
         return True
-
-    # Video diizinkan hanya jika ALLOW_GIFS_VIDEOS=True
     if mt.startswith("video/"):
         return ALLOW_GIFS_VIDEOS
-
     return False
 
 def media_too_big(msg) -> bool:
@@ -467,48 +425,33 @@ def media_too_big(msg) -> bool:
 
 
 # ========= Post-on-threshold with EDIT/REPLY/NEW (persisted) =========
-# Urutan tier baru (perlu untuk naik-turun tier aman)
 TIER_ORDER = {"Low 🌱": 0, "Medium ⚡": 1, "Strong 💪": 2, "FOMO 🔥": 3}
 
-last_posted: Dict[str, Dict[str, object]] = {}  # keyword -> {"msg_id": int, "tier": str}
-# simpan body & waktu update terakhir per entitas
+last_posted: Dict[str, Dict[str, object]] = {}
 last_body: Dict[str, str] = {}
 last_update_ts: Dict[str, float] = {}
 
 def format_body_with_spacing(body: str, tier_label: str) -> str:
-    """
-    Rapikan teks dengan menambahkan spasi antar bagian penting & header tier.
-    - Menyisipkan baris kosong sebelum: stats, ca, links, security, trade carefully
-    - Menghapus baris kosong berlebihan
-    - Menaruh [TIER] di paling atas + satu baris kosong
-    """
     if not body:
         return f"[{tier_label}]"
-
-    # Normalisasi pemisah baris & trimming
     raw_lines = [ln.strip() for ln in body.splitlines()]
-    raw_lines = [ln for ln in raw_lines if ln != ""]  # buang baris kosong berlebihan sejak awal
-
+    raw_lines = [ln for ln in raw_lines if ln != ""]
     formatted: List[str] = []
     trigger_words = ("stats", "ca", "links", "security", "trade carefully")
-
-    for i, line in enumerate(raw_lines):
+    for line in raw_lines:
         low = line.lower()
         if any(tw in low for tw in trigger_words):
             if formatted and formatted[-1] != "":
                 formatted.append("")
         formatted.append(line)
-
     pretty = "\n".join(formatted)
     pretty = re.sub(r"\n{3,}", "\n\n", pretty).strip()
-
     return f"[{tier_label}]\n\n{pretty}"
 
 async def _send_initial(msg, text: str) -> int:
     if DRY_RUN:
         print("[DRY_RUN] send_initial:", text[:140])
         return -1
-    # kirim media bila ada & allowed
     if INCLUDE_MEDIA and is_image_message(msg) and not media_too_big(msg):
         try:
             if getattr(msg, "photo", None):
@@ -546,15 +489,8 @@ async def _send_initial(msg, text: str) -> int:
         return await _send_initial(msg, text)
 
 async def post_or_update(keyword: str, body: str, new_tier: str, src_msg, *, update_like: bool = False, allow_tier_upgrade: bool = True) -> None:
-    """
-    allow_tier_upgrade: hanya True jika ada GRUP BARU yang berkontribusi
-    pada entitas dalam window; kalau False, meski class_label hasil hitung
-    lebih tinggi, kita TIDAK meng-upgrade tier.
-    """
     prev = last_posted.get(keyword)
     now_ts = datetime.now().timestamp()
-
-    # kirim pertama kali
     if not prev:
         text = format_body_with_spacing(body, new_tier)
         msg_id = await _send_initial(src_msg, text)
@@ -564,11 +500,9 @@ async def post_or_update(keyword: str, body: str, new_tier: str, src_msg, *, upd
         if msg_id != -1:
             db_save_last_posted(keyword, msg_id, new_tier)
         return
-
-    # Jika tier naik, cek dulu apakah diizinkan
     if TIER_ORDER.get(new_tier, 0) > TIER_ORDER.get(prev["tier"], 0):
         if not allow_tier_upgrade:
-            text = format_body_with_spacing(body, prev["tier"])  # no upgrade
+            text = format_body_with_spacing(body, prev["tier"])
             if not update_like:
                 return
             try:
@@ -585,8 +519,6 @@ async def post_or_update(keyword: str, body: str, new_tier: str, src_msg, *, upd
             except Exception as e:
                 debug_log("Update gagal (no-upgrade path)", str(e))
             return
-
-        # tier naik dan diizinkan
         try:
             text = format_body_with_spacing(body, new_tier)
             await client.edit_message(TARGET_CHAT, prev["msg_id"], text)
@@ -608,15 +540,10 @@ async def post_or_update(keyword: str, body: str, new_tier: str, src_msg, *, upd
             if msg_id != -1:
                 db_save_last_posted(keyword, msg_id, new_tier)
         return
-
-    # Tier sama: hanya proses jika ini update_like
     if not update_like:
         return
-
-    # Hindari spam: kalau body sama atau masih cooldown, no-op
     if body.strip() == last_body.get(keyword, "").strip() and (now_ts - last_update_ts.get(keyword, 0) < UPDATE_COOLDOWN_SEC):
         return
-
     try:
         text = format_body_with_spacing(body, new_tier)
         if UPDATE_STRATEGY == "edit":
@@ -646,7 +573,7 @@ async def post_or_update(keyword: str, body: str, new_tier: str, src_msg, *, upd
         debug_log("Update gagal (strategy)", str(e))
 
 
-# ========= Core actions (fallback kept) =========
+# ========= Core actions =========
 async def send_as_is(msg, text_override: Optional[str] = None) -> None:
     if DRY_RUN:
         print("[DRY_RUN] send_as_is:", (text_override or msg.message or "")[:140])
@@ -659,7 +586,6 @@ async def send_as_is(msg, text_override: Optional[str] = None) -> None:
         orig_text = msg.message or (getattr(msg, "raw_text", None) or "")
         entities = getattr(msg, "entities", None)
 
-    # ✅ perbaikan operator logika: gunakan 'and'
     if INCLUDE_MEDIA and is_image_message(msg) and not media_too_big(msg):
         try:
             if getattr(msg, "photo", None):
@@ -696,60 +622,36 @@ async def send_as_is(msg, text_override: Optional[str] = None) -> None:
         await client.send_message(TARGET_CHAT, orig_text, formatting_entities=entities, link_preview=True)
 
 
-# ========= Keyword extraction ($ticker-aware) =========
+# ========= Keyword & entity extraction =========
 TICKER_CLEAN_RE = re.compile(r"\$[A-Za-z0-9]{2,12}")
 TICKER_NOISY_RE = re.compile(r"\$[A-Za-z0-9](?:[^A-Za-z0-9]+[A-Za-z0-9]){1,11}")
 
 def _extract_tickers(text_norm: str) -> List[str]:
-    """
-    Ambil $TICKER dengan dua cara:
-    - Bersih: $ABC, $JBCOIN
-    - Noisy: $J*BCOIN -> dinormalisasi jadi $JBCOIN untuk *keyword* saja.
-      (Teks asli tetap dikirim apa adanya.)
-    """
     found = []
-
-    # bersih
     for m in TICKER_CLEAN_RE.finditer(text_norm):
         found.append(m.group(0).lower())
-
-    # noisy -> normalisasi internal
     for m in TICKER_NOISY_RE.finditer(text_norm):
         raw = m.group(0)
         norm = "$" + re.sub(r"[^A-Za-z0-9]+", "", raw[1:])
-        if 3 <= len(norm) <= 13:  # termasuk '$'
+        if 3 <= len(norm) <= 13:
             found.append(norm.lower())
-
-    # unik & pertahankan urutan
-    seen = set()
-    uniq = []
+    seen = set(); uniq = []
     for x in found:
         if x not in seen:
-            uniq.append(x)
-            seen.add(x)
+            uniq.append(x); seen.add(x)
     return uniq
 
 def _extract_all_keywords(text_norm: str) -> List[str]:
-    """
-    Deteksi SEMUA keyword dari THEME_KEYWORDS + $ticker.
-    Tidak menghapus simbol '$' (sesuai permintaan).
-    """
     t = re.sub(r"\$([a-z0-9]+)", r"\1", text_norm, flags=re.I)
-
     found = []
     for kw in THEME_KEYWORDS:
         if re.search(rf"(^|\W){re.escape(kw)}(\W|$)", t, flags=re.I):
             found.append(kw.lower())
-
-    tickers = _extract_tickers(text_norm)
-    found.extend(tickers)
-
-    uniq = []
-    seen = set()
-    for kw in found:
-        if kw not in seen:
-            uniq.append(kw)
-            seen.add(kw)
+    found.extend(_extract_tickers(text_norm))
+    seen = set(); uniq = []
+    for x in found:
+        if x not in seen:
+            uniq.append(x); seen.add(x)
     return uniq
 
 def _choose_dominant_keyword(text_norm: str, kws: List[str]) -> Optional[str]:
@@ -776,19 +678,15 @@ def _unique_counts_by_role(keyword: str) -> Tuple[int, int]:
         (core_ids if role == "core" else sup_ids).add(gk)
     return len(core_ids), len(sup_ids)
 
-
-# ========= Entity-key extraction (CA > $ticker) =========
 def extract_entity_key(text: str) -> Optional[str]:
     t = normalize_for_filter(text)
     m_evm = CA_EVM_RE.search(t)
     m_sol = CA_SOL_RE.search(t)
     if m_evm or m_sol:
         if m_evm:
-            addr = m_evm.group(0).lower()
-            return f"ca:evm:{addr}"
+            return f"ca:evm:{m_evm.group(0).lower()}"
         else:
-            addr = m_sol.group(0)
-            return f"ca:sol:{addr}"
+            return f"ca:sol:{m_sol.group(0)}"
     tickers = _extract_tickers(t.lower())
     if tickers:
         return f"ticker:{tickers[0][1:].lower()}"
@@ -797,17 +695,10 @@ def extract_entity_key(text: str) -> Optional[str]:
 
 # ========= NEW: Filter Phanes di jalur umum =========
 async def _is_phanes_and_not_leaderboard(msg, text: str) -> bool:
-    """
-    True jika pesan berasal dari Phanes (via_bot atau username pengirim === bot Phanes)
-    DAN bukan teks leaderboard. Pesan seperti ini akan diabaikan di jalur umum.
-    """
     try:
-        # via inline bot
         if getattr(msg, "via_bot_id", None) and PHANES_BOT_ID is not None:
             if int(msg.via_bot_id) == int(PHANES_BOT_ID):
                 return not _is_true_leaderboard(text or "")
-
-        # username sender
         sender = await msg.get_sender()
         uname = (getattr(sender, "username", "") or "").lower()
         if uname == LEADERBOARD_BOT.lstrip("@").lower():
@@ -821,7 +712,6 @@ async def process_message(msg, source_chat_id: int) -> None:
     orig_text = msg.message or (getattr(msg, "raw_text", None) or "")
     text_norm = normalize_for_filter(orig_text).lower()
 
-    # === HARD FILTER: jika ini pesan Phanes non-leaderboard, skip total ===
     if await _is_phanes_and_not_leaderboard(msg, orig_text):
         debug_log("Skip: pesan Phanes non-leaderboard", orig_text)
         return
@@ -927,7 +817,7 @@ async def on_new_message(event):
     except Exception as e:
         print(f"Process error di chat {event.chat_id}: {e}")
 
-# === Leaderboard listener (KHUSUS grup + filter via_bot/username + pola teks + anti-spam) ===
+# === Leaderboard listener (ketat) ===
 @client.on(events.NewMessage(chats=(LEADERBOARD_GROUP,)))
 async def on_leaderboard_reply(event):
     try:
@@ -936,9 +826,7 @@ async def on_leaderboard_reply(event):
         if not text:
             return
 
-        # --- Pastikan sumbernya memang Phanes bot (inline atau username) ---
         ok_source = False
-
         if getattr(msg, "via_bot_id", None) and PHANES_BOT_ID is not None:
             if int(msg.via_bot_id) == int(PHANES_BOT_ID):
                 ok_source = True
@@ -955,11 +843,9 @@ async def on_leaderboard_reply(event):
         if not ok_source:
             return
 
-        # --- HANYA ambil leaderboard utama (header wajib) ---
         if not _is_true_leaderboard(text):
             return
 
-        # ===== Dedup + cooldown dengan hash yang dinormalisasi =====
         global _last_lb_hash, _last_lb_ts
         h = _hash_text_1line(_normalize_lb_for_hash(text))
         now = asyncio.get_event_loop().time()
@@ -968,13 +854,43 @@ async def on_leaderboard_reply(event):
         _last_lb_hash = h
         _last_lb_ts = now
 
-        # Forward apa adanya ke TARGET_CHAT
         await send_as_is(msg)
         debug_log("Forward Leaderboard", text[:120])
     except Exception as e:
         debug_log("LB forward error", str(e))
 
 
+# ========= Scheduler: /lb acak per JAM =========
+async def periodic_lb_trigger():
+    """Kirim /lb ke LEADERBOARD_GROUP tiap interval acak (jam)."""
+    try:
+        lb_ent = await client.get_entity(LEADERBOARD_GROUP)
+    except Exception as e:
+        print(f"[LB-SCHED] Gagal resolve LEADERBOARD_GROUP: {e} — retry 5m")
+        await asyncio.sleep(300)
+        return asyncio.create_task(periodic_lb_trigger())
+
+    while True:
+        try:
+            wait_min = max(1, LB_INTERVAL_MIN_HOURS)
+            wait_max = max(wait_min + 1, LB_INTERVAL_MAX_HOURS)
+            delta_hr = random.randint(wait_min, wait_max)
+            jitter_min = random.randint(1, 10)
+            sleep_s = delta_hr * 3600 + jitter_min * 60
+
+            print(f"[LB-SCHED] Next /lb in ~{delta_hr}h {jitter_min}m")
+            await asyncio.sleep(sleep_s)
+
+            await client.send_message(lb_ent, LB_TRIGGER)
+            print("[LB-SCHED] /lb sent")
+        except FloodWaitError as fw:
+            print(f"[LB-SCHED] FloodWait {fw.seconds}s, menunggu...")
+            await asyncio.sleep(fw.seconds + 2)
+        except Exception as e:
+            print(f"[LB-SCHED] Error: {e} — cooldown 5m & lanjut")
+            await asyncio.sleep(300)
+
+
 # ========= Entry points =========
 async def _resolve_and_tag_chats(raw_list, role_label: str) -> list:
     resolved = []
@@ -992,22 +908,20 @@ async def start_bot_background() -> None:
     await client.start()
     _init_db()
 
-    # Load persisted state
     global last_posted, keyword_group_last_seen, PHANES_BOT_ID
     last_posted, keyword_group_last_seen = db_load_state()
 
     await _resolve_and_tag_chats(CORE_CHATS, "core")
     await _resolve_and_tag_chats(SUPPORT_CHATS, "support")
 
-    # Resolve bot Phanes (untuk via_bot_id)
     try:
         ph_ent = await client.get_entity(LEADERBOARD_BOT)
         PHANES_BOT_ID = abs(int(ph_ent.id))
         print(f"Resolved Phanes bot id: {PHANES_BOT_ID}")
     except Exception as e:
-        print(f"Gagal resolve LEADERBOARD_BOT: {e} (akan fallback ke pola teks)")
+        print(f"Gagal resolve LEADERBOARD_BOT: {e} (fallback pola teks)")
 
-    # resolve & TRIGGER SEKALI untuk percobaan
+    # (opsional) trigger awal
     try:
         lb_ent = await client.get_entity(LEADERBOARD_GROUP)
         await client.send_message(lb_ent, LB_TRIGGER)
@@ -1015,7 +929,9 @@ async def start_bot_background() -> None:
     except Exception as e:
         print(f"Gagal resolve/trigger leaderboard group: {e}")
 
-    # Tidak ada backfill (ANTI-NYEPAM)
+    # === START SCHEDULER /lb acak per JAM ===
+    asyncio.create_task(periodic_lb_trigger())
+
     print("Kurator berjalan (background task). Menunggu pesan baru...")
     asyncio.create_task(client.run_until_disconnected())
 
@@ -1030,15 +946,14 @@ async def app_main() -> None:
     await _resolve_and_tag_chats(CORE_CHATS, "core")
     await _resolve_and_tag_chats(SUPPORT_CHATS, "support")
 
-    # Resolve bot Phanes (untuk via_bot_id)
     try:
         ph_ent = await client.get_entity(LEADERBOARD_BOT)
         PHANES_BOT_ID = abs(int(ph_ent.id))
         print(f"Resolved Phanes bot id: {PHANES_BOT_ID}")
     except Exception as e:
-        print(f"Gagal resolve LEADERBOARD_BOT: {e} (akan fallback ke pola teks)")
+        print(f"Gagal resolve LEADERBOARD_BOT: {e} (fallback pola teks)")
 
-    # Trigger /lb sekali (tanpa jadwal) untuk tes
+    # (opsional) trigger awal
     try:
         lb_ent = await client.get_entity(LEADERBOARD_GROUP)
         await client.send_message(lb_ent, LB_TRIGGER)
@@ -1046,8 +961,12 @@ async def app_main() -> None:
     except Exception as e:
         print(f"Gagal trigger leaderboard group: {e}")
 
+    # === START SCHEDULER /lb acak per JAM ===
+    asyncio.create_task(periodic_lb_trigger())
+
     print("Kurator berjalan. Menunggu pesan baru... (Stop dengan interrupt).")
     await client.run_until_disconnected()
     
+
 if __name__ == "__main__":
     asyncio.run(app_main())