forked from argoproj/argo-cd
-
Notifications
You must be signed in to change notification settings - Fork 0
/
actions.go
123 lines (96 loc) · 2.61 KB
/
actions.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
package app
import (
. "github.com/argoproj/argo-cd/pkg/apis/application/v1alpha1"
"github.com/argoproj/argo-cd/test/e2e/fixture"
)
// this implements the "when" part of given/when/then
//
// none of the func implement error checks, and that is complete intended, you should check for errors
// using the Then()
type Actions struct {
context *Context
lastOutput string
lastError error
}
func (a *Actions) PatchFile(file string, jsonPath string) *Actions {
fixture.Patch(a.context.path+"/"+file, jsonPath)
return a
}
func (a *Actions) DeleteFile(file string) *Actions {
fixture.Delete(a.context.path + "/" + file)
return a
}
func (a *Actions) Create() *Actions {
args := []string{
"app", "create", a.context.name,
"--repo", fixture.RepoURL(),
"--path", a.context.path,
"--dest-server", a.context.destServer,
"--dest-namespace", fixture.DeploymentNamespace(),
}
if a.context.env != "" {
args = append(args, "--env", a.context.env)
}
for _, parameter := range a.context.parameters {
args = append(args, "--parameter", parameter)
}
if a.context.namePrefix != "" {
args = append(args, "--nameprefix", a.context.namePrefix)
}
if a.context.configManagementPlugin != "" {
args = append(args, "--config-management-plugin", a.context.configManagementPlugin)
}
a.runCli(args...)
return a
}
func (a *Actions) PatchApp(patch string) *Actions {
a.runCli("app", "patch", a.context.name, "--patch", patch)
return a
}
func (a *Actions) Sync() *Actions {
args := []string{"app", "sync", a.context.name, "--timeout", "5"}
if a.context.async {
args = append(args, "--async")
}
if a.context.prune {
args = append(args, "--prune")
}
if a.context.resource != "" {
args = append(args, "--resource", a.context.resource)
}
if a.context.localPath != "" {
args = append(args, "--local", a.context.localPath)
}
a.runCli(args...)
return a
}
func (a *Actions) TerminateOp() *Actions {
a.runCli("app", "terminate-op", a.context.name)
return a
}
func (a *Actions) Refresh(refreshType RefreshType) *Actions {
flag := map[RefreshType]string{
RefreshTypeNormal: "--refresh",
RefreshTypeHard: "--hard-refresh",
}[refreshType]
a.runCli("app", "get", a.context.name, flag)
return a
}
func (a *Actions) Delete(cascade bool) *Actions {
args := []string{"app", "delete", a.context.name}
if cascade {
args = append(args, "--cascade")
}
a.runCli(args...)
return a
}
func (a *Actions) And(block func()) *Actions {
block()
return a
}
func (a *Actions) Then() *Consequences {
return &Consequences{a.context, a}
}
func (a *Actions) runCli(args ...string) {
a.lastOutput, a.lastError = fixture.RunCli(args...)
}