didericis-claude
a3d9ac9605
BottleMetadata gains a backend field (default ""). Docker prepare writes "docker"; smolmachines prepare writes "smolmachines". read_metadata deserialises it with "" as the backward-compatible default. resume now passes metadata.backend to _launch_bottle so a preserved smolmachines bottle is resumed on the right backend without requiring BOT_BOTTLE_BACKEND to be set manually. _bottle_for_slug now reads metadata.backend and constructs a SmolmachinesBottle for smolmachines slugs instead of always defaulting to DockerBottle. No-metadata slugs still fall back to Docker. Closes #137
328 lines
11 KiB
Python
328 lines
11 KiB
Python
"""Unit: per-bottle state helpers (PRD 0016 Phase 1) + identity +
|
|
launch metadata."""
|
|
|
|
import re
|
|
import tempfile
|
|
import unittest
|
|
from pathlib import Path
|
|
|
|
from bot_bottle import supervise
|
|
from bot_bottle.backend.docker import bottle_state
|
|
from bot_bottle.backend.docker.bottle_state import (
|
|
BottleMetadata,
|
|
read_metadata,
|
|
write_metadata,
|
|
)
|
|
|
|
|
|
class _FakeHomeMixin:
|
|
def _setup_fake_home(self):
|
|
self._tmp = tempfile.TemporaryDirectory(prefix="bottle-state-test.")
|
|
original = supervise.bot_bottle_root
|
|
|
|
def fake_root() -> Path:
|
|
return Path(self._tmp.name) / ".bot-bottle"
|
|
|
|
supervise.bot_bottle_root = fake_root # type: ignore[assignment]
|
|
self._restore = lambda: setattr(supervise, "bot_bottle_root", original)
|
|
|
|
def _teardown_fake_home(self):
|
|
self._restore()
|
|
self._tmp.cleanup()
|
|
|
|
|
|
class TestPerBottleDockerfile(_FakeHomeMixin, unittest.TestCase):
|
|
def setUp(self):
|
|
self._setup_fake_home()
|
|
|
|
def tearDown(self):
|
|
self._teardown_fake_home()
|
|
|
|
def test_returns_none_when_absent(self):
|
|
self.assertIsNone(bottle_state.per_bottle_dockerfile("dev"))
|
|
|
|
def test_write_then_read_roundtrip(self):
|
|
bottle_state.write_per_bottle_dockerfile(
|
|
"dev", "FROM python:3.13\nRUN apk add ripgrep\n",
|
|
)
|
|
self.assertEqual(
|
|
"FROM python:3.13\nRUN apk add ripgrep\n",
|
|
bottle_state.per_bottle_dockerfile("dev"),
|
|
)
|
|
|
|
def test_isolated_per_slug(self):
|
|
bottle_state.write_per_bottle_dockerfile("dev", "FROM dev\n")
|
|
bottle_state.write_per_bottle_dockerfile("api", "FROM api\n")
|
|
self.assertEqual("FROM dev\n", bottle_state.per_bottle_dockerfile("dev"))
|
|
self.assertEqual("FROM api\n", bottle_state.per_bottle_dockerfile("api"))
|
|
|
|
def test_dockerfile_path_under_state_dir(self):
|
|
path = bottle_state.per_bottle_dockerfile_path("dev")
|
|
self.assertTrue(str(path).endswith("/.bot-bottle/state/dev/Dockerfile"))
|
|
|
|
def test_image_tag_unique_per_slug(self):
|
|
self.assertEqual(
|
|
"bot-bottle-rebuilt-dev:latest",
|
|
bottle_state.per_bottle_image_tag("dev"),
|
|
)
|
|
self.assertNotEqual(
|
|
bottle_state.per_bottle_image_tag("dev"),
|
|
bottle_state.per_bottle_image_tag("api"),
|
|
)
|
|
|
|
def test_transcript_dir_under_state_dir(self):
|
|
path = bottle_state.transcript_snapshot_dir("dev")
|
|
self.assertTrue(str(path).endswith("/.bot-bottle/state/dev/transcript"))
|
|
|
|
|
|
class TestBottleIdentity(unittest.TestCase):
|
|
"""bottle_identity(agent_name) — PRD 0016 follow-up.
|
|
|
|
Every call mints a fresh identity with a random 5-char suffix
|
|
so multiple instances of the same agent can run in parallel
|
|
without container name collisions. The slug-prefix is for
|
|
readability; the suffix is for uniqueness. To continue an
|
|
existing bottle, use the recorded identity via
|
|
`cli.py resume <identity>`, not this function."""
|
|
|
|
def test_format_is_slug_dash_5_alnum(self):
|
|
identity = bottle_state.bottle_identity("dev")
|
|
self.assertTrue(identity.startswith("dev-"))
|
|
suffix = identity[len("dev-"):]
|
|
self.assertEqual(5, len(suffix))
|
|
self.assertTrue(
|
|
re.fullmatch(r"[a-z0-9]+", suffix),
|
|
f"suffix {suffix!r} must be lowercase base36",
|
|
)
|
|
|
|
def test_two_calls_yield_different_identities(self):
|
|
# 5-char base36 gives ~60M combinations; collision in two
|
|
# calls is astronomically unlikely. If this ever flakes it's
|
|
# almost certainly a regression, not a bad-luck collision.
|
|
a = bottle_state.bottle_identity("dev")
|
|
b = bottle_state.bottle_identity("dev")
|
|
self.assertNotEqual(a, b)
|
|
|
|
def test_different_agents_get_different_prefixes(self):
|
|
a = bottle_state.bottle_identity("dev")
|
|
b = bottle_state.bottle_identity("api")
|
|
self.assertTrue(a.startswith("dev-"))
|
|
self.assertTrue(b.startswith("api-"))
|
|
|
|
def test_agent_name_slugified(self):
|
|
identity = bottle_state.bottle_identity("My Agent")
|
|
self.assertTrue(identity.startswith("my-agent-"))
|
|
|
|
|
|
class TestPreserveMarker(_FakeHomeMixin, unittest.TestCase):
|
|
"""The .preserve marker is how capability_apply tells cli.py's
|
|
session-end cleanup to keep the state dir instead of removing it."""
|
|
|
|
def setUp(self):
|
|
self._setup_fake_home()
|
|
|
|
def tearDown(self):
|
|
self._teardown_fake_home()
|
|
|
|
def test_default_is_unpreserved(self):
|
|
self.assertFalse(bottle_state.is_preserved("dev-x"))
|
|
|
|
def test_mark_then_is_preserved(self):
|
|
bottle_state.mark_preserved("dev-x")
|
|
self.assertTrue(bottle_state.is_preserved("dev-x"))
|
|
|
|
def test_clear_removes_marker(self):
|
|
bottle_state.mark_preserved("dev-x")
|
|
bottle_state.clear_preserve_marker("dev-x")
|
|
self.assertFalse(bottle_state.is_preserved("dev-x"))
|
|
|
|
def test_clear_is_idempotent(self):
|
|
# No marker present — should not raise.
|
|
bottle_state.clear_preserve_marker("never-existed")
|
|
self.assertFalse(bottle_state.is_preserved("never-existed"))
|
|
|
|
def test_marker_path_under_state_dir(self):
|
|
path = bottle_state.preserve_marker_path("dev-x")
|
|
self.assertTrue(str(path).endswith("/.bot-bottle/state/dev-x/.preserve"))
|
|
|
|
|
|
class TestCleanupState(_FakeHomeMixin, unittest.TestCase):
|
|
"""cleanup_state removes the entire per-bottle state dir.
|
|
Called by cli.py when a session ends without the preserve marker."""
|
|
|
|
def setUp(self):
|
|
self._setup_fake_home()
|
|
|
|
def tearDown(self):
|
|
self._teardown_fake_home()
|
|
|
|
def test_removes_state_dir_and_contents(self):
|
|
bottle_state.write_per_bottle_dockerfile("dev-x", "FROM x\n")
|
|
d = bottle_state.bottle_state_dir("dev-x")
|
|
self.assertTrue(d.is_dir())
|
|
bottle_state.cleanup_state("dev-x")
|
|
self.assertFalse(d.exists())
|
|
|
|
def test_idempotent_when_dir_missing(self):
|
|
# Never created — should not raise.
|
|
bottle_state.cleanup_state("never-existed")
|
|
|
|
|
|
class TestBottleMetadata(_FakeHomeMixin, unittest.TestCase):
|
|
def setUp(self):
|
|
self._setup_fake_home()
|
|
|
|
def tearDown(self):
|
|
self._teardown_fake_home()
|
|
|
|
def test_read_missing_returns_none(self):
|
|
self.assertIsNone(read_metadata("does-not-exist"))
|
|
|
|
def test_write_then_read_roundtrip(self):
|
|
meta = BottleMetadata(
|
|
identity="dev-a4f8c",
|
|
agent_name="dev",
|
|
cwd="/proj/A",
|
|
copy_cwd=True,
|
|
started_at="2026-05-25T12:00:00+00:00",
|
|
)
|
|
write_metadata(meta)
|
|
loaded = read_metadata("dev-a4f8c")
|
|
self.assertEqual(meta, loaded)
|
|
|
|
def test_metadata_lives_under_state_dir(self):
|
|
meta = BottleMetadata(
|
|
identity="dev-x", agent_name="dev",
|
|
cwd="", copy_cwd=False, started_at="t",
|
|
)
|
|
path = write_metadata(meta)
|
|
self.assertTrue(
|
|
str(path).endswith("/.bot-bottle/state/dev-x/metadata.json"),
|
|
)
|
|
|
|
def test_overwriting_metadata_updates_timestamp(self):
|
|
# `resume` re-writes metadata with a fresh started_at;
|
|
# everything else stays the same.
|
|
write_metadata(BottleMetadata(
|
|
identity="dev-y", agent_name="dev",
|
|
cwd="/proj/A", copy_cwd=True, started_at="t1",
|
|
))
|
|
write_metadata(BottleMetadata(
|
|
identity="dev-y", agent_name="dev",
|
|
cwd="/proj/A", copy_cwd=True, started_at="t2",
|
|
))
|
|
loaded = read_metadata("dev-y")
|
|
assert loaded is not None
|
|
self.assertEqual("t2", loaded.started_at)
|
|
|
|
|
|
class TestBottleMetadataBackend(_FakeHomeMixin, unittest.TestCase):
|
|
"""PRD 0040: backend field is persisted and read back."""
|
|
|
|
def setUp(self):
|
|
self._setup_fake_home()
|
|
|
|
def tearDown(self):
|
|
self._teardown_fake_home()
|
|
|
|
def test_backend_field_roundtrips_docker(self):
|
|
meta = BottleMetadata(
|
|
identity="dev-b1",
|
|
agent_name="dev",
|
|
cwd="",
|
|
copy_cwd=False,
|
|
started_at="2026-06-02T00:00:00+00:00",
|
|
compose_project="bot-bottle-dev-b1",
|
|
backend="docker",
|
|
)
|
|
write_metadata(meta)
|
|
loaded = read_metadata("dev-b1")
|
|
self.assertIsNotNone(loaded)
|
|
assert loaded is not None
|
|
self.assertEqual("docker", loaded.backend)
|
|
|
|
def test_backend_field_roundtrips_smolmachines(self):
|
|
meta = BottleMetadata(
|
|
identity="dev-b2",
|
|
agent_name="dev",
|
|
cwd="",
|
|
copy_cwd=False,
|
|
started_at="2026-06-02T00:00:00+00:00",
|
|
compose_project="",
|
|
backend="smolmachines",
|
|
)
|
|
write_metadata(meta)
|
|
loaded = read_metadata("dev-b2")
|
|
self.assertIsNotNone(loaded)
|
|
assert loaded is not None
|
|
self.assertEqual("smolmachines", loaded.backend)
|
|
|
|
def test_missing_backend_field_defaults_to_empty(self):
|
|
# Old state dirs written before PRD 0040 have no backend key.
|
|
import json
|
|
from bot_bottle.backend.docker import bottle_state as bs
|
|
path = bs.metadata_path("dev-b3")
|
|
path.parent.mkdir(parents=True, exist_ok=True)
|
|
path.write_text(json.dumps({
|
|
"identity": "dev-b3",
|
|
"agent_name": "dev",
|
|
"cwd": "",
|
|
"copy_cwd": False,
|
|
"started_at": "2026-06-02T00:00:00+00:00",
|
|
"compose_project": "bot-bottle-dev-b3",
|
|
}))
|
|
loaded = read_metadata("dev-b3")
|
|
self.assertIsNotNone(loaded)
|
|
assert loaded is not None
|
|
self.assertEqual("", loaded.backend)
|
|
|
|
|
|
class TestBottleForSlugBackend(_FakeHomeMixin, unittest.TestCase):
|
|
"""PRD 0040: _bottle_for_slug constructs the right bottle type."""
|
|
|
|
def setUp(self):
|
|
self._setup_fake_home()
|
|
|
|
def tearDown(self):
|
|
self._teardown_fake_home()
|
|
|
|
def test_docker_metadata_returns_docker_bottle(self):
|
|
from bot_bottle.backend.docker.bottle import DockerBottle
|
|
from bot_bottle.cli.dashboard import _bottle_for_slug
|
|
write_metadata(BottleMetadata(
|
|
identity="dev-d1",
|
|
agent_name="dev",
|
|
cwd="",
|
|
copy_cwd=False,
|
|
started_at="2026-06-02T00:00:00+00:00",
|
|
compose_project="bot-bottle-dev-d1",
|
|
backend="docker",
|
|
))
|
|
bottle, _ = _bottle_for_slug("dev-d1", {}, None)
|
|
self.assertIsInstance(bottle, DockerBottle)
|
|
|
|
def test_smolmachines_metadata_returns_smolmachines_bottle(self):
|
|
from bot_bottle.backend.smolmachines.bottle import SmolmachinesBottle
|
|
from bot_bottle.cli.dashboard import _bottle_for_slug
|
|
write_metadata(BottleMetadata(
|
|
identity="dev-s1",
|
|
agent_name="dev",
|
|
cwd="",
|
|
copy_cwd=False,
|
|
started_at="2026-06-02T00:00:00+00:00",
|
|
compose_project="",
|
|
backend="smolmachines",
|
|
))
|
|
bottle, _ = _bottle_for_slug("dev-s1", {}, None)
|
|
self.assertIsInstance(bottle, SmolmachinesBottle)
|
|
|
|
def test_no_metadata_defaults_to_docker_bottle(self):
|
|
from bot_bottle.backend.docker.bottle import DockerBottle
|
|
from bot_bottle.cli.dashboard import _bottle_for_slug
|
|
bottle, _ = _bottle_for_slug("unknown-slug", {}, None)
|
|
self.assertIsInstance(bottle, DockerBottle)
|
|
|
|
|
|
if __name__ == "__main__":
|
|
unittest.main()
|