Add e2e tests for gdrive

internal/controller/controllerconfig_controller.go

@@ -139,7 +139,23 @@ func (r *ControllerConfigReconciler) Reconcile(ctx context.Context, req ctrl.Req
 		}
 	}
 
-	// initialize LDAP client and cache if configured
+	// initialize cache client (used for LDAP and group membership caching)
+	if CacheClient == nil {
+		cc, err := pkgcache.New(&pkgcache.Config{
+			Driver: pkgcache.DriverMemory,
+			InMemory: &inmemory.Config{
+				DefaultExpiration: -1,
+				CleanupInterval:   -1,
+			},
+		})
+		if err != nil {
+			return ctrl.Result{}, fmt.Errorf("failed to create cache client: %w", err)
+		}
+		CacheClient = cc
+		logger.Info("Cache client initialized")
+	}
+
+	// initialize LDAP client if configured
 	if config.Spec.LDAPConfig != nil && config.Spec.LDAPConfig.Server != "" {
 		ldapCfg := *config.Spec.LDAPConfig
 		lc, err := ldap.InitLDAP(ldap.Config{
@@ -156,19 +172,7 @@ func (r *ControllerConfigReconciler) Reconcile(ctx context.Context, req ctrl.Req
 			return ctrl.Result{RequeueAfter: 10 * time.Second}, nil
 		}
 		LDAPClient = lc
-
-		cc, err := pkgcache.New(&pkgcache.Config{
-			Driver: pkgcache.DriverMemory,
-			InMemory: &inmemory.Config{
-				DefaultExpiration: -1,
-				CleanupInterval:   -1,
-			},
-		})
-		if err != nil {
-			return ctrl.Result{}, fmt.Errorf("failed to create cache client: %w", err)
-		}
-		CacheClient = cc
-		logger.Info("LDAP client and cache initialized")
+		logger.Info("LDAP client initialized")
 	}
 
 	GoogleDriveControllerCfg = config.Spec.GoogleDriveConfig

internal/controller/sourcecrawler_controller.go

@@ -21,6 +21,7 @@ import (
 	"errors"
 	"fmt"
 	"net/url"
+	"os"
 	"strings"
 	"time"
 
@@ -221,7 +222,7 @@ func (r *SourceCrawlerReconciler) buildGDriveSource(
 		return nil, fmt.Errorf("failed to create google client: %w", err)
 	}
 
-	if LDAPClient == nil {
+	if LDAPClient == nil && os.Getenv("CURRENT_ENV") != "e2e-test" {
 		return nil, errors.New("LDAP client not initialized in ControllerConfig")
 	}
 	if CacheClient == nil {

pkg/gdrive/permissions.go

@@ -74,7 +74,7 @@ func (c *Client) GetFilePermissions(
 				logger.V(1).Info("user LDAP data found in cache",
 					"email", p.EmailAddress,
 				)
-			} else {
+			} else if c.ldapClient != nil {
 				// Cache miss - query LDAP
 				userData, err := c.ldapClient.GetUserByEmail(
 					ctx, p.EmailAddress)