123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369 |
- package bucash
- import (
- "encoding/json"
- //"errors"
- "fmt"
- "strconv"
- . "template"
- "time"
- simplejson "github.com/go-simplejson"
- tml "github.com/toml-master"
- )
- var (
- Config config
- CoinApi BuCashApi
- )
- type Bucash struct {
- walletstatus bool
- }
- const (
- NameCoin = "BCC"
- )
- func (m Bucash) InitDriver(parm interface{}) bool {
- if m.initconfig() == false {
- return false
- }
- go m.getwalletinfo()
- return true
- }
- //get the server's total available balance
- func (m Bucash) 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))
- }
- UnconfirmedBalance, err := CoinApi.WalleGetUnconfirmedBalance("")
- if err != nil {
- LOG("ERROR", " 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", "lite 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 Bucash) 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)
- for _, listtransaction := range litelisttransactionsinfo {
- // get all transactions from block startHright to endHeight
- 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"] = "BCC"
- 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
- }
- //Sent an amount from an account to a lite address.
- func (m Bucash) 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)
- transactionid, err := CoinApi.WalleSendFrom("", destination, 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))
- }
- 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))
- }
- //create a new address&key for receiving payments
- func (m Bucash) 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 Bucash) 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)
- }
- }
- //config rpc from lite.toml
- func (m Bucash) initconfig() bool {
- if _, err := tml.DecodeFile("./src/bucash/bucash.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
- CoinApi.InitRpcConf(User, Password, Host, Port)
- initLiteErr()
- f, err := strconv.ParseFloat(Config.Limit.Fee, 64)
- if err != nil {
- LOG("ERROR", "inner json error:%v", err.Error())
- return false
- }
- fee := float64(f)
- CoinApi.WalletSetTxFee(fee)
- return true
- }
- func (m Bucash) 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 (m Bucash) 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"] = "BCC"
- 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 Bucash) SendRawTransaction(parm interface{}) ([]byte, error) {
- pjs := parm.(*simplejson.Json)
- transdata := pjs.Get("data").MustString()
- if len(transdata) == 0 {
- return nil, fmt.Errorf(`{"cointype":"BCC","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":"BCC","errcode":%v,"msg":"%s"}`, SEND_RAW_TRANSACTION_ERR, getErrMsg(SEND_RAW_TRANSACTION_ERR, nil))
- }
- var jbuf []byte
- resp := make(map[string]interface{})
- resp["cointype"] = "BCC"
- 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":"BCC","errcode":%v,"msg":"%s"}`, INNER_ERR, getErrMsg(INNER_ERR, nil))
- }
- return jbuf, nil
- }
- func (m Bucash) SumcoinBalance(parm interface{}) ([]byte, error) {
- return nil, nil
- }
- func init() {
- Register(NameCoin, &Bucash{})
- }
|