From 169f4d4ebb1d82c14465a2bc808c48297f1a45e3 Mon Sep 17 00:00:00 2001
From: Geoffrey Ragot <geoffrey.ragot@gmail.com>
Date: Mon, 26 Feb 2024 17:30:15 +0100
Subject: [PATCH] feat(orchestration): add publishing module

---
 ee/orchestration/cmd/root.go   | 1 +
 ee/orchestration/cmd/worker.go | 2 ++
 2 files changed, 3 insertions(+)

diff --git a/ee/orchestration/cmd/root.go b/ee/orchestration/cmd/root.go
index 065474c4b1..09161d71d4 100644
--- a/ee/orchestration/cmd/root.go
+++ b/ee/orchestration/cmd/root.go
@@ -85,6 +85,7 @@ func NewRootCommand() *cobra.Command {
 	auth.InitAuthFlags(cmd.PersistentFlags())
 	bunconnect.InitFlags(cmd.PersistentFlags())
 	iam.InitFlags(cmd.PersistentFlags())
+	publish.InitCLIFlags(cmd)
 
 	return cmd
 }
diff --git a/ee/orchestration/cmd/worker.go b/ee/orchestration/cmd/worker.go
index c3361af746..8f79b8d9cc 100644
--- a/ee/orchestration/cmd/worker.go
+++ b/ee/orchestration/cmd/worker.go
@@ -1,6 +1,7 @@
 package cmd
 
 import (
+	"github.com/formancehq/stack/libs/go-libs/publish"
 	"net/http"
 
 	"github.com/formancehq/orchestration/internal/triggers"
@@ -33,6 +34,7 @@ func workerOptions() fx.Option {
 			viper.GetString(temporalTaskQueueFlag),
 			viper.GetStringSlice(topicsFlag),
 		),
+		publish.CLIPublisherModule("orchestration"),
 	)
 }