mirror of
https://github.com/hanzo-fi/payments.git
synced 2026-10-30 20:31:20 +00:00
Paul NicolasandGitHub
979b040d94
* chore(storage): remove errors.Wrap deprecated * feat: add psu models * feat(storage): add psu migrations and functions * feat(*): add payment service users entity * feat(tests): update sdks and add psu integration tests * feat(validation): add validation on email and phone number
256 lines
9.4 KiB
Go
256 lines
9.4 KiB
Go
package test_suite
|
|
|
|
import (
|
|
"fmt"
|
|
|
|
"github.com/formancehq/go-libs/v3/logging"
|
|
"github.com/formancehq/go-libs/v3/pointer"
|
|
"github.com/formancehq/go-libs/v3/testing/deferred"
|
|
"github.com/formancehq/payments/internal/events"
|
|
"github.com/formancehq/payments/internal/models"
|
|
"github.com/formancehq/payments/pkg/client/models/components"
|
|
evts "github.com/formancehq/payments/pkg/events"
|
|
"github.com/google/uuid"
|
|
"github.com/nats-io/nats.go"
|
|
|
|
. "github.com/formancehq/payments/pkg/testserver"
|
|
. "github.com/onsi/ginkgo/v2"
|
|
. "github.com/onsi/gomega"
|
|
)
|
|
|
|
var _ = Context("Payment API Payment Service Users", func() {
|
|
var (
|
|
db = UseTemplatedDatabase()
|
|
ctx = logging.TestingContext()
|
|
|
|
v3CreateRequest *components.V3CreatePaymentServiceUserRequest
|
|
|
|
baID1 uuid.UUID
|
|
baID2 uuid.UUID
|
|
|
|
app *deferred.Deferred[*Server]
|
|
)
|
|
|
|
app = NewTestServer(func() Configuration {
|
|
return Configuration{
|
|
Stack: stack,
|
|
NatsURL: natsServer.GetValue().ClientURL(),
|
|
PostgresConfiguration: db.GetValue().ConnectionOptions(),
|
|
TemporalNamespace: temporalServer.GetValue().DefaultNamespace(),
|
|
TemporalAddress: temporalServer.GetValue().Address(),
|
|
Output: GinkgoWriter,
|
|
}
|
|
})
|
|
|
|
v3CreateRequest = &components.V3CreatePaymentServiceUserRequest{
|
|
Name: "test",
|
|
ContactDetails: &components.V3ContactDetailsRequest{
|
|
Email: pointer.For("[email protected]"),
|
|
PhoneNumber: pointer.For("+33612131415"),
|
|
},
|
|
Address: &components.V3AddressRequest{
|
|
StreetNumber: pointer.For("1"),
|
|
StreetName: pointer.For("test"),
|
|
City: pointer.For("test"),
|
|
Region: pointer.For("test"),
|
|
PostalCode: pointer.For("test"),
|
|
Country: pointer.For("FR"),
|
|
},
|
|
BankAccountIDs: []string{},
|
|
Metadata: map[string]string{},
|
|
}
|
|
|
|
BeforeEach(func() {
|
|
createResponse, err := app.GetValue().SDK().Payments.V3.CreateBankAccount(ctx, &components.V3CreateBankAccountRequest{
|
|
Name: "foo",
|
|
AccountNumber: pointer.For("123456789"),
|
|
Iban: pointer.For("DE89370400440532013000"),
|
|
Country: pointer.For("DE"),
|
|
})
|
|
Expect(err).To(BeNil())
|
|
baID1, err = uuid.Parse(createResponse.GetV3CreateBankAccountResponse().Data)
|
|
Expect(err).To(BeNil())
|
|
|
|
createResponse, err = app.GetValue().SDK().Payments.V3.CreateBankAccount(ctx, &components.V3CreateBankAccountRequest{
|
|
Name: "bar",
|
|
AccountNumber: pointer.For("123456789"),
|
|
Iban: pointer.For("DE89370400440532013000"),
|
|
Country: pointer.For("DE"),
|
|
})
|
|
Expect(err).To(BeNil())
|
|
baID2, err = uuid.Parse(createResponse.GetV3CreateBankAccountResponse().Data)
|
|
Expect(err).To(BeNil())
|
|
|
|
// Only add the first bank account to the request, the second one will be added via the api
|
|
v3CreateRequest.BankAccountIDs = []string{baID1.String()}
|
|
_ = baID2
|
|
|
|
})
|
|
|
|
When("creating a payment service user", func() {
|
|
var (
|
|
psuID string
|
|
)
|
|
|
|
BeforeEach(func() {
|
|
createResponse, err := app.GetValue().SDK().Payments.V3.CreatePaymentServiceUser(ctx, v3CreateRequest)
|
|
Expect(err).To(BeNil())
|
|
psuID = createResponse.GetV3CreatePaymentServiceUserResponse().Data
|
|
})
|
|
|
|
It("should be ok", func() {
|
|
id, err := uuid.Parse(psuID)
|
|
Expect(err).To(BeNil())
|
|
|
|
getResponse, err := app.GetValue().SDK().Payments.V3.GetPaymentServiceUser(ctx, psuID)
|
|
Expect(err).To(BeNil())
|
|
Expect(getResponse.GetV3GetPaymentServiceUserResponse().Data.ID).To(Equal(id.String()))
|
|
})
|
|
})
|
|
|
|
When("adding a bank account to a payment service user", func() {
|
|
var (
|
|
psuID string
|
|
)
|
|
|
|
BeforeEach(func() {
|
|
createResponse, err := app.GetValue().SDK().Payments.V3.CreatePaymentServiceUser(ctx, v3CreateRequest)
|
|
Expect(err).To(BeNil())
|
|
psuID = createResponse.GetV3CreatePaymentServiceUserResponse().Data
|
|
})
|
|
|
|
It("should be ok", func() {
|
|
_, err := app.GetValue().SDK().Payments.V3.AddBankAccountToPaymentServiceUser(ctx, psuID, baID2.String())
|
|
Expect(err).To(BeNil())
|
|
|
|
getResponse, err := app.GetValue().SDK().Payments.V3.GetPaymentServiceUser(ctx, psuID)
|
|
Expect(err).To(BeNil())
|
|
Expect(getResponse.GetV3GetPaymentServiceUserResponse().Data.BankAccountIDs).To(ContainElement(baID2.String()))
|
|
})
|
|
|
|
It("should not do anything if the bank account is already added", func() {
|
|
_, err := app.GetValue().SDK().Payments.V3.AddBankAccountToPaymentServiceUser(ctx, psuID, baID2.String())
|
|
Expect(err).To(BeNil())
|
|
|
|
getResponse, err := app.GetValue().SDK().Payments.V3.GetPaymentServiceUser(ctx, psuID)
|
|
Expect(err).To(BeNil())
|
|
Expect(getResponse.GetV3GetPaymentServiceUserResponse().Data.BankAccountIDs).To(ContainElement(baID2.String()))
|
|
|
|
_, err = app.GetValue().SDK().Payments.V3.AddBankAccountToPaymentServiceUser(ctx, psuID, baID2.String())
|
|
Expect(err).To(BeNil())
|
|
|
|
getResponse, err = app.GetValue().SDK().Payments.V3.GetPaymentServiceUser(ctx, psuID)
|
|
Expect(err).To(BeNil())
|
|
Expect(getResponse.GetV3GetPaymentServiceUserResponse().Data.BankAccountIDs).To(ContainElement(baID2.String()))
|
|
})
|
|
|
|
It("should fail if bank account does not exists", func() {
|
|
_, err := app.GetValue().SDK().Payments.V3.AddBankAccountToPaymentServiceUser(ctx, psuID, uuid.New().String())
|
|
Expect(err).To(HaveOccurred())
|
|
Expect(err.Error()).To(ContainSubstring("failed to add bank account to payment service user: bank account: not found"))
|
|
})
|
|
|
|
It("should fail if payment service user does not exists", func() {
|
|
_, err := app.GetValue().SDK().Payments.V3.AddBankAccountToPaymentServiceUser(ctx, uuid.New().String(), baID2.String())
|
|
Expect(err).To(HaveOccurred())
|
|
Expect(err.Error()).To(ContainSubstring("failed to add bank account to payment service user: value not found"))
|
|
})
|
|
})
|
|
|
|
When("forwarding a psu bank account to a connector", func() {
|
|
var (
|
|
connectorID string
|
|
e chan *nats.Msg
|
|
psuID string
|
|
)
|
|
|
|
BeforeEach(func() {
|
|
e = Subscribe(GinkgoT(), app.GetValue())
|
|
|
|
createResponse, err := app.GetValue().SDK().Payments.V3.CreatePaymentServiceUser(ctx, v3CreateRequest)
|
|
Expect(err).To(BeNil())
|
|
psuID = createResponse.GetV3CreatePaymentServiceUserResponse().Data
|
|
|
|
connectorID, err = installConnector(ctx, app.GetValue(), uuid.New(), 3)
|
|
Expect(err).To(BeNil())
|
|
})
|
|
|
|
AfterEach(func() {
|
|
uninstallConnector(ctx, app.GetValue(), connectorID)
|
|
})
|
|
|
|
It("should fail when connector ID is invalid", func() {
|
|
_, err := app.GetValue().SDK().Payments.V3.ForwardPaymentServiceUserBankAccount(ctx, psuID, baID1.String(), &components.V3ForwardPaymentServiceUserBankAccountRequest{
|
|
ConnectorID: "invalid",
|
|
})
|
|
Expect(err).NotTo(BeNil())
|
|
Expect(err.Error()).To(ContainSubstring("400"))
|
|
})
|
|
|
|
It("should fail when bank account ID is invalid", func() {
|
|
_, err := app.GetValue().SDK().Payments.V3.ForwardPaymentServiceUserBankAccount(ctx, psuID, "invalid", &components.V3ForwardPaymentServiceUserBankAccountRequest{
|
|
ConnectorID: connectorID,
|
|
})
|
|
Expect(err).NotTo(BeNil())
|
|
Expect(err.Error()).To(ContainSubstring("400"))
|
|
})
|
|
|
|
It("should be ok when connector is installed", func() {
|
|
forwardResponse, err := app.GetValue().SDK().Payments.V3.ForwardPaymentServiceUserBankAccount(ctx, psuID, baID1.String(), &components.V3ForwardPaymentServiceUserBankAccountRequest{
|
|
ConnectorID: connectorID,
|
|
})
|
|
Expect(err).To(BeNil())
|
|
taskID, err := models.TaskIDFromString(forwardResponse.GetV3ForwardPaymentServiceUserBankAccountResponse().Data.TaskID)
|
|
Expect(err).To(BeNil())
|
|
Expect(taskID.Reference).To(ContainSubstring(baID1.String()))
|
|
cID := models.MustConnectorIDFromString(connectorID)
|
|
Expect(taskID.Reference).To(ContainSubstring(cID.Reference.String()))
|
|
|
|
connectorID, err := models.ConnectorIDFromString(connectorID)
|
|
Expect(err).To(BeNil())
|
|
|
|
getResponse, err := app.GetValue().SDK().Payments.V3.GetBankAccount(ctx, baID1.String())
|
|
Expect(err).To(BeNil())
|
|
|
|
Expect(getResponse.GetV3GetBankAccountResponse().Data.AccountNumber).ToNot(BeNil())
|
|
accountNumber := *getResponse.GetV3GetBankAccountResponse().Data.AccountNumber
|
|
Expect(getResponse.GetV3GetBankAccountResponse().Data.Iban).ToNot(BeNil())
|
|
iban := *getResponse.GetV3GetBankAccountResponse().Data.Iban
|
|
|
|
accountID := models.AccountID{
|
|
Reference: fmt.Sprintf("dummypay-%s", baID1.String()),
|
|
ConnectorID: connectorID,
|
|
}
|
|
|
|
Eventually(e).Should(Receive(Event(evts.EventTypeSavedBankAccount, WithPayload(
|
|
events.BankAccountMessagePayload{
|
|
ID: baID1.String(),
|
|
Country: "DE",
|
|
Name: getResponse.GetV3GetBankAccountResponse().Data.Name,
|
|
AccountNumber: fmt.Sprintf("%s****%s", accountNumber[0:2], accountNumber[len(accountNumber)-3:]),
|
|
IBAN: fmt.Sprintf("%s**************%s", iban[0:4], iban[len(iban)-4:]),
|
|
CreatedAt: getResponse.GetV3GetBankAccountResponse().Data.GetCreatedAt(),
|
|
Metadata: map[string]string{
|
|
"com.formance.spec/owner/addressLine1": "1 test",
|
|
"com.formance.spec/owner/city": "test",
|
|
"com.formance.spec/owner/email": "[email protected]",
|
|
"com.formance.spec/owner/phoneNumber": "+33612131415",
|
|
"com.formance.spec/owner/postalCode": "test",
|
|
"com.formance.spec/owner/region": "test",
|
|
"com.formance.spec/owner/streetName": "test",
|
|
"com.formance.spec/owner/streetNumber": "1",
|
|
},
|
|
RelatedAccounts: []events.BankAccountRelatedAccountsPayload{
|
|
{
|
|
AccountID: accountID.String(),
|
|
CreatedAt: getResponse.GetV3GetBankAccountResponse().Data.GetCreatedAt(),
|
|
ConnectorID: connectorID.String(),
|
|
Provider: "dummypay",
|
|
},
|
|
},
|
|
},
|
|
))))
|
|
})
|
|
})
|
|
})
|