fixed linting

Author: manab-pr

internal/integrations/definitions/authentik/builder.go

@@ -67,10 +67,10 @@ func Builder() registry.Builder {
 					Handle:       HealthCheck{}.Handle(),
 				},
 				{
-					Name:         directorySyncOperation.Name(),
-					Description:  "Collect Authentik directory users, groups, and memberships as directory accounts",
-					Topic:        definitionID.OperationTopic(directorySyncOperation.Name()),
-					ClientRef:    authentikClient.ID(),
+					Name:                directorySyncOperation.Name(),
+					Description:         "Collect Authentik directory users, groups, and memberships as directory accounts",
+					Topic:               definitionID.OperationTopic(directorySyncOperation.Name()),
+					ClientRef:           authentikClient.ID(),
 					ConfigSchema:        directorySyncSchema,
 					Policy:              types.ExecutionPolicy{Reconcile: true},
 					SkipDefaultLookback: true,

internal/integrations/definitions/authentik/client.go

@@ -85,4 +85,4 @@ func extractScheme(baseURL string) (string, error) {
 	}
 
 	return u.Scheme, nil
-}
+}

internal/integrations/definitions/authentik/installation.go

@@ -25,7 +25,11 @@ func resolveInstallationMetadata(ctx context.Context, req types.InstallationRequ
 
 	apiClient := client.(*authentikSDK.APIClient)
 
-	info, _, err := apiClient.AdminApi.AdminSystemRetrieve(ctx).Execute()
+	info, resp, err := apiClient.AdminApi.AdminSystemRetrieve(ctx).Execute()
+	if resp != nil {
+		_ = resp.Body.Close()
+	}
+
 	if err != nil {
 		return InstallationMetadata{}, false, ErrHealthCheckFailed
 	}
@@ -35,4 +39,4 @@ func resolveInstallationMetadata(ctx context.Context, req types.InstallationRequ
 		Host:    info.GetHttpHost(),
 		BaseURL: cred.BaseURL,
 	}, true, nil
-}
+}

internal/integrations/definitions/authentik/mappings.go

@@ -8,7 +8,7 @@ import (
 
 // mapExprDirectoryAccount is the CEL mapping expression for Authentik user payloads mapped to DirectoryAccount
 var mapExprDirectoryAccount = providerkit.CelMapExpr([]providerkit.CelMapEntry{
-    {Key: integrationgenerated.IntegrationMappingDirectoryAccountExternalID, Expr: `'uid' in payload ? payload.uid : ""`},
+	{Key: integrationgenerated.IntegrationMappingDirectoryAccountExternalID, Expr: `'uid' in payload ? payload.uid : ""`},
 	{Key: integrationgenerated.IntegrationMappingDirectoryAccountCanonicalEmail, Expr: `'email' in payload && payload.email != null ? payload.email : ""`},
 	{Key: integrationgenerated.IntegrationMappingDirectoryAccountDisplayName, Expr: `'name' in payload && payload.name != null && payload.name != "" ? payload.name : ('username' in payload ? payload.username : "")`},
 	{Key: integrationgenerated.IntegrationMappingDirectoryAccountStatus, Expr: `dyn('is_active' in payload ? (payload.is_active ? "ACTIVE" : "INACTIVE") : "INACTIVE")`},
@@ -63,4 +63,4 @@ func authentikMappings() []types.MappingRegistration {
 			},
 		},
 	}
-}
+}

internal/integrations/definitions/authentik/operation_directory_sync.go

@@ -127,7 +127,11 @@ func listDirectoryUsers(ctx context.Context, c *authentikSDK.APIClient, lastRunA
 			req = req.LastUpdatedGt(*lastRunAt)
 		}
 
-		result, _, err := req.Execute()
+		result, resp, err := req.Execute()
+		if resp != nil {
+			_ = resp.Body.Close()
+		}
+
 		if err != nil {
 			return nil, ErrDirectoryUsersFetchFailed
 		}
@@ -154,11 +158,15 @@ func listDirectoryGroups(ctx context.Context, c *authentikSDK.APIClient) ([]auth
 			return nil, err
 		}
 
-		result, _, err := c.CoreApi.CoreGroupsList(ctx).
+		result, resp, err := c.CoreApi.CoreGroupsList(ctx).
 			Page(page).
 			PageSize(directoryDefaultPageSize).
 			IncludeUsers(true).
 			Execute()
+		if resp != nil {
+			_ = resp.Body.Close()
+		}
+
 		if err != nil {
 			return nil, ErrDirectoryGroupsFetchFailed
 		}
@@ -173,4 +181,4 @@ func listDirectoryGroups(ctx context.Context, c *authentikSDK.APIClient) ([]auth
 	}
 
 	return groups, nil
-}
+}

internal/integrations/definitions/authentik/operation_health.go

@@ -27,7 +27,11 @@ func (h HealthCheck) Handle() types.OperationHandler {
 
 // Run executes the Authentik health check
 func (HealthCheck) Run(ctx context.Context, c *authentikSDK.APIClient) (json.RawMessage, error) {
-	me, _, err := c.CoreApi.CoreUsersMeRetrieve(ctx).Execute()
+	me, resp, err := c.CoreApi.CoreUsersMeRetrieve(ctx).Execute()
+	if resp != nil {
+		_ = resp.Body.Close()
+	}
+
 	if err != nil {
 		return nil, ErrHealthCheckFailed
 	}