aboutsummaryrefslogblamecommitdiffstats
path: root/lib/action_cable/server.rb
blob: 222c77fd512060568d7600d98fd0b6f06fd74b74 (plain) (tree)
1
2
3
4
5
6
7
8
9

                  

                                                                   
                                                     
 


                                                                                           
                                          
                                    

       

                                              

       



                                                                        

                                                                  

       



                                                         



                                   

     
module ActionCable
  class Server
    cattr_accessor(:logger, instance_reader: true) { Rails.logger }

    attr_accessor :registered_channels, :redis_config

    def initialize(redis_config:, channels:, worker_pool_size: 100, connection: Connection)
      @redis_config = redis_config
      @registered_channels = Set.new(channels)
      @worker_pool_size = worker_pool_size
      @connection_class = connection
    end

    def call(env)
      @connection_class.new(self, env).process
    end

    def worker_pool
      @worker_pool ||= ActionCable::Worker.pool(size: @worker_pool_size)
    end

    def pubsub
      @pubsub ||= EM::Hiredis.connect(@redis_config['url']).pubsub
    end

    def remote_connections
      @remote_connections ||= RemoteConnections.new(self)
    end

    def connection_identifiers
      @connection_class.identifiers
    end

  end
end