Update plugins/sora2.js

plugins/sora2.js

@@ -1,7 +1,7 @@
 const axios = require('axios');
 const dns = require('dns').promises;
 
-const PROXY_URL = 'https://young-sunset-2246.herzfnf.workers.dev';
+const PROXY_URL = 'https://proxy-sigma-roan.vercel.app/api/proxy';
 
 dns.setServers([
     '1.1.1.1',
@@ -24,30 +24,8 @@ function generatePassword() {
     return password;
 }
 
-let cachedProxyIP = null;
-
-async function resolveProxyIP() {
-    if (cachedProxyIP) {
-        return cachedProxyIP;
-    }
-    
-    try {
-        const hostname = 'young-sunset-2246.herzfnf.workers.dev';
-        const addresses = await dns.resolve4(hostname);
-        cachedProxyIP = addresses[0];
-        console.log(`DNS Resolved: ${hostname} -> ${cachedProxyIP}`);
-        return cachedProxyIP;
-    } catch (error) {
-        console.error('DNS resolution failed:', error.message);
-        return null;
-    }
-}
-
 async function proxyRequest(url, options = {}) {
     const targetPath = url.startsWith('http') ? url : url;
-    const encodedPath = encodeURIComponent(targetPath);
-    
-    let proxyUrl = `${PROXY_URL}?url=${encodedPath}`;
     
     const headers = {
         'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36',
@@ -56,10 +34,12 @@ async function proxyRequest(url, options = {}) {
     };
     
     const axiosConfig = {
-        url: proxyUrl,
         method: options.method || 'GET',
         headers: headers,
         timeout: 30000,
+        params: {
+            url: targetPath
+        },
         validateStatus: function (status) {
             return status >= 200 && status < 600;
         }
@@ -73,32 +53,27 @@ async function proxyRequest(url, options = {}) {
     
     for (let attempt = 1; attempt <= 3; attempt++) {
         try {
-            console.log(`Attempt ${attempt}: ${proxyUrl}`);
+            axiosConfig.url = PROXY_URL;
+            console.log(`Attempt ${attempt}: ${PROXY_URL}?url=${targetPath}`);
+            
             const response = await axios(axiosConfig);
-            return response;
+            
+            if (response.status >= 200 && response.status < 300) {
+                return response;
+            }
+            
+            console.log(`Attempt ${attempt} got status ${response.status}`);
+            
+            if (attempt < 3) {
+                await new Promise(resolve => setTimeout(resolve, 1000 * attempt));
+            }
             
         } catch (error) {
             lastError = error;
             console.error(`Attempt ${attempt} failed:`, error.code || error.message);
             
-            if (error.code === 'ENOTFOUND' || error.code === 'EAI_AGAIN') {
-                console.log('DNS issue detected, trying to resolve...');
-                const ip = await resolveProxyIP();
-                
-                if (ip && attempt === 1) {
-                    console.log(`Retrying with resolved IP: ${ip}`);
-                    axiosConfig.url = proxyUrl.replace('young-sunset-2246.herzfnf.workers.dev', ip);
-                    axiosConfig.headers['Host'] = 'young-sunset-2246.herzfnf.workers.dev';
-                }
-                
-                if (attempt < 3) {
-                    await new Promise(resolve => setTimeout(resolve, 2000 * attempt));
-                    continue;
-                }
-            }
-            
             if (attempt < 3) {
-                await new Promise(resolve => setTimeout(resolve, 1000 * attempt));
+                await new Promise(resolve => setTimeout(resolve, 2000 * attempt));
             }
         }
     }
@@ -107,6 +82,7 @@ async function proxyRequest(url, options = {}) {
 }
 
 async function createTempEmail() {
+    console.log('Creating temporary email...');
     const { data } = await axios.post('https://api.internal.temp-mail.io/api/v3/email/new', {
         min_name_length: 10,
         max_name_length: 10
@@ -120,10 +96,12 @@ async function createTempEmail() {
         timeout: 15000
     });
     
+    console.log(`Email created: ${data.email}`);
     return data;
 }
 
 async function getHcaptchaToken() {
+    console.log('Getting hCaptcha token...');
     const { data } = await axios.get(
         'https://anabot.my.id/api/tools/bypass?url=https%3A%2F%2Fapi.hcaptcha.com&siteKey=6f70c0f2-3ef6-4972-9fb6-c0b4bade3af8&type=hcaptcha-invisible&apikey=freeApikey',
         {
@@ -135,10 +113,12 @@ async function getHcaptchaToken() {
         throw new Error('Failed to get hCaptcha token');
     }
     
+    console.log('hCaptcha token obtained');
     return data.data.result.token;
 }
 
 async function sendVerificationEmail(email) {
+    console.log(`Sending verification email to ${email}...`);
     const hcaptchaToken = await getHcaptchaToken();
     const encodedEmail = encodeURIComponent(email);
     
@@ -158,11 +138,13 @@ async function sendVerificationEmail(email) {
         throw new Error(`Failed to send verification email: ${data.msg || 'Unknown error'}`);
     }
     
+    console.log('Verification email sent successfully');
     await new Promise(resolve => setTimeout(resolve, 3000));
     return true;
 }
 
 async function getVerificationCode(email) {
+    console.log('Waiting for verification code...');
     let attempts = 0;
     const maxAttempts = 30;
     
@@ -188,11 +170,13 @@ async function getVerificationCode(email) {
                 const codeMatch = bodyText.match(/Verification Code:\s*(\d{6})/);
                 
                 if (codeMatch) {
+                    console.log(`Verification code received: ${codeMatch[1]}`);
                     return codeMatch[1];
                 }
             }
             
             attempts++;
+            console.log(`Checking for verification code... attempt ${attempts}/${maxAttempts}`);
         } catch (error) {
             console.log(`Email check attempt ${attempts} failed:`, error.message);
             attempts++;
@@ -203,6 +187,7 @@ async function getVerificationCode(email) {
 }
 
 async function registerAccount(email, password, verificationCode) {
+    console.log('Registering account...');
     const { data } = await proxyRequest('/api/auth/register', {
         method: 'POST',
         headers: {
@@ -223,10 +208,12 @@ async function registerAccount(email, password, verificationCode) {
         throw new Error(`Registration failed: ${data.msg || 'Unknown error'}`);
     }
     
+    console.log('Account registered successfully');
     return data.data.token;
 }
 
 async function createVideo(prompt, ratio, authToken, email) {
+    console.log('Creating video task...');
     await new Promise(resolve => setTimeout(resolve, 2000));
     
     const { data } = await proxyRequest('/aimodels/api/v1/ai/video/create', {
@@ -257,6 +244,7 @@ async function createVideo(prompt, ratio, authToken, email) {
         throw new Error(`Failed to create video: ${data.message || 'Unknown error'}`);
     }
     
+    console.log(`Video task created with ID: ${data.data}`);
     return data.data;
 }
 
@@ -276,6 +264,7 @@ async function getTaskStatus(taskId, authToken) {
 }
 
 async function waitForVideoCompletion(taskId, authToken) {
+    console.log('Waiting for video generation...');
     let attempts = 0;
     const maxAttempts = 120;
     
@@ -284,8 +273,11 @@ async function waitForVideoCompletion(taskId, authToken) {
         
         const taskData = await getTaskStatus(taskId, authToken);
         
+        console.log(`Video status check ${attempts + 1}/${maxAttempts} - State: ${taskData.state}`);
+        
         if (taskData.state === 1 && taskData.completeData) {
             const completeData = JSON.parse(taskData.completeData);
+            console.log('Video generation completed!');
             return completeData.data.result_urls[0];
         }
         
@@ -296,32 +288,26 @@ async function waitForVideoCompletion(taskId, authToken) {
         attempts++;
     }
     
-    throw new Error('Video generation timeout');
+    throw new Error('Video generation timeout after 10 minutes');
 }
 
 async function sora2(prompt, ratio = 'portrait') {
-    console.log('Starting Sora2 video generation...');
+    console.log('=== Starting Sora2 Video Generation ===');
+    console.log(`Prompt: ${prompt}`);
+    console.log(`Ratio: ${ratio}`);
     
     const tempMail = await createTempEmail();
     const email = tempMail.email;
     const password = generatePassword();
     
-    console.log(`Email created: ${email}`);
-    
     await sendVerificationEmail(email);
-    console.log('Verification email sent');
-    
     const verificationCode = await getVerificationCode(email);
-    console.log(`Verification code received: ${verificationCode}`);
-    
     const authToken = await registerAccount(email, password, verificationCode);
-    console.log('Account registered successfully');
-    
     const taskId = await createVideo(prompt, ratio, authToken, email);
-    console.log(`Video task created: ${taskId}`);
-    
     const videoUrl = await waitForVideoCompletion(taskId, authToken);
-    console.log(`Video completed: ${videoUrl}`);
+    
+    console.log('=== Video Generation Completed ===');
+    console.log(`Video URL: ${videoUrl}`);
     
     return {
         success: true,
@@ -333,6 +319,8 @@ async function sora2(prompt, ratio = 'portrait') {
 }
 
 const handler = async (req, res) => {
+    const startTime = Date.now();
+    
     try {
         const { prompt, key, ratio = 'portrait' } = req.query;
         
@@ -340,7 +328,8 @@ const handler = async (req, res) => {
             return res.status(400).json({
                 author: 'Herza',
                 success: false,
-                msg: 'Missing required parameter: prompt'
+                msg: 'Missing required parameter: prompt',
+                usage: '/api/AI/sora2?prompt=your_prompt&ratio=portrait&key=your_key'
             });
         }
         
@@ -360,8 +349,21 @@ const handler = async (req, res) => {
             });
         }
         
+        console.log(`\n${'='.repeat(60)}`);
+        console.log('NEW REQUEST RECEIVED');
+        console.log(`Prompt: ${prompt}`);
+        console.log(`Ratio: ${ratio}`);
+        console.log(`${'='.repeat(60)}\n`);
+        
         const result = await sora2(prompt, ratio);
         
+        const duration = ((Date.now() - startTime) / 1000).toFixed(2);
+        
+        console.log(`\n${'='.repeat(60)}`);
+        console.log('REQUEST COMPLETED');
+        console.log(`Duration: ${duration}s`);
+        console.log(`${'='.repeat(60)}\n`);
+        
         res.json({
             author: 'Herza',
             success: true,
@@ -374,25 +376,35 @@ const handler = async (req, res) => {
                 account: {
                     email: result.email,
                     password: result.password
-                }
+                },
+                processingTime: `${duration}s`
             }
         });
     } catch (error) {
-        console.error('Error generating Sora2 video:', error);
+        console.error('\n❌ ERROR:', error.message);
+        console.error('Stack:', error.stack);
+        
+        const duration = ((Date.now() - startTime) / 1000).toFixed(2);
+        
         res.status(500).json({
             author: 'Herza',
             success: false,
-            msg: error.message || 'Terjadi kesalahan saat generate video.'
+            msg: error.message || 'Terjadi kesalahan saat generate video.',
+            processingTime: `${duration}s`,
+            error: {
+                code: error.code || 'UNKNOWN',
+                details: error.response?.data || null
+            }
         });
     }
 }
 
 module.exports = {
     name: 'Sora2 Video Generator',
-    description: 'Generate videos using Sora2 AI model from Bylo.ai',
+    description: 'Generate videos using Sora2 AI model from Bylo.ai via Vercel Proxy',
     type: 'GET',
     routes: ['api/AI/sora2'],
-    tags: ['AI', 'Sora', 'OpenAI'],
+    tags: ['AI', 'Sora', 'OpenAI', 'Video'],
     parameters: ['prompt', 'ratio', 'key'],
     enabled: true,
     main: ['AI'],