Files
fgueryandGitHub a63e3a20a8 feat(EN-214): create events via storage instead of manually calling event activity (#594)
* 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
2025-11-24 16:05:42 +00:00

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()
}