client.go

/*
 * MIT License
 *
 * Copyright (c) 2024 Anton Stremovskyy
 *
 * Permission is hereby granted, free of charge, to any person obtaining a copy
 * of this software and associated documentation files (the "Software"), to deal
 * in the Software without restriction, including without limitation the rights
 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
 * copies of the Software, and to permit persons to whom the Software is
 * furnished to do so, subject to the following conditions:
 *
 * The above copyright notice and this permission notice shall be included in all
 * copies or substantial portions of the Software.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 * SOFTWARE.
 */

package go_ipay

import (
	"fmt"
	"net/url"

	"github.com/stremovskyy/go-ipay/internal/http"
	"github.com/stremovskyy/go-ipay/ipay"
	"github.com/stremovskyy/go-ipay/log"
	"github.com/stremovskyy/recorder"
)

type client struct {
	ipayClient *http.Client
	recorder   recorder.Recorder
}

func (c *client) SetLogLevel(levelDebug log.Level) {
	log.SetLevel(levelDebug)
}

func NewDefaultClient() Ipay {
	return &client{
		ipayClient: http.NewClient(http.DefaultOptions()),
	}
}

func NewClientWithRecorder(rec recorder.Recorder) Ipay {
	return &client{
		ipayClient: http.NewClient(http.DefaultOptions()).WithRecorder(rec),
	}
}

func NewClient(options ...Option) Ipay {
	c := &client{
		ipayClient: http.NewClient(http.DefaultOptions()),
	}

	for _, option := range options {
		option(c)
	}

	return c
}

func (c *client) VerificationLink(request *Request) (*url.URL, error) {
	if request == nil {
		return nil, ErrRequestIsNil
	}

	createTokenRequest := ipay.NewRequest(
		ipay.ActionCreateToken3DS, ipay.LangUk,
		ipay.WithAuth(request.GetAuth()),
		ipay.WithInvoiceInTransactions(request.GetAmount(), request.GetSubMerchantID()),
		ipay.WithRedirects(request.GetRedirects()),
		ipay.WithPersonalData(request.GetPersonalData()),
		ipay.WithPaymentID(request.GetPaymentID()),
		ipay.WithAmount(0),
		ipay.WithWebhookURL(request.GetWebhookURL()),
		ipay.WithDescription(request.GetDescription()),
		ipay.WithOutAmount(true),
		ipay.WithAML(request.GetAML()),
	)

	apiResponse, err := c.ipayClient.Api(createTokenRequest)
	if err != nil {
		return nil, fmt.Errorf("cannot get API response: %v", err)
	}

	u, err := url.Parse(apiResponse.Url)
	if err != nil {
		return nil, fmt.Errorf("cannot parse URL: %v", err)
	}

	return u, nil
}

func (c *client) Status(request *Request) (*ipay.Response, error) {
	if request == nil {
		return nil, ErrRequestIsNil
	}

	statusRequest := ipay.NewRequest(
		ipay.ActionGetPaymentStatus, ipay.LangUk,
		ipay.WithAuth(request.GetAuth()),
		ipay.WithIpayPaymentID(request.GetIpayPaymentID()),
		ipay.WithWebhookURL(request.GetWebhookURL()),
	)

	apiResponse, err := c.ipayClient.Api(statusRequest)
	if err != nil {
		return nil, fmt.Errorf("cannot get API response: %v", err)
	}

	return apiResponse, nil
}

func (c *client) PaymentURL(request *Request) (*ipay.PaymentResponse, error) {
	if request == nil {
		return nil, ErrRequestIsNil
	}

	XMLPaymentURLRequest := ipay.CreateXMLPaymentCreateRequest()
	XMLPaymentURLRequest.SetAuth(request.GetAuth())
	XMLPaymentURLRequest.SetRedirects(request.GetRedirects())
	XMLPaymentURLRequest.AddTransaction(request.GetTransaction())
	XMLPaymentURLRequest.SetPersonalData(request.GetPersonalData())
	XMLPaymentURLRequest.AddCardToken(request.GetCardToken())

	apiResponse, err := c.ipayClient.ApiXML(XMLPaymentURLRequest)
	if err != nil {
		return nil, fmt.Errorf("cannot get API response: %v", err)
	}

	return apiResponse, nil
}

func (c *client) Payment(request *Request) (*ipay.Response, error) {
	if request == nil {
		return nil, ErrRequestIsNil
	}

	if request.IsMobile() {
		return c.handleMobilePayment(request, false)
	}

	return c.handleStandardPayment(request, false)
}

func (c *client) Hold(request *Request) (*ipay.Response, error) {
	if request == nil {
		return nil, ErrRequestIsNil
	}

	if request.IsMobile() {
		return c.handleMobilePayment(request, true)
	}

	return c.handleStandardPayment(request, true)
}

