Hero Studio

@@ -0,0 +1,136 @@+#!/usr/bin/env node+/* Reference implementation: bulk hardware pages with style-gated heroes.+   Copy it, point it at a parts directory, run it. It is DELIBERATELY plain+   node with no dependencies, and it resumes: every completed part lands in+   bulk-state.json, so a crash or a rate-limit stop never repeats work.++   Layout it expects (one dir per part):+     parts/+       lm317-dpak/+         part.json        { "title": "LM317 (DPAK)", "mpn": "LM317MDT", "kind": "component", "tags": [...] }+         model.step       (REQUIRED by the registry)+         render.png       (from chip-thumbnailer; becomes the hero showcase)+         symbol.kicad_sym footprint.kicad_mod   (optional, warnings without)++   Usage:+     node bulk-publish-reference.mjs --parts ./parts --org adom \+       --style <saved-style> --human colby --quote "match the family style" \+       [--pace 4] [--dry-run] [--studio-port 8846]++   Before running: pose ONE representative part, let a human Generate, then+   `hero-studio style save <name>`. That approval gates every hero this+   script produces (it rides each PNG's provenance).++   Rate limits: publishes run SERIALLY with --pace seconds between; any+   publish whose output mentions a 429/rate answer triggers exponential+   backoff (30s, 60s, 120s) and a retry, then the part is marked failed and+   the loop continues. Nothing here hammers the wiki. */+import { execFileSync, execFile } from 'child_process';+import fs from 'fs';+import path from 'path';++const arg = (f, d) => { const i = process.argv.indexOf(f); return i >= 0 ? process.argv[i + 1] : d; };+const has = (f) => process.argv.includes(f);+const PARTS = arg('--parts');+const ORG = arg('--org', 'adom');+const STYLE = arg('--style');+const HUMAN = arg('--human');+const QUOTE = arg('--quote');+const PACE = Number(arg('--pace', 4));+const PORT = arg('--studio-port', process.env.HERO_STUDIO_PORT || '8846');+const DRY = has('--dry-run');+if (!PARTS || !STYLE || !HUMAN || !QUOTE) {+  console.error('usage: bulk-publish-reference.mjs --parts <dir> --style <name> --human <who> --quote "<their words>" [--org adom] [--pace 4] [--dry-run]');+  process.exit(2);+}+const AI_THREAD = process.env.ADOM_AI_THREAD || 'hardware bulk publish';+const sleep = (s) => new Promise((r) => setTimeout(r, s * 1000));+const STATE_FILE = path.join(PARTS, 'bulk-state.json');+const state = fs.existsSync(STATE_FILE) ? JSON.parse(fs.readFileSync(STATE_FILE, 'utf8')) : { done: {}, failed: {} };+const save = () => fs.writeFileSync(STATE_FILE, JSON.stringify(state, null, 1));++const dirs = fs.readdirSync(PARTS).filter((d) => fs.existsSync(path.join(PARTS, d, 'part.json')));+console.error(`bulk: ${dirs.length} part(s); ${Object.keys(state.done).length} already done (resume)`);++// 1. heroes first, one paced batch through the human-gated style+const partsManifest = [];+for (const d of dirs) {+  if (state.done[d]) continue;+  const meta = JSON.parse(fs.readFileSync(path.join(PARTS, d, 'part.json'), 'utf8'));+  const render = path.join(PARTS, d, 'render.png');+  partsManifest.push({+    ref: `${ORG}/${d}`, title: meta.title, kind: meta.kind || 'component',+    vitrine: fs.existsSync(render) ? render : undefined, _dir: d,+  });+}+if (partsManifest.length && !DRY) {+  const manifestPath = path.join(PARTS, 'parts-batch.json');+  fs.writeFileSync(manifestPath, JSON.stringify(partsManifest.map(({ _dir, ...p }) => p)));+  console.error('generating heroes through the gated style (local, paced)...');+  const out = execFileSync('hero-studio', ['--ai-thread', AI_THREAD, 'batch',+    '--style', STYLE, '--parts', manifestPath, '--pace', '2',+    '--human', HUMAN, '--quote', QUOTE, '--port', PORT], { encoding: 'utf8', stdio: ['ignore', 'pipe', 'inherit'] });+  const results = JSON.parse(out).results;+  // copy each generated hero into its part dir as docs/hero.png; generated/+  // lives next to the hero-studio install (same resolution bin/hero-studio uses)+  const pkgDir = path.join(path.dirname(fs.realpathSync(execFileSync('which', ['hero-studio'], { encoding: 'utf8' }).trim())), '..');+  for (const r of results) {+    if (!r.ok) { state.failed[r.ref] = r.error; continue; }+    const p = partsManifest.find((x) => x.ref === r.ref);+    const dst = path.join(PARTS, p._dir, 'docs');+    fs.mkdirSync(dst, { recursive: true });+    fs.copyFileSync(path.join(pkgDir, 'generated', r.file), path.join(dst, 'hero.png'));+  }+  save();+}++// 2. init + publish, serial, paced, 429-aware+const run = (cmd, args, cwd) => new Promise((res) => {+  execFile(cmd, args, { cwd, encoding: 'utf8' }, (err, so, se) => res({ ok: !err, out: (so || '') + (se || '') }));+});+for (const p of partsManifest) {+  if (state.done[p._dir] || state.failed[p.ref]) continue;+  const dir = path.join(PARTS, p._dir);+  const meta = JSON.parse(fs.readFileSync(path.join(dir, 'part.json'), 'utf8'));+  if (DRY) { console.error(`[dry] would publish ${p.ref}`); continue; }+  // scaffold in place if package.json is absent+  if (!fs.existsSync(path.join(dir, 'package.json'))) {+    const pkg = {+      slug: p._dir, title: meta.title, type: 'hardware', kind: meta.kind || 'component',+      version: meta.version || '0.1.0', brief: meta.brief || meta.title,+      description: meta.description || meta.title, tags: meta.tags || ['hardware'],+      dependencies: {}, hero: { path: 'docs/hero.png' }, org: ORG, platform: 'any',+    };+    if (meta.mpn) pkg.mpn = meta.mpn;+    fs.writeFileSync(path.join(dir, 'package.json'), JSON.stringify(pkg, null, 2));+  }+  const lint = await run('adom-wiki', ['pkg', 'lint'], dir);+  if (/\berror\b/i.test(lint.out) && !/0 error/.test(lint.out)) {+    console.error(`  ${p.ref}: lint errors, skipping (fix and re-run; resume skips done parts)`);+    state.failed[p.ref] = 'lint';+    save();+    continue;+  }+  let published = false;+  for (let attempt = 0, backoff = 30; attempt < 4 && !published; attempt++) {+    const pub = await run('adom-wiki', ['pkg', 'publish', '--org', ORG], dir);+    if (pub.ok && /"published"/.test(pub.out)) {+      published = true;+      if (meta.source) await run('adom-wiki', ['page', 'edit', p.ref, '--source', meta.source], dir);+      state.done[p._dir] = { at: new Date().toISOString() };+      delete state.failed[p.ref];+      console.error(`  ${p.ref}: published`);+    } else if (/429|rate/i.test(pub.out)) {+      console.error(`  ${p.ref}: rate-limited; backing off ${backoff}s (attempt ${attempt + 1})`);+      await sleep(backoff);+      backoff *= 2;+    } else {+      console.error(`  ${p.ref}: FAILED: ${pub.out.split('\n').find((l) => /error/i.test(l)) || 'unknown'}`);+      state.failed[p.ref] = 'publish';+      break;+    }+  }+  save();+  await sleep(PACE);+}+console.error(`done: ${Object.keys(state.done).length} published, ${Object.keys(state.failed).length} failed (bulk-state.json has the ledger; re-running resumes)`);