Added client library and Tests

Refactor resource objects & add in a connection check

Makefile

@@ -19,7 +19,7 @@ deps:
 
 deps-local:
 	@if ! [ -f glide.yaml ]; then glide init --non-interactive; fi
-	@glide install --strip-vcs --strip-vendor
+	@glide install
 
 build:
 	@${DOCKER_CMD} make build-local
@@ -36,8 +36,18 @@ lint-local:
 test:
 	@${DOCKER_CMD} make test-local
 
+test-client:
+	@docker-compose build
+	@docker-compose create
+	@docker-compose start
+	@-make test-client-local
+	@docker-compose kill
+
 test-local: lint-local
-	@ginkgo -race -trace -randomizeAllSpecs -r -cover
+	@ginkgo -race -trace -randomizeAllSpecs -r -cover --skipPackage=client
+
+test-client-local:
+	@ginkgo -race -trace -randomizeAllSpecs -cover client
 
 coveralls:
 	@go get github.com/mattn/goveralls

client/README.md

@@ -0,0 +1 @@
+# Golang REST client for RackHD ipam

client/client.go

@@ -0,0 +1,143 @@
+package ipamapi
+
+import (
+	"bytes"
+	"encoding/json"
+	"errors"
+	"fmt"
+	"io"
+	"log"
+	"mime"
+	"net/http"
+	"time"
+
+	"github.com/RackHD/ipam/controllers/helpers"
+	"github.com/RackHD/ipam/interfaces"
+	"github.com/RackHD/ipam/resources/factory"
+	"github.com/hashicorp/go-cleanhttp"
+)
+
+// Client struct is used to configure the creation of a client
+type Client struct {
+	Address string
+	Scheme  string
+}
+
+// NewClient returns a new client
+func NewClient(address string) *Client {
+	// bootstrap the config
+	c := &Client{
+		Address: address,
+		Scheme:  "http",
+	}
+
+	// Make sure IPAM connection is alive, with retries
+	for i := 0; i < 5; i++ {
+		_, err := c.IndexPools()
+		if err == nil {
+			return c
+		}
+		log.Println("Could not connect to IPAM, retrying in 5 Seconds...")
+		time.Sleep(5 * time.Second)
+	}
+
+	return nil
+}
+
+// SendResource is used to send a generic resource type
+func (c *Client) SendResource(method, path string, in interfaces.Resource) (string, error) {
+
+	body, err := encodeBody(in)
+	if err != nil {
+		return "", err
+	}
+	req, err := http.NewRequest(method, c.Scheme+"://"+c.Address+path, body)
+	if err != nil {
+		return "", err
+	}
+	req.Header.Set(
+		"Content-Type",
+		mime.FormatMediaType(
+			fmt.Sprintf("%s+%s", in.Type(), "json"),
+			map[string]string{"version": in.Version()},
+		),
+	)
+
+	client := cleanhttp.DefaultClient()
+	resp, err := client.Do(req)
+	if err != nil {
+		return "", err
+	}
+	if resp.StatusCode < 200 || resp.StatusCode > 300 {
+		return "", errors.New(resp.Status)
+	}
+
+	return resp.Header.Get("Location"), nil
+}
+
+// ReceiveResource is used to receive the passed reasource type
+func (c *Client) ReceiveResource(method, path, resourceType, resourceVersion string) (interfaces.Resource, error) {
+
+	req, err := http.NewRequest(method, c.Scheme+"://"+c.Address+path, nil)
+
+	req.Header.Set(
+		"Content-Type",
+		mime.FormatMediaType(
+			fmt.Sprintf("%s+%s", resourceType, "json"),
+			map[string]string{"version": resourceVersion},
+		),
+	)
+
+	client := cleanhttp.DefaultClient()
+	resp, err := client.Do(req)
+	if err != nil {
+		return nil, err
+	}
+
+	mediaType, err := helpers.NewMediaType(resp.Header.Get("Content-Type"))
+	if err != nil {
+		return nil, err
+	}
+	resource, err := factory.Require(mediaType.Type, mediaType.Version)
+	if err != nil {
+		return nil, err
+	}
+
+	err = decodeBody(resp, &resource)
+	if err != nil {
+		return nil, err
+	}
+
+	return resource, nil
+}
+
+// SendReceiveResource is used to send a resource type and then
+// upon success, fetch and recieve that resource type
+func (c *Client) SendReceiveResource(methodSend, methodReceive, path string, in interfaces.Resource) (interfaces.Resource, error) {
+
+	location, err := c.SendResource(methodSend, path, in)
+	if err != nil {
+		return nil, err
+	}
+	out, err := c.ReceiveResource(methodReceive, location, "", "")
+	return out, err
+}
+
+// decodeBody is used to JSON decode a body
+func decodeBody(resp *http.Response, out interface{}) error {
+	dec := json.NewDecoder(resp.Body)
+	return dec.Decode(out)
+}
+
+// encodeBody is used to encode a request body
+func encodeBody(obj interface{}) (io.Reader, error) {
+	if obj == nil {
+		return nil, nil
+	}
+	buf := bytes.NewBuffer(nil)
+	enc := json.NewEncoder(buf)
+	if err := enc.Encode(obj); err != nil {
+		return nil, err
+	}
+	return buf, nil
+}

client/client_suite_test.go

@@ -0,0 +1,13 @@
+package ipamapi_test
+
+import (
+	. "github.com/onsi/ginkgo"
+	. "github.com/onsi/gomega"
+
+	"testing"
+)
+
+func TestClient(t *testing.T) {
+	RegisterFailHandler(Fail)
+	RunSpecs(t, "Client Suite")
+}