Skip to content

Commit

Permalink
got namespace filter test to pass with node string tag
Browse files Browse the repository at this point in the history
  • Loading branch information
shanalily committed Jan 25, 2022
1 parent 7beb686 commit f4008c0
Show file tree
Hide file tree
Showing 6 changed files with 34 additions and 45 deletions.
1 change: 1 addition & 0 deletions api/filters/filtersutil/setters.go
Expand Up @@ -19,6 +19,7 @@ func SetString(value string) SetFn {
n := &yaml.Node{
Kind: yaml.ScalarNode,
Value: value,
Tag: yaml.NodeTagString,
}
if yaml.IsYaml1_1NonString(n) {
n.Style = yaml.DoubleQuotedStyle
Expand Down
3 changes: 2 additions & 1 deletion api/filters/namespace/namespace.go
Expand Up @@ -77,7 +77,8 @@ func (ns Filter) metaNamespaceHack(obj *yaml.RNode, gvk resid.Gvk) error {
FsSlice: []types.FieldSpec{
{Path: types.MetadataNamespacePath, CreateIfNotPresent: true},
},
SetValue: filtersutil.SetScalar(ns.Namespace),
// SetValue: filtersutil.SetScalar(ns.Namespace),
SetValue: filtersutil.SetString(ns.Namespace),
CreateKind: yaml.ScalarNode, // Namespace is a ScalarNode
}
_, err := f.Filter(obj)
Expand Down
1 change: 0 additions & 1 deletion api/internal/accumulator/resaccumulator.go
Expand Up @@ -70,7 +70,6 @@ func (ra *ResAccumulator) GetTransformerConfig() *builtinconfig.TransformerConfi
// by digging into a particular fieldpath of "james".
func (ra *ResAccumulator) MergeVars(incoming []types.Var) error {
for _, v := range incoming {
fmt.Printf("MergVars v.ObjRef.Namespace: %s", v.ObjRef.Namespace)
targetId := resid.NewResIdWithNamespace(v.ObjRef.GVK(), v.ObjRef.Name, v.ObjRef.Namespace)
idMatcher := targetId.GvknEquals
if targetId.Namespace != "" || targetId.IsClusterScoped() {
Expand Down
68 changes: 31 additions & 37 deletions api/internal/accumulator/resaccumulator_test.go
Expand Up @@ -27,50 +27,44 @@ func makeResAccumulator(t *testing.T) *ResAccumulator {
if err != nil {
t.Fatalf("unexpected err: %v", err)
}
r := resmaptest_test.NewRmBuilderDefault(t).
Add(map[string]interface{}{
"apiVersion": "apps/v1",
"kind": "Deployment",
"metadata": map[string]interface{}{
"name": "deploy1",
"namespace": "01234",
},
"spec": map[string]interface{}{
"template": map[string]interface{}{
"spec": map[string]interface{}{
"containers": []interface{}{
map[string]interface{}{
"command": []interface{}{
"myserver",
"--somebackendService $(SERVICE_ONE)",
"--yetAnother $(SERVICE_TWO)",
err = ra.AppendAll(
resmaptest_test.NewRmBuilderDefault(t).
Add(map[string]interface{}{
"apiVersion": "apps/v1",
"kind": "Deployment",
"metadata": map[string]interface{}{
"name": "deploy1",
},
"spec": map[string]interface{}{
"template": map[string]interface{}{
"spec": map[string]interface{}{
"containers": []interface{}{
map[string]interface{}{
"command": []interface{}{
"myserver",
"--somebackendService $(SERVICE_ONE)",
"--yetAnother $(SERVICE_TWO)",
},
},
},
},
},
},
}}).
Add(map[string]interface{}{
"apiVersion": "v1",
"kind": "Service",
"metadata": map[string]interface{}{
"name": "backendOne",
}}).
Add(map[string]interface{}{
"apiVersion": "v1",
"kind": "Service",
"metadata": map[string]interface{}{
"name": "backendTwo",
}}).ResMap()
err = ra.AppendAll(r)
if err != nil {
t.Fatalf("unexpected err: %v", err)
}
result, err := r.AsYaml()
}}).
Add(map[string]interface{}{
"apiVersion": "v1",
"kind": "Service",
"metadata": map[string]interface{}{
"name": "backendOne",
}}).
Add(map[string]interface{}{
"apiVersion": "v1",
"kind": "Service",
"metadata": map[string]interface{}{
"name": "backendTwo",
}}).ResMap())
if err != nil {
t.Fatalf("unexpected err: %v", err)
}
t.Fatalf(string(result))
return ra
}

Expand Down
2 changes: 0 additions & 2 deletions api/internal/builtins/NamespaceTransformer.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

4 changes: 0 additions & 4 deletions api/internal/target/kusttarget_configplugin.go
Expand Up @@ -194,10 +194,6 @@ var transformerConfigurators = map[builtinhelpers.BuiltinPluginType]func(
}
c.Namespace = kt.kustomization.Namespace
c.FieldSpecs = tc.NameSpace
fmt.Printf("c.Namespace: %s\n", c.Namespace)
// for i, spec := range c.FieldSpecs {
// fmt.Printf("c.FieldSpecs[%d]: %s\n", i, spec.String())
// }
p := f()
err = kt.configureBuiltinPlugin(p, c, bpt)
if err != nil {
Expand Down

0 comments on commit f4008c0

Please sign in to comment.