Update src/index.ts

src/index.ts

@@ -36,7 +36,14 @@ const CONFIG: Config = {
     SMTP_PASS: process.env.SMTP_PASS || 'your-app-password'
 };
 
-// ================== স্টেট ম্যানেজমেন্ট (TypeScript টাইপসহ) ==================
+// ================== PAT চেক ==================
+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);
+}
+
+// ================== স্টেট ম্যানেজমেন্ট ==================
 let prodProcess: ChildProcess | null = null;
 let prodVersionPath: string | null = null;
 let isUpdating: boolean = false;
@@ -60,7 +67,7 @@ async function sendEmail(subject: string, text: string): Promise<void> {
     }
 }
 
-// ================== গিট ইউটিলিটি (Promise র্যাপার) ==================
+// ================== গিট ইউটিলিটি (PAT সহ) ==================
 function runGitCommand(cmd: string, cwd: string): Promise<string> {
     return new Promise((resolve, reject) => {
         exec(cmd, { cwd }, (error, stdout, stderr) => {
@@ -70,35 +77,44 @@ function runGitCommand(cmd: string, cwd: string): Promise<string> {
     });
 }
 
+// PAT সহ URL তৈরি করা
+function getRepoUrlWithPat(repoUrl: string): string {
+    // যদি URL-এ ইতিমধ্যে PAT থাকে, তাহলে ফেরত দিন
+    if (repoUrl.includes('@')) return repoUrl;
+    // https://github.com/... -> https://PAT@github.com/...
+    return repoUrl.replace('https://', `https://${CONFIG.GITHUB_PAT}@`);
+}
+
 async function getCurrentCommitSha(repoUrl: string): Promise<string | null> {
     try {
-        const output = await runGitCommand(`git ls-remote ${repoUrl} main`, process.cwd());
+        const urlWithPat = getRepoUrlWithPat(repoUrl);
+        const output = await runGitCommand(`git ls-remote ${urlWithPat} main`, process.cwd());
         return output.split(/\s/)[0];
-    } catch {
+    } catch (err: any) {
+        console.error('⚠️ Failed to fetch SHA:', err.message);
         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 ${repoUrl} ${targetDir}`, process.cwd());
+        await runGitCommand(`git clone ${urlWithPat} ${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) },
@@ -108,10 +124,10 @@ function deployAgent(versionDir: string, port: number): Promise<ChildProcess> {
             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 });
+                    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);
@@ -121,7 +137,7 @@ function deployAgent(versionDir: string, port: number): Promise<ChildProcess> {
                 } catch (err: any) {
                     reject(`Health check error on port ${port}: ${err.message}`);
                 }
-            }, 5000);
+            }, 8000);
         });
     });
 }
@@ -132,7 +148,8 @@ async function syncMemory(versionPath: string): Promise<void> {
     try {
         const memoryBackupDir = '/app/memory-backup';
         if (!fs.existsSync(memoryBackupDir)) {
-            await runGitCommand(`git clone ${CONFIG.RES3_REPO} ${memoryBackupDir}`, process.cwd());
+            const urlWithPat = getRepoUrlWithPat(CONFIG.RES3_REPO);
+            await runGitCommand(`git clone ${urlWithPat} ${memoryBackupDir}`, process.cwd());
         }
 
         const srcMemory = path.join(versionPath, 'memory');
@@ -143,15 +160,20 @@ async function syncMemory(versionPath: string): Promise<void> {
             fs.cpSync(srcMemory, dstMemory, { recursive: true });
         }
 
-        await runGitCommand(`git add . && git commit -m "Memory sync from runner [skip ci]" || echo "No changes"`, memoryBackupDir);
+        // PAT দিয়ে পুশ করা
+        await runGitCommand(`git config --local user.email "oracus-runner@bot.com"`, memoryBackupDir);
+        await runGitCommand(`git config --local user.name "Oracus Runner"`, memoryBackupDir);
+        await runGitCommand(`git add .`, memoryBackupDir);
+        await runGitCommand(`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...');
@@ -162,11 +184,9 @@ async function checkAndUpdate(): Promise<void> {
     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 {
@@ -182,32 +202,25 @@ async function checkAndUpdate(): Promise<void> {
 
         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}`);
@@ -226,7 +239,7 @@ async function checkAndUpdate(): Promise<void> {
     }
 }
 
-// ================== HTTP সার্ভার (পোর্ট ৭৮৬০ - UptimeRobot) ==================
+// ================== HTTP সার্ভার ==================
 const server = http.createServer(async (req, res) => {
     const url = new URL(req.url || '/', `http://${req.headers.host}`);
 
@@ -250,7 +263,7 @@ server.listen(CONFIG.HEALTH_PORT, '0.0.0.0', () => {
     checkAndUpdate();
 });
 
-// ================== প্রসেস হ্যান্ডলিং (ক্র্যাশ হলে রিস্টার্ট) ==================
+// ================== প্রসেস হ্যান্ডলিং ==================
 process.on('uncaughtException', (err) => {
     console.error('💥 Uncaught Exception:', err);
     sendEmail('CRASH - Uncaught Exception', err.stack || err.message);