Files
Paul NicolasandGitHub d66040c0eb feat(*): add plaid bank bridge connector and boilerplate (#499)
* feat(models): add bank bridge models

* feat(storage): add bank bridge migrations and functions

* feat(engine): add bank bridge workflows

* feat(connectors): add plaid bank bridge connector

* feat(events): add bank bridge events

* feat(api): add bank bridge router

* feat(*): bank bridge boilerplate

* fix nil pointer crash

* add more check when getting link attempts + change enum

* fix tests

* remove print

* fixes after reviews

* add specific table for access tokens

* fixes after reviews

* fix go mod tidy

* remove indexes + null default

* plaid: add tests

* *: add more tests

* fix after rebase
2025-07-30 13:44:31 +00:00

62 lines
1.1 KiB
Go

package services
import (
"fmt"
"github.com/formancehq/payments/internal/connectors/engine"
"github.com/formancehq/payments/internal/models"
errorsutils "github.com/formancehq/payments/internal/utils/errors"
"github.com/pkg/errors"
)
var (
ErrValidation = errors.New("validation error")
ErrNotFound = errors.New("not found")
)
type storageError struct {
err error
msg string
}
func (e *storageError) Error() string {
return fmt.Sprintf("%s: %s", e.msg, e.err)
}
func (e *storageError) Is(err error) bool {
_, ok := err.(*storageError)
return ok
}
func (e *storageError) Unwrap() error {
return e.err
}
func newStorageError(err error, msg string) error {
if err == nil {
return nil
}
return &storageError{
err: err,
msg: msg,
}
}
func handleEngineErrors(err error) error {
if err == nil {
return nil
}
switch {
case errors.Is(err, engine.ErrValidation), errors.Is(err, models.ErrValidation):
return errorsutils.NewWrappedError(
err,
ErrValidation,
)
case errors.Is(err, engine.ErrNotFound):
return fmt.Errorf("%w: %w", err, ErrNotFound)
default:
return err
}
}