bootsnap/test/load_path_cache/change_observer_test.rb

# frozen_string_literal: true

require("test_helper")

module Bootsnap
  module LoadPathCache
    class ChangeObserverTest < Minitest::Test
      include LoadPathCacheHelper

      def setup
        super
        @observer = Object.new
        @observer.instance_variable_set(:@mutex, Mutex.new)
        @arr = []
        ChangeObserver.register(@arr, @observer)
      end

      def test_observes_changes
        @observer.expects(:push_paths).with(@arr, "a")
        @arr << "a"

        @observer.expects(:push_paths).with(@arr, "b", "c")
        @arr.push("b", "c")

        @observer.expects(:push_paths).with(@arr, "d", "e")
        @arr.append("d", "e")

        @observer.expects(:unshift_paths).with(@arr, "f", "g")
        @arr.unshift("f", "g")

        @observer.expects(:push_paths).with(@arr, "h", "i")
        @arr.push("h", "i")

        @observer.expects(:unshift_paths).with(@arr, "j", "k")
        @arr.prepend("j", "k")
      end

      def test_unregister
        @observer.expects(:push_paths).never
        @observer.expects(:unshift_paths).never
        @observer.expects(:reinitialize).never

        ChangeObserver.unregister(@arr)

        @arr << "a"
        @arr.push("b", "c")
        @arr.append("d", "e")
        @arr.unshift("f", "g")
        @arr.push("h", "i")
        @arr.prepend("j", "k")
        @arr.delete(3)
        @arr.compact!
        @arr.map!(&:upcase)
        assert_equal %w(J K F G A B C D E H I), @arr
      end

      def test_reinitializes_on_aggressive_modifications
        @observer.expects(:push_paths).with(@arr, "a", "b", "c")
        @arr.push("a", "b", "c")

        @observer.expects(:reinitialize).times(4)
        @arr.delete(3)
        @arr.compact!
        @arr.map!(&:upcase)
        assert_equal("C", @arr.pop)
        assert_equal(%w(A B), @arr)
      end

      def test_register_frozen
        # just assert no crash
        ChangeObserver.register(@arr.dup.freeze, @observer)
      end

      def test_register_twice_observes_once
        ChangeObserver.register(@arr, @observer)

        @observer.expects(:push_paths).with(@arr, "a").once
        @arr << "a"
        assert_equal(%w(a), @arr)
      end

      def test_dup_returns_ractor_shareable_instance
        return unless defined?(Ractor)

        ChangeObserver.register(@arr, @observer)
        Ractor.make_shareable(@arr.dup.freeze)
      end

      def test_clone_returns_ractor_shareable_instance
        return unless defined?(Ractor)

        ChangeObserver.register(@arr, @observer)
        Ractor.make_shareable(@arr.clone.freeze)
      end

      def test_uniq_without_block
        @observer.expects(:reinitialize).never
        @arr.uniq!
      end

      def test_uniq_with_block
        @observer.expects(:reinitialize).once
        @arr.uniq! { |i| i }
      end
    end
  end
end