12604847790

Committed 03 Jan 2025 10:37PM UTC coverage: 79.346% (-0.1%) from 79.487%

Build # 12604847790

Build Type

push

github

Committed by

palkan

Commit Message

fix: anycable dependency

Run Details

344 of 565 branches covered (60.88%)

Branch coverage included in aggregate %.

1 of 1 new or added line in 1 file covered. (100.0%)

7 existing lines in 2 files now uncovered.

893 of 994 relevant lines covered (89.84%)

45.42 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

88.41

/lib/anycable/rails.rb

# frozen_string_literal: true

require "anycable"
require "anycable/rails/version"
require "anycable/rails/config"
require "anycable/rails/rack"

require "globalid"
require "active_support/core_ext/module/attribute_accessors_per_thread"

require "anycable/rails/ext"
require "anycable/rails/channel"

module AnyCable
  # Rails handler for AnyCable
  module Rails
    autoload :Helper, "anycable/rails/helper"
    autoload :PubSubChannel, "anycable/rails/pubsub_channel"

    require "anycable/rails/railtie"

    ADAPTER_ALIASES = %w[any_cable anycable].freeze

    thread_mattr_accessor :current_socket_id
    thread_mattr_accessor :current_broadcast_options

    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

      def with_socket_id(socket_id)
        old_socket_id, self.current_socket_id = current_socket_id, socket_id
        yield
      ensure
        self.current_socket_id = old_socket_id
      end

      def with_broadcast_options(**options)
        old_options = current_broadcast_options
        self.current_broadcast_options = options.reverse_merge(old_options || {})
        yield
      ensure
        self.current_broadcast_options = old_options
      end

      def broadcasting_to_others(socket_id: nil, &block)
        if socket_id
          with_socket_id(socket_id) { with_broadcast_options(to_others: true, &block) }
        else
          with_broadcast_options(to_others: true, &block)
        end
      end

      def signed_stream_name(streamables)
        Streams.signed(stream_name_from(streamables))
      end

      def stream_name_from(streamables)
        if streamables.is_a?(Array)
          streamables.map { |streamable| stream_name_from(streamable) }.join(":")
        else
          streamables.then { |streamable| streamable.try(:to_gid_param) || streamable.to_param }
        end
      end

      module Extension
        def broadcast(...)
          super
          ::AnyCable.broadcast(...)
        end
      end

      def extend_adapter!(adapter)
        adapter.extend(Extension)
      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&.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

1	# frozen_string_literal: true
2
3	require "anycable"	12✔
4	require "anycable/rails/version"	12✔
5	require "anycable/rails/config"	12✔
6	require "anycable/rails/rack"	12✔
7
8	require "globalid"	12✔
9	require "active_support/core_ext/module/attribute_accessors_per_thread"	12✔
10
11	require "anycable/rails/ext"	12✔
12	require "anycable/rails/channel"	12✔
13
14	module AnyCable	12✔
15	# Rails handler for AnyCable
16	module Rails	12✔
17	autoload :Helper, "anycable/rails/helper"	12✔
18	autoload :PubSubChannel, "anycable/rails/pubsub_channel"	12✔
19
20	require "anycable/rails/railtie"	12✔
21
22	ADAPTER_ALIASES = %w[any_cable anycable].freeze	12✔
23
24	thread_mattr_accessor :current_socket_id	12✔
25	thread_mattr_accessor :current_broadcast_options	12✔
26
27	class << self	12✔
28	def enabled?	12✔
29	adapter = ::ActionCable.server.config.cable&.fetch("adapter", nil)	30!
30	compatible_adapter?(adapter)	30✔
31	end
32
33	def compatible_adapter?(adapter)	12✔
34	ADAPTER_ALIASES.include?(adapter)	30✔
35	end
36
37	def with_socket_id(socket_id)	12✔
38	old_socket_id, self.current_socket_id = current_socket_id, socket_id	396✔
39	yield	396✔
40	ensure
41	self.current_socket_id = old_socket_id	396✔
42	end
43
44	def with_broadcast_options(**options)	12✔
45	old_options = current_broadcast_options	42✔
46	self.current_broadcast_options = options.reverse_merge(old_options \|\| {})	42✔
47	yield	42✔
48	ensure
49	self.current_broadcast_options = old_options	42✔
50	end
51
52	def broadcasting_to_others(socket_id: nil, &block)	12✔
53	if socket_id	12✔
54	with_socket_id(socket_id) { with_broadcast_options(to_others: true, &block) }	12✔
55	else	3✔
56	with_broadcast_options(to_others: true, &block)	6✔
57	end
58	end
59
60	def signed_stream_name(streamables)	12✔
61	Streams.signed(stream_name_from(streamables))	6✔
62	end
63
64	def stream_name_from(streamables)	12✔
65	if streamables.is_a?(Array)	132✔
66	streamables.map { \|streamable\| stream_name_from(streamable) }.join(":")	48✔
67	else	60✔
68	streamables.then { \|streamable\| streamable.try(:to_gid_param) \|\| streamable.to_param }	240✔
69	end
70	end
71
72	module Extension	12✔
73	def broadcast(...)	12✔
74	super	6✔
75	::AnyCable.broadcast(...)	6✔
76	end
77	end
78
79	def extend_adapter!(adapter)	12✔
80	adapter.extend(Extension)	6✔
81	end
82	end
83	end
84	end
85
86	# Warn if application has been already initialized.
87	# AnyCable should be loaded before initialization in order to work correctly.
88	if defined?(::Rails) && ::Rails.application&.initialized?	12!
89	puts("\n**************************************************")	×
UNCOV 90	puts(	×
91	"⛔️ WARNING: AnyCable loaded after application initialization. Might not work correctly.\n" \
92	"Please, make sure to remove `require: false` in your Gemfile or " \
93	"require manually in `environment.rb` before `Rails.application.initialize!`"
94	)
UNCOV 95	puts("**************************************************\n\n")	×
96	end

anycable / anycable-rails / 12604847790

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous