Squashed 'tools/' content from commit b990f48

git-subtree-dir: tools git-subtree-split: b990f488bdc7909b62d9245bc4b4caf58f5ae7ea

Author: Alessandro Puccetti

.gitignore

@@ -0,0 +1,7 @@
+cover/cover
+socks/proxy
+socks/image.tar
+runner/runner
+cmd/wcloud/wcloud
+*.pyc
+*~

README.md

@@ -0,0 +1,42 @@
+# Weaveworks Build Tools
+
+Included in this repo are tools shared by weave.git and scope.git. They include
+
+- ```cover```: a tool which merges overlapping coverage reports generated by go
+ test
+- ```files-with-type```: a tool to search directories for files of a given
+ MIME type
+- ```lint```: a script to lint Go project; runs various tools like golint, go
+ vet, errcheck etc
+- ```rebuild-image```: a script to rebuild docker images when their input files
+ change; useful when you using docker images to build your software, but you
+ don't want to build the image every time.
+- ```shell-lint```: a script to lint multiple shell files with 
+ [shellcheck](http://www.shellcheck.net/)
+- ```socks```: a simple, dockerised SOCKS proxy for getting your laptop onto
+ the Weave network
+- ```test```: a script to run all go unit tests in subdirectories, gather the
+ coverage results, and merge them into a single report.
+- ```runner```: a tool for running tests in parallel; given each test is
+ suffixed with the number of hosts it requires, and the hosts available are
+ contained in the environment variable HOSTS, the tool will run tests in
+ parallel, on different hosts.
+- ```scheduler```: an appengine application that can be used to distribute
+ tests across different shards in CircleCI.
+
+## Using build-tools.git
+
+To allow you to tie your code to a specific version of build-tools.git, such
+that future changes don't break you, we recommendation that you [`git subtree`]()
+this repository into your own repository:
+
+[`git subtree`]: http://blogs.atlassian.com/2013/05/alternatives-to-git-submodule-git-subtree/
+
+```
+git subtree add --prefix tools https://github.com/weaveworks/build-tools.git master --squash
+````
+
+To update the code in build-tools.git, the process is therefore:
+- PR into build-tools.git, go through normal review process etc.
+- Do `git subtree pull --prefix tools https://github.com/weaveworks/build-tools.git master --squash`
+ in your repo, and PR that.

circle.yml

@@ -0,0 +1,24 @@
+machine:
+ services:
+ - docker
+ environment:
+ GOPATH: /home/ubuntu
+ SRCDIR: /home/ubuntu/src/github.com/weaveworks/tools
+ PATH: $PATH:$HOME/bin
+
+dependencies:
+ post:
+ - go clean -i net
+ - go install -tags netgo std
+ - mkdir -p $(dirname $SRCDIR)
+ - cp -r $(pwd)/ $SRCDIR
+ - go get github.com/golang/lint/golint github.com/fzipp/gocyclo github.com/kisielk/errcheck
+
+test:
+ override:
+ - cd $SRCDIR; ./lint .
+ - cd $SRCDIR/cover; make
+ - cd $SRCDIR/socks; make
+ - cd $SRCDIR/runner; make
+ - cd $SRCDIR/cmd/wcloud; make
+

cmd/wcloud/Makefile

@@ -0,0 +1,11 @@
+.PHONY: all clean
+
+all: wcloud
+
+wcloud: *.go
+go get ./$(@D)
+go build -o $@ ./$(@D)
+
+clean:
+rm -rf wcloud
+go clean ./...

cmd/wcloud/cli.go

@@ -0,0 +1,238 @@
+package main
+
+import (
+"bytes"
+"encoding/json"
+"flag"
+"fmt"
+"io/ioutil"
+"os"
+"os/user"
+"path/filepath"
+"strings"
+"time"
+
+"github.com/olekukonko/tablewriter"
+"gopkg.in/yaml.v2"
+)
+
+// ArrayFlags allows you to collect repeated flags
+type ArrayFlags []string
+
+func (a *ArrayFlags) String() string {
+return strings.Join(*a, ",")
+}
+
+// Set implements flags.Value
+func (a *ArrayFlags) Set(value string) error {
+*a = append(*a, value)
+return nil
+}
+
+func env(key, def string) string {
+if val, ok := os.LookupEnv(key); ok {
+return val
+}
+return def
+}
+
+var (
+token = env("SERVICE_TOKEN", "")
+baseURL = env("BASE_URL", "https://cloud.weave.works")
+)
+
+func usage() {
+fmt.Println(`Usage:
+deploy <image>:<version> Deploy image to your configured env
+list List recent deployments
+config (<filename>) Get (or set) the configured env
+logs <deploy> Show lots for the given deployment`)
+}
+
+func main() {
+if len(os.Args) <= 1 {
+usage()
+os.Exit(1)
+}
+
+c := NewClient(token, baseURL)
+
+switch os.Args[1] {
+case "deploy":
+deploy(c, os.Args[2:])
+case "list":
+list(c, os.Args[2:])
+case "config":
+config(c, os.Args[2:])
+case "logs":
+logs(c, os.Args[2:])
+case "events":
+events(c, os.Args[2:])
+case "help":
+usage()
+default:
+usage()
+}
+}
+
+func deploy(c Client, args []string) {
+var (
+flags = flag.NewFlagSet("", flag.ContinueOnError)
+username = flags.String("u", "", "Username to report to deploy service (default with be current user)")
+services ArrayFlags
+)
+flags.Var(&services, "service", "Service to update (can be repeated)")
+if err := flags.Parse(args); err != nil {
+usage()
+return
+}
+args = flags.Args()
+if len(args) != 1 {
+usage()
+return
+}
+parts := strings.SplitN(args[0], ":", 2)
+if len(parts) < 2 {
+usage()
+return
+}
+if *username == "" {
+user, err := user.Current()
+if err != nil {
+fmt.Println(err.Error())
+os.Exit(1)
+}
+*username = user.Username
+}
+deployment := Deployment{
+ImageName: parts[0],
+Version: parts[1],
+TriggeringUser: *username,
+IntendedServices: services,
+}
+if err := c.Deploy(deployment); err != nil {
+fmt.Println(err.Error())
+os.Exit(1)
+}
+}
+
+func list(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)
+deployments, err := c.GetDeployments(from.Unix(), through.Unix())
+if err != nil {
+fmt.Println(err.Error())
+os.Exit(1)
+}
+
+table := tablewriter.NewWriter(os.Stdout)
+table.SetHeader([]string{"Created", "ID", "Image", "Version", "State"})
+table.SetBorder(false)
+table.SetColumnSeparator(" ")
+for _, deployment := range deployments {
+table.Append([]string{
+deployment.CreatedAt.Format(time.RFC822),
+deployment.ID,
+deployment.ImageName,
+deployment.Version,
+deployment.State,
+})
+}
+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(from.Unix(), through.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
+buf, err := ioutil.ReadFile(filename)
+if err != nil {
+return nil, err
+}
+if extension == ".yaml" || extension == ".yml" {
+if err := yaml.Unmarshal(buf, &config); err != nil {
+return nil, err
+}
+} else {
+if err := json.NewDecoder(bytes.NewReader(buf)).Decode(&config); err != nil {
+return nil, err
+}
+}
+return &config, nil
+}
+
+func config(c Client, args []string) {
+if len(args) > 1 {
+usage()
+return
+}
+
+if len(args) == 1 {
+config, err := loadConfig(args[0])
+if err != nil {
+fmt.Println("Error reading config:", err)
+os.Exit(1)
+}
+
+if err := c.SetConfig(config); err != nil {
+fmt.Println(err.Error())
+os.Exit(1)
+}
+} else {
+config, err := c.GetConfig()
+if err != nil {
+fmt.Println(err.Error())
+os.Exit(1)
+}
+
+buf, err := yaml.Marshal(config)
+if err != nil {
+fmt.Println(err.Error())
+os.Exit(1)
+}
+
+fmt.Println(string(buf))
+}
+}
+
+func logs(c Client, args []string) {
+if len(args) != 1 {
+usage()
+return
+}
+
+output, err := c.GetLogs(args[0])
+if err != nil {
+fmt.Println(err.Error())
+os.Exit(1)
+}
+
+fmt.Println(string(output))
+}