Sha256: 844effb420babe417dbf5f4a8f5f71214fc114ae8eef7a977e6f8a851cf8e39c
Contents?: true
Size: 1.1 KB
Versions: 21
Compression:
Stored size: 1.1 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.logger 'Send command to server EvoStream'
@result = 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
21 entries across 21 versions & 1 rubygems