Spaces:

Fourstore
/

cf

Paused

App Files Files Community

fourmovie commited on Nov 4, 2025

Commit

02f17f2

1 Parent(s): 9d5ffec

update

Browse files

Files changed (2) hide show

endpoints/recaptchav3.js +0 -82
index.js +140 -48

endpoints/recaptchav3.js DELETED Viewed

@@ -1,82 +0,0 @@
-async function recaptchav3({ domain, siteKey, proxy, action = 'homepage' }, page) {
-  if (!domain) throw new Error("Missing domain parameter");
-  if (!siteKey) throw new Error("Missing siteKey parameter");
-  const timeout = global.timeOut || 60000;
-  let isResolved = false;
-  const cl = setTimeout(async () => {
-    if (!isResolved) {
-      throw new Error("Timeout Error");
-    }
-  }, timeout);
-  try {
-    if (proxy?.username && proxy?.password) {
-      await page.authenticate({
-        username: proxy.username,
-        password: proxy.password,
-      });
-    }
-    const htmlContent = `
-      <!DOCTYPE html>
-      <html lang="en">
-      <head>
-        <script src="https://www.google.com/recaptcha/api.js?render=${siteKey}"></script>
-      </head>
-      <body>
-        <input type="hidden" id="recaptchav3Token" name="recaptchav3">
-        <script>
-          grecaptcha.ready(function() {
-            grecaptcha.execute("${siteKey}", {action: "${action}"}).then(function(token) {
-              document.getElementById("recaptchav3Token").value = token;
-            });
-          });
-        </script>
-      </body>
-      </html>
-    `;
-    await page.setRequestInterception(true);
-    page.removeAllListeners("request");
-    page.on("request", async (request) => {
-      if ([domain, domain + "/"].includes(request.url()) && request.resourceType() === "document") {
-        await request.respond({
-          status: 200,
-          contentType: "text/html",
-          body: htmlContent,
-        });
-      } else {
-        await request.continue();
-      }
-    });
-    await page.goto(domain, { waitUntil: "domcontentloaded" });
-    await page.waitForFunction(() => {
-      const tokenInput = document.getElementById("recaptchav3Token");
-      return tokenInput && tokenInput.value.length > 10;
-    }, { timeout });
-    const token = await page.evaluate(() => {
-      try {
-        return document.getElementById("recaptchav3Token").value;
-      } catch {
-        return null;
-      }
-    });
-    isResolved = true;
-    clearTimeout(cl);
-    if (!token || token.length < 10) throw new Error("Failed to get token");
-    return token;
-  } catch (e) {
-    clearTimeout(cl);
-    throw e;
-  }
-}
-module.exports = recaptchav3;

index.js CHANGED Viewed

@@ -4,9 +4,9 @@ const fs = require("fs")
 const path = require("path")
 const app = express()
-const port = process.env.PORT || 8080
 const authToken = process.env.authToken || null
-const DOMAIN = 'https://rezaharis-cf.hf.space'
 global.browserLimit = Number(process.env.browserLimit) || 20
 global.timeOut = Number(process.env.timeOut) || 60000
