2026-08-24 01:18:40 +02:00
|
|
|
from tamq.broker import BrokerIdentity, InputBroker
|
|
|
|
|
from tamq.store import Store
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def test_broker_preserves_identity(tmp_path):
|
|
|
|
|
store = Store(tmp_path / "queue.sqlite3")
|
|
|
|
|
broker = InputBroker(store, BrokerIdentity("tmux-amq-42", "net-kingdom"))
|
|
|
|
|
assert broker.inspect_line("@railiance-platform: hello") is not None
|
|
|
|
|
row = store.list()[0]
|
|
|
|
|
assert row["sender_repo"] == "net-kingdom"
|
|
|
|
|
assert row["endpoint_id"] == "tmux-amq-42"
|
2026-08-25 00:08:57 +02:00
|
|
|
|
|
|
|
|
|
|
|
|
|
def test_broker_accepts_hash_address_alias(tmp_path):
|
|
|
|
|
store = Store(tmp_path / "queue.sqlite3")
|
|
|
|
|
broker = InputBroker(store, BrokerIdentity("tmux-amq-42-boot", "net-kingdom"))
|
|
|
|
|
assert broker.inspect_line("#railiance-platform: hello") is not None
|
|
|
|
|
row = store.list()[0]
|
|
|
|
|
assert row["sender_repo"] == "net-kingdom"
|
|
|
|
|
assert row["target_repo"] == "railiance-platform"
|
|
|
|
|
assert row["endpoint_id"] == "tmux-amq-42-boot"
|
