feat: streaming library sync, memory cards, and save state history

backend/alembic/env.py

@@ -6,7 +6,13 @@
 
 from config.config_manager import ConfigManager
 from logger.logger import unify_logger
-from models.assets import Save, Screenshot, State  # noqa
+from models.assets import (  # noqa
+    MemoryCard,
+    MemoryCardVersion,
+    Save,
+    Screenshot,
+    State,
+)
 from models.base import BaseModel
 from models.collection import VirtualCollection
 from models.firmware import Firmware  # noqa

backend/alembic/versions/0104_memory_cards.py

@@ -0,0 +1,112 @@
+"""Add memory_cards and memory_card_versions tables
+
+Revision ID: 0104_memory_cards
+Revises: 0103_roms_facets_provider_ids
+Create Date: 2026-07-12 00:00:00.000000
+
+"""
+
+import sqlalchemy as sa
+from alembic import op
+
+# revision identifiers, used by Alembic.
+revision = "0104_memory_cards"
+down_revision = "0103_roms_facets_provider_ids"
+branch_labels = None
+depends_on = None
+
+
+def upgrade() -> None:
+    op.create_table(
+        "memory_cards",
+        sa.Column("id", sa.Integer(), autoincrement=True, nullable=False),
+        sa.Column("user_id", sa.Integer(), nullable=False),
+        sa.Column("emulator", sa.String(length=50), nullable=False),
+        sa.Column("platform_id", sa.Integer(), nullable=True),
+        sa.Column("name", sa.String(length=255), nullable=False),
+        sa.Column("slot", sa.Integer(), nullable=False, server_default="1"),
+        sa.Column(
+            "is_public",
+            sa.Boolean(),
+            nullable=False,
+            server_default=sa.text("false"),
+        ),
+        sa.Column(
+            "created_at",
+            sa.TIMESTAMP(timezone=True),
+            nullable=False,
+            server_default=sa.text("now()"),
+        ),
+        sa.Column(
+            "updated_at",
+            sa.TIMESTAMP(timezone=True),
+            nullable=False,
+            server_default=sa.text("now()"),
+        ),
+        sa.ForeignKeyConstraint(["user_id"], ["users.id"], ondelete="CASCADE"),
+        sa.ForeignKeyConstraint(["platform_id"], ["platforms.id"], ondelete="SET NULL"),
+        sa.PrimaryKeyConstraint("id"),
+    )
+    with op.batch_alter_table("memory_cards") as batch_op:
+        batch_op.create_index(
+            batch_op.f("ix_memory_cards_user_emulator"),
+            ["user_id", "emulator"],
+        )
+        batch_op.create_index(
+            batch_op.f("ix_memory_cards_public"),
+            ["is_public"],
+        )
+
+    op.create_table(
+        "memory_card_versions",
+        sa.Column("id", sa.Integer(), autoincrement=True, nullable=False),
+        sa.Column("memory_card_id", sa.Integer(), nullable=False),
+        sa.Column("file_name", sa.String(length=450), nullable=False),
+        sa.Column("file_name_no_tags", sa.String(length=450), nullable=False),
+        sa.Column("file_name_no_ext", sa.String(length=450), nullable=False),
+        sa.Column("file_extension", sa.String(length=100), nullable=False),
+        sa.Column("file_path", sa.String(length=1000), nullable=False),
+        sa.Column(
+            "file_size_bytes", sa.BigInteger(), nullable=False, server_default="0"
+        ),
+        sa.Column(
+            "missing_from_fs",
+            sa.Boolean(),
+            nullable=False,
+            server_default=sa.text("false"),
+        ),
+        sa.Column("content_hash", sa.String(length=32), nullable=True),
+        sa.Column(
+            "created_at",
+            sa.TIMESTAMP(timezone=True),
+            nullable=False,
+            server_default=sa.text("now()"),
+        ),
+        sa.Column(
+            "updated_at",
+            sa.TIMESTAMP(timezone=True),
+            nullable=False,
+            server_default=sa.text("now()"),
+        ),
+        sa.ForeignKeyConstraint(
+            ["memory_card_id"], ["memory_cards.id"], ondelete="CASCADE"
+        ),
+        sa.PrimaryKeyConstraint("id"),
+    )
+    with op.batch_alter_table("memory_card_versions") as batch_op:
+        batch_op.create_index(
+            batch_op.f("ix_memory_card_versions_card"),
+            ["memory_card_id"],
+        )
+        batch_op.create_index(
+            batch_op.f("ix_memory_card_versions_card_hash"),
+            ["memory_card_id", "content_hash"],
+        )
+
+
+def downgrade() -> None:
+    # drop_table removes the tables' indexes and foreign keys; dropping the
+    # FK-backing indexes explicitly first is both redundant and rejected by
+    # MariaDB/MySQL.
+    op.drop_table("memory_card_versions")
+    op.drop_table("memory_cards")

