summaryrefslogtreecommitdiff
path: root/vendor/github.com/onsi/ginkgo/internal
diff options
context:
space:
mode:
authorValentin Rothberg <rothberg@redhat.com>2019-06-24 11:29:13 +0200
committerValentin Rothberg <rothberg@redhat.com>2019-06-24 13:20:59 +0200
commitd697456dc90adbaf68224ed7c115b38d5855e582 (patch)
tree5fd88c48b34e7bead0028fa97e39f43f03880642 /vendor/github.com/onsi/ginkgo/internal
parenta3211b73c62a9fcc13f09305bf629ef507b26d34 (diff)
downloadpodman-d697456dc90adbaf68224ed7c115b38d5855e582.tar.gz
podman-d697456dc90adbaf68224ed7c115b38d5855e582.tar.bz2
podman-d697456dc90adbaf68224ed7c115b38d5855e582.zip
migrate to go-modules
Signed-off-by: Valentin Rothberg <rothberg@redhat.com>
Diffstat (limited to 'vendor/github.com/onsi/ginkgo/internal')
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/codelocation/code_location_suite_test.go13
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/codelocation/code_location_test.go80
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/containernode/container_node_suite_test.go13
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/containernode/container_node_test.go213
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/failer/failer_suite_test.go13
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/failer/failer_test.go141
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/leafnodes/it_node_test.go22
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/leafnodes/leaf_node_suite_test.go13
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/leafnodes/measure_node_test.go155
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/leafnodes/setup_nodes_test.go48
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/leafnodes/shared_runner_test.go353
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/leafnodes/suite_nodes_test.go230
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/leafnodes/synchronized_after_suite_node_test.go199
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/leafnodes/synchronized_before_suite_node_test.go446
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/remote/aggregator_test.go315
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/remote/fake_output_interceptor_test.go22
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/remote/fake_poster_test.go33
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/remote/forwarding_reporter_test.go181
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/remote/remote_suite_test.go13
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/remote/server_test.go269
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/spec/spec_suite_test.go13
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/spec/spec_test.go739
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/spec/specs.go45
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/spec/specs_test.go287
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/spec_iterator/index_computer_test.go149
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/spec_iterator/parallel_spec_iterator_test.go112
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/spec_iterator/serial_spec_iterator_test.go64
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/spec_iterator/sharded_parallel_spec_iterator_test.go62
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/spec_iterator/spec_iterator_suite_test.go13
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/specrunner/spec_runner_suite_test.go13
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/specrunner/spec_runner_test.go785
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/suite/suite_suite_test.go35
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/suite/suite_test.go385
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/writer/writer_suite_test.go13
-rw-r--r--vendor/github.com/onsi/ginkgo/internal/writer/writer_test.go75
35 files changed, 33 insertions, 5529 deletions
diff --git a/vendor/github.com/onsi/ginkgo/internal/codelocation/code_location_suite_test.go b/vendor/github.com/onsi/ginkgo/internal/codelocation/code_location_suite_test.go
deleted file mode 100644
index f06abf3c5..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/codelocation/code_location_suite_test.go
+++ /dev/null
@@ -1,13 +0,0 @@
-package codelocation_test
-
-import (
- . "github.com/onsi/ginkgo"
- . "github.com/onsi/gomega"
-
- "testing"
-)
-
-func TestCodelocation(t *testing.T) {
- RegisterFailHandler(Fail)
- RunSpecs(t, "CodeLocation Suite")
-}
diff --git a/vendor/github.com/onsi/ginkgo/internal/codelocation/code_location_test.go b/vendor/github.com/onsi/ginkgo/internal/codelocation/code_location_test.go
deleted file mode 100644
index cca75a449..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/codelocation/code_location_test.go
+++ /dev/null
@@ -1,80 +0,0 @@
-package codelocation_test
-
-import (
- "runtime"
-
- . "github.com/onsi/ginkgo"
- "github.com/onsi/ginkgo/internal/codelocation"
- "github.com/onsi/ginkgo/types"
- . "github.com/onsi/gomega"
-)
-
-var _ = Describe("CodeLocation", func() {
- var (
- codeLocation types.CodeLocation
- expectedFileName string
- expectedLineNumber int
- )
-
- caller0 := func() {
- codeLocation = codelocation.New(1)
- }
-
- caller1 := func() {
- _, expectedFileName, expectedLineNumber, _ = runtime.Caller(0)
- expectedLineNumber += 2
- caller0()
- }
-
- BeforeEach(func() {
- caller1()
- })
-
- It("should use the passed in skip parameter to pick out the correct file & line number", func() {
- Ω(codeLocation.FileName).Should(Equal(expectedFileName))
- Ω(codeLocation.LineNumber).Should(Equal(expectedLineNumber))
- })
-
- Describe("stringer behavior", func() {
- It("should stringify nicely", func() {
- Ω(codeLocation.String()).Should(ContainSubstring("code_location_test.go:%d", expectedLineNumber))
- })
- })
-
- //There's no better way than to test this private method as it
- //goes out of its way to prune out ginkgo related code in the stack trace
- Describe("PruneStack", func() {
- It("should remove any references to ginkgo and pkg/testing and pkg/runtime", func() {
- input := `/Skip/me
-Skip: skip()
-/Skip/me
-Skip: skip()
-/Users/whoever/gospace/src/github.com/onsi/ginkgo/whatever.go:10 (0x12314)
-Something: Func()
-/Users/whoever/gospace/src/github.com/onsi/ginkgo/whatever_else.go:10 (0x12314)
-SomethingInternalToGinkgo: Func()
-/usr/goroot/pkg/strings/oops.go:10 (0x12341)
-Oops: BlowUp()
-/Users/whoever/gospace/src/mycode/code.go:10 (0x12341)
-MyCode: Func()
-/Users/whoever/gospace/src/mycode/code_test.go:10 (0x12341)
-MyCodeTest: Func()
-/Users/whoever/gospace/src/mycode/code_suite_test.go:12 (0x37f08)
-TestFoo: RunSpecs(t, "Foo Suite")
-/usr/goroot/pkg/testing/testing.go:12 (0x37f08)
-TestingT: Blah()
-/usr/goroot/pkg/runtime/runtime.go:12 (0x37f08)
-Something: Func()
-`
- prunedStack := codelocation.PruneStack(input, 1)
- Ω(prunedStack).Should(Equal(`/usr/goroot/pkg/strings/oops.go:10 (0x12341)
-Oops: BlowUp()
-/Users/whoever/gospace/src/mycode/code.go:10 (0x12341)
-MyCode: Func()
-/Users/whoever/gospace/src/mycode/code_test.go:10 (0x12341)
-MyCodeTest: Func()
-/Users/whoever/gospace/src/mycode/code_suite_test.go:12 (0x37f08)
-TestFoo: RunSpecs(t, "Foo Suite")`))
- })
- })
-})
diff --git a/vendor/github.com/onsi/ginkgo/internal/containernode/container_node_suite_test.go b/vendor/github.com/onsi/ginkgo/internal/containernode/container_node_suite_test.go
deleted file mode 100644
index c6fc314ff..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/containernode/container_node_suite_test.go
+++ /dev/null
@@ -1,13 +0,0 @@
-package containernode_test
-
-import (
- . "github.com/onsi/ginkgo"
- . "github.com/onsi/gomega"
-
- "testing"
-)
-
-func TestContainernode(t *testing.T) {
- RegisterFailHandler(Fail)
- RunSpecs(t, "Containernode Suite")
-}
diff --git a/vendor/github.com/onsi/ginkgo/internal/containernode/container_node_test.go b/vendor/github.com/onsi/ginkgo/internal/containernode/container_node_test.go
deleted file mode 100644
index 11ac9b70b..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/containernode/container_node_test.go
+++ /dev/null
@@ -1,213 +0,0 @@
-package containernode_test
-
-import (
- "math/rand"
-
- "github.com/onsi/ginkgo/internal/leafnodes"
-
- . "github.com/onsi/ginkgo"
- . "github.com/onsi/gomega"
-
- "github.com/onsi/ginkgo/internal/codelocation"
- . "github.com/onsi/ginkgo/internal/containernode"
- "github.com/onsi/ginkgo/types"
-)
-
-var _ = Describe("Container Node", func() {
- var (
- codeLocation types.CodeLocation
- container *ContainerNode
- )
-
- BeforeEach(func() {
- codeLocation = codelocation.New(0)
- container = New("description text", types.FlagTypeFocused, codeLocation)
- })
-
- Describe("creating a container node", func() {
- It("can answer questions about itself", func() {
- Ω(container.Text()).Should(Equal("description text"))
- Ω(container.Flag()).Should(Equal(types.FlagTypeFocused))
- Ω(container.CodeLocation()).Should(Equal(codeLocation))
- })
- })
-
- Describe("pushing setup nodes", func() {
- It("can append setup nodes of various types and fetch them by type", func() {
- befA := leafnodes.NewBeforeEachNode(func() {}, codelocation.New(0), 0, nil, 0)
- befB := leafnodes.NewBeforeEachNode(func() {}, codelocation.New(0), 0, nil, 0)
- aftA := leafnodes.NewAfterEachNode(func() {}, codelocation.New(0), 0, nil, 0)
- aftB := leafnodes.NewAfterEachNode(func() {}, codelocation.New(0), 0, nil, 0)
- jusBefA := leafnodes.NewJustBeforeEachNode(func() {}, codelocation.New(0), 0, nil, 0)
- jusBefB := leafnodes.NewJustBeforeEachNode(func() {}, codelocation.New(0), 0, nil, 0)
-
- container.PushSetupNode(befA)
- container.PushSetupNode(befB)
- container.PushSetupNode(aftA)
- container.PushSetupNode(aftB)
- container.PushSetupNode(jusBefA)
- container.PushSetupNode(jusBefB)
-
- subject := leafnodes.NewItNode("subject", func() {}, types.FlagTypeNone, codelocation.New(0), 0, nil, 0)
- container.PushSubjectNode(subject)
-
- Ω(container.SetupNodesOfType(types.SpecComponentTypeBeforeEach)).Should(Equal([]leafnodes.BasicNode{befA, befB}))
- Ω(container.SetupNodesOfType(types.SpecComponentTypeAfterEach)).Should(Equal([]leafnodes.BasicNode{aftA, aftB}))
- Ω(container.SetupNodesOfType(types.SpecComponentTypeJustBeforeEach)).Should(Equal([]leafnodes.BasicNode{jusBefA, jusBefB}))
- Ω(container.SetupNodesOfType(types.SpecComponentTypeIt)).Should(BeEmpty()) //subjects are not setup nodes
- })
- })
-
- Context("With appended containers and subject nodes", func() {
- var (
- itA, itB, innerItA, innerItB leafnodes.SubjectNode
- innerContainer *ContainerNode
- )
-
- BeforeEach(func() {
- itA = leafnodes.NewItNode("Banana", func() {}, types.FlagTypeNone, codelocation.New(0), 0, nil, 0)
- itB = leafnodes.NewItNode("Apple", func() {}, types.FlagTypeNone, codelocation.New(0), 0, nil, 0)
-
- innerItA = leafnodes.NewItNode("inner A", func() {}, types.FlagTypeNone, codelocation.New(0), 0, nil, 0)
- innerItB = leafnodes.NewItNode("inner B", func() {}, types.FlagTypeNone, codelocation.New(0), 0, nil, 0)
-
- innerContainer = New("Orange", types.FlagTypeNone, codelocation.New(0))
-
- container.PushSubjectNode(itA)
- container.PushContainerNode(innerContainer)
- innerContainer.PushSubjectNode(innerItA)
- innerContainer.PushSubjectNode(innerItB)
- container.PushSubjectNode(itB)
- })
-
- Describe("Collating", func() {
- It("should return a collated set of containers and subject nodes in the correct order", func() {
- collated := container.Collate()
- Ω(collated).Should(HaveLen(4))
-
- Ω(collated[0]).Should(Equal(CollatedNodes{
- Containers: []*ContainerNode{container},
- Subject: itA,
- }))
-
- Ω(collated[1]).Should(Equal(CollatedNodes{
- Containers: []*ContainerNode{container, innerContainer},
- Subject: innerItA,
- }))
-
- Ω(collated[2]).Should(Equal(CollatedNodes{
- Containers: []*ContainerNode{container, innerContainer},
- Subject: innerItB,
- }))
-
- Ω(collated[3]).Should(Equal(CollatedNodes{
- Containers: []*ContainerNode{container},
- Subject: itB,
- }))
- })
- })
-
- Describe("Backpropagating Programmatic Focus", func() {
- //This allows inner focused specs to override the focus of outer focussed
- //specs and more closely maps to what a developer wants to happen
- //when debugging a test suite
-
- Context("when a parent is focused *and* an inner subject is focused", func() {
- BeforeEach(func() {
- container = New("description text", types.FlagTypeFocused, codeLocation)
- itA = leafnodes.NewItNode("A", func() {}, types.FlagTypeNone, codelocation.New(0), 0, nil, 0)
- container.PushSubjectNode(itA)
-
- innerContainer = New("Orange", types.FlagTypeNone, codelocation.New(0))
- container.PushContainerNode(innerContainer)
- innerItA = leafnodes.NewItNode("inner A", func() {}, types.FlagTypeFocused, codelocation.New(0), 0, nil, 0)
- innerContainer.PushSubjectNode(innerItA)
- })
-
- It("should unfocus the parent", func() {
- container.BackPropagateProgrammaticFocus()
-
- Ω(container.Flag()).Should(Equal(types.FlagTypeNone))
- Ω(itA.Flag()).Should(Equal(types.FlagTypeNone))
- Ω(innerContainer.Flag()).Should(Equal(types.FlagTypeNone))
- Ω(innerItA.Flag()).Should(Equal(types.FlagTypeFocused))
- })
- })
-
- Context("when a parent is focused *and* an inner container is focused", func() {
- BeforeEach(func() {
- container = New("description text", types.FlagTypeFocused, codeLocation)
- itA = leafnodes.NewItNode("A", func() {}, types.FlagTypeNone, codelocation.New(0), 0, nil, 0)
- container.PushSubjectNode(itA)
-
- innerContainer = New("Orange", types.FlagTypeFocused, codelocation.New(0))
- container.PushContainerNode(innerContainer)
- innerItA = leafnodes.NewItNode("inner A", func() {}, types.FlagTypeNone, codelocation.New(0), 0, nil, 0)
- innerContainer.PushSubjectNode(innerItA)
- })
-
- It("should unfocus the parent", func() {
- container.BackPropagateProgrammaticFocus()
-
- Ω(container.Flag()).Should(Equal(types.FlagTypeNone))
- Ω(itA.Flag()).Should(Equal(types.FlagTypeNone))
- Ω(innerContainer.Flag()).Should(Equal(types.FlagTypeFocused))
- Ω(innerItA.Flag()).Should(Equal(types.FlagTypeNone))
- })
- })
-
- Context("when a parent is pending and a child is focused", func() {
- BeforeEach(func() {
- container = New("description text", types.FlagTypeFocused, codeLocation)
- itA = leafnodes.NewItNode("A", func() {}, types.FlagTypeNone, codelocation.New(0), 0, nil, 0)
- container.PushSubjectNode(itA)
-
- innerContainer = New("Orange", types.FlagTypePending, codelocation.New(0))
- container.PushContainerNode(innerContainer)
- innerItA = leafnodes.NewItNode("inner A", func() {}, types.FlagTypeFocused, codelocation.New(0), 0, nil, 0)
- innerContainer.PushSubjectNode(innerItA)
- })
-
- It("should not do anything", func() {
- container.BackPropagateProgrammaticFocus()
-
- Ω(container.Flag()).Should(Equal(types.FlagTypeFocused))
- Ω(itA.Flag()).Should(Equal(types.FlagTypeNone))
- Ω(innerContainer.Flag()).Should(Equal(types.FlagTypePending))
- Ω(innerItA.Flag()).Should(Equal(types.FlagTypeFocused))
- })
- })
- })
-
- Describe("Shuffling", func() {
- var unshuffledCollation []CollatedNodes
- BeforeEach(func() {
- unshuffledCollation = container.Collate()
-
- r := rand.New(rand.NewSource(17))
- container.Shuffle(r)
- })
-
- It("should sort, and then shuffle, the top level contents of the container", func() {
- shuffledCollation := container.Collate()
- Ω(shuffledCollation).Should(HaveLen(len(unshuffledCollation)))
- Ω(shuffledCollation).ShouldNot(Equal(unshuffledCollation))
-
- for _, entry := range unshuffledCollation {
- Ω(shuffledCollation).Should(ContainElement(entry))
- }
-
- innerAIndex, innerBIndex := 0, 0
- for i, entry := range shuffledCollation {
- if entry.Subject == innerItA {
- innerAIndex = i
- } else if entry.Subject == innerItB {
- innerBIndex = i
- }
- }
-
- Ω(innerAIndex).Should(Equal(innerBIndex - 1))
- })
- })
- })
-})
diff --git a/vendor/github.com/onsi/ginkgo/internal/failer/failer_suite_test.go b/vendor/github.com/onsi/ginkgo/internal/failer/failer_suite_test.go
deleted file mode 100644
index 8dce7be9a..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/failer/failer_suite_test.go
+++ /dev/null
@@ -1,13 +0,0 @@
-package failer_test
-
-import (
- . "github.com/onsi/ginkgo"
- . "github.com/onsi/gomega"
-
- "testing"
-)
-
-func TestFailer(t *testing.T) {
- RegisterFailHandler(Fail)
- RunSpecs(t, "Failer Suite")
-}
diff --git a/vendor/github.com/onsi/ginkgo/internal/failer/failer_test.go b/vendor/github.com/onsi/ginkgo/internal/failer/failer_test.go
deleted file mode 100644
index 65210a40a..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/failer/failer_test.go
+++ /dev/null
@@ -1,141 +0,0 @@
-package failer_test
-
-import (
- . "github.com/onsi/ginkgo"
- . "github.com/onsi/ginkgo/internal/failer"
- . "github.com/onsi/gomega"
-
- "github.com/onsi/ginkgo/internal/codelocation"
- "github.com/onsi/ginkgo/types"
-)
-
-var _ = Describe("Failer", func() {
- var (
- failer *Failer
- codeLocationA types.CodeLocation
- codeLocationB types.CodeLocation
- )
-
- BeforeEach(func() {
- codeLocationA = codelocation.New(0)
- codeLocationB = codelocation.New(0)
- failer = New()
- })
-
- Context("with no failures", func() {
- It("should return success when drained", func() {
- failure, state := failer.Drain(types.SpecComponentTypeIt, 3, codeLocationB)
- Ω(failure).Should(BeZero())
- Ω(state).Should(Equal(types.SpecStatePassed))
- })
- })
-
- Describe("Skip", func() {
- It("should handle failures", func() {
- failer.Skip("something skipped", codeLocationA)
- failure, state := failer.Drain(types.SpecComponentTypeIt, 3, codeLocationB)
- Ω(failure).Should(Equal(types.SpecFailure{
- Message: "something skipped",
- Location: codeLocationA,
- ForwardedPanic: "",
- ComponentType: types.SpecComponentTypeIt,
- ComponentIndex: 3,
- ComponentCodeLocation: codeLocationB,
- }))
- Ω(state).Should(Equal(types.SpecStateSkipped))
- })
- })
-
- Describe("Fail", func() {
- It("should handle failures", func() {
- failer.Fail("something failed", codeLocationA)
- failure, state := failer.Drain(types.SpecComponentTypeIt, 3, codeLocationB)
- Ω(failure).Should(Equal(types.SpecFailure{
- Message: "something failed",
- Location: codeLocationA,
- ForwardedPanic: "",
- ComponentType: types.SpecComponentTypeIt,
- ComponentIndex: 3,
- ComponentCodeLocation: codeLocationB,
- }))
- Ω(state).Should(Equal(types.SpecStateFailed))
- })
- })
-
- Describe("Panic", func() {
- It("should handle panics", func() {
- failer.Panic(codeLocationA, "some forwarded panic")
- failure, state := failer.Drain(types.SpecComponentTypeIt, 3, codeLocationB)
- Ω(failure).Should(Equal(types.SpecFailure{
- Message: "Test Panicked",
- Location: codeLocationA,
- ForwardedPanic: "some forwarded panic",
- ComponentType: types.SpecComponentTypeIt,
- ComponentIndex: 3,
- ComponentCodeLocation: codeLocationB,
- }))
- Ω(state).Should(Equal(types.SpecStatePanicked))
- })
- })
-
- Describe("Timeout", func() {
- It("should handle timeouts", func() {
- failer.Timeout(codeLocationA)
- failure, state := failer.Drain(types.SpecComponentTypeIt, 3, codeLocationB)
- Ω(failure).Should(Equal(types.SpecFailure{
- Message: "Timed out",
- Location: codeLocationA,
- ForwardedPanic: "",
- ComponentType: types.SpecComponentTypeIt,
- ComponentIndex: 3,
- ComponentCodeLocation: codeLocationB,
- }))
- Ω(state).Should(Equal(types.SpecStateTimedOut))
- })
- })
-
- Context("when multiple failures are registered", func() {
- BeforeEach(func() {
- failer.Fail("something failed", codeLocationA)
- failer.Fail("something else failed", codeLocationA)
- })
-
- It("should only report the first one when drained", func() {
- failure, state := failer.Drain(types.SpecComponentTypeIt, 3, codeLocationB)
-
- Ω(failure).Should(Equal(types.SpecFailure{
- Message: "something failed",
- Location: codeLocationA,
- ForwardedPanic: "",
- ComponentType: types.SpecComponentTypeIt,
- ComponentIndex: 3,
- ComponentCodeLocation: codeLocationB,
- }))
- Ω(state).Should(Equal(types.SpecStateFailed))
- })
-
- It("should report subsequent failures after being drained", func() {
- failer.Drain(types.SpecComponentTypeIt, 3, codeLocationB)
- failer.Fail("yet another thing failed", codeLocationA)
-
- failure, state := failer.Drain(types.SpecComponentTypeIt, 3, codeLocationB)
-
- Ω(failure).Should(Equal(types.SpecFailure{
- Message: "yet another thing failed",
- Location: codeLocationA,
- ForwardedPanic: "",
- ComponentType: types.SpecComponentTypeIt,
- ComponentIndex: 3,
- ComponentCodeLocation: codeLocationB,
- }))
- Ω(state).Should(Equal(types.SpecStateFailed))
- })
-
- It("should report sucess on subsequent drains if no errors occur", func() {
- failer.Drain(types.SpecComponentTypeIt, 3, codeLocationB)
- failure, state := failer.Drain(types.SpecComponentTypeIt, 3, codeLocationB)
- Ω(failure).Should(BeZero())
- Ω(state).Should(Equal(types.SpecStatePassed))
- })
- })
-})
diff --git a/vendor/github.com/onsi/ginkgo/internal/leafnodes/it_node_test.go b/vendor/github.com/onsi/ginkgo/internal/leafnodes/it_node_test.go
deleted file mode 100644
index 29fa0c6e2..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/leafnodes/it_node_test.go
+++ /dev/null
@@ -1,22 +0,0 @@
-package leafnodes_test
-
-import (
- . "github.com/onsi/ginkgo"
- . "github.com/onsi/ginkgo/internal/leafnodes"
- . "github.com/onsi/gomega"
-
- "github.com/onsi/ginkgo/internal/codelocation"
- "github.com/onsi/ginkgo/types"
-)
-
-var _ = Describe("It Nodes", func() {
- It("should report the correct type, text, flag, and code location", func() {
- codeLocation := codelocation.New(0)
- it := NewItNode("my it node", func() {}, types.FlagTypeFocused, codeLocation, 0, nil, 3)
- Ω(it.Type()).Should(Equal(types.SpecComponentTypeIt))
- Ω(it.Flag()).Should(Equal(types.FlagTypeFocused))
- Ω(it.Text()).Should(Equal("my it node"))
- Ω(it.CodeLocation()).Should(Equal(codeLocation))
- Ω(it.Samples()).Should(Equal(1))
- })
-})
diff --git a/vendor/github.com/onsi/ginkgo/internal/leafnodes/leaf_node_suite_test.go b/vendor/github.com/onsi/ginkgo/internal/leafnodes/leaf_node_suite_test.go
deleted file mode 100644
index a7ba9e006..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/leafnodes/leaf_node_suite_test.go
+++ /dev/null
@@ -1,13 +0,0 @@
-package leafnodes_test
-
-import (
- . "github.com/onsi/ginkgo"
- . "github.com/onsi/gomega"
-
- "testing"
-)
-
-func TestLeafNode(t *testing.T) {
- RegisterFailHandler(Fail)
- RunSpecs(t, "LeafNode Suite")
-}
diff --git a/vendor/github.com/onsi/ginkgo/internal/leafnodes/measure_node_test.go b/vendor/github.com/onsi/ginkgo/internal/leafnodes/measure_node_test.go
deleted file mode 100644
index 1cd13336a..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/leafnodes/measure_node_test.go
+++ /dev/null
@@ -1,155 +0,0 @@
-package leafnodes_test
-
-import (
- . "github.com/onsi/ginkgo"
- . "github.com/onsi/ginkgo/internal/leafnodes"
- . "github.com/onsi/gomega"
-
- "time"
-
- "github.com/onsi/ginkgo/internal/codelocation"
- Failer "github.com/onsi/ginkgo/internal/failer"
- "github.com/onsi/ginkgo/types"
-)
-
-var _ = Describe("Measure Nodes", func() {
- It("should report the correct type, text, flag, and code location", func() {
- codeLocation := codelocation.New(0)
- measure := NewMeasureNode("my measure node", func(b Benchmarker) {}, types.FlagTypeFocused, codeLocation, 10, nil, 3)
- Ω(measure.Type()).Should(Equal(types.SpecComponentTypeMeasure))
- Ω(measure.Flag()).Should(Equal(types.FlagTypeFocused))
- Ω(measure.Text()).Should(Equal("my measure node"))
- Ω(measure.CodeLocation()).Should(Equal(codeLocation))
- Ω(measure.Samples()).Should(Equal(10))
- })
-
- Describe("benchmarking", func() {
- var measure *MeasureNode
-
- Describe("Value", func() {
- BeforeEach(func() {
- measure = NewMeasureNode("the measurement", func(b Benchmarker) {
- b.RecordValue("foo", 7, "info!")
- b.RecordValue("foo", 2)
- b.RecordValue("foo", 3)
- b.RecordValue("bar", 0.3)
- b.RecordValue("bar", 0.1)
- b.RecordValue("bar", 0.5)
- b.RecordValue("bar", 0.7)
- }, types.FlagTypeFocused, codelocation.New(0), 1, Failer.New(), 3)
- Ω(measure.Run()).Should(Equal(types.SpecStatePassed))
- })
-
- It("records passed in values and reports on them", func() {
- report := measure.MeasurementsReport()
- Ω(report).Should(HaveLen(2))
- Ω(report["foo"].Name).Should(Equal("foo"))
- Ω(report["foo"].Info).Should(Equal("info!"))
- Ω(report["foo"].Order).Should(Equal(0))
- Ω(report["foo"].SmallestLabel).Should(Equal("Smallest"))
- Ω(report["foo"].LargestLabel).Should(Equal(" Largest"))
- Ω(report["foo"].AverageLabel).Should(Equal(" Average"))
- Ω(report["foo"].Units).Should(Equal(""))
- Ω(report["foo"].Results).Should(Equal([]float64{7, 2, 3}))
- Ω(report["foo"].Smallest).Should(BeNumerically("==", 2))
- Ω(report["foo"].Largest).Should(BeNumerically("==", 7))
- Ω(report["foo"].Average).Should(BeNumerically("==", 4))
- Ω(report["foo"].StdDeviation).Should(BeNumerically("~", 2.16, 0.01))
-
- Ω(report["bar"].Name).Should(Equal("bar"))
- Ω(report["bar"].Info).Should(BeNil())
- Ω(report["bar"].SmallestLabel).Should(Equal("Smallest"))
- Ω(report["bar"].Order).Should(Equal(1))
- Ω(report["bar"].LargestLabel).Should(Equal(" Largest"))
- Ω(report["bar"].AverageLabel).Should(Equal(" Average"))
- Ω(report["bar"].Units).Should(Equal(""))
- Ω(report["bar"].Results).Should(Equal([]float64{0.3, 0.1, 0.5, 0.7}))
- Ω(report["bar"].Smallest).Should(BeNumerically("==", 0.1))
- Ω(report["bar"].Largest).Should(BeNumerically("==", 0.7))
- Ω(report["bar"].Average).Should(BeNumerically("==", 0.4))
- Ω(report["bar"].StdDeviation).Should(BeNumerically("~", 0.22, 0.01))
- })
- })
-
- Describe("Value with precision", func() {
- BeforeEach(func() {
- measure = NewMeasureNode("the measurement", func(b Benchmarker) {
- b.RecordValueWithPrecision("foo", 7, "ms", 7, "info!")
- b.RecordValueWithPrecision("foo", 2, "ms", 6)
- b.RecordValueWithPrecision("foo", 3, "ms", 5)
- b.RecordValueWithPrecision("bar", 0.3, "ns", 4)
- b.RecordValueWithPrecision("bar", 0.1, "ns", 3)
- b.RecordValueWithPrecision("bar", 0.5, "ns", 2)
- b.RecordValueWithPrecision("bar", 0.7, "ns", 1)
- }, types.FlagTypeFocused, codelocation.New(0), 1, Failer.New(), 3)
- Ω(measure.Run()).Should(Equal(types.SpecStatePassed))
- })
-
- It("records passed in values and reports on them", func() {
- report := measure.MeasurementsReport()
- Ω(report).Should(HaveLen(2))
- Ω(report["foo"].Name).Should(Equal("foo"))
- Ω(report["foo"].Info).Should(Equal("info!"))
- Ω(report["foo"].Order).Should(Equal(0))
- Ω(report["foo"].SmallestLabel).Should(Equal("Smallest"))
- Ω(report["foo"].LargestLabel).Should(Equal(" Largest"))
- Ω(report["foo"].AverageLabel).Should(Equal(" Average"))
- Ω(report["foo"].Units).Should(Equal("ms"))
- Ω(report["foo"].Results).Should(Equal([]float64{7, 2, 3}))
- Ω(report["foo"].Smallest).Should(BeNumerically("==", 2))
- Ω(report["foo"].Largest).Should(BeNumerically("==", 7))
- Ω(report["foo"].Average).Should(BeNumerically("==", 4))
- Ω(report["foo"].StdDeviation).Should(BeNumerically("~", 2.16, 0.01))
-
- Ω(report["bar"].Name).Should(Equal("bar"))
- Ω(report["bar"].Info).Should(BeNil())
- Ω(report["bar"].SmallestLabel).Should(Equal("Smallest"))
- Ω(report["bar"].Order).Should(Equal(1))
- Ω(report["bar"].LargestLabel).Should(Equal(" Largest"))
- Ω(report["bar"].AverageLabel).Should(Equal(" Average"))
- Ω(report["bar"].Units).Should(Equal("ns"))
- Ω(report["bar"].Results).Should(Equal([]float64{0.3, 0.1, 0.5, 0.7}))
- Ω(report["bar"].Smallest).Should(BeNumerically("==", 0.1))
- Ω(report["bar"].Largest).Should(BeNumerically("==", 0.7))
- Ω(report["bar"].Average).Should(BeNumerically("==", 0.4))
- Ω(report["bar"].StdDeviation).Should(BeNumerically("~", 0.22, 0.01))
- })
- })
-
- Describe("Time", func() {
- BeforeEach(func() {
- measure = NewMeasureNode("the measurement", func(b Benchmarker) {
- b.Time("foo", func() {
- time.Sleep(200 * time.Millisecond)
- }, "info!")
- b.Time("foo", func() {
- time.Sleep(300 * time.Millisecond)
- })
- b.Time("foo", func() {
- time.Sleep(250 * time.Millisecond)
- })
- }, types.FlagTypeFocused, codelocation.New(0), 1, Failer.New(), 3)
- Ω(measure.Run()).Should(Equal(types.SpecStatePassed))
- })
-
- It("records passed in values and reports on them", func() {
- report := measure.MeasurementsReport()
- Ω(report).Should(HaveLen(1))
- Ω(report["foo"].Name).Should(Equal("foo"))
- Ω(report["foo"].Info).Should(Equal("info!"))
- Ω(report["foo"].SmallestLabel).Should(Equal("Fastest Time"))
- Ω(report["foo"].LargestLabel).Should(Equal("Slowest Time"))
- Ω(report["foo"].AverageLabel).Should(Equal("Average Time"))
- Ω(report["foo"].Units).Should(Equal("s"))
- Ω(report["foo"].Results).Should(HaveLen(3))
- Ω(report["foo"].Results[0]).Should(BeNumerically("~", 0.2, 0.06))
- Ω(report["foo"].Results[1]).Should(BeNumerically("~", 0.3, 0.06))
- Ω(report["foo"].Results[2]).Should(BeNumerically("~", 0.25, 0.06))
- Ω(report["foo"].Smallest).Should(BeNumerically("~", 0.2, 0.06))
- Ω(report["foo"].Largest).Should(BeNumerically("~", 0.3, 0.06))
- Ω(report["foo"].Average).Should(BeNumerically("~", 0.25, 0.06))
- Ω(report["foo"].StdDeviation).Should(BeNumerically("~", 0.07, 0.04))
- })
- })
- })
-})
diff --git a/vendor/github.com/onsi/ginkgo/internal/leafnodes/setup_nodes_test.go b/vendor/github.com/onsi/ginkgo/internal/leafnodes/setup_nodes_test.go
deleted file mode 100644
index 9810688cb..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/leafnodes/setup_nodes_test.go
+++ /dev/null
@@ -1,48 +0,0 @@
-package leafnodes_test
-
-import (
- . "github.com/onsi/ginkgo"
- "github.com/onsi/ginkgo/types"
- . "github.com/onsi/gomega"
-
- . "github.com/onsi/ginkgo/internal/leafnodes"
-
- "github.com/onsi/ginkgo/internal/codelocation"
-)
-
-var _ = Describe("Setup Nodes", func() {
- Describe("BeforeEachNodes", func() {
- It("should report the correct type and code location", func() {
- codeLocation := codelocation.New(0)
- beforeEach := NewBeforeEachNode(func() {}, codeLocation, 0, nil, 3)
- Ω(beforeEach.Type()).Should(Equal(types.SpecComponentTypeBeforeEach))
- Ω(beforeEach.CodeLocation()).Should(Equal(codeLocation))
- })
- })
-
- Describe("AfterEachNodes", func() {
- It("should report the correct type and code location", func() {
- codeLocation := codelocation.New(0)
- afterEach := NewAfterEachNode(func() {}, codeLocation, 0, nil, 3)
- Ω(afterEach.Type()).Should(Equal(types.SpecComponentTypeAfterEach))
- Ω(afterEach.CodeLocation()).Should(Equal(codeLocation))
- })
- })
-
- Describe("JustBeforeEachNodes", func() {
- It("should report the correct type and code location", func() {
- codeLocation := codelocation.New(0)
- justBeforeEach := NewJustBeforeEachNode(func() {}, codeLocation, 0, nil, 3)
- Ω(justBeforeEach.Type()).Should(Equal(types.SpecComponentTypeJustBeforeEach))
- Ω(justBeforeEach.CodeLocation()).Should(Equal(codeLocation))
- })
- })
- Describe("JustAfterEachNodes", func() {
- It("should report the correct type and code location", func() {
- codeLocation := codelocation.New(0)
- justAfterEach := NewJustAfterEachNode(func() {}, codeLocation, 0, nil, 3)
- Ω(justAfterEach.Type()).Should(Equal(types.SpecComponentTypeJustAfterEach))
- Ω(justAfterEach.CodeLocation()).Should(Equal(codeLocation))
- })
- })
-})
diff --git a/vendor/github.com/onsi/ginkgo/internal/leafnodes/shared_runner_test.go b/vendor/github.com/onsi/ginkgo/internal/leafnodes/shared_runner_test.go
deleted file mode 100644
index 0897836cb..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/leafnodes/shared_runner_test.go
+++ /dev/null
@@ -1,353 +0,0 @@
-package leafnodes_test
-
-import (
- . "github.com/onsi/ginkgo"
- . "github.com/onsi/ginkgo/internal/leafnodes"
- . "github.com/onsi/gomega"
-
- "reflect"
- "time"
-
- "github.com/onsi/ginkgo/internal/codelocation"
- Failer "github.com/onsi/ginkgo/internal/failer"
- "github.com/onsi/ginkgo/types"
-)
-
-type runnable interface {
- Run() (outcome types.SpecState, failure types.SpecFailure)
- CodeLocation() types.CodeLocation
-}
-
-func SynchronousSharedRunnerBehaviors(build func(body interface{}, timeout time.Duration, failer *Failer.Failer, componentCodeLocation types.CodeLocation) runnable, componentType types.SpecComponentType, componentIndex int) {
- var (
- outcome types.SpecState
- failure types.SpecFailure
-
- failer *Failer.Failer
-
- componentCodeLocation types.CodeLocation
- innerCodeLocation types.CodeLocation
-
- didRun bool
- )
-
- BeforeEach(func() {
- failer = Failer.New()
- componentCodeLocation = codelocation.New(0)
- innerCodeLocation = codelocation.New(0)
-
- didRun = false
- })
-
- Describe("synchronous functions", func() {
- Context("when the function passes", func() {
- BeforeEach(func() {
- outcome, failure = build(func() {
- didRun = true
- }, 0, failer, componentCodeLocation).Run()
- })
-
- It("should have a succesful outcome", func() {
- Ω(didRun).Should(BeTrue())
-
- Ω(outcome).Should(Equal(types.SpecStatePassed))
- Ω(failure).Should(BeZero())
- })
- })
-
- Context("when a failure occurs", func() {
- BeforeEach(func() {
- outcome, failure = build(func() {
- didRun = true
- failer.Fail("bam", innerCodeLocation)
- panic("should not matter")
- }, 0, failer, componentCodeLocation).Run()
- })
-
- It("should return the failure", func() {
- Ω(didRun).Should(BeTrue())
-
- Ω(outcome).Should(Equal(types.SpecStateFailed))
- Ω(failure).Should(Equal(types.SpecFailure{
- Message: "bam",
- Location: innerCodeLocation,
- ForwardedPanic: "",
- ComponentIndex: componentIndex,
- ComponentType: componentType,
- ComponentCodeLocation: componentCodeLocation,
- }))
- })
- })
-
- Context("when a panic occurs", func() {
- BeforeEach(func() {
- outcome, failure = build(func() {
- didRun = true
- innerCodeLocation = codelocation.New(0)
- panic("ack!")
- }, 0, failer, componentCodeLocation).Run()
- })
-
- It("should return the panic", func() {
- Ω(didRun).Should(BeTrue())
-
- Ω(outcome).Should(Equal(types.SpecStatePanicked))
- Ω(failure.ForwardedPanic).Should(Equal("ack!"))
- })
- })
-
- Context("when a panic occurs with a nil value", func() {
- BeforeEach(func() {
- outcome, failure = build(func() {
- didRun = true
- innerCodeLocation = codelocation.New(0)
- panic(nil)
- }, 0, failer, componentCodeLocation).Run()
- })
-
- It("should return the nil-valued panic", func() {
- Ω(didRun).Should(BeTrue())
-
- Ω(outcome).Should(Equal(types.SpecStatePanicked))
- Ω(failure.ForwardedPanic).Should(Equal("<nil>"))
- })
- })
-
- })
-}
-
-func AsynchronousSharedRunnerBehaviors(build func(body interface{}, timeout time.Duration, failer *Failer.Failer, componentCodeLocation types.CodeLocation) runnable, componentType types.SpecComponentType, componentIndex int) {
- var (
- outcome types.SpecState
- failure types.SpecFailure
-
- failer *Failer.Failer
-
- componentCodeLocation types.CodeLocation
- innerCodeLocation types.CodeLocation
-
- didRun bool
- )
-
- BeforeEach(func() {
- failer = Failer.New()
- componentCodeLocation = codelocation.New(0)
- innerCodeLocation = codelocation.New(0)
-
- didRun = false
- })
-
- Describe("asynchronous functions", func() {
- var timeoutDuration time.Duration
-
- BeforeEach(func() {
- timeoutDuration = time.Duration(1 * float64(time.Second))
- })
-
- Context("when running", func() {
- It("should run the function as a goroutine, and block until it's done", func() {
- proveAsync := make(chan bool)
-
- build(func(done Done) {
- didRun = true
- proveAsync <- true
- close(done)
- }, timeoutDuration, failer, componentCodeLocation).Run()
-
- Eventually(proveAsync).Should(Receive(Equal(true)))
- })
- })
-
- Context("when the function passes", func() {
- BeforeEach(func() {
- outcome, failure = build(func(done Done) {
- didRun = true
- close(done)
- }, timeoutDuration, failer, componentCodeLocation).Run()
- })
-
- It("should have a succesful outcome", func() {
- Ω(didRun).Should(BeTrue())
- Ω(outcome).Should(Equal(types.SpecStatePassed))
- Ω(failure).Should(BeZero())
- })
- })
-
- Context("when the function fails", func() {
- BeforeEach(func() {
- outcome, failure = build(func(done Done) {
- didRun = true
- failer.Fail("bam", innerCodeLocation)
- time.Sleep(20 * time.Millisecond)
- defer close(done)
- panic("doesn't matter")
- }, 10*time.Millisecond, failer, componentCodeLocation).Run()
- })
-
- It("should return the failure", func() {
- Ω(didRun).Should(BeTrue())
-
- Ω(outcome).Should(Equal(types.SpecStateFailed))
- Ω(failure).Should(Equal(types.SpecFailure{
- Message: "bam",
- Location: innerCodeLocation,
- ForwardedPanic: "",
- ComponentIndex: componentIndex,
- ComponentType: componentType,
- ComponentCodeLocation: componentCodeLocation,
- }))
- })
- })
-
- Context("when the function doesn't close the done channel in time", func() {
- var guard chan struct{}
-
- BeforeEach(func() {
- guard = make(chan struct{})
- outcome, failure = build(func(done Done) {
- didRun = true
- close(guard)
- }, 10*time.Millisecond, failer, componentCodeLocation).Run()
- })
-
- It("should return a timeout", func() {
- <-guard
- Ω(didRun).Should(BeTrue())
-
- Ω(outcome).Should(Equal(types.SpecStateTimedOut))
- Ω(failure).Should(Equal(types.SpecFailure{
- Message: "Timed out",
- Location: componentCodeLocation,
- ForwardedPanic: "",
- ComponentIndex: componentIndex,
- ComponentType: componentType,
- ComponentCodeLocation: componentCodeLocation,
- }))
- })
- })
-
- Context("when the function panics", func() {
- BeforeEach(func() {
- outcome, failure = build(func(done Done) {
- didRun = true
- innerCodeLocation = codelocation.New(0)
- panic("ack!")
- }, 100*time.Millisecond, failer, componentCodeLocation).Run()
- })
-
- It("should return the panic", func() {
- Ω(didRun).Should(BeTrue())
-
- Ω(outcome).Should(Equal(types.SpecStatePanicked))
- Ω(failure.ForwardedPanic).Should(Equal("ack!"))
- })
- })
-
- Context("when the function panics with a nil value", func() {
- BeforeEach(func() {
- outcome, failure = build(func(done Done) {
- didRun = true
- innerCodeLocation = codelocation.New(0)
- panic(nil)
- }, 100*time.Millisecond, failer, componentCodeLocation).Run()
- })
-
- It("should return the nil-valued panic", func() {
- Ω(didRun).Should(BeTrue())
-
- Ω(outcome).Should(Equal(types.SpecStatePanicked))
- Ω(failure.ForwardedPanic).Should(Equal("<nil>"))
- })
- })
- })
-}
-
-func InvalidSharedRunnerBehaviors(build func(body interface{}, timeout time.Duration, failer *Failer.Failer, componentCodeLocation types.CodeLocation) runnable, componentType types.SpecComponentType) {
- var (
- failer *Failer.Failer
- componentCodeLocation types.CodeLocation
- )
-
- BeforeEach(func() {
- failer = Failer.New()
- componentCodeLocation = codelocation.New(0)
- })
-
- Describe("invalid functions", func() {
- Context("when passed something that's not a function", func() {
- It("should panic", func() {
- Ω(func() {
- build("not a function", 0, failer, componentCodeLocation)
- }).Should(Panic())
- })
- })
-
- Context("when the function takes the wrong kind of argument", func() {
- It("should panic", func() {
- Ω(func() {
- build(func(oops string) {}, 0, failer, componentCodeLocation)
- }).Should(Panic())
- })
- })
-
- Context("when the function takes more than one argument", func() {
- It("should panic", func() {
- Ω(func() {
- build(func(done Done, oops string) {}, 0, failer, componentCodeLocation)
- }).Should(Panic())
- })
- })
- })
-}
-
-var _ = Describe("Shared RunnableNode behavior", func() {
- Describe("It Nodes", func() {
- build := func(body interface{}, timeout time.Duration, failer *Failer.Failer, componentCodeLocation types.CodeLocation) runnable {
- return NewItNode("", body, types.FlagTypeFocused, componentCodeLocation, timeout, failer, 3)
- }
-
- SynchronousSharedRunnerBehaviors(build, types.SpecComponentTypeIt, 3)
- AsynchronousSharedRunnerBehaviors(build, types.SpecComponentTypeIt, 3)
- InvalidSharedRunnerBehaviors(build, types.SpecComponentTypeIt)
- })
-
- Describe("Measure Nodes", func() {
- build := func(body interface{}, _ time.Duration, failer *Failer.Failer, componentCodeLocation types.CodeLocation) runnable {
- return NewMeasureNode("", func(Benchmarker) {
- reflect.ValueOf(body).Call([]reflect.Value{})
- }, types.FlagTypeFocused, componentCodeLocation, 10, failer, 3)
- }
-
- SynchronousSharedRunnerBehaviors(build, types.SpecComponentTypeMeasure, 3)
- })
-
- Describe("BeforeEach Nodes", func() {
- build := func(body interface{}, timeout time.Duration, failer *Failer.Failer, componentCodeLocation types.CodeLocation) runnable {
- return NewBeforeEachNode(body, componentCodeLocation, timeout, failer, 3)
- }
-
- SynchronousSharedRunnerBehaviors(build, types.SpecComponentTypeBeforeEach, 3)
- AsynchronousSharedRunnerBehaviors(build, types.SpecComponentTypeBeforeEach, 3)
- InvalidSharedRunnerBehaviors(build, types.SpecComponentTypeBeforeEach)
- })
-
- Describe("AfterEach Nodes", func() {
- build := func(body interface{}, timeout time.Duration, failer *Failer.Failer, componentCodeLocation types.CodeLocation) runnable {
- return NewAfterEachNode(body, componentCodeLocation, timeout, failer, 3)
- }
-
- SynchronousSharedRunnerBehaviors(build, types.SpecComponentTypeAfterEach, 3)
- AsynchronousSharedRunnerBehaviors(build, types.SpecComponentTypeAfterEach, 3)
- InvalidSharedRunnerBehaviors(build, types.SpecComponentTypeAfterEach)
- })
-
- Describe("JustBeforeEach Nodes", func() {
- build := func(body interface{}, timeout time.Duration, failer *Failer.Failer, componentCodeLocation types.CodeLocation) runnable {
- return NewJustBeforeEachNode(body, componentCodeLocation, timeout, failer, 3)
- }
-
- SynchronousSharedRunnerBehaviors(build, types.SpecComponentTypeJustBeforeEach, 3)
- AsynchronousSharedRunnerBehaviors(build, types.SpecComponentTypeJustBeforeEach, 3)
- InvalidSharedRunnerBehaviors(build, types.SpecComponentTypeJustBeforeEach)
- })
-})
diff --git a/vendor/github.com/onsi/ginkgo/internal/leafnodes/suite_nodes_test.go b/vendor/github.com/onsi/ginkgo/internal/leafnodes/suite_nodes_test.go
deleted file mode 100644
index 246b329fe..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/leafnodes/suite_nodes_test.go
+++ /dev/null
@@ -1,230 +0,0 @@
-package leafnodes_test
-
-import (
- . "github.com/onsi/ginkgo"
- . "github.com/onsi/gomega"
-
- . "github.com/onsi/ginkgo/internal/leafnodes"
-
- "time"
-
- "github.com/onsi/ginkgo/internal/codelocation"
- Failer "github.com/onsi/ginkgo/internal/failer"
- "github.com/onsi/ginkgo/types"
-)
-
-var _ = Describe("SuiteNodes", func() {
- Describe("BeforeSuite nodes", func() {
- var befSuite SuiteNode
- var failer *Failer.Failer
- var codeLocation types.CodeLocation
- var innerCodeLocation types.CodeLocation
- var outcome bool
-
- BeforeEach(func() {
- failer = Failer.New()
- codeLocation = codelocation.New(0)
- innerCodeLocation = codelocation.New(0)
- })
-
- Context("when the body passes", func() {
- BeforeEach(func() {
- befSuite = NewBeforeSuiteNode(func() {
- time.Sleep(10 * time.Millisecond)
- }, codeLocation, 0, failer)
- outcome = befSuite.Run(0, 0, "")
- })
-
- It("should return true when run and report as passed", func() {
- Ω(outcome).Should(BeTrue())
- Ω(befSuite.Passed()).Should(BeTrue())
- })
-
- It("should have the correct summary", func() {
- summary := befSuite.Summary()
- Ω(summary.ComponentType).Should(Equal(types.SpecComponentTypeBeforeSuite))
- Ω(summary.CodeLocation).Should(Equal(codeLocation))
- Ω(summary.State).Should(Equal(types.SpecStatePassed))
- Ω(summary.RunTime).Should(BeNumerically(">=", 10*time.Millisecond))
- Ω(summary.Failure).Should(BeZero())
- })
- })
-
- Context("when the body fails", func() {
- BeforeEach(func() {
- befSuite = NewBeforeSuiteNode(func() {
- failer.Fail("oops", innerCodeLocation)
- }, codeLocation, 0, failer)
- outcome = befSuite.Run(0, 0, "")
- })
-
- It("should return false when run and report as failed", func() {
- Ω(outcome).Should(BeFalse())
- Ω(befSuite.Passed()).Should(BeFalse())
- })
-
- It("should have the correct summary", func() {
- summary := befSuite.Summary()
- Ω(summary.State).Should(Equal(types.SpecStateFailed))
- Ω(summary.Failure.Message).Should(Equal("oops"))
- Ω(summary.Failure.Location).Should(Equal(innerCodeLocation))
- Ω(summary.Failure.ForwardedPanic).Should(BeEmpty())
- Ω(summary.Failure.ComponentIndex).Should(Equal(0))
- Ω(summary.Failure.ComponentType).Should(Equal(types.SpecComponentTypeBeforeSuite))
- Ω(summary.Failure.ComponentCodeLocation).Should(Equal(codeLocation))
- })
- })
-
- Context("when the body times out", func() {
- BeforeEach(func() {
- befSuite = NewBeforeSuiteNode(func(done Done) {
- }, codeLocation, time.Millisecond, failer)
- outcome = befSuite.Run(0, 0, "")
- })
-
- It("should return false when run and report as failed", func() {
- Ω(outcome).Should(BeFalse())
- Ω(befSuite.Passed()).Should(BeFalse())
- })
-
- It("should have the correct summary", func() {
- summary := befSuite.Summary()
- Ω(summary.State).Should(Equal(types.SpecStateTimedOut))
- Ω(summary.Failure.ForwardedPanic).Should(BeEmpty())
- Ω(summary.Failure.ComponentIndex).Should(Equal(0))
- Ω(summary.Failure.ComponentType).Should(Equal(types.SpecComponentTypeBeforeSuite))
- Ω(summary.Failure.ComponentCodeLocation).Should(Equal(codeLocation))
- })
- })
-
- Context("when the body panics", func() {
- BeforeEach(func() {
- befSuite = NewBeforeSuiteNode(func() {
- panic("bam")
- }, codeLocation, 0, failer)
- outcome = befSuite.Run(0, 0, "")
- })
-
- It("should return false when run and report as failed", func() {
- Ω(outcome).Should(BeFalse())
- Ω(befSuite.Passed()).Should(BeFalse())
- })
-
- It("should have the correct summary", func() {
- summary := befSuite.Summary()
- Ω(summary.State).Should(Equal(types.SpecStatePanicked))
- Ω(summary.Failure.ForwardedPanic).Should(Equal("bam"))
- Ω(summary.Failure.ComponentIndex).Should(Equal(0))
- Ω(summary.Failure.ComponentType).Should(Equal(types.SpecComponentTypeBeforeSuite))
- Ω(summary.Failure.ComponentCodeLocation).Should(Equal(codeLocation))
- })
- })
- })
-
- Describe("AfterSuite nodes", func() {
- var aftSuite SuiteNode
- var failer *Failer.Failer
- var codeLocation types.CodeLocation
- var innerCodeLocation types.CodeLocation
- var outcome bool
-
- BeforeEach(func() {
- failer = Failer.New()
- codeLocation = codelocation.New(0)
- innerCodeLocation = codelocation.New(0)
- })
-
- Context("when the body passes", func() {
- BeforeEach(func() {
- aftSuite = NewAfterSuiteNode(func() {
- time.Sleep(10 * time.Millisecond)
- }, codeLocation, 0, failer)
- outcome = aftSuite.Run(0, 0, "")
- })
-
- It("should return true when run and report as passed", func() {
- Ω(outcome).Should(BeTrue())
- Ω(aftSuite.Passed()).Should(BeTrue())
- })
-
- It("should have the correct summary", func() {
- summary := aftSuite.Summary()
- Ω(summary.ComponentType).Should(Equal(types.SpecComponentTypeAfterSuite))
- Ω(summary.CodeLocation).Should(Equal(codeLocation))
- Ω(summary.State).Should(Equal(types.SpecStatePassed))
- Ω(summary.RunTime).Should(BeNumerically(">=", 10*time.Millisecond))
- Ω(summary.Failure).Should(BeZero())
- })
- })
-
- Context("when the body fails", func() {
- BeforeEach(func() {
- aftSuite = NewAfterSuiteNode(func() {
- failer.Fail("oops", innerCodeLocation)
- }, codeLocation, 0, failer)
- outcome = aftSuite.Run(0, 0, "")
- })
-
- It("should return false when run and report as failed", func() {
- Ω(outcome).Should(BeFalse())
- Ω(aftSuite.Passed()).Should(BeFalse())
- })
-
- It("should have the correct summary", func() {
- summary := aftSuite.Summary()
- Ω(summary.State).Should(Equal(types.SpecStateFailed))
- Ω(summary.Failure.Message).Should(Equal("oops"))
- Ω(summary.Failure.Location).Should(Equal(innerCodeLocation))
- Ω(summary.Failure.ForwardedPanic).Should(BeEmpty())
- Ω(summary.Failure.ComponentIndex).Should(Equal(0))
- Ω(summary.Failure.ComponentType).Should(Equal(types.SpecComponentTypeAfterSuite))
- Ω(summary.Failure.ComponentCodeLocation).Should(Equal(codeLocation))
- })
- })
-
- Context("when the body times out", func() {
- BeforeEach(func() {
- aftSuite = NewAfterSuiteNode(func(done Done) {
- }, codeLocation, time.Millisecond, failer)
- outcome = aftSuite.Run(0, 0, "")
- })
-
- It("should return false when run and report as failed", func() {
- Ω(outcome).Should(BeFalse())
- Ω(aftSuite.Passed()).Should(BeFalse())
- })
-
- It("should have the correct summary", func() {
- summary := aftSuite.Summary()
- Ω(summary.State).Should(Equal(types.SpecStateTimedOut))
- Ω(summary.Failure.ForwardedPanic).Should(BeEmpty())
- Ω(summary.Failure.ComponentIndex).Should(Equal(0))
- Ω(summary.Failure.ComponentType).Should(Equal(types.SpecComponentTypeAfterSuite))
- Ω(summary.Failure.ComponentCodeLocation).Should(Equal(codeLocation))
- })
- })
-
- Context("when the body panics", func() {
- BeforeEach(func() {
- aftSuite = NewAfterSuiteNode(func() {
- panic("bam")
- }, codeLocation, 0, failer)
- outcome = aftSuite.Run(0, 0, "")
- })
-
- It("should return false when run and report as failed", func() {
- Ω(outcome).Should(BeFalse())
- Ω(aftSuite.Passed()).Should(BeFalse())
- })
-
- It("should have the correct summary", func() {
- summary := aftSuite.Summary()
- Ω(summary.State).Should(Equal(types.SpecStatePanicked))
- Ω(summary.Failure.ForwardedPanic).Should(Equal("bam"))
- Ω(summary.Failure.ComponentIndex).Should(Equal(0))
- Ω(summary.Failure.ComponentType).Should(Equal(types.SpecComponentTypeAfterSuite))
- Ω(summary.Failure.ComponentCodeLocation).Should(Equal(codeLocation))
- })
- })
- })
-})
diff --git a/vendor/github.com/onsi/ginkgo/internal/leafnodes/synchronized_after_suite_node_test.go b/vendor/github.com/onsi/ginkgo/internal/leafnodes/synchronized_after_suite_node_test.go
deleted file mode 100644
index edbdf6ae5..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/leafnodes/synchronized_after_suite_node_test.go
+++ /dev/null
@@ -1,199 +0,0 @@
-package leafnodes_test
-
-import (
- "sync"
-
- . "github.com/onsi/ginkgo"
- . "github.com/onsi/ginkgo/internal/leafnodes"
- "github.com/onsi/ginkgo/types"
- . "github.com/onsi/gomega"
-
- "net/http"
-
- "github.com/onsi/gomega/ghttp"
-
- "time"
-
- "github.com/onsi/ginkgo/internal/codelocation"
- Failer "github.com/onsi/ginkgo/internal/failer"
-)
-
-var _ = Describe("SynchronizedAfterSuiteNode", func() {
- var failer *Failer.Failer
- var node SuiteNode
- var codeLocation types.CodeLocation
- var innerCodeLocation types.CodeLocation
- var outcome bool
- var server *ghttp.Server
- var things []string
- var lock *sync.Mutex
-
- BeforeEach(func() {
- things = []string{}
- server = ghttp.NewServer()
- codeLocation = codelocation.New(0)
- innerCodeLocation = codelocation.New(0)
- failer = Failer.New()
- lock = &sync.Mutex{}
- })
-
- AfterEach(func() {
- server.Close()
- })
-
- newNode := func(bodyA interface{}, bodyB interface{}) SuiteNode {
- return NewSynchronizedAfterSuiteNode(bodyA, bodyB, codeLocation, time.Millisecond, failer)
- }
-
- ranThing := func(thing string) {
- lock.Lock()
- defer lock.Unlock()
- things = append(things, thing)
- }
-
- thingsThatRan := func() []string {
- lock.Lock()
- defer lock.Unlock()
- return things
- }
-
- Context("when not running in parallel", func() {
- Context("when all is well", func() {
- BeforeEach(func() {
- node = newNode(func() {
- ranThing("A")
- }, func() {
- ranThing("B")
- })
-
- outcome = node.Run(1, 1, server.URL())
- })
-
- It("should run A, then B", func() {
- Ω(thingsThatRan()).Should(Equal([]string{"A", "B"}))
- })
-
- It("should report success", func() {
- Ω(outcome).Should(BeTrue())
- Ω(node.Passed()).Should(BeTrue())
- Ω(node.Summary().State).Should(Equal(types.SpecStatePassed))
- })
- })
-
- Context("when A fails", func() {
- BeforeEach(func() {
- node = newNode(func() {
- ranThing("A")
- failer.Fail("bam", innerCodeLocation)
- }, func() {
- ranThing("B")
- })
-
- outcome = node.Run(1, 1, server.URL())
- })
-
- It("should still run B", func() {
- Ω(thingsThatRan()).Should(Equal([]string{"A", "B"}))
- })
-
- It("should report failure", func() {
- Ω(outcome).Should(BeFalse())
- Ω(node.Passed()).Should(BeFalse())
- Ω(node.Summary().State).Should(Equal(types.SpecStateFailed))
- })
- })
-
- Context("when B fails", func() {
- BeforeEach(func() {
- node = newNode(func() {
- ranThing("A")
- }, func() {
- ranThing("B")
- failer.Fail("bam", innerCodeLocation)
- })
-
- outcome = node.Run(1, 1, server.URL())
- })
-
- It("should run all the things", func() {
- Ω(thingsThatRan()).Should(Equal([]string{"A", "B"}))
- })
-
- It("should report failure", func() {
- Ω(outcome).Should(BeFalse())
- Ω(node.Passed()).Should(BeFalse())
- Ω(node.Summary().State).Should(Equal(types.SpecStateFailed))
- })
- })
- })
-
- Context("when running in parallel", func() {
- Context("as the first node", func() {
- BeforeEach(func() {
- server.AppendHandlers(ghttp.CombineHandlers(
- ghttp.VerifyRequest("GET", "/RemoteAfterSuiteData"),
- func(writer http.ResponseWriter, request *http.Request) {
- ranThing("Request1")
- },
- ghttp.RespondWithJSONEncoded(200, types.RemoteAfterSuiteData{CanRun: false}),
- ), ghttp.CombineHandlers(
- ghttp.VerifyRequest("GET", "/RemoteAfterSuiteData"),
- func(writer http.ResponseWriter, request *http.Request) {
- ranThing("Request2")
- },
- ghttp.RespondWithJSONEncoded(200, types.RemoteAfterSuiteData{CanRun: false}),
- ), ghttp.CombineHandlers(
- ghttp.VerifyRequest("GET", "/RemoteAfterSuiteData"),
- func(writer http.ResponseWriter, request *http.Request) {
- ranThing("Request3")
- },
- ghttp.RespondWithJSONEncoded(200, types.RemoteAfterSuiteData{CanRun: true}),
- ))
-
- node = newNode(func() {
- ranThing("A")
- }, func() {
- ranThing("B")
- })
-
- outcome = node.Run(1, 3, server.URL())
- })
-
- It("should run A and, when the server says its time, run B", func() {
- Ω(thingsThatRan()).Should(Equal([]string{"A", "Request1", "Request2", "Request3", "B"}))
- })
-
- It("should report success", func() {
- Ω(outcome).Should(BeTrue())
- Ω(node.Passed()).Should(BeTrue())
- Ω(node.Summary().State).Should(Equal(types.SpecStatePassed))
- })
- })
-
- Context("as any other node", func() {
- BeforeEach(func() {
- node = newNode(func() {
- ranThing("A")
- }, func() {
- ranThing("B")
- })
-
- outcome = node.Run(2, 3, server.URL())
- })
-
- It("should run A, and not run B", func() {
- Ω(thingsThatRan()).Should(Equal([]string{"A"}))
- })
-
- It("should not talk to the server", func() {
- Ω(server.ReceivedRequests()).Should(BeEmpty())
- })
-
- It("should report success", func() {
- Ω(outcome).Should(BeTrue())
- Ω(node.Passed()).Should(BeTrue())
- Ω(node.Summary().State).Should(Equal(types.SpecStatePassed))
- })
- })
- })
-})
diff --git a/vendor/github.com/onsi/ginkgo/internal/leafnodes/synchronized_before_suite_node_test.go b/vendor/github.com/onsi/ginkgo/internal/leafnodes/synchronized_before_suite_node_test.go
deleted file mode 100644
index 46c3e276b..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/leafnodes/synchronized_before_suite_node_test.go
+++ /dev/null
@@ -1,446 +0,0 @@
-package leafnodes_test
-
-import (
- . "github.com/onsi/ginkgo"
- . "github.com/onsi/ginkgo/internal/leafnodes"
- . "github.com/onsi/gomega"
-
- "net/http"
-
- "github.com/onsi/gomega/ghttp"
-
- "time"
-
- "github.com/onsi/ginkgo/internal/codelocation"
- Failer "github.com/onsi/ginkgo/internal/failer"
- "github.com/onsi/ginkgo/types"
-)
-
-var _ = Describe("SynchronizedBeforeSuiteNode", func() {
- var failer *Failer.Failer
- var node SuiteNode
- var codeLocation types.CodeLocation
- var innerCodeLocation types.CodeLocation
- var outcome bool
- var server *ghttp.Server
-
- BeforeEach(func() {
- server = ghttp.NewServer()
- codeLocation = codelocation.New(0)
- innerCodeLocation = codelocation.New(0)
- failer = Failer.New()
- })
-
- AfterEach(func() {
- server.Close()
- })
-
- newNode := func(bodyA interface{}, bodyB interface{}) SuiteNode {
- return NewSynchronizedBeforeSuiteNode(bodyA, bodyB, codeLocation, time.Millisecond, failer)
- }
-
- Describe("when not running in parallel", func() {
- Context("when all is well", func() {
- var data []byte
- BeforeEach(func() {
- data = nil
-
- node = newNode(func() []byte {
- return []byte("my data")
- }, func(d []byte) {
- data = d
- })
-
- outcome = node.Run(1, 1, server.URL())
- })
-
- It("should run A, then B passing the output from A to B", func() {
- Ω(data).Should(Equal([]byte("my data")))
- })
-
- It("should report success", func() {
- Ω(outcome).Should(BeTrue())
- Ω(node.Passed()).Should(BeTrue())
- Ω(node.Summary().State).Should(Equal(types.SpecStatePassed))
- })
- })
-
- Context("when A fails", func() {
- var ranB bool
- BeforeEach(func() {
- ranB = false
- node = newNode(func() []byte {
- failer.Fail("boom", innerCodeLocation)
- return nil
- }, func([]byte) {
- ranB = true
- })
-
- outcome = node.Run(1, 1, server.URL())
- })
-
- It("should not run B", func() {
- Ω(ranB).Should(BeFalse())
- })
-
- It("should report failure", func() {
- Ω(outcome).Should(BeFalse())
- Ω(node.Passed()).Should(BeFalse())
- Ω(node.Summary().State).Should(Equal(types.SpecStateFailed))
- })
- })
-
- Context("when B fails", func() {
- BeforeEach(func() {
- node = newNode(func() []byte {
- return nil
- }, func([]byte) {
- failer.Fail("boom", innerCodeLocation)
- })
-
- outcome = node.Run(1, 1, server.URL())
- })
-
- It("should report failure", func() {
- Ω(outcome).Should(BeFalse())
- Ω(node.Passed()).Should(BeFalse())
- Ω(node.Summary().State).Should(Equal(types.SpecStateFailed))
- })
- })
-
- Context("when A times out", func() {
- var ranB bool
- BeforeEach(func() {
- ranB = false
- node = newNode(func(Done) []byte {
- time.Sleep(time.Second)
- return nil
- }, func([]byte) {
- ranB = true
- })
-
- outcome = node.Run(1, 1, server.URL())
- })
-
- It("should not run B", func() {
- Ω(ranB).Should(BeFalse())
- })
-
- It("should report failure", func() {
- Ω(outcome).Should(BeFalse())
- Ω(node.Passed()).Should(BeFalse())
- Ω(node.Summary().State).Should(Equal(types.SpecStateTimedOut))
- })
- })
-
- Context("when B times out", func() {
- BeforeEach(func() {
- node = newNode(func() []byte {
- return nil
- }, func([]byte, Done) {
- time.Sleep(time.Second)
- })
-
- outcome = node.Run(1, 1, server.URL())
- })
-
- It("should report failure", func() {
- Ω(outcome).Should(BeFalse())
- Ω(node.Passed()).Should(BeFalse())
- Ω(node.Summary().State).Should(Equal(types.SpecStateTimedOut))
- })
- })
- })
-
- Describe("when running in parallel", func() {
- var ranB bool
- var parallelNode, parallelTotal int
- BeforeEach(func() {
- ranB = false
- parallelNode, parallelTotal = 1, 3
- })
-
- Context("as the first node, it runs A", func() {
- var expectedState types.RemoteBeforeSuiteData
-
- BeforeEach(func() {
- parallelNode, parallelTotal = 1, 3
- })
-
- JustBeforeEach(func() {
- server.AppendHandlers(ghttp.CombineHandlers(
- ghttp.VerifyRequest("POST", "/BeforeSuiteState"),
- ghttp.VerifyJSONRepresenting(expectedState),
- ))
-
- outcome = node.Run(parallelNode, parallelTotal, server.URL())
- })
-
- Context("when A succeeds", func() {
- BeforeEach(func() {
- expectedState = types.RemoteBeforeSuiteData{Data: []byte("my data"), State: types.RemoteBeforeSuiteStatePassed}
-
- node = newNode(func() []byte {
- return []byte("my data")
- }, func([]byte) {
- ranB = true
- })
- })
-
- It("should post about A succeeding", func() {
- Ω(server.ReceivedRequests()).Should(HaveLen(1))
- })
-
- It("should run B", func() {
- Ω(ranB).Should(BeTrue())
- })
-
- It("should report success", func() {
- Ω(outcome).Should(BeTrue())
- })
- })
-
- Context("when A fails", func() {
- BeforeEach(func() {
- expectedState = types.RemoteBeforeSuiteData{Data: nil, State: types.RemoteBeforeSuiteStateFailed}
-
- node = newNode(func() []byte {
- panic("BAM")
- }, func([]byte) {
- ranB = true
- })
- })
-
- It("should post about A failing", func() {
- Ω(server.ReceivedRequests()).Should(HaveLen(1))
- })
-
- It("should not run B", func() {
- Ω(ranB).Should(BeFalse())
- })
-
- It("should report failure", func() {
- Ω(outcome).Should(BeFalse())
- })
- })
- })
-
- Context("as the Nth node", func() {
- var statusCode int
- var response interface{}
- var ranA bool
- var bData []byte
-
- BeforeEach(func() {
- ranA = false
- bData = nil
-
- statusCode = http.StatusOK
-
- server.AppendHandlers(ghttp.CombineHandlers(
- ghttp.VerifyRequest("GET", "/BeforeSuiteState"),
- ghttp.RespondWith(http.StatusOK, string((types.RemoteBeforeSuiteData{Data: nil, State: types.RemoteBeforeSuiteStatePending}).ToJSON())),
- ), ghttp.CombineHandlers(
- ghttp.VerifyRequest("GET", "/BeforeSuiteState"),
- ghttp.RespondWith(http.StatusOK, string((types.RemoteBeforeSuiteData{Data: nil, State: types.RemoteBeforeSuiteStatePending}).ToJSON())),
- ), ghttp.CombineHandlers(
- ghttp.VerifyRequest("GET", "/BeforeSuiteState"),
- ghttp.RespondWithJSONEncodedPtr(&statusCode, &response),
- ))
-
- node = newNode(func() []byte {
- ranA = true
- return nil
- }, func(data []byte) {
- bData = data
- })
-
- parallelNode, parallelTotal = 2, 3
- })
-
- Context("when A on node1 succeeds", func() {
- BeforeEach(func() {
- response = types.RemoteBeforeSuiteData{Data: []byte("my data"), State: types.RemoteBeforeSuiteStatePassed}
- outcome = node.Run(parallelNode, parallelTotal, server.URL())
- })
-
- It("should not run A", func() {
- Ω(ranA).Should(BeFalse())
- })
-
- It("should poll for A", func() {
- Ω(server.ReceivedRequests()).Should(HaveLen(3))
- })
-
- It("should run B when the polling succeeds", func() {
- Ω(bData).Should(Equal([]byte("my data")))
- })
-
- It("should succeed", func() {
- Ω(outcome).Should(BeTrue())
- Ω(node.Passed()).Should(BeTrue())
- })
- })
-
- Context("when A on node1 fails", func() {
- BeforeEach(func() {
- response = types.RemoteBeforeSuiteData{Data: []byte("my data"), State: types.RemoteBeforeSuiteStateFailed}
- outcome = node.Run(parallelNode, parallelTotal, server.URL())
- })
-
- It("should not run A", func() {
- Ω(ranA).Should(BeFalse())
- })
-
- It("should poll for A", func() {
- Ω(server.ReceivedRequests()).Should(HaveLen(3))
- })
-
- It("should not run B", func() {
- Ω(bData).Should(BeNil())
- })
-
- It("should fail", func() {
- Ω(outcome).Should(BeFalse())
- Ω(node.Passed()).Should(BeFalse())
-
- summary := node.Summary()
- Ω(summary.State).Should(Equal(types.SpecStateFailed))
- Ω(summary.Failure.Message).Should(Equal("BeforeSuite on Node 1 failed"))
- Ω(summary.Failure.Location).Should(Equal(codeLocation))
- Ω(summary.Failure.ComponentType).Should(Equal(types.SpecComponentTypeBeforeSuite))
- Ω(summary.Failure.ComponentIndex).Should(Equal(0))
- Ω(summary.Failure.ComponentCodeLocation).Should(Equal(codeLocation))
- })
- })
-
- Context("when node1 disappears", func() {
- BeforeEach(func() {
- response = types.RemoteBeforeSuiteData{Data: []byte("my data"), State: types.RemoteBeforeSuiteStateDisappeared}
- outcome = node.Run(parallelNode, parallelTotal, server.URL())
- })
-
- It("should not run A", func() {
- Ω(ranA).Should(BeFalse())
- })
-
- It("should poll for A", func() {
- Ω(server.ReceivedRequests()).Should(HaveLen(3))
- })
-
- It("should not run B", func() {
- Ω(bData).Should(BeNil())
- })
-
- It("should fail", func() {
- Ω(outcome).Should(BeFalse())
- Ω(node.Passed()).Should(BeFalse())
-
- summary := node.Summary()
- Ω(summary.State).Should(Equal(types.SpecStateFailed))
- Ω(summary.Failure.Message).Should(Equal("Node 1 disappeared before completing BeforeSuite"))
- Ω(summary.Failure.Location).Should(Equal(codeLocation))
- Ω(summary.Failure.ComponentType).Should(Equal(types.SpecComponentTypeBeforeSuite))
- Ω(summary.Failure.ComponentIndex).Should(Equal(0))
- Ω(summary.Failure.ComponentCodeLocation).Should(Equal(codeLocation))
- })
- })
- })
- })
-
- Describe("construction", func() {
- Describe("the first function", func() {
- Context("when the first function returns a byte array", func() {
- Context("and takes nothing", func() {
- It("should be fine", func() {
- Ω(func() {
- newNode(func() []byte { return nil }, func([]byte) {})
- }).ShouldNot(Panic())
- })
- })
-
- Context("and takes a done function", func() {
- It("should be fine", func() {
- Ω(func() {
- newNode(func(Done) []byte { return nil }, func([]byte) {})
- }).ShouldNot(Panic())
- })
- })
-
- Context("and takes more than one thing", func() {
- It("should panic", func() {
- Ω(func() {
- newNode(func(Done, Done) []byte { return nil }, func([]byte) {})
- }).Should(Panic())
- })
- })
-
- Context("and takes something else", func() {
- It("should panic", func() {
- Ω(func() {
- newNode(func(bool) []byte { return nil }, func([]byte) {})
- }).Should(Panic())
- })
- })
- })
-
- Context("when the first function does not return a byte array", func() {
- It("should panic", func() {
- Ω(func() {
- newNode(func() {}, func([]byte) {})
- }).Should(Panic())
-
- Ω(func() {
- newNode(func() []int { return nil }, func([]byte) {})
- }).Should(Panic())
- })
- })
- })
-
- Describe("the second function", func() {
- Context("when the second function takes a byte array", func() {
- It("should be fine", func() {
- Ω(func() {
- newNode(func() []byte { return nil }, func([]byte) {})
- }).ShouldNot(Panic())
- })
- })
-
- Context("when it also takes a done channel", func() {
- It("should be fine", func() {
- Ω(func() {
- newNode(func() []byte { return nil }, func([]byte, Done) {})
- }).ShouldNot(Panic())
- })
- })
-
- Context("if it takes anything else", func() {
- It("should panic", func() {
- Ω(func() {
- newNode(func() []byte { return nil }, func([]byte, chan bool) {})
- }).Should(Panic())
-
- Ω(func() {
- newNode(func() []byte { return nil }, func(string) {})
- }).Should(Panic())
- })
- })
-
- Context("if it takes nothing at all", func() {
- It("should panic", func() {
- Ω(func() {
- newNode(func() []byte { return nil }, func() {})
- }).Should(Panic())
- })
- })
-
- Context("if it returns something", func() {
- It("should panic", func() {
- Ω(func() {
- newNode(func() []byte { return nil }, func([]byte) []byte { return nil })
- }).Should(Panic())
- })
- })
- })
- })
-})
diff --git a/vendor/github.com/onsi/ginkgo/internal/remote/aggregator_test.go b/vendor/github.com/onsi/ginkgo/internal/remote/aggregator_test.go
deleted file mode 100644
index aedf93927..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/remote/aggregator_test.go
+++ /dev/null
@@ -1,315 +0,0 @@
-package remote_test
-
-import (
- . "github.com/onsi/ginkgo"
- . "github.com/onsi/gomega"
-
- "time"
-
- "github.com/onsi/ginkgo/config"
- . "github.com/onsi/ginkgo/internal/remote"
- st "github.com/onsi/ginkgo/reporters/stenographer"
- "github.com/onsi/ginkgo/types"
-)
-
-var _ = Describe("Aggregator", func() {
- var (
- aggregator *Aggregator
- reporterConfig config.DefaultReporterConfigType
- stenographer *st.FakeStenographer
- result chan bool
-
- ginkgoConfig1 config.GinkgoConfigType
- ginkgoConfig2 config.GinkgoConfigType
-
- suiteSummary1 *types.SuiteSummary
- suiteSummary2 *types.SuiteSummary
-
- beforeSummary *types.SetupSummary
- afterSummary *types.SetupSummary
- specSummary *types.SpecSummary
-
- suiteDescription string
- )
-
- BeforeEach(func() {
- reporterConfig = config.DefaultReporterConfigType{
- NoColor: false,
- SlowSpecThreshold: 0.1,
- NoisyPendings: true,
- Succinct: false,
- Verbose: true,
- }
- stenographer = st.NewFakeStenographer()
- result = make(chan bool, 1)
- aggregator = NewAggregator(2, result, reporterConfig, stenographer)
-
- //
- // now set up some fixture data
- //
-
- ginkgoConfig1 = config.GinkgoConfigType{
- RandomSeed: 1138,
- RandomizeAllSpecs: true,
- ParallelNode: 1,
- ParallelTotal: 2,
- }
-
- ginkgoConfig2 = config.GinkgoConfigType{
- RandomSeed: 1138,
- RandomizeAllSpecs: true,
- ParallelNode: 2,
- ParallelTotal: 2,
- }
-
- suiteDescription = "My Parallel Suite"
-
- suiteSummary1 = &types.SuiteSummary{
- SuiteDescription: suiteDescription,
-
- NumberOfSpecsBeforeParallelization: 30,
- NumberOfTotalSpecs: 17,
- NumberOfSpecsThatWillBeRun: 15,
- NumberOfPendingSpecs: 1,
- NumberOfSkippedSpecs: 1,
- }
-
- suiteSummary2 = &types.SuiteSummary{
- SuiteDescription: suiteDescription,
-
- NumberOfSpecsBeforeParallelization: 30,
- NumberOfTotalSpecs: 13,
- NumberOfSpecsThatWillBeRun: 8,
- NumberOfPendingSpecs: 2,
- NumberOfSkippedSpecs: 3,
- }
-
- beforeSummary = &types.SetupSummary{
- State: types.SpecStatePassed,
- CapturedOutput: "BeforeSuiteOutput",
- }
-
- afterSummary = &types.SetupSummary{
- State: types.SpecStatePassed,
- CapturedOutput: "AfterSuiteOutput",
- }
-
- specSummary = &types.SpecSummary{
- State: types.SpecStatePassed,
- CapturedOutput: "SpecOutput",
- }
- })
-
- call := func(method string, args ...interface{}) st.FakeStenographerCall {
- return st.NewFakeStenographerCall(method, args...)
- }
-
- beginSuite := func() {
- stenographer.Reset()
- aggregator.SpecSuiteWillBegin(ginkgoConfig2, suiteSummary2)
- aggregator.SpecSuiteWillBegin(ginkgoConfig1, suiteSummary1)
- Eventually(func() interface{} {
- return len(stenographer.Calls())
- }).Should(BeNumerically(">=", 3))
- }
-
- Describe("Announcing the beginning of the suite", func() {
- Context("When one of the parallel-suites starts", func() {
- BeforeEach(func() {
- aggregator.SpecSuiteWillBegin(ginkgoConfig2, suiteSummary2)
- })
-
- It("should be silent", func() {
- Consistently(func() interface{} { return stenographer.Calls() }).Should(BeEmpty())
- })
- })
-
- Context("once all of the parallel-suites have started", func() {
- BeforeEach(func() {
- aggregator.SpecSuiteWillBegin(ginkgoConfig2, suiteSummary2)
- aggregator.SpecSuiteWillBegin(ginkgoConfig1, suiteSummary1)
- Eventually(func() interface{} {
- return stenographer.Calls()
- }).Should(HaveLen(3))
- })
-
- It("should announce the beginning of the suite", func() {
- Ω(stenographer.Calls()).Should(HaveLen(3))
- Ω(stenographer.Calls()[0]).Should(Equal(call("AnnounceSuite", suiteDescription, ginkgoConfig1.RandomSeed, true, false)))
- Ω(stenographer.Calls()[1]).Should(Equal(call("AnnounceTotalNumberOfSpecs", 30, false)))
- Ω(stenographer.Calls()[2]).Should(Equal(call("AnnounceAggregatedParallelRun", 2, false)))
- })
- })
- })
-
- Describe("Announcing specs and before suites", func() {
- Context("when the parallel-suites have not all started", func() {
- BeforeEach(func() {
- aggregator.BeforeSuiteDidRun(beforeSummary)
- aggregator.AfterSuiteDidRun(afterSummary)
- aggregator.SpecDidComplete(specSummary)
- })
-
- It("should not announce any specs", func() {
- Consistently(func() interface{} { return stenographer.Calls() }).Should(BeEmpty())
- })
-
- Context("when the parallel-suites subsequently start", func() {
- BeforeEach(func() {
- beginSuite()
- })
-
- It("should announce the specs, the before suites and the after suites", func() {
- Eventually(func() interface{} {
- return stenographer.Calls()
- }).Should(ContainElement(call("AnnounceSuccesfulSpec", specSummary)))
-
- Ω(stenographer.Calls()).Should(ContainElement(call("AnnounceCapturedOutput", beforeSummary.CapturedOutput)))
- Ω(stenographer.Calls()).Should(ContainElement(call("AnnounceCapturedOutput", afterSummary.CapturedOutput)))
- })
- })
- })
-
- Context("When the parallel-suites have all started", func() {
- BeforeEach(func() {
- beginSuite()
- stenographer.Reset()
- })
-
- Context("When a spec completes", func() {
- BeforeEach(func() {
- aggregator.BeforeSuiteDidRun(beforeSummary)
- aggregator.SpecDidComplete(specSummary)
- aggregator.AfterSuiteDidRun(afterSummary)
- Eventually(func() interface{} {
- return stenographer.Calls()
- }).Should(HaveLen(5))
- })
-
- It("should announce the captured output of the BeforeSuite", func() {
- Ω(stenographer.Calls()[0]).Should(Equal(call("AnnounceCapturedOutput", beforeSummary.CapturedOutput)))
- })
-
- It("should announce that the spec will run (when in verbose mode)", func() {
- Ω(stenographer.Calls()[1]).Should(Equal(call("AnnounceSpecWillRun", specSummary)))
- })
-
- It("should announce the captured stdout of the spec", func() {
- Ω(stenographer.Calls()[2]).Should(Equal(call("AnnounceCapturedOutput", specSummary.CapturedOutput)))
- })
-
- It("should announce completion", func() {
- Ω(stenographer.Calls()[3]).Should(Equal(call("AnnounceSuccesfulSpec", specSummary)))
- })
-
- It("should announce the captured output of the AfterSuite", func() {
- Ω(stenographer.Calls()[4]).Should(Equal(call("AnnounceCapturedOutput", afterSummary.CapturedOutput)))
- })
- })
- })
- })
-
- Describe("Announcing the end of the suite", func() {
- BeforeEach(func() {
- beginSuite()
- stenographer.Reset()
- })
-
- Context("When one of the parallel-suites ends", func() {
- BeforeEach(func() {
- aggregator.SpecSuiteDidEnd(suiteSummary2)
- })
-
- It("should be silent", func() {
- Consistently(func() interface{} { return stenographer.Calls() }).Should(BeEmpty())
- })
-
- It("should not notify the channel", func() {
- Ω(result).Should(BeEmpty())
- })
- })
-
- Context("once all of the parallel-suites end", func() {
- BeforeEach(func() {
- time.Sleep(200 * time.Millisecond)
-
- suiteSummary1.SuiteSucceeded = true
- suiteSummary1.NumberOfPassedSpecs = 15
- suiteSummary1.NumberOfFailedSpecs = 0
- suiteSummary1.NumberOfFlakedSpecs = 3
- suiteSummary2.SuiteSucceeded = false
- suiteSummary2.NumberOfPassedSpecs = 5
- suiteSummary2.NumberOfFailedSpecs = 3
- suiteSummary2.NumberOfFlakedSpecs = 4
-
- aggregator.SpecSuiteDidEnd(suiteSummary2)
- aggregator.SpecSuiteDidEnd(suiteSummary1)
- Eventually(func() interface{} {
- return stenographer.Calls()
- }).Should(HaveLen(2))
- })
-
- It("should announce the end of the suite", func() {
- compositeSummary := stenographer.Calls()[1].Args[0].(*types.SuiteSummary)
-
- Ω(compositeSummary.SuiteSucceeded).Should(BeFalse())
- Ω(compositeSummary.NumberOfSpecsThatWillBeRun).Should(Equal(23))
- Ω(compositeSummary.NumberOfTotalSpecs).Should(Equal(30))
- Ω(compositeSummary.NumberOfPassedSpecs).Should(Equal(20))
- Ω(compositeSummary.NumberOfFailedSpecs).Should(Equal(3))
- Ω(compositeSummary.NumberOfPendingSpecs).Should(Equal(3))
- Ω(compositeSummary.NumberOfSkippedSpecs).Should(Equal(4))
- Ω(compositeSummary.NumberOfFlakedSpecs).Should(Equal(7))
- Ω(compositeSummary.RunTime.Seconds()).Should(BeNumerically(">", 0.2))
- })
- })
-
- Context("when all the parallel-suites pass", func() {
- BeforeEach(func() {
- suiteSummary1.SuiteSucceeded = true
- suiteSummary2.SuiteSucceeded = true
-
- aggregator.SpecSuiteDidEnd(suiteSummary2)
- aggregator.SpecSuiteDidEnd(suiteSummary1)
- Eventually(func() interface{} {
- return stenographer.Calls()
- }).Should(HaveLen(2))
- })
-
- It("should report success", func() {
- compositeSummary := stenographer.Calls()[1].Args[0].(*types.SuiteSummary)
-
- Ω(compositeSummary.SuiteSucceeded).Should(BeTrue())
- })
-
- It("should notify the channel that it succeded", func(done Done) {
- Ω(<-result).Should(BeTrue())
- close(done)
- })
- })
-
- Context("when one of the parallel-suites fails", func() {
- BeforeEach(func() {
- suiteSummary1.SuiteSucceeded = true
- suiteSummary2.SuiteSucceeded = false
-
- aggregator.SpecSuiteDidEnd(suiteSummary2)
- aggregator.SpecSuiteDidEnd(suiteSummary1)
- Eventually(func() interface{} {
- return stenographer.Calls()
- }).Should(HaveLen(2))
- })
-
- It("should report failure", func() {
- compositeSummary := stenographer.Calls()[1].Args[0].(*types.SuiteSummary)
-
- Ω(compositeSummary.SuiteSucceeded).Should(BeFalse())
- })
-
- It("should notify the channel that it failed", func(done Done) {
- Ω(<-result).Should(BeFalse())
- close(done)
- })
- })
- })
-})
diff --git a/vendor/github.com/onsi/ginkgo/internal/remote/fake_output_interceptor_test.go b/vendor/github.com/onsi/ginkgo/internal/remote/fake_output_interceptor_test.go
deleted file mode 100644
index ef54862ea..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/remote/fake_output_interceptor_test.go
+++ /dev/null
@@ -1,22 +0,0 @@
-package remote_test
-
-import "os"
-
-type fakeOutputInterceptor struct {
- DidStartInterceptingOutput bool
- DidStopInterceptingOutput bool
- InterceptedOutput string
-}
-
-func (interceptor *fakeOutputInterceptor) StartInterceptingOutput() error {
- interceptor.DidStartInterceptingOutput = true
- return nil
-}
-
-func (interceptor *fakeOutputInterceptor) StopInterceptingAndReturnOutput() (string, error) {
- interceptor.DidStopInterceptingOutput = true
- return interceptor.InterceptedOutput, nil
-}
-
-func (interceptor *fakeOutputInterceptor) StreamTo(*os.File) {
-}
diff --git a/vendor/github.com/onsi/ginkgo/internal/remote/fake_poster_test.go b/vendor/github.com/onsi/ginkgo/internal/remote/fake_poster_test.go
deleted file mode 100644
index 3543c59c6..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/remote/fake_poster_test.go
+++ /dev/null
@@ -1,33 +0,0 @@
-package remote_test
-
-import (
- "io"
- "io/ioutil"
- "net/http"
-)
-
-type post struct {
- url string
- bodyType string
- bodyContent []byte
-}
-
-type fakePoster struct {
- posts []post
-}
-
-func newFakePoster() *fakePoster {
- return &fakePoster{
- posts: make([]post, 0),
- }
-}
-
-func (poster *fakePoster) Post(url string, bodyType string, body io.Reader) (resp *http.Response, err error) {
- bodyContent, _ := ioutil.ReadAll(body)
- poster.posts = append(poster.posts, post{
- url: url,
- bodyType: bodyType,
- bodyContent: bodyContent,
- })
- return nil, nil
-}
diff --git a/vendor/github.com/onsi/ginkgo/internal/remote/forwarding_reporter_test.go b/vendor/github.com/onsi/ginkgo/internal/remote/forwarding_reporter_test.go
deleted file mode 100644
index 0d7e4769c..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/remote/forwarding_reporter_test.go
+++ /dev/null
@@ -1,181 +0,0 @@
-package remote_test
-
-import (
- "encoding/json"
-
- . "github.com/onsi/ginkgo"
- "github.com/onsi/ginkgo/config"
- . "github.com/onsi/ginkgo/internal/remote"
- "github.com/onsi/ginkgo/types"
- . "github.com/onsi/gomega"
-)
-
-var _ = Describe("ForwardingReporter", func() {
- var (
- reporter *ForwardingReporter
- interceptor *fakeOutputInterceptor
- poster *fakePoster
- suiteSummary *types.SuiteSummary
- specSummary *types.SpecSummary
- setupSummary *types.SetupSummary
- serverHost string
- )
-
- BeforeEach(func() {
- serverHost = "http://127.0.0.1:7788"
-
- poster = newFakePoster()
-
- interceptor = &fakeOutputInterceptor{
- InterceptedOutput: "The intercepted output!",
- }
-
- reporter = NewForwardingReporter(config.DefaultReporterConfigType{}, serverHost, poster, interceptor, nil, "")
-
- suiteSummary = &types.SuiteSummary{
- SuiteDescription: "My Test Suite",
- }
-
- setupSummary = &types.SetupSummary{
- State: types.SpecStatePassed,
- }
-
- specSummary = &types.SpecSummary{
- ComponentTexts: []string{"My", "Spec"},
- State: types.SpecStatePassed,
- }
- })
-
- Context("When a suite begins", func() {
- BeforeEach(func() {
- reporter.SpecSuiteWillBegin(config.GinkgoConfig, suiteSummary)
- })
-
- It("should start intercepting output", func() {
- Ω(interceptor.DidStartInterceptingOutput).Should(BeTrue())
- })
-
- It("should POST the SuiteSummary and Ginkgo Config to the Ginkgo server", func() {
- Ω(poster.posts).Should(HaveLen(1))
- Ω(poster.posts[0].url).Should(Equal("http://127.0.0.1:7788/SpecSuiteWillBegin"))
- Ω(poster.posts[0].bodyType).Should(Equal("application/json"))
-
- var sentData struct {
- SentConfig config.GinkgoConfigType `json:"config"`
- SentSuiteSummary *types.SuiteSummary `json:"suite-summary"`
- }
-
- err := json.Unmarshal(poster.posts[0].bodyContent, &sentData)
- Ω(err).ShouldNot(HaveOccurred())
-
- Ω(sentData.SentConfig).Should(Equal(config.GinkgoConfig))
- Ω(sentData.SentSuiteSummary).Should(Equal(suiteSummary))
- })
- })
-
- Context("when a BeforeSuite completes", func() {
- BeforeEach(func() {
- reporter.BeforeSuiteDidRun(setupSummary)
- })
-
- It("should stop, then start intercepting output", func() {
- Ω(interceptor.DidStopInterceptingOutput).Should(BeTrue())
- Ω(interceptor.DidStartInterceptingOutput).Should(BeTrue())
- })
-
- It("should POST the SetupSummary to the Ginkgo server", func() {
- Ω(poster.posts).Should(HaveLen(1))
- Ω(poster.posts[0].url).Should(Equal("http://127.0.0.1:7788/BeforeSuiteDidRun"))
- Ω(poster.posts[0].bodyType).Should(Equal("application/json"))
-
- var summary *types.SetupSummary
- err := json.Unmarshal(poster.posts[0].bodyContent, &summary)
- Ω(err).ShouldNot(HaveOccurred())
- setupSummary.CapturedOutput = interceptor.InterceptedOutput
- Ω(summary).Should(Equal(setupSummary))
- })
- })
-
- Context("when an AfterSuite completes", func() {
- BeforeEach(func() {
- reporter.AfterSuiteDidRun(setupSummary)
- })
-
- It("should stop, then start intercepting output", func() {
- Ω(interceptor.DidStopInterceptingOutput).Should(BeTrue())
- Ω(interceptor.DidStartInterceptingOutput).Should(BeTrue())
- })
-
- It("should POST the SetupSummary to the Ginkgo server", func() {
- Ω(poster.posts).Should(HaveLen(1))
- Ω(poster.posts[0].url).Should(Equal("http://127.0.0.1:7788/AfterSuiteDidRun"))
- Ω(poster.posts[0].bodyType).Should(Equal("application/json"))
-
- var summary *types.SetupSummary
- err := json.Unmarshal(poster.posts[0].bodyContent, &summary)
- Ω(err).ShouldNot(HaveOccurred())
- setupSummary.CapturedOutput = interceptor.InterceptedOutput
- Ω(summary).Should(Equal(setupSummary))
- })
- })
-
- Context("When a spec will run", func() {
- BeforeEach(func() {
- reporter.SpecWillRun(specSummary)
- })
-
- It("should POST the SpecSummary to the Ginkgo server", func() {
- Ω(poster.posts).Should(HaveLen(1))
- Ω(poster.posts[0].url).Should(Equal("http://127.0.0.1:7788/SpecWillRun"))
- Ω(poster.posts[0].bodyType).Should(Equal("application/json"))
-
- var summary *types.SpecSummary
- err := json.Unmarshal(poster.posts[0].bodyContent, &summary)
- Ω(err).ShouldNot(HaveOccurred())
- Ω(summary).Should(Equal(specSummary))
- })
-
- Context("When a spec completes", func() {
- BeforeEach(func() {
- specSummary.State = types.SpecStatePanicked
- reporter.SpecDidComplete(specSummary)
- })
-
- It("should POST the SpecSummary to the Ginkgo server and include any intercepted output", func() {
- Ω(poster.posts).Should(HaveLen(2))
- Ω(poster.posts[1].url).Should(Equal("http://127.0.0.1:7788/SpecDidComplete"))
- Ω(poster.posts[1].bodyType).Should(Equal("application/json"))
-
- var summary *types.SpecSummary
- err := json.Unmarshal(poster.posts[1].bodyContent, &summary)
- Ω(err).ShouldNot(HaveOccurred())
- specSummary.CapturedOutput = interceptor.InterceptedOutput
- Ω(summary).Should(Equal(specSummary))
- })
-
- It("should stop, then start intercepting output", func() {
- Ω(interceptor.DidStopInterceptingOutput).Should(BeTrue())
- Ω(interceptor.DidStartInterceptingOutput).Should(BeTrue())
- })
- })
- })
-
- Context("When a suite ends", func() {
- BeforeEach(func() {
- reporter.SpecSuiteDidEnd(suiteSummary)
- })
-
- It("should POST the SuiteSummary to the Ginkgo server", func() {
- Ω(poster.posts).Should(HaveLen(1))
- Ω(poster.posts[0].url).Should(Equal("http://127.0.0.1:7788/SpecSuiteDidEnd"))
- Ω(poster.posts[0].bodyType).Should(Equal("application/json"))
-
- var summary *types.SuiteSummary
-
- err := json.Unmarshal(poster.posts[0].bodyContent, &summary)
- Ω(err).ShouldNot(HaveOccurred())
-
- Ω(summary).Should(Equal(suiteSummary))
- })
- })
-})
diff --git a/vendor/github.com/onsi/ginkgo/internal/remote/remote_suite_test.go b/vendor/github.com/onsi/ginkgo/internal/remote/remote_suite_test.go
deleted file mode 100644
index e6b4e9f32..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/remote/remote_suite_test.go
+++ /dev/null
@@ -1,13 +0,0 @@
-package remote_test
-
-import (
- . "github.com/onsi/ginkgo"
- . "github.com/onsi/gomega"
-
- "testing"
-)
-
-func TestRemote(t *testing.T) {
- RegisterFailHandler(Fail)
- RunSpecs(t, "Remote Spec Forwarding Suite")
-}
diff --git a/vendor/github.com/onsi/ginkgo/internal/remote/server_test.go b/vendor/github.com/onsi/ginkgo/internal/remote/server_test.go
deleted file mode 100644
index 36bd00355..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/remote/server_test.go
+++ /dev/null
@@ -1,269 +0,0 @@
-package remote_test
-
-import (
- . "github.com/onsi/ginkgo"
- . "github.com/onsi/ginkgo/internal/remote"
- . "github.com/onsi/gomega"
-
- "github.com/onsi/ginkgo/config"
- "github.com/onsi/ginkgo/reporters"
- "github.com/onsi/ginkgo/types"
-
- "bytes"
- "encoding/json"
- "net/http"
-)
-
-var _ = Describe("Server", func() {
- var (
- server *Server
- )
-
- BeforeEach(func() {
- var err error
- server, err = NewServer(3)
- Ω(err).ShouldNot(HaveOccurred())
-
- server.Start()
- })
-
- AfterEach(func() {
- server.Close()
- })
-
- Describe("Streaming endpoints", func() {
- var (
- reporterA, reporterB *reporters.FakeReporter
- forwardingReporter *ForwardingReporter
-
- suiteSummary *types.SuiteSummary
- setupSummary *types.SetupSummary
- specSummary *types.SpecSummary
- )
-
- BeforeEach(func() {
- reporterA = reporters.NewFakeReporter()
- reporterB = reporters.NewFakeReporter()
-
- server.RegisterReporters(reporterA, reporterB)
-
- forwardingReporter = NewForwardingReporter(config.DefaultReporterConfigType{}, server.Address(), &http.Client{}, &fakeOutputInterceptor{}, nil, "")
-
- suiteSummary = &types.SuiteSummary{
- SuiteDescription: "My Test Suite",
- }
-
- setupSummary = &types.SetupSummary{
- State: types.SpecStatePassed,
- }
-
- specSummary = &types.SpecSummary{
- ComponentTexts: []string{"My", "Spec"},
- State: types.SpecStatePassed,
- }
- })
-
- It("should make its address available", func() {
- Ω(server.Address()).Should(MatchRegexp(`http://127.0.0.1:\d{2,}`))
- })
-
- Describe("/SpecSuiteWillBegin", func() {
- It("should decode and forward the Ginkgo config and suite summary", func(done Done) {
- forwardingReporter.SpecSuiteWillBegin(config.GinkgoConfig, suiteSummary)
- Ω(reporterA.Config).Should(Equal(config.GinkgoConfig))
- Ω(reporterB.Config).Should(Equal(config.GinkgoConfig))
- Ω(reporterA.BeginSummary).Should(Equal(suiteSummary))
- Ω(reporterB.BeginSummary).Should(Equal(suiteSummary))
- close(done)
- })
- })
-
- Describe("/BeforeSuiteDidRun", func() {
- It("should decode and forward the setup summary", func() {
- forwardingReporter.BeforeSuiteDidRun(setupSummary)
- Ω(reporterA.BeforeSuiteSummary).Should(Equal(setupSummary))
- Ω(reporterB.BeforeSuiteSummary).Should(Equal(setupSummary))
- })
- })
-
- Describe("/AfterSuiteDidRun", func() {
- It("should decode and forward the setup summary", func() {
- forwardingReporter.AfterSuiteDidRun(setupSummary)
- Ω(reporterA.AfterSuiteSummary).Should(Equal(setupSummary))
- Ω(reporterB.AfterSuiteSummary).Should(Equal(setupSummary))
- })
- })
-
- Describe("/SpecWillRun", func() {
- It("should decode and forward the spec summary", func(done Done) {
- forwardingReporter.SpecWillRun(specSummary)
- Ω(reporterA.SpecWillRunSummaries[0]).Should(Equal(specSummary))
- Ω(reporterB.SpecWillRunSummaries[0]).Should(Equal(specSummary))
- close(done)
- })
- })
-
- Describe("/SpecDidComplete", func() {
- It("should decode and forward the spec summary", func(done Done) {
- forwardingReporter.SpecDidComplete(specSummary)
- Ω(reporterA.SpecSummaries[0]).Should(Equal(specSummary))
- Ω(reporterB.SpecSummaries[0]).Should(Equal(specSummary))
- close(done)
- })
- })
-
- Describe("/SpecSuiteDidEnd", func() {
- It("should decode and forward the suite summary", func(done Done) {
- forwardingReporter.SpecSuiteDidEnd(suiteSummary)
- Ω(reporterA.EndSummary).Should(Equal(suiteSummary))
- Ω(reporterB.EndSummary).Should(Equal(suiteSummary))
- close(done)
- })
- })
- })
-
- Describe("Synchronization endpoints", func() {
- Describe("GETting and POSTing BeforeSuiteState", func() {
- getBeforeSuite := func() types.RemoteBeforeSuiteData {
- resp, err := http.Get(server.Address() + "/BeforeSuiteState")
- Ω(err).ShouldNot(HaveOccurred())
- Ω(resp.StatusCode).Should(Equal(http.StatusOK))
-
- r := types.RemoteBeforeSuiteData{}
- decoder := json.NewDecoder(resp.Body)
- err = decoder.Decode(&r)
- Ω(err).ShouldNot(HaveOccurred())
-
- return r
- }
-
- postBeforeSuite := func(r types.RemoteBeforeSuiteData) {
- resp, err := http.Post(server.Address()+"/BeforeSuiteState", "application/json", bytes.NewReader(r.ToJSON()))
- Ω(err).ShouldNot(HaveOccurred())
- Ω(resp.StatusCode).Should(Equal(http.StatusOK))
- }
-
- Context("when the first node's Alive has not been registered yet", func() {
- It("should return pending", func() {
- state := getBeforeSuite()
- Ω(state).Should(Equal(types.RemoteBeforeSuiteData{Data: nil, State: types.RemoteBeforeSuiteStatePending}))
-
- state = getBeforeSuite()
- Ω(state).Should(Equal(types.RemoteBeforeSuiteData{Data: nil, State: types.RemoteBeforeSuiteStatePending}))
- })
- })
-
- Context("when the first node is Alive but has not responded yet", func() {
- BeforeEach(func() {
- server.RegisterAlive(1, func() bool {
- return true
- })
- })
-
- It("should return pending", func() {
- state := getBeforeSuite()
- Ω(state).Should(Equal(types.RemoteBeforeSuiteData{Data: nil, State: types.RemoteBeforeSuiteStatePending}))
-
- state = getBeforeSuite()
- Ω(state).Should(Equal(types.RemoteBeforeSuiteData{Data: nil, State: types.RemoteBeforeSuiteStatePending}))
- })
- })
-
- Context("when the first node has responded", func() {
- var state types.RemoteBeforeSuiteData
- BeforeEach(func() {
- server.RegisterAlive(1, func() bool {
- return false
- })
-
- state = types.RemoteBeforeSuiteData{
- Data: []byte("my data"),
- State: types.RemoteBeforeSuiteStatePassed,
- }
- postBeforeSuite(state)
- })
-
- It("should return the passed in state", func() {
- returnedState := getBeforeSuite()
- Ω(returnedState).Should(Equal(state))
- })
- })
-
- Context("when the first node is no longer Alive and has not responded yet", func() {
- BeforeEach(func() {
- server.RegisterAlive(1, func() bool {
- return false
- })
- })
-
- It("should return disappeared", func() {
- state := getBeforeSuite()
- Ω(state).Should(Equal(types.RemoteBeforeSuiteData{Data: nil, State: types.RemoteBeforeSuiteStateDisappeared}))
-
- state = getBeforeSuite()
- Ω(state).Should(Equal(types.RemoteBeforeSuiteData{Data: nil, State: types.RemoteBeforeSuiteStateDisappeared}))
- })
- })
- })
-
- Describe("GETting RemoteAfterSuiteData", func() {
- getRemoteAfterSuiteData := func() bool {
- resp, err := http.Get(server.Address() + "/RemoteAfterSuiteData")
- Ω(err).ShouldNot(HaveOccurred())
- Ω(resp.StatusCode).Should(Equal(http.StatusOK))
-
- a := types.RemoteAfterSuiteData{}
- decoder := json.NewDecoder(resp.Body)
- err = decoder.Decode(&a)
- Ω(err).ShouldNot(HaveOccurred())
-
- return a.CanRun
- }
-
- Context("when there are unregistered nodes", func() {
- BeforeEach(func() {
- server.RegisterAlive(2, func() bool {
- return false
- })
- })
-
- It("should return false", func() {
- Ω(getRemoteAfterSuiteData()).Should(BeFalse())
- })
- })
-
- Context("when all none-node-1 nodes are still running", func() {
- BeforeEach(func() {
- server.RegisterAlive(2, func() bool {
- return true
- })
-
- server.RegisterAlive(3, func() bool {
- return false
- })
- })
-
- It("should return false", func() {
- Ω(getRemoteAfterSuiteData()).Should(BeFalse())
- })
- })
-
- Context("when all none-1 nodes are done", func() {
- BeforeEach(func() {
- server.RegisterAlive(2, func() bool {
- return false
- })
-
- server.RegisterAlive(3, func() bool {
- return false
- })
- })
-
- It("should return true", func() {
- Ω(getRemoteAfterSuiteData()).Should(BeTrue())
- })
-
- })
- })
- })
-})
diff --git a/vendor/github.com/onsi/ginkgo/internal/spec/spec_suite_test.go b/vendor/github.com/onsi/ginkgo/internal/spec/spec_suite_test.go
deleted file mode 100644
index 8681a7206..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/spec/spec_suite_test.go
+++ /dev/null
@@ -1,13 +0,0 @@
-package spec_test
-
-import (
- . "github.com/onsi/ginkgo"
- . "github.com/onsi/gomega"
-
- "testing"
-)
-
-func TestSpec(t *testing.T) {
- RegisterFailHandler(Fail)
- RunSpecs(t, "Spec Suite")
-}
diff --git a/vendor/github.com/onsi/ginkgo/internal/spec/spec_test.go b/vendor/github.com/onsi/ginkgo/internal/spec/spec_test.go
deleted file mode 100644
index b4a2c9c79..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/spec/spec_test.go
+++ /dev/null
@@ -1,739 +0,0 @@
-package spec_test
-
-import (
- "time"
-
- . "github.com/onsi/ginkgo"
- . "github.com/onsi/gomega"
- "github.com/onsi/gomega/gbytes"
-
- . "github.com/onsi/ginkgo/internal/spec"
-
- "github.com/onsi/ginkgo/internal/codelocation"
- "github.com/onsi/ginkgo/internal/containernode"
- Failer "github.com/onsi/ginkgo/internal/failer"
- "github.com/onsi/ginkgo/internal/leafnodes"
- "github.com/onsi/ginkgo/types"
-)
-
-var noneFlag = types.FlagTypeNone
-var focusedFlag = types.FlagTypeFocused
-var pendingFlag = types.FlagTypePending
-
-var _ = Describe("Spec", func() {
- var (
- failer *Failer.Failer
- codeLocation types.CodeLocation
- nodesThatRan []string
- spec *Spec
- buffer *gbytes.Buffer
- )
-
- newBody := func(text string, fail bool) func() {
- return func() {
- nodesThatRan = append(nodesThatRan, text)
- if fail {
- failer.Fail(text, codeLocation)
- }
- }
- }
-
- newIt := func(text string, flag types.FlagType, fail bool) *leafnodes.ItNode {
- return leafnodes.NewItNode(text, newBody(text, fail), flag, codeLocation, 0, failer, 0)
- }
-
- newItWithBody := func(text string, body interface{}) *leafnodes.ItNode {
- return leafnodes.NewItNode(text, body, noneFlag, codeLocation, 0, failer, 0)
- }
-
- newMeasure := func(text string, flag types.FlagType, fail bool, samples int) *leafnodes.MeasureNode {
- return leafnodes.NewMeasureNode(text, func(Benchmarker) {
- nodesThatRan = append(nodesThatRan, text)
- if fail {
- failer.Fail(text, codeLocation)
- }
- }, flag, codeLocation, samples, failer, 0)
- }
-
- newBef := func(text string, fail bool) leafnodes.BasicNode {
- return leafnodes.NewBeforeEachNode(newBody(text, fail), codeLocation, 0, failer, 0)
- }
-
- newAft := func(text string, fail bool) leafnodes.BasicNode {
- return leafnodes.NewAfterEachNode(newBody(text, fail), codeLocation, 0, failer, 0)
- }
-
- newJusBef := func(text string, fail bool) leafnodes.BasicNode {
- return leafnodes.NewJustBeforeEachNode(newBody(text, fail), codeLocation, 0, failer, 0)
- }
-
- newJusAft := func(text string, fail bool) leafnodes.BasicNode {
- return leafnodes.NewJustAfterEachNode(newBody(text, fail), codeLocation, 0, failer, 0)
- }
-
- newContainer := func(text string, flag types.FlagType, setupNodes ...leafnodes.BasicNode) *containernode.ContainerNode {
- c := containernode.New(text, flag, codeLocation)
- for _, node := range setupNodes {
- c.PushSetupNode(node)
- }
- return c
- }
-
- containers := func(containers ...*containernode.ContainerNode) []*containernode.ContainerNode {
- return containers
- }
-
- BeforeEach(func() {
- buffer = gbytes.NewBuffer()
- failer = Failer.New()
- codeLocation = codelocation.New(0)
- nodesThatRan = []string{}
- })
-
- Describe("marking specs focused and pending", func() {
- It("should satisfy various caes", func() {
- cases := []struct {
- ContainerFlags []types.FlagType
- SubjectFlag types.FlagType
- Pending bool
- Focused bool
- }{
- {[]types.FlagType{}, noneFlag, false, false},
- {[]types.FlagType{}, focusedFlag, false, true},
- {[]types.FlagType{}, pendingFlag, true, false},
- {[]types.FlagType{noneFlag}, noneFlag, false, false},
- {[]types.FlagType{focusedFlag}, noneFlag, false, true},
- {[]types.FlagType{pendingFlag}, noneFlag, true, false},
- {[]types.FlagType{noneFlag}, focusedFlag, false, true},
- {[]types.FlagType{focusedFlag}, focusedFlag, false, true},
- {[]types.FlagType{pendingFlag}, focusedFlag, true, true},
- {[]types.FlagType{noneFlag}, pendingFlag, true, false},
- {[]types.FlagType{focusedFlag}, pendingFlag, true, true},
- {[]types.FlagType{pendingFlag}, pendingFlag, true, false},
- {[]types.FlagType{focusedFlag, noneFlag}, noneFlag, false, true},
- {[]types.FlagType{noneFlag, focusedFlag}, noneFlag, false, true},
- {[]types.FlagType{pendingFlag, noneFlag}, noneFlag, true, false},
- {[]types.FlagType{noneFlag, pendingFlag}, noneFlag, true, false},
- {[]types.FlagType{focusedFlag, pendingFlag}, noneFlag, true, true},
- }
-
- for i, c := range cases {
- subject := newIt("it node", c.SubjectFlag, false)
- containers := []*containernode.ContainerNode{}
- for _, flag := range c.ContainerFlags {
- containers = append(containers, newContainer("container", flag))
- }
-
- spec := New(subject, containers, false)
- Ω(spec.Pending()).Should(Equal(c.Pending), "Case %d: %#v", i, c)
- Ω(spec.Focused()).Should(Equal(c.Focused), "Case %d: %#v", i, c)
-
- if c.Pending {
- Ω(spec.Summary("").State).Should(Equal(types.SpecStatePending))
- }
- }
- })
- })
-
- Describe("Skip", func() {
- It("should be skipped", func() {
- spec := New(newIt("it node", noneFlag, false), containers(newContainer("container", noneFlag)), false)
- Ω(spec.Skipped()).Should(BeFalse())
- spec.Skip()
- Ω(spec.Skipped()).Should(BeTrue())
- Ω(spec.Summary("").State).Should(Equal(types.SpecStateSkipped))
- })
- })
-
- Describe("IsMeasurement", func() {
- It("should be true if the subject is a measurement node", func() {
- spec := New(newIt("it node", noneFlag, false), containers(newContainer("container", noneFlag)), false)
- Ω(spec.IsMeasurement()).Should(BeFalse())
- Ω(spec.Summary("").IsMeasurement).Should(BeFalse())
- Ω(spec.Summary("").NumberOfSamples).Should(Equal(1))
-
- spec = New(newMeasure("measure node", noneFlag, false, 10), containers(newContainer("container", noneFlag)), false)
- Ω(spec.IsMeasurement()).Should(BeTrue())
- Ω(spec.Summary("").IsMeasurement).Should(BeTrue())
- Ω(spec.Summary("").NumberOfSamples).Should(Equal(10))
- })
- })
-
- Describe("Passed", func() {
- It("should pass when the subject passed", func() {
- spec := New(newIt("it node", noneFlag, false), containers(), false)
- spec.Run(buffer)
-
- Ω(spec.Passed()).Should(BeTrue())
- Ω(spec.Failed()).Should(BeFalse())
- Ω(spec.Summary("").State).Should(Equal(types.SpecStatePassed))
- Ω(spec.Summary("").Failure).Should(BeZero())
- })
- })
-
- Describe("Flaked", func() {
- It("should work if Run is called twice and gets different results", func() {
- i := 0
- spec := New(newItWithBody("flaky it", func() {
- i++
- if i == 1 {
- failer.Fail("oops", codeLocation)
- }
- }), containers(), false)
- spec.Run(buffer)
- Ω(spec.Passed()).Should(BeFalse())
- Ω(spec.Failed()).Should(BeTrue())
- Ω(spec.Flaked()).Should(BeFalse())
- Ω(spec.Summary("").State).Should(Equal(types.SpecStateFailed))
- Ω(spec.Summary("").Failure.Message).Should(Equal("oops"))
- spec.Run(buffer)
- Ω(spec.Passed()).Should(BeTrue())
- Ω(spec.Failed()).Should(BeFalse())
- Ω(spec.Flaked()).Should(BeTrue())
- Ω(spec.Summary("").State).Should(Equal(types.SpecStatePassed))
- })
- })
-
- Describe("Failed", func() {
- It("should be failed if the failure was panic", func() {
- spec := New(newItWithBody("panicky it", func() {
- panic("bam")
- }), containers(), false)
- spec.Run(buffer)
- Ω(spec.Passed()).Should(BeFalse())
- Ω(spec.Failed()).Should(BeTrue())
- Ω(spec.Summary("").State).Should(Equal(types.SpecStatePanicked))
- Ω(spec.Summary("").Failure.Message).Should(Equal("Test Panicked"))
- Ω(spec.Summary("").Failure.ForwardedPanic).Should(Equal("bam"))
- })
-
- It("should be failed if the failure was a timeout", func() {
- spec := New(newItWithBody("sleepy it", func(done Done) {}), containers(), false)
- spec.Run(buffer)
- Ω(spec.Passed()).Should(BeFalse())
- Ω(spec.Failed()).Should(BeTrue())
- Ω(spec.Summary("").State).Should(Equal(types.SpecStateTimedOut))
- Ω(spec.Summary("").Failure.Message).Should(Equal("Timed out"))
- })
-
- It("should be failed if the failure was... a failure", func() {
- spec := New(newItWithBody("failing it", func() {
- failer.Fail("bam", codeLocation)
- }), containers(), false)
- spec.Run(buffer)
- Ω(spec.Passed()).Should(BeFalse())
- Ω(spec.Failed()).Should(BeTrue())
- Ω(spec.Summary("").State).Should(Equal(types.SpecStateFailed))
- Ω(spec.Summary("").Failure.Message).Should(Equal("bam"))
- })
- })
-
- Describe("Concatenated string", func() {
- It("should concatenate the texts of the containers and the subject", func() {
- spec := New(
- newIt("it node", noneFlag, false),
- containers(
- newContainer("outer container", noneFlag),
- newContainer("inner container", noneFlag),
- ),
- false,
- )
-
- Ω(spec.ConcatenatedString()).Should(Equal("outer container inner container it node"))
- })
- })
-
- Describe("running it specs", func() {
- Context("with just an it", func() {
- Context("that succeeds", func() {
- It("should run the it and report on its success", func() {
- spec := New(newIt("it node", noneFlag, false), containers(), false)
- spec.Run(buffer)
- Ω(spec.Passed()).Should(BeTrue())
- Ω(spec.Failed()).Should(BeFalse())
- Ω(nodesThatRan).Should(Equal([]string{"it node"}))
- })
- })
-
- Context("that fails", func() {
- It("should run the it and report on its success", func() {
- spec := New(newIt("it node", noneFlag, true), containers(), false)
- spec.Run(buffer)
- Ω(spec.Passed()).Should(BeFalse())
- Ω(spec.Failed()).Should(BeTrue())
- Ω(spec.Summary("").Failure.Message).Should(Equal("it node"))
- Ω(nodesThatRan).Should(Equal([]string{"it node"}))
- })
- })
- })
-
- Context("with a full set of setup nodes", func() {
- var failingNodes map[string]bool
-
- BeforeEach(func() {
- failingNodes = map[string]bool{}
- })
-
- JustBeforeEach(func() {
- spec = New(
- newIt("it node", noneFlag, failingNodes["it node"]),
- containers(
- newContainer("outer container", noneFlag,
- newBef("outer bef A", failingNodes["outer bef A"]),
- newBef("outer bef B", failingNodes["outer bef B"]),
- newJusBef("outer jusbef A", failingNodes["outer jusbef A"]),
- newJusBef("outer jusbef B", failingNodes["outer jusbef B"]),
- newJusAft("outer jusaft A", failingNodes["outer jusaft A"]),
- newJusAft("outer jusaft B", failingNodes["outer jusaft B"]),
- newAft("outer aft A", failingNodes["outer aft A"]),
- newAft("outer aft B", failingNodes["outer aft B"]),
- ),
- newContainer("inner container", noneFlag,
- newBef("inner bef A", failingNodes["inner bef A"]),
- newBef("inner bef B", failingNodes["inner bef B"]),
- newJusBef("inner jusbef A", failingNodes["inner jusbef A"]),
- newJusBef("inner jusbef B", failingNodes["inner jusbef B"]),
- newJusAft("inner jusaft A", failingNodes["inner jusaft A"]),
- newJusAft("inner jusaft B", failingNodes["inner jusaft B"]),
- newAft("inner aft A", failingNodes["inner aft A"]),
- newAft("inner aft B", failingNodes["inner aft B"]),
- ),
- ),
- false,
- )
- spec.Run(buffer)
- })
-
- Context("that all pass", func() {
- It("should walk through the nodes in the correct order", func() {
- Ω(spec.Passed()).Should(BeTrue())
- Ω(spec.Failed()).Should(BeFalse())
- Ω(nodesThatRan).Should(Equal([]string{
- "outer bef A",
- "outer bef B",
- "inner bef A",
- "inner bef B",
- "outer jusbef A",
- "outer jusbef B",
- "inner jusbef A",
- "inner jusbef B",
- "it node",
- "inner jusaft A",
- "inner jusaft B",
- "outer jusaft A",
- "outer jusaft B",
- "inner aft A",
- "inner aft B",
- "outer aft A",
- "outer aft B",
- }))
- })
- })
-
- Context("when the subject fails", func() {
- BeforeEach(func() {
- failingNodes["it node"] = true
- })
-
- It("should run the afters", func() {
- Ω(spec.Passed()).Should(BeFalse())
- Ω(spec.Failed()).Should(BeTrue())
- Ω(nodesThatRan).Should(Equal([]string{
- "outer bef A",
- "outer bef B",
- "inner bef A",
- "inner bef B",
- "outer jusbef A",
- "outer jusbef B",
- "inner jusbef A",
- "inner jusbef B",
- "it node",
- "inner jusaft A",
- "inner jusaft B",
- "outer jusaft A",
- "outer jusaft B",
- "inner aft A",
- "inner aft B",
- "outer aft A",
- "outer aft B",
- }))
- Ω(spec.Summary("").Failure.Message).Should(Equal("it node"))
- })
- })
-
- Context("when an inner before fails", func() {
- BeforeEach(func() {
- failingNodes["inner bef A"] = true
- })
-
- It("should not run any other befores, but it should run the subsequent afters", func() {
- Ω(spec.Passed()).Should(BeFalse())
- Ω(spec.Failed()).Should(BeTrue())
- Ω(nodesThatRan).Should(Equal([]string{
- "outer bef A",
- "outer bef B",
- "inner bef A",
- "inner jusaft A",
- "inner jusaft B",
- "outer jusaft A",
- "outer jusaft B",
- "inner aft A",
- "inner aft B",
- "outer aft A",
- "outer aft B",
- }))
- Ω(spec.Summary("").Failure.Message).Should(Equal("inner bef A"))
- })
- })
-
- Context("when an outer before fails", func() {
- BeforeEach(func() {
- failingNodes["outer bef B"] = true
- })
-
- It("should not run any other befores, but it should run the subsequent afters", func() {
- Ω(spec.Passed()).Should(BeFalse())
- Ω(spec.Failed()).Should(BeTrue())
- Ω(nodesThatRan).Should(Equal([]string{
- "outer bef A",
- "outer bef B",
- "outer jusaft A",
- "outer jusaft B",
- "outer aft A",
- "outer aft B",
- }))
- Ω(spec.Summary("").Failure.Message).Should(Equal("outer bef B"))
- })
- })
-
- Context("when an after fails", func() {
- BeforeEach(func() {
- failingNodes["inner aft B"] = true
- })
-
- It("should run all other afters, but mark the test as failed", func() {
- Ω(spec.Passed()).Should(BeFalse())
- Ω(spec.Failed()).Should(BeTrue())
- Ω(nodesThatRan).Should(Equal([]string{
- "outer bef A",
- "outer bef B",
- "inner bef A",
- "inner bef B",
- "outer jusbef A",
- "outer jusbef B",
- "inner jusbef A",
- "inner jusbef B",
- "it node",
- "inner jusaft A",
- "inner jusaft B",
- "outer jusaft A",
- "outer jusaft B",
- "inner aft A",
- "inner aft B",
- "outer aft A",
- "outer aft B",
- }))
- Ω(spec.Summary("").Failure.Message).Should(Equal("inner aft B"))
- })
- })
-
- Context("when a just before each fails", func() {
- BeforeEach(func() {
- failingNodes["outer jusbef B"] = true
- })
-
- It("should run the afters, but not the subject", func() {
- Ω(spec.Passed()).Should(BeFalse())
- Ω(spec.Failed()).Should(BeTrue())
- Ω(nodesThatRan).Should(Equal([]string{
- "outer bef A",
- "outer bef B",
- "inner bef A",
- "inner bef B",
- "outer jusbef A",
- "outer jusbef B",
- "inner jusaft A",
- "inner jusaft B",
- "outer jusaft A",
- "outer jusaft B",
- "inner aft A",
- "inner aft B",
- "outer aft A",
- "outer aft B",
- }))
- Ω(spec.Summary("").Failure.Message).Should(Equal("outer jusbef B"))
- })
- })
-
- Context("when a just after each fails", func() {
- BeforeEach(func() {
- failingNodes["outer jusaft A"] = true
- })
-
- It("should run all other afters, but mark the test as failed", func() {
- Ω(spec.Passed()).Should(BeFalse())
- Ω(spec.Failed()).Should(BeTrue())
- Ω(nodesThatRan).Should(Equal([]string{
- "outer bef A",
- "outer bef B",
- "inner bef A",
- "inner bef B",
- "outer jusbef A",
- "outer jusbef B",
- "inner jusbef A",
- "inner jusbef B",
- "it node",
- "inner jusaft A",
- "inner jusaft B",
- "outer jusaft A",
- "outer jusaft B",
- "inner aft A",
- "inner aft B",
- "outer aft A",
- "outer aft B",
- }))
- Ω(spec.Summary("").Failure.Message).Should(Equal("outer jusaft A"))
- })
- })
-
- Context("when an after fails after an earlier node has failed", func() {
- BeforeEach(func() {
- failingNodes["it node"] = true
- failingNodes["inner aft B"] = true
- })
-
- It("should record the earlier failure", func() {
- Ω(spec.Passed()).Should(BeFalse())
- Ω(spec.Failed()).Should(BeTrue())
- Ω(nodesThatRan).Should(Equal([]string{
- "outer bef A",
- "outer bef B",
- "inner bef A",
- "inner bef B",
- "outer jusbef A",
- "outer jusbef B",
- "inner jusbef A",
- "inner jusbef B",
- "it node",
- "inner jusaft A",
- "inner jusaft B",
- "outer jusaft A",
- "outer jusaft B",
- "inner aft A",
- "inner aft B",
- "outer aft A",
- "outer aft B",
- }))
- Ω(spec.Summary("").Failure.Message).Should(Equal("it node"))
- })
- })
- })
- })
-
- Describe("running measurement specs", func() {
- Context("when the measurement succeeds", func() {
- It("should run N samples", func() {
- spec = New(
- newMeasure("measure node", noneFlag, false, 3),
- containers(
- newContainer("container", noneFlag,
- newBef("bef A", false),
- newJusBef("jusbef A", false),
- newJusAft("jusaft A", false),
- newAft("aft A", false),
- ),
- ),
- false,
- )
- spec.Run(buffer)
-
- Ω(spec.Passed()).Should(BeTrue())
- Ω(spec.Failed()).Should(BeFalse())
- Ω(nodesThatRan).Should(Equal([]string{
- "bef A",
- "jusbef A",
- "measure node",
- "jusaft A",
- "aft A",
- "bef A",
- "jusbef A",
- "measure node",
- "jusaft A",
- "aft A",
- "bef A",
- "jusbef A",
- "measure node",
- "jusaft A",
- "aft A",
- }))
- })
- })
-
- Context("when the measurement fails", func() {
- It("should bail after the failure occurs", func() {
- spec = New(
- newMeasure("measure node", noneFlag, true, 3),
- containers(
- newContainer("container", noneFlag,
- newBef("bef A", false),
- newJusBef("jusbef A", false),
- newJusAft("jusaft A", false),
- newAft("aft A", false),
- ),
- ),
- false,
- )
- spec.Run(buffer)
-
- Ω(spec.Passed()).Should(BeFalse())
- Ω(spec.Failed()).Should(BeTrue())
- Ω(nodesThatRan).Should(Equal([]string{
- "bef A",
- "jusbef A",
- "measure node",
- "jusaft A",
- "aft A",
- }))
- })
- })
- })
-
- Describe("Summary", func() {
- var (
- subjectCodeLocation types.CodeLocation
- outerContainerCodeLocation types.CodeLocation
- innerContainerCodeLocation types.CodeLocation
- summary *types.SpecSummary
- )
-
- BeforeEach(func() {
- subjectCodeLocation = codelocation.New(0)
- outerContainerCodeLocation = codelocation.New(0)
- innerContainerCodeLocation = codelocation.New(0)
-
- spec = New(
- leafnodes.NewItNode("it node", func() {
- time.Sleep(10 * time.Millisecond)
- }, noneFlag, subjectCodeLocation, 0, failer, 0),
- containers(
- containernode.New("outer container", noneFlag, outerContainerCodeLocation),
- containernode.New("inner container", noneFlag, innerContainerCodeLocation),
- ),
- false,
- )
-
- spec.Run(buffer)
- Ω(spec.Passed()).Should(BeTrue())
- summary = spec.Summary("suite id")
- })
-
- It("should have the suite id", func() {
- Ω(summary.SuiteID).Should(Equal("suite id"))
- })
-
- It("should have the component texts and code locations", func() {
- Ω(summary.ComponentTexts).Should(Equal([]string{"outer container", "inner container", "it node"}))
- Ω(summary.ComponentCodeLocations).Should(Equal([]types.CodeLocation{outerContainerCodeLocation, innerContainerCodeLocation, subjectCodeLocation}))
- })
-
- It("should have a runtime", func() {
- Ω(summary.RunTime).Should(BeNumerically(">=", 10*time.Millisecond))
- })
-
- It("should have a runtime which remains consistent after spec run", func() {
- totalRunTime := summary.RunTime
- Ω(totalRunTime).Should(BeNumerically(">=", 10*time.Millisecond))
-
- Consistently(func() time.Duration { return spec.Summary("suite id").RunTime }).Should(Equal(totalRunTime))
- })
-
- It("should not be a measurement, or have a measurement summary", func() {
- Ω(summary.IsMeasurement).Should(BeFalse())
- Ω(summary.Measurements).Should(BeEmpty())
- })
- })
-
- Describe("Summaries for measurements", func() {
- var summary *types.SpecSummary
-
- BeforeEach(func() {
- spec = New(leafnodes.NewMeasureNode("measure node", func(b Benchmarker) {
- b.RecordValue("a value", 7, "some info")
- b.RecordValueWithPrecision("another value", 8, "ns", 5, "more info")
- }, noneFlag, codeLocation, 4, failer, 0), containers(), false)
- spec.Run(buffer)
- Ω(spec.Passed()).Should(BeTrue())
- summary = spec.Summary("suite id")
- })
-
- It("should include the number of samples", func() {
- Ω(summary.NumberOfSamples).Should(Equal(4))
- })
-
- It("should be a measurement", func() {
- Ω(summary.IsMeasurement).Should(BeTrue())
- })
-
- It("should have the measurements report", func() {
- Ω(summary.Measurements).Should(HaveKey("a value"))
- report := summary.Measurements["a value"]
- Ω(report.Name).Should(Equal("a value"))
- Ω(report.Info).Should(Equal("some info"))
- Ω(report.Results).Should(Equal([]float64{7, 7, 7, 7}))
-
- Ω(summary.Measurements).Should(HaveKey("another value"))
- report = summary.Measurements["another value"]
- Ω(report.Name).Should(Equal("another value"))
- Ω(report.Info).Should(Equal("more info"))
- Ω(report.Results).Should(Equal([]float64{8, 8, 8, 8}))
- Ω(report.Units).Should(Equal("ns"))
- Ω(report.Precision).Should(Equal(5))
- })
- })
-
- Describe("When told to emit progress", func() {
- It("should emit progress to the writer as it runs Befores, JustBefores, Afters, and Its", func() {
- spec = New(
- newIt("it node", noneFlag, false),
- containers(
- newContainer("outer container", noneFlag,
- newBef("outer bef A", false),
- newJusBef("outer jusbef A", false),
- newJusAft("outer jusaft A", false),
- newAft("outer aft A", false),
- ),
- newContainer("inner container", noneFlag,
- newBef("inner bef A", false),
- newJusBef("inner jusbef A", false),
- newJusAft("inner jusaft A", false),
- newAft("inner aft A", false),
- ),
- ),
- true,
- )
- spec.Run(buffer)
-
- Ω(buffer).Should(gbytes.Say(`\[BeforeEach\] outer container`))
- Ω(buffer).Should(gbytes.Say(`\[BeforeEach\] inner container`))
- Ω(buffer).Should(gbytes.Say(`\[JustBeforeEach\] outer container`))
- Ω(buffer).Should(gbytes.Say(`\[JustBeforeEach\] inner container`))
- Ω(buffer).Should(gbytes.Say(`\[It\] it node`))
- Ω(buffer).Should(gbytes.Say(`\[JustAfterEach\] inner container`))
- Ω(buffer).Should(gbytes.Say(`\[JustAfterEach\] outer container`))
- Ω(buffer).Should(gbytes.Say(`\[AfterEach\] inner container`))
- Ω(buffer).Should(gbytes.Say(`\[AfterEach\] outer container`))
- })
-
- It("should emit progress to the writer as it runs Befores, JustBefores, JustAfters, Afters, and Measures", func() {
- spec = New(
- newMeasure("measure node", noneFlag, false, 2),
- containers(),
- true,
- )
- spec.Run(buffer)
-
- Ω(buffer).Should(gbytes.Say(`\[Measure\] measure node`))
- Ω(buffer).Should(gbytes.Say(`\[Measure\] measure node`))
- })
- })
-})
diff --git a/vendor/github.com/onsi/ginkgo/internal/spec/specs.go b/vendor/github.com/onsi/ginkgo/internal/spec/specs.go
index 006185ab5..27c0d1d6c 100644
--- a/vendor/github.com/onsi/ginkgo/internal/spec/specs.go
+++ b/vendor/github.com/onsi/ginkgo/internal/spec/specs.go
@@ -7,14 +7,21 @@ import (
)
type Specs struct {
- specs []*Spec
+ specs []*Spec
+ names []string
+
hasProgrammaticFocus bool
RegexScansFilePath bool
}
func NewSpecs(specs []*Spec) *Specs {
+ names := make([]string, len(specs))
+ for i, spec := range specs {
+ names[i] = spec.ConcatenatedString()
+ }
return &Specs{
specs: specs,
+ names: names,
}
}
@@ -30,10 +37,13 @@ func (e *Specs) Shuffle(r *rand.Rand) {
sort.Sort(e)
permutation := r.Perm(len(e.specs))
shuffledSpecs := make([]*Spec, len(e.specs))
+ names := make([]string, len(e.specs))
for i, j := range permutation {
shuffledSpecs[i] = e.specs[j]
+ names[i] = e.names[j]
}
e.specs = shuffledSpecs
+ e.names = names
}
func (e *Specs) ApplyFocus(description string, focusString string, skipString string) {
@@ -64,33 +74,43 @@ func (e *Specs) applyProgrammaticFocus() {
// toMatch returns a byte[] to be used by regex matchers. When adding new behaviours to the matching function,
// this is the place which we append to.
-func (e *Specs) toMatch(description string, spec *Spec) []byte {
+func (e *Specs) toMatch(description string, i int) []byte {
+ if i > len(e.names) {
+ return nil
+ }
if e.RegexScansFilePath {
return []byte(
description + " " +
- spec.ConcatenatedString() + " " +
- spec.subject.CodeLocation().FileName)
+ e.names[i] + " " +
+ e.specs[i].subject.CodeLocation().FileName)
} else {
return []byte(
description + " " +
- spec.ConcatenatedString())
+ e.names[i])
}
}
func (e *Specs) applyRegExpFocusAndSkip(description string, focusString string, skipString string) {
- for _, spec := range e.specs {
+ var focusFilter *regexp.Regexp
+ if focusString != "" {
+ focusFilter = regexp.MustCompile(focusString)
+ }
+ var skipFilter *regexp.Regexp
+ if skipString != "" {
+ skipFilter = regexp.MustCompile(skipString)
+ }
+
+ for i, spec := range e.specs {
matchesFocus := true
matchesSkip := false
- toMatch := e.toMatch(description, spec)
+ toMatch := e.toMatch(description, i)
- if focusString != "" {
- focusFilter := regexp.MustCompile(focusString)
+ if focusFilter != nil {
matchesFocus = focusFilter.Match([]byte(toMatch))
}
- if skipString != "" {
- skipFilter := regexp.MustCompile(skipString)
+ if skipFilter != nil {
matchesSkip = skipFilter.Match([]byte(toMatch))
}
@@ -115,9 +135,10 @@ func (e *Specs) Len() int {
}
func (e *Specs) Less(i, j int) bool {
- return e.specs[i].ConcatenatedString() < e.specs[j].ConcatenatedString()
+ return e.names[i] < e.names[j]
}
func (e *Specs) Swap(i, j int) {
+ e.names[i], e.names[j] = e.names[j], e.names[i]
e.specs[i], e.specs[j] = e.specs[j], e.specs[i]
}
diff --git a/vendor/github.com/onsi/ginkgo/internal/spec/specs_test.go b/vendor/github.com/onsi/ginkgo/internal/spec/specs_test.go
deleted file mode 100644
index 066fbbb3a..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/spec/specs_test.go
+++ /dev/null
@@ -1,287 +0,0 @@
-package spec_test
-
-import (
- "math/rand"
-
- . "github.com/onsi/ginkgo"
- . "github.com/onsi/ginkgo/internal/spec"
- . "github.com/onsi/gomega"
-
- "github.com/onsi/ginkgo/internal/codelocation"
- "github.com/onsi/ginkgo/internal/containernode"
- "github.com/onsi/ginkgo/internal/leafnodes"
- "github.com/onsi/ginkgo/types"
-)
-
-var _ = Describe("Specs", func() {
- var specs *Specs
-
- newSpec := func(text string, flag types.FlagType) *Spec {
- subject := leafnodes.NewItNode(text, func() {}, flag, codelocation.New(0), 0, nil, 0)
- return New(subject, []*containernode.ContainerNode{}, false)
- }
-
- newMeasureSpec := func(text string, flag types.FlagType) *Spec {
- subject := leafnodes.NewMeasureNode(text, func(Benchmarker) {}, flag, codelocation.New(0), 0, nil, 0)
- return New(subject, []*containernode.ContainerNode{}, false)
- }
-
- newSpecs := func(args ...interface{}) *Specs {
- specs := []*Spec{}
- for index := 0; index < len(args)-1; index += 2 {
- specs = append(specs, newSpec(args[index].(string), args[index+1].(types.FlagType)))
- }
- return NewSpecs(specs)
- }
-
- specTexts := func(specs *Specs) []string {
- texts := []string{}
- for _, spec := range specs.Specs() {
- texts = append(texts, spec.ConcatenatedString())
- }
- return texts
- }
-
- willRunTexts := func(specs *Specs) []string {
- texts := []string{}
- for _, spec := range specs.Specs() {
- if !(spec.Skipped() || spec.Pending()) {
- texts = append(texts, spec.ConcatenatedString())
- }
- }
- return texts
- }
-
- skippedTexts := func(specs *Specs) []string {
- texts := []string{}
- for _, spec := range specs.Specs() {
- if spec.Skipped() {
- texts = append(texts, spec.ConcatenatedString())
- }
- }
- return texts
- }
-
- pendingTexts := func(specs *Specs) []string {
- texts := []string{}
- for _, spec := range specs.Specs() {
- if spec.Pending() {
- texts = append(texts, spec.ConcatenatedString())
- }
- }
- return texts
- }
-
- Describe("Shuffling specs", func() {
- It("should shuffle the specs using the passed in randomizer", func() {
- specs17 := newSpecs("C", noneFlag, "A", noneFlag, "B", noneFlag)
- specs17.Shuffle(rand.New(rand.NewSource(17)))
- texts17 := specTexts(specs17)
-
- specs17Again := newSpecs("C", noneFlag, "A", noneFlag, "B", noneFlag)
- specs17Again.Shuffle(rand.New(rand.NewSource(17)))
- texts17Again := specTexts(specs17Again)
-
- specs15 := newSpecs("C", noneFlag, "A", noneFlag, "B", noneFlag)
- specs15.Shuffle(rand.New(rand.NewSource(15)))
- texts15 := specTexts(specs15)
-
- specsUnshuffled := newSpecs("C", noneFlag, "A", noneFlag, "B", noneFlag)
- textsUnshuffled := specTexts(specsUnshuffled)
-
- Ω(textsUnshuffled).Should(Equal([]string{"C", "A", "B"}))
-
- Ω(texts17).Should(Equal(texts17Again))
- Ω(texts17).ShouldNot(Equal(texts15))
- Ω(texts17).ShouldNot(Equal(textsUnshuffled))
- Ω(texts15).ShouldNot(Equal(textsUnshuffled))
-
- Ω(texts17).Should(HaveLen(3))
- Ω(texts17).Should(ContainElement("A"))
- Ω(texts17).Should(ContainElement("B"))
- Ω(texts17).Should(ContainElement("C"))
-
- Ω(texts15).Should(HaveLen(3))
- Ω(texts15).Should(ContainElement("A"))
- Ω(texts15).Should(ContainElement("B"))
- Ω(texts15).Should(ContainElement("C"))
- })
- })
-
- Describe("with no programmatic focus", func() {
- BeforeEach(func() {
- specs = newSpecs("A1", noneFlag, "A2", noneFlag, "B1", noneFlag, "B2", pendingFlag)
- specs.ApplyFocus("", "", "")
- })
-
- It("should not report as having programmatic specs", func() {
- Ω(specs.HasProgrammaticFocus()).Should(BeFalse())
- })
- })
-
- Describe("Applying focus/skip", func() {
- var description, focusString, skipString string
-
- BeforeEach(func() {
- description, focusString, skipString = "", "", ""
- })
-
- JustBeforeEach(func() {
- specs = newSpecs("A1", focusedFlag, "A2", noneFlag, "B1", focusedFlag, "B2", pendingFlag)
- specs.ApplyFocus(description, focusString, skipString)
- })
-
- Context("with neither a focus string nor a skip string", func() {
- It("should apply the programmatic focus", func() {
- Ω(willRunTexts(specs)).Should(Equal([]string{"A1", "B1"}))
- Ω(skippedTexts(specs)).Should(Equal([]string{"A2", "B2"}))
- Ω(pendingTexts(specs)).Should(BeEmpty())
- })
-
- It("should report as having programmatic specs", func() {
- Ω(specs.HasProgrammaticFocus()).Should(BeTrue())
- })
- })
-
- Context("with a focus regexp", func() {
- BeforeEach(func() {
- focusString = "A"
- })
-
- It("should override the programmatic focus", func() {
- Ω(willRunTexts(specs)).Should(Equal([]string{"A1", "A2"}))
- Ω(skippedTexts(specs)).Should(Equal([]string{"B1", "B2"}))
- Ω(pendingTexts(specs)).Should(BeEmpty())
- })
-
- It("should not report as having programmatic specs", func() {
- Ω(specs.HasProgrammaticFocus()).Should(BeFalse())
- })
- })
-
- Context("with a focus regexp", func() {
- BeforeEach(func() {
- focusString = "B"
- })
-
- It("should not override any pendings", func() {
- Ω(willRunTexts(specs)).Should(Equal([]string{"B1"}))
- Ω(skippedTexts(specs)).Should(Equal([]string{"A1", "A2"}))
- Ω(pendingTexts(specs)).Should(Equal([]string{"B2"}))
- })
- })
-
- Context("with a description", func() {
- BeforeEach(func() {
- description = "C"
- focusString = "C"
- })
-
- It("should include the description in the focus determination", func() {
- Ω(willRunTexts(specs)).Should(Equal([]string{"A1", "A2", "B1"}))
- Ω(skippedTexts(specs)).Should(BeEmpty())
- Ω(pendingTexts(specs)).Should(Equal([]string{"B2"}))
- })
- })
-
- Context("with a description", func() {
- BeforeEach(func() {
- description = "C"
- skipString = "C"
- })
-
- It("should include the description in the focus determination", func() {
- Ω(willRunTexts(specs)).Should(BeEmpty())
- Ω(skippedTexts(specs)).Should(Equal([]string{"A1", "A2", "B1", "B2"}))
- Ω(pendingTexts(specs)).Should(BeEmpty())
- })
- })
-
- Context("with a skip regexp", func() {
- BeforeEach(func() {
- skipString = "A"
- })
-
- It("should override the programmatic focus", func() {
- Ω(willRunTexts(specs)).Should(Equal([]string{"B1"}))
- Ω(skippedTexts(specs)).Should(Equal([]string{"A1", "A2"}))
- Ω(pendingTexts(specs)).Should(Equal([]string{"B2"}))
- })
-
- It("should not report as having programmatic specs", func() {
- Ω(specs.HasProgrammaticFocus()).Should(BeFalse())
- })
- })
-
- Context("with both a focus and a skip regexp", func() {
- BeforeEach(func() {
- focusString = "1"
- skipString = "B"
- })
-
- It("should AND the two", func() {
- Ω(willRunTexts(specs)).Should(Equal([]string{"A1"}))
- Ω(skippedTexts(specs)).Should(Equal([]string{"A2", "B1", "B2"}))
- Ω(pendingTexts(specs)).Should(BeEmpty())
- })
-
- It("should not report as having programmatic specs", func() {
- Ω(specs.HasProgrammaticFocus()).Should(BeFalse())
- })
- })
- })
-
- Describe("With a focused spec within a pending context and a pending spec within a focused context", func() {
- BeforeEach(func() {
- pendingInFocused := New(
- leafnodes.NewItNode("PendingInFocused", func() {}, pendingFlag, codelocation.New(0), 0, nil, 0),
- []*containernode.ContainerNode{
- containernode.New("", focusedFlag, codelocation.New(0)),
- }, false)
-
- focusedInPending := New(
- leafnodes.NewItNode("FocusedInPending", func() {}, focusedFlag, codelocation.New(0), 0, nil, 0),
- []*containernode.ContainerNode{
- containernode.New("", pendingFlag, codelocation.New(0)),
- }, false)
-
- specs = NewSpecs([]*Spec{
- newSpec("A", noneFlag),
- newSpec("B", noneFlag),
- pendingInFocused,
- focusedInPending,
- })
- specs.ApplyFocus("", "", "")
- })
-
- It("should not have a programmatic focus and should run all tests", func() {
- Ω(willRunTexts(specs)).Should(Equal([]string{"A", "B"}))
- Ω(skippedTexts(specs)).Should(BeEmpty())
- Ω(pendingTexts(specs)).Should(ConsistOf(ContainSubstring("PendingInFocused"), ContainSubstring("FocusedInPending")))
- })
- })
-
- Describe("skipping measurements", func() {
- BeforeEach(func() {
- specs = NewSpecs([]*Spec{
- newSpec("A", noneFlag),
- newSpec("B", noneFlag),
- newSpec("C", pendingFlag),
- newMeasureSpec("measurementA", noneFlag),
- newMeasureSpec("measurementB", pendingFlag),
- })
- })
-
- It("should skip measurements", func() {
- Ω(willRunTexts(specs)).Should(Equal([]string{"A", "B", "measurementA"}))
- Ω(skippedTexts(specs)).Should(BeEmpty())
- Ω(pendingTexts(specs)).Should(Equal([]string{"C", "measurementB"}))
-
- specs.SkipMeasurements()
-
- Ω(willRunTexts(specs)).Should(Equal([]string{"A", "B"}))
- Ω(skippedTexts(specs)).Should(Equal([]string{"measurementA", "measurementB"}))
- Ω(pendingTexts(specs)).Should(Equal([]string{"C"}))
- })
- })
-})
diff --git a/vendor/github.com/onsi/ginkgo/internal/spec_iterator/index_computer_test.go b/vendor/github.com/onsi/ginkgo/internal/spec_iterator/index_computer_test.go
deleted file mode 100644
index 65da9837c..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/spec_iterator/index_computer_test.go
+++ /dev/null
@@ -1,149 +0,0 @@
-package spec_iterator_test
-
-import (
- . "github.com/onsi/ginkgo"
- . "github.com/onsi/ginkgo/internal/spec_iterator"
- . "github.com/onsi/gomega"
-)
-
-var _ = Describe("ParallelizedIndexRange", func() {
- var startIndex, count int
-
- It("should return the correct index range for 4 tests on 2 nodes", func() {
- startIndex, count = ParallelizedIndexRange(4, 2, 1)
- Ω(startIndex).Should(Equal(0))
- Ω(count).Should(Equal(2))
-
- startIndex, count = ParallelizedIndexRange(4, 2, 2)
- Ω(startIndex).Should(Equal(2))
- Ω(count).Should(Equal(2))
- })
-
- It("should return the correct index range for 5 tests on 2 nodes", func() {
- startIndex, count = ParallelizedIndexRange(5, 2, 1)
- Ω(startIndex).Should(Equal(0))
- Ω(count).Should(Equal(3))
-
- startIndex, count = ParallelizedIndexRange(5, 2, 2)
- Ω(startIndex).Should(Equal(3))
- Ω(count).Should(Equal(2))
- })
-
- It("should return the correct index range for 5 tests on 3 nodes", func() {
- startIndex, count = ParallelizedIndexRange(5, 3, 1)
- Ω(startIndex).Should(Equal(0))
- Ω(count).Should(Equal(2))
-
- startIndex, count = ParallelizedIndexRange(5, 3, 2)
- Ω(startIndex).Should(Equal(2))
- Ω(count).Should(Equal(2))
-
- startIndex, count = ParallelizedIndexRange(5, 3, 3)
- Ω(startIndex).Should(Equal(4))
- Ω(count).Should(Equal(1))
- })
-
- It("should return the correct index range for 5 tests on 4 nodes", func() {
- startIndex, count = ParallelizedIndexRange(5, 4, 1)
- Ω(startIndex).Should(Equal(0))
- Ω(count).Should(Equal(2))
-
- startIndex, count = ParallelizedIndexRange(5, 4, 2)
- Ω(startIndex).Should(Equal(2))
- Ω(count).Should(Equal(1))
-
- startIndex, count = ParallelizedIndexRange(5, 4, 3)
- Ω(startIndex).Should(Equal(3))
- Ω(count).Should(Equal(1))
-
- startIndex, count = ParallelizedIndexRange(5, 4, 4)
- Ω(startIndex).Should(Equal(4))
- Ω(count).Should(Equal(1))
- })
-
- It("should return the correct index range for 5 tests on 5 nodes", func() {
- startIndex, count = ParallelizedIndexRange(5, 5, 1)
- Ω(startIndex).Should(Equal(0))
- Ω(count).Should(Equal(1))
-
- startIndex, count = ParallelizedIndexRange(5, 5, 2)
- Ω(startIndex).Should(Equal(1))
- Ω(count).Should(Equal(1))
-
- startIndex, count = ParallelizedIndexRange(5, 5, 3)
- Ω(startIndex).Should(Equal(2))
- Ω(count).Should(Equal(1))
-
- startIndex, count = ParallelizedIndexRange(5, 5, 4)
- Ω(startIndex).Should(Equal(3))
- Ω(count).Should(Equal(1))
-
- startIndex, count = ParallelizedIndexRange(5, 5, 5)
- Ω(startIndex).Should(Equal(4))
- Ω(count).Should(Equal(1))
- })
-
- It("should return the correct index range for 5 tests on 6 nodes", func() {
- startIndex, count = ParallelizedIndexRange(5, 6, 1)
- Ω(startIndex).Should(Equal(0))
- Ω(count).Should(Equal(1))
-
- startIndex, count = ParallelizedIndexRange(5, 6, 2)
- Ω(startIndex).Should(Equal(1))
- Ω(count).Should(Equal(1))
-
- startIndex, count = ParallelizedIndexRange(5, 6, 3)
- Ω(startIndex).Should(Equal(2))
- Ω(count).Should(Equal(1))
-
- startIndex, count = ParallelizedIndexRange(5, 6, 4)
- Ω(startIndex).Should(Equal(3))
- Ω(count).Should(Equal(1))
-
- startIndex, count = ParallelizedIndexRange(5, 6, 5)
- Ω(startIndex).Should(Equal(4))
- Ω(count).Should(Equal(1))
-
- startIndex, count = ParallelizedIndexRange(5, 6, 6)
- Ω(count).Should(Equal(0))
- })
-
- It("should return the correct index range for 5 tests on 7 nodes", func() {
- startIndex, count = ParallelizedIndexRange(5, 7, 6)
- Ω(count).Should(Equal(0))
-
- startIndex, count = ParallelizedIndexRange(5, 7, 7)
- Ω(count).Should(Equal(0))
- })
-
- It("should return the correct index range for 11 tests on 7 nodes", func() {
- startIndex, count = ParallelizedIndexRange(11, 7, 1)
- Ω(startIndex).Should(Equal(0))
- Ω(count).Should(Equal(2))
-
- startIndex, count = ParallelizedIndexRange(11, 7, 2)
- Ω(startIndex).Should(Equal(2))
- Ω(count).Should(Equal(2))
-
- startIndex, count = ParallelizedIndexRange(11, 7, 3)
- Ω(startIndex).Should(Equal(4))
- Ω(count).Should(Equal(2))
-
- startIndex, count = ParallelizedIndexRange(11, 7, 4)
- Ω(startIndex).Should(Equal(6))
- Ω(count).Should(Equal(2))
-
- startIndex, count = ParallelizedIndexRange(11, 7, 5)
- Ω(startIndex).Should(Equal(8))
- Ω(count).Should(Equal(1))
-
- startIndex, count = ParallelizedIndexRange(11, 7, 6)
- Ω(startIndex).Should(Equal(9))
- Ω(count).Should(Equal(1))
-
- startIndex, count = ParallelizedIndexRange(11, 7, 7)
- Ω(startIndex).Should(Equal(10))
- Ω(count).Should(Equal(1))
- })
-
-})
diff --git a/vendor/github.com/onsi/ginkgo/internal/spec_iterator/parallel_spec_iterator_test.go b/vendor/github.com/onsi/ginkgo/internal/spec_iterator/parallel_spec_iterator_test.go
deleted file mode 100644
index c5a762fd5..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/spec_iterator/parallel_spec_iterator_test.go
+++ /dev/null
@@ -1,112 +0,0 @@
-package spec_iterator_test
-
-import (
- "net/http"
-
- . "github.com/onsi/ginkgo/internal/spec_iterator"
- "github.com/onsi/gomega/ghttp"
-
- "github.com/onsi/ginkgo/internal/codelocation"
- "github.com/onsi/ginkgo/internal/containernode"
- "github.com/onsi/ginkgo/internal/leafnodes"
- "github.com/onsi/ginkgo/internal/spec"
- "github.com/onsi/ginkgo/types"
-
- . "github.com/onsi/ginkgo"
- . "github.com/onsi/gomega"
-)
-
-var _ = Describe("ParallelSpecIterator", func() {
- var specs []*spec.Spec
- var iterator *ParallelIterator
- var server *ghttp.Server
-
- newSpec := func(text string, flag types.FlagType) *spec.Spec {
- subject := leafnodes.NewItNode(text, func() {}, flag, codelocation.New(0), 0, nil, 0)
- return spec.New(subject, []*containernode.ContainerNode{}, false)
- }
-
- BeforeEach(func() {
- specs = []*spec.Spec{
- newSpec("A", types.FlagTypePending),
- newSpec("B", types.FlagTypeNone),
- newSpec("C", types.FlagTypeNone),
- newSpec("D", types.FlagTypeNone),
- }
- specs[3].Skip()
-
- server = ghttp.NewServer()
-
- iterator = NewParallelIterator(specs, "http://"+server.Addr())
- })
-
- AfterEach(func() {
- server.Close()
- })
-
- It("should report the total number of specs", func() {
- Ω(iterator.NumberOfSpecsPriorToIteration()).Should(Equal(4))
- })
-
- It("should not report the number to be processed", func() {
- n, known := iterator.NumberOfSpecsToProcessIfKnown()
- Ω(n).Should(Equal(-1))
- Ω(known).Should(BeFalse())
- })
-
- It("should not report the number that will be run", func() {
- n, known := iterator.NumberOfSpecsThatWillBeRunIfKnown()
- Ω(n).Should(Equal(-1))
- Ω(known).Should(BeFalse())
- })
-
- Describe("iterating", func() {
- Describe("when the server returns well-formed responses", func() {
- BeforeEach(func() {
- server.AppendHandlers(
- ghttp.RespondWithJSONEncoded(http.StatusOK, Counter{Index: 0}),
- ghttp.RespondWithJSONEncoded(http.StatusOK, Counter{Index: 1}),
- ghttp.RespondWithJSONEncoded(http.StatusOK, Counter{Index: 3}),
- ghttp.RespondWithJSONEncoded(http.StatusOK, Counter{Index: 4}),
- )
- })
-
- It("should return the specs in question", func() {
- Ω(iterator.Next()).Should(Equal(specs[0]))
- Ω(iterator.Next()).Should(Equal(specs[1]))
- Ω(iterator.Next()).Should(Equal(specs[3]))
- spec, err := iterator.Next()
- Ω(spec).Should(BeNil())
- Ω(err).Should(MatchError(ErrClosed))
- })
- })
-
- Describe("when the server 404s", func() {
- BeforeEach(func() {
- server.AppendHandlers(
- ghttp.RespondWith(http.StatusNotFound, ""),
- )
- })
-
- It("should return an error", func() {
- spec, err := iterator.Next()
- Ω(spec).Should(BeNil())
- Ω(err).Should(MatchError("unexpected status code 404"))
- })
- })
-
- Describe("when the server returns gibberish", func() {
- BeforeEach(func() {
- server.AppendHandlers(
- ghttp.RespondWith(http.StatusOK, "ß"),
- )
- })
-
- It("should error", func() {
- spec, err := iterator.Next()
- Ω(spec).Should(BeNil())
- Ω(err).ShouldNot(BeNil())
- })
- })
- })
-})
diff --git a/vendor/github.com/onsi/ginkgo/internal/spec_iterator/serial_spec_iterator_test.go b/vendor/github.com/onsi/ginkgo/internal/spec_iterator/serial_spec_iterator_test.go
deleted file mode 100644
index dde4a344e..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/spec_iterator/serial_spec_iterator_test.go
+++ /dev/null
@@ -1,64 +0,0 @@
-package spec_iterator_test
-
-import (
- . "github.com/onsi/ginkgo/internal/spec_iterator"
-
- "github.com/onsi/ginkgo/internal/codelocation"
- "github.com/onsi/ginkgo/internal/containernode"
- "github.com/onsi/ginkgo/internal/leafnodes"
- "github.com/onsi/ginkgo/internal/spec"
- "github.com/onsi/ginkgo/types"
-
- . "github.com/onsi/ginkgo"
- . "github.com/onsi/gomega"
-)
-
-var _ = Describe("SerialSpecIterator", func() {
- var specs []*spec.Spec
- var iterator *SerialIterator
-
- newSpec := func(text string, flag types.FlagType) *spec.Spec {
- subject := leafnodes.NewItNode(text, func() {}, flag, codelocation.New(0), 0, nil, 0)
- return spec.New(subject, []*containernode.ContainerNode{}, false)
- }
-
- BeforeEach(func() {
- specs = []*spec.Spec{
- newSpec("A", types.FlagTypePending),
- newSpec("B", types.FlagTypeNone),
- newSpec("C", types.FlagTypeNone),
- newSpec("D", types.FlagTypeNone),
- }
- specs[3].Skip()
-
- iterator = NewSerialIterator(specs)
- })
-
- It("should report the total number of specs", func() {
- Ω(iterator.NumberOfSpecsPriorToIteration()).Should(Equal(4))
- })
-
- It("should report the number to be processed", func() {
- n, known := iterator.NumberOfSpecsToProcessIfKnown()
- Ω(n).Should(Equal(4))
- Ω(known).Should(BeTrue())
- })
-
- It("should report the number that will be run", func() {
- n, known := iterator.NumberOfSpecsThatWillBeRunIfKnown()
- Ω(n).Should(Equal(2))
- Ω(known).Should(BeTrue())
- })
-
- Describe("iterating", func() {
- It("should return the specs in order", func() {
- Ω(iterator.Next()).Should(Equal(specs[0]))
- Ω(iterator.Next()).Should(Equal(specs[1]))
- Ω(iterator.Next()).Should(Equal(specs[2]))
- Ω(iterator.Next()).Should(Equal(specs[3]))
- spec, err := iterator.Next()
- Ω(spec).Should(BeNil())
- Ω(err).Should(MatchError(ErrClosed))
- })
- })
-})
diff --git a/vendor/github.com/onsi/ginkgo/internal/spec_iterator/sharded_parallel_spec_iterator_test.go b/vendor/github.com/onsi/ginkgo/internal/spec_iterator/sharded_parallel_spec_iterator_test.go
deleted file mode 100644
index c3786e03a..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/spec_iterator/sharded_parallel_spec_iterator_test.go
+++ /dev/null
@@ -1,62 +0,0 @@
-package spec_iterator_test
-
-import (
- . "github.com/onsi/ginkgo/internal/spec_iterator"
-
- "github.com/onsi/ginkgo/internal/codelocation"
- "github.com/onsi/ginkgo/internal/containernode"
- "github.com/onsi/ginkgo/internal/leafnodes"
- "github.com/onsi/ginkgo/internal/spec"
- "github.com/onsi/ginkgo/types"
-
- . "github.com/onsi/ginkgo"
- . "github.com/onsi/gomega"
-)
-
-var _ = Describe("ShardedParallelSpecIterator", func() {
- var specs []*spec.Spec
- var iterator *ShardedParallelIterator
-
- newSpec := func(text string, flag types.FlagType) *spec.Spec {
- subject := leafnodes.NewItNode(text, func() {}, flag, codelocation.New(0), 0, nil, 0)
- return spec.New(subject, []*containernode.ContainerNode{}, false)
- }
-
- BeforeEach(func() {
- specs = []*spec.Spec{
- newSpec("A", types.FlagTypePending),
- newSpec("B", types.FlagTypeNone),
- newSpec("C", types.FlagTypeNone),
- newSpec("D", types.FlagTypeNone),
- }
- specs[3].Skip()
-
- iterator = NewShardedParallelIterator(specs, 2, 1)
- })
-
- It("should report the total number of specs", func() {
- Ω(iterator.NumberOfSpecsPriorToIteration()).Should(Equal(4))
- })
-
- It("should report the number to be processed", func() {
- n, known := iterator.NumberOfSpecsToProcessIfKnown()
- Ω(n).Should(Equal(2))
- Ω(known).Should(BeTrue())
- })
-
- It("should report the number that will be run", func() {
- n, known := iterator.NumberOfSpecsThatWillBeRunIfKnown()
- Ω(n).Should(Equal(1))
- Ω(known).Should(BeTrue())
- })
-
- Describe("iterating", func() {
- It("should return the specs in order", func() {
- Ω(iterator.Next()).Should(Equal(specs[0]))
- Ω(iterator.Next()).Should(Equal(specs[1]))
- spec, err := iterator.Next()
- Ω(spec).Should(BeNil())
- Ω(err).Should(MatchError(ErrClosed))
- })
- })
-})
diff --git a/vendor/github.com/onsi/ginkgo/internal/spec_iterator/spec_iterator_suite_test.go b/vendor/github.com/onsi/ginkgo/internal/spec_iterator/spec_iterator_suite_test.go
deleted file mode 100644
index 5c08a77e3..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/spec_iterator/spec_iterator_suite_test.go
+++ /dev/null
@@ -1,13 +0,0 @@
-package spec_iterator_test
-
-import (
- . "github.com/onsi/ginkgo"
- . "github.com/onsi/gomega"
-
- "testing"
-)
-
-func TestSpecIterator(t *testing.T) {
- RegisterFailHandler(Fail)
- RunSpecs(t, "SpecIterator Suite")
-}
diff --git a/vendor/github.com/onsi/ginkgo/internal/specrunner/spec_runner_suite_test.go b/vendor/github.com/onsi/ginkgo/internal/specrunner/spec_runner_suite_test.go
deleted file mode 100644
index c8388fb6f..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/specrunner/spec_runner_suite_test.go
+++ /dev/null
@@ -1,13 +0,0 @@
-package specrunner_test
-
-import (
- . "github.com/onsi/ginkgo"
- . "github.com/onsi/gomega"
-
- "testing"
-)
-
-func TestSpecRunner(t *testing.T) {
- RegisterFailHandler(Fail)
- RunSpecs(t, "Spec Runner Suite")
-}
diff --git a/vendor/github.com/onsi/ginkgo/internal/specrunner/spec_runner_test.go b/vendor/github.com/onsi/ginkgo/internal/specrunner/spec_runner_test.go
deleted file mode 100644
index a41437922..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/specrunner/spec_runner_test.go
+++ /dev/null
@@ -1,785 +0,0 @@
-package specrunner_test
-
-import (
- . "github.com/onsi/ginkgo"
- "github.com/onsi/ginkgo/internal/spec_iterator"
- . "github.com/onsi/ginkgo/internal/specrunner"
- "github.com/onsi/ginkgo/types"
- . "github.com/onsi/gomega"
-
- "github.com/onsi/ginkgo/config"
- "github.com/onsi/ginkgo/internal/codelocation"
- "github.com/onsi/ginkgo/internal/containernode"
- Failer "github.com/onsi/ginkgo/internal/failer"
- "github.com/onsi/ginkgo/internal/leafnodes"
- "github.com/onsi/ginkgo/internal/spec"
- Writer "github.com/onsi/ginkgo/internal/writer"
- "github.com/onsi/ginkgo/reporters"
-)
-
-var noneFlag = types.FlagTypeNone
-var pendingFlag = types.FlagTypePending
-
-var _ = Describe("Spec Runner", func() {
- var (
- reporter1 *reporters.FakeReporter
- reporter2 *reporters.FakeReporter
- failer *Failer.Failer
- writer *Writer.FakeGinkgoWriter
-
- thingsThatRan []string
-
- runner *SpecRunner
- )
-
- newBefSuite := func(text string, fail bool) leafnodes.SuiteNode {
- return leafnodes.NewBeforeSuiteNode(func() {
- writer.AddEvent(text)
- thingsThatRan = append(thingsThatRan, text)
- if fail {
- failer.Fail(text, codelocation.New(0))
- }
- }, codelocation.New(0), 0, failer)
- }
-
- newAftSuite := func(text string, fail bool) leafnodes.SuiteNode {
- return leafnodes.NewAfterSuiteNode(func() {
- writer.AddEvent(text)
- thingsThatRan = append(thingsThatRan, text)
- if fail {
- failer.Fail(text, codelocation.New(0))
- }
- }, codelocation.New(0), 0, failer)
- }
-
- newSpec := func(text string, flag types.FlagType, fail bool) *spec.Spec {
- subject := leafnodes.NewItNode(text, func() {
- writer.AddEvent(text)
- thingsThatRan = append(thingsThatRan, text)
- if fail {
- failer.Fail(text, codelocation.New(0))
- }
- }, flag, codelocation.New(0), 0, failer, 0)
-
- return spec.New(subject, []*containernode.ContainerNode{}, false)
- }
-
- newFlakySpec := func(text string, flag types.FlagType, failures int) *spec.Spec {
- runs := 0
- subject := leafnodes.NewItNode(text, func() {
- writer.AddEvent(text)
- thingsThatRan = append(thingsThatRan, text)
- runs++
- if runs < failures {
- failer.Fail(text, codelocation.New(0))
- }
- }, flag, codelocation.New(0), 0, failer, 0)
-
- return spec.New(subject, []*containernode.ContainerNode{}, false)
- }
-
- newSpecWithBody := func(text string, body interface{}) *spec.Spec {
- subject := leafnodes.NewItNode(text, body, noneFlag, codelocation.New(0), 0, failer, 0)
-
- return spec.New(subject, []*containernode.ContainerNode{}, false)
- }
-
- newRunner := func(config config.GinkgoConfigType, beforeSuiteNode leafnodes.SuiteNode, afterSuiteNode leafnodes.SuiteNode, specs ...*spec.Spec) *SpecRunner {
- iterator := spec_iterator.NewSerialIterator(specs)
- return New("description", beforeSuiteNode, iterator, afterSuiteNode, []reporters.Reporter{reporter1, reporter2}, writer, config)
- }
-
- BeforeEach(func() {
- reporter1 = reporters.NewFakeReporter()
- reporter2 = reporters.NewFakeReporter()
- writer = Writer.NewFake()
- failer = Failer.New()
-
- thingsThatRan = []string{}
- })
-
- Describe("Running and Reporting", func() {
- var specA, pendingSpec, anotherPendingSpec, failedSpec, specB, skippedSpec *spec.Spec
- var willRunCalls, didCompleteCalls []string
- var conf config.GinkgoConfigType
-
- JustBeforeEach(func() {
- willRunCalls = []string{}
- didCompleteCalls = []string{}
- specA = newSpec("spec A", noneFlag, false)
- pendingSpec = newSpec("pending spec", pendingFlag, false)
- anotherPendingSpec = newSpec("another pending spec", pendingFlag, false)
- failedSpec = newSpec("failed spec", noneFlag, true)
- specB = newSpec("spec B", noneFlag, false)
- skippedSpec = newSpec("skipped spec", noneFlag, false)
- skippedSpec.Skip()
-
- reporter1.SpecWillRunStub = func(specSummary *types.SpecSummary) {
- willRunCalls = append(willRunCalls, "Reporter1")
- }
- reporter2.SpecWillRunStub = func(specSummary *types.SpecSummary) {
- willRunCalls = append(willRunCalls, "Reporter2")
- }
-
- reporter1.SpecDidCompleteStub = func(specSummary *types.SpecSummary) {
- didCompleteCalls = append(didCompleteCalls, "Reporter1")
- }
- reporter2.SpecDidCompleteStub = func(specSummary *types.SpecSummary) {
- didCompleteCalls = append(didCompleteCalls, "Reporter2")
- }
-
- runner = newRunner(conf, newBefSuite("BefSuite", false), newAftSuite("AftSuite", false), specA, pendingSpec, anotherPendingSpec, failedSpec, specB, skippedSpec)
- runner.Run()
- })
-
- BeforeEach(func() {
- conf = config.GinkgoConfigType{RandomSeed: 17}
- })
-
- It("should skip skipped/pending tests", func() {
- Ω(thingsThatRan).Should(Equal([]string{"BefSuite", "spec A", "failed spec", "spec B", "AftSuite"}))
- })
-
- It("should report to any attached reporters", func() {
- Ω(reporter1.Config).Should(Equal(reporter2.Config))
- Ω(reporter1.BeforeSuiteSummary).Should(Equal(reporter2.BeforeSuiteSummary))
- Ω(reporter1.BeginSummary).Should(Equal(reporter2.BeginSummary))
- Ω(reporter1.SpecWillRunSummaries).Should(Equal(reporter2.SpecWillRunSummaries))
- Ω(reporter1.SpecSummaries).Should(Equal(reporter2.SpecSummaries))
- Ω(reporter1.AfterSuiteSummary).Should(Equal(reporter2.AfterSuiteSummary))
- Ω(reporter1.EndSummary).Should(Equal(reporter2.EndSummary))
- })
-
- It("should report that a spec did end in reverse order", func() {
- Ω(willRunCalls[0:4]).Should(Equal([]string{"Reporter1", "Reporter2", "Reporter1", "Reporter2"}))
- Ω(didCompleteCalls[0:4]).Should(Equal([]string{"Reporter2", "Reporter1", "Reporter2", "Reporter1"}))
- })
-
- It("should report the passed in config", func() {
- Ω(reporter1.Config.RandomSeed).Should(BeNumerically("==", 17))
- })
-
- It("should report the beginning of the suite", func() {
- Ω(reporter1.BeginSummary.SuiteDescription).Should(Equal("description"))
- Ω(reporter1.BeginSummary.SuiteID).Should(MatchRegexp("[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}"))
- Ω(reporter1.BeginSummary.NumberOfSpecsBeforeParallelization).Should(Equal(6))
- Ω(reporter1.BeginSummary.NumberOfTotalSpecs).Should(Equal(6))
- Ω(reporter1.BeginSummary.NumberOfSpecsThatWillBeRun).Should(Equal(3))
- Ω(reporter1.BeginSummary.NumberOfPendingSpecs).Should(Equal(-1))
- Ω(reporter1.BeginSummary.NumberOfSkippedSpecs).Should(Equal(-1))
- })
-
- It("should report the end of the suite", func() {
- Ω(reporter1.EndSummary.SuiteDescription).Should(Equal("description"))
- Ω(reporter1.EndSummary.SuiteSucceeded).Should(BeFalse())
- Ω(reporter1.EndSummary.SuiteID).Should(MatchRegexp("[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}"))
- Ω(reporter1.EndSummary.NumberOfSpecsBeforeParallelization).Should(Equal(6))
- Ω(reporter1.EndSummary.NumberOfTotalSpecs).Should(Equal(6))
- Ω(reporter1.EndSummary.NumberOfSpecsThatWillBeRun).Should(Equal(3))
- Ω(reporter1.EndSummary.NumberOfPendingSpecs).Should(Equal(2))
- Ω(reporter1.EndSummary.NumberOfSkippedSpecs).Should(Equal(1))
- Ω(reporter1.EndSummary.NumberOfPassedSpecs).Should(Equal(2))
- Ω(reporter1.EndSummary.NumberOfFailedSpecs).Should(Equal(1))
- })
-
- Context("when told to perform a dry run", func() {
- BeforeEach(func() {
- conf.DryRun = true
- })
-
- It("should report to the reporters", func() {
- Ω(reporter1.Config).Should(Equal(reporter2.Config))
- Ω(reporter1.BeforeSuiteSummary).Should(Equal(reporter2.BeforeSuiteSummary))
- Ω(reporter1.BeginSummary).Should(Equal(reporter2.BeginSummary))
- Ω(reporter1.SpecWillRunSummaries).Should(Equal(reporter2.SpecWillRunSummaries))
- Ω(reporter1.SpecSummaries).Should(Equal(reporter2.SpecSummaries))
- Ω(reporter1.AfterSuiteSummary).Should(Equal(reporter2.AfterSuiteSummary))
- Ω(reporter1.EndSummary).Should(Equal(reporter2.EndSummary))
- })
-
- It("should not actually run anything", func() {
- Ω(thingsThatRan).Should(BeEmpty())
- })
-
- It("report before and after suites as passed", func() {
- Ω(reporter1.BeforeSuiteSummary.State).Should(Equal(types.SpecStatePassed))
- Ω(reporter1.AfterSuiteSummary.State).Should(Equal(types.SpecStatePassed))
- })
-
- It("should report specs as passed", func() {
- summaries := reporter1.SpecSummaries
- Ω(summaries).Should(HaveLen(6))
- Ω(summaries[0].ComponentTexts).Should(ContainElement("spec A"))
- Ω(summaries[0].State).Should(Equal(types.SpecStatePassed))
- Ω(summaries[1].ComponentTexts).Should(ContainElement("pending spec"))
- Ω(summaries[1].State).Should(Equal(types.SpecStatePending))
- Ω(summaries[2].ComponentTexts).Should(ContainElement("another pending spec"))
- Ω(summaries[2].State).Should(Equal(types.SpecStatePending))
- Ω(summaries[3].ComponentTexts).Should(ContainElement("failed spec"))
- Ω(summaries[3].State).Should(Equal(types.SpecStatePassed))
- Ω(summaries[4].ComponentTexts).Should(ContainElement("spec B"))
- Ω(summaries[4].State).Should(Equal(types.SpecStatePassed))
- Ω(summaries[5].ComponentTexts).Should(ContainElement("skipped spec"))
- Ω(summaries[5].State).Should(Equal(types.SpecStateSkipped))
- })
-
- It("should report the end of the suite", func() {
- Ω(reporter1.EndSummary.SuiteDescription).Should(Equal("description"))
- Ω(reporter1.EndSummary.SuiteSucceeded).Should(BeTrue())
- Ω(reporter1.EndSummary.SuiteID).Should(MatchRegexp("[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}"))
- Ω(reporter1.EndSummary.NumberOfSpecsBeforeParallelization).Should(Equal(6))
- Ω(reporter1.EndSummary.NumberOfTotalSpecs).Should(Equal(6))
- Ω(reporter1.EndSummary.NumberOfSpecsThatWillBeRun).Should(Equal(3))
- Ω(reporter1.EndSummary.NumberOfPendingSpecs).Should(Equal(2))
- Ω(reporter1.EndSummary.NumberOfSkippedSpecs).Should(Equal(1))
- Ω(reporter1.EndSummary.NumberOfPassedSpecs).Should(Equal(0))
- Ω(reporter1.EndSummary.NumberOfFailedSpecs).Should(Equal(0))
- })
-
- It("should not report a slow test", func() {
- summaries := reporter1.SpecSummaries
- for _, s := range summaries {
- Expect(s.RunTime).To(BeZero())
- }
- })
- })
- })
-
- Describe("reporting on specs", func() {
- var proceed chan bool
- var ready chan bool
- var finished chan bool
- BeforeEach(func() {
- ready = make(chan bool)
- proceed = make(chan bool)
- finished = make(chan bool)
- skippedSpec := newSpec("SKIP", noneFlag, false)
- skippedSpec.Skip()
-
- runner = newRunner(
- config.GinkgoConfigType{},
- newBefSuite("BefSuite", false),
- newAftSuite("AftSuite", false),
- skippedSpec,
- newSpec("PENDING", pendingFlag, false),
- newSpecWithBody("RUN", func() {
- close(ready)
- <-proceed
- }),
- )
- go func() {
- runner.Run()
- close(finished)
- }()
- })
-
- It("should report about pending/skipped specs", func() {
- <-ready
- Ω(reporter1.SpecWillRunSummaries).Should(HaveLen(3))
-
- Ω(reporter1.SpecWillRunSummaries[0].ComponentTexts[0]).Should(Equal("SKIP"))
- Ω(reporter1.SpecWillRunSummaries[1].ComponentTexts[0]).Should(Equal("PENDING"))
- Ω(reporter1.SpecWillRunSummaries[2].ComponentTexts[0]).Should(Equal("RUN"))
-
- Ω(reporter1.SpecSummaries[0].ComponentTexts[0]).Should(Equal("SKIP"))
- Ω(reporter1.SpecSummaries[1].ComponentTexts[0]).Should(Equal("PENDING"))
- Ω(reporter1.SpecSummaries).Should(HaveLen(2))
-
- close(proceed)
- <-finished
-
- Ω(reporter1.SpecSummaries).Should(HaveLen(3))
- Ω(reporter1.SpecSummaries[2].ComponentTexts[0]).Should(Equal("RUN"))
- })
- })
-
- Describe("Running and Reporting when there's flakes", func() {
- var specA, pendingSpec, flakySpec, failedSpec, specB, skippedSpec *spec.Spec
- var willRunCalls, didCompleteCalls []string
- var conf config.GinkgoConfigType
- var failedSpecFlag = noneFlag
-
- JustBeforeEach(func() {
- willRunCalls = []string{}
- didCompleteCalls = []string{}
- specA = newSpec("spec A", noneFlag, false)
- pendingSpec = newSpec("pending spec", pendingFlag, false)
- flakySpec = newFlakySpec("flaky spec", noneFlag, 3)
- failedSpec = newSpec("failed spec", failedSpecFlag, true)
- specB = newSpec("spec B", noneFlag, false)
- skippedSpec = newSpec("skipped spec", noneFlag, false)
- skippedSpec.Skip()
-
- reporter1.SpecWillRunStub = func(specSummary *types.SpecSummary) {
- willRunCalls = append(willRunCalls, "Reporter1")
- }
- reporter2.SpecWillRunStub = func(specSummary *types.SpecSummary) {
- willRunCalls = append(willRunCalls, "Reporter2")
- }
-
- reporter1.SpecDidCompleteStub = func(specSummary *types.SpecSummary) {
- didCompleteCalls = append(didCompleteCalls, "Reporter1")
- }
- reporter2.SpecDidCompleteStub = func(specSummary *types.SpecSummary) {
- didCompleteCalls = append(didCompleteCalls, "Reporter2")
- }
-
- runner = newRunner(conf, newBefSuite("BefSuite", false), newAftSuite("AftSuite", false), specA, pendingSpec, flakySpec, failedSpec, specB, skippedSpec)
- runner.Run()
- })
-
- BeforeEach(func() {
- failedSpecFlag = noneFlag
- conf = config.GinkgoConfigType{
- RandomSeed: 17,
- FlakeAttempts: 5,
- }
- })
-
- It("should skip skipped/pending tests", func() {
- Ω(thingsThatRan).Should(Equal([]string{"BefSuite", "spec A", "flaky spec", "flaky spec", "flaky spec", "failed spec", "failed spec", "failed spec", "failed spec", "failed spec", "spec B", "AftSuite"}))
- })
-
- It("should report to any attached reporters", func() {
- Ω(reporter1.Config).Should(Equal(reporter2.Config))
- Ω(reporter1.BeforeSuiteSummary).Should(Equal(reporter2.BeforeSuiteSummary))
- Ω(reporter1.BeginSummary).Should(Equal(reporter2.BeginSummary))
- Ω(reporter1.SpecWillRunSummaries).Should(Equal(reporter2.SpecWillRunSummaries))
- Ω(reporter1.SpecSummaries).Should(Equal(reporter2.SpecSummaries))
- Ω(reporter1.AfterSuiteSummary).Should(Equal(reporter2.AfterSuiteSummary))
- Ω(reporter1.EndSummary).Should(Equal(reporter2.EndSummary))
- })
-
- It("should report that a spec did end in reverse order", func() {
- Ω(willRunCalls[0:4]).Should(Equal([]string{"Reporter1", "Reporter2", "Reporter1", "Reporter2"}))
- Ω(didCompleteCalls[0:4]).Should(Equal([]string{"Reporter2", "Reporter1", "Reporter2", "Reporter1"}))
- })
-
- It("should report the passed in config", func() {
- Ω(reporter1.Config.RandomSeed).Should(BeNumerically("==", 17))
- })
-
- It("should report the beginning of the suite", func() {
- Ω(reporter1.BeginSummary.SuiteDescription).Should(Equal("description"))
- Ω(reporter1.BeginSummary.SuiteID).Should(MatchRegexp("[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}"))
- Ω(reporter1.BeginSummary.NumberOfSpecsBeforeParallelization).Should(Equal(6))
- Ω(reporter1.BeginSummary.NumberOfTotalSpecs).Should(Equal(6))
- Ω(reporter1.BeginSummary.NumberOfSpecsThatWillBeRun).Should(Equal(4))
- Ω(reporter1.BeginSummary.NumberOfPendingSpecs).Should(Equal(-1))
- Ω(reporter1.BeginSummary.NumberOfSkippedSpecs).Should(Equal(-1))
- })
-
- It("should report the end of the suite", func() {
- Ω(reporter1.EndSummary.SuiteDescription).Should(Equal("description"))
- Ω(reporter1.EndSummary.SuiteSucceeded).Should(BeFalse())
- Ω(reporter1.EndSummary.SuiteID).Should(MatchRegexp("[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}"))
- Ω(reporter1.EndSummary.NumberOfSpecsBeforeParallelization).Should(Equal(6))
- Ω(reporter1.EndSummary.NumberOfTotalSpecs).Should(Equal(6))
- Ω(reporter1.EndSummary.NumberOfSpecsThatWillBeRun).Should(Equal(4))
- Ω(reporter1.EndSummary.NumberOfPendingSpecs).Should(Equal(1))
- Ω(reporter1.EndSummary.NumberOfSkippedSpecs).Should(Equal(1))
- Ω(reporter1.EndSummary.NumberOfPassedSpecs).Should(Equal(3))
- Ω(reporter1.EndSummary.NumberOfFailedSpecs).Should(Equal(1))
- Ω(reporter1.EndSummary.NumberOfFlakedSpecs).Should(Equal(1))
- })
-
- Context("when nothing fails", func() {
- BeforeEach(func() {
- failedSpecFlag = pendingFlag
- })
-
- It("the suite should pass even with flakes", func() {
- Ω(reporter1.EndSummary.SuiteSucceeded).Should(BeTrue())
- Ω(reporter1.EndSummary.NumberOfFlakedSpecs).Should(Equal(1))
- })
- })
-
- Context("when told to perform a dry run", func() {
- BeforeEach(func() {
- conf.DryRun = true
- })
-
- It("should report to the reporters", func() {
- Ω(reporter1.Config).Should(Equal(reporter2.Config))
- Ω(reporter1.BeforeSuiteSummary).Should(Equal(reporter2.BeforeSuiteSummary))
- Ω(reporter1.BeginSummary).Should(Equal(reporter2.BeginSummary))
- Ω(reporter1.SpecWillRunSummaries).Should(Equal(reporter2.SpecWillRunSummaries))
- Ω(reporter1.SpecSummaries).Should(Equal(reporter2.SpecSummaries))
- Ω(reporter1.AfterSuiteSummary).Should(Equal(reporter2.AfterSuiteSummary))
- Ω(reporter1.EndSummary).Should(Equal(reporter2.EndSummary))
- })
-
- It("should not actually run anything", func() {
- Ω(thingsThatRan).Should(BeEmpty())
- })
-
- It("report before and after suites as passed", func() {
- Ω(reporter1.BeforeSuiteSummary.State).Should(Equal(types.SpecStatePassed))
- Ω(reporter1.AfterSuiteSummary.State).Should(Equal(types.SpecStatePassed))
- })
-
- It("should report specs as passed", func() {
- summaries := reporter1.SpecSummaries
- Ω(summaries).Should(HaveLen(6))
- Ω(summaries[0].ComponentTexts).Should(ContainElement("spec A"))
- Ω(summaries[0].State).Should(Equal(types.SpecStatePassed))
- Ω(summaries[1].ComponentTexts).Should(ContainElement("pending spec"))
- Ω(summaries[1].State).Should(Equal(types.SpecStatePending))
- Ω(summaries[2].ComponentTexts).Should(ContainElement("flaky spec"))
- Ω(summaries[2].State).Should(Equal(types.SpecStatePassed))
- Ω(summaries[3].ComponentTexts).Should(ContainElement("failed spec"))
- Ω(summaries[3].State).Should(Equal(types.SpecStatePassed))
- Ω(summaries[4].ComponentTexts).Should(ContainElement("spec B"))
- Ω(summaries[4].State).Should(Equal(types.SpecStatePassed))
- Ω(summaries[5].ComponentTexts).Should(ContainElement("skipped spec"))
- Ω(summaries[5].State).Should(Equal(types.SpecStateSkipped))
- })
-
- It("should report the end of the suite", func() {
- Ω(reporter1.EndSummary.SuiteDescription).Should(Equal("description"))
- Ω(reporter1.EndSummary.SuiteSucceeded).Should(BeTrue())
- Ω(reporter1.EndSummary.SuiteID).Should(MatchRegexp("[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}"))
- Ω(reporter1.EndSummary.NumberOfSpecsBeforeParallelization).Should(Equal(6))
- Ω(reporter1.EndSummary.NumberOfTotalSpecs).Should(Equal(6))
- Ω(reporter1.EndSummary.NumberOfSpecsThatWillBeRun).Should(Equal(4))
- Ω(reporter1.EndSummary.NumberOfPendingSpecs).Should(Equal(1))
- Ω(reporter1.EndSummary.NumberOfSkippedSpecs).Should(Equal(1))
- Ω(reporter1.EndSummary.NumberOfPassedSpecs).Should(Equal(0))
- Ω(reporter1.EndSummary.NumberOfFailedSpecs).Should(Equal(0))
- })
- })
- })
-
- Describe("Running BeforeSuite & AfterSuite", func() {
- var success bool
- var befSuite leafnodes.SuiteNode
- var aftSuite leafnodes.SuiteNode
- Context("with a nil BeforeSuite & AfterSuite", func() {
- BeforeEach(func() {
- runner = newRunner(
- config.GinkgoConfigType{},
- nil,
- nil,
- newSpec("A", noneFlag, false),
- newSpec("B", noneFlag, false),
- )
- success = runner.Run()
- })
-
- It("should not report about the BeforeSuite", func() {
- Ω(reporter1.BeforeSuiteSummary).Should(BeNil())
- })
-
- It("should not report about the AfterSuite", func() {
- Ω(reporter1.AfterSuiteSummary).Should(BeNil())
- })
-
- It("should run the specs", func() {
- Ω(thingsThatRan).Should(Equal([]string{"A", "B"}))
- })
- })
-
- Context("when the BeforeSuite & AfterSuite pass", func() {
- BeforeEach(func() {
- befSuite = newBefSuite("BefSuite", false)
- aftSuite = newBefSuite("AftSuite", false)
- runner = newRunner(
- config.GinkgoConfigType{},
- befSuite,
- aftSuite,
- newSpec("A", noneFlag, false),
- newSpec("B", noneFlag, false),
- )
- success = runner.Run()
- })
-
- It("should run the BeforeSuite, the AfterSuite and the specs", func() {
- Ω(thingsThatRan).Should(Equal([]string{"BefSuite", "A", "B", "AftSuite"}))
- })
-
- It("should report about the BeforeSuite", func() {
- Ω(reporter1.BeforeSuiteSummary).Should(Equal(befSuite.Summary()))
- })
-
- It("should report about the AfterSuite", func() {
- Ω(reporter1.AfterSuiteSummary).Should(Equal(aftSuite.Summary()))
- })
-
- It("should report success", func() {
- Ω(success).Should(BeTrue())
- Ω(reporter1.EndSummary.SuiteSucceeded).Should(BeTrue())
- Ω(reporter1.EndSummary.NumberOfFailedSpecs).Should(Equal(0))
- })
-
- It("should not dump the writer", func() {
- Ω(writer.EventStream).ShouldNot(ContainElement("DUMP"))
- })
- })
-
- Context("when the BeforeSuite fails", func() {
- BeforeEach(func() {
- befSuite = newBefSuite("BefSuite", true)
- aftSuite = newBefSuite("AftSuite", false)
-
- skipped := newSpec("Skipped", noneFlag, false)
- skipped.Skip()
-
- runner = newRunner(
- config.GinkgoConfigType{},
- befSuite,
- aftSuite,
- newSpec("A", noneFlag, false),
- newSpec("B", noneFlag, false),
- newSpec("Pending", pendingFlag, false),
- skipped,
- )
- success = runner.Run()
- })
-
- It("should not run the specs, but it should run the AfterSuite", func() {
- Ω(thingsThatRan).Should(Equal([]string{"BefSuite", "AftSuite"}))
- })
-
- It("should report about the BeforeSuite", func() {
- Ω(reporter1.BeforeSuiteSummary).Should(Equal(befSuite.Summary()))
- })
-
- It("should report about the AfterSuite", func() {
- Ω(reporter1.AfterSuiteSummary).Should(Equal(aftSuite.Summary()))
- })
-
- It("should report failure", func() {
- Ω(success).Should(BeFalse())
- Ω(reporter1.EndSummary.SuiteSucceeded).Should(BeFalse())
- Ω(reporter1.EndSummary.NumberOfFailedSpecs).Should(Equal(2))
- Ω(reporter1.EndSummary.NumberOfSpecsThatWillBeRun).Should(Equal(2))
- })
-
- It("should dump the writer", func() {
- Ω(writer.EventStream).Should(ContainElement("DUMP"))
- })
- })
-
- Context("when some other test fails", func() {
- BeforeEach(func() {
- aftSuite = newBefSuite("AftSuite", false)
-
- runner = newRunner(
- config.GinkgoConfigType{},
- nil,
- aftSuite,
- newSpec("A", noneFlag, true),
- )
- success = runner.Run()
- })
-
- It("should still run the AfterSuite", func() {
- Ω(thingsThatRan).Should(Equal([]string{"A", "AftSuite"}))
- })
-
- It("should report about the AfterSuite", func() {
- Ω(reporter1.AfterSuiteSummary).Should(Equal(aftSuite.Summary()))
- })
-
- It("should report failure", func() {
- Ω(success).Should(BeFalse())
- Ω(reporter1.EndSummary.SuiteSucceeded).Should(BeFalse())
- Ω(reporter1.EndSummary.NumberOfFailedSpecs).Should(Equal(1))
- Ω(reporter1.EndSummary.NumberOfSpecsThatWillBeRun).Should(Equal(1))
- })
- })
-
- Context("when the AfterSuite fails", func() {
- BeforeEach(func() {
- befSuite = newBefSuite("BefSuite", false)
- aftSuite = newBefSuite("AftSuite", true)
- runner = newRunner(
- config.GinkgoConfigType{},
- befSuite,
- aftSuite,
- newSpec("A", noneFlag, false),
- newSpec("B", noneFlag, false),
- )
- success = runner.Run()
- })
-
- It("should run everything", func() {
- Ω(thingsThatRan).Should(Equal([]string{"BefSuite", "A", "B", "AftSuite"}))
- })
-
- It("should report about the BeforeSuite", func() {
- Ω(reporter1.BeforeSuiteSummary).Should(Equal(befSuite.Summary()))
- })
-
- It("should report about the AfterSuite", func() {
- Ω(reporter1.AfterSuiteSummary).Should(Equal(aftSuite.Summary()))
- })
-
- It("should report failure", func() {
- Ω(success).Should(BeFalse())
- Ω(reporter1.EndSummary.SuiteSucceeded).Should(BeFalse())
- Ω(reporter1.EndSummary.NumberOfFailedSpecs).Should(Equal(0))
- })
-
- It("should dump the writer", func() {
- Ω(writer.EventStream).Should(ContainElement("DUMP"))
- })
- })
- })
-
- Describe("When instructed to fail fast", func() {
- BeforeEach(func() {
- conf := config.GinkgoConfigType{
- FailFast: true,
- }
- runner = newRunner(conf, nil, newAftSuite("after-suite", false), newSpec("passing", noneFlag, false), newSpec("failing", noneFlag, true), newSpec("dont-see", noneFlag, true), newSpec("dont-see", noneFlag, true))
- })
-
- It("should return false, report failure, and not run anything past the failing test", func() {
- Ω(runner.Run()).Should(BeFalse())
- Ω(reporter1.EndSummary.SuiteSucceeded).Should(BeFalse())
- Ω(thingsThatRan).Should(Equal([]string{"passing", "failing", "after-suite"}))
- })
-
- It("should announce the subsequent specs as skipped", func() {
- runner.Run()
- Ω(reporter1.SpecSummaries).Should(HaveLen(4))
- Ω(reporter1.SpecSummaries[2].State).Should(Equal(types.SpecStateSkipped))
- Ω(reporter1.SpecSummaries[3].State).Should(Equal(types.SpecStateSkipped))
- })
-
- It("should mark all subsequent specs as skipped", func() {
- runner.Run()
- Ω(reporter1.EndSummary.NumberOfSkippedSpecs).Should(Equal(2))
- })
- })
-
- Describe("Marking failure and success", func() {
- Context("when all tests pass", func() {
- BeforeEach(func() {
- runner = newRunner(config.GinkgoConfigType{}, nil, nil, newSpec("passing", noneFlag, false), newSpec("pending", pendingFlag, false))
- })
-
- It("should return true and report success", func() {
- Ω(runner.Run()).Should(BeTrue())
- Ω(reporter1.EndSummary.SuiteSucceeded).Should(BeTrue())
- })
- })
-
- Context("when a test fails", func() {
- BeforeEach(func() {
- runner = newRunner(config.GinkgoConfigType{}, nil, nil, newSpec("failing", noneFlag, true), newSpec("pending", pendingFlag, false))
- })
-
- It("should return false and report failure", func() {
- Ω(runner.Run()).Should(BeFalse())
- Ω(reporter1.EndSummary.SuiteSucceeded).Should(BeFalse())
- })
- })
-
- Context("when there is a pending test, but pendings count as failures", func() {
- BeforeEach(func() {
- runner = newRunner(config.GinkgoConfigType{FailOnPending: true}, nil, nil, newSpec("passing", noneFlag, false), newSpec("pending", pendingFlag, false))
- })
-
- It("should return false and report failure", func() {
- Ω(runner.Run()).Should(BeFalse())
- Ω(reporter1.EndSummary.SuiteSucceeded).Should(BeFalse())
- })
- })
- })
-
- Describe("Managing the writer", func() {
- BeforeEach(func() {
- runner = newRunner(
- config.GinkgoConfigType{},
- nil,
- nil,
- newSpec("A", noneFlag, false),
- newSpec("B", noneFlag, true),
- newSpec("C", noneFlag, false),
- )
- reporter1.SpecWillRunStub = func(specSummary *types.SpecSummary) {
- writer.AddEvent("R1.WillRun")
- }
- reporter2.SpecWillRunStub = func(specSummary *types.SpecSummary) {
- writer.AddEvent("R2.WillRun")
- }
- reporter1.SpecDidCompleteStub = func(specSummary *types.SpecSummary) {
- writer.AddEvent("R1.DidComplete")
- }
- reporter2.SpecDidCompleteStub = func(specSummary *types.SpecSummary) {
- writer.AddEvent("R2.DidComplete")
- }
- runner.Run()
- })
-
- It("should truncate between tests, but only dump if a test fails", func() {
- Ω(writer.EventStream).Should(Equal([]string{
- "TRUNCATE",
- "R1.WillRun",
- "R2.WillRun",
- "A",
- "R2.DidComplete",
- "R1.DidComplete",
- "TRUNCATE",
- "R1.WillRun",
- "R2.WillRun",
- "B",
- "BYTES",
- "R2.DidComplete",
- "DUMP",
- "R1.DidComplete",
- "TRUNCATE",
- "R1.WillRun",
- "R2.WillRun",
- "C",
- "R2.DidComplete",
- "R1.DidComplete",
- }))
- })
- })
-
- Describe("CurrentSpecSummary", func() {
- It("should return the spec summary for the currently running spec", func() {
- var summary *types.SpecSummary
- runner = newRunner(
- config.GinkgoConfigType{},
- nil,
- nil,
- newSpec("A", noneFlag, false),
- newSpecWithBody("B", func() {
- var ok bool
- summary, ok = runner.CurrentSpecSummary()
- Ω(ok).Should(BeTrue())
- }),
- newSpec("C", noneFlag, false),
- )
- runner.Run()
-
- Ω(summary.ComponentTexts).Should(Equal([]string{"B"}))
-
- summary, ok := runner.CurrentSpecSummary()
- Ω(summary).Should(BeNil())
- Ω(ok).Should(BeFalse())
- })
- })
-
- Describe("generating a suite id", func() {
- It("should generate an id randomly", func() {
- runnerA := newRunner(config.GinkgoConfigType{}, nil, nil)
- runnerA.Run()
- IDA := reporter1.BeginSummary.SuiteID
-
- runnerB := newRunner(config.GinkgoConfigType{}, nil, nil)
- runnerB.Run()
- IDB := reporter1.BeginSummary.SuiteID
-
- IDRegexp := "[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}"
- Ω(IDA).Should(MatchRegexp(IDRegexp))
- Ω(IDB).Should(MatchRegexp(IDRegexp))
-
- Ω(IDA).ShouldNot(Equal(IDB))
- })
- })
-})
diff --git a/vendor/github.com/onsi/ginkgo/internal/suite/suite_suite_test.go b/vendor/github.com/onsi/ginkgo/internal/suite/suite_suite_test.go
deleted file mode 100644
index 06fe1d12a..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/suite/suite_suite_test.go
+++ /dev/null
@@ -1,35 +0,0 @@
-package suite_test
-
-import (
- . "github.com/onsi/ginkgo"
- . "github.com/onsi/gomega"
-
- "testing"
-)
-
-func Test(t *testing.T) {
- RegisterFailHandler(Fail)
- RunSpecs(t, "Suite")
-}
-
-var numBeforeSuiteRuns = 0
-var numAfterSuiteRuns = 0
-
-var _ = BeforeSuite(func() {
- numBeforeSuiteRuns++
-})
-
-var _ = AfterSuite(func() {
- numAfterSuiteRuns++
- Ω(numBeforeSuiteRuns).Should(Equal(1))
- Ω(numAfterSuiteRuns).Should(Equal(1))
-})
-
-//Fakes
-type fakeTestingT struct {
- didFail bool
-}
-
-func (fakeT *fakeTestingT) Fail() {
- fakeT.didFail = true
-}
diff --git a/vendor/github.com/onsi/ginkgo/internal/suite/suite_test.go b/vendor/github.com/onsi/ginkgo/internal/suite/suite_test.go
deleted file mode 100644
index fd2d11dc3..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/suite/suite_test.go
+++ /dev/null
@@ -1,385 +0,0 @@
-package suite_test
-
-import (
- "bytes"
-
- . "github.com/onsi/ginkgo"
- . "github.com/onsi/ginkgo/internal/suite"
- . "github.com/onsi/gomega"
-
- "math/rand"
- "time"
-
- "github.com/onsi/ginkgo/config"
- "github.com/onsi/ginkgo/internal/codelocation"
- Failer "github.com/onsi/ginkgo/internal/failer"
- Writer "github.com/onsi/ginkgo/internal/writer"
- "github.com/onsi/ginkgo/reporters"
- "github.com/onsi/ginkgo/types"
-)
-
-var _ = Describe("Suite", func() {
- var (
- specSuite *Suite
- fakeT *fakeTestingT
- fakeR *reporters.FakeReporter
- writer *Writer.FakeGinkgoWriter
- failer *Failer.Failer
- )
-
- BeforeEach(func() {
- writer = Writer.NewFake()
- fakeT = &fakeTestingT{}
- fakeR = reporters.NewFakeReporter()
- failer = Failer.New()
- specSuite = New(failer)
- })
-
- Describe("running a suite", func() {
- var (
- runOrder []string
- randomizeAllSpecs bool
- randomSeed int64
- focusString string
- parallelNode int
- parallelTotal int
- runResult bool
- hasProgrammaticFocus bool
- )
-
- var f = func(runText string) func() {
- return func() {
- runOrder = append(runOrder, runText)
- }
- }
-
- BeforeEach(func() {
- randomizeAllSpecs = false
- randomSeed = 11
- parallelNode = 1
- parallelTotal = 1
- focusString = ""
-
- runOrder = make([]string, 0)
- specSuite.SetBeforeSuiteNode(f("BeforeSuite"), codelocation.New(0), 0)
- specSuite.PushBeforeEachNode(f("top BE"), codelocation.New(0), 0)
- specSuite.PushJustBeforeEachNode(f("top JBE"), codelocation.New(0), 0)
- specSuite.PushAfterEachNode(f("top AE"), codelocation.New(0), 0)
-
- specSuite.PushContainerNode("container", func() {
- specSuite.PushBeforeEachNode(f("BE"), codelocation.New(0), 0)
- specSuite.PushJustBeforeEachNode(f("JBE"), codelocation.New(0), 0)
- specSuite.PushAfterEachNode(f("AE"), codelocation.New(0), 0)
- specSuite.PushItNode("it", f("IT"), types.FlagTypeNone, codelocation.New(0), 0)
-
- specSuite.PushContainerNode("inner container", func() {
- specSuite.PushItNode("inner it", f("inner IT"), types.FlagTypeNone, codelocation.New(0), 0)
- }, types.FlagTypeNone, codelocation.New(0))
- }, types.FlagTypeNone, codelocation.New(0))
-
- specSuite.PushContainerNode("container 2", func() {
- specSuite.PushBeforeEachNode(f("BE 2"), codelocation.New(0), 0)
- specSuite.PushItNode("it 2", f("IT 2"), types.FlagTypeNone, codelocation.New(0), 0)
- }, types.FlagTypeNone, codelocation.New(0))
-
- specSuite.PushItNode("top level it", f("top IT"), types.FlagTypeNone, codelocation.New(0), 0)
-
- specSuite.SetAfterSuiteNode(f("AfterSuite"), codelocation.New(0), 0)
- })
-
- JustBeforeEach(func() {
- runResult, hasProgrammaticFocus = specSuite.Run(fakeT, "suite description", []reporters.Reporter{fakeR}, writer, config.GinkgoConfigType{
- RandomSeed: randomSeed,
- RandomizeAllSpecs: randomizeAllSpecs,
- FocusString: focusString,
- ParallelNode: parallelNode,
- ParallelTotal: parallelTotal,
- })
- })
-
- It("provides the config and suite description to the reporter", func() {
- Ω(fakeR.Config.RandomSeed).Should(Equal(int64(randomSeed)))
- Ω(fakeR.Config.RandomizeAllSpecs).Should(Equal(randomizeAllSpecs))
- Ω(fakeR.BeginSummary.SuiteDescription).Should(Equal("suite description"))
- })
-
- It("reports that the BeforeSuite node ran", func() {
- Ω(fakeR.BeforeSuiteSummary).ShouldNot(BeNil())
- })
-
- It("reports that the AfterSuite node ran", func() {
- Ω(fakeR.AfterSuiteSummary).ShouldNot(BeNil())
- })
-
- It("provides information about the current test", func() {
- description := CurrentGinkgoTestDescription()
- Ω(description.ComponentTexts).Should(Equal([]string{"Suite", "running a suite", "provides information about the current test"}))
- Ω(description.FullTestText).Should(Equal("Suite running a suite provides information about the current test"))
- Ω(description.TestText).Should(Equal("provides information about the current test"))
- Ω(description.IsMeasurement).Should(BeFalse())
- Ω(description.FileName).Should(ContainSubstring("suite_test.go"))
- Ω(description.LineNumber).Should(BeNumerically(">", 50))
- Ω(description.LineNumber).Should(BeNumerically("<", 150))
- Ω(description.Failed).Should(BeFalse())
- Ω(description.Duration).Should(BeNumerically(">", 0))
- })
-
- Measure("should run measurements", func(b Benchmarker) {
- r := rand.New(rand.NewSource(time.Now().UnixNano()))
-
- runtime := b.Time("sleeping", func() {
- sleepTime := time.Duration(r.Float64() * 0.01 * float64(time.Second))
- time.Sleep(sleepTime)
- })
- Ω(runtime.Seconds()).Should(BeNumerically("<=", 1))
- Ω(runtime.Seconds()).Should(BeNumerically(">=", 0))
-
- randomValue := r.Float64() * 10.0
- b.RecordValue("random value", randomValue)
- Ω(randomValue).Should(BeNumerically("<=", 10.0))
- Ω(randomValue).Should(BeNumerically(">=", 0.0))
-
- b.RecordValueWithPrecision("specific value", 123.4567, "ms", 2)
- b.RecordValueWithPrecision("specific value", 234.5678, "ms", 2)
- }, 10)
-
- It("creates a node hierarchy, converts it to a spec collection, and runs it", func() {
- Ω(runOrder).Should(Equal([]string{
- "BeforeSuite",
- "top BE", "BE", "top JBE", "JBE", "IT", "AE", "top AE",
- "top BE", "BE", "top JBE", "JBE", "inner IT", "AE", "top AE",
- "top BE", "BE 2", "top JBE", "IT 2", "top AE",
- "top BE", "top JBE", "top IT", "top AE",
- "AfterSuite",
- }))
- })
- Context("when in an AfterEach block", func() {
- AfterEach(func() {
- description := CurrentGinkgoTestDescription()
- Ω(description.IsMeasurement).Should(BeFalse())
- Ω(description.FileName).Should(ContainSubstring("suite_test.go"))
- Ω(description.Failed).Should(BeFalse())
- Ω(description.Duration).Should(BeNumerically(">", 0))
- })
-
- It("still provides information about the current test", func() {
- Ω(true).To(BeTrue())
- })
- })
-
- Context("when told to randomize all specs", func() {
- BeforeEach(func() {
- randomizeAllSpecs = true
- })
-
- It("does", func() {
- Ω(runOrder).Should(Equal([]string{
- "BeforeSuite",
- "top BE", "top JBE", "top IT", "top AE",
- "top BE", "BE", "top JBE", "JBE", "inner IT", "AE", "top AE",
- "top BE", "BE", "top JBE", "JBE", "IT", "AE", "top AE",
- "top BE", "BE 2", "top JBE", "IT 2", "top AE",
- "AfterSuite",
- }))
- })
- })
-
- Context("when provided with a filter", func() {
- BeforeEach(func() {
- focusString = `inner|\d`
- })
-
- It("converts the filter to a regular expression and uses it to filter the running specs", func() {
- Ω(runOrder).Should(Equal([]string{
- "BeforeSuite",
- "top BE", "BE", "top JBE", "JBE", "inner IT", "AE", "top AE",
- "top BE", "BE 2", "top JBE", "IT 2", "top AE",
- "AfterSuite",
- }))
- })
-
- It("should not report a programmatic focus", func() {
- Ω(hasProgrammaticFocus).Should(BeFalse())
- })
- })
-
- Context("with a programatically focused spec", func() {
- BeforeEach(func() {
- specSuite.PushItNode("focused it", f("focused it"), types.FlagTypeFocused, codelocation.New(0), 0)
-
- specSuite.PushContainerNode("focused container", func() {
- specSuite.PushItNode("inner focused it", f("inner focused it"), types.FlagTypeFocused, codelocation.New(0), 0)
- specSuite.PushItNode("inner unfocused it", f("inner unfocused it"), types.FlagTypeNone, codelocation.New(0), 0)
- }, types.FlagTypeFocused, codelocation.New(0))
-
- })
-
- It("should only run the focused test, applying backpropagation to favor most deeply focused leaf nodes", func() {
- Ω(runOrder).Should(Equal([]string{
- "BeforeSuite",
- "top BE", "top JBE", "focused it", "top AE",
- "top BE", "top JBE", "inner focused it", "top AE",
- "AfterSuite",
- }))
- })
-
- It("should report a programmatic focus", func() {
- Ω(hasProgrammaticFocus).Should(BeTrue())
- })
- })
-
- Context("when the specs pass", func() {
- It("doesn't report a failure", func() {
- Ω(fakeT.didFail).Should(BeFalse())
- })
-
- It("should return true", func() {
- Ω(runResult).Should(BeTrue())
- })
- })
-
- Context("when a spec fails", func() {
- var location types.CodeLocation
- BeforeEach(func() {
- specSuite.PushItNode("top level it", func() {
- location = codelocation.New(0)
- failer.Fail("oops!", location)
- }, types.FlagTypeNone, codelocation.New(0), 0)
- })
-
- It("should return false", func() {
- Ω(runResult).Should(BeFalse())
- })
-
- It("reports a failure", func() {
- Ω(fakeT.didFail).Should(BeTrue())
- })
-
- It("generates the correct failure data", func() {
- Ω(fakeR.SpecSummaries[0].Failure.Message).Should(Equal("oops!"))
- Ω(fakeR.SpecSummaries[0].Failure.Location).Should(Equal(location))
- })
- })
-
- Context("when runnable nodes are nested within other runnable nodes", func() {
- Context("when an It is nested", func() {
- BeforeEach(func() {
- specSuite.PushItNode("top level it", func() {
- specSuite.PushItNode("nested it", f("oops"), types.FlagTypeNone, codelocation.New(0), 0)
- }, types.FlagTypeNone, codelocation.New(0), 0)
- })
-
- It("should fail", func() {
- Ω(fakeT.didFail).Should(BeTrue())
- })
- })
-
- Context("when a Measure is nested", func() {
- BeforeEach(func() {
- specSuite.PushItNode("top level it", func() {
- specSuite.PushMeasureNode("nested measure", func(Benchmarker) {}, types.FlagTypeNone, codelocation.New(0), 10)
- }, types.FlagTypeNone, codelocation.New(0), 0)
- })
-
- It("should fail", func() {
- Ω(fakeT.didFail).Should(BeTrue())
- })
- })
-
- Context("when a BeforeEach is nested", func() {
- BeforeEach(func() {
- specSuite.PushItNode("top level it", func() {
- specSuite.PushBeforeEachNode(f("nested bef"), codelocation.New(0), 0)
- }, types.FlagTypeNone, codelocation.New(0), 0)
- })
-
- It("should fail", func() {
- Ω(fakeT.didFail).Should(BeTrue())
- })
- })
-
- Context("when a JustBeforeEach is nested", func() {
- BeforeEach(func() {
- specSuite.PushItNode("top level it", func() {
- specSuite.PushJustBeforeEachNode(f("nested jbef"), codelocation.New(0), 0)
- }, types.FlagTypeNone, codelocation.New(0), 0)
- })
-
- It("should fail", func() {
- Ω(fakeT.didFail).Should(BeTrue())
- })
- })
-
- Context("when a AfterEach is nested", func() {
- BeforeEach(func() {
- specSuite.PushItNode("top level it", func() {
- specSuite.PushAfterEachNode(f("nested aft"), codelocation.New(0), 0)
- }, types.FlagTypeNone, codelocation.New(0), 0)
- })
-
- It("should fail", func() {
- Ω(fakeT.didFail).Should(BeTrue())
- })
- })
- })
- })
-
- Describe("BeforeSuite", func() {
- Context("when setting BeforeSuite more than once", func() {
- It("should panic", func() {
- specSuite.SetBeforeSuiteNode(func() {}, codelocation.New(0), 0)
-
- Ω(func() {
- specSuite.SetBeforeSuiteNode(func() {}, codelocation.New(0), 0)
- }).Should(Panic())
-
- })
- })
- })
-
- Describe("AfterSuite", func() {
- Context("when setting AfterSuite more than once", func() {
- It("should panic", func() {
- specSuite.SetAfterSuiteNode(func() {}, codelocation.New(0), 0)
-
- Ω(func() {
- specSuite.SetAfterSuiteNode(func() {}, codelocation.New(0), 0)
- }).Should(Panic())
- })
- })
- })
-
- Describe("By", func() {
- It("writes to the GinkgoWriter", func() {
- originalGinkgoWriter := GinkgoWriter
- buffer := &bytes.Buffer{}
-
- GinkgoWriter = buffer
- By("Saying Hello GinkgoWriter")
- GinkgoWriter = originalGinkgoWriter
-
- Ω(buffer.String()).Should(ContainSubstring("STEP"))
- Ω(buffer.String()).Should(ContainSubstring(": Saying Hello GinkgoWriter\n"))
- })
-
- It("calls the passed-in callback if present", func() {
- a := 0
- By("calling the callback", func() {
- a = 1
- })
- Ω(a).Should(Equal(1))
- })
-
- It("panics if there is more than one callback", func() {
- Ω(func() {
- By("registering more than one callback", func() {}, func() {})
- }).Should(Panic())
- })
- })
-
- Describe("GinkgoRandomSeed", func() {
- It("returns the current config's random seed", func() {
- Ω(GinkgoRandomSeed()).Should(Equal(config.GinkgoConfig.RandomSeed))
- })
- })
-})
diff --git a/vendor/github.com/onsi/ginkgo/internal/writer/writer_suite_test.go b/vendor/github.com/onsi/ginkgo/internal/writer/writer_suite_test.go
deleted file mode 100644
index e20657791..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/writer/writer_suite_test.go
+++ /dev/null
@@ -1,13 +0,0 @@
-package writer_test
-
-import (
- . "github.com/onsi/ginkgo"
- . "github.com/onsi/gomega"
-
- "testing"
-)
-
-func TestWriter(t *testing.T) {
- RegisterFailHandler(Fail)
- RunSpecs(t, "Writer Suite")
-}
diff --git a/vendor/github.com/onsi/ginkgo/internal/writer/writer_test.go b/vendor/github.com/onsi/ginkgo/internal/writer/writer_test.go
deleted file mode 100644
index 3e1d17c6d..000000000
--- a/vendor/github.com/onsi/ginkgo/internal/writer/writer_test.go
+++ /dev/null
@@ -1,75 +0,0 @@
-package writer_test
-
-import (
- "github.com/onsi/gomega/gbytes"
-
- . "github.com/onsi/ginkgo"
- . "github.com/onsi/ginkgo/internal/writer"
- . "github.com/onsi/gomega"
-)
-
-var _ = Describe("Writer", func() {
- var writer *Writer
- var out *gbytes.Buffer
-
- BeforeEach(func() {
- out = gbytes.NewBuffer()
- writer = New(out)
- })
-
- It("should stream directly to the outbuffer by default", func() {
- writer.Write([]byte("foo"))
- Ω(out).Should(gbytes.Say("foo"))
- })
-
- It("should not emit the header when asked to DumpOutWitHeader", func() {
- writer.Write([]byte("foo"))
- writer.DumpOutWithHeader("my header")
- Ω(out).ShouldNot(gbytes.Say("my header"))
- Ω(out).Should(gbytes.Say("foo"))
- })
-
- Context("when told not to stream", func() {
- BeforeEach(func() {
- writer.SetStream(false)
- })
-
- It("should only write to the buffer when told to DumpOut", func() {
- writer.Write([]byte("foo"))
- Ω(out).ShouldNot(gbytes.Say("foo"))
- writer.DumpOut()
- Ω(out).Should(gbytes.Say("foo"))
- })
-
- It("should truncate the internal buffer when told to truncate", func() {
- writer.Write([]byte("foo"))
- writer.Truncate()
- writer.DumpOut()
- Ω(out).ShouldNot(gbytes.Say("foo"))
-
- writer.Write([]byte("bar"))
- writer.DumpOut()
- Ω(out).Should(gbytes.Say("bar"))
- })
-
- Describe("emitting a header", func() {
- Context("when the buffer has content", func() {
- It("should emit the header followed by the content", func() {
- writer.Write([]byte("foo"))
- writer.DumpOutWithHeader("my header")
-
- Ω(out).Should(gbytes.Say("my header"))
- Ω(out).Should(gbytes.Say("foo"))
- })
- })
-
- Context("when the buffer has no content", func() {
- It("should not emit the header", func() {
- writer.DumpOutWithHeader("my header")
-
- Ω(out).ShouldNot(gbytes.Say("my header"))
- })
- })
- })
- })
-})