stack/components/fctl/cmd/payments/connectors/configs/getconfig.go

package configs

import (
	"fmt"
	"strings"

	"github.com/formancehq/fctl/cmd/payments/connectors/internal"
	"github.com/formancehq/fctl/cmd/payments/connectors/views"
	"github.com/formancehq/fctl/cmd/payments/versions"
	fctl "github.com/formancehq/fctl/pkg"
	"github.com/formancehq/formance-sdk-go/v2/pkg/models/operations"
	"github.com/formancehq/formance-sdk-go/v2/pkg/models/shared"
	"github.com/formancehq/go-libs/collectionutils"
	"github.com/pterm/pterm"
	"github.com/spf13/cobra"
)

type PaymentsGetConfigStore struct {
	ConnectorConfig *shared.ConnectorConfigResponse `json:"connectorConfig"`
	Provider        string                          `json:"provider"`
	ConnectorID     string                          `json:"connectorId"`
}

type PaymentsGetConfigController struct {
	PaymentsVersion versions.Version

	store *PaymentsGetConfigStore

	providerNameFlag string
	connectorIDFlag  string
}

func (c *PaymentsGetConfigController) SetVersion(version versions.Version) {
	c.PaymentsVersion = version
}

var _ fctl.Controller[*PaymentsGetConfigStore] = (*PaymentsGetConfigController)(nil)

func NewDefaultPaymentsGetConfigStore() *PaymentsGetConfigStore {
	return &PaymentsGetConfigStore{}
}

func NewPaymentsGetConfigController() *PaymentsGetConfigController {
	return &PaymentsGetConfigController{
		store:            NewDefaultPaymentsGetConfigStore(),
		providerNameFlag: "provider",
		connectorIDFlag:  "connector-id",
	}
}

func NewGetConfigCommand() *cobra.Command {
	c := NewPaymentsGetConfigController()
	return fctl.NewCommand("get-config",
		fctl.WithAliases("getconfig", "getconf", "gc", "get", "g"),
		fctl.WithArgs(cobra.ExactArgs(0)),
		fctl.WithStringFlag("provider", "", "Provider name"),
		fctl.WithStringFlag("connector-id", "", "Connector ID"),
		fctl.WithShortDescription(fmt.Sprintf("Read a connector config (Connectors available: %v)", internal.AllConnectors)),
		fctl.WithController[*PaymentsGetConfigStore](c),
	)
}

func (c *PaymentsGetConfigController) GetStore() *PaymentsGetConfigStore {
	return c.store
}

func (c *PaymentsGetConfigController) Run(cmd *cobra.Command, args []string) (fctl.Renderable, error) {
	store := fctl.GetStackStore(cmd.Context())

	if err := versions.GetPaymentsVersion(cmd, args, c); err != nil {
		return nil, err
	}

	provider := fctl.GetString(cmd, c.providerNameFlag)
	connectorID := fctl.GetString(cmd, c.connectorIDFlag)

	switch c.PaymentsVersion {
	case versions.V0:
		if provider == "" {
			return nil, fmt.Errorf("provider is required")
		}

		response, err := store.Client().Payments.V1.ReadConnectorConfig(cmd.Context(), operations.ReadConnectorConfigRequest{
			Connector: shared.Connector(provider),
		})
		if err != nil {
			return nil, err
		}

		if response.StatusCode >= 300 {
			return nil, fmt.Errorf("unexpected status code: %d", response.StatusCode)
		}

		c.store.Provider = provider
		c.store.ConnectorConfig = response.ConnectorConfigResponse

	case versions.V1:
		connectorList, err := store.Client().Payments.V1.ListAllConnectors(cmd.Context())
		if err != nil {
			return nil, err
		}
		if connectorList.StatusCode >= 300 {
			return nil, fmt.Errorf("unexpected status code: %d", connectorList.StatusCode)
		}

		connectorsFiltered := collectionutils.Filter(connectorList.ConnectorsResponse.Data, func(connector shared.ConnectorsResponseData) bool {
			if connectorID != "" {
				return connector.ConnectorID == connectorID
			}

			if provider != "" {
				return connector.Provider == shared.Connector(strings.ToUpper(provider))
			}

			return true
		})

		switch len(connectorsFiltered) {
		case 0:
			return nil, fmt.Errorf("no connectors found")
		case 1:
			provider = string(connectorsFiltered[0].Provider)
			connectorID = connectorsFiltered[0].ConnectorID
		default:
			options := make([]string, 0, len(connectorsFiltered))
			for _, connector := range connectorsFiltered {
				options = append(options, strings.Join([]string{"id:" + connector.ConnectorID, "provider:" + string(connector.Provider), "name:" + connector.Name, "enabled:" + fctl.BoolPointerToString(connector.Enabled)}, " "))
			}
			printer := pterm.DefaultInteractiveSelect.WithOptions(options)
			selectedOption, err := printer.Show("Please select a connector")
			if err != nil {
				return nil, err
			}
			connectorID = strings.Split(strings.Split(selectedOption, " ")[0], ":")[1]
			provider = strings.Split(strings.Split(selectedOption, " ")[1], ":")[1]
		}

		response, err := store.Client().Payments.V1.ReadConnectorConfigV1(cmd.Context(), operations.ReadConnectorConfigV1Request{
			Connector:   shared.Connector(provider),
			ConnectorID: connectorID,
		})
		if err != nil {
			return nil, err
		}

		if response.StatusCode >= 300 {
			return nil, fmt.Errorf("unexpected status code: %d", response.StatusCode)
		}

		c.store.Provider = strings.ToLower(provider)
		c.store.ConnectorID = connectorID
		c.store.ConnectorConfig = response.ConnectorConfigResponse
	}

	return c, nil

}

// TODO: This need to use the ui.NewListModel
func (c *PaymentsGetConfigController) Render(cmd *cobra.Command, args []string) error {
	var err error
	switch c.store.Provider {
	case internal.StripeConnector:
		err = views.DisplayStripeConfig(cmd, c.store.ConnectorConfig)
	case internal.ModulrConnector:
		err = views.DisplayModulrConfig(cmd, c.store.ConnectorConfig)
	case internal.BankingCircleConnector:
		err = views.DisplayBankingCircleConfig(cmd, c.store.ConnectorConfig)
	case internal.CurrencyCloudConnector:
		err = views.DisplayCurrencyCloudConfig(cmd, c.store.ConnectorConfig)
	case internal.WiseConnector:
		err = views.DisplayWiseConfig(cmd, c.store.ConnectorConfig)
	case internal.MangoPayConnector:
		err = views.DisplayMangopayConfig(cmd, c.store.ConnectorConfig)
	case internal.MoneycorpConnector:
		err = views.DisplayMoneycorpConfig(cmd, c.store.ConnectorConfig)
	case internal.AtlarConnector:
		err = views.DisplayAtlarConfig(cmd, c.store.ConnectorConfig)
	case internal.AdyenConnector:
		err = views.DisplayAdyenConfig(cmd, c.store.ConnectorConfig)
	default:
		pterm.Error.WithWriter(cmd.OutOrStderr()).Printfln("Connection unknown.")
	}

	return err

}