NanoClaw 코어 기능 가이드: 메시징 I/O 및 지식 가속화 (2/3)

import { Client, LocalAuth } from 'whatsapp-web.js';
import { enqueueMessage } from '../group-queue';

export function initializeWhatsApp() {
    const client = new Client({
        // 매번 QR 코드를 다시 찍지 않도록 영구 지속 스토리지 볼륨에 인증 세션 덤프 보존
        authStrategy: new LocalAuth({ dataPath: '/opt/nanoclaw/storage/.wwebjs_auth' }),
        puppeteer: {
            headless: true,
            args: [
                '--no-sandbox',             // Docker 격리 컨테이너 내부 런타임 가동을 위한 필수 플래그
                '--disable-setuid-sandbox',
                '--disable-dev-shm-usage',  // 메모리 부족으로 인한 브라우저 프로세스 좀비 크래시 방지
                '--disable-gpu',
                '--no-zygote'
            ]
        }
    });

    client.on('qr', (qr) => {
        console.log('[NanoClaw WHATSAPP] 인증용 QR 코드가 발행되었습니다. 스캔이 필요합니다:', qr);
    });

    client.on('ready', () => {
        console.log('[NanoClaw WHATSAPP] 웹 세션 연동이 최종 완료되어 정상 상시 대기 중입니다.');
    });

    client.on('message', async (msg) => {
        const payload = {
            source: 'whatsapp',
            sender: msg.author || msg.from,
            text: msg.body,
            reply: async (text: string) => { await client.sendMessage(msg.from, text); }
        };
        // 병렬 유입 발언을 단일 그룹 컨텍스트 순차 큐에 바인딩
        await enqueueMessage(msg.from, payload); // 전용 FIFO 큐 파이프라인 정렬 수립
    });

    client.initialize();
}

import TelegramBot from 'node-telegram-bot-api';
import { enqueueMessage } from '../group-queue';

export function initializeTelegram() {
    const token = process.env.TELEGRAM_BOT_TOKEN;
    if (!token) {
        console.error('[NanoClaw TELEGRAM] 오류: 토큰이 환경변수에 존재하지 않아 구동을 건너뜁니다.');
        return;
    }

    // 외부 웹훅 서버 없이 사설 내부망에서도 패킷 유실 없는 고속 롱폴링 드라이버 기동
    const bot = new TelegramBot(token, { polling: true });

    console.log('[NanoClaw TELEGRAM] 롱 폴링 게이트웨이가 성공적으로 상시 런타임 리스너를 시작했습니다.');

    bot.on('message', async (msg) => {
        // 텍스트가 없거나 텔레그램 고유 봇 커맨드 구문(/start 등)은 코어 엔진 부하 방지를 위해 필터링
        if (!msg.text || msg.text.startsWith('/')) return;

        const payload = {
            source: 'telegram',
            sender: msg.from?.id.toString() || 'unknown',
            text: msg.text,
            reply: async (text: string) => { await bot.sendMessage(msg.chat.id, text); }
        };
        // 단일 대화방 룸 ID(chat.id)를 키값으로 FIFO 워크 큐 분기 처리
        await enqueueMessage(msg.chat.id.toString(), payload);
    });
}

# [System Core State Memory]
- Group Identifier: telegram--100123456
- Last Synchronized: 2026-05-27T02:40:00Z
- Core Mission: 호스트 서비스 리소스 모니터링 및 미디어 인프라 운영 자동화 파이프라인 유지

## 1. 운영 룰셋 및 강제 제약 필터 (Guardrails)
* 사용자의 명시적인 확인 서명이 있기 전에는 어떠한 상황에서도 시스템 영구 볼륨 마운트 해제 커맨드를 수행하지 말 것.
* 모든 자산 모니터링 산출 보고 데이터는 마크다운 정렬 표(Table) 서식을 준수하여 인간 운영자의 가독성을 보장할 것.
* 예외 크래시 발생 시 코어를 정지하지 말고 오류 스택을 이 파일의 에러 타임라인에 기록 후 우회 처리를 전개할 것.

## 2. 지속성 로컬 지식베이스 (Knowledge Base)
* 타깃 프로덕션 도메인 자산: it-get.com IT 엔지니어링 마스터 미디어 사이트 운영 정보 및 미들웨어 구조
* 백업 NAS 사설 인프라 엔드포인트 세팅 주소: 192.168.1.50
* 핵심 모듈 종속성 스키마 버전: Node.js v18 + Docker Engine v26.0+ 최적화 상태

const BLACKLIST_PATTERNS = [
    /ignore\s+previous\s+instructions/id,  // 이전 지침 시스템 프롬프트 초기화 무력화 구문 강제 차단
    /system\s+prompt\s+reveal/id,          // 백서 마스터 설계 보안 기밀 유출 프롬프트 방어
    /rm\s+-rf\s+\//i,                      // 격리 샌드박스 내부라 하더라도 악성 루트 디렉토리 파괴 시도 즉시 드롭
    /printenv/i,                           // 자격증명(Credential) 정보 및 호스트 변수 강제 덤프 시도 차단
    /cat\s+\/proc\/self\/environ/i         // 커널 정보 조회 우회 스크립트 인젝션 차단
];

export function validateInboundMessage(text: string): boolean {
    const sanitizedText = text.trim();
    
    for (const pattern of BLACKLIST_PATTERNS) {
        if (pattern.test(sanitizedText)) {
            console.error(`\n[NanoClaw CRITICAL SECURITY ALERT]`);
            console.error(`악성 주입 공격 패턴 감지되어 LLM 진입 전 즉시 차단되었습니다.`);
            console.error(`매칭된 보안 규칙 정규식: ${pattern}\n`);
            return false; // 보안 정합성 검증 실패 반환 (메시지 드롭)
        }
    }
    return true; // 정상 패킷으로 판명 시 통과
}

import * as dotenv from 'dotenv';
import * as path from 'path';

// 1편에서 견고하게 수립한 리눅스 파일 시스템 내부의 서비스 환경 프로필 절대 경로 바인딩
dotenv.config({ path: '/opt/nanoclaw/core/.env' }); 

import { initializeWhatsApp } from './clients/whatsapp';
import { initializeTelegram } from './clients/telegram';

async function main() {
    console.log('==================================================================');
    console.log(' [Master Core] NanoClaw 메시징 I/O 및 고속 통합 가드레일 레이어 기동 ');
    console.log('==================================================================');

    // 1. WhatsApp 게이트웨이 구동 (상용 멀티 디바이스 환경 필요 시 주석 해제)
    // initializeWhatsApp();

    // 2. 외부 포트 완전 폐쇄형 사설망 대응 텔레그램 롱 폴링 게이트웨이 기동
    initializeTelegram();
}

// 프로덕션 환경에서 메신저 소켓 단절 등으로 발생하는 예외 크래시 방어 핸들러 배치
process.on('unhandledRejection', (reason, promise) => {
    console.error('[NanoClaw NON-FATAL CRASH] 예측하지 못한 비동기 예외 트랙킹:', promise, '사유:', reason);
});

process.on('uncaughtException', (error) => {
    console.error('[NanoClaw FATAL CRASH] 시스템 코어 무결성 치명적 오류 발생:', error);
    // 필요 시 알림 전송 후 프로세스 안전 재시작 스케줄 유도
    process.exit(1);
});

main().catch((err) => {
    console.error('[NanoClaw ENGINE INITIALIZE FAILED] 코어 인프라 진입 실패:', err);
    process.exit(1);
});