zammad/lib/sessions/client.rb

class Sessions::Client

  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

    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]
      return if !session_data[:user][:id]
      user = User.lookup( :id => session_data[:user][:id] )
      return if !user

      # init new backends
      if user_id_last_run != user.id
        user_id_last_run = user.id

        # release old objects
        backend_pool.each {|pool|
          pool = nil
        }

        # create new pool
        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}"

      # 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