Sutty/trabajo-afectivo
5
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Split of web sockets worker and renamed collection names.

Browse source
This commit is contained in:
Martin Edenhofer 2013-09-22 00:40:19 +02:00
parent 98aeff516d
commit d2ef07c759
26 changed files with 763 additions and 652 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
app/assets/javascripts/app/controllers/ticket_zoom.js.coffee
View file

@ -72,7 +72,7 @@ class App.TicketZoom extends App.Controller
success: (data, status, xhr) =>
# check if ticket has changed
newTicketRaw = data.assets.tickets[ticket_id]
newTicketRaw = data.assets.Ticket[ticket_id]
if @ticketUpdatedAtLastCall && !force
# return if ticket hasnt changed

7
app/assets/javascripts/app/lib/app_post/collection.js.coffee
View file

@ -25,18 +25,25 @@ class _collectionSingleton extends Spine.Module
for type, collections of data
if type is 'users'
type = 'User'
throw "BREAK, users"
if type is 'tickets'
type = 'Ticket'
throw "BREAK, tickets"
if type is 'ticket_article'
type = 'TicketArticle'
throw "BREAK, ticket_article"
if type is 'organization'
type = 'Organization'
throw "BREAK, organization"
if type is 'history_object'
type = 'HistoryObject'
throw "BREAK, history_object"
if type is 'history_type'
type = 'HistoryType'
throw "BREAK, history_type"
if type is 'history_attribute'
type = 'HistoryAttribute'
throw "BREAK, history_attribute"
@log 'debug', 'loadCollection:trigger', type, collections
@load( localStorage: data.localStorage, type: type, data: collections )

18
app/controllers/sessions/collection_base.rb
View file

@ -4,29 +4,29 @@ module ExtraCollection
def session( collections, user )
# all base stuff
collections['Taskbar'] = Taskbar.where( :user_id => user.id )
collections['Role'] = Role.all
collections['Group'] = Group.all
collections[ Taskbar.to_online_model ] = Taskbar.where( :user_id => user.id )
collections[ Role.to_online_model ] = Role.all
collections[ Group.to_online_model ] = Group.all
if !user.is_role('Customer')
collections['Organization'] = Organization.all
collections[ Organization.to_online_model ] = Organization.all
else
if user.organization_id
collections['Organization'] = Organization.where( :id => user.organization_id )
collections[ Organization.to_online_model ] = Organization.where( :id => user.organization_id )
end
end
end
def push( collections, user )
# all base stuff
collections['Role'] = Role.all
collections['Group'] = Group.all
collections[ Role.to_online_model ] = Role.all
collections[ Group.to_online_model ] = Group.all
if !user.is_role('Customer')
collections['Organization'] = Organization.all
collections[ Organization.to_online_model ] = Organization.all
else
if user.organization_id
collections['Organization'] = Organization.where( :id => user.organization_id )
collections[ Organization.to_online_model ] = Organization.where( :id => user.organization_id )
end
end
end

16
app/controllers/sessions/collection_network.rb
View file

@ -3,18 +3,18 @@
module ExtraCollection
def session( collections, user )
collections['Network'] = Network.all
collections['NetworkCategory'] = Network::Category.all
collections['NetworkCategoryType'] = Network::Category::Type.all
collections['NetworkPrivacy'] = Network::Privacy.all
collections[ Network.to_online_model ] = Network.all
collections[ Network::Category.to_online_model ] = Network::Category.all
collections[ Network::Category::Type.to_online_model ] = Network::Category::Type.all
collections[ Network::Privacy.to_online_model ] = Network::Privacy.all
end
def push( collections, user )
collections['Network'] = Network.all
collections['NetworkCategory'] = Network::Category.all
collections['NetworkCategoryType'] = Network::Category::Type.all
collections['NetworkPrivacy'] = Network::Privacy.all
collections[ Network.to_online_model ] = Network.all
collections[ Network::Category.to_online_model ] = Network::Category.all
collections[ Network::Category::Type.to_online_model ] = Network::Category::Type.all
collections[ Network::Privacy.to_online_model ] = Network::Privacy.all
end
module_function :session, :push

28
app/controllers/sessions/collection_ticket.rb
View file

@ -4,37 +4,37 @@ module ExtraCollection
def session( collections, user )
# all ticket stuff
collections['TicketStateType'] = Ticket::StateType.all
collections['TicketState'] = Ticket::State.all
collections['TicketPriority'] = Ticket::Priority.all
collections['TicketArticleType'] = Ticket::Article::Type.all
collections['TicketArticleSender'] = Ticket::Article::Sender.all
collections[ Ticket::StateType.to_online_model ] = Ticket::StateType.all
collections[ Ticket::State.to_online_model ] = Ticket::State.all
collections[ Ticket::Priority.to_online_model ] = Ticket::Priority.all
collections[ Ticket::Article::Type.to_online_model ] = Ticket::Article::Type.all
collections[ Ticket::Article::Sender.to_online_model ] = Ticket::Article::Sender.all
if !user.is_role('Customer')
# all signatures
collections['Signature'] = Signature.all
collections[ Signature.to_online_model ] = Signature.all
# all email addresses
collections['EmailAddress'] = EmailAddress.all
collections[ EmailAddress.to_online_model ] = EmailAddress.all
end
end
def push( collections, user )
# all ticket stuff
collections['TicketStateType'] = Ticket::StateType.all
collections['TicketState'] = Ticket::State.all
collections['TicketPriority'] = Ticket::Priority.all
collections['TicketArticleType'] = Ticket::Article::Type.all
collections['TicketArticleSender'] = Ticket::Article::Sender.all
collections[ Ticket::StateType.to_online_model ] = Ticket::StateType.all
collections[ Ticket::State.to_online_model ] = Ticket::State.all
collections[ Ticket::Priority.to_online_model ] = Ticket::Priority.all
collections[ Ticket::Article::Type.to_online_model ] = Ticket::Article::Type.all
collections[ Ticket::Article::Sender.to_online_model ] = Ticket::Article::Sender.all
if !user.is_role('Customer')
# all signatures
collections['Signature'] = Signature.all
collections[ Signature.to_online_model ] = Signature.all
# all email addresses
collections['EmailAddress'] = EmailAddress.all
collections[ EmailAddress.to_online_model ] = EmailAddress.all
end
end

4
app/controllers/sessions_controller.rb
View file

@ -160,8 +160,8 @@ class SessionsController < ApplicationController
end
}
render :json => {
:sessions => sessions_clean,
:users => users,
:sessions => sessions_clean,
User.to_online_model.to_sym => users,
}
end

6
app/controllers/ticket_overviews_controller.rb
View file

