mirror of
https://github.com/block/buzz.git
synced 2026-11-12 20:31:12 +00:00
Signed-off-by: Tyler Longwell <tlongwell@block.xyz> Signed-off-by: npub1mprnacetjua2xx3p5eddmhxyk6wv929ymm5py8kd2xfxurxahspqqlgyta <d8473ee32b973aa31a21a65adddcc4b69cc2a8a4dee8121ecd51926e0cddbc02@sprout-oss.stage.blox.sqprod.co> Signed-off-by: npub17jjz49l9jjmhhk7cac63j8yt9z555n9cw8vk7v5jz4vzw4ppld5qgj57cc <f4a42a97e594b77bdbd8ee35191c8b28a94a4cb871d96f32921558275421fb68@sprout-oss.stage.blox.sqprod.co> Signed-off-by: Tyler Longwell <tlongwell@squareup.com> Signed-off-by: tlongwell-block <109685178+tlongwell-block@users.noreply.github.com> Co-authored-by: npub1qyvc0c5kl4gqv2fd97fsk46tu378sqgy35vc83rvgfwne90sel7s0ed67d <011987e296fd5006292d2f930b574be47c7801048d1983c46c425d3c95f0cffd@sprout-oss.stage.blox.sqprod.co> Co-authored-by: Tyler Longwell <tlongwell@block.xyz> Co-authored-by: npub1mprnacetjua2xx3p5eddmhxyk6wv929ymm5py8kd2xfxurxahspqqlgyta <d8473ee32b973aa31a21a65adddcc4b69cc2a8a4dee8121ecd51926e0cddbc02@sprout-oss.stage.blox.sqprod.co> Co-authored-by: npub1cc3ha7z055mu0rwwu7806t2wt8mj3pvu0uv5mfp2c50dahaqhczshdalg6 <c6237ef84fa537c78dcee78efd2d4e59f728859c7f194da42ac51ededfa0be05@sprout-oss.stage.blox.sqprod.co> Co-authored-by: npub17jjz49l9jjmhhk7cac63j8yt9z555n9cw8vk7v5jz4vzw4ppld5qgj57cc <f4a42a97e594b77bdbd8ee35191c8b28a94a4cb871d96f32921558275421fb68@sprout-oss.stage.blox.sqprod.co> Co-authored-by: npub1jh9wn95s0472h86ahapupaf7m6kx4v9sx2n0atj2hltcfer8k06s5n3pyf <95cae996907d7cab9f5dbf43c0f53edeac6ab0b032a6feae4abfd784e467b3f5@sprout-oss.stage.blox.sqprod.co> Co-authored-by: npub1t2tgm7d8f995uqvmnm8h88sg3wnpp9a5xysjf6dg3tjmgt3ltulqdp8ehr <5a968df9a7494b4e019b9ecf739e088ba61097b4312124e9a88ae5b42e3f5f3e@sprout-oss.stage.blox.sqprod.co> Co-authored-by: npub12gtutshhh76rx0jx697f32f9tffd4hhp3hx58fp4x6u4uemkm7sqf8f757 <5217c5c2f7bfb4333e46d17c98a9255a52dadee18dcd43a43536b95e6776dfa0@sprout-oss.stage.blox.sqprod.co>
56 lines
1.9 KiB
Rust
56 lines
1.9 KiB
Rust
#![deny(unsafe_code)]
|
|
#![warn(missing_docs)]
|
|
//! NIP-01 WebSocket relay for Buzz private team communication.
|
|
|
|
/// REST API route handlers.
|
|
pub mod api;
|
|
/// WebSocket audio relay for huddle voice channels.
|
|
pub mod audio;
|
|
/// Relay configuration from environment variables.
|
|
pub mod config;
|
|
/// Runtime conformance harness — abstract trace emission at the
|
|
/// ingest/read accept-reject boundary, replayed against
|
|
/// `docs/spec/MultiTenantRelay.tla` by the independent `buzz-conformance`
|
|
/// checker.
|
|
pub mod conformance;
|
|
/// WebSocket connection lifecycle and state.
|
|
pub mod connection;
|
|
/// Relay error types.
|
|
pub mod error;
|
|
/// WebSocket message handlers for NIP-01 client commands.
|
|
pub mod handlers;
|
|
/// Stateless HMAC-signed relay invite tokens (mint/verify).
|
|
pub mod invite_token;
|
|
/// Inter-relay mesh startup wiring (`BUZZ_MESH` seam).
|
|
pub mod mesh_boot;
|
|
/// Relay-signed mesh-LLM status publisher.
|
|
pub mod mesh_status_publisher;
|
|
/// Prometheus metrics: recorder, upkeep, HTTP middleware.
|
|
pub mod metrics;
|
|
/// NIP-11 relay information document.
|
|
pub mod nip11;
|
|
/// NIP-01 client/relay message parsing.
|
|
pub mod protocol;
|
|
/// Durable NIP-PL matcher and delivery worker.
|
|
pub mod push_runtime;
|
|
/// Axum router construction.
|
|
pub mod router;
|
|
/// Shared application state.
|
|
pub mod state;
|
|
/// Subscription registry with (channel, kind) fan-out index.
|
|
pub mod subscription;
|
|
/// OpenTelemetry tracing initialisation (tracer provider + OTLP exporter).
|
|
pub mod telemetry;
|
|
/// Row-zero host binding: resolve the request community from the connection host.
|
|
pub mod tenant;
|
|
/// Relay-side tunnel session directory and routing.
|
|
pub mod tunnel;
|
|
/// Webhook secret generation and constant-time comparison.
|
|
pub mod webhook_secret;
|
|
/// Workflow action sink — relay-side implementation of [`buzz_workflow::ActionSink`].
|
|
pub mod workflow_sink;
|
|
|
|
pub use config::Config;
|
|
pub use error::{RelayError, Result};
|
|
pub use state::AppState;
|