webhook

May 21, 2025

Changes in this version

+ const DefaultTransferAction

+ var ErrInvalidHMACToken = errors.New("invalid authorization hmac token")

+ var MockConfig = config.WebhookConfig

+ type HMAC struct

+ func NewHMAC(keyID string, key []byte) *HMAC

+ func (h *HMAC) Append(header, value string)

+ func (h *HMAC) Authorization() (_ string, err error)

+ func (h *HMAC) Headers() string

+ func (h *HMAC) Key() string

+ func (h *HMAC) Nonce() string

+ func (h *HMAC) Signature() (_ string, err error)

+ type HMACToken struct

+ func ParseHMAC(token string) (tok *HMACToken, err error)

+ func (h *HMACToken) Collect(headers http.Header)

+ func (h *HMACToken) Headers() []string

+ func (h *HMACToken) KeyID() string

+ func (h *HMACToken) Verify(key []byte) (bool, error)

type Mock

+ func NewMock() *Mock

Jan 30, 2025

Changes in this version

type Payload

+ Sunrise *generic.Sunrise

Aug 9, 2024

Changes in this version

+ const Timeout

+ var ErrIdentityRequired = errors.New("identity payload is required in webhook response")

+ var ErrTransactionRequired = errors.New("pending or transaction payload is required in webhook response")

+ var MockURL *url.URL

+ type Handler interface

+ Callback func(context.Context, *Request) (*Reply, error)

+ func New(webhook *url.URL) Handler

+ type Mock struct

+ Callbacks int

+ OnCallback func(context.Context, *Request) (*Reply, error)

+ func (m *Mock) Callback(ctx context.Context, req *Request) (*Reply, error)

+ func (m *Mock) Reset()

+ func (m *Mock) UseError(err error)

+ func (m *Mock) UseFixture(path string) (err error)

+ func (m *Mock) UseReply(rep *Reply)

+ type Payload struct

+ Identity *ivms101.IdentityPayload

+ Pending *generic.Pending

+ ReceivedAt string

+ SentAt string

+ Transaction *generic.Transaction

+ func (p *Payload) IsZero() bool

+ func (p *Payload) Proto() (payload *trisa.Payload, err error)

+ type Reply struct

+ Error *trisa.Error

+ Payload *Payload

+ TransactionID uuid.UUID

+ TransferAction string

+ func MockErrorReply(_ context.Context, req *Request) (*Reply, error)

+ func MockPendingReply(_ context.Context, req *Request) (*Reply, error)

+ func (r *Reply) TransferState() trisa.TransferState

+ type Request struct

+ Counterparty *api.Counterparty

+ Error *trisa.Error

+ HMAC string

+ PKS string

+ Payload *Payload

+ Timestamp string

+ TransactionID uuid.UUID

+ TransferState string

+ func (r *Request) AddPayload(payload *trisa.Payload) (err error)

+ type Webhook struct

+ func (h *Webhook) Callback(ctx context.Context, out *Request) (in *Reply, err error)