feat: register protocol endpoints in all 14 linkers

Shidfar · claude · Shidfar · commit 641d9b936ae3 · 2026-04-08T17:00:41.000Z
Co-Authored-By: Claude Opus 4.6 (1M context) &lt;noreply@anthropic.com&gt;
diff --git a/src/pipeline/servicelink_eventbridge.c b/src/pipeline/servicelink_eventbridge.c
@@ -579,6 +579,22 @@ int cbm_servicelink_eventbridge(cbm_pipeline_ctx_t *ctx) {
                  "producers", itoa_eb(prod_count),
                  "consumers", itoa_eb(cons_count));
 
+    /* Register endpoints for cross-repo matching */
+    if (ctx->endpoints) {
+        for (int i = 0; i < prod_count; i++) {
+            sl_register_endpoint(ctx->endpoints, ctx->project_name, "eventbridge",
+                                 "producer", producers[i].identifier,
+                                 producers[i].source_qn, producers[i].file_path,
+                                 producers[i].extra);
+        }
+        for (int i = 0; i < cons_count; i++) {
+            sl_register_endpoint(ctx->endpoints, ctx->project_name, "eventbridge",
+                                 "consumer", consumers[i].identifier,
+                                 consumers[i].handler_qn, consumers[i].file_path,
+                                 consumers[i].extra);
+        }
+    }
+
     /* 4. Match consumers to producers and create edges */
     int link_count = 0;
 
diff --git a/src/pipeline/servicelink_graphql.c b/src/pipeline/servicelink_graphql.c
@@ -834,6 +834,22 @@ int cbm_servicelink_graphql(cbm_pipeline_ctx_t *ctx) {
                  "producers", itoa_gql(prod_count),
                  "consumers", itoa_gql(cons_count));
 
