mirror of
https://github.com/hanzo-fi/payments.git
synced 2026-10-30 20:31:20 +00:00
* feat(EN-214): add outbox table migration * feat(EN-214): add outbox models and storage layer * feat(EN-214): implement outbox publisher activity * feat(EN-214): implement outbox schedule activity * feat(EN-214): add outbox publisher workflow * feat(EN-214): migrate accounts to outbox pattern * feat(EN-214): migrate balances to outbox pattern * feat(EN-214): migrate payments to outbox pattern * feat(EN-214): migrate bank accounts to outbox pattern * feat(EN-214): migrate pools to outbox pattern * feat(EN-214): migrate payment initiations to outbox pattern * feat(EN-214): migrate PSU and connections to outbox pattern * feat(EN-214): migrate connectors to outbox pattern * feat(EN-214): remove legacy send_events workflow * feat(EN-214): update workflows to use outbox pattern * feat(EN-214): improve outbox idempotency and error handling * feat(EN-214): update storage tasks and tests * test(EN-214): update e2e tests for outbox pattern * test(EN-214): clean up workflow tests * chore(EN-214): update docker compose configuration * feat(EN-214): add e2e run config in ide * fix: add back docker-compose-dev run config * chore: improve connector uninstall comments & remove connector id being passed * fix: ensure events are not pushed if balances are not created * fix: ensure err is not overwritten when using rollback * fix: ensure we use v3 provider format * chore: apply the nitpick comments from coderabbit * chore: consistentely use e() error handling * feat: optionally disable publisher schedule to make e2e test more consistent * fix: improve error handling on uninstall connector * avoid using custom payload and rely on existing interfaces; also avoid using different types for events * fix: remove unecessary unmarshalling * fix: ensure that rollbackOnTxError picks up errors on tx.Commit() * fix: add extra validation on iban & account number in the test * test: cover marshall/unmarshalling of event payload * fix: increase test timeout * try to make test more resiliant * fix: wrong pointer use in loop * fix: error formatting issue * fix: move oubtox schedule creation out of an activity and do it in the worker itself * feat: OutboxEventDeleteAndSend as batch * change outbox_event to have id only instead of idempotency key * make e2e test less brittle, save eventID as idempotency key in publication * feat: make outbox_event keep an history * feat(EN-214): added a schedule to cleanup outbox events * test: make cleanup actually clean * ignore linting rules for now * feat: do not add psu metadata to event anymore as it's irrelevant * fix: create local variable instead of relying on pointers, even if not 100% necessary * fix: remove temporal schedule describe calls
62 lines
1.4 KiB
Go
62 lines
1.4 KiB
Go
package errors
|
|
|
|
import "fmt"
|
|
|
|
type wrappedError struct {
|
|
err error
|
|
}
|
|
|
|
// NewWrappedError creates a new error that wraps the cause error with the new error.
|
|
// It should be use when you want to have the end cause of an error and not all
|
|
// the stack trace, for example when you want to store the transfer/payout creation
|
|
// error.
|
|
func NewWrappedError(cause error, newError error) error {
|
|
return &wrappedError{
|
|
err: fmt.Errorf("%w: %w", cause, newError),
|
|
}
|
|
}
|
|
|
|
func (e *wrappedError) Error() string {
|
|
return e.err.Error()
|
|
}
|
|
|
|
// This method is needed for all errors to be recognized by the errors.Is function
|
|
func (e *wrappedError) Unwrap() []error {
|
|
return e.err.(interface{ Unwrap() []error }).Unwrap()
|
|
}
|
|
|
|
// Cause unwraps the error to the root cause
|
|
func Cause(err error) error {
|
|
for {
|
|
switch v := err.(type) {
|
|
case interface{ Unwrap() error }:
|
|
next := v.Unwrap()
|
|
if next == nil {
|
|
return err
|
|
}
|
|
err = next
|
|
case interface{ Unwrap() []error }:
|
|
nexts := v.Unwrap()
|
|
if len(nexts) == 0 {
|
|
return err
|
|
}
|
|
// we assume that the cause error is always the first one
|
|
err = nexts[0]
|
|
default:
|
|
return err
|
|
}
|
|
}
|
|
}
|
|
|
|
// RetryableError is a marker interface for errors that should be retried
|
|
type RetryableError interface {
|
|
error
|
|
Retryable()
|
|
}
|
|
|
|
// NonRetryableError is a marker interface for errors that should not be retried
|
|
type NonRetryableError interface {
|
|
error
|
|
NonRetryable()
|
|
}
|