import { runSSH, b64 } from './ssh';

import type { DelegateParams, DelegateResult } from './types';

const HOST = process.env.ZPM_CLAUDE_HOST || 'REDACTED-IP';

const USER = process.env.ZPM_CLAUDE_USER || 'zion';

export async function claudeAdapter(p: DelegateParams): Promise<DelegateResult> {

  const start = Date.now();

  const cwd = p.cwd || '/shared/projects';

  const prompt = p.context ? `${p.context}\n\n---\n\n${p.task}` : p.task;

  const cmd = `export PATH="$HOME/.local/bin:/usr/local/bin:$PATH"; export IS_SANDBOX=1; cd ${JSON.stringify(cwd)} 2>/dev/null; printf %s ${b64(prompt)} | base64 -d | claude -p --dangerously-skip-permissions 2>&1`;

  try {

    const r = await runSSH(HOST, USER, cmd, p.timeoutMs ?? 120_000);

    return { ok: r.code === 0, output: r.stdout.trim() || r.stderr.trim(), artifacts: [], error: r.code === 0 ? undefined : `exit ${r.code}`, durationMs: Date.now() - start };

  } catch (e) {

    return { ok: false, output: '', artifacts: [], error: (e as Error).message, durationMs: Date.now() - start };

  }

}