mongodb

package
v0.3.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 20, 2021 License: GPL-3.0 Imports: 12 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrItemNotFound = newError(-32002, "mgoError: Item not found")
	ErrItemIsDup    = newError(-32003, "mgoError: Item is duplicate")
	ErrSwapNotFound = newError(-32011, "mgoError: Swap is not found")
	ErrWrongKey     = newError(-32012, "mgoError: Wrong key")
)

mongodb special errors

Functions

func AddP2shAddress 

func AddP2shAddress(ma *MgoP2shAddress) error

AddP2shAddress add p2sh address

func AddRegisteredAddress 

func AddRegisteredAddress(address string) error

AddRegisteredAddress add register address

func AddSwapin 

func AddSwapin(ms *MgoSwap) error

AddSwapin add swapin

func AddSwapinResult 

func AddSwapinResult(mr *MgoSwapResult) error

AddSwapinResult add swapin result

func AddSwapout 

func AddSwapout(ms *MgoSwap) error

AddSwapout add swapout

func AddSwapoutResult 

func AddSwapoutResult(mr *MgoSwapResult) error

AddSwapoutResult add swapout result

func AddToBlacklist 

func AddToBlacklist(address, pairID string) error

AddToBlacklist add to blacklist

func FindP2shBindAddress 

func FindP2shBindAddress(p2shAddress string) (string, error)

FindP2shBindAddress find bind address through p2sh address

func GetCountOfSwapinResults 

func GetCountOfSwapinResults(pairID string) (int, error)

GetCountOfSwapinResults get count of swapin results

func GetCountOfSwapinResultsWithStatus 

func GetCountOfSwapinResultsWithStatus(pairID string, status SwapStatus) (int, error)

GetCountOfSwapinResultsWithStatus get count of swapin results with status

func GetCountOfSwapinsWithStatus 

func GetCountOfSwapinsWithStatus(pairID string, status SwapStatus) (int, error)

GetCountOfSwapinsWithStatus get count of swapins with status

func GetCountOfSwapoutResults 

func GetCountOfSwapoutResults(pairID string) (int, error)

GetCountOfSwapoutResults get count of swapout results

func GetCountOfSwapoutResultsWithStatus 

func GetCountOfSwapoutResultsWithStatus(pairID string, status SwapStatus) (int, error)

GetCountOfSwapoutResultsWithStatus get count of swapout results with status

func GetCountOfSwapoutsWithStatus 

func GetCountOfSwapoutsWithStatus(pairID string, status SwapStatus) (int, error)

GetCountOfSwapoutsWithStatus get count of swapout with status

func GetSwapKey added in v0.3.0 

func GetSwapKey(txid, pairID, bind string) string

GetSwapKey txid + pairID + bind

func HasSession 

func HasSession() bool

HasSession has session connected

func ManualManageSwap 

func ManualManageSwap(txid, pairID, bind, memo string, isSwapin, isPass bool) error

ManualManageSwap manual manage swap

func MongoServerInit 

func MongoServerInit(addrs []string, dbname, user, pass string)

MongoServerInit int mongodb server session

func PassSwapinBigValue 

func PassSwapinBigValue(txid, pairID, bind string) error

PassSwapinBigValue pass swapin big value

func PassSwapoutBigValue 

func PassSwapoutBigValue(txid, pairID, bind string) error

PassSwapoutBigValue pass swapout big value

func QueryBlacklist 

func QueryBlacklist(address, pairID string) (isBlacked bool, err error)

QueryBlacklist query if is blacked

func RemoveFromBlacklist 

func RemoveFromBlacklist(address, pairID string) error

RemoveFromBlacklist remove from blacklist

func Reswapin 

func Reswapin(txid, pairID, bind, forceOpt string) error

Reswapin reswapin

func Reswapout 

func Reswapout(txid, pairID, bind, forceOpt string) error

Reswapout reswapout

func ReverifySwapin 

func ReverifySwapin(txid, pairID, bind string) error

ReverifySwapin reverify swapin

func ReverifySwapout 

func ReverifySwapout(txid, pairID, bind string) error

ReverifySwapout reverify swapout

func UpdateLatestScanInfo 

func UpdateLatestScanInfo(isSrc bool, blockHeight uint64) error

UpdateLatestScanInfo update latest scan info

func UpdateSwapResultStatus 

func UpdateSwapResultStatus(isSwapin bool, txid, pairID, bind string, status SwapStatus, timestamp int64, memo string) error

UpdateSwapResultStatus update swap result status

func UpdateSwapStatus 

func UpdateSwapStatus(isSwapin bool, txid, pairID, bind string, status SwapStatus, timestamp int64, memo string) error

UpdateSwapStatus update swap status

func UpdateSwapinResult 

func UpdateSwapinResult(txid, pairID, bind string, items *SwapResultUpdateItems) error

UpdateSwapinResult update swapin result

func UpdateSwapinResultStatus 

func UpdateSwapinResultStatus(txid, pairID, bind string, status SwapStatus, timestamp int64, memo string) error

UpdateSwapinResultStatus update swapin result status

