File size: 7,336 Bytes
2592ab2 719a7ec | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 | from fakes import seed_agent, seed_message
def seed_board(hub):
seed_agent(hub, "agent-1")
seed_agent(hub, "agent-2")
seed_message(hub, "20260601-100000-000", "agent-1", "first post", type="agent")
seed_message(hub, "20260601-110000-000", "agent-2", "trying fp8 quantization", type="note")
seed_message(hub, "20260602-090000-000", "agent-1", "an update", type="agent", via="bucket")
def test_default_listing_is_backward_compatible(env):
seed_board(env.hub)
data = env.client.get("/v1/messages").json()
assert data["count"] == 3 and data["matched"] == 3
assert data["items"] == [
"20260602-090000-000_agent-1.md",
"20260601-110000-000_agent-2.md",
"20260601-100000-000_agent-1.md",
]
assert data["next"] is None
def test_filename_tier_filters(env):
seed_board(env.hub)
assert env.client.get("/v1/messages?agent=agent-2").json()["items"] == [
"20260601-110000-000_agent-2.md"
]
data = env.client.get("/v1/messages?since=2026-06-01T10:30:00Z").json()
assert data["matched"] == 2
data = env.client.get("/v1/messages?since=20260601-103000&until=20260601-235959").json()
assert data["items"] == ["20260601-110000-000_agent-2.md"]
def test_frontmatter_filters_and_q(env):
seed_board(env.hub)
assert env.client.get("/v1/messages?type=note").json()["matched"] == 1
assert env.client.get("/v1/messages?via=bucket").json()["matched"] == 1
assert env.client.get("/v1/messages?q=FP8").json()["items"] == [
"20260601-110000-000_agent-2.md"
]
def test_expand_returns_full_records(env):
seed_board(env.hub)
data = env.client.get("/v1/messages?expand=true&limit=2").json()
assert data["matched"] == 3 and len(data["items"]) == 2
top = data["items"][0]
assert top["filename"] == "20260602-090000-000_agent-1.md"
assert top["frontmatter"]["agent"] == "agent-1"
assert top["body"].strip() == "an update"
assert data["next"] == "20260601-110000-000_agent-2.md"
def test_cursor_pages_through_descending(env):
seed_board(env.hub)
first = env.client.get("/v1/messages?limit=2").json()
assert first["next"] == first["items"][-1]
second = env.client.get(f"/v1/messages?limit=2&before={first['next']}").json()
assert second["items"] == ["20260601-100000-000_agent-1.md"]
assert second["next"] is None
def test_expanded_limit_is_capped(make_env):
env = make_env(EXPAND_MAX_LIMIT=2)
seed_board(env.hub)
data = env.client.get("/v1/messages?expand=true&limit=100").json()
assert len(data["items"]) == 2
plain = env.client.get("/v1/messages?limit=100").json()
assert len(plain["items"]) == 3 # cap applies to expanded pages only
def test_invalid_since_is_400_invalid_query(env):
r = env.client.get("/v1/messages?since=not-a-date")
assert r.status_code == 400
assert r.json()["error"]["code"] == "INVALID_QUERY"
def test_single_get_serves_parsed_and_404s(env):
seed_board(env.hub)
r = env.client.get("/v1/messages/20260601-100000-000_agent-1.md")
assert r.status_code == 200
assert r.json()["body"].strip() == "first post"
r = env.client.get("/v1/messages/20990101-000000-000_ghost.md")
assert r.status_code == 404
assert r.json()["error"]["code"] == "NOT_FOUND"
def test_post_raw_requires_registration(env):
r = env.client.post("/v1/messages", json={"agent_id": "ghost", "body": "hi"})
assert r.status_code == 404
assert r.json()["error"]["code"] == "NOT_REGISTERED"
def test_post_then_immediate_list_sees_the_message(env):
seed_agent(env.hub, "agent-1")
r = env.client.post("/v1/messages", json={"agent_id": "agent-1", "body": "just in"})
assert r.status_code == 201
filename = r.json()["filename"]
data = env.client.get("/v1/messages").json()
assert filename in data["items"]
# ── human-authored posts (§5.4a) — the dashboard path ──────────────
def _post_human(env, agent_id="human-test-user", body="hi", token="user-token", **extra):
return env.client.post(
"/v1/messages",
json={"agent_id": agent_id, "body": body, **extra},
headers={"Authorization": f"Bearer {token}"},
)
def test_post_human_requires_bearer_token(env):
r = env.client.post(
"/v1/messages", json={"agent_id": "human-test-user", "body": "hi"}
)
assert r.status_code == 401
assert r.json()["error"]["code"] == "UNAUTHORIZED"
def test_post_human_bad_token_is_401(env):
env.hub.whoami_fails = True
r = _post_human(env)
assert r.status_code == 401
assert r.json()["error"]["code"] == "UNAUTHORIZED"
def test_post_human_rejects_non_org_member(env):
env.hub.whoami_orgs = set()
r = _post_human(env)
assert r.status_code == 403
assert r.json()["error"]["code"] == "IDENTITY_MISMATCH"
def test_post_human_rejects_forged_handle(env):
r = _post_human(env, agent_id="human-somebody-else")
assert r.status_code == 403
assert r.json()["error"]["code"] == "IDENTITY_MISMATCH"
def test_post_human_handle_matches_lowercased_hf_user(env):
env.hub.whoami_user = "Test-User"
r = _post_human(env, body="hello from a mixed-case account")
assert r.status_code == 201
def test_post_human_delivers_mentions_and_refs(env):
seed_agent(env.hub, "agent-1")
seed_message(env.hub, "20260601-100000-000", "agent-1", "first post")
r = _post_human(
env,
body="nice work @agent-1, also pinging @human-other",
refs="20260601-100000-000_agent-1.md",
)
assert r.status_code == 201
data = r.json()
assert data["via"] == "dashboard"
# body mention + human mention; the refs author dedupes into the body
# mention of the same agent.
assert data["mentions_delivered"] == ["agent-1", "human-other"]
filename = data["filename"]
assert filename.endswith("_human-test-user.md")
board = env.hub.read_central_text(f"message_board/{filename}")
assert "agent: human-test-user" in board
assert "type: user" in board
assert "via: dashboard" in board
# byte-identical fan-out copies, immediately visible through the API
assert env.hub.read_central_text(f"inbox/agent-1/{filename}") == board
assert env.hub.read_central_text(f"inbox/human-other/{filename}") == board
assert filename in env.client.get("/v1/messages").json()["items"]
assert filename in env.client.get("/v1/inbox/agent-1").json()["items"]
def test_post_human_never_self_delivers(env):
r = _post_human(env, body="note to self @human-test-user and @nobody-registered")
assert r.status_code == 201
assert r.json()["mentions_delivered"] == []
def test_post_human_defaults_to_type_user(env):
r = _post_human(env, body="plain message")
assert r.status_code == 201
fm = env.client.get(f"/v1/messages/{r.json()['filename']}").json()["frontmatter"]
assert fm["type"] == "user"
assert fm["agent"] == "human-test-user"
def test_bare_human_id_still_unroutable(env):
# "human" (no suffix) is not a human handle; it falls through to the
# registration gate and can never be registered, so it 404s.
r = env.client.post("/v1/messages", json={"agent_id": "human", "body": "hi"})
assert r.status_code == 404
assert r.json()["error"]["code"] == "NOT_REGISTERED"
|