Add deployment support

cmd/autocomplete/deployments.go

@@ -0,0 +1,26 @@
+package autocomplete
+
+import (
+	"fmt"
+
+	"github.com/Scalingo/codegangsta-cli"
+	"gopkg.in/errgo.v1"
+	"github.com/Scalingo/cli/config"
+  "github.com/Scalingo/cli/appdetect"
+)
+
+func DeploymentsAutoComplete(c *cli.Context) error {
+  client := config.ScalingoClient()
+  currentApp := appdetect.CurrentApp(c)
+
+  deployments, err := client.DeploymentList(currentApp)
+  if err != nil {
+    return errgo.Mask(err, errgo.Any)
+  }
+
+  for _, deployment := range(deployments) {
+    fmt.Println(deployment.ID)
+  }
+
+  return nil
+}

cmd/commands.go

@@ -31,6 +31,11 @@ var (
 		DomainsRemoveCommand,
 		DomainsSSLCommand,
 
+		// Deploiments
+		DeploymentsListCommand,
+		DeploymentLogCommand,
+		DeploymentFollowCommand,
+
 		// Collaborators
 		CollaboratorsListCommand,
 		CollaboratorsAddCommand,

cmd/deployments.go

@@ -0,0 +1,66 @@
+package cmd
+
+import (
+	"github.com/Scalingo/cli/deployments"
+	"github.com/Scalingo/cli/appdetect"
+	"github.com/Scalingo/cli/cmd/autocomplete"
+	"github.com/Scalingo/codegangsta-cli"
+)
+
+var (
+	DeploymentsListCommand = cli.Command{
+		Name:     "deployments",
+		Category: "Deployment",
+		Usage:    "List app deployments",
+		Flags:    []cli.Flag{appFlag},
+		Description: ` List all of your previous app deployments
+    $ scalingo -a myapp deployments
+`,
+		Action: func(c *cli.Context) {
+			currentApp := appdetect.CurrentApp(c)
+			err := deployments.List(currentApp)
+			if err != nil {
+				errorQuit(err)
+			}
+		},
+	}
+	DeploymentLogCommand = cli.Command{
+		Name:     "deployment-logs",
+		Category: "Deployment",
+		Usage:    "View deployment logs",
+		Flags:    []cli.Flag{appFlag},
+		Description: ` Get the logs of an app deployment
+		$ scalingo -a myapp deployment-logs my-deployment
+`,
+		Action: func(c *cli.Context) {
+			currentApp := appdetect.CurrentApp(c)
+			if len(c.Args()) == 1 {
+				err := deployments.Logs(currentApp, c.Args()[0])
+				if err != nil {
+					errorQuit(err)
+				}
+			} else {
+				cli.ShowCommandHelp(c, "deployment-logs")
+			}
+		},
+		BashComplete: func(c *cli.Context){
+			autocomplete.DeploymentsAutoComplete(c)
+		},
+	}
+	DeploymentFollowCommand = cli.Command{
+		Name:     "deployment-follow",
+		Category: "Deployment",
+		Usage:    "Follow deployement event stream",
+		Flags:    []cli.Flag{appFlag},
+		Description: ` Get real-time deployment informations
+		$ scalingo -a myapp deployment-follow
+		`,
+		Action: func(c *cli.Context) {
+			currentApp := appdetect.CurrentApp(c)
+			err := deployments.Stream(currentApp)
+			if err != nil {
+				errorQuit(err)
+			}
+		},
+	}
+)

cmd/error.go

@@ -14,6 +14,7 @@ import (
 	"github.com/stvp/rollbar"
 	"gopkg.in/errgo.v1"
 	"github.com/Scalingo/cli/config"
+	"github.com/Scalingo/cli/debug"
 	"github.com/Scalingo/cli/io"
 	"github.com/Scalingo/cli/session"
 )
@@ -64,6 +65,7 @@ func errorQuit(err error) {
 	newReportError(err).Report()
 	rollbar.Wait()
 	io.Error("An error occured:")
+	debug.Println(errgo.Details(err))
 	fmt.Println(io.Indent(err.Error(), 7))
 	os.Exit(1)
 }

deployments/follow.go

@@ -0,0 +1,97 @@
+package deployments
+
+import (
+	"encoding/json"
+	"fmt"
+	stdio "io"
+	"strings"
+	"time"
+
+	"github.com/Scalingo/go-scalingo"
+	"golang.org/x/net/websocket"
+	"gopkg.in/errgo.v1"
+	"github.com/Scalingo/cli/config"
+	"github.com/Scalingo/cli/debug"
+)
+
+type deployEvent struct {
+	ID   string          `json:"id"`
+	Type string          `json:"type"`
+	Data json.RawMessage `json:"data"`
+}
+
+type logData struct {
+	Content string `json:"content"`
+}
+
+type statusData struct {
+	Content string `json:"Status"`
+}
+
+func Stream(appName string) error {
+	c := config.ScalingoClient()
+	app, err := c.AppsShow(appName)
+	if err != nil {
+		return errgo.Mask(err, errgo.Any)
+	}
+
+	debug.Println("Opening socket to : " + app.Links.DeploymentsStream)
+
+	conn, err := c.DeploymentStream(app.Links.DeploymentsStream)
+	if err != nil {
+		return errgo.Mask(err, errgo.Any)
+	}
+
+	var event deployEvent
+	oldStatus := ""
+	for {
+		err := websocket.JSON.Receive(conn, &event)
+		if err != nil {
+			conn.Close()
+			if err == stdio.EOF {
+				debug.Println("Remote server broke the connection, reconnecting")
+				for err != nil {
+					conn, err = c.DeploymentStream(app.Links.DeploymentsStream)
+					time.Sleep(time.Second * 1)
+				}
+				continue
+			} else {
+				return errgo.Mask(err, errgo.Any)
+			}
+		} else {
+			switch event.Type {
+			case "ping":
+			case "log":
+				var logData logData
+				err := json.Unmarshal(event.Data, &logData)
+				if err != nil {
+					config.C.Logger.Println(err)
+				} else {
+					fmt.Println("[LOG] " + strings.TrimSpace(logData.Content))
+				}
+			case "status":
+				var statusData statusData
+				err := json.Unmarshal(event.Data, &statusData)
+				if err != nil {
+					config.C.Logger.Println(err)
+				} else {
+					if oldStatus == "" {
+						fmt.Println("[STATUS] New status : " + statusData.Content)
+					} else {
+						fmt.Println("[STATUS] New status : " + oldStatus + " → " + statusData.Content)
+					}
+					oldStatus = statusData.Content
+				}
+			case "new":
+				var newData map[string]*scalingo.Deployment
+				err := json.Unmarshal(event.Data, &newData)
+				if err != nil {
+					config.C.Logger.Println(err)
+				} else {
+					fmt.Println("[NEW] New deploy : " + newData["deployment"].ID + " from " + newData["deployment"].User.Username)
+					oldStatus = ""
+				}
+			}
+		}
+	}
+}

deployments/list.go

@@ -0,0 +1,36 @@
+package deployments
+
+import (
+	"os"
+
+	"github.com/olekukonko/tablewriter"
+	"gopkg.in/errgo.v1"
+	"github.com/Scalingo/cli/config"
+)
+
+func List(app string) error {
+	c := config.ScalingoClient()
+	deployments, err := c.DeploymentList(app)
+	if err != nil {
+		return errgo.Mask(err)
+	}
+
+	if len(deployments) == 0 {
+
+	} else {
+		t := tablewriter.NewWriter(os.Stdout)
+		t.SetHeader([]string{"ID", "Date", "User", "Status"})
+
+		for _, deployment := range deployments {
+			t.Append([]string{deployment.ID,
+				deployment.CreatedAt.Format("2006/01/02 15:04:05"),
+				deployment.User.Username,
+				deployment.Status,
+			})
+		}
+		t.Render()
+
+	}
+
+	return nil
+}

deployments/logs.go

@@ -0,0 +1,34 @@
+package deployments
+
+import (
+	stdio "io"
+	"os"
+
+	"gopkg.in/errgo.v1"
+	"github.com/Scalingo/cli/config"
+	"github.com/Scalingo/cli/io"
+)
+
+func Logs(app string, deployment string) error {
+	client := config.ScalingoClient()
+	deploy, err := client.Deployment(app, deployment)
+
+	if err != nil {
+		return errgo.Mask(err, errgo.Any)
+	}
+
+	res, err := client.DeploymentLogs(deploy.Links.Output)
+
+	if err != nil {
+		return errgo.Mask(err, errgo.Any)
+	}
+
+	defer res.Body.Close()
+
+	if res.StatusCode == 404 {
+		io.Error("There is no log for this deployment.")
+	} else {
+		stdio.Copy(os.Stdout, res.Body)
+	}
+	return nil
+}