zammad/lib/sessions/event/spool.rb

# Copyright (C) 2012-2022 Zammad Foundation, https://zammad-foundation.org/

class Sessions::Event::Spool < Sessions::Event::Base

=begin

Event module to serve spool messages and send them to new client connection.

To execute this manually, just paste the following into the browser console

  App.WebSocket.send({event:'spool'})

=end

  def run

    # error handling
    if @payload['timestamp']
      log 'info', "request spool data > '#{Time.at(@payload['timestamp']).utc.iso8601}'"
    else
      log 'info', 'request spool with init data'
    end

    if !@session || !@session['id']
      log 'error', "Can't send spool, session not authenticated"
      return {
        event: 'error',
        data:  {
          error: __('Can\'t send spool, session not authenticated'),
        },
      }
    end

    spool = Sessions.spool_list(@payload['timestamp'], @session['id'])
    spool.each do |item|

      # create new msg to push to client
      if item[:type] == 'direct'
        log 'info', "send spool to (user_id=#{@session['id']})"
      else
        log 'info', 'send spool'
      end
      websocket_send(@client_id, item[:message])
    end

    # send spool:sent event to client
    log 'info', 'send spool:sent event'
    {
      event: 'spool:sent',
      data:  {
        timestamp: Time.now.utc.to_i,
      },
    }
  end

end