thePR0M3TH3AN/TORCH
1
0 Fork 0
mirror of https://github.com/PR0M3TH3AN/TORCH.git synced 2026-11-04 11:51:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

[decompose] extract modules from src/lib.mjs

Browse Source 
Co-authored-by: PR0M3TH3AN <[email protected]>
This commit is contained in:
google-labs-jules[bot]andPR0M3TH3AN committed 2026-02-14 13:18:07 +00:00
1 parent c731f2b09d
commit 581dc3484e
12 files changed
+429 -528
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

src/constants.mjs
+9
View File
@@ -1,2 +1,11 @@
export const DEFAULT_DASHBOARD_PORT = 4173; export const DEFAULT_DASHBOARD_PORT = 4173;
export const RACE_CHECK_DELAY_MS = 1500; export const RACE_CHECK_DELAY_MS = 1500;
export const DEFAULT_RELAYS = [
'wss://relay.damus.io',
'wss://nos.lol',
'wss://relay.primal.net',
];
export const DEFAULT_TTL = 7200;
export const DEFAULT_NAMESPACE = 'torch';
export const DEFAULT_QUERY_TIMEOUT_MS = 15_000;
export const VALID_CADENCES = new Set(['daily', 'weekly']);
src/context/CONTEXT_2026-02-14.md
+14 -12
View File
@@ -1,14 +1,16 @@
# Context: 2026-02-14 Constants Refactor # Context: Decompose src/lib.mjs
## Chosen File
`src/lib.mjs` (approx 700 lines).
## Reason for Selection
It is one of the largest grandfathered files (excluding HTML files which are harder to module-decompose). It contains mixed concerns: roster management, lock operations, and dashboard server logic.
## Extraction Plan
1. Extract roster logic to `src/roster.mjs`.
2. Extract lock operations to `src/lock-ops.mjs`.
3. Extract dashboard logic to `src/dashboard.mjs`.
4. Move configuration helpers to `src/torch-config.mjs` and constants to `src/constants.mjs`.
## Goal ## Goal
To refactor duplicate or magic numeric literals into a canonical constants file. Reduce `src/lib.mjs` by at least 200 lines while preserving behavior.
Specifically targeting `4173` (default dashboard port) and `1500` (race check delay).
## Scope
- Create `src/constants.mjs`.
- Modify `src/lib.mjs`.
## Constraints
- Must preserve existing values.
- Must pass lint and tests.
- Must follow `const-refactor-agent` guidelines.
src/dashboard.mjs
+81
View File
@@ -0,0 +1,81 @@
import fs from 'node:fs';
import path from 'node:path';
import http from 'node:http';
import { fileURLToPath } from 'node:url';
import { DEFAULT_DASHBOARD_PORT } from './constants.mjs';
export async function cmdDashboard(port = DEFAULT_DASHBOARD_PORT) {
// Resolve package root relative to this file (src/dashboard.mjs)
// this file is in <root>/src/dashboard.mjs, so '..' goes to <root>
const packageRoot = path.resolve(path.dirname(fileURLToPath(import.meta.url)), '..');
const server = http.createServer((req, res) => {
// URL parsing
const url = new URL(req.url, `http://${req.headers.host}`);
let pathname = url.pathname;
// Redirect / to /dashboard/
if (pathname === '/' || pathname === '/dashboard') {
res.writeHead(302, { 'Location': '/dashboard/' });
res.end();
return;
}
// Special case: /torch-config.json
// Priority: User's CWD > Package default
if (pathname === '/torch-config.json') {
const userConfigPath = path.resolve(process.cwd(), 'torch-config.json');
if (fs.existsSync(userConfigPath)) {
res.writeHead(200, { 'Content-Type': 'application/json' });
fs.createReadStream(userConfigPath).pipe(res);
return;
}
// If not found in CWD, fall through to serve from packageRoot (if it exists there)
// or return empty object if missing?
// Falling through means it looks for packageRoot/torch-config.json
}
// Security check: prevent directory traversal
const safePath = path.normalize(pathname).replace(new RegExp('^(\\.\\.[\\/\\\\])+'), '');
let filePath = path.join(packageRoot, safePath);
// If directory, try index.html
if (fs.existsSync(filePath) && fs.statSync(filePath).isDirectory()) {
filePath = path.join(filePath, 'index.html');
}
// Check if file exists and is a file
if (!fs.existsSync(filePath) || !fs.statSync(filePath).isFile()) {
res.writeHead(404);
res.end('Not Found');
return;
}
// MIME types
const extname = path.extname(filePath);
let contentType = 'text/plain';
switch (extname) {
case '.html': contentType = 'text/html'; break;
case '.js': contentType = 'text/javascript'; break;
case '.css': contentType = 'text/css'; break;
case '.json': contentType = 'application/json'; break;
case '.png': contentType = 'image/png'; break;
case '.jpg': contentType = 'image/jpeg'; break;
case '.svg': contentType = 'image/svg+xml'; break;
case '.ico': contentType = 'image/x-icon'; break;
case '.md': contentType = 'text/markdown'; break;
}
res.writeHead(200, { 'Content-Type': contentType });
fs.createReadStream(filePath).pipe(res);
});
server.listen(port, () => {
console.log(`Dashboard running at http://localhost:${port}/dashboard/`);
console.log(`Serving files from ${packageRoot}`);
console.log(`Using configuration from ${process.cwd()}`);
});
// Keep process alive
return new Promise(() => {});
}
src/decisions/DECISIONS_2026-02-14.md
+11 -9
View File
@@ -1,12 +1,14 @@
# Decisions: 2026-02-14 Constants Refactor # Decisions
- **Extracted `DEFAULT_DASHBOARD_PORT` (4173)** ## Module Boundaries
- **Reason**: Magic number used in multiple places (`cmdDashboard`, `parseArgs`). - `src/roster.mjs`: Handles loading roster from file or environment. Used by `cmdCheck`, `cmdLock`.
- **Location**: `src/constants.mjs`. - `src/lock-ops.mjs`: Handles low-level Nostr operations (`queryLocks`, `publishLock`) and parsing.
- `src/dashboard.mjs`: Handles the HTTP server for the dashboard.
- `src/torch-config.mjs`: Now includes "effective config" getters (`getRelays`, etc.) to centralize config logic.
- **Extracted `RACE_CHECK_DELAY_MS` (1500)** ## Naming
- **Reason**: Magic number for timing logic. - Used `lock-ops.mjs` instead of `lock.mjs` to avoid confusion with the action "lock".
- **Location**: `src/constants.mjs`. - Preserved existing function names to minimize refactor impact.
- **Created `src/constants.mjs`** ## Exports
- **Reason**: No dedicated constants file existed for this level of abstraction. - `src/lib.mjs` will re-export `cmdDashboard` etc. if they were previously exported, to maintain library interface.
src/lib.mjs
+16 -328
View File
@@ -3,81 +3,27 @@
// TORCH — Task Orchestration via Relay-Coordinated Handoff // TORCH — Task Orchestration via Relay-Coordinated Handoff
// Generic Nostr-based task locking for multi-agent development. // Generic Nostr-based task locking for multi-agent development.
import fs from 'node:fs';
import path from 'node:path';
import http from 'node:http';
import { fileURLToPath } from 'node:url';
import { generateSecretKey, getPublicKey, finalizeEvent } from 'nostr-tools/pure'; import { generateSecretKey, getPublicKey, finalizeEvent } from 'nostr-tools/pure';
import { SimplePool } from 'nostr-tools/pool';
import { useWebSocketImplementation } from 'nostr-tools/relay'; import { useWebSocketImplementation } from 'nostr-tools/relay';
import WebSocket from 'ws'; import WebSocket from 'ws';
import { loadTorchConfig } from './torch-config.mjs'; import {
loadTorchConfig,
getRelays,
getNamespace,
getTtl,
} from './torch-config.mjs';
import {
DEFAULT_DASHBOARD_PORT,
RACE_CHECK_DELAY_MS,
VALID_CADENCES,
} from './constants.mjs';
import { cmdInit, cmdUpdate } from './ops.mjs'; import { cmdInit, cmdUpdate } from './ops.mjs';
import { DEFAULT_DASHBOARD_PORT, RACE_CHECK_DELAY_MS } from './constants.mjs'; import { getRoster } from './roster.mjs';
import { queryLocks, publishLock, parseLockEvent } from './lock-ops.mjs';
import { cmdDashboard } from './dashboard.mjs';
useWebSocketImplementation(WebSocket); useWebSocketImplementation(WebSocket);
const DEFAULT_RELAYS = [
'wss://relay.damus.io',
'wss://nos.lol',
'wss://relay.primal.net',
];
const DEFAULT_TTL = 7200;
const DEFAULT_NAMESPACE = 'torch';
const DEFAULT_QUERY_TIMEOUT_MS = 15_000;
const VALID_CADENCES = new Set(['daily', 'weekly']);
// If installed as a package, prompts/roster.json is relative to this file
const ROSTER_FILE = path.resolve(path.dirname(fileURLToPath(import.meta.url)), 'prompts/roster.json');
const USER_ROSTER_FILE = path.resolve(process.cwd(), 'torch/roster.json');
const FALLBACK_ROSTER = {
daily: [
'audit-agent',
'ci-health-agent',
'const-refactor-agent',
'content-audit-agent',
'decompose-agent',
'deps-security-agent',
'design-system-audit-agent',
'docs-agent',
'docs-alignment-agent',
'docs-code-investigator',
'innerhtml-migration-agent',
'known-issues-agent',
'load-test-agent',
'onboarding-audit-agent',
'perf-agent',
'prompt-curator-agent',
'protocol-research-agent',
'scheduler-update-agent',
'style-agent',
'test-audit-agent',
'todo-triage-agent',
],
weekly: [
'bug-reproducer-agent',
'changelog-agent',
'dead-code-agent',
'event-schema-agent',
'frontend-console-debug-agent',
'fuzz-agent',
'interop-agent',
'perf-deepdive-agent',
'perf-optimization-agent',
'pr-review-agent',
'race-condition-agent',
'refactor-agent',
'smoke-agent',
'telemetry-agent',
'test-coverage-agent',
'weekly-synthesis-agent',
],
};
let cachedCanonicalRoster = null;
// Custom Error class for controlled exits // Custom Error class for controlled exits
class ExitError extends Error { class ExitError extends Error {
constructor(code, message) { constructor(code, message) {
@@ -86,106 +32,6 @@ class ExitError extends Error {
} }
} }
function getRelays() {
const config = loadTorchConfig();
const envRelays = process.env.NOSTR_LOCK_RELAYS;
if (envRelays) {
return envRelays.split(',').map((r) => r.trim()).filter(Boolean);
}
if (config.nostrLock.relays?.length) {
return config.nostrLock.relays;
}
return DEFAULT_RELAYS;
}
function getNamespace() {
const config = loadTorchConfig();
const namespace = (process.env.NOSTR_LOCK_NAMESPACE || config.nostrLock.namespace || DEFAULT_NAMESPACE).trim();
return namespace || DEFAULT_NAMESPACE;
}
function getTtl() {
const config = loadTorchConfig();
const envTtl = process.env.NOSTR_LOCK_TTL;
if (envTtl) {
const parsed = parseInt(envTtl, 10);
if (!Number.isNaN(parsed) && parsed > 0) return parsed;
}
if (config.nostrLock.ttlSeconds) {
return config.nostrLock.ttlSeconds;
}
return DEFAULT_TTL;
}
function getQueryTimeoutMs() {
const config = loadTorchConfig();
const envValue = process.env.NOSTR_LOCK_QUERY_TIMEOUT_MS;
if (envValue) {
const parsed = parseInt(envValue, 10);
if (!Number.isNaN(parsed) && parsed > 0) return parsed;
}
return config.nostrLock.queryTimeoutMs || DEFAULT_QUERY_TIMEOUT_MS;
}
function loadCanonicalRoster() {
if (cachedCanonicalRoster) return cachedCanonicalRoster;
let rosterPath = ROSTER_FILE;
// Prefer user-managed roster if present
if (fs.existsSync(USER_ROSTER_FILE)) {
rosterPath = USER_ROSTER_FILE;
}
try {
const parsed = JSON.parse(fs.readFileSync(rosterPath, 'utf8'));
const daily = Array.isArray(parsed.daily) ? parsed.daily.map((item) => String(item).trim()).filter(Boolean) : [];
const weekly = Array.isArray(parsed.weekly)
? parsed.weekly.map((item) => String(item).trim()).filter(Boolean)
: [];
if (daily.length > 0 && weekly.length > 0) {
cachedCanonicalRoster = { daily, weekly };
return cachedCanonicalRoster;
}
console.error(`WARNING: Roster file is missing daily/weekly entries, falling back: ${rosterPath}`);
} catch {
// It's okay if roster file is missing when used as a library/CLI without the file present
}
cachedCanonicalRoster = FALLBACK_ROSTER;
return cachedCanonicalRoster;
}
function parseEnvRoster(value) {
if (!value) return null;
return value
.split(',')
.map((item) => item.trim())
.filter(Boolean);
}
function getRoster(cadence) {
const config = loadTorchConfig();
const dailyFromEnv = parseEnvRoster(process.env.NOSTR_LOCK_DAILY_ROSTER);
const weeklyFromEnv = parseEnvRoster(process.env.NOSTR_LOCK_WEEKLY_ROSTER);
const canonical = loadCanonicalRoster();
const dailyFromConfig = config.nostrLock.dailyRoster;
const weeklyFromConfig = config.nostrLock.weeklyRoster;
if (cadence === 'daily') {
if (dailyFromEnv && dailyFromEnv.length) return dailyFromEnv;
if (dailyFromConfig && dailyFromConfig.length) return dailyFromConfig;
return canonical.daily;
}
if (weeklyFromEnv && weeklyFromEnv.length) return weeklyFromEnv;
if (weeklyFromConfig && weeklyFromConfig.length) return weeklyFromConfig;
return canonical.weekly;
}
function todayDateStr() { function todayDateStr() {
return new Date().toISOString().slice(0, 10); return new Date().toISOString().slice(0, 10);
} }
@@ -194,90 +40,8 @@ function nowUnix() {
return Math.floor(Date.now() / 1000); return Math.floor(Date.now() / 1000);
} }
export function parseLockEvent(event) { // Re-export for backward compatibility/library usage
const dTag = event.tags.find((t) => t[0] === 'd')?.[1] ?? ''; export { parseLockEvent, queryLocks, publishLock, cmdDashboard };
const expTag = event.tags.find((t) => t[0] === 'expiration')?.[1];
const expiresAt = expTag ? parseInt(expTag, 10) : null;
let content = {};
try {
const parsed = JSON.parse(event.content);
if (parsed && typeof parsed === 'object' && !Array.isArray(parsed)) {
content = parsed;
}
} catch {
// Ignore malformed JSON content
}
return {
eventId: event.id,
pubkey: event.pubkey,
createdAt: event.created_at,
createdAtIso: new Date(event.created_at * 1000).toISOString(),
expiresAt,
expiresAtIso: expiresAt ? new Date(expiresAt * 1000).toISOString() : null,
dTag,
agent: content.agent ?? null,
cadence: content.cadence ?? null,
status: content.status ?? null,
date: content.date ?? null,
platform: content.platform ?? null,
};
}
function filterActiveLocks(locks) {
const now = nowUnix();
return locks.filter((lock) => !lock.expiresAt || lock.expiresAt > now);
}
export async function queryLocks(relays, cadence, dateStr, namespace) {
const pool = new SimplePool();
const tagFilter = `${namespace}-lock-${cadence}-${dateStr}`;
const queryTimeoutMs = getQueryTimeoutMs();
try {
const events = await Promise.race([
pool.querySync(relays, {
kinds: [30078],
'#t': [tagFilter],
}),
new Promise((_, reject) =>
setTimeout(() => reject(new Error('Relay query timed out')), queryTimeoutMs),
),
]);
return filterActiveLocks(events.map(parseLockEvent));
} finally {
pool.close(relays);
}
}
export async function publishLock(relays, event) {
const pool = new SimplePool();
try {
const publishPromises = pool.publish(relays, event);
const results = await Promise.allSettled(publishPromises);
const successes = results.filter((r) => r.status === 'fulfilled');
if (successes.length === 0) {
const errors = results.map((r, i) => {
if (r.status === 'rejected') {
const reason = r.reason;
const message = reason instanceof Error ? reason.message : String(reason ?? 'unknown');
return `${relays[i]}: ${message}`;
}
return `${relays[i]}: unknown`;
});
throw new Error(`Failed to publish to any relay:\n ${errors.join('\n ')}`);
}
console.error(` Published to ${successes.length}/${relays.length} relays`);
return event;
} finally {
pool.close(relays);
}
}
export async function cmdCheck(cadence) { export async function cmdCheck(cadence) {
const relays = getRelays(); const relays = getRelays();
@@ -481,82 +245,6 @@ export async function cmdList(cadence) {
} }
} }
export async function cmdDashboard(port = DEFAULT_DASHBOARD_PORT) {
// Resolve package root relative to this file (src/lib.mjs)
// this file is in <root>/src/lib.mjs, so '..' goes to <root>
const packageRoot = path.resolve(path.dirname(fileURLToPath(import.meta.url)), '..');
const server = http.createServer((req, res) => {
// URL parsing
const url = new URL(req.url, `http://${req.headers.host}`);
let pathname = url.pathname;
// Redirect / to /dashboard/
if (pathname === '/' || pathname === '/dashboard') {
res.writeHead(302, { 'Location': '/dashboard/' });
res.end();
return;
}
// Special case: /torch-config.json
// Priority: User's CWD > Package default
if (pathname === '/torch-config.json') {
const userConfigPath = path.resolve(process.cwd(), 'torch-config.json');
if (fs.existsSync(userConfigPath)) {
res.writeHead(200, { 'Content-Type': 'application/json' });
fs.createReadStream(userConfigPath).pipe(res);
return;
}
// If not found in CWD, fall through to serve from packageRoot (if it exists there)
// or return empty object if missing?
// Falling through means it looks for packageRoot/torch-config.json
}
// Security check: prevent directory traversal
const safePath = path.normalize(pathname).replace(new RegExp('^(\\.\\.[\\/\\\\])+'), '');
let filePath = path.join(packageRoot, safePath);
// If directory, try index.html
if (fs.existsSync(filePath) && fs.statSync(filePath).isDirectory()) {
filePath = path.join(filePath, 'index.html');
}
// Check if file exists and is a file
if (!fs.existsSync(filePath) || !fs.statSync(filePath).isFile()) {
res.writeHead(404);
res.end('Not Found');
return;
}
// MIME types
const extname = path.extname(filePath);
let contentType = 'text/plain';
switch (extname) {
case '.html': contentType = 'text/html'; break;
case '.js': contentType = 'text/javascript'; break;
case '.css': contentType = 'text/css'; break;
case '.json': contentType = 'application/json'; break;
case '.png': contentType = 'image/png'; break;
case '.jpg': contentType = 'image/jpeg'; break;
case '.svg': contentType = 'image/svg+xml'; break;
case '.ico': contentType = 'image/x-icon'; break;
case '.md': contentType = 'text/markdown'; break;
}
res.writeHead(200, { 'Content-Type': contentType });
fs.createReadStream(filePath).pipe(res);
});
server.listen(port, () => {
console.log(`Dashboard running at http://localhost:${port}/dashboard/`);
console.log(`Serving files from ${packageRoot}`);
console.log(`Using configuration from ${process.cwd()}`);
});
// Keep process alive
return new Promise(() => {});
}
function parseArgs(argv) { function parseArgs(argv) {
const args = { command: null, agent: null, cadence: null, dryRun: false, force: false, port: DEFAULT_DASHBOARD_PORT }; const args = { command: null, agent: null, cadence: null, dryRun: false, force: false, port: DEFAULT_DASHBOARD_PORT };
let i = 0; let i = 0;
src/lock-ops.mjs
+91
View File
@@ -0,0 +1,91 @@
import { SimplePool } from 'nostr-tools/pool';
import { getQueryTimeoutMs } from './torch-config.mjs';
function nowUnix() {
return Math.floor(Date.now() / 1000);
}
export function parseLockEvent(event) {
const dTag = event.tags.find((t) => t[0] === 'd')?.[1] ?? '';
const expTag = event.tags.find((t) => t[0] === 'expiration')?.[1];
const expiresAt = expTag ? parseInt(expTag, 10) : null;
let content = {};
try {
const parsed = JSON.parse(event.content);
if (parsed && typeof parsed === 'object' && !Array.isArray(parsed)) {
content = parsed;
}
} catch {
// Ignore malformed JSON content
}
return {
eventId: event.id,
pubkey: event.pubkey,
createdAt: event.created_at,
createdAtIso: new Date(event.created_at * 1000).toISOString(),
expiresAt,
expiresAtIso: expiresAt ? new Date(expiresAt * 1000).toISOString() : null,
dTag,
agent: content.agent ?? null,
cadence: content.cadence ?? null,
status: content.status ?? null,
date: content.date ?? null,
platform: content.platform ?? null,
};
}
function filterActiveLocks(locks) {
const now = nowUnix();
return locks.filter((lock) => !lock.expiresAt || lock.expiresAt > now);
}
export async function queryLocks(relays, cadence, dateStr, namespace) {
const pool = new SimplePool();
const tagFilter = `${namespace}-lock-${cadence}-${dateStr}`;
const queryTimeoutMs = getQueryTimeoutMs();
try {
const events = await Promise.race([
pool.querySync(relays, {
kinds: [30078],
'#t': [tagFilter],
}),
new Promise((_, reject) =>
setTimeout(() => reject(new Error('Relay query timed out')), queryTimeoutMs),
),
]);
return filterActiveLocks(events.map(parseLockEvent));
} finally {
pool.close(relays);
}
}
export async function publishLock(relays, event) {
const pool = new SimplePool();
try {
const publishPromises = pool.publish(relays, event);
const results = await Promise.allSettled(publishPromises);
const successes = results.filter((r) => r.status === 'fulfilled');
if (successes.length === 0) {
const errors = results.map((r, i) => {
if (r.status === 'rejected') {
const reason = r.reason;
const message = reason instanceof Error ? reason.message : String(reason ?? 'unknown');
return `${relays[i]}: ${message}`;
}
return `${relays[i]}: unknown`;
});
throw new Error(`Failed to publish to any relay:\n ${errors.join('\n ')}`);
}
console.error(` Published to ${successes.length}/${relays.length} relays`);
return event;
} finally {
pool.close(relays);
}
}
src/perf/decompose/raw-file-size-report.log
+3
View File
@@ -0,0 +1,3 @@
dashboard/index.html: 748 lines (excess: 448)
landing/index.html: 757 lines (excess: 457)
src/lib.mjs: 693 lines (excess: 393)
src/roster.mjs
+111
View File
@@ -0,0 +1,111 @@
import fs from 'node:fs';
import path from 'node:path';
import { fileURLToPath } from 'node:url';
import { loadTorchConfig } from './torch-config.mjs';
const ROSTER_FILE = path.resolve(path.dirname(fileURLToPath(import.meta.url)), 'prompts/roster.json');
const USER_ROSTER_FILE = path.resolve(process.cwd(), 'torch/roster.json');
const FALLBACK_ROSTER = {
daily: [
'audit-agent',
'ci-health-agent',
'const-refactor-agent',
'content-audit-agent',
'decompose-agent',
'deps-security-agent',
'design-system-audit-agent',
'docs-agent',
'docs-alignment-agent',
'docs-code-investigator',
'innerhtml-migration-agent',
'known-issues-agent',
'load-test-agent',
'onboarding-audit-agent',
'perf-agent',
'prompt-curator-agent',
'protocol-research-agent',
'scheduler-update-agent',
'style-agent',
'test-audit-agent',
'todo-triage-agent',
],
weekly: [
'bug-reproducer-agent',
'changelog-agent',
'dead-code-agent',
'event-schema-agent',
'frontend-console-debug-agent',
'fuzz-agent',
'interop-agent',
'perf-deepdive-agent',
'perf-optimization-agent',
'pr-review-agent',
'race-condition-agent',
'refactor-agent',
'smoke-agent',
'telemetry-agent',
'test-coverage-agent',
'weekly-synthesis-agent',
],
};
let cachedCanonicalRoster = null;
function loadCanonicalRoster() {
if (cachedCanonicalRoster) return cachedCanonicalRoster;
let rosterPath = ROSTER_FILE;
// Prefer user-managed roster if present
if (fs.existsSync(USER_ROSTER_FILE)) {
rosterPath = USER_ROSTER_FILE;
}
try {
const parsed = JSON.parse(fs.readFileSync(rosterPath, 'utf8'));
const daily = Array.isArray(parsed.daily) ? parsed.daily.map((item) => String(item).trim()).filter(Boolean) : [];
const weekly = Array.isArray(parsed.weekly)
? parsed.weekly.map((item) => String(item).trim()).filter(Boolean)
: [];
if (daily.length > 0 && weekly.length > 0) {
cachedCanonicalRoster = { daily, weekly };
return cachedCanonicalRoster;
}
console.error(`WARNING: Roster file is missing daily/weekly entries, falling back: ${rosterPath}`);
} catch {
// It's okay if roster file is missing when used as a library/CLI without the file present
}
cachedCanonicalRoster = FALLBACK_ROSTER;
return cachedCanonicalRoster;
}
function parseEnvRoster(value) {
if (!value) return null;
return value
.split(',')
.map((item) => item.trim())
.filter(Boolean);
}
export function getRoster(cadence) {
const config = loadTorchConfig();
const dailyFromEnv = parseEnvRoster(process.env.NOSTR_LOCK_DAILY_ROSTER);
const weeklyFromEnv = parseEnvRoster(process.env.NOSTR_LOCK_WEEKLY_ROSTER);
const canonical = loadCanonicalRoster();
const dailyFromConfig = config.nostrLock.dailyRoster;
const weeklyFromConfig = config.nostrLock.weeklyRoster;
if (cadence === 'daily') {
if (dailyFromEnv && dailyFromEnv.length) return dailyFromEnv;
if (dailyFromConfig && dailyFromConfig.length) return dailyFromConfig;
return canonical.daily;
}
if (weeklyFromEnv && weeklyFromEnv.length) return weeklyFromEnv;
if (weeklyFromConfig && weeklyFromConfig.length) return weeklyFromConfig;
return canonical.weekly;
}
src/test_logs/TEST_LOG_2026-02-14.md
+12 -174
View File
@@ -1,177 +1,15 @@
# Test Logs
> [email protected] lint ## Initial State
> eslint . - `src/lib.mjs` size: ~693 lines.
- `npm test` passing.
## Commands Run
- `node scripts/check-file-size.mjs --report`
/app/scripts/agent/debug-frontend.mjs ## Verification
3:8 warning 'path' is defined but never used no-unused-vars - `npm run lint`: Passed (1 warning in test file).
- `npm test`: Passed (9/9 tests).
/app/test/nostr-lock.test.mjs - `node scripts/check-file-size.mjs --update`: Updated baseline.
1:10 warning 'test' is defined but never used no-unused-vars - New `src/lib.mjs` size: 381 lines.
- Reduction: ~312 lines (Target: >200).
✖ 2 problems (0 errors, 2 warnings)
> [email protected] test
> node --test test/*.test.mjs
TAP version 13
# Subtest: CLI Smoke Test
# Subtest: should print usage when no args provided
ok 1 - should print usage when no args provided
---
duration_ms: 325.690702
type: 'test'
...
# Subtest: should fail when checking without cadence
ok 2 - should fail when checking without cadence
---
duration_ms: 187.135216
type: 'test'
...
# Subtest: should include paused agents in check output
ok 3 - should include paused agents in check output
---
duration_ms: 15297.898808
type: 'test'
...
1..3
ok 1 - CLI Smoke Test
---
duration_ms: 15812.845491
type: 'suite'
...
# Initializing torch configuration in /app/test-ops-P1ZLv8/project1/torch...
# Created torch/roster.json
# Created torch/META_PROMPTS.md
# Created torch/scheduler-flow.md
# Created torch/daily-scheduler.md
# Created torch/weekly-scheduler.md
# Created 23 files in torch/prompts/daily/
# Created 20 files in torch/prompts/weekly/
# Initialization complete.
# You can now customize the files in torch/ and torch/prompts/.
# Initializing torch configuration in /app/test-ops-P1ZLv8/project2/torch...
# Initializing torch configuration in /app/test-ops-P1ZLv8/project3/torch...
# Created torch/roster.json
# Created torch/META_PROMPTS.md
# Created torch/scheduler-flow.md
# Created torch/daily-scheduler.md
# Created torch/weekly-scheduler.md
# Created 23 files in torch/prompts/daily/
# Created 20 files in torch/prompts/weekly/
# Initialization complete.
# You can now customize the files in torch/ and torch/prompts/.
# Updating torch configuration in /app/test-ops-P1ZLv8/project3/torch...
# Creating backup at torch/_backups/backup_2026-02-14T07-28-56-279Z...
# Updating static files...
# Updated META_PROMPTS.md
# Updated scheduler-flow.md
# Updated daily-scheduler.md
# Updated weekly-scheduler.md
# Skipped roster.json (preserved)
# Updating prompts...
# daily/: 0 added, 0 updated, 23 preserved
# weekly/: 0 added, 0 updated, 20 preserved
# Update complete.
# Initializing torch configuration in /app/test-ops-P1ZLv8/project4/torch...
# Created torch/roster.json
# Created torch/META_PROMPTS.md
# Created torch/scheduler-flow.md
# Created torch/daily-scheduler.md
# Created torch/weekly-scheduler.md
# Created 23 files in torch/prompts/daily/
# Created 20 files in torch/prompts/weekly/
# Initialization complete.
# You can now customize the files in torch/ and torch/prompts/.
# Updating torch configuration in /app/test-ops-P1ZLv8/project4/torch...
# Creating backup at torch/_backups/backup_2026-02-14T07-28-56-310Z...
# Updating static files...
# Updated META_PROMPTS.md
# Updated scheduler-flow.md
# Updated daily-scheduler.md
# Updated weekly-scheduler.md
# Overwrote roster.json (forced)
# Updating prompts...
# daily/: 0 added, 23 updated, 0 preserved
# weekly/: 0 added, 20 updated, 0 preserved
# Update complete.
# Initializing torch configuration in /app/test-ops-P1ZLv8/project5/torch...
# Created torch/roster.json
# Created torch/META_PROMPTS.md
# Created torch/scheduler-flow.md
# Created torch/daily-scheduler.md
# Created torch/weekly-scheduler.md
# Created 23 files in torch/prompts/daily/
# Created 20 files in torch/prompts/weekly/
# Initialization complete.
# You can now customize the files in torch/ and torch/prompts/.
# Updating torch configuration in /app/test-ops-P1ZLv8/project5/torch...
# Creating backup at torch/_backups/backup_2026-02-14T07-28-56-350Z...
# Updating static files...
# Updated META_PROMPTS.md
# Updated scheduler-flow.md
# Updated daily-scheduler.md
# Updated weekly-scheduler.md
# Skipped roster.json (preserved)
# Updating prompts...
# daily/: 0 added, 0 updated, 23 preserved
# weekly/: 0 added, 0 updated, 20 preserved
# Update complete.
# Initializing torch configuration in /app/test-ops-P1ZLv8/project_roster/torch...
# Created torch/roster.json
# Created torch/META_PROMPTS.md
# Created torch/scheduler-flow.md
# Created torch/daily-scheduler.md
# Created torch/weekly-scheduler.md
# Created 23 files in torch/prompts/daily/
# Created 20 files in torch/prompts/weekly/
# Initialization complete.
# You can now customize the files in torch/ and torch/prompts/.
# Checking locks: namespace=torch, cadence=daily, date=2026-02-14
# Relays: wss://relay.damus.io, wss://nos.lol, wss://relay.primal.net
# Subtest: cmdInit creates directory structure and files
ok 2 - cmdInit creates directory structure and files
---
duration_ms: 31.478284
type: 'test'
...
# Subtest: cmdInit fails if directory exists without force
ok 3 - cmdInit fails if directory exists without force
---
duration_ms: 1.223212
type: 'test'
...
# Subtest: cmdUpdate preserves modified prompt
ok 4 - cmdUpdate preserves modified prompt
---
duration_ms: 29.696939
type: 'test'
...
# Subtest: cmdUpdate overwrites prompt with force
ok 5 - cmdUpdate overwrites prompt with force
---
duration_ms: 33.378006
type: 'test'
...
# Subtest: cmdUpdate creates backup
ok 6 - cmdUpdate creates backup
---
duration_ms: 35.96283
type: 'test'
...
# Subtest: torch-lock check respects local roster
ok 7 - torch-lock check respects local roster
---
duration_ms: 15295.37334
type: 'test'
...
1..7
# tests 9
# suites 1
# pass 9
# fail 0
# cancelled 0
# skipped 0
# todo 0
# duration_ms 15904.442607
src/todo/TODO_2026-02-14.md
+10 -5
View File
@@ -1,6 +1,11 @@
# Todo: 2026-02-14 Constants Refactor # TODO Checklist
- [ ] Create `src/constants.mjs` with `DEFAULT_DASHBOARD_PORT` and `RACE_CHECK_DELAY_MS`. - [ ] Update `src/constants.mjs` with defaults.
- [ ] Update `src/lib.mjs` to import and use new constants. - [ ] Update `src/torch-config.mjs` with config getters.
- [ ] Verify changes with `npm run lint` and `npm test`. - [ ] Create `src/roster.mjs` with roster logic.
- [ ] Document decisions. - [ ] Create `src/lock-ops.mjs` with lock operations.
- [ ] Create `src/dashboard.mjs` with dashboard logic.
- [ ] Update `src/lib.mjs` to import new modules.
- [ ] Verify `npm run lint` passes.
- [ ] Verify `npm test` passes.
- [ ] Update baseline using `scripts/check-file-size.mjs --update`.
src/torch-config.mjs
+47
View File
@@ -1,5 +1,11 @@
import fs from 'node:fs'; import fs from 'node:fs';
import path from 'node:path'; import path from 'node:path';
import {
DEFAULT_RELAYS,
DEFAULT_TTL,
DEFAULT_NAMESPACE,
DEFAULT_QUERY_TIMEOUT_MS,
} from './constants.mjs';
const DEFAULT_CONFIG_PATH = 'torch-config.json'; const DEFAULT_CONFIG_PATH = 'torch-config.json';
@@ -87,3 +93,44 @@ export function loadTorchConfig() {
return cachedConfig; return cachedConfig;
} }
export function getRelays() {
const config = loadTorchConfig();
const envRelays = process.env.NOSTR_LOCK_RELAYS;
if (envRelays) {
return envRelays.split(',').map((r) => r.trim()).filter(Boolean);
}
if (config.nostrLock.relays?.length) {
return config.nostrLock.relays;
}
return DEFAULT_RELAYS;
}
export function getNamespace() {
const config = loadTorchConfig();
const namespace = (process.env.NOSTR_LOCK_NAMESPACE || config.nostrLock.namespace || DEFAULT_NAMESPACE).trim();
return namespace || DEFAULT_NAMESPACE;
}
export function getTtl() {
const config = loadTorchConfig();
const envTtl = process.env.NOSTR_LOCK_TTL;
if (envTtl) {
const parsed = parseInt(envTtl, 10);
if (!Number.isNaN(parsed) && parsed > 0) return parsed;
}
if (config.nostrLock.ttlSeconds) {
return config.nostrLock.ttlSeconds;
}
return DEFAULT_TTL;
}
export function getQueryTimeoutMs() {
const config = loadTorchConfig();
const envValue = process.env.NOSTR_LOCK_QUERY_TIMEOUT_MS;
if (envValue) {
const parsed = parseInt(envValue, 10);
if (!Number.isNaN(parsed) && parsed > 0) return parsed;
}
return config.nostrLock.queryTimeoutMs || DEFAULT_QUERY_TIMEOUT_MS;
}
task-logs/daily/2026-02-14T07-10-00Z__decompose-agent__completed.md
+24
View File
@@ -0,0 +1,24 @@
# Decompose Agent - Completed
**Agent:** decompose-agent
**Status:** Completed
**Date:** 2026-02-14
## Summary
Decomposed `src/lib.mjs` (approx 700 lines) into:
- `src/roster.mjs`: Roster logic.
- `src/lock-ops.mjs`: Lock operations.
- `src/dashboard.mjs`: Dashboard server.
- `src/torch-config.mjs`: Configuration getters.
- `src/constants.mjs`: Defaults and constants.
## Artifacts
- `src/context/CONTEXT_2026-02-14.md`
- `src/todo/TODO_2026-02-14.md`
- `src/decisions/DECISIONS_2026-02-14.md`
- `src/test_logs/TEST_LOG_2026-02-14.md`
## Verification
- `npm run lint`: Passed.
- `npm test`: Passed.
- Baseline updated: `src/lib.mjs` reduced to 381 lines.