func (c *client) handleMobilePayment(request *Request, isPreauth bool) (*ipay.Response, error) {
	var paymentRequest *ipay.RequestWrapper
	var apiFunc func(*ipay.RequestWrapper) (*ipay.Response, error)

	common := []func(*ipay.RequestWrapper){
		ipay.WithAuth(request.GetMobileAuth()),
		ipay.WithInvoiceAmount(request.GetAmount()),
		ipay.WithInvoiceInTransactions(request.GetAmount(), request.GetSubMerchantID()),
		ipay.WithWebhookURL(request.GetWebhookURL()),
		ipay.WithDescription(request.GetDescription()),
		ipay.WithPaymentID(request.GetPaymentID()),
		ipay.WithPersonalData(request.GetPersonalData()),
	}

	if isPreauth {
		common = append(common, ipay.WithPreauth(true))
	}

	if request.IsApplePay() {
		container, err := request.GetAppleContainer()
		if err != nil {
			return nil, fmt.Errorf("cannot get Apple Container: %v", err)
		}
		paymentRequest = ipay.NewRequest(
			ipay.MobilePaymentCreate, ipay.LangUk,
			append(common, ipay.WithAppleContainer(container))...,
		)
		apiFunc = c.ipayClient.ApplePayApi
	} else {
		token, err := request.GetGoogleToken()
		if err != nil {
			return nil, fmt.Errorf("cannot get Google Token: %v", err)
		}

		paymentRequest = ipay.NewRequest(
			ipay.MobilePaymentCreate, ipay.LangUk,
			append(common, ipay.WithGoogleContainer(token))...,
		)
		apiFunc = c.ipayClient.GooglePayApi
	}

	apiResponse, err := apiFunc(paymentRequest)
	if err != nil {
		return nil, fmt.Errorf("cannot get API response: %v", err)
	}
	return apiResponse, nil
}

func (c *client) handleStandardPayment(request *Request, preauth bool) (*ipay.Response, error) {
	options := []func(*ipay.RequestWrapper){
		ipay.WithAmount(request.GetAmount()),
		ipay.WithCurrency(request.GetCurrency()),
		ipay.WithAuth(request.GetAuth()),
		ipay.WithPersonalData(request.GetPersonalData()),
		ipay.WithInvoiceInTransactions(request.GetAmount(), request.GetSubMerchantID()),
		ipay.WithCardToken(request.GetCardToken()),
		ipay.WithPaymentID(request.GetPaymentID()),
		ipay.WithDescription(request.GetDescription()),
		ipay.WithWebhookURL(request.GetWebhookURL()),
	}

	if preauth {
		options = append(options, ipay.WithPreauth(true))
	}

	holdRequest := ipay.NewRequest(ipay.ActionDebiting, ipay.LangUk, options...)

	apiResponse, err := c.ipayClient.Api(holdRequest)
	if err != nil {
		return nil, fmt.Errorf("cannot get API response: %v", err)
	}

	return apiResponse, nil
}

func (c *client) Capture(invoiceRequest *Request) (*ipay.Response, error) {
	captureRequest := ipay.NewRequest(
		ipay.ActionCompletion, ipay.LangUk,
		ipay.WithAuth(invoiceRequest.GetAuth()),
		ipay.WithAmountInTransactions(invoiceRequest.GetAmount(), invoiceRequest.GetSubMerchantID()),
		ipay.WithDescription(invoiceRequest.GetDescription()),
		ipay.WithIpayPaymentID(invoiceRequest.GetIpayPaymentID()),
		ipay.WithWebhookURL(invoiceRequest.GetWebhookURL()),
		ipay.WithReceiver(invoiceRequest.GetReceiver()),
		ipay.WithRelatedIDs(invoiceRequest.GetRelatedIDs()),
	)

	apiResponse, err := c.ipayClient.Api(captureRequest)
	if err != nil {
		return nil, fmt.Errorf("cannot get API response: %v", err)
	}

	return apiResponse, nil
}

func (c *client) Refund(request *Request) (*ipay.Response, error) {
	refundRequest := ipay.NewRequest(
		ipay.ActionReversal, ipay.LangUk,
		ipay.WithAuth(request.GetAuth()),
		ipay.WithIpayPaymentID(request.GetIpayPaymentID()),
		ipay.WithWebhookURL(request.GetWebhookURL()),
	)

	apiResponse, err := c.ipayClient.Api(refundRequest)
	if err != nil {
		return nil, fmt.Errorf("cannot get API response: %v", err)
	}

	return apiResponse, nil
}

func (c *client) Credit(request *Request) (*ipay.Response, error) {
	options := []func(*ipay.RequestWrapper){
		ipay.WithAuth(request.GetAuth()),
		ipay.WithInvoiceAmount(request.GetAmount()),
		ipay.WithPaymentID(request.GetPaymentID()),
		ipay.WithWebhookURL(request.GetWebhookURL()),
		ipay.WithTrackingData(request.GetTrackingData()),
		ipay.WithDescription(request.GetDescription()),
		ipay.WithReceiver(request.GetReceiver()),
	}

	if request.GetCardToken() != nil {
		options = append(options, ipay.WithCardToken(request.GetCardToken()))
	} else if request.GetCardPan() != nil {
		options = append(options, ipay.WithCardPan(request.GetCardPan()))
	} else {
		return nil, fmt.Errorf("cannot get API response: %v", "CardToken or Card pan is required")
	}

	creditRequest := ipay.NewRequest(
		ipay.ActionCredit, ipay.LangUk,
		options...,
	)

	apiResponse, err := c.ipayClient.Api(creditRequest)
	if err != nil {
		return nil, fmt.Errorf("cannot get API response: %v", err)
	}

	return apiResponse, nil
}