core

Documentation

Index

• func AddXNode(node *models.Xnode) error
• func ConnectToXNode(node *models.Xnode) (pb.XNodeGrpcClient, error)
• type AdminPurchaseNotify
• type CallbackParameters
• type NextPayTerminal
  • func NewNextPayTerminal(apiKey, callbackUri string) NextPayTerminal
  • func (n NextPayTerminal) CreateRedirectUrl(transId string) string
  • func (n NextPayTerminal) CreateToken(amount, purchaseId int64) (string, error)
  • func (n NextPayTerminal) VerifyOrder(parameters CallbackParameters) (VerifyResponse, error)
• type Notification
• type NotificationType
• type PaymentTerminal
• type SubService
  • func NewSubService() *SubService
  • func (s *SubService) GenerateUserSub(token string) (string, error)
• type UserService
  • func NewUserService(terminal PaymentTerminal) *UserService
  • func (u *UserService) ConfirmPurchase(purchaseId string) error
  • func (u *UserService) CreateBankTransaction(user *models.Tuser, pck *models.Package) (string, error)
  • func (u *UserService) DisabledCallback() error
  • func (u *UserService) GetRandomBankCard() (string, error)
  • func (u *UserService) ListAvailablePackages() ([]*models.Package, error)
  • func (u *UserService) ProcessPurchaseOnReceipt(user *models.Tuser) (AdminPurchaseNotify, error)
  • func (u *UserService) Register(tid uint64, username string, packageName string) error
  • func (u *UserService) RejectPurchase(purchaseId string) error
  • func (u *UserService) SpawnRunners()
  • func (u *UserService) Status(uid uint64) (*models.Tuser, error)
  • func (u *UserService) SubscribeNotification(ch chan<- Notification)
  • func (u *UserService) TrafficUsageRunner()
  • func (u *UserService) Unregister(uid uint64) error
  • func (u *UserService) Upgrade(user *models.Tuser, pck *models.Package) error
  • func (u *UserService) VerifyBankTransaction(parameters CallbackParameters) (*models.Purchase, error)
• type VerifyResponse

Functions

func AddXNode

func AddXNode(node *models.Xnode) error

func ConnectToXNode

func ConnectToXNode(node *models.Xnode) (pb.XNodeGrpcClient, error)

Types

type AdminPurchaseNotify

type AdminPurchaseNotify struct {
	Tuser    *models.Tuser
	Purchase *models.Purchase
	Photo    *tele.Photo
}

AdminPurchaseNotify used to send notification to admins on new card2card event

type CallbackParameters

type CallbackParameters struct {
	TransactionId string
	OrderId       int64
	Amount        int64
}

type NextPayTerminal

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

func NewNextPayTerminal

func NewNextPayTerminal(apiKey, callbackUri string) NextPayTerminal

func (NextPayTerminal) CreateRedirectUrl

func (n NextPayTerminal) CreateRedirectUrl(transId string) string

func (NextPayTerminal) CreateToken

func (n NextPayTerminal) CreateToken(amount, purchaseId int64) (string, error)

func (NextPayTerminal) VerifyOrder

func (n NextPayTerminal) VerifyOrder(parameters CallbackParameters) (VerifyResponse, error)

type Notification

type Notification struct {
	Type  NotificationType
	User  *models.Tuser
	Extra interface{}
}

type NotificationType

type NotificationType int

const (
	PurchaseSuccessful NotificationType = iota
	PurchaseRejected
	PurchaseFailed

	UserMaxTrafficReached
)

type PaymentTerminal

type PaymentTerminal interface {
	CreateToken(int64, int64) (string, error)
	VerifyOrder(CallbackParameters) (VerifyResponse, error)
	CreateRedirectUrl(transId string) string
}

type SubService

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

func NewSubService

func NewSubService() *SubService

func (*SubService) GenerateUserSub

func (s *SubService) GenerateUserSub(token string) (string, error)

GenerateUserSub requests user's sub-content from xNodes and merge them together

type UserService

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

func NewUserService

func NewUserService(terminal PaymentTerminal) *UserService

func (*UserService) ConfirmPurchase

func (u *UserService) ConfirmPurchase(purchaseId string) error

func (*UserService) CreateBankTransaction

func (u *UserService) CreateBankTransaction(user *models.Tuser, pck *models.Package) (string, error)

CreateBankTransaction communicate with bank-terminal to get a new transaction and returns transaction id

func (*UserService) DisabledCallback

func (u *UserService) DisabledCallback() error

DisabledCallback is a callback-function to be called by XrayPanels when they have disabled a user due to traffic limit

func (*UserService) GetRandomBankCard

func (u *UserService) GetRandomBankCard() (string, error)

func (*UserService) ListAvailablePackages

func (u *UserService) ListAvailablePackages() ([]*models.Package, error)

func (*UserService) ProcessPurchaseOnReceipt

func (u *UserService) ProcessPurchaseOnReceipt(user *models.Tuser) (AdminPurchaseNotify, error)

ProcessPurchaseOnReceipt process a purchase when the user paid the price and sent a receipt to the admins

func (*UserService) Register

func (u *UserService) Register(tid uint64, username string, packageName string) error

Register a user on local repo and send a "AddClient" request to panels

func (*UserService) RejectPurchase

func (u *UserService) RejectPurchase(purchaseId string) error

func (*UserService) SpawnRunners

func (u *UserService) SpawnRunners()

func (*UserService) Status

func (u *UserService) Status(uid uint64) (*models.Tuser, error)

func (*UserService) SubscribeNotification

func (u *UserService) SubscribeNotification(ch chan<- Notification)

func (*UserService) TrafficUsageRunner

func (u *UserService) TrafficUsageRunner()

TrafficUsageRunner runs periodically to fetch the latest traffic-usage from xPanels

func (*UserService) Unregister

func (u *UserService) Unregister(uid uint64) error

func (*UserService) Upgrade

func (u *UserService) Upgrade(user *models.Tuser, pck *models.Package) error

Upgrade the user to a new package then send a command to all the available servers

func (*UserService) VerifyBankTransaction

func (u *UserService) VerifyBankTransaction(parameters CallbackParameters) (*models.Purchase, error)

type VerifyResponse

type VerifyResponse struct {
	Code        int64  `json:"code"`
	Amount      int64  `json:"amount"`
	OrderId     string `json:"order_id"`
	CardHolder  string `json:"card_holder"`
	ShaparakRef string `json:"Shaparak_Ref_Id"`
	Custom      interface{}
}