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 *proto.Order, rep grpc.BillingService, retBrok rabbitmq.BrokerInterface, ...) *Handler
  • func (h *Handler) GetNotifier() (Notifier, error)
  • func (h *Handler) HandleError(msg string, err error, t Table)
  • func (h *Handler) SendToUserCentrifugo(order *proto.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{
	constant.OrderStatusNew:                         "NEW",
	constant.OrderStatusPaymentSystemCreate:         "IN_PROGRESS",
	constant.OrderStatusPaymentSystemRejectOnCreate: "DECLINED",
	constant.OrderStatusPaymentSystemReject:         "DECLINED",
	constant.OrderStatusPaymentSystemComplete:       "COMPLETED",
	constant.OrderStatusProjectInProgress:           "COMPLETED",
	constant.OrderStatusProjectComplete:             "COMPLETED",
	constant.OrderStatusProjectPending:              "COMPLETED",
	constant.OrderStatusProjectReject:               "REFUNDED",
	constant.OrderStatusRefund:                      "REFUNDED",
	constant.OrderStatusChargeback:                  "CHARGEBACK_RESOLVED",
	constant.OrderStatusPaymentSystemDeclined:       "DECLINED",
	constant.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 *proto.Order,
	rep grpc.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 *proto.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      *billing.Order `json:"object"`
}

type Table

type Table map[string]interface{}

type XSolla

type XSolla Empty

func (*XSolla) Notify

func (n *XSolla) Notify() error