This commit is contained in:
shinya
2026-02-27 20:21:20 +08:00
parent dceea4ca3b
commit 8f193126fb
2 changed files with 6 additions and 6 deletions

View File

@@ -1,6 +1,5 @@
/* eslint-disable no-console,@typescript-eslint/no-explicit-any */ /* eslint-disable no-console,@typescript-eslint/no-explicit-any */
import * as crypto from 'crypto';
import { NextRequest, NextResponse } from 'next/server'; import { NextRequest, NextResponse } from 'next/server';
import { getConfig, refineConfig } from '@/lib/config'; import { getConfig, refineConfig } from '@/lib/config';
@@ -145,21 +144,21 @@ async function refreshRecordAndFavorites() {
}; };
// 并发限制工具 // 并发限制工具
async function runWithConcurrency<T>( const runWithConcurrency = async <T>(
tasks: (() => Promise<T>)[], tasks: (() => Promise<T>)[],
concurrency: number concurrency: number
): Promise<T[]> { ): Promise<T[]> => {
const results: T[] = []; const results: T[] = [];
let index = 0; let index = 0;
async function worker() { const worker = async () => {
while (index < tasks.length) { while (index < tasks.length) {
const i = index++; const i = index++;
results[i] = await tasks[i](); results[i] = await tasks[i]();
} }
} };
await Promise.all(Array.from({ length: Math.min(concurrency, tasks.length) }, () => worker())); await Promise.all(Array.from({ length: Math.min(concurrency, tasks.length) }, () => worker()));
return results; return results;
} };
// 处理单个用户的播放记录和收藏 // 处理单个用户的播放记录和收藏
const processUser = async (user: string) => { const processUser = async (user: string) => {

View File

@@ -1,6 +1,7 @@
/* eslint-disable no-console */ /* eslint-disable no-console */
import { NextRequest, NextResponse } from 'next/server'; import { NextRequest, NextResponse } from 'next/server';
import { getAuthInfoFromCookie } from '@/lib/auth'; import { getAuthInfoFromCookie } from '@/lib/auth';
import { getAvailableApiSites } from '@/lib/config'; import { getAvailableApiSites } from '@/lib/config';