Sha256: 90f42dd3559823b0eb6c91a37e8f73ea0a9bde1759ead85b291bd20e9e50ac97
Contents?: true
Size: 1.63 KB
Versions: 6
Compression:
Stored size: 1.63 KB
Contents
# frozen_string_literal: true
# :reek:TooManyStatements
# :reek:UtilityFunction
def create_janus_instances
instance = RubyRabbitmqJanus::Models::JanusInstance
(1..2).each do |number|
id_instance = ENV['MONGO'].match?('true') ? { _id: number.to_s } : { id: number }
janus = instance.create(id_instance.merge(enable: true))
janus.save
end
end
def attach_base
res = nil
@gateway.session_endpoint_private(@session_instance) do |tr|
res = tr.publish_message('base::attach', @session_instance)
end
@options.merge!('handle_id' => res.sender).merge!(@session_instance)
end
def attach_admin
res = nil
@gateway.admin_endpoint(@session_instance) do |tr|
res = tr.publish_message('base::attach', @session_instance)
end
@options.merge!('handle_id' => res.sender).merge!(@session_instance)
end
def session
res = nil
@gateway.session_endpoint_private(@instance) do |tr|
res = tr.publish_message('base::create', @instance)
end
@options.merge!('session_id' => res.session).merge!(@instance)
end
def clear
@response = nil
@options = {}
end
# :reek:NilCheck
def find_instance
janus_instance = RubyRabbitmqJanus::Models::JanusInstance.all.sample
define_variables(janus_instance) unless janus_instance.nil?
end
def define_variables(janus_instance)
@session = { 'session_id' => janus_instance.session_id }
@instance = { 'instance' => janus_instance.instance }
@session_instance = @session.merge(@instance)
end
def initializer_rrj(metadata)
@gateway = if metadata[:level].eql?(:admin)
RubyRabbitmqJanus::RRJAdmin.new
else
RubyRabbitmqJanus::RRJ.new
end
end
Version data entries
6 entries across 6 versions & 1 rubygems