dev

package
v0.0.0-...-04eb8a4 Latest Latest
Warning

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

 Go to latest Published: Oct 31, 2019 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Sep     = "dcrmparm"
	SepSave = "dcrmsepsave"
	SepSg   = "dcrmmsg"
	SepDel  = "dcrmsepdel"

	PaillierKeyLength = 2048

	//callback
	GetGroup               func(string) (int, string)
	SendToGroupAllNodes    func(string, string) string
	GetSelfEnode           func() string
	BroadcastInGroupOthers func(string, string)
	SendToPeer             func(string, string) error
	ParseNode              func(string) string
)
View Source 
var (
	//rpc-req //dcrm node
	RpcMaxWorker = 10000
	RpcMaxQueue  = 10000
	RpcReqQueue  chan RpcReq

	Enode_cnts int
	NodeCnt    = 3
	ThresHold  = 3
)

//////////////////////dcrm///////////////////////////////

View Source 
var (
	//err code 1
	ErrEncodeSendMsgFail          = `{Code:1,Error:"encode send msg fail."}`
	ErrParamError                 = `{Code:2,Error:"parameters error."}`
	ErrGetOtherNodesDataFail      = `{Code:3,Error:"NetWork Error,Get Data From Other Node Fail."}`
	ErrUnknownChType              = `{Code:4,Error:"unknown channel type."}`
	ErrGetChValueFail             = `{Code:5,Error:"get channel value fail."}`
	ErrNoGetLOAccout              = `{Code:6,Error:"There's no proper account to do lockout."}`
	ErrNoFindWorker               = `{Code:7,Error:"can not find worker."}`
	ErrOutsideTxFail              = `{Code:8,Error:"outside tx fail."}`
	ErrReqAddrTimeout             = `{Code:9,Error:"request dcrm address timeout."}`
	ErrGetWorkerIdError           = `{Code:10,Error:"get worker id error."}`
	ErrGetPrexDataError           = `{Code:11,Error:"get msg prefix data error."}`
	ErrValidateRealFusionAddrFail = `{Code:12,Error:"validate real fusion from fail."}`
	ErrValidateRealDcrmFromFail   = `{Code:13,Error:"validate real dcrm from fail."}`
	ErrSendTxToNetFail            = `{Code:14,Error:"send tx to outside net fail."}`
	ErrSendDataToGroupFail        = `{Code:15,Error:"send data to group fail."}`
	ErrInternalMsgFormatError     = `{Code:16,Error:"msg data format error."}`
	ErrGetNoResFromGroupMem       = `{Code:17,Error:"no get any result from other group node."}`
	ErrCoinTypeNotSupported       = `{Code:18,Error:"coin type is not supported."}`
	ErrTokenTypeError             = `{Code:19,Error:"token type error."}`
	ErrValidateLIFromAddrFail     = `{Code:20,Error:"lockin validate from address fail."}`
	ErrValidateLIValueFail        = `{Code:21,Error:"lockin validate value fail."}`
	ErrConfirmAddrFail            = `{Code:22,Error:"the dcrm address confirm validate fail."}`
	ErrGroupNotReady              = `{Code:23,Error:"the group is not ready.please try again."}`
	ErrGetGenPubkeyFail           = `{Code:24,Error:"get generate pubkey fail."}`
	ErrGetGenSaveDataFail         = `{Code:25,Error:"get generate save data fail."}`
	ErrCreateDbFail               = `{Code:26,Error:"create db fail."}`
	ErrGetRealEosUserFail         = `{Code:27,Error:"cannot get real eos account."}`
	ErrDcrmSigWrongSize           = `{Code:28,Error:"wrong size for dcrm sig."}`
	ErrDcrmSigFail                = `{Code:29,Error:"dcrm sign fail."}`
	ErrInvalidDcrmAddr            = `{Code:30,Error:"invalid dcrm address."}`
	ErrGetC1Timeout               = `{Code:31,Error:"get C1 timeout."}`
	ErrGetEnodeByUIdFail          = `{Code:32,Error:"can not find proper enodes by uid."}`
	ErrGetD1Timeout               = `{Code:33,Error:"get D1 timeout."}`
	ErrGetSHARE1Timeout           = `{Code:34,Error:"get SHARE1 timeout."}`
	ErrGetAllSHARE1Fail           = `{Code:35,Error:"get all SHARE1 msg fail."}`
	ErrGetAllD1Fail               = `{Code:36,Error:"get all D1 msg fail."}`
	ErrVerifySHARE1Fail           = `{Code:37,Error:"verify SHARE1 fail."}`
	ErrGetAllC1Fail               = `{Code:38,Error:"get all C1 msg fail."}`
	ErrKeyGenVerifyCommitFail     = `{Code:39,Error:"verify commit in keygenerate fail."}`
	ErrGetZKFACTPROOFTimeout      = `{Code:40,Error:""get ZKFACTPROOF timeout."}`
	ErrGetZKUPROOFTimeout         = `{Code:41,Error:""get ZKUPROOF timeout."}`
	ErrGetAllZKFACTPROOFFail      = `{Code:42,Error:"get all ZKFACTPROOF msg fail."}`
	ErrVerifyZKFACTPROOFFail      = `{Code:43,Error:"verify ZKFACTPROOF fail."}`
	ErrGetAllZKUPROOFFail         = `{Code:44,Error:"get all ZKUPROOF msg fail."}`
	ErrVerifyZKUPROOFFail         = `{Code:45,Error:"verify ZKUPROOF fail."}`
	ErrGetC11Timeout              = `{Code:46,Error:"get C11 timeout."}`
	ErrGetMTAZK1PROOFTimeout      = `{Code:47,Error:"get MTAZK1PROOF timeout."}`
	ErrGetKCTimeout               = `{Code:48,Error:"get KC timeout."}`
	ErrGetAllKCFail               = `{Code:49,Error:"get all KC msg fail."}`
	ErrGetAllMTAZK1PROOFFail      = `{Code:50,Error:"get all MTAZK1PROOF msg fail."}`
	ErrVerifyMTAZK1PROOFFail      = `{Code:51,Error:"verify MTAZK1PROOF fail.""}`
	ErrGetMKGTimeout              = `{Code:52,Error:"get MKG timeout."}`
	ErrGetAllMKGFail              = `{Code:53,Error:"get all MKG msg fail."}`
	ErrGetMKWTimeout              = `{Code:54,Error:"get MKW timeout."}`
	ErrGetAllMKWFail              = `{Code:55,Error:"get all MKW msg fail."}`
	ErrVerifyMKGFail              = `{Code:56,Error:"verify MKG fail.""}`
	ErrVerifyMKWFail              = `{Code:57,Error:"verify MKW fail.""}`
	ErrGetPaillierPrivKeyFail     = `{Code:58,Error:"get paillier privkey fail.""}`
	ErrGetDELTA1Timeout           = `{Code:59,Error:"get DELTA1 timeout."}`
	ErrGetAllDELTA1Fail           = `{Code:60,Error:"get all DELTA1 msg fail."}`
	ErrGetD11Timeout              = `{Code:61,Error:"get D11 timeout."}`
	ErrGetAllD11Fail              = `{Code:62,Error:"get all D11 msg fail."}`
	ErrGetAllC11Fail              = `{Code:63,Error:"get all C11 msg fail."}`
	ErrSignVerifyCommitFail       = `{Code:64,Error:"verify commit in dcrm sign fail."}`
	ErrREqualZero                 = `{Code:65,Error:"sign error: r equal zero."}`
	ErrGetS1Timeout               = `{Code:66,Error:"get S1 timeout."}`
	ErrGetAllS1Fail               = `{Code:67,Error:"get all S1 msg fail."}`
	ErrVerifySAllFail             = `{Code:68,Error:"verify SAll != m*G + r*PK in dcrm sign ec2."}`
	ErrGetSS1Timeout              = `{Code:69,Error:"get SS1 timeout."}`
	ErrGetAllSS1Fail              = `{Code:70,Error:"get all SS1 msg fail."}`
	ErrSEqualZero                 = `{Code:71,Error:"sign error: s equal zero."}`
	ErrDcrmSignVerifyFail         = `{Code:72,Error:"dcrm sign verify fail."}`
	ErrInvalidCoinbase            = `{Code:73,Error:"Invalid Coinbase."}`
	ErrStateDBError               = `{Code:74,Error:"StateDB Error."}`
	ErrEosAccountNameError        = `{Code:75,Error:"eos account name must be 12 character long, lowercase letters or 1-5."}`
	ErrReqEosPubkeyError          = `{Code:76,Error:"Request eos pubkey error."}`

	ErrAlreadyKnownLOTx         = `{Code:101,Error:"already known lockout transaction with same nonce."}`
	ErrOrderAlreadySend         = `{Code:102,Error:"the miner has send order already."}`
	ErrTxDataError              = `{Code:103,Error:"tx input data error."}`
	ErrInvalidDcrmPubkey        = `{Code:104,Error:"invalid dcrm pubkey."}`
	ErrDcrmAddrAlreadyConfirmed = `{Code:105,Error:"the account has confirmed dcrm address."}`
	ErrDcrmAddrNotConfirmed     = `{Code:106,Error:"the account has not confirmed dcrm address before."}`
	ErrDcrmAddrAlreadyLockIn    = `{Code:107,Error:"the dcrmaddr has lockin alread."}`
	ErrNotRealLockIn            = `{Code:108,Error:"it is not the real lockin,it is BTC change."}`
	ErrInsufficientDcrmFunds    = `{Code:109,Error:"Insufficient Dcrm Funds For Value + Fee."}`
	ErrInvalidAddrToLO          = `{Code:110,Error:"Lock Out To Invalid Address."}`
	ErrLOToSelf                 = `{Code:111,Error:"can not lockout to yourself."}`
	ErrInvalidTx                = `{Code:112,Error:"tx data invalid."}`
	ErrHashKeyMiss              = `{Code:113,Error:"hash key and real dcrm from is miss."}`

	//TODO
	ErrGetTradeUnitFail = `{Code:114,Error:"get trade unit fail."}`
	ErrCalcOrderBalance = `{Code:115,Error:"calc balance error."}`

	ErrFromNotFusionAccount    = `{Code:116,Error:"From Must Be Fusion Account In LockOut Tx."}`
	ErrReqAddrInsufficient     = `{Code:117,Error:"Insufficient for req addr,need least 5 fsn."}`
	ErrAddNewTradeInsufficient = `{Code:118,Error:"Insufficient for add new trade,need least 5 fsn."}`
)

