feat: Unkey Deploy CLI

go/cmd/cli/app/cli.go

@@ -0,0 +1,118 @@
+package app
+
+import (
+	"context"
+	"fmt"
+	"os"
+
+	"github.com/unkeyed/unkey/go/cmd/cli/commands"
+	"github.com/unkeyed/unkey/go/cmd/cli/commands/deploy"
+)
+
+// CLI represents our command line interface
+type CLI struct {
+	args    []string
+	name    string
+	usage   string
+	version string
+	env     map[string]string
+}
+
+// New creates a new CLI instance
+func New(args []string, name, usage, version string) *CLI {
+	env := map[string]string{
+		"UNKEY_WORKSPACE_ID": os.Getenv("UNKEY_WORKSPACE_ID"),
+		"UNKEY_PROJECT_ID":   os.Getenv("UNKEY_PROJECT_ID"),
+	}
+
+	return &CLI{
+		args:    args,
+		name:    name,
+		usage:   usage,
+		version: version,
+		env:     env,
+	}
+}
+
+// Run executes the CLI
+func (c *CLI) Run(ctx context.Context) error {
+	if len(c.args) < 2 {
+		c.PrintUsage()
+		return nil
+	}
+
+	command := c.args[1]
+	switch command {
+	case "init":
+		return commands.Init(c.args[2:], c.env)
+	case "deploy":
+		return deploy.Deploy(ctx, c.args[2:], c.env)
+	case "version":
+		return commands.Version(ctx, c.args[2:], c.env)
+	case "help", "-h", "--help":
+		return c.runHelp()
+	case "-v", "--version":
+		fmt.Println(c.version)
+		return nil
+	default:
+		c.PrintUsage()
+		return fmt.Errorf("unknown command: %s", command)
+	}
+}
+
+// runHelp handles the help command
+func (c *CLI) runHelp() error {
+	if len(c.args) < 3 {
+		c.PrintUsage()
+		return nil
+	}
+
+	helpTopic := c.args[2]
+	switch helpTopic {
+	case "init":
+		commands.PrintInitHelp()
+	case "deploy":
+		deploy.PrintDeployHelp()
+	case "version":
+		commands.PrintVersionHelp()
+	default:
+		fmt.Printf("No help available for '%s'\n", helpTopic)
+		c.PrintUsage()
+	}
+	return nil
+}
+
+// PrintUsage prints general usage information
+func (c *CLI) PrintUsage() {
+	fmt.Printf("%s - %s\n", c.name, c.usage)
+	fmt.Println("")
+	fmt.Println("USAGE:")
+	fmt.Printf("    %s <command> [flags]\n", c.name)
+	fmt.Println("")
+	fmt.Println("VERSION:")
+	fmt.Printf("    %s\n", c.version)
+	fmt.Println("")
+	fmt.Println("COMMANDS:")
+	fmt.Println("    init       Initialize configuration file")
+	fmt.Println("    deploy     Deploy a new version")
+	fmt.Println("    version    Manage API versions")
+	fmt.Println("    help       Show help information")
+	fmt.Println("")
+	fmt.Println("FLAGS:")
+	fmt.Println("    -h, --help       Show help")
+	fmt.Println("    -v, --version    Show version")
+	fmt.Println("")
+	fmt.Println("ENVIRONMENT VARIABLES:")
+	fmt.Println("    UNKEY_WORKSPACE_ID    Workspace ID (can be overridden by --workspace-id)")
+	fmt.Println("    UNKEY_PROJECT_ID      Project ID (can be overridden by --project-id)")
+	fmt.Println("")
+	fmt.Println("EXAMPLES:")
+	fmt.Printf("    %s help\n", c.name)
+	fmt.Printf("    %s help deploy\n", c.name)
+	fmt.Printf("    %s init\n", c.name)
+	fmt.Printf("    %s deploy --workspace-id=ws_123 --project-id=proj_456\n", c.name)
+	fmt.Printf("    UNKEY_WORKSPACE_ID=ws_123 %s deploy\n", c.name)
+	fmt.Printf("    UNKEY_WORKSPACE_ID=ws_123 UNKEY_PROJECT_ID=proj_456 %s deploy\n", c.name)
+	fmt.Println("")
+	fmt.Printf("For detailed help on a command, use '%s help <command>'\n", c.name)
+}

go/cmd/cli/commands/deploy/build_docker.go

@@ -0,0 +1,84 @@
+package deploy
+
+import (
+	"context"
+	"fmt"
+	"os/exec"
+	"strings"
+	"time"
+
+	"github.com/unkeyed/unkey/go/pkg/git"
+)
+
+func generateImageTag(opts *DeployOptions, gitInfo git.Info) string {
+	if gitInfo.ShortSHA != "" {
+		return fmt.Sprintf("%s-%s", opts.Branch, gitInfo.ShortSHA)
+	}
+	return fmt.Sprintf("%s-%d", opts.Branch, time.Now().Unix())
+}
+
+func buildImage(ctx context.Context, opts *DeployOptions, dockerImage string) error {
+	buildArgs := []string{"build"}
+	if opts.Dockerfile != "Dockerfile" {
+		buildArgs = append(buildArgs, "-f", opts.Dockerfile)
+	}
+	buildArgs = append(buildArgs,
+		"-t", dockerImage,
+		"--build-arg", fmt.Sprintf("VERSION=%s", opts.Commit),
+		opts.Context,
+	)
+
+	cmd := exec.CommandContext(ctx, "docker", buildArgs...)
+
+	// Stream output directly instead of complex pipe handling
+	output, err := cmd.CombinedOutput()
+	if err != nil {
+		fmt.Printf("Docker build failed:\n%s\n", string(output))
+		return ErrDockerBuildFailed
+	}
+
+	return nil
+}
+
+func pushImage(ctx context.Context, dockerImage, registry string) error {
+	cmd := exec.CommandContext(ctx, "docker", "push", dockerImage)
+	output, err := cmd.CombinedOutput()
+	if err != nil {
+		detailedMsg := classifyPushError(string(output), registry)
+		return fmt.Errorf("%s", detailedMsg)
+	}
+	fmt.Printf("%s\n", string(output))
+	return nil
+}
+
+func classifyPushError(output, registry string) string {
+	output = strings.TrimSpace(output)
+	registryHost := getRegistryHost(registry)
+
+	switch {
+	case strings.Contains(output, "denied"):
+		return fmt.Sprintf("registry access denied. Try: docker login %s", registryHost)
+
+	case strings.Contains(output, "not found") || strings.Contains(output, "404"):
+		return "registry not found. Create repository or use --registry=your-registry/your-app"
+
+	case strings.Contains(output, "unauthorized"):
+		return fmt.Sprintf("authentication required. Run: docker login %s", registryHost)
+
+	default:
+		return output
+	}
+}
+
+func getRegistryHost(registry string) string {
+	parts := strings.Split(registry, "/")
+	if len(parts) > 0 {
+		return parts[0]
+	}
+	return "docker.io"
+}
+
+func isDockerAvailable() bool {
+	cmd := exec.Command("docker", "--version")
+	return cmd.Run() == nil
+}