mirror of
https://github.com/retailcrm/api-client-go.git
synced 2025-04-04 05:33:32 +03:00
multiversion structure
This commit is contained in:
Alex Lushpai
parent
0291ca92a9
commit
c7f57a271b
14 changed files with 587 additions and 508 deletions
142
client.go
142
client.go
|
|
@ -1,142 +0,0 @@
|
|||
package retailcrm
|
||||
|
||||
import (
|
||||
"encoding/json"
|
||||
"errors"
|
||||
"fmt"
|
||||
"io/ioutil"
|
||||
"net/http"
|
||||
"net/url"
|
||||
"strings"
|
||||
"time"
|
||||
)
|
||||
|
||||
const (
|
||||
apiPrefix = "/api"
|
||||
)
|
||||
|
||||
// Client type
|
||||
type Client struct {
|
||||
Url string
|
||||
Key string
|
||||
Version string
|
||||
httpClient *http.Client
|
||||
}
|
||||
|
||||
// ErrorResponse type
|
||||
type ErrorResponse struct {
|
||||
ErrorMsg string `json:"errorMsg,omitempty"`
|
||||
Errors map[string]string `json:"errors,omitempty"`
|
||||
}
|
||||
|
||||
// New initalize client
|
||||
func New(url string, key string, version string) *Client {
|
||||
return &Client {
|
||||
url,
|
||||
key,
|
||||
version,
|
||||
&http.Client{Timeout: 20 * time.Second},
|
||||
}
|
||||
}
|
||||
|
||||
func buildUrl(url string, version string) string {
|
||||
var versionPlaceholder string = "/" + version
|
||||
if version == "" {
|
||||
versionPlaceholder = ""
|
||||
}
|
||||
|
||||
var requestUrl = fmt.Sprintf("%s%s%s", url, apiPrefix, versionPlaceholder)
|
||||
|
||||
return requestUrl
|
||||
}
|
||||
|
||||
func (c *Client) getRequest(urlWithParameters string) ([]byte, int, error) {
|
||||
var res []byte
|
||||
var reqUrl = buildUrl(c.Url, c.Version)
|
||||
|
||||
req, err := http.NewRequest("GET", fmt.Sprintf("%s%s", reqUrl , urlWithParameters), nil)
|
||||
if err != nil {
|
||||
return res, 0, err
|
||||
}
|
||||
|
||||
req.Header.Set("X-API-KEY", c.Key)
|
||||
|
||||
resp, err := c.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 (c *Client) postRequest(url string, postParams url.Values) ([]byte, int, error) {
|
||||
var res []byte
|
||||
var reqUrl = buildUrl(c.Url, c.Version)
|
||||
|
||||
req, err := http.NewRequest(
|
||||
"POST",
|
||||
fmt.Sprintf("%s%s", reqUrl, 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", c.Key)
|
||||
|
||||
resp, err := c.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
|
||||
}
|
||||
|
||||
// ErrorResponse method
|
||||
func (c *Client) ErrorResponse(data []byte) (*ErrorResponse, error) {
|
||||
var resp ErrorResponse
|
||||
err := json.Unmarshal(data, &resp)
|
||||
|
||||
return &resp, err
|
||||
}
|
||||
|
||||
// CheckBy select identifier type
|
||||
func CheckBy(by string) string {
|
||||
var context = "id"
|
||||
|
||||
if by != "id" {
|
||||
context = "externalId"
|
||||
}
|
||||
|
||||
return context
|
||||
}
|
||||
|
|
@ -1,46 +0,0 @@
|
|||
package retailcrm
|
||||
|
||||
import (
|
||||
"net/http"
|
||||
"net/url"
|
||||
"testing"
|
||||
)
|
||||
|
||||
const (
|
||||
TestUrl = "https://demo.retailcrm.ru"
|
||||
TestApiKey = "111"
|
||||
TestVersion = "v5"
|
||||
WrongApiKeyMsg = "Wrong \"apiKey\" value."
|
||||
)
|
||||
|
||||
func client() *Client {
|
||||
return New(TestUrl, TestApiKey, TestVersion)
|
||||
}
|
||||
|
||||
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()
|
||||
}
|
||||
}
|
||||
|
|
@ -1,5 +1,4 @@
|
|||
{
|
||||
"url": "https://demo.retailcrm.ru",
|
||||
"key": "Bz9SLca32BYgv2R6yQMlDCUSgO018257",
|
||||
"version": "v5"
|
||||
"key": "111"
|
||||
}
|
||||
|
|
|
|||
|
|
@ -1,40 +0,0 @@
|
|||
package retailcrm
|
||||
|
||||
import (
|
||||
"encoding/json"
|
||||
"os"
|
||||
"fmt"
|
||||
)
|
||||
|
||||
type Configuration struct {
|
||||
Url string `json:"url"`
|
||||
Key string `json:"key"`
|
||||
Ver string `json:"version"`
|
||||
}
|
||||
|
||||
func buildConfiguration() *Configuration {
|
||||
file, _ := os.Open("config.json")
|
||||
decoder := json.NewDecoder(file)
|
||||
configuration := Configuration{}
|
||||
err := decoder.Decode(&configuration)
|
||||
if err != nil {
|
||||
fmt.Println("error:", err)
|
||||
}
|
||||
|
||||
return &Configuration {
|
||||
configuration.Url,
|
||||
configuration.Key,
|
||||
configuration.Ver,
|
||||
}
|
||||
}
|
||||
|
||||
func UnversionedClient() *Client {
|
||||
configuration := buildConfiguration()
|
||||
return New(configuration.Url, configuration.Key, "")
|
||||
}
|
||||
|
||||
func VersionedClient() *Client {
|
||||
configuration := buildConfiguration()
|
||||
return New(configuration.Url, configuration.Key, configuration.Ver)
|
||||
}
|
||||
|
||||
|
|
@ -1,46 +0,0 @@
|
|||
package retailcrm
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"encoding/json"
|
||||
"net/http"
|
||||
"errors"
|
||||
)
|
||||
|
||||
// ApiVersions get available API versions
|
||||
func (c *Client) ApiVersions() (*VersionResponse, int, error) {
|
||||
var resp VersionResponse
|
||||
data, status, err := c.getRequest(fmt.Sprintf("/api-versions"))
|
||||
|
||||
if err != nil {
|
||||
return &resp, status, err
|
||||
}
|
||||
|
||||
if status >= http.StatusBadRequest {
|
||||
return &resp, status, errors.New(fmt.Sprintf("HTTP request error. Status code: %d.\n", status))
|
||||
}
|
||||
|
||||
err = json.Unmarshal(data, &resp)
|
||||
|
||||
return &resp, status, err
|
||||
}
|
||||
|
||||
// ApiCredentials get available API methods
|
||||
func (c *Client) ApiCredentials() (*CredentialResponse, int, error) {
|
||||
var resp CredentialResponse
|
||||
data, status, err := c.getRequest(fmt.Sprintf("/credentials"))
|
||||
|
||||
if err != nil {
|
||||
return &resp, status, err
|
||||
}
|
||||
|
||||
if status >= http.StatusBadRequest {
|
||||
return &resp, status, errors.New(fmt.Sprintf("HTTP request error. Status code: %d.\n", status))
|
||||
}
|
||||
|
||||
err = json.Unmarshal(data, &resp)
|
||||
|
||||
return &resp, status, err
|
||||
}
|
||||
|
||||
|
||||
|
|
@ -1,42 +0,0 @@
|
|||
package retailcrm
|
||||
|
||||
import (
|
||||
"testing"
|
||||
"net/http"
|
||||
)
|
||||
|
||||
func TestVersions(t *testing.T) {
|
||||
c := UnversionedClient()
|
||||
|
||||
data, status, err := c.ApiVersions()
|
||||
|
||||
if err != nil {
|
||||
t.Fail()
|
||||
}
|
||||
|
||||
if status >= http.StatusBadRequest {
|
||||
t.Fail()
|
||||
}
|
||||
|
||||
if data.Success != true {
|
||||
t.Fail()
|
||||
}
|
||||
}
|
||||
|
||||
func TestCredentials(t *testing.T) {
|
||||
c := UnversionedClient()
|
||||
|
||||
data, status, err := c.ApiCredentials()
|
||||
|
||||
if err != nil {
|
||||
t.Fail()
|
||||
}
|
||||
|
||||
if status >= http.StatusBadRequest {
|
||||
t.Fail()
|
||||
}
|
||||
|
||||
if data.Success != true {
|
||||
t.Fail()
|
||||
}
|
||||
}
|
||||
|
|
@ -1,60 +0,0 @@
|
|||
package retailcrm
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"net/http"
|
||||
"errors"
|
||||
"encoding/json"
|
||||
"github.com/google/go-querystring/query"
|
||||
)
|
||||
|
||||
// Customer get method
|
||||
func (c *Client) Customer(id, by, site string) (*CustomerResponse, int, error) {
|
||||
var resp CustomerResponse
|
||||
var context = CheckBy(by)
|
||||
|
||||
fw := CustomerGetFilter{context, site}
|
||||
params, _ := query.Values(fw)
|
||||
data, status, err := c.getRequest(fmt.Sprintf("/customers/%s?%s", id, params.Encode()))
|
||||
if err != nil {
|
||||
return &resp, status, err
|
||||
}
|
||||
|
||||
if status >= http.StatusBadRequest {
|
||||
return &resp, status, errors.New(fmt.Sprintf("HTTP request error. Status code: %d.\n", status))
|
||||
}
|
||||
|
||||
err = json.Unmarshal(data, &resp)
|
||||
|
||||
return &resp, status, err
|
||||
}
|
||||
|
||||
// Customers list method
|
||||
func (c *Client) Customers(filter CustomersFilter, limit, page int) (*CustomersResponse, int, error) {
|
||||
var resp CustomersResponse
|
||||
|
||||
if limit == 0 {
|
||||
limit = 20
|
||||
}
|
||||
|
||||
if page == 0 {
|
||||
page = 1
|
||||
}
|
||||
|
||||
fw := CustomersParameters{filter, limit, page}
|
||||
params, _ := query.Values(fw)
|
||||
|
||||
data, status, err := c.getRequest(fmt.Sprintf("/customers?%s", params.Encode()))
|
||||
|
||||
if err != nil {
|
||||
return &resp, status, err
|
||||
}
|
||||
|
||||
if status >= http.StatusBadRequest {
|
||||
return &resp, status, errors.New(fmt.Sprintf("HTTP request error. Status code: %d.\n", status))
|
||||
}
|
||||
|
||||
err = json.Unmarshal(data, &resp)
|
||||
|
||||
return &resp, status, err
|
||||
}
|
||||
|
|
@ -1,54 +0,0 @@
|
|||
package retailcrm
|
||||
|
||||
import (
|
||||
"testing"
|
||||
"net/http"
|
||||
)
|
||||
|
||||
func TestCustomer(t *testing.T) {
|
||||
c := VersionedClient()
|
||||
data, status, err := c.Customer("163", "id", "")
|
||||
|
||||
if err != nil {
|
||||
t.Errorf("%s", err)
|
||||
t.Fail()
|
||||
}
|
||||
|
||||
if status >= http.StatusBadRequest {
|
||||
t.Errorf("%s", err)
|
||||
t.Fail()
|
||||
}
|
||||
|
||||
if data.Success != true {
|
||||
t.Errorf("%s", err)
|
||||
t.Fail()
|
||||
}
|
||||
|
||||
if data.Customer.Id != 163 {
|
||||
t.Errorf("%s", err)
|
||||
t.Fail()
|
||||
}
|
||||
}
|
||||
|
||||
func TestCustomers(t *testing.T) {
|
||||
c := VersionedClient()
|
||||
f := CustomersFilter{}
|
||||
f.City = "Москва"
|
||||
|
||||
data, status, err := c.Customers(f, 20, 1)
|
||||
|
||||
if err != nil {
|
||||
t.Errorf("%s", err)
|
||||
t.Fail()
|
||||
}
|
||||
|
||||
if status >= http.StatusBadRequest {
|
||||
t.Errorf("%s", err)
|
||||
t.Fail()
|
||||
}
|
||||
|
||||
if data.Success != true {
|
||||
t.Errorf("%s", err)
|
||||
t.Fail()
|
||||
}
|
||||
}
|
||||
12
retailcrm.go
Normal file
12
retailcrm.go
Normal file
|
|
@ -0,0 +1,12 @@
|
|||
package retailcrm
|
||||
|
||||
import (
|
||||
"github.com/retailcrm/api-client-go/v5"
|
||||
)
|
||||
|
||||
// Version5 API client for v5
|
||||
func Version5(url string, key string) *v5.Client {
|
||||
var client = v5.New(url, key)
|
||||
|
||||
return client
|
||||
}
|
||||
15
types_api.go
15
types_api.go
|
|
@ -1,15 +0,0 @@
|
|||
package retailcrm
|
||||
|
||||
// VersionResponse return available API versions
|
||||
type VersionResponse struct {
|
||||
Success bool `json:"success,omitempty"`
|
||||
Versions []string `json:"versions,brackets,omitempty"`
|
||||
}
|
||||
|
||||
// CredentialResponse return available API methods
|
||||
type CredentialResponse struct {
|
||||
Success bool `json:"success,omitempty"`
|
||||
Credentials []string `json:"credentials,brackets,omitempty"`
|
||||
SiteAccess string `json:"siteAccess,omitempty"`
|
||||
SitesAvailable []string `json:"sitesAvailable,brackets,omitempty"`
|
||||
}
|
||||
|
|
@ -1,60 +0,0 @@
|
|||
package retailcrm
|
||||
|
||||
// Pagination type
|
||||
type Pagination struct {
|
||||
Limit int `json:"limit,omitempty"`
|
||||
TotalCount int `json:"totalCount,omitempty"`
|
||||
CurrentPage int `json:"currentPage,omitempty"`
|
||||
TotalPageCount int `json:"totalPageCount,omitempty"`
|
||||
}
|
||||
|
||||
// Address type
|
||||
type Address struct {
|
||||
Index string `json:"index,omitempty"`
|
||||
CountryIso string `json:"countryIso,omitempty"`
|
||||
Region string `json:"region,omitempty"`
|
||||
RegionId int `json:"regionId,omitempty"`
|
||||
City string `json:"city,omitempty"`
|
||||
CityId int `json:"cityId,omitempty"`
|
||||
CityType string `json:"cityType,omitempty"`
|
||||
Street string `json:"street,omitempty"`
|
||||
StreetId int `json:"streetId,omitempty"`
|
||||
StreetType string `json:"streetType,omitempty"`
|
||||
Building string `json:"building,omitempty"`
|
||||
Flat string `json:"flat,omitempty"`
|
||||
IntercomCode string `json:"intercomCode,omitempty"`
|
||||
Floor int `json:"floor,omitempty"`
|
||||
Block int `json:"block,omitempty"`
|
||||
House string `json:"house,omitempty"`
|
||||
Metro string `json:"metro,omitempty"`
|
||||
Notes string `json:"notes,omitempty"`
|
||||
Text string `json:"text,omitempty"`
|
||||
}
|
||||
|
||||
// Source type
|
||||
type Source struct {
|
||||
Source string `json:"source,omitempty"`
|
||||
Medium string `json:"medium,omitempty"`
|
||||
Campaign string `json:"campaign,omitempty"`
|
||||
Keyword string `json:"keyword,omitempty"`
|
||||
Content string `json:"content,omitempty"`
|
||||
}
|
||||
|
||||
// Contragent type
|
||||
type Contragent struct {
|
||||
ContragentType string `json:"contragentType,omitempty"`
|
||||
LegalName string `json:"legalName,omitempty"`
|
||||
LegalAddress string `json:"legalAddress,omitempty"`
|
||||
INN string `json:"INN,omitempty"`
|
||||
OKPO string `json:"OKPO,omitempty"`
|
||||
KPP string `json:"KPP,omitempty"`
|
||||
OGRN string `json:"OGRN,omitempty"`
|
||||
OGRNIP string `json:"OGRNIP,omitempty"`
|
||||
CertificateNumber string `json:"certificateNumber,omitempty"`
|
||||
CertificateDate string `json:"certificateDate,omitempty"`
|
||||
BIK string `json:"BIK,omitempty"`
|
||||
Bank string `json:"bank,omitempty"`
|
||||
BankAddress string `json:"bankAddress,omitempty"`
|
||||
CorrAccount string `json:"corrAccount,omitempty"`
|
||||
BankAccount string `json:"bankAccount,omitempty"`
|
||||
}
|
||||
287
v5/client.go
Normal file
287
v5/client.go
Normal file
|
|
@ -0,0 +1,287 @@
|
|||
package v5
|
||||
|
||||
import (
|
||||
"errors"
|
||||
"fmt"
|
||||
"encoding/json"
|
||||
"io/ioutil"
|
||||
"net/http"
|
||||
"net/url"
|
||||
"strings"
|
||||
"strconv"
|
||||
"time"
|
||||
"github.com/google/go-querystring/query"
|
||||
)
|
||||
|
||||
const (
|
||||
versionedPrefix = "/api/v5"
|
||||
unversionedPrefix = "/api"
|
||||
)
|
||||
|
||||
// Client type
|
||||
type Client struct {
|
||||
Url string
|
||||
Key string
|
||||
httpClient *http.Client
|
||||
}
|
||||
|
||||
// ErrorResponse type
|
||||
type ErrorResponse struct {
|
||||
ErrorMsg string `json:"errorMsg,omitempty"`
|
||||
Errors map[string]string `json:"errors,omitempty"`
|
||||
}
|
||||
|
||||
// New initalize client
|
||||
func New(url string, key string) *Client {
|
||||
return &Client{
|
||||
url,
|
||||
key,
|
||||
&http.Client{Timeout: 20 * time.Second},
|
||||
}
|
||||
}
|
||||
|
||||
func (c *Client) getRequest(urlWithParameters string) ([]byte, int, error) {
|
||||
var res []byte
|
||||
|
||||
req, err := http.NewRequest("GET", fmt.Sprintf("%s%s", c.Url , urlWithParameters), nil)
|
||||
if err != nil {
|
||||
return res, 0, err
|
||||
}
|
||||
|
||||
req.Header.Set("X-API-KEY", c.Key)
|
||||
|
||||
resp, err := c.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 (c *Client) postRequest(url string, postParams url.Values) ([]byte, int, error) {
|
||||
var res []byte
|
||||
|
||||
req, err := http.NewRequest(
|
||||
"POST",
|
||||
fmt.Sprintf("%s%s", c.Url, 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", c.Key)
|
||||
|
||||
resp, err := c.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
|
||||
}
|
||||
|
||||
// ErrorResponse method
|
||||
func (c *Client) ErrorResponse(data []byte) (*ErrorResponse, error) {
|
||||
var resp ErrorResponse
|
||||
err := json.Unmarshal(data, &resp)
|
||||
|
||||
return &resp, err
|
||||
}
|
||||
|
||||
// checkBy select identifier type
|
||||
func checkBy(by string) string {
|
||||
var context = "id"
|
||||
|
||||
if by != "id" {
|
||||
context = "externalId"
|
||||
}
|
||||
|
||||
return context
|
||||
}
|
||||
|
||||
// ApiVersions get available API versions
|
||||
func (c *Client) ApiVersions() (*VersionResponse, int, error) {
|
||||
var resp VersionResponse
|
||||
data, status, err := c.getRequest(fmt.Sprintf("%s/api-versions", unversionedPrefix))
|
||||
|
||||
if err != nil {
|
||||
return &resp, status, err
|
||||
}
|
||||
|
||||
if status >= http.StatusBadRequest {
|
||||
return &resp, status, errors.New(fmt.Sprintf("HTTP request error. Status code: %d.\n", status))
|
||||
}
|
||||
|
||||
err = json.Unmarshal(data, &resp)
|
||||
|
||||
return &resp, status, err
|
||||
}
|
||||
|
||||
// ApiCredentials get available API methods
|
||||
func (c *Client) ApiCredentials() (*CredentialResponse, int, error) {
|
||||
var resp CredentialResponse
|
||||
data, status, err := c.getRequest(fmt.Sprintf("%s/credentials", unversionedPrefix))
|
||||
|
||||
if err != nil {
|
||||
return &resp, status, err
|
||||
}
|
||||
|
||||
if status >= http.StatusBadRequest {
|
||||
return &resp, status, errors.New(fmt.Sprintf("HTTP request error. Status code: %d.\n", status))
|
||||
}
|
||||
|
||||
err = json.Unmarshal(data, &resp)
|
||||
|
||||
return &resp, status, err
|
||||
}
|
||||
|
||||
// Customer get method
|
||||
func (c *Client) Customer(id, by, site string) (*CustomerResponse, int, error) {
|
||||
var resp CustomerResponse
|
||||
var context = checkBy(by)
|
||||
|
||||
fw := CustomerGetFilter{context, site}
|
||||
params, _ := query.Values(fw)
|
||||
data, status, err := c.getRequest(fmt.Sprintf("%s/customers/%s?%s", versionedPrefix, id, params.Encode()))
|
||||
if err != nil {
|
||||
return &resp, status, err
|
||||
}
|
||||
|
||||
if status >= http.StatusBadRequest {
|
||||
return &resp, status, errors.New(fmt.Sprintf("HTTP request error. Status code: %d.\n", status))
|
||||
}
|
||||
|
||||
err = json.Unmarshal(data, &resp)
|
||||
|
||||
return &resp, status, err
|
||||
}
|
||||
|
||||
// Customers list method
|
||||
func (c *Client) Customers(filter CustomersFilter, limit, page int) (*CustomersResponse, int, error) {
|
||||
var resp CustomersResponse
|
||||
|
||||
if limit == 0 {
|
||||
limit = 20
|
||||
}
|
||||
|
||||
if page == 0 {
|
||||
page = 1
|
||||
}
|
||||
|
||||
fw := CustomersParameters{filter, limit, page}
|
||||
params, _ := query.Values(fw)
|
||||
|
||||
data, status, err := c.getRequest(fmt.Sprintf("%s/customers?%s", versionedPrefix, params.Encode()))
|
||||
|
||||
if err != nil {
|
||||
return &resp, status, err
|
||||
}
|
||||
|
||||
if status >= http.StatusBadRequest {
|
||||
return &resp, status, errors.New(fmt.Sprintf("HTTP request error. Status code: %d.\n", status))
|
||||
}
|
||||
|
||||
err = json.Unmarshal(data, &resp)
|
||||
|
||||
return &resp, status, err
|
||||
}
|
||||
|
||||
func (c *Client) CustomerCreate(customer Customer, site ...string) (*CustomerChangeResponse, int, error) {
|
||||
var resp CustomerChangeResponse
|
||||
customerJson, _ := json.Marshal(&customer)
|
||||
|
||||
p := url.Values{
|
||||
"customer": {string(customerJson[:])},
|
||||
}
|
||||
|
||||
if len(site) > 0 {
|
||||
s := site[0]
|
||||
|
||||
if s != "" {
|
||||
p.Add("site", s)
|
||||
}
|
||||
}
|
||||
|
||||
data, status, err := c.postRequest(fmt.Sprintf("%s/customers/create", versionedPrefix), p)
|
||||
|
||||
|
||||
if err != nil {
|
||||
return &resp, status, err
|
||||
}
|
||||
|
||||
if status >= http.StatusBadRequest {
|
||||
return &resp, status, errors.New(fmt.Sprintf("HTTP request error. Status code: %d.\n", status))
|
||||
}
|
||||
|
||||
err = json.Unmarshal(data, &resp)
|
||||
|
||||
return &resp, status, err
|
||||
}
|
||||
|
||||
func (c *Client) CustomerEdit(customer Customer, by string, site ...string) (*CustomerChangeResponse, int, error) {
|
||||
var resp CustomerChangeResponse
|
||||
var uid = strconv.Itoa(customer.Id)
|
||||
var context = checkBy(by)
|
||||
|
||||
if context == "externalId" {
|
||||
uid = customer.ExternalId
|
||||
}
|
||||
|
||||
customerJson, _ := json.Marshal(&customer)
|
||||
|
||||
p := url.Values{
|
||||
"by": {string(context)},
|
||||
"customer": {string(customerJson[:])},
|
||||
}
|
||||
|
||||
if len(site) > 0 {
|
||||
s := site[0]
|
||||
|
||||
if s != "" {
|
||||
p.Add("site", s)
|
||||
}
|
||||
}
|
||||
|
||||
data, status, err := c.postRequest(fmt.Sprintf("%s/customers/%s/edit", versionedPrefix, uid), p)
|
||||
if err != nil {
|
||||
return &resp, status, err
|
||||
}
|
||||
|
||||
if status >= http.StatusBadRequest {
|
||||
return &resp, status, errors.New(fmt.Sprintf("HTTP request error. Status code: %d.\n", status))
|
||||
}
|
||||
|
||||
err = json.Unmarshal(data, &resp)
|
||||
|
||||
return &resp, status, err
|
||||
}
|
||||
207
v5/client_test.go
Normal file
207
v5/client_test.go
Normal file
|
|
@ -0,0 +1,207 @@
|
|||
package v5
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"time"
|
||||
"os"
|
||||
"testing"
|
||||
"net/http"
|
||||
"net/url"
|
||||
"encoding/json"
|
||||
"math/rand"
|
||||
)
|
||||
|
||||
type Configuration struct {
|
||||
Url string `json:"url"`
|
||||
Key string `json:"key"`
|
||||
Ver string `json:"version"`
|
||||
}
|
||||
|
||||
func buildConfiguration() *Configuration {
|
||||
file, _ := os.Open("../config.json")
|
||||
decoder := json.NewDecoder(file)
|
||||
configuration := Configuration{}
|
||||
err := decoder.Decode(&configuration)
|
||||
if err != nil {
|
||||
fmt.Println("error:", err)
|
||||
}
|
||||
|
||||
return &Configuration {
|
||||
configuration.Url,
|
||||
configuration.Key,
|
||||
configuration.Ver,
|
||||
}
|
||||
}
|
||||
|
||||
var r *rand.Rand // Rand for this package.
|
||||
|
||||
func init() {
|
||||
r = rand.New(rand.NewSource(time.Now().UnixNano()))
|
||||
}
|
||||
|
||||
func RandomString(strlen int) string {
|
||||
const chars = "abcdefghijklmnopqrstuvwxyz0123456789"
|
||||
result := make([]byte, strlen)
|
||||
for i := range result {
|
||||
result[i] = chars[r.Intn(len(chars))]
|
||||
}
|
||||
return string(result)
|
||||
}
|
||||
|
||||
func client() *Client {
|
||||
configuration := buildConfiguration()
|
||||
return New(configuration.Url, configuration.Key)
|
||||
}
|
||||
|
||||
func TestGetRequest(t *testing.T) {
|
||||
c := client()
|
||||
|
||||
_, status, _ := c.getRequest("/fake-method")
|
||||
|
||||
if status != http.StatusNotFound {
|
||||
t.Fail()
|
||||
}
|
||||
}
|
||||
|
||||
func TestPostRequest(t *testing.T) {
|
||||
c := client()
|
||||
|
||||
_, status, _ := c.postRequest("/fake-method", url.Values{})
|
||||
|
||||
if status != http.StatusNotFound {
|
||||
t.Fail()
|
||||
}
|
||||
}
|
||||
|
||||
func TestClient_ApiVersionsVersions(t *testing.T) {
|
||||
c := client()
|
||||
|
||||
data, status, err := c.ApiVersions()
|
||||
|
||||
if err != nil {
|
||||
t.Fail()
|
||||
}
|
||||
|
||||
if status >= http.StatusBadRequest {
|
||||
t.Fail()
|
||||
}
|
||||
|
||||
if data.Success != true {
|
||||
t.Fail()
|
||||
}
|
||||
}
|
||||
|
||||
func TestClient_ApiCredentialsCredentials(t *testing.T) {
|
||||
c := client()
|
||||
|
||||
data, status, err := c.ApiCredentials()
|
||||
|
||||
if err != nil {
|
||||
t.Fail()
|
||||
}
|
||||
|
||||
if status >= http.StatusBadRequest {
|
||||
t.Fail()
|
||||
}
|
||||
|
||||
if data.Success != true {
|
||||
t.Fail()
|
||||
}
|
||||
}
|
||||
|
||||
func TestClient_CustomersCustomers(t *testing.T) {
|
||||
c := client()
|
||||
f := CustomersFilter{}
|
||||
f.City = "Москва"
|
||||
|
||||
data, status, err := c.Customers(f, 20, 1)
|
||||
|
||||
if err != nil {
|
||||
t.Errorf("%s", err)
|
||||
t.Fail()
|
||||
}
|
||||
|
||||
if status >= http.StatusBadRequest {
|
||||
t.Errorf("%s", err)
|
||||
t.Fail()
|
||||
}
|
||||
|
||||
if data.Success != true {
|
||||
t.Errorf("%s", err)
|
||||
t.Fail()
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
func TestClient_CustomerChange(t *testing.T) {
|
||||
c := client()
|
||||
f := Customer{}
|
||||
|
||||
random := RandomString(8)
|
||||
|
||||
f.FirstName = "Понтелей"
|
||||
f.LastName = "Турбин"
|
||||
f.Patronymic = "Аристархович"
|
||||
f.ExternalId = random
|
||||
f.Email = fmt.Sprintf("%s@example.com", random)
|
||||
|
||||
cr, sc, err := c.CustomerCreate(f)
|
||||
|
||||
if err != nil {
|
||||
t.Errorf("%s", err)
|
||||
t.Fail()
|
||||
}
|
||||
|
||||
if sc != http.StatusCreated {
|
||||
t.Errorf("%s", err)
|
||||
t.Fail()
|
||||
}
|
||||
|
||||
if cr.Success != true {
|
||||
t.Errorf("%s", err)
|
||||
t.Fail()
|
||||
}
|
||||
|
||||
f.Id = cr.Id
|
||||
f.Vip = true
|
||||
|
||||
ed, se, err := c.CustomerEdit(f, "id")
|
||||
|
||||
if err != nil {
|
||||
t.Errorf("%s", err)
|
||||
t.Fail()
|
||||
}
|
||||
|
||||
if se != http.StatusOK {
|
||||
t.Errorf("%s", err)
|
||||
t.Fail()
|
||||
}
|
||||
|
||||
if ed.Success != true {
|
||||
t.Errorf("%s", err)
|
||||
t.Fail()
|
||||
}
|
||||
|
||||
data, status, err := c.Customer(f.ExternalId, "externalId", "")
|
||||
|
||||
if err != nil {
|
||||
t.Errorf("%s", err)
|
||||
t.Fail()
|
||||
}
|
||||
|
||||
if status >= http.StatusBadRequest {
|
||||
t.Errorf("%s", err)
|
||||
t.Fail()
|
||||
}
|
||||
|
||||
if data.Success != true {
|
||||
t.Errorf("%s", err)
|
||||
t.Fail()
|
||||
}
|
||||
|
||||
if data.Customer.ExternalId != f.ExternalId {
|
||||
t.Errorf("%s", err)
|
||||
t.Fail()
|
||||
}
|
||||
}
|
||||
|
|
@ -1,4 +1,77 @@
|
|||
package retailcrm
|
||||
package v5
|
||||
|
||||
// VersionResponse return available API versions
|
||||
type VersionResponse struct {
|
||||
Success bool `json:"success,omitempty"`
|
||||
Versions []string `json:"versions,brackets,omitempty"`
|
||||
}
|
||||
|
||||
// CredentialResponse return available API methods
|
||||
type CredentialResponse struct {
|
||||
Success bool `json:"success,omitempty"`
|
||||
Credentials []string `json:"credentials,brackets,omitempty"`
|
||||
SiteAccess string `json:"siteAccess,omitempty"`
|
||||
SitesAvailable []string `json:"sitesAvailable,brackets,omitempty"`
|
||||
}
|
||||
|
||||
// Pagination type
|
||||
type Pagination struct {
|
||||
Limit int `json:"limit,omitempty"`
|
||||
TotalCount int `json:"totalCount,omitempty"`
|
||||
CurrentPage int `json:"currentPage,omitempty"`
|
||||
TotalPageCount int `json:"totalPageCount,omitempty"`
|
||||
}
|
||||
|
||||
// Address type
|
||||
type Address struct {
|
||||
Index string `json:"index,omitempty"`
|
||||
CountryIso string `json:"countryIso,omitempty"`
|
||||
Region string `json:"region,omitempty"`
|
||||
RegionId int `json:"regionId,omitempty"`
|
||||
City string `json:"city,omitempty"`
|
||||
CityId int `json:"cityId,omitempty"`
|
||||
CityType string `json:"cityType,omitempty"`
|
||||
Street string `json:"street,omitempty"`
|
||||
StreetId int `json:"streetId,omitempty"`
|
||||
StreetType string `json:"streetType,omitempty"`
|
||||
Building string `json:"building,omitempty"`
|
||||
Flat string `json:"flat,omitempty"`
|
||||
IntercomCode string `json:"intercomCode,omitempty"`
|
||||
Floor int `json:"floor,omitempty"`
|
||||
Block int `json:"block,omitempty"`
|
||||
House string `json:"house,omitempty"`
|
||||
Metro string `json:"metro,omitempty"`
|
||||
Notes string `json:"notes,omitempty"`
|
||||
Text string `json:"text,omitempty"`
|
||||
}
|
||||
|
||||
// Source type
|
||||
type Source struct {
|
||||
Source string `json:"source,omitempty"`
|
||||
Medium string `json:"medium,omitempty"`
|
||||
Campaign string `json:"campaign,omitempty"`
|
||||
Keyword string `json:"keyword,omitempty"`
|
||||
Content string `json:"content,omitempty"`
|
||||
}
|
||||
|
||||
// Contragent type
|
||||
type Contragent struct {
|
||||
ContragentType string `json:"contragentType,omitempty"`
|
||||
LegalName string `json:"legalName,omitempty"`
|
||||
LegalAddress string `json:"legalAddress,omitempty"`
|
||||
INN string `json:"INN,omitempty"`
|
||||
OKPO string `json:"OKPO,omitempty"`
|
||||
KPP string `json:"KPP,omitempty"`
|
||||
OGRN string `json:"OGRN,omitempty"`
|
||||
OGRNIP string `json:"OGRNIP,omitempty"`
|
||||
CertificateNumber string `json:"certificateNumber,omitempty"`
|
||||
CertificateDate string `json:"certificateDate,omitempty"`
|
||||
BIK string `json:"BIK,omitempty"`
|
||||
Bank string `json:"bank,omitempty"`
|
||||
BankAddress string `json:"bankAddress,omitempty"`
|
||||
CorrAccount string `json:"corrAccount,omitempty"`
|
||||
BankAccount string `json:"bankAccount,omitempty"`
|
||||
}
|
||||
|
||||
// Customer type
|
||||
type Customer struct {
|
||||
|
|
@ -68,3 +141,9 @@ type CustomersResponse struct {
|
|||
Pagination *Pagination `json:"pagination,omitempty"`
|
||||
Customers []Customer `json:"customers,omitempty,brackets"`
|
||||
}
|
||||
|
||||
type CustomerChangeResponse struct {
|
||||
Success bool `json:"success"`
|
||||
Id int `json:"id,omitempty"`
|
||||
State string `json:"state,omitempty"`
|
||||
}
|
||||
Loading…
Add table
Reference in a new issue