plugeth/ethchain/transaction.go

250 lines
5.3 KiB
Go
Raw Normal View History

2014-02-14 22:56:09 +00:00
package ethchain
import (
"bytes"
"fmt"
"math/big"
"github.com/ethereum/eth-go/ethcrypto"
2014-02-14 22:56:09 +00:00
"github.com/ethereum/eth-go/ethutil"
"github.com/obscuren/secp256k1-go"
)
2014-02-19 10:35:17 +00:00
var ContractAddr = []byte{0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0}
2014-06-19 11:42:47 +00:00
func IsContractAddr(addr []byte) bool {
return bytes.Compare(addr, ContractAddr) == 0
}
2014-02-14 22:56:09 +00:00
type Transaction struct {
Nonce uint64
Recipient []byte
Value *big.Int
Gas *big.Int
2014-04-18 11:41:07 +00:00
GasPrice *big.Int
Data []byte
2014-02-14 22:56:09 +00:00
v byte
r, s []byte
2014-03-27 14:42:39 +00:00
// Indicates whether this tx is a contract creation transaction
contractCreation bool
2014-02-14 22:56:09 +00:00
}
2014-05-22 16:24:04 +00:00
func NewContractCreationTx(value, gas, gasPrice *big.Int, script []byte) *Transaction {
2014-06-14 22:10:42 +00:00
return &Transaction{Recipient: ContractAddr, Value: value, Gas: gas, GasPrice: gasPrice, Data: script, contractCreation: true}
}
func NewTransactionMessage(to []byte, value, gas, gasPrice *big.Int, data []byte) *Transaction {
return &Transaction{Recipient: to, Value: value, GasPrice: gasPrice, Gas: gas, Data: data}
}
2014-02-25 10:22:18 +00:00
func NewTransactionFromBytes(data []byte) *Transaction {
2014-02-14 22:56:09 +00:00
tx := &Transaction{}
tx.RlpDecode(data)
return tx
}
func NewTransactionFromValue(val *ethutil.Value) *Transaction {
tx := &Transaction{}
tx.RlpValueDecode(val)
return tx
}
2014-06-13 10:45:11 +00:00
func (self *Transaction) GasValue() *big.Int {
return new(big.Int).Mul(self.Gas, self.GasPrice)
}
func (self *Transaction) TotalValue() *big.Int {
v := self.GasValue()
return v.Add(v, self.Value)
}
2014-02-14 22:56:09 +00:00
func (tx *Transaction) Hash() []byte {
data := []interface{}{tx.Nonce, tx.GasPrice, tx.Gas, tx.Recipient, tx.Value, tx.Data}
return ethcrypto.Sha3Bin(ethutil.NewValue(data).Encode())
2014-02-14 22:56:09 +00:00
}
func (tx *Transaction) CreatesContract() bool {
return tx.contractCreation
2014-02-14 22:56:09 +00:00
}
/* Deprecated */
func (tx *Transaction) IsContract() bool {
return tx.CreatesContract()
}
2014-05-02 12:08:54 +00:00
func (tx *Transaction) CreationAddress() []byte {
return ethcrypto.Sha3Bin(ethutil.NewValue([]interface{}{tx.Sender(), tx.Nonce}).Encode())[12:]
2014-05-02 12:08:54 +00:00
}
2014-02-14 22:56:09 +00:00
func (tx *Transaction) Signature(key []byte) []byte {
hash := tx.Hash()
sig, _ := secp256k1.Sign(hash, key)
return sig
}
func (tx *Transaction) PublicKey() []byte {
hash := tx.Hash()
2014-07-01 22:05:48 +00:00
// TODO
r := ethutil.LeftPadBytes(tx.r, 32)
s := ethutil.LeftPadBytes(tx.s, 32)
2014-02-14 22:56:09 +00:00
sig := append(r, s...)
2014-02-14 22:56:09 +00:00
sig = append(sig, tx.v-27)
pubkey, _ := secp256k1.RecoverPubkey(hash, sig)
return pubkey
}
func (tx *Transaction) Sender() []byte {
pubkey := tx.PublicKey()
// Validate the returned key.
// Return nil if public key isn't in full format
if pubkey[0] != 4 {
return nil
}
return ethcrypto.Sha3Bin(pubkey[1:])[12:]
2014-02-14 22:56:09 +00:00
}
func (tx *Transaction) Sign(privk []byte) error {
sig := tx.Signature(privk)
tx.r = sig[:32]
tx.s = sig[32:64]
tx.v = sig[64] + 27
return nil
}
func (tx *Transaction) RlpData() interface{} {
2014-05-20 11:06:47 +00:00
data := []interface{}{tx.Nonce, tx.GasPrice, tx.Gas, tx.Recipient, tx.Value, tx.Data}
// TODO Remove prefixing zero's
return append(data, tx.v, new(big.Int).SetBytes(tx.r).Bytes(), new(big.Int).SetBytes(tx.s).Bytes())
2014-02-14 22:56:09 +00:00
}
func (tx *Transaction) RlpValue() *ethutil.Value {
return ethutil.NewValue(tx.RlpData())
}
func (tx *Transaction) RlpEncode() []byte {
return tx.RlpValue().Encode()
}
func (tx *Transaction) RlpDecode(data []byte) {
tx.RlpValueDecode(ethutil.NewValueFromBytes(data))
}
func (tx *Transaction) RlpValueDecode(decoder *ethutil.Value) {
tx.Nonce = decoder.Get(0).Uint()
2014-05-20 11:06:47 +00:00
tx.GasPrice = decoder.Get(1).BigInt()
tx.Gas = decoder.Get(2).BigInt()
tx.Recipient = decoder.Get(3).Bytes()
tx.Value = decoder.Get(4).BigInt()
tx.Data = decoder.Get(5).Bytes()
tx.v = byte(decoder.Get(6).Uint())
2014-06-20 18:12:08 +00:00
tx.r = decoder.Get(7).Bytes()
tx.s = decoder.Get(8).Bytes()
2014-06-19 11:42:47 +00:00
if IsContractAddr(tx.Recipient) {
tx.contractCreation = true
}
}
func (tx *Transaction) String() string {
return fmt.Sprintf(`
TX(%x)
Contract: %v
From: %x
2014-05-22 15:56:33 +00:00
To: %x
Nonce: %v
GasPrice: %v
Gas: %v
Value: %v
Data: 0x%x
V: 0x%x
R: 0x%x
S: 0x%x
`,
tx.Hash(),
len(tx.Recipient) == 0,
tx.Sender(),
2014-05-22 15:56:33 +00:00
tx.Recipient,
tx.Nonce,
tx.GasPrice,
tx.Gas,
tx.Value,
tx.Data,
tx.v,
tx.r,
tx.s)
}
type Receipt struct {
Tx *Transaction
PostState []byte
CumulativeGasUsed *big.Int
}
2014-06-13 10:45:11 +00:00
type Receipts []*Receipt
func NewRecieptFromValue(val *ethutil.Value) *Receipt {
r := &Receipt{}
r.RlpValueDecode(val)
return r
}
func (self *Receipt) RlpValueDecode(decoder *ethutil.Value) {
self.Tx = NewTransactionFromValue(decoder.Get(0))
self.PostState = decoder.Get(1).Bytes()
self.CumulativeGasUsed = decoder.Get(2).BigInt()
}
func (self *Receipt) RlpData() interface{} {
return []interface{}{self.Tx.RlpData(), self.PostState, self.CumulativeGasUsed}
}
func (self *Receipt) String() string {
return fmt.Sprintf(`
R
Tx:[ %v]
PostState: 0x%x
CumulativeGasUsed: %v
`,
self.Tx,
self.PostState,
self.CumulativeGasUsed)
2014-02-14 22:56:09 +00:00
}
2014-07-14 20:52:44 +00:00
func (self *Receipt) Cmp(other *Receipt) bool {
if bytes.Compare(self.PostState, other.PostState) != 0 {
return false
}
return true
}
// Transaction slice type for basic sorting
type Transactions []*Transaction
func (s Transactions) Len() int { return len(s) }
func (s Transactions) Swap(i, j int) { s[i], s[j] = s[j], s[i] }
type TxByNonce struct{ Transactions }
func (s TxByNonce) Less(i, j int) bool {
return s.Transactions[i].Nonce < s.Transactions[j].Nonce
}