listener

Documentation

Index

• type HTTP
• type PaymentListener
  • func NewPaymentListener(config *config.Config, database db.Database, horizon hc.ClientInterface, ...) (pl PaymentListener, err error)
  • func (pl *PaymentListener) ConvertToBridgePayment(op operations.Operation) (bridge.PaymentResponse, error)
  • func (pl *PaymentListener) Listen() (err error)
  • func (pl *PaymentListener) ReprocessPayment(payment bridge.PaymentResponse, force bool) error

Types

type HTTP

type HTTP interface {
	Do(req *http.Request) (resp *http.Response, err error)
}

HTTP represents an http client that a payment listener can use to make HTTP requests.

type PaymentListener

type PaymentListener struct {
	// contains filtered or unexported fields
}

PaymentListener is listening for a new payments received by ReceivingAccount

func NewPaymentListener

func NewPaymentListener(
	config *config.Config,
	database db.Database,
	horizon hc.ClientInterface,
	now func() time.Time,
) (pl PaymentListener, err error)

NewPaymentListener creates a new PaymentListener

func (*PaymentListener) ConvertToBridgePayment

func (pl *PaymentListener) ConvertToBridgePayment(op operations.Operation) (bridge.PaymentResponse, error)

ConvertToBridgePayment constructs a bridge.PaymentResponse struct from the operation received from horizon. This is done in order to have a standard response because the response from horizon can either be a payment, path_payment or account_merge operation; all of which have different fields.

func (*PaymentListener) Listen

func (pl *PaymentListener) Listen() (err error)

Listen starts listening for new payments

func (*PaymentListener) ReprocessPayment

func (pl *PaymentListener) ReprocessPayment(payment bridge.PaymentResponse, force bool) error