alikia2x/cvsa
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add: task specified request for NetScheduler

Browse Source
This commit is contained in:
alikia2x (寒寒) 2025-02-10 21:42:32 +08:00
parent fa8540edc5
commit e570e3bbff
Signed by: alikia2x
GPG Key ID: 56209E0CCD8420C6
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
lib/mq/scheduler.ts
View File

@ -4,9 +4,6 @@ import {RateLimiter} from "lib/mq/rateLimiter.ts";
interface Proxy { interface Proxy {
type: string; type: string;
task: string; task: string;
data?: {
[key: string]: string;
};
limiter?: RateLimiter; limiter?: RateLimiter;
} }
@ -56,11 +53,12 @@ export class NetScheduler {
* - The native `fetch` function threw an error: with error code FETCH_ERROR * - The native `fetch` function threw an error: with error code FETCH_ERROR
* - The proxy type is not supported: with error code NOT_IMPLEMENTED * - The proxy type is not supported: with error code NOT_IMPLEMENTED
*/ */
async request<R>(url: string, method: string = "GET"): Promise<R | null> { async request<R>(url: string, method: string = "GET", task: string): Promise<R | null> {
// find a available proxy // find a available proxy
const proxiesNames = Object.keys(this.proxies); const proxiesNames = Object.keys(this.proxies);
for (const proxyName of proxiesNames) { for (const proxyName of proxiesNames) {
const proxy = this.proxies[proxyName]; const proxy = this.proxies[proxyName];
if (proxy.task !== task) continue;
if (!proxy.limiter) { if (!proxy.limiter) {
return await this.proxyRequest<R>(url, proxyName, method); return await this.proxyRequest<R>(url, proxyName, method);
} }