Rely on the NATS cluster connection status when reporting the Eventin…

…g CR status

.golangci.yaml

@@ -173,6 +173,8 @@ linters-settings:
         alias: istio$1$2
       - pkg: github.com/nats-io/nats-server/v2/(\w+)$
         alias: natsio$1
+      - pkg: github.com/nats-io/nats.go
+        alias: natsio
       - pkg: github.com/kyma-project/eventing-manager/internal/controller/(\w+)$
         alias: controller$1
       - pkg: github.com/kyma-project/kyma/common/logging/logger
@@ -181,6 +183,12 @@ linters-settings:
         alias: natsv1alpha1
       - pkg: github.com/kyma-project/nats-manager/testutils
         alias: natstestutils
+      - pkg: github.com/kyma-project/eventing-manager/internal/connection/nats
+        alias: natsconnection
+      - pkg: github.com/kyma-project/eventing-manager/internal/connection/nats/errors
+        alias: natsconnectionerrors
+      - pkg: github.com/kyma-project/eventing-manager/internal/connection/nats/mocks
+        alias: natsconnectionmocks
       - pkg: github.com/kyma-project/eventing-manager/internal/controller/eventing/subscription/(\w+)$
         alias: subscriptioncontroller$1
       - pkg: github.com/kyma-project/eventing-manager/internal/controller/operator/eventing

Dockerfile

@@ -14,8 +14,7 @@ RUN go mod download
 # Copy the go source
 COPY cmd/main.go cmd/main.go
 COPY api/ api/
-COPY internal/controller/ internal/controller/
-COPY internal/label/ internal/label/
+COPY internal/ internal/
 COPY pkg/ pkg/
 COPY testing/ testing/
 COPY options/ options/

api/operator/v1alpha1/eventing_types.go

@@ -224,6 +224,10 @@ func (e *Eventing) SyncStatusActiveBackend() {
 	e.Status.ActiveBackend = e.Spec.Backend.Type
 }
 
+func (e *Eventing) IsPreviousBackendEmpty() bool {
+	return e.Status.ActiveBackend == ""
+}
+
 func (e *Eventing) IsSpecBackendTypeChanged() bool {
 	return e.Status.ActiveBackend != e.Spec.Backend.Type
 }

internal/connection/interface.go

@@ -0,0 +1,12 @@
+package connection
+
+type Interface interface {
+	// Connect connects and returns an error if it failed.
+	Connect() error
+
+	// IsConnected returns true if it is connected, otherwise returns false.
+	IsConnected() bool
+
+	// Disconnect disconnects the active connection.
+	Disconnect()
+}

internal/connection/nats/errors/errors.go

@@ -0,0 +1,11 @@
+package errors
+
+import (
+	"errors"
+)
+
+const (
+	errCannotConnect = "cannot connect to NATS"
+)
+
+var ErrCannotConnect = errors.New(errCannotConnect)

internal/connection/nats/interfase.go

@@ -0,0 +1,17 @@
+package nats
+
+import (
+	natsio "github.com/nats-io/nats.go"
+
+	"github.com/kyma-project/eventing-manager/internal/connection"
+)
+
+//go:generate go run github.com/vektra/mockery/v2 --name Interface
+type Interface interface {
+	connection.Interface
+
+	RegisterReconnectHandler(natsio.ConnHandler)
+	IsReconnectHandlerRegistered() bool
+	RegisterDisconnectErrHandler(natsio.ConnErrHandler)
+	IsDisconnectErrHandlerRegistered() bool
+}