@@ -49,42 +49,97 @@ function writeCache(key, value) {
 app.use(express.json())
 app.use(express.urlencoded({ extended: true }))
 app.get('/', (req, res) => {
-  res.json({
-    message: 'Server is running',
     domain: DOMAIN,
-    status: 'active'
   })
 })
 if (process.env.NODE_ENV !== 'development') {
-  let server = app.listen(port, () => {
     console.log(`Server running on port ${port}`)
     console.log(`Domain: ${DOMAIN}`)
   })
   try {
     server.timeout = global.timeOut
   } catch {}
 }
-async function createBrowser(proxyServer = null) {
   const connectOptions = {
-    headless: false,
     turnstile: true,
-    connectOption: { defaultViewport: null },
-    disableXvfb: false,
   }
   if (proxyServer) {
-    connectOptions.args = [`--proxy-server=${proxyServer}`]
   }
   const { browser } = await connect(connectOptions)
   const pages = await browser.pages()
   const page = pages[0]
-  await page.goto('about:blank')
   await page.setRequestInterception(true)
   page.on('request', (req) => {
@@ -99,30 +154,29 @@ async function createBrowser(proxyServer = null) {
   return { browser, page }
 }
 const turnstile = require('./endpoints/turnstile')
 const cloudflare = require('./endpoints/cloudflare')
 app.post('/cloudflare', async (req, res) => {
   const data = req.body
-  if (!data || typeof data.mode !== 'string') {
-    return res.status(400).json({ message: 'Bad Request: missing or invalid mode' })
-  }
-  if (authToken && data.authToken !== authToken) {
-    return res.status(401).json({ message: 'Unauthorized' })
   }
   if (global.browserLimit <= 0) {
-    return res.status(429).json({ message: 'Too Many Requests' })
   }
-  let cacheKey, cached
-  if (data.mode === "iuam") {
-    cacheKey = JSON.stringify(data)
-    cached = readCache(cacheKey)
-    if (cached) {
-      return res.status(200).json({ ...cached, cached: true })
-    }
   }
   global.browserLimit--
@@ -131,50 +185,88 @@ app.post('/cloudflare', async (req, res) => {
   try {
     const proxyServer = data.proxy ? `${data.proxy.hostname}:${data.proxy.port}` : null
-    const ctx = await createBrowser(proxyServer)
     browser = ctx.browser
     page = ctx.page
-    await page.goto('about:blank')
-    switch (data.mode) {
-      case "turnstile":
-        result = await turnstile(data, page)
-          .then(token => ({ token }))
-          .catch(err => ({ code: 500, message: err.message }))
-        break
-      case "iuam":
-        result = await cloudflare(data, page)
-          .then(r => ({ ...r }))
-          .catch(err => ({ code: 500, message: err.message }))
-        if (!result.code || result.code === 200) {
-          writeCache(cacheKey, result)
-        }
-        break
-      default:
-        result = { code: 400, message: 'Invalid mode' }
-    }
   } catch (err) {
-    result = { code: 500, message: err.message }
   } finally {
     if (browser) {
-      try { await browser.close() } catch {}
     }
     global.browserLimit++
   }
-  res.status(result.code ?? 200).json(result)
 })
 app.use((req, res) => {
   res.status(404).json({ message: 'Not Found' })
 })
 if (process.env.NODE_ENV === 'development') {
   module.exports = app
 }

 const path = require("path")
 const app = express()
+const port = process.env.PORT || 7860
 const authToken = process.env.authToken || null
+const DOMAIN = 'https://rezaharis-cf.hf.space' // DOMAINNYA DI SINI
 global.browserLimit = Number(process.env.browserLimit) || 20
 global.timeOut = Number(process.env.timeOut) || 60000
 app.use(express.json())
 app.use(express.urlencoded({ extended: true }))
+// Middleware untuk auth token
+app.use((req, res, next) => {
+  if (authToken && req.path !== '/health' && req.path !== '/') {
+    const token = req.body.authToken || req.query.authToken
+    if (token !== authToken) {
+      return res.status(401).json({ message: 'Unauthorized' })
+    }
+  }
+  next()
+})
+// Root endpoint
 app.get('/', (req, res) => {
+  res.status(200).json({
+    message: 'Cloudflare Solver API',
+    status: 'active',
+    domain: DOMAIN, // TAMPILKAN DOMAIN DI RESPONSE
+    endpoints: ['/cloudflare', '/turnstile', '/health', '/info']
+  })
+})
+// Health check endpoint
+app.get('/health', (req, res) => {
+  res.status(200).json({
+    status: 'OK',
+    browserLimit: global.browserLimit,
+    domain: DOMAIN,
+    timestamp: new Date().toISOString()
+  })
+})
+// Info endpoint
+app.get('/info', (req, res) => {
+  res.status(200).json({
+    browserLimit: global.browserLimit,
+    timeOut: global.timeOut,
     domain: DOMAIN,
+    cacheEnabled: true,
+    cacheTTL: CACHE_TTL
   })
 })
 if (process.env.NODE_ENV !== 'development') {
+  let server = app.listen(port, '0.0.0.0', () => {
     console.log(`Server running on port ${port}`)
     console.log(`Domain: ${DOMAIN}`)
   })
   try {
     server.timeout = global.timeOut
+    server.keepAliveTimeout = 60000
   } catch {}
 }
+async function createBrowser(proxyServer = null, proxyAuth = null) {
   const connectOptions = {
+    headless: true,
     turnstile: true,
+    connectOption: {
+      defaultViewport: null,
+      args: [
+        '--no-sandbox',
+        '--disable-setuid-sandbox',
+        '--disable-dev-shm-usage',
+        '--disable-accelerated-2d-canvas',
+        '--no-first-run',
+        '--no-zygote',
+        '--disable-gpu',
+        '--disable-web-security',
+        '--disable-features=site-per-process',
+        '--disable-blink-features=AutomationControlled'
+      ]
+    },
+    disableXvfb: true,
   }
   if (proxyServer) {
+    connectOptions.connectOption.args.push(`--proxy-server=${proxyServer}`)
   }
   const { browser } = await connect(connectOptions)
+  // Set stealth
   const pages = await browser.pages()
   const page = pages[0]
+  // Remove webdriver property
+  await page.evaluateOnNewDocument(() => {
+    Object.defineProperty(navigator, 'webdriver', {
+      get: () => undefined,
+    })
+  })
   await page.setRequestInterception(true)
   page.on('request', (req) => {
   return { browser, page }
 }
+// Import endpoints
 const turnstile = require('./endpoints/turnstile')
 const cloudflare = require('./endpoints/cloudflare')
+// ENDPOINT CLOUDFLARE - GUNAKAN DOMAIN YANG SUDAH DIATUR
 app.post('/cloudflare', async (req, res) => {
   const data = req.body
+  if (!data) {
+    return res.status(400).json({ message: 'Bad Request: missing data' })
   }
+  // Gunakan domain dari request atau domain default
+  const domain = data.domain || DOMAIN
   if (global.browserLimit <= 0) {
+    return res.status(429).json({ message: 'Too Many Requests: browser limit reached' })
   }
+  // Check cache
+  const cacheKey = JSON.stringify({...data, domain})
+  const cached = readCache(cacheKey)
+  if (cached) {
+    return res.status(200).json({ ...cached, cached: true })
   }
   global.browserLimit--
   try {
     const proxyServer = data.proxy ? `${data.proxy.hostname}:${data.proxy.port}` : null
+    const ctx = await createBrowser(proxyServer, data.proxy)
     browser = ctx.browser
     page = ctx.page
+    // Pass domain ke fungsi cloudflare
+    result = await cloudflare({...data, domain}, page)
+    if (result.cf_clearance) {
+      writeCache(cacheKey, result)
+    }
+  } catch (err) {
+    result = {
+      cf_clearance: null,
+      user_agent: null,
+      elapsed_time: 0,
+      error: err.message
+    }
+  } finally {
+    if (browser) {
+      try {
+        await browser.close()
+      } catch (err) {
+        console.error('Error closing browser:', err.message)
+      }
+    }
+    global.browserLimit++
+  }
+  res.status(200).json(result)
+})
+// Endpoint khusus untuk Turnstile
+app.post('/turnstile', async (req, res) => {
+  const data = req.body
+  if (!data || !data.sitekey || !data.url) {
+    return res.status(400).json({ message: 'Bad Request: missing sitekey or url' })
+  }
+  if (global.browserLimit <= 0) {
+    return res.status(429).json({ message: 'Too Many Requests: browser limit reached' })
+  }
+  global.browserLimit--
+  let result
+  let browser, page
+  try {
+    const proxyServer = data.proxy ? `${data.proxy.hostname}:${data.proxy.port}` : null
+    const ctx = await createBrowser(proxyServer, data.proxy)
+    browser = ctx.browser
+    page = ctx.page
+    const token = await turnstile(data, page)
+    result = { token }
   } catch (err) {
+    result = { error: err.message }
   } finally {
     if (browser) {
+      try {
+        await browser.close()
+      } catch (err) {
+        console.error('Error closing browser:', err.message)
+      }
     }
     global.browserLimit++
   }
+  res.status(200).json(result)
 })
 app.use((req, res) => {
   res.status(404).json({ message: 'Not Found' })
 })
+// Error handling middleware
+app.use((err, req, res, next) => {
+  console.error('Server Error:', err)
+  res.status(500).json({ message: 'Internal Server Error' })
+})
 if (process.env.NODE_ENV === 'development') {
   module.exports = app
 }