fix(nexus/graph): query instance detail across all selected graphs (#1051)

The Composer's instance inspector returned empty detail when an individual's
triples were split across multiple selected graphs. The whole pipeline was
single-graph: InstanceDrawer looped over the selected graphs and stopped at the
first one returning any triple (e.g. the graph holding rdf:type), so data
properties and relations living in another graph were never fetched.

Make instance-detail span every selected graph in one request:
- DiscoveryInstanceDetailRequest accepts graph_uris: list[str] (graph_uri kept
  for back-compat); a model_validator merges + dedupes and errors if none given.
- _discover_instance_detail_sync expands all four VALUES ?g {...} clauses to
  range over every graph; add relation dedup since multi-graph can surface the
  same triple from two graphs.
- FastAPI handler forwards payload.graph_uris.
- fetchInstanceDetail takes graphUris: string[] and posts graph_uris.
- InstanceDrawer makes one multi-graph call instead of the first-wins loop.

Author: Dr0p42

libs/naas-abi/naas_abi/apps/nexus/apps/api/app/services/graph/adapters/primary/graph__primary_adapter__FastAPI.py

@@ -939,7 +939,7 @@ async def discovery_instance_detail(
     try:
         detail = await graph_service.discover_instance_detail(
             workspace_id=payload.workspace_id,
-            graph_uri=payload.graph_uri,
+            graph_uris=payload.graph_uris,
             instance_uri=payload.instance_uri,
         )
     except Exception as exc:

libs/naas-abi/naas_abi/apps/nexus/apps/api/app/services/graph/adapters/primary/graph__primary_adapter__schemas.py

@@ -3,7 +3,7 @@
 from datetime import datetime
 from typing import Any
 
-from pydantic import BaseModel, Field
+from pydantic import BaseModel, Field, model_validator
 
 
 class GraphInfo(BaseModel):
@@ -244,9 +244,25 @@ class DiscoveryInstanceDetail(BaseModel):
 
 class DiscoveryInstanceDetailRequest(BaseModel):
     workspace_id: str = Field(..., min_length=1, max_length=100)
-    graph_uri: str = Field(..., min_length=1)
+    # An instance's triples can be split across several named graphs (e.g. its
+    # rdf:type in one graph, its data properties in another). Pass every selected
+    # graph in `graph_uris` so the detail query spans them all. `graph_uri` is
+    # kept for back-compat with older callers that send a single graph.
+    graph_uri: str | None = Field(default=None, min_length=1)
+    graph_uris: list[str] = Field(default_factory=list)
     instance_uri: str = Field(..., min_length=1)
 
+    @model_validator(mode="after")
+    def _merge_graph_uris(self) -> DiscoveryInstanceDetailRequest:
+        merged: list[str] = []
+        for g in [*self.graph_uris, *([self.graph_uri] if self.graph_uri else [])]:
+            if g and g not in merged:
+                merged.append(g)
+        if not merged:
+            raise ValueError("at least one of graph_uri or graph_uris is required")
+        self.graph_uris = merged
+        return self
+
 
 class DiscoveryRelationType(BaseModel):
     uri: str

libs/naas-abi/naas_abi/apps/nexus/apps/api/app/services/graph/service.py

@@ -2747,21 +2747,25 @@ def _discover_instances_sync(
     async def discover_instance_detail(
         self,
         workspace_id: str,
-        graph_uri: str,
+        graph_uris: list[str],
         instance_uri: str,
     ) -> DiscoveryInstanceDetailData:
         return await asyncio.to_thread(
-            self._discover_instance_detail_sync, workspace_id, graph_uri, instance_uri
+            self._discover_instance_detail_sync, workspace_id, graph_uris, instance_uri
         )
 
     def _discover_instance_detail_sync(
         self,
         workspace_id: str,
-        graph_uri: str,
+        graph_uris: list[str],
         instance_uri: str,
     ) -> DiscoveryInstanceDetailData:
         store = self._get_triple_store()
 
+        # The instance's triples may be spread across several named graphs, so every
+        # sub-query below ranges over all selected graphs via this VALUES list.
+        graph_values = " ".join(f"<{g}>" for g in graph_uris)
+
         # Label and class
         label = _get_ontology_label(store, instance_uri) or _uri_fragment(instance_uri)
         class_uri = ""
@@ -2770,7 +2774,7 @@ def _discover_instance_detail_sync(
         PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>
         PREFIX owl: <http://www.w3.org/2002/07/owl#>
         SELECT ?cls WHERE {{
-            VALUES ?g {{ <{graph_uri}> }}
+            VALUES ?g {{ {graph_values} }}
             GRAPH ?g {{
                 <{instance_uri}> rdf:type ?cls .
                 FILTER(isIRI(?cls))
@@ -2796,7 +2800,7 @@ def _discover_instance_detail_sync(
         seen_data_triples: set[tuple[str, str]] = set()
         dp_query = f"""
         SELECT ?p ?o WHERE {{
-            VALUES ?g {{ <{graph_uri}> }}
+            VALUES ?g {{ {graph_values} }}
             GRAPH ?g {{
                 <{instance_uri}> ?p ?o .
                 FILTER(isLiteral(?o))
@@ -2831,11 +2835,12 @@ def _discover_instance_detail_sync(
 
         # Outgoing relations (instance is domain/subject)
         inspector_relations: list[DiscoveryInspectorRelation] = []
+        seen_relations: set[tuple[str, str, str]] = set()
         out_query = f"""
         PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>
         PREFIX rdfs: <http://www.w3.org/2000/01/rdf-schema#>
         SELECT ?p ?pLabel ?o ?oLabel WHERE {{
-            VALUES ?g {{ <{graph_uri}> }}
+            VALUES ?g {{ {graph_values} }}
             GRAPH ?g {{
                 <{instance_uri}> ?p ?o .
                 FILTER(?p != rdf:type)
@@ -2855,6 +2860,10 @@ def _discover_instance_detail_sync(
                     continue
                 pred_uri = str(p)
                 other_uri = str(o)
+                rel_key = ("domain", pred_uri, other_uri)
+                if rel_key in seen_relations:
+                    continue
+                seen_relations.add(rel_key)
                 p_label_val = getattr(row, "pLabel", None)
                 o_label_val = getattr(row, "oLabel", None)
                 inspector_relations.append(
@@ -2878,7 +2887,7 @@ def _discover_instance_detail_sync(
         PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>
         PREFIX rdfs: <http://www.w3.org/2000/01/rdf-schema#>
         SELECT ?s ?sLabel ?p ?pLabel WHERE {{
-            VALUES ?g {{ <{graph_uri}> }}
+            VALUES ?g {{ {graph_values} }}
             GRAPH ?g {{
                 ?s ?p <{instance_uri}> .
                 FILTER(?p != rdf:type)
@@ -2898,6 +2907,10 @@ def _discover_instance_detail_sync(
                     continue
                 pred_uri = str(p)
                 other_uri = str(s)
+                rel_key = ("range", pred_uri, other_uri)
+                if rel_key in seen_relations:
+                    continue
+                seen_relations.add(rel_key)
                 p_label_val = getattr(row, "pLabel", None)
                 s_label_val = getattr(row, "sLabel", None)
                 inspector_relations.append(

libs/naas-abi/naas_abi/apps/nexus/apps/web/src/components/graph/explore/InstanceDrawer.tsx

@@ -9,7 +9,7 @@ export interface InstanceDrawerProps {
   workspaceId: string
   /** The inspect history stack of individual IRIs; the last entry is the one shown. */
   trail: string[]
-  /** Graphs to look in (the Composer's selected graphs); the first that has it wins. */
+  /** Graphs to look in (the Composer's selected graphs); the detail query unions across them all. */
   graphs: string[]
   onClose: () => void
   /** Escalate to the full Individuals page for this individual. */
@@ -29,7 +29,8 @@ const STORAGE_KEY = 'composer-inspect-width-v2'
  * Side panel that shows one individual's detail (data properties + relations). It sits as a
  * flex sibling of the table (pushing it, not overlaying), is resizable by dragging its left
  * edge, and keeps a breadcrumb trail so relation hops can be walked back. The grain query only
- * knows a row's URI, not its graph, so we resolve the graph by trying each selected graph.
+ * knows a row's URI, not its graph, and an individual's triples can be split across graphs, so
+ * the detail query spans every selected graph in one request.
  */
 export function InstanceDrawer({
   workspaceId,
@@ -121,23 +122,16 @@ export function InstanceDrawer({
     setDetail(null)
     setNotFound(false)
     ;(async () => {
-      for (const g of graphList) {
-        try {
-          const d = await fetchInstanceDetail({ workspaceId, graphUri: g, instanceUri: uri })
-          if (cancelled) return
-          const found = !!d.class_uri || d.data_properties.length > 0 || d.relations.length > 0
-          if (found) {
-            setDetail(d)
-            setLoading(false)
-            return
-          }
-        } catch {
-          /* not in this graph — try the next */
-        }
-      }
-      if (!cancelled) {
-        setNotFound(true)
-        setLoading(false)
+      try {
+        const d = await fetchInstanceDetail({ workspaceId, graphUris: graphList, instanceUri: uri })
+        if (cancelled) return
+        const found = !!d.class_uri || d.data_properties.length > 0 || d.relations.length > 0
+        if (found) setDetail(d)
+        else setNotFound(true)
+      } catch {
+        if (!cancelled) setNotFound(true)
+      } finally {
+        if (!cancelled) setLoading(false)
       }
     })()
     return () => {

libs/naas-abi/naas_abi/apps/nexus/apps/web/src/lib/graph-query/client.ts

@@ -177,15 +177,20 @@ export interface InstanceDetail {
   relations: InstanceRelation[]
 }
 
-/** POST /api/graph/discovery/instance-detail — full detail for one individual in a graph. */
+/**
+ * POST /api/graph/discovery/instance-detail — full detail for one individual.
+ * An individual's triples can be split across several named graphs (its rdf:type in
+ * one, its data properties/relations in another), so pass every selected graph and the
+ * backend unions across them all.
+ */
 export function fetchInstanceDetail(params: {
   workspaceId: string
-  graphUri: string
+  graphUris: string[]
   instanceUri: string
 }): Promise<InstanceDetail> {
   return postJson<InstanceDetail>(`/api/graph/discovery/instance-detail`, {
     workspace_id: params.workspaceId,
-    graph_uri: params.graphUri,
+    graph_uris: params.graphUris,
     instance_uri: params.instanceUri,
   })
 }