tretrauit/castorsrm
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: check consent button every second

Browse Source
This commit is contained in:
tretrauit
2025-04-13 00:34:57 +07:00
parent cb427a9fa4
commit 50c5927be7
2 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/proxy/reflect4.ts
View File

@ -36,8 +36,7 @@ async function spawn(context: BrowserContext, targetUrl: string, spawnId: string
await page.waitForTimeout(15000); // Wait for 15 second to let the page load await page.waitForTimeout(15000); // Wait for 15 second to let the page load
// Keep-alive the page open for 5 minutes then refresh // Keep-alive the page open for 5 minutes then refresh
if (targetUrl.startsWith("https://www.twitch.tv/")) { if (targetUrl.startsWith("https://www.twitch.tv/")) {
logger.info(`[${spawnId}] Twitch URL detected, initializing...`); logger.info(`[${spawnId}] Twitch URL detected, using Twitch mode...`);
await twitch.init(page, spawnId);
await twitch.keepAlive(page, spawnId); await twitch.keepAlive(page, spawnId);
} else { } else {
logger.warn(`[${spawnId}] Unsupported URL: ${targetUrl}`); logger.warn(`[${spawnId}] Unsupported URL: ${targetUrl}`);

7
src/website/twitch.ts
View File

@ -1,7 +1,7 @@
import type { Page } from "patchright"; import type { Page } from "patchright";
import logger from "../logger"; import logger from "../logger";
async function init(page: Page, spawnId: string = "unknown") { async function checkConsentButton(page: Page, spawnId: string = "unknown") {
const consentButton = page.locator("button[data-a-target='consent-banner-accept']"); const consentButton = page.locator("button[data-a-target='consent-banner-accept']");
if ((await consentButton.all()).length > 0) { if ((await consentButton.all()).length > 0) {
logger.debug(`[${spawnId}] Consent button found, clicking it...`); logger.debug(`[${spawnId}] Consent button found, clicking it...`);
@ -21,7 +21,10 @@ async function keepAlive(page: Page, spawnId: string = "unknown") {
if ((await page.locator(".ScCoreButton-sc-ocjdkq-0.ggPgVz").all()).length > 0) { if ((await page.locator(".ScCoreButton-sc-ocjdkq-0.ggPgVz").all()).length > 0) {
logger.debug(`[${spawnId}] Player encountered an error, refreshing the page...`); logger.debug(`[${spawnId}] Player encountered an error, refreshing the page...`);
await page.reload({timeout: 0, waitUntil: "domcontentloaded"}); await page.reload({timeout: 0, waitUntil: "domcontentloaded"});
waitTime = 0;
continue;
} }
await checkConsentButton(page, spawnId);
if (waitTime > 5 * 60 * 1000) { if (waitTime > 5 * 60 * 1000) {
logger.debug(`[${spawnId}] Waited for more than 5 minutes, refreshing the page...`); logger.debug(`[${spawnId}] Waited for more than 5 minutes, refreshing the page...`);
await page.reload({timeout: 0, waitUntil: "domcontentloaded"}); await page.reload({timeout: 0, waitUntil: "domcontentloaded"});
@ -33,4 +36,4 @@ async function keepAlive(page: Page, spawnId: string = "unknown") {
} }
} }
export { init, keepAlive }; export { keepAlive };