diff --git a/server/helpers/requests.ts b/server/helpers/requests.ts index 07dad43..2d69483 100644 --- a/server/helpers/requests.ts +++ b/server/helpers/requests.ts @@ -21,7 +21,9 @@ async function doRequestWithRetries ( msToWait: number, currentRetry = 0 ): Promise<{ response: request.RequestResponse, body: T }> { - const res = await doRequest(requestOptions) + const updatedRequestOptions = Object.assign({}, requestOptions, { timeout: 10000 }) + + const res = await doRequest(updatedRequestOptions) if (res.response.statusCode === 429) { if (currentRetry < maxRetries) { diff --git a/server/lib/schedulers/videos-indexer.ts b/server/lib/schedulers/videos-indexer.ts index d5b603a..12db142 100644 --- a/server/lib/schedulers/videos-indexer.ts +++ b/server/lib/schedulers/videos-indexer.ts @@ -102,14 +102,18 @@ export class VideosIndexer extends AbstractScheduler { logger.info('Adding video data from %s.', host) do { + logger.debug('Getting results from %s (from = %d).', host, start) + videos = await getVideos(host, start) start += videos.length - logger.debug('Getting %d results from %s (from = %d).', videos.length, host, start) + logger.debug('Got %d results from %s (from = %d).', videos.length, host, start) if (videos.length !== 0) { const { created } = await indexVideos(videos) + logger.debug('Indexed %d videos from %s.', videos.length, host) + // Fetch complete video foreach created video (to get tags) for (const c of created) { this.scheduleVideoIndexation(host, c.uuid)