feat(backend): added new consumer groups for new canvas pipeline

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 \

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,
 		},

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,
 		},

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"`
 }
 

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"`