Skip to content

Commit f052004

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 08f5392 commit f052004

11 files changed

Lines changed: 4208 additions & 9 deletions

Makefile.cbm

Lines changed: 14 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -178,7 +178,6 @@ PIPELINE_SRCS = \
178178
src/pipeline/pass_infrascan.c \
179179
src/pipeline/httplink.c \
180180
src/pipeline/pass_servicelinks.c \
181-
src/pipeline/servicelink_stubs.c \
182181
src/pipeline/servicelink_graphql.c \
183182
src/pipeline/servicelink_grpc.c \
184183
src/pipeline/servicelink_kafka.c \
@@ -188,7 +187,11 @@ PIPELINE_SRCS = \
188187
src/pipeline/servicelink_sse.c \
189188
src/pipeline/servicelink_pubsub.c \
190189
src/pipeline/servicelink_rabbitmq.c \
191-
src/pipeline/servicelink_eventbridge.c
190+
src/pipeline/servicelink_eventbridge.c \
191+
src/pipeline/servicelink_mqtt.c \
192+
src/pipeline/servicelink_nats.c \
193+
src/pipeline/servicelink_redis_pubsub.c \
194+
src/pipeline/servicelink_trpc.c
192195

193196
# Traces module (new)
194197
TRACES_SRCS = src/traces/traces.c
@@ -314,6 +317,14 @@ TEST_SERVICELINK_RABBITMQ_SRCS = tests/test_servicelink_rabbitmq.c
314317

315318
TEST_SERVICELINK_EVENTBRIDGE_SRCS = tests/test_servicelink_eventbridge.c
316319

320+
TEST_SERVICELINK_MQTT_SRCS = tests/test_servicelink_mqtt.c
321+
322+
TEST_SERVICELINK_NATS_SRCS = tests/test_servicelink_nats.c
323+
324+
TEST_SERVICELINK_REDIS_PUBSUB_SRCS = tests/test_servicelink_redis_pubsub.c
325+
326+
TEST_SERVICELINK_TRPC_SRCS = tests/test_servicelink_trpc.c
327+
317328
TEST_CLI_SRCS = tests/test_cli.c
318329

319330
TEST_MEM_SRCS = tests/test_mem.c
@@ -322,7 +333,7 @@ TEST_UI_SRCS = tests/test_ui.c
322333

323334
TEST_SECURITY_SRCS = tests/test_security.c
324335

325-
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_HTTPLINK_SRCS) $(TEST_CLI_SRCS) $(TEST_MEM_SRCS) $(TEST_UI_SRCS) $(TEST_SECURITY_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)
336+
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_HTTPLINK_SRCS) $(TEST_CLI_SRCS) $(TEST_MEM_SRCS) $(TEST_UI_SRCS) $(TEST_SECURITY_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)
326337

327338
# ── Build directories ────────────────────────────────────────────
328339

0 commit comments

Comments
 (0)