package ethchain import ( "bytes" "fmt" "github.com/ethereum/eth-go/ethutil" "github.com/obscuren/secp256k1-go" "math/big" ) var ContractAddr = []byte{0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0} type Transaction struct { Nonce uint64 Recipient []byte Value *big.Int Gas *big.Int GasPrice *big.Int Data []byte v byte r, s []byte // Indicates whether this tx is a contract creation transaction contractCreation bool } func NewContractCreationTx(value, gas, gasPrice *big.Int, script []byte) *Transaction { 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} } func NewTransactionFromBytes(data []byte) *Transaction { tx := &Transaction{} tx.RlpDecode(data) return tx } func NewTransactionFromValue(val *ethutil.Value) *Transaction { tx := &Transaction{} tx.RlpValueDecode(val) return tx } 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) } func (tx *Transaction) Hash() []byte { data := []interface{}{tx.Nonce, tx.GasPrice, tx.Gas, tx.Recipient, tx.Value, tx.Data} return ethutil.Sha3Bin(ethutil.NewValue(data).Encode()) } func (tx *Transaction) CreatesContract() bool { return tx.contractCreation } /* Depricated */ func (tx *Transaction) IsContract() bool { return tx.CreatesContract() } func (tx *Transaction) CreationAddress() []byte { return ethutil.Sha3Bin(ethutil.NewValue([]interface{}{tx.Sender(), tx.Nonce}).Encode())[12:] } 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() // If we don't make a copy we will overwrite the existing underlying array dst := make([]byte, len(tx.r)) copy(dst, tx.r) sig := append(dst, tx.s...) 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 ethutil.Sha3Bin(pubkey[1:])[12:] } 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{} { data := []interface{}{tx.Nonce, tx.GasPrice, tx.Gas, tx.Recipient, tx.Value, tx.Data} return append(data, tx.v, tx.r, tx.s) } 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() 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()) tx.r = decoder.Get(7).Bytes() tx.s = decoder.Get(8).Bytes() if bytes.Compare(tx.Recipient, ContractAddr) == 0 { tx.contractCreation = true } } func (tx *Transaction) String() string { return fmt.Sprintf(` TX(%x) Contract: %v From: %x 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(), 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 } 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) } // 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 }