Skip to content

Commit c831a25

Browse files
fgueryfguery
committed
chore: move test to a more appropriate file
1 parent c9d91ad commit c831a25

File tree

2 files changed

+112
-113
lines changed

2 files changed

+112
-113
lines changed

‎internal/connectors/engine/workflow/fetch_payments_test.go‎

Lines changed: 0 additions & 113 deletions
Original file line numberDiff line numberDiff line change
@@ -529,116 +529,3 @@ func (s *UnitTestSuite) Test_FetchNextPayments_StorageInstancesUpdate_Error() {
529529
s.Error(err)
530530
s.ErrorContains(err, expectedErr.Error())
531531
}
532-
533-
func (s *UnitTestSuite) Test_StoreWebhookTranslation_Empty_Success() {
534-
s.env.ExecuteWorkflow(RunStoreWebhookTranslation, StoreWebhookTranslation{
535-
ConnectorID: s.connectorID,
536-
})
537-
538-
s.True(s.env.IsWorkflowCompleted())
539-
err := s.env.GetWorkflowError()
540-
s.NoError(err)
541-
}
542-
543-
// TODO these test should probably not lie in "fetch_payment_test" file...
544-
func (s *UnitTestSuite) Test_StoreWebhookTranslation_Account_Success() {
545-
s.env.OnActivity(activities.StorageAccountsStoreActivity, mock.Anything, mock.Anything).Once().Return(func(ctx context.Context, accounts []models.Account) error {
546-
s.Len(accounts, 1)
547-
s.Equal(s.accountID, accounts[0].ID)
548-
return nil
549-
})
550-
551-
s.env.ExecuteWorkflow(RunStoreWebhookTranslation, StoreWebhookTranslation{
552-
ConnectorID: s.connectorID,
553-
Account: &s.pspAccount,
554-
})
555-
556-
s.True(s.env.IsWorkflowCompleted())
557-
err := s.env.GetWorkflowError()
558-
s.NoError(err)
559-
}
560-
561-
func (s *UnitTestSuite) Test_StoreWebhookTranslation_Account_StorageAccountsStore_Error() {
562-
expectedErr := errors.New("error-test")
563-
s.env.OnActivity(activities.StorageAccountsStoreActivity, mock.Anything, mock.Anything).Once().Return(
564-
temporal.NewNonRetryableApplicationError("error-test", "STORAGE", expectedErr),
565-
)
566-
567-
s.env.ExecuteWorkflow(RunStoreWebhookTranslation, StoreWebhookTranslation{
568-
ConnectorID: s.connectorID,
569-
Account: &s.pspAccount,
570-
})
571-
572-
s.True(s.env.IsWorkflowCompleted())
573-
err := s.env.GetWorkflowError()
574-
s.Error(err)
575-
s.ErrorContains(err, expectedErr.Error())
576-
}
577-
578-
func (s *UnitTestSuite) Test_StoreWebhookTranslation_ExternalAccount_Success() {
579-
s.env.OnActivity(activities.StorageAccountsStoreActivity, mock.Anything, mock.Anything).Once().Return(func(ctx context.Context, accounts []models.Account) error {
580-
s.Len(accounts, 1)
581-
s.Equal(s.accountID, accounts[0].ID)
582-
return nil
583-
})
584-
585-
s.env.ExecuteWorkflow(RunStoreWebhookTranslation, StoreWebhookTranslation{
586-
ConnectorID: s.connectorID,
587-
ExternalAccount: &s.pspAccount,
588-
})
589-
590-
s.True(s.env.IsWorkflowCompleted())
591-
err := s.env.GetWorkflowError()
592-
s.NoError(err)
593-
}
594-
595-
func (s *UnitTestSuite) Test_StoreWebhookTranslation_ExternalAccount_StorageAccountsStore_Error() {
596-
expectedErr := errors.New("error-test")
597-
s.env.OnActivity(activities.StorageAccountsStoreActivity, mock.Anything, mock.Anything).Once().Return(
598-
temporal.NewNonRetryableApplicationError("error-test", "STORAGE", expectedErr),
599-
)
600-
601-
s.env.ExecuteWorkflow(RunStoreWebhookTranslation, StoreWebhookTranslation{
602-
ConnectorID: s.connectorID,
603-
ExternalAccount: &s.pspAccount,
604-
})
605-
606-
s.True(s.env.IsWorkflowCompleted())
607-
err := s.env.GetWorkflowError()
608-
s.Error(err)
609-
s.ErrorContains(err, "error-test")
610-
}
611-
612-
func (s *UnitTestSuite) Test_StoreWebhookTranslation_Payment_Success() {
613-
s.env.OnActivity(activities.StoragePaymentsStoreActivity, mock.Anything, mock.Anything).Once().Return(func(ctx context.Context, payments []models.Payment) error {
614-
s.Len(payments, 1)
615-
s.Equal(s.paymentPayoutID, payments[0].ID)
616-
return nil
617-
})
618-
619-
s.env.ExecuteWorkflow(RunStoreWebhookTranslation, StoreWebhookTranslation{
620-
ConnectorID: s.connectorID,
621-
Payment: &s.pspPayment,
622-
})
623-
624-
s.True(s.env.IsWorkflowCompleted())
625-
err := s.env.GetWorkflowError()
626-
s.NoError(err)
627-
}
628-
629-
func (s *UnitTestSuite) Test_StoreWebhookTranslation_Payment_StoragePaymentsStore_Error() {
630-
expectedErr := errors.New("error-test")
631-
s.env.OnActivity(activities.StoragePaymentsStoreActivity, mock.Anything, mock.Anything).Once().Return(
632-
temporal.NewNonRetryableApplicationError("error-test", "STORAGE", expectedErr),
633-
)
634-
635-
s.env.ExecuteWorkflow(RunStoreWebhookTranslation, StoreWebhookTranslation{
636-
ConnectorID: s.connectorID,
637-
Payment: &s.pspPayment,
638-
})
639-
640-
s.True(s.env.IsWorkflowCompleted())
641-
err := s.env.GetWorkflowError()
642-
s.Error(err)
643-
s.ErrorContains(err, expectedErr.Error())
644-
}

