-
Notifications
You must be signed in to change notification settings - Fork 199
/
raw_docker.go
122 lines (97 loc) · 3.04 KB
/
raw_docker.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
package config
import (
"fmt"
"strings"
)
type rawDocker struct {
Volume interface{} `yaml:"VOLUME,omitempty"`
Expose interface{} `yaml:"EXPOSE,omitempty"`
Env map[string]string `yaml:"ENV,omitempty"`
Label map[string]string `yaml:"LABEL,omitempty"`
Cmd interface{} `yaml:"CMD,omitempty"`
Workdir string `yaml:"WORKDIR,omitempty"`
User string `yaml:"USER,omitempty"`
Entrypoint interface{} `yaml:"ENTRYPOINT,omitempty"`
HealthCheck string `yaml:"HEALTHCHECK,omitempty"`
rawStapelImage *rawStapelImage `yaml:"-"` // parent
UnsupportedAttributes map[string]interface{} `yaml:",inline"`
}
func (c *rawDocker) UnmarshalYAML(unmarshal func(interface{}) error) error {
if parent, ok := parentStack.Peek().(*rawStapelImage); ok {
c.rawStapelImage = parent
}
type plain rawDocker
if err := unmarshal((*plain)(c)); err != nil {
return err
}
if err := checkOverflow(c.UnsupportedAttributes, c, c.rawStapelImage.doc); err != nil {
return err
}
return nil
}
func (c *rawDocker) toDirective() (docker *Docker, err error) {
docker = &Docker{}
if volume, err := InterfaceToStringArray(c.Volume, c, c.rawStapelImage.doc); err != nil {
return nil, err
} else {
docker.Volume = volume
}
if expose, err := InterfaceToStringArray(c.Expose, c, c.rawStapelImage.doc); err != nil {
return nil, err
} else {
docker.Expose = expose
}
docker.Env = c.Env
docker.Label = c.Label
if cmd, err := prepareCommand(c.Cmd, c, c.rawStapelImage.doc); err != nil {
return nil, err
} else {
docker.Cmd = cmd
}
docker.Workdir = c.Workdir
docker.User = c.User
if entrypoint, err := prepareCommand(c.Entrypoint, c, c.rawStapelImage.doc); err != nil {
return nil, err
} else {
docker.Entrypoint = entrypoint
}
if docker.Entrypoint != "" && docker.Cmd == "" {
docker.Cmd = "[]"
}
docker.HealthCheck = c.HealthCheck
docker.raw = c
if err := c.validateDirective(docker); err != nil {
return nil, err
}
return docker, nil
}
func prepareCommand(stringOrArray interface{}, configSection interface{}, doc *doc) (cmd string, err error) {
if stringOrArray != nil {
if val, ok := stringOrArray.(string); ok {
cmd = val
} else if interfaceArray, ok := stringOrArray.([]interface{}); ok {
var stringArray []string
for _, interf := range interfaceArray {
if val, ok := interf.(string); ok {
stringArray = append(stringArray, val)
} else {
return cmd, newDetailedConfigError(fmt.Sprintf("single string or array of strings expected, got `%v`!", stringOrArray), configSection, doc)
}
}
if len(stringArray) == 0 {
cmd = "[]"
} else {
cmd = fmt.Sprintf("[\"%s\"]", strings.Join(stringArray, "\", \""))
}
} else {
return cmd, newDetailedConfigError(fmt.Sprintf("single string or array of strings expected, got `%v`!", stringOrArray), configSection, doc)
}
}
return
}
func (c *rawDocker) validateDirective(docker *Docker) (err error) {
if err := docker.validate(); err != nil {
return err
}
return nil
}