Method enqueueAutoRetryJob

server/modules/downloadModule.js:114–162

* Enqueue a follow-up URL-list job for videos that failed with a transient * HTTP 403. Owning channels are resolved so channel-tier settings (quality, * audio format, subfolder routing) apply on the retry; the source job's * overrideSettings carry dialog-picked options through for manual an

({ retryVideos, autoRetryAttempt, runId, sourceJobData = {} })

   * @param {Object} params.sourceJobData - the failing job's data payload
   */
  async enqueueAutoRetryJob({ retryVideos, autoRetryAttempt, runId, sourceJobData = {} }) {
    if (!Array.isArray(retryVideos) || retryVideos.length === 0) return;

    const ownerChannelMap = { ...(this.getJobDataValue(sourceJobData, 'ownerChannelMap') || {}) };
    const unmappedIds = retryVideos
      .map((video) => video.youtubeId)
      .filter((id) => id && !ownerChannelMap[id]);
    if (unmappedIds.length > 0) {
      try {
        const rows = await ChannelVideo.findAll({
          where: { youtube_id: unmappedIds },
          attributes: ['youtube_id', 'channel_id'],
        });
        for (const row of rows) {
          if (row.channel_id) ownerChannelMap[row.youtube_id] = row.channel_id;
        }
      } catch (err) {
        logger.warn({ err }, 'Could not resolve owning channels for auto-retry; falling back to global settings');
      }
    }

    // A single owning channel lets doSpecificDownloads resolve channel-tier
    // quality/audio/skip-video-folder; with mixed channels those fall back to
    // the copied override or global settings (subfolder routing still resolves
    // per video via ownerChannelMap in post-processing).
    const mappedChannelIds = new Set(
      retryVideos.map((video) => ownerChannelMap[video.youtubeId]).filter(Boolean)
    );
    const channelId = this.getJobDataValue(sourceJobData, 'channelId')
      || (mappedChannelIds.size === 1 ? [...mappedChannelIds][0] : null);
    const effectiveQuality = this.getJobDataValue(sourceJobData, 'effectiveQuality') || null;

    const body = {
      urls: retryVideos.map((video) => video.url),
      overrideSettings: { ...this.getOverrideSettings(sourceJobData) },
      jobLabel: autoRetryJobLabel(retryVideos.length),
      autoRetryAttempt,
    };
    if (Object.keys(ownerChannelMap).length > 0) body.ownerChannelMap = ownerChannelMap;
    if (channelId) body.channelId = channelId;
    if (effectiveQuality) body.effectiveQuality = effectiveQuality;
    if (runId) body.runId = runId;

    logger.info(
      { videoCount: retryVideos.length, autoRetryAttempt, channelId, runId },
      'Enqueueing auto-retry job for transient 403 failures'
    );
    await this.doSpecificDownloads({ body });
  }

  async doChannelDownloads(jobData = {}, isNextJob = false) {
    const overrideSettings = this.getOverrideSettings(jobData);