diff --git a/lib/mq/scheduler.ts b/lib/mq/scheduler.ts index 7d6ed80..994a174 100644 --- a/lib/mq/scheduler.ts +++ b/lib/mq/scheduler.ts @@ -253,8 +253,8 @@ class NetScheduler { const netScheduler = new NetScheduler(); const videoInfoRateLimiterConfig: RateLimiterConfig[] = [ { - window: new SlidingWindow(redis, 1), - max: 3, + window: new SlidingWindow(redis, 3), + max: 5, }, { window: new SlidingWindow(redis, 30), diff --git a/lib/mq/task/queueLatestVideo.ts b/lib/mq/task/queueLatestVideo.ts index f688c2f..eac26b5 100644 --- a/lib/mq/task/queueLatestVideo.ts +++ b/lib/mq/task/queueLatestVideo.ts @@ -35,7 +35,7 @@ export async function queueLatestVideos( }); videosFound.add(aid); allExists = false; - delay += Math.random() * SECOND * 0.5; + delay += Math.random() * SECOND * 1.5; } i += aids.length; logger.log( diff --git a/lib/net/getVideoInfo.ts b/lib/net/getVideoInfo.ts index e64a91b..0cd78ac 100644 --- a/lib/net/getVideoInfo.ts +++ b/lib/net/getVideoInfo.ts @@ -6,7 +6,6 @@ export async function getVideoInfo(aid: number): Promise(url, "getVideoInfo"); const errMessage = `Error fetching metadata for ${aid}:`; - logger.log("Fetching metadata for " + aid, "net", "fn:getVideoInfo"); if (data.code !== 0) { logger.error(errMessage + data.message, "net", "fn:getVideoInfo"); return null;