Update server.js

server.js

@@ -1,29 +1,15 @@
-const { app: electronApp, session } = require("electron");
-
-// Global Proxy Auth Handler
-electronApp.on("login", (event, webContents, details, authInfo, callback) => {
-  if (authInfo.isProxy) {
-    const ses = webContents.session;
-    if (ses.proxyCredentials) {
-      logger.debug(`[Main] Providing credentials for proxy via app.on('login')`);
-      event.preventDefault();
-      callback(ses.proxyCredentials.username, ses.proxyCredentials.password);
-    }
-  }
-});
-
+const { app: electronApp } = require("electron");
 const express = require("express");
 const bodyParser = require("body-parser");
 const cors = require("cors");
-const sqlite3 = require("sqlite3");
+const sqlite3 = require("sqlite3").verbose();
 const { v4: uuidv4 } = require("uuid");
 const path = require("path");
 const RecaptchaSolver = require("./solver");
 const http = require("http");
 const { Server } = require("socket.io");
-const logger = require("./logger");
 
-const PORT = 7860;
+const PORT = 3000;
 const app = express();
 const server = http.createServer(app);
 const io = new Server(server, {
@@ -94,7 +80,7 @@ app.post("/api/register", (req, res) => {
 
   // Kiểm tra xem HWID này đã được cộng tiền lần nào chưa
   db.get("SELECT id FROM users WHERE hwid = ?", [hwid], (err, row) => {
-    const initialCredits = row ? 0 : 100; // Nếu đã tồn tại HWID thì 0, mới thì 10
+    const initialCredits = row ? 0 : 100; // Nếu đã tồn tại HWID thì 0, mới thì 100
     const message = row
       ? "Đăng ký thành công! (Máy này đã nhận bonus trước đó nên không được cộng thêm)"
       : "Đăng ký thành công! Bạn nhận được +100 Credits bonus.";
@@ -220,6 +206,9 @@ app.post("/api/admin/approve", requireAdmin, (req, res) => {
       return res.status(400).json({ error: "Giao dịch không hợp lệ" });
 
     if (action === "reject") {
+      db.run("UPDATE transactions SET status = 'rejected' WHERE id = ?", [
+        transId,
+      ]);
       db.run("UPDATE transactions SET status = 'rejected' WHERE id = ?", [
         transId,
       ]);
@@ -273,59 +262,10 @@ app.post("/api/admin/update-credits", requireAdmin, (req, res) => {
   );
 });
 
-// --- CAPTCHA SOLVE QUEUE ---
-const solveQueue = [];
-let activeSolves = 0;
-const MAX_CONCURRENT_SOLVES = 3; // Tăng lên 3 vì đã tối ưu logging
-
-async function processQueue() {
-  if (solveQueue.length === 0 || activeSolves >= MAX_CONCURRENT_SOLVES) {
-    logger.updateStats(activeSolves, solveQueue.length);
-    return;
-  }
-
-  activeSolves++;
-  const { req, res, user, targetUrl, targetKey, action, proxy } = solveQueue.shift();
-
-  logger.debug(`Processing request for ${user.username}. Active: ${activeSolves}/${MAX_CONCURRENT_SOLVES}`);
-  logger.updateStats(activeSolves, solveQueue.length);
-
-  const solver = new RecaptchaSolver();
-  try {
-    const token = await solver.getRecaptchaToken(
-      targetUrl,
-      targetKey,
-      action || "homepage",
-      proxy
-    );
-
-    if (token && !token.startsWith("ERROR")) {
-      db.run("UPDATE users SET credits = credits - 1 WHERE id = ?", [user.id]);
-      db.run(
-        "INSERT INTO usage_logs (user_id, action, details) VALUES (?, ?, ?)",
-        [user.id, "SOLVE_CAPTCHA", targetUrl]
-      );
-
-      res.json({ success: true, token: token });
-      io.emit("user:credit-update");
-      logger.debug(`Success for ${user.username}`);
-    } else {
-      res.status(500).json({ success: false, error: token });
-      logger.warn(`Solver returned error for ${user.username}: ${token}`);
-    }
-  } catch (e) {
-    res.status(500).json({ success: false, error: e.message });
-    logger.error(`Catch error for ${user.username}: ${e.message}`);
-  } finally {
-    activeSolves--;
-    logger.updateStats(activeSolves, solveQueue.length);
-    processQueue();
-  }
-}
-
-// --- API GIẢI CAPTCHA ---
+// --- API GIẢI CAPTCHA (GIỮ NGUYÊN) ---
 app.post("/api/solve", async (req, res) => {
-  const { action, proxy } = req.body;
+  // const { url, siteKey, action } = req.body;
+  const { action } = req.body;
   const targetUrl = "https://labs.google";
   const targetKey = "6LdsFiUsAAAAAIjVDZcuLhaHiDn5nnHVXVRQGeMV";
   const apiKey = req.headers["x-api-key"];
@@ -336,12 +276,54 @@ app.post("/api/solve", async (req, res) => {
     "SELECT * FROM users WHERE api_key = ?",
     [apiKey],
     async (err, user) => {
-      if (!user) return res.status(403).json({ error: "API Key không hợp lệ" });
-      if (user.credits < 1) return res.status(402).json({ error: "Hết tiền, nạp thêm đi!" });
-
-      solveQueue.push({ req, res, user, targetUrl, targetKey, action, proxy });
-      logger.updateStats(activeSolves, solveQueue.length);
-      processQueue();
+      if (!user)
+        return res.status(403).json({ error: "API Key không tồn tại" });
+      if (user.credits <= 0)
+        return res.status(402).json({ error: "Hết tiền rồi!" });
+
+      const solver = new RecaptchaSolver();
+      try {
+        const token = await solver.getRecaptchaToken(
+          targetUrl,
+          targetKey,
+          action || undefined
+        );
+        if (token && !token.startsWith("ERROR")) {
+          db.run("UPDATE users SET credits = credits - 1 WHERE id = ?", [
+            user.id,
+          ]);
+
+          const logDetails = JSON.stringify({
+            url: targetUrl,
+            status: "Success",
+            length: token.length,
+          });
+
+          db.run(
+            "INSERT INTO usage_logs (user_id, action, details) VALUES (?, ?, ?)",
+            [user.id, "SOLVE_CAPTCHA", logDetails]
+          );
+
+          res.json({ success: true, token: token });
+          io.emit("user:credit-update");
+        } else {
+          // Log Failure
+          const logDetails = JSON.stringify({
+            url: targetUrl,
+            status: "Failed",
+            error: token || "Unknown Error",
+            length: 0,
+          });
+          db.run(
+            "INSERT INTO usage_logs (user_id, action, details) VALUES (?, ?, ?)",
+            [user.id, "SOLVE_CAPTCHA", logDetails]
+          );
+
+          res.status(500).json({ success: false, error: token });
+        }
+      } catch (e) {
+        res.status(500).json({ success: false, error: e.message });
+      }
     }
   );
 });
@@ -353,7 +335,7 @@ electronApp.on("window-all-closed", (e) => e.preventDefault());
 electronApp.whenReady().then(() => {
   // 1. Start Default Port 3000
   server.listen(PORT, () =>
-    console.log(`Server running at: 0.0.0.0:${PORT}`)
+    console.log(`Server running at: http://localhost:${PORT}`)
   );
 
   // 2. Start HTTP Port 80