Workflows Feature Branch (#215)

* Implement task orchestration api in the cli (#205)

* Generate task server

* Generate Render API types

* Generate workflow API client

* Add local task store

* Add client wrapper

* Add port finder

* Add coordinator

* Add callback server

* Add API server

* Add command

* add chi as dependency

* Make tasks and task runs internal

* [ref CAP-6689] Workflows & workflow versions (#209)

* Generated api schema

* List workflows and workflow versions, deploy new versions
- Logs are broken so deploying a new version shows broken logs
- Lots of todos incoming in next commit

* Updated todos with more actionable details and tickets

* Update reference to deploys as version

* Task listing

* added comment

* [CAP-7312] Implement TUI for starting a task (#208)

* [EXP-3146] Invalid timestamp message suggests a valid timestamp (#207)

`time.RFC3339` is not itself a valid timestamp, but only a valid format
string for timestamp parsing.

I've chosen to emit time.Now() in RFC-3339 rather than a fixed timestamp
because it will 1) emit in the user's timezone and 2) have an increased
chance of being closer to the time the user wants and therefore be
easier to edit.

* Add generated types

* Add command

* Add input-file

* Update generated types

* Integrate with task list CLI commands

---------

Co-authored-by: Dan Wendorf <github@danwendorf.com>

* [CAP-7471] Update cli to use updated sdk protocol (#212)

* Use unix sockets

* Update task server API

* Fix API server

* Exec user's command

* Get task by id or slug/name

* Update task command

* Intake input and output as any, but transmit them as json.RawMessage

* [CAP-7311] List task runs (#210)

* Added task runs

* clean up comments

* Remove local hack, can now list tasks

* [CAP-7542] Refactor CLI workflow commands (#213)

* Fix task run list

* Start dependencies

* stop using default client in workflow cmds

* move into workflow view folder

* Split out loader and types

* Move one more default client

* Move type

* Move interactive commands into flow package

* Move RunE into struct

* Update workflow prefix

* Force version selection

* Fix dependencies

* Fix task run list

* Only initialize once

* Update dependencies

* Update DI

* Move flows

* Remove Flow suffix

* Delete unused init code

* Clean up dependencies

* Comment remaining usage of dependencies in context

* [CAP-7542] Make CLI commands work with local dev server (#214)

* Add local flag

* Use the new `/tasks` endpoint

* Fix runs query

* [CAP-7489] CLI task run logs (#216)

* Move logs to flow

* Split out log loader

* Move set workspace into flow

* Handle options

* Use dependencies for loading resources

* Move resource selector out of log view

* Add logs to workflow CLI commands

* [CAP-7489] Local task run logs (#217)

* Keep logs in memory in dev mode

* Update apiserver to respond with logs

* Update local tasks to work with logs

* [CAP-7611] Task run details view (#218)

* Add task run result view

* Update task details styling

* [CAP-7619] Implement subtasking in the cli (#219)

* Add task run result view

* Update task details styling

* Implement subtasks in CLI

* [CAP-7622] Improve tailing logs locally (#222)

* Ensure old logs are delivered

* Specify start time before now to ensure we get all the logs for this task run

* Clean up channels when websocket is closed

* Update breadcrumbs (#220)

* Fix tests (#223)

* Better cli error handling for apiserver (#225)

* [CAP-7561] Update CLI to allow specifying ports (#226)

* Add SSE streaming

* Allow specifying port

* Update types

* Add logs in task run palette (#227)

* Put commands under early access (#228)

* Fix test

* Add login only client

* Fix for windows

* Fix logs in local mode

---------

Co-authored-by: Tucker Chapin <tuckerchapin@gmail.com>
Co-authored-by: Dan Wendorf <github@danwendorf.com>

Author: 3 people

cmd/deploycreate.go

@@ -10,9 +10,11 @@ import (
 
 	"github.com/render-oss/cli/pkg/client"
 	"github.com/render-oss/cli/pkg/command"
+	"github.com/render-oss/cli/pkg/dependencies"
 	"github.com/render-oss/cli/pkg/deploy"
 	"github.com/render-oss/cli/pkg/resource"
 	"github.com/render-oss/cli/pkg/text"
+	"github.com/render-oss/cli/pkg/tui/flows"
 	"github.com/render-oss/cli/pkg/tui/views"
 	"github.com/render-oss/cli/pkg/types"
 )
@@ -30,13 +32,14 @@ var deployCreateCmd = &cobra.Command{
 }
 
 var InteractiveDeployCreate = func(ctx context.Context, input types.DeployInput, breadcrumb string) tea.Cmd {
+	deps := dependencies.GetFromContext(ctx)
 	return command.AddToStackFunc(
 		ctx,
 		deployCreateCmd,
 		breadcrumb,
 		&input,
 		views.NewDeployCreateView(ctx, input, func(d *client.Deploy) tea.Cmd {
-			return TailResourceLogs(ctx, input.ServiceID)
+			return flows.NewLogFlow(deps).TailLogsFlow(ctx, input.ServiceID)
 		}))
 }
 

cmd/deploylist.go

@@ -10,9 +10,11 @@ import (
 	"github.com/render-oss/cli/pkg/client"
 	"github.com/render-oss/cli/pkg/command"
 	"github.com/render-oss/cli/pkg/dashboard"
+	"github.com/render-oss/cli/pkg/dependencies"
 	"github.com/render-oss/cli/pkg/deploy"
 	"github.com/render-oss/cli/pkg/resource"
 	"github.com/render-oss/cli/pkg/text"
+	"github.com/render-oss/cli/pkg/tui/flows"
 	"github.com/render-oss/cli/pkg/tui/views"
 )
 
@@ -23,11 +25,12 @@ var deployListCmd = &cobra.Command{
 }
 
 var InteractiveDeployList = func(ctx context.Context, input views.DeployListInput, r resource.Resource, breadcrumb string) tea.Cmd {
+	deps := dependencies.GetFromContext(ctx)
 	return command.AddToStackFunc(ctx, deployListCmd, breadcrumb, &input, views.NewDeployListView(
 		ctx,
 		input,
 		func(c *client.Deploy) tea.Cmd {
-			return InteractivePalette(ctx, commandsForDeploy(c, r.ID(), r.Type()), c.Id)
+			return InteractivePalette(ctx, commandsForDeploy(deps, c, r.ID(), r.Type()), c.Id)
 		},
 	))
 }
@@ -55,7 +58,7 @@ func interactiveDeployList(cmd *cobra.Command, input views.DeployListInput) tea.
 	return InteractiveDeployList(ctx, input, service, "Deploys for "+resource.BreadcrumbForResource(service))
 }
 
-func commandsForDeploy(dep *client.Deploy, serviceID, serviceType string) []views.PaletteCommand {
+func commandsForDeploy(deps *dependencies.Dependencies, dep *client.Deploy, serviceID, serviceType string) []views.PaletteCommand {
 	var startTime *command.TimeOrRelative
 	if dep.CreatedAt != nil {
 		startTime = &command.TimeOrRelative{T: dep.CreatedAt}
@@ -71,15 +74,14 @@ func commandsForDeploy(dep *client.Deploy, serviceID, serviceType string) []view
 			Name:        "logs",
 			Description: "View deploy logs",
 			Action: func(ctx context.Context, args []string) tea.Cmd {
-				return InteractiveLogs(
+				return flows.NewLogFlow(deps).LogsFlow(
 					ctx,
 					views.LogInput{
 						ResourceIDs: []string{serviceID},
 						StartTime:   startTime,
 						EndTime:     endTime,
 						Direction:   "forward",
 					},
-					"Logs",
 				)
 			},
 		},

cmd/earlyaccess.go

@@ -0,0 +1,15 @@
+package cmd
+
+import (
+	"github.com/spf13/cobra"
+)
+
+var EarlyAccessCmd = &cobra.Command{
+	Use:   "ea",
+	Short: "Early access commands",
+	Long:  `These commands are in early access and are subject to change.`,
+}
+
+func init() {
+	rootCmd.AddCommand(EarlyAccessCmd)
+}

cmd/environment.go

@@ -11,6 +11,7 @@ import (
 	"github.com/render-oss/cli/pkg/project"
 	"github.com/render-oss/cli/pkg/text"
 	"github.com/render-oss/cli/pkg/tui"
+	"github.com/render-oss/cli/pkg/tui/flows"
 	"github.com/render-oss/cli/pkg/tui/views"
 )
 
@@ -31,8 +32,8 @@ var InteractiveEnvironment = func(ctx context.Context, input views.EnvironmentIn
 			}, e.Name)
 		},
 		tui.WithCustomOptions[*client.Environment]([]tui.CustomOption{
-			WithCopyID(ctx, servicesCmd),
-			WithWorkspaceSelection(ctx),
+			flows.WithCopyID(ctx, servicesCmd),
+			flows.WithWorkspaceSelection(ctx),
 		}),
 	))
 }

cmd/jobcreate.go

@@ -10,8 +10,10 @@ import (
 	"github.com/render-oss/cli/pkg/client"
 	clientjob "github.com/render-oss/cli/pkg/client/jobs"
 	"github.com/render-oss/cli/pkg/command"
+	"github.com/render-oss/cli/pkg/dependencies"
 	"github.com/render-oss/cli/pkg/resource"
 	"github.com/render-oss/cli/pkg/text"
+	"github.com/render-oss/cli/pkg/tui/flows"
 	"github.com/render-oss/cli/pkg/tui/views"
 )
 
@@ -22,16 +24,17 @@ var JobCreateCmd = &cobra.Command{
 }
 
 var InteractiveJobCreate = func(ctx context.Context, input *views.JobCreateInput, breadcrumb string) tea.Cmd {
+	deps := dependencies.GetFromContext(ctx)
 	return command.AddToStackFunc(
 		ctx,
 		JobCreateCmd,
 		breadcrumb,
 		input,
 		views.NewJobCreateView(ctx, input, JobCreateCmd, views.CreateJob, func(j *clientjob.Job) tea.Cmd {
-			return InteractiveLogs(ctx, views.LogInput{
+			return flows.NewLogFlow(deps).LogsFlow(ctx, views.LogInput{
 				ResourceIDs: []string{j.Id},
 				Tail:        true,
-			}, "Logs")
+			})
 		}),
 	)
 }

cmd/joblist.go

@@ -10,9 +10,11 @@ import (
 	"github.com/render-oss/cli/pkg/client"
 	clientjob "github.com/render-oss/cli/pkg/client/jobs"
 	"github.com/render-oss/cli/pkg/command"
+	"github.com/render-oss/cli/pkg/dependencies"
 	"github.com/render-oss/cli/pkg/job"
 	"github.com/render-oss/cli/pkg/resource"
 	"github.com/render-oss/cli/pkg/text"
+	"github.com/render-oss/cli/pkg/tui/flows"
 	"github.com/render-oss/cli/pkg/tui/views"
 )
 
@@ -23,10 +25,11 @@ var jobListCmd = &cobra.Command{
 }
 
 var InteractiveJobList = func(ctx context.Context, input views.JobListInput, breadcrumb string) tea.Cmd {
+	deps := dependencies.GetFromContext(ctx)
 	return command.AddToStackFunc(ctx, jobListCmd, breadcrumb, &views.ProjectInput{}, views.NewJobListView(ctx,
 		&input,
 		func(j *clientjob.Job) tea.Cmd {
-			return InteractivePalette(ctx, commandsForJob(j), j.Id)
+			return InteractivePalette(ctx, commandsForJob(deps, j), j.Id)
 		},
 	))
 }
@@ -58,7 +61,7 @@ func interactiveJobList(cmd *cobra.Command, input views.JobListInput) tea.Cmd {
 	return InteractiveJobList(ctx, input, "Jobs for "+resource.BreadcrumbForResource(service))
 }
 
-func commandsForJob(j *clientjob.Job) []views.PaletteCommand {
+func commandsForJob(deps *dependencies.Dependencies, j *clientjob.Job) []views.PaletteCommand {
 	var startTime *command.TimeOrRelative
 	if j.StartedAt != nil {
 		startTime = &command.TimeOrRelative{T: j.StartedAt}
@@ -74,14 +77,13 @@ func commandsForJob(j *clientjob.Job) []views.PaletteCommand {
 			Name:        "logs",
 			Description: "View job logs",
 			Action: func(ctx context.Context, args []string) tea.Cmd {
-				return InteractiveLogs(
+				return flows.NewLogFlow(deps).LogsFlow(
 					ctx,
 					views.LogInput{
 						ResourceIDs: []string{j.Id},
 						StartTime:   startTime,
 						EndTime:     endTime,
 					},
-					"Logs",
 				)
 			},
 		},

cmd/kvcli.go

@@ -10,6 +10,7 @@ import (
 	"github.com/render-oss/cli/pkg/command"
 	"github.com/render-oss/cli/pkg/keyvalue"
 	"github.com/render-oss/cli/pkg/tui"
+	"github.com/render-oss/cli/pkg/tui/flows"
 	"github.com/render-oss/cli/pkg/tui/views"
 )
 
@@ -34,9 +35,9 @@ func InteractiveKeyValueCLIView(ctx context.Context, input *views.RedisCLIInput)
 
 func getRedisTableOptions(ctx context.Context, input *views.RedisCLIInput) []tui.CustomOption {
 	return []tui.CustomOption{
-		WithCopyID(ctx, servicesCmd),
-		WithWorkspaceSelection(ctx),
-		WithProjectFilter(ctx, redisCLICmd, "redisCLI", input, func(ctx context.Context, project *client.Project) tea.Cmd {
+		flows.WithCopyID(ctx, servicesCmd),
+		flows.WithWorkspaceSelection(ctx),
+		flows.WithProjectFilter(ctx, redisCLICmd, "redisCLI", input, func(ctx context.Context, project *client.Project) tea.Cmd {
 			if project != nil {
 				input.EnvironmentIDs = project.EnvironmentIds
 			}