File size: 4,854 Bytes
5112d5b | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 | import { exec, execFile } from 'node:child_process';
import { mkdir, readFile, writeFile } from 'node:fs/promises';
import { dirname, join, resolve } from 'node:path';
import { homedir } from 'node:os';
import { fileURLToPath } from 'node:url';
import { promisify } from 'node:util';
import { getFrontendDualDbRoutingStatus } from './supabase.js';
const execAsync = promisify(exec);
const execFileAsync = promisify(execFile);
const AGENT_ROOT = resolve(dirname(fileURLToPath(import.meta.url)), '..', '..');
const HF_PULL_SCRIPT = resolve(AGENT_ROOT, 'scripts', 'hf_pull_script.py');
const RUN_OPENCODE_SCRIPT = resolve(AGENT_ROOT, 'scripts', 'run_opencode.py');
const DEFAULT_STATE_PATH = join(homedir(), '.config', 'sin', 'sin-frontend', 'onboarding-state.json');
type OnboardingState = {
ownerEmail?: string;
notes?: string;
updatedAt?: string;
};
export type TemplateAgentAction =
| { action: 'agent.help' }
| { action: 'sin.frontend.health' }
| { action: 'sin.frontend.onboarding.status' }
| { action: 'sin.frontend.onboarding.save'; ownerEmail?: string; notes?: string; confirm?: boolean }
| { action: 'sin.frontend.code.generate'; prompt: string; contextDir?: string }
| { action: 'sin.frontend.code.review'; targetDir: string };
export type FrontendAgentAction = TemplateAgentAction;
export async function executeTemplateAgentAction(action: TemplateAgentAction): Promise<unknown> {
switch (action.action) {
case 'agent.help':
return buildHelpPayload();
case 'sin.frontend.health':
return {
ok: true,
agent: 'sin-code-frontend',
primaryModel: 'google/antigravity-gemini-3.1-pro',
fallbackModel: 'opencode/nemotron-3-super-free',
team: 'Team - Coding',
status: 'Elite Coder Runtime Online',
dualDb: getFrontendDualDbRoutingStatus(),
};
case 'sin.frontend.onboarding.status':
return {
ok: true,
statePath: DEFAULT_STATE_PATH,
state: await readState(),
};
case 'sin.frontend.onboarding.save':
if (!action.confirm) {
throw new Error('input_required:confirm=true required');
}
return {
ok: true,
statePath: DEFAULT_STATE_PATH,
state: await writeState({
ownerEmail: clean(action.ownerEmail),
notes: clean(action.notes),
updatedAt: new Date().toISOString(),
}),
};
case 'sin.frontend.code.generate':
return await executeOpenCode(action.prompt, action.contextDir);
case 'sin.frontend.code.review':
return await executeOpenCode(
`Review ${action.targetDir} according to multi-billion dollar Google Workspace level Alpha standards.`,
action.targetDir,
);
}
}
export const executeFrontendAgentAction = executeTemplateAgentAction;
async function executeOpenCode(prompt: string, dir?: string) {
await execFileAsync('python3', [HF_PULL_SCRIPT], { cwd: AGENT_ROOT }).catch(() => {
console.warn('Rotator token pull failed, using cached auth if available');
});
const options = dir ? { cwd: dir } : {};
try {
const { stdout } = await execFileAsync('python3', [RUN_OPENCODE_SCRIPT, '--model', 'google/antigravity-gemini-3.1-pro', '--agent', 'sin-executor-solo', '--cwd', dir || AGENT_ROOT, '--timeout-sec', '900', '--prompt', prompt], { cwd: AGENT_ROOT });
const result = JSON.parse(stdout) as { ok: boolean; stdout: string; stderr: string; timeout: boolean; returncode: number };
if (!result.ok) {
throw new Error(result.timeout ? `${result.stderr || result.stdout || 'opencode_timeout'}\nagent_timeout:900s` : (result.stderr || result.stdout || `opencode_returncode_${result.returncode}`));
}
return {
ok: true,
expertAnalysis: result.stdout,
warnings: result.stderr || undefined,
};
} catch (error: any) {
throw new Error(`Master Coder Execution Failed: ${error.message}`);
}
}
function buildHelpPayload() {
return {
ok: true,
agent: 'sin-code-frontend',
mandate: 'CEO Elite Master Boss Coder for multi-billion dollar Alpha frontends.',
actions: [
'sin.frontend.health',
'sin.frontend.onboarding.status',
'sin.frontend.onboarding.save',
'sin.frontend.code.generate',
'sin.frontend.code.review',
],
};
}
async function readState(): Promise<OnboardingState | null> {
try {
return JSON.parse(await readFile(DEFAULT_STATE_PATH, 'utf8')) as OnboardingState;
} catch {
return null;
}
}
async function writeState(state: OnboardingState) {
await mkdir(dirname(DEFAULT_STATE_PATH), { recursive: true });
await writeFile(DEFAULT_STATE_PATH, `${JSON.stringify(state, null, 2)}\n`, 'utf8');
return state;
}
function clean(value: string | undefined) {
const normalized = String(value || '').trim();
return normalized || undefined;
}
|