payments/internal/connectors/plugins/public/currencycloud/client/auth.go

package client

import (
	"context"
	"fmt"
	"net/http"
	"net/url"
	"strings"

	"github.com/formancehq/payments/internal/connectors/metrics"
	errorsutils "github.com/formancehq/payments/internal/utils/errors"
)

func (c *client) authenticate(ctx context.Context) error {
	ctx = context.WithValue(ctx, metrics.MetricOperationContextKey, "authenticate")

	form := make(url.Values)

	form.Add("login_id", c.loginID)
	form.Add("api_key", c.apiKey)

	req, err := http.NewRequestWithContext(ctx, http.MethodPost,
		c.buildEndpoint("v2/authenticate/api"), strings.NewReader(form.Encode()))
	if err != nil {
		return fmt.Errorf("failed to create request: %w", err)
	}

	req.Header.Add("Content-Type", "application/x-www-form-urlencoded")
	req.Header.Add("Accept", "application/json")

	//nolint:tagliatelle // allow for client code
	type response struct {
		AuthToken string `json:"auth_token"`
	}

	var res response
	var errRes currencyCloudError
	_, err = c.httpClient.Do(ctx, req, &res, &errRes)
	if err != nil {
		return errorsutils.NewWrappedError(
			fmt.Errorf("failed to get authenticate: %v", errRes.Error()),
			err,
		)
	}

	c.authToken = res.AuthToken

	return nil
}

func (c *client) ensureLogin(ctx context.Context) error {
	if c.authToken == "" {
		_, err, _ := c.singleFlight.Do("authenticate", func() (interface{}, error) {
			return nil, c.authenticate(ctx)
		})
		return err
	}
	return nil
}