123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300 |
- package zcash
- import (
- "encoding/json"
- //"errors"
- "fmt"
- "strconv"
- . "template"
- "time"
- simplejson "github.com/go-simplejson"
- tml "github.com/toml-master"
- )
- var (
- BucketZEC string = "ZEC"
- ZecConfig config
- zcashOp ZcashApi
- )
- type Zcash struct{}
- const (
- NameZcash = "ZEC"
- )
- func (m Zcash) InitDriver(parm interface{}) bool {
- if m.initconfig() == false {
- return false
- }
- go m.zcashgetinfo()
- return true
- }
- //get the server's total available balance
- func (m Zcash) CoinBalance(parm interface{}) ([]byte, error) {
- confirmedBalance, err := zcashOp.WalleGetBalance("")
- if err != nil {
- LOG("ERROR", "zcash GetBalance err:%v", err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, GETBALANCE_ERR, getErrMsg(GETBALANCE_ERR, nil))
- }
- UnconfirmedBalance, err := zcashOp.WalleGetUnconfirmedBalance("")
- if err != nil {
- LOG("ERROR", "zcash GetUnconfirmedBalance err:%s", err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, GETUNCONFIRMEDBALANCE_ERR, getErrMsg(GETUNCONFIRMEDBALANCE_ERR, nil))
- }
- var jbuf []byte
- resp := make(map[string]interface{})
- resp["confirmedbalance"] = confirmedBalance
- resp["unconfirmed"] = UnconfirmedBalance
- resp["errcode"] = 0
- resp["exact"] = 0
- if jbuf, err = json.Marshal(resp); err != nil {
- LOG("ERROR", "zcash inner json error:%v", err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, INNER_ERR, getErrMsg(INNER_ERR, nil))
- }
- return jbuf, nil
- }
- //Returns up to 'count' most recent transactions skipping the first 'from' transactions for account 'account'.
- func (m Zcash) TransInfo(parm interface{}) ([]byte, error) {
- pjs := parm.(*simplejson.Json)
- startH := pjs.Get("starth").MustUint64()
- endH := pjs.Get("endh").MustUint64()
- if startH < 1 {
- startH = 1
- }
- //get longest block count
- blockcount, err := zcashOp.WalleGetBlockCount()
- if err != nil {
- LOG("ERROR", "zcash WalleGetBlockCount err:%v", err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, GETCLOCKCOUNT_ERR, getErrMsg(GETCLOCKCOUNT_ERR, nil))
- }
- //first get block hash and time by height
- if startH > blockcount {
- LOG("DEBUG", "zcash startheight:%v > blockcount:%v", startH, blockcount)
- startH = blockcount
- }
- startheight := strconv.FormatUint(uint64(startH-1), 10)
- startblockhash, _, err := zcashOp.WalletGetBlockinfo(startheight)
- if err != nil {
- LOG("ERROR", "zcash GetBlockinfo startH:%v err:%v", startH, err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, GETBLOCKINFO_ERR, getErrMsg(GETBLOCKINFO_ERR, nil))
- }
- if endH > blockcount {
- LOG("DEBUG", "zcash endheight:%v > blockcount:%v", endH, blockcount)
- endH = blockcount
- }
- endheight := strconv.FormatUint(endH, 10)
- _, endblocktime, err := zcashOp.WalletGetBlockinfo(endheight)
- if err != nil {
- LOG("ERROR", "zcash GetBlockinfo 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 := zcashOp.WalleListSinceBlock(startblockhash)
- if err != nil {
- LOG("ERROR", "zcash WalleListSinceBlock err:%v", err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, TRANSINFO_ERR, getErrMsg(TRANSINFO_ERR, nil))
- }
- var zcashlisttransactionsinfo []Zcashlisttransactions
- if err = json.Unmarshal([]byte(resp), &zcashlisttransactionsinfo); err != nil {
- LOG("ERROR", "zcash 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)
- for _, zcashtransaction := range zcashlisttransactionsinfo {
- // get all transactions from block startHright to endHeight
- if zcashtransaction.Blocktime <= endblocktime {
- requestData := make(map[string]interface{})
- height, err := zcashOp.WalletGetBlockHeight(zcashtransaction.Blockhash)
- if err != nil {
- LOG("ERROR", "zcash WalletGetBlockHeight error:%v", err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, GETBLOCKINFO_ERR, getErrMsg(GETBLOCKINFO_ERR, nil))
- }
- requestData["confirmationheight"] = height
- requestData["address"] = zcashtransaction.Address
- requestData["confirmationtimestamp"] = zcashtransaction.Timereceived
- requestData["value"] = zcashtransaction.Amount
- requestData["transactionid"] = zcashtransaction.Txid
- requestData["confirmations"] = zcashtransaction.Confirmations
- requestData["walletaddress"] = true
- outputsArr = append(outputsArr, requestData)
- }
- }
- var jbuf []byte
- resptmp := make(map[string]interface{})
- resptmp["errcode"] = 0
- resptmp["cointype"] = "ZEC"
- resptmp["outputs"] = outputsArr
- if jbuf, err = json.Marshal(resptmp); err != nil {
- LOG("ERROR", "zcash inner json error:%v", err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, INNER_ERR, getErrMsg(INNER_ERR, nil))
- }
- return jbuf, nil
- }
- //Sent an amount from an account to a zcash address.
- func (m Zcash) 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", "zcash 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", "zcash inner json error:%v", err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, INNER_ERR, getErrMsg(INNER_ERR, nil))
- }
- amount := float64(f)
- transactionid, err := zcashOp.WalleSendFrom("", destination, amount, 1, "", "")
- if err != nil {
- LOG("ERROR", "zcash Send coin error:%v", err.Error())
- 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["transactionid"] = []string{transactionid}
- resp["errcode"] = 0
- resp["msg"] = "ok"
- if jbuf, err = json.Marshal(resp); err != nil {
- LOG("ERROR", "zcash 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", "zcash transactionid is null error:%v", err.Error())
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, INNER_ERR, getErrMsg(INNER_ERR, nil))
- }
- //create a new Zcash t-address&key for receiving payments
- func (m Zcash) CreateAddress(parm interface{}) ([]byte, error) {
- addr, err := zcashOp.WalletNewAddr()
- if err != nil {
- LOG("ERROR", "zcash get new t-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 := zcashOp.WalletDumpPrivKey(addr)
- if err != nil {
- LOG("ERROR", "zcash 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", "zcash 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", "zcash privkey is null error:%v")
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, INNER_ERR, getErrMsg(INNER_ERR, nil))
- }
- LOG("ERROR", "zcash address is null error:%v")
- return nil, fmt.Errorf(`{"errcode":%v,"mesage":"%s"}`, INNER_ERR, getErrMsg(INNER_ERR, nil))
- }
- func (m Zcash) zcashgetinfo() bool {
- fmt.Println("zcashgetinfo begin:")
- for {
- time.Sleep(time.Second)
- }
- }
- //config rpc from zcash.toml
- func (m Zcash) initconfig() bool {
- if _, err := tml.DecodeFile("./src/zcash/zcash.toml", &ZecConfig); err != nil {
- fmt.Println(err)
- return false
- }
- fmt.Printf("%+v\n", ZecConfig)
- zcashUser := ZecConfig.ZcashRpc.Zcashrpcuser
- zcashPassword := ZecConfig.ZcashRpc.Zcashrpcpassword
- zcashHost := ZecConfig.ZcashRpc.Zcashhost
- zcashPort := ZecConfig.ZcashRpc.Zcashport
- zcashOp.InitRpcConf(zcashUser, zcashPassword, zcashHost, zcashPort)
- initZcashErr()
- f, err := strconv.ParseFloat(ZecConfig.Limit.Fee, 64)
- if err != nil {
- LOG("ERROR", "zcash inner json error:%v", err.Error())
- return false
- }
- fee := float64(f)
- zcashOp.WalletSetTxFee(fee)
- return true
- }
- func (m Zcash) ChainHeight(parm interface{}) ([]byte, error) {
- blockcount, err := zcashOp.WalleGetBlockCount()
- if err != nil {
- LOG("ERROR", "zcash 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 (m Zcash) ListUnspent(parm interface{}) ([]byte, error) {
- return nil, nil
- }
- func (m Zcash) SendRawTransaction(parm interface{}) ([]byte, error) {
- return nil, nil
- }
- func (m Zcash) SumcoinBalance(parm interface{}) ([]byte, error) {
- return nil, nil
- }
- func init() {
- Register(NameZcash, &Zcash{})
- }
|