Merge #8

8: Revamp command-handling and models r=Jaskaranbir a=Jaskaranbir



Co-authored-by: Jaskaranbir <jaskaranbir.dhillon@gmail.com>

Author: ninja-bruh

.env

@@ -1,26 +1,27 @@
 SERVICE_NAME=agg-userauth-cmd
-KAFKA_LOG_PRODUCER_TOPIC=log.sink
 
-# ===> Kafka
+# ===> Kafka Config
 KAFKA_BROKERS=kafka:9092
 
-KAFKA_CONSUMER_EVENT_GROUP=agg.userauth.cmd.event.1
-KAFKA_CONSUMER_EVENT_QUERY_GROUP=agg.userauth.cmd.eq.1
+KAFKA_CONSUMER_GROUP_REQUEST=agg.userauth.request.group.1
+KAFKA_CONSUMER_TOPIC_REQUEST=agg.userauth.request
 
-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.userauth.response
+KAFKA_CONSUMER_GROUP_ESRESP=agg.userauth.esresp.1
+KAFKA_CONSUMER_TOPIC_ESRESP=esquery.response
 
-# ===> Mongo
+KAFKA_PRODUCER_TOPIC_ESREQ=esquery.request
+KAFKA_PRODUCER_TOPIC_EVENTS=event.rns_eventstore.events
+
+KAFKA_END_OF_STREAM_TOKEN=__eos__
+AGG_BUILDER_TIMEOUT_SEC=5
+
+# ===> Mongo Config
 MONGO_HOSTS=mongo:27017
 MONGO_USERNAME=root
 MONGO_PASSWORD=root
 
 MONGO_DATABASE=rns_projections
-MONGO_AGG_COLLECTION=agg_userauth
+MONGO_AGG_COLLECTION=agg_userauth_cmd
 MONGO_META_COLLECTION=aggregate_meta
 
-MONGO_CONNECTION_TIMEOUT_MS=3000
-MONGO_RESOURCE_TIMEOUT_MS=5000
+MONGO_CONNECTION_TIMEOUT_MS=5000

.golangci.yml

@@ -12,6 +12,6 @@ linters-settings:
     check-type-assertions: true
     check-blank: true
   lll:
-    line-length: 90
+    line-length: 100
   unparam:
     algo: rta

Gopkg.lock

@@ -33,16 +33,20 @@
   version = "1.19.0"
 
 [[constraint]]
-  name = "github.com/TerrexTech/go-commonutils"
-  version = "3.1.0"
+  name = "github.com/TerrexTech/agg-userauth-model"
+  version = "1.0.0"
+
+[[constraint]]
+  name = "github.com/TerrexTech/go-agg-builder"
+  version = "2.0.0"
 
 [[constraint]]
-  name = "github.com/TerrexTech/go-eventspoll"
-  version = "4.0.0"
+  name = "github.com/TerrexTech/go-common-models"
+  version = "2.0.0"
 
 [[constraint]]
-  name = "github.com/TerrexTech/go-eventstore-models"
-  version = "4.0.0"
+  name = "github.com/TerrexTech/go-commonutils"
+  version = "3.1.0"
 
 [[constraint]]
   name = "github.com/TerrexTech/go-kafkautils"
@@ -60,22 +64,26 @@
   name = "github.com/joho/godotenv"
   version = "1.3.0"
 
-[[constraint]]
-  name = "github.com/mongodb/mongo-go-driver"
-  version = "=0.0.14"
-
 [[constraint]]
   name = "github.com/onsi/ginkgo"
-  version = "1.6.0"
+  version = "1.7.0"
 
 [[constraint]]
   name = "github.com/onsi/gomega"
-  version = "1.4.2"
+  version = "1.4.3"
 
 [[constraint]]
   name = "github.com/pkg/errors"
   version = "0.8.0"
 
+[[constraint]]
+  branch = "master"
+  name = "golang.org/x/crypto"
+
+[[constraint]]
+  branch = "master"
+  name = "golang.org/x/sync"
+
 [prune]
   go-tests = true
   unused-packages = true

Gopkg.toml

@@ -1,7 +1,7 @@
 UserAuth Aggregate - Command
 ---
 
-This service handles `delete`, `insert`, and `update` events for UserAuth Aggregate.
+This service handles `delete`, `insert`, and `update` commands for UserAuth Aggregate.
 
 Check included [docker-compose.yaml][0] and [run_test.sh][1] for sample run-configuration for this service.