andgineer / dinary-server / 24677589726

77%

push

github

Wake drain loop on new expense POSTs instead of only on timer

Replace the plain `asyncio.sleep(interval)` in the lifespan drain loop
with `asyncio.wait_for(event.wait(), timeout=interval)` and expose a
thread-safe `sheet_logging.notify_new_work()` that `POST /api/expenses`
calls after committing a fresh ledger row. The periodic timer stays as
the canonical fallback for crash recovery; user-visible sheet-append
latency drops from "up to drain_interval_sec" to "≈ 1 RTT to Google
Sheets" without re-introducing fire-and-forget per-POST workers. Only
fresh creates notify (replays did not enqueue a new queue row); notifies
are coalesced so burst traffic does not thrash the sweep.

Made-with: Cursor

45 of 48 new or added lines in 3 files covered. (93.75%)

1766 of 2460 relevant lines covered (71.79%)

0.72 hits per line