func UpdateSwapinStatus 

func UpdateSwapinStatus(txid, pairID, bind string, status SwapStatus, timestamp int64, memo string) error

UpdateSwapinStatus update swapin status

func UpdateSwapoutResult 

func UpdateSwapoutResult(txid, pairID, bind string, items *SwapResultUpdateItems) error

UpdateSwapoutResult update swapout result

func UpdateSwapoutResultStatus 

func UpdateSwapoutResultStatus(txid, pairID, bind string, status SwapStatus, timestamp int64, memo string) error

UpdateSwapoutResultStatus update swapout result status

func UpdateSwapoutStatus 

func UpdateSwapoutStatus(txid, pairID, bind string, status SwapStatus, timestamp int64, memo string) error

UpdateSwapoutStatus update swapout status

Types

type MgoBlackAccount 

type MgoBlackAccount struct {
	Key       string `bson:"_id"` // address + pairid
	Address   string `bson:"address"`
	PairID    string `bson:"pairid"`
	Timestamp int64  `bson:"timestamp"`
}

MgoBlackAccount key is address

type MgoLatestScanInfo 

type MgoLatestScanInfo struct {
	Key         string `bson:"_id"`
	BlockHeight uint64 `bson:"blockheight"`
	Timestamp   int64  `bson:"timestamp"`
}

MgoLatestScanInfo latest scan info

func FindLatestScanInfo 

func FindLatestScanInfo(isSrc bool) (*MgoLatestScanInfo, error)

FindLatestScanInfo find latest scan info

type MgoP2shAddress 

type MgoP2shAddress struct {
	Key         string `bson:"_id"`
	P2shAddress string `bson:"p2shaddress"`
}

MgoP2shAddress key is the bind address

func FindP2shAddress 

func FindP2shAddress(key string) (*MgoP2shAddress, error)

FindP2shAddress find p2sh addrss through bind address

func FindP2shAddresses 

func FindP2shAddresses(offset, limit int) ([]*MgoP2shAddress, error)

FindP2shAddresses find p2sh address

type MgoRegisteredAddress 

type MgoRegisteredAddress struct {
	Key       string `bson:"_id"`
	Timestamp int64  `bson:"timestamp"`
}

MgoRegisteredAddress key is address (in whitelist)

func FindRegisteredAddress 

func FindRegisteredAddress(key string) (*MgoRegisteredAddress, error)

FindRegisteredAddress find register address

type MgoSwap 

type MgoSwap struct {
	Key       string     `bson:"_id"` // txid + pairid + bind
	PairID    string     `bson:"pairid"`
	TxID      string     `bson:"txid"`
	TxTo      string     `bson:"txto"`
	TxType    uint32     `bson:"txtype"`
	Bind      string     `bson:"bind"`
	Status    SwapStatus `bson:"status"`
	Timestamp int64      `bson:"timestamp"`
	Memo      string     `bson:"memo"`
}

MgoSwap registered swap

func FindSwap 

func FindSwap(isSwapin bool, txid, pairID, bind string) (*MgoSwap, error)

FindSwap find swap

func FindSwapin 

func FindSwapin(txid, pairID, bind string) (*MgoSwap, error)

FindSwapin find swapin

func FindSwapinsWithPairIDAndStatus added in v0.3.0 

func FindSwapinsWithPairIDAndStatus(pairID string, status SwapStatus, septime int64) ([]*MgoSwap, error)

FindSwapinsWithPairIDAndStatus find swapin with pairID and status in the past septime

func FindSwapinsWithStatus 

func FindSwapinsWithStatus(status SwapStatus, septime int64) ([]*MgoSwap, error)

FindSwapinsWithStatus find swapin with status in the past septime

func FindSwapout 

func FindSwapout(txid, pairID, bind string) (*MgoSwap, error)

FindSwapout find swapout

func FindSwapoutsWithPairIDAndStatus added in v0.3.0 

func FindSwapoutsWithPairIDAndStatus(pairID string, status SwapStatus, septime int64) ([]*MgoSwap, error)

FindSwapoutsWithPairIDAndStatus find swapout with pairID and status in the past septime

func FindSwapoutsWithStatus 

func FindSwapoutsWithStatus(status SwapStatus, septime int64) ([]*MgoSwap, error)

FindSwapoutsWithStatus find swapout with status

type MgoSwapResult 

type MgoSwapResult struct {
	Key        string     `bson:"_id"` // txid + pairid + bind
	PairID     string     `bson:"pairid"`
	TxID       string     `bson:"txid"`
	TxTo       string     `bson:"txto"`
	TxHeight   uint64     `bson:"txheight"`
	TxTime     uint64     `bson:"txtime"`
	From       string     `bson:"from"`
	To         string     `bson:"to"`
	Bind       string     `bson:"bind"`
	Value      string     `bson:"value"`
	SwapTx     string     `bson:"swaptx"`
	OldSwapTxs []string   `bson:"oldswaptxs"`
	SwapHeight uint64     `bson:"swapheight"`
	SwapTime   uint64     `bson:"swaptime"`
	SwapValue  string     `bson:"swapvalue"`
	SwapType   uint32     `bson:"swaptype"`
	SwapNonce  uint64     `bson:"swapnonce"`
	Status     SwapStatus `bson:"status"`
	Timestamp  int64      `bson:"timestamp"`
	Memo       string     `bson:"memo"`
}

