Sha256: 2cdfbbe2bc86c620685572b13bfaf0cc8849c3ec08c2eabe9cbf1bb86f7e9754
Contents?: true
Size: 1.34 KB
Versions: 14
Compression:
Stored size: 1.34 KB
Contents
# frozen_string_literal: true
module Evostream
module Events
# Action OutStreamCreated
class OutStreamCreated < Event
def initialize(id_flux, request)
super(id_flux)
@request = request
end
def execute
stream_flux = what_flux.upcase.constantize
model.streams.push(stream_flux.new(config_id: ex_config, flux: ex_flux))
model.save
@result = { status: 201, message: 'Action successfully executed.' }
end
private
def what_flux
hls? ? 'Hls' : 'Dash'
end
def hls?
@request.key?(:hlsSettings) || @request.key?('hlsSettings')
end
def name_flux
case what_flux
when 'Hls' then 'playlistName'
when 'Dash' then 'manifestName'
end
end
def name_settings
@request[select_key_setting]
end
def ex_config
name_settings['configId']
end
def ex_flux
Evostream::Service.uri_out + '/' + name_settings['groupName'] + '/' +
@request['name'] + '/' + name_settings[name_flux]
end
def select_key_setting
if @request.key?(:hlsSettings)
:hlsSettings
elsif @request.key?(:dashSettings)
:dashSettings
elsif @request.key?(:pushSettings)
:pushSettings
end
end
end
end
end
Version data entries
14 entries across 14 versions & 1 rubygems