Sha256: 0f8df09bdce2d53a208a5bcc74b1805e559e8f5d56a4aef1d25c2a1067ce4101
Contents?: true
Size: 1.07 KB
Versions: 23
Compression:
Stored size: 1.07 KB
Contents
# frozen_string_literal: true
require "anycable/rails/connection"
module AnyCable
module Rails
class ConnectionFactory
def initialize(&block)
@mappings = []
@use_router = false
instance_eval(&block) if block
end
def call(socket, **options)
connection_class = use_router? ? resolve_connection_class(socket.env) :
ActionCable.server.config.connection_class.call
AnyCable::Rails::Connection.new(connection_class, socket, **options)
end
def map(route, &block)
raise ArgumentError, "Block is required" unless block
@use_router = true
mappings << [route, block]
end
private
attr_reader :mappings, :use_router
alias_method :use_router?, :use_router
def resolve_connection_class(env)
path = env["PATH_INFO"]
mappings.each do |(prefix, resolver)|
return resolver.call if path.starts_with?(prefix)
end
raise "No connection class found matching #{path}"
end
end
end
end
Version data entries
23 entries across 23 versions & 2 rubygems