MgoSwapResult swap result (verified swap)

func FindSwapResult 

func FindSwapResult(isSwapin bool, txid, pairID, bind string) (*MgoSwapResult, error)

FindSwapResult find swap result

func FindSwapinResult 

func FindSwapinResult(txid, pairID, bind string) (*MgoSwapResult, error)

FindSwapinResult find swapin result

func FindSwapinResults 

func FindSwapinResults(address, pairID string, offset, limit int) ([]*MgoSwapResult, error)

FindSwapinResults find swapin history results

func FindSwapinResultsWithStatus 

func FindSwapinResultsWithStatus(status SwapStatus, septime int64) ([]*MgoSwapResult, error)

FindSwapinResultsWithStatus find swapin result with status

func FindSwapoutResult 

func FindSwapoutResult(txid, pairID, bind string) (*MgoSwapResult, error)

FindSwapoutResult find swapout result

func FindSwapoutResults 

func FindSwapoutResults(address, pairID string, offset, limit int) ([]*MgoSwapResult, error)

FindSwapoutResults find swapout history results

func FindSwapoutResultsWithStatus 

func FindSwapoutResultsWithStatus(status SwapStatus, septime int64) ([]*MgoSwapResult, error)

FindSwapoutResultsWithStatus find swapout result with status

type MgoSwapStatistics 

type MgoSwapStatistics struct {
	Key                string `bson:"_id"` // pairid
	PairID             string `bson:"pairid"`
	StableSwapinCount  int    `bson:"swapincount"`
	TotalSwapinValue   string `bson:"totalswapinvalue"`
	TotalSwapinFee     string `bson:"totalswapinfee"`
	StableSwapoutCount int    `bson:"swapoutcount"`
	TotalSwapoutValue  string `bson:"totalswapoutvalue"`
	TotalSwapoutFee    string `bson:"totalswapoutfee"`
}

MgoSwapStatistics swap statistics

func FindSwapStatistics 

func FindSwapStatistics(pairID string) (*MgoSwapStatistics, error)

FindSwapStatistics find swap statistics

type SwapResultUpdateItems 

type SwapResultUpdateItems struct {
	SwapTx     string
	OldSwapTxs []string
	SwapHeight uint64
	SwapTime   uint64
	SwapValue  string
	SwapType   uint32
	SwapNonce  uint64
	Status     SwapStatus
	Timestamp  int64
	Memo       string
}

SwapResultUpdateItems swap update items

type SwapStatistics 

type SwapStatistics struct {
	PairID              string
	TotalSwapinCount    int
	TotalSwapoutCount   int
	PendingSwapinCount  int
	PendingSwapoutCount int
	StableSwapinCount   int
	TotalSwapinValue    string
	TotalSwapinFee      string
	StableSwapoutCount  int
	TotalSwapoutValue   string
	TotalSwapoutFee     string
}

SwapStatistics rpc return struct

func GetSwapStatistics 

func GetSwapStatistics(pairID string) (*SwapStatistics, error)

GetSwapStatistics get swap statistics

type SwapStatus 

type SwapStatus uint16

SwapStatus swap status 

const (
	TxNotStable           SwapStatus = iota // 0
	TxVerifyFailed                          // 1
	TxWithWrongSender                       // 2
	TxWithWrongValue                        // 3
	TxIncompatible                          // 4
	TxNotSwapped                            // 5
	TxSwapFailed                            // 6
	TxProcessed                             // 7
	MatchTxEmpty                            // 8
	MatchTxNotStable                        // 9
	MatchTxStable                           // 10
	TxWithWrongMemo                         // 11
	TxWithBigValue                          // 12
	TxSenderNotRegistered                   // 13
	MatchTxFailed                           // 14
	SwapInBlacklist                         // 15
	ManualMakeFail                          // 16
	BindAddrIsContract                      // 17
	RPCQueryError                           // 18

	KeepStatus = 255
)

swap status values

func GetStatusByTokenVerifyError 

func GetStatusByTokenVerifyError(err error) SwapStatus

GetStatusByTokenVerifyError get status by token verify error

func (SwapStatus) CanManualMakeFail 

func (status SwapStatus) CanManualMakeFail() bool

CanManualMakeFail can manual make fail

func (SwapStatus) CanManualMakePass 

func (status SwapStatus) CanManualMakePass() bool

CanManualMakePass can manual make pass

func (SwapStatus) CanReswap 

func (status SwapStatus) CanReswap() bool

CanReswap can reswap

func (SwapStatus) CanRetry 

func (status SwapStatus) CanRetry() bool

CanRetry can retry

func (SwapStatus) CanReverify 

func (status SwapStatus) CanReverify() bool

CanReverify can reverify

func (SwapStatus) String 

func (status SwapStatus) String() string

nolint:gocyclo // allow big simple switch

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.