dangernoodle-io / breadboard / 28003570767

100%

push

github

jae/bb pub sink event (#534)

* feat(bb_pub): add per-source tags, subscription filter, sample_into, source_info_ex

- add BB_PUB_MAX_TAGS_PER_SOURCE/BB_PUB_TAG_MAX constants and per-source tag storage
- add bb_pub_subscribe_fn type and subscribe/subscribe_ctx fields to bb_pub_sink_t
- add bb_pub_subscription_t helper + bb_pub_subscription_match/predicate
- add bb_pub_register_source_ex (tags), bb_pub_source_info_ex, bb_pub_sample_into
- filter sinks in tick_once fan-out when sink.subscribe is set (before serialize)
- reset ntags/tag_ptrs in bb_pub_test_reset
- zero subscribe/subscribe_ctx in bb_sink_mqtt and bb_sink_http factory functions
  to protect legacy callers that don't initialize the new sink fields

* feat: add bb_sink_event component

- bb_sink_event is a bb_pub_sink_t adapter that routes telemetry payloads
  to bb_event topics via bb_event_post, bridging the periodic publisher
  to the SSE/event-bus fan-out stack
- bb_sink_event_register_topic: register subtopic, create bb_event topic,
  attach to bb_event_routes with retained flag
- bb_sink_event_seed_all: seed retained topics from bb_pub sources at boot
- bb_sink_event_reset_for_test: test isolation hook
- CMakeLists/Kconfig/header under components/bb_sink_event/
- host implementation under platform/host/bb_sink_event/
- wire into native_scaffold.py and platformio.ini
  (BB_SINK_EVENT_TESTING, BB_SINK_EVENT_MAX_TOPICS=4 for tests)

* test: add host tests for bb_pub subscription filter, tags, sample_into, bb_sink_event

- test_bb_pub_subscription.c: subscription_match, register_source_ex, source_info_ex,
  tick filter by subtopic/tag, sample_into, tag reset
- test_bb_sink_event.c: sink fill, topic registration, tick delivery, seed_all,
  unregistered skip, sample_skip, max topics overflow
- test_bb_pub_parity.c: parity smoke tests for register_source_ex and predicate
- test_main.c: forward decls + RUN_TEST blocks for all new tests; adds
  bb_sink_event_reset_for_test to global setUp; incl... (continued)

1764 of 1764 branches covered (100.0%)

Branch coverage included in aggregate %.

2896 of 2896 relevant lines covered (100.0%)

1226.98 hits per line