# frozen_string_literal: true

require_relative 'helper'

class SuperviseTest < MiniTest::Test
  def test_supervise_with_block
    buffer = []
    f1 = spin(:f1) { receive }
    f2 = spin(:f2) { receive }
    supervisor = spin(:supervisor) { supervise(f1, f2) { |*args| buffer << args } }

    snooze
    f1 << 'foo'
    f1.await
    10.times { snooze }
    assert_equal [[f1, 'foo']], buffer

    f2 << 'bar'
    f2.await
    assert_equal [[f1, 'foo'], [f2, 'bar']], buffer
  end

  def test_supervise_with_on_done
    buffer = []
    f1 = spin(:f1) { receive }
    f2 = spin(:f2) { receive }
    supervisor = spin(:supervisor) do
      supervise(f1, f2, on_done: ->(*args) { buffer << args })
    end

    snooze
    f1 << 'foo'
    f1.await
    10.times { snooze }
    assert_equal [[f1, 'foo']], buffer

    f2 << 'bar'
    f2.await
    assert_equal [[f1, 'foo'], [f2, 'bar']], buffer
  end

  def test_supervise_with_on_error
    buffer = []
    f1 = spin(:f1) { receive }
    f2 = spin(:f2) { receive }
    supervisor = spin(:supervisor) do
      supervise(f1, f2, on_error: ->(*args) { buffer << args })
    end

    snooze
    f1 << 'foo'
    f1.await
    10.times { snooze }
    assert_equal [], buffer

    e = RuntimeError.new('blah')
    f2.raise(e)
    3.times { snooze }
    assert_equal [[f2, e]], buffer
  end

  def test_supervise_with_manual_restart
    buffer = []
    f1 = spin(:f1) { receive }
    supervisor = spin(:supervisor) do
      supervise(f1) do |f, r|
        buffer << [f, r]
        f.restart
      end
    end

    snooze
    f1 << 'foo'
    f1.await
    snooze
    assert_equal [[f1, 'foo']], buffer

    10.times { snooze }

    assert_equal 1, supervisor.children.size
    f2 = supervisor.children.first
    assert f1 != f2
    assert_equal :f1, f2.tag
    assert_equal supervisor, f2.parent

    e = RuntimeError.new('bar')
    f2.raise(e)
    f2.await rescue nil
    3.times { snooze }
    assert_equal [[f1, 'foo'], [f2, e]], buffer

    assert_equal 1, supervisor.children.size
    f3 = supervisor.children.first
    assert f2 != f3
    assert f1 != f3
    assert_equal :f1, f3.tag
    assert_equal supervisor, f3.parent
  end

  def test_supervise_with_restart_always
    buffer = []
    f1 = spin(:f1) do
      buffer << receive
    rescue => e
      buffer << e
      e
    end
    supervisor = spin(:supervisor) { supervise(f1, restart: :always) }

    snooze
    f1 << 'foo'
    f1.await
    snooze
    assert_equal ['foo'], buffer

    10.times { snooze }

    assert_equal 1, supervisor.children.size
    f2 = supervisor.children.first
    assert f1 != f2
    assert_equal :f1, f2.tag
    assert_equal supervisor, f2.parent

    e = RuntimeError.new('bar')
    f2.raise(e)
    f2.await rescue nil
    3.times { snooze }
    assert_equal ['foo', e], buffer

    assert_equal 1, supervisor.children.size
    f3 = supervisor.children.first
    assert f2 != f3
    assert f1 != f3
    assert_equal :f1, f3.tag
    assert_equal supervisor, f3.parent
  end

  def test_supervise_with_restart_true
    buffer = []
    f1 = spin(:f1) do
      buffer << receive
    rescue => e
      buffer << e
      e
    end
    supervisor = spin(:supervisor) { supervise(f1, restart: true) }

    snooze
    f1 << 'foo'
    f1.await
    snooze
    assert_equal ['foo'], buffer

    10.times { snooze }

    assert_equal 1, supervisor.children.size
    f2 = supervisor.children.first
    assert f1 != f2
    assert_equal :f1, f2.tag
    assert_equal supervisor, f2.parent

    e = RuntimeError.new('bar')
    f2.raise(e)
    f2.await rescue nil
    3.times { snooze }
    assert_equal ['foo', e], buffer

    assert_equal 1, supervisor.children.size
    f3 = supervisor.children.first
    assert f2 != f3
    assert f1 != f3
    assert_equal :f1, f3.tag
    assert_equal supervisor, f3.parent
  end

  def test_supervise_with_restart_on_error
    buffer = []
    f1 = spin(:f1) do
      buffer << receive
    rescue => e
      buffer << e
      e
    end
    supervisor = spin(:supervisor) { supervise(f1, restart: :on_error) }

    snooze
    e = RuntimeError.new('bar')
    f1.raise(e)
    f1.await rescue nil
    snooze
    assert_equal [e], buffer

    10.times { snooze }

    assert_equal 1, supervisor.children.size
    f2 = supervisor.children.first
    assert f1 != f2
    assert_equal :f1, f2.tag
    assert_equal supervisor, f2.parent

    f2 << 'foo'
    f2.await rescue nil
    3.times { snooze }
    assert_equal [e, 'foo'], buffer

    assert_equal 0, supervisor.children.size
  end

  def test_supervise_terminate
    buffer = []
    f1 = spin(:f1) do
      buffer << receive
    rescue => e
      buffer << e
      e
    end
    supervisor = spin(:supervisor) { supervise(f1, restart: :on_error) }

    sleep 0.05
    supervisor.terminate
    supervisor.await

    assert_equal [], buffer
  end

  def test_supervise_without_explicit_fibers
    buffer = []
    first = nil
    supervisor = spin do
      3.times do |i|
        f = spin do
          first = Fiber.current if i == 0
          receive
          buffer << i
        end
      end
      Fiber.current.parent << :ok
      supervise(restart: :always)
    end
    msg = receive
    assert_equal :ok, msg
    assert_equal 3, supervisor.children.size

    sleep 0.1
    assert_equal [], buffer

    old_first = first
    first << :foo
    first = nil
    snooze
    assert_equal [0], buffer

    snooze
    assert_equal 3, supervisor.children.size
    snooze
    assert first
    assert first != old_first
  end

  def test_supervise_with_added_fibers
    buffer = []
    supervisor = spin do
      supervise { |f, r| buffer << [f, r] }
    end
    snooze
    f1 = supervisor.spin { snooze; :foo }
    f2 = supervisor.spin { snooze; :bar }
    Fiber.await(f1, f2)
    snooze
    assert_equal [[f1, :foo], [f2, :bar]], buffer
  end

  def test_detached_supervisor
    buffer = []

    s = nil
    f = spin {
      foo = spin do
        sleep 0.1
      ensure
        buffer << :foo
      end
      bar = spin do
        sleep 0.2
      ensure
        buffer << :bar
      end

      s = spin { supervise }.detach
      Fiber.current.attach_all_children_to(s)

      s.terminate(true)
    }

    f.await
    s.await
    assert_equal [:foo, :bar], buffer
  end
end