Spaces:

Fourstore
/

cf

Paused

App Files Files Community

fourmovie commited on Oct 30, 2025

Commit

9d5ffec

1 Parent(s): 2d0d285

update

Browse files

Files changed (2) hide show

endpoints/recaptchav3.js +82 -0
index.js +20 -112

endpoints/recaptchav3.js ADDED Viewed

	@@ -0,0 +1,82 @@

+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

@@ -2,19 +2,15 @@ const express = require('express')
 const { connect } = require("puppeteer-real-browser")
 const fs = require("fs")
 const path = require("path")
-const os = require('os')
 const app = express()
-const port = process.env.PORT || 7860
 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
-let hitCount = 0
-const startTime = Date.now()
 const CACHE_DIR = path.join(__dirname, "cache")
 const CACHE_FILE = path.join(CACHE_DIR, "cache.json")
 const CACHE_TTL = 5 * 60 * 1000
@@ -50,31 +46,14 @@ function writeCache(key, value) {
   saveCache(cache)
 }
-function getRuntimeInfo() {
-  const mem = process.memoryUsage()
-  const totalMem = os.totalmem()
-  const usedMem = totalMem - os.freemem()
-  return {
-    os: os.type(),
-    platform: os.platform(),
-    architecture: os.arch(),
-    cpuCount: os.cpus().length,
-    uptime: `${process.uptime().toFixed(2)} seconds`,
-    memoryUsage: `${Math.round(usedMem / 1024 / 1024)} MB used of ${Math.round(totalMem / 1024 / 1024)} MB`
-  }
-}
 app.use(express.json())
 app.use(express.urlencoded({ extended: true }))
 app.get('/', (req, res) => {
-  hitCount++
   res.json({
-    author: "fourstore",
-    hit: hitCount,
-    message: "Gunakan: curl -X POST https://rezaharis-cf.hf.space/cloudflare -H 'Content-Type: application/json' -d '{\"mode\":\"turnstile\",\"sitekey\":\"xxx\",\"url\":\"https://example.com\"}'",
-    runtime: getRuntimeInfo()
   })
 })
@@ -124,62 +103,25 @@ const turnstile = require('./endpoints/turnstile')
 const cloudflare = require('./endpoints/cloudflare')
 app.post('/cloudflare', async (req, res) => {
-  hitCount++
   const data = req.body
-  if (!data || !data.mode) {
-    return res.status(400).json({
-      author: "fourstore",
-      hit: hitCount,
-      message: "Parameter 'mode' diperlukan",
-      runtime: getRuntimeInfo(),
-      status: "failed"
-    })
-  }
-  if (!data.sitekey || !data.url) {
-    return res.status(400).json({
-      author: "fourstore",
-      hit: hitCount,
-      message: "Parameter 'sitekey' dan 'url' diperlukan",
-      runtime: getRuntimeInfo(),
-      status: "failed"
-    })
   }
   if (authToken && data.authToken !== authToken) {
-    return res.status(401).json({
-      author: "fourstore",
-      hit: hitCount,
-      message: "Unauthorized",
-      runtime: getRuntimeInfo(),
-      status: "failed"
-    })
   }
   if (global.browserLimit <= 0) {
-    return res.status(429).json({
-      author: "fourstore",
-      hit: hitCount,
-      message: "Too Many Requests",
-      runtime: getRuntimeInfo(),
-      status: "failed"
-    })
   }
   let cacheKey, cached
   if (data.mode === "iuam") {
     cacheKey = JSON.stringify(data)
     cached = readCache(cacheKey)
     if (cached) {
-      return res.status(200).json({
-        author: "fourstore",
-        hit: hitCount,
-        ...cached,
-        cached: true,
-        runtime: getRuntimeInfo(),
-        status: "success"
-      })
     }
   }
@@ -197,29 +139,17 @@ app.post('/cloudflare', async (req, res) => {
     switch (data.mode) {
       case "turnstile":
         result = await turnstile(data, page)
-          .then(token => ({
-            token,
-            status: "success"
-          }))
-          .catch(err => ({
-            code: 500,
-            message: err.message,
-            status: "failed"
-          }))
         break
       case "iuam":
         result = await cloudflare(data, page)
-          .then(r => ({
-            ...r,
-            status: "success"
-          }))
-          .catch(err => ({
-            code: 500,
-            message: err.message,
-            status: "failed"
-          }))
         if (!result.code || result.code === 200) {
           writeCache(cacheKey, result)
@@ -227,18 +157,10 @@ app.post('/cloudflare', async (req, res) => {
         break
       default:
-        result = {
-          code: 400,
-          message: 'Invalid mode',
-          status: "failed"
-        }
     }
   } catch (err) {
-    result = {
-      code: 500,
-      message: err.message,
-      status: "failed"
-    }
   } finally {
     if (browser) {
       try { await browser.close() } catch {}
@@ -246,25 +168,11 @@ app.post('/cloudflare', async (req, res) => {
     global.browserLimit++
   }
-  const response = {
-    author: "fourstore",
-    hit: hitCount,
-    ...result,
-    runtime: getRuntimeInfo()
-  }
-  res.status(result.code ?? 200).json(response)
 })
 app.use((req, res) => {
-  hitCount++
-  res.status(404).json({
-    author: "fourstore",
-    hit: hitCount,
-    message: "Not Found",
-    runtime: getRuntimeInfo(),
-    status: "failed"
-  })
 })
 if (process.env.NODE_ENV === 'development') {

 const { connect } = require("puppeteer-real-browser")
 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
 const CACHE_DIR = path.join(__dirname, "cache")
 const CACHE_FILE = path.join(CACHE_DIR, "cache.json")
 const CACHE_TTL = 5 * 60 * 1000
   saveCache(cache)
 }
 app.use(express.json())
 app.use(express.urlencoded({ extended: true }))
 app.get('/', (req, res) => {
   res.json({
+    message: 'Server is running',
+    domain: DOMAIN,
+    status: 'active'
   })
 })
 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 })
     }
   }
     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') {