[ND-7649] - add pipeline jobs command

Author: mihaichitic

cmd/pipeline/jobs.go

@@ -0,0 +1,40 @@
+package pipeline
+
+import (
+	"bunnyshell.com/cli/pkg/api/workflow_job"
+	"bunnyshell.com/cli/pkg/lib"
+	"github.com/spf13/cobra"
+)
+
+func init() {
+	listOptions := workflow_job.NewListOptions()
+
+	var pipelineID string
+	var jobStatuses []string
+
+	command := &cobra.Command{
+		Use: "jobs",
+
+		Short: "List jobs in a pipeline",
+
+		ValidArgsFunction: cobra.NoFileCompletions,
+
+		RunE: func(cmd *cobra.Command, args []string) error {
+			listOptions.Workflow = pipelineID
+			listOptions.Status = jobStatuses
+
+			return lib.ShowCollection(cmd, listOptions, func() (lib.ModelWithPagination, error) {
+				return workflow_job.List(listOptions)
+			})
+		},
+	}
+
+	flags := command.Flags()
+
+	flags.AddFlag(getIDOption(&pipelineID).GetRequiredFlag("id"))
+	flags.StringArrayVar(&jobStatuses, "jobStatus", jobStatuses, "Filter by Job Status (repeatable)")
+
+	listOptions.UpdateFlagSet(flags)
+
+	mainCmd.AddCommand(command)
+}

pkg/api/workflow_job/list.go

@@ -0,0 +1,68 @@
+package workflow_job
+
+import (
+	"net/http"
+
+	"bunnyshell.com/cli/pkg/api"
+	"bunnyshell.com/cli/pkg/api/common"
+	"bunnyshell.com/cli/pkg/lib"
+	"bunnyshell.com/sdk"
+	"github.com/spf13/pflag"
+)
+
+type ListOptions struct {
+	common.ListOptions
+
+	Workflow string
+	Status   []string
+}
+
+func NewListOptions() *ListOptions {
+	return &ListOptions{
+		ListOptions: *common.NewListOptions(),
+	}
+}
+
+func (lo *ListOptions) UpdateFlagSet(flags *pflag.FlagSet) {
+	lo.ListOptions.UpdateFlagSet(flags)
+}
+
+func List(options *ListOptions) (*sdk.PaginatedWorkflowJobCollection, error) {
+	model, resp, err := ListRaw(options)
+	if err != nil {
+		return nil, api.ParseError(resp, err)
+	}
+
+	return model, nil
+}
+
+func ListRaw(options *ListOptions) (*sdk.PaginatedWorkflowJobCollection, *http.Response, error) {
+	profile := options.GetProfile()
+
+	ctx, cancel := lib.GetContextFromProfile(profile)
+	defer cancel()
+
+	request := lib.GetAPIFromProfile(profile).WorkflowJobAPI.WorkflowJobList(ctx)
+
+	return applyOptions(request, options).Execute()
+}
+
+func applyOptions(request sdk.ApiWorkflowJobListRequest, options *ListOptions) sdk.ApiWorkflowJobListRequest {
+	if options == nil {
+		return request
+	}
+
+	if options.Workflow != "" {
+		request = request.Workflow(options.Workflow)
+	}
+
+	if options.Page > 1 {
+		request = request.Page(options.Page)
+	}
+
+	if len(options.Status) > 0 {
+		request = request.Status(options.Status)
+	}
+
+	return request
+}

pkg/formatter/stylish.go

@@ -38,6 +38,8 @@ func stylish(data interface{}) ([]byte, error) {
 		tabulateKubernetesCollection(writer, dataType)
 	case *sdk.PaginatedPipelineCollection:
 		tabulatePipelineCollection(writer, dataType)
+	case *sdk.PaginatedWorkflowJobCollection:
+		tabulateWorkflowJobCollection(writer, dataType)
 	case *sdk.PaginatedComponentGitCollection:
 		tabulateComponentGitCollection(writer, dataType)
 	case []sdk.ComponentGitCollection:

pkg/formatter/stylish.workflow_job.go

@@ -0,0 +1,56 @@
+package formatter
+
+import (
+	"fmt"
+	"text/tabwriter"
+	"time"
+
+	"bunnyshell.com/sdk"
+)
+
+func tabulateWorkflowJobCollection(writer *tabwriter.Writer, data *sdk.PaginatedWorkflowJobCollection) {
+	fmt.Fprintf(
+		writer,
+		"%v\t %v\t %v\t %v\t %v\t %v\t %v\t %v\n",
+		"JobID",
+		"PipelineID",
+		"Name",
+		"Type",
+		"Status",
+		"StartedAt",
+		"Duration",
+		"AllowedToFail",
+	)
+
+	if data.Embedded != nil {
+		for _, item := range data.Embedded.Item {
+			duration := ""
+			if value, ok := item.GetDurationOk(); ok && value != nil {
+				duration = (time.Duration(*value) * time.Second).String()
+			}
+
+			allowedToFail := ""
+			if value, ok := item.GetAllowedToFailOk(); ok && value != nil {
+				allowedToFail = fmt.Sprintf("%t", *value)
+			}
+
+			startedAt := ""
+			if value, ok := item.GetStartedAtOk(); ok && value != nil {
+				startedAt = value.Format(time.RFC3339)
+			}
+
+			fmt.Fprintf(
+				writer,
+				"%v\t %v\t %v\t %v\t %v\t %v\t %v\t %v\n",
+				item.GetId(),
+				item.GetWorkflow(),
+				item.GetName(),
+				item.GetType(),
+				item.GetStatus(),
+				startedAt,
+				duration,
+				allowedToFail,
+			)
+		}
+	}
+}