@ -49,7 +49,7 @@ class TicketOverviewsController < ApplicationController
end
# get related users
assets = { :users => {} }
assets = { User.to_online_model.to_sym => {} }
overview[:ticket_ids].each {|ticket_id|
ticket = Ticket.lookup( :id => ticket_id )
assets = ticket.assets(assets)
@ -70,8 +70,8 @@ class TicketOverviewsController < ApplicationController
Group.find(group_id).users.each {|user|
next if !agents[ user.id ]
groups_users[ group_id ].push user.id
if !assets[:users][user.id]
assets[:users][user.id] = User.user_data_full(user.id)
if !assets[ User.to_online_model.to_sym ][user.id]
assets[ User.to_online_model.to_sym ][user.id] = User.user_data_full(user.id)
end
}
}

24
app/controllers/tickets_controller.rb
View file

@ -304,22 +304,22 @@ class TicketsController < ApplicationController
# get related users
assets = {}
assets[:users] = {}
assets[ User.to_online_model.to_sym ] = {}
assets = ticket.assets(assets)
# get attributes to update
attributes_to_change = Ticket::ScreenOptions.attributes_to_change( :user => current_user, :ticket => ticket )
attributes_to_change[:owner_id].each { |user_id|
if !assets[:users][user_id]
assets[:users][user_id] = User.user_data_full( user_id )
if !assets[ User.to_online_model.to_sym ][user_id]
assets[ User.to_online_model.to_sym ][user_id] = User.user_data_full( user_id )
end
}
attributes_to_change[:group_id__owner_id].each {|group_id, user_ids|
user_ids.each {|user_id|
if !assets[:users][user_id]
assets[:users][user_id] = User.user_data_full( user_id )
if !assets[ User.to_online_model.to_sym ][user_id]
assets[ User.to_online_model.to_sym ][user_id] = User.user_data_full( user_id )
end
}
}
@ -362,17 +362,17 @@ class TicketsController < ApplicationController
)
assets = {}
assets[:users] = {}
assets[ User.to_online_model.to_sym ] = {}
attributes_to_change[:owner_id].each { |user_id|
if !assets[:users][user_id]
assets[:users][user_id] = User.user_data_full( user_id )
if !assets[ User.to_online_model.to_sym ][user_id]
assets[ User.to_online_model.to_sym ][user_id] = User.user_data_full( user_id )
end
}
attributes_to_change[:group_id__owner_id].each {|group_id, user_ids|
user_ids.each {|user_id|
if !assets[:users][user_id]
assets[:users][user_id] = User.user_data_full( user_id )
if !assets[ User.to_online_model.to_sym ][user_id]
assets[ User.to_online_model.to_sym ][user_id] = User.user_data_full( user_id )
end
}
}
@ -387,8 +387,8 @@ class TicketsController < ApplicationController
owner_ids = []
ticket.agent_of_group.each { |user|
owner_ids.push user.id
if !assets[:users][user.id]
assets[:users][user.id] = User.user_data_full( user.id )
if !assets[ User.to_online_model.to_sym ][user.id]
assets[ User.to_online_model.to_sym ][user.id] = User.user_data_full( user.id )
end
}

20
app/models/history/assets.rb
View file

@ -22,22 +22,22 @@ returns
def assets (data)
if !data[:users]
data[:users] = {}
if !data[ User.to_online_model.to_sym ]
data[ User.to_online_model.to_sym ] = {}
end
if !data[:users][ self['created_by_id'] ]
data[:users][ self['created_by_id'] ] = User.user_data_full( self['created_by_id'] )
if !data[ User.to_online_model.to_sym ][ self['created_by_id'] ]
data[ User.to_online_model.to_sym ][ self['created_by_id'] ] = User.user_data_full( self['created_by_id'] )
end
# fetch meta relations
if !data[:history_object]
data[:history_object] = History::Object.all()
if !data[ History::Object.to_online_model.to_sym ]
data[ History::Object.to_online_model.to_sym ] = History::Object.all()
end
if !data[:history_type]
data[:history_type] = History::Type.all()
if !data[ History::Type.to_online_model.to_sym ]
data[ History::Type.to_online_model.to_sym ] = History::Type.all()
end
if !data[:history_attribute]
data[:history_attribute] = History::Attribute.all()
if !data[ History::Attribute.to_online_model.to_sym ]
data[ History::Attribute.to_online_model.to_sym ] = History::Attribute.all()
end
data

18
app/models/organization/assets.rb
View file

@ -22,19 +22,19 @@ returns
def assets (data)
if !data[:organizations]
data[:organizations] = {}
if !data[ Organization.to_online_model.to_sym ]
data[ Organization.to_online_model.to_sym ] = {}
end
if !data[:users]
data[:users] = {}
if !data[ User.to_online_model.to_sym ]
data[ User.to_online_model.to_sym ] = {}
end
if !data[:organizations][ self.id ]
data[:organizations][ self.id ] = self.attributes
data[:organizations][ self.id ][:user_ids] = []
if !data[ Organization.to_online_model.to_sym ][ self.id ]
data[ Organization.to_online_model.to_sym ][ self.id ] = self.attributes
data[ Organization.to_online_model.to_sym ][ self.id ][:user_ids] = []
users = User.where( :organization_id => self.id ).limit(10)
users.each {|user|
data[:users][ user.id ] = User.user_data_full( user.id )
data[:organizations][ self.id ][:user_ids].push user.id
data[ User.to_online_model.to_sym ][ user.id ] = User.user_data_full( user.id )
data[ Organization.to_online_model.to_sym ][ self.id ][:user_ids].push user.id
}
end
data

22
app/models/ticket/article/assets.rb
View file

@ -23,24 +23,24 @@ returns
def assets (data)
if !data[:ticket_article]
data[:ticket_article] = {}
if !data[ Ticket::Article.to_online_model.to_sym ]
data[ Ticket::Article.to_online_model.to_sym ] = {}
end
if !data[:ticket_article][ self.id ]
data[:ticket_article][ self.id ] = self.attributes
if !data[ Ticket::Article.to_online_model.to_sym ][ self.id ]
data[ Ticket::Article.to_online_model.to_sym ][ self.id ] = self.attributes
# add attachment list to article
data[:ticket_article][ self.id ]['attachments'] = Store.list( :object => 'Ticket::Article', :o_id => self.id )
data[ Ticket::Article.to_online_model.to_sym ][ self.id ]['attachments'] = Store.list( :object => 'Ticket::Article', :o_id => self.id )
end
if !data[:users]
data[:users] = {}
if !data[ User.to_online_model.to_sym ]
data[ User.to_online_model.to_sym ] = {}
end
if !data[:users][ self['created_by_id'] ]
data[:users][ self['created_by_id'] ] = User.user_data_full( self['created_by_id'] )
if !data[ User.to_online_model.to_sym ][ self['created_by_id'] ]
data[ User.to_online_model.to_sym ][ self['created_by_id'] ] = User.user_data_full( self['created_by_id'] )
end
if !data[:users][ self['updated_by_id'] ]
data[:users][ self['updated_by_id'] ] = User.user_data_full( self['updated_by_id'] )
if !data[ User.to_online_model.to_sym ][ self['updated_by_id'] ]
data[ User.to_online_model.to_sym ][ self['updated_by_id'] ] = User.user_data_full( self['updated_by_id'] )
end
data
end

