This repository has been archived on 2024-04-08. You can view files and clone it, but cannot push or open issues or pull requests.
dagger/plan/task/writefile.go
Vasek - Tom C fd6d1b55fe
Rename mode to permissions in fs.cue
Signed-off-by: Vasek - Tom C <tom.chauveau@epitech.eu>
2021-12-22 14:59:55 +01:00

90 lines
1.7 KiB
Go

package task
import (
"context"
"fmt"
"io/fs"
"cuelang.org/go/cue"
"github.com/moby/buildkit/client/llb"
"go.dagger.io/dagger/compiler"
"go.dagger.io/dagger/plancontext"
"go.dagger.io/dagger/solver"
)
func init() {
Register("WriteFile", func() Task { return &writeFileTask{} })
}
type writeFileTask struct {
}
func (t *writeFileTask) Run(ctx context.Context, pctx *plancontext.Context, s solver.Solver, v *compiler.Value) (*compiler.Value, error) {
var contents []byte
var err error
path, err := v.Lookup("path").String()
if err != nil {
return nil, err
}
switch kind := v.Lookup("contents").Kind(); kind {
// TODO: support bytes?
// case cue.BytesKind:
// contents, err = v.Lookup("contents").Bytes()
case cue.StringKind:
var str string
str, err = v.Lookup("contents").String()
if err == nil {
contents = []byte(str)
}
case cue.BottomKind:
err = fmt.Errorf("%s: WriteFile contents is not set", path)
default:
err = fmt.Errorf("%s: unhandled data type in WriteFile: %s", path, kind)
}
if err != nil {
return nil, err
}
permissions, err := v.Lookup("permissions").Int64()
if err != nil {
return nil, err
}
input, err := pctx.FS.FromValue(v.Lookup("input"))
if err != nil {
return nil, err
}
inputState, err := input.State()
if err != nil {
return nil, err
}
outputState := inputState.File(
llb.Mkfile(path, fs.FileMode(permissions), contents),
withCustomName(v, "WriteFile %s", path),
)
result, err := s.Solve(ctx, outputState, pctx.Platform.Get())
if err != nil {
return nil, err
}
outputFS := pctx.FS.New(result)
output := compiler.NewValue()
if err := output.FillPath(cue.ParsePath("output"), outputFS.MarshalCUE()); err != nil {
return nil, err
}
return output, nil
}