Skip to content

Storage unification + incremental parity + MCP reader migration (PR 5/5) #380

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
Shidfar wants to merge 21 commits into
base: main
Choose a base branch
from
Open

Storage unification + incremental parity + MCP reader migration (PR 5/5) #380

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
21 commits
Select commit Hold shift + click to select a range
9e5cc64
feat: add cross-service protocol linking infrastructure
Shidfar Apr 9, 2026
1f0a130
feat: add GraphQL and gRPC protocol linkers
Shidfar Apr 9, 2026
d591f09
feat: add Kafka, SQS, SNS, and EventBridge protocol linkers
Shidfar Apr 9, 2026
c23579b
feat: add Pub/Sub, RabbitMQ, MQTT, NATS, and Redis Pub/Sub linkers
Shidfar Apr 9, 2026
e4ada4f
feat: add WebSocket, SSE, and tRPC protocol linkers
Shidfar Apr 9, 2026
43082f4
build: wire 14 protocol linkers into pipeline
Shidfar May 25, 2026
f312a49
feat: add cross-repo protocol linking and community detection
Shidfar Apr 9, 2026
7fa8444
feat: add paginated summary guard to cross_project_links
Shidfar Apr 24, 2026
8544167
build: wire cross-repo pass + community detection into pipeline
Shidfar May 25, 2026
0d14141
feat: add HTTP servicelinker plumbing
Shidfar Apr 22, 2026
723afa2
feat: implement HTTP cross-project endpoint registration
Shidfar Apr 22, 2026
4d20d88
feat: add HTTP-aware cross-repo matcher with ambiguity handling
Shidfar Apr 22, 2026
e34234e
test: add HTTP cross-project linker tests and fixtures
Shidfar Apr 22, 2026
39bbeb2
fix: make S2 and S3 signals reachable in HTTP linker
Shidfar Apr 22, 2026
72bdc20
fix: scope MAX_CANDIDATES cap to HTTP protocol only
Shidfar Apr 23, 2026
3d208ec
test: widen incr_accuracy_vs_full nodes tolerance to ±15
Shidfar Apr 27, 2026
fff9ab5
refactor: unify cross-repo storage on edges table
Shidfar Apr 27, 2026
48efad2
fix: invoke cbm_cross_project_link from incremental pipeline
Shidfar Apr 27, 2026
e7bef62
feat(mcp): migrate cross_project_links reader to per-project edges
Shidfar May 26, 2026
059bf8a
test(mcp): cover cross_project_links reader end-to-end
Shidfar May 26, 2026
cca215b
docs(README): align with upstream/main
Shidfar May 26, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
45 changes: 40 additions & 5 deletions Makefile.cbm
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -197,7 +197,25 @@ PIPELINE_SRCS = \
src/pipeline/pass_semantic_edges.c \
src/pipeline/pass_cross_repo.c \
src/pipeline/artifact.c \
src/pipeline/pass_pkgmap.c
src/pipeline/pass_pkgmap.c \
src/pipeline/pass_servicelinks.c \
src/pipeline/servicelink_graphql.c \
src/pipeline/servicelink_grpc.c \
src/pipeline/servicelink_kafka.c \
src/pipeline/servicelink_sqs.c \
src/pipeline/servicelink_sns.c \
src/pipeline/servicelink_ws.c \
src/pipeline/servicelink_sse.c \
src/pipeline/servicelink_pubsub.c \
src/pipeline/servicelink_rabbitmq.c \
src/pipeline/servicelink_eventbridge.c \
src/pipeline/servicelink_mqtt.c \
src/pipeline/servicelink_nats.c \
src/pipeline/servicelink_redis_pubsub.c \
src/pipeline/servicelink_trpc.c \
src/pipeline/servicelink_http.c \
src/pipeline/pass_communities.c \
src/pipeline/pass_crossrepolinks.c

# SimHash / MinHash module
SIMHASH_SRCS = src/simhash/minhash.c
Expand Down Expand Up @@ -337,7 +355,6 @@ TEST_INTEGRATION_SRCS = tests/test_integration.c tests/test_incremental.c

TEST_TRACES_SRCS = tests/test_traces.c


TEST_CLI_SRCS = tests/test_cli.c

TEST_MEM_SRCS = tests/test_mem.c
Expand All @@ -351,9 +368,27 @@ TEST_YAML_SRCS = tests/test_yaml.c
TEST_SIMHASH_SRCS = tests/test_simhash.c

