Skip to content

Commit

Permalink
Merge pull request #27 from weaveworks/wcloud-events
Browse files Browse the repository at this point in the history
Add wcloud events, update flags and error nicely when there is no config
  • Loading branch information
tomwilkie authored Jul 18, 2016
2 parents e9e7e6b + 77355b9 commit 3925eb6
Show file tree
Hide file tree
Showing 2 changed files with 50 additions and 6 deletions.
33 changes: 29 additions & 4 deletions cmd/wcloud/cli.go
Original file line number Diff line number Diff line change
Expand Up @@ -52,6 +52,8 @@ func main() {
config(c, os.Args[2:])
case "logs":
logs(c, os.Args[2:])
case "events":
events(c, os.Args[2:])
case "help":
usage()
default:
Expand Down Expand Up @@ -80,14 +82,17 @@ func deploy(c Client, args []string) {
}

func list(c Client, args []string) {
flags := flag.NewFlagSet("list", flag.ContinueOnError)
page := flags.Int("page", 0, "Zero based index of page to list.")
pagesize := flags.Int("page-size", 10, "Number of results per page")
var (
flags = flag.NewFlagSet("", flag.ContinueOnError)
since = flags.Duration("since", 7*24*time.Hour, "How far back to fetch results")
)
if err := flags.Parse(args); err != nil {
usage()
return
}
deployments, err := c.GetDeployments(*page, *pagesize)
through := time.Now()
from := through.Add(-*since)
deployments, err := c.GetDeployments(through.Unix(), from.Unix())
if err != nil {
fmt.Println(err.Error())
os.Exit(1)
Expand All @@ -109,6 +114,26 @@ func list(c Client, args []string) {
table.Render()
}

func events(c Client, args []string) {
var (
flags = flag.NewFlagSet("", flag.ContinueOnError)
since = flags.Duration("since", 7*24*time.Hour, "How far back to fetch results")
)
if err := flags.Parse(args); err != nil {
usage()
return
}
through := time.Now()
from := through.Add(-*since)
events, err := c.GetEvents(through.Unix(), from.Unix())
if err != nil {
fmt.Println(err.Error())
os.Exit(1)
}

fmt.Println("events: ", string(events))
}

func loadConfig(filename string) (*Config, error) {
extension := filepath.Ext(filename)
var config Config
Expand Down
23 changes: 21 additions & 2 deletions cmd/wcloud/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -53,8 +53,8 @@ func (c Client) Deploy(deployment Deployment) error {
}

// GetDeployments returns a list of deployments
func (c Client) GetDeployments(page, pagesize int) ([]Deployment, error) {
req, err := c.newRequest("GET", fmt.Sprintf("/api/deploy?page=%d&pagesize=%d", page, pagesize), nil)
func (c Client) GetDeployments(from, through int64) ([]Deployment, error) {
req, err := c.newRequest("GET", fmt.Sprintf("/api/deploy?from=%d&through=%d", from, through), nil)
if err != nil {
return nil, err
}
Expand All @@ -74,6 +74,22 @@ func (c Client) GetDeployments(page, pagesize int) ([]Deployment, error) {
return response.Deployments, nil
}

// GetEvents returns the raw events.
func (c Client) GetEvents(from, through int64) ([]byte, error) {
req, err := c.newRequest("GET", fmt.Sprintf("/api/deploy/from=%d&through=%d", from, through), nil)
if err != nil {
return nil, err
}
res, err := http.DefaultClient.Do(req)
if err != nil {
return nil, err
}
if res.StatusCode != 200 {
return nil, fmt.Errorf("Error making request: %s", res.Status)
}
return ioutil.ReadAll(res.Body)
}

// GetConfig returns the current Config
func (c Client) GetConfig() (*Config, error) {
req, err := c.newRequest("GET", "/api/config/deploy", nil)
Expand All @@ -84,6 +100,9 @@ func (c Client) GetConfig() (*Config, error) {
if err != nil {
return nil, err
}
if res.StatusCode == 404 {
return nil, fmt.Errorf("No configuration uploaded yet.")
}
if res.StatusCode != 200 {
return nil, fmt.Errorf("Error making request: %s", res.Status)
}
Expand Down

0 comments on commit 3925eb6

Please sign in to comment.