Documentation
¶
Index ¶
- func CheckAMLCompliance(rpcUrl string, txHash string) (bool, error)
- func CreateLockPaymentOrder(ctx context.Context, network *ent.Network, event *types.OrderCreatedEvent, ...) error
- func GetProviderAddressFromLockOrder(ctx context.Context, lockOrder *ent.LockPaymentOrder) (string, error)
- func GetProviderAddresses(ctx context.Context, token *ent.Token, currencyCode string) ([]string, error)
- func GetProvisionBucket(ctx context.Context, amount decimal.Decimal, currency *ent.FiatCurrency) (*ent.ProvisionBucket, bool, error)
- func HandleCancellation(ctx context.Context, createdLockPaymentOrder *ent.LockPaymentOrder, ...) error
- func HandleReceiveAddressValidity(ctx context.Context, receiveAddress *ent.ReceiveAddress, ...) error
- func ProcessCreatedOrders(ctx context.Context, network *ent.Network, orderIds []string, ...) error
- func ProcessLinkedAddresses(ctx context.Context, orderService types.OrderService, ...) error
- func ProcessReceiveAddresses(ctx context.Context, orderService types.OrderService, ...) error
- func ProcessRefundedOrders(ctx context.Context, network *ent.Network, orderIds []string, ...) error
- func ProcessSettledOrders(ctx context.Context, network *ent.Network, orderIds []string, ...) error
- func ProcessTransfers(ctx context.Context, orderService types.OrderService, ...) error
- func UpdateOrderStatusRefunded(ctx context.Context, network *ent.Network, event *types.OrderRefundedEvent, ...) error
- func UpdateOrderStatusSettled(ctx context.Context, network *ent.Network, event *types.OrderSettledEvent, ...) error
- func UpdateReceiveAddressStatus(ctx context.Context, receiveAddress *ent.ReceiveAddress, ...) (done bool, err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CheckAMLCompliance ¶
CheckAMLCompliance checks if a transaction is compliant with AML regulations.
func CreateLockPaymentOrder ¶
func CreateLockPaymentOrder( ctx context.Context, network *ent.Network, event *types.OrderCreatedEvent, refundOrder func(context.Context, *ent.Network, string) error, assignLockPaymentOrder func(context.Context, types.LockPaymentOrderFields) error, ) error
CreateLockPaymentOrder saves a lock payment order in the database
func GetProviderAddressFromLockOrder ¶ added in v0.0.2
func GetProviderAddressFromLockOrder(ctx context.Context, lockOrder *ent.LockPaymentOrder) (string, error)
GetProviderAddressFromLockOrder gets the provider address for a lock payment order
func GetProviderAddresses ¶ added in v0.0.2
func GetProviderAddresses(ctx context.Context, token *ent.Token, currencyCode string) ([]string, error)
GetProviderAddresses gets provider addresses for a given token, network, and currency
func GetProvisionBucket ¶
func GetProvisionBucket(ctx context.Context, amount decimal.Decimal, currency *ent.FiatCurrency) (*ent.ProvisionBucket, bool, error)
GetProvisionBucket gets a provision bucket for the given amount and currency.
func HandleCancellation ¶
func HandleCancellation(ctx context.Context, createdLockPaymentOrder *ent.LockPaymentOrder, lockPaymentOrder *types.LockPaymentOrderFields, cancellationReason string, refundOrder func(context.Context, *ent.Network, string) error) error
HandleCancellation handles the cancellation of a lock payment order.
func HandleReceiveAddressValidity ¶
func HandleReceiveAddressValidity(ctx context.Context, receiveAddress *ent.ReceiveAddress, paymentOrder *ent.PaymentOrder) error
HandleReceiveAddressValidity handles the validity of a receive address.
func ProcessCreatedOrders ¶
func ProcessCreatedOrders( ctx context.Context, network *ent.Network, orderIds []string, orderIdToEvent map[string]*types.OrderCreatedEvent, orderService types.OrderService, priorityQueueService *services.PriorityQueueService, ) error
ProcessCreatedOrders processes created orders for a network
func ProcessLinkedAddresses ¶
func ProcessLinkedAddresses(ctx context.Context, orderService types.OrderService, unknownAddresses []string, addressToEvent map[string]*types.TokenTransferEvent, token *ent.Token) error
ProcessLinkedAddresses processes transfers to linked addresses and creates payment orders
func ProcessReceiveAddresses ¶
func ProcessReceiveAddresses( ctx context.Context, orderService types.OrderService, priorityQueueService *services.PriorityQueueService, unknownAddresses []string, addressToEvent map[string]*types.TokenTransferEvent, ) error
ProcessReceiveAddresses processes transfers to receive addresses and updates their status
func ProcessRefundedOrders ¶
func ProcessRefundedOrders(ctx context.Context, network *ent.Network, orderIds []string, orderIdToEvent map[string]*types.OrderRefundedEvent) error
ProcessRefundedOrders processes refunded orders for a network
func ProcessSettledOrders ¶
func ProcessSettledOrders(ctx context.Context, network *ent.Network, orderIds []string, orderIdToEvent map[string]*types.OrderSettledEvent) error
ProcessSettledOrders processes settled orders for a network
func ProcessTransfers ¶
func ProcessTransfers( ctx context.Context, orderService types.OrderService, priorityQueueService *services.PriorityQueueService, unknownAddresses []string, addressToEvent map[string]*types.TokenTransferEvent, token *ent.Token, ) error
ProcessTransfers processes transfers for a network
func UpdateOrderStatusRefunded ¶
func UpdateOrderStatusRefunded(ctx context.Context, network *ent.Network, event *types.OrderRefundedEvent, messageHash string) error
UpdateOrderStatusRefunded updates the status of a payment order to refunded
func UpdateOrderStatusSettled ¶
func UpdateOrderStatusSettled(ctx context.Context, network *ent.Network, event *types.OrderSettledEvent, messageHash string) error
UpdateOrderStatusSettled updates the status of a payment order to settled
func UpdateReceiveAddressStatus ¶
func UpdateReceiveAddressStatus( ctx context.Context, receiveAddress *ent.ReceiveAddress, paymentOrder *ent.PaymentOrder, event *types.TokenTransferEvent, createOrder func(ctx context.Context, orderID uuid.UUID) error, getProviderRate func(ctx context.Context, providerProfile *ent.ProviderProfile, tokenSymbol string, currency string) (decimal.Decimal, error), ) (done bool, err error)
UpdateReceiveAddressStatus updates the status of a receive address based on a transfer event.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.