Update Api.js

Api.js

@@ -1,6 +1,6 @@
 /**
  * API.js — FINAL TOTAL
- * Rate limiting + Cloudflare Interstitial + Cache + Task Queue
+ * Rate limiting + Cloudflare Interstitial + Cache + Task Queue + Ablink
  */
 
 const express = require('express');
@@ -69,7 +69,7 @@ function writeCache(type, taskId, value) {
 
 // ================= CLEAN CACHE PERIODIC =================
 setInterval(() => {
-    const types = ["recaptcha2", "recaptcha3", "turnstile", "interstitial"];
+    const types = ["recaptcha2", "recaptcha3", "turnstile", "interstitial", "ablink"];
     const now = Date.now();
     types.forEach(type => {
         const dir = path.join(CACHE_DIR, type);
@@ -85,8 +85,8 @@ setInterval(() => {
 }, 600000); // 10 menit
 
 // ================= EXPRESS =================
-app.use(express.json());
-app.use(express.urlencoded({ extended: true }));
+app.use(express.json({ limit: '10mb' }));
+app.use(express.urlencoded({ extended: true, limit: '10mb' }));
 
 const tasks = {};
 
@@ -107,13 +107,14 @@ app.get("/", (req, res) => {
         message: "CAPTCHA Solver API",
         version: "8.0.0",
         limits: { concurrent: MAX_CONCURRENT, timeout: global.timeOut },
-        endpoints: ["/solve", "/health", "/stats"]
+        endpoints: ["/solve", "/solve/ablink", "/health", "/stats"]
     });
 });
 
 // ================= SOLVE ENDPOINT =================
 app.post('/solve', async (req, res) => {
-    const { type, domain, siteKey, taskId, action, proxy, isInvisible } = req.body;
+    // Tambahkan cdata di sini
+    const { type, domain, siteKey, taskId, action, proxy, isInvisible, cdata } = req.body;
 
     // Polling jika taskId dikirim
     if (taskId) {
@@ -132,7 +133,7 @@ app.post('/solve', async (req, res) => {
     const cached = readCache(type, newTaskId);
     if (cached) {
         tasks[newTaskId] = cached;
-        return res.json({ taskId: newTaskId, status: "done", cached: true });
+        return res.json({ taskId: newTaskId, status: "done", cached: true, solution: cached.solution });
     }
 
     try {
@@ -150,7 +151,8 @@ app.post('/solve', async (req, res) => {
                     solution = await recaptchaV3({ domain, siteKey, action, proxy }, page);
                     break;
                 case "turnstile":
-                    solution = await turnstile({ domain, siteKey, action, proxy }, page);
+                    // Kirimkan cdata ke fungsi turnstile
+                    solution = await turnstile({ domain, siteKey, action, cdata, proxy }, page);
                     break;
                 case "interstitial":
                     solution = await interstitial({ domain, proxy }, page);
@@ -179,8 +181,7 @@ app.post('/solve', async (req, res) => {
         res.status(500).json({ taskId: newTaskId, status: "error", message: error.message });
     }
 });
-
-// GET /solve?taskId=xxx — polling
+// GET /solve?taskId=xxx — polling (existing)
 app.get('/solve', (req, res) => {
     const { taskId } = req.query;
     if (!taskId) return res.status(400).json({ error: "Missing taskId" });
@@ -190,6 +191,46 @@ app.get('/solve', (req, res) => {
     return res.json({ status: task.status, solution: task.solution });
 });
 
+// ================= ABLINK ENDPOINT =================
+app.post('/solve/ablink', async (req, res) => {
+    const { instructionImage, options } = req.body;
+    if (!instructionImage || !Array.isArray(options) || options.length === 0) {
+        return res.status(400).json({ error: 'Missing instructionImage or options array' });
+    }
+
+    const newTaskId = Date.now().toString(36) + Math.random().toString(36).substr(2);
+    tasks[newTaskId] = { status: "pending" };
+    console.log(`🆕 New ablink task: ${newTaskId}`);
+
+    // Cek cache
+    const cached = readCache("ablink", newTaskId);
+    if (cached) {
+        tasks[newTaskId] = cached;
+        return res.json({ taskId: newTaskId, status: "done", cached: true, solution: cached.solution });
+    }
+
+    try {
+        const result = await addTask(async () => {
+            console.log(`🚀 Processing ablink: ${newTaskId}`);
+            const solution = await solveAblink(instructionImage, options);
+            tasks[newTaskId] = { status: "done", solution };
+            writeCache("ablink", newTaskId, tasks[newTaskId]);
+            return solution;
+        });
+
+        res.json({ 
+            taskId: newTaskId, 
+            status: "queued", 
+            position: taskQueue.length,
+            estimatedWait: taskQueue.length * 30000
+        });
+    } catch (error) {
+        tasks[newTaskId] = { status: "error", message: error.message };
+        console.error(`❌ Failed ablink: ${newTaskId} - ${error.message}`);
+        res.status(500).json({ taskId: newTaskId, status: "error", message: error.message });
+    }
+});
+
 // ================= BROWSER INIT =================
 async function init_browser(proxyServer = null) {
     const connectOptions = {
@@ -230,7 +271,8 @@ async function init_browser(proxyServer = null) {
 const recaptchaV2 = require('./Api/recaptcha2');
 const recaptchaV3 = require('./Api/recaptcha3');
 const turnstile = require('./Api/turnstile');
-const interstitial = require('./interstitial'); // pastikan file ini ada
+const interstitial = require('./interstitial');
+const solveAblink = require('./ablinksolver');
 
 // ================= STATS =================
 app.get('/stats', (req, res) => {
@@ -257,4 +299,4 @@ app.listen(port, () => {
 🕐 Started: ${new Date().toISOString()}
 ==========================================
 `);
-});
+});