bvandeusenandClaude Opus 5.5
6d8db0bb65
CI & Build / Python lint (push) Successful in 2s
CI & Build / Plugin hooks (push) Successful in 12s
CI & Build / TypeScript typecheck (push) Successful in 32s
CI & Build / Python tests (push) Successful in 1m37s
CI & Build / integration (push) Successful in 2m7s
CI & Build / Build & push image (push) Successful in 22s
instance_identity is one row made by migration 0127 with a random id, so an instance has it before its first account. A full backup carries it in its header as instance_id (the tar manifest header and the JSON top level); BACKUP_VERSION is 28. The table rides in _NOT_INCLUDED: a restore decides from the header value rather than copying a row. Two stores with the same id number their rows the same way. That is what lets a later step roll a live instance back by original id, refuse a backup whose ids would land on unrelated rows, and have a fresh-instance restore adopt the backup's id (adopt_instance_id). Milestone 582, step 1. Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
43 lines
1.5 KiB
Python
43 lines
1.5 KiB
Python
"""Real-Postgres proof that every instance has one id lineage, that a full
|
|
backup carries it, and that adopting a backup's id replaces this one's."""
|
|
import io
|
|
|
|
import pytest
|
|
|
|
from grimoire.models import async_session
|
|
from grimoire.services import backup
|
|
from grimoire.services.backup_file import read_archive, write_archive_to
|
|
from grimoire.services.instance import adopt_instance_id, get_instance_id
|
|
|
|
pytestmark = [pytest.mark.integration, pytest.mark.usefixtures("_dispose_engine")]
|
|
|
|
|
|
async def test_the_migration_gave_this_instance_an_id_and_it_stays_put():
|
|
first = await get_instance_id()
|
|
assert first and len(first) >= 32
|
|
assert await get_instance_id() == first
|
|
|
|
|
|
async def test_a_full_backup_carries_the_instance_id_through_the_tar():
|
|
payload = await backup.export_full_backup()
|
|
assert payload["instance_id"] == await get_instance_id()
|
|
|
|
out = io.BytesIO()
|
|
write_archive_to(payload, out, app_version="test")
|
|
out.seek(0)
|
|
assert read_archive(out)["instance_id"] == payload["instance_id"]
|
|
|
|
|
|
async def test_adopting_a_backups_id_replaces_this_instances():
|
|
own = await get_instance_id()
|
|
try:
|
|
async with async_session() as s:
|
|
await adopt_instance_id(s, "adopted-lineage")
|
|
await s.commit()
|
|
assert await get_instance_id() == "adopted-lineage"
|
|
finally:
|
|
async with async_session() as s:
|
|
await adopt_instance_id(s, own)
|
|
await s.commit()
|
|
assert await get_instance_id() == own
|