Graph.

# Who placed this order?
curl "https://$OC_HOST/v1/tenants/$OC_TENANT/graph/shop.orders/neighbors?rel=placed_by&pk=01JTRX9KQ3YH8K2WMX0F5JZAB7" \
  -H "Authorization: Bearer $OC_TOKEN"

const pks = await db.graph.neighbors("shop.orders", {
  rel: "placed_by",
  pk:  "01JTRX9KQ3YH8K2WMX0F5JZAB7",
});
console.log(pks);   // string[] - raw primary keys

hits = db.graph.neighbors(
    "shop.orders",
    rel="placed_by",
    pk="01JTRX9KQ3YH8K2WMX0F5JZAB7",
)
for n in hits:
    print(n.pk, n.depth)   # depth is always 1 here

hits, err := db.Graph().Neighbors(ctx, "shop.orders", originchain.NeighborsRequest{
    Rel: "placed_by",
    PK:  "01JTRX9KQ3YH8K2WMX0F5JZAB7",
})
if err != nil { /* handle */ }
for _, n := range hits {
    fmt.Println(n.PK, n.Depth)   // Depth is always 1 here
}

# Flip it: which orders did this customer place?
curl "https://$OC_HOST/v1/tenants/$OC_TENANT/graph/shop.orders/reverse?rel=placed_by&pk=01JTRX1H4Q9P0N2WMX0F5JZ001" \
  -H "Authorization: Bearer $OC_TOKEN"

const pks = await db.graph.reverseNeighbors("shop.orders", {
  rel: "placed_by",
  pk:  "01JTRX1H4Q9P0N2WMX0F5JZ001",
});
console.log(pks.length, "orders for this customer");

hits = db.graph.reverse_neighbors(
    "shop.orders",
    rel="placed_by",
    pk="01JTRX1H4Q9P0N2WMX0F5JZ001",
)
print(len(hits), "orders for this customer")

hits, err := db.Graph().ReverseNeighbors(ctx, "shop.orders", originchain.NeighborsRequest{
    Rel: "placed_by",
    PK:  "01JTRX1H4Q9P0N2WMX0F5JZ001",
})
if err != nil { /* handle */ }
fmt.Println(len(hits), "orders for this customer")

# Everyone within 3 referral hops of this customer.
curl "https://$OC_HOST/v1/tenants/$OC_TENANT/graph/shop.customers/bfs?rel=referrer&pk=01JTRX1H4Q9P0N2WMX0F5JZ001&max_depth=3" \
  -H "Authorization: Bearer $OC_TOKEN"

const hits = await db.graph.bfs("shop.customers", {
  rel:       "referrer",
  pk:        "01JTRX1H4Q9P0N2WMX0F5JZ001",
  max_depth: 3,
});
for (const h of hits) console.log(h.depth, h.pk);

hits = db.graph.bfs(
    "shop.customers",
    rel="referrer",
    pk="01JTRX1H4Q9P0N2WMX0F5JZ001",
    max_depth=3,
)
for h in hits:
    print(h.depth, h.pk)

hits, err := db.Graph().BFS(ctx, "shop.customers", originchain.BFSRequest{
    Rel:      "referrer",
    PK:       "01JTRX1H4Q9P0N2WMX0F5JZ001",
    MaxDepth: 3,
})
if err != nil { /* handle */ }
for _, h := range hits {
    fmt.Println(h.Depth, h.PK)
}

curl "https://$OC_HOST/v1/tenants/$OC_TENANT/graph/shop.customers/path?rel=referrer&src=01JTRX1H4Q9P0N2WMX0F5JZ001&dst=01JTRX1H4Q9P0N2WMX0F5JZ027&max_depth=3" \
  -H "Authorization: Bearer $OC_TOKEN"

const res = await db.graph.path("shop.customers", {
  rel:       "referrer",
  src:       "01JTRX1H4Q9P0N2WMX0F5JZ001",
  dst:       "01JTRX1H4Q9P0N2WMX0F5JZ027",
  max_depth: 3,
});
console.log(res.reachable);   // boolean - no node list

res = db.graph.path(
    "shop.customers",
    rel="referrer",
    src="01JTRX1H4Q9P0N2WMX0F5JZ001",
    dst="01JTRX1H4Q9P0N2WMX0F5JZ027",
    max_depth=3,
)
print(res.reachable)   # True / False - no node list

res, err := db.Graph().Path(ctx, "shop.customers", originchain.PathRequest{
    Rel:      "referrer",
    Src:      "01JTRX1H4Q9P0N2WMX0F5JZ001",
    Dst:      "01JTRX1H4Q9P0N2WMX0F5JZ027",
    MaxDepth: 3,
})
if err != nil { /* handle */ }
fmt.Println(res.Reachable)   // bool - no node list

curl -X POST "https://$OC_HOST/v1/tenants/$OC_TENANT/query" \
  -H "Authorization: Bearer $OC_TOKEN" \
  -H "Content-Type: application/json" \
  -d '{
    "op":      "relation_hop",
    "schema":  "shop.orders",
    "rel":     "placed_by",
    "from_pk": ["01JTRX9KQ3YH8K2WMX0F5JZAB7"],
    "target":  "shop.customers"
  }'

