feat(operator): add brokertopicconsumer for orchestration (#1287)

formancehq · Feb 27, 2024 · a01caa4 · a01caa4
1 parent 506f9a4
commit a01caa4
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 0 deletions.
diff --git a/components/operator/api/formance.com/v1beta1/orchestration_types.go b/components/operator/api/formance.com/v1beta1/orchestration_types.go
@@ -51,6 +51,8 @@ type Orchestration struct {
 	Status OrchestrationStatus `json:"status,omitempty"`
 }
 
+func (in *Orchestration) isEventPublisher() {}
+
 func (in *Orchestration) IsEE() bool {
 	return false
 }
@@ -103,3 +105,5 @@ type OrchestrationList struct {
 func init() {
 	SchemeBuilder.Register(&Orchestration{}, &OrchestrationList{})
 }
+
+var _ EventPublisher = (*Orchestration)(nil)
diff --git a/components/operator/internal/resources/brokertopicconsumers/create.go b/components/operator/internal/resources/brokertopicconsumers/create.go
@@ -82,6 +82,9 @@ func CreateOrUpdateOnAllServices(ctx core.Context, consumer interface {
 
 	ret := make([]*v1beta1.BrokerTopicConsumer, 0)
 	for _, service := range services {
+		if service.GetKind() == consumer.GetObjectKind().GroupVersionKind().Kind {
+			continue
+		}
 		brokerTopicConsumer, err := Create(ctx, strings.ToLower(service.GetKind()), consumer)
 		if err != nil {
 			return nil, err

diff --git a/components/operator/internal/resources/orchestrations/controller.go b/components/operator/internal/resources/orchestrations/controller.go
@@ -20,6 +20,7 @@ import (
 	"github.com/formancehq/operator/api/formance.com/v1beta1"
 	. "github.com/formancehq/operator/internal/core"
 	"github.com/formancehq/operator/internal/resources/brokertopicconsumers"
+	"github.com/formancehq/operator/internal/resources/brokertopics"
 	"github.com/formancehq/operator/internal/resources/databases"
 	"github.com/formancehq/operator/internal/resources/gatewayhttpapis"
 	"github.com/formancehq/operator/internal/resources/jobs"
@@ -97,6 +98,7 @@ func init() {
 			WithWatchDependency[*v1beta1.Orchestration](&v1beta1.Auth{}),
 			WithWatchDependency[*v1beta1.Orchestration](&v1beta1.Payments{}),
 			WithWatchDependency[*v1beta1.Orchestration](&v1beta1.Wallets{}),
+			brokertopics.Watch[*v1beta1.Orchestration]("orchestration"),
 			databases.Watch[*v1beta1.Orchestration](),
 		),
 	)