feat: VOTE ULANG SEGERA Telegram notification + emoticon on all notifications

- telegram.py: emoticons on all existing notif (🚀✅⚠️🔴💰🔍) + new notify_warn for expiring voters
- db.py: voter_notify table (owner/urgency/notified_at) for state-change dedup
- get_voters.py: _notify_warn() after persist() — urgency escalation ⚠️/🔴/🚨 by days remaining
- Dockerfile.scan: add telegram.py to COPY
- test_get_voters.py: 15 new V66 assertions (schema, record, cleanup, integration, escalation)
- test_distribute.py: updated notification format assertions
- SPEC.md: V66 + B26

Dockerfile.scan

@@ -10,6 +10,6 @@ WORKDIR /app
 COPY requirements.txt .
 RUN pip install --no-cache-dir -r requirements.txt
 
-COPY config.py db.py get_voters.py scan_loop.py ./
+COPY config.py db.py get_voters.py scan_loop.py telegram.py ./
 
 CMD ["python", "scan_loop.py"]

SPEC.md

@@ -132,6 +132,7 @@ V62: stempel scan UTC-naive (B24): `get_voters.persist` menulis `scanned_at`/`fi
 V63: jeda antar kirim distribusi: send-loop `run_distribution` tidur `DISTRIBUTE_SEND_DELAY` (int, default 30) detik ANTAR pemilih — setelah pemilih ke-i selesai diproses (sent/hold/failed), sebelum pemilih i+1; N pemilih → N−1 tidur, ⊖ tidur setelah pemilih TERAKHIR; real-run saja (dry-run ⊖ tidur — tak ada kirim). Tujuan: beri node/Hyperion waktu mengejar indeks + meratakan beban broadcast run panjang; jeda seragam terlepas hasil pemilih sebelumnya (pacing deterministik utk oracle). Oracle test_distribute V63: 3 pemilih → sleep dipanggil 2× dgn nilai `DISTRIBUTE_SEND_DELAY` | V63,V21,V22
 V64: banner BERITA hermetik utk oracle (B25): route index menghitung jam via helper modul `_now()` (isi = `datetime.now()` lokal, ⊖ inline di route) & mengoper ke `_next_schedule(now)`/`_recurrence_label(now)` — test mock `dashboard._now` ke tanggal TETAP (sebelum/sesudah launch) sehingga asersi baris-berulang ⊖ bergantung jam dinding nyata; tanpa ini, setelah tanggal first-run baked (2026-08-17) LEWAT di kalender, `_is_first_run_next(real_now)` ⊖ pernah True (`start >= now` gagal) → baris berulang tampil → asersi "TAK tampil saat first-run" gagal walau `_next_schedule` sudah di-mock (B25; test lulus hanya kalau kalender < tanggal launch). Oracle test_dashboard V38: mock `_now` sebelum launch → baris hilang; sesudah launch → baris muncul | V64,V38,V44
 V65: semua stempel data (audit trail, pembayaran, klaim) UTC-naive konsisten — `distribute.py` `created_at`, `db.py` `updated_at` (update_payment_status), `db.py` `now` (update_claim_fee) memakai `datetime.now(timezone.utc).replace(tzinfo=None)` — sama basis dengan `get_voters.persist` (V62), `eligible_voters` (V57), semua cutoff umur dashboard; ⊖ `datetime.now()` lokal yang menghasilkan WIB (UTC+7) dan merusak perbandingan string UTC. Oracle: test_distribute + test_claim tetap hijau | V65,V62,V57,V40,V52
+V66: notifikasi VOTE ULANG SEGERA via Telegram + emoticon pada SEMUA notifikasi: `get_voters._notify_warn(now)` setelah `persist()` — query pemilih dalam jendela `now−STALE < last_vote ≤ now−(STALE−WARN)` dari tabel `voters`, hitung urgensi dari sisa hari (≤1d=🚨/3, ≤2d=🔴/2, >2d=⚠️/1), filter yg sdh diberi tahu pada level ≥ urgensi saat ini (tabel `voter_notify`, state-change-only → max 3 notif/pemilih per jendela), kirim via `telegram.notify_warn` ke KOMUNITAS (daftar max 50 + link per-akun `mining.databisnis.id?q={owner}`), catat ke `voter_notify`, bersihkan baris stale. Tabel `voter_notify` (owner PK, urgency INT, notified_at TEXT) — `ensure_notify_schema`/`get_notify_urgency`/`record_notify`/`cleanup_notify` di `db.py`. `Dockerfile.scan` salin `telegram.py`. SEMUA notifikasi Telegram (`notify_start`/`notify_finish`/`notify_failure`/`notify_claim`/`notify_claim_unmeasured`/`notify_claim_failure`) kini punya emoticon prefix (🚀/✅/⚠️/🔴/💰/🔍). Oracle test_get_voters V66: voter_notify schema + record/get/cleanup + _notify_warn integrasi (mock telegram) + skip redundancy + escalation trigger | V66,V62,V40
 V35: kill-switch distribusi `DISTRIBUTE_ENABLED` default false → run nyata (bukan dry-run) no-op: exit 0, ⊥ baca saldo, ⊥ tanda tangan, ⊥ tulis DB, ⊥ notif; `--dry-run` tetap menampilkan rencana (read-only); nilai `true`/`1`/`yes` → normal
 V36: notifikasi klaim reward (sukses `notify_claim` & gagal `notify_claim_failure`) → kanal INTERNAL saja, ⊥ pernah ke KOMUNITAS (V30); fee gagal ⊥ spam — satu notif per klaim (saat transisi ke `failed`)
 V37: jadwal distribusi MINGGUAN (⊥ harian): `distribute_loop` menunggu `DISTRIBUTE_WEEKDAY` — SATU hari (`sat`) atau CSV beberapa hari (`wed,sat`), nama `mon`..`sun` atau 0-6 (V44: multi-hari, event terdekat di antara hari-hari terdaftar) — jam `DISTRIBUTE_HOUR` (lokal TZ); plus satu one-off `DISTRIBUTE_FIRST_RUN` (`YYYY-MM-DD`; default baked `2026-08-17`) yang diambil bila lebih dekat dari mingguan; setelah lewat (atau ⊥ diset) → hanya mingguan; batas dihitung ulang tiap iterasi loop (setelah run → jadwal berikutnya); payout di-tunda bila `DISTRIBUTE_ENABLED=false` (V35) — jadwal tetap maju, run jadi no-op; `distribute_loop.main` baca jadwal via `config` (⊥ `os.getenv` sendiri) agar konsisten dgn dashboard V38
@@ -225,3 +226,4 @@ B22|2026-08-13|`_send_rejected` BLACKLIST (deteksi `error` di body) — body 500
 B23|2026-08-13|respons `/v2/*` bentuk non-dict (200-an `[...]`/`"..."` dari proxy salah) → `AttributeError: 'list' object has no attribute 'get'` DII DALAM `except RequestException` → run distribusi BEBENTI total; sama di `verify_txid`/`reward_from_tx`/`dashboard._get_liquid_vex`|guard `isinstance(data, dict)` di semua pembaca `/v2/*` → non-dict → skip/skip-node/None (V61, F5); oracle `_get_json`/`verify_txid` non-dict → None
 B24|2026-08-17|`first_seen_at`/`scanned_at` tersimpan WIB (UTC+7) tapi dibandingkan sbg string UTC di SEMUA cutoff umur (dashboard + `db.eligible_voters` + distribusi): `get_voters.persist` memakai `datetime.now()` (waktu lokal container `TZ=Asia/Jakarta`) sedangkan cutoff pakai `datetime.now(timezone.utc)` — offset +7 jam membuat pemilih BARU tampak belum matang ~7 jam lebih lama (kasus nyata: idrsaku33351/m4dhanchocil/danuprasetya first_seen 13 Agt 17:39 WIB, seharusnya matang 16 Agt 17:39 WIB, kode melepas dari BARU baru 17 Agt 00:39 WIB)|`persist` stempel UTC-naive (`datetime.now(timezone.utc).replace(tzinfo=None)`); migrasi data existing WIB→UTC (−7 jam) dgn backup `*_bak_wib` (V62); oracle V62 guard stempel ≈ now-UTC ⊖ WIB
 B25|2026-08-19|oracle V38 HTML-render bergantung jam dinding nyata: route index `_now = datetime.now()` inline → `_recurrence_label(real_now)` → `_is_first_run_next` cek `start >= now` — setelah tanggal first-run baked (2026-08-17) LEWAT di kalender nyata, `start >= now` ⊖ pernah True → baris berulang `SETIAP RABU & SABTU` tampil → asersi "baris berulang TAK tampil saat first-run" GAGAL walau `_next_schedule` sudah di-mock ke 2026-08-17 (test lulus hanya kalau kalender nyata < tanggal launch)|route pakai helper modul `_now()` injectable + oracle mock `dashboard._now` ke tanggal tetap sebelum/sesudah launch (V64)
+B26|2026-08-27|tidak ada notifikasi Telegram untuk pemilih yang masuk jendela VOTE ULANG SEGERA — pemilih hanya terlihat di dashboard dgn badge amber, ⊥ alert proaktif ke komunitas → vote kedaluwarsa tanpa peringatan|`get_voters._notify_warn` + `telegram.notify_warn` + tabel `voter_notify` utk state-change dedup + emoticon pada SEMUA notifikasi (V66)

db.py

@@ -388,6 +388,94 @@ def record_first_seen(rows, scanned_at):
         conn.close()
 
 
+# ——————————————————————————————————————————————————————————————————————
+# V66: Notifikasi VOTE ULANG SEGERA — tabel lacak siapa sudah diberi tahu
+# pada level urgensi berapa. Satu baris per owner (PK), di-update saat
+# urgensi naik. Bersihkan otomatis saat pemilih keluar dari jendela warn.
+# ——————————————————————————————————————————————————————————————————————
+
+_NOTIFY_COLS = (
+    'owner VARCHAR(13) PRIMARY KEY, '
+    'urgency INTEGER NOT NULL, '
+    'notified_at TEXT NOT NULL'
+)
+_NOTIFY_DDL_SQLITE = (f'CREATE TABLE IF NOT EXISTS voter_notify '
+                     f'({_NOTIFY_COLS})')
+_NOTIFY_DDL_MYSQL = (f'CREATE TABLE IF NOT EXISTS voter_notify '
+                    f'({_NOTIFY_COLS})')
+
+
+def ensure_notify_schema():
+    """Buat tabel lacak notifikasi VOTE ULANG SEGERA bila belum ada (idempoten)."""
+    conn = connect()
+    try:
+        cur = conn.cursor()
+        if DB_BACKEND == 'sqlite':
+            cur.execute(_NOTIFY_DDL_SQLITE)
+        else:
+            cur.execute(_NOTIFY_DDL_MYSQL)
+        conn.commit()
+    finally:
+        conn.close()
+
+
+def get_notify_urgency(owner):
+    """V66: ambil level urgensi terakhir yang sudah diberi tahu utk `owner`.
+
+    Kembalikan integer (1/2/3) atau None bila belum pernah diberi tahu.
+    """
+    ensure_notify_schema()
+    row = queryone(
+        'SELECT urgency FROM voter_notify WHERE owner = %s', (owner,))
+    return row[0] if row else None
+
+
+def record_notify(owner, urgency, notified_at):
+    """V66: catat bahwa `owner` sudah diberi tahu pada level `urgency`.
+
+    INSERT OR IGNORE (baru) + UPDATE bila urgensi naik (tidak turun).
+    Idempoten — safe dipanggil berulang.
+    """
+    ensure_notify_schema()
+    conn = connect()
+    try:
+        cur = conn.cursor()
+        if DB_BACKEND == 'sqlite':
+            cur.execute(
+                'INSERT OR IGNORE INTO voter_notify '
+                '(owner, urgency, notified_at) VALUES (?, ?, ?)',
+                (owner, urgency, notified_at))
+            cur.execute(
+                'UPDATE voter_notify SET urgency = ?, notified_at = ? '
+                'WHERE owner = ? AND urgency < ?',
+                (urgency, notified_at, owner, urgency))
+        else:
+            cur.execute(
+                'INSERT INTO voter_notify '
+                '(owner, urgency, notified_at) VALUES (%s, %s, %s) '
+                'ON DUPLICATE KEY UPDATE '
+                'urgency = IF(%s > urgency, %s, urgency), '
+                'notified_at = IF(%s > urgency, %s, notified_at)',
+                (owner, urgency, notified_at, urgency, urgency,
+                 urgency, notified_at))
+        conn.commit()
+    finally:
+        conn.close()
+
+
+def cleanup_notify(cutoff):
+    """V66: hapus baris notifikasi yang sudah lewat jendela warn (stale)."""
+    ensure_notify_schema()
+    conn = connect()
+    try:
+        cur = conn.cursor()
+        cur.execute(_translate(
+            'DELETE FROM voter_notify WHERE notified_at < %s'), (cutoff,))
+        conn.commit()
+    finally:
+        conn.close()
+
+
 def eligible_voters(owner=None):
     """V57: pemilih yang memenuhi syarat reward (single source, dipakai
     `distribute.py` + endpoint `/api/voter/<owner>`).

get_voters.py

@@ -15,7 +15,9 @@ from datetime import datetime, timedelta, timezone
 import requests
 
 import db
-from config import API_NODE, MIN_STAKED_VEX, TARGET_BP
+import telegram
+from config import (API_NODE, MIN_STAKED_VEX, TARGET_BP,
+                    VEX_EXPIRED_DAYS, VEX_STALE_DAYS, VEX_WARN_DAYS)
 
 # Kontrak & scope sistem Vexanium = vexcore (BUKAN vexio sesuai konvensi EOS)
 CODE = 'vexcore'
@@ -175,6 +177,48 @@ def summarize(rows, scanned_at):
               f"{row['staked']:,.4f} VEX - Bobot: {row['weight']}")
 
 
+def _notify_warn(now):
+    """V66: kirim notifikasi VOTE ULANG SEGERA ke komunitas.
+
+    Query pemilih dalam jendela `now − STALE < last_vote ≤ now − (STALE − WARN)`,
+    hitung urgensi berdasarkan sisa hari (1=⚠️ >2h, 2=🔴 ≤2h, 3=🚨 ≤1h),
+ filter yang sudah diberi tahu pada level ≥ urgensi saat ini, kirim
+    via Telegram, catat ke `voter_notify`. Bersihkan baris stale.
+    """
+    stale_cutoff = (now - timedelta(days=VEX_STALE_DAYS)).isoformat(timespec='seconds')
+    warn_cutoff = (now - timedelta(days=VEX_STALE_DAYS - VEX_WARN_DAYS)).isoformat(
+        timespec='seconds')
+    rows = db.query(
+        'SELECT v.owner, v.staked, v.last_vote FROM voters v '
+        'WHERE v.last_vote > %s AND v.last_vote <= %s',
+        (stale_cutoff, warn_cutoff))
+    if not rows:
+        db.cleanup_notify((now - timedelta(days=VEX_EXPIRED_DAYS)).isoformat(
+            timespec='seconds'))
+        return
+    to_notify = []
+    for owner, staked, last_vote in rows:
+        vote_dt = datetime.fromisoformat(last_vote)
+        days_left = VEX_STALE_DAYS - (now - vote_dt).days
+        if days_left <= 1:
+            urgency = 3
+        elif days_left <= 2:
+            urgency = 2
+        else:
+            urgency = 1
+        prev = db.get_notify_urgency(owner)
+        if prev is not None and prev >= urgency:
+            continue
+        to_notify.append((owner, f'{staked:,.4f}', urgency))
+    if to_notify:
+        telegram.notify_warn(to_notify)
+        for owner, _, urgency in to_notify:
+            db.record_notify(owner, urgency,
+                             now.isoformat(timespec='seconds'))
+    db.cleanup_notify((now - timedelta(days=VEX_EXPIRED_DAYS)).isoformat(
+        timespec='seconds'))
+
+
 def main():
     """Titik masuk CLI."""
     print(f'Mulai memindai voters untuk BP: "{TARGET_BP}"...')
@@ -186,6 +230,7 @@ def main():
         if item is not None:
             filtered.append(item)
     scanned_at = persist(filtered)
+    _notify_warn(now)
     summarize(filtered, scanned_at)
     return 0
 

telegram.py

@@ -1,10 +1,12 @@
-"""Kirim notifikasi status distribusi + klaim via Telegram Bot API (best-effort).
+"""Kirim notifikasi status distribusi + klaim + warn via Telegram Bot API (best-effort).
 
 Dua kanal (V30/V36): KOMUNITAS (`TELEGRAM_COMMUNITY_CHAT_IDS`) hanya brief
-mulai/selesai distribusi; INTERNAL (`TELEGRAM_INTERNAL_CHAT_IDS`) detail
-distribusi + semua kegagalan + klaim reward (⊥ komunitas). Token tunggal
+mulai/selesai distribusi + VOTE ULANG SEGERA; INTERNAL (`TELEGRAM_INTERNAL_CHAT_IDS`)
+detail distribusi + semua kegagalan + klaim reward (⊥ komunitas). Token tunggal
 `TELEGRAM_BOT_TOKEN`. Tanpa token/daftar → kanal itu no-op senyap (⊥ ganggu
 run). Gagal kirim hanya dicatat — ⊥ pernah crash distribusi/klaim.
+
+V66: semua notifikasi kini punya emoticon prefix.
 """
 
 import requests
@@ -12,6 +14,9 @@ import requests
 from config import (TELEGRAM_BOT_TOKEN, TELEGRAM_COMMUNITY_CHAT_IDS,
                     TELEGRAM_INTERNAL_CHAT_IDS)
 
+# Batas panjang pesan Telegram per kiriman (karakter)
+_MAX_MSG_LEN = 4096
+
 
 def send_text(text, chat_ids=None):
     """Kirim `text` ke daftar chat id. `chat_ids=None` → kanal komunitas.
@@ -40,61 +45,125 @@ def send_internal(text):
 
 def notify_start(run_date, n_voters, total_share, balance):
     """Run nyata dimulai: komunitas brief + internal detail."""
-    send_text(f'DISTRIBUSI MULAI\nTanggal: {run_date}')
+    send_text(f'🚀 DISTRIBUSI MULAI\n📅 Tanggal: {run_date}')
     send_internal(
-        f'DISTRIBUSI MULAI\n'
-        f'Tanggal: {run_date}\n'
-        f'Pemilih: {n_voters}\n'
-        f'Total share: {total_share} VEX\n'
-        f'Saldo: {balance} VEX'
+        f'🚀 DISTRIBUSI MULAI\n'
+        f'📅 Tanggal: {run_date}\n'
+        f'👥 Pemilih: {n_voters}\n'
+        f'💎 Total share: {total_share} VEX\n'
+        f'💰 Saldo: {balance} VEX'
     )
 
 
 def notify_finish(status, sent, total, total_share, failed, run_date):
     """Run selesai: komunitas brief + internal detail (ok | partial)."""
+    if status == 'ok':
+        emoji = '✅'
+        label = 'Berhasil'
+    else:
+        emoji = '⚠️'
+        label = 'Sebagian'
     send_text(
-        f'DISTRIBUSI SELESAI\n'
-        f'Tanggal: {run_date}\n'
-        f'Status: {status}'
+        f'{emoji} DISTRIBUSI SELESAI\n'
+        f'📅 Tanggal: {run_date}\n'
+        f'📊 Status: {label}'
     )
     send_internal(
-        f'DISTRIBUSI SELESAI\n'
-        f'Tanggal: {run_date}\n'
-        f'Status: {status}\n'
-        f'Terkirim: {sent}/{total} pemilih\n'
-        f'Total share: {total_share} VEX\n'
-        f'Gagal: {len(failed)}'
+        f'{emoji} DISTRIBUSI SELESAI\n'
+        f'📅 Tanggal: {run_date}\n'
+        f'📊 Status: {label}\n'
+        f'👥 Terkirim: {sent}/{total} pemilih\n'
+        f'💎 Total share: {total_share} VEX\n'
+        f'❌ Gagal: {len(failed)}'
     )
 
 
 def notify_failure(exc):
     """Run gagal total — kanal internal saja (ops detail)."""
     send_internal(
-        f'DISTRIBUSI GAGAL\n'
-        f'Error: {exc}'
+        f'🔴 DISTRIBUSI GAGAL\n'
+        f'❗ Error: {exc}'
     )
 
 
 def notify_claim(reward, fee, wallet):
     """Klaim reward BP sukses — kanal internal saja, ⊥ komunitas (V36)."""
     send_internal(
-        f'KLAIM REWARD SUKSES\n'
-        f'Reward: {reward} VEX\n'
-        f'Fee BP: {fee} VEX → {wallet}'
+        f'💰 KLAIM REWARD SUKSES\n'
+        f'💎 Reward: {reward} VEX\n'
+        f'💸 Fee BP: {fee} VEX → {wallet}'
     )
 
 
 def notify_claim_unmeasured(txid_label):
     """Klaim mendarat tapi reward tak terukur (V45) — internal, ⊥ "sukses 0"."""
     send_internal(
-        f'KLAIM MENDARAT · REWARD TAK TERUKUR\n'
-        f'Periksa reward & fee BP manual (txid {txid_label})'
+        f'🔍 KLAIM MENDARAT · REWARD TAK TERUKUR\n'
+        f'⚠️ Periksa reward & fee BP manual (txid {txid_label})'
     )
 
 
 def notify_claim_failure(exc):
     """Kegagalan siklus klaim — kanal internal saja (V36)."""
     send_internal(
-        f'KLAIM GAGAL\n'
-        f'Error: {exc}'
+        f'🔴 KLAIM GAGAL\n'
+        f'❗ Error: {exc}'
     )
+
+
+# ——————————————————————————————————————————————————————————————————————
+# V66: Notifikasi VOTE ULANG SEGERA — komunitas.
+# voters = list of (owner, staked, urgency) di mana urgency 1=⚠️ 2=🔴 3=🚨.
+# ——————————————————————————————————————————————————————————————————————
+
+_URGENCY_EMOJI = {1: '⚠️', 2: '🔴', 3: '🚨'}
+
+
+def notify_warn(voters):
+    """VOTE ULANG SEGERA — komunitas, best-effort.
+
+    Kirim daftar akun yang vote-nya akan kedaluwarsa, diurutkan berdasarkan
+    urgensi (paling mendesak di atas). Maks 50 entri; sisanya arahkan ke
+    dashboard.
+    """
+    if not voters:
+        return
+    # Urutkan: urgensi tinggi dulu (3 > 2 > 1)
+    sorted_voters = sorted(voters, key=lambda v: v[2], reverse=True)
+    truncated = len(sorted_voters) > 50
+    display = sorted_voters[:50]
+    # Emoji dari baris paling mendesak
+    top_emoji = _URGENCY_EMOJI.get(display[0][2], '⚠️')
+    lines = [f'{top_emoji} VOTE ULANG SEGERA', '',
+             f'{len(sorted_voters)} akun akan kedaluwarsa:', '']
+    for owner, staked, urgency in display:
+        emoji = _URGENCY_EMOJI.get(urgency, '⚠️')
+        lines.append(f'• {emoji} {owner} — {staked} VEX')
+        lines.append(f'  ↳ https://mining.databisnis.id?q={owner}')
+    if truncated:
+        lines.append('')
+        lines.append('📋 Cek https://mining.databisnis.id untuk daftar lengkap')
+    lines.append('')
+    lines.append('Vote ulang sekarang agar tidak kehilangan hak bagian!')
+    text = '\n'.join(lines)
+    # Telegram batas 4096 karakter — split bila perlu
+    if len(text) <= _MAX_MSG_LEN:
+        send_text(text)
+    else:
+        # Kirim header dulu, lalu sisa per-chunk
+        header = f'{top_emoji} VOTE ULANG SEGERA\n\n{len(sorted_voters)} akun akan kedaluwarsa:\n'
+        send_text(header)
+        chunk = []
+        chunk_len = 0
+        for owner, staked, urgency in display:
+            emoji = _URGENCY_EMOJI.get(urgency, '⚠️')
+            line = f'• {emoji} {owner} — {staked} VEX\n  ↳ https://mining.databisnis.id?q={owner}\n'
+            if chunk_len + len(line) > _MAX_MSG_LEN - 100:
+                send_text('\n'.join(chunk))
+                chunk = []
+                chunk_len = 0
+            chunk.append(line.rstrip())
+            chunk_len += len(line)
+        if chunk:
+            send_text('\n'.join(chunk))
+        send_text('Vote ulang sekarang agar tidak kehilangan hak bagian!')

test_distribute.py

@@ -620,12 +620,12 @@ def main():
     check('V30 komunitas brief MULAI', 'DISTRIBUSI MULAI' in comm[0][2]
           and 'Pemilih' not in comm[0][2])
     check('V30 komunitas brief SELESAI + status', 'DISTRIBUSI SELESAI'
-          in comm[1][2] and 'Status: ok' in comm[1][2]
+          in comm[1][2] and 'Berhasil' in comm[1][2]
           and 'Terkirim' not in comm[1][2])
     check('V30 internal 2 notif detail', len(intern) == 2)
     check('V30 internal detail MULAI', 'DISTRIBUSI MULAI' in intern[0][2]
           and 'Pemilih: 2' in intern[0][2])
-    check('V30 internal detail SELESAI', '2/2 pemilih' in intern[1][2]
+    check('V30 internal detail SELESAI', 'Terkirim: 2/2 pemilih' in intern[1][2]
           and 'Gagal: 0' in intern[1][2])
 
     # no-op (pemilih kosong) → ⊥ notif baru

test_get_voters.py

@@ -16,6 +16,7 @@ import requests
 
 import db
 import get_voters as gv
+import telegram
 
 
 def _fresh_weight(staked_raw, days_ago=5):
@@ -257,6 +258,115 @@ def main():
     check('V41 first_seen idempoten (record ulang ⊥ overwrite)',
           fs['aaa1'] == scanned_a and fs['aaa1'] != '2000-01-01T00:00:00')
 
+    # V66: voter_notify — tabel lacak notifikasi VOTE ULANG SEGERA
+    db.ensure_notify_schema()
+    conn = sqlite3.connect(db.DB_PATH)
+    cols = [r[1] for r in conn.execute(
+        'PRAGMA table_info(voter_notify)').fetchall()]
+    pk = [r[1] for r in conn.execute(
+        'PRAGMA table_info(voter_notify)').fetchall() if r[5]]
+    conn.close()
+    check('V66 voter_notify tabel ada', 'owner' in cols)
+    check('V66 voter_notify PK = owner', pk == ['owner'])
+    check('V66 urgency kolom ada', 'urgency' in cols)
+    check('V66 notified_at kolom ada', 'notified_at' in cols)
+
+    # record_notify: insert baru
+    db.record_notify('aaa1', 1, '2026-08-27T08:00:00')
+    check('V66 get_notify_urgency(aaa1) = 1', db.get_notify_urgency('aaa1') == 1)
+    check('V66 get_notify_urgency(unk) = None', db.get_notify_urgency('unk9') is None)
+
+    # record_notify: idempoten (INSERT OR IGNORE) — urgency tetap 1
+    db.record_notify('aaa1', 1, '2026-08-27T08:00:00')
+    check('V66 record_notify idempoten', db.get_notify_urgency('aaa1') == 1)
+
+    # record_notify: urgency naik → update
+    db.record_notify('aaa1', 2, '2026-08-28T08:00:00')
+    check('V66 urgency naik 1→2', db.get_notify_urgency('aaa1') == 2)
+    # urgency turun → ⊥ update
+    db.record_notify('aaa1', 1, '2026-08-29T08:00:00')
+    check('V66 urgency turun 2→1 ⊥ update', db.get_notify_urgency('aaa1') == 2)
+
+    # cleanup_notify: hapus baris tua
+    db.record_notify('old1', 1, '2026-08-01T00:00:00')
+    db.record_notify('new1', 1, '2026-08-27T00:00:00')
+    db.cleanup_notify('2026-08-15T00:00:00')
+    check('V66 cleanup hapus baris tua', db.get_notify_urgency('old1') is None)
+    check('V66 cleanup simpan baris baru', db.get_notify_urgency('new1') == 1)
+
+    # V66: _notify_warn — integrasi dengan telegram.notify_warn
+    # Siapkan pemilih dalam jendela VOTE ULANG SEGERA (last_vote 26 hari lalu)
+    warn_now = datetime(2026, 8, 27, 8, 0, 0)
+    warn_vote = (warn_now - timedelta(days=26)).isoformat(timespec='seconds')
+    safe_vote = (warn_now - timedelta(days=20)).isoformat(timespec='seconds')
+    # Masukkan pemilih langsung ke DB (bypass scan)
+    wrn2_vote = (warn_now - timedelta(days=27)).isoformat(timespec='seconds')
+    db.replace_snapshot([
+        {'owner': 'wrn1', 'weight': '1.0', 'staked': 5000.0,
+         'last_vote': warn_vote},
+        {'owner': 'wrn2', 'weight': '2.0', 'staked': 3000.0,
+         'last_vote': wrn2_vote},
+        {'owner': 'safe', 'weight': '3.0', 'staked': 8000.0,
+         'last_vote': safe_vote},
+    ], warn_now.isoformat(timespec='seconds'))
+
+    sent = []
+    _orig_warn = telegram.notify_warn
+    telegram.notify_warn = lambda v: sent.append(v)
+    try:
+        gv._notify_warn(warn_now)
+        check('V66 _notify_warn dipanggil', len(sent) == 1)
+        voters_notified = sent[0]
+        owners_notified = [v[0] for v in voters_notified]
+        check('V66 wrn2 (27h, ≤2d) masuk', 'wrn2' in owners_notified)
+        check('V66 wrn1 (26h, >2d) masuk', 'wrn1' in owners_notified)
+        check('V66 safe (20h, ⊥ window) tak masuk', 'safe' not in owners_notified)
+        # Cek urgensi
+        by_owner = {v[0]: v[2] for v in voters_notified}
+        check('V66 wrn2 urgensi = 3 (≤1d)', by_owner['wrn2'] == 3)
+        check('V66 wrn1 urgensi = 2 (≤2d)', by_owner['wrn1'] == 2)
+        # Cek voter_notify tercatat
+        check('V66 voter_notify wrn2 = 3', db.get_notify_urgency('wrn2') == 3)
+        check('V66 voter_notify wrn1 = 2', db.get_notify_urgency('wrn1') == 2)
+    finally:
+        telegram.notify_warn = _orig_warn
+
+    # V66: _notify_warn — skip bila sudah diberi tahu pada urgensi ≥ saat ini
+    sent.clear()
+    telegram.notify_warn = lambda v: sent.append(v)
+    try:
+        gv._notify_warn(warn_now)  # wrn1 sudah urgensi 2, wrn2 sudah urgensi 3
+        check('V66 _notify_warn skip redundancy', len(sent) == 0)
+    finally:
+        telegram.notify_warn = _orig_warn
+
+    # V66: _notify_warn — escalation trigger (wrn1 dari 2→3)
+    sent.clear()
+    # Hapus lacak utk wrn1 supaya bisa test escalation dratch
+    conn = sqlite3.connect(db.DB_PATH)
+    conn.execute('DELETE FROM voter_notify WHERE owner = ?', ('wrn1',))
+    conn.commit()
+    conn.close()
+    # Update wrn1 last_vote ke 27 hari lalu (≤1d → urgensi 3)
+    closer_vote = (warn_now - timedelta(days=27)).isoformat(
+        timespec='seconds')
+    db.replace_snapshot([
+        {'owner': 'wrn1', 'weight': '1.0', 'staked': 5000.0,
+         'last_vote': closer_vote},
+        {'owner': 'wrn2', 'weight': '2.0', 'staked': 3000.0,
+         'last_vote': wrn2_vote},
+    ], warn_now.isoformat(timespec='seconds'))
+    telegram.notify_warn = lambda v: sent.append(v)
+    try:
+        gv._notify_warn(warn_now)
+        check('V66 escalation trigger (2→3)', len(sent) == 1)
+        by_owner = {v[0]: v[2] for v in sent[0]}
+        check('V66 wrn1 escalation ke urgensi 3', by_owner['wrn1'] == 3)
+        check('V66 voter_notify wrn1 updated ke 3',
+              db.get_notify_urgency('wrn1') == 3)
+    finally:
+        telegram.notify_warn = _orig_warn
+
     print('\nSEMUA UJI PASS')