flow: add convenience field "run" to os.Exec

Author: Tony Worm

flow/tasks/os/embed.go

@@ -10,13 +10,14 @@ import (
 //go:embed schema.cue
 var task_schema string
 
-var task_chan cue.Value
-var task_send cue.Value
-var task_recv cue.Value
+var task_exec cue.Value
+// var task_chan cue.Value
+// var task_send cue.Value
+// var task_recv cue.Value
 var task_watch cue.Value
 
 func init_schemas(ctx *cue.Context) {
-	if task_chan.Exists() {
+	if task_exec.Exists() {
 		return
 	}
 
@@ -26,19 +27,24 @@ func init_schemas(ctx *cue.Context) {
 		panic("should not have a schema error")
 	}
 
-	task_chan = val.LookupPath(cue.ParsePath("Chan"))
-	if !task_chan.Exists() {
-		panic("missing flow/tasks/csp.Chan schema")
-	}
-	task_send = val.LookupPath(cue.ParsePath("Send"))
-	if !task_send.Exists() {
-		panic("missing flow/tasks/csp.Send schema")
-	}
-	task_recv = val.LookupPath(cue.ParsePath("Recv"))
-	if !task_recv.Exists() {
-		panic("missing flow/tasks/csp.Recv schema")
+	task_exec = val.LookupPath(cue.ParsePath("Exec"))
+	if !task_exec.Exists() {
+		panic("missing flow/tasks/os.Exec schema")
 	}
 
+	// task_chan = val.LookupPath(cue.ParsePath("Chan"))
+	// if !task_chan.Exists() {
+	// 	panic("missing flow/tasks/csp.Chan schema")
+	// }
+	// task_send = val.LookupPath(cue.ParsePath("Send"))
+	// if !task_send.Exists() {
+	// 	panic("missing flow/tasks/csp.Send schema")
+	// }
+	// task_recv = val.LookupPath(cue.ParsePath("Recv"))
+	// if !task_recv.Exists() {
+	// 	panic("missing flow/tasks/csp.Recv schema")
+	// }
+
 	task_watch = val.LookupPath(cue.ParsePath("Watch"))
 	if !task_watch.Exists() {
 		panic("missing flow/tasks/fs.Watch schema")

flow/tasks/os/exec.go

@@ -11,6 +11,7 @@ import (
 	"cuelang.org/go/cue"
 
 	hofcontext "github.com/hofstadter-io/hof/flow/context"
+	"github.com/hofstadter-io/hof/lib/cuetils"
 )
 
 type Exec struct{}
@@ -24,6 +25,12 @@ func (T *Exec) Run(ctx *hofcontext.Context) (interface{}, error) {
 	v := ctx.Value
 	var cmd *exec.Cmd
 
+	init_schemas(v.Context())
+	// unify with schema
+	v = v.Unify(task_exec)
+	if v.Err() != nil {
+		return nil, cuetils.ExpandCueError(v.Err())
+	}
 	// TODO, rework how i/o works for exec
 
 	// todo, check failure modes, fill, not return error?

flow/tasks/os/schema.cue

@@ -1,10 +1,18 @@
 package os
 
+import "strings"
+
 Exec: {
 	@task(os.Exec)
 
+	// the command to run
 	cmd: string | [string, ...string]
 
+	run?: string
+	if run != _|_ {
+		cmd: strings.Split(run, " ")
+	}
+
 	// dir specifies the working directory of the command.
 	// The default is the current working directory.
 	dir?: string
@@ -13,7 +21,7 @@ Exec: {
 	// If the value is a list, the entries mus be of the form key=value,
 	// where the last value takes precedence in the case of multiple
 	// occurrences of the same key.
-	env: {[string]: string} | [...=~"="]
+	env?: {[string]: string} | [...=~"="]
 
 	// stdout captures the output from stdout if it is of type bytes or string.
 	// The default value of null indicates it is redirected to the stdout of the