Per new api

Signed-off-by: Vishal Rana <[email protected]>

Author: vishr

Gopkg.lock

@@ -22,9 +22,9 @@
 
 
 [[constraint]]
-  name = "github.com/dghubble/sling"
-  version = "1.1.0"
+  name = "github.com/labstack/gommon"
+  version = "0.2.3"
 
 [[constraint]]
-  name = "github.com/stretchr/testify"
-  version = "1.1.4"
+  name = "github.com/go-resty/resty"
+  version = "1.0.0"

Gopkg.toml

@@ -1,29 +1,22 @@
 package labstack
 
 import (
-	"sync"
+	"fmt"
 
-	"github.com/dghubble/sling"
-	glog "github.com/labstack/gommon/log"
+	"github.com/go-resty/resty"
+	"github.com/labstack/gommon/log"
 )
 
 type (
 	Client struct {
-		accountID string
-		apiKey    string
-		sling     *sling.Sling
-		logger    *glog.Logger
+		apiKey string
+		resty  *resty.Client
+		logger *log.Logger
 	}
 
-	Fields map[string]interface{}
-
-	SearchParameters struct {
-		Query       string   `json:"query"`
-		QueryString string   `json:"query_string"`
-		Since       string   `json:"since"`
-		Sort        []string `json:"sort"`
-		Size        int      `json:"size"`
-		From        int      `json:"from"`
+	APIError struct {
+		Code    int    `json:"code"`
+		Message string `json:"message"`
 	}
 )
 
@@ -32,34 +25,25 @@ const (
 )
 
 // NewClient creates a new client for the LabStack API.
-func NewClient(accountID, apiKey string) *Client {
+func NewClient(apiKey string) *Client {
 	return &Client{
-		accountID: accountID,
-		apiKey:    apiKey,
-		sling:     sling.New().Base(apiURL).Add("Authorization", "Bearer "+apiKey),
-		logger:    glog.New("labstack"),
+		apiKey: apiKey,
+		resty:  resty.New().SetHostURL(apiURL).SetAuthToken(apiKey),
+		logger: log.New("labstack"),
 	}
 }
 
-// Cube returns the cube service.
-func (c *Client) Cube() (cube *Cube) {
-	cube = &Cube{
-		sling:            c.sling.Path("/cube"),
-		mutex:            new(sync.RWMutex),
-		logger:           c.logger,
-		AccountID:        c.accountID,
-		APIKey:           c.apiKey,
-		BatchSize:        60,
-		DispatchInterval: 60,
+func (c *Client) Download(id string, path string) (err *APIError) {
+	err = new(APIError)
+	_, e := c.resty.R().
+		SetOutput(path).
+		Get(fmt.Sprintf("%s/%s", apiURL, id))
+	if e != nil {
+		err.Message = e.Error()
 	}
-	cube.resetRequests()
 	return
 }
 
-// Jet returns the jet service.
-func (c *Client) Jet() *Jet {
-	return &Jet{
-		sling:  c.sling.Path("/jet"),
-		logger: c.logger,
-	}
+func (e *APIError) Error() string {
+	return e.Message
 }