Method doSpecificDownloads

server/modules/downloadModule.js:592–744

(reqOrJobData, isNextJob = false)

  }

  async doSpecificDownloads(reqOrJobData, isNextJob = false) {
    const jobData = reqOrJobData.body ? reqOrJobData.body : reqOrJobData;

    // Build job type with optional source indicator
    let jobType = MANUAL_DOWNLOAD_LABEL;
    const initiatedBy = this.getJobDataValue(jobData, 'initiatedBy');
    if (initiatedBy && initiatedBy.type === 'api_key' && initiatedBy.name) {
      jobType = `${MANUAL_DOWNLOAD_LABEL} (via API: ${initiatedBy.name})`;
    }
    const jobLabel = this.getJobDataValue(jobData, 'jobLabel');
    if (jobLabel && typeof jobLabel === 'string') {
      jobType = jobLabel;
    }

    logger.info({ jobData }, 'Running specific downloads job');

    const urls = reqOrJobData.body
      ? reqOrJobData.body.urls
      : reqOrJobData.data.urls;
    const jobId = await jobModule.addOrUpdateJob(
      {
        jobType: jobType,
        status: '',
        output: '',
        id: jobData.id ? jobData.id : '',
        data: jobData,
        action: this.doSpecificDownloads.bind(this),
      },
      isNextJob
    );

    this.registerJobWithRun(jobData, jobId);

    if (jobModule.getJob(jobId).status === 'In Progress') {
      // Use override settings if provided, otherwise use defaults
      const overrideSettings = this.getOverrideSettings(jobData);
      let effectiveQuality = overrideSettings.resolution ||
        this.getJobDataValue(jobData, 'effectiveQuality') ||
        null;

      const channelId = this.getJobDataValue(jobData, 'channelId');

      let channelRecord = null;
      if (channelId) {
        try {
          const Channel = require('../models/channel');
          channelRecord = await Channel.findOne({
            where: { channel_id: channelId },
            attributes: ['video_quality', 'audio_format', 'skip_video_folder'],
          });

          if (!effectiveQuality && channelRecord && channelRecord.video_quality) {
            effectiveQuality = channelRecord.video_quality;
          }
        } catch (channelErr) {
          console.error('[DownloadModule] Error determining channel quality override:', channelErr.message);
        }
      }