Merge #3

3: Fix test env variables r=Jaskaranbir a=Jaskaranbir



Co-authored-by: Jaskaranbir <[email protected]>

Author: ninja-bruh

main/.env

@@ -36,7 +36,7 @@ else
 fi
 
 echo "Waiting additional time for Cassandra to be ready."
-add_wait=20
+add_wait=30
 cur_add_wait=0
 while (( ++cur_add_wait != add_wait ))
 do
@@ -62,4 +62,4 @@ sleep 5
 docker ps -a
 
 docker-compose up --build --force-recreate agg-inventory-query-test
-exit $?
+docker ps -a

run_test.sh

@@ -4,8 +4,8 @@ KAFKA_BROKERS=kafka:9092
 KAFKA_CONSUMER_EVENT_GROUP=agg.inventory.cmd.event.1
 KAFKA_CONSUMER_EVENT_QUERY_GROUP=agg.inventory.cmd.eq.1
 
-KAFKA_CONSUMER_EVENT_TOPIC=event.persistence.response.2
-KAFKA_CONSUMER_EVENT_QUERY_TOPIC=esquery.response.2
+KAFKA_CONSUMER_EVENT_TOPIC=event.persistence.response
+KAFKA_CONSUMER_EVENT_QUERY_TOPIC=esquery.response
 KAFKA_PRODUCER_EVENT_TOPIC=event.rns_eventstore.events
 KAFKA_PRODUCER_EVENT_QUERY_TOPIC=esquery.request
 KAFKA_PRODUCER_RESPONSE_TOPIC=agg.inventory.response

test/.env.agg-inventory-cmd

@@ -178,7 +178,6 @@ var _ = Describe("InventoryAggregate", func() {
 
 					result := []inventory.Inventory{}
 					err = json.Unmarshal(kr.Result, &result)
-					log.Println(err)
 					Expect(err).ToNot(HaveOccurred())
 
 					for _, r := range result {