create PR automation

cmd/command/plural/plural.go

@@ -253,7 +253,7 @@ func CreateNewApp(plural *Plural) *cli.App {
 		output.Command(),
 		ops.Command(plural.Plural),
 		profile.Command(),
-		pr.Command(),
+		pr.Command(plural.Plural),
 		proxy.Command(plural.Plural),
 		push.Command(plural.Plural),
 		repo.Command(plural.Plural),

cmd/command/pr/pr.go

@@ -1,21 +1,57 @@
 package pr
 
 import (
+	"io"
+	"os"
+
+	"github.com/pluralsh/plural-cli/pkg/client"
+	"github.com/pluralsh/plural-cli/pkg/common"
 	"github.com/pluralsh/plural-cli/pkg/pr"
+	"github.com/pluralsh/plural-cli/pkg/utils"
+	"github.com/samber/lo"
 	"github.com/urfave/cli"
 )
 
-func Command() cli.Command {
+func init() {
+	consoleToken = ""
+	consoleURL = ""
+}
+
+var consoleToken string
+var consoleURL string
+
+type Plural struct {
+	client.Plural
+}
+
+func Command(clients client.Plural) cli.Command {
+	p := Plural{
+		Plural: clients,
+	}
 	return cli.Command{
 		Name:        "pull-requests",
 		Aliases:     []string{"pr"},
 		Usage:       "Generate and manage pull requests",
-		Subcommands: prCommands(),
+		Subcommands: p.prCommands(),
 		Category:    "CD",
+		Flags: []cli.Flag{
+			cli.StringFlag{
+				Name:        "token",
+				Usage:       "console token",
+				EnvVar:      "PLURAL_CONSOLE_TOKEN",
+				Destination: &consoleToken,
+			},
+			cli.StringFlag{
+				Name:        "url",
+				Usage:       "console url address",
+				EnvVar:      "PLURAL_CONSOLE_URL",
+				Destination: &consoleURL,
+			},
+		},
 	}
 }
 
-func prCommands() []cli.Command {
+func (p *Plural) prCommands() []cli.Command {
 	return []cli.Command{
 		{
 			Name:   "template",
@@ -34,6 +70,16 @@ func prCommands() []cli.Command {
 				},
 			},
 		},
+		{
+			Name:      "create",
+			Action:    common.LatestVersion(common.RequireArgs(p.handleCreatePrAutomation, []string{"ID"})),
+			Usage:     "create PR automation",
+			ArgsUsage: "ID",
+			Flags: []cli.Flag{
+				cli.StringFlag{Name: "context", Usage: "JSON blob string"},
+				cli.StringFlag{Name: "branch", Usage: "branch name"},
+			},
+		},
 	}
 }
 
@@ -49,3 +95,33 @@ func handlePrTemplate(c *cli.Context) error {
 
 	return pr.Apply(template)
 }
+
+func (p *Plural) handleCreatePrAutomation(c *cli.Context) error {
+	if err := p.InitConsoleClient(consoleToken, consoleURL); err != nil {
+		return err
+	}
+	var branch, context *string
+
+	id := c.Args().Get(0)
+	if c := c.String("context"); c != "" {
+		if c == "-" {
+			bytes, err := io.ReadAll(os.Stdin)
+			if err != nil {
+				return err
+			}
+			context = lo.ToPtr(string(bytes))
+		}
+	}
+
+	if b := c.String("branch"); b != "" {
+		branch = &b
+	}
+
+	pr, err := p.ConsoleClient.CreatePullRequest(id, branch, context)
+	if err != nil {
+		return err
+	}
+
+	utils.Success("PR %s created successfully\n", pr.ID)
+	return nil
+}

go.mod

@@ -56,7 +56,7 @@ require (
 	github.com/packethost/packngo v0.29.0
 	github.com/pkg/browser v0.0.0-20210911075715-681adbf594b8
 	github.com/pluralsh/cluster-api-migration v0.2.16
-	github.com/pluralsh/console/go/client v1.4.0
+	github.com/pluralsh/console/go/client v1.5.0
 	github.com/pluralsh/gqlclient v1.12.1
 	github.com/pluralsh/plural-operator v0.5.5
 	github.com/pluralsh/polly v0.1.8

go.sum

@@ -1884,8 +1884,8 @@ github.com/pkg/sftp v1.13.6 h1:JFZT4XbOU7l77xGSpOdW+pwIMqP044IyjXX6FGyEKFo=
 github.com/pkg/sftp v1.13.6/go.mod h1:tz1ryNURKu77RL+GuCzmoJYxQczL3wLNNpPWagdg4Qk=
 github.com/pluralsh/cluster-api-migration v0.2.16 h1:MQGrLQAhGSSpyjEDamhnJZaQ8MkxlHzR8PZxIVavLIM=
 github.com/pluralsh/cluster-api-migration v0.2.16/go.mod h1:24PjMsYv3vSlUiYw7BeUQ0GAtK0Jk2B1iwh35WGQLx8=
-github.com/pluralsh/console/go/client v1.4.0 h1:Mr/gyU20jrLZZ9diEznv3aU/CJ5wk13qLes/4O9unwM=
-github.com/pluralsh/console/go/client v1.4.0/go.mod h1:lpoWASYsM9keNePS3dpFiEisUHEfObIVlSL3tzpKn8k=
+github.com/pluralsh/console/go/client v1.5.0 h1:O5pHJUXqBJWUt66MiCRlyatarNFQGy1Fy6QaC5P0avY=
+github.com/pluralsh/console/go/client v1.5.0/go.mod h1:lpoWASYsM9keNePS3dpFiEisUHEfObIVlSL3tzpKn8k=
 github.com/pluralsh/controller-reconcile-helper v0.0.4 h1:1o+7qYSyoeqKFjx+WgQTxDz4Q2VMpzprJIIKShxqG0E=
 github.com/pluralsh/controller-reconcile-helper v0.0.4/go.mod h1:AfY0gtteD6veBjmB6jiRx/aR4yevEf6K0M13/pGan/s=
 github.com/pluralsh/gqlclient v1.12.1 h1:JDOkP9jjqkPdTYdpH5hooG4F8T6FDH90XfipeXJmJFY=

pkg/console/console.go

@@ -54,6 +54,7 @@ type ConsoleClient interface {
 	UpdateDeploymentSettings(attr consoleclient.DeploymentSettingsAttributes) (*consoleclient.UpdateDeploymentSettings, error)
 	GetGlobalSettings() (*consoleclient.DeploymentSettingsFragment, error)
 	ListStackRuns(stackID string) (*consoleclient.ListStackRuns, error)
+	CreatePullRequest(id string, branch, context *string) (*consoleclient.PullRequestFragment, error)
 }
 
 type authedTransport struct {

pkg/console/pr.go

@@ -0,0 +1,15 @@
+package console
+
+import (
+	consoleclient "github.com/pluralsh/console/go/client"
+	"github.com/pluralsh/plural-cli/pkg/api"
+)
+
+func (c *consoleClient) CreatePullRequest(id string, branch, context *string) (*consoleclient.PullRequestFragment, error) {
+	result, err := c.client.CreatePullRequest(c.ctx, id, nil, branch, context)
+	if err != nil {
+		return nil, api.GetErrorResponse(err, "CreatePullRequest")
+	}
+
+	return result.CreatePullRequest, nil
+}