Fixed tests

Author: vgarvardt

cmd/goengine/main.go

@@ -2,6 +2,7 @@ package main
 
 import (
 	"context"
+	"errors"
 	"os"
 	"time"
 
@@ -19,6 +20,13 @@ func main() {
 	var streamName goengine.StreamName = "test"
 
 	mongoDSN := os.Getenv("STORAGE_DSN")
+	if len(mongoDSN) == 0 {
+		panic(errors.New("missing STORAGE_DSN environment variable"))
+	}
+	brokerDSN := os.Getenv("BROKER_DSN")
+	if len(mongoDSN) == 0 {
+		panic(errors.New("missing BROKER_DSN environment variable"))
+	}
 
 	goengine.Log("Connecting to the database", map[string]interface{}{"dsn": mongoDSN}, nil)
 	mongoClient, err := mongo.NewClientWithOptions(
@@ -56,8 +64,6 @@ func main() {
 	registry.RegisterType(&RecipeCreated{})
 	registry.RegisterType(&RecipeRated{})
 
-	// bus := inmemory.NewInMemoryEventBus()
-	brokerDSN := os.Getenv("BROKER_DSN")
 	goengine.Log("Setting up the event bus", map[string]interface{}{"dsn": brokerDSN}, nil)
 	bus := rabbit.NewEventBus(brokerDSN, "events", "events")
 

docker-compose.yml

@@ -2,15 +2,12 @@ version: '2'
 services:
 
   rabbitmq:
-    image: rabbitmq:3.6.1-management
+    image: rabbitmq:3-management-alpine
     ports:
       - "15672:15672"
       - "5672:5672"
-      
-  redis:
-    image: redis
 
   mongo:
-      image: mongo
-      ports:
-        - "27017:27017"
+    image: mongo
+    ports:
+      - "27017:27017"

inmemory/eventstore_test.go

@@ -41,7 +41,7 @@ var _ = Describe("In Memory Event Store", func() {
 		})
 
 		It("should count the events that happened", func() {
-			Expect(inMemory.CountEventsFor(streamName, aggregateId)).Should(Equal(4))
+			Expect(inMemory.CountEventsFor(streamName, aggregateId)).Should(Equal(int64(4)))
 		})
 
 		It("should retrieve events for version bigger then 1", func() {