client_test.go

package mobilepay

import (
	"context"
	"fmt"
	"github.com/stretchr/testify/assert"
	"gopkg.in/h2non/gock.v1"
	"io/ioutil"
	"net/http"
	"net/url"
	"testing"
	"time"
)

func TestClient_Timeout(t *testing.T) {
	var config = &Config{}

	client := New("test", "test", config)

	assert.Equal(t, 10*time.Second, client.client.Timeout)
}

func TestClient_Auth_Keys(t *testing.T) {
	var config = &Config{}

	client := New("client_id", "api_key", config)

	assert.Len(t, client.headers, 2)
	assert.Contains(t, client.headers, "x-ibm-client-id")
	assert.Contains(t, client.headers, "Authorization")
	assert.Equal(t, "client_id", client.headers["x-ibm-client-id"])
	assert.Equal(t, "Bearer api_key", client.headers["Authorization"])
}

func TestClient_CheckResponse(t *testing.T) {
	defer gock.Off() // Flush pending mocks after test execution

	testdata, err := ioutil.ReadFile("testdata/capture_payment_409_amount_too_large.json")
	if err != nil {
		t.Fatal(err)
	}

	gock.New(TestBaseUrl).
		Post("/v1/payments/25df9ee7-5608-4b7a-98d0-df649861075b/capture").
		Reply(409).
		JSON(testdata)

	url := fmt.Sprintf("%s/%s", TestBaseUrl, "/v1/payments/25df9ee7-5608-4b7a-98d0-df649861075b/capture")
	res, err := http.Post(url, "application/json", nil)
	assert.Nil(t, err)

	err = CheckResponse(res)
	assert.Error(t, err)
	assert.IsType(t, &ErrorResponse{}, err)
	mpError, ok := err.(*ErrorResponse)
	assert.True(t, ok)
	assert.Equal(t, 409, mpError.StatusCode)
	assert.Equal(t, "amount_too_large", mpError.Conflict.Code)
}

func TestClient_CheckResponse_Unknown_Error_Format(t *testing.T) {
	defer gock.Off() // Flush pending mocks after test execution

	gock.New(TestBaseUrl).
		Post("/v1/payments/25df9ee7-5608-4b7a-98d0-df649861075b/capture").
		Reply(409).
		JSON("Unknown error")

	url := fmt.Sprintf("%s/%s", TestBaseUrl, "/v1/payments/25df9ee7-5608-4b7a-98d0-df649861075b/capture")
	res, err := http.Post(url, "application/json", nil)
	assert.Nil(t, err)

	err = CheckResponse(res)
	assert.Error(t, err)
	assert.IsType(t, &ErrorResponse{}, err)
	mpError, ok := err.(*ErrorResponse)
	assert.True(t, ok)
	assert.Equal(t, 409, mpError.StatusCode)
	assert.Equal(t, "Unknown error", mpError.Message)
}

func TestClient_CheckResponse_500_Error(t *testing.T) {
	defer gock.Off() // Flush pending mocks after test execution

	gock.New(TestBaseUrl).
		Post("/v1/payments/25df9ee7-5608-4b7a-98d0-df649861075b/capture").
		Reply(500).
		JSON("Backend error")

	var config = &Config{URL: TestBaseUrl}

	client := New("client_id", "api_key", config)
	ctx := context.TODO()
	err := client.Payment.Capture(ctx, "25df9ee7-5608-4b7a-98d0-df649861075b", 100)

	assert.Error(t, err)
	assert.IsType(t, &ErrorResponse{}, err)
	mpError, ok := err.(*ErrorResponse)
	assert.True(t, ok)
	assert.Equal(t, 500, mpError.StatusCode)
	assert.Equal(t, "Backend error", mpError.Message)
}

func TestClient_ErrorResponse(t *testing.T) {
	error := ErrorResponse{
		Response: &http.Response{
			StatusCode: http.StatusConflict,
			Request: &http.Request{
				Method: http.MethodPost,
				URL: &url.URL{
					Scheme: "https",
					Host:   "bla.com",
				},
			},
		},
		Message: "Unknown error",
		Conflict: &ConflictError{
			Code:          "amount_too_large",
			Message:       "Cannot capture a larger amount than is reserved.",
			CorrelationID: "d503b7ed-b5d0-4751-b3ac-52ecd7cd3a4a",
			Origin:        "MPY",
		},
		StatusCode: http.StatusConflict,
	}

	expected := fmt.Sprintf("%s %s: %d %v", "POST", "https://bla.com", 409, "Unknown error")

	assert.Equal(t, expected, error.Error())
}

func TestClient_NewRequest_Invalid_URL(t *testing.T) {
	var config = &Config{}

	client := New("client_id", "api_key", config)
	ctx := context.TODO()

	res, err := client.NewRequest(ctx, http.MethodGet, " http://foo.com", nil)
	assert.Error(t, err)
	assert.Nil(t, res)
}

func TestClient_NewRequest_Invalid_JSON_Body(t *testing.T) {
	// a channel is not json serializable.
	body := make(chan int)
	var config = &Config{}

	client := New("client_id", "api_key", config)
	ctx := context.TODO()

	res, err := client.NewRequest(ctx, http.MethodPost, "/v1/payments/25df9ee7-5608-4b7a-98d0-df649861075b/capture", body)
	assert.Error(t, err)
	assert.Nil(t, res)
}

func TestClient_addOptions(t *testing.T) {
	{
		var nilPnt *string
		_, err := addOptions(":", nilPnt)
		assert.NoError(t, err)
	}

	{
		_, err := addOptions(":", nil)
		assert.Error(t, err)
	}

	{
		type test interface{}
		var tester test
		_, err := addOptions("/", &tester)
		assert.Error(t, err)
	}

	{
		type test struct {
			CustomerID string `url:"customerId,omitempty"`
		}
		params := &test{CustomerID: "+4588888888"}
		path, err := addOptions("/appswitch/api/v1/reservations/merchants/APPDK0000000000/2020-01-04T19_58/2020-01-04T20_58", params)
		assert.NoError(t, err)
		assert.Equal(t, "/appswitch/api/v1/reservations/merchants/APPDK0000000000/2020-01-04T19_58/2020-01-04T20_58?customerId=%2B4588888888", path)
	}
}