Update src/index.ts

src/index.ts

@@ -4,327 +4,261 @@ 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';
+import { Resend } from 'resend';
 
-// ============================================================
-//  কনফিগারেশন
-// ============================================================
 const __filename = fileURLToPath(import.meta.url);
 const __dirname = path.dirname(__filename);
 
 interface Config {
-    RES1_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;
+  RES1_REPO: string;
+  GITHUB_PAT: string;
+  VERSIONS_DIR: string;
+  HEALTH_PORT: number;
+  PROD_PORT: number;
+  TEST_PORT: number;
+  ADMIN_EMAIL: string;
+  RESEND_API_KEY: string;
+  FROM_EMAIL: string;
 }
 
 const CONFIG: Config = {
-    RES1_REPO: 'https://github.com/NepsenX/Oracus-AI.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'
+  RES1_REPO: 'https://github.com/NepsenX/Oracus-AI.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',
+  RESEND_API_KEY: process.env.RESEND_API_KEY || '',
+  FROM_EMAIL: 'onboarding@resend.dev' // Resend-এর ডিফল্ট sender
 };
 
-// PAT না থাকলে Exit
 if (!CONFIG.GITHUB_PAT) {
-    console.error('❌ GITHUB_PAT environment variable is not set!');
-    console.error('Please add GITHUB_PAT to Repository Secrets.');
-    process.exit(1);
+  console.error('❌ GITHUB_PAT not set!');
+  process.exit(1);
 }
 
-// ============================================================
-//  স্টেট ম্যানেজমেন্ট
-// ============================================================
-let prodProcess: ChildProcess | null = null;
-let prodVersionPath: string | null = null;
-let isUpdating: boolean = false;
+if (!CONFIG.RESEND_API_KEY) {
+  console.warn('⚠️ RESEND_API_KEY not set. Email notifications disabled.');
+}
+
+const resend = CONFIG.RESEND_API_KEY ? new Resend(CONFIG.RESEND_API_KEY) : null;
 
 // ============================================================
-//  ইমেইল ফাংশন
+// ইমেইল ফাংশন (Resend API - SMTP লাগে না!)
 // ============================================================
 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);
+  if (!resend) {
+    console.log(`📧 [SKIP] Email would be sent: "${subject}"`);
+    return;
+  }
+  try {
+    const { data, error } = await resend.emails.send({
+      from: CONFIG.FROM_EMAIL,
+      to: [CONFIG.ADMIN_EMAIL],
+      subject: `[Oracus Runner] ${subject}`,
+      text: text
+    });
+    if (error) {
+      console.error('❌ Resend error:', error);
+    } else {
+      console.log(`✅ Email sent! ID: ${data?.id}`);
     }
+  } catch (err: any) {
+    console.error(`⚠️ Email failed (ignored): ${err.message}`);
+  }
 }
 
 // ============================================================
-//  গিট ইউটিলিটি (PAT সহ)
+// গিট ইউটিলিটি
 // ============================================================
 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());
-        });
+  return new Promise((resolve, reject) => {
+    exec(cmd, { cwd }, (error, stdout, stderr) => {
+      if (error) reject(stderr || error.message);
+      else resolve(stdout.trim());
     });
+  });
 }
 
 function getRepoUrlWithPat(repoUrl: string): string {
-    if (repoUrl.includes('@')) return repoUrl;
-    return repoUrl.replace('https://', `https://${CONFIG.GITHUB_PAT}@`);
+  if (repoUrl.includes('@')) return repoUrl;
+  return repoUrl.replace('https://', `https://${CONFIG.GITHUB_PAT}@`);
 }
 
 async function getCurrentCommitSha(repoUrl: string): Promise<string | null> {
-    try {
-        const urlWithPat = getRepoUrlWithPat(repoUrl);
-        const output = await runGitCommand(`git ls-remote ${urlWithPat} main`, process.cwd());
-        return output.split(/\s/)[0];
-    } catch (err: any) {
-        console.error('⚠️ Failed to fetch SHA:', err.message);
-        return null;
-    }
+  try {
+    const urlWithPat = getRepoUrlWithPat(repoUrl);
+    const output = await runGitCommand(`git ls-remote ${urlWithPat} main`, process.cwd());
+    return output.split(/\s/)[0];
+  } catch {
+    return null;
+  }
 }
 
 async function cloneOrPull(repoUrl: string, targetDir: string): Promise<void> {
-    const urlWithPat = getRepoUrlWithPat(repoUrl);
-    if (!fs.existsSync(targetDir)) {
-        console.log(`📥 Cloning ${repoUrl} into ${targetDir}...`);
-        await runGitCommand(`git clone ${urlWithPat} ${targetDir}`, process.cwd());
-    } else {
-        console.log(`🔄 Pulling latest in ${targetDir}...`);
-        await runGitCommand(`git pull`, targetDir);
-    }
+  const urlWithPat = getRepoUrlWithPat(repoUrl);
+  if (!fs.existsSync(targetDir)) {
+    console.log(`📥 Cloning into ${targetDir}...`);
+    await runGitCommand(`git clone ${urlWithPat} ${targetDir}`, process.cwd());
+  } else {
+    console.log(`🔄 Pulling latest...`);
+    await runGitCommand(`git pull`, targetDir);
+  }
 }
 
