Merge pull request #4079 from Joshua-Anderson/add-releases

feat(client-go): add releases endpoint

Author: mboersma

client-go/cmd/releases.go

@@ -0,0 +1,87 @@
+package cmd
+
+import (
+	"fmt"
+	"os"
+	"text/tabwriter"
+
+	"github.com/deis/deis/client-go/controller/models/releases"
+)
+
+// ReleasesList lists an app's releases.
+func ReleasesList(appID string) error {
+	c, appID, err := load(appID)
+
+	if err != nil {
+		return err
+	}
+
+	releases, err := releases.List(c, appID)
+
+	fmt.Printf("=== %s Releases\n", appID)
+
+	w := new(tabwriter.Writer)
+
+	w.Init(os.Stdout, 0, 8, 1, '\t', 0)
+	for _, r := range releases {
+		fmt.Fprintf(w, "v%d\t%s\t%s\n", r.Version, r.Created, r.Summary)
+	}
+	w.Flush()
+	return nil
+}
+
+// ReleasesInfo prints info about a specific release.
+func ReleasesInfo(appID string, version int) error {
+	c, appID, err := load(appID)
+
+	if err != nil {
+		return err
+	}
+
+	r, err := releases.Get(c, appID, version)
+
+	if err != nil {
+		return err
+	}
+
+	fmt.Printf("=== %s Release v%d\n", appID, version)
+	if r.Build != "" {
+		fmt.Println("build:   ", r.Build)
+	}
+	fmt.Println("config:  ", r.Config)
+	fmt.Println("owner:   ", r.Owner)
+	fmt.Println("created: ", r.Created)
+	fmt.Println("summary: ", r.Summary)
+	fmt.Println("updated: ", r.Updated)
+	fmt.Println("uuid:    ", r.UUID)
+
+	return nil
+}
+
+// ReleasesRollback rolls an app back to a previous release.
+func ReleasesRollback(appID string, version int) error {
+	c, appID, err := load(appID)
+
+	if err != nil {
+		return err
+	}
+
+	if version == -1 {
+		fmt.Print("Rolling back one release... ")
+	} else {
+		fmt.Printf("Rolling back to v%d... ", version)
+	}
+
+	quit := progress()
+	newVersion, err := releases.Rollback(c, appID, version)
+	quit <- true
+	<-quit
+
+	if err != nil {
+		return err
+	}
+
+	fmt.Printf("done, v%d\n", newVersion)
+
+	return nil
+}

client-go/controller/api/releases.go

@@ -0,0 +1,27 @@
+package api
+
+// Release is the definition of the release object.
+type Release struct {
+	App     string `json:"app"`
+	Build   string `json:"build,omitempty"`
+	Config  string `json:"config"`
+	Created string `json:"created"`
+	Owner   string `json:"owner"`
+	Summary string `json:"summary"`
+	Updated string `json:"updated"`
+	UUID    string `json:"uuid"`
+	Version int    `json:"version"`
+}
+
+// Releases is the definition of GET /v1/apps/<app id>/releases/.
+type Releases struct {
+	Count    int       `json:"count"`
+	Next     int       `json:"next"`
+	Previous int       `json:"previous"`
+	Releases []Release `json:"results"`
+}
+
+// ReleaseRollback is the defenition of POST /v1/apps/<app id>/releases/.
+type ReleaseRollback struct {
+	Version int `json:"version"`
+}

client-go/controller/models/releases/releases.go

@@ -0,0 +1,89 @@
+package releases
+
+import (
+	"encoding/json"
+	"errors"
+	"fmt"
+
+	"github.com/deis/deis/client-go/controller/api"
+	"github.com/deis/deis/client-go/controller/client"
+)
+
+// List lists an app's releases.
+func List(c *client.Client, appID string) ([]api.Release, error) {
+	u := fmt.Sprintf("/v1/apps/%s/releases/", appID)
+
+	body, status, err := c.BasicRequest("GET", u, nil)
+
+	if err != nil {
+		return []api.Release{}, err
+	}
+
+	if status != 200 {
+		return []api.Release{}, errors.New(body)
+	}
+
+	releases := api.Releases{}
+	if err = json.Unmarshal([]byte(body), &releases); err != nil {
+		return []api.Release{}, err
+	}
+
+	return releases.Releases, nil
+}
+
+// Get a release of an app.
+func Get(c *client.Client, appID string, version int) (api.Release, error) {
+	u := fmt.Sprintf("/v1/apps/%s/releases/v%d/", appID, version)
+
+	body, status, err := c.BasicRequest("GET", u, nil)
+
+	if err != nil {
+		return api.Release{}, err
+	}
+
+	if status != 200 {
+		return api.Release{}, errors.New(body)
+	}
+
+	release := api.Release{}
+	if err = json.Unmarshal([]byte(body), &release); err != nil {
+		return api.Release{}, err
+	}
+
+	return release, nil
+}
+
+// Rollback rolls back an app to a previous release.
+func Rollback(c *client.Client, appID string, version int) (int, error) {
+	u := fmt.Sprintf("/v1/apps/%s/releases/rollback/", appID)
+
+	req := api.ReleaseRollback{Version: version}
+
+	var err error
+	var reqBody []byte
+	if version != -1 {
+		reqBody, err = json.Marshal(req)
+
+		if err != nil {
+			return -1, err
+		}
+	}
+
+	body, status, err := c.BasicRequest("POST", u, reqBody)
+
+	if err != nil {
+		return -1, err
+	}
+
+	if status != 201 {
+		return -1, errors.New(body)
+	}
+
+	response := api.ReleaseRollback{}
+
+	if err = json.Unmarshal([]byte(body), &response); err != nil {
+		return -1, err
+	}
+
+	return response.Version, nil
+}