NanoClaw 실전 엔터프라이즈 활용 가이드: 고급 스케줄링 및 커스텀 스킬 개발 (3/3 최종 완결판)

import cron from 'node-cron';
import { EventEmitter } from 'events';

export interface AutomatedJob {
    id: string;
    name: string;
    expression: string;
    task: () => Promise;
}

class CronQueueEngine extends EventEmitter {
    private jobs: Map = new Map();
    private isProcessing: boolean = false;
    private jobQueue: string[] = [];

    constructor() {
        super();
    }

    // 1. 새로운 정기 스케줄 태스크 등록 및 동시성 격리 파이프라인 배치
    public registerJob(job: AutomatedJob): void {
        if (this.jobs.has(job.id)) {
            throw new Error(`[Cron Engine] 치명적 오류: 이미 등록된 작업 ID입니다. (${job.id})`);
        }

        const scheduledTask = cron.schedule(job.expression, async () => {
            console.log(`[Cron Engine] 스케줄 시그널 감지 - 작업 큐 진입: ${job.name} (${new Date().toISOString()})`);
            this.jobQueue.push(job.id);
            await this.processQueue(job.task);
        }, {
            scheduled: true,
            timezone: "Asia/Seoul" // 엔터프라이즈 홈랩 인프라 표준 타임존 고정
        });

        this.jobs.set(job.id, scheduledTask);
        console.log(`[Cron Engine] 성공: 정기 태스크가 스케줄러에 등록되었습니다. -> [${job.name}]`);
    }

    // 2. 순차 FIFO 제어를 통한 중복 실행(Race Condition) 방어 엔진
    private async processQueue(task: () => Promise): Promise {
        if (this.isProcessing) {
            console.warn(`[Cron Engine] 경고: 이전 작업이 진행 중입니다. 현재 태스크는 작업 큐에서 상시 대기합니다.`);
            return;
        }

        this.isProcessing = true;
        
        try {
            // 자율 코드 실행 단 유입 직전 하드웨어 가속 확보 및 작업 전개
            await task();
            this.jobQueue.shift();
        } catch (error) {
            console.error(`[Cron Engine] 치명적 예외 발생 (태스크 실패 케이스 감지):`, error);
            this.emit('jobFailed', { jobId: this.jobQueue[0], error });
        } finally {
            this.isProcessing = false;
            // 대기 중인 후속 배치 작업이 존재할 경우 재귀 루프 호출
            if (this.jobQueue.length > 0) {
                this.emit('nextJobTriggered');
            }
        }
    }
}

export const cronEngine = new CronQueueEngine();

import { execFile } from 'child_process';
import * as fs from 'fs';
import * as path from 'path';

export interface PythonExecutionResult {
    success: boolean;
    stdout: string;
    stderr: string;
    executionTimeMs: number;
}

