/* * Copyright (c) 2013, 2014 Conformal Systems LLC * * Permission to use, copy, modify, and distribute this software for any * purpose with or without fee is hereby granted, provided that the above * copyright notice and this permission notice appear in all copies. * * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE. */ package txstore import ( "github.com/btcsuite/btcutil" "github.com/conformal/btcchain" "github.com/conformal/btcjson" "github.com/conformal/btcnet" "github.com/conformal/btcscript" ) // ToJSON returns a slice of btcjson listtransactions result types for all credits // and debits of this transaction. func (t *TxRecord) ToJSON(account string, chainHeight int32, net *btcnet.Params) ([]btcjson.ListTransactionsResult, error) { t.s.mtx.RLock() defer t.s.mtx.RUnlock() results := []btcjson.ListTransactionsResult{} if d, err := t.Debits(); err == nil { r, err := d.toJSON(account, chainHeight, net) if err != nil { return nil, err } results = r } for _, c := range t.Credits() { r, err := c.toJSON(account, chainHeight, net) if err != nil { return nil, err } results = append(results, r) } return results, nil } // ToJSON returns a slice of objects that may be marshaled as a JSON array // of JSON objects for a listtransactions RPC reply. func (d Debits) ToJSON(account string, chainHeight int32, net *btcnet.Params) ([]btcjson.ListTransactionsResult, error) { d.s.mtx.RLock() defer d.s.mtx.RUnlock() return d.toJSON(account, chainHeight, net) } func (d Debits) toJSON(account string, chainHeight int32, net *btcnet.Params) ([]btcjson.ListTransactionsResult, error) { msgTx := d.Tx().MsgTx() reply := make([]btcjson.ListTransactionsResult, 0, len(msgTx.TxOut)) for _, txOut := range msgTx.TxOut { address := "" _, addrs, _, _ := btcscript.ExtractPkScriptAddrs(txOut.PkScript, net) if len(addrs) == 1 { address = addrs[0].EncodeAddress() } result := btcjson.ListTransactionsResult{ Account: account, Address: address, Category: "send", Amount: btcutil.Amount(-txOut.Value).ToUnit(btcutil.AmountBTC), Fee: d.Fee().ToUnit(btcutil.AmountBTC), TxID: d.Tx().Sha().String(), Time: d.txRecord.received.Unix(), TimeReceived: d.txRecord.received.Unix(), WalletConflicts: []string{}, } if d.BlockHeight != -1 { b, err := d.s.lookupBlock(d.BlockHeight) if err != nil { return nil, err } result.BlockHash = b.Hash.String() result.BlockIndex = int64(d.Tx().Index()) result.BlockTime = b.Time.Unix() result.Confirmations = int64(confirms(d.BlockHeight, chainHeight)) } reply = append(reply, result) } return reply, nil } // CreditCategory describes the type of wallet transaction output. The category // of "sent transactions" (debits) is always "send", and is not expressed by // this type. type CreditCategory int // These constants define the possible credit categories. const ( CreditReceive CreditCategory = iota CreditGenerate CreditImmature ) // category returns the category of the credit. The passed block chain height is // used to distinguish immature from mature coinbase outputs. func (c *Credit) Category(chainHeight int32) CreditCategory { c.s.mtx.RLock() defer c.s.mtx.RUnlock() return c.category(chainHeight) } func (c *Credit) category(chainHeight int32) CreditCategory { if c.isCoinbase() { if confirmed(btcchain.CoinbaseMaturity, c.BlockHeight, chainHeight) { return CreditGenerate } return CreditImmature } return CreditReceive } // String returns the category as a string. This string may be used as the // JSON string for categories as part of listtransactions and gettransaction // RPC responses. func (c CreditCategory) String() string { switch c { case CreditReceive: return "receive" case CreditGenerate: return "generate" case CreditImmature: return "immature" default: return "unknown" } } // ToJSON returns a slice of objects that may be marshaled as a JSON array // of JSON objects for a listtransactions RPC reply. func (c Credit) ToJSON(account string, chainHeight int32, net *btcnet.Params) (btcjson.ListTransactionsResult, error) { c.s.mtx.RLock() defer c.s.mtx.RUnlock() return c.toJSON(account, chainHeight, net) } func (c Credit) toJSON(account string, chainHeight int32, net *btcnet.Params) (btcjson.ListTransactionsResult, error) { msgTx := c.Tx().MsgTx() txout := msgTx.TxOut[c.OutputIndex] var address string _, addrs, _, _ := btcscript.ExtractPkScriptAddrs(txout.PkScript, net) if len(addrs) == 1 { address = addrs[0].EncodeAddress() } result := btcjson.ListTransactionsResult{ Account: account, Category: c.category(chainHeight).String(), Address: address, Amount: btcutil.Amount(txout.Value).ToUnit(btcutil.AmountBTC), TxID: c.Tx().Sha().String(), Time: c.received.Unix(), TimeReceived: c.received.Unix(), WalletConflicts: []string{}, } if c.BlockHeight != -1 { b, err := c.s.lookupBlock(c.BlockHeight) if err != nil { return btcjson.ListTransactionsResult{}, err } result.BlockHash = b.Hash.String() result.BlockIndex = int64(c.Tx().Index()) result.BlockTime = b.Time.Unix() result.Confirmations = int64(confirms(c.BlockHeight, chainHeight)) } return result, nil }