Contents

# frozen_string_literal: true

require "action_cable"
require "anycable/rails/connections/serializable_identification"

ActionCable::Connection::Base.include(AnyCable::Rails::Connections::SerializableIdentification)
ActionCable::Connection::Base.prepend(Module.new do
  def anycabled?
    anycable_socket
  end

  # Allow overriding #subscriptions to use a custom implementation
  attr_writer :subscriptions

  # Alias for the #socket which is only set within AnyCable RPC context
  attr_accessor :anycable_socket

  # Enhance #send_welcome_message to include sid if present
  def send_welcome_message
    transmit({
      type: ActionCable::INTERNAL[:message_types][:welcome],
      sid: env["anycable.sid"]
    }.compact)
  end

  def subscribe_to_internal_channel
    super unless anycabled?
  end
end)

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
anycable-rails-core-1.5.6	lib/anycable/rails/next/action_cable_ext/connection.rb
anycable-rails-core-1.6.0.rc.1	lib/anycable/rails/next/action_cable_ext/connection.rb
anycable-rails-core-1.5.5	lib/anycable/rails/next/action_cable_ext/connection.rb
anycable-rails-core-1.5.4	lib/anycable/rails/next/action_cable_ext/connection.rb