mirror of
https://github.com/SAP/jenkins-library.git
synced 2024-12-12 10:55:20 +02:00
YamlUtil (prepares for cf deploy) (#1624)
Migrates basically `com/sap/piper/variablesubstitution/YamlUtils.groovy`.
This commit is contained in:
Marcus Holl
GitHub
parent
a4fc7bf4af
commit
d53ff9de0b
1
go.mod
1
go.mod
@ -47,4 +47,5 @@ require (
|
||||
golang.org/x/sys v0.0.0-20200602225109-6fdc65e7d980 // indirect
|
||||
google.golang.org/genproto v0.0.0-20200602104108-2bb8d6132df6 // indirect
|
||||
gopkg.in/ini.v1 v1.57.0
|
||||
gopkg.in/yaml.v2 v2.3.0
|
||||
)
|
||||
|
||||
236
pkg/yaml/yamlUtil.go
Normal file
236
pkg/yaml/yamlUtil.go
Normal file
@ -0,0 +1,236 @@
|
||||
package yaml
|
||||
|
||||
import (
|
||||
"bytes"
|
||||
"fmt"
|
||||
"github.com/SAP/jenkins-library/pkg/log"
|
||||
"github.com/SAP/jenkins-library/pkg/piperutils"
|
||||
"gopkg.in/yaml.v2"
|
||||
"io"
|
||||
"os"
|
||||
"reflect"
|
||||
"regexp"
|
||||
"strings"
|
||||
)
|
||||
|
||||
type fUtils interface {
|
||||
FileRead(name string) ([]byte, error)
|
||||
FileWrite(name string, data []byte, mode os.FileMode) error
|
||||
}
|
||||
|
||||
var _fileUtils fUtils
|
||||
|
||||
var _stat = os.Stat
|
||||
var _traverse = traverse
|
||||
|
||||
// Substitute ...
|
||||
func Substitute(ymlFile string, replacements map[string]interface{}, replacementsFiles []string) (bool, error) {
|
||||
|
||||
if _fileUtils == nil {
|
||||
_fileUtils = piperutils.Files{}
|
||||
}
|
||||
|
||||
bIn, err := _fileUtils.FileRead(ymlFile)
|
||||
if err != nil {
|
||||
return false, err
|
||||
}
|
||||
|
||||
inDecoder := yaml.NewDecoder(bytes.NewReader(bIn))
|
||||
|
||||
buf := new(bytes.Buffer)
|
||||
outEncoder := yaml.NewEncoder(buf)
|
||||
|
||||
var updated bool
|
||||
|
||||
mergedReplacements, err := getReplacements(replacements, replacementsFiles)
|
||||
if err != nil {
|
||||
return false, err
|
||||
}
|
||||
|
||||
for {
|
||||
|
||||
mIn := make(map[string]interface{})
|
||||
|
||||
decodeErr := inDecoder.Decode(&mIn)
|
||||
|
||||
if decodeErr != nil {
|
||||
if decodeErr == io.EOF {
|
||||
break
|
||||
}
|
||||
return false, decodeErr
|
||||
}
|
||||
|
||||
if err != nil {
|
||||
return false, err
|
||||
}
|
||||
|
||||
out, _updated, err := _traverse(mIn, mergedReplacements)
|
||||
if err != nil {
|
||||
return false, err
|
||||
}
|
||||
|
||||
updated = _updated || updated
|
||||
|
||||
err = outEncoder.Encode(out)
|
||||
}
|
||||
|
||||
if updated {
|
||||
|
||||
fInfo, err := _stat(ymlFile)
|
||||
if err != nil {
|
||||
return false, err
|
||||
}
|
||||
|
||||
err = _fileUtils.FileWrite(ymlFile, buf.Bytes(), fInfo.Mode())
|
||||
if err != nil {
|
||||
return false, err
|
||||
}
|
||||
}
|
||||
|
||||
return updated, nil
|
||||
}
|
||||
|
||||
func traverse(node interface{}, replacements map[string]interface{}) (interface{}, bool, error) {
|
||||
switch t := node.(type) {
|
||||
case string:
|
||||
return handleString(t, replacements)
|
||||
case bool:
|
||||
return t, false, nil
|
||||
case int:
|
||||
return t, false, nil
|
||||
case map[string]interface{}:
|
||||
return handleMap(t, replacements)
|
||||
case []interface{}:
|
||||
return handleSlice(t, replacements)
|
||||
default:
|
||||
return nil, false, fmt.Errorf("Unkown type received: '%v' (%v)", reflect.TypeOf(node), node)
|
||||
}
|
||||
}
|
||||
|
||||
func handleString(value string, replacements map[string]interface{}) (interface{}, bool, error) {
|
||||
|
||||
trimmed := strings.TrimSpace(value)
|
||||
re := regexp.MustCompile(`\(\(.*?\)\)`)
|
||||
matches := re.FindAllSubmatch([]byte(trimmed), -1)
|
||||
fullMatch := isFullMatch(trimmed, matches)
|
||||
if fullMatch {
|
||||
log.Entry().Infof("FullMatchFound: %v", value)
|
||||
parameterName := getParameterName(matches[0][0])
|
||||
parameterValue := getParameterValue(parameterName, replacements)
|
||||
if parameterValue == nil {
|
||||
return nil, false, fmt.Errorf("No value available for parameters '%s', replacements: %v", parameterName, replacements)
|
||||
}
|
||||
log.Entry().Infof("FullMatchFound: '%s', replacing with '%v'", parameterName, parameterValue)
|
||||
return parameterValue, true, nil
|
||||
}
|
||||
// we have to scan for multiple variables
|
||||
// we return always a string
|
||||
updated := false
|
||||
for i, match := range matches {
|
||||
parameterName := getParameterName(match[0])
|
||||
log.Entry().Infof("XPartial match found: (%d) %v, %v", i, parameterName, value)
|
||||
parameterValue := getParameterValue(parameterName, replacements)
|
||||
if parameterValue == nil {
|
||||
return nil, false, fmt.Errorf("No value available for parameter '%s', replacements: %v", parameterName, replacements)
|
||||
}
|
||||
|
||||
var conversion string
|
||||
switch t := parameterValue.(type) {
|
||||
case string:
|
||||
conversion = "%s"
|
||||
case bool:
|
||||
conversion = "%t"
|
||||
case int:
|
||||
conversion = "%d"
|
||||
case float64:
|
||||
conversion = "%g" // exponent as need, only required digits
|
||||
default:
|
||||
return nil, false, fmt.Errorf("Unsupported datatype found during travseral of yaml file: '%v', type: '%v'", parameterValue, reflect.TypeOf(t))
|
||||
}
|
||||
valueAsString := fmt.Sprintf(conversion, parameterValue)
|
||||
log.Entry().Infof("Value as String: %v: '%v'", parameterName, valueAsString)
|
||||
value = strings.Replace(value, "(("+parameterName+"))", valueAsString, -1)
|
||||
updated = true
|
||||
log.Entry().Infof("PartialMatchFound (%d): '%v', replaced with : '%s'", i, parameterName, valueAsString)
|
||||
}
|
||||
|
||||
return value, updated, nil
|
||||
}
|
||||
|
||||
func getParameterName(b []byte) string {
|
||||
pName := string(b)
|
||||
log.Entry().Infof("ParameterName is: '%s'", pName)
|
||||
return strings.Replace(strings.Replace(string(b), "((", "", 1), "))", "", 1)
|
||||
}
|
||||
|
||||
func getParameterValue(name string, replacements map[string]interface{}) interface{} {
|
||||
|
||||
r := replacements[name]
|
||||
log.Entry().Infof("Value '%v' resolved for parameter '%s'", r, name)
|
||||
return r
|
||||
}
|
||||
|
||||
func isFullMatch(value string, matches [][][]byte) bool {
|
||||
return strings.HasPrefix(value, "((") && strings.HasSuffix(value, "))") && len(matches) == 1 && len(matches[0]) == 1
|
||||
}
|
||||
|
||||
func handleSlice(t []interface{}, replacements map[string]interface{}) ([]interface{}, bool, error) {
|
||||
tNode := make([]interface{}, 0)
|
||||
updated := false
|
||||
for _, e := range t {
|
||||
if val, _updated, err := traverse(e, replacements); err == nil {
|
||||
updated = updated || _updated
|
||||
tNode = append(tNode, val)
|
||||
|
||||
} else {
|
||||
return nil, false, err
|
||||
}
|
||||
}
|
||||
return tNode, updated, nil
|
||||
}
|
||||
|
||||
func handleMap(t map[string]interface{}, replacements map[string]interface{}) (map[string]interface{}, bool, error) {
|
||||
tNode := make(map[string]interface{})
|
||||
updated := false
|
||||
for key, value := range t {
|
||||
if val, _updated, err := traverse(value, replacements); err == nil {
|
||||
updated = updated || _updated
|
||||
tNode[key] = val
|
||||
} else {
|
||||
return nil, false, err
|
||||
}
|
||||
}
|
||||
return tNode, updated, nil
|
||||
}
|
||||
|
||||
func getReplacements(replacements map[string]interface{}, replacementsFiles []string) (map[string]interface{}, error) {
|
||||
|
||||
mReplacements := make(map[string]interface{})
|
||||
|
||||
for _, replacementsFile := range replacementsFiles {
|
||||
bReplacements, err := _fileUtils.FileRead(replacementsFile)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
replacementsDecoder := yaml.NewDecoder(bytes.NewReader(bReplacements))
|
||||
|
||||
for {
|
||||
decodeErr := replacementsDecoder.Decode(&mReplacements)
|
||||
|
||||
if decodeErr != nil {
|
||||
if decodeErr == io.EOF {
|
||||
break
|
||||
}
|
||||
return nil, decodeErr
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// the parameters from the map has a higher precedence,
|
||||
// hence we merge after resolving parameters from the files
|
||||
for k, v := range replacements {
|
||||
mReplacements[k] = v
|
||||
}
|
||||
return mReplacements, nil
|
||||
}
|
||||
401
pkg/yaml/yamlUtil_test.go
Normal file
401
pkg/yaml/yamlUtil_test.go
Normal file
@ -0,0 +1,401 @@
|
||||
package yaml
|
||||
|
||||
import (
|
||||
"github.com/SAP/jenkins-library/pkg/mock"
|
||||
"github.com/SAP/jenkins-library/pkg/piperutils"
|
||||
"github.com/ghodss/yaml"
|
||||
"github.com/stretchr/testify/assert"
|
||||
"os"
|
||||
"regexp"
|
||||
"testing"
|
||||
"time"
|
||||
)
|
||||
|
||||
type fileInfoMock struct {
|
||||
name string
|
||||
data []byte
|
||||
}
|
||||
|
||||
func (fInfo fileInfoMock) Name() string { return "" }
|
||||
func (fInfo fileInfoMock) Size() int64 { return int64(0) }
|
||||
func (fInfo fileInfoMock) Mode() os.FileMode { return 0444 }
|
||||
func (fInfo fileInfoMock) ModTime() time.Time { return time.Time{} }
|
||||
func (fInfo fileInfoMock) IsDir() bool { return false }
|
||||
func (fInfo fileInfoMock) Sys() interface{} { return nil }
|
||||
|
||||
func TestFilesRelated(t *testing.T) {
|
||||
|
||||
traverseCalled := false
|
||||
|
||||
var replacements map[string]interface{}
|
||||
|
||||
oldStat := _stat
|
||||
oldTraverse := _traverse
|
||||
|
||||
var fileMock *mock.FilesMock
|
||||
|
||||
defer func() {
|
||||
_stat = oldStat
|
||||
_traverse = oldTraverse
|
||||
_fileUtils = &piperutils.Files{}
|
||||
}()
|
||||
|
||||
setupFileMock := func(files map[string][]byte) {
|
||||
|
||||
fileMock = &mock.FilesMock{}
|
||||
for name, content := range files {
|
||||
fileMock.AddFile(name, content)
|
||||
}
|
||||
_fileUtils = fileMock
|
||||
}
|
||||
|
||||
reset := func() {
|
||||
|
||||
traverseCalled = false
|
||||
|
||||
replacements = make(map[string]interface{})
|
||||
|
||||
_stat = func(name string) (os.FileInfo, error) {
|
||||
return fileInfoMock{}, nil
|
||||
}
|
||||
|
||||
setupFileMock(map[string][]byte{})
|
||||
|
||||
_traverse = func(_ interface{}, _replacements map[string]interface{}) (interface{}, bool, error) {
|
||||
replacements = _replacements
|
||||
traverseCalled = true
|
||||
return nil, true, nil
|
||||
}
|
||||
}
|
||||
|
||||
t.Run("WriteFileOnUpdate", func(t *testing.T) {
|
||||
|
||||
reset()
|
||||
defer reset()
|
||||
|
||||
setupFileMock(map[string][]byte{
|
||||
"manifest.yml": []byte("a: dummy"),
|
||||
"replacements.yml": []byte{},
|
||||
})
|
||||
|
||||
updated, err := Substitute("manifest.yml", map[string]interface{}{}, []string{"replacements.yml"})
|
||||
|
||||
if assert.NoError(t, err) {
|
||||
assert.True(t, updated)
|
||||
assert.True(t, fileMock.HasWrittenFile("manifest.yml"))
|
||||
assert.True(t, traverseCalled)
|
||||
}
|
||||
})
|
||||
|
||||
t.Run("DontWriteOnNoUpdate", func(t *testing.T) {
|
||||
|
||||
reset()
|
||||
defer reset()
|
||||
|
||||
setupFileMock(map[string][]byte{
|
||||
"manifest.yml": []byte("a: dummy"),
|
||||
"replacements.yml": []byte{},
|
||||
})
|
||||
|
||||
_traverse = func(interface{}, map[string]interface{}) (interface{}, bool, error) {
|
||||
traverseCalled = true
|
||||
return nil, false, nil
|
||||
}
|
||||
|
||||
updated, err := Substitute("manifest.yml", map[string]interface{}{}, []string{"replacements.yml"})
|
||||
|
||||
if assert.NoError(t, err) {
|
||||
assert.False(t, updated)
|
||||
assert.False(t, fileMock.HasWrittenFile("manifest.yml"))
|
||||
}
|
||||
})
|
||||
|
||||
t.Run("Read multiple replacement yamls in one file", func(t *testing.T) {
|
||||
|
||||
// expected behaviour in case of multiple yaml documents in one "file":
|
||||
// we merge the content. The latest wins
|
||||
|
||||
reset()
|
||||
defer reset()
|
||||
|
||||
setupFileMock(map[string][]byte{
|
||||
"manifest.yml": []byte("a: dummy"),
|
||||
"replacements.yml": []byte("a: x # A comment.\nc: d\n---\na: b\nzz: 1234\n"),
|
||||
})
|
||||
|
||||
_, err := Substitute("manifest.yml", map[string]interface{}{}, []string{"replacements.yml"})
|
||||
|
||||
if assert.NoError(t, err) {
|
||||
assert.Equal(t, map[string]interface{}{"a": "b", "c": "d", "zz": 1234}, replacements)
|
||||
}
|
||||
})
|
||||
|
||||
t.Run("Handle multi manifest", func(t *testing.T) {
|
||||
|
||||
reset()
|
||||
defer reset()
|
||||
|
||||
_traverse = func(_ interface{}, _replacements map[string]interface{}) (interface{}, bool, error) {
|
||||
return map[string]interface{}{"called": true}, true, nil
|
||||
}
|
||||
|
||||
setupFileMock(map[string][]byte{
|
||||
"manifest.yml": []byte("a: dummy\n---\n b: otherDummy\n"),
|
||||
// here we have two yaml documents in one "file" ...
|
||||
"replacements.yml": []byte("a: b # A comment.\nc: d\n---\nzz: 1234\n"),
|
||||
})
|
||||
|
||||
_, err := Substitute("manifest.yml", map[string]interface{}{}, []string{"replacements.yml"})
|
||||
|
||||
if assert.NoError(t, err) {
|
||||
content, err := fileMock.FileRead("manifest.yml")
|
||||
if assert.NoError(t, err) {
|
||||
// ... the two yaml files results in two yaml documents, separated by '---'
|
||||
assert.Equal(t, "called: true\n---\ncalled: true\n", string(content))
|
||||
}
|
||||
}
|
||||
})
|
||||
|
||||
t.Run("Handle single manifest", func(t *testing.T) {
|
||||
|
||||
reset()
|
||||
defer reset()
|
||||
|
||||
setupFileMock(map[string][]byte{
|
||||
"manifest.yml": []byte("a: dummy\n"),
|
||||
// here we have two yaml documents in one "file" ...
|
||||
"replacements.yml": []byte("a: b # A comment.\nc: d\n---\nzz: 1234\n"),
|
||||
})
|
||||
|
||||
_traverse = func(_ interface{}, _replacements map[string]interface{}) (interface{}, bool, error) {
|
||||
return map[string]interface{}{"called": true}, true, nil
|
||||
}
|
||||
|
||||
_, err := Substitute("manifest.yml", map[string]interface{}{}, []string{"replacements.yml"})
|
||||
|
||||
if assert.NoError(t, err) {
|
||||
content, err := fileMock.FileRead("manifest.yml")
|
||||
if assert.NoError(t, err) {
|
||||
// we have a single yaml document (no '---' inbetween)
|
||||
assert.Equal(t, "called: true\n", string(content))
|
||||
}
|
||||
}
|
||||
})
|
||||
|
||||
t.Run("Manifest does not exist", func(t *testing.T) {
|
||||
|
||||
reset()
|
||||
defer reset()
|
||||
|
||||
_, err := Substitute("manifestDoesNotExist.yml", map[string]interface{}{}, []string{"replacements.yml"})
|
||||
|
||||
if assert.EqualError(t, err, "could not read 'manifestDoesNotExist.yml'") {
|
||||
assert.False(t, traverseCalled)
|
||||
}
|
||||
})
|
||||
|
||||
t.Run("Replacements does not exist", func(t *testing.T) {
|
||||
|
||||
reset()
|
||||
defer reset()
|
||||
|
||||
setupFileMock(map[string][]byte{
|
||||
"manifest.yml": []byte("a: dummy\n"),
|
||||
})
|
||||
|
||||
_, err := Substitute("manifest.yml", map[string]interface{}{}, []string{"replacementsDoesNotExist.yml"})
|
||||
|
||||
if assert.EqualError(t, err, "could not read 'replacementsDoesNotExist.yml'") {
|
||||
assert.True(t, fileMock.HasFile("manifest.yml"))
|
||||
assert.False(t, traverseCalled)
|
||||
}
|
||||
})
|
||||
|
||||
t.Run("Replacements from map has precedence over replacments from file", func(t *testing.T) {
|
||||
|
||||
reset()
|
||||
defer reset()
|
||||
|
||||
setupFileMock(map[string][]byte{
|
||||
"manifest.yml": []byte("a: ((a))\nb: ((b))"),
|
||||
"replacements.yml": []byte("a: aa # A comment.\nb: bb\n"),
|
||||
})
|
||||
|
||||
_traverse = traverse
|
||||
|
||||
_, err := Substitute("manifest.yml", map[string]interface{}{"b": "xx"}, []string{"replacements.yml"})
|
||||
|
||||
if assert.NoError(t, err) {
|
||||
content, err := fileMock.FileRead("manifest.yml")
|
||||
if assert.NoError(t, err) {
|
||||
assert.Equal(t, "a: aa\nb: xx\n", string(content))
|
||||
}
|
||||
}
|
||||
})
|
||||
}
|
||||
|
||||
func TestSubstitution(t *testing.T) {
|
||||
|
||||
document := make(map[string]interface{})
|
||||
replacements := make(map[string]interface{})
|
||||
|
||||
yaml.Unmarshal([]byte(
|
||||
`unique-prefix: uniquePrefix # A unique prefix. E.g. your D/I/C-User
|
||||
xsuaa-instance-name: uniquePrefix-catalog-service-odatav2-xsuaa
|
||||
hana-instance-name: uniquePrefix-catalog-service-odatav2-hana
|
||||
integer-variable: 1
|
||||
boolean-variable: Yes
|
||||
float-variable: 0.25
|
||||
json-variable: >
|
||||
[
|
||||
{"name":"token-destination",
|
||||
"url":"https://www.google.com",
|
||||
"forwardAuthToken": true}
|
||||
]
|
||||
object-variable:
|
||||
hello: "world"
|
||||
this: "is an object with"
|
||||
one: 1
|
||||
float: 25.0
|
||||
bool: Yes`), &replacements)
|
||||
|
||||
err := yaml.Unmarshal([]byte(
|
||||
`applications:
|
||||
- name: ((unique-prefix))-catalog-service-odatav2-0.0.1
|
||||
memory: 1024M
|
||||
disk_quota: 512M
|
||||
instances: ((integer-variable))
|
||||
buildpacks:
|
||||
- java_buildpack
|
||||
path: ./srv/target/srv-backend-0.0.1-SNAPSHOT.jar
|
||||
routes:
|
||||
- route: ((unique-prefix))-catalog-service-odatav2-001.cfapps.eu10.hana.ondemand.com
|
||||
|
||||
services:
|
||||
- ((xsuaa-instance-name)) # requires an instance of xsuaa instantiated with xs-security.json of this project. See services-manifest.yml.
|
||||
- ((hana-instance-name)) # requires an instance of hana service with plan hdi-shared. See services-manifest.yml.
|
||||
|
||||
env:
|
||||
spring.profiles.active: cloud # activate the spring profile named 'cloud'.
|
||||
xsuaa-instance-name: ((xsuaa-instance-name))
|
||||
db_service_instance_name: ((hana-instance-name))
|
||||
booleanVariable: ((boolean-variable))
|
||||
floatVariable: ((float-variable))
|
||||
json-variable: ((json-variable))
|
||||
object-variable: ((object-variable))
|
||||
string-variable: ((boolean-variable))-((float-variable))-((integer-variable))-((json-variable))
|
||||
single-var-with-string-constants: ((boolean-variable))-with-some-more-text
|
||||
`), &document)
|
||||
|
||||
replaced, updated, err := traverse(document, replacements)
|
||||
|
||||
t.Run("The basics", func(t *testing.T) {
|
||||
assert.NoError(t, err)
|
||||
assert.True(t, updated)
|
||||
})
|
||||
|
||||
t.Run("Check no variables left", func(t *testing.T) {
|
||||
|
||||
data, err := yaml.Marshal(&replaced)
|
||||
|
||||
if assert.NoError(t, err) {
|
||||
assert.Nil(t, regexp.MustCompile("\\(\\(.*\\)\\)").Find(data))
|
||||
}
|
||||
})
|
||||
|
||||
app := getApplication(t, replaced, 0)
|
||||
|
||||
t.Run("Assert data type and substitution correctness", func(t *testing.T) {
|
||||
|
||||
t.Run("Check instances", func(t *testing.T) {
|
||||
if one, ok := app["instances"].(float64); ok {
|
||||
assert.Equal(t, 1, int(one))
|
||||
} else {
|
||||
assert.Fail(t, "Value for 'instances' is not a float64")
|
||||
}
|
||||
})
|
||||
|
||||
t.Run("Check services", func(t *testing.T) {
|
||||
if services, ok := app["services"].([]interface{}); ok {
|
||||
assert.IsType(t, "string", services[0])
|
||||
} else {
|
||||
assert.FailNow(t, "first service is not of type string.")
|
||||
}
|
||||
})
|
||||
|
||||
t.Run("Assert correct variable substitution - name", func(t *testing.T) {
|
||||
assert.Equal(t, "uniquePrefix-catalog-service-odatav2-0.0.1", app["name"])
|
||||
})
|
||||
|
||||
t.Run("Assert correct variable substitution - services", func(t *testing.T) {
|
||||
if services, ok := app["services"].([]interface{}); ok {
|
||||
assert.Equal(t, "uniquePrefix-catalog-service-odatav2-xsuaa", services[0])
|
||||
assert.Equal(t, "uniquePrefix-catalog-service-odatav2-hana", services[1])
|
||||
} else {
|
||||
assert.Fail(t, "'services' node is not a list")
|
||||
}
|
||||
})
|
||||
|
||||
t.Run("Check env", func(t *testing.T) {
|
||||
|
||||
if env, ok := app["env"].(map[string]interface{}); ok {
|
||||
|
||||
t.Run("Check float", func(t *testing.T) {
|
||||
assert.IsType(t, float64(42), env["floatVariable"])
|
||||
})
|
||||
|
||||
t.Run("Check boolean", func(t *testing.T) {
|
||||
assert.IsType(t, true, env["booleanVariable"])
|
||||
})
|
||||
|
||||
t.Run("Check json variable is string", func(t *testing.T) {
|
||||
assert.IsType(t, "string", env["json-variable"])
|
||||
})
|
||||
|
||||
t.Run("Check object variable is map", func(t *testing.T) {
|
||||
assert.IsType(t, make(map[string]interface{}), env["object-variable"])
|
||||
})
|
||||
|
||||
t.Run("Check string variable (composed 1)", func(t *testing.T) {
|
||||
assert.IsType(t, "string", env["string-variable"])
|
||||
assert.Regexp(t, "^true-0.25-1-.*", env["string-variable"])
|
||||
})
|
||||
|
||||
t.Run("Check string variable (composed 2)", func(t *testing.T) {
|
||||
assert.Equal(t, "true-with-some-more-text", env["single-var-with-string-constants"])
|
||||
})
|
||||
|
||||
t.Run("Assert correct variable substitution - xsuaa-instance-name", func(t *testing.T) {
|
||||
assert.Equal(t, "uniquePrefix-catalog-service-odatav2-xsuaa", env["xsuaa-instance-name"])
|
||||
})
|
||||
|
||||
t.Run("Assert correct variable substitution - db_service_instance_name", func(t *testing.T) {
|
||||
assert.Equal(t, "uniquePrefix-catalog-service-odatav2-hana", env["db_service_instance_name"])
|
||||
})
|
||||
|
||||
} else {
|
||||
assert.FailNow(t, "env is not a map")
|
||||
}
|
||||
})
|
||||
})
|
||||
}
|
||||
|
||||
func getApplication(t *testing.T, tree interface{}, index int) map[string]interface{} {
|
||||
|
||||
const nodeNameApplications = "applications"
|
||||
|
||||
if m, ok := tree.(map[string]interface{}); !ok {
|
||||
assert.FailNow(t, "Cannot prepare tests", "Outermost node inside replaced structure is not a map.")
|
||||
} else {
|
||||
if apps, ok := m[nodeNameApplications].([]interface{}); !ok {
|
||||
assert.FailNowf(t, "Cannot prepare tests", "Node '%s' is not an interface slice.", nodeNameApplications)
|
||||
} else {
|
||||
if app, ok := apps[0].(map[string]interface{}); ok {
|
||||
return app
|
||||
} else {
|
||||
assert.FailNowf(t, "Cannot prepare tests", "The first node inside '%s' is not a map.", nodeNameApplications)
|
||||
}
|
||||
}
|
||||
}
|
||||
return nil // we should end up earlier in an assert or return above ...
|
||||
}
|
||||
Loading…
Reference in New Issue
Block a user