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 



120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
 
# File 'lib/mrpin/core/remote/socket/base/socket_client_base.rb', line 120

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 



66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
 
# File 'lib/mrpin/core/remote/socket/base/socket_client_base.rb', line 66

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 



107
108
109
110
111
112
113
114
115
116
117
 
# File 'lib/mrpin/core/remote/socket/base/socket_client_base.rb', line 107

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 



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

def send_raw_data(raw_data)
  send_data(raw_data)
end

#send_response(response_obj) ⇒ Object 



144
145
146
147
148
149
150
151
152
153
154
 
# File 'lib/mrpin/core/remote/socket/base/socket_client_base.rb', line 144

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 



184
185
186
187
188
189
 
# File 'lib/mrpin/core/remote/socket/base/socket_client_base.rb', line 184

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 



177
178
179
180
181
 
# File 'lib/mrpin/core/remote/socket/base/socket_client_base.rb', line 177

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

  send_response(response)
end

#unbind ⇒ Object 



192
193
194
195
196
 
# File 'lib/mrpin/core/remote/socket/base/socket_client_base.rb', line 192

def unbind
  on_connection_closed

  nil
end