gofer_test.go

package gofer

import (
	"testing"
)

func TestManualIndex(t *testing.T) {
	manual := manual([]*Task{&Task{Label: "one", manual: []*Task{&Task{Label: "two", manual: []*Task{&Task{Label: "three"}}}}}})
	task := manual.index("one:two:three")

	if nil == task || "three" != task.Label {
		t.Errorf(`Expected label of nested tast to be "three", got %s.`, task)
	}
}

func TestManualSectionalize(t *testing.T) {
	manual := make(manual, 0)
	manual.sectionalize("one:two:three")

	task := manual.index("one:two:three")

	if nil == task {
		t.Error(`Unable to find task created during call to sectionalize.`)
	} else if "one:two" != task.Namespace || "three" != task.Label {
		t.Errorf(`Tasks was not created properly during call to sectionalize,`+
			` wanted "one:two" & "three", got "%s" & "%s".`, task.Namespace, task.Label)
	}
}

func TestRegister(t *testing.T) {
	task := Task{
		Namespace: "one:two",
		Label:     "three",
	}

	Register(task)

	stored := gofer.index("one:two:three")
	parent := gofer.index("one:two")

	if nil == stored || nil == parent {
		t.Error(`Register failed to create and store task.`)
	} else if "one:two" != stored.Namespace || "three" != stored.Label {
		t.Errorf(`Register failed to store task properly, expected Namespace to be "one:two"`+
			` & Label to be "three", got %s & %s.`, stored.Namespace, stored.Label)
	} else if "one" != parent.Namespace || "two" != parent.Label {
		t.Errorf(`Register failed to create parent properly, expected Namespace to be "one:two"`+
			` & Label to be "three", got %s & %s.`, parent.Namespace, parent.Label)
	}

	other := Task{
		Namespace: "one:two",
		Label:     "four",
	}

	Register(other)
	stored = gofer.index("one:two")

	if 1 != len(gofer) {
		t.Error(`Register failed to associate parent Namespace properly.`)
	} else if 2 != len(stored.manual) {
		t.Error(`Register failed to associate parent Namespace properly.`)
	}
}

func TestPerform(t *testing.T) {
	unperformed := true

	task := Task{
		Namespace: "one:two",
		Label:     "five",
		Action: func(arguments ...string) error {
			unperformed = false
			return nil
		},
	}

	Register(task)
	err := Perform("one:two:five")

	if nil != err {
		t.Error(err)
	} else if unperformed {
		t.Error(`"unperformed" flag was not flipped to false, call to Perform failed to run action.`)
	}
}

func TestNoNamespace(t *testing.T) {
	unperformed := true

	task := Task{
		Label: "label",
		Action: func(arguments ...string) error {
			unperformed = false
			return nil
		},
	}

	err := Register(task)

	if nil != err {
		t.Error(err)
		return
	}

	err = Perform("label")

	if nil != err {
		t.Error(err)
	} else if unperformed {
		t.Error(`"unperformed" flag was not flipped to false, call to Perform failed to run action.`)
	}
}

func TestPerformWithDependencies(t *testing.T) {
	unperformed := true

	dependency := Task{
		Namespace: "one:two",
		Label:     "six",
		Action: func(arguments ...string) error {
			unperformed = false
			return nil
		},
	}

	task := Task{
		Namespace:    "one:two",
		Label:        "seven",
		Dependencies: []string{"one:two:six"},
		Action: func(arguments ...string) error {
			return nil
		},
	}
	Register(dependency)
	Register(task)

	err := Perform("one:two:seven")

	if nil != err {
		t.Error(err)
	} else if unperformed {
		t.Error(`"unperformed" flag was not flipped to false, call to Perform failed to run dependency action.`)
	}
}

func TestDependencyOrdering(t *testing.T) {
	var executed []int

	check := func(j int) bool {
		for _, i := range executed {
			if j == i {
				return true
			}
		}
		return false
	}

	d1 := Task{
		Namespace: "d",
		Label:     "one",
		Action: func(arguments ...string) error {
			executed = append(executed, 1)
			return nil
		},
	}

	d2 := Task{
		Namespace:    "d",
		Label:        "two",
		Dependencies: []string{"d:one"},
		Action: func(arguments ...string) error {
			if !check(1) {
				t.Error(`Expected "d:one" to have previously executed.`)
			}
			executed = append(executed, 2)
			return nil
		},
	}

	d3 := Task{
		Namespace:    "d",
		Label:        "three",
		Dependencies: []string{"d:one", "d:four"},
		Action: func(arguments ...string) error {
			if !check(1) || !check(4) {
				t.Error(`Expected "d:one" and "d:four" to have previously executed.`)
			}
			executed = append(executed, 3)
			return nil
		},
	}

	d4 := Task{
		Namespace:    "d",
		Label:        "four",
		Dependencies: []string{"d:one"},
		Action: func(arguments ...string) error {
			if !check(1) {
				t.Error(`Expected "d:one" and "d:four" to have previously executed.`)
			}
			executed = append(executed, 4)
			return nil
		},
	}

	d5 := Task{
		Namespace:    "d",
		Label:        "five",
		Dependencies: []string{"d:two", "d:three"},
		Action: func(arguments ...string) error {
			if !check(2) || !check(3) {
				t.Error(`Expected "d:one" and "d:four" to have previously executed.`)
			}
			executed = append(executed, 5)
			return nil
		},
	}

	Register(d1)
	Register(d2)
	Register(d3)
	Register(d4)
	Register(d5)

	if err := Perform("d:five"); nil != err {
		t.Errorf(`Unexpected error encounted, %s.`, err)
	}
}

func TestCyclicDependencies(t *testing.T) {
	d1 := Task{
		Namespace:    "d",
		Label:        "one",
		Dependencies: []string{"d:three"},
		Action: func(arguments ...string) error {
			return nil
		},
	}

	d2 := Task{
		Namespace:    "d",
		Label:        "two",
		Dependencies: []string{"d:one"},
		Action: func(arguments ...string) error {
			return nil
		},
	}

	d3 := Task{
		Namespace:    "d",
		Label:        "three",
		Dependencies: []string{"d:four"},
		Action: func(arguments ...string) error {
			return nil
		},
	}

	d4 := Task{
		Namespace:    "d",
		Label:        "four",
		Dependencies: []string{"d:one"},
		Action: func(arguments ...string) error {
			return nil
		},
	}

	d5 := Task{
		Namespace:    "d",
		Label:        "five",
		Dependencies: []string{"d:two", "d:three"},
		Action: func(arguments ...string) error {
			return nil
		},
	}

	Register(d1)
	Register(d2)
	Register(d3)
	Register(d4)
	Register(d5)

	if err := Perform("d:five"); errCyclicDependency != err {
		t.Errorf(`Unexpected error encounted, %s.`, err)
	}
}