module AnyCable::Rails

def compatible_adapter?(adapter)
  ADAPTER_ALIASES.include?(adapter)
end

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

def enabled?
  adapter = ::ActionCable.server.config.cable&.fetch("adapter", nil)
  compatible_adapter?(adapter)
end

def extend_adapter!(adapter)
  adapter.extend(Extension)
end

def fetch(identifier)
  add("identifier" => identifier) unless subscriptions[identifier]
  unless subscriptions[identifier]
    raise "Channel not found: #{ActiveSupport::JSON.decode(identifier).fetch("channel")}"
  end
  subscriptions[identifier]
end

def public_request
  request
end

def rejected?
  subscription_rejected?
end

def send_welcome_message
  transmit({
    type: ActionCable::INTERNAL[:message_types][:welcome],
    sid: env["anycable.sid"]
  }.compact)
end

def serialize(obj, json: false)
  obj.try(:to_gid_param) || (json ? obj.to_json : obj)
end