1import fs from 'node:fs';
2import path from 'node:path';
3import { resolveProjectRoot } from '../context.mjs';
4 
5export const IMPECCABLE_DIR = '.impeccable';
6export const LIVE_DIR = 'live';
7export const CRITIQUE_DIR = 'critique';
8 
9export function getImpeccableDir(cwd = process.cwd(), options = {}) {
10  return path.join(resolveProjectRoot(cwd, options), IMPECCABLE_DIR);
11}
12 
13export function getDesignSidecarPath(cwd = process.cwd(), options = {}) {
14  return path.join(getImpeccableDir(cwd, options), 'design.json');
15}
16 
17export function getDesignSidecarCandidates(cwd = process.cwd(), contextDir = cwd, options = {}) {
18  const projectRoot = resolveProjectRoot(cwd, options);
19  const candidates = [
20    getDesignSidecarPath(cwd, options),
21    path.join(projectRoot, 'DESIGN.json'),
22  ];
23  const contextLegacy = path.join(contextDir, 'DESIGN.json');
24  if (!candidates.includes(contextLegacy)) candidates.push(contextLegacy);
25  return candidates;
26}
27 
28export function resolveDesignSidecarPath(cwd = process.cwd(), contextDir = cwd, options = {}) {
29  return firstExisting(getDesignSidecarCandidates(cwd, contextDir, options));
30}
31 
32export function getLiveDir(cwd = process.cwd(), options = {}) {
33  return path.join(getImpeccableDir(cwd, options), LIVE_DIR);
34}
35 
36export function getLiveConfigPath(cwd = process.cwd(), options = {}) {
37  return path.join(getLiveDir(cwd, options), 'config.json');
38}
39 
40export function getLegacyLiveConfigPath(scriptsDir) {
41  return path.join(scriptsDir, 'config.json');
42}
43 
44export function resolveLiveConfigPath({ cwd = process.cwd(), scriptsDir, env = process.env, targetPath } = {}) {
45  if (env.IMPECCABLE_LIVE_CONFIG && env.IMPECCABLE_LIVE_CONFIG.trim()) {
46    const configured = env.IMPECCABLE_LIVE_CONFIG.trim();
47    return path.isAbsolute(configured) ? configured : path.resolve(cwd, configured);
48  }
49  const primary = getLiveConfigPath(cwd, { targetPath });
50  if (fs.existsSync(primary)) return primary;
51  if (scriptsDir) {
52    const legacy = getLegacyLiveConfigPath(scriptsDir);
53    if (fs.existsSync(legacy)) return legacy;
54  }
55  return primary;
56}
57 
58export function getLiveServerPath(cwd = process.cwd(), options = {}) {
59  return path.join(getLiveDir(cwd, options), 'server.json');
60}
61 
62export function getLegacyLiveServerPath(cwd = process.cwd(), options = {}) {
63  return path.join(resolveProjectRoot(cwd, options), '.impeccable-live.json');
64}
65 
66export function readLiveServerInfo(cwd = process.cwd(), options = {}) {
67  for (const filePath of [getLiveServerPath(cwd, options), getLegacyLiveServerPath(cwd, options)]) {
68    try {
69      const info = JSON.parse(fs.readFileSync(filePath, 'utf-8'));
70      if (info && typeof info.pid === 'number' && !isLiveServerPidReachable(info.pid)) {
71        try { fs.unlinkSync(filePath); } catch {}
72        continue;
73      }
74      return { info, path: filePath };
75    } catch {
76      /* try next */
77    }
78  }
79  return null;
80}
81 
82export function isLiveServerPidReachable(pid) {
83  try {
84    process.kill(pid, 0);
85    return true;
86  } catch (err) {
87    // ESRCH means "no such process". EPERM means the process exists but this
88    // user cannot signal it, so the live server info is still valid.
89    return err?.code !== 'ESRCH';
90  }
91}
92 
93export function writeLiveServerInfo(cwd = process.cwd(), info, options = {}) {
94  const filePath = getLiveServerPath(cwd, options);
95  fs.mkdirSync(path.dirname(filePath), { recursive: true });
96  fs.writeFileSync(filePath, JSON.stringify(info));
97  return filePath;
98}
99 
100export function removeLiveServerInfo(cwd = process.cwd(), options = {}) {
101  for (const filePath of [getLiveServerPath(cwd, options), getLegacyLiveServerPath(cwd, options)]) {
102    try { fs.unlinkSync(filePath); } catch {}
103  }
104}
105 
106export function getLiveSessionsDir(cwd = process.cwd(), options = {}) {
107  return path.join(getLiveDir(cwd, options), 'sessions');
108}
109 
110export function getLegacyLiveSessionsDir(cwd = process.cwd(), options = {}) {
111  return path.join(resolveProjectRoot(cwd, options), '.impeccable-live', 'sessions');
112}
113 
114export function getLiveAnnotationsDir(cwd = process.cwd(), options = {}) {
115  return path.join(getLiveDir(cwd, options), 'annotations');
116}
117 
118export function getCritiqueDir(cwd = process.cwd(), options = {}) {
119  return path.join(getImpeccableDir(cwd, options), CRITIQUE_DIR);
120}
121 
122export function getLegacyLiveAnnotationsDir(cwd = process.cwd(), options = {}) {
123  return path.join(resolveProjectRoot(cwd, options), '.impeccable-live', 'annotations');
124}
125 
126function firstExisting(paths) {
127  return paths.find((filePath) => fs.existsSync(filePath)) || null;
128}
129