Skip to content

Commit 689fe12

Browse files
committed
removed unused var and methods
Signed-off-by: Alka Kumari <alkumari@redhat.com>
1 parent 1ec1e76 commit 689fe12

File tree

2 files changed

+15
-42
lines changed

2 files changed

+15
-42
lines changed

controllers/argocd/argocd_controller.go

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -326,10 +326,7 @@ func (r *ReconcileArgoCD) internalReconcile(ctx context.Context, request ctrl.Re
326326
}
327327

328328
// Process DropMetadata for namespace-based label cleanup
329-
if err := r.processDropMetadataForCleanup(argocd); err != nil {
330-
reqLogger.Error(err, "failed to process DropMetadata cleanup")
331-
// Don't fail the reconciliation, just log the error and continue
332-
}
329+
r.processDropMetadataForCleanup(argocd)
333330

334331
if err := r.reconcileResources(argocd); err != nil {
335332
// Error reconciling ArgoCD sub-resources - requeue the request.

controllers/argocd/util.go

Lines changed: 14 additions & 38 deletions
Original file line numberDiff line numberDiff line change
@@ -1315,27 +1315,11 @@ func removeDropMetadataForNamespace(namespace string) {
13151315
delete(DropMetadataStore, namespace)
13161316
}
13171317

1318-
// getDropMetadataForResource retrieves DropMetadata for a specific resource in a namespace
1319-
func getDropMetadataForResource(namespace, resource string) *DropMetadata {
1320-
if metadataList, exists := DropMetadataStore[namespace]; exists {
1321-
for _, metadata := range metadataList {
1322-
if metadata.Resource == resource {
1323-
return &metadata
1324-
}
1325-
}
1326-
}
1327-
return nil
1328-
}
1329-
13301318
// processDropMetadataForCleanup processes the DropMetadata store and cleans up removed labels from resources
1331-
func (r *ReconcileArgoCD) processDropMetadataForCleanup(argocd *argoproj.ArgoCD) error {
1319+
func (r *ReconcileArgoCD) processDropMetadataForCleanup(argocd *argoproj.ArgoCD) {
13321320
namespace := argocd.GetNamespace()
13331321
dropMetadataList := getDropMetadataForNamespace(namespace)
13341322

1335-
if len(dropMetadataList) == 0 {
1336-
return nil
1337-
}
1338-
13391323
log.Info("Processing DropMetadata for cleanup",
13401324
"argocd", fmt.Sprintf("%s/%s", argocd.Namespace, argocd.Name),
13411325
"namespace", namespace,
@@ -1352,7 +1336,6 @@ func (r *ReconcileArgoCD) processDropMetadataForCleanup(argocd *argoproj.ArgoCD)
13521336

13531337
// Clear the DropMetadata for this namespace after cleanup
13541338
removeDropMetadataForNamespace(namespace)
1355-
return nil
13561339
}
13571340

13581341
// cleanupLabelsFromResourceType removes labels from specific resource types
@@ -1417,15 +1400,11 @@ func (r *ReconcileArgoCD) cleanupLabelsFromDeployment(argocd *argoproj.ArgoCD, d
14171400
return fmt.Errorf("failed to get deployment %s: %w", deploymentName, err)
14181401
}
14191402

1420-
if currentLabels, err := r.removeLabelsFromObject(deployment, labelsToRemove); err != nil {
1421-
log.Error(err, "failed to remove labels from deployment", "name", deploymentName)
1403+
currentLabels := r.removeLabelsFromObject(deployment, labelsToRemove)
1404+
deployment.Spec.Template.Labels = currentLabels
1405+
if err := r.Update(context.TODO(), deployment); err != nil {
1406+
log.Error(err, "failed to update deployment after removing labels", "name", deploymentName)
14221407
return err
1423-
} else {
1424-
deployment.Spec.Template.Labels = currentLabels
1425-
if err := r.Update(context.TODO(), deployment); err != nil {
1426-
log.Error(err, "failed to update deployment after removing labels", "name", deploymentName)
1427-
return err
1428-
}
14291408
}
14301409
return nil
14311410
}
@@ -1444,16 +1423,13 @@ func (r *ReconcileArgoCD) cleanupLabelsFromStatefulSet(argocd *argoproj.ArgoCD,
14441423
return fmt.Errorf("failed to get statefulset %s: %w", statefulSetName, err)
14451424
}
14461425

1447-
if currentLabels, err := r.removeLabelsFromObject(statefulSet, labelsToRemove); err != nil {
1448-
log.Error(err, "failed to remove labels from statefulset", "name", statefulSetName)
1426+
currentLabels := r.removeLabelsFromObject(statefulSet, labelsToRemove)
1427+
statefulSet.SetLabels(currentLabels)
1428+
if err := r.Update(context.TODO(), statefulSet); err != nil {
1429+
log.Error(err, "failed to update statefulset after removing labels", "name", statefulSetName)
14491430
return err
1450-
} else {
1451-
statefulSet.SetLabels(currentLabels)
1452-
if err := r.Update(context.TODO(), statefulSet); err != nil {
1453-
log.Error(err, "failed to update statefulset after removing labels", "name", statefulSetName)
1454-
return err
1455-
}
14561431
}
1432+
14571433
return nil
14581434
}
14591435

@@ -1525,10 +1501,10 @@ func (r *ReconcileArgoCD) calculateRemovedSpecLabels(oldCR, newCR *argoproj.Argo
15251501

15261502
}
15271503

1528-
func (r *ReconcileArgoCD) removeLabelsFromObject(obj client.Object, labelsToRemove []string) (map[string]string, error) {
1504+
func (r *ReconcileArgoCD) removeLabelsFromObject(obj client.Object, labelsToRemove []string) map[string]string {
15291505
currentLabels := obj.GetLabels()
15301506
if currentLabels == nil {
1531-
return nil, nil
1507+
return nil
15321508
}
15331509

15341510
modified := false
@@ -1539,9 +1515,9 @@ func (r *ReconcileArgoCD) removeLabelsFromObject(obj client.Object, labelsToRemo
15391515
}
15401516
}
15411517
if modified {
1542-
return currentLabels, nil
1518+
return currentLabels
15431519
}
1544-
return currentLabels, nil
1520+
return currentLabels
15451521
}
15461522

15471523
// deleteRBACsForNamespace deletes the RBACs when the label from the namespace is removed.

0 commit comments

Comments
 (0)