Viren070/AIOStreams
1
0
Fork 0
mirror of https://github.com/Viren070/AIOStreams.git synced 2025-12-01 23:14:04 +01:00
Code Issues Packages Projects Releases Wiki Activity

feat: remove background processing

Browse Source
This commit is contained in:
Viren070
2025-10-25 17:58:15 +01:00
parent ec8f3ce42a
commit 26d1181627
1 changed files with 8 additions and 44 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/core/src/wrapper.ts
+8 -44
View File
@@ -151,10 +151,8 @@ export class Wrapper {
`Fetching manifest for ${this.addon.name} ${this.addon.displayIdentifier || this.addon.identifier} (${makeUrlLogSafe(this.manifestUrl)})`
);
try {
const backgroundTimeout =
Env.BACKGROUND_RESOURCE_REQUEST_TIMEOUT ?? Env.MAX_TIMEOUT;
const res = await makeRequest(this.manifestUrl, {
timeout: backgroundTimeout,
timeout: options?.timeout ?? Env.MANIFEST_TIMEOUT,
headers: this.addon.headers,
forwardIp: this.addon.ip,
});
@@ -382,45 +380,13 @@ export class Wrapper {
}
}
const processRequest = async () => {
const result = await requestFn();
const doCache = shouldCache ? shouldCache(result) : true;
// bypass cache only skips retrieving from cache, it still caches the result
if (cacher && doCache) {
await cacher.set(cacheKey, result, cacheTtl);
}
return result;
};
const requestPromise = processRequest();
const timeoutPromise = new Promise<T>((_, reject) =>
setTimeout(
() =>
reject(
new Error(
`Request for ${resourceName} for ${this.getAddonName(this.addon)} timed out after ${timeout}ms`
)
),
timeout
)
);
try {
return await Promise.race([requestPromise, timeoutPromise]);
} catch (error: any) {
if (error.message.includes('timed out')) {
logger.warn(
`Request for ${resourceName} for ${this.getAddonName(this.addon)} timed out. Will process in background.`
);
requestPromise.catch((bgError) => {
logger.warn(
`Background request for ${resourceName} for ${this.getAddonName(this.addon)} failed: ${bgError.message}`
);
});
}
throw error;
const result = await requestFn();
const doCache = shouldCache ? shouldCache(result) : true;
// bypass cache only skips retrieving from cache, it still caches the result
if (cacher && doCache) {
await cacher.set(cacheKey, result, cacheTtl);
}
return result;
}
private async makeResourceRequest<T>(
@@ -445,10 +411,8 @@ export class Wrapper {
const requestFn = async (): Promise<T> => {
try {
const backgroundTimeout =
Env.BACKGROUND_RESOURCE_REQUEST_TIMEOUT ?? Env.MAX_TIMEOUT;
const res = await makeRequest(url, {
timeout: backgroundTimeout,
timeout: timeout,
headers: this.addon.headers,
forwardIp: this.addon.ip,
});