Class: Helios::Videos::Migration::ConvertVideoJob

Inherits:
ApplicationJob
  • Object
show all
Defined in:
app/jobs/helios/videos/migration/convert_video_job.rb

Overview

Per-video conversion job: gets a download URL from the source provider, submits it to the destination provider for ingestion, and updates the video record.

For Mux destinations, the playback ID comes back immediately so the provider is flipped right away.

For Cloudflare destinations, a CheckIngestionJob is enqueued to poll for readiness before flipping the provider.

Instance Method Summary collapse

Instance Method Details

#perform(video_id:, from:, to:, use_original: false) ⇒ Object

Parameters:

  • video_id (Integer)
  • from (String) —

    source provider

  • to (String) —

    destination provider

  • use_original (Boolean) (defaults to: false) —

    if true, use the original S3 file instead of downloading from the source provider



21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
 
# File 'app/jobs/helios/videos/migration/convert_video_job.rb', line 21

def perform(video_id:, from:, to:, use_original: false)
  video = Helios::Videos.video_class.find(video_id)

  unless video.provider == from
    Rails.logger.info("[helios-videos] Migration: video #{video_id} is already on #{video.provider}, skipping")
    return
  end

  source_processor = Helios::Videos.processor_for(from.to_sym)
  dest_processor = Helios::Videos.processor_for(to.to_sym)

  # Get source URL — either from the original S3 upload or from the current provider
  if use_original
    unless video.video_file.attached?
      Rails.logger.error("[helios-videos] Migration: video #{video_id} has no original file attached, falling back to provider download")
      source_url = source_processor.download_url(video, expiration: 12.hours)
    else
      source_url = video.video_file.url
      Rails.logger.info("[helios-videos] Migration: using original S3 file for video #{video_id}")
    end
  else
    source_url = source_processor.download_url(video, expiration: 12.hours)
  end

  unless source_url.present?
    Rails.logger.error("[helios-videos] Migration: could not get download URL for video #{video_id}")
    return
  end

  Rails.logger.info("[helios-videos] Migration: ingesting video #{video_id} from #{from} -> #{to}")

  # Submit to destination processor
  dest_processor.ingest_from_url!(video, source_url, provider: to)

  if to.to_sym == :mux
    # Mux returns playback IDs immediately — flip provider now
    video.update!(provider: to)
    Rails.logger.info("[helios-videos] Migration: video #{video_id} migrated to #{to}")

    # Download new thumbnail from the new provider
    dest_processor.download_thumbnail!(video)
  else
    # Cloudflare needs processing time — enqueue a check
    CheckIngestionJob.set(wait: 30.seconds).perform_later(
      video_id: video_id,
      to: to,
      attempt: 1
    )
  end
end