dcrm erros

Functions

func Call 

func Call(msg interface{}, enode string)

func Compress 

func Compress(c []byte) (string, error)

//compress

func Dcrmcall 

func Dcrmcall(msg interface{}, enode string) <-chan string

func Dcrmcallret 

func Dcrmcallret(msg interface{}, enode string)

func Decode2 

func Decode2(s string) (interface{}, error)

func DefaultDataDir 

func DefaultDataDir() string

func DisMsg 

func DisMsg(msg string)

msg: hash-enode:C1:X1:X2

func DoubleHash 

func DoubleHash(id string, keytype string) *big.Int

func Encode2 

func Encode2(obj interface{}) (string, error)

func GetChannelValue 

func GetChannelValue(t int, obj interface{}) (string, error)

func GetDbDir 

func GetDbDir() string

func GetEnodesByUid 

func GetEnodesByUid(uid *big.Int, cointype string, groupid string) string

func GetEnodesInfo 

func GetEnodesInfo()

func GetGroupDir 

func GetGroupDir() string

func GetGroupIdByEnode 

func GetGroupIdByEnode(enode string) string

func GetIds 

func GetIds(cointype string, groupid string) sortableIDSSlice

func GetPaillierPk 

func GetPaillierPk(save string, index int) *lib.PublicKey

