jerry/buzz
1
0
Fork 0
mirror of https://github.com/block/buzz.git synced 2026-11-08 10:21:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat(keyless): route broker capabilities

Browse Source 
Signed-off-by: Joel Robotham <jrobotham@squareup.com>
This commit is contained in:
Joel Robotham
2026-08-28 16:17:11 +10:00
parent 0c3e036798
commit 688f4b5c5f
16 changed files with 997 additions and 236 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
crates/buzz-cli/examples/mock_broker.rs
View File

@@ -73,6 +73,42 @@ async fn action(headers: axum::http::HeaderMap, body: Bytes) -> Response {
"dTag": FAKE_EVENT_ID,
}),
),
"storage.get" => succeeded(
request_id,
action,
serde_json::json!({ "value": "I am a keyless agent using broker-backed memory." }),
),
"storage.put" => succeeded(
request_id,
action,
serde_json::json!({ "eventId": FAKE_EVENT_ID, "kind": 30174, "createdAt": 1_700_000_000u64 }),
),
"presence.set" => succeeded(
request_id,
action,
serde_json::json!({ "eventId": FAKE_EVENT_ID, "kind": 20001, "createdAt": 1_700_000_000u64 }),
),
"typing.set" => succeeded(
request_id,
action,
serde_json::json!({ "eventId": FAKE_EVENT_ID, "kind": 20002, "createdAt": 1_700_000_000u64 }),
),
"observer.emit" => succeeded(
request_id,
action,
serde_json::json!({
"accepted": request
.get("args")
.and_then(|args| args.get("frames"))
.and_then(|frames| frames.as_array())
.map_or(0, Vec::len),
}),
),
"liveness.ping" => succeeded(
request_id,
action,
serde_json::json!({ "eventId": FAKE_EVENT_ID, "kind": 24200, "createdAt": 1_700_000_000u64 }),
),
"channel.read" => succeeded(request_id, action, serde_json::json!({ "messages": [] })),
other => serde_json::json!({
"type": "broker_result",