1 files changed, 33 insertions, 0 deletions

diff --git a/components/wisp_relay/broadcaster.c b/components/wisp_relay/broadcaster.c
new file mode 100644
index 0000000..738cbdb
--- /dev/null
+++ b/components/wisp_relay/broadcaster.c
@@ -0,0 +1,33 @@
+#include "broadcaster.h"
+#include "relay_core.h"
+#include "router.h"
+#include "sub_manager.h"
+#include "esp_log.h"
+
+static const char *TAG = "broadcaster";
+
+void broadcaster_fanout_json(relay_ctx_t *ctx, const char *event_json,
+                             size_t event_len, int event_kind,
+                             const char *event_pubkey_hex,
+                             uint64_t event_created_at)
+{
+    if (!ctx || !ctx->sub_manager) return;
+
+    sub_match_result_t matches;
+    sub_manager_match_json(ctx->sub_manager, event_json, event_len, event_kind,
+                           event_pubkey_hex, event_created_at, &matches);
+
+    if (matches.count == 0) {
+        ESP_LOGD(TAG, "No subscribers for event kind=%d", event_kind);
+        return;
+    }
+
+    ESP_LOGD(TAG, "Broadcasting event kind=%d to %d subscriptions",
+             event_kind, matches.count);
+
+    for (uint8_t i = 0; i < matches.count; i++) {
+        sub_match_entry_t *entry = &matches.matches[i];
+        router_send_event(ctx, entry->conn_fd, entry->sub_id,
+                          event_json, event_len);
+    }
+}