const res = await fetch(
  `https://${process.env.OC_HOST}/v1/tenants/${process.env.OC_TENANT}/query`,
  {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${process.env.OC_TOKEN}`,
      "Content-Type":  "application/json",
    },
    body: JSON.stringify({
      op:      "relation_hop",
      schema:  "shop.orders",
      rel:     "placed_by",
      from_pk: ["01JTRX9KQ3YH8K2WMX0F5JZAB7"],
      target:  "shop.customers",
    }),
  },
);
const rows = await res.json();   // full target rows, not just PKs

import os, requests

BASE = f"https://{os.environ['OC_HOST']}/v1/tenants/{os.environ['OC_TENANT']}"
H    = {"Authorization": f"Bearer {os.environ['OC_TOKEN']}"}

rows = requests.post(f"{BASE}/query", headers=H, json={
    "op":      "relation_hop",
    "schema":  "shop.orders",
    "rel":     "placed_by",
    "from_pk": ["01JTRX9KQ3YH8K2WMX0F5JZAB7"],
    "target":  "shop.customers",
}).json()
print(rows)   # full target rows, not just PKs

plan := map[string]any{
    "op":      "relation_hop",
    "schema":  "shop.orders",
    "rel":     "placed_by",
    "from_pk": []string{"01JTRX9KQ3YH8K2WMX0F5JZAB7"},
    "target":  "shop.customers",
}
body, _ := json.Marshal(plan)
req, _ := http.NewRequestWithContext(ctx, "POST",
    "https://"+os.Getenv("OC_HOST")+"/v1/tenants/"+os.Getenv("OC_TENANT")+"/query",
    bytes.NewReader(body))
req.Header.Set("Authorization", "Bearer "+os.Getenv("OC_TOKEN"))
req.Header.Set("Content-Type", "application/json")

resp, err := http.DefaultClient.Do(req)
if err != nil { /* handle */ }
defer resp.Body.Close()

var rows []map[string]any   // full target rows, not just PKs
json.NewDecoder(resp.Body).Decode(&rows)

# PageRank needs an explicit node universe - it does not rank a whole
# table for you. Pass the PKs you want scored.
curl "https://$OC_HOST/v1/tenants/$OC_TENANT/graph/shop.customers/pagerank?rel=referrer&nodes=c001,c002,c003,c004,c005&damping=0.85" \
  -H "Authorization: Bearer $OC_TOKEN"

// The TS SDK wraps neighbors / reverse / bfs / path / dijkstra only.
// The algorithm endpoints are plain GETs.
const qs = new URLSearchParams({
  rel:     "referrer",
  nodes:   "c001,c002,c003,c004,c005",
  damping: "0.85",
});
const res = await fetch(
  `https://${process.env.OC_HOST}/v1/tenants/${process.env.OC_TENANT}/graph/shop.customers/pagerank?${qs}`,
  { headers: { "Authorization": `Bearer ${process.env.OC_TOKEN}` } },
);
const hits: { pk: string; score: number }[] = await res.json();
for (const h of hits) console.log(h.pk, h.score);

scores = db.graph.pagerank(
    "shop.customers",
    rel="referrer",
    nodes=["c001", "c002", "c003", "c004", "c005"],
    damping=0.85,
)
for pk, score in sorted(scores.items(), key=lambda kv: -kv[1]):
    print(pk, round(score, 4))

// The Go SDK wraps Neighbors / ReverseNeighbors / BFS / Path / Dijkstra
// only. The algorithm endpoints are plain GETs.
q := url.Values{}
q.Set("rel", "referrer")
q.Set("nodes", "c001,c002,c003,c004,c005")
q.Set("damping", "0.85")

req, _ := http.NewRequestWithContext(ctx, "GET",
    "https://"+os.Getenv("OC_HOST")+"/v1/tenants/"+os.Getenv("OC_TENANT")+
        "/graph/shop.customers/pagerank?"+q.Encode(), nil)
req.Header.Set("Authorization", "Bearer "+os.Getenv("OC_TOKEN"))

resp, err := http.DefaultClient.Do(req)
if err != nil { /* handle */ }
defer resp.Body.Close()

var hits []struct {
    PK    string  `json:"pk"`
    Score float64 `json:"score"`
}
json.NewDecoder(resp.Body).Decode(&hits)
for _, h := range hits { fmt.Println(h.PK, h.Score) }

curl "https://$OC_HOST/v1/tenants/$OC_TENANT/graph/shop.customers/louvain?rel=referrer" \
  -H "Authorization: Bearer $OC_TOKEN"

const res = await fetch(
  `https://${process.env.OC_HOST}/v1/tenants/${process.env.OC_TENANT}/graph/shop.customers/louvain?rel=referrer`,
  { headers: { "Authorization": `Bearer ${process.env.OC_TOKEN}` } },
);
const { communities } = await res.json();
for (const c of communities) console.log(c.community, c.pk);

communities = db.graph.louvain("shop.customers", rel="referrer")
# {pk -> community_id}, ids are dense integers from 0
for pk, cid in communities.items():
    print(cid, pk)

req, _ := http.NewRequestWithContext(ctx, "GET",
    "https://"+os.Getenv("OC_HOST")+"/v1/tenants/"+os.Getenv("OC_TENANT")+
        "/graph/shop.customers/louvain?rel=referrer", nil)
req.Header.Set("Authorization", "Bearer "+os.Getenv("OC_TOKEN"))

resp, err := http.DefaultClient.Do(req)
if err != nil { /* handle */ }
defer resp.Body.Close()

var out struct {
    Communities []struct {
        PK        string `json:"pk"`
        Community int    `json:"community"`
    } `json:"communities"`
}
json.NewDecoder(resp.Body).Decode(&out)
for _, c := range out.Communities { fmt.Println(c.Community, c.PK) }