From 7eba722320c330aaa9e5b939904006101be7ef07 Mon Sep 17 00:00:00 2001
From: Ilyas Salikhov <salikhoff@gmail.com>
Date: Sat, 9 Dec 2017 22:39:14 +0300
Subject: [PATCH] =?UTF-8?q?=D0=97=D0=B0=D0=B3=D0=BE=D1=82=D0=BE=D0=B2?=
 =?UTF-8?q?=D0=BA=D0=B0=20=D0=B4=D0=BB=D1=8F=20=D1=80=D0=B0=D0=B1=D0=BE?=
 =?UTF-8?q?=D1=82=D1=8B=20=D1=81=20API?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .gitignore     |  31 ++++++++++++++
 client.go      | 112 +++++++++++++++++++++++++++++++++++++++++++++++++
 client_test.go |  45 ++++++++++++++++++++
 3 files changed, 188 insertions(+)
 create mode 100644 .gitignore
 create mode 100644 client.go
 create mode 100644 client_test.go

diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..cd35ca5
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,31 @@
+# Compiled Object files, Static and Dynamic libs (Shared Objects)
+*.o
+*.a
+*.so
+
+# Folders
+_obj
+
+# Architecture specific extensions/prefixes
+*.[568vq]
+[568vq].out
+
+*.cgo1.go
+*.cgo2.c
+_cgo_defun.c
+_cgo_gotypes.go
+_cgo_export.*
+
+_testmain.go
+
+*.exe
+*.test
+*.prof
+
+
+# IDE's files
+.idea
+*.iml
+
+# Project ignores
+
diff --git a/client.go b/client.go
new file mode 100644
index 0000000..1b37527
--- /dev/null
+++ b/client.go
@@ -0,0 +1,112 @@
+package retailcrm
+
+import (
+	"encoding/json"
+	"errors"
+	"fmt"
+	"io/ioutil"
+	"net/http"
+	"net/url"
+	"strings"
+	"time"
+)
+
+const (
+	ApiPrefix = "/api/v5"
+)
+
+type Client struct {
+	Url        string
+	apiKey     string
+	httpClient *http.Client
+}
+
+type ErrorResponse struct {
+	ErrorMsg string            `json:"errorMsg,omitempty"`
+	Errors   map[string]string `json:"errors,omitempty"`
+}
+
+func New(url string, apiKey string) *Client {
+	return &Client{
+		url,
+		apiKey,
+		&http.Client{Timeout: 20 * time.Second},
+	}
+}
+
+func (r *Client) GetRequest(urlWithParameters string) ([]byte, int, error) {
+	var res []byte
+
+	req, err := http.NewRequest("GET", fmt.Sprintf("%s%s%s", r.Url, ApiPrefix, urlWithParameters), nil)
+	if err != nil {
+		return res, 0, err
+	}
+
+	req.Header.Set("X-API-KEY", r.apiKey)
+
+	resp, err := r.httpClient.Do(req)
+	if err != nil {
+		return res, 0, err
+	}
+
+	if resp.StatusCode >= http.StatusInternalServerError {
+		return res, resp.StatusCode, errors.New(fmt.Sprintf("HTTP request error. Status code: %d.\n", resp.StatusCode))
+	}
+
+	res, err = buildRawResponse(resp)
+	if err != nil {
+		return res, 0, err
+	}
+
+	return res, resp.StatusCode, nil
+}
+
+func (r *Client) PostRequest(url string, postParams url.Values) ([]byte, int, error) {
+	var res []byte
+
+	req, err := http.NewRequest(
+		"POST",
+		fmt.Sprintf("%s%s%s", r.Url, ApiPrefix, url),
+		strings.NewReader(postParams.Encode()),
+	)
+	if err != nil {
+		return res, 0, err
+	}
+
+	req.Header.Set("Content-Type", "application/x-www-form-urlencoded")
+	req.Header.Set("X-API-KEY", r.apiKey)
+
+	resp, err := r.httpClient.Do(req)
+	if err != nil {
+		return res, 0, err
+	}
+
+	if resp.StatusCode >= http.StatusInternalServerError {
+		return res, resp.StatusCode, errors.New(fmt.Sprintf("HTTP request error. Status code: %d.\n", resp.StatusCode))
+	}
+
+	res, err = buildRawResponse(resp)
+	if err != nil {
+		return res, 0, err
+	}
+
+	return res, resp.StatusCode, nil
+}
+
+func buildRawResponse(resp *http.Response) ([]byte, error) {
+	defer resp.Body.Close()
+
+	res, err := ioutil.ReadAll(resp.Body)
+	if err != nil {
+		return res, err
+	}
+
+	return res, nil
+}
+
+func (r *Client) ErrorResponse(data []byte) (*ErrorResponse, error) {
+	var resp ErrorResponse
+	err := json.Unmarshal(data, &resp)
+
+	return &resp, err
+}
diff --git a/client_test.go b/client_test.go
new file mode 100644
index 0000000..80110ae
--- /dev/null
+++ b/client_test.go
@@ -0,0 +1,45 @@
+package retailcrm
+
+import (
+	"net/http"
+	"net/url"
+	"testing"
+)
+
+const (
+	TestUrl        = "https://demo.retailcrm.ru"
+	TestApiKey     = "111"
+	WrongApiKeyMsg = "Wrong \"apiKey\" value."
+)
+
+func client() *Client {
+	return New(TestUrl, TestApiKey)
+}
+
+func TestGetRequest(t *testing.T) {
+	c := client()
+
+	data, status, _ := c.GetRequest("/store/products")
+	if status != http.StatusForbidden {
+		t.Fail()
+	}
+
+	resp, _ := c.ErrorResponse(data)
+	if resp.ErrorMsg != WrongApiKeyMsg {
+		t.Fail()
+	}
+}
+
+func TestPostRequest(t *testing.T) {
+	c := client()
+
+	data, status, _ := c.PostRequest("/orders/create", url.Values{})
+	if status != http.StatusForbidden {
+		t.Fail()
+	}
+
+	resp, _ := c.ErrorResponse(data)
+	if resp.ErrorMsg != WrongApiKeyMsg {
+		t.Fail()
+	}
+}