53 lines
1.6 KiB
Ruby
53 lines
1.6 KiB
Ruby
module Sessions
|
|
class Stop
|
|
def initialize(session)
|
|
@session = session
|
|
end
|
|
|
|
def call
|
|
cancel_timeout_job
|
|
Streams::YoutubeRelay.stop(@session)
|
|
Sessions::RegiaAccess.revoke!(@session)
|
|
@session.end_stream!
|
|
complete_youtube_broadcast! if @session.youtube_broadcast_id.present?
|
|
|
|
recording = Recordings::FinalizeSession.new(@session).call
|
|
Recordings::UploadJob.perform_async(@session.id) if recording&.status == "processing"
|
|
remove_mediamtx_paths!
|
|
|
|
begin
|
|
Tournaments::CaptureStreamResult.call(@session)
|
|
rescue StandardError => e
|
|
Rails.logger.warn("[Sessions::Stop] tournament result: #{e.class}: #{e.message}")
|
|
end
|
|
log_event("ended")
|
|
SessionChannel.broadcast_message(@session, { type: "stream_event", event: "ended" })
|
|
@session
|
|
end
|
|
|
|
private
|
|
|
|
def cancel_timeout_job
|
|
return if @session.timeout_job_id.blank?
|
|
|
|
Sidekiq::ScheduledSet.new.find_job(@session.timeout_job_id)&.delete
|
|
end
|
|
|
|
def log_event(type)
|
|
@session.stream_events.create!(event_type: type, occurred_at: Time.current, metadata: {})
|
|
end
|
|
|
|
def remove_mediamtx_paths!
|
|
Mediamtx::Client.for_session(@session).delete_path(@session)
|
|
rescue Mediamtx::Client::Error => e
|
|
Rails.logger.warn("[Sessions::Stop] delete_path #{@session.id}: #{e.message}")
|
|
end
|
|
|
|
def complete_youtube_broadcast!
|
|
Youtube::BroadcastService.new(@session.match.team).complete_broadcast!(@session.youtube_broadcast_id)
|
|
rescue Youtube::BroadcastService::Error => e
|
|
Rails.logger.warn("[Sessions::Stop] YouTube complete: #{e.message}")
|
|
end
|
|
end
|
|
end
|