starts pipeline with new resource

start pipeline shows the list of resources available in
the namespace, also adds an option in the last to create
new resource on the go

start pipeline directly jumps to create resource flow if
there are no resource found in the namespace

Signed-off-by: Pradeep Kumar <pradkuma@redhat.com>

pkg/cmd/pipeline/start.go

@@ -24,6 +24,7 @@ import (
 	"github.com/AlecAivazis/survey/v2/terminal"
 	"github.com/spf13/cobra"
 	"github.com/tektoncd/cli/pkg/cli"
+	"github.com/tektoncd/cli/pkg/cmd/pipelineresource"
 	"github.com/tektoncd/cli/pkg/cmd/pipelinerun"
 	"github.com/tektoncd/cli/pkg/flags"
 	"github.com/tektoncd/cli/pkg/helper/labels"
@@ -195,14 +196,26 @@ func (opt *startOptions) getInput(pname string) error {
 }
 
 func (opt *startOptions) getInputResources(resources resourceOptionsFilter, pipeline *v1alpha1.Pipeline) error {
-	var ans string
 	for _, res := range pipeline.Spec.Resources {
 		options := getOptionsByType(resources, string(res.Type))
+		// directly create resource
 		if len(options) == 0 {
-			return fmt.Errorf("no pipeline resource of type %s found in namespace: %s",
-				string(res.Type), opt.cliparams.Namespace())
+			ns := opt.cliparams.Namespace()
+			fmt.Fprintf(opt.stream.Out, "no pipeline resource of type \"%s\" found in namespace: %s\n", string(res.Type), ns)
+			fmt.Fprintf(opt.stream.Out, "please create new \"%s\" resource\n", string(res.Type))
+			newres, err := opt.createPipelineResource(res.Name, res.Type)
+			if err != nil {
+				return err
+			}
+			fmt.Printf("resource status %s\n\n", newres.Status)
+			opt.Resources = append(opt.Resources, res.Name+"="+newres.Name)
+			return nil
 		}
 
+		// shows create option in the resource list
+		resCreateOpt := fmt.Sprintf("create new \"%s\" resource", res.Type)
+		options = append(options, resCreateOpt)
+		var ans string
 		var qs = []*survey.Question{
 			{
 				Name: "pipelineresource",
@@ -218,8 +231,16 @@ func (opt *startOptions) getInputResources(resources resourceOptionsFilter, pipe
 			return err
 		}
 
-		name := strings.TrimSpace(strings.Split(ans, " ")[0])
-		opt.Resources = append(opt.Resources, res.Name+"="+name)
+		if ans == resCreateOpt {
+			newres, err := opt.createPipelineResource(res.Name, res.Type)
+			if err != nil {
+				return err
+			}
+			opt.Resources = append(opt.Resources, res.Name+"="+newres.Name)
+		} else {
+			name := strings.TrimSpace(strings.Split(ans, " ")[0])
+			opt.Resources = append(opt.Resources, res.Name+"="+name)
+		}
 	}
 	return nil
 }
@@ -525,3 +546,40 @@ func parseDeprecatedTaskSvc(s []string) (map[string]v1alpha1.DeprecatedPipelineR
 	}
 	return svcs, nil
 }
+
+func (opt *startOptions) createPipelineResource(resName string, resType v1alpha1.PipelineResourceType) (*v1alpha1.PipelineResource, error) {
+	res := pipelineresource.Resource{
+		AskOpts: opt.askOpts,
+		Params:  opt.cliparams,
+		PipelineResource: v1alpha1.PipelineResource{
+			ObjectMeta: v1.ObjectMeta{Namespace: opt.cliparams.Namespace()},
+			Spec:       v1alpha1.PipelineResourceSpec{Type: resType},
+		}}
+
+	if err := res.AskMeta(); err != nil {
+		return nil, err
+	}
+
+	resourceTypeParams := map[v1alpha1.PipelineResourceType]func() error{
+		v1alpha1.PipelineResourceTypeGit:         res.AskGitParams,
+		v1alpha1.PipelineResourceTypeStorage:     res.AskStorageParams,
+		v1alpha1.PipelineResourceTypeImage:       res.AskImageParams,
+		v1alpha1.PipelineResourceTypeCluster:     res.AskClusterParams,
+		v1alpha1.PipelineResourceTypePullRequest: res.AskPullRequestParams,
+	}
+	if res.PipelineResource.Spec.Type != "" {
+		if err := resourceTypeParams[res.PipelineResource.Spec.Type](); err != nil {
+			return nil, err
+		}
+	}
+	cs, err := opt.cliparams.Clients()
+	if err != nil {
+		return nil, err
+	}
+	newRes, err := cs.Tekton.TektonV1alpha1().PipelineResources(opt.cliparams.Namespace()).Create(&res.PipelineResource)
+	if err != nil {
+		return nil, err
+	}
+	fmt.Fprintf(opt.stream.Out, "New %s resource \"%s\" has been created\n", newRes.Spec.Type, newRes.Name)
+	return newRes, nil
+}