Skip to content

Commit e125b04

Browse files
committed
feat: add MQTT, NATS, Redis Pub/Sub, and tRPC protocol linkers (Session 6)
Complete all 14 cross-service protocol linkers. Implements topic/subject wildcard matching (MQTT +/#, NATS */>, Redis glob), tRPC procedure path matching, and 31 new tests. Deletes servicelink_stubs.c — zero stubs remain. Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
1 parent 8e0f365 commit e125b04

11 files changed

Lines changed: 4212 additions & 8 deletions

Makefile.cbm

Lines changed: 18 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -200,7 +200,11 @@ PIPELINE_SRCS = \
200200
src/pipeline/servicelink_sse.c \
201201
src/pipeline/servicelink_pubsub.c \
202202
src/pipeline/servicelink_rabbitmq.c \
203-
src/pipeline/servicelink_eventbridge.c
203+
src/pipeline/servicelink_eventbridge.c \
204+
src/pipeline/servicelink_mqtt.c \
205+
src/pipeline/servicelink_nats.c \
206+
src/pipeline/servicelink_redis_pubsub.c \
207+
src/pipeline/servicelink_trpc.c
204208

205209
# SimHash / MinHash module
206210
SIMHASH_SRCS = src/simhash/minhash.c
@@ -337,6 +341,14 @@ TEST_SERVICELINK_RABBITMQ_SRCS = tests/test_servicelink_rabbitmq.c
337341

338342
TEST_SERVICELINK_EVENTBRIDGE_SRCS = tests/test_servicelink_eventbridge.c
339343

344+
TEST_SERVICELINK_MQTT_SRCS = tests/test_servicelink_mqtt.c
345+
346+
TEST_SERVICELINK_NATS_SRCS = tests/test_servicelink_nats.c
347+
348+
TEST_SERVICELINK_REDIS_PUBSUB_SRCS = tests/test_servicelink_redis_pubsub.c
349+
350+
TEST_SERVICELINK_TRPC_SRCS = tests/test_servicelink_trpc.c
351+
340352
TEST_CLI_SRCS = tests/test_cli.c
341353

342354
TEST_MEM_SRCS = tests/test_mem.c
@@ -359,8 +371,12 @@ TEST_SERVICELINK_SSE_SRCS = tests/test_servicelink_sse.c
359371
TEST_SERVICELINK_PUBSUB_SRCS = tests/test_servicelink_pubsub.c
360372
TEST_SERVICELINK_RABBITMQ_SRCS = tests/test_servicelink_rabbitmq.c
361373
TEST_SERVICELINK_EVENTBRIDGE_SRCS = tests/test_servicelink_eventbridge.c
374+
TEST_SERVICELINK_MQTT_SRCS = tests/test_servicelink_mqtt.c
375+
TEST_SERVICELINK_NATS_SRCS = tests/test_servicelink_nats.c
376+
TEST_SERVICELINK_REDIS_PUBSUB_SRCS = tests/test_servicelink_redis_pubsub.c
377+
TEST_SERVICELINK_TRPC_SRCS = tests/test_servicelink_trpc.c
362378

363-
ALL_TEST_SRCS = $(TEST_FOUNDATION_SRCS) $(TEST_EXTRACTION_SRCS) $(TEST_STORE_SRCS) $(TEST_CYPHER_SRCS) $(TEST_MCP_SRCS) $(TEST_DISCOVER_SRCS) $(TEST_GRAPH_BUFFER_SRCS) $(TEST_PIPELINE_SRCS) $(TEST_WATCHER_SRCS) $(TEST_LZ4_SRCS) $(TEST_SQLITE_WRITER_SRCS) $(TEST_GO_LSP_SRCS) $(TEST_C_LSP_SRCS) $(TEST_TRACES_SRCS) $(TEST_CLI_SRCS) $(TEST_MEM_SRCS) $(TEST_UI_SRCS) $(TEST_SECURITY_SRCS) $(TEST_YAML_SRCS) $(TEST_SIMHASH_SRCS) $(TEST_INTEGRATION_SRCS) $(TEST_SERVICELINK_GRAPHQL_SRCS) $(TEST_SERVICELINK_GRPC_SRCS) $(TEST_SERVICELINK_KAFKA_SRCS) $(TEST_SERVICELINK_SQS_SRCS) $(TEST_SERVICELINK_SNS_SRCS) $(TEST_SERVICELINK_WS_SRCS) $(TEST_SERVICELINK_SSE_SRCS) $(TEST_SERVICELINK_PUBSUB_SRCS) $(TEST_SERVICELINK_RABBITMQ_SRCS) $(TEST_SERVICELINK_EVENTBRIDGE_SRCS)
379+
ALL_TEST_SRCS = $(TEST_FOUNDATION_SRCS) $(TEST_EXTRACTION_SRCS) $(TEST_STORE_SRCS) $(TEST_CYPHER_SRCS) $(TEST_MCP_SRCS) $(TEST_DISCOVER_SRCS) $(TEST_GRAPH_BUFFER_SRCS) $(TEST_PIPELINE_SRCS) $(TEST_WATCHER_SRCS) $(TEST_LZ4_SRCS) $(TEST_SQLITE_WRITER_SRCS) $(TEST_GO_LSP_SRCS) $(TEST_C_LSP_SRCS) $(TEST_TRACES_SRCS) $(TEST_CLI_SRCS) $(TEST_MEM_SRCS) $(TEST_UI_SRCS) $(TEST_SECURITY_SRCS) $(TEST_YAML_SRCS) $(TEST_SIMHASH_SRCS) $(TEST_INTEGRATION_SRCS) $(TEST_SERVICELINK_GRAPHQL_SRCS) $(TEST_SERVICELINK_GRPC_SRCS) $(TEST_SERVICELINK_KAFKA_SRCS) $(TEST_SERVICELINK_SQS_SRCS) $(TEST_SERVICELINK_SNS_SRCS) $(TEST_SERVICELINK_WS_SRCS) $(TEST_SERVICELINK_SSE_SRCS) $(TEST_SERVICELINK_PUBSUB_SRCS) $(TEST_SERVICELINK_RABBITMQ_SRCS) $(TEST_SERVICELINK_EVENTBRIDGE_SRCS) $(TEST_SERVICELINK_MQTT_SRCS) $(TEST_SERVICELINK_NATS_SRCS) $(TEST_SERVICELINK_REDIS_PUBSUB_SRCS) $(TEST_SERVICELINK_TRPC_SRCS)
364380

365381
# ── Build directories ────────────────────────────────────────────
366382

0 commit comments

Comments
 (0)