Contents

# frozen_string_literal: true

require_relative "../test_helper"

class StimulusReflex::BroadcasterTestCase < ActionCable::Channel::TestCase
  tests StimulusReflex::Channel

  def assert_broadcast_on(stream, data, &block)
    serialized_msg = ActiveSupport::JSON.decode(ActiveSupport::JSON.encode(data))

    new_messages = broadcasts(stream)
    if block
      old_messages = new_messages
      clear_messages(stream)

      yield
      new_messages = broadcasts(stream)
      clear_messages(stream)

      (old_messages + new_messages).each { |m| pubsub_adapter.broadcast(stream, m) }
    end

    message = new_messages.find { |msg| ActiveSupport::JSON.decode(msg) == serialized_msg }

    unless message
      puts "\n\n#{ActiveSupport::JSON.decode(new_messages.first)}\n#{data}\n\n"
    end

    assert message, "No messages sent with #{data} to #{stream}"
  end

  setup do
    stub_connection(session_id: SecureRandom.uuid)
    def connection.env
      @env ||= {}
    end
    @reflex = StimulusReflex::Reflex.new(subscribe, url: "https://test.stimulusreflex.com", client_attributes: {reflex_id: "666"})
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
stimulus_reflex-3.5.0.pre8	test/broadcasters/broadcaster_test_case.rb
stimulus_reflex-3.5.0.pre7	test/broadcasters/broadcaster_test_case.rb
stimulus_reflex-3.5.0.pre6	test/broadcasters/broadcaster_test_case.rb
stimulus_reflex-3.5.0.pre5	test/broadcasters/broadcaster_test_case.rb
stimulus_reflex-3.5.0.pre4	test/broadcasters/broadcaster_test_case.rb
stimulus_reflex-3.5.0.pre3	test/broadcasters/broadcaster_test_case.rb