handler

Documentation

Index

• Constants
• Variables
• type CardPay
  • func (n *CardPay) Notify() error
• type Centrifugo
  • func (c *Centrifugo) Publish(ctx context.Context, channel string, msg interface{}) error
• type CentrifugoInterface
  • func NewCentrifugo(cfg *config.Centrifugo, httpClient *http.Client) CentrifugoInterface
• type Default
  • func (n *Default) Notify() error
• type Empty
  • func (n *Empty) Notify() error
• type Handler
  • func NewHandler(o *billingpb.Order, rep billingpb.BillingService, ...) *Handler
  • func (h *Handler) GetNotifier() (Notifier, error)
  • func (h *Handler) HandleError(msg string, err error, t Table)
  • func (h *Handler) SendToUserCentrifugo(order *billingpb.Order) error
• type NotificationStat
  • func (ns *NotificationStat) Get(key string) bool
• type Notifier
• type OrderNotificationMessage
• type Table
• type XSolla
  • func (n *XSolla) Notify() error

Constants

const (
	LoggerNotificationCentrifugo = "Send message to centrifugo failed"
	LoggerNotificationRedis      = "Set stat in redis failed"

	MIMEApplicationJSON = "application/json"

	HeaderAccept        = "Accept"
	HeaderContentType   = "Content-Type"
	HeaderSignature     = "Signature"
	HeaderAuthorization = "Authorization"

	NotificationActionCheck   = "check"
	NotificationActionPayment = "payment"

	RetryDlxTimeout   = 600
	RetryExchangeName = "notify-payment-retry"
	RetryMaxCount     = 288

	CountryCodeUSA = "US"
)

Variables

var OrderAlphabetStatuses = map[int32]string{
	recurringpb.OrderStatusNew:                         "NEW",
	recurringpb.OrderStatusPaymentSystemCreate:         "IN_PROGRESS",
	recurringpb.OrderStatusPaymentSystemRejectOnCreate: "DECLINED",
	recurringpb.OrderStatusPaymentSystemReject:         "DECLINED",
	recurringpb.OrderStatusPaymentSystemComplete:       "COMPLETED",
	recurringpb.OrderStatusProjectInProgress:           "COMPLETED",
	recurringpb.OrderStatusProjectComplete:             "COMPLETED",
	recurringpb.OrderStatusProjectPending:              "COMPLETED",
	recurringpb.OrderStatusProjectReject:               "REFUNDED",
	recurringpb.OrderStatusRefund:                      "REFUNDED",
	recurringpb.OrderStatusChargeback:                  "CHARGEBACK_RESOLVED",
	recurringpb.OrderStatusPaymentSystemDeclined:       "DECLINED",
	recurringpb.OrderStatusPaymentSystemCanceled:       "CANCELLED",
}

Types

type CardPay

type CardPay Empty

func (*CardPay) Notify

func (n *CardPay) Notify() error

type Centrifugo

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

func (*Centrifugo) Publish

func (c *Centrifugo) Publish(ctx context.Context, channel string, msg interface{}) error

type CentrifugoInterface

type CentrifugoInterface interface {
	Publish(context.Context, string, interface{}) error
}

func NewCentrifugo

func NewCentrifugo(cfg *config.Centrifugo, httpClient *http.Client) CentrifugoInterface

type Default

type Default Empty

func (*Default) Notify

func (n *Default) Notify() error

type Empty

type Empty struct {
	*Handler
}

func (*Empty) Notify

func (n *Empty) Notify() error

type Handler

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

func NewHandler

func NewHandler(
	o *billingpb.Order,
	rep billingpb.BillingService,
	retBrok rabbitmq.BrokerInterface,
	taxjarTransactionsBroker rabbitmq.BrokerInterface,
	taxjarRefundsBroker rabbitmq.BrokerInterface,
	redis *redis.Client,
	dlv amqp.Delivery,
	cfg *config.Config,
	centrifugoPaymentForm CentrifugoInterface,
	centrifugoDashboard CentrifugoInterface,
) *Handler

func (*Handler) GetNotifier

func (h *Handler) GetNotifier() (Notifier, error)

func (*Handler) HandleError

func (h *Handler) HandleError(msg string, err error, t Table)

func (*Handler) SendToUserCentrifugo

func (h *Handler) SendToUserCentrifugo(order *billingpb.Order) error

type NotificationStat

type NotificationStat struct {
	StatKey string
	// contains filtered or unexported fields
}

func (*NotificationStat) Get

func (ns *NotificationStat) Get(key string) bool

type Notifier

type Notifier interface {
	Notify() error
}

type OrderNotificationMessage

type OrderNotificationMessage struct {
	Id          string           `json:"id"`
	Type        string           `json:"type"`
	Event       string           `json:"event"`
	Live        bool             `json:"live"`
	CreatedAt   string           `json:"created_at"`
	ExpiresAt   string           `json:"expires_at"`
	DeliveryTry int32            `json:"delivery_try"`
	Object      *billingpb.Order `json:"object"`
}

type Table

type Table map[string]interface{}

type XSolla

type XSolla Empty

func (*XSolla) Notify

func (n *XSolla) Notify() error