mongodb

package
v3.5.2 Latest Latest
Warning

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

 Go to latest Published: May 5, 2022 License: GPL-3.0 Imports: 17 Imported by: 0

Documentation

Overview

Package mongodb is a wrapper of mongo-go-driver that defines the collections and CRUD apis on them.

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")
	ErrForbidUpdateNonce  = newError(-32013, "mgoError: Forbid update swap nonce")
	ErrForbidUpdateSwapTx = newError(-32014, "mgoError: Forbid update swap tx")
)

mongodb special errors

View Source 
var (

	// MgoWaitGroup wait all mongodb related task done
	MgoWaitGroup = new(sync.WaitGroup)
)

Functions

func AddRouterSwap 

func AddRouterSwap(ms *MgoSwap) error

AddRouterSwap add router swap

func AddRouterSwapResult 

func AddRouterSwapResult(mr *MgoSwapResult) error

AddRouterSwapResult add router swap result

func AddUsedRValue added in v3.2.0 

func AddUsedRValue(pubkey, r string) error

AddUsedRValue add used r, if error mean already exist

func AllocateRouterSwapNonce added in v3.4.0 

func AllocateRouterSwapNonce(args *tokens.BuildTxArgs, nonceptr *uint64, isRecycleNonce bool) (swapnonce uint64, err error)

AllocateRouterSwapNonce allocate swap nonce (for parallel signing)

func ConvertFromSwapInfo 

func ConvertFromSwapInfo(swapinfo *SwapInfo) (tokens.SwapInfo, error)

ConvertFromSwapInfo convert

func FindNextSwapNonce 

func FindNextSwapNonce(chainID, mpc string) (uint64, error)

FindNextSwapNonce find next swap nonce

func GetRouterSwapKey added in v3.4.0 

func GetRouterSwapKey(fromChainID, txid string, logindex int) string

GetRouterSwapKey get router swap key

func GetStatusInfo added in v3.4.0 

func GetStatusInfo(statuses string) (statusInfo map[string]interface{}, err error)

GetStatusInfo get status info

func HasClient added in v3.4.0 

func HasClient() bool

HasClient has client

func MongoServerInit 

func MongoServerInit(appName string, hosts []string, dbName, user, pass string)

MongoServerInit int mongodb server session

func PassRouterSwapVerify added in v3.4.0 

func PassRouterSwapVerify(fromChainID, txid string, logindex int, timestamp int64) error

PassRouterSwapVerify pass router swap verify

func RouterAdminPassBigValue 

func RouterAdminPassBigValue(fromChainID, txid string, logIndex int) error

RouterAdminPassBigValue pass big value

func RouterAdminReswap 

func RouterAdminReswap(fromChainID, txid string, logIndex int) error

RouterAdminReswap reswap

func UpdateRouterOldSwapTxs added in v3.4.0 

func UpdateRouterOldSwapTxs(fromChainID, txid string, logindex int, swapTx string) error

UpdateRouterOldSwapTxs update old swaptxs by appending `swapTx`

func UpdateRouterSwapInfoAndStatus added in v3.4.0 

func UpdateRouterSwapInfoAndStatus(fromChainID, txid string, logindex int, swapInfo *SwapInfo, status SwapStatus, timestamp int64, memo string) error

UpdateRouterSwapInfoAndStatus update router swap info and status

func UpdateRouterSwapResult 

func UpdateRouterSwapResult(fromChainID, txid string, logindex int, items *SwapResultUpdateItems) error

UpdateRouterSwapResult update router swap result

func UpdateRouterSwapResultStatus 

func UpdateRouterSwapResultStatus(fromChainID, txid string, logindex int, status SwapStatus, timestamp int64, memo string) error

UpdateRouterSwapResultStatus update router swap result status

func UpdateRouterSwapStatus 

func UpdateRouterSwapStatus(fromChainID, txid string, logindex int, status SwapStatus, timestamp int64, memo string) error

UpdateRouterSwapStatus update router swap status

Types

type AnyCallSwapInfo 

type AnyCallSwapInfo struct {
	CallFrom   string   `bson:"callFrom"   json:"callFrom"`
	CallTo     []string `bson:"callTo"     json:"callTo"`
	CallData   []string `bson:"callData"   json:"callData"`
	Callbacks  []string `bson:"callbacks"  json:"callbacks"`
	CallNonces []string `bson:"callNonces" json:"callNonces"`
}

AnyCallSwapInfo struct

type CurveAnyCallSwapInfo added in v3.5.0 

