Contents

require 'json'
require 'sockjs/session'

class SocketConnectionHandler < SockJS::Session
  # Create one instance of the dispatcher
  
  def self.dispatcher=(val)
    @@dispatcher = val
  end
  
  def self.dispatcher
    @@dispatcher
  end
  
  # Sends a message to all, optionally skipping a users channel
  def self.send_message_all(skip_channel=nil, *args)
    @@channels.each do |channel|
      if skip_channel && channel == skip_channel
        next
      end
      channel.send_message(*args)
    end
    
  end
  
  def initialize(session, *args)
    @session = session

    @@channels ||= []
    @@channels << self
    
    super
  end
  
  def process_message(message)
    # self.class.message_all(message)
    # Messages are json and wrapped in an array
    message = JSON.parse(message).first
    
    @@dispatcher.dispatch(self, message)
  end
  
  def send_message(*args)
    str = JSON.dump([*args])
    
    send(str)
  end
  
  def closed
    puts "CHANNEL CLOSED: #{self.inspect}"
    # Remove ourself from the available channels
    @@channels.delete(self)

    QueryTasks.new(self).close!
  end
  
  def inspect
    "<#{self.class.to_s}:#{object_id}>"
  end

end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
volt-0.6.5	lib/volt/server/socket_connection_handler.rb
volt-0.6.4	lib/volt/server/socket_connection_handler.rb
volt-0.6.3	lib/volt/server/socket_connection_handler.rb
volt-0.6.2	lib/volt/server/socket_connection_handler.rb
volt-0.6.1	lib/volt/server/socket_connection_handler.rb
volt-0.6.0	lib/volt/server/socket_connection_handler.rb