Enveloop CLI commands

gql/schema.graphql

@@ -347,6 +347,11 @@ type AddOnProvider {
 }
 
 enum AddOnType {
+  """
+  An Enveloop team
+  """
+  enveloop
+
   """
   A Kubernetes cluster
   """

internal/command/extensions/enveloop/create.go

@@ -0,0 +1,68 @@
+package enveloop
+
+import (
+	"context"
+
+	"github.com/spf13/cobra"
+	"github.com/superfly/flyctl/gql"
+	"github.com/superfly/flyctl/internal/appconfig"
+	"github.com/superfly/flyctl/internal/command"
+	extensions_core "github.com/superfly/flyctl/internal/command/extensions/core"
+	"github.com/superfly/flyctl/internal/command/orgs"
+	"github.com/superfly/flyctl/internal/command/secrets"
+	"github.com/superfly/flyctl/internal/flag"
+)
+
+func create() (cmd *cobra.Command) {
+	const (
+		short = "Provision an Enveloop team"
+		long  = short + "\n"
+	)
+
+	cmd = command.New("create", short, long, runCreate, command.RequireSession, command.LoadAppNameIfPresent)
+	flag.Add(cmd,
+		flag.App(),
+		flag.AppConfig(),
+		flag.Org(),
+		extensions_core.SharedFlags,
+		SharedFlags,
+		flag.String{
+			Name:        "name",
+			Shorthand:   "n",
+			Description: "The name of your AddOn",
+		},
+	)
+	return cmd
+}
+
+func runCreate(ctx context.Context) (err error) {
+	appName := appconfig.NameFromContext(ctx)
+	params := extensions_core.ExtensionParams{}
+
+	if appName != "" {
+		params.AppName = appName
+	} else {
+		org, err := orgs.OrgFromFlagOrSelect(ctx)
+		if err != nil {
+			return err
+		}
+
+		params.Organization = org
+	}
+
+	var options gql.AddOnOptions
+
+	params.Options = options
+	params.PlanID = "starter" // starter is the only plan for now
+	params.Provider = "enveloop"
+	extension, err := extensions_core.ProvisionExtension(ctx, params)
+	if err != nil {
+		return err
+	}
+
+	if extension.SetsSecrets {
+		err = secrets.DeploySecrets(ctx, gql.ToAppCompact(*extension.App), false, false)
+	}
+
+	return err
+}

internal/command/extensions/enveloop/dashboard.go

@@ -0,0 +1,46 @@
+package enveloop
+
+import (
+	"context"
+
+	"github.com/spf13/cobra"
+	"github.com/superfly/flyctl/gql"
+	"github.com/superfly/flyctl/internal/command"
+	extensions_core "github.com/superfly/flyctl/internal/command/extensions/core"
+	"github.com/superfly/flyctl/internal/flag"
+)
+
+func dashboard() (cmd *cobra.Command) {
+	const (
+		long = `Visit the Enveloop dashboard`
+
+		short = long
+		usage = "dashboard [database_name]"
+	)
+
+	cmd = command.New(usage, short, long, runDashboard, command.RequireSession, command.LoadAppNameIfPresent)
+
+	flag.Add(cmd,
+		flag.App(),
+		flag.AppConfig(),
+		flag.Org(),
+		extensions_core.SharedFlags,
+	)
+	// cmd.Args = cobra.NoArgs
+	cmd.Args = cobra.MaximumNArgs(1)
+	return cmd
+}
+
+func runDashboard(ctx context.Context) (err error) {
+	org := flag.GetOrg(ctx)
+
+	if org != "" {
+		return extensions_core.OpenOrgDashboard(ctx, org, "enveloop")
+	}
+
+	extension, _, err := extensions_core.Discover(ctx, gql.AddOnTypeEnveloop)
+	if err != nil {
+		return err
+	}
+	return extensions_core.OpenDashboard(ctx, extension.Name)
+}

internal/command/extensions/enveloop/destroy.go

@@ -0,0 +1,72 @@
+package enveloop
+
+import (
+	"context"
+	"fmt"
+
+	"github.com/spf13/cobra"
+	fly "github.com/superfly/fly-go"
+	"github.com/superfly/flyctl/gql"
+	"github.com/superfly/flyctl/internal/command"
+	extensions_core "github.com/superfly/flyctl/internal/command/extensions/core"
+	"github.com/superfly/flyctl/internal/flag"
+	"github.com/superfly/flyctl/internal/prompt"
+	"github.com/superfly/flyctl/iostreams"
+)
+
+func destroy() (cmd *cobra.Command) {
+	const (
+		long = `Permanently destroy an Enveloop cluster`
+
+		short = long
+		usage = "destroy [name]"
+	)
+
+	cmd = command.New(usage, short, long, runDestroy, command.RequireSession, command.LoadAppNameIfPresent)
+
+	cmd.Args = cobra.MaximumNArgs(1)
+
+	flag.Add(cmd,
+		flag.App(),
+		flag.AppConfig(),
+		extensions_core.SharedFlags,
+	)
+
+	return cmd
+}
+
+func runDestroy(ctx context.Context) (err error) {
+	io := iostreams.FromContext(ctx)
+	colorize := io.ColorScheme()
+
+	extension, _, err := extensions_core.Discover(ctx, gql.AddOnTypeEnveloop)
+	if err != nil {
+		return err
+	}
+
+	if !flag.GetYes(ctx) {
+		const msg = "Destroying an  Enveloop cluster is not reversible."
+		fmt.Fprintln(io.ErrOut, colorize.Red(msg))
+
+		switch confirmed, err := prompt.Confirmf(ctx, "Do you want to destroy the cluster named %s?", extension.Name); {
+		case err == nil:
+			if !confirmed {
+				return nil
+			}
+		case prompt.IsNonInteractive(err):
+			return prompt.NonInteractiveError("yes flag must be specified when not running interactively")
+		default:
+			return err
+		}
+	}
+
+	client := fly.ClientFromContext(ctx).GenqClient
+	if _, err := gql.DeleteAddOn(ctx, client, extension.Name); err != nil {
+		return err
+	}
+
+	out := iostreams.FromContext(ctx).Out
+	fmt.Fprintf(out, "Your Enveloop cluster %s was destroyed\n", extension.Name)
+
+	return nil
+}

internal/command/extensions/enveloop/enveloop.go

@@ -0,0 +1,21 @@
+package enveloop
+
+import (
+	"github.com/spf13/cobra"
+	"github.com/superfly/flyctl/internal/command"
+	"github.com/superfly/flyctl/internal/flag"
+)
+
+func New() (cmd *cobra.Command) {
+	const (
+		short = "Provision and manage Enveloop teams"
+		long  = short + "\n"
+	)
+
+	cmd = command.New("enveloop", short, long, nil)
+	cmd.AddCommand(create(), list(), plans(), dashboard(), destroy())
+
+	return cmd
+}
+
+var SharedFlags = flag.Set{}

internal/command/extensions/enveloop/list.go

@@ -0,0 +1,53 @@
+package enveloop
+
+import (
+	"context"
+
+	"github.com/spf13/cobra"
+	fly "github.com/superfly/fly-go"
+	"github.com/superfly/flyctl/gql"
+	"github.com/superfly/flyctl/internal/command"
+	extensions_core "github.com/superfly/flyctl/internal/command/extensions/core"
+	"github.com/superfly/flyctl/internal/flag"
+	"github.com/superfly/flyctl/internal/render"
+	"github.com/superfly/flyctl/iostreams"
+)
+
+func list() (cmd *cobra.Command) {
+	const (
+		long  = `List your  Enveloop clusters`
+		short = long
+		usage = "list"
+	)
+
+	cmd = command.New(usage, short, long, runList, command.RequireSession)
+	cmd.Aliases = []string{"ls"}
+
+	flag.Add(cmd,
+		flag.Org(),
+		extensions_core.SharedFlags,
+	)
+	return cmd
+}
+
+func runList(ctx context.Context) (err error) {
+	client := fly.ClientFromContext(ctx).GenqClient
+	response, err := gql.ListAddOns(ctx, client, "enveloop")
+	if err != nil {
+		return err
+	}
+
+	var rows [][]string
+	for _, extension := range response.AddOns.Nodes {
+		rows = append(rows, []string{
+			extension.Name,
+			extension.Organization.Slug,
+			// extension.addOnPlan.displayName,
+		})
+	}
+
+	out := iostreams.FromContext(ctx).Out
+	_ = render.Table(out, "", rows, "Name", "Team", "AddOn Name")
+
+	return nil
+}

internal/command/extensions/enveloop/plans.go

@@ -0,0 +1,57 @@
+package enveloop
+
+import (
+	"context"
+	"fmt"
+
+	"github.com/spf13/cobra"
+	fly "github.com/superfly/fly-go"
+	"github.com/superfly/flyctl/gql"
+	"github.com/superfly/flyctl/internal/command"
+	extensions_core "github.com/superfly/flyctl/internal/command/extensions/core"
+	"github.com/superfly/flyctl/internal/flag"
+	"github.com/superfly/flyctl/internal/render"
+	"github.com/superfly/flyctl/iostreams"
+)
+
+func plans() (cmd *cobra.Command) {
+	const (
+		long  = `List all Enveloop plans`
+		short = long
+		usage = "plans"
+	)
+
+	cmd = command.New(usage, short, long, runListPlans, command.RequireSession)
+	cmd.Aliases = []string{"ls"}
+
+	flag.Add(cmd,
+		flag.Org(),
+		extensions_core.SharedFlags,
+	)
+	return cmd
+}
+
+func runListPlans(ctx context.Context) (err error) {
+	client := fly.ClientFromContext(ctx).GenqClient
+	response, err := gql.ListAddOnPlans(ctx, client)
+	if err != nil {
+		return err
+	}
+
+	fmt.Printf("%+v\n", response)
+
+	var rows [][]string
+	for _, extension := range response.AddOnPlans.Nodes {
+		rows = append(rows, []string{
+			extension.Id,
+			extension.DisplayName,
+			extension.Description,
+			fmt.Sprintf("$%d / mo", extension.PricePerMonth),
+		})
+	}
+
+	out := iostreams.FromContext(ctx).Out
+	_ = render.Table(out, "", rows, "Id", "Name", "Description", "Price")
+
+	return nil
+}

internal/command/extensions/extensions.go

@@ -5,6 +5,7 @@ import (
 	"github.com/spf13/cobra"
 
 	"github.com/superfly/flyctl/internal/command"
+	"github.com/superfly/flyctl/internal/command/extensions/enveloop"
 	"github.com/superfly/flyctl/internal/command/extensions/kafka"
 	"github.com/superfly/flyctl/internal/command/extensions/kubernetes"
 	"github.com/superfly/flyctl/internal/command/extensions/planetscale"
@@ -30,6 +31,7 @@ func New() (cmd *cobra.Command) {
 		tigris.New(),
 		kubernetes.New(),
 		kafka.New(),
+		enveloop.New(),
 	)
 	return
 }