TEST_STACK_OVERFLOW_SRCS = tests/test_stack_overflow.c

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_ZSTD_SRCS) $(TEST_ARTIFACT_SRCS) $(TEST_SQLITE_WRITER_SRCS) $(TEST_GO_LSP_SRCS) $(TEST_C_LSP_SRCS) $(TEST_PHP_LSP_SRCS) $(TEST_CS_LSP_SRCS) $(TEST_CS_LSP_BENCH_SRCS) $(TEST_SCOPE_SRCS) $(TEST_TYPE_REP_SRCS) $(TEST_PY_LSP_SRCS) $(TEST_PY_LSP_BENCH_SRCS) $(TEST_PY_LSP_STRESS_SRCS) $(TEST_PY_LSP_SCALE_SRCS) $(TEST_TS_LSP_SRCS) $(TEST_TRACES_SRCS) $(TEST_CLI_SRCS) $(TEST_MEM_SRCS) $(TEST_UI_SRCS) $(TEST_SECURITY_SRCS) $(TEST_YAML_SRCS) $(TEST_SIMHASH_SRCS) $(TEST_STACK_OVERFLOW_SRCS) $(TEST_INTEGRATION_SRCS)

TEST_ENDPOINT_REGISTRY_SRCS = tests/test_endpoint_registry.c
TEST_SERVICELINK_GRAPHQL_SRCS = tests/test_servicelink_graphql.c
TEST_SERVICELINK_GRPC_SRCS = tests/test_servicelink_grpc.c
TEST_SERVICELINK_KAFKA_SRCS = tests/test_servicelink_kafka.c
TEST_SERVICELINK_SQS_SRCS = tests/test_servicelink_sqs.c
TEST_SERVICELINK_SNS_SRCS = tests/test_servicelink_sns.c
TEST_SERVICELINK_WS_SRCS = tests/test_servicelink_ws.c
TEST_SERVICELINK_SSE_SRCS = tests/test_servicelink_sse.c
TEST_SERVICELINK_PUBSUB_SRCS = tests/test_servicelink_pubsub.c
TEST_SERVICELINK_RABBITMQ_SRCS = tests/test_servicelink_rabbitmq.c
TEST_SERVICELINK_EVENTBRIDGE_SRCS = tests/test_servicelink_eventbridge.c
TEST_SERVICELINK_MQTT_SRCS = tests/test_servicelink_mqtt.c
TEST_SERVICELINK_NATS_SRCS = tests/test_servicelink_nats.c
TEST_SERVICELINK_REDIS_PUBSUB_SRCS = tests/test_servicelink_redis_pubsub.c
TEST_SERVICELINK_TRPC_SRCS = tests/test_servicelink_trpc.c
TEST_SERVICELINK_HTTP_SRCS = tests/test_servicelink_http.c
TEST_COMMUNITIES_SRCS = tests/test_communities.c
TEST_ENDPOINT_PERSISTENCE_SRCS = tests/test_endpoint_persistence.c
TEST_CROSS_PROJECT_LINKS_SRCS = tests/test_cross_project_links.c

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_ZSTD_SRCS) $(TEST_ARTIFACT_SRCS) $(TEST_SQLITE_WRITER_SRCS) $(TEST_GO_LSP_SRCS) $(TEST_C_LSP_SRCS) $(TEST_PHP_LSP_SRCS) $(TEST_CS_LSP_SRCS) $(TEST_CS_LSP_BENCH_SRCS) $(TEST_SCOPE_SRCS) $(TEST_TYPE_REP_SRCS) $(TEST_PY_LSP_SRCS) $(TEST_PY_LSP_BENCH_SRCS) $(TEST_PY_LSP_STRESS_SRCS) $(TEST_PY_LSP_SCALE_SRCS) $(TEST_TS_LSP_SRCS) $(TEST_TRACES_SRCS) $(TEST_CLI_SRCS) $(TEST_MEM_SRCS) $(TEST_UI_SRCS) $(TEST_SECURITY_SRCS) $(TEST_YAML_SRCS) $(TEST_SIMHASH_SRCS) $(TEST_STACK_OVERFLOW_SRCS) $(TEST_INTEGRATION_SRCS) $(TEST_ENDPOINT_REGISTRY_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) $(TEST_SERVICELINK_HTTP_SRCS) $(TEST_COMMUNITIES_SRCS) $(TEST_ENDPOINT_PERSISTENCE_SRCS) $(TEST_CROSS_PROJECT_LINKS_SRCS)

# ── Build directories ────────────────────────────────────────────

Expand Down
Loading