func GetPaillierPk(save string,index int) *paillier.PublicKey {

func GetPaillierSk 

func GetPaillierSk(save string, index int) *lib.PrivateKey

func GetPaillierSk(save string,index int) *paillier.PrivateKey {

func GetRandomInt 

func GetRandomInt(length int) *big.Int

func GetRandomIntFromZn 

func GetRandomIntFromZn(n *big.Int) *big.Int

func GetRetErr 

func GetRetErr(err string) error

func GetRetErrJsonStr 

func GetRetErrJsonStr(code int, err string) string

func GetSignString 

func GetSignString(r *big.Int, s *big.Int, v int32, i int) string

func GetZkFactProof 

func GetZkFactProof(save string, index int) *lib.ZkFactProof

func GetZkFactProof(save string,index int) *paillier.ZkFactProof {

func InitChan 

func InitChan()

workers,RpcMaxWorker,RpcReqWorker,RpcReqQueue,RpcMaxQueue,ReqDispatcher

func InitDev 

func InitDev(groupId string)

func IsCurNode 

func IsCurNode(enodes string, cur string) bool

func IsInGroup 

func IsInGroup(enode string, groupId string) bool

func KeyGenerate_ec2 

func KeyGenerate_ec2(msgprex string, ch chan interface{}, id int, cointype string) bool

ec2 msgprex = hash

func PutGroup 

func PutGroup(groupId string) bool

func ReadBits 

func ReadBits(bigint *big.Int, buf []byte)

ReadBits encodes the absolute value of bigint as big-endian bytes. Callers must ensure that buf has enough space. If buf is too short the result will be incomplete.

func RegP2pBroadcastInGroupOthersCallBack 

func RegP2pBroadcastInGroupOthersCallBack(f func(string, string))

func RegP2pGetGroupCallBack 

func RegP2pGetGroupCallBack(f func(string) (int, string))

func RegP2pGetSelfEnodeCallBack 

func RegP2pGetSelfEnodeCallBack(f func() string)

func RegP2pParseNodeCallBack 

func RegP2pParseNodeCallBack(f func(string) string)

func RegP2pSendMsgToPeerCallBack 

func RegP2pSendMsgToPeerCallBack(f func(string, string) error)

func RegP2pSendToGroupAllNodesCallBack 

func RegP2pSendToGroupAllNodesCallBack(f func(string, string) string)

func SendMsgToDcrmGroup 

func SendMsgToDcrmGroup(msg string, groupid string)

func SendMsgToPeer 

func SendMsgToPeer(enodes string, msg string)

func SendReqToGroup 

func SendReqToGroup(msg string, rpctype string) (string, error)

func SetUpMsgList 

func SetUpMsgList(msg string)

func Sign_ec2 

func Sign_ec2(msgprex string, save string, message string, cointype string, pkx *big.Int, pky *big.Int, ch chan interface{}, id int) string

msgprex = hash return value is the backup for the dcrm sig

func Tool_DecimalByteSlice2HexString 

func Tool_DecimalByteSlice2HexString(DecimalSlice []byte) string

func UnCompress 

func UnCompress(s string) (string, error)

//uncompress

func Verify 

func Verify(r *big.Int, s *big.Int, v int32, message string, pkx *big.Int, pky *big.Int) bool

func Verify2 

func Verify2(r *big.Int, s *big.Int, v int32, message string, pkx *big.Int, pky *big.Int) bool

Types

type DcrmHash 

type DcrmHash [32]byte

func Keccak256Hash 

func Keccak256Hash(data ...[]byte) (h DcrmHash)

Keccak256Hash calculates and returns the Keccak256 hash of the input data, converting it to an internal Hash data structure.

func (DcrmHash) Hex 

func (h DcrmHash) Hex() string

type ECDSASignature 

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

func (*ECDSASignature) GetR 

func (this *ECDSASignature) GetR() *big.Int

func (*ECDSASignature) GetRecoveryParam 

func (this *ECDSASignature) GetRecoveryParam() int32

func (*ECDSASignature) GetRoudFiveAborted 

func (this *ECDSASignature) GetRoudFiveAborted() bool

func (*ECDSASignature) GetS 

func (this *ECDSASignature) GetS() *big.Int

func (*ECDSASignature) New 

func (this *ECDSASignature) New()

func (*ECDSASignature) New2 

func (this *ECDSASignature) New2(r *big.Int, s *big.Int)

func (*ECDSASignature) New3 

func (this *ECDSASignature) New3(r *big.Int, s *big.Int, recoveryParam int32)

func (*ECDSASignature) SetR 

func (this *ECDSASignature) SetR(r *big.Int)

func (*ECDSASignature) SetRecoveryParam 

func (this *ECDSASignature) SetRecoveryParam(recoveryParam int32)

func (*ECDSASignature) SetRoudFiveAborted 

func (this *ECDSASignature) SetRoudFiveAborted(roudFiveAborted bool)

func (*ECDSASignature) SetS 

func (this *ECDSASignature) SetS(s *big.Int)

type Err 

type Err struct {
	Info string
}

error type 1

func (Err) Error 

func (e Err) Error() string

type ErrorRet 

type ErrorRet struct {
	Code  int
	Error string
}

type RecvMsg 

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

RecvMsg

func (*RecvMsg) Run 

func (self *RecvMsg) Run(workid int, ch chan interface{}) bool

type ReqAddrSendMsgToDcrm 

type ReqAddrSendMsgToDcrm struct {
	KeyType string
}

func (*ReqAddrSendMsgToDcrm) Run 

func (self *ReqAddrSendMsgToDcrm) Run(workid int, ch chan interface{}) bool

type ReqDispatcher 

type ReqDispatcher struct {
	// A pool of workers channels that are registered with the dispatcher
	WorkerPool chan chan RpcReq
}

rpc-req

func NewReqDispatcher 

func NewReqDispatcher(maxWorkers int) *ReqDispatcher

func (*ReqDispatcher) Run 

func (d *ReqDispatcher) Run()

type RpcDcrmRes 

type RpcDcrmRes struct {
	Ret string
	Err error
}

func GetGroupRes 

func GetGroupRes(wid int) RpcDcrmRes

type RpcReq 

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

type RpcReqWorker 

type RpcReqWorker struct {
	RpcReqWorkerPool chan chan RpcReq
	RpcReqChannel    chan RpcReq
	// contains filtered or unexported fields
}

func FindWorker 

func FindWorker(sid string) (*RpcReqWorker, error)

func NewRpcReqWorker 

func NewRpcReqWorker(workerPool chan chan RpcReq) *RpcReqWorker

func (*RpcReqWorker) Clear 

func (w *RpcReqWorker) Clear()

func (*RpcReqWorker) Start 

func (w *RpcReqWorker) Start()

func (*RpcReqWorker) Stop 

func (w *RpcReqWorker) Stop()

type SendMsg 

type SendMsg struct {
	MsgType string
	Nonce   string
	WorkId  int
	Msg     string
}

type SignSendMsgToDcrm 

type SignSendMsgToDcrm struct {
	PubKey  string
	KeyType string
	Message string
}

func (*SignSendMsgToDcrm) Run 

func (self *SignSendMsgToDcrm) Run(workid int, ch chan interface{}) bool

type WorkReq 

type WorkReq interface {
	Run(workid int, ch chan interface{}) bool
}

Source Files

View all Source files

Directories

Path Synopsis

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.