blob: 4f743a57e65d7f9586cb9c6fb0f6eb7d22eda026 [file] [log] [blame]
// Copyright 2018 The CUE Authors
//
// 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 cmd
// This file contains code or initializing and running custom commands.
import (
"context"
"encoding/json"
"io/ioutil"
"net/http"
"net/http/httptest"
"strings"
"sync"
"github.com/spf13/cobra"
"cuelang.org/go/cue"
"cuelang.org/go/cue/errors"
"cuelang.org/go/internal"
itask "cuelang.org/go/internal/task"
_ "cuelang.org/go/pkg/tool/cli" // Register tasks
_ "cuelang.org/go/pkg/tool/exec"
_ "cuelang.org/go/pkg/tool/file"
_ "cuelang.org/go/pkg/tool/http"
_ "cuelang.org/go/pkg/tool/os"
"cuelang.org/go/tools/flow"
)
const (
commandSection = "command"
)
func lookupString(obj cue.Value, key, def string) string {
str, err := obj.Lookup(key).String()
if err == nil {
def = str
}
return strings.TrimSpace(def)
}
// splitLine splits the first line and the rest of the string.
func splitLine(s string) (line, tail string) {
line = s
if p := strings.IndexByte(s, '\n'); p >= 0 {
line, tail = strings.TrimSpace(s[:p]), strings.TrimSpace(s[p+1:])
}
return
}
func addCustom(c *Command, parent *cobra.Command, typ, name string, tools *cue.Instance) (*cobra.Command, error) {
if tools == nil {
return nil, errors.New("no commands defined")
}
// TODO: validate allowing incomplete.
o := tools.Lookup(typ, name)
if !o.Exists() {
return nil, o.Err()
}
docs := o.Doc()
var usage, short, long string
if len(docs) > 0 {
txt := docs[0].Text()
short, txt = splitLine(txt)
short = lookupString(o, "short", short)
if strings.HasPrefix(txt, "Usage:") {
usage, txt = splitLine(txt[len("Usage:"):])
}
usage = lookupString(o, "usage", usage)
usage = lookupString(o, "$usage", usage)
long = lookupString(o, "long", txt)
}
if !strings.HasPrefix(usage, name+" ") {
usage = name
}
sub := &cobra.Command{
Use: usage,
Short: lookupString(o, "$short", short),
Long: lookupString(o, "$long", long),
RunE: mkRunE(c, func(cmd *Command, args []string) error {
// TODO:
// - parse flags and env vars
// - constrain current config with config section
return doTasks(cmd, typ, name, tools)
}),
}
parent.AddCommand(sub)
// TODO: implement var/flag handling.
return sub, nil
}
func doTasks(cmd *Command, typ, command string, root *cue.Instance) error {
cfg := &flow.Config{
Root: cue.MakePath(cue.Str(commandSection), cue.Str(command)),
InferTasks: true,
IgnoreConcrete: true,
}
c := flow.New(cfg, root, newTaskFunc(cmd))
err := c.Run(context.Background())
exitIfErr(cmd, root, err, true)
return err
}
// func (r *customRunner) tagReference(t *task, ref cue.Value) error {
// inst, path := ref.Reference()
// if len(path) == 0 {
// return errors.Newf(ref.Pos(),
// "$after must be a reference or list of references, found %s", ref)
// }
// if inst != r.root {
// return errors.Newf(ref.Pos(),
// "reference in $after must refer to value in same package")
// }
// // TODO: allow referring to group of tasks.
// if !r.tagDependencies(t, path) {
// return errors.Newf(ref.Pos(),
// "reference %s does not refer to task or task group",
// strings.Join(path, "."), // TODO: more correct representation.
// )
// }
// return nil
// }
func isTask(v cue.Value) bool {
// This mimics the v0.2 behavior. The cutoff is really quite arbitrary. A
// sane implementation should not use InferTasks, really.
if len(v.Path().Selectors()) == 0 {
return false
}
return v.Kind() == cue.StructKind &&
(v.Lookup("$id").Exists() || v.Lookup("kind").Exists())
}
var legacyKinds = map[string]string{
"exec": "tool/exec.Run",
"http": "tool/http.Do",
"print": "tool/cli.Print",
"testserver": "cmd/cue/cmd.Test",
}
func newTaskFunc(cmd *Command) flow.TaskFunc {
return func(v cue.Value) (flow.Runner, error) {
if !isTask(v) {
return nil, nil
}
kind, err := v.Lookup("$id").String()
if err != nil {
// Lookup kind for backwards compatibility.
// TODO: consider at some point whether kind can be removed.
var err1 error
kind, err1 = v.Lookup("kind").String()
if err1 != nil {
return nil, errors.Promote(err1, "newTask")
}
}
if k, ok := legacyKinds[kind]; ok {
kind = k
}
rf := itask.Lookup(kind)
if rf == nil {
return nil, errors.Newf(v.Pos(), "runner of kind %q not found", kind)
}
// Verify entry against template.
v = internal.UnifyBuiltin(v, kind).(cue.Value)
if err := v.Err(); err != nil {
return nil, errors.Promote(err, "newTask")
}
runner, err := rf(v)
if err != nil {
return nil, errors.Promote(err, "errors running task")
}
return flow.RunnerFunc(func(t *flow.Task) error {
c := &itask.Context{
Context: t.Context(),
Stdin: cmd.InOrStdin(),
Stdout: cmd.OutOrStdout(),
Stderr: cmd.OutOrStderr(),
Obj: t.Value(),
}
value, err := runner.Run(c)
if err != nil {
return err
}
if value != nil {
_ = t.Fill(value)
}
return nil
}), nil
}
}
func init() {
itask.Register("cmd/cue/cmd.Test", newTestServerCmd)
}
var testOnce sync.Once
func newTestServerCmd(v cue.Value) (itask.Runner, error) {
server := ""
testOnce.Do(func() {
s := httptest.NewServer(http.HandlerFunc(
func(w http.ResponseWriter, req *http.Request) {
data, _ := ioutil.ReadAll(req.Body)
d := map[string]interface{}{
"data": string(data),
"when": "now",
}
enc := json.NewEncoder(w)
_ = enc.Encode(d)
}))
server = s.URL
})
return testServerCmd(server), nil
}
type testServerCmd string
func (s testServerCmd) Run(ctx *itask.Context) (x interface{}, err error) {
return map[string]interface{}{"url": string(s)}, nil
}