NEO-57: add prototype resource node catalogs, schemas, and CI gates

Four frozen ResourceNodeDef rows and per-node yield tables under
content/resource-nodes/ with JSON Schema validation and Slice 2 gates
(four nodeDefIds, gatherLens coverage, scrap_metal_bulk yields only).

content/README.md

@@ -8,11 +8,11 @@ Data-driven definitions (skills, items, recipes, quests) validated in CI with **
 | [`skills/`](skills/) | Skill catalogs; each row matches [`schemas/skill-def.schema.json`](schemas/skill-def.schema.json) — **stable `id`**, **`allowedXpSourceKinds`** for [E2.M1](../docs/decomposition/modules/E2_M1_SkillDefinitionRegistry.md) / [E2.M2](../docs/decomposition/modules/E2_M2_XpAwardAndLevelEngine.md) |
 | [`mastery/`](mastery/) | Mastery catalogs; each file matches [`schemas/mastery-catalog.schema.json`](schemas/mastery-catalog.schema.json) — **stable `branchId` / `perkId`**, tier gates via skill level ([E2.M3](../docs/decomposition/modules/E2_M3_MasteryAndPerkUnlocks.md)) |
 | [`items/`](items/) | Item catalogs; each row matches [`schemas/item-def.schema.json`](schemas/item-def.schema.json) — **stable `id`**, **`stackMax`**, **`inventorySlotKind`** for [E3.M3](../docs/decomposition/modules/E3_M3_ItemizationAndInventorySchema.md) |
