address PR review: MCP producer strings and pass6 producer_kind

Update server tool descriptions for the four-kind graph surface; use
ProducerRow.producer_kind in pass6 async rematch; fix AGENT-GUIDE v14 banner tense.

Co-authored-by: Cursor <cursoragent@cursor.com>

Author: HumanBean17

build_ast_graph.py

@@ -2142,10 +2142,11 @@ def _micro_factor(member: MemberEntry | None) -> float:
             member = member_by_id.get(producer.member_id) if producer else None
             base = row.confidence / max(1e-9, (0.3 * _micro_factor(member)))
             src_route = route_by_id.get(row.route_id)
+            async_kind = producer.producer_kind if producer else "kafka_send"
             call = OutgoingCallDecl(
                 method_fqn=f"{member.parent_fqn}#{member.decl.signature}" if member else "",
                 method_sig=member.decl.signature if member else "",
-                client_kind="kafka_send",
+                client_kind=async_kind,
                 channel="async",
                 feign_target_name="",
                 feign_target_url="",

docs/AGENT-GUIDE.md

@@ -15,7 +15,7 @@
 > Calibrated against ontology version **14** (see `ast_java.ONTOLOGY_VERSION` /
 > `java_ontology.EDGE_SCHEMA` + valid sets): canonical edge navigation schema in
 > `docs/EDGE-NAVIGATION.md`. v14 re-index required; `HTTP_CALLS` is `Client → Route`;
-> PR-C adds `Producer` + `DECLARES_PRODUCER` and flips `ASYNC_CALLS`.
+> `Producer` + `DECLARES_PRODUCER` and `ASYNC_CALLS` (`Producer → Route`) ship in v14.
 > Still includes stored `OVERRIDES` Symbol→Symbol edges and v12 HTTP brownfield
 > (`@CodebaseHttpClient`, shared `CodebaseHttpMethod` enum, inbound layer-C HTTP routes
 > replace same-method built-in rows). **Design rationale:** navigation surface and tools —

server.py

@@ -27,7 +27,7 @@
     "Java codebase graph navigator (LanceDB + Kuzu). "
     "Tools: search (NL/code locate), find (structured NodeFilter), describe (one node + edge_summary: stored edge-label counts and optional composed keys for type Symbols and override-axis virtual keys for method Symbols), "
     "neighbors (one hop; you MUST pass direction in|out AND edge_types list — no defaults), "
-    "resolve (identifier-shaped lookup for symbol/route/client — three statuses one|many|none). "
+    "resolve (identifier-shaped lookup for symbol/route/client/producer — three statuses one|many|none). "
     "NodeFilter `filter` is a JSON object (preferred); a JSON-encoded string is also accepted as a fallback. "
     "Unknown filter keys and populated fields not applicable to the effective node kind fail with success=false and message. "
     "Edge labels: EXTENDS, IMPLEMENTS, INJECTS, OVERRIDES, DECLARES, DECLARES_CLIENT, DECLARES_PRODUCER, CALLS, EXPOSES, HTTP_CALLS, ASYNC_CALLS. "
@@ -385,7 +385,8 @@ async def search(
             "Exact structured listing for one node kind. Per-kind applicable fields: **symbol** — "
             "microservice, module, role, exclude_roles, annotation, capability, fqn_prefix, symbol_kind, symbol_kinds; "
             "**route** — microservice, module, http_method, path_prefix, framework; **client** — microservice, module, "
-            "source_layer, client_kind, target_service, target_path_prefix, http_method. "
+            "source_layer, client_kind, target_service, target_path_prefix, http_method; **producer** — microservice, "
+            "module, source_layer, producer_kind, topic_prefix. "
             "Wildcards in prefix fields are rejected. An empty filter (`{}`) or `filter=None` means no predicate (all nodes of "
             "that kind; use pagination). Unknown keys or inapplicable populated fields return success=false. "
             "Successful responses echo `limit`/`offset` and may include `hints` (advisory next-step strings)."
@@ -395,7 +396,8 @@ async def find(
         kind: Literal["symbol", "route", "client", "producer"] = Field(
             description=(
                 "Which graph table to search. 'symbol' = declarations, "
-                "'route' = endpoints, 'client' = outbound clients."
+                "'route' = endpoints, 'client' = outbound HTTP clients, "
+                "'producer' = outbound async producers."
             )
         ),
         filter: dict[str, Any] | str = Field(
@@ -429,8 +431,9 @@ async def describe(
         id: str | None = Field(
             default=None,
             description=(
-                "Graph node id: sym:, route:, or client: prefix "
-                '(e.g. sym:com.bank.chat.core.api.ChatController#joinOperator(JoinOperatorRequest)). '
+                "Graph node id: sym:, route:, client:, or producer: prefix "
+                '(e.g. sym:com.bank.chat.core.api.ChatController#joinOperator(JoinOperatorRequest); '
+                "producer:svc|com.foo.Bar#send()|kafka_send|orders.created). "
                 "When set, takes precedence over fqn."
             ),
         ),
@@ -453,7 +456,9 @@ async def describe(
         ),
     )
     async def neighbors(
-        ids: str | list[str] = Field(description="Origin symbol/route/client id, or list for batch"),
+        ids: str | list[str] = Field(
+            description="Origin symbol/route/client/producer id, or list for batch",
+        ),
         direction: Literal["in", "out"] = Field(
             description="Required. 'in' = predecessors (callers), 'out' = successors (callees). No default.",
         ),
@@ -494,8 +499,8 @@ async def neighbors(
     @mcp.tool(
         name="resolve",
         description=(
-            "Identifier-shaped node lookup (FQN, sym:/route:/client: id, HTTP method+path, "
-            "route path template, client target_service, or target+path pair). Returns "
+            "Identifier-shaped node lookup (FQN, sym:/route:/client:/producer: id, HTTP method+path, "
+            "route path template, client target_service, target+path pair, or producer topic). Returns "
             "status=one (single node), many (≥2 ranked candidates with reason), or none "
             "(no match — fall back to search(query=...) for natural language or fuzzy text). "
             "Optional hint_kind narrows to symbol, route, client, or producer. "
@@ -508,11 +513,13 @@ async def neighbors(
     )
     async def resolve(
         identifier: str = Field(
-            description="Identifier-shaped node lookup (FQN, id prefix, route path, client target, …)",
+            description=(
+                "Identifier-shaped node lookup (FQN, id prefix, route path, client target, producer topic, …)"
+            ),
         ),
         hint_kind: Literal["symbol", "route", "client", "producer"] | None = Field(
             default=None,
-            description="Optional kind constraint. Omit to search all three kinds.",
+            description="Optional kind constraint. Omit to search symbol, route, client, and producer.",
         ),
     ) -> mcp_v2.ResolveOutput:
         return await asyncio.to_thread(mcp_v2.resolve_v2, identifier, hint_kind, None)