-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathnew_git.go
131 lines (115 loc) · 3.69 KB
/
new_git.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
124
125
126
127
128
129
130
131
package gitgo
import (
"github.com/yyle88/eroticgo"
"github.com/yyle88/osexec"
"github.com/yyle88/zaplog"
)
type Gcm struct {
execConfig *osexec.ExecConfig
output []byte
errorOnce error
debugMode bool
}
func New(path string) *Gcm {
return newOkGcm(osexec.NewCommandConfig().WithPath(path).WithDebugMode(debugModeOpen), make([]byte, 0), debugModeOpen)
}
func NewGcm(path string, execConfig *osexec.ExecConfig) *Gcm {
return newOkGcm(execConfig.ShallowClone().WithPath(path).WithDebugMode(debugModeOpen), make([]byte, 0), debugModeOpen)
}
func newOkGcm(execConfig *osexec.ExecConfig, output []byte, debugMode bool) *Gcm {
if debugMode {
if len(output) > 0 {
zaplog.ZAPS.Skip3.SUG.Debugln("done", "message:", "\n"+eroticgo.GREEN.Sprint(string(output))+"\n", "-")
} else {
zaplog.ZAPS.Skip3.SUG.Debugln("done", "\n", "-")
}
}
return &Gcm{
execConfig: execConfig,
output: output,
errorOnce: nil,
debugMode: debugMode,
}
}
func newWaGcm(execConfig *osexec.ExecConfig, output []byte, errorOnce error, debugMode bool) *Gcm {
if debugMode {
if len(output) > 0 {
zaplog.ZAPS.Skip3.SUG.Errorln("wrong", eroticgo.RED.Sprint(errorOnce), "message:", "\n"+eroticgo.RED.Sprint(string(output))+"\n", "-")
} else {
zaplog.ZAPS.Skip3.SUG.Errorln("wrong", eroticgo.RED.Sprint(errorOnce))
}
}
return &Gcm{
execConfig: execConfig,
output: output,
errorOnce: errorOnce,
debugMode: debugMode,
}
}
func (G *Gcm) Result() ([]byte, error) {
return G.output, G.errorOnce
}
// 这个函数不要使用导出的，因为日志里是跳过3层调用栈，假如使用导出的，跳出的栈的层数就不正确啦
func (G *Gcm) do(name string, args ...string) *Gcm {
if G.errorOnce != nil {
return G //当出错时就不要再往下执行，直接在这里拦住，这样整个链式的后续动作就都不执行
}
output, err := G.execConfig.Exec(name, args...)
if err != nil {
return newWaGcm(G.execConfig, output, err, G.debugMode)
}
return newOkGcm(G.execConfig, output, G.debugMode)
}
func (G *Gcm) UpdateCommandConfig(updateConfig func(cfg *osexec.CommandConfig)) *Gcm {
updateConfig(G.execConfig)
return G
}
func (G *Gcm) UpdateExecConfig(updateConfig func(cfg *osexec.ExecConfig)) *Gcm {
updateConfig(G.execConfig)
return G
}
func (G *Gcm) WithDebug() *Gcm {
return G.WithDebugMode(true)
}
func (G *Gcm) WithDebugMode(debugMode bool) *Gcm {
G.debugMode = debugMode
G.execConfig.WithDebugMode(debugMode)
return G
}
func (G *Gcm) ShowDebugMessage() *Gcm {
switch {
case G.errorOnce != nil && len(G.output) > 0:
zaplog.ZAPS.Skip1.SUG.Errorln("wrong", eroticgo.RED.Sprint(G.errorOnce), "message:", "\n"+eroticgo.RED.Sprint(string(G.output))+"\n", "-")
case G.errorOnce != nil:
zaplog.ZAPS.Skip1.SUG.Errorln("wrong", eroticgo.RED.Sprint(G.errorOnce), "\n", "-")
case len(G.output) > 0:
zaplog.ZAPS.Skip1.SUG.Debugln("done", "message:", "\n"+eroticgo.GREEN.Sprint(string(G.output))+"\n", "-")
default:
zaplog.ZAPS.Skip1.SUG.Debugln("done", "\n", "-")
}
return G
}
func (G *Gcm) MustDone() *Gcm {
if G.errorOnce != nil {
if len(G.output) > 0 {
zaplog.ZAPS.Skip1.SUG.Panicln("wrong", eroticgo.RED.Sprint(G.errorOnce), "message:", "\n"+eroticgo.RED.Sprint(string(G.output))+"\n", "-")
} else {
zaplog.ZAPS.Skip1.SUG.Panicln("wrong", eroticgo.RED.Sprint(G.errorOnce), "\n", "-")
}
}
return G
}
func (G *Gcm) When(condition func(*Gcm) bool, run func(*Gcm) *Gcm) *Gcm {
if condition(G) {
return run(G)
}
return G
}
func (G *Gcm) WhenThen(condition func(*Gcm) (bool, error), run func(*Gcm) *Gcm) *Gcm {
if success, err := condition(G); err != nil {
return newWaGcm(G.execConfig, []byte{}, err, G.debugMode)
} else if success {
return run(G)
}
return G
}