trabajo-afectivo/lib/sessions/event/chat_session_init.rb

75 lines
1.5 KiB
Ruby
Raw Normal View History

class Sessions::Event::ChatSessionInit < Sessions::Event::ChatBase
2015-11-10 14:01:04 +00:00
=begin
a customer requests a new chat session
payload
{
event: 'chat_session_init',
data: {
chat_id: 'the id of chat',
url: 'the browser url',
},
}
return is sent as message back to peer
=end
def run
2015-12-09 13:09:37 +00:00
return super if super
return if !check_chat_exists
2015-11-10 14:01:04 +00:00
2016-01-05 08:49:11 +00:00
# geo ip lookup
geo_ip = nil
2016-01-05 12:46:43 +00:00
if @remote_ip
geo_ip = Service::GeoIp.location(@remote_ip)
2016-01-05 08:49:11 +00:00
end
2016-03-24 14:34:49 +00:00
# dns lookup
dns_name = nil
if @remote_ip
begin
dns = Resolv::DNS.new
dns.timeouts = 3
result = dns.getname @remote_ip
if result
dns_name = result.to_s
end
rescue => e
Rails.logger.error e
2016-03-24 14:34:49 +00:00
end
end
2015-11-10 14:01:04 +00:00
# create chat session
chat_session = Chat::Session.create(
chat_id: @payload['data']['chat_id'],
name: '',
state: 'waiting',
2015-11-10 14:01:04 +00:00
preferences: {
url: @payload['data']['url'],
participants: [@client_id],
remote_ip: @remote_ip,
geo_ip: geo_ip,
dns_name: dns_name,
2015-11-10 14:01:04 +00:00
},
)
# send broadcast to agents
Chat.broadcast_agent_state_update([chat_session.chat_id])
2015-11-10 14:01:04 +00:00
# return new session
{
event: 'chat_session_queue',
data: {
state: 'queue',
position: Chat.waiting_chat_count([chat_session.chat_id]),
2015-11-10 14:01:04 +00:00
session_id: chat_session.session_id,
},
}
end
2015-12-09 13:09:37 +00:00
2015-11-10 14:01:04 +00:00
end