Sha256: 4b69c7af5d320209c6a6a94849aab571e407124800973c720794e417c9eca563
Contents?: true
Size: 1.92 KB
Versions: 21
Compression:
Stored size: 1.92 KB
Contents
# frozen_string_literal: true
require "anycable"
require "anycable/rails/version"
require "anycable/rails/config"
require "anycable/rails/rack"
require "globalid"
module AnyCable
# Rails handler for AnyCable
module Rails
require "anycable/rails/railtie"
ADAPTER_ALIASES = %w[any_cable anycable].freeze
class << self
def enabled?
adapter = ::ActionCable.server.config.cable&.fetch("adapter", nil)
compatible_adapter?(adapter)
end
def compatible_adapter?(adapter)
ADAPTER_ALIASES.include?(adapter)
end
# Serialize connection/channel state variable to string
# using GlobalID where possible or JSON (if json: true)
def serialize(obj, json: false)
obj.try(:to_gid_param) || (json ? obj.to_json : obj)
end
# Deserialize previously serialized value from string to
# Ruby object.
# If the resulting object is a Hash, make it indifferent
def deserialize(str, json: false)
str.yield_self do |val|
next val unless val.is_a?(String)
gval = GlobalID::Locator.locate(val)
return gval if gval
next val unless json
JSON.parse(val)
end.yield_self do |val|
next val.with_indifferent_access if val.is_a?(Hash)
val
end
end
end
end
end
# Warn if application has been already initialized.
# AnyCable should be loaded before initialization in order to work correctly.
if defined?(::Rails) && ::Rails.application && ::Rails.application.initialized?
puts("\n**************************************************")
puts(
"⛔️ WARNING: AnyCable loaded after application initialization. Might not work correctly.\n"\
"Please, make sure to remove `require: false` in your Gemfile or "\
"require manually in `environment.rb` before `Rails.application.initialize!`"
)
puts("**************************************************\n\n")
end
Version data entries
21 entries across 21 versions & 1 rubygems