Create src/index.ts

src/index.ts

@@ -0,0 +1,262 @@
+import * as http from 'node:http';
+import { exec, spawn, ChildProcess } from 'node:child_process';
+import * as fs from 'node:fs';
+import * as path from 'node:path';
+import { fileURLToPath } from 'node:url';
+import axios from 'axios';
+import nodemailer from 'nodemailer';
+
+// ================== কনফিগারেশন ==================
+const __filename = fileURLToPath(import.meta.url);
+const __dirname = path.dirname(__filename);
+
+interface Config {
+    RES1_REPO: string;
+    RES3_REPO: string;
+    GITHUB_PAT: string;
+    VERSIONS_DIR: string;
+    HEALTH_PORT: number;
+    PROD_PORT: number;
+    TEST_PORT: number;
+    ADMIN_EMAIL: string;
+    SMTP_USER: string;
+    SMTP_PASS: string;
+}
+
+const CONFIG: Config = {
+    RES1_REPO: 'https://github.com/NepsenX/Oracus-AI.git',
+    RES3_REPO: 'https://github.com/oracusai-nepsenx/Recovery-Temp.git',
+    GITHUB_PAT: process.env.GITHUB_PAT || '',
+    VERSIONS_DIR: '/app/versions',
+    HEALTH_PORT: 7860,
+    PROD_PORT: 7000,
+    TEST_PORT: 2000,
+    ADMIN_EMAIL: 'oracusai.nepsenx@gmail.com',
+    SMTP_USER: 'oracusai.nepsenx@gmail.com',
+    SMTP_PASS: process.env.SMTP_PASS || 'your-app-password'
+};
+
+// ================== স্টেট ম্যানেজমেন্ট (TypeScript টাইপসহ) ==================
+let prodProcess: ChildProcess | null = null;
+let prodVersionPath: string | null = null;
+let isUpdating: boolean = false;
+
+// ================== ইমেইল ফাংশন ==================
+async function sendEmail(subject: string, text: string): Promise<void> {
+    try {
+        const transporter = nodemailer.createTransport({
+            service: 'gmail',
+            auth: { user: CONFIG.SMTP_USER, pass: CONFIG.SMTP_PASS }
+        });
+        await transporter.sendMail({
+            from: CONFIG.SMTP_USER,
+            to: CONFIG.ADMIN_EMAIL,
+            subject: `[Oracus Runner] ${subject}`,
+            text: text
+        });
+        console.log(`📧 Email sent: ${subject}`);
+    } catch (err: any) {
+        console.error('❌ Failed to send email:', err.message);
+    }
+}
+
+// ================== গিট ইউটিলিটি (Promise র্যাপার) ==================
+function runGitCommand(cmd: string, cwd: string): Promise<string> {
+    return new Promise((resolve, reject) => {
+        exec(cmd, { cwd }, (error, stdout, stderr) => {
+            if (error) reject(stderr || error.message);
+            else resolve(stdout.trim());
+        });
+    });
+}
+
+async function getCurrentCommitSha(repoUrl: string): Promise<string | null> {
+    try {
+        const output = await runGitCommand(`git ls-remote ${repoUrl} main`, process.cwd());
+        return output.split(/\s/)[0];
+    } catch {
+        return null;
+    }
+}
+
+async function cloneOrPull(repoUrl: string, targetDir: string): Promise<void> {
+    if (!fs.existsSync(targetDir)) {
+        console.log(`📥 Cloning ${repoUrl} into ${targetDir}...`);
+        await runGitCommand(`git clone ${repoUrl} ${targetDir}`, process.cwd());
+    } else {
+        console.log(`🔄 Pulling latest in ${targetDir}...`);
+        await runGitCommand(`git pull`, targetDir);
+    }
+}
+
+// ================== এজেন্ট ডিপ্লয় (পোর্ট প্যারামিটার সহ) ==================
+function deployAgent(versionDir: string, port: number): Promise<ChildProcess> {
+    return new Promise((resolve, reject) => {
+        console.log(`🚀 Starting agent on port ${port} from ${versionDir}...`);
+
+        // ১. ডিপেন্ডেন্সি ও বিল্ড
+        exec(`npm install && npm run build`, { cwd: versionDir }, (err) => {
+            if (err) return reject(`Build failed: ${err.message}`);
+
+            // ২. প্রসেস স্পন (পোর্ট এনভ ভেরিয়েবল হিসেবে)
+            const proc = spawn('npm', ['start'], {
+                cwd: versionDir,
+                env: { ...process.env, PORT: String(port) },
+                stdio: 'pipe'
+            });
+
+            proc.stdout.on('data', (data) => console.log(`[AGENT:${port}] ${data}`));
+            proc.stderr.on('data', (data) => console.error(`[AGENT ERR:${port}] ${data}`));
+
+            // ৩. হেলথ চেক (৫ সেকেন্ড অপেক্ষা)
+            setTimeout(async () => {
+                try {
+                    const res = await axios.get(`http://localhost:${port}/health`, { timeout: 2000 });
+                    if (res.status === 200) {
+                        console.log(`✅ Health check passed on port ${port}!`);
+                        resolve(proc);
+                    } else {
+                        reject(`Health check failed (non-200) on port ${port}`);
+                    }
+                } catch (err: any) {
+                    reject(`Health check error on port ${port}: ${err.message}`);
+                }
+            }, 5000);
+        });
+    });
+}
+
+// ================== মেমোরি সিঙ্ক (Res3) ==================
+async function syncMemory(versionPath: string): Promise<void> {
+    if (!versionPath) return;
+    try {
+        const memoryBackupDir = '/app/memory-backup';
+        if (!fs.existsSync(memoryBackupDir)) {
+            await runGitCommand(`git clone ${CONFIG.RES3_REPO} ${memoryBackupDir}`, process.cwd());
+        }
+
+        const srcMemory = path.join(versionPath, 'memory');
+        const dstMemory = path.join(memoryBackupDir, 'memory');
+
+        if (fs.existsSync(srcMemory)) {
+            fs.rmSync(dstMemory, { recursive: true, force: true });
+            fs.cpSync(srcMemory, dstMemory, { recursive: true });
+        }
+
+        await runGitCommand(`git add . && git commit -m "Memory sync from runner [skip ci]" || echo "No changes"`, memoryBackupDir);
+        await runGitCommand(`git push`, memoryBackupDir);
+        console.log('💾 Memory synced to Res3.');
+    } catch (err: any) {
+        console.error('⚠️ Memory sync failed:', err.message);
+    }
+}
+
+// ================== মূল আপডেট লজিক (ব্লু-গ্রিন) ==================
+async function checkAndUpdate(): Promise<void> {
+    if (isUpdating) {
+        console.log('⏳ Update already in progress...');
+        return;
+    }
+
+    isUpdating = true;
+    try {
+        console.log('🔍 Checking for updates...');
+
+        // ১. সর্বশেষ SHA বের করা
+        const latestSha = await getCurrentCommitSha(CONFIG.RES1_REPO);
+        if (!latestSha) throw new Error('Could not fetch latest SHA');
+
+        // ২. বর্তমান প্রোডাকশন SHA বের করা
+        let currentSha: string | null = null;
+        if (prodVersionPath && fs.existsSync(path.join(prodVersionPath, '.git'))) {
+            try {
+                currentSha = await runGitCommand('git rev-parse HEAD', prodVersionPath);
+            } catch {}
+        }
+
+        if (latestSha === currentSha) {
+            console.log('✅ Already up to date.');
+            isUpdating = false;
+            return;
+        }
+
+        console.log(`🆕 New version detected: ${latestSha}. Deploying V2 on port ${CONFIG.TEST_PORT}...`);
+
+        // ৩. V2 (টেস্ট) ডাউনলোড
+        const testVersionDir = path.join(CONFIG.VERSIONS_DIR, `v2_${Date.now()}`);
+        await cloneOrPull(CONFIG.RES1_REPO, testVersionDir);
+
+        // ৪. V2-কে পোর্ট ২০০০-এ চালান
+        const testProc = await deployAgent(testVersionDir, CONFIG.TEST_PORT);
+
+        console.log(`✅ V2 passed health check! Promoting V2 to port ${CONFIG.PROD_PORT}...`);
+
+        // ৫. প্রমোশন: পুরনো V1 (পোর্ট ৭০০০) বন্ধ
+        if (prodProcess) {
+            console.log('🛑 Stopping old V1 (Production)...');
+            prodProcess.kill('SIGTERM');
+            setTimeout(() => { if (!prodProcess?.killed) prodProcess?.kill('SIGKILL'); }, 3000);
+        }
+
+        // ৬. V2-কে পোর্ট ২০০০ থেকে তুলে ৭০০০-এ চালু
+        testProc.kill('SIGTERM');
+        await new Promise(resolve => setTimeout(resolve, 1000));
+        const newProdProc = await deployAgent(testVersionDir, CONFIG.PROD_PORT);
+
+        // ৭. স্টেট আপডেট
+        prodProcess = newProdProc;
+        prodVersionPath = testVersionDir;
+
+        // ৮. মেমোরি সিঙ্ক
+        await syncMemory(testVersionDir);
+
+        console.log(`✅ Successfully deployed V2 (${latestSha}) on port ${CONFIG.PROD_PORT}`);
+        await sendEmail('Deployment Successful', `Version ${latestSha} is now LIVE on port 7000.`);
+
+    } catch (error: any) {
+        console.error('❌ Deployment failed:', error);
+        if (prodProcess) {
+            console.log('🔄 Auto-rollback: Keeping old V1 running on port 7000.');
+        } else {
+            console.log('⚠️ No previous version available to rollback to.');
+        }
+        await sendEmail('Deployment FAILED - Rollback', `Error: ${error.message}. Previous version is still running.`);
+    } finally {
+        isUpdating = false;
+    }
+}
+
+// ================== HTTP সার্ভার (পোর্ট ৭৮৬০ - UptimeRobot) ==================
+const server = http.createServer(async (req, res) => {
+    const url = new URL(req.url || '/', `http://${req.headers.host}`);
+
+    if (url.pathname === '/') {
+        res.writeHead(200, { 'Content-Type': 'text/plain' });
+        res.end('Oracus Runner is Alive! (Port 7860)');
+        setImmediate(() => checkAndUpdate());
+    } else if (url.pathname === '/force-update') {
+        res.writeHead(200);
+        res.end('Force update triggered.');
+        setImmediate(() => checkAndUpdate());
+    } else {
+        res.writeHead(404);
+        res.end('Not Found');
+    }
+});
+
+server.listen(CONFIG.HEALTH_PORT, '0.0.0.0', () => {
+    console.log(`✅ Health server running on port ${CONFIG.HEALTH_PORT}`);
+    console.log('⏳ Initial setup: Deploying V1 on port 7000...');
+    checkAndUpdate();
+});
+
+// ================== প্রসেস হ্যান্ডলিং (ক্র্যাশ হলে রিস্টার্ট) ==================
+process.on('uncaughtException', (err) => {
+    console.error('💥 Uncaught Exception:', err);
+    sendEmail('CRASH - Uncaught Exception', err.stack || err.message);
+});
+
+process.on('unhandledRejection', (reason) => {
+    console.error('💥 Unhandled Rejection:', reason);
+    sendEmail('CRASH - Unhandled Rejection', String(reason));
+});