type CurveAnyCallSwapInfo struct {
	CallFrom string `json:"callFrom"`
	CallTo   string `json:"callTo"`
	CallData string `json:"callData"`
	Fallback string `json:"fallback"`
}

CurveAnyCallSwapInfo struct

type ERC20SwapInfo added in v3.4.0 

type ERC20SwapInfo struct {
	Token         string   `bson:"token"                   json:"token"`
	TokenID       string   `bson:"tokenID"                 json:"tokenID"`
	ForNative     bool     `bson:"forNative,omitempty"     json:"forNative,omitempty"`
	ForUnderlying bool     `bson:"forUnderlying,omitempty" json:"forUnderlying,omitempty"`
	Path          []string `bson:"path,omitempty"          json:"path,omitempty"`
	AmountOutMin  string   `bson:"amountOutMin,omitempty"  json:"amountOutMin,omitempty"`
	CallProxy     string   `bson:"callProxy,omitempty"     json:"callProxy,omitempty"`
	CallData      string   `bson:"callData,omitempty"     json:"callData,omitempty"`
}

ERC20SwapInfo struct

type MgoSwap 

type MgoSwap struct {
	Key         string `bson:"_id"` // fromChainID + txid + logindex
	SwapType    uint32 `bson:"swaptype"`
	TxID        string `bson:"txid"`
	TxTo        string `bson:"txto"`
	From        string `bson:"from"`
	Bind        string `bson:"bind"`
	Value       string `bson:"value"`
	LogIndex    int    `bson:"logIndex"`
	FromChainID string `bson:"fromChainID"`
	ToChainID   string `bson:"toChainID"`
	SwapInfo    `bson:"swapinfo"`
	Status      SwapStatus `bson:"status"`
	InitTime    int64      `bson:"inittime"`
	Timestamp   int64      `bson:"timestamp"`
	Memo        string     `bson:"memo"`
}

MgoSwap registered swap

func FindRouterSwap 

func FindRouterSwap(fromChainID, txid string, logindex int) (*MgoSwap, error)

FindRouterSwap find router swap

func FindRouterSwapAuto added in v3.4.0 

func FindRouterSwapAuto(fromChainID, txid string, logindex int) (*MgoSwap, error)

FindRouterSwapAuto find router swap

func FindRouterSwapsWithChainIDAndStatus 

func FindRouterSwapsWithChainIDAndStatus(fromChainID string, status SwapStatus, septime int64) ([]*MgoSwap, error)

FindRouterSwapsWithChainIDAndStatus find router swap with chainid and status in the past septime

func FindRouterSwapsWithStatus 

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

FindRouterSwapsWithStatus find router swap with status

func GetRegisteredRouterSwap added in v3.4.0 

func GetRegisteredRouterSwap(fromChainID, txid string, logIndex int) (oldSwap *MgoSwap, registeredOk bool)

GetRegisteredRouterSwap get registered router swap

func (*MgoSwap) ToSwapResult added in v3.4.0 

func (swap *MgoSwap) ToSwapResult() *MgoSwapResult

ToSwapResult converts

type MgoSwapResult 

type MgoSwapResult struct {
	Key         string `bson:"_id"` // fromChainID + txid + logindex
	SwapType    uint32 `bson:"swaptype"`
	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"`
	LogIndex    int    `bson:"logIndex"`
	FromChainID string `bson:"fromChainID"`
	ToChainID   string `bson:"toChainID"`
	SwapInfo    `bson:"swapinfo"`
	SwapTx      string     `bson:"swaptx"`
	OldSwapTxs  []string   `bson:"oldswaptxs,omitempty" json:"oldswaptxs,omitempty"`
	SwapHeight  uint64     `bson:"swapheight"`
	SwapTime    uint64     `bson:"swaptime"`
	SwapValue   string     `bson:"swapvalue"`
	SwapNonce   uint64     `bson:"swapnonce"`
	Status      SwapStatus `bson:"status"`
	InitTime    int64      `bson:"inittime"`
	Timestamp   int64      `bson:"timestamp"`
	Memo        string     `bson:"memo"`
	MPC         string     `bson:"mpc"`
}

MgoSwapResult swap result (verified swap)

func FindRouterSwapResult 

func FindRouterSwapResult(fromChainID, txid string, logindex int) (*MgoSwapResult, error)

FindRouterSwapResult find router swap result

func FindRouterSwapResultAuto added in v3.4.0 

func FindRouterSwapResultAuto(fromChainID, txid string, logindex int) (*MgoSwapResult, error)

FindRouterSwapResultAuto find router swap result

func FindRouterSwapResults 

func FindRouterSwapResults(fromChainID, address string, offset, limit int, status string) ([]*MgoSwapResult, error)

FindRouterSwapResults find router swap results with chainid and address

func FindRouterSwapResultsToReplace 

func FindRouterSwapResultsToReplace(chainID string, septime int64) ([]*MgoSwapResult, error)

FindRouterSwapResultsToReplace find router swap result with status

func FindRouterSwapResultsToStable added in v3.5.1 

func FindRouterSwapResultsToStable(chainID string, septime int64) ([]*MgoSwapResult, error)

FindRouterSwapResultsToStable find swap results to stable

func FindRouterSwapResultsWithChainIDAndStatus 

func FindRouterSwapResultsWithChainIDAndStatus(fromChainID string, status SwapStatus, septime int64) ([]*MgoSwapResult, error)

FindRouterSwapResultsWithChainIDAndStatus find router swap result with chainid and status in the past septime

func FindRouterSwapResultsWithStatus 

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

FindRouterSwapResultsWithStatus find router swap result with status

type MgoUsedRValue added in v3.2.0 

type MgoUsedRValue struct {
	Key       string `bson:"_id"` // r + pubkey
	Timestamp int64  `bson:"timestamp"`
}

MgoUsedRValue security enhancement

type NFTSwapInfo added in v3.4.0 

type NFTSwapInfo struct {
	Token   string   `bson:"token"          json:"token"`
	TokenID string   `bson:"tokenID"        json:"tokenID"`
	IDs     []string `bson:"ids"            json:"ids"`
	Amounts []string `bson:"amounts"        json:"amounts"`
	Batch   bool     `bson:"batch"          json:"batch"`
	Data    string   `bson:"data,omitempty" json:"data,omitempty"`
}

NFTSwapInfo struct

type SwapInfo 

type SwapInfo struct {
	ERC20SwapInfo        *ERC20SwapInfo        `bson:"routerSwapInfo,omitempty"  json:"routerSwapInfo,omitempty"`
	NFTSwapInfo          *NFTSwapInfo          `bson:"nftSwapInfo,omitempty"     json:"nftSwapInfo,omitempty"`
	AnyCallSwapInfo      *AnyCallSwapInfo      `bson:"anycallSwapInfo,omitempty" json:"anycallSwapInfo,omitempty"`
	CurveAnyCallSwapInfo *CurveAnyCallSwapInfo `bson:"anycallSwapInfo2,omitempty" json:"anycallSwapInfo2,omitempty"`
}

SwapInfo struct

func ConvertToSwapInfo 

func ConvertToSwapInfo(info *tokens.SwapInfo) SwapInfo

ConvertToSwapInfo convert

func (*SwapInfo) GetToken added in v3.4.0 

func (s *SwapInfo) GetToken() string

GetToken get token

func (*SwapInfo) GetTokenID 

func (s *SwapInfo) GetTokenID() string

GetTokenID get tokenID

type SwapResultUpdateItems 

type SwapResultUpdateItems struct {
	MPC        string
	SwapTx     string
	SwapHeight uint64
	SwapTime   uint64
	SwapValue  string
	SwapNonce  uint64
	Status     SwapStatus
	Timestamp  int64
	Memo       string
}

SwapResultUpdateItems swap update items

type SwapStatus 

type SwapStatus uint16

SwapStatus swap status 

const (
	TxNotStable       SwapStatus = 0
	TxVerifyFailed    SwapStatus = 1
	TxWithWrongValue  SwapStatus = 3
	TxNotSwapped      SwapStatus = 5
	TxProcessed       SwapStatus = 7
	MatchTxEmpty      SwapStatus = 8
	MatchTxNotStable  SwapStatus = 9
	MatchTxStable     SwapStatus = 10
	TxWithBigValue    SwapStatus = 12
	MatchTxFailed     SwapStatus = 14
	SwapInBlacklist   SwapStatus = 15
	ManualMakeFail    SwapStatus = 16
	TxWithWrongPath   SwapStatus = 19
	MissTokenConfig   SwapStatus = 20
	NoUnderlyingToken SwapStatus = 21

	KeepStatus SwapStatus = 255
	Reswapping SwapStatus = 256
)

swap status values

func GetRouterSwapStatusByVerifyError 

func GetRouterSwapStatusByVerifyError(err error) SwapStatus

GetRouterSwapStatusByVerifyError get router swap status by verify error

func (SwapStatus) IsRegisteredOk 

func (status SwapStatus) IsRegisteredOk() bool

IsRegisteredOk is successfully registered

func (SwapStatus) IsResultStatus added in v3.4.0 

func (status SwapStatus) IsResultStatus() bool

IsResultStatus is swap result status

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.