mirror of
https://github.com/kuhyx/screen-locker.git
synced 2026-11-10 21:27:13 +01:00
Krzysztof kuhy Rudnicki
373a075606
- A day's RunnerUp walks (_Walking.tcx) count once their moving time sums to 40 min - Rest days: declared ahead, 2 per ISO week, HMAC-signed; pay the first workout unit - Grace floor: shutdown >= first task + 60 min (capped); skipped on a sick day - Workout ledger: one signed credit row per log credit slot and rest day - Day-aware ladder amounts from earned_time 0.4.0; preview_shutdown dry-run script Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com> Claude-Session: https://claude.ai/code/session_01QrjUTo1yhgAsUUasdw4bpG Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>
87 lines
3.3 KiB
Python
87 lines
3.3 KiB
Python
"""``--backfill-workout-ledger``: one-shot, idempotent ledger backfill.
|
|
|
|
python -m screen_locker.screen_lock --backfill-workout-ledger --dry-run
|
|
python -m screen_locker.screen_lock --backfill-workout-ledger
|
|
--from 2026-10-01 --to 2026-10-09 [--dry-run]
|
|
|
|
Writes a signed row for every workout credit slot already in ``log.json`` for
|
|
the days (default: today) and for every declared rest day in that range --
|
|
the credits made before the ledger existed. Rows already present (same
|
|
``entry_id``) are skipped, so running it twice writes nothing the second
|
|
time. ``--dry-run`` prints the rows it would add, unsigned, with a count per
|
|
source, and writes nothing.
|
|
"""
|
|
|
|
from __future__ import annotations
|
|
|
|
import argparse
|
|
from collections import Counter
|
|
from datetime import date, timedelta
|
|
import json
|
|
import sys
|
|
from typing import TYPE_CHECKING, Any
|
|
|
|
from screen_locker._day import today_str
|
|
from screen_locker._log_io import load_workout_log
|
|
from screen_locker._rest_day import rest_day_declarations
|
|
from screen_locker._workout_ledger import (
|
|
append_rows,
|
|
credit_row,
|
|
existing_rows,
|
|
ledger_path,
|
|
new_rows,
|
|
rest_row,
|
|
)
|
|
|
|
if TYPE_CHECKING:
|
|
from collections.abc import Sequence
|
|
from pathlib import Path
|
|
|
|
|
|
def backfill_rows(log_file: Path, first: date, last: date) -> list[dict[str, Any]]:
|
|
"""Unsigned rows for every credit slot and rest day from ``first`` to ``last``."""
|
|
logs = load_workout_log(log_file)
|
|
declared = rest_day_declarations()
|
|
rows: list[dict[str, Any]] = []
|
|
day = first
|
|
while day <= last:
|
|
iso = day.isoformat()
|
|
entries = [e for e in logs.get(iso, []) if isinstance(e, dict)]
|
|
for index in range(len(entries)):
|
|
row = credit_row(iso, entries, index)
|
|
if row is not None and row["entry_id"] not in {r["entry_id"] for r in rows}:
|
|
rows.append(row)
|
|
if day in declared:
|
|
rows.append(rest_row(day, declared[day]))
|
|
day += timedelta(days=1)
|
|
return rows
|
|
|
|
|
|
def run_backfill(log_file: Path, argv: Sequence[str]) -> int:
|
|
"""Backfill (or preview) the workout ledger. Returns a process exit code."""
|
|
parser = argparse.ArgumentParser(prog="screen-locker --backfill-workout-ledger")
|
|
parser.add_argument("--from", dest="first", default=None, help="YYYY-MM-DD")
|
|
parser.add_argument("--to", dest="last", default=None, help="YYYY-MM-DD")
|
|
parser.add_argument("--dry-run", action="store_true", help="print, write nothing")
|
|
args = parser.parse_args(list(argv))
|
|
today = date.fromisoformat(today_str())
|
|
first = date.fromisoformat(args.first) if args.first else today
|
|
last = date.fromisoformat(args.last) if args.last else first
|
|
rows = backfill_rows(log_file, first, last)
|
|
path = ledger_path()
|
|
if args.dry_run:
|
|
existing = existing_rows(path)
|
|
fresh = new_rows(rows, existing or [])
|
|
for row in fresh:
|
|
sys.stdout.write(json.dumps(row) + "\n")
|
|
per_source = Counter(r["detail"]["source"] for r in fresh)
|
|
sys.stdout.write(
|
|
f"ledger {path} ({'present' if path.exists() else 'missing'}), "
|
|
f"{first}..{last}: {len(rows)} candidate row(s), {len(fresh)} new; "
|
|
f"per source: {dict(sorted(per_source.items()))}\n"
|
|
)
|
|
return 0
|
|
added = append_rows(rows, path)
|
|
sys.stdout.write(f"{added} new row(s) appended to {path}\n")
|
|
return 0
|