+    /* Register endpoints for cross-repo matching */
+    if (ctx->endpoints) {
+        for (int i = 0; i < prod_count; i++) {
+            sl_register_endpoint(ctx->endpoints, ctx->project_name, "graphql",
+                                 "producer", producers[i].identifier,
+                                 producers[i].source_qn, producers[i].file_path,
+                                 producers[i].extra);
+        }
+        for (int i = 0; i < cons_count; i++) {
+            sl_register_endpoint(ctx->endpoints, ctx->project_name, "graphql",
+                                 "consumer", consumers[i].identifier,
+                                 consumers[i].handler_qn, consumers[i].file_path,
+                                 consumers[i].extra);
+        }
+    }
+
     if (prod_count == 0 || cons_count == 0) {
         cbm_log_info("servicelink.done", "protocol", "graphql",
                      "links", "0");
diff --git a/src/pipeline/servicelink_grpc.c b/src/pipeline/servicelink_grpc.c
@@ -615,6 +615,22 @@ int cbm_servicelink_grpc(cbm_pipeline_ctx_t *ctx) {
                  "producers", itoa_grpc(prod_count),
                  "consumers", itoa_grpc(cons_count));
 
+    /* Register endpoints for cross-repo matching */
+    if (ctx->endpoints) {
+        for (int i = 0; i < prod_count; i++) {
+            sl_register_endpoint(ctx->endpoints, ctx->project_name, "grpc",
+                                 "producer", producers[i].identifier,
+                                 producers[i].source_qn, producers[i].file_path,
+                                 producers[i].extra);
+        }
+        for (int i = 0; i < cons_count; i++) {
+            sl_register_endpoint(ctx->endpoints, ctx->project_name, "grpc",
+                                 "consumer", consumers[i].identifier,
+                                 consumers[i].handler_qn, consumers[i].file_path,
+                                 consumers[i].extra);
+        }
+    }
+
     /* 4. Match consumers to producers and create edges.
      *    Collect best matches, dedup by (src, tgt) keeping highest confidence
      *    to prevent lower-confidence overwrites via gbuf dedup. */
diff --git a/src/pipeline/servicelink_kafka.c b/src/pipeline/servicelink_kafka.c
@@ -484,6 +484,22 @@ int cbm_servicelink_kafka(cbm_pipeline_ctx_t *ctx) {
                  "producers", itoa_kafka(prod_count),
                  "consumers", itoa_kafka(cons_count));
 
+    /* Register endpoints for cross-repo matching */
+    if (ctx->endpoints) {
+        for (int i = 0; i < prod_count; i++) {
+            sl_register_endpoint(ctx->endpoints, ctx->project_name, "kafka",
+                                 "producer", producers[i].identifier,
+                                 producers[i].source_qn, producers[i].file_path,
+                                 producers[i].extra);
+        }
+        for (int i = 0; i < cons_count; i++) {
+            sl_register_endpoint(ctx->endpoints, ctx->project_name, "kafka",
+                                 "consumer", consumers[i].identifier,
+                                 consumers[i].handler_qn, consumers[i].file_path,
+                                 consumers[i].extra);
+        }
+    }
+
     /* 4. Match consumers to producers and create edges */
     int link_count = 0;
 
diff --git a/src/pipeline/servicelink_mqtt.c b/src/pipeline/servicelink_mqtt.c
@@ -532,6 +532,22 @@ int cbm_servicelink_mqtt(cbm_pipeline_ctx_t *ctx) {
                  "producers", itoa_mqtt(prod_count),
                  "consumers", itoa_mqtt(cons_count));
 
+    /* Register endpoints for cross-repo matching */
+    if (ctx->endpoints) {
+        for (int i = 0; i < prod_count; i++) {
+            sl_register_endpoint(ctx->endpoints, ctx->project_name, "mqtt",
+                                 "producer", producers[i].identifier,
+                                 producers[i].source_qn, producers[i].file_path,
+                                 producers[i].extra);
+        }
+        for (int i = 0; i < cons_count; i++) {
+            sl_register_endpoint(ctx->endpoints, ctx->project_name, "mqtt",
+                                 "consumer", consumers[i].identifier,
+                                 consumers[i].handler_qn, consumers[i].file_path,
+                                 consumers[i].extra);
+        }
+    }
+
     /* 4. ALL-match: for each consumer, check ALL producers and create edges for any match */
     int link_count = 0;
 
diff --git a/src/pipeline/servicelink_nats.c b/src/pipeline/servicelink_nats.c
@@ -571,6 +571,22 @@ int cbm_servicelink_nats(cbm_pipeline_ctx_t *ctx) {
                  "producers", itoa_nats(prod_count),
                  "consumers", itoa_nats(cons_count));
 
+    /* Register endpoints for cross-repo matching */
+    if (ctx->endpoints) {
+        for (int i = 0; i < prod_count; i++) {
+            sl_register_endpoint(ctx->endpoints, ctx->project_name, "nats",
+                                 "producer", producers[i].identifier,
+                                 producers[i].source_qn, producers[i].file_path,
+                                 producers[i].extra);
+        }
+        for (int i = 0; i < cons_count; i++) {
+            sl_register_endpoint(ctx->endpoints, ctx->project_name, "nats",
+                                 "consumer", consumers[i].identifier,
+                                 consumers[i].handler_qn, consumers[i].file_path,
+                                 consumers[i].extra);
+        }
+    }
+
     /* 4. ALL-match: check ALL producers for each consumer (like RabbitMQ) */
     int link_count = 0;
 
diff --git a/src/pipeline/servicelink_pubsub.c b/src/pipeline/servicelink_pubsub.c
@@ -447,6 +447,22 @@ int cbm_servicelink_pubsub(cbm_pipeline_ctx_t *ctx) {
                  "producers", itoa_pubsub(prod_count),
                  "consumers", itoa_pubsub(cons_count));
 
+    /* Register endpoints for cross-repo matching */
+    if (ctx->endpoints) {
+        for (int i = 0; i < prod_count; i++) {
+            sl_register_endpoint(ctx->endpoints, ctx->project_name, "pubsub",
+                                 "producer", producers[i].identifier,
+                                 producers[i].source_qn, producers[i].file_path,
+                                 producers[i].extra);
+        }
+        for (int i = 0; i < cons_count; i++) {
+            sl_register_endpoint(ctx->endpoints, ctx->project_name, "pubsub",
+                                 "consumer", consumers[i].identifier,
+                                 consumers[i].handler_qn, consumers[i].file_path,
+                                 consumers[i].extra);
+        }
+    }
+
     /* 4. Match consumers to producers by topic name and create edges */
     int link_count = 0;
 
diff --git a/src/pipeline/servicelink_rabbitmq.c b/src/pipeline/servicelink_rabbitmq.c
@@ -599,6 +599,22 @@ int cbm_servicelink_rabbitmq(cbm_pipeline_ctx_t *ctx) {
                  "producers", itoa_amqp(prod_count),
                  "consumers", itoa_amqp(cons_count));
 
+    /* Register endpoints for cross-repo matching */
+    if (ctx->endpoints) {
+        for (int i = 0; i < prod_count; i++) {
+            sl_register_endpoint(ctx->endpoints, ctx->project_name, "rabbitmq",
+                                 "producer", producers[i].identifier,
+                                 producers[i].source_qn, producers[i].file_path,
+                                 producers[i].extra);
+        }
+        for (int i = 0; i < cons_count; i++) {
+            sl_register_endpoint(ctx->endpoints, ctx->project_name, "rabbitmq",
+                                 "consumer", consumers[i].identifier,
+                                 consumers[i].handler_qn, consumers[i].file_path,
+                                 consumers[i].extra);
+        }
+    }
+
     /* 4. Match consumers to producers and create edges */
     int link_count = 0;
 
diff --git a/src/pipeline/servicelink_redis_pubsub.c b/src/pipeline/servicelink_redis_pubsub.c
@@ -578,6 +578,22 @@ int cbm_servicelink_redis_pubsub(cbm_pipeline_ctx_t *ctx) {
                  "producers", itoa_redis(prod_count),
                  "consumers", itoa_redis(cons_count));
 
+    /* Register endpoints for cross-repo matching */
+    if (ctx->endpoints) {
+        for (int i = 0; i < prod_count; i++) {
+            sl_register_endpoint(ctx->endpoints, ctx->project_name, "redis_pubsub",
+                                 "producer", producers[i].identifier,
+                                 producers[i].source_qn, producers[i].file_path,
+                                 producers[i].extra);
+        }
+        for (int i = 0; i < cons_count; i++) {
+            sl_register_endpoint(ctx->endpoints, ctx->project_name, "redis_pubsub",
+                                 "consumer", consumers[i].identifier,
+                                 consumers[i].handler_qn, consumers[i].file_path,
+                                 consumers[i].extra);
+        }
+    }
+
     /* 4. ALL-match: for each consumer, check ALL producers, create edges for matches */
     int link_count = 0;
 
diff --git a/src/pipeline/servicelink_sns.c b/src/pipeline/servicelink_sns.c
@@ -451,6 +451,22 @@ int cbm_servicelink_sns(cbm_pipeline_ctx_t *ctx) {
                  "producers", itoa_sns(prod_count),
                  "consumers", itoa_sns(cons_count));
 
+    /* Register endpoints for cross-repo matching */
+    if (ctx->endpoints) {
+        for (int i = 0; i < prod_count; i++) {
+            sl_register_endpoint(ctx->endpoints, ctx->project_name, "sns",
+                                 "producer", producers[i].identifier,
+                                 producers[i].source_qn, producers[i].file_path,
+                                 producers[i].extra);
+        }
+        for (int i = 0; i < cons_count; i++) {
+            sl_register_endpoint(ctx->endpoints, ctx->project_name, "sns",
+                                 "consumer", consumers[i].identifier,
+                                 consumers[i].handler_qn, consumers[i].file_path,
+                                 consumers[i].extra);
+        }
+    }
+
     /* 4. Match consumers to producers by topic name and create edges */
     int link_count = 0;
 
diff --git a/src/pipeline/servicelink_sqs.c b/src/pipeline/servicelink_sqs.c
@@ -435,6 +435,22 @@ int cbm_servicelink_sqs(cbm_pipeline_ctx_t *ctx) {
                  "producers", itoa_sqs(prod_count),
                  "consumers", itoa_sqs(cons_count));
 
+    /* Register endpoints for cross-repo matching */
+    if (ctx->endpoints) {
+        for (int i = 0; i < prod_count; i++) {
+            sl_register_endpoint(ctx->endpoints, ctx->project_name, "sqs",
+                                 "producer", producers[i].identifier,
+                                 producers[i].source_qn, producers[i].file_path,
+                                 producers[i].extra);
+        }
+        for (int i = 0; i < cons_count; i++) {
+            sl_register_endpoint(ctx->endpoints, ctx->project_name, "sqs",
+                                 "consumer", consumers[i].identifier,
+                                 consumers[i].handler_qn, consumers[i].file_path,
+                                 consumers[i].extra);
+        }
+    }
+
     /* 4. Match consumers to producers and create edges */
     int link_count = 0;
 
diff --git a/src/pipeline/servicelink_sse.c b/src/pipeline/servicelink_sse.c
@@ -425,6 +425,22 @@ int cbm_servicelink_sse(cbm_pipeline_ctx_t *ctx) {
                  "producers", itoa_sse(prod_count),
                  "consumers", itoa_sse(cons_count));
 
+    /* Register endpoints for cross-repo matching */
+    if (ctx->endpoints) {
+        for (int i = 0; i < prod_count; i++) {
+            sl_register_endpoint(ctx->endpoints, ctx->project_name, "sse",
+                                 "producer", producers[i].identifier,
+                                 producers[i].source_qn, producers[i].file_path,
+                                 producers[i].extra);
+        }
+        for (int i = 0; i < cons_count; i++) {
+            sl_register_endpoint(ctx->endpoints, ctx->project_name, "sse",
+                                 "consumer", consumers[i].identifier,
+                                 consumers[i].handler_qn, consumers[i].file_path,
+                                 consumers[i].extra);
+        }
+    }
+
     /* 4. Match consumers to producers using path matching */
     int link_count = 0;
 
diff --git a/src/pipeline/servicelink_trpc.c b/src/pipeline/servicelink_trpc.c
@@ -324,6 +324,22 @@ int cbm_servicelink_trpc(cbm_pipeline_ctx_t *ctx) {
                  "producers", itoa_trpc(prod_count),
                  "consumers", itoa_trpc(cons_count));
 
+    /* Register endpoints for cross-repo matching */
+    if (ctx->endpoints) {
+        for (int i = 0; i < prod_count; i++) {
+            sl_register_endpoint(ctx->endpoints, ctx->project_name, "trpc",
+                                 "producer", producers[i].identifier,
+                                 producers[i].source_qn, producers[i].file_path,
+                                 producers[i].extra);
+        }
+        for (int i = 0; i < cons_count; i++) {
+            sl_register_endpoint(ctx->endpoints, ctx->project_name, "trpc",
+                                 "consumer", consumers[i].identifier,
+                                 consumers[i].handler_qn, consumers[i].file_path,
+                                 consumers[i].extra);
+        }
+    }
+
     /* 4. Best-match: find best matching producer for each consumer */
     int link_count = 0;
 
diff --git a/src/pipeline/servicelink_ws.c b/src/pipeline/servicelink_ws.c
@@ -530,6 +530,22 @@ int cbm_servicelink_ws(cbm_pipeline_ctx_t *ctx) {
                  "producers", itoa_ws(prod_count),
                  "consumers", itoa_ws(cons_count));
 
+    /* Register endpoints for cross-repo matching */
+    if (ctx->endpoints) {
+        for (int i = 0; i < prod_count; i++) {
+            sl_register_endpoint(ctx->endpoints, ctx->project_name, "ws",
+                                 "producer", producers[i].identifier,
+                                 producers[i].source_qn, producers[i].file_path,
+                                 producers[i].extra);
+        }
+        for (int i = 0; i < cons_count; i++) {
+            sl_register_endpoint(ctx->endpoints, ctx->project_name, "ws",
+                                 "consumer", consumers[i].identifier,
+                                 consumers[i].handler_qn, consumers[i].file_path,
+                                 consumers[i].extra);
+        }
+    }
+
     /* 4. Match consumers to producers using path matching and create edges */
     int link_count = 0;
 
