Skip to content

Commit

Permalink
Pipeline: Preliminary implementation
Browse files Browse the repository at this point in the history
Signed-off-by: Richard Kosegi <richard.kosegi@gmail.com>
  • Loading branch information
rkosegi committed Jun 11, 2024
1 parent 6a2d201 commit c6139a1
Show file tree
Hide file tree
Showing 20 changed files with 1,765 additions and 0 deletions.
1 change: 1 addition & 0 deletions go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@ module github.com/rkosegi/yaml-toolkit
go 1.21

require (
github.com/go-task/slim-sprig/v3 v3.0.0
github.com/google/go-cmp v0.6.0
github.com/magiconair/properties v1.8.7
github.com/stretchr/testify v1.9.0
Expand Down
2 changes: 2 additions & 0 deletions go.sum
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E=
github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
github.com/go-task/slim-sprig/v3 v3.0.0 h1:sUs3vkvUymDpBKi3qH1YSqBQk9+9D/8M2mN1vB6EwHI=
github.com/go-task/slim-sprig/v3 v3.0.0/go.mod h1:W848ghGpv3Qj3dhTPRyJypKRiqCdHZiAzKg9hl15HA8=
github.com/google/go-cmp v0.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI=
github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
github.com/kr/pretty v0.2.1 h1:Fmg33tUaq4/8ym9TJN1x7sLJnHVwhP33CNkpYV/7rwI=
Expand Down
192 changes: 192 additions & 0 deletions pipeline/actions.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,192 @@
/*
Copyright 2024 Richard Kosegi
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/

package pipeline

import (
"bytes"
"encoding/base64"
"fmt"
"github.com/rkosegi/yaml-toolkit/dom"
"github.com/rkosegi/yaml-toolkit/patch"
"github.com/rkosegi/yaml-toolkit/props"
)

func (am ActionMeta) String() string {
return fmt.Sprintf("[name=%s,order=%d,when=%s]", am.Name, am.Order, safeStrDeref(am.When))
}

func (s ActionSpec) CloneWith(ctx ActionContext) Action {
return ActionSpec{
ActionMeta: s.ActionMeta,
Operations: s.Operations.CloneWith(ctx).(OpSpec),
Children: s.Children.CloneWith(ctx).(ChildActions),
}
}

func (s ActionSpec) String() string {
return fmt.Sprintf("ActionSpec[meta=%v]", s.ActionMeta)
}

func (s ActionSpec) Do(ctx ActionContext) error {
for _, a := range []Action{s.Operations, s.Children} {
if s.When != nil {
if ok, err := ctx.TemplateEngine().EvalBool(*s.When, ctx.Snapshot()); err != nil {
return err
} else if !ok {
return nil
}
}
err := ctx.Executor().Execute(a)
if err != nil {
return err
}
}
return nil
}

func (pfm ParseFileMode) toValue(content []byte) (dom.Node, error) {
switch pfm {
case ParseFileModeBinary:
return dom.LeafNode(base64.StdEncoding.EncodeToString(content)), nil
case ParseFileModeText:
return dom.LeafNode(string(content)), nil
case ParseFileModeYaml:
return b.FromReader(bytes.NewReader(content), dom.DefaultYamlDecoder)
case ParseFileModeJson:
return b.FromReader(bytes.NewReader(content), dom.DefaultJsonDecoder)
case ParseFileModeProperties:
return b.FromReader(bytes.NewReader(content), props.DecoderFn)
default:
return nil, fmt.Errorf("invalid ParseFileMode: %v", pfm)
}
}

func (ia *ImportOp) String() string {
return fmt.Sprintf("Import[file=%s,path=%s,mode=%s]", ia.File, ia.Path, ia.Mode)
}

func (ia *ImportOp) Do(ctx ActionContext) error {
val, err := parseFile(ia.File, ia.Mode)
if err != nil {
return err
}
if len(ia.Path) > 0 {
ctx.Data().AddValueAt(ia.Path, val)
} else {
if !val.IsContainer() {
return ErrNotContainer
} else {
for k, v := range val.(dom.Container).Children() {
ctx.Data().AddValueAt(k, v)
}
}
}
return nil
}

func (ia *ImportOp) CloneWith(ctx ActionContext) Action {
return &ImportOp{
Mode: ia.Mode,
Path: ctx.TemplateEngine().RenderLenient(ia.Path, ctx.Snapshot()),
File: ctx.TemplateEngine().RenderLenient(ia.File, ctx.Snapshot()),
}
}

func (ps *PatchOp) String() string {
return fmt.Sprintf("Patch[Op=%s,Path=%s]", ps.Op, ps.Path)
}

func (ps *PatchOp) Do(ctx ActionContext) error {
oo := &patch.OpObj{
Op: ps.Op,
}
path, err := patch.ParsePath(ps.Path)
if err != nil {
return err
}
oo.Path = path
oo.Value = b.FromMap(ps.Value)
if len(ps.From) > 0 {
from, err := patch.ParsePath(ps.From)
if err != nil {
return err
}
oo.From = &from
}
return patch.Do(oo, ctx.Data())
}

func (ps *PatchOp) CloneWith(ctx ActionContext) Action {
return &PatchOp{
Op: ps.Op,
Value: ps.Value,
From: ctx.TemplateEngine().RenderLenient(ps.From, ctx.Snapshot()),
Path: ctx.TemplateEngine().RenderLenient(ps.Path, ctx.Snapshot()),
}
}

func (sa *SetOp) String() string {
return fmt.Sprintf("Set[Path=%s]", sa.Path)
}

func (sa *SetOp) Do(ctx ActionContext) error {
gd := ctx.Data()
if sa.Data == nil {
return ErrNoDataToSet
}
data := ctx.Factory().FromMap(sa.Data)
if len(sa.Path) > 0 {
gd.AddValueAt(sa.Path, data)
} else {
for k, v := range data.Children() {
gd.AddValueAt(k, v)
}
}
return nil
}

func (sa *SetOp) CloneWith(ctx ActionContext) Action {
return &SetOp{
Data: sa.Data,
Path: ctx.TemplateEngine().RenderLenient(sa.Path, ctx.Snapshot()),
}
}

func (ts *TemplateOp) String() string {
return fmt.Sprintf("Template[WriteTo=%s]", ts.WriteTo)
}

func (ts *TemplateOp) Do(ctx ActionContext) error {
if len(ts.Template) == 0 {
return ErrTemplateEmpty
}
if len(ts.WriteTo) == 0 {
return ErrWriteToEmpty
}
val, err := ctx.TemplateEngine().Render(ts.Template, map[string]interface{}{
"Data": ctx.Snapshot(),
})
ctx.Data().AddValueAt(ts.WriteTo, dom.LeafNode(val))
return err
}

func (ts *TemplateOp) CloneWith(ctx ActionContext) Action {
return &TemplateOp{
Template: ts.Template,
WriteTo: ctx.TemplateEngine().RenderLenient(ts.WriteTo, ctx.Snapshot()),
}
}
Loading

0 comments on commit c6139a1

Please sign in to comment.