backend/alembic/versions/0105_container_adoptions.py

@@ -0,0 +1,53 @@
+"""Add streaming_container_adoptions table
+
+Revision ID: 0105_container_adoptions
+Revises: 0104_memory_cards
+Create Date: 2026-07-21 00:00:00.000000
+
+"""
+
+import sqlalchemy as sa
+from alembic import op
+
+# revision identifiers, used by Alembic.
+revision = "0105_container_adoptions"
+down_revision = "0104_memory_cards"
+branch_labels = None
+depends_on = None
+
+
+def upgrade() -> None:
+    op.create_table(
+        "streaming_container_adoptions",
+        sa.Column("id", sa.Integer(), autoincrement=True, nullable=False),
+        sa.Column("container_key", sa.String(length=512), nullable=False),
+        sa.Column("outcome", sa.String(length=16), nullable=False),
+        sa.Column("decided_by_user_id", sa.Integer(), nullable=True),
+        sa.Column(
+            "decided_at",
+            sa.TIMESTAMP(timezone=True),
+            nullable=False,
+            server_default=sa.text("now()"),
+        ),
+        sa.Column(
+            "created_at",
+            sa.TIMESTAMP(timezone=True),
+            nullable=False,
+            server_default=sa.text("now()"),
+        ),
+        sa.Column(
+            "updated_at",
+            sa.TIMESTAMP(timezone=True),
+            nullable=False,
+            server_default=sa.text("now()"),
+        ),
+        sa.ForeignKeyConstraint(
+            ["decided_by_user_id"], ["users.id"], ondelete="SET NULL"
+        ),
+        sa.PrimaryKeyConstraint("id"),
+        sa.UniqueConstraint("container_key"),
+    )
+
+
+def downgrade() -> None:
+    op.drop_table("streaming_container_adoptions")

backend/config/__init__.py

@@ -283,6 +283,12 @@ def _get_env(var: str, fallback: str | None = None) -> str | None:
 STREAMING_SAVE_TIMEOUT: Final[int] = safe_int(
     _get_env("STREAMING_SAVE_TIMEOUT"), 45
 )  # 45 seconds
+# How many save states to keep per ROM, emulator and user. Each capture is
+# kept as its own asset rather than overwriting a slot, so the oldest are
+# pruned once this many exist. 0 disables pruning.
+STREAMING_STATE_HISTORY_LIMIT: Final[int] = safe_int(
+    _get_env("STREAMING_STATE_HISTORY_LIMIT"), 50
+)
 
 # SENTRY
 SENTRY_DSN: Final[str | None] = _get_env("SENTRY_DSN")

backend/config/config_manager.py

@@ -166,6 +166,13 @@ class StreamingContainer(TypedDict):
     host: str
     broker_host: str
     label: str
+    library_path: NotRequired[str]
+    # Namespace for stored states/cards; defaults to label (or platform)
+    # lowercased when omitted.
+    emulator: NotRequired[str]
+    # Opt in to whole memory-card sync (broker /memory-card). When true, the
+    # legacy per-file /save-file in-game-save path is skipped for this container.
+    memory_card_sync: NotRequired[bool]
 
 
 class Config: