Class: SocketClientBase

Inherits:
EM::Connection
  • Object
show all
Defined in:
lib/mrpin/core/remote/socket/base/socket_client_base.rb

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#callback_on_disconnect ⇒ Object

Returns the value of attribute callback_on_disconnect.



28
29
30
 
# File 'lib/mrpin/core/remote/socket/base/socket_client_base.rb', line 28

def callback_on_disconnect
  @callback_on_disconnect
end

#ip ⇒ Object (readonly)

Returns the value of attribute ip.



21
22
23
 
# File 'lib/mrpin/core/remote/socket/base/socket_client_base.rb', line 21

def ip
  @ip
end

#player ⇒ Object

Returns the value of attribute player.



26
27
28
 
# File 'lib/mrpin/core/remote/socket/base/socket_client_base.rb', line 26

def player
  @player
end

#should_disconnect_session ⇒ Object

use for disconnect_inactive_players and on_application_exit



24
25
26
 
# File 'lib/mrpin/core/remote/socket/base/socket_client_base.rb', line 24

def should_disconnect_session
  @should_disconnect_session
end

#time_last_request ⇒ Object (readonly)

Properties



20
21
22
 
# File 'lib/mrpin/core/remote/socket/base/socket_client_base.rb', line 20

def time_last_request
  @time_last_request
end

Class Method Details

.manager_remote ⇒ Object 



13
14
15
 
# File 'lib/mrpin/core/remote/socket/base/socket_client_base.rb', line 13

def self.manager_remote
  @manager_remote
end

.manager_remote=(value) ⇒ Object 



8
9
10
 
# File 'lib/mrpin/core/remote/socket/base/socket_client_base.rb', line 8

def self.manager_remote=(value)
  @manager_remote = value
end

Instance Method Details

#get_requests ⇒ Object 



115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
 
# File 'lib/mrpin/core/remote/socket/base/socket_client_base.rb', line 115

def get_requests
  result = []

  return result unless @is_online

  @requests_locker.synchronize do
    begin

      unless @data_buffer.empty?
        deserialize_data = AMF::Root.deserialize(@data_buffer)
        result           = deserialize_data[:objects]
        @data_buffer     = deserialize_data[:incomplete_objects] || ''
      end

    rescue Exception => e
      on_get_requests_error(e)
    end #begin/rescue
  end #synchronize

  result
end

#is_online? ⇒ Boolean

Returns:

  • (Boolean) 


31
32
33
 
# File 'lib/mrpin/core/remote/socket/base/socket_client_base.rb', line 31

def is_online?
  @is_online
end

#post_init ⇒ Object 



61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
 
# File 'lib/mrpin/core/remote/socket/base/socket_client_base.rb', line 61

def post_init
  @logger = AppInfo.instance.logger

  @requests_locker = Mutex.new

  @is_online = true

  @time_last_request = Time.now.to_i

  @should_disconnect_session = true

  @manager_remote = self.class.manager_remote
  @manager_remote.on_client_connected(self)

  @data_buffer = ''

  @player                 = nil
  @callback_on_disconnect = nil

  init_ip

  nil
end

#receive_data(data) ⇒ Object 



102
103
104
105
106
107
108
109
110
111
112
 
# File 'lib/mrpin/core/remote/socket/base/socket_client_base.rb', line 102

def receive_data(data)
  @time_last_request = Time.now.to_i

  @requests_locker.synchronize do
    @data_buffer += data
  end

  @manager_remote.handle_data_from(self)

  nil
end

#send_raw_data(raw_data) ⇒ Object 



167
168
169
 
# File 'lib/mrpin/core/remote/socket/base/socket_client_base.rb', line 167

def send_raw_data(raw_data)
  send_data(raw_data)
end

#send_response(response_obj) ⇒ Object 



139
140
141
142
143
144
145
146
147
148
149
 
# File 'lib/mrpin/core/remote/socket/base/socket_client_base.rb', line 139

def send_response(response_obj)
  return unless @is_online

  report_about_sent_request(response_obj)

  response = AMF::Root.serialize(response_obj)

  send_data(response)

  nil #for prevent return other value
end

#send_response_error(request_id, description = nil) ⇒ Object 



179
180
181
182
183
184
 
# File 'lib/mrpin/core/remote/socket/base/socket_client_base.rb', line 179

def send_response_error(request_id, description = nil)
  response             = Api::ResponseError.new(request_id)
  response.description = description

  send_response(response)
end

#send_response_ok(request_id) ⇒ Object 



172
173
174
175
176
 
# File 'lib/mrpin/core/remote/socket/base/socket_client_base.rb', line 172

def send_response_ok(request_id)
  response = Api::ResponseOk.new(request_id)

  send_response(response)
end

#unbind ⇒ Object 



187
188
189
190
191
 
# File 'lib/mrpin/core/remote/socket/base/socket_client_base.rb', line 187

def unbind
  on_connection_closed

  nil
end