export async function executePythonSkillInSandbox(
    scriptContent: string,
    inputPayload: object
): Promise {
    const startTime = Date.now();
    const uniqueId = `skill_${Math.random().toString(36).substring(2, 11)}`;
    
    // 1. 호스트의 격리된 보안 임시 공간(IPC Volume)에 독립 파일로 덤프
    const sandboxDir = '/opt/nanoclaw/ipc/sandbox_workspace';
    if (!fs.existsSync(sandboxDir)) fs.mkdirSync(sandboxDir, { recursive: true });

    const scriptPath = path.join(sandboxDir, `${uniqueId}.py`);
    const inputPath = path.join(sandboxDir, `${uniqueId}_input.json`);

    fs.writeFileSync(scriptPath, scriptContent, 'utf-8');
    fs.writeFileSync(inputPath, JSON.stringify(inputPayload), 'utf-8');

    return new Promise((resolve) => {
        // 2. 외부 인젝션을 물리적으로 차단하기 위해 셸 격리형 execFile 커맨드 아키텍처 아규먼트 선언
        const dockerArgs = [
            'run', '--rm',
            '--network', 'none', // 내부 사설망 횡적 이동(Lateral Movement) 방지를 위해 네트워크 스택 원천 격리
            '--memory', '256m',  // Cgroup 기반 메모리 점유 하드 캡 제한
            '--cpu-quota', '30000',
            '-v', `${sandboxDir}:/workspace:ro`, // Read-Only 마운트로 임시 스크립트 무단 위조 변조 원천 차단
            'python:3.10-slim',
            'sh', '-c', `python /workspace/${uniqueId}.py < /workspace/${uniqueId}_input.json`
        ];

        execFile('docker', dockerArgs, { timeout: 30000 }, (error, stdout, stderr) => {
            // 3. 실행 종료 즉시 임시 아티팩트 자원 반환 및 물리 파기 처리
            if (fs.existsSync(scriptPath)) fs.unlinkSync(scriptPath);
            if (fs.existsSync(inputPath)) fs.unlinkSync(inputPath);

            const executionTimeMs = Date.now() - startTime;

            if (error && error.killed) {
                resolve({
                    success: false,
                    stdout: "",
                    stderr: `[TIMEOUT CRITICAL] 파이썬 스킬이 허용된 연산 임계 제한 시간(30초)을 초과하여 강제 살해되었습니다.`,
                    executionTimeMs
                });
                return;
            }

            resolve({
                success: !error,
                stdout: stdout.trim(),
                stderr: stderr.trim(),
                executionTimeMs
            });
        });
    });
}

import { Anthropic } from '@anthropic-ai/sdk';
import { executePythonSkillInSandbox } from '../skills/custom-python';

const anthropic = new Anthropic({ apiKey: process.env.ANTHROPIC_API_KEY });

export async function runSwarmOrchestrator(userRequest: string): Promise {
    console.log(`[Swarm Engine] 군집 협업 분기 가동 시작: -> 입력 요구사항: "${userRequest}"`);

    // STEP 1: 기획 에이전트(Planner) - 해결을 위한 파이썬 알고리즘 논리 아키텍처 설계
    const plannerResponse = await anthropic.messages.create({
        model: "claude-3-5-sonnet-20241022",
        max_tokens: 1500,
        system: "당신은 NanoClaw Swarm의 마스터 플래너입니다. 사용자의 요구사항을 분석하여 오직 실행기 에이전트가 실행할 '순수 Python 소스 코드'만 작성하여 변환 출력하십시오. 마크다운 기호 없이 코드 본문만 반환해야 합니다.",
        messages: [{ role: "user", content: userRequest }]
    });

    const rawScript = (plannerResponse.content[0] as any).text.trim();
    console.log(`[Swarm Engine] 01. Planner 에이전트 코드 초안 설계 완료.`);

    // STEP 2: 실행 에이전트(Executor) - 가상 격리 샌드박스 내부 물리 런타임 인터셉트 실행
    console.log(`[Swarm Engine] 02. Executor 에이전트 가상 샌드박스 런타임 스폰 진입...`);
    const runtimeResult = await executePythonSkillInSandbox(rawScript, { baseTargetDomain: "it-get.com" });

    // STEP 3: 검수 에이전트(Reviewer) - 실행 결과 로그 및 무결성 정합성 최종 교차 검증
    console.log(`[Swarm Engine] 03. Reviewer 에이전트 최종 품질 및 가독성 검수 분석 시작.`);
    const reviewerResponse = await anthropic.messages.create({
        model: "claude-3-5-sonnet-20241022",
        max_tokens: 2000,
        system: "당신은 최종 검수관입니다. 기획 에이전트가 짠 소스코드와 샌드박스 실행 결과물을 대조하여 결함 유무를 파악하고, 개발자 관점의 명료한 최종 엔터프라이즈 통합 기술 보고서를 한국어로 완성도 높게 정리해 출력하십시오.",
        messages: [{
            role: "user",
            content: `[요구사항]: ${userRequest}\n\n[작성코드]:\n${rawScript}\n\n[샌드박스 출력로그]:\nSTDOUT: ${runtimeResult.stdout}\nSTDERR: ${runtimeResult.stderr}`
        }]
    });

    return (reviewerResponse.content[0] as any).text;
}