alpha version of Karbon implementation

client/client.go

@@ -17,11 +17,11 @@ import (
 )
 
 const (
-	libraryVersion = "v3"
+	// libraryVersion = "v3"
 	defaultBaseURL = "https://%s/"
-	absolutePath   = "api/nutanix/" + libraryVersion
-	userAgent      = "nutanix/" + libraryVersion
-	mediaType      = "application/json"
+	// absolutePath   = "api/nutanix/" + libraryVersion
+	// userAgent      = "nutanix/" + libraryVersion
+	mediaType = "application/json"
 )
 
 // Client Config Configuration of the client
@@ -41,6 +41,9 @@ type Client struct {
 
 	// Optional function called after every successful request made.
 	onRequestCompleted RequestCompletionCallback
+
+	// absolutePath: for example api/nutanix/v3
+	AbsolutePath string
 }
 
 // RequestCompletionCallback defines the type of the request callback function
@@ -59,7 +62,14 @@ type Credentials struct {
 }
 
 // NewClient returns a new Nutanix API client.
-func NewClient(credentials *Credentials) (*Client, error) {
+func NewClient(credentials *Credentials, userAgent string, absolutePath string) (*Client, error) {
+	if userAgent == "" {
+		return nil, fmt.Errorf("userAgent argument must be passed")
+	}
+	if absolutePath == "" {
+		return nil, fmt.Errorf("absolutePath argument must be passed")
+	}
+
 	transCfg := &http.Transport{
 		// nolint:gas
 		TLSClientConfig: &tls.Config{InsecureSkipVerify: credentials.Insecure}, // ignore expired SSL certificates
@@ -85,7 +95,7 @@ func NewClient(credentials *Credentials) (*Client, error) {
 		return nil, err
 	}
 
-	c := &Client{credentials, httpClient, baseURL, userAgent, nil, nil}
+	c := &Client{credentials, httpClient, baseURL, userAgent, nil, nil, absolutePath}
 
 	if credentials.SessionAuth {
 		log.Printf("[DEBUG] Using session_auth\n")
@@ -117,7 +127,7 @@ func NewClient(credentials *Credentials) (*Client, error) {
 
 // NewRequest creates a request
 func (c *Client) NewRequest(ctx context.Context, method, urlStr string, body interface{}) (*http.Request, error) {
-	rel, errp := url.Parse(absolutePath + urlStr)
+	rel, errp := url.Parse(c.AbsolutePath + urlStr)
 	if errp != nil {
 		return nil, errp
 	}
@@ -156,7 +166,7 @@ func (c *Client) NewRequest(ctx context.Context, method, urlStr string, body int
 
 // NewUploadRequest Handles image uploads for image service
 func (c *Client) NewUploadRequest(ctx context.Context, method, urlStr string, body []byte) (*http.Request, error) {
-	rel, errp := url.Parse(absolutePath + urlStr)
+	rel, errp := url.Parse(c.AbsolutePath + urlStr)
 	if errp != nil {
 		return nil, errp
 	}
@@ -235,6 +245,7 @@ func CheckResponse(r *http.Response) error {
 	if c >= 200 && c <= 299 {
 		return nil
 	}
+	log.Print("[DEBUG] after status check")
 
 	// Nutanix returns non-json response with code 401 when
 	// invalid credentials are used
@@ -247,26 +258,27 @@ func CheckResponse(r *http.Response) error {
 	if err != nil {
 		return err
 	}
-
+	log.Print("[DEBUG] after readall")
 	rdr2 := ioutil.NopCloser(bytes.NewBuffer(buf))
 
 	r.Body = rdr2
-
+	log.Print("[DEBUG] after rdr2")
 	// if has entities -> return nil
 	// if has message_list -> check_error["state"]
 	// if has status -> check_error["status.state"]
 	if len(buf) == 0 {
 		return nil
 	}
+	log.Print("[DEBUG] after len(buf)")
 
 	var res map[string]interface{}
 	err = json.Unmarshal(buf, &res)
 	if err != nil {
 		return fmt.Errorf("unmarshalling error response %s", err)
 	}
+	log.Print("[DEBUG] after json.Unmarshal")
 
 	errRes := &ErrorResponse{}
-
 	if status, ok := res["status"]; ok {
 		_, sok := status.(string)
 		if sok {
@@ -280,14 +292,26 @@ func CheckResponse(r *http.Response) error {
 		return nil
 	}
 
+	log.Print("[DEBUG] after bunch of switch cases")
 	if err != nil {
 		return err
 	}
+	log.Print("[DEBUG] first nil check")
 
+	//karbon error check
+	if message_info, ok := res["message_info"]; ok {
+		log.Print(message_info)
+		return fmt.Errorf("error: %s", message_info)
+	}
+	if message, ok := res["message"]; ok {
+		log.Print(message)
+		return fmt.Errorf("error: %s", message)
+	}
 	if errRes.State != "ERROR" {
 		return nil
 	}
 
+	log.Print("[DEBUG] after errRes.State")
 	pretty, _ := json.MarshalIndent(errRes, "", "  ")
 	return fmt.Errorf("error: %s", string(pretty))
 }

client/client_test.go

@@ -12,18 +12,24 @@ import (
 	"testing"
 )
 
+const (
+	testLibraryVersion = "v3"
+	testAbsolutePath   = "api/nutanix/" + testLibraryVersion
+	testUserAgent      = "nutanix/" + testLibraryVersion
+)
+
 func setup() (*http.ServeMux, *Client, *httptest.Server) {
 	mux := http.NewServeMux()
 	server := httptest.NewServer(mux)
 
-	client, _ := NewClient(&Credentials{"", "username", "password", "", "", true, false, ""})
+	client, _ := NewClient(&Credentials{"", "username", "password", "", "", true, false, ""}, testUserAgent, testAbsolutePath)
 	client.BaseURL, _ = url.Parse(server.URL)
 
 	return mux, client, server
 }
 
 func TestNewClient(t *testing.T) {
-	c, err := NewClient(&Credentials{"foo.com", "username", "password", "", "", true, false, ""})
+	c, err := NewClient(&Credentials{"foo.com", "username", "password", "", "", true, false, ""}, testUserAgent, testAbsolutePath)
 
 	if err != nil {
 		t.Errorf("Unexpected Error: %v", err)
@@ -35,19 +41,19 @@ func TestNewClient(t *testing.T) {
 		t.Errorf("NewClient BaseURL = %v, expected %v", c.BaseURL, expectedURL)
 	}
 
-	if c.UserAgent != userAgent {
-		t.Errorf("NewClient UserAgent = %v, expected %v", c.UserAgent, userAgent)
+	if c.UserAgent != testUserAgent {
+		t.Errorf("NewClient UserAgent = %v, expected %v", c.UserAgent, testUserAgent)
 	}
 }
 
 func TestNewRequest(t *testing.T) {
-	c, err := NewClient(&Credentials{"foo.com", "username", "password", "", "", true, false, ""})
+	c, err := NewClient(&Credentials{"foo.com", "username", "password", "", "", true, false, ""}, testUserAgent, testAbsolutePath)
 
 	if err != nil {
 		t.Errorf("Unexpected Error: %v", err)
 	}
 
-	inURL, outURL := "/foo", fmt.Sprintf(defaultBaseURL+absolutePath+"/foo", "foo.com")
+	inURL, outURL := "/foo", fmt.Sprintf(defaultBaseURL+testAbsolutePath+"/foo", "foo.com")
 	inBody, outBody := map[string]interface{}{"name": "bar"}, `{"name":"bar"}`+"\n"
 
 	req, _ := c.NewRequest(context.TODO(), http.MethodPost, inURL, inBody)

client/karbon/karbon_api.go

@@ -0,0 +1,38 @@
+package karbon
+
+import (
+	"github.com/terraform-providers/terraform-provider-nutanix/client"
+)
+
+const (
+	absolutePath = "karbon"
+	userAgent    = "nutanix"
+)
+
+// Client manages the V3 API
+type Client struct {
+	client          *client.Client
+	Cluster         ClusterService
+	PrivateRegistry PrivateRegistryService
+}
+
+// NewKarbonAPIClient return a client to operate Karbon resources
+func NewKarbonAPIClient(credentials client.Credentials) (*Client, error) {
+	c, err := client.NewClient(&credentials, userAgent, absolutePath)
+
+	if err != nil {
+		return nil, err
+	}
+
+	f := &Client{
+		client: c,
+		Cluster: ClusterOperations{
+			client: c,
+		},
+		PrivateRegistry: PrivateRegistryOperations{
+			client: c,
+		},
+	}
+
+	return f, nil
+}