28
app/models/ticket/assets.rb
View file

@ -23,27 +23,27 @@ returns
def assets (data)
if !data[:tickets]
data[:tickets] = {}
if !data[ Ticket.to_online_model.to_sym ]
data[ Ticket.to_online_model.to_sym ] = {}
end
if !data[:tickets][ self.id ]
data[:tickets][ self.id ] = self.attributes
if !data[ Ticket.to_online_model.to_sym ][ self.id ]
data[ Ticket.to_online_model.to_sym ][ self.id ] = self.attributes
end
if !data[:users]
data[:users] = {}
if !data[ User.to_online_model.to_sym ]
data[ User.to_online_model.to_sym ] = {}
end
if !data[:users][ self['owner_id'] ]
data[:users][ self['owner_id'] ] = User.user_data_full( self['owner_id'] )
if !data[ User.to_online_model.to_sym ][ self['owner_id'] ]
data[ User.to_online_model.to_sym ][ self['owner_id'] ] = User.user_data_full( self['owner_id'] )
end
if !data[:users][ self['customer_id'] ]
data[:users][ self['customer_id'] ] = User.user_data_full( self['customer_id'] )
if !data[ User.to_online_model.to_sym ][ self['customer_id'] ]
data[ User.to_online_model.to_sym ][ self['customer_id'] ] = User.user_data_full( self['customer_id'] )
end
if !data[:users][ self['created_by_id'] ]
data[:users][ self['created_by_id'] ] = User.user_data_full( self['created_by_id'] )
if !data[ User.to_online_model.to_sym ][ self['created_by_id'] ]
data[ User.to_online_model.to_sym ][ self['created_by_id'] ] = User.user_data_full( self['created_by_id'] )
end
if !data[:users][ self['updated_by_id'] ]
data[:users][ self['updated_by_id'] ] = User.user_data_full( self['updated_by_id'] )
if !data[ User.to_online_model.to_sym ][ self['updated_by_id'] ]
data[ User.to_online_model.to_sym ][ self['updated_by_id'] ] = User.user_data_full( self['updated_by_id'] )
end
data
end

8
app/models/user/assets.rb
View file

@ -22,11 +22,11 @@ returns
def assets (data)
if !data[:users]
data[:users] = {}
if !data[ User.to_online_model.to_sym ]
data[ User.to_online_model.to_sym ] = {}
end
if !data[:users][ self.id ]
data[:users][ self.id ] = User.user_data_full( self.id )
if !data[ User.to_online_model.to_sym ][ self.id ]
data[ User.to_online_model.to_sym ][ self.id ] = User.user_data_full( self.id )
end
data
end

6
lib/core_ext/class.rb
View file

@ -7,4 +7,8 @@ class Class
tr("-", "_").
downcase
end
end
def to_online_model
camel_cased_word = self.to_s
camel_cased_word.gsub(/::/, '')
end
end

557
lib/sessions.rb
View file

