Compare commits
12 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
7d8f43540f | ||
|
|
114a5b90b9 | ||
|
|
a0995a79e1 | ||
|
|
2f94b8c774 | ||
|
|
35832e6269 | ||
|
|
965c83ba85 | ||
|
|
a3c9d93adc | ||
|
|
549a2b9b41 | ||
|
|
c36446bb59 | ||
|
|
ebafb17c9d | ||
|
|
178fd7086a | ||
|
|
de08ee28c0 |
2
.github/workflows/tests.yml
vendored
2
.github/workflows/tests.yml
vendored
@@ -25,7 +25,7 @@ jobs:
|
||||
- name: Setup go
|
||||
uses: actions/setup-go@v2
|
||||
with:
|
||||
go-version: '1.19'
|
||||
go-version: '1.20'
|
||||
- name: Setup
|
||||
run: |
|
||||
go install github.com/mattn/goveralls@latest
|
||||
|
||||
10
README.md
10
README.md
@@ -23,6 +23,7 @@ A simple example on how to use this library:
|
||||
package main
|
||||
|
||||
import (
|
||||
"context"
|
||||
"fmt"
|
||||
"log"
|
||||
"net/http"
|
||||
@@ -33,11 +34,14 @@ import (
|
||||
func main() {
|
||||
// Create a client with your Client-Id and Api-Key
|
||||
// [Documentation]: https://docs.ozon.ru/api/seller/en/#tag/Auth
|
||||
client := ozon.NewClient("my-client-id", "my-api-key")
|
||||
opts := []ozon.ClientOption{
|
||||
ozon.WithAPIKey("api-key"),
|
||||
ozon.WithClientId("client-id"),
|
||||
}
|
||||
c := ozon.NewClient(opts...)
|
||||
|
||||
// Send request with parameters
|
||||
ctx, _ := context.WithTimeout(context.Background(), testTimeout)
|
||||
resp, err := client.Products().GetProductDetails(&ozon.GetProductDetailsParams{
|
||||
resp, err := client.Products().GetProductDetails(context.Background(), &ozon.GetProductDetailsParams{
|
||||
ProductId: 123456789,
|
||||
})
|
||||
if err != nil || resp.StatusCode != http.StatusOK {
|
||||
|
||||
24
client.go
24
client.go
@@ -7,6 +7,8 @@ import (
|
||||
"io/ioutil"
|
||||
"net/http"
|
||||
"net/http/httptest"
|
||||
"net/url"
|
||||
"reflect"
|
||||
)
|
||||
|
||||
type HttpClient interface {
|
||||
@@ -34,14 +36,25 @@ func NewMockClient(handler http.HandlerFunc) *Client {
|
||||
}
|
||||
}
|
||||
|
||||
func (c Client) newRequest(ctx context.Context, method string, url string, body interface{}) (*http.Request, error) {
|
||||
func (c Client) newRequest(ctx context.Context, method string, uri string, body interface{}) (*http.Request, error) {
|
||||
// Set default values for empty fields if `default` tag is present
|
||||
// And body is not nil
|
||||
if body != nil {
|
||||
if err := getDefaultValues(reflect.ValueOf(body)); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
}
|
||||
|
||||
bodyJson, err := json.Marshal(body)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
url = c.baseUrl + url
|
||||
req, err := http.NewRequestWithContext(ctx, method, url, bytes.NewBuffer(bodyJson))
|
||||
uri, err = url.JoinPath(c.baseUrl, uri)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
req, err := http.NewRequestWithContext(ctx, method, uri, bytes.NewBuffer(bodyJson))
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@@ -58,11 +71,6 @@ func (c Client) Request(ctx context.Context, method string, path string, req, re
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
rawQuery, err := buildRawQuery(httpReq, req)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
httpReq.URL.RawQuery = rawQuery
|
||||
|
||||
httpResp, err := c.client.Do(httpReq)
|
||||
if err != nil {
|
||||
|
||||
130
core.go
130
core.go
@@ -4,6 +4,7 @@ import (
|
||||
"fmt"
|
||||
"net/http"
|
||||
"reflect"
|
||||
"strconv"
|
||||
"testing"
|
||||
"time"
|
||||
)
|
||||
@@ -32,51 +33,103 @@ func (r Response) CopyCommonResponse(rhs *CommonResponse) {
|
||||
rhs.Message = r.Message
|
||||
}
|
||||
|
||||
func getDefaultValues(v interface{}) (map[string]string, error) {
|
||||
isNil, err := isZero(v)
|
||||
if err != nil {
|
||||
return make(map[string]string), err
|
||||
}
|
||||
|
||||
if isNil {
|
||||
return make(map[string]string), nil
|
||||
}
|
||||
|
||||
out := make(map[string]string)
|
||||
|
||||
vType := reflect.TypeOf(v).Elem()
|
||||
vValue := reflect.ValueOf(v).Elem()
|
||||
func getDefaultValues(v reflect.Value) error {
|
||||
vValue := v.Elem()
|
||||
vType := vValue.Type()
|
||||
|
||||
for i := 0; i < vType.NumField(); i++ {
|
||||
field := vType.Field(i)
|
||||
tag := field.Tag.Get("json")
|
||||
defaultValue := field.Tag.Get("default")
|
||||
|
||||
if field.Type.Kind() == reflect.Slice {
|
||||
// Attach any slices as query params
|
||||
fieldVal := vValue.Field(i)
|
||||
for j := 0; j < fieldVal.Len(); j++ {
|
||||
out[tag] = fmt.Sprintf("%v", fieldVal.Index(j))
|
||||
}
|
||||
} else {
|
||||
// Add any scalar values as query params
|
||||
fieldVal := fmt.Sprintf("%v", vValue.Field(i))
|
||||
|
||||
// If no value was set by the user, use the default
|
||||
// value specified in the struct tag.
|
||||
if fieldVal == "" || fieldVal == "0" {
|
||||
if defaultValue == "" {
|
||||
switch field.Type.Kind() {
|
||||
case reflect.Slice:
|
||||
for j := 0; j < vValue.Field(i).Len(); j++ {
|
||||
// skip if slice type is primitive
|
||||
if vValue.Field(i).Index(j).Kind() != reflect.Struct {
|
||||
continue
|
||||
}
|
||||
|
||||
fieldVal = defaultValue
|
||||
// Attach any slices as query params
|
||||
err := getDefaultValues(vValue.Field(i).Index(j).Addr())
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
case reflect.String:
|
||||
isNil, err := isZero(vValue.Field(i).Addr())
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
if !isNil {
|
||||
continue
|
||||
}
|
||||
|
||||
out[tag] = fmt.Sprintf("%v", fieldVal)
|
||||
defaultValue, ok := field.Tag.Lookup("default")
|
||||
if !ok {
|
||||
continue
|
||||
}
|
||||
|
||||
vValue.Field(i).SetString(defaultValue)
|
||||
case reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int64:
|
||||
isNil, err := isZero(vValue.Field(i).Addr())
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
if !isNil {
|
||||
continue
|
||||
}
|
||||
|
||||
defaultValue, ok := field.Tag.Lookup("default")
|
||||
if !ok {
|
||||
continue
|
||||
}
|
||||
defaultValueInt, err := strconv.Atoi(defaultValue)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
vValue.Field(i).SetInt(int64(defaultValueInt))
|
||||
case reflect.Uint, reflect.Uint8, reflect.Uint16, reflect.Uint32, reflect.Uint64:
|
||||
isNil, err := isZero(vValue.Field(i).Addr())
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
if !isNil {
|
||||
continue
|
||||
}
|
||||
|
||||
defaultValue, ok := field.Tag.Lookup("default")
|
||||
if !ok {
|
||||
continue
|
||||
}
|
||||
defaultValueUint, err := strconv.ParseUint(defaultValue, 10, 64)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
vValue.Field(i).SetUint(uint64(defaultValueUint))
|
||||
case reflect.Struct:
|
||||
err := getDefaultValues(vValue.Field(i).Addr())
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
case reflect.Ptr:
|
||||
isNil, err := isZero(vValue.Field(i).Addr())
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
if isNil {
|
||||
continue
|
||||
}
|
||||
|
||||
if err := getDefaultValues(vValue.Field(i)); err != nil {
|
||||
return err
|
||||
}
|
||||
default:
|
||||
continue
|
||||
}
|
||||
}
|
||||
|
||||
return out, nil
|
||||
return nil
|
||||
}
|
||||
|
||||
func buildRawQuery(req *http.Request, v interface{}) (string, error) {
|
||||
@@ -86,23 +139,20 @@ func buildRawQuery(req *http.Request, v interface{}) (string, error) {
|
||||
return query.Encode(), nil
|
||||
}
|
||||
|
||||
values, err := getDefaultValues(v)
|
||||
err := getDefaultValues(reflect.ValueOf(v))
|
||||
if err != nil {
|
||||
return "", err
|
||||
}
|
||||
for k, v := range values {
|
||||
query.Add(k, v)
|
||||
}
|
||||
|
||||
return query.Encode(), nil
|
||||
}
|
||||
|
||||
func isZero(v interface{}) (bool, error) {
|
||||
t := reflect.TypeOf(v)
|
||||
func isZero(v reflect.Value) (bool, error) {
|
||||
t := v.Elem().Type()
|
||||
if !t.Comparable() {
|
||||
return false, fmt.Errorf("type is not comparable: %v", t)
|
||||
}
|
||||
return v == reflect.Zero(t).Interface(), nil
|
||||
return reflect.Zero(t).Equal(v.Elem()), nil
|
||||
}
|
||||
|
||||
func TimeFromString(t *testing.T, format, datetime string) time.Time {
|
||||
|
||||
72
core_test.go
72
core_test.go
@@ -1,34 +1,56 @@
|
||||
package core
|
||||
|
||||
import (
|
||||
"log"
|
||||
"reflect"
|
||||
"testing"
|
||||
|
||||
"github.com/stretchr/testify/assert"
|
||||
)
|
||||
|
||||
type TestTagDefaultValueStruct struct {
|
||||
TestString string `json:"test_string" default:"something"`
|
||||
TestNumber int `json:"test_number" default:"12"`
|
||||
type DefaultStructure struct {
|
||||
EmptyField string `json:"empty_field" default:"empty_string"`
|
||||
Field string `json:"field" default:"string"`
|
||||
}
|
||||
|
||||
func TestTagDefaultValue(t *testing.T) {
|
||||
testStruct := &TestTagDefaultValueStruct{}
|
||||
|
||||
values, err := getDefaultValues(testStruct)
|
||||
if err != nil {
|
||||
log.Fatalf("error when getting default values from tags: %s", err)
|
||||
}
|
||||
|
||||
expected := map[string]string{
|
||||
"test_string": "something",
|
||||
"test_number": "12",
|
||||
}
|
||||
|
||||
if len(values) != len(expected) {
|
||||
log.Fatalf("expected equal length of values and expected: expected: %d, got: %d", len(expected), len(values))
|
||||
}
|
||||
for expKey, expValue := range expected {
|
||||
if expValue != values[expKey] {
|
||||
log.Fatalf("not equal values for key %s", expKey)
|
||||
}
|
||||
}
|
||||
type DefaultRequest struct {
|
||||
Field int `json:"field" default:"100"`
|
||||
EmptyField int `json:"empty_field" default:"14"`
|
||||
Structure DefaultStructure `json:"structure"`
|
||||
Slice []DefaultStructure `json:"slice"`
|
||||
OptionalStructure *DefaultStructure `json:"optional_structure"`
|
||||
EmptyOptionalStructure *DefaultStructure `json:"empty_optional_structure"`
|
||||
}
|
||||
|
||||
func TestDefaultValues(t *testing.T) {
|
||||
req := &DefaultRequest{
|
||||
Field: 50,
|
||||
Structure: DefaultStructure{
|
||||
Field: "something",
|
||||
},
|
||||
Slice: []DefaultStructure{
|
||||
{
|
||||
Field: "something",
|
||||
},
|
||||
{
|
||||
Field: "something",
|
||||
},
|
||||
},
|
||||
OptionalStructure: &DefaultStructure{
|
||||
Field: "something",
|
||||
},
|
||||
}
|
||||
err := getDefaultValues(reflect.ValueOf(req))
|
||||
assert.Nil(t, err)
|
||||
|
||||
assert.Equal(t, 50, req.Field)
|
||||
assert.Equal(t, 14, req.EmptyField)
|
||||
assert.Equal(t, "something", req.Structure.Field)
|
||||
assert.Equal(t, "empty_string", req.Structure.EmptyField)
|
||||
assert.Equal(t, "something", req.Slice[0].Field)
|
||||
assert.Equal(t, "something", req.Slice[1].Field)
|
||||
assert.Equal(t, "empty_string", req.Slice[1].EmptyField)
|
||||
assert.Equal(t, "empty_string", req.Slice[1].EmptyField)
|
||||
assert.Equal(t, "something", req.OptionalStructure.Field)
|
||||
assert.Equal(t, "empty_string", req.OptionalStructure.EmptyField)
|
||||
assert.Equal(t, (*DefaultStructure)(nil), req.EmptyOptionalStructure)
|
||||
}
|
||||
|
||||
10
go.mod
10
go.mod
@@ -1,3 +1,11 @@
|
||||
module github.com/diphantxm/ozon-api-client
|
||||
|
||||
go 1.18
|
||||
go 1.20
|
||||
|
||||
require (
|
||||
github.com/davecgh/go-spew v1.1.1 // indirect
|
||||
github.com/pmezard/go-difflib v1.0.0 // indirect
|
||||
github.com/stretchr/objx v0.5.0 // indirect
|
||||
github.com/stretchr/testify v1.8.4 // indirect
|
||||
gopkg.in/yaml.v3 v3.0.1 // indirect
|
||||
)
|
||||
|
||||
17
go.sum
Normal file
17
go.sum
Normal file
@@ -0,0 +1,17 @@
|
||||
github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
|
||||
github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
|
||||
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
|
||||
github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
|
||||
github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
|
||||
github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
|
||||
github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
|
||||
github.com/stretchr/objx v0.5.0 h1:1zr/of2m5FGMsad5YfcqgdqdWrIhu+EBEJRhR1U7z/c=
|
||||
github.com/stretchr/objx v0.5.0/go.mod h1:Yh+to48EsGEfYuaHDzXPcE3xhTkx73EhmCGUpEOglKo=
|
||||
github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
|
||||
github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU=
|
||||
github.com/stretchr/testify v1.8.4 h1:CcVxjf3Q8PM0mHUKJCdn+eZZtm5yQwehR5yeSVQQcUk=
|
||||
github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo=
|
||||
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
|
||||
gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
|
||||
gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
|
||||
gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
|
||||
@@ -165,7 +165,7 @@ type GetStocksOnWarehousesParams struct {
|
||||
Offset int64 `json:"offset"`
|
||||
|
||||
// Warehouse type filter:
|
||||
WarehouseType WarehouseType `json:"warehouse_type"`
|
||||
WarehouseType WarehouseType `json:"warehouse_type" default:"ALL"`
|
||||
}
|
||||
|
||||
type GetStocksOnWarehousesResponse struct {
|
||||
|
||||
@@ -83,7 +83,7 @@ type CancellationInfoState struct {
|
||||
|
||||
// Method for getting information about a rFBS cancellation request
|
||||
func (c Cancellations) GetInfo(ctx context.Context, params *GetCancellationInfoParams) (*GetCancellationInfoResponse, error) {
|
||||
url := "/v1/delivery-method/list"
|
||||
url := "/v1/conditional-cancellation/get"
|
||||
|
||||
resp := &GetCancellationInfoResponse{}
|
||||
|
||||
@@ -98,17 +98,17 @@ func (c Cancellations) GetInfo(ctx context.Context, params *GetCancellationInfoP
|
||||
|
||||
type ListCancellationsParams struct {
|
||||
// Filters
|
||||
Filter ListCancellationsFilter `json:"filter"`
|
||||
Filter *ListCancellationsFilter `json:"filter,omitempty"`
|
||||
|
||||
// Number of cancellation requests in the response
|
||||
Limit int32 `json:"limit"`
|
||||
Limit int32 `json:"limit,omitempty"`
|
||||
|
||||
// Number of elements that will be skipped in the response.
|
||||
// For example, if offset=10, the response will start with the 11th element found
|
||||
Offset int32 `json:"offset"`
|
||||
Offset int32 `json:"offset,omitempty"`
|
||||
|
||||
// Additional information
|
||||
With ListCancellationWith `json:"with"`
|
||||
With *ListCancellationWith `json:"with,omitempty"`
|
||||
}
|
||||
|
||||
type ListCancellationsFilter struct {
|
||||
@@ -173,7 +173,7 @@ type ApproveRejectCancellationsParams struct {
|
||||
CancellationId int64 `json:"cancellation_id"`
|
||||
|
||||
// Comment
|
||||
Comment string `json:"comment"`
|
||||
Comment string `json:"comment,omitempty"`
|
||||
}
|
||||
|
||||
type ApproveRejectCancellationsResponse struct {
|
||||
|
||||
@@ -98,13 +98,13 @@ func TestListCancellations(t *testing.T) {
|
||||
http.StatusOK,
|
||||
map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"},
|
||||
&ListCancellationsParams{
|
||||
Filter: ListCancellationsFilter{
|
||||
Filter: &ListCancellationsFilter{
|
||||
CancellationInitiator: []string{"CLIENT"},
|
||||
State: "ALL",
|
||||
},
|
||||
Limit: 2,
|
||||
Offset: 0,
|
||||
With: ListCancellationWith{
|
||||
With: &ListCancellationWith{
|
||||
Counters: true,
|
||||
},
|
||||
},
|
||||
|
||||
@@ -13,7 +13,7 @@ type Categories struct {
|
||||
|
||||
type GetProductTreeParams struct {
|
||||
// Response language
|
||||
Language Language `json:"language"`
|
||||
Language Language `json:"language,omitempty"`
|
||||
}
|
||||
|
||||
type GetProductTreeResponse struct {
|
||||
@@ -25,7 +25,7 @@ type GetProductTreeResponse struct {
|
||||
|
||||
type GetProductTreeResult struct {
|
||||
// Category identifier
|
||||
CategoryId int64 `json:"category_id"`
|
||||
DescriptionCategoryId int64 `json:"description_category_id"`
|
||||
|
||||
// Category name
|
||||
CategoryName string `json:"category_name"`
|
||||
@@ -64,10 +64,10 @@ func (c *Categories) Tree(ctx context.Context, params *GetProductTreeParams) (*G
|
||||
|
||||
type GetCategoryAttributesParams struct {
|
||||
// Category identifier
|
||||
CategoryId int64 `json:"category_id"`
|
||||
DescriptionCategoryId int64 `json:"description_category_id"`
|
||||
|
||||
// Response language
|
||||
Language Language `json:"language"`
|
||||
Language Language `json:"language,omitempty"`
|
||||
|
||||
// Product type identifier
|
||||
TypeId int64 `json:"type_id"`
|
||||
@@ -123,6 +123,12 @@ type GetCategoryAttributesResult struct {
|
||||
|
||||
// Characteristic type
|
||||
Type string `json:"type"`
|
||||
|
||||
// Complex attribute identifier
|
||||
AttributeComplexId int64 `json:"attribute_complex_id"`
|
||||
|
||||
// Maximum number of values for attribute
|
||||
MaxValueCount int64 `json:"max_value_count"`
|
||||
}
|
||||
|
||||
// Getting characteristics for specified product category and type.
|
||||
@@ -149,10 +155,10 @@ type GetAttributeDictionaryParams struct {
|
||||
AttributeId int64 `json:"attribute_id"`
|
||||
|
||||
// Category identifier
|
||||
CategoryId int64 `json:"category_id"`
|
||||
DescriptionCategoryId int64 `json:"description_category_id"`
|
||||
|
||||
// Response language
|
||||
Language Language `json:"language"`
|
||||
Language Language `json:"language,omitempty"`
|
||||
|
||||
// Identifier of the directory to start the response with.
|
||||
// If `last_value_id` is 10, the response will contain directories starting from the 11th
|
||||
@@ -162,7 +168,7 @@ type GetAttributeDictionaryParams struct {
|
||||
//
|
||||
// - maximum—5000,
|
||||
// - minimum—1.
|
||||
Limit int64 `json:"limit"`
|
||||
Limit int64 `json:"limit,omitempty"`
|
||||
|
||||
// Product type identifier
|
||||
TypeId int64 `json:"type_id"`
|
||||
@@ -200,7 +206,7 @@ type GetAttributeDictionaryResult struct {
|
||||
// To check if an attribute has a nested directory,
|
||||
// use the `/v1/description-category/attribute` method.
|
||||
func (c *Categories) AttributesDictionary(ctx context.Context, params *GetAttributeDictionaryParams) (*GetAttributeDictionaryResponse, error) {
|
||||
url := "/v1/description-category/attribute"
|
||||
url := "/v1/description-category/attribute/values"
|
||||
|
||||
resp := &GetAttributeDictionaryResponse{}
|
||||
|
||||
|
||||
@@ -27,7 +27,7 @@ func TestGetProductTree(t *testing.T) {
|
||||
`{
|
||||
"result": [
|
||||
{
|
||||
"category_id": 0,
|
||||
"description_category_id": 0,
|
||||
"category_name": "string",
|
||||
"children": [],
|
||||
"disabled": true,
|
||||
@@ -81,7 +81,7 @@ func TestGetCategoryAttributes(t *testing.T) {
|
||||
http.StatusOK,
|
||||
map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"},
|
||||
&GetCategoryAttributesParams{
|
||||
CategoryId: 12345,
|
||||
DescriptionCategoryId: 12345,
|
||||
Language: English,
|
||||
TypeId: 2,
|
||||
},
|
||||
@@ -97,7 +97,9 @@ func TestGetCategoryAttributes(t *testing.T) {
|
||||
"is_collection": true,
|
||||
"is_required": true,
|
||||
"name": "string",
|
||||
"type": "string"
|
||||
"type": "string",
|
||||
"attribute_complex_id": 0,
|
||||
"max_value_count": 0
|
||||
}
|
||||
]
|
||||
}`,
|
||||
@@ -147,7 +149,7 @@ func TestGetAttributeDictionary(t *testing.T) {
|
||||
map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"},
|
||||
&GetAttributeDictionaryParams{
|
||||
AttributeId: 123456,
|
||||
CategoryId: 12,
|
||||
DescriptionCategoryId: 12,
|
||||
Language: English,
|
||||
LastValueId: 1,
|
||||
Limit: 5,
|
||||
|
||||
@@ -121,7 +121,7 @@ type ListOfCertifiedCategoriesResultCert struct {
|
||||
|
||||
// List of certified categories
|
||||
func (c Certificates) ListOfCertifiedCategories(ctx context.Context, params *ListOfCertifiedCategoriesParams) (*ListOfCertifiedCategoriesResponse, error) {
|
||||
url := "/v1/product/certificate/types"
|
||||
url := "/v1/product/certification/list"
|
||||
|
||||
resp := &ListOfCertifiedCategoriesResponse{}
|
||||
|
||||
|
||||
@@ -14,14 +14,14 @@ type Chats struct {
|
||||
|
||||
type ListChatsParams struct {
|
||||
// Chats filter
|
||||
Filter ListChatsFilter `json:"filter"`
|
||||
Filter *ListChatsFilter `json:"filter,omitempty"`
|
||||
|
||||
// Number of values in the response. Default value is 1
|
||||
Limit int64 `json:"limit" default:"1"`
|
||||
// Number of values in the response. The default value is 30. The maximum value is 1000
|
||||
Limit int64 `json:"limit" default:"30"`
|
||||
|
||||
// Number of elements that will be skipped in the response.
|
||||
// For example, if offset=10, the response will start with the 11th element found
|
||||
Offset int64 `json:"offset"`
|
||||
Offset int64 `json:"offset,omitempty"`
|
||||
}
|
||||
|
||||
type ListChatsFilter struct {
|
||||
@@ -173,7 +173,7 @@ type ChatHistoryParams struct {
|
||||
// Default value is the last visible message
|
||||
FromMessageId string `json:"from_message_id"`
|
||||
|
||||
// Number of messages in the response. The default value is 50
|
||||
// Number of messages in the response. The default value is 50. The maximum value is 1000
|
||||
Limit int64 `json:"limit" default:"50"`
|
||||
}
|
||||
|
||||
@@ -240,7 +240,7 @@ type UpdateChatParams struct {
|
||||
FromMessageId uint64 `json:"from_message_id"`
|
||||
|
||||
// Number of messages in the response
|
||||
Limit int64 `json:"limit"`
|
||||
Limit int64 `json:"limit,omitempty"`
|
||||
}
|
||||
|
||||
type UpdateChatResponse struct {
|
||||
|
||||
@@ -22,7 +22,7 @@ func TestListChats(t *testing.T) {
|
||||
http.StatusOK,
|
||||
map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"},
|
||||
&ListChatsParams{
|
||||
Filter: ListChatsFilter{
|
||||
Filter: &ListChatsFilter{
|
||||
ChatStatus: "Opened",
|
||||
UnreadOnly: true,
|
||||
},
|
||||
|
||||
@@ -468,8 +468,10 @@ const (
|
||||
type GetFBOReturnsFilterStatus string
|
||||
|
||||
const (
|
||||
GetFBOReturnsFilterStatusCreated GetFBOReturnsFilterStatus = "Created"
|
||||
GetFBOReturnsFilterStatusReturnedToOzon GetFBOReturnsFilterStatus = "ReturnedToOzon"
|
||||
GetFBOReturnsFilterStatusCancelled GetFBOReturnsFilterStatus = "Cancelled"
|
||||
GetFBOReturnsFilterStatusCancelledWithCompensation GetFBOReturnsFilterStatus = "CancelledWithCompensation"
|
||||
)
|
||||
|
||||
type GetFBOReturnsReturnStatus string
|
||||
|
||||
12
ozon/fbo.go
12
ozon/fbo.go
@@ -14,7 +14,7 @@ type FBO struct {
|
||||
|
||||
type GetFBOShipmentsListParams struct {
|
||||
// Sorting direction
|
||||
Direction string `json:"dir"`
|
||||
Direction string `json:"dir,omitempty"`
|
||||
|
||||
// Shipment search filter
|
||||
Filter GetFBOShipmentsListFilter `json:"filter"`
|
||||
@@ -23,13 +23,13 @@ type GetFBOShipmentsListParams struct {
|
||||
Limit int64 `json:"limit"`
|
||||
|
||||
// Number of elements that will be skipped in the response. For example, if offset=10, the response will start with the 11th element found
|
||||
Offset int64 `json:"offset"`
|
||||
Offset int64 `json:"offset,omitempty"`
|
||||
|
||||
// true if the address transliteration from Cyrillic to Latin is enabled
|
||||
Translit bool `json:"translit"`
|
||||
Translit bool `json:"translit,omitempty"`
|
||||
|
||||
// Additional fields to add to the response
|
||||
With GetFBOShipmentsListWith `json:"with"`
|
||||
With *GetFBOShipmentsListWith `json:"with,omitempty"`
|
||||
}
|
||||
|
||||
// Shipment search filter
|
||||
@@ -185,10 +185,10 @@ type GetShipmentDetailsParams struct {
|
||||
PostingNumber string `json:"posting_number"`
|
||||
|
||||
// true if the address transliteration from Cyrillic to Latin is enabled
|
||||
Translit bool `json:"translit"`
|
||||
Translit bool `json:"translit,omitempty"`
|
||||
|
||||
// Additional fields to add to the response
|
||||
With GetShipmentDetailsWith `json:"with"`
|
||||
With *GetShipmentDetailsWith `json:"with,omitempty"`
|
||||
}
|
||||
|
||||
type GetShipmentDetailsWith struct {
|
||||
|
||||
@@ -31,7 +31,7 @@ func TestGetFBOShipmentsList(t *testing.T) {
|
||||
Limit: 5,
|
||||
Offset: 0,
|
||||
Translit: true,
|
||||
With: GetFBOShipmentsListWith{
|
||||
With: &GetFBOShipmentsListWith{
|
||||
AnalyticsData: true,
|
||||
FinancialData: true,
|
||||
},
|
||||
@@ -165,7 +165,7 @@ func TestGetShipmentDetails(t *testing.T) {
|
||||
&GetShipmentDetailsParams{
|
||||
PostingNumber: "50520644-0012-7",
|
||||
Translit: true,
|
||||
With: GetShipmentDetailsWith{
|
||||
With: &GetShipmentDetailsWith{
|
||||
AnalyticsData: true,
|
||||
FinancialData: true,
|
||||
},
|
||||
|
||||
147
ozon/fbs.go
147
ozon/fbs.go
@@ -14,7 +14,7 @@ type FBS struct {
|
||||
|
||||
type ListUnprocessedShipmentsParams struct {
|
||||
// Sorting direction
|
||||
Direction Order `json:"dir"`
|
||||
Direction Order `json:"dir,omitempty"`
|
||||
|
||||
// Request filter
|
||||
Filter ListUnprocessedShipmentsFilter `json:"filter"`
|
||||
@@ -27,10 +27,10 @@ type ListUnprocessedShipmentsParams struct {
|
||||
|
||||
// Number of elements that will be skipped in the response.
|
||||
// For example, if `offset` = 10, the response will start with the 11th element found
|
||||
Offset int64 `json:"offset"`
|
||||
Offset int64 `json:"offset,omitempty"`
|
||||
|
||||
// Additional fields that should be added to the response
|
||||
With ListUnprocessedShipmentsWith `json:"with"`
|
||||
With *ListUnprocessedShipmentsWith `json:"with,omitempty"`
|
||||
}
|
||||
|
||||
type ListUnprocessedShipmentsFilter struct {
|
||||
@@ -511,9 +511,9 @@ func (c FBS) ListUnprocessedShipments(ctx context.Context, params *ListUnprocess
|
||||
|
||||
type GetFBSShipmentsListParams struct {
|
||||
// Sorting direction
|
||||
Direction string `json:"direction"`
|
||||
Direction string `json:"dir,omitempty"`
|
||||
|
||||
//Filter
|
||||
// Filter
|
||||
Filter GetFBSShipmentsListFilter `json:"filter"`
|
||||
|
||||
// Number of shipments in the response:
|
||||
@@ -522,10 +522,10 @@ type GetFBSShipmentsListParams struct {
|
||||
Limit int64 `json:"limit"`
|
||||
|
||||
// Number of elements that will be skipped in the response. For example, if offset=10, the response will start with the 11th element found
|
||||
Offset int64 `json:"offset"`
|
||||
Offset int64 `json:"offset,omitempty"`
|
||||
|
||||
// Additional fields that should be added to the response
|
||||
With GetFBSShipmentsListWith `json:"with"`
|
||||
With *GetFBSShipmentsListWith `json:"with,omitempty"`
|
||||
}
|
||||
|
||||
type GetFBSShipmentsListFilter struct {
|
||||
@@ -625,7 +625,7 @@ type PackOrderParams struct {
|
||||
PostingNumber string `json:"posting_number"`
|
||||
|
||||
// Additional information
|
||||
With PackOrderWith `json:"with"`
|
||||
With *PackOrderWith `json:"with,omitempty"`
|
||||
}
|
||||
|
||||
type PackOrderPackage struct {
|
||||
@@ -865,7 +865,7 @@ type GetShipmentDataByIdentifierParams struct {
|
||||
PostingNumber string `json:"posting_number"`
|
||||
|
||||
// Additional fields that should be added to the response
|
||||
With GetShipmentDataByIdentifierWith `json:"with"`
|
||||
With *GetShipmentDataByIdentifierWith `json:"with,omitempty"`
|
||||
}
|
||||
|
||||
type GetShipmentDataByIdentifierWith struct {
|
||||
@@ -1750,18 +1750,76 @@ func (c FBS) GetDropOffPointRestrictions(ctx context.Context, params *GetDropOff
|
||||
}
|
||||
|
||||
type CheckProductItemsDataParams struct {
|
||||
// Quantity of boxes the product is packed in
|
||||
MultiBoxQuantity int32 `json:"multi_box_qty"`
|
||||
|
||||
// Shipment number
|
||||
PostingNumber string `json:"posting_number"`
|
||||
|
||||
Products CheckProductItemsDataProduct `json:"products"`
|
||||
// Product list
|
||||
Products []CheckProductItemsDataProduct `json:"products"`
|
||||
}
|
||||
|
||||
type CheckProductItemsDataProduct struct {
|
||||
// Product items data
|
||||
Exemplars []FBSProductExemplar `json:"exemplars"`
|
||||
Exemplars []CheckProductItemsDataProductExemplar `json:"exemplars"`
|
||||
|
||||
// SKU, FBS product identifier in the Ozon system
|
||||
// Indication that you need to pass the сustoms cargo declaration
|
||||
// (CCD) number for the product and shipment
|
||||
IsGTDNeeded bool `json:"is_gtd_needed"`
|
||||
|
||||
// Indication that you need to pass the "Chestny ZNAK" labeling
|
||||
IsMandatoryMarkNeeded bool `json:"is_mandatory_mark_needed"`
|
||||
|
||||
// Indication that you need to pass the product batch registration number
|
||||
IsRNPTNeeded bool `json:"is_rnpt_needed"`
|
||||
|
||||
// Product ID
|
||||
ProductId int64 `json:"product_id"`
|
||||
|
||||
// Items quantity
|
||||
Quantity int32 `json:"quantity"`
|
||||
}
|
||||
|
||||
type CheckProductItemsDataProductExemplar struct {
|
||||
// Item identifier
|
||||
ExemplarId int64 `json:"exemplar_id"`
|
||||
|
||||
// Customs cargo declaration (CCD) number
|
||||
GTD string `json:"gtd"`
|
||||
|
||||
// Сustoms cargo declaration (CCD) check status
|
||||
GTDCheckStatus string `json:"gtd_check_status"`
|
||||
|
||||
// Сustoms cargo declaration (CCD) check error codes
|
||||
GTDErrorCodes []string `json:"gtd_error_codes"`
|
||||
|
||||
// Indication that the customs cargo declaration (CCD) number isn't specified
|
||||
IsGTDAbsent bool `json:"is_gtd_absent"`
|
||||
|
||||
// "Chestny ZNAK" labeling check status
|
||||
MandatoryMarkCheckStatus MandatoryMarkStatus `json:"mandatory_mark_check_status"`
|
||||
|
||||
// "Chestny ZNAK" labeling check error codes
|
||||
MandatoryMarkErrorCodes []string `json:"mandatory_mark_error_codes"`
|
||||
|
||||
// Indication that the product batch registration number isn't specified
|
||||
IsRNPTAbsent bool `json:"is_rnpt_absent"`
|
||||
|
||||
// Mandatory "Chestny ZNAK" labeling
|
||||
MandatoryMark string `json:"mandatory_mark"`
|
||||
|
||||
// Product batch registration number
|
||||
RNPT string `json:"rnpt"`
|
||||
|
||||
// Product batch registration number check status
|
||||
RNPTCheckStatus string `json:"rnpt_check_status"`
|
||||
|
||||
// Product batch registration number check error codes
|
||||
RNPTErrorCodes []string `json:"rnpt_error_codes"`
|
||||
|
||||
// Unique identifier of charges of the jewelry
|
||||
JWUIN string `json:"jw_uin"`
|
||||
}
|
||||
|
||||
type CheckProductItemsDataResponse struct {
|
||||
@@ -1772,20 +1830,23 @@ type CheckProductItemsDataResponse struct {
|
||||
}
|
||||
|
||||
// Asynchronous method:
|
||||
// - for checking the availability of product items in the “Chestny ZNAK” labeling system
|
||||
// - for saving product items data
|
||||
//
|
||||
// To get the checks results, use the `/v4/fbs/posting/product/exemplar/status method`
|
||||
// for checking the availability of product items in the “Chestny ZNAK” labeling system;
|
||||
// for saving product items data.
|
||||
// To get the checks results, use the `/v4/fbs/posting/product/exemplar/status` method.
|
||||
// To get data about created items, use the `/v5/fbs/fbs/posting/product/exemplar/create-or-get` method.
|
||||
//
|
||||
// If necessary, specify the number of the cargo customs declaration in the gtd parameter. If it is missing, pass the value `is_gtd_absent` = true
|
||||
// If necessary, specify the number of the cargo customs declaration in the gtd parameter.
|
||||
// If it is missing, pass the value `is_gtd_absent` = true.
|
||||
//
|
||||
// If you have multiple identical products in a shipment, specify one `product_id` and `exemplars` array for each product in the shipment
|
||||
// If you have multiple identical products in a shipment, specify one `product_id` and exemplars array for each product in the shipment.
|
||||
//
|
||||
// # Always pass a complete set of product items data
|
||||
// Always pass a complete set of product items data.
|
||||
//
|
||||
// For example, you have 10 product items in your system.
|
||||
// You have passed them for checking and saving. Then they added another 60 product items to your system.
|
||||
// When you pass product items for checking and saving again, pass all of them: both old and newly added
|
||||
// You've passed them for checking and saving.
|
||||
// Then you added another 60 product items to your system.
|
||||
// When you pass product items for checking and saving again, pass all of them: both old and newly added.
|
||||
func (c FBS) CheckProductItemsData(ctx context.Context, params *CheckProductItemsDataParams) (*CheckProductItemsDataResponse, error) {
|
||||
url := "/v4/fbs/posting/product/exemplar/set"
|
||||
|
||||
@@ -1996,8 +2057,8 @@ type PartialPackOrderParams struct {
|
||||
}
|
||||
|
||||
type PartialPackOrderProduct struct {
|
||||
// Data array on product items
|
||||
ExemplarInfo []FBSProductExemplar `json:"exemplar_info"`
|
||||
// Product item identifiers
|
||||
ExemplarIds []string `json:"exemplarIds"`
|
||||
|
||||
// FBS product identifier in the Ozon system, SKU
|
||||
ProductId int64 `json:"product_id"`
|
||||
@@ -2009,11 +2070,8 @@ type PartialPackOrderProduct struct {
|
||||
type PartialPackOrderResponse struct {
|
||||
core.CommonResponse
|
||||
|
||||
// Additional data about shipments
|
||||
AdditionalData []PartialPackOrderAdditionalData `json:"additional_data"`
|
||||
|
||||
// Identifiers of shipments that were created after package
|
||||
Result []string `json:"result"`
|
||||
// Shipments numbers formed after packaging
|
||||
Result string `json:"result"`
|
||||
}
|
||||
|
||||
type PartialPackOrderAdditionalData struct {
|
||||
@@ -2029,7 +2087,7 @@ type PartialPackOrderAdditionalData struct {
|
||||
//
|
||||
// The status of the original shipment will only change when the split shipments status changes
|
||||
func (c FBS) PartialPackOrder(ctx context.Context, params *PartialPackOrderParams) (*PartialPackOrderResponse, error) {
|
||||
url := "/v3/posting/fbs/ship/package"
|
||||
url := "/v4/posting/fbs/ship/package"
|
||||
|
||||
resp := &PartialPackOrderResponse{}
|
||||
|
||||
@@ -2791,3 +2849,36 @@ func (c FBS) GetActPDF(ctx context.Context, params *GetActPDFParams) (*GetActPDF
|
||||
|
||||
return resp, nil
|
||||
}
|
||||
|
||||
type CreateOrGetProductExemplarParams struct {
|
||||
// Shipment number
|
||||
PostingNumber string `json:"posting_number"`
|
||||
}
|
||||
|
||||
type CreateOrGetProductExemplarResponse struct {
|
||||
core.CommonResponse
|
||||
|
||||
// Quantity of boxes the product is packed in
|
||||
MultiBoxQuantity int32 `json:"multi_box_qty"`
|
||||
|
||||
// Shipment number
|
||||
PostingNumber string `json:"posting_number"`
|
||||
|
||||
// Product list
|
||||
Products []CheckProductItemsDataProduct `json:"products"`
|
||||
}
|
||||
|
||||
// Method returns the created items data passed in the `/v5/fbs/posting/product/exemplar/set` method.
|
||||
func (c FBS) CreateOrGetProductExemplar(ctx context.Context, params *CreateOrGetProductExemplarParams) (*CreateOrGetProductExemplarResponse, error) {
|
||||
url := "/v5/fbs/posting/product/exemplar/create-or-get"
|
||||
|
||||
resp := &CreateOrGetProductExemplarResponse{}
|
||||
|
||||
response, err := c.client.Request(ctx, http.MethodPost, url, params, resp, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
response.CopyCommonResponse(&resp.CommonResponse)
|
||||
|
||||
return resp, nil
|
||||
}
|
||||
|
||||
118
ozon/fbs_test.go
118
ozon/fbs_test.go
@@ -29,7 +29,7 @@ func TestListUnprocessedShipments(t *testing.T) {
|
||||
Status: "awaiting_packaging",
|
||||
},
|
||||
Limit: 100,
|
||||
With: ListUnprocessedShipmentsWith{
|
||||
With: &ListUnprocessedShipmentsWith{
|
||||
AnalyticsData: true,
|
||||
Barcodes: true,
|
||||
FinancialData: true,
|
||||
@@ -210,7 +210,7 @@ func TestGetFBSShipmentsList(t *testing.T) {
|
||||
},
|
||||
Limit: 0,
|
||||
Offset: 0,
|
||||
With: GetFBSShipmentsListWith{
|
||||
With: &GetFBSShipmentsListWith{
|
||||
AnalyticsData: true,
|
||||
FinancialData: true,
|
||||
Translit: true,
|
||||
@@ -330,7 +330,7 @@ func TestPackOrder(t *testing.T) {
|
||||
},
|
||||
},
|
||||
PostingNumber: "89491381-0072-1",
|
||||
With: PackOrderWith{
|
||||
With: &PackOrderWith{
|
||||
AdditionalData: true,
|
||||
},
|
||||
},
|
||||
@@ -556,7 +556,7 @@ func TestGetShipmentDataByIdentifier(t *testing.T) {
|
||||
map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"},
|
||||
&GetShipmentDataByIdentifierParams{
|
||||
PostingNumber: "57195475-0050-3",
|
||||
With: GetShipmentDataByIdentifierWith{},
|
||||
With: &GetShipmentDataByIdentifierWith{},
|
||||
},
|
||||
`{
|
||||
"result": {
|
||||
@@ -1395,15 +1395,27 @@ func TestCheckProductItemsData(t *testing.T) {
|
||||
http.StatusOK,
|
||||
map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"},
|
||||
&CheckProductItemsDataParams{
|
||||
PostingNumber: "48173252-0034-4",
|
||||
Products: CheckProductItemsDataProduct{
|
||||
Exemplars: []FBSProductExemplar{
|
||||
MultiBoxQuantity: 0,
|
||||
PostingNumber: "1234",
|
||||
Products: []CheckProductItemsDataProduct{
|
||||
{
|
||||
IsGTDAbsest: true,
|
||||
MandatoryMark: "010290000151642731tVMohkbfFgunB",
|
||||
Exemplars: []CheckProductItemsDataProductExemplar{
|
||||
{
|
||||
ExemplarId: 1,
|
||||
GTD: "string",
|
||||
IsGTDAbsent: true,
|
||||
IsRNPTAbsent: true,
|
||||
MandatoryMark: "string",
|
||||
RNPT: "string",
|
||||
JWUIN: "string",
|
||||
},
|
||||
},
|
||||
ProductId: 476925391,
|
||||
IsGTDNeeded: true,
|
||||
IsMandatoryMarkNeeded: true,
|
||||
IsRNPTNeeded: true,
|
||||
ProductId: 22,
|
||||
Quantity: 11,
|
||||
},
|
||||
},
|
||||
},
|
||||
`{
|
||||
@@ -1784,22 +1796,15 @@ func TestPartialPackOrder(t *testing.T) {
|
||||
PostingNumber: "48173252-0034-4",
|
||||
Products: []PartialPackOrderProduct{
|
||||
{
|
||||
ExemplarInfo: []FBSProductExemplar{
|
||||
{
|
||||
MandatoryMark: "mark",
|
||||
GTD: "gtd",
|
||||
IsGTDAbsest: true,
|
||||
},
|
||||
},
|
||||
ExemplarIds: []string{"string"},
|
||||
ProductId: 247508873,
|
||||
Quantity: 1,
|
||||
},
|
||||
},
|
||||
},
|
||||
`{
|
||||
"result": [
|
||||
"48173252-0034-9"
|
||||
]
|
||||
`
|
||||
{
|
||||
"result": "48173252-0034-9"
|
||||
}`,
|
||||
},
|
||||
// Test No Client-Id or Api-Key
|
||||
@@ -2843,3 +2848,74 @@ func TestGetActPDF(t *testing.T) {
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
func TestCreateOrGetProductExemplar(t *testing.T) {
|
||||
t.Parallel()
|
||||
|
||||
tests := []struct {
|
||||
statusCode int
|
||||
headers map[string]string
|
||||
params *CreateOrGetProductExemplarParams
|
||||
response string
|
||||
}{
|
||||
// Test Ok
|
||||
{
|
||||
http.StatusOK,
|
||||
map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"},
|
||||
&CreateOrGetProductExemplarParams{
|
||||
PostingNumber: "string",
|
||||
},
|
||||
`{
|
||||
"multi_box_qty": 0,
|
||||
"posting_number": "string",
|
||||
"products": [
|
||||
{
|
||||
"exemplars": [
|
||||
{
|
||||
"exemplar_id": 0,
|
||||
"gtd": "string",
|
||||
"is_gtd_absent": true,
|
||||
"is_rnpt_absent": true,
|
||||
"mandatory_mark": "string",
|
||||
"rnpt": "string",
|
||||
"jw_uin": "string"
|
||||
}
|
||||
],
|
||||
"is_gtd_needed": true,
|
||||
"is_mandatory_mark_needed": true,
|
||||
"is_rnpt_needed": true,
|
||||
"product_id": 0,
|
||||
"quantity": 0
|
||||
}
|
||||
]
|
||||
}`,
|
||||
},
|
||||
// Test No Client-Id or Api-Key
|
||||
{
|
||||
http.StatusUnauthorized,
|
||||
map[string]string{},
|
||||
&CreateOrGetProductExemplarParams{},
|
||||
`{
|
||||
"code": 16,
|
||||
"message": "Client-Id and Api-Key headers are required"
|
||||
}`,
|
||||
},
|
||||
}
|
||||
|
||||
for _, test := range tests {
|
||||
c := NewMockClient(core.NewMockHttpHandler(test.statusCode, test.response, test.headers))
|
||||
|
||||
ctx, _ := context.WithTimeout(context.Background(), testTimeout)
|
||||
resp, err := c.FBS().CreateOrGetProductExemplar(ctx, test.params)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
continue
|
||||
}
|
||||
|
||||
compareJsonResponse(t, test.response, &CreateOrGetProductExemplarResponse{})
|
||||
|
||||
if resp.StatusCode != test.statusCode {
|
||||
t.Errorf("got wrong status code: got: %d, expected: %d", resp.StatusCode, test.statusCode)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
53
ozon/ozon.go
53
ozon/ozon.go
@@ -10,6 +10,15 @@ const (
|
||||
DefaultAPIBaseUrl = "https://api-seller.ozon.ru"
|
||||
)
|
||||
|
||||
type ClientOptions struct {
|
||||
client core.HttpClient
|
||||
|
||||
baseUri string
|
||||
|
||||
apiKey string
|
||||
clientId string
|
||||
}
|
||||
|
||||
type Client struct {
|
||||
client *core.Client
|
||||
|
||||
@@ -110,10 +119,46 @@ func (c Client) Barcodes() *Barcodes {
|
||||
return c.barcodes
|
||||
}
|
||||
|
||||
func NewClient(httpClient core.HttpClient, clientId, apiKey string) *Client {
|
||||
coreClient := core.NewClient(httpClient, DefaultAPIBaseUrl, map[string]string{
|
||||
"Client-Id": clientId,
|
||||
"Api-Key": apiKey,
|
||||
type ClientOption func(c *ClientOptions)
|
||||
|
||||
func WithHttpClient(httpClient core.HttpClient) ClientOption {
|
||||
return func(c *ClientOptions) {
|
||||
c.client = httpClient
|
||||
}
|
||||
}
|
||||
|
||||
func WithURI(uri string) ClientOption {
|
||||
return func(c *ClientOptions) {
|
||||
c.baseUri = uri
|
||||
}
|
||||
}
|
||||
|
||||
func WithClientId(clientId string) ClientOption {
|
||||
return func(c *ClientOptions) {
|
||||
c.clientId = clientId
|
||||
}
|
||||
}
|
||||
|
||||
func WithAPIKey(apiKey string) ClientOption {
|
||||
return func(c *ClientOptions) {
|
||||
c.apiKey = apiKey
|
||||
}
|
||||
}
|
||||
|
||||
func NewClient(opts ...ClientOption) *Client {
|
||||
// default values
|
||||
options := &ClientOptions{
|
||||
client: http.DefaultClient,
|
||||
baseUri: DefaultAPIBaseUrl,
|
||||
}
|
||||
|
||||
for _, opt := range opts {
|
||||
opt(options)
|
||||
}
|
||||
|
||||
coreClient := core.NewClient(options.client, options.baseUri, map[string]string{
|
||||
"Client-Id": options.clientId,
|
||||
"Api-Key": options.apiKey,
|
||||
})
|
||||
|
||||
return &Client{
|
||||
|
||||
27
ozon/ozon_test.go
Normal file
27
ozon/ozon_test.go
Normal file
@@ -0,0 +1,27 @@
|
||||
package ozon
|
||||
|
||||
import (
|
||||
"net/http"
|
||||
"testing"
|
||||
)
|
||||
|
||||
const (
|
||||
apiKey = "some_key"
|
||||
clientId = "some_client_id"
|
||||
)
|
||||
|
||||
func TestNewClient(t *testing.T) {
|
||||
client := NewClient(
|
||||
WithAPIKey(apiKey),
|
||||
WithClientId(clientId),
|
||||
WithURI(DefaultAPIBaseUrl),
|
||||
WithHttpClient(http.DefaultClient),
|
||||
)
|
||||
|
||||
if client.client.Options["Api-Key"] != apiKey {
|
||||
t.Errorf("expected api key: %s, but got: %s", apiKey, client.client.Options["Api-Key"])
|
||||
}
|
||||
if client.client.Options["Client-Id"] != clientId {
|
||||
t.Errorf("expected client id: %s, but got: %s", clientId, client.client.Options["Client-Id"])
|
||||
}
|
||||
}
|
||||
@@ -27,13 +27,13 @@ type GetStocksInfoParams struct {
|
||||
|
||||
type GetStocksInfoFilter struct {
|
||||
// Filter by the offer_id parameter. It is possible to pass a list of values
|
||||
OfferId string `json:"offer_id"`
|
||||
OfferId string `json:"offer_id,omitempty"`
|
||||
|
||||
// Filter by the product_id parameter. It is possible to pass a list of values
|
||||
ProductId int64 `json:"product_id"`
|
||||
ProductId int64 `json:"product_id,omitempty"`
|
||||
|
||||
// Filter by product visibility
|
||||
Visibility string `json:"visibility"`
|
||||
Visibility string `json:"visibility,omitempty"`
|
||||
}
|
||||
|
||||
type GetStocksInfoResponse struct {
|
||||
@@ -130,6 +130,9 @@ type ProductDetails struct {
|
||||
// Category identifier
|
||||
DescriptionCategoryId int64 `json:"description_category_id"`
|
||||
|
||||
// Product type identifier
|
||||
TypeId int64 `json:"type_id"`
|
||||
|
||||
// Marketing color
|
||||
ColorImage string `json:"color_image"`
|
||||
|
||||
@@ -142,6 +145,12 @@ type ProductDetails struct {
|
||||
// Product SKU
|
||||
SKU int64 `json:"sku"`
|
||||
|
||||
// SKU of the product that is sold from the Ozon warehouse (FBO)
|
||||
FBOSKU int64 `json:"fbo_sku,omitempty"`
|
||||
|
||||
// SKU of the product that is sold from the seller's warehouse (FBS and rFBS)
|
||||
FBSSKU int64 `json:"fbs_sku,omitempty"`
|
||||
|
||||
// Document generation task number
|
||||
Id int64 `json:"id"`
|
||||
|
||||
@@ -853,7 +862,7 @@ type CreateOrUpdateAttribute struct {
|
||||
|
||||
type CreateOrUpdateAttributeValue struct {
|
||||
// Directory identifier
|
||||
DictionaryValueId int64 `json:"dictrionary_value_id"`
|
||||
DictionaryValueId int64 `json:"dictionary_value_id"`
|
||||
|
||||
// Value from the directory
|
||||
Value string `json:"value"`
|
||||
@@ -888,7 +897,7 @@ type CreateOrUpdateProductResult struct {
|
||||
|
||||
// This method allows you to create products and update their details
|
||||
func (c Products) CreateOrUpdateProduct(ctx context.Context, params *CreateOrUpdateProductParams) (*CreateOrUpdateProductResponse, error) {
|
||||
url := "/v2/product/import"
|
||||
url := "/v3/product/import"
|
||||
|
||||
resp := &CreateOrUpdateProductResponse{}
|
||||
|
||||
@@ -1347,10 +1356,10 @@ type GetDescriptionOfProductParams struct {
|
||||
Limit int64 `json:"limit"`
|
||||
|
||||
// The parameter by which the products will be sorted
|
||||
SortBy string `json:"sort_by"`
|
||||
SortBy string `json:"sort_by,omitempty"`
|
||||
|
||||
// Sorting direction
|
||||
SortDirection string `json:"sort_direction"`
|
||||
SortDirection string `json:"sort_dir,omitempty"`
|
||||
}
|
||||
|
||||
type GetDescriptionOfProductFilter struct {
|
||||
@@ -1609,7 +1618,7 @@ func (c Products) GetProductRangeLimit(ctx context.Context) (*GetProductRangeLim
|
||||
|
||||
resp := &GetProductRangeLimitResponse{}
|
||||
|
||||
response, err := c.client.Request(ctx, http.MethodPost, url, &struct{}{}, resp, nil)
|
||||
response, err := c.client.Request(ctx, http.MethodPost, url, nil, resp, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@@ -1937,7 +1946,7 @@ type GetPRoductPriceInfoResultItem struct {
|
||||
Commissions GetProductPriceInfoResultItemCommission `json:"commissions"`
|
||||
|
||||
// Promotions information
|
||||
MarketingActions []GetProductPriceInfoResultItemMarketingActions `json:"marketing_actions"`
|
||||
MarketingActions *GetProductPriceInfoResultItemMarketingActions `json:"marketing_actions"`
|
||||
|
||||
// Seller product identifier
|
||||
OfferId string `json:"offer_id"`
|
||||
|
||||
@@ -127,7 +127,7 @@ func TestGetProductDetails(t *testing.T) {
|
||||
"7533900005"
|
||||
],
|
||||
"buybox_price": "",
|
||||
"description_category_id": 17038062,
|
||||
"type_id": 0,
|
||||
"created_at": "2021-10-21T15:48:03.529178Z",
|
||||
"images": [
|
||||
"https://cdn1.ozone.ru/s3/multimedia-5/6088931525.jpg",
|
||||
@@ -141,6 +141,7 @@ func TestGetProductDetails(t *testing.T) {
|
||||
"reserved": 0
|
||||
},
|
||||
"currency_code": "RUB",
|
||||
"description_category_id": 12,
|
||||
"marketing_price": "",
|
||||
"min_price": "",
|
||||
"old_price": "",
|
||||
@@ -1378,6 +1379,7 @@ func TestListProductsByIDs(t *testing.T) {
|
||||
],
|
||||
"buybox_price": "",
|
||||
"description_category_id": 93726157,
|
||||
"type_id": 0,
|
||||
"created_at": "2021-06-03T03:40:05.871465Z",
|
||||
"images": [],
|
||||
"has_discounted_item": true,
|
||||
@@ -1420,7 +1422,24 @@ func TestListProductsByIDs(t *testing.T) {
|
||||
"active_product": false,
|
||||
"reasons": {}
|
||||
},
|
||||
"price_index": "0.00",
|
||||
"price_indexes": {
|
||||
"external_index_data": {
|
||||
"minimal_price": "string",
|
||||
"minimal_price_currency": "string",
|
||||
"price_index_value": 0
|
||||
},
|
||||
"ozon_index_data": {
|
||||
"minimal_price": "string",
|
||||
"minimal_price_currency": "string",
|
||||
"price_index_value": 0
|
||||
},
|
||||
"price_index": "WITHOUT_INDEX",
|
||||
"self_marketplaces_index_data": {
|
||||
"minimal_price": "string",
|
||||
"minimal_price_currency": "string",
|
||||
"price_index_value": 0
|
||||
}
|
||||
},
|
||||
"images360": [],
|
||||
"is_kgt": false,
|
||||
"color_image": "",
|
||||
|
||||
@@ -154,7 +154,7 @@ type ProductsAvailableForPromotionParams struct {
|
||||
|
||||
// Number of elements that will be skipped in the response.
|
||||
// For example, if offset=10, the response will start with the 11th element found
|
||||
Offset float64 `json:"offset"`
|
||||
Offset float64 `json:"offset,omitempty"`
|
||||
}
|
||||
|
||||
type ProductsAvailableForPromotionResponse struct {
|
||||
@@ -218,7 +218,7 @@ type ProductsInPromotionParams struct {
|
||||
Limit float64 `json:"limit"`
|
||||
|
||||
// Number of elements that will be skipped in the response. For example, if offset=10, the response will start with the 11th element found
|
||||
Offset float64 `json:"offset"`
|
||||
Offset float64 `json:"offset,omitempty"`
|
||||
}
|
||||
|
||||
type ProductsInPromotionResponse struct {
|
||||
@@ -355,7 +355,7 @@ type ProductsAvailableForHotSalePromotionParams struct {
|
||||
Limit float64 `json:"limit"`
|
||||
|
||||
// Number of elements that will be skipped in the response. For example, if offset=10, the response will start with the 11th element found
|
||||
Offset float64 `json:"offset"`
|
||||
Offset float64 `json:"offset,omitempty"`
|
||||
}
|
||||
|
||||
type ProductsAvailableForHotSalePromotionResponse struct {
|
||||
|
||||
@@ -450,7 +450,7 @@ func (c Reports) GetProducts(ctx context.Context, params *GetProductsReportParam
|
||||
|
||||
type GetReturnsReportParams struct {
|
||||
// Filter
|
||||
Filter GetReturnsReportsFilter `json:"filter"`
|
||||
Filter *GetReturnsReportsFilter `json:"filter,omitempty"`
|
||||
|
||||
// Default: "DEFAULT"
|
||||
// Response language:
|
||||
@@ -501,7 +501,7 @@ func (c Reports) GetReturns(ctx context.Context, params *GetReturnsReportParams)
|
||||
|
||||
type GetShipmentReportParams struct {
|
||||
// Filter
|
||||
Filter GetShipmentReportFilter `json:"filter"`
|
||||
Filter *GetShipmentReportFilter `json:"filter,omitempty"`
|
||||
|
||||
// Default: "DEFAULT"
|
||||
// Response language:
|
||||
|
||||
@@ -375,7 +375,7 @@ func TestGetReturnsReport(t *testing.T) {
|
||||
http.StatusOK,
|
||||
map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"},
|
||||
&GetReturnsReportParams{
|
||||
Filter: GetReturnsReportsFilter{
|
||||
Filter: &GetReturnsReportsFilter{
|
||||
DeliverySchema: "fbs",
|
||||
},
|
||||
},
|
||||
@@ -435,7 +435,7 @@ func TestGetShipmentReport(t *testing.T) {
|
||||
http.StatusOK,
|
||||
map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"},
|
||||
&GetShipmentReportParams{
|
||||
Filter: GetShipmentReportFilter{
|
||||
Filter: &GetShipmentReportFilter{
|
||||
DeliverySchema: []string{"fbs", "fbo", "crossborder"},
|
||||
ProcessedAtFrom: core.TimeFromString(t, "2006-01-02T15:04:05Z", "2021-09-02T17:10:54.861Z"),
|
||||
ProcessedAtTo: core.TimeFromString(t, "2006-01-02T15:04:05Z", "2021-11-02T17:10:54.861Z"),
|
||||
|
||||
@@ -14,7 +14,7 @@ type Returns struct {
|
||||
|
||||
type GetFBOReturnsParams struct {
|
||||
// Filter
|
||||
Filter GetFBOReturnsFilter `json:"filter"`
|
||||
Filter *GetFBOReturnsFilter `json:"filter,omitempty"`
|
||||
|
||||
// Identifier of the last value on the page. Leave this field blank in the first request.
|
||||
//
|
||||
@@ -56,7 +56,7 @@ type GetFBOReturnsReturn struct {
|
||||
// Return destination
|
||||
DestinationPlaceName string `json:"dst_place_name"`
|
||||
|
||||
// Return identifier
|
||||
// Return shipment identifier
|
||||
Id int64 `json:"id"`
|
||||
|
||||
// Indication that the package has been opened. true, if it has been
|
||||
@@ -65,6 +65,9 @@ type GetFBOReturnsReturn struct {
|
||||
// Shipment number
|
||||
PostingNumber string `json:"posting_number"`
|
||||
|
||||
// Unique return record identifier
|
||||
ReturnId int64 `json:"return_id"`
|
||||
|
||||
// Return reason
|
||||
ReturnReasonName string `json:"return_reason_name"`
|
||||
|
||||
@@ -95,7 +98,7 @@ func (c Returns) GetFBOReturns(ctx context.Context, params *GetFBOReturnsParams)
|
||||
|
||||
type GetFBSReturnsParams struct {
|
||||
// Filter
|
||||
Filter GetFBSReturnsFilter `json:"filter"`
|
||||
Filter *GetFBSReturnsFilter `json:"filter,omitempty"`
|
||||
|
||||
// Number of values in the response:
|
||||
// - maximum — 1000,
|
||||
@@ -264,7 +267,7 @@ func (c Returns) GetFBSReturns(ctx context.Context, params *GetFBSReturnsParams)
|
||||
|
||||
type GetRFBSReturnsParams struct {
|
||||
// Filter
|
||||
Filter GetRFBSReturnsFilter `json:"filter"`
|
||||
Filter *GetRFBSReturnsFilter `json:"filter,omitempty"`
|
||||
|
||||
// Identifier of the last value on the page.
|
||||
// Leave this field blank in the first request
|
||||
@@ -667,7 +670,7 @@ func (c Returns) IsGiveoutEnabled(ctx context.Context) (*IsGiveoutEnabledRespons
|
||||
|
||||
resp := &IsGiveoutEnabledResponse{}
|
||||
|
||||
response, err := c.client.Request(ctx, http.MethodPost, url, struct{}{}, resp, nil)
|
||||
response, err := c.client.Request(ctx, http.MethodPost, url, nil, resp, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@@ -697,7 +700,7 @@ func (c Returns) GetGiveoutPDF(ctx context.Context) (*GetGiveoutResponse, error)
|
||||
|
||||
resp := &GetGiveoutResponse{}
|
||||
|
||||
response, err := c.client.Request(ctx, http.MethodPost, url, struct{}{}, resp, nil)
|
||||
response, err := c.client.Request(ctx, http.MethodPost, url, nil, resp, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@@ -714,7 +717,7 @@ func (c Returns) GetGiveoutPNG(ctx context.Context) (*GetGiveoutResponse, error)
|
||||
|
||||
resp := &GetGiveoutResponse{}
|
||||
|
||||
response, err := c.client.Request(ctx, http.MethodPost, url, struct{}{}, resp, nil)
|
||||
response, err := c.client.Request(ctx, http.MethodPost, url, nil, resp, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@@ -739,7 +742,7 @@ func (c Returns) GetGiveoutBarcode(ctx context.Context) (*GetGiveoutBarcodeRespo
|
||||
|
||||
resp := &GetGiveoutBarcodeResponse{}
|
||||
|
||||
response, err := c.client.Request(ctx, http.MethodPost, url, struct{}{}, resp, nil)
|
||||
response, err := c.client.Request(ctx, http.MethodPost, url, nil, resp, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@@ -758,7 +761,7 @@ func (c Returns) ResetGiveoutBarcode(ctx context.Context) (*GetGiveoutResponse,
|
||||
|
||||
resp := &GetGiveoutResponse{}
|
||||
|
||||
response, err := c.client.Request(ctx, http.MethodPost, url, struct{}{}, resp, nil)
|
||||
response, err := c.client.Request(ctx, http.MethodPost, url, nil, resp, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@@ -814,7 +817,7 @@ func (c Returns) GetGiveoutList(ctx context.Context, params *GetGiveoutListParam
|
||||
|
||||
resp := &GetGiveoutListResponse{}
|
||||
|
||||
response, err := c.client.Request(ctx, http.MethodPost, url, struct{}{}, resp, nil)
|
||||
response, err := c.client.Request(ctx, http.MethodPost, url, nil, resp, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@@ -867,7 +870,7 @@ func (c Returns) GetGiveoutInfo(ctx context.Context, params *GetGiveoutInfoParam
|
||||
|
||||
resp := &GetGiveoutInfoResponse{}
|
||||
|
||||
response, err := c.client.Request(ctx, http.MethodPost, url, struct{}{}, resp, nil)
|
||||
response, err := c.client.Request(ctx, http.MethodPost, url, nil, resp, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
@@ -22,7 +22,7 @@ func TestGetFBOReturns(t *testing.T) {
|
||||
http.StatusOK,
|
||||
map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"},
|
||||
&GetFBOReturnsParams{
|
||||
Filter: GetFBOReturnsFilter{
|
||||
Filter: &GetFBOReturnsFilter{
|
||||
PostingNumber: "some number",
|
||||
},
|
||||
LastId: 123,
|
||||
@@ -105,7 +105,7 @@ func TestGetFBSReturns(t *testing.T) {
|
||||
http.StatusOK,
|
||||
map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"},
|
||||
&GetFBSReturnsParams{
|
||||
Filter: GetFBSReturnsFilter{
|
||||
Filter: &GetFBSReturnsFilter{
|
||||
PostingNumber: []string{"07402477-0022-2"},
|
||||
Status: "returned_to_seller",
|
||||
},
|
||||
@@ -212,7 +212,7 @@ func TestGetRFBSReturns(t *testing.T) {
|
||||
&GetRFBSReturnsParams{
|
||||
LastId: 999,
|
||||
Limit: 555,
|
||||
Filter: GetRFBSReturnsFilter{
|
||||
Filter: &GetRFBSReturnsFilter{
|
||||
OfferId: "123",
|
||||
PostingNumber: "111",
|
||||
GroupState: []RFBSReturnsGroupState{RFBSReturnsGroupStateAll},
|
||||
|
||||
@@ -102,7 +102,7 @@ func (c Warehouses) GetListOfWarehouses(ctx context.Context) (*GetListOfWarehous
|
||||
|
||||
type GetListOfDeliveryMethodsParams struct {
|
||||
// Search filter for delivery methods
|
||||
Filter GetListOfDeliveryMethodsFilter `json:"filter"`
|
||||
Filter *GetListOfDeliveryMethodsFilter `json:"filter,omitempty"`
|
||||
|
||||
// Number of items in a response. Maximum is 50, minimum is 1
|
||||
Limit int64 `json:"limit"`
|
||||
@@ -181,7 +181,7 @@ func (c Warehouses) GetListOfDeliveryMethods(ctx context.Context, params *GetLis
|
||||
|
||||
resp := &GetListOfDeliveryMethodsResponse{}
|
||||
|
||||
response, err := c.client.Request(ctx, http.MethodPost, url, nil, resp, nil)
|
||||
response, err := c.client.Request(ctx, http.MethodPost, url, params, resp, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
@@ -99,7 +99,7 @@ func TestGetListOfDeliveryMethods(t *testing.T) {
|
||||
http.StatusOK,
|
||||
map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"},
|
||||
&GetListOfDeliveryMethodsParams{
|
||||
Filter: GetListOfDeliveryMethodsFilter{
|
||||
Filter: &GetListOfDeliveryMethodsFilter{
|
||||
WarehouseId: 15588127982000,
|
||||
},
|
||||
Limit: 100,
|
||||
|
||||
Reference in New Issue
Block a user