일 하나에 알림 한 번

    # The Chief is a sanctuary (todo #624): a worker session's plumbing (ready,
    # disconnected, enrolled) stays in Coop and on Telegram, and the Chief
    # reads it with the coop tool when asked.
    chief_message=None
    if not chief_doors.coop_info_only(body.text,body.reason):
        # The Chief line is durable in its outbox before this waits, and the
        # wait is bounded: a busy Chief held this request past the engine's
        # 15 s timeout, every retry added a waiter, and each re-sent Telegram
        # once the Chief was free (cold review #6). It lands when the Chief is
        # free, and a line about a work item settles first: a newer line for
        # the same item within the window takes its place (one event used to
        # reach the Chief as reply, blocked, then parked or escalated).
        item=chief_doors.coop_item(body.text)
        chief_message=await report_to_chief(text=body.text,source_id='coop-notify:'+body.outbox_id,store=store,
                                            wait=NOTIFY_CHIEF_WAIT_SECONDS,group='coop:'+item if item else None,
                                            settle=chief_doors.COOP_SETTLE_SECONDS)
    answer={'delivered':True,'channel':'telegram','outbox_id':body.outbox_id,'chief_message_id':chief_message}
    if chief_task:
        answer['chief_task']=chief_task
    item=chief_doors.coop_item(body.text)
    settle=chief_doors.COOP_SETTLE_SECONDS
    if item and settle>0:
        state=await _hold_notify(store,body.outbox_id,body.text,'coop:'+item,settle)
        if state=='held':
            return {**answer,'settling':True}
        return {**answer,'already_sent':state in ('sent','repeat'),'state':state}

"""A minimal sketch: lines about one work item settle for a window, the newest
takes the place of the ones still settling, and a retry of a replaced line
never lands. Not the engine: one table, a fake clock, no Telegram."""
import sqlite3

SETTLE = 120.0
db = sqlite3.connect(":memory:")
db.execute("""CREATE TABLE outbox (key TEXT PRIMARY KEY, item TEXT, text TEXT,
              not_before REAL, superseded_by TEXT, landed REAL)""")
OWED = "landed IS NULL AND superseded_by IS NULL"


def report(key, item, text, now):
    """Hold a line until it settles; only a NEW row supersedes older ones."""
    inserted = db.execute("INSERT OR IGNORE INTO outbox (key, item, text, not_before) VALUES (?, ?, ?, ?)",
                          (key, item, text, now + SETTLE)).rowcount
    if inserted:
        db.execute(f"UPDATE outbox SET superseded_by=? WHERE item=? AND key!=? AND {OWED}", (key, item, key))
        return "settling"
    (by,) = db.execute("SELECT superseded_by FROM outbox WHERE key=?", (key,)).fetchone()
    return f"retry of a line replaced by {by}: never lands" if by else "retry: nothing changes"


def drain(now):
    """Land every line whose window has passed and that nothing replaced."""
    due = db.execute(f"SELECT key, text FROM outbox WHERE {OWED} AND not_before<=? ORDER BY not_before",
                     (now,)).fetchall()
    for key, text in due:
        db.execute("UPDATE outbox SET landed=? WHERE key=?", (now, key))
        print(f"t={now:5.0f}s  RING  {text}")


print(report("c1", "todo #9", "[Coop] worker reply: todo #9 ...", now=0))
print(report("c2", "todo #9", "[Coop] blocked: todo #9 ...", now=1))
print(report("c3", "todo #9", "[Coop] parked for Dad: todo #9 ...", now=62))
print(report("c1", "todo #9", "[Coop] worker reply: todo #9 ...", now=70))   # the engine retries c1
print(report("d1", "todo #12", "[Coop] done: todo #12 ...", now=80))
for t in (60, 121, 182, 200):
    drain(t)

# Output:
# settling
# settling
# settling
# retry of a line replaced by c2: never lands
# settling
# t=  182s  RING  [Coop] parked for Dad: todo #9 ...
# t=  200s  RING  [Coop] done: todo #12 ...