Extend state with daily block; add local_today helper

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: Social Media Launch Of App

sync_forks.py

@@ -241,33 +241,43 @@ def resolve_token() -> str:
  sys.exit(1)
 
 
-def load_state() -> tuple[datetime | None, dict[str, dict[str, Any]]]:
- """Read the last run timestamp and the forks left in conflict last run.
+def load_state() -> tuple[datetime | None, dict[str, dict[str, Any]], dict[str, Any]]:
+ """Read the last run timestamp, the forks left in conflict, and the daily block.
 
- Tolerant of the older state format that only stored `last_run` — a missing
- `conflicts` key simply yields an empty mapping.
+ Tolerant of older state formats: a missing `conflicts` or `daily` key simply
+ yields an empty mapping.
  """
  if not STATE_FILE.exists():
- return None, {}
+ return None, {}, {}
  try:
  data = json.loads(STATE_FILE.read_text())
  raw_last_run = data.get("last_run")
  last_run = datetime.fromisoformat(raw_last_run) if raw_last_run else None
- return last_run, data.get("conflicts", {})
+ return last_run, data.get("conflicts", {}), data.get("daily", {})
  except (ValueError, json.JSONDecodeError) as exc:
  console.print(
  f"[dim yellow]Warning: couldn't read state file ({exc}); forcing full check.[/]"
  )
- return None, {}
+ return None, {}, {}
 
 
-def save_state(run_time: datetime, conflicts: dict[str, dict[str, Any]]) -> None:
- """Persist this run's start time and any still-conflicting forks for the next run."""
+def save_state(
+ run_time: datetime, conflicts: dict[str, dict[str, Any]], daily: dict[str, Any]
+) -> None:
+ """Persist this run's start time, still-conflicting forks, and the daily block."""
  STATE_FILE.write_text(
- json.dumps({"last_run": run_time.isoformat(), "conflicts": conflicts}, indent=2)
+ json.dumps(
+ {"last_run": run_time.isoformat(), "conflicts": conflicts, "daily": daily},
+ indent=2,
+ )
  )
 
 
+def local_today() -> str:
+ """Local calendar date (YYYY-MM-DD) used as the daily-rollup boundary."""
+ return datetime.now().astimezone().date().isoformat()
+
+
 def upstream_changed(parent: dict[str, Any], last_run: datetime | None) -> bool:
  """True if upstream was pushed since our last run (or if we can't tell)."""
  pushed_at = parent.get("pushedAt")

test_sync_forks.py

@@ -213,10 +213,12 @@ def test_save_then_load(self):
  with tempfile.TemporaryDirectory() as tmp:
  self._use_tmp(tmp)
  conflicts = {"me/fork": {"first_seen": NOW.isoformat(), "runs": 2}}
- sf.save_state(NOW, conflicts)
- last_run, loaded = sf.load_state()
+ daily = {"date": "2026-06-08", "synced": {"a": 3}}
+ sf.save_state(NOW, conflicts, daily)
+ last_run, loaded, loaded_daily = sf.load_state()
  self.assertEqual(last_run, NOW)
  self.assertEqual(loaded, conflicts)
+ self.assertEqual(loaded_daily, daily)
 
  def test_legacy_state_without_conflicts_key(self):
  import tempfile
@@ -225,17 +227,23 @@ def test_legacy_state_without_conflicts_key(self):
  with tempfile.TemporaryDirectory() as tmp:
  sf.STATE_FILE = Path(tmp) / "sync_state.json"
  sf.STATE_FILE.write_text(json.dumps({"last_run": NOW.isoformat()}))
- last_run, loaded = sf.load_state()
+ last_run, loaded, daily = sf.load_state()
  self.assertEqual(last_run, NOW)
  self.assertEqual(loaded, {})
+ self.assertEqual(daily, {})
 
  def test_missing_file(self):
  import tempfile
  from pathlib import Path
 
  with tempfile.TemporaryDirectory() as tmp:
  sf.STATE_FILE = Path(tmp) / "nope.json"
- self.assertEqual(sf.load_state(), (None, {}))
+ self.assertEqual(sf.load_state(), (None, {}, {}))
+
+
+class LocalTodayTests(unittest.TestCase):
+ def test_returns_iso_date_string(self):
+ self.assertRegex(sf.local_today(), r"^\d{4}-\d{2}-\d{2}$")
 
 
 class BuildRunReportTests(unittest.TestCase):