# -*- coding: utf-8 -*- require File.dirname(__FILE__) + '/daemon_logger' # Базовый модуль для прослушивания JSON запросов от клиента module GameServer::BaseListner # семафор (mutex) для доступа к коннекшену. должен устанавливаться в приложении connection.semaphore = Mutex.new # если не установлен - то не используется attr_accessor :semaphore MAX_INPUT_BUFFER_SIZE = 128 * 1024 include DaemonLogger::Mixins def initialize(*args) super(*args) self.input_buffer = "" end def find_controller(request) return unless request.name =~ /^[A-Za-z_]+$/ controller_name = (controllers_classes_root + "::" + request.name.camelize) log controller_name controller_name.constantize rescue NameError return end def send_error(name, comment = "") send_line(['error', name, comment].to_json ) end def send_line(string) send_data(string + "\000\n" ) end def connection_info "CONNECTION" end def send_json(object) #send_line '' + "\n\n" + object.to_json + "\n\n\000" send_line object.to_json end def send_json_with_marker(marker, object) send_json [marker, object] end def send_data(data) log "Data sended to #{connection_info}: " + data#.inspect if semaphore semaphore.synchronize { super(data) } else super(data) end end def critical_error(e) log_exception e send_error(e.class.to_s.underscore) # close_connection_after_writing end # В этом буфере хранится начало сообщения от клиента, если оно вдруг разбилось на несколько кусоков данных attr_accessor :input_buffer # Обработать входящие данные (может быть несклько строк запросов в одном пакете данных) def receive_data(data) data.gsub!("\000", "") complete_message = input_buffer + data if complete_message[-1] != "\n" self.input_buffer = complete_message if input_buffer.size >= MAX_INPUT_BUFFER_SIZE self.input_buffer.clear raise "OVERFLOW OF INPUT BUFFER #{input_buffer.size}" end return else input_buffer.clear end log "Received from #{connection_info} (size #{complete_message.size}): " + complete_message.inspect return if policy_file_request(complete_message) complete_message.split("\n").each do |query_string| operation = proc { process_query(query_string) } callback = proc { nil } EventMachine.defer(operation, callback) end rescue => e critical_error(e) end # Обработать один запрос def process_query(query_string) request = GameServer::RequestParser.new(query_string).parse controller = find_controller(request) return send_error('unknown_request', request.name) unless controller controller.new(self, request, GameServer::ObjectSpace.instance).run rescue GameServer::RequestParser::ParserError send_error('bad_syntax') rescue GameServer::ServerError => e send_error("server_error", "#{e.name} #{!(e.comment.empty?) ? ':' + e.comment : ''}") rescue GameError => e send_error(e.class.to_s.underscore, e.message) rescue => e critical_error(e) end def policy_file_request(data) if data =~ /^