trabajo-afectivo/lib/sessions/client.rb

80 lines
1.8 KiB
Ruby
Raw Normal View History

class Sessions::Client
2013-09-29 23:46:11 +00:00
def initialize( client_id )
@client_id = client_id
self.log 'notify', '---client start ws connection---'
self.fetch
self.log 'notify', '---client exiting ws connection---'
end
def fetch
2014-07-13 18:52:32 +00:00
backends = [
'Sessions::Backend::TicketOverviewIndex',
'Sessions::Backend::TicketOverviewList',
'Sessions::Backend::Collections',
'Sessions::Backend::Rss',
'Sessions::Backend::ActivityStream',
'Sessions::Backend::TicketCreate',
]
backend_pool = []
user_id_last_run = nil
loop_count = 0
while true
# get connection user
session_data = Sessions.get( @client_id )
return if !session_data
return if !session_data[:user]
2014-10-13 23:58:21 +00:00
return if !session_data[:user]['id']
user = User.lookup( id: session_data[:user]['id'] )
return if !user
2014-07-13 18:52:32 +00:00
# init new backends
if user_id_last_run != user.id
2014-07-13 23:29:29 +00:00
user_id_last_run = user.id
# release old objects
backend_pool.each {|pool|
pool = nil
}
# create new pool
2014-07-13 18:52:32 +00:00
backend_pool = []
backends.each {|backend|
item = backend.constantize.new(user, self, @client_id)
backend_pool.push item
}
end
loop_count += 1
self.log 'notice', "---client - looking for data of user #{user.id}"
2014-07-13 18:52:32 +00:00
# push messages from backends
backend_pool.each {|pool|
pool.push
}
self.log 'notice', '---/client-'
# start faster in the beginnig
if loop_count < 20
sleep 0.6
else
sleep 1
end
end
end
# send update to browser
def send( data )
Sessions.send( @client_id, data )
end
def log( level, data )
return if level == 'notice'
puts "#{Time.now}:client(#{ @client_id }) #{ data }"
end
end