run specific release

allow users to run a command on a container for a given release

This allows user to build a release, then run commands such as
migrations then promote the release

api/controllers/processes.go

@@ -115,14 +115,15 @@ func ProcessRunDetached(rw http.ResponseWriter, r *http.Request) *httperr.Error
 	app := vars["app"]
 	process := vars["process"]
 	command := GetForm(r, "command")
+	release := GetForm(r, "release")
 
 	a, err := models.GetApp(app)
 
 	if awsError(err) == "ValidationError" {
 		return httperr.Errorf(404, "no such app: %s", app)
 	}
 
-	err = a.RunDetached(process, command)
+	err = a.RunDetached(process, command, release)
 
 	if err != nil {
 		return httperr.Server(err)
@@ -138,6 +139,7 @@ func ProcessRunAttached(ws *websocket.Conn) *httperr.Error {
 	app := vars["app"]
 	process := vars["process"]
 	command := header.Get("Command")
+	release := header.Get("Release")
 	height, _ := strconv.Atoi(header.Get("Height"))
 	width, _ := strconv.Atoi(header.Get("Width"))
 
@@ -151,7 +153,7 @@ func ProcessRunAttached(ws *websocket.Conn) *httperr.Error {
 		return httperr.Server(err)
 	}
 
-	return httperr.Server(a.RunAttached(process, command, height, width, ws))
+	return httperr.Server(a.RunAttached(process, command, release, height, width, ws))
 }
 
 func ProcessStop(rw http.ResponseWriter, r *http.Request) *httperr.Error {

api/models/app.go

@@ -470,7 +470,7 @@ func (a *App) ExecAttached(pid, command string, height, width int, rw io.ReadWri
 	return nil
 }
 
-func (a *App) RunAttached(process, command string, height, width int, rw io.ReadWriter) error {
+func (a *App) RunAttached(process, command, releaseId string, height, width int, rw io.ReadWriter) error {
 	resources, err := a.Resources()
 
 	if err != nil {
@@ -499,7 +499,11 @@ func (a *App) RunAttached(process, command string, height, width int, rw io.Read
 		ea = append(ea, fmt.Sprintf("%s=%s", *env.Name, *env.Value))
 	}
 
-	release, err := GetRelease(a.Name, a.Release)
+	if len(releaseId) == 0 {
+		releaseId = a.Release
+	}
+
+	release, err := GetRelease(a.Name, releaseId)
 
 	if err != nil {
 		return err
@@ -668,7 +672,7 @@ func (a *App) RunAttached(process, command string, height, width int, rw io.Read
 	return nil
 }
 
-func (a *App) RunDetached(process, command string) error {
+func (a *App) RunDetached(process, command, releaseId string) error {
 	resources, err := a.Resources()
 
 	if err != nil {

client/processes.go

@@ -79,7 +79,7 @@ func (c *Client) ExecProcessAttached(app, pid, command string, in io.Reader, out
 	return code, nil
 }
 
-func (c *Client) RunProcessAttached(app, process, command string, height, width int, in io.Reader, out io.WriteCloser) (int, error) {
+func (c *Client) RunProcessAttached(app, process, command, release string, height, width int, in io.Reader, out io.WriteCloser) (int, error) {
 	r, w := io.Pipe()
 
 	defer r.Close()
@@ -91,6 +91,7 @@ func (c *Client) RunProcessAttached(app, process, command string, height, width
 
 	headers := map[string]string{
 		"Command": command,
+		"Release": release,
 		"Height":  strconv.Itoa(height),
 		"Width":   strconv.Itoa(width),
 	}
@@ -106,11 +107,12 @@ func (c *Client) RunProcessAttached(app, process, command string, height, width
 	return code, nil
 }
 
-func (c *Client) RunProcessDetached(app, process, command string) error {
+func (c *Client) RunProcessDetached(app, process, command, release string) error {
 	var success interface{}
 
 	params := map[string]string{
 		"command": command,
+		"release": release,
 	}
 
 	err := c.Post(fmt.Sprintf("/apps/%s/processes/%s/run", app, process), params, &success)

cmd/convox/run.go

@@ -24,6 +24,10 @@ func init() {
 				Name:  "detach",
 				Usage: "run in the background",
 			},
+			cli.StringFlag{
+				Name:  "release, r",
+				Usage: "Release Name. Defaults to current release.",
+			},
 		},
 	})
 }
@@ -50,7 +54,9 @@ func cmdRun(c *cli.Context) {
 
 	args := strings.Join(c.Args()[1:], " ")
 
-	code, err := runAttached(c, app, ps, args)
+	release := c.String("release")
+
+	code, err := runAttached(c, app, ps, args, release)
 
 	if err != nil {
 		stdcli.Error(err)
@@ -82,9 +88,11 @@ func cmdRunDetached(c *cli.Context) {
 		command = strings.Join(args, " ")
 	}
 
+	release := c.String("release")
+
 	fmt.Printf("Running `%s` on %s... ", command, ps)
 
-	err = rackClient(c).RunProcessDetached(app, ps, command)
+	err = rackClient(c).RunProcessDetached(app, ps, command, release)
 
 	if err != nil {
 		stdcli.Error(err)
@@ -94,7 +102,7 @@ func cmdRunDetached(c *cli.Context) {
 	fmt.Println("OK")
 }
 
-func runAttached(c *cli.Context, app string, ps string, args string) (int, error) {
+func runAttached(c *cli.Context, app, ps, args, release string) (int, error) {
 	fd := os.Stdin.Fd()
 
 	if terminal.IsTerminal(int(fd)) {
@@ -113,7 +121,7 @@ func runAttached(c *cli.Context, app string, ps string, args string) (int, error
 		return -1, err
 	}
 
-	code, err := rackClient(c).RunProcessAttached(app, ps, args, h, w, os.Stdin, os.Stdout)
+	code, err := rackClient(c).RunProcessAttached(app, ps, args, release, h, w, os.Stdin, os.Stdout)
 
 	if err != nil {
 		return -1, err