@ -217,7 +217,7 @@ module Sessions
if !@@user_threads[user.id]
start_user_thread = true
@@user_threads[user.id] = Thread.new {
UserState.new(user.id)
Sessions::Worker.new(user.id)
@@user_threads[user.id] = nil
puts "close user(#{user.id}) thread"
# raise "Exception from thread"
@ -232,7 +232,7 @@ module Sessions
# start client thread
if !@@client_threads[client_id]
@@client_threads[client_id] = Thread.new {
ClientState.new(client_id)
Sessions::Client.new(client_id)
@@client_threads[client_id] = nil
puts "close client(#{client_id}) thread"
# raise "Exception from thread"
@ -307,555 +307,4 @@ module Sessions
FileUtils.rm_rf path
end
end
module CacheIn
@@data = {}
@@data_time = {}
@@expires_in = {}
@@expires_in_ttl = {}
def self.set( key, value, params = {} )
# puts 'CacheIn.set:' + key + '-' + value.inspect
if params[:expires_in]
@@expires_in[key] = Time.now + params[:expires_in]
@@expires_in_ttl[key] = params[:expires_in]
end
@@data[ key ] = value
@@data_time[ key ] = Time.now
end
def self.expired( key, params = {} )
# expire if value never was set
return true if !@@data.include? key
# ignore_expire
return false if params[:ignore_expire]
# set re_expire
if params[:re_expire]
if @@expires_in[key]
@@expires_in[key] = Time.now + @@expires_in_ttl[key]
end
return false
end
# check if expired
if @@expires_in[key]
return true if @@expires_in[key] < Time.now
return false
end
# return false if key was set without expires_in
return false
end
def self.get_time( key, params = {} )
data = self.get( key, params )
if data
return @@data_time[key]
end
return nil
end
def self.get( key, params = {} )
# puts 'CacheIn.get:' + key + '-' + @@data[ key ].inspect
return if self.expired( key, params )
@@data[ key ]
end
end
class UserState
def initialize( user_id )
@user_id = user_id
@data = {}
@cache_key = 'user_' + user_id.to_s
self.log 'notify', "---user started user state"
CacheIn.set( 'last_run_' + user_id.to_s , true, { :expires_in => 20.seconds } )
self.fetch
end
def fetch
user = User.find( @user_id )
return if !user
while true
# check if user is still with min one open connection
if !CacheIn.get( 'last_run_' + user.id.to_s )
self.log 'notify', "---user - closeing thread - no open user connection"
return
end
self.log 'notice', "---user - fetch user data"
# overview
cache_key = @cache_key + '_overview'
if CacheIn.expired(cache_key)
overview = Ticket::Overviews.list(
:current_user => user,
)
overview_cache = CacheIn.get( cache_key, { :re_expire => true } )
self.log 'notice', 'fetch overview - ' + cache_key
if overview != overview_cache
self.log 'notify', 'fetch overview changed - ' + cache_key
# puts overview.inspect
# puts '------'
# puts overview_cache.inspect
CacheIn.set( cache_key, overview, { :expires_in => 4.seconds } )
end
end
# overview lists
overviews = Ticket::Overviews.all(
:current_user => user,
)
overviews.each { |overview|
cache_key = @cache_key + '_overview_data_' + overview.link
if CacheIn.expired(cache_key)
overview_data = Ticket::Overviews.list(
:view => overview.link,
:current_user => user,
:array => true,
)
overview_data_cache = CacheIn.get( cache_key, { :re_expire => true } )
self.log 'notice', 'fetch overview_data - ' + cache_key
if overview_data != overview_data_cache
self.log 'notify', 'fetch overview_data changed - ' + cache_key
CacheIn.set( cache_key, overview_data, { :expires_in => 5.seconds } )
end
end
}
# create_attributes
cache_key = @cache_key + '_ticket_create_attributes'
if CacheIn.expired(cache_key)
ticket_create_attributes = Ticket::ScreenOptions.attributes_to_change(
:current_user_id => user.id,
)
ticket_create_attributes_cache = CacheIn.get( cache_key, { :re_expire => true } )
self.log 'notice', 'fetch ticket_create_attributes - ' + cache_key
if ticket_create_attributes != ticket_create_attributes_cache
self.log 'notify', 'fetch ticket_create_attributes changed - ' + cache_key
CacheIn.set( cache_key, ticket_create_attributes, { :expires_in => 2.minutes } )
end
end
# recent viewed
cache_key = @cache_key + '_recent_viewed'
if CacheIn.expired(cache_key)
recent_viewed = RecentView.list_fulldata( user, 10 )
recent_viewed_cache = CacheIn.get( cache_key, { :re_expire => true } )
self.log 'notice', 'fetch recent_viewed - ' + cache_key
if recent_viewed != recent_viewed_cache
self.log 'notify', 'fetch recent_viewed changed - ' + cache_key
recent_viewed_full = RecentView.list_fulldata( user, 10 )
CacheIn.set( cache_key, recent_viewed, { :expires_in => 5.seconds } )
CacheIn.set( cache_key + '_push', recent_viewed_full )
end
end
# activity steam
cache_key = @cache_key + '_activity_stream'
if CacheIn.expired(cache_key)
activity_stream = History.activity_stream( user, 20 )
activity_stream_cache = CacheIn.get( cache_key, { :re_expire => true } )
self.log 'notice', 'fetch activity_stream - ' + cache_key
if activity_stream != activity_stream_cache
self.log 'notify', 'fetch activity_stream changed - ' + cache_key
activity_stream_full = History.activity_stream_fulldata( user, 20 )
CacheIn.set( cache_key, activity_stream, { :expires_in => 0.75.minutes } )
CacheIn.set( cache_key + '_push', activity_stream_full )
end
end
# rss
cache_key = @cache_key + '_rss'
if CacheIn.expired(cache_key)
url = 'http://www.heise.de/newsticker/heise-atom.xml'
rss_items = Rss.fetch( url, 8 )
rss_items_cache = CacheIn.get( cache_key, { :re_expire => true } )
self.log 'notice', 'fetch rss - ' + cache_key
if rss_items != rss_items_cache
self.log 'notify', 'fetch rss changed - ' + cache_key
CacheIn.set( cache_key, rss_items, { :expires_in => 2.minutes } )
CacheIn.set( cache_key + '_push', {
head: 'Heise ATOM',
items: rss_items,
})
end
end
# auto population of default collections
self.log 'notice', "---user - fetch push_collection data"
# get available collections
cache_key = @cache_key + '_push_collections'
collections = CacheIn.get( cache_key )
if !collections
collections = {}
push_collection = SessionHelper::push_collections(user)
push_collection.each { | key, value |
collections[ key ] = true
}
CacheIn.set( cache_key, collections, { :expires_in => 2.minutes } )
end
# check all collections to push
push_collection = {}
collections.each { | key, v |
cache_key = @cache_key + '_push_collections_' + key
if CacheIn.expired(cache_key)
if push_collection.empty?
push_collection = SessionHelper::push_collections(user)
end
push_collection_cache = CacheIn.get( cache_key, { :re_expire => true } )
self.log 'notice', "---user - fetch push_collection data " + cache_key
if !push_collection[key] || !push_collection_cache || push_collection[key] != push_collection_cache || !push_collection[ key ].zip( push_collection_cache ).all? { |x, y| x.attributes == y.attributes }
self.log 'notify', 'fetch push_collection changed - ' + cache_key
CacheIn.set( cache_key, push_collection[key], { :expires_in => 1.minutes } )
end
end
}
self.log 'notice', "---/user-"
sleep 1
end
end
def log( level, data )
return if level == 'notice'
puts "#{Time.now}:user_id(#{ @user_id }) #{ data }"
end
end
class ClientState
def initialize( client_id )
@client_id = client_id
@cache_key = ''
@data = {}
@pushed = {}
self.log 'notify', "---client start ws connection---"
self.fetch
self.log 'notify', "---client exiting ws connection---"
end
def fetch
loop_count = 0
while true
# get connection user
session_data = Sessions.get( @client_id )
return if !session_data
return if !session_data[:user]
return if !session_data[:user][:id]
user = User.lookup( :id => session_data[:user][:id] )
return if !user
# set cache key
@cache_key = 'user_' + user.id.to_s
loop_count += 1
self.log 'notice', "---client - looking for data of user #{user.id}"
# remember last run
CacheIn.set( 'last_run_' + user.id.to_s , true, { :expires_in => 20.seconds } )
# verify already pushed data
if !CacheIn.get( 'pushed_users' + @client_id.to_s )
CacheIn.set( 'pushed_users' + @client_id.to_s , true, { :expires_in => 20.seconds } )
if @pushed[:users]
users = {}
@pushed[:users].each {|user_id, user_o|
self.user( user_id, users )
}
if !users.empty?
users.each {|user_id, user_data|
self.log 'notify', "push update of already pushed user id #{user_id}"
}
# send update to browser
self.send({
:data => {
:collections => {
:User => users,
},
},
:event => [ 'loadCollection', 'ticket_overview_rebuild' ],
});
end
end
end
# verify already pushed data
if !CacheIn.get( 'pushed_tickets' + @client_id.to_s )
CacheIn.set( 'pushed_tickets' + @client_id.to_s , true, { :expires_in => 20.seconds } )
if @pushed[:tickets]
tickets = {}
users = {}
@pushed[:tickets].each {|ticket_id, ticket_data|
self.ticket( ticket_id, tickets, users )
}
if !tickets.empty?
tickets.each {|id, ticket|
self.log 'notify', "push update of already pushed ticket id #{id}"
}
# send update to browser
self.send({
:data => {
:collections => {
:Ticket => tickets,
:User => users,
},
},
:event => [ 'loadCollection', 'ticket_overview_rebuild' ],
});
end
end
end
# overview
cache_key = @cache_key + '_overview'
overview_time = CacheIn.get_time( cache_key, { :ignore_expire => true } )
if overview_time && @data[:overview_time] != overview_time
@data[:overview_time] = overview_time
overview = CacheIn.get( cache_key, { :ignore_expire => true } )
self.log 'notify', "push overview for user #{user.id}"
# send update to browser
self.send({
:event => 'navupdate_ticket_overview',
:data => overview,
})
end
# overview_data
overviews = Ticket::Overviews.all(
:current_user => user,
)
overviews.each { |overview|
cache_key = @cache_key + '_overview_data_' + overview.link
overview_data_time = CacheIn.get_time( cache_key, { :ignore_expire => true } )
if overview_data_time && @data[cache_key] != overview_data_time
@data[cache_key] = overview_data_time
overview_data = CacheIn.get( cache_key, { :ignore_expire => true } )
self.log 'notify', "push overview_data #{overview.link} for user #{user.id}"
users = {}
tickets = {}
overview_data[:ticket_ids].each {|ticket_id|
self.ticket( ticket_id, tickets, users )
}
# get groups
group_ids = []
Group.where( :active => true ).each { |group|
group_ids.push group.id
}
agents = {}
Ticket::ScreenOptions.agents.each { |user|
agents[ user.id ] = 1
}
groups_users = {}
groups_users[''] = []
group_ids.each {|group_id|
groups_users[ group_id ] = []
Group.find(group_id).users.each {|user|
next if !agents[ user.id ]
groups_users[ group_id ].push user.id
if !users[user.id]
users[user.id] = User.user_data_full(user.id)
end
}
}
# send update to browser
self.send({
:data => {
:users => users,
:tickets => tickets,
},
:event => [ 'loadAssets' ]
})
self.send({
:data => {
:overview => overview_data[:overview],
:ticket_ids => overview_data[:ticket_ids],
:tickets_count => overview_data[:tickets_count],
:bulk => {
:group_id__owner_id => groups_users,
:owner_id => [],
},
},
:event => [ 'ticket_overview_rebuild' ],
:collection => 'ticket_overview_' + overview.link.to_s,
})
end
}
# ticket_create_attributes
cache_key = @cache_key + '_ticket_create_attributes'
ticket_create_attributes_time = CacheIn.get_time( cache_key, { :ignore_expire => true } )
if ticket_create_attributes_time && @data[:ticket_create_attributes_time] != ticket_create_attributes_time
@data[:ticket_create_attributes_time] = ticket_create_attributes_time
create_attributes = CacheIn.get( cache_key, { :ignore_expire => true } )
users = {}
create_attributes[:owner_id].each {|user_id|
if !users[user_id]
users[user_id] = User.user_data_full(user_id)
end
}
data = {
:users => users,
:edit_form => create_attributes,
}
self.log 'notify', "push ticket_create_attributes for user #{user.id}"
# send update to browser
self.send({
:collection => 'ticket_create_attributes',
:data => data,
})
end
# recent viewed
cache_key = @cache_key + '_recent_viewed'
recent_viewed_time = CacheIn.get_time( cache_key, { :ignore_expire => true } )
if recent_viewed_time && @data[:recent_viewed_time] != recent_viewed_time
@data[:recent_viewed_time] = recent_viewed_time
recent_viewed = CacheIn.get( cache_key, { :ignore_expire => true } )
self.log 'notify', "push recent_viewed for user #{user.id}"
# send update to browser
r = CacheIn.get( cache_key + '_push', { :ignore_expire => true } )
self.send({
:event => 'update_recent_viewed',
:data => r,
})
end
# activity stream
cache_key = @cache_key + '_activity_stream'
activity_stream_time = CacheIn.get_time( cache_key, { :ignore_expire => true } )
if activity_stream_time && @data[:activity_stream_time] != activity_stream_time
@data[:activity_stream_time] = activity_stream_time
activity_stream = CacheIn.get( cache_key, { :ignore_expire => true } )
self.log 'notify', "push activity_stream for user #{user.id}"
# send update to browser
r = CacheIn.get( cache_key + '_push', { :ignore_expire => true } )
self.send({
:event => 'activity_stream_rebuild',
:collection => 'activity_stream',
:data => r,
})
end
# rss
cache_key = @cache_key + '_rss'
rss_items_time = CacheIn.get_time( cache_key, { :ignore_expire => true } )
if rss_items_time && @data[:rss_time] != rss_items_time
@data[:rss_time] = rss_items_time
rss_items = CacheIn.get( cache_key, { :ignore_expire => true } )
self.log 'notify', "push rss for user #{user.id}"
# send update to browser
r = CacheIn.get( cache_key + '_push', { :ignore_expire => true } )
self.send({
:event => 'rss_rebuild',
:collection => 'dashboard_rss',
:data => r,
})
end
# push_collections
cache_key = @cache_key + '_push_collections'
collections = CacheIn.get( cache_key ) || {}
collections.each { | key, v |
collection_cache_key = @cache_key + '_push_collections_' + key
collection_time = CacheIn.get_time( collection_cache_key, { :ignore_expire => true } )
if collection_time && @data[ collection_cache_key + '_time' ] != collection_time
@data[ collection_cache_key + '_time' ] = collection_time
push_collections = CacheIn.get( collection_cache_key, { :ignore_expire => true } )
self.log 'notify', "push push_collections #{key} for user #{user.id}"
# send update to browser
data = {}
data['collections'] = {}
data['collections'][key] = push_collections
self.send({
:event => 'resetCollection',
:data => data,
})
end
}
self.log 'notice', "---/client-"
# start faster in the beginnig
if loop_count < 20
sleep 0.6
else
sleep 1
end
end
end
# add ticket if needed
def ticket( ticket_id, tickets, users )
if !@pushed[:tickets]
@pushed[:tickets] = {}
end
ticket = Ticket.lookup( :id => ticket_id )
if @pushed[:tickets][ticket_id] != ticket['updated_at']
@pushed[:tickets][ticket_id] = ticket['updated_at']
tickets[ticket_id] = ticket
end
# add users if needed
self.user( ticket['owner_id'], users )
self.user( ticket['customer_id'], users )
self.user( ticket['created_by_id'], users )
if ticket['updated_by_id']
self.user( ticket['updated_by_id'], users )
end
end
# add user if needed
def user( user_id, users )
if !@pushed[:users]
@pushed[:users] = {}
end
# get user
user = User.user_data_full( user_id )
# user is already on client and not changed
return if @pushed[:users][ user_id ] == user['updated_at']
@pushed[:users][user_id] = user['updated_at']
# user not on client or different
self.log 'notice', 'push user ... ' + user['login']
users[ user_id ] = user
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
end

2
lib/sessions/backend.rb Normal file
View file

@ -0,0 +1,2 @@
module Sessions::Backend
end

39
lib/sessions/backend/activity_stream.rb Normal file
View file

@ -0,0 +1,39 @@
module Sessions::Backend::ActivityStream
@@last_change = {}
def self.worker( user, worker )
cache_key = 'user_' + user.id.to_s + '_activity_stream'
if Sessions::CacheIn.expired(cache_key)
activity_stream = History.activity_stream( user, 20 )
activity_stream_cache = Sessions::CacheIn.get( cache_key, { :re_expire => true } )
worker.log 'notice', 'fetch activity_stream - ' + cache_key
if activity_stream != activity_stream_cache
worker.log 'notify', 'fetch activity_stream changed - ' + cache_key
activity_stream_full = History.activity_stream_fulldata( user, 20 )
Sessions::CacheIn.set( cache_key, activity_stream, { :expires_in => 0.75.minutes } )
Sessions::CacheIn.set( cache_key + '_push', activity_stream_full )
end
end
end
def self.push( user, client )
cache_key = 'user_' + user.id.to_s + '_activity_stream'
activity_stream_time = Sessions::CacheIn.get_time( cache_key, { :ignore_expire => true } )
if activity_stream_time && @@last_change[ user.id ] != activity_stream_time
@@last_change[ user.id ] = activity_stream_time
activity_stream = Sessions::CacheIn.get( cache_key, { :ignore_expire => true } )
client.log 'notify', "push activity_stream for user #{user.id}"
# send update to browser
r = Sessions::CacheIn.get( cache_key + '_push', { :ignore_expire => true } )
client.send({
:event => 'activity_stream_rebuild',
:collection => 'activity_stream',
:data => r,
})
end
end
end

70
lib/sessions/backend/collections.rb Normal file
View file

@ -0,0 +1,70 @@
module Sessions::Backend::Collections
@@last_change = {}
def self.worker( user, worker )
worker.log 'notice', "---user - fetch push_collection data"
# get available collections
cache_key = 'user_' + user.id.to_s + '_push_collections'
collections = Sessions::CacheIn.get( cache_key )
if !collections
collections = {}
push_collection = SessionHelper::push_collections(user)
push_collection.each { | key, value |
collections[ key ] = true
}
Sessions::CacheIn.set( cache_key, collections, { :expires_in => 2.minutes } )
end
# check all collections to push
push_collection = {}
collections.each { | key, v |
cache_key = 'user_' + user.id.to_s + '_push_collections_' + key
if Sessions::CacheIn.expired(cache_key)
if push_collection.empty?
push_collection = SessionHelper::push_collections(user)
end
push_collection_cache = Sessions::CacheIn.get( cache_key, { :re_expire => true } )
worker.log 'notice', "---user - fetch push_collection data " + cache_key
if !push_collection[key] || !push_collection_cache || push_collection[key] != push_collection_cache || !push_collection[ key ].zip( push_collection_cache ).all? { |x, y| x.attributes == y.attributes }
worker.log 'notify', 'fetch push_collection changed - ' + cache_key
Sessions::CacheIn.set( cache_key, push_collection[key], { :expires_in => 1.minutes } )
end
end
}
end
def self.push( user, client )
cache_key = 'user_' + user.id.to_s + '_push_collections'
if !@@last_change[ user.id ]
@@last_change[ user.id ] = {}
end
collections = Sessions::CacheIn.get( cache_key ) || {}
collections.each { | key, v |
collection_cache_key = 'user_' + user.id.to_s + '_push_collections_' + key
collection_time = Sessions::CacheIn.get_time( collection_cache_key, { :ignore_expire => true } )
if collection_time && @@last_change[ user.id ][ key ] != collection_time
@@last_change[ user.id ][ key ] = collection_time
push_collections = Sessions::CacheIn.get( collection_cache_key, { :ignore_expire => true } )
client.log 'notify', "push push_collections #{key} for user #{user.id}"
# send update to browser
data = {}
data['collections'] = {}
data['collections'][key] = push_collections
client.send({
:event => 'resetCollection',
:data => data,
})
end
}
end
end

38
lib/sessions/backend/recent_viewed.rb Normal file
View file

@ -0,0 +1,38 @@
module Sessions::Backend::RecentViewed
@@last_change = {}
def self.worker( user, worker )
cache_key = 'user_' + user.id.to_s + '_recent_viewed'
if Sessions::CacheIn.expired(cache_key)
recent_viewed = RecentView.list_fulldata( user, 10 )
recent_viewed_cache = Sessions::CacheIn.get( cache_key, { :re_expire => true } )
worker.log 'notice', 'fetch recent_viewed - ' + cache_key
if recent_viewed != recent_viewed_cache
worker.log 'notify', 'fetch recent_viewed changed - ' + cache_key
recent_viewed_full = RecentView.list_fulldata( user, 10 )
Sessions::CacheIn.set( cache_key, recent_viewed, { :expires_in => 5.seconds } )
Sessions::CacheIn.set( cache_key + '_push', recent_viewed_full )
end
end
end
def self.push( user, client )
cache_key = 'user_' + user.id.to_s + '_recent_viewed'
recent_viewed_time = Sessions::CacheIn.get_time( cache_key, { :ignore_expire => true } )
if recent_viewed_time && @@last_change[ user.id ] != recent_viewed_time
@@last_change[ user.id ] = recent_viewed_time
recent_viewed = Sessions::CacheIn.get( cache_key, { :ignore_expire => true } )
client.log 'notify', "push recent_viewed for user #{user.id}"
# send update to browser
r = Sessions::CacheIn.get( cache_key + '_push', { :ignore_expire => true } )
client.send({
:event => 'update_recent_viewed',
:data => r,
})
end
end
end

41
lib/sessions/backend/rss.rb Normal file
View file

@ -0,0 +1,41 @@
module Sessions::Backend::Rss
@@last_change = {}
def self.worker( user, worker )
cache_key = 'user_' + user.id.to_s + '_rss'
if Sessions::CacheIn.expired(cache_key)
url = 'http://www.heise.de/newsticker/heise-atom.xml'
rss_items = Rss.fetch( url, 8 )
rss_items_cache = Sessions::CacheIn.get( cache_key, { :re_expire => true } )
worker.log 'notice', 'fetch rss - ' + cache_key
if rss_items != rss_items_cache
worker.log 'notify', 'fetch rss changed - ' + cache_key
Sessions::CacheIn.set( cache_key, rss_items, { :expires_in => 2.minutes } )
Sessions::CacheIn.set( cache_key + '_push', {
head: 'Heise ATOM',
items: rss_items,
})
end
end
end
def self.push( user, client )
cache_key = 'user_' + user.id.to_s + '_rss'
rss_items_time = Sessions::CacheIn.get_time( cache_key, { :ignore_expire => true } )
if rss_items_time && @@last_change[ user.id ] != rss_items_time
@@last_change[ user.id ] = rss_items_time
rss_items = Sessions::CacheIn.get( cache_key, { :ignore_expire => true } )
client.log 'notify', "push rss for user #{user.id}"
# send update to browser
r = Sessions::CacheIn.get( cache_key + '_push', { :ignore_expire => true } )
client.send({
:event => 'rss_rebuild',
:collection => 'dashboard_rss',
:data => r,
})
end
end
end

48
lib/sessions/backend/ticket_create.rb Normal file
View file

@ -0,0 +1,48 @@
module Sessions::Backend::TicketCreate
@@last_change = {}
def self.worker( user, worker )
cache_key = 'user_' + user.id.to_s + '_ticket_create_attributes'
if Sessions::CacheIn.expired(cache_key)
ticket_create_attributes = Ticket::ScreenOptions.attributes_to_change(
:current_user_id => user.id,
)
ticket_create_attributes_cache = Sessions::CacheIn.get( cache_key, { :re_expire => true } )
worker.log 'notice', 'fetch ticket_create_attributes - ' + cache_key
if ticket_create_attributes != ticket_create_attributes_cache
worker.log 'notify', 'fetch ticket_create_attributes changed - ' + cache_key
Sessions::CacheIn.set( cache_key, ticket_create_attributes, { :expires_in => 2.minutes } )
end
end
end
def self.push( user, client )
cache_key = 'user_' + user.id.to_s + '_ticket_create_attributes'
ticket_create_attributes_time = Sessions::CacheIn.get_time( cache_key, { :ignore_expire => true } )
if ticket_create_attributes_time && @@last_change[ user.id ] != ticket_create_attributes_time
@@last_change[ user.id ] = ticket_create_attributes_time
create_attributes = Sessions::CacheIn.get( cache_key, { :ignore_expire => true } )
users = {}
create_attributes[:owner_id].each {|user_id|
if !users[user_id]
users[user_id] = User.user_data_full(user_id)
end
}
data = {
:users => users,
:edit_form => create_attributes,
}
client.log 'notify', "push ticket_create_attributes for user #{user.id}"
# send update to browser
client.send({
:collection => 'ticket_create_attributes',
:data => data,
})
end
end
end

39
lib/sessions/backend/ticket_overview_index.rb Normal file
View file

@ -0,0 +1,39 @@
module Sessions::Backend::TicketOverviewIndex
@@last_change = {}
def self.worker( user, worker )
cache_key = 'user_' + user.id.to_s + '_overview'
if Sessions::CacheIn.expired(cache_key)
overview = Ticket::Overviews.list(
:current_user => user,
)
overview_cache = Sessions::CacheIn.get( cache_key, { :re_expire => true } )
worker.log 'notice', 'fetch overview - ' + cache_key
if overview != overview_cache
worker.log 'notify', 'fetch overview changed - ' + cache_key
# puts overview.inspect
# puts '------'
# puts overview_cache.inspect
Sessions::CacheIn.set( cache_key, overview, { :expires_in => 4.seconds } )
end
end
end
def self.push( user, client )
cache_key = 'user_' + user.id.to_s + '_overview'
overview_time = Sessions::CacheIn.get_time( cache_key, { :ignore_expire => true } )
if overview_time && @@last_change[ user.id ] != overview_time
@@last_change[ user.id ] = overview_time
overview = Sessions::CacheIn.get( cache_key, { :ignore_expire => true } )
client.log 'notify', "push overview for user #{user.id}"
# send update to browser
client.send({
:event => 'navupdate_ticket_overview',
:data => overview,
})
end
end
end

95
lib/sessions/backend/ticket_overview_list.rb Normal file
View file

@ -0,0 +1,95 @@
module Sessions::Backend::TicketOverviewList
@@last_change = {}
def self.worker( user, worker )
overviews = Ticket::Overviews.all(
:current_user => user,
)
overviews.each { |overview|
cache_key = 'user_' + user.id.to_s + '_overview_data_' + overview.link
if Sessions::CacheIn.expired(cache_key)
overview_data = Ticket::Overviews.list(
:view => overview.link,
:current_user => user,
:array => true,
)
overview_data_cache = Sessions::CacheIn.get( cache_key, { :re_expire => true } )
worker.log 'notice', 'fetch overview_data - ' + cache_key
if overview_data != overview_data_cache
worker.log 'notify', 'fetch overview_data changed - ' + cache_key
Sessions::CacheIn.set( cache_key, overview_data, { :expires_in => 5.seconds } )
end
end
}
end
def self.push( user, client )
overviews = Ticket::Overviews.all(
:current_user => user,
)
overviews.each { |overview|
cache_key = 'user_' + user.id.to_s + '_overview_data_' + overview.link
if !@@last_change[ user.id ]
@@last_change[ user.id ] = {}
end
overview_data_time = Sessions::CacheIn.get_time( cache_key, { :ignore_expire => true } )
if overview_data_time && @@last_change[ user.id ][overview.link] != overview_data_time
@@last_change[ user.id ][overview.link] = overview_data_time
overview_data = Sessions::CacheIn.get( cache_key, { :ignore_expire => true } )
client.log 'notify', "push overview_data #{overview.link} for user #{user.id}"
users = {}
tickets = {}
overview_data[:ticket_ids].each {|ticket_id|
client.ticket( ticket_id, tickets, users )
}
# get groups
group_ids = []
Group.where( :active => true ).each { |group|
group_ids.push group.id
}
agents = {}
Ticket::ScreenOptions.agents.each { |user|
agents[ user.id ] = 1
}
groups_users = {}
groups_users[''] = []
group_ids.each {|group_id|
groups_users[ group_id ] = []
Group.find(group_id).users.each {|user|
next if !agents[ user.id ]
groups_users[ group_id ].push user.id
if !users[user.id]
users[user.id] = User.user_data_full(user.id)
end
}
}
# send update to browser
client.send({
:data => {
User.to_online_model.to_sym => users,
Ticket.to_online_model.to_sym => tickets,
},
:event => [ 'loadAssets' ]
})
client.send({
:data => {
:overview => overview_data[:overview],
:ticket_ids => overview_data[:ticket_ids],
:tickets_count => overview_data[:tickets_count],
:bulk => {
:group_id__owner_id => groups_users,
:owner_id => [],
},
},
:event => [ 'ticket_overview_rebuild' ],
:collection => 'ticket_overview_' + overview.link.to_s,
})
end
}
end
end

56
lib/sessions/cache_in.rb Normal file
View file

@ -0,0 +1,56 @@
module Sessions::CacheIn
@@data = {}
@@data_time = {}
@@expires_in = {}
@@expires_in_ttl = {}
def self.set( key, value, params = {} )
# puts 'CacheIn.set:' + key + '-' + value.inspect
if params[:expires_in]
@@expires_in[key] = Time.now + params[:expires_in]
@@expires_in_ttl[key] = params[:expires_in]
end
@@data[ key ] = value
@@data_time[ key ] = Time.now
end
def self.expired( key, params = {} )
# expire if value never was set
return true if !@@data.include? key
# ignore_expire
return false if params[:ignore_expire]
# set re_expire
if params[:re_expire]
if @@expires_in[key]
@@expires_in[key] = Time.now + @@expires_in_ttl[key]
end
return false
end
# check if expired
if @@expires_in[key]
return true if @@expires_in[key] < Time.now
return false
end
# return false if key was set without expires_in
return false
end
def self.get_time( key, params = {} )
data = self.get( key, params )
if data
return @@data_time[key]
end
return nil
end
def self.get( key, params = {} )
# puts 'CacheIn.get:' + key + '-' + @@data[ key ].inspect
return if self.expired( key, params )
@@data[ key ]
end
end

165
lib/sessions/client.rb Normal file
View file

@ -0,0 +1,165 @@
class Sessions::Client
def initialize( client_id )
@client_id = client_id
@cache_key = ''
@data = {}
@pushed = {}
self.log 'notify', "---client start ws connection---"
self.fetch
self.log 'notify', "---client exiting ws connection---"
end
def fetch
loop_count = 0
while true
# get connection user
session_data = Sessions.get( @client_id )
return if !session_data
return if !session_data[:user]
return if !session_data[:user][:id]
user = User.lookup( :id => session_data[:user][:id] )
return if !user
# set cache key
@cache_key = 'user_' + user.id.to_s
loop_count += 1
self.log 'notice', "---client - looking for data of user #{user.id}"
# remember last run
Sessions::CacheIn.set( 'last_run_' + user.id.to_s , true, { :expires_in => 20.seconds } )
# verify already pushed data
if !Sessions::CacheIn.get( 'pushed_users' + @client_id.to_s )
Sessions::CacheIn.set( 'pushed_users' + @client_id.to_s , true, { :expires_in => 20.seconds } )
if @pushed[:users]
users = {}
@pushed[:users].each {|user_id, user_o|
self.user( user_id, users )
}
if !users.empty?
users.each {|user_id, user_data|
self.log 'notify', "push update of already pushed user id #{user_id}"
}
# send update to browser
self.send({
:data => {
:collections => {
User.to_online_model.to_sym => users,
},
},
:event => [ 'loadCollection', 'ticket_overview_rebuild' ],
});
end
end
end
# verify already pushed data
if !Sessions::CacheIn.get( 'pushed_tickets' + @client_id.to_s )
Sessions::CacheIn.set( 'pushed_tickets' + @client_id.to_s , true, { :expires_in => 20.seconds } )
if @pushed[:tickets]
tickets = {}
users = {}
@pushed[:tickets].each {|ticket_id, ticket_data|
self.ticket( ticket_id, tickets, users )
}
if !tickets.empty?
tickets.each {|id, ticket|
self.log 'notify', "push update of already pushed ticket id #{id}"
}
# send update to browser
self.send({
:data => {
:collections => {
Ticket.to_online_model.to_sym => tickets,
User.to_online_model.to_sym => users,
},
},
:event => [ 'loadCollection', 'ticket_overview_rebuild' ],
});
end
end
end
# overview
Sessions::Backend::TicketOverviewIndex.push( user, self )
# overview_data
Sessions::Backend::TicketOverviewList.push( user, self )
# ticket_create_attributes
Sessions::Backend::TicketCreate.push( user, self )
# recent viewed
Sessions::Backend::RecentViewed.push( user, self )
# activity stream
Sessions::Backend::ActivityStream.push( user, self )
# rss
Sessions::Backend::Rss.push( user, self )
# push_collections
Sessions::Backend::Collections.push( user, self )
self.log 'notice', "---/client-"
# start faster in the beginnig
if loop_count < 20
sleep 0.6
else
sleep 1
end
end
end
# add ticket if needed
def ticket( ticket_id, tickets, users )
if !@pushed[:tickets]
@pushed[:tickets] = {}
end
ticket = Ticket.lookup( :id => ticket_id )
if @pushed[:tickets][ticket_id] != ticket['updated_at']
@pushed[:tickets][ticket_id] = ticket['updated_at']
tickets[ticket_id] = ticket
end
# add users if needed
self.user( ticket['owner_id'], users )
self.user( ticket['customer_id'], users )
self.user( ticket['created_by_id'], users )
if ticket['updated_by_id']
self.user( ticket['updated_by_id'], users )
end
end
# add user if needed
def user( user_id, users )
if !@pushed[:users]
@pushed[:users] = {}
end
# get user
user = User.user_data_full( user_id )
# user is already on client and not changed
return if @pushed[:users][ user_id ] == user['updated_at']
@pushed[:users][user_id] = user['updated_at']
# user not on client or different
self.log 'notice', 'push user ... ' + user['login']
users[ user_id ] = user
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

58
lib/sessions/worker.rb Normal file
View file

@ -0,0 +1,58 @@
class Sessions::Worker
def initialize( user_id )
@user_id = user_id
@data = {}
@cache_key = 'user_' + user_id.to_s
self.log 'notify', "---user started user state"
Sessions::CacheIn.set( 'last_run_' + user_id.to_s , true, { :expires_in => 20.seconds } )
user = User.find( @user_id )
return if !user
self.fetch( user )
end
def fetch(user)
while true
# check if user is still with min one open connection
if !Sessions::CacheIn.get( 'last_run_' + user.id.to_s )
self.log 'notify', "---user - closeing thread - no open user connection"
return
end
self.log 'notice', "---user - fetch user data"
# overview
Sessions::Backend::TicketOverviewIndex.worker( user, self )
# overview lists
Sessions::Backend::TicketOverviewList.worker( user, self )
# create_attributes
Sessions::Backend::TicketCreate.worker( user, self )
# recent viewed
Sessions::Backend::RecentViewed.worker( user, self )
# activity steam
Sessions::Backend::ActivityStream.worker( user, self )
# rss
Sessions::Backend::Rss.worker( user, self )
# auto population of default collections
Sessions::Backend::Collections.worker( user, self )
self.log 'notice', "---/user-"
sleep 1
end
end
def log( level, data )
return if level == 'notice'
puts "#{Time.now}:user_id(#{ @user_id }) #{ data }"
end
end