123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460 |
- package dcrcash
- import (
- "encoding/json"
- "fmt"
- "strconv"
- . "template"
- "time"
- simplejson "github.com/go-simplejson"
- tml "github.com/toml-master"
- )
- var (
- Config config
- CoinApi DcrCashApi
- WalleTxfee float64
- )
- type DcrCash struct {
- walletstatus bool
- }
- const (
- NameCoin = "DCR"
- SendToError = "-32603"
- DefaultMaxsumamout = 20.0
- DEFAULTACCOUNT = "default"
- )
- func (m DcrCash) InitDriver(param interface{}) bool {
- if m.initconfig() == false {
- return false
- }
- go m.getwalletinfo()
- return true
- }
- func (m DcrCash) initconfig() bool {
- if _, err := tml.DecodeFile("./src/dcrcash/dcrcash.toml", &Config); err != nil {
- fmt.Println(err)
- return false
- }
- fmt.Printf("%+v\n", Config)
- User := Config.Rpc.Rpcuser
- Password := Config.Rpc.Rpcpassword
- Host := Config.Rpc.Rpchost
- Port := Config.Rpc.Rpcport
- //Walletpass = Config.WalletInfo.Pripassphrase
- CoinApi.InitRpcConf(User, Password, Host, Port)
- initDcrError()
- f, err := strconv.ParseFloat(Config.Limit.Fee, 64)
- if err != nil {
- LOG("ERROR", "init json error:%v", err.Error())
- return false
- }
- fee := float64(f)
- CoinApi.WalletSetTxFee(fee) //
- return true
- }
- func (m DcrCash) getwalletinfo() bool {
- fmt.Println("Walletinfo:")
- m.walletstatus = false
- for {
- if m.walletstatus == false {
- resp, err := CoinApi.WalletInfo()
- if err != nil {
- LOG("ERROR", "WalletInfo error:%v", err.Error())
- time.Sleep(time.Second * 1)
- continue
- }
- LOG("DEBUG", "walletInfo resp:%v", string(resp))
- m.walletstatus = true
- }
- time.Sleep(time.Second)
- }
- }
- func (m DcrCash) CoinBalance(parm interface{}) ([]byte, error) {
- confirmedBalance, err := CoinApi.WalleGetBalance("*")
- if err != nil {
- LOG("ERROR", " GetBalance err:%v", err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, GETBALANCE_ERR, getErrMsg(GETBALANCE_ERR, nil))
- }
- var balance []account
- if err = json.Unmarshal(confirmedBalance, &balance); err != nil {
- LOG("ERROR", " inner json error:%v", err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, INNER_ERR, getErrMsg(INNER_ERR, nil))
- }
- //var totalConfirbalance float64
- //var totalUnconfirbalance float64
- var maxConfirbalance float64
- var maxUnconfirbalance float64
- for _, vbalance := range balance {
- /*if vbalance.Spendable != 0 {
- totalConfirbalance += vbalance.Spendable
- }
- if vbalance.Unconfirmed != 0 {
- totalUnconfirbalance += vbalance.Unconfirmed
- }*/
- if vbalance.Spendable > maxConfirbalance {
- maxConfirbalance = vbalance.Spendable
- }
- if vbalance.Unconfirmed > maxUnconfirbalance {
- maxUnconfirbalance = vbalance.Unconfirmed
- }
- }
- var jbuf []byte
- resp := make(map[string]interface{})
- resp["confirmedbalance"] = maxConfirbalance
- resp["unconfirmed"] = maxUnconfirbalance
- resp["errcode"] = 0
- resp["exact"] = 0
- if jbuf, err = json.Marshal(resp); err != nil {
- LOG("ERROR", "lite inner json error:%v", err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, INNER_ERR, getErrMsg(INNER_ERR, nil))
- }
- return jbuf, nil
- }
- func (m DcrCash) CreateAddress(parm interface{}) ([]byte, error) {
- addr, err := CoinApi.WalletNewAddr()
- if err != nil {
- LOG("ERROR", " get new address error:%v", err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, GETNEWADDRESS_ERR, getErrMsg(GETNEWADDRESS_ERR, nil))
- }
- if len(addr) != 0 {
- //get key by the address
- key, err := CoinApi.WalletDumpPrivKey(addr)
- if err != nil {
- LOG("ERROR", " dump private key error:%v", err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, DUMPPRIVKEY_ERR, getErrMsg(DUMPPRIVKEY_ERR, nil))
- }
- if len(key) != 0 {
- var jbuf []byte
- resp := make(map[string]interface{})
- resp["address"] = addr
- resp["privkey"] = key
- resp["errcode"] = 0
- if jbuf, err = json.Marshal(resp); err != nil {
- LOG("ERROR", " inner json error:%v", err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, INNER_ERR, getErrMsg(INNER_ERR, nil))
- }
- return jbuf, nil
- }
- LOG("ERROR", " privkey is null error:%v")
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, INNER_ERR, getErrMsg(INNER_ERR, nil))
- }
- LOG("ERROR", " address is null error:%v")
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, INNER_ERR, getErrMsg(INNER_ERR, nil))
- }
- func (m DcrCash) SumcoinBalance(parm interface{}) ([]byte, error) {
- pjs := parm.(*simplejson.Json)
- //
- Sumamount := pjs.Get("sumamount").MustFloat64()
- Minsumamount := pjs.Get("minamount").MustFloat64()
- if Sumamount <= 0.0 {
- LOG("ERROR", " Summary amount is nil!")
- Sumamount = DefaultMaxsumamout
- }
- if Minsumamount < WalleTxfee {
- Minsumamount = WalleTxfee
- }
- //list Accounts and account of balance
- accountsofValues, err := CoinApi.ListAccounts()
- if err != nil {
- LOG("ERROR", "List accounts error:%v", err.Error())
- return nil, err
- }
- //var AccValues []AccountsOfvalue
- AccValues := map[string]float64{}
- if err = json.Unmarshal(accountsofValues, &AccValues); err != nil {
- LOG("ERROR", "Unmarshal error:%v", err.Error())
- return nil, err
- }
- var Totalbalance float64
- transactionsids := make([]string, 0)
- for account, value := range AccValues {
- if (value > Minsumamount) && account != DEFAULTACCOUNT {
- amount := value - WalleTxfee
- transactionid, err := CoinApi.WalletSendFrom(account, DEFAULTACCOUNT, amount, 1, "", "")
- if err != nil {
- LOG("ERROR", " Send coin error:%v", err.Error())
- //return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, SENDCOINS_ERR, getErrMsg(SENDCOINS_ERR, nil))
- continue
- }
- transactionsids = append(transactionsids, transactionid)
- Totalbalance += amount
- if Totalbalance >= Sumamount {
- break
- }
- }
- }
- if len(transactionsids) != 0 {
- var jbuf []byte
- resp := make(map[string]interface{})
- resp["transcationids"] = transactionsids
- resp["errcode"] = 0
- resp["msg"] = "ok"
- if jbuf, err = json.Marshal(resp); err != nil {
- LOG("ERROR", " inner json error:%v", err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, INNER_ERR, getErrMsg(INNER_ERR, nil))
- }
- return jbuf, nil
- }
- LOG("ERROR", " transactionids is null error:%v", err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, INNER_ERR, getErrMsg(INNER_ERR, nil))
- //fromaccout = "default"
- }
- func (m DcrCash) TransferAccounts(parm interface{}) ([]byte, error) {
- pjs := parm.(*simplejson.Json)
- amountTmp := pjs.Get("amount").MustString()
- destination := pjs.Get("address").MustString()
- if len(amountTmp) == 0 {
- LOG("ERROR", " amount illeagal")
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, AMOUNT_ERR, getErrMsg(AMOUNT_ERR, nil))
- }
- f, err := strconv.ParseFloat(amountTmp, 64)
- if err != nil {
- LOG("ERROR", " inner json error:%v", err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, INNER_ERR, getErrMsg(INNER_ERR, nil))
- }
- amount := float64(f)
- //list Accounts and account of balance
- accountsofValues, err := CoinApi.ListAccounts()
- if err != nil {
- LOG("ERROR", "List accounts error:%v", err.Error())
- return nil, err
- }
- AccValues := map[string]float64{}
- if err = json.Unmarshal(accountsofValues, &AccValues); err != nil {
- LOG("ERROR", "Unmarshal error:%v", err.Error())
- return nil, err
- }
- fromaccout := ""
- for account, value := range AccValues {
- if value >= (amount + WalleTxfee) {
- fromaccout = account
- break
- }
- }
- transactionid, err := CoinApi.WalletSendFrom(fromaccout, destination, amount, 1, "", "")
- if err != nil {
- LOG("ERROR", " Send coin error:%v", err.Error())
- fmt.Println(transactionid)
- if transactionid == SendToError {
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, INSUFFICIENT_FUNDS_TRANSACTION_ERR, getErrMsg(INSUFFICIENT_FUNDS_TRANSACTION_ERR, nil))
- }
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, SENDCOINS_ERR, getErrMsg(SENDCOINS_ERR, nil))
- }
- if len(transactionid) != 0 {
- var jbuf []byte
- resp := make(map[string]interface{})
- resp["transcationids"] = []string{transactionid}
- resp["errcode"] = 0
- resp["msg"] = "ok"
- if jbuf, err = json.Marshal(resp); err != nil {
- LOG("ERROR", " inner json error:%v", err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, INNER_ERR, getErrMsg(INNER_ERR, nil))
- }
- return jbuf, nil
- }
- LOG("ERROR", " transactionid is null error:%v", err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, INNER_ERR, getErrMsg(INNER_ERR, nil))
- }
- func (m DcrCash) TransInfo(parm interface{}) ([]byte, error) {
- pjs := parm.(*simplejson.Json)
- startH := pjs.Get("starth").MustUint64()
- endH := pjs.Get("endh").MustUint64()
- if startH < 1 {
- LOG("DEBUG", " input para err:%v", startH)
- startH = 1
- }
- //get longest block count
- blockcount, err := CoinApi.WalleGetBlockCount()
- if err != nil {
- LOG("ERROR", " WalleGetBlockCount err:%v", err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, GETCLOCKCOUNT_ERR, getErrMsg(GETCLOCKCOUNT_ERR, nil))
- }
- //get startblock hash by height
- if startH > blockcount {
- LOG("DEBUG", " startheight:%v > blockcount:%v", startH, blockcount)
- startH = blockcount
- }
- startblockhash, err := CoinApi.WalletGetBlockHash(uint64(startH - 1))
- if err != nil {
- LOG("ERROR", " WalletGetBlockHash startH:%v err:%v", startH, err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, GETBLOCKINFO_ERR, getErrMsg(GETBLOCKINFO_ERR, nil))
- }
- //get endblock time by height
- if endH > blockcount {
- LOG("DEBUG", " endheight:%v > blockcount:%v", endH, blockcount)
- endH = blockcount
- }
- endblockhash, err := CoinApi.WalletGetBlockHash(uint64(endH))
- if err != nil {
- LOG("ERROR", " WalletGetBlockHash startH:%v err:%v", startH, err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, GETBLOCKINFO_ERR, getErrMsg(GETBLOCKINFO_ERR, nil))
- }
- endblocktime, err := CoinApi.WalletGetBlockTime(endblockhash)
- if err != nil {
- LOG("ERROR", " WalletGetBlockTime endH:%v err:%v", endH, err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, GETBLOCKINFO_ERR, getErrMsg(GETBLOCKINFO_ERR, nil))
- }
- //Get all transactions in blocks since block [blockhash]
- resp, err := CoinApi.WalleListSinceBlock(startblockhash)
- if err != nil {
- LOG("ERROR", " WalleListSinceBlock err:%v", err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, TRANSINFO_ERR, getErrMsg(TRANSINFO_ERR, nil))
- }
- var litelisttransactionsinfo []Listtransactions
- if err = json.Unmarshal([]byte(resp), &litelisttransactionsinfo); err != nil {
- LOG("ERROR", " inner json error:%v", err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, INNER_ERR, getErrMsg(INNER_ERR, nil))
- }
- outputsArr := make([]map[string]interface{}, 0)
- fmt.Println("WalleListSinceBlock_num:", len(litelisttransactionsinfo))
- for index, listtransaction := range litelisttransactionsinfo {
- // get all transactions from block startHright to endHeight
- fmt.Println("BLockTime,Endblocktime", listtransaction.Blocktime, endblocktime, index)
- if listtransaction.Blocktime <= endblocktime {
- requestData := make(map[string]interface{})
- confirmationheight, err := CoinApi.WalletGetBlockHeight(listtransaction.Blockhash)
- if err != nil {
- LOG("ERROR", "WalletGetBlockHeight error:%v", err.Error())
- continue
- }
- requestData["confirmationheight"] = confirmationheight
- requestData["address"] = listtransaction.Address
- requestData["confirmationtimestamp"] = listtransaction.Timereceived
- requestData["value"] = listtransaction.Amount
- requestData["transactionid"] = listtransaction.Txid
- requestData["confirmations"] = listtransaction.Confirmations
- requestData["walletaddress"] = true
- requestData["vout"] = listtransaction.Vout
- outputsArr = append(outputsArr, requestData)
- }
- }
- var jbuf []byte
- resptmp := make(map[string]interface{})
- resptmp["errcode"] = 0
- resptmp["cointype"] = "DCR"
- resptmp["outputs"] = outputsArr
- if jbuf, err = json.Marshal(resptmp); err != nil {
- LOG("ERROR", " inner json error:%v", err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, INNER_ERR, getErrMsg(INNER_ERR, nil))
- }
- return jbuf, nil
- }
- func (m DcrCash) ListUnspent(parm interface{}) ([]byte, error) {
- pjs := parm.(*simplejson.Json)
- address, err := pjs.Get("address").StringArray()
- if err != nil {
- LOG("ERROR", " input parm error:%v", err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, LISTUNSPENT_ERR, getErrMsg(LISTUNSPENT_ERR, nil))
- }
- unspent, err := CoinApi.Listunspent(address)
- if err != nil {
- LOG("ERROR", " get listunspent:%v", err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, LISTUNSPENT_ERR, getErrMsg(LISTUNSPENT_ERR, nil))
- }
- var jbuf []byte
- resptmp := make(map[string]interface{})
- resptmp["errcode"] = 0
- resptmp["cointype"] = "DCR"
- resptmp["unspents"] = unspent
- if jbuf, err = json.Marshal(resptmp); err != nil {
- LOG("ERROR", " inner json error:%v", err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, INNER_ERR, getErrMsg(INNER_ERR, nil))
- }
- return jbuf, nil
- }
- func (m DcrCash) SendRawTransaction(parm interface{}) ([]byte, error) {
- pjs := parm.(*simplejson.Json)
- transdata := pjs.Get("data").MustString()
- if len(transdata) == 0 {
- return nil, fmt.Errorf(`{"cointype":"DCR","errcode":%v,"msg":"%v"}`, PARM_ERR, getErrMsg(PARM_ERR, []byte("hexstring is null")))
- }
- transactionhex, err := CoinApi.SendRawTransaction(transdata)
- if err != nil {
- LOG("ERROR", " SendRawTransaction err:%s", err.Error())
- return nil, fmt.Errorf(`{"cointype":"DCR","errcode":%v,"msg":"%s"}`, SEND_RAW_TRANSACTION_ERR, getErrMsg(SEND_RAW_TRANSACTION_ERR, nil))
- }
- var jbuf []byte
- resp := make(map[string]interface{})
- resp["cointype"] = "DCR"
- resp["transactionids"] = transactionhex
- resp["errcode"] = 0
- resp["msg"] = "OK"
- if jbuf, err = json.Marshal(resp); err != nil {
- LOG("ERROR", "inner json error:%v", err.Error())
- return nil, fmt.Errorf(`{"cointype":"DCR","errcode":%v,"msg":"%s"}`, INNER_ERR, getErrMsg(INNER_ERR, nil))
- }
- return jbuf, nil
- }
- func (m DcrCash) ChainHeight(parm interface{}) ([]byte, error) {
- blockcount, err := CoinApi.WalleGetBlockCount()
- if err != nil {
- LOG("ERROR", " get current block count error:%v", err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, GETCLOCKCOUNT_ERR, getErrMsg(GETCLOCKCOUNT_ERR, nil))
- }
- sendstr := fmt.Sprintf(`{"errcode":%v,"height":%v}`, OK, blockcount)
- return []byte(sendstr), nil
- }
- func init() {
- Register(NameCoin, &DcrCash{})
- }
|