Wait for func cli manager to be ready before starting controllers

Author: creydr

cmd/main.go

@@ -17,6 +17,7 @@ limitations under the License.
 package main
 
 import (
+	"context"
 	"crypto/tls"
 	"flag"
 	"os"
@@ -210,13 +211,22 @@ func main() {
 		os.Exit(1)
 	}
 
-	// Initialize and add func CLI manager
+	// Initialize func CLI manager
 	funcCLIManager, err := funccli.NewManager(ctrl.Log, funcCLIPath, funcCLICheckInterval)
 	if err != nil {
 		setupLog.Error(err, "unable to create func CLI manager")
 		os.Exit(1)
 	}
 
+	// Ensure func CLI is ready before controllers start
+	setupLog.Info("Downloading func CLI before starting controllers")
+	ctx := context.Background()
+	if err := funcCLIManager.EnsureReady(ctx); err != nil {
+		setupLog.Error(err, "failed to ensure func CLI is ready")
+		os.Exit(1)
+	}
+	setupLog.Info("Func CLI is ready")
+
 	if err := (&controller.FunctionReconciler{
 		Client:         mgr.GetClient(),
 		Scheme:         mgr.GetScheme(),

internal/funccli/manager.go

@@ -123,6 +123,13 @@ func (m *Manager) GetCurrentVersion(ctx context.Context) (string, error) {
 	return version, nil
 }
 
+// EnsureReady ensures the func CLI is downloaded and ready to use.
+// This should be called before controllers start processing resources.
+func (m *Manager) EnsureReady(ctx context.Context) error {
+	m.logger.Info("Ensuring func CLI is ready")
+	return m.checkAndUpdate(ctx)
+}
+
 // checkAndUpdate checks for a new version and downloads it if available
 func (m *Manager) checkAndUpdate(ctx context.Context) error {
 	// Lock to ensure only one update happens at a time