From 44dbb093c305f9dae377447b740f16e722556a1b Mon Sep 17 00:00:00 2001 From: bymyself Date: Fri, 20 Feb 2026 02:21:55 -0800 Subject: [PATCH] feat: pass filtering fields to frontend instead of server-side filtering Remove server-side includeOnDistributions filtering and fileByDistribution resolution. Instead, forward requiresCustomNodes and includeOnDistributions in the info object so the frontend handles filtering client-side. Amp-Thread-ID: https://ampcode.com/threads/T-019c6f43-6212-7308-bea6-bfc35a486cbf --- app/subgraph_manager.py | 15 ++++++++------- 1 file changed, 8 insertions(+), 7 deletions(-) diff --git a/app/subgraph_manager.py b/app/subgraph_manager.py index ceabf8a0f..d32dee7a9 100644 --- a/app/subgraph_manager.py +++ b/app/subgraph_manager.py @@ -42,7 +42,6 @@ class SubgraphManager: def __init__(self): self.cached_custom_node_subgraphs: dict[SubgraphEntry] | None = None self.cached_blueprint_subgraphs: dict[SubgraphEntry] | None = None - self.distribution = os.environ.get("DISTRIBUTION", "localhost") def _create_entry(self, file: str, source: str, node_pack: str) -> tuple[str, SubgraphEntry]: """Create a subgraph entry from a file path. Expects normalized path (forward slashes).""" @@ -121,12 +120,7 @@ class SubgraphManager: logging.warning("Blueprint entry missing 'name' in category '%s', skipping", module_name) continue - include_on = blueprint.get("includeOnDistributions") - if include_on is not None and self.distribution not in include_on: - continue - - file_by_dist = blueprint.get("fileByDistribution", {}) - filename = file_by_dist.get(self.distribution, f"{name}.json") + filename = f"{name}.json" filepath = os.path.realpath(os.path.join(blueprints_dir, filename)) if not filepath.startswith(os.path.realpath(blueprints_dir) + os.sep): logging.warning("Blueprint path escapes blueprints directory: %s", filepath) @@ -137,6 +131,13 @@ class SubgraphManager: continue entry_id, entry = self._create_entry(filepath, Source.templates, module_name) + info = entry["info"] + include_on = blueprint.get("includeOnDistributions") + if include_on is not None: + info["includeOnDistributions"] = include_on + requires = blueprint.get("requiresCustomNodes") + if requires is not None: + info["requiresCustomNodes"] = requires subgraphs_dict[entry_id] = entry elif os.path.exists(blueprints_dir): logging.warning("No blueprint index.json found at %s, falling back to glob", index_path)