Sha256: e65e7d26d47d97d115eafc7a68f132dab1a69b0127ae50b4cb11376957757caf
Contents?: true
Size: 1.03 KB
Versions: 15
Compression:
Stored size: 1.03 KB
Contents
# frozen_string_literal: true
module Evostream
module Events
# Action inStreamCreated
class InStreamCreated < Event
def execute
super do |type_flux|
klass = "Evostream::Commands::Create#{type_flux.upcase}".constantize
command = send(type_flux, type_flux)
Evostream.send_command(klass.new(command).cmd)
end
end
private
def hls(flux)
{
local_stream_names: stream_name,
target_folder: target_folder(flux),
cleanup_destination: 1,
group_name: group_name(flux),
keep_alive: 1,
chunk_length: 1,
playlist_length: 10,
playlist_type: 'rolling'
}
end
alias dash hls
def target_folder(flux)
"#{Evostream::Service.web_root}#{group_name(flux)}/#{stream_name}"
end
def group_name(type_flux)
"#{Evostream::Service.name}#{type_flux}"
end
def stream_name
"#{Evostream::Service.name}#{id_flux}"
end
end
end
end
Version data entries
15 entries across 15 versions & 1 rubygems