update golagci-lint

Signed-off-by: Per Goncalves da Silva <[email protected]>

Author: Per Goncalves da Silva

.github/workflows/sanity.yaml

@@ -24,8 +24,7 @@ jobs:
       with:
         go-version-file: "go.mod"
     - name: Run linting checks
-      uses: "golangci/golangci-lint-action@v6"
+      uses: golangci/golangci-lint-action@v6
       with:
-        version: "v1.55.2"
-        skip-pkg-cache: true
+        version: v1.57.2
 

.golangci.yaml

@@ -1,11 +1,5 @@
 run:
   timeout: 8m
-  skip-dirs:
-  - pkg/lib
-  - pkg/api
-  - pkg/fakes
-  - pkg/package-server/apis
-  - test/e2e
 
 linters:
   enable:
@@ -41,7 +35,13 @@ linters-settings:
 issues:
   max-issues-per-linter: 0
   max-same-issues: 0
+  exclude-dirs:
+    - pkg/lib
+    - pkg/api
+    - pkg/fakes
+    - pkg/package-server/apis
+    - test/e2e
 
 output:
-  format: tab
+  formats: tab
   sort-results: true

go.mod

@@ -2,7 +2,7 @@ module github.com/operator-framework/operator-lifecycle-manager
 
 go 1.22.0
 
-toolchain go1.22.2
+toolchain go1.22.3
 
 require (
 	github.com/blang/semver/v4 v4.0.0
@@ -31,7 +31,7 @@ require (
 	github.com/otiai10/copy v1.14.0
 	github.com/pkg/errors v0.9.1
 	github.com/prometheus/client_golang v1.19.0
-	github.com/prometheus/client_model v0.6.0
+	github.com/prometheus/client_model v0.6.1
 	github.com/prometheus/common v0.51.1
 	github.com/sirupsen/logrus v1.9.3
 	github.com/spf13/cobra v1.8.0
@@ -62,10 +62,8 @@ require (
 
 // todo: remove this once k8s.io/component-base is updated to use the new prometheus/client_model
 replace (
-	github.com/prometheus/client_golang => github.com/prometheus/client_golang v1.16.0
-	github.com/prometheus/client_model => github.com/prometheus/client_model v0.4.0
-	github.com/prometheus/common => github.com/prometheus/common v0.44.0
-	github.com/prometheus/procfs => github.com/prometheus/procfs v0.10.1
+	github.com/prometheus/client_golang => github.com/prometheus/client_golang v1.18.0
+	github.com/prometheus/common => github.com/prometheus/common v0.47.0
 )
 
 require (
@@ -170,7 +168,6 @@ require (
 	github.com/mattn/go-isatty v0.0.20 // indirect
 	github.com/mattn/go-runewidth v0.0.15 // indirect
 	github.com/mattn/go-sqlite3 v1.14.22 // indirect
-	github.com/matttproud/golang_protobuf_extensions v1.0.4 // indirect
 	github.com/mitchellh/copystructure v1.2.0 // indirect
 	github.com/mitchellh/go-wordwrap v1.0.1 // indirect
 	github.com/mitchellh/reflectwalk v1.0.2 // indirect

go.sum

@@ -174,6 +174,9 @@ func (s *SourceStore) Add(key registry.CatalogKey, address string) (*SourceConn,
 		return nil, err
 	}
 
+	// non-blocking call to start exercising the connection
+	conn.Connect()
+
 	ctx, cancel := context.WithCancel(context.Background())
 	source := SourceConn{
 		SourceMeta: SourceMeta{
@@ -233,6 +236,11 @@ func (s *SourceStore) watch(ctx context.Context, key registry.CatalogKey, source
 					// This function is non-blocking. Therefore, when it returns we'll still return IDLE
 					// as the state (we'll see further state changes in subsequent iterations of the loop).
 					source.Conn.Connect()
+					regitryClient := registry.NewClientFromConn(source.Conn)
+
+					// Let's force a health check to make sure the connection is healthy
+					c, err := regitryClient.HealthCheck(ctx, 10*time.Second)
+					s.logger.WithError(err).WithField("address", source.Address).Debugf("gRPC health check: %v", c)
 
 					// notify subscriber
 					s.notify <- SourceState{Key: key, State: newState}

pkg/controller/registry/grpc/source.go

@@ -21,6 +21,7 @@ const (
 	catalogMountPath   string = "/opt/olm"
 	catalogServicePort int32  = 50051
 	catalogReadyState  string = "READY"
+	catalogIdleState   string = "IDLE"
 )
 
 type MagicCatalog struct {
@@ -147,7 +148,7 @@ func (c *MagicCatalog) catalogSourceIsReady(ctx context.Context) error {
 			return false, err
 		}
 		state := catalogSource.Status.GRPCConnectionState.LastObservedState
-		if state != catalogReadyState {
+		if state != catalogReadyState && state != catalogIdleState {
 			return false, nil
 		}
 		return true, nil

test/e2e/magic_catalog.go

@@ -3607,7 +3607,7 @@ func updateInternalCatalog(t GinkgoTInterface, c operatorclient.ClientInterface,
 		before := fetchedInitialCatalog.Status.ConfigMapResource
 		after := catalog.Status.ConfigMapResource
 		if after != nil && after.LastUpdateTime.After(before.LastUpdateTime.Time) && after.ResourceVersion != before.ResourceVersion &&
-			catalog.Status.GRPCConnectionState.LastConnectTime.After(after.LastUpdateTime.Time) && catalog.Status.GRPCConnectionState.LastObservedState == "READY" {
+			catalog.Status.GRPCConnectionState.LastConnectTime.After(after.LastUpdateTime.Time) && (catalog.Status.GRPCConnectionState.LastObservedState == "READY" || catalog.Status.GRPCConnectionState.LastObservedState == "IDLE") {
 			fmt.Println("catalog updated")
 			return true
 		}

test/e2e/subscription_e2e_test.go

@@ -364,7 +364,7 @@ func catalogSourceRegistryPodSynced() func(catalog *operatorsv1alpha1.CatalogSou
 			lastState = state
 			lastTime = time.Now()
 		}
-		if registry != nil && connState != nil && !connState.LastConnectTime.IsZero() && connState.LastObservedState == "READY" {
+		if registry != nil && connState != nil && !connState.LastConnectTime.IsZero() && (connState.LastObservedState == "READY" || connState.LastObservedState == "IDLE") {
 			fmt.Printf("probing catalog %s pod with address %s\n", catalog.GetName(), registry.Address())
 			return registryPodHealthy(registry.Address())
 		}