brock/torrentio
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add resolver queue per debrid

Browse Source
This commit is contained in:
TheBeastLT
2023-11-11 12:30:29 +02:00
parent 3366903107
commit 4c2f4306b1
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
addon/moch/moch.js
View File

@@ -59,9 +59,12 @@ export const MochOptions = {
} }
}; };
const unrestrictQueue = new namedQueue((task, callback) => task.method() const unrestrictQueues = {}
.then(result => callback(false, result)) Object.values(MochOptions)
.catch((error => callback(error))), 20); .map(moch => moch.key)
.forEach(mochKey => unrestrictQueues[mochKey] = new namedQueue((task, callback) => task.method()
.then(result => callback(false, result))
.catch((error => callback(error))), 20));
export function hasMochConfigured(config) { export function hasMochConfigured(config) {
return Object.keys(MochOptions).find(moch => config?.[moch]) return Object.keys(MochOptions).find(moch => config?.[moch])
@@ -107,6 +110,7 @@ export async function resolve(parameters) {
return StaticResponse.FAILED_UNEXPECTED; return StaticResponse.FAILED_UNEXPECTED;
}) })
.then(url => isStaticUrl(url) ? `${parameters.host}/${url}` : url); .then(url => isStaticUrl(url) ? `${parameters.host}/${url}` : url);
const unrestrictQueue = unrestrictQueues[moch.key];
return new Promise(((resolve, reject) => { return new Promise(((resolve, reject) => {
unrestrictQueue.push({ id, method }, (error, result) => result ? resolve(result) : reject(error)); unrestrictQueue.push({ id, method }, (error, result) => result ? resolve(result) : reject(error));
})); }));