-// ============================================================
-//  📂 মেমোরি কপি ইউটিলিটি (শুধু লোকাল)
-// ============================================================
-function copyMemoryFolder(srcVersionPath: string, dstVersionPath: string): void {
-    const srcMemory = path.join(srcVersionPath, 'memory');
-    const dstMemory = path.join(dstVersionPath, 'memory');
-    
-    if (fs.existsSync(srcMemory)) {
-        // গন্তব্য memory ফোল্ডার মুছে ফেলো
-        if (fs.existsSync(dstMemory)) {
-            fs.rmSync(dstMemory, { recursive: true, force: true });
-        }
-        // সোর্স থেকে কপি করো
-        fs.cpSync(srcMemory, dstMemory, { recursive: true });
-        console.log(`📂 Memory copied from ${srcMemory} to ${dstMemory}`);
-    } else {
-        console.log(`⚠️ Source memory folder not found: ${srcMemory}`);
-    }
+function copyMemoryFolder(srcPath: string, dstPath: string): void {
+  const srcMemory = path.join(srcPath, 'memory');
+  const dstMemory = path.join(dstPath, 'memory');
+  if (fs.existsSync(srcMemory)) {
+    if (fs.existsSync(dstMemory)) fs.rmSync(dstMemory, { recursive: true, force: true });
+    fs.cpSync(srcMemory, dstMemory, { recursive: true });
+    console.log(`📂 Memory copied`);
+  }
 }
 
 // ============================================================
-//  🚀 এজেন্ট ডিপ্লয় (পোর্ট প্যারামিটার সহ)
+// এজেন্ট ডিপ্লয়
 // ============================================================
 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: 3000 });
