2015-11-11 13:10:26 +00:00
|
|
|
class Sessions::Event::ChatSessionStart < Sessions::Event::ChatBase
|
2015-11-10 14:01:04 +00:00
|
|
|
|
2015-11-11 13:10:26 +00:00
|
|
|
def run
|
2015-11-10 14:01:04 +00:00
|
|
|
|
|
|
|
# find first in waiting list
|
|
|
|
chat_session = Chat::Session.where(state: 'waiting').order('created_at ASC').first
|
|
|
|
if !chat_session
|
|
|
|
return {
|
|
|
|
event: 'chat_session_start',
|
|
|
|
data: {
|
|
|
|
state: 'failed',
|
|
|
|
message: 'No session available.',
|
|
|
|
},
|
|
|
|
}
|
|
|
|
end
|
2015-11-11 13:10:26 +00:00
|
|
|
chat_session.user_id = @session['id']
|
2015-11-10 14:01:04 +00:00
|
|
|
chat_session.state = 'running'
|
2015-11-11 13:10:26 +00:00
|
|
|
chat_session.preferences[:participants] = chat_session.add_recipient(@client_id)
|
2015-11-10 14:01:04 +00:00
|
|
|
chat_session.save
|
|
|
|
|
|
|
|
# send chat_session_init to client
|
|
|
|
chat_user = User.find(chat_session.user_id)
|
2015-11-11 20:44:54 +00:00
|
|
|
url = nil
|
|
|
|
if chat_user.image && chat_user.image != 'none'
|
|
|
|
url = "/api/v1/users/image/#{chat_user.image}"
|
|
|
|
end
|
2015-11-10 14:01:04 +00:00
|
|
|
user = {
|
|
|
|
name: chat_user.fullname,
|
2015-11-11 20:44:54 +00:00
|
|
|
avatar: url,
|
2015-11-10 14:01:04 +00:00
|
|
|
}
|
|
|
|
data = {
|
|
|
|
event: 'chat_session_start',
|
|
|
|
data: {
|
|
|
|
state: 'ok',
|
|
|
|
agent: user,
|
|
|
|
session_id: chat_session.session_id,
|
|
|
|
},
|
|
|
|
}
|
2015-11-11 13:10:26 +00:00
|
|
|
chat_session.send_to_recipients(data, @client_id)
|
2015-11-10 14:01:04 +00:00
|
|
|
|
|
|
|
# send chat_session_init to agent
|
|
|
|
{
|
|
|
|
event: 'chat_session_start',
|
|
|
|
data: {
|
|
|
|
state: 'ok',
|
|
|
|
session: chat_session,
|
|
|
|
},
|
|
|
|
}
|
|
|
|
end
|
|
|
|
end
|