webhook

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)