Sha256: 73d22c871653b3dd4ef48d928bad84d7c1a3325e80f96357d87bf99a8dc088c7
Contents?: true
Size: 1.47 KB
Versions: 60
Compression:
Stored size: 1.47 KB
Contents
module Isomorfeus module Transport class ClientProcessor def self.process(json_hash) if json_hash.key?(:response) process_response(json_hash) elsif json_hash.key?(:notification) process_message(json_hash) end end def self.process_message(message_hash) processor_class_name = message_hash[:notification][:class] Isomorfeus.raise_error(message: "Not a valid channel class #{processor_class_name}!") unless Isomorfeus.valid_channel_class_name?(processor_class_name) processor_class = Isomorfeus.cached_channel_class(processor_class_name) unless processor_class.respond_to?(:process_message) Isomorfeus.raise_error(message: "Cannot process message, #{processor_class} must be a Channel and must have the on_message block defined!") end processor_class.process_message(message_hash[:notification][:message], message_hash[:notification][:error], message_hash[:notification][:channel]) end def self.process_response(response_hash) response_hash[:response][:agent_ids].keys.each do |agent_id| agent = Isomorfeus::Transport::RequestAgent.get(agent_id) if agent && !agent.promise.realized? agent.full_response = response_hash agent.response = response_hash[:response][:agent_ids][agent_id] agent.promise.resolve(agent) end end end end end end
Version data entries
60 entries across 60 versions & 1 rubygems