reaper_test.go

package kdone

import (
	"testing"

	"github.com/go-kata/kerror"
)

type testObjectInitializer = func(t *testing.T, c *int, value int) (int, Destructor, error)

func newTestObject(t *testing.T, c *int, value int) (int, Destructor, error) {
	t.Logf("test object (%d) was initialized", value)
	return value, DestructorFunc(func() error {
		*c -= value
		t.Logf("test object (%d) was finalized", value)
		return nil
	}), nil
}

func newTestObjectWithError(t *testing.T, c *int, value int) (int, Destructor, error) {
	t.Logf("test object (%d) was initialized (but will not be finalized...)", value)
	return value, DestructorFunc(func() error {
		*c -= value
		t.Logf("test object (%d) was finalized", value)
		return nil
	}), kerror.New(kerror.Label("test.Error"), "test error")
}

func newTestObjectWithPanic(t *testing.T, c *int, value int) (int, Destructor, error) {
	t.Logf("test object (%d) was initialized (but will not be finalized...)", value)
	kerror.Panic("keep calm, this is a test panic")
	return value, DestructorFunc(func() error {
		*c -= value
		t.Logf("test object (%d) was finalized", value)
		return nil
	}), nil
}

func newTestObjectWithPanicInDestructor(t *testing.T, c *int, value int) (int, Destructor, error) {
	t.Logf("test object (%d) was initialized", value)
	return value, DestructorFunc(func() error {
		*c -= value
		t.Logf("test object (%d) was finalized (and panic now, boo!)", value)
		kerror.Panic("keep calm, this is a test panic")
		return nil
	}), nil
}

func newTestCompositeObject(t *testing.T, e testObjectInitializer, c *int, values ...int) (int, Destructor, error) {
	reaper := NewReaper()
	defer reaper.MustFinalize()
	sum := 0
	for _, value := range values {
		obj, dtor, err := newTestObject(t, c, value)
		if err != nil {
			return 0, nil, err
		}
		reaper.MustAssume(dtor)
		sum += obj
	}
	if e != nil {
		obj, dtor, err := e(t, c, 1000)
		if err != nil {
			return 0, nil, err
		}
		reaper.MustAssume(dtor)
		sum += obj
	}
	return sum, reaper.MustRelease(), nil
}

func TestReaper(t *testing.T) {
	var c int
	defer func() {
		if c != -6 {
			t.Fail()
			return
		}
	}()
	obj, dtor, err := newTestCompositeObject(t, nil, &c, 1, 2, 3)
	if err != nil {
		t.Fail()
		return
	}
	defer dtor.MustDestroy()
	if c != 0 {
		t.Fail()
		return
	}
	if obj != 6 {
		t.Fail()
		return
	}
}

func TestReaper__Error(t *testing.T) {
	var c int
	_, _, err := newTestCompositeObject(t, newTestObjectWithError, &c, 1, 2, 3)
	if err == nil {
		t.Fail()
		return
	}
	if c != -6 {
		t.Fail()
		return
	}
	t.Logf("%+v", err)
}

func TestReaper__Panic(t *testing.T) {
	var c int
	defer func() {
		if c != -6 {
			t.Fail()
			return
		}
		v := recover()
		t.Logf("%+v", v)
		if v == nil {
			t.Fail()
			return
		}
		err, ok := v.(error)
		if !ok {
			t.Fail()
			return
		}
		if kerror.ClassOf(err) != kerror.EPanic || kerror.MessageOf(err) != "keep calm, this is a test panic" {
			t.Fail()
			return
		}
	}()
	_, _, _ = newTestCompositeObject(t, newTestObjectWithPanic, &c, 1, 2, 3)
}

