Sha256: 1509390f3b32ed7f11e0d83e7972db4d10226886918441bc72cae8853adf18c9

Contents?: true

Size: 1.46 KB

Versions: 5

Compression:

Stored size: 1.46 KB

Contents

# frozen_string_literal: true

# :markup: markdown

module ActionCable
  module Connection
    module Identification
      extend ActiveSupport::Concern

      included do
        class_attribute :identifiers, default: Set.new
      end

      module ClassMethods
        # Mark a key as being a connection identifier index that can then be used to
        # find the specific connection again later. Common identifiers are current_user
        # and current_account, but could be anything, really.
        #
        # Note that anything marked as an identifier will automatically create a
        # delegate by the same name on any channel instances created off the connection.
        def identified_by(*identifiers)
          Array(identifiers).each { |identifier| attr_accessor identifier }
          self.identifiers += identifiers
        end
      end

      # Return a single connection identifier that combines the value of all the
      # registered identifiers into a single gid.
      def connection_identifier
        unless defined? @connection_identifier
          @connection_identifier = connection_gid identifiers.filter_map { |id| instance_variable_get("@#{id}") }
        end

        @connection_identifier
      end

      private
        def connection_gid(ids)
          ids.map do |o|
            if o.respond_to? :to_gid_param
              o.to_gid_param
            else
              o.to_s
            end
          end.sort.join(":")
        end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version Path
actioncable-8.0.1 lib/action_cable/connection/identification.rb
actioncable-8.0.0.1 lib/action_cable/connection/identification.rb
actioncable-8.0.0 lib/action_cable/connection/identification.rb
actioncable-8.0.0.rc2 lib/action_cable/connection/identification.rb
actioncable-8.0.0.rc1 lib/action_cable/connection/identification.rb