atlasexec: add the 'migrate push' command

atlasexec/atlas.go

@@ -23,6 +23,18 @@ type (
 	LoginParams struct {
 		Token string
 	}
+	// MigratePushParams are the parameters for the `migrate push` command.
+	MigratePushParams struct {
+		Name        string
+		Tag         string
+		DevURL      string
+		DirURL      string
+		DirFormat   string
+		LockTimeout string
+		ConfigURL   string
+		Env         string
+		Vars        Vars
+	}
 	// MigrateApplyParams are the parameters for the `migrate apply` command.
 	MigrateApplyParams struct {
 		Env             string
@@ -138,6 +150,39 @@ func (c *Client) Logout(ctx context.Context) error {
 	return err
 }
 
+// MigratePush runs the 'migrate push' command.
+func (c *Client) MigratePush(ctx context.Context, params *MigratePushParams) (string, error) {
+	args := []string{"migrate", "push"}
+	if params.DevURL != "" {
+		args = append(args, "--dev-url", params.DevURL)
+	}
+	if params.DirURL != "" {
+		args = append(args, "--dir", params.DirURL)
+	}
+	if params.DirFormat != "" {
+		args = append(args, "--dir-format", params.DirFormat)
+	}
+	if params.LockTimeout != "" {
+		args = append(args, "--lock-timeout", params.LockTimeout)
+	}
+	if params.ConfigURL != "" {
+		args = append(args, "--config", params.ConfigURL)
+	}
+	if params.Env != "" {
+		args = append(args, "--env", params.Env)
+	}
+	args = append(args, params.Vars.AsArgs()...)
+	if params.Name == "" {
+		return "", errors.New("directory name cannot be empty")
+	}
+	if params.Tag != "" {
+		args = append(args, fmt.Sprintf("%s:%s", params.Name, params.Tag))
+	} else {
+		args = append(args, params.Name)
+	}
+	return stringVal(c.runCommand(ctx, args))
+}
+
 // MigrateApply runs the 'migrate apply' command.
 func (c *Client) MigrateApply(ctx context.Context, params *MigrateApplyParams) (*MigrateApply, error) {
 	args := []string{"migrate", "apply", "--format", "{{ json . }}"}