func TestReaper__PanicInDestructor(t *testing.T) {
	var c int
	defer func() {
		if c != -1006 {
			t.Fail()
			return
		}
	}()
	obj, dtor, err := newTestCompositeObject(t, newTestObjectWithPanicInDestructor, &c, 1, 2, 3)
	if err != nil {
		t.Fail()
		return
	}
	defer func() {
		dtorErr := dtor.Destroy()
		t.Logf("%+v", dtorErr)
		if dtorErr == nil {
			t.Fail()
			return
		}
	}()
	if c != 0 {
		t.Fail()
		return
	}
	if obj != 1006 {
		t.Fail()
		return
	}
}

func TestReaper_Assume__NilDestructor(t *testing.T) {
	reaper := NewReaper()
	err := reaper.Assume(nil)
	t.Logf("%+v", err)
	if kerror.ClassOf(err) != kerror.EInvalid {
		t.Fail()
		return
	}
}

func TestReaper_Assume__Released(t *testing.T) {
	reaper := NewReaper()
	reaper.MustRelease()
	err := reaper.Assume(Noop)
	t.Logf("%+v", err)
	if kerror.ClassOf(err) != kerror.EIllegal {
		t.Fail()
		return
	}
}

func TestReaper_Assume__Finalized(t *testing.T) {
	reaper := NewReaper()
	reaper.MustFinalize()
	err := reaper.Assume(Noop)
	t.Logf("%+v", err)
	if kerror.ClassOf(err) != kerror.EIllegal {
		t.Fail()
		return
	}
}

func TestReaper_Release__Released(t *testing.T) {
	reaper := NewReaper()
	reaper.MustRelease()
	_, err := reaper.Release()
	t.Logf("%+v", err)
	if kerror.ClassOf(err) != kerror.EIllegal {
		t.Fail()
		return
	}
}

func TestReaper_Release__Finalized(t *testing.T) {
	reaper := NewReaper()
	reaper.MustFinalize()
	_, err := reaper.Release()
	t.Logf("%+v", err)
	if kerror.ClassOf(err) != kerror.EIllegal {
		t.Fail()
		return
	}
}

func TestReaper_Released(t *testing.T) {
	reaper := NewReaper()
	reaper.MustRelease()
	if !reaper.Released() {
		t.Fail()
		return
	}
}

func TestReaper_Finalize__Released(t *testing.T) {
	var c int
	reaper := NewReaper()
	reaper.MustAssume(DestructorFunc(func() error {
		c--
		return nil
	}))
	reaper.MustRelease()
	reaper.MustFinalize()
	if c != 0 {
		t.Fail()
		return
	}
}

func TestReaper_Finalize__Finalized(t *testing.T) {
	reaper := NewReaper()
	reaper.MustFinalize()
	err := reaper.Finalize()
	t.Logf("%+v", err)
	if kerror.ClassOf(err) != kerror.EIllegal {
		t.Fail()
		return
	}
}

func TestReaper_Finalized(t *testing.T) {
	reaper := NewReaper()
	reaper.MustFinalize()
	if !reaper.Finalized() {
		t.Fail()
		return
	}
}

func TestNilReaper_Assume(t *testing.T) {
	err := (*Reaper)(nil).Assume(Noop)
	t.Logf("%+v", err)
	if kerror.ClassOf(err) != kerror.ENil {
		t.Fail()
		return
	}
}

func TestNilReaper_Release(t *testing.T) {
	dtor, err := (*Reaper)(nil).Release()
	f, ok := dtor.(DestructorFunc)
	if !ok {
		t.Fail()
		return
	}
	if err := f.Destroy(); err != nil {
		t.Logf("%+v", err)
		t.Fail()
		return
	}
	if err != nil {
		t.Logf("%+v", err)
		t.Fail()
		return
	}
}

func TestNilReaper_Released(t *testing.T) {
	if (*Reaper)(nil).Released() {
		t.Fail()
		return
	}
}

func TestNilReaper_Finalize(t *testing.T) {
	if err := (*Reaper)(nil).Finalize(); err != nil {
		t.Logf("%+v", err)
		t.Fail()
		return
	}
}

func TestNilReaper_Finalized(t *testing.T) {
	if (*Reaper)(nil).Finalized() {
		t.Fail()
		return
	}
}