/**
* API_TURNSTILE
*/
async function turnstile({ domain, siteKey, action, proxy }, page) {
if (!domain) throw new Error("Missing domain parameter");
if (!siteKey) throw new Error("Missing siteKey parameter");
const timeout = global.timeOut;
return new Promise(async (resolve, reject) => {
let isResolved = false;
const cl = setTimeout(() => {
if (!isResolved) {
isResolved = true;
reject(new Error("Timeout Error"));
}
}, timeout);
try {
if (proxy?.username && proxy?.password) {
await page.authenticate({
username: proxy.username,
password: proxy.password,
});
}
const htmlContent = `
`;
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.waitForSelector('[name="cf-response"]', { timeout });
const token = await page.evaluate(() => {
return document.querySelector('[name="cf-response"]').value;
});
isResolved = true;
clearTimeout(cl);
if (!token || token.length < 10) {
reject(new Error("Failed to get token"));
} else {
resolve({ token: token, type: 'turnstile' });
}
} catch (e) {
if (!isResolved) {
isResolved = true;
clearTimeout(cl);
reject(e);
}
}
});
}
module.exports = turnstile;