feat: add durable matchmaking metadata schema

server/migrations/0001_initial.sql

@@ -19,6 +19,15 @@ CREATE TABLE sessions (
     created_at TIMESTAMPTZ NOT NULL DEFAULT now()
 );
 
+CREATE TABLE idempotency_keys (
+    scope TEXT NOT NULL,
+    idempotency_key TEXT NOT NULL CHECK (char_length(idempotency_key) BETWEEN 16 AND 128),
+    payload_digest BYTEA NOT NULL,
+    result JSONB NOT NULL,
+    created_at TIMESTAMPTZ NOT NULL DEFAULT now(),
+    PRIMARY KEY (scope, idempotency_key)
+);
+
 CREATE TABLE queue_tickets (
     ticket_id TEXT PRIMARY KEY,
     player_id TEXT NOT NULL REFERENCES identities(player_id),
@@ -95,6 +104,25 @@ CREATE TABLE ratings (
     updated_at TIMESTAMPTZ NOT NULL DEFAULT now()
 );
 
+CREATE TABLE seasons (
+    season_id TEXT PRIMARY KEY,
+    playlist TEXT NOT NULL CHECK (playlist = 'ranked'),
+    starts_at TIMESTAMPTZ NOT NULL,
+    ends_at TIMESTAMPTZ NOT NULL CHECK (ends_at > starts_at),
+    rolled_over_at TIMESTAMPTZ
+);
+
+CREATE TABLE penalties (
+    penalty_id TEXT PRIMARY KEY,
+    player_id TEXT NOT NULL REFERENCES identities(player_id),
+    match_id TEXT REFERENCES matches(match_id),
+    playlist TEXT NOT NULL CHECK (playlist IN ('casual', 'ranked')),
+    kind TEXT NOT NULL,
+    starts_at TIMESTAMPTZ NOT NULL,
+    ends_at TIMESTAMPTZ NOT NULL CHECK (ends_at > starts_at),
+    created_at TIMESTAMPTZ NOT NULL DEFAULT now()
+);
+
 CREATE TABLE result_receipts (
     result_id TEXT PRIMARY KEY,
     match_id TEXT NOT NULL UNIQUE REFERENCES matches(match_id),

server/migrations/test_migration.py

@@ -10,15 +10,16 @@ SQL = (Path(__file__).parent / "0001_initial.sql").read_text()
 class MigrationTest(unittest.TestCase):
     def test_durable_domains_and_fences_exist(self):
         required_tables = {
-            "identities", "sessions", "queue_tickets", "proposals",
+            "identities", "sessions", "idempotency_keys", "queue_tickets", "proposals",
             "proposal_participants", "matches", "match_participants",
-            "ratings", "result_receipts", "outbox", "audit_events",
+            "ratings", "seasons", "penalties", "result_receipts", "outbox", "audit_events",
         }
         for table in required_tables:
             self.assertIn(f"CREATE TABLE {table}", SQL)
         self.assertIn("queue_tickets_one_active_per_player", SQL)
         self.assertIn("match_participants_one_active_match", SQL)
         self.assertIn("UNIQUE (aggregate_type, aggregate_id, revision)", SQL)
+        self.assertIn("PRIMARY KEY (scope, idempotency_key)", SQL)
 
     def test_redis_is_not_a_durable_dependency(self):
         self.assertNotIn("CREATE TABLE redis", SQL.lower())
@@ -34,6 +35,12 @@ class MigrationTest(unittest.TestCase):
         self.assertIn("participation_active BOOLEAN NOT NULL DEFAULT TRUE", SQL)
         self.assertIn("WHERE participation_active", SQL)
 
+    def test_seasons_are_ranked_only_and_penalties_are_durable(self):
+        self.assertIn("CHECK (playlist = 'ranked')", SQL)
+        self.assertIn("CREATE TABLE penalties", SQL)
+        self.assertIn("REFERENCES identities(player_id)", SQL)
+        self.assertIn("REFERENCES matches(match_id)", SQL)
+
 
 if __name__ == "__main__":
     unittest.main()