‎internal/connectors/engine/workflow/handle_webhooks_test.go‎

Lines changed: 112 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1508,3 +1508,115 @@ func (s *UnitTestSuite) Test_HandleWebhooks_MultipleResponses_Success() {
15081508
err := s.env.GetWorkflowError()
15091509
s.NoError(err)
15101510
}
1511+
1512+
func (s *UnitTestSuite) Test_StoreWebhookTranslation_Empty_Success() {
1513+
s.env.ExecuteWorkflow(RunStoreWebhookTranslation, StoreWebhookTranslation{
1514+
ConnectorID: s.connectorID,
1515+
})
1516+
1517+
s.True(s.env.IsWorkflowCompleted())
1518+
err := s.env.GetWorkflowError()
1519+
s.NoError(err)
1520+
}
1521+
1522+
func (s *UnitTestSuite) Test_StoreWebhookTranslation_Account_Success() {
1523+
s.env.OnActivity(activities.StorageAccountsStoreActivity, mock.Anything, mock.Anything).Once().Return(func(ctx context.Context, accounts []models.Account) error {
1524+
s.Len(accounts, 1)
1525+
s.Equal(s.accountID, accounts[0].ID)
1526+
return nil
1527+
})
1528+
1529+
s.env.ExecuteWorkflow(RunStoreWebhookTranslation, StoreWebhookTranslation{
1530+
ConnectorID: s.connectorID,
1531+
Account: &s.pspAccount,
1532+
})
1533+
1534+
s.True(s.env.IsWorkflowCompleted())
1535+
err := s.env.GetWorkflowError()
1536+
s.NoError(err)
1537+
}
1538+
1539+
func (s *UnitTestSuite) Test_StoreWebhookTranslation_Account_StorageAccountsStore_Error() {
1540+
expectedErr := errors.New("error-test")
1541+
s.env.OnActivity(activities.StorageAccountsStoreActivity, mock.Anything, mock.Anything).Once().Return(
1542+
temporal.NewNonRetryableApplicationError("error-test", "STORAGE", expectedErr),
1543+
)
1544+
1545+
s.env.ExecuteWorkflow(RunStoreWebhookTranslation, StoreWebhookTranslation{
1546+
ConnectorID: s.connectorID,
1547+
Account: &s.pspAccount,
1548+
})
1549+
1550+
s.True(s.env.IsWorkflowCompleted())
1551+
err := s.env.GetWorkflowError()
1552+
s.Error(err)
1553+
s.ErrorContains(err, expectedErr.Error())
1554+
}
1555+
1556+
func (s *UnitTestSuite) Test_StoreWebhookTranslation_ExternalAccount_Success() {
1557+
s.env.OnActivity(activities.StorageAccountsStoreActivity, mock.Anything, mock.Anything).Once().Return(func(ctx context.Context, accounts []models.Account) error {
1558+
s.Len(accounts, 1)
1559+
s.Equal(s.accountID, accounts[0].ID)
1560+
return nil
1561+
})
1562+
1563+
s.env.ExecuteWorkflow(RunStoreWebhookTranslation, StoreWebhookTranslation{
1564+
ConnectorID: s.connectorID,
1565+
ExternalAccount: &s.pspAccount,
1566+
})
1567+
1568+
s.True(s.env.IsWorkflowCompleted())
1569+
err := s.env.GetWorkflowError()
1570+
s.NoError(err)
1571+
}
1572+
1573+
func (s *UnitTestSuite) Test_StoreWebhookTranslation_ExternalAccount_StorageAccountsStore_Error() {
1574+
expectedErr := errors.New("error-test")
1575+
s.env.OnActivity(activities.StorageAccountsStoreActivity, mock.Anything, mock.Anything).Once().Return(
1576+
temporal.NewNonRetryableApplicationError("error-test", "STORAGE", expectedErr),
1577+
)
1578+
1579+
s.env.ExecuteWorkflow(RunStoreWebhookTranslation, StoreWebhookTranslation{
1580+
ConnectorID: s.connectorID,
1581+
ExternalAccount: &s.pspAccount,
1582+
})
1583+
1584+
s.True(s.env.IsWorkflowCompleted())
1585+
err := s.env.GetWorkflowError()
1586+
s.Error(err)
1587+
s.ErrorContains(err, "error-test")
1588+
}
1589+
1590+
func (s *UnitTestSuite) Test_StoreWebhookTranslation_Payment_Success() {
1591+
s.env.OnActivity(activities.StoragePaymentsStoreActivity, mock.Anything, mock.Anything).Once().Return(func(ctx context.Context, payments []models.Payment) error {
1592+
s.Len(payments, 1)
1593+
s.Equal(s.paymentPayoutID, payments[0].ID)
1594+
return nil
1595+
})
1596+
1597+
s.env.ExecuteWorkflow(RunStoreWebhookTranslation, StoreWebhookTranslation{
1598+
ConnectorID: s.connectorID,
1599+
Payment: &s.pspPayment,
1600+
})
1601+
1602+
s.True(s.env.IsWorkflowCompleted())
1603+
err := s.env.GetWorkflowError()
1604+
s.NoError(err)
1605+
}
1606+
1607+
func (s *UnitTestSuite) Test_StoreWebhookTranslation_Payment_StoragePaymentsStore_Error() {
1608+
expectedErr := errors.New("error-test")
1609+
s.env.OnActivity(activities.StoragePaymentsStoreActivity, mock.Anything, mock.Anything).Once().Return(
1610+
temporal.NewNonRetryableApplicationError("error-test", "STORAGE", expectedErr),
1611+
)
1612+
1613+
s.env.ExecuteWorkflow(RunStoreWebhookTranslation, StoreWebhookTranslation{
1614+
ConnectorID: s.connectorID,
1615+
Payment: &s.pspPayment,
1616+
})
1617+
1618+
s.True(s.env.IsWorkflowCompleted())
1619+
err := s.env.GetWorkflowError()
1620+
s.Error(err)
1621+
s.ErrorContains(err, expectedErr.Error())
1622+
}

0 commit comments

Comments
 (0)