sindri / master / tests / test_aegis_bridge.py
from sindri.config import SindriConfig, AgentProfile, QueueConfig
from sindri.aegis_bridge import AegisBridge
def make_config(tmp_path):
return SindriConfig(
data_dir=tmp_path,
agents={"fast": AgentProfile(harness="claude", model="claude-haiku-4-5")},
queues={"triage": QueueConfig(agent="fast", max_parallel=2)},
on={"issue.opened": "triage"},
)
def test_bridge_enqueue_without_start(tmp_path):
cfg = make_config(tmp_path)
bridge = AegisBridge(cfg)
enqueued = []
bridge._enqueue_fn = lambda queue, payload: enqueued.append((queue, payload))
bridge.enqueue("triage", {"type": "issue.opened", "repo": "myrepo", "issue_id": 1})
assert len(enqueued) == 1
assert enqueued[0][0] == "triage"
assert enqueued[0][1]["issue_id"] == 1