#!/usr/bin/env python3
"""Grep korpus Threads @ukyhandoko untuk frasa kartu #77 (konten menjawab vs ramai)."""
import sys
from datetime import datetime, timedelta

ROOT = "/home/mantapman/.hermes/profiles/atun/workspace"
sys.path.insert(0, ROOT)
from repliz_client import get_client, ACC
import repliz_openssl_transport
repliz_openssl_transport.install(verbose=False)

UKY = ACC.UKY_THREADS
c = get_client()
docs = []
r = c.get_schedules(page=1, limit=100)
pages = (r["totalDocs"] + 99) // 100
docs.extend(r["docs"])
for p in range(2, pages + 1):
    docs.extend(c.get_schedules(page=p, limit=100)["docs"])

mine = []
for d in docs:
    acc = d.get("account") or {}
    aid = d.get("accountId") or acc.get("id") or acc.get("_id")
    if aid == UKY:
        mine.append(d)

KW = ["ramai", "menjawab", "jawaban", "mengejar", "konten yang", "konten ", "viral", "menjawab pertanyaan"]
for kw in KW:
    print("#" * 20, kw)
    n = 0
    for d in mine:
        desc = d.get("description") or ""
        blob = (desc + " " + (d.get("topic") or "")).lower()
        if kw in blob:
            n += 1
            at = d.get("scheduleAt") or ""
            w = datetime.fromisoformat(at.replace("Z", "+00:00")) + timedelta(hours=7) if at else None
            print(f"--- {w.strftime('%Y-%m-%d %H:%M') if w else '?'} [{d.get('status')}] {d.get('type')} topic={(d.get('topic') or '')!r}")
            print(desc.replace("\n", " / ")[:400])
    print("   total:", n)