-| [`resource-nodes/`](resource-nodes/) | Resource node catalogs (planned E3M1-01); each row matches JSON Schema under [`schemas/`](schemas/) — **stable `nodeDefId`**, **`gatherLens`**, yields for [E3.M1](../docs/decomposition/modules/E3_M1_ResourceNodeAndGatherLoop.md) |
+| [`resource-nodes/`](resource-nodes/) | Resource node + yield catalogs; node rows match [`schemas/resource-node-def.schema.json`](schemas/resource-node-def.schema.json), yield rows match [`schemas/resource-yield-row.schema.json`](schemas/resource-yield-row.schema.json) — **stable `nodeDefId`**, **`gatherLens`**, **`maxGathers`** for [E3.M1](../docs/decomposition/modules/E3_M1_ResourceNodeAndGatherLoop.md) |
 
 **Prototype Slice 1 (NEO-33):** CI expects **exactly three** skill rows with ids **`salvage`**, **`refine`**, **`intrusion`** (gather + process + tech). Each row must declare **`allowedXpSourceKinds`** (non-empty); see [E2.M1 — Designer note: `allowedXpSourceKinds`](../docs/decomposition/modules/E2_M1_SkillDefinitionRegistry.md#designer-note-allowedxpsourcekinds-and-grant-call-sites) for what each kind means for grant wiring.
 
-**Prototype Slice 2 — resource nodes (NEO-57, planned):** CI will expect **exactly four** node defs aligned to [E3.M1 gather lens freeze](../docs/decomposition/modules/E3_M1_ResourceNodeAndGatherLoop.md#prototype-slice-2-freeze-e3m1-01); yields reference frozen item ids only. See [E3M1-prototype-backlog.md](../docs/plans/E3M1-prototype-backlog.md).
+**Prototype Slice 2 — resource nodes (NEO-57):** CI expects **exactly four** `nodeDefId` values aligned to [E3.M1 gather lens freeze](../docs/decomposition/modules/E3_M1_ResourceNodeAndGatherLoop.md#prototype-slice-2-freeze-e3m1-01) — one row per **`gatherLens`**; exactly one yield row per node referencing **`scrap_metal_bulk`** only. **Do not rename** `nodeDefId` after ship. See [E3M1-prototype-backlog.md](../docs/plans/E3M1-prototype-backlog.md) and [NEO-57 plan](../docs/plans/NEO-57-implementation-plan.md).
 
 **Prototype Slice 1 — items (NEO-50):** CI expects **exactly six** item rows with ids **`scrap_metal_bulk`**, **`refined_plate_stock`**, **`field_stim_mk0`**, **`survey_drone_kit`**, **`contract_handoff_token`**, **`prototype_armor_shell`** — one row per **`prototypeRole`** (`material` through `equip_stub`). **Do not rename** ids after ship—change **`displayName`** only. See [E3.M3 — Designer note](../docs/decomposition/modules/E3_M3_ItemizationAndInventorySchema.md#designer-note-stack-slot-and-v1-scope) and [freeze table](../docs/decomposition/modules/E3_M3_ItemizationAndInventorySchema.md#prototype-slice-1-freeze-neo-50).
 

content/resource-nodes/prototype_resource_nodes.json

@@ -0,0 +1,29 @@
+{
+  "schemaVersion": 1,
+  "nodes": [
+    {
+      "nodeDefId": "prototype_resource_node_alpha",
+      "displayName": "Prototype Salvage Heap",
+      "gatherLens": "consumer_salvage",
+      "maxGathers": 10
+    },
+    {
+      "nodeDefId": "prototype_subsurface_vein_beta",
+      "displayName": "Prototype Subsurface Vein",
+      "gatherLens": "subsurface",
+      "maxGathers": 10
+    },
+    {
+      "nodeDefId": "prototype_bio_mat_gamma",
+      "displayName": "Prototype Bio Mat",
+      "gatherLens": "bio",
+      "maxGathers": 10
+    },
+    {
+      "nodeDefId": "prototype_urban_bulk_delta",
+      "displayName": "Prototype Urban Bulk",
+      "gatherLens": "urban_bulk",
+      "maxGathers": 10
+    }
+  ]
+}

content/resource-nodes/prototype_resource_yields.json

@@ -0,0 +1,25 @@
+{
+  "schemaVersion": 1,
+  "yields": [
+    {
+      "nodeDefId": "prototype_resource_node_alpha",
+      "itemId": "scrap_metal_bulk",
+      "quantity": 1
+    },
+    {
+      "nodeDefId": "prototype_subsurface_vein_beta",
+      "itemId": "scrap_metal_bulk",
+      "quantity": 2
+    },
+    {
+      "nodeDefId": "prototype_bio_mat_gamma",
+      "itemId": "scrap_metal_bulk",
+      "quantity": 3
+    },
+    {
+      "nodeDefId": "prototype_urban_bulk_delta",
+      "itemId": "scrap_metal_bulk",
+      "quantity": 5
+    }
+  ]
+}

content/schemas/resource-node-def.schema.json

@@ -0,0 +1,31 @@
+{
+  "$schema": "https://json-schema.org/draft/2020-12/schema",
+  "$id": "https://neon-sprawl.local/schemas/resource-node-def.json",
+  "title": "ResourceNodeDef",
+  "description": "Single resource node row for catalogs (e.g. content/resource-nodes/*_resource_nodes.json). nodeDefId is stable forever—rename displayName only. See docs/decomposition/modules/E3_M1_ResourceNodeAndGatherLoop.md.",
+  "type": "object",
+  "additionalProperties": false,
+  "required": ["nodeDefId", "displayName", "gatherLens", "maxGathers"],
+  "properties": {
+    "nodeDefId": {
+      "type": "string",
+      "pattern": "^[a-z][a-z0-9_]*$",
+      "description": "Immutable node key; must match interactableId for prototype wiring."
+    },
+    "displayName": {
+      "type": "string",
+      "minLength": 1,
+      "description": "Player-facing label; safe to change without migrating state."
+    },
+    "gatherLens": {
+      "type": "string",
+      "description": "Prototype Slice 2 gather lens (one per frozen node). CI requires exactly one row per lens.",
+      "enum": ["consumer_salvage", "subsurface", "bio", "urban_bulk"]
+    },
+    "maxGathers": {
+      "type": "integer",
+      "minimum": 1,
+      "description": "Successful gathers before node instance is depleted (prototype Slice 2)."
+    }
+  }
+}

content/schemas/resource-yield-row.schema.json

@@ -0,0 +1,26 @@
+{
+  "$schema": "https://json-schema.org/draft/2020-12/schema",
+  "$id": "https://neon-sprawl.local/schemas/resource-yield-row.json",
+  "title": "ResourceYieldRow",
+  "description": "Fixed yield row for a resource node (content/resource-nodes/*_resource_yields.json). One row per nodeDefId in prototype Slice 2.",
+  "type": "object",
+  "additionalProperties": false,
+  "required": ["nodeDefId", "itemId", "quantity"],
+  "properties": {
+    "nodeDefId": {
+      "type": "string",
+      "pattern": "^[a-z][a-z0-9_]*$",
+      "description": "Resource node this yield applies to."
+    },
+    "itemId": {
+      "type": "string",
+      "pattern": "^[a-z][a-z0-9_]*$",
+      "description": "Item def id from content/items (prototype Slice 2: scrap_metal_bulk only)."
+    },
+    "quantity": {
+      "type": "integer",
+      "minimum": 1,
+      "description": "Items granted per successful gather."
+    }
+  }
+}

docs/decomposition/modules/CT_M1_ContentValidationPipeline.md

@@ -45,7 +45,9 @@ Content tooling **Slice 1** — schemas + CI; **Slice 4** — server parity hard
 
 **Mastery catalogs ([NEO-45](https://linear.app/neon-sprawl/issue/NEO-45)):** the same script validates `content/mastery/*_mastery.json` against [`content/schemas/mastery-catalog.schema.json`](../../../content/schemas/mastery-catalog.schema.json), cross-checks track `skillId` against loaded `SkillDef` ids, rejects **duplicate `perkId`**, enforces **branch integrity** (tier branch sets match; `perkIds` reference defined perks), and (Slice 4) requires **exactly one** track for **`salvage`** only.
 
-**Item catalogs ([NEO-50](https://linear.app/neon-sprawl/issue/NEO-50)):** the same script validates each row in `content/items/*_items.json` against [`content/schemas/item-def.schema.json`](../../../content/schemas/item-def.schema.json), rejects **duplicate `id`** across files, and (Slice 1) enforces the **frozen six-item** id set plus **exactly one row per `prototypeRole`** (`material` through `equip_stub`). Extend the script when additional catalogs and schemas ship.
+**Item catalogs ([NEO-50](https://linear.app/neon-sprawl/issue/NEO-50)):** the same script validates each row in `content/items/*_items.json` against [`content/schemas/item-def.schema.json`](../../../content/schemas/item-def.schema.json), rejects **duplicate `id`** across files, and (Slice 1) enforces the **frozen six-item** id set plus **exactly one row per `prototypeRole`** (`material` through `equip_stub`).
+
+**Resource node catalogs ([NEO-57](https://linear.app/neon-sprawl/issue/NEO-57)):** the same script validates `content/resource-nodes/*_resource_nodes.json` rows against [`content/schemas/resource-node-def.schema.json`](../../../content/schemas/resource-node-def.schema.json) and `*_resource_yields.json` rows against [`content/schemas/resource-yield-row.schema.json`](../../../content/schemas/resource-yield-row.schema.json); rejects **duplicate `nodeDefId`**; (Slice 2) enforces the **frozen four-node** id set, **one row per `gatherLens`**, exactly **one yield row per node**, yield **`itemId`** cross-check against item catalogs, and **only `scrap_metal_bulk`** as yield item in prototype. Extend the script when additional catalogs and schemas ship.
 
 **Decomposition vocabulary:** the same workflow runs [`scripts/check_decomposition_language.py`](../../../scripts/check_decomposition_language.py) (stdlib only) over `docs/decomposition/**/*.md` to catch wording that treats **combat** as a leveled **`SkillDef`** line instead of **gig** progression (see script docstring for patterns). Adjust the script if a future doc needs a documented exception.
 

docs/decomposition/modules/documentation_and_implementation_alignment.md

@@ -53,7 +53,7 @@ Rows appear when work starts; default for unlisted modules is **Planned** / not
 | E2.M1 | In Progress | **NEO-33 landed:** frozen prototype trio **`salvage`** / **`refine`** / **`intrusion`** in [`content/skills/prototype_skills.json`](../../../content/skills/prototype_skills.json); PR gate + [`validate_content.py`](../../../scripts/validate_content.py) enforce schema, duplicate `id`, exact trio ids, and category coverage; designer note on **`allowedXpSourceKinds`** in [E2_M1](E2_M1_SkillDefinitionRegistry.md) + [`content/README.md`](../../../content/README.md). **NEO-34 landed:** fail-fast server load of `content/skills/*.json` at startup — `server/NeonSprawl.Server/Game/Skills/` ([NEO-34](../../plans/NEO-34-implementation-plan.md)); config + discovery in [server README — Skill catalog](../../../server/README.md#skill-catalog-contentskills-neo-34). **NEO-35 landed:** `ISkillDefinitionRegistry` / `SkillDefinitionRegistry` + DI ([NEO-35](../../plans/NEO-35-implementation-plan.md)). **NEO-36 landed:** versioned **`GET /game/world/skill-definitions`** ([NEO-36](../../plans/NEO-36-implementation-plan.md)) — `SkillDefinitionsWorldApi` + `SkillDefinitionsListDtos` in `server/NeonSprawl.Server/Game/Skills/`; Bruno `bruno/neon-sprawl-server/skill-definitions/`; manual QA [`NEO-36`](../../manual-qa/NEO-36.md). **E2.M2 consumer (NEO-38 landed):** grant path validates `skillId` + `sourceKind` vs catalog **`allowedXpSourceKinds`** on **`POST …/skill-progression`** ([NEO-38](../../plans/NEO-38-implementation-plan.md)); see [server README — Skill progression grant](../../../server/README.md#skill-progression-grant-neo-38) and [E2_M2](E2_M2_XpAwardAndLevelEngine.md). | [NEO-33](../../plans/NEO-33-implementation-plan.md), [NEO-34](../../plans/NEO-34-implementation-plan.md), [NEO-35](../../plans/NEO-35-implementation-plan.md), [NEO-36](../../plans/NEO-36-implementation-plan.md); [E2_M1](E2_M1_SkillDefinitionRegistry.md); [module_dependency_register.md](module_dependency_register.md) **E2.M1 note**; `server/NeonSprawl.Server/Game/Skills/`; [`docs/manual-qa/NEO-36.md`](../../manual-qa/NEO-36.md); [server README — Skill definitions (NEO-36)](../../../server/README.md#skill-definitions-neo-36) |
 | E2.M3 | In Progress | **NEO-45 landed:** prototype **`salvage`** mastery catalog + CI gates (see [NEO-45 plan](../../plans/NEO-45-implementation-plan.md)). **NEO-46 landed:** fail-fast server load under `server/NeonSprawl.Server/Game/Mastery/` — `MasteryCatalogLoader`, `IMasteryCatalogRegistry`, cross-check vs `ISkillDefinitionRegistry`, Slice 4 + **`tierIndex`** 1..N gate; see [NEO-46 plan](../../plans/NEO-46-implementation-plan.md). **NEO-47 landed:** `PerkUnlockEngine`, `IPlayerPerkStateStore` + **`V004`**, level-up hook in skill XP grants; see [NEO-47 plan](../../plans/NEO-47-implementation-plan.md). **NEO-49 landed:** comment-only **`perk_unlock`** telemetry hook site in [`PerkUnlockEngine.TryUnlockPerks`](../../../server/NeonSprawl.Server/Game/Mastery/PerkUnlockEngine.cs) ([NEO-49 plan](../../plans/NEO-49-implementation-plan.md), [`NEO-49` manual QA](../../manual-qa/NEO-49.md)); [server README — Perk unlock telemetry (NEO-49)](../../../server/README.md#perk-unlock-engine-and-telemetry-hooks-neo-47-neo-49). **NEO-48 landed:** **`GET`/`POST /game/players/{id}/perk-state`** — `PerkStateApi` + DTOs in `Game/Mastery/` ([NEO-48](../../plans/NEO-48-implementation-plan.md), [`NEO-48` manual QA](../../manual-qa/NEO-48.md)); [server README — Perk state (NEO-48)](../../../server/README.md#perk-state-neo-48); Bruno `bruno/neon-sprawl-server/perk-state/`. | [NEO-45](../../plans/NEO-45-implementation-plan.md), [NEO-46](../../plans/NEO-46-implementation-plan.md), [NEO-47](../../plans/NEO-47-implementation-plan.md), [NEO-48](../../plans/NEO-48-implementation-plan.md), [NEO-49](../../plans/NEO-49-implementation-plan.md), [E2M3-pre-production-backlog](../../plans/E2M3-pre-production-backlog.md), [E2_M3](E2_M3_MasteryAndPerkUnlocks.md) |
 | E2.M2 | In Progress | **NEO-37 landed:** versioned **`GET /game/players/{id}/skill-progression`** ([NEO-37](../../plans/NEO-37-implementation-plan.md)) — read model for every registered skill; known-player gate via `IPositionStateStore`; [server README — Skill progression snapshot (NEO-37)](../../../server/README.md#skill-progression-snapshot-neo-37); manual QA [`NEO-37`](../../manual-qa/NEO-37.md). **NEO-38 landed:** **`POST`** same path — grant apply, persistence (`IPlayerSkillProgressionStore`, `V003` migration), structured denies + **`levelUps`** ([NEO-38](../../plans/NEO-38-implementation-plan.md)); manual QA [`NEO-38`](../../manual-qa/NEO-38.md); Bruno `bruno/neon-sprawl-server/skill-progression/`; [server README — Skill progression grant (NEO-38)](../../../server/README.md#skill-progression-grant-neo-38). **NEO-39 landed:** data-driven `LevelCurve` content + schema + CI validation (`*_level_curve.json`) with fail-fast startup schema checks; progression GET/POST level resolution now uses `ISkillLevelCurve` content-backed thresholds ([NEO-39](../../plans/NEO-39-implementation-plan.md)); manual QA [`NEO-39`](../../manual-qa/NEO-39.md). **NEO-40 landed:** comment-only telemetry hook sites in [`SkillProgressionSnapshotApi.cs`](../../../server/NeonSprawl.Server/Game/Skills/SkillProgressionSnapshotApi.cs) on **`POST …/skill-progression`** for future **`xp_grant`** / **`level_up`** ([NEO-40](../../plans/NEO-40-implementation-plan.md), [`NEO-40` manual QA](../../manual-qa/NEO-40.md)). **NEO-41 landed:** gather prototype — **`POST …/interact`** with **`kind: resource_node`** grants **`salvage`** + **`activity`** (10 XP) via [`SkillProgressionGrantOperations`](../../../server/NeonSprawl.Server/Game/Skills/SkillProgressionGrantOperations.cs) ([NEO-41](../../plans/NEO-41-implementation-plan.md), [`NEO-41` manual QA](../../manual-qa/NEO-41.md)); [server README — Interaction](../../../server/README.md#interaction-neo-9). **NEO-42 landed (prep):** **`RefineActivitySkillXpGrant`** / **`RefineSkillXpConstants`** + deny-registry factory + tests — same NEO-38 grant stack; **E3.M2** must invoke on craft/refine success ([NEO-42](../../plans/NEO-42-implementation-plan.md), [`NEO-42` manual QA](../../manual-qa/NEO-42.md)); [server README — Craft / refine hook (NEO-42)](../../../server/README.md#craft--refine-hook--skill-xp-neo-42). **NEO-43 landed (prep):** **`MissionRewardSkillXpGrant`** / **`MissionRewardSkillXpConstants`** + deny-registry factory + tests — same NEO-38 grant stack with fixed **`sourceKind: mission_reward`**; **E7.M2** must invoke from quest hand-in ([NEO-43](../../plans/NEO-43-implementation-plan.md), [`NEO-43` manual QA](../../manual-qa/NEO-43.md)); [server README — Mission / quest reward (NEO-43)](../../../server/README.md#mission--quest-reward--skill-xp-neo-43). **Slice 3 still open:** [NEO-44](https://linear.app/neon-sprawl/issue/NEO-44). See [epic_02 — E2.M2 + Slice 3](../epics/epic_02_skills_and_progression.md). | [NEO-37](../../plans/NEO-37-implementation-plan.md), [NEO-38](../../plans/NEO-38-implementation-plan.md), [NEO-39](../../plans/NEO-39-implementation-plan.md), [NEO-40](../../plans/NEO-40-implementation-plan.md), [NEO-41](../../plans/NEO-41-implementation-plan.md), [NEO-42](../../plans/NEO-42-implementation-plan.md), [NEO-43](../../plans/NEO-43-implementation-plan.md), [E2_M2](E2_M2_XpAwardAndLevelEngine.md); label **`E2.M2`** on NEO-37–NEO-41, NEO-42–NEO-44 |
-| E3.M1 | In Progress | **NEO-41 landed (prototype):** `POST …/interact` success on **`resource_node`** (`prototype_resource_node_alpha`) applies **`salvage`** skill XP (**`sourceKind: activity`**, 10 XP) via shared NEO-38 grant operations. **Still planned:** `GatherResult`, yields, inventory per [E3_M1](E3_M1_ResourceNodeAndGatherLoop.md). | [NEO-41](../../plans/NEO-41-implementation-plan.md), [E3_M1](E3_M1_ResourceNodeAndGatherLoop.md); `server/NeonSprawl.Server/Game/Interaction/`, `Game/Skills/` |
+| E3.M1 | In Progress | **NEO-41 landed (prototype):** `POST …/interact` success on **`resource_node`** (`prototype_resource_node_alpha`) applies **`salvage`** skill XP (**`sourceKind: activity`**, 10 XP) via shared NEO-38 grant operations. **NEO-57 landed:** frozen four-node catalog in [`content/resource-nodes/`](../../../content/resource-nodes/); [`resource-node-def.schema.json`](../../../content/schemas/resource-node-def.schema.json), [`resource-yield-row.schema.json`](../../../content/schemas/resource-yield-row.schema.json); CI gates in [`validate_content.py`](../../../scripts/validate_content.py). **Still planned:** server load, `GatherResult`, depletion, inventory grants per [E3_M1](E3_M1_ResourceNodeAndGatherLoop.md). | [NEO-41](../../plans/NEO-41-implementation-plan.md), [NEO-57](../../plans/NEO-57-implementation-plan.md), [E3_M1](E3_M1_ResourceNodeAndGatherLoop.md); `content/resource-nodes/`, `server/NeonSprawl.Server/Game/Interaction/` |
 | E3.M3 | In Progress | **NEO-50 landed:** frozen prototype six-item catalog in [`content/items/prototype_items.json`](../../../content/items/prototype_items.json); [`item-def.schema.json`](../../../content/schemas/item-def.schema.json); PR gate + [`validate_content.py`](../../../scripts/validate_content.py). **NEO-51 landed:** fail-fast server load of `content/items/*_items.json` at startup — `server/NeonSprawl.Server/Game/Items/` ([NEO-51](../../plans/NEO-51-implementation-plan.md)); [server README — Item catalog](../../../server/README.md#item-catalog-contentitems-neo-51). **NEO-52 landed:** injectable **`IItemDefinitionRegistry`** + lookup tests ([NEO-52](../../plans/NEO-52-implementation-plan.md)). **NEO-53 landed:** **`GET /game/world/item-definitions`** — `ItemDefinitionsWorldApi` + DTOs in `Game/Items/` ([NEO-53](../../plans/NEO-53-implementation-plan.md), [`NEO-53` manual QA](../../manual-qa/NEO-53.md)); [server README — Item definitions (NEO-53)](../../../server/README.md#item-definitions-neo-53); Bruno `bruno/neon-sprawl-server/item-definitions/`. **NEO-54 landed:** **`IPlayerInventoryStore`** + **`PlayerInventoryOperations`** — 24 bag + 1 equipment slots, stack rules, `V005` migration ([NEO-54](../../plans/NEO-54-implementation-plan.md)). **NEO-55 landed:** **`GET`/`POST /game/players/{id}/inventory`** — `PlayerInventoryApi` + DTOs in `Game/Items/` ([NEO-55](../../plans/NEO-55-implementation-plan.md)); [server README — Player inventory (NEO-54 store, NEO-55 HTTP)](../../../server/README.md#player-inventory-neo-54-store-neo-55-http); Bruno `bruno/neon-sprawl-server/inventory/`. **NEO-56 landed:** comment-only **`item_created`** / **`inventory_transfer_denied`** telemetry hook sites in [`PlayerInventoryOperations`](../../../server/NeonSprawl.Server/Game/Items/PlayerInventoryOperations.cs) ([NEO-56](../../plans/NEO-56-implementation-plan.md), [`NEO-56` manual QA](../../manual-qa/NEO-56.md)); no E9.M1 ingest. | [NEO-50](../../plans/NEO-50-implementation-plan.md), [NEO-51](../../plans/NEO-51-implementation-plan.md), [NEO-52](../../plans/NEO-52-implementation-plan.md), [NEO-53](../../plans/NEO-53-implementation-plan.md), [NEO-54](../../plans/NEO-54-implementation-plan.md), [NEO-55](../../plans/NEO-55-implementation-plan.md), [NEO-56](../../plans/NEO-56-implementation-plan.md), [E3M3-prototype-backlog](../../plans/E3M3-prototype-backlog.md), [E3_M3](E3_M3_ItemizationAndInventorySchema.md) |
 
 ---

docs/plans/NEO-57-implementation-plan.md

@@ -39,10 +39,10 @@
 
 ## Acceptance criteria checklist
 
-- [ ] PR gate validates resource-node JSON against schema.
+- [x] PR gate validates resource-node JSON against schema.
-- [ ] Exactly four prototype node ids; duplicate `nodeDefId` fails CI.
+- [x] Exactly four prototype node ids; duplicate `nodeDefId` fails CI.
-- [ ] Every yield references a valid frozen item id (`scrap_metal_bulk`).
+- [x] Every yield references a valid frozen item id (`scrap_metal_bulk`).
-- [ ] Stable id list documented in module doc freeze box.
+- [x] Stable id list documented in module doc freeze box.
 
 ## Technical approach
 

scripts/validate_content.py

@@ -7,6 +7,8 @@ Validates:
 - mastery catalogs: content/mastery/*_mastery.json vs content/schemas/mastery-catalog.schema.json
   (post-schema: tierIndex unique and sequential 1..N per track, aligned with server boot — NEO-46)
 - item catalogs: content/items/*_items.json rows vs content/schemas/item-def.schema.json (NEO-50)
+- resource node catalogs: content/resource-nodes/*_resource_nodes.json vs resource-node-def.schema.json (NEO-57)
+- resource yield catalogs: content/resource-nodes/*_resource_yields.json vs resource-yield-row.schema.json (NEO-57)
 """
 
 from __future__ import annotations
@@ -22,9 +24,12 @@ SKILL_SCHEMA = REPO_ROOT / "content/schemas/skill-def.schema.json"
 LEVEL_CURVE_SCHEMA = REPO_ROOT / "content/schemas/level-curve.schema.json"
 MASTERY_SCHEMA = REPO_ROOT / "content/schemas/mastery-catalog.schema.json"
 ITEM_SCHEMA = REPO_ROOT / "content/schemas/item-def.schema.json"
+RESOURCE_NODE_SCHEMA = REPO_ROOT / "content/schemas/resource-node-def.schema.json"
+RESOURCE_YIELD_ROW_SCHEMA = REPO_ROOT / "content/schemas/resource-yield-row.schema.json"
 SKILLS_DIR = REPO_ROOT / "content/skills"
 MASTERY_DIR = REPO_ROOT / "content/mastery"
 ITEMS_DIR = REPO_ROOT / "content/items"
+RESOURCE_NODES_DIR = REPO_ROOT / "content/resource-nodes"
 
 # Slice 1 prototype lock (NEO-33): exact ids + category coverage after schema passes.
 PROTOTYPE_SLICE1_SKILL_IDS = frozenset({"salvage", "refine", "intrusion"})
@@ -47,6 +52,21 @@ PROTOTYPE_SLICE1_ITEM_ROLES = frozenset(
 # Slice 4 prototype lock (NEO-45): exactly one salvage track across all mastery files.
 PROTOTYPE_SLICE4_SALVAGE_SKILL_ID = "salvage"
 
+# Slice 2 prototype lock (NEO-57): exact nodeDefIds + gatherLens coverage after schema passes.
+# Keep in sync with server loader when E3M1-02 lands.
+PROTOTYPE_SLICE2_NODE_IDS = frozenset(
+    {
+        "prototype_resource_node_alpha",
+        "prototype_subsurface_vein_beta",
+        "prototype_bio_mat_gamma",
+        "prototype_urban_bulk_delta",
+    }
+)
+PROTOTYPE_SLICE2_GATHER_LENSES = frozenset(
+    {"consumer_salvage", "subsurface", "bio", "urban_bulk"}
+)
+PROTOTYPE_SLICE2_YIELD_ITEM_IDS = frozenset({"scrap_metal_bulk"})
+
 
 def _prototype_slice1_gate(seen_ids: dict[str, str], id_to_category: dict[str, str]) -> str | None:
     """Return a human-readable error if Slice 1 contract fails, else None."""
@@ -371,6 +391,166 @@ def _prototype_slice4_gate(track_skill_ids: list[str]) -> str | None:
     return None
 
 
+def _prototype_slice2_resource_node_gate(
+    seen_ids: dict[str, str],
+    id_to_lens: dict[str, str],
+) -> str | None:
+    """Return a human-readable error if Slice 2 resource-node contract fails, else None."""
+    ids = frozenset(seen_ids.keys())
+    if ids != PROTOTYPE_SLICE2_NODE_IDS:
+        return (
+            "error: prototype Slice 2 expects exactly nodeDefIds "
+            f"{sorted(PROTOTYPE_SLICE2_NODE_IDS)!r}, got {sorted(ids)!r}"
+        )
+    lenses = set(id_to_lens.values())
+    if lenses != PROTOTYPE_SLICE2_GATHER_LENSES:
+        return (
+            "error: prototype Slice 2 requires exactly one row per gatherLens "
+            f"{sorted(PROTOTYPE_SLICE2_GATHER_LENSES)!r}, lenses seen: {sorted(lenses)!r}"
+        )
+    return None
+
+
+def _prototype_slice2_yield_gate(
+    yield_node_ids: frozenset[str],
+    yield_item_ids: frozenset[str],
+) -> str | None:
+    """Return a human-readable error if Slice 2 yield contract fails, else None."""
+    if yield_node_ids != PROTOTYPE_SLICE2_NODE_IDS:
+        return (
+            "error: prototype Slice 2 expects exactly one yield row per nodeDefId "
+            f"{sorted(PROTOTYPE_SLICE2_NODE_IDS)!r}, yield nodeDefIds: {sorted(yield_node_ids)!r}"
+        )
+    if yield_item_ids != PROTOTYPE_SLICE2_YIELD_ITEM_IDS:
+        return (
+            "error: prototype Slice 2 expects yield itemIds "
+            f"{sorted(PROTOTYPE_SLICE2_YIELD_ITEM_IDS)!r} only, got {sorted(yield_item_ids)!r}"
+        )
+    return None
+
+
+def _validate_resource_node_catalogs(
+    *,
+    node_files: list[Path],
+    node_validator: Draft202012Validator,
+) -> tuple[int, dict[str, str], dict[str, str]]:
+    """Validate resource node JSON files. Returns (error_count, seen_ids, id_to_lens)."""
+    errors = 0
+    seen_ids: dict[str, str] = {}
+    id_to_lens: dict[str, str] = {}
+
+    for path in node_files:
+        rel = str(path.relative_to(REPO_ROOT))
+        data = json.loads(path.read_text(encoding="utf-8"))
+        schema_version = data.get("schemaVersion")
+        if schema_version != 1:
+            print(f"error: {rel}: expected schemaVersion 1, got {schema_version!r}", file=sys.stderr)
+            errors += 1
+            continue
+
+        nodes = data.get("nodes")
+        if not isinstance(nodes, list):
+            print(f"error: {rel}: expected top-level 'nodes' array", file=sys.stderr)
+            errors += 1
+            continue
+
+        for i, row in enumerate(nodes):
+            if not isinstance(row, dict):
+                print(f"error: {rel}: nodes[{i}] must be an object", file=sys.stderr)
+                errors += 1
+                continue
+            row_schema_errors = 0
+            for err in sorted(node_validator.iter_errors(row), key=lambda e: e.path):
+                loc = ".".join(str(p) for p in err.path) or "(root)"
+                print(f"error: {rel} nodes[{i}] {loc}: {err.message}", file=sys.stderr)
+                row_schema_errors += 1
+                errors += 1
+            nid = row.get("nodeDefId")
+            if isinstance(nid, str) and row_schema_errors == 0:
+                prev = seen_ids.get(nid)
+                if prev:
+                    print(
+                        f"error: duplicate nodeDefId {nid!r} in {prev} and {rel}",
+                        file=sys.stderr,
+                    )
+                    errors += 1
+                else:
+                    seen_ids[nid] = rel
+                    gather_lens = row.get("gatherLens")
+                    if isinstance(gather_lens, str):
+                        id_to_lens[nid] = gather_lens
+
+    return errors, seen_ids, id_to_lens
+
+
+def _validate_resource_yield_catalogs(
+    *,
+    yield_files: list[Path],
+    yield_validator: Draft202012Validator,
+    known_node_ids: frozenset[str],
+    known_item_ids: frozenset[str],
+) -> tuple[int, frozenset[str], frozenset[str]]:
+    """Validate yield JSON files. Returns (error_count, yield_node_ids, yield_item_ids)."""
+    errors = 0
+    seen_node_ids: dict[str, str] = {}
+    yield_item_ids: set[str] = set()
+
+    for path in yield_files:
+        rel = str(path.relative_to(REPO_ROOT))
+        data = json.loads(path.read_text(encoding="utf-8"))
+        schema_version = data.get("schemaVersion")
+        if schema_version != 1:
+            print(f"error: {rel}: expected schemaVersion 1, got {schema_version!r}", file=sys.stderr)
+            errors += 1
+            continue
+
+        yields = data.get("yields")
+        if not isinstance(yields, list):
+            print(f"error: {rel}: expected top-level 'yields' array", file=sys.stderr)
+            errors += 1
+            continue
+
+        for i, row in enumerate(yields):
+            if not isinstance(row, dict):
+                print(f"error: {rel}: yields[{i}] must be an object", file=sys.stderr)
+                errors += 1
+                continue
+            row_schema_errors = 0
+            for err in sorted(yield_validator.iter_errors(row), key=lambda e: e.path):
+                loc = ".".join(str(p) for p in err.path) or "(root)"
+                print(f"error: {rel} yields[{i}] {loc}: {err.message}", file=sys.stderr)
+                row_schema_errors += 1
+                errors += 1
+            nid = row.get("nodeDefId")
+            item_id = row.get("itemId")
+            if isinstance(nid, str) and row_schema_errors == 0:
+                prev = seen_node_ids.get(nid)
+                if prev:
+                    print(
+                        f"error: duplicate yield nodeDefId {nid!r} in {prev} and {rel}",
+                        file=sys.stderr,
+                    )
+                    errors += 1
+                else:
+                    seen_node_ids[nid] = rel
+                    if nid not in known_node_ids:
+                        print(
+                            f"error: {rel} yields[{i}]: nodeDefId {nid!r} is not defined in resource node catalogs",
+                            file=sys.stderr,
+                        )
+                        errors += 1
+            if isinstance(item_id, str) and row_schema_errors == 0:
+                yield_item_ids.add(item_id)
+                if item_id not in known_item_ids:
+                    print(
+                        f"error: {rel} yields[{i}]: itemId {item_id!r} is not in item catalogs",
+                        file=sys.stderr,
+                    )
+                    errors += 1
+
+    return errors, frozenset(seen_node_ids.keys()), frozenset(yield_item_ids)
+
+
 def main() -> int:
     if not SKILL_SCHEMA.is_file():
         print(f"error: missing schema {SKILL_SCHEMA}", file=sys.stderr)
@@ -384,6 +564,12 @@ def main() -> int:
     if not ITEM_SCHEMA.is_file():
         print(f"error: missing schema {ITEM_SCHEMA}", file=sys.stderr)
         return 1
+    if not RESOURCE_NODE_SCHEMA.is_file():
+        print(f"error: missing schema {RESOURCE_NODE_SCHEMA}", file=sys.stderr)
+        return 1
+    if not RESOURCE_YIELD_ROW_SCHEMA.is_file():
+        print(f"error: missing schema {RESOURCE_YIELD_ROW_SCHEMA}", file=sys.stderr)
+        return 1
 
     skill_schema = json.loads(SKILL_SCHEMA.read_text(encoding="utf-8"))
     skill_validator = Draft202012Validator(skill_schema)
@@ -393,6 +579,10 @@ def main() -> int:
     mastery_validator = Draft202012Validator(mastery_schema)
     item_schema = json.loads(ITEM_SCHEMA.read_text(encoding="utf-8"))
     item_validator = Draft202012Validator(item_schema)
+    resource_node_schema = json.loads(RESOURCE_NODE_SCHEMA.read_text(encoding="utf-8"))
+    resource_node_validator = Draft202012Validator(resource_node_schema)
+    resource_yield_schema = json.loads(RESOURCE_YIELD_ROW_SCHEMA.read_text(encoding="utf-8"))
+    resource_yield_validator = Draft202012Validator(resource_yield_schema)
 
     if not SKILLS_DIR.is_dir():
         print(f"error: missing directory {SKILLS_DIR}", file=sys.stderr)
@@ -426,6 +616,20 @@ def main() -> int:
         print(f"error: no *_items.json files under {ITEMS_DIR}", file=sys.stderr)
         return 1
 
+    if not RESOURCE_NODES_DIR.is_dir():
+        print(f"error: missing directory {RESOURCE_NODES_DIR}", file=sys.stderr)
+        return 1
+
+    node_files = sorted(RESOURCE_NODES_DIR.glob("*_resource_nodes.json"))
+    if not node_files:
+        print(f"error: no *_resource_nodes.json files under {RESOURCE_NODES_DIR}", file=sys.stderr)
+        return 1
+
+    yield_files = sorted(RESOURCE_NODES_DIR.glob("*_resource_yields.json"))
+    if not yield_files:
+        print(f"error: no *_resource_yields.json files under {RESOURCE_NODES_DIR}", file=sys.stderr)
+        return 1
+
     seen_ids: dict[str, str] = {}
     id_to_category: dict[str, str] = {}
     errors = 0
@@ -571,14 +775,45 @@ def main() -> int:
         print(slice1_item_err, file=sys.stderr)
         return 1
 
+    node_errors, node_seen_ids, id_to_lens = _validate_resource_node_catalogs(
+        node_files=node_files,
+        node_validator=resource_node_validator,
+    )
+    if node_errors:
+        print(f"content validation failed with {node_errors} error(s)", file=sys.stderr)
+        return 1
+
+    slice2_node_err = _prototype_slice2_resource_node_gate(node_seen_ids, id_to_lens)
+    if slice2_node_err:
+        print(slice2_node_err, file=sys.stderr)
+        return 1
+
+    yield_errors, yield_node_ids, yield_item_ids = _validate_resource_yield_catalogs(
+        yield_files=yield_files,
+        yield_validator=resource_yield_validator,
+        known_node_ids=frozenset(node_seen_ids.keys()),
+        known_item_ids=frozenset(item_seen_ids.keys()),
+    )
+    if yield_errors:
+        print(f"content validation failed with {yield_errors} error(s)", file=sys.stderr)
+        return 1
+
+    slice2_yield_err = _prototype_slice2_yield_gate(yield_node_ids, yield_item_ids)
+    if slice2_yield_err:
+        print(slice2_yield_err, file=sys.stderr)
+        return 1
+
     print(
         "content OK: "
         f"{len(skill_files)} skill catalog file(s), "
         f"{len(curve_files)} level curve file(s), "
         f"{len(mastery_files)} mastery catalog file(s), "
         f"{len(item_files)} item catalog file(s), "
+        f"{len(node_files)} resource node catalog file(s), "
+        f"{len(yield_files)} resource yield catalog file(s), "
         f"{len(seen_ids)} unique skill id(s), "
         f"{len(item_seen_ids)} unique item id(s), "
+        f"{len(node_seen_ids)} unique nodeDefId(s), "
         f"{len(track_skill_ids)} mastery track(s)"
     )
     return 0