Unit tests are finally working

Author: vgarvardt

aggregate_root_test.go

@@ -1,4 +1,4 @@
-package goengine_test
+package goengine
 
 import (
 	. "github.com/onsi/ginkgo"

event_store_test.go

@@ -1,10 +1,10 @@
-package goengine_test
+package goengine
 
 import (
+	"testing"
+
 	. "github.com/onsi/ginkgo"
 	. "github.com/onsi/gomega"
-
-	"testing"
 )
 
 func TestGoengine(t *testing.T) {

goengine_suite_test.go

@@ -38,7 +38,10 @@ func (bus *EventBus) ReceiveEvents(options goengine.VersionedEventReceiverOption
 				ch <- nil
 			case versionedEvent := <-bus.publishedEventsChannel:
 				ackCh := make(chan bool)
-				options.ReceiveEvent <- goengine.VersionedEventTransactedAccept{versionedEvent, ackCh}
+				options.ReceiveEvent <- goengine.VersionedEventTransactedAccept{
+					Event:                 versionedEvent,
+					ProcessedSuccessfully: ackCh,
+				}
 				<-ackCh
 			}
 		}

inmemory/eventbus.go

@@ -1,51 +1,50 @@
-package inmemory_test
+package inmemory
 
 import (
-	. "github.com/hellofresh/goengine"
-	. "github.com/hellofresh/goengine/inmemory"
+	"github.com/hellofresh/goengine"
 
 	. "github.com/onsi/ginkgo"
 	. "github.com/onsi/gomega"
 )
 
 var _ = Describe("In Memory Event Store", func() {
-	var events []*DomainMessage
-	var inMemory *EventStore = NewEventStore()
-	var aggregateId string
-	var streamName StreamName
+	var events []*goengine.DomainMessage
+	var inMemory goengine.EventStore = NewEventStore()
+	var aggregateID string
+	var streamName goengine.StreamName
 
 	BeforeEach(func() {
 		events = nil                                         // clear the slice before each execution
-		aggregateId = "eca7741f-b4c2-4fec-bfc7-be438a794be9" //uuid.New()
+		aggregateID = "eca7741f-b4c2-4fec-bfc7-be438a794be9" //uuid.New()
 		streamName = "test"
 	})
 
 	JustBeforeEach(func() {
-		events = append(events, RecordNow(aggregateId, 0, NewSomethingHappened()))
-		events = append(events, RecordNow(aggregateId, 1, NewSomethingHappened()))
-		events = append(events, RecordNow(aggregateId, 2, NewSomethingHappened()))
-		events = append(events, RecordNow(aggregateId, 3, NewSomethingHappened()))
+		events = append(events, goengine.RecordNow(aggregateID, 0, NewSomethingHappened()))
+		events = append(events, goengine.RecordNow(aggregateID, 1, NewSomethingHappened()))
+		events = append(events, goengine.RecordNow(aggregateID, 2, NewSomethingHappened()))
+		events = append(events, goengine.RecordNow(aggregateID, 3, NewSomethingHappened()))
 	})
 
 	Describe("when something happens", func() {
 		It("should save an event", func() {
-			err := inMemory.Append(NewEventStream(streamName, events))
+			err := inMemory.Append(goengine.NewEventStream(streamName, events))
 			Expect(err).To(BeNil())
 		})
 
-		It("should retrive the things that happened", func() {
-			stream, err := inMemory.GetEventsFor(streamName, aggregateId)
+		It("should retrieve the things that happened", func() {
+			stream, err := inMemory.GetEventsFor(streamName, aggregateID)
 
 			Expect(err).To(BeNil())
 			Expect(stream.Events).To(HaveLen(4))
 		})
 
 		It("should count the events that happened", func() {
-			Expect(inMemory.CountEventsFor(streamName, aggregateId)).Should(Equal(int64(4)))
+			Expect(inMemory.CountEventsFor(streamName, aggregateID)).Should(Equal(int64(4)))
 		})
 
 		It("should retrieve events for version bigger then 1", func() {
-			stream, err := inMemory.FromVersion(streamName, aggregateId, 1)
+			stream, err := inMemory.FromVersion(streamName, aggregateID, 1)
 
 			Expect(err).To(BeNil())
 			Expect(stream.Events).To(HaveLen(3))

inmemory/eventstore_test.go

@@ -1,10 +1,10 @@
-package inmemory_test
+package inmemory
 
 import (
+	"testing"
+
 	. "github.com/onsi/ginkgo"
 	. "github.com/onsi/gomega"
-
-	"testing"
 )
 
 func TestGoengine(t *testing.T) {

inmemory/inmemory_suite_test.go

@@ -1,8 +1,6 @@
-package inmemory_test
+package inmemory
 
-import (
-	"time"
-)
+import "time"
 
 type SomethingHappened struct {
 	occurredOn time.Time

inmemory/mock_test.go

@@ -1,22 +1,6 @@
-package goengine_test
+package goengine
 
-import (
-	"time"
-
-	. "github.com/hellofresh/goengine"
-)
-
-type SomethingHappened struct {
-	occurredOn time.Time
-}
-
-func NewSomethingHappened() SomethingHappened {
-	return SomethingHappened{time.Now()}
-}
-
-func (e SomethingHappened) OccurredOn() time.Time {
-	return e.occurredOn
-}
+import "time"
 
 type RecipeCreated struct {
 	occurredOn time.Time

mock_test.go

@@ -163,7 +163,10 @@ func (s *EventStore) createIndexes(c *mongo.Collection) error {
 	_, err := c.Indexes().CreateOne(
 		ctx,
 		mongo.IndexModel{
-			Keys:    bsonx.Doc{{"aggregate_id", bsonx.Int32(1)}, {"version", bsonx.Int32(-1)}},
+			Keys: bsonx.Doc{
+				{Key: "aggregate_id", Value: bsonx.Int32(1)},
+				{Key: "version", Value: bsonx.Int32(-1)},
+			},
 			Options: options.Index().SetUnique(true).SetBackground(true),
 		},
 	)