Sha256: a38fafda803f9717514889ab2786d98aa97ec692f96b0425f41cfa7f0537dd15
Contents?: true
Size: 1.73 KB
Versions: 10
Compression:
Stored size: 1.73 KB
Contents
module Isomorfeus
module Transport
class ServerSocketProcessor
include Isomorfeus::Transport::ServerProcessor
def initialize(user)
@user = user
end
def on_message(client, data)
if Isomorfeus.development?
if Isomorfeus.server_requires_reload?
write_lock = Isomorfeus.zeitwerk_lock.try_write_lock
if write_lock
Isomorfeus.zeitwerk.reload
Isomorfeus.zeitwerk_lock.release_write_lock
end
end
Isomorfeus.zeitwerk_lock.acquire_read_lock
end
request_hash = Oj.load(data, mode: :strict)
handler_instance_cache = {}
response_agent_array = []
Thread.current[:isomorfeus_user] = user(client)
Thread.current[:isomorfeus_pub_sub_client] = client
process_request(request_hash, handler_instance_cache, response_agent_array)
handler_instance_cache.each_value do |handler|
handler.resolve if handler.resolving?
end
result = {}
response_agent_array.each do |response_agent|
result.deep_merge!(response_agent.result)
end
client.write Oj.dump(result, mode: :strict) unless result.empty?
ensure
Thread.current[:isomorfeus_user] = nil
Thread.current[:isomorfeus_pub_sub_client] = nil
Isomorfeus.zeitwerk_lock.release_read_lock if Isomorfeus.development?
end
def on_close(client)
# nothing for now
end
def on_open(client)
# nothing for now
end
def on_shutdown(client)
# nothing for now
end
def user(client)
@user ||= Anonymous.new
end
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems