Creepso/p-stream
1
0
Fork 0
mirror of https://github.com/p-stream/p-stream.git synced 2026-05-09 17:01:05 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

add retries to token check

Browse source
This commit is contained in:
Pas 2025-04-15 21:50:56 -06:00
parent 2c9c30afb1
commit a2df05b103
1 changed files with 77 additions and 24 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

101
src/pages/parts/settings/SetupPart.tsx
View file

@ -1,3 +1,4 @@
/* eslint-disable no-console */
import classNames from "classnames"; import classNames from "classnames";
import { ReactNode } from "react"; import { ReactNode } from "react";
import { useTranslation } from "react-i18next"; import { useTranslation } from "react-i18next";
@ -21,6 +22,14 @@ import { useAuthStore } from "@/stores/auth";
const testUrl = "https://postman-echo.com/get"; const testUrl = "https://postman-echo.com/get";
const febboxApiTestUrl = "https://fed-api.pstream.org/movie/tt15239678"; const febboxApiTestUrl = "https://fed-api.pstream.org/movie/tt15239678";
const sleep = (ms: number): Promise<void> => {
return new Promise((resolve) => {
setTimeout(() => {
resolve();
}, ms);
});
};
export type Status = "success" | "unset" | "error"; export type Status = "success" | "unset" | "error";
type SetupData = { type SetupData = {
@ -48,36 +57,80 @@ export async function testFebboxToken(
if (!febboxToken) { if (!febboxToken) {
return "unset"; return "unset";
} }
try {
const response = await fetch(febboxApiTestUrl, {
headers: {
"ui-token": febboxToken,
},
});
if (!response.ok) { let attempts = 0;
console.error("Febbox API test failed with status:", response.status); const maxAttempts = 3;
return "error";
}
const data = (await response.json()) as any; while (attempts < maxAttempts) {
if (!data || !data.streams) { console.log(
console.error("Invalid response format from Febbox API:", data); `Attempt ${attempts + 1} of ${maxAttempts} to check Febbox token`,
return "error"; );
} try {
const response = await fetch(febboxApiTestUrl, {
headers: {
"ui-token": febboxToken,
},
});
const isVIPLink = Object.values(data.streams).some((link: any) => { if (!response.ok) {
if (typeof link === "string") { console.error("Febbox API test failed with status:", response.status);
return link.toLowerCase().includes("vip"); attempts += 1;
if (attempts === maxAttempts) {
console.log("Max attempts reached, returning error");
return "error";
}
console.log("Retrying after failed response...");
await sleep(3000);
continue;
} }
return false;
});
return isVIPLink ? "success" : "error"; const data = (await response.json()) as any;
} catch (error: any) { if (!data || !data.streams) {
console.error("Error testing Febbox token:", error); console.error("Invalid response format from Febbox API:", data);
return "error"; attempts += 1;
if (attempts === maxAttempts) {
console.log("Max attempts reached, returning error");
return "error";
}
console.log("Retrying after invalid response format...");
await sleep(3000);
continue;
}
const isVIPLink = Object.values(data.streams).some((link: any) => {
if (typeof link === "string") {
return link.toLowerCase().includes("vip");
}
return false;
});
if (isVIPLink) {
console.log("VIP link found, returning success");
return "success";
}
console.log("No VIP link found in attempt", attempts + 1);
attempts += 1;
if (attempts === maxAttempts) {
console.log("Max attempts reached, returning error");
return "error";
}
console.log("Retrying after no VIP link found...");
await sleep(3000);
} catch (error: any) {
console.error("Error testing Febbox token:", error);
attempts += 1;
if (attempts === maxAttempts) {
console.log("Max attempts reached, returning error");
return "error";
}
console.log("Retrying after error...");
await sleep(3000);
}
} }
console.log("All attempts exhausted, returning error");
return "error";
} }
function useIsSetup() { function useIsSetup() {