graph.json is written "directed": false and carries direction in arc order
(#563), or in _src/_tgt markers on legacy files (#2309). A plain undirected
node_link_graph load re-orders endpoints by node-list position, so every
link whose target precedes its source in the node list came back reversed
(79% of links on graphify's own graph).
query, path/explain, affected, merge-graphs and the MCP server already
restore direction. The remaining reloaders did not:
- export html / neo4j / falkordb (cypher.txt and --push) / obsidian canvas
- graph.html re-rendered by update, watch and the git hooks
- the git merge driver, which wrote the reversal into the committed
graph.json, even when merging three identical copies
Add paths.restore_arc_direction, the inline idiom query and merge-graphs
already use, and apply it in load_node_link_graph and the export loader.
to_cypher, to_canvas and push_to_neo4j/falkordb now read _src/_tgt as
to_html already does. The merge driver writes direction back into arc
order before saving, as to_json does, so the committed file keeps the
post-#563 convention.
global add has the same bug and is fixed separately.
Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
(cherry picked from commit 5a461c99d7)
7.3 KiB
Architecture
graphify is a Claude Code skill backed by a Python library. The skill orchestrates the library; the library can be used standalone.
Pipeline
detect() → extract() → build() → cluster() → analyze helpers → report.generate() → export.to_*()
Each stage lives in its own module and they communicate through plain Python dicts and NetworkX graphs. While designed to minimize shared state, some stages (like extractors) rely on ambient module-level state around the active scan root. Most stages are a single function; analyze.py and export.py are sets of sibling functions rather than one entry point.
Module responsibilities
Signatures below are the real ones - tests/test_architecture_doc.py imports every symbol named here, so this table cannot drift from the code.
| Module | Entry point(s) | Input → Output |
|---|---|---|
detect.py |
detect(root) |
directory → scan summary dict: files grouped by category, plus total_files, total_words, warning, scan_root, … |
extract.py |
extract(paths, *, root=None, ...), collect_files(target) |
list of file paths → {nodes, edges} dict. collect_files expands a directory into that list, and lives here, not in detect.py |
build.py |
build(extractions), build_from_json(extraction) |
extraction dict(s) → nx.Graph |
cluster.py |
cluster(G) |
graph → {community_id: [node_id, ...]} (the graph is not mutated) |
analyze.py |
god_nodes(G), surprising_connections(G), suggest_questions(G, communities, community_labels), find_import_cycles(G), graph_diff(G_old, G_new) |
graph → one list/dict per analysis. There is no single analyze() entry point |
report.py |
generate(G, communities, cohesion_scores, community_labels, ...) |
graph + analysis → GRAPH_REPORT.md string |
export.py |
to_json, to_html, to_obsidian, to_svg, to_graphml, to_canvas, to_cypher |
graph → graph.json, graph.html, Obsidian vault, graph.svg, … one function per format |
wiki.py |
to_wiki(G, communities, output_dir, ...) |
graph → one markdown article per community + index.md |
callflow_html.py |
write_callflow_html(...) |
graphify-out files → Mermaid architecture/call-flow HTML |
ingest.py |
ingest(url, target_dir, ...) |
URL → file saved to corpus dir |
cache.py |
check_semantic_cache(files, root), save_semantic_cache(nodes, edges, ...) |
files → cached nodes / edges / hyperedges + the list of files still needing extraction |
security.py |
validate_url, safe_fetch, validate_graph_path, sanitize_label |
URL / path / label → validated value, or raises |
validate.py |
validate_extraction(data), assert_valid(data) |
extraction dict → list of schema error strings (validate_extraction returns them; assert_valid raises) |
serve.py |
serve(graph_path), serve_http(graph_path, *, host, port, ...) |
graph file path → MCP stdio server / HTTP server |
watch.py |
watch(watch_path, debounce=3.0), check_update(watch_path) |
directory → rebuild on change; check_update reports whether a re-extraction is pending |
benchmark.py |
run_benchmark(graph_path) |
graph file → corpus vs subgraph token comparison |
Calling extract() from your own code
extract() takes a list of paths, and root is keyword-only and optional:
from pathlib import Path
from graphify.extract import extract
paths = [Path("src/lib/content.ts"), Path("src/pages/index.astro")]
result = extract(paths, root=Path(".").resolve()) # pass root explicitly
Always pass root. Node ids and source_file values are derived relative to it; when it is omitted, extract() infers one from the paths you passed, which is the common parent of that list rather than your project root. A single-file call therefore anchors to that file's own directory, and ids can end up carrying path segments from the machine they were extracted on.
Extraction output schema
Every extractor returns:
{
"nodes": [
{"id": "unique_string", "label": "human name", "source_file": "path", "source_location": "L42"}
],
"edges": [
{"source": "id_a", "target": "id_b", "relation": "calls|imports|uses|...", "confidence": "EXTRACTED|INFERRED|AMBIGUOUS"}
]
}
validate.py enforces this schema before build() consumes it.
Edge direction in graph.json
graph.json is written "directed": false, but every link is directed: arc order is the direction (source → target, #563). Older canonicalized files carry it in _src/_tgt markers instead, and those win where present (#2309).
A plain json_graph.node_link_graph() load loses this: an undirected graph re-orders each edge's endpoints by node-list position. Load through paths.load_node_link_graph() (or apply paths.restore_arc_direction() to the raw dict first), which stamps _src/_tgt on every edge. Then read direction as data.get("_src", u) / data.get("_tgt", v), never from u, v. Anything that writes graph.json back out pops the markers into arc order first, as export.to_json() does.
Confidence labels
| Label | Meaning |
|---|---|
EXTRACTED |
Relationship is explicitly stated in the source (e.g., an import statement, a direct call) |
INFERRED |
Relationship is a reasonable deduction (e.g., call-graph second pass, co-occurrence in context) |
AMBIGUOUS |
Relationship is uncertain; flagged for human review in GRAPH_REPORT.md |
Adding a new language extractor
- Add an
extract_<lang>(path: Path) -> dictfunction following the existing pattern (tree-sitter parse → walk nodes → collectnodesandedges→ call-graph second pass for INFERREDcallsedges). New languages go in their own module undergraphify/extractors/- seegraphify/extractors/MIGRATION.md;extract.pyre-exports them while the existing ones are ported out of it. - Register the file suffix in
extract()'s dispatch table and incollect_files()(both inextract.py). - Add the suffix to
CODE_EXTENSIONSindetect.pyand_WATCHED_EXTENSIONSinwatch.py. - Add the tree-sitter package to
pyproject.tomldependencies. - Add a fixture file to
tests/fixtures/and tests totests/test_languages.py.
Security
All external input passes through graphify/security.py before use:
- URLs →
validate_url()(http/https only) +_NoFileRedirectHandler(blocks file:// redirects) - Fetched content →
safe_fetch()/safe_fetch_text()(size cap, timeout) - Graph file paths →
validate_graph_path()(must resolve insidegraphify-out/) - Node labels →
sanitize_label()(strips control chars, caps 256 chars)
See SECURITY.md for the full threat model.
Testing
analyze.suggest_questions() interleaves candidates across question types before
applying its result limit (seven by default). This keeps ambiguous relationships
from hiding bridge, inferred-relationship, isolation, and low-cohesion signals.
The existing candidate order within each type is preserved; if the limit is smaller
than the number of available types, their generation order determines priority.
One test file per module under tests/. Run with:
pytest tests/ -q
The test suite is designed to avoid network access and uncontrolled filesystem effects; most tests are isolated with temporary directories and environment fixtures.