From 78a91461448bd41aec39e2c8252e89067c94c9b6 Mon Sep 17 00:00:00 2001
From: Alexander <zavorotynskiy@pm.me>
Date: Mon, 22 Jan 2024 17:03:15 +0100
Subject: [PATCH] feat(backend): added new consumer groups for new canvas
 pipeline

---
 backend/Dockerfile                             | 2 ++
 backend/cmd/canvas-handler/main.go             | 2 +-
 backend/cmd/canvas-maker/main.go               | 2 +-
 backend/internal/config/imagestorage/config.go | 1 +
 backend/internal/config/videostorage/config.go | 1 +
 5 files changed, 6 insertions(+), 2 deletions(-)

diff --git a/backend/Dockerfile b/backend/Dockerfile
index 8421e4b80..9826b55ba 100644
--- a/backend/Dockerfile
+++ b/backend/Dockerfile
@@ -81,6 +81,8 @@ ENV TZ=UTC \
     GROUP_HEURISTICS=heuristics \
     GROUP_IMAGE_STORAGE=image-storage \
     GROUP_VIDEO_STORAGE=video-storage \
+    GROUP_CANVAS_IMAGES=canvas-images \
+    GROUP_CANVAS_VIDEO=canvas-video \
     AWS_REGION_WEB=eu-central-1 \
     AWS_REGION_IOS=eu-west-1 \
     AWS_REGION_ASSETS=eu-central-1 \
diff --git a/backend/cmd/canvas-handler/main.go b/backend/cmd/canvas-handler/main.go
index 6db3d8d03..b25aab437 100644
--- a/backend/cmd/canvas-handler/main.go
+++ b/backend/cmd/canvas-handler/main.go
@@ -33,7 +33,7 @@ func main() {
 	producer := queue.NewProducer(cfg.MessageSizeLimit, true)
 
 	canvasConsumer := queue.NewConsumer(
-		cfg.GroupImageStorage,
+		cfg.GroupCanvasImages,
 		[]string{
 			cfg.TopicCanvasImages,
 		},
diff --git a/backend/cmd/canvas-maker/main.go b/backend/cmd/canvas-maker/main.go
index c1b442cb6..3ef98f7a0 100644
--- a/backend/cmd/canvas-maker/main.go
+++ b/backend/cmd/canvas-maker/main.go
@@ -39,7 +39,7 @@ func main() {
 	workDir := cfg.FSDir
 
 	canvasConsumer := queue.NewConsumer(
-		cfg.GroupVideoStorage,
+		cfg.GroupCanvasVideo,
 		[]string{
 			cfg.TopicCanvasTrigger,
 		},
diff --git a/backend/internal/config/imagestorage/config.go b/backend/internal/config/imagestorage/config.go
index 3dabfa06b..8f8f3d6b2 100644
--- a/backend/internal/config/imagestorage/config.go
+++ b/backend/internal/config/imagestorage/config.go
@@ -14,6 +14,7 @@ type Config struct {
 	TopicCanvasImages  string `env:"TOPIC_CANVAS_IMAGES,required"`
 	TopicCanvasTrigger string `env:"TOPIC_CANVAS_TRIGGER,required"`
 	GroupImageStorage  string `env:"GROUP_IMAGE_STORAGE,required"`
+	GroupCanvasImages  string `env:"GROUP_CANVAS_IMAGE,required"`
 	UseProfiler        bool   `env:"PROFILER_ENABLED,default=false"`
 }
 
diff --git a/backend/internal/config/videostorage/config.go b/backend/internal/config/videostorage/config.go
index 41fbed038..8b1d8924c 100644
--- a/backend/internal/config/videostorage/config.go
+++ b/backend/internal/config/videostorage/config.go
@@ -11,6 +11,7 @@ type Config struct {
 	objectstorage.ObjectsConfig
 	FSDir              string `env:"FS_DIR,required"`
 	GroupVideoStorage  string `env:"GROUP_VIDEO_STORAGE,required"`
+	GroupCanvasVideo   string `env:"GROUP_CANVAS_VIDEO,required"`
 	TopicMobileTrigger string `env:"TOPIC_MOBILE_TRIGGER,required"`
 	TopicTrigger       string `env:"TOPIC_TRIGGER,required"`
 	TopicCanvasTrigger string `env:"TOPIC_CANVAS_TRIGGER,required"`