paymentevents

Documentation

Index

• type Handler
  • func New(merchants *merchant.Service, processingService *processing.Service, ...) *Handler
  • func (h *Handler) Consumers() map[bus.Topic][]bus.Consumer
  • func (h *Handler) ProcessPaymentStatusUpdate(ctx context.Context, message bus.Message) error
  • func (h *Handler) ProcessWithdrawals(ctx context.Context, message bus.Message) error
  • func (h *Handler) SendSuccessfulPaymentNotification(ctx context.Context, message bus.Message) error
• type PaymentWebhook

Types

type Handler

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

func New

func New(
	merchants *merchant.Service,
	processingService *processing.Service,
	payments *payment.Service,
	slackWebhookURL string,
	logger *zerolog.Logger,
) *Handler

func (*Handler) Consumers

func (h *Handler) Consumers() map[bus.Topic][]bus.Consumer

func (*Handler) ProcessPaymentStatusUpdate

func (h *Handler) ProcessPaymentStatusUpdate(ctx context.Context, message bus.Message) error

func (*Handler) ProcessWithdrawals

func (h *Handler) ProcessWithdrawals(ctx context.Context, message bus.Message) error

func (*Handler) SendSuccessfulPaymentNotification

func (h *Handler) SendSuccessfulPaymentNotification(ctx context.Context, message bus.Message) error

type PaymentWebhook

type PaymentWebhook struct {
	ID     string `json:"id"`
	Status string `json:"status"`

	CustomerEmail string `json:"customerEmail"`

	SelectedBlockchain string `json:"selectedBlockchain"`
	SelectedCurrency   string `json:"selectedCurrency"`

	IsTest bool `json:"isTest"`

	LinkID *string `json:"paymentLinkId"`
}