v2 gogobosh

.travis.yml

@@ -1,6 +1,6 @@
 language: go
 
-go: 1.4.2
+go: 1.5.3
 
 install:
   - export PATH=$PATH:$HOME/gopath/bin

LICENSE

@@ -0,0 +1,21 @@
+The MIT License
+
+Copyright (c) 2016 Dr Nic, Long Nguyen
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in
+all copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
+THE SOFTWARE.

TODO

@@ -0,0 +1 @@
+UAA Support

api.go

@@ -0,0 +1,253 @@
+package gogobosh
+
+import (
+	"bytes"
+	"encoding/json"
+	"io/ioutil"
+	"log"
+	"strconv"
+	"strings"
+	"time"
+)
+
+// GetStemcells from given BOSH
+func (c *Client) GetStemcells() (stemcells []Stemcell, err error) {
+	r := c.NewRequest("GET", "/stemcells")
+	resp, err := c.DoRequest(r)
+
+	if err != nil {
+		log.Printf("Error requesting stemcells  %v", err)
+		return
+	}
+	resBody, err := ioutil.ReadAll(resp.Body)
+	if err != nil {
+		log.Printf("Error reading stemcells request %v", resBody)
+		return
+	}
+	err = json.Unmarshal(resBody, &stemcells)
+	if err != nil {
+		log.Printf("Error unmarshaling stemcells %v", err)
+		return
+	}
+	return
+}
+
+// GetReleases from given BOSH
+func (c *Client) GetReleases() (releases []Release, err error) {
+	r := c.NewRequest("GET", "/releases")
+	resp, err := c.DoRequest(r)
+
+	if err != nil {
+		log.Printf("Error requesting releases  %v", err)
+		return
+	}
+	resBody, err := ioutil.ReadAll(resp.Body)
+	if err != nil {
+		log.Printf("Error reading releases request %v", resBody)
+		return
+	}
+	err = json.Unmarshal(resBody, &releases)
+	if err != nil {
+		log.Printf("Error unmarshaling releases %v", err)
+		return
+	}
+	return
+}
+
+// GetDeployments from given BOSH
+func (c *Client) GetDeployments() (deployments []Deployment, err error) {
+	r := c.NewRequest("GET", "/deployments")
+	resp, err := c.DoRequest(r)
+
+	if err != nil {
+		log.Printf("Error requesting deployments  %v", err)
+		return
+	}
+	resBody, err := ioutil.ReadAll(resp.Body)
+	if err != nil {
+		log.Printf("Error reading deployments request %v", resBody)
+		return
+	}
+	err = json.Unmarshal(resBody, &deployments)
+	if err != nil {
+		log.Printf("Error unmarshaling deployments %v", err)
+		return
+	}
+	return
+}
+
+// GetDeployment from given BOSH
+func (c *Client) GetDeployment(name string) (manifest Manifest, err error) {
+	r := c.NewRequest("GET", "/deployments/"+name)
+	resp, err := c.DoRequest(r)
+
+	if err != nil {
+		log.Printf("Error requesting deployment manifest %v", err)
+		return
+	}
+	resBody, err := ioutil.ReadAll(resp.Body)
+	if err != nil {
+		log.Printf("Error reading deployment manifest request %v", resBody)
+		return
+	}
+	err = json.Unmarshal(resBody, &manifest)
+	if err != nil {
+		log.Printf("Error unmarshaling deployment manifest %v", err)
+		return
+	}
+	return
+}
+
+// DeleteDeployment from given BOSH
+func (c *Client) DeleteDeployment(name string) (task Task, err error) {
+	r := c.NewRequest("DELETE", "/deployments/"+name+"?force=true")
+	resp, err := c.DoRequest(r)
+
+	if err != nil {
+		log.Printf("Error requesting deleting deployment %v", err)
+		return
+	}
+	resBody, err := ioutil.ReadAll(resp.Body)
+	if err != nil {
+		log.Printf("Error reading deleting deployment request %v", resBody)
+		return
+	}
+	err = json.Unmarshal(resBody, &task)
+	if err != nil {
+		log.Printf("Error unmarshaling tasks %v", err)
+		return
+	}
+	return
+}
+
+// CreateDeployment from given BOSH
+func (c *Client) CreateDeployment(manifest string) (task Task, err error) {
+	r := c.NewRequest("POST", "/deployments")
+	buffer := bytes.NewBufferString(manifest)
+	r.body = buffer
+	r.header["Content-Type"] = "text/yaml"
+
+	resp, err := c.DoRequest(r)
+	if err != nil {
+		log.Printf("Error requesting create deployment %v", err)
+		return
+	}
+	resBody, err := ioutil.ReadAll(resp.Body)
+	if err != nil {
+		log.Printf("Error reading task request %v", resBody)
+		return
+	}
+	err = json.Unmarshal(resBody, &task)
+	if err != nil {
+		log.Printf("Error unmarshaling task %v", err)
+		return
+	}
+	return
+}
+
+// GetDeploymentVMs from given BOSH
+func (c *Client) GetDeploymentVMs(name string) (vms []VM, err error) {
+	var task Task
+	r := c.NewRequest("GET", "/deployments/"+name+"/vms?format=full")
+	resp, err := c.DoRequest(r)
+	if err != nil {
+		log.Printf("Error requesting deployment vms %v", err)
+		return
+	}
+
+	resBody, err := ioutil.ReadAll(resp.Body)
+	if err != nil {
+		log.Printf("Error reading deployment vms request %v", resBody)
+		return
+	}
+	err = json.Unmarshal(resBody, &task)
+	if err != nil {
+		log.Printf("Error unmarshaling tasks %v", err)
+		return
+	}
+	for {
+		taskStatus, err := c.GetTask(task.ID)
+		if err != nil {
+			log.Printf("Error getting task %v", err)
+		}
+		if taskStatus.State == "done" {
+			break
+		}
+		time.Sleep(1 * time.Second)
+	}
+	output := c.GetTaskResult(task.ID)
+	for _, value := range output {
+		if len(value) > 0 {
+			var vm VM
+			err = json.Unmarshal([]byte(value), &vm)
+			if err != nil {
+				log.Printf("Error unmarshaling vms %v %v", value, err)
+				return
+			}
+			vms = append(vms, vm)
+		}
+	}
+	return
+}
+
+// GetTasks from given BOSH
+func (c *Client) GetTasks() (tasks []Task, err error) {
+	r := c.NewRequest("GET", "/tasks")
+	resp, err := c.DoRequest(r)
+
+	if err != nil {
+		log.Printf("Error requesting tasks  %v", err)
+		return
+	}
+	resBody, err := ioutil.ReadAll(resp.Body)
+	if err != nil {
+		log.Printf("Error reading tasks request %v", resBody)
+		return
+	}
+	err = json.Unmarshal(resBody, &tasks)
+	if err != nil {
+		log.Printf("Error unmarshaling tasks %v", err)
+		return
+	}
+	return
+}
+
+// GetTask from given BOSH
+func (c *Client) GetTask(id int) (task Task, err error) {
+	stringID := strconv.Itoa(id)
+	r := c.NewRequest("GET", "/tasks/"+stringID)
+	resp, err := c.DoRequest(r)
+
+	if err != nil {
+		log.Printf("Error requesting task %v", err)
+		return
+	}
+	resBody, err := ioutil.ReadAll(resp.Body)
+	if err != nil {
+		log.Printf("Error reading task request %v", resBody)
+		return
+	}
+	err = json.Unmarshal(resBody, &task)
+	if err != nil {
+		log.Printf("Error unmarshaling task %v", err)
+		return
+	}
+	return
+}
+
+// GetTaskResult from given BOSH
+func (c *Client) GetTaskResult(id int) (output []string) {
+	stringID := strconv.Itoa(id)
+	r := c.NewRequest("GET", "/tasks/"+stringID+"/output?type=result")
+	resp, err := c.DoRequest(r)
+
+	if err != nil {
+		log.Printf("Error requesting task %v", err)
+	}
+	resBody, err := ioutil.ReadAll(resp.Body)
+	if err != nil {
+		log.Printf("Error reading task request %v", resBody)
+	}
+	output = strings.Split(string(resBody), "\n")
+	return
+}