refactor: unify cross-repo storage on edges table

Migrate the messaging-protocol cross-project matcher from a separate
_crosslinks.db file to bidirectional CROSS_* edges in each project's
edges table. Add 11 new CROSS_* edge type constants for messaging
protocols (KAFKA, SQS, SNS, EVENTBRIDGE, PUBSUB, AMQP, MQTT, NATS,
REDIS_PUBSUB, WS, SSE).

Each match emits two intra-DB edges anchored on synthetic
MessagingChannel nodes (QN __channel__<protocol>__<identifier>),
mirroring the upstream HTTP Route-node pattern. Producer DB gets
function -> channel; consumer DB gets channel -> function. Cross-project
metadata lives in edge properties JSON.

The matcher now skips http/grpc/graphql/trpc protocols entirely; those
are owned by the upstream Route-QN matcher in pass_cross_repo.c.

Author: Shidfar

src/pipeline/pass_cross_repo.c

@@ -39,6 +39,42 @@ enum {
 #define CR_MS_PER_SEC 1000.0
 #define CR_NS_PER_MS 1000000.0
 
+/* ── Messaging protocol → CROSS_* edge type mapping ──────────────
+ *
+ * Upstream owns HTTP/gRPC/GraphQL/tRPC via Route-QN matching, so those
+ * protocols are intentionally absent from this mapping: the messaging
+ * matcher in pass_crossrepolinks.c skips them via
+ * cbm_messaging_protocol_to_cross_edge() returning NULL, leaving upstream
+ * as the sole source of their CROSS_* edges.
+ */
+const char *const CBM_MESSAGING_CROSS_EDGE_TYPES[CBM_MESSAGING_CROSS_EDGE_TYPE_COUNT] = {
+    CBM_EDGE_CROSS_KAFKA_CALLS,        CBM_EDGE_CROSS_SQS_CALLS,
+    CBM_EDGE_CROSS_SNS_CALLS,          CBM_EDGE_CROSS_EVENTBRIDGE_CALLS,
+    CBM_EDGE_CROSS_PUBSUB_CALLS,       CBM_EDGE_CROSS_AMQP_CALLS,
+    CBM_EDGE_CROSS_MQTT_CALLS,         CBM_EDGE_CROSS_NATS_CALLS,
+    CBM_EDGE_CROSS_REDIS_PUBSUB_CALLS, CBM_EDGE_CROSS_WS_CALLS,
+    CBM_EDGE_CROSS_SSE_CALLS,
+};
+
+const char *cbm_messaging_protocol_to_cross_edge(const char *protocol) {
+    if (!protocol) {
+        return NULL;
+    }
+    if (strcmp(protocol, "kafka") == 0)        return CBM_EDGE_CROSS_KAFKA_CALLS;
+    if (strcmp(protocol, "sqs") == 0)          return CBM_EDGE_CROSS_SQS_CALLS;
+    if (strcmp(protocol, "sns") == 0)          return CBM_EDGE_CROSS_SNS_CALLS;
+    if (strcmp(protocol, "eventbridge") == 0)  return CBM_EDGE_CROSS_EVENTBRIDGE_CALLS;
+    if (strcmp(protocol, "pubsub") == 0)       return CBM_EDGE_CROSS_PUBSUB_CALLS;
+    if (strcmp(protocol, "rabbitmq") == 0)     return CBM_EDGE_CROSS_AMQP_CALLS;
+    if (strcmp(protocol, "amqp") == 0)         return CBM_EDGE_CROSS_AMQP_CALLS;
+    if (strcmp(protocol, "mqtt") == 0)         return CBM_EDGE_CROSS_MQTT_CALLS;
+    if (strcmp(protocol, "nats") == 0)         return CBM_EDGE_CROSS_NATS_CALLS;
+    if (strcmp(protocol, "redis_pubsub") == 0) return CBM_EDGE_CROSS_REDIS_PUBSUB_CALLS;
+    if (strcmp(protocol, "ws") == 0)           return CBM_EDGE_CROSS_WS_CALLS;
+    if (strcmp(protocol, "sse") == 0)          return CBM_EDGE_CROSS_SSE_CALLS;
+    return NULL;
+}
+
 /* TLS buffer for integer-to-string in log calls. */
 static CBM_TLS char cr_ibuf[CBM_SZ_32];
 static const char *cr_itoa(int v) {

src/pipeline/pass_cross_repo.h

@@ -7,6 +7,41 @@
 
 #include "store/store.h"
 
+/* ── CROSS_* edge type names ─────────────────────────────────────
+ *
+ * Upstream Route-QN matcher emits the first six. The messaging matcher
+ * (pass_crossrepolinks.c) emits the remaining eleven.
+ */
+#define CBM_EDGE_CROSS_HTTP_CALLS    "CROSS_HTTP_CALLS"
+#define CBM_EDGE_CROSS_ASYNC_CALLS   "CROSS_ASYNC_CALLS"
+#define CBM_EDGE_CROSS_CHANNEL       "CROSS_CHANNEL"
+#define CBM_EDGE_CROSS_GRPC_CALLS    "CROSS_GRPC_CALLS"
+#define CBM_EDGE_CROSS_GRAPHQL_CALLS "CROSS_GRAPHQL_CALLS"
+#define CBM_EDGE_CROSS_TRPC_CALLS    "CROSS_TRPC_CALLS"
+
+#define CBM_EDGE_CROSS_KAFKA_CALLS        "CROSS_KAFKA_CALLS"
+#define CBM_EDGE_CROSS_SQS_CALLS          "CROSS_SQS_CALLS"
+#define CBM_EDGE_CROSS_SNS_CALLS          "CROSS_SNS_CALLS"
+#define CBM_EDGE_CROSS_EVENTBRIDGE_CALLS  "CROSS_EVENTBRIDGE_CALLS"
+#define CBM_EDGE_CROSS_PUBSUB_CALLS       "CROSS_PUBSUB_CALLS"
+#define CBM_EDGE_CROSS_AMQP_CALLS         "CROSS_AMQP_CALLS"
+#define CBM_EDGE_CROSS_MQTT_CALLS         "CROSS_MQTT_CALLS"
+#define CBM_EDGE_CROSS_NATS_CALLS         "CROSS_NATS_CALLS"
+#define CBM_EDGE_CROSS_REDIS_PUBSUB_CALLS "CROSS_REDIS_PUBSUB_CALLS"
+#define CBM_EDGE_CROSS_WS_CALLS           "CROSS_WS_CALLS"
+#define CBM_EDGE_CROSS_SSE_CALLS          "CROSS_SSE_CALLS"
+
+/* All messaging CROSS_* edge types produced by pass_crossrepolinks.c.
+ * Used for idempotent cleanup before re-emission and for MCP queries. */
+extern const char *const CBM_MESSAGING_CROSS_EDGE_TYPES[];
+#define CBM_MESSAGING_CROSS_EDGE_TYPE_COUNT 11
+
+/* Map a messaging protocol name (e.g. "kafka") to its CROSS_* edge type
+ * constant (e.g. "CROSS_KAFKA_CALLS"). Returns NULL for unknown/skipped
+ * protocols ("http", "grpc", "graphql", "trpc" are owned by the upstream
+ * Route-QN matcher and intentionally return NULL here). */
+const char *cbm_messaging_protocol_to_cross_edge(const char *protocol);
+
 /* Result of a cross-repo matching run. */
 typedef struct {
     int http_edges;    /* CROSS_HTTP_CALLS edges created */