Canonical contract creation

pull/150/head
obscuren 11 years ago
parent cc8464ce80
commit 281559d427
  1. 22
      ethchain/state_manager.go
  2. 3
      ethchain/state_object.go
  3. 9
      ethchain/transaction.go
  4. 7
      ethchain/types.go
  5. 4
      ethpub/pub.go

@ -84,7 +84,7 @@ func (sm *StateManager) BlockChain() *BlockChain {
return sm.bc return sm.bc
} }
func (sm *StateManager) MakeContract(state *State, tx *Transaction) *StateObject { func (sm *StateManager) MakeStateObject(state *State, tx *Transaction) *StateObject {
contract := MakeContract(tx, state) contract := MakeContract(tx, state)
if contract != nil { if contract != nil {
state.states[string(tx.CreationAddress())] = contract.state state.states[string(tx.CreationAddress())] = contract.state
@ -123,18 +123,24 @@ func (sm *StateManager) ApplyTransaction(state *State, block *Block, tx *Transac
// If there's no recipient, it's a contract // If there's no recipient, it's a contract
// Check if this is a contract creation traction and if so // Check if this is a contract creation traction and if so
// create a contract of this tx. // create a contract of this tx.
// TODO COMMENT THIS SECTION
totalGasUsed := big.NewInt(0) totalGasUsed := big.NewInt(0)
if tx.IsContract() { if tx.IsContract() {
err := sm.Ethereum.TxPool().ProcessTransaction(tx, state, false) err := sm.Ethereum.TxPool().ProcessTransaction(tx, state, false)
if err == nil { if err == nil {
contract := sm.MakeContract(state, tx) contract := sm.MakeStateObject(state, tx)
if contract != nil { if contract != nil {
sm.EvalScript(state, contract.Init(), contract, tx, block) script, err := sm.EvalScript(state, contract.Init(), contract, tx, block)
if err != nil {
return nil, fmt.Errorf("[STATE] Error during init script run %v", err)
}
contract.script = script
state.UpdateStateObject(contract)
} else { } else {
return nil, fmt.Errorf("[STATE] Unable to create contract") return nil, fmt.Errorf("[STATE] Unable to create contract")
} }
} else { } else {
return nil, fmt.Errorf("[STATE] contract create:", err) return nil, fmt.Errorf("[STATE] contract creation tx:", err)
} }
} else { } else {
err := sm.Ethereum.TxPool().ProcessTransaction(tx, state, false) err := sm.Ethereum.TxPool().ProcessTransaction(tx, state, false)
@ -331,10 +337,10 @@ func (sm *StateManager) Stop() {
sm.bc.Stop() sm.bc.Stop()
} }
func (sm *StateManager) EvalScript(state *State, script []byte, object *StateObject, tx *Transaction, block *Block) { func (sm *StateManager) EvalScript(state *State, script []byte, object *StateObject, tx *Transaction, block *Block) (ret []byte, err error) {
account := state.GetAccount(tx.Sender()) account := state.GetAccount(tx.Sender())
err := account.ConvertGas(tx.Gas, tx.GasPrice) err = account.ConvertGas(tx.Gas, tx.GasPrice)
if err != nil { if err != nil {
ethutil.Config.Log.Debugln(err) ethutil.Config.Log.Debugln(err)
return return
@ -351,11 +357,13 @@ func (sm *StateManager) EvalScript(state *State, script []byte, object *StateObj
Value: tx.Value, Value: tx.Value,
//Price: tx.GasPrice, //Price: tx.GasPrice,
}) })
closure.Call(vm, tx.Data, nil) ret, err = closure.Call(vm, tx.Data, nil)
// Update the account (refunds) // Update the account (refunds)
state.UpdateStateObject(account) state.UpdateStateObject(account)
state.UpdateStateObject(object) state.UpdateStateObject(object)
return
} }
func (sm *StateManager) notifyChanges(state *State) { func (sm *StateManager) notifyChanges(state *State) {

@ -28,8 +28,7 @@ func MakeContract(tx *Transaction, state *State) *StateObject {
value := tx.Value value := tx.Value
contract := NewContract(addr, value, ZeroHash256) contract := NewContract(addr, value, ZeroHash256)
contract.script = tx.Data contract.initScript = tx.Data
contract.initScript = tx.Init
state.UpdateStateObject(contract) state.UpdateStateObject(contract)

@ -16,7 +16,6 @@ type Transaction struct {
Gas *big.Int Gas *big.Int
GasPrice *big.Int GasPrice *big.Int
Data []byte Data []byte
Init []byte
v byte v byte
r, s []byte r, s []byte
@ -24,8 +23,8 @@ type Transaction struct {
contractCreation bool contractCreation bool
} }
func NewContractCreationTx(value, gas, gasPrice *big.Int, script []byte, init []byte) *Transaction { func NewContractCreationTx(value, gas, gasPrice *big.Int, script []byte) *Transaction {
return &Transaction{Value: value, Gas: gas, GasPrice: gasPrice, Data: script, Init: init, contractCreation: true} return &Transaction{Value: value, Gas: gas, GasPrice: gasPrice, Data: script, contractCreation: true}
} }
func NewTransactionMessage(to []byte, value, gas, gasPrice *big.Int, data []byte) *Transaction { func NewTransactionMessage(to []byte, value, gas, gasPrice *big.Int, data []byte) *Transaction {
@ -115,10 +114,6 @@ func (tx *Transaction) Sign(privk []byte) error {
func (tx *Transaction) RlpData() interface{} { func (tx *Transaction) RlpData() interface{} {
data := []interface{}{tx.Nonce, tx.GasPrice, tx.Gas, tx.Recipient, tx.Value, tx.Data} data := []interface{}{tx.Nonce, tx.GasPrice, tx.Gas, tx.Recipient, tx.Value, tx.Data}
if tx.contractCreation {
data = append(data, tx.Init)
}
return append(data, tx.v, tx.r, tx.s) return append(data, tx.v, tx.r, tx.s)
} }

@ -322,3 +322,10 @@ func IsOpCode(s string) bool {
} }
return false return false
} }
func AppendScript(init, script []byte) []byte {
s := append(init, byte(oRETURN))
s = append(s, script...)
return s
}

@ -141,7 +141,9 @@ func (lib *PEthereum) createTx(key, recipient, valueStr, gasStr, gasPriceStr, in
} }
} }
tx = ethchain.NewContractCreationTx(value, gas, gasPrice, mainScript, initScript) script := ethchain.AppendScript(initScript, mainScript)
tx = ethchain.NewContractCreationTx(value, gas, gasPrice, script)
} else { } else {
// Just in case it was submitted as a 0x prefixed string // Just in case it was submitted as a 0x prefixed string
if len(initStr) > 0 && initStr[0:2] == "0x" { if len(initStr) > 0 && initStr[0:2] == "0x" {

Loading…
Cancel
Save