-                    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}`);
-                }
-            }, 8000);
-        });
+  return new Promise((resolve, reject) => {
+    console.log(`🚀 Starting agent on port ${port}...`);
+    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: 3000 });
+          if (res.status === 200) {
+            console.log(`✅ Health check passed on port ${port}!`);
+            resolve(proc);
+          } else reject(`Health check failed on port ${port}`);
+        } catch (err: any) {
+          reject(`Health check error on port ${port}: ${err.message}`);
+        }
+      }, 8000);
     });
+  });
 }
 
 // ============================================================
-//  🧠 মূল আপডেট লজিক (আপনার বর্ণিত ফ্লো - Res3 বাদ)
-// ============================================================
+let prodProcess: ChildProcess | null = null;
+let prodVersionPath: string | null = null;
+let isUpdating: boolean = false;
+
 async function checkAndUpdate(): Promise<void> {
-    if (isUpdating) {
-        console.log('⏳ Update already in progress...');
-        return;
+  if (isUpdating) {
+    console.log('⏳ Update already in progress...');
+    return;
+  }
+  isUpdating = true;
+  let testProcess: ChildProcess | null = null;
+  let testVersionPath: string | null = null;
+
+  try {
+    console.log('🔍 Checking for updates...');
+    const latestSha = await getCurrentCommitSha(CONFIG.RES1_REPO);
+    if (!latestSha) throw new Error('Could not fetch latest SHA');
+
+    let currentSha: string | null = null;
+    if (prodVersionPath && fs.existsSync(path.join(prodVersionPath, '.git'))) {
+      try { currentSha = await runGitCommand('git rev-parse HEAD', prodVersionPath); } catch {}
     }
 
-    isUpdating = true;
-    let testProcess: ChildProcess | null = null;
-    let testVersionPath: string | null = null;
-
-    try {
-        console.log('🔍 Checking for updates...');
-
-        // ১. Res1-এর সর্বশেষ 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 {}
-        }
-
-        // ৩. যদি SHA একই হয়, তাহলে কিছু করো না
-        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)
-        testVersionPath = path.join(CONFIG.VERSIONS_DIR, `v2_${Date.now()}`);
-        await cloneOrPull(CONFIG.RES1_REPO, testVersionPath);
-
-        // ৫. V2-কে পোর্ট ২০০০-এ চালাও (টেস্ট)
-        testProcess = await deployAgent(testVersionPath, CONFIG.TEST_PORT);
-        console.log(`✅ V2 passed health check on port ${CONFIG.TEST_PORT}!`);
-
-        // ৬. সফল! এখন প্রমোশন শুরু করো
-
-        // ৬.১: ৭০০০-এর memory ফোল্ডার ২০০০-এ কপি করো (যদি ৭০০০-এর Agent আগে থেকে চালু থাকে)
-        if (prodVersionPath) {
-            copyMemoryFolder(prodVersionPath, testVersionPath);
-        } else {
-            console.log('⚠️ No previous version found. Starting fresh without memory copy.');
-        }
-
-        // ৬.২: ২০০০-এর Agent বন্ধ করো (memory লক হয়ে যেতে পারে)
-        if (testProcess) {
-            console.log('🛑 Stopping test agent on port 2000...');
-            testProcess.kill('SIGTERM');
-            await new Promise(resolve => setTimeout(resolve, 2000));
-            if (!testProcess.killed) {
-                testProcess.kill('SIGKILL');
-            }
-        }
+    if (latestSha === currentSha) {
+      console.log('✅ Already up to date.');
+      isUpdating = false;
+      return;
+    }
 
-        // ৬.৩: এখন ২০০০-এর কোড দিয়ে ৭০০০-এ চালাও (memory সহ)
-        console.log(`🚀 Promoting V2 to production port ${CONFIG.PROD_PORT}...`);
-        const newProdProc = await deployAgent(testVersionPath, CONFIG.PROD_PORT);
+    console.log(`🆕 New version: ${latestSha}. Deploying on port ${CONFIG.TEST_PORT}...`);
+    testVersionPath = path.join(CONFIG.VERSIONS_DIR, `v2_${Date.now()}`);
+    await cloneOrPull(CONFIG.RES1_REPO, testVersionPath);
+    testProcess = await deployAgent(testVersionPath, CONFIG.TEST_PORT);
+    console.log(`✅ V2 passed health check!`);
 
-        // ৬.৪: পুরনো ৭০০০ বন্ধ করো
-        if (prodProcess) {
-            console.log('🛑 Stopping old production agent on port 7000...');
-            prodProcess.kill('SIGTERM');
-            setTimeout(() => {
-                if (!prodProcess?.killed) prodProcess?.kill('SIGKILL');
-            }, 3000);
-        }
+    if (prodVersionPath) copyMemoryFolder(prodVersionPath, testVersionPath);
 
-        // ৬.৫: স্টেট আপডেট করো
-        prodProcess = newProdProc;
-        prodVersionPath = testVersionPath;
-        testProcess = null;
-        testVersionPath = null;
+    if (testProcess) {
+      testProcess.kill('SIGTERM');
+      await new Promise(resolve => setTimeout(resolve, 2000));
+      if (!testProcess.killed) testProcess.kill('SIGKILL');
+    }
 
-        console.log(`✅ Successfully deployed V2 (${latestSha}) on port ${CONFIG.PROD_PORT}`);
-        await sendEmail('Deployment Successful', `Version ${latestSha} is now LIVE on port 7000.`);
+    console.log(`🚀 Promoting to production port ${CONFIG.PROD_PORT}...`);
+    const newProdProc = await deployAgent(testVersionPath, CONFIG.PROD_PORT);
 
-    } catch (error: any) {
-        console.error('❌ Deployment failed:', error);
+    if (prodProcess) {
+      console.log('🛑 Stopping old production...');
+      prodProcess.kill('SIGTERM');
+      setTimeout(() => { if (!prodProcess?.killed) prodProcess?.kill('SIGKILL'); }, 3000);
+    }
 
-        // ৭. ❌ ব্যর্থ! ২০০০ বন্ধ করো, ৭০০০ অপরিবর্তিত রাখো
-        if (testProcess) {
-            console.log('🛑 Stopping failed test agent on port 2000...');
-            testProcess.kill('SIGTERM');
-            setTimeout(() => {
-                if (!testProcess?.killed) testProcess?.kill('SIGKILL');
-            }, 2000);
-        }
+    prodProcess = newProdProc;
+    prodVersionPath = testVersionPath;
+    testProcess = null;
+    testVersionPath = null;
 
-        // ব্যর্থতার ইমেইল পাঠাও
-        await sendEmail('Deployment FAILED', `Error: ${error.message}. Port 7000 is unchanged.`);
+    console.log(`✅ Successfully deployed V2 (${latestSha}) on port ${CONFIG.PROD_PORT}`);
+    await sendEmail('Deployment Successful', `Version ${latestSha} is now LIVE on port 7000.`);
 
-        if (prodProcess) {
-            console.log('🔄 Keeping old version running on port 7000.');
-        } else {
-            console.log('⚠️ No previous version available. Port 7000 is empty.');
-        }
-    } finally {
-        isUpdating = false;
+  } catch (error: any) {
+    console.error('❌ Deployment failed:', error);
+    if (testProcess) {
+      testProcess.kill('SIGTERM');
+      setTimeout(() => { if (!testProcess?.killed) testProcess?.kill('SIGKILL'); }, 2000);
     }
+    await sendEmail('Deployment FAILED', `Error: ${error.message}. Port 7000 is unchanged.`);
+    if (prodProcess) console.log('🔄 Keeping old version running.');
+    else console.log('⚠️ No previous version available.');
+  } finally {
+    isUpdating = false;
+  }
 }
 
 // ============================================================
-//  HTTP সার্ভার (পোর্ট ৭৮৬০ - UptimeRobot পাবে)
+// HTTP সার্ভার
 // ============================================================
 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 if (url.pathname === '/status') {
-        const status = {
-            prodRunning: prodProcess !== null,
-            prodVersion: prodVersionPath ? path.basename(prodVersionPath) : 'none',
-            isUpdating: isUpdating
-        };
-        res.writeHead(200, { 'Content-Type': 'application/json' });
-        res.end(JSON.stringify(status, null, 2));
-    } else {
-        res.writeHead(404);
-        res.end('Not Found');
-    }
+  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!');
+    setImmediate(() => checkAndUpdate());
+  } else if (url.pathname === '/force-update') {
+    res.writeHead(200);
+    res.end('Force update triggered.');
+    setImmediate(() => checkAndUpdate());
+  } else if (url.pathname === '/status') {
+    res.writeHead(200, { 'Content-Type': 'application/json' });
+    res.end(JSON.stringify({
+      prodRunning: prodProcess !== null,
+      prodVersion: prodVersionPath ? path.basename(prodVersionPath) : 'none',
+      isUpdating
+    }, null, 2));
+  } 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();
+  console.log(`✅ Health server running on port ${CONFIG.HEALTH_PORT}`);
+  console.log('⏳ Initial setup...');
+  checkAndUpdate();
 });
 
-// ============================================================
-//  প্রসেস হ্যান্ডলিং
-// ============================================================
 process.on('uncaughtException', (err) => {
-    console.error('💥 Uncaught Exception:', err);
-    sendEmail('CRASH - Uncaught Exception', err.stack || err.message);
+  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));
+  console.error('💥 Unhandled Rejection:', reason);
+  sendEmail('CRASH - Unhandled Rejection', String(reason));
 });