Added a turbo stream for the current and next match on mat stats page.

test/models/match_broadcast_test.rb

@@ -0,0 +1,68 @@
+require 'test_helper'
+
+class MatchBroadcastTest < ActiveSupport::TestCase
+  include ActionView::RecordIdentifier
+
+  test "broadcasts to old and new mats when mat changes" do
+    create_double_elim_tournament_single_weight_1_6(4)
+    mat1 = @tournament.mats.create!(name: "Mat 1")
+    mat2 = @tournament.mats.create!(name: "Mat 2")
+    @tournament.matches.update_all(mat_id: nil)
+    match = @tournament.matches.first
+
+    # Set an initial mat
+    match.update!(mat: mat1)
+    stream1 = stream_name_for(mat1)
+    stream2 = stream_name_for(mat2)
+
+    # Clear the stream so we can test changes from this state
+    clear_streams(stream1, stream2)
+
+    # Update the mat and check the stream
+    match.update!(mat: mat2)
+    assert_equal [mat1.id, mat2.id], match.saved_change_to_mat_id
+
+    assert_equal 1, broadcasts_for(stream1).size
+    assert_equal 1, broadcasts_for(stream2).size
+
+    assert_includes broadcasts_for(stream2).last, dom_id(mat2, :current_match)
+  end
+
+  test "broadcasts when a match is removed from a mat" do
+    create_double_elim_tournament_single_weight_1_6(4)
+    mat = @tournament.mats.create!(name: "Mat 1")
+    @tournament.matches.update_all(mat_id: nil)
+    match = @tournament.matches.first
+
+    # Set an initial mat
+    match.update!(mat: mat)
+    stream = stream_name_for(mat)
+
+    # Clear the stream so we can test changes from this state
+    clear_streams(stream)
+
+    # Update the mat and check the stream
+    match.update!(mat: nil)
+    assert_equal [mat.id, nil], match.saved_change_to_mat_id
+
+    assert_equal 1, broadcasts_for(stream).size
+    assert_includes broadcasts_for(stream).last, dom_id(mat, :current_match)
+  end
+
+  private
+
+  def broadcasts_for(stream)
+    ActionCable.server.pubsub.broadcasts(stream)
+  end
+
+  def clear_streams(*streams)
+    ActionCable.server.pubsub.clear
+    streams.each do |stream|
+      broadcasts_for(stream).clear
+    end
+  end
+
+  def stream_name_for(streamable)
+    Turbo::StreamsChannel.send(:stream_name_from, [streamable])
+  end
+end