Skip to content

Commit

Permalink
move app_actions.go to proto3
Browse files Browse the repository at this point in the history
Signed-off-by: pashakostohrys <[email protected]>
  • Loading branch information
pasha-codefresh committed Jun 25, 2024
1 parent 4ad8901 commit 74dc3f1
Showing 1 changed file with 19 additions and 20 deletions.
39 changes: 19 additions & 20 deletions cmd/argocd/commands/app_actions.go
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,6 @@ import (

log "github.com/sirupsen/logrus"
"github.com/spf13/cobra"
"k8s.io/utils/ptr"
"sigs.k8s.io/yaml"

"github.com/argoproj/argo-cd/v2/cmd/argocd/commands/headless"
Expand Down Expand Up @@ -84,7 +83,7 @@ func NewApplicationResourceActionsListCommand(clientOpts *argocdclient.ClientOpt
appName, appNs := argo.ParseFromQualifiedName(args[0], "")
conn, appIf := headless.NewClientOrDie(clientOpts, c).NewApplicationClientOrDie()
defer io.Close(conn)
resources, err := getActionableResourcesForApplication(appIf, ctx, &appNs, &appName)
resources, err := getActionableResourcesForApplication(appIf, ctx, appNs, appName)
errors.CheckError(err)
filteredObjects, err := util.FilterResources(command.Flags().Changed("group"), resources, group, kind, namespace, resourceName, true)
errors.CheckError(err)
Expand All @@ -93,13 +92,13 @@ func NewApplicationResourceActionsListCommand(clientOpts *argocdclient.ClientOpt
obj := filteredObjects[i]
gvk := obj.GroupVersionKind()
availActionsForResource, err := appIf.ListResourceActions(ctx, &applicationpkg.ApplicationResourceRequest{
Name: &appName,
AppNamespace: &appNs,
Namespace: ptr.To(obj.GetNamespace()),
ResourceName: ptr.To(obj.GetName()),
Group: ptr.To(gvk.Group),
Kind: ptr.To(gvk.Kind),
Version: ptr.To(gvk.Version),
Name: appName,
AppNamespace: appNs,
Namespace: obj.GetNamespace(),
ResourceName: obj.GetName(),
Group: gvk.Group,
Kind: gvk.Kind,
Version: gvk.Version,
})
errors.CheckError(err)
for _, action := range availActionsForResource.Actions {
Expand Down Expand Up @@ -176,7 +175,7 @@ func NewApplicationResourceActionsRunCommand(clientOpts *argocdclient.ClientOpti

conn, appIf := headless.NewClientOrDie(clientOpts, c).NewApplicationClientOrDie()
defer io.Close(conn)
resources, err := getActionableResourcesForApplication(appIf, ctx, &appNs, &appName)
resources, err := getActionableResourcesForApplication(appIf, ctx, appNs, appName)
errors.CheckError(err)
filteredObjects, err := util.FilterResources(command.Flags().Changed("group"), resources, group, kind, namespace, resourceName, all)
errors.CheckError(err)
Expand All @@ -192,22 +191,22 @@ func NewApplicationResourceActionsRunCommand(clientOpts *argocdclient.ClientOpti
gvk := obj.GroupVersionKind()
objResourceName := obj.GetName()
_, err := appIf.RunResourceAction(ctx, &applicationpkg.ResourceActionRunRequest{
Name: &appName,
AppNamespace: &appNs,
Namespace: ptr.To(obj.GetNamespace()),
ResourceName: ptr.To(objResourceName),
Group: ptr.To(gvk.Group),
Kind: ptr.To(gvk.Kind),
Version: ptr.To(gvk.GroupVersion().Version),
Action: ptr.To(actionName),
Name: appName,
AppNamespace: appNs,
Namespace: obj.GetNamespace(),
ResourceName: objResourceName,
Group: gvk.Group,
Kind: gvk.Kind,
Version: gvk.GroupVersion().Version,
Action: actionName,
})
errors.CheckError(err)
}
}
return command
}

func getActionableResourcesForApplication(appIf applicationpkg.ApplicationServiceClient, ctx context.Context, appNs *string, appName *string) ([]*v1alpha1.ResourceDiff, error) {
func getActionableResourcesForApplication(appIf applicationpkg.ApplicationServiceClient, ctx context.Context, appNs string, appName string) ([]*v1alpha1.ResourceDiff, error) {
resources, err := appIf.ManagedResources(ctx, &applicationpkg.ResourcesQuery{
ApplicationName: appName,
AppNamespace: appNs,
Expand All @@ -233,7 +232,7 @@ func getActionableResourcesForApplication(appIf applicationpkg.ApplicationServic
Group: appGVK.Group,
Kind: appGVK.Kind,
Namespace: app.Namespace,
Name: *appName,
Name: appName,
LiveState: string(appManifest),
}), nil
}

0 comments on commit 74dc3f1

Please sign in to comment.