aboutsummaryrefslogtreecommitdiffstats
path: root/common
diff options
context:
space:
mode:
authorzsfelfoldi <zsfelfoldi@gmail.com>2015-04-03 23:37:59 +0800
committerzelig <viktor.tron@gmail.com>2015-04-20 03:57:49 +0800
commite2d333d2095edb349388433c28f4d6a381b1df62 (patch)
tree2bc2dbf45ffeb1de93606122d263913d790d048f /common
parentac0e5e8b6de43a40bbc25f541aa2399202bbe420 (diff)
downloadgo-tangerine-e2d333d2095edb349388433c28f4d6a381b1df62.tar
go-tangerine-e2d333d2095edb349388433c28f4d6a381b1df62.tar.gz
go-tangerine-e2d333d2095edb349388433c28f4d6a381b1df62.tar.bz2
go-tangerine-e2d333d2095edb349388433c28f4d6a381b1df62.tar.lz
go-tangerine-e2d333d2095edb349388433c28f4d6a381b1df62.tar.xz
go-tangerine-e2d333d2095edb349388433c28f4d6a381b1df62.tar.zst
go-tangerine-e2d333d2095edb349388433c28f4d6a381b1df62.zip
NatSpec contracts in genesis block, end to end test (unfinished)
Diffstat (limited to 'common')
-rw-r--r--common/bytes.go17
-rw-r--r--common/natspec/natspec.go5
-rw-r--r--common/natspec/natspec_e2e_test.go143
-rw-r--r--common/natspec/statereg.go44
-rw-r--r--common/resolver/resolver.go11
-rw-r--r--common/resolver/resolver_test.go12
6 files changed, 174 insertions, 58 deletions
diff --git a/common/bytes.go b/common/bytes.go
index 5bdacd810..5d1245107 100644
--- a/common/bytes.go
+++ b/common/bytes.go
@@ -147,6 +147,23 @@ func Hex2Bytes(str string) []byte {
return h
}
+func Hex2BytesFixed(str string, flen int) []byte {
+
+ h, _ := hex.DecodeString(str)
+ if len(h) == flen {
+ return h
+ } else {
+ if len(h) > flen {
+ return h[len(h)-flen : len(h)]
+ } else {
+ hh := make([]byte, flen)
+ copy(hh[flen-len(h):flen], h[:])
+ return hh
+ }
+ }
+
+}
+
func StringToByteFunc(str string, cb func(str string) []byte) (ret []byte) {
if len(str) > 1 && str[0:2] == "0x" && !strings.Contains(str, "\n") {
ret = Hex2Bytes(str[2:])
diff --git a/common/natspec/natspec.go b/common/natspec/natspec.go
index 145da14fe..b047f19d6 100644
--- a/common/natspec/natspec.go
+++ b/common/natspec/natspec.go
@@ -49,11 +49,10 @@ func New(xeth *xeth.XEth, tx string, http *docserver.DocServer) (self *NatSpec,
// parse out host/domain
// set up nameresolver with natspecreg + urlhint contract addresses
- stateReg := NewStateReg(xeth)
res := resolver.New(
xeth,
- stateReg.caNatSpec,
- stateReg.caURL,
+ resolver.NameRegContractAddress,
+ resolver.URLHintContractAddress,
)
// resolve host via nameReg/UrlHint Resolver
diff --git a/common/natspec/natspec_e2e_test.go b/common/natspec/natspec_e2e_test.go
new file mode 100644
index 000000000..ad6c13f2a
--- /dev/null
+++ b/common/natspec/natspec_e2e_test.go
@@ -0,0 +1,143 @@
+package natspec
+
+import (
+ "fmt"
+ "io/ioutil"
+ "math/big"
+ "os"
+ "testing"
+
+ "github.com/ethereum/go-ethereum/accounts"
+ "github.com/ethereum/go-ethereum/common"
+ "github.com/ethereum/go-ethereum/common/resolver"
+ "github.com/ethereum/go-ethereum/core"
+ //"github.com/ethereum/go-ethereum/core/types"
+ "github.com/ethereum/go-ethereum/crypto"
+ "github.com/ethereum/go-ethereum/eth"
+ xe "github.com/ethereum/go-ethereum/xeth"
+)
+
+type testFrontend struct {
+ t *testing.T
+ ethereum *eth.Ethereum
+ xeth *xe.XEth
+}
+
+func (f *testFrontend) UnlockAccount(acc []byte) bool {
+ f.t.Logf("Unlocking account %v\n", common.Bytes2Hex(acc))
+ f.ethereum.AccountManager().Unlock(acc, "password")
+ return true
+}
+
+func (testFrontend) ConfirmTransaction(message string) bool { return true }
+
+var port = 30300
+
+func testJEthRE(t *testing.T) (ethereum *eth.Ethereum, err error) {
+ os.RemoveAll("/tmp/eth/")
+ err = os.MkdirAll("/tmp/eth/keys/e273f01c99144c438695e10f24926dc1f9fbf62d/", os.ModePerm)
+ if err != nil {
+ t.Errorf("%v", err)
+ return
+ }
+ err = os.MkdirAll("/tmp/eth/data", os.ModePerm)
+ if err != nil {
+ t.Errorf("%v", err)
+ return
+ }
+ ks := crypto.NewKeyStorePlain("/tmp/eth/keys")
+ ioutil.WriteFile("/tmp/eth/keys/e273f01c99144c438695e10f24926dc1f9fbf62d/e273f01c99144c438695e10f24926dc1f9fbf62d",
+ []byte(`{"Id":"RhRXD+fNRKS4jx+7ZfEsNA==","Address":"4nPwHJkUTEOGleEPJJJtwfn79i0=","PrivateKey":"h4ACVpe74uIvi5Cg/2tX/Yrm2xdr3J7QoMbMtNX2CNc="}`), os.ModePerm)
+
+ port++
+ ethereum, err = eth.New(&eth.Config{
+ DataDir: "/tmp/eth",
+ AccountManager: accounts.NewManager(ks),
+ Port: fmt.Sprintf("%d", port),
+ MaxPeers: 10,
+ Name: "test",
+ })
+
+ if err != nil {
+ t.Errorf("%v", err)
+ return
+ }
+
+ return
+}
+
+func (self *testFrontend) insertTx(addr, contract, fnsig string, args []string) {
+
+ hash := common.Bytes2Hex(crypto.Sha3([]byte(fnsig)))
+ data := "0x" + hash[0:8]
+ for _, arg := range args {
+ data = data + common.Bytes2Hex(common.Hex2BytesFixed(arg, 32))
+ }
+ self.t.Logf("Tx data: %v", data)
+ self.xeth.Transact(addr, contract, "100000000000", "100000", "100000", data)
+
+ cb := common.HexToAddress(addr)
+ stateDb := self.ethereum.ChainManager().State().Copy()
+
+ coinbase := stateDb.GetStateObject(cb)
+ coinbase.SetGasPool(big.NewInt(100000))
+ block := self.ethereum.ChainManager().NewBlock(cb)
+ txs := self.ethereum.TxPool().GetTransactions()
+ tx := txs[0]
+
+ _, gas, err := core.ApplyMessage(core.NewEnv(stateDb, self.ethereum.ChainManager(), tx, block), tx, coinbase)
+
+ self.t.Logf("ApplyMessage: gas %v err %v", gas, err)
+
+ self.ethereum.TxPool().RemoveSet(txs)
+ self.xeth = self.xeth.WithState(stateDb)
+
+}
+
+func TestNatspecE2E(t *testing.T) {
+ ethereum, err := testJEthRE(t)
+ if err != nil {
+ t.Errorf("error creating jsre, got %v", err)
+ return
+ }
+ err = ethereum.Start()
+ if err != nil {
+ t.Errorf("error starting ethereum: %v", err)
+ return
+ }
+ defer ethereum.Stop()
+
+ frontend := &testFrontend{t: t, ethereum: ethereum}
+ frontend.xeth = xe.New(ethereum, frontend)
+
+ addr := frontend.xeth.Coinbase()
+ if addr != "0x"+core.TestAccount {
+ t.Errorf("CoinBase %v does not match TestAccount 0x%v", addr, core.TestAccount)
+ }
+ t.Logf("CoinBase is %v", addr)
+
+ balance := frontend.xeth.BalanceAt(core.TestAccount)
+ if balance != core.TestBalance {
+ t.Errorf("Balance %v does not match TestBalance %v", balance, core.TestBalance)
+ }
+ t.Logf("Balance is %v", balance)
+
+ frontend.insertTx(addr, core.ContractAddrURLhint, "register(bytes32,bytes32)", []string{"1234", "5678"})
+
+ t.Logf("testcnt: %v", frontend.xeth.StorageAt(core.ContractAddrURLhint, "00"))
+
+ for i := 0; i < 10; i++ {
+ t.Logf("storage[%v] = %v", i, frontend.xeth.StorageAt("0x"+core.ContractAddrURLhint, fmt.Sprintf("%v", i)))
+ }
+
+ rsv := resolver.New(frontend.xeth, resolver.URLHintContractAddress, resolver.NameRegContractAddress)
+ url, err2 := rsv.ContentHashToUrl(common.BytesToHash(common.Hex2BytesFixed("1234", 32)))
+
+ t.Logf("URL: %v err: %v", url, err2)
+
+ /*
+ This test is unfinished; first we need to see the result of a
+ transaction in the contract storage (testcnt should be 1).
+ */
+
+}
diff --git a/common/natspec/statereg.go b/common/natspec/statereg.go
deleted file mode 100644
index 53d4a3081..000000000
--- a/common/natspec/statereg.go
+++ /dev/null
@@ -1,44 +0,0 @@
-package natspec
-
-import (
- "github.com/ethereum/go-ethereum/xeth"
-)
-
-type StateReg struct {
- xeth *xeth.XEth
- caURL, caNatSpec string //contract addresses
-}
-
-func NewStateReg(xeth *xeth.XEth) (self *StateReg) {
- self = &StateReg{}
- self.xeth = xeth
- self.testCreateContracts()
- return
-
-}
-
-const codeURLhint = "0x33600081905550609c8060136000396000f30060003560e060020a900480632f926732" +
- "14601f578063f39ec1f714603157005b602b6004356024356044565b60006000f35b603a" +
- "600435607f565b8060005260206000f35b600054600160a060020a031633600160a06002" +
- "0a031614606257607b565b8060016000848152602001908152602001600020819055505b" +
- "5050565b60006001600083815260200190815260200160002054905091905056"
-
-const codeNatSpec = "0x33600081905550609c8060136000396000f30060003560e060020a900480632f926732" +
- "14601f578063f39ec1f714603157005b602b6004356024356044565b60006000f35b603a" +
- "600435607f565b8060005260206000f35b600054600160a060020a031633600160a06002" +
- "0a031614606257607b565b8060016000848152602001908152602001600020819055505b" +
- "5050565b60006001600083815260200190815260200160002054905091905056"
-
-func (self *StateReg) testCreateContracts() {
-
- var err error
- self.caURL, err = self.xeth.Transact(self.xeth.Coinbase(), "", "100000", "", self.xeth.DefaultGas().String(), codeURLhint)
- if err != nil {
- panic(err)
- }
- self.caNatSpec, err = self.xeth.Transact(self.xeth.Coinbase(), "", "100000", "", self.xeth.DefaultGas().String(), codeNatSpec)
- if err != nil {
- panic(err)
- }
-
-}
diff --git a/common/resolver/resolver.go b/common/resolver/resolver.go
index ba592feb0..1d80fdb42 100644
--- a/common/resolver/resolver.go
+++ b/common/resolver/resolver.go
@@ -5,6 +5,7 @@ import (
"fmt"
"github.com/ethereum/go-ethereum/common"
+ "github.com/ethereum/go-ethereum/core"
"github.com/ethereum/go-ethereum/crypto"
)
@@ -17,8 +18,8 @@ The resolver is meant to be called by the roundtripper transport implementation
of a url scheme
*/
const (
- urlHintContractAddress = "urlhint"
- nameRegContractAddress = "nameReg"
+ URLHintContractAddress = core.ContractAddrURLhint
+ NameRegContractAddress = core.ContractAddrHashReg
)
type Resolver struct {
@@ -37,7 +38,7 @@ func New(eth Backend, uhca, nrca string) *Resolver {
func (self *Resolver) NameToContentHash(name string) (chash common.Hash, err error) {
// look up in nameReg
- key := storageAddress(0, common.Hex2Bytes(name))
+ key := storageAddress(1, common.Hex2BytesFixed(name, 32))
hash := self.backend.StorageAt(self.nameRegContractAddress, key)
copy(chash[:], common.Hex2Bytes(hash))
return
@@ -45,8 +46,8 @@ func (self *Resolver) NameToContentHash(name string) (chash common.Hash, err err
func (self *Resolver) ContentHashToUrl(chash common.Hash) (uri string, err error) {
// look up in nameReg
- key := storageAddress(0, chash[:])
- uri = self.backend.StorageAt(self.urlHintContractAddress, key)
+ key := storageAddress(2, chash[:])
+ uri = string(common.Hex2Bytes(self.backend.StorageAt(self.urlHintContractAddress, key)))
l := len(uri)
for (l > 0) && (uri[l-1] == 0) {
l--
diff --git a/common/resolver/resolver_test.go b/common/resolver/resolver_test.go
index a5b6c3b4f..5652213f6 100644
--- a/common/resolver/resolver_test.go
+++ b/common/resolver/resolver_test.go
@@ -23,13 +23,13 @@ func NewTestBackend() *testBackend {
self := &testBackend{}
self.contracts = make(map[string](map[string]string))
- self.contracts[nameRegContractAddress] = make(map[string]string)
+ self.contracts[NameRegContractAddress] = make(map[string]string)
key := storageAddress(0, common.Hex2Bytes(codehash))
- self.contracts[nameRegContractAddress][key] = hash
+ self.contracts[NameRegContractAddress][key] = hash
- self.contracts[urlHintContractAddress] = make(map[string]string)
+ self.contracts[URLHintContractAddress] = make(map[string]string)
key = storageAddress(0, common.Hex2Bytes(hash))
- self.contracts[urlHintContractAddress][key] = url
+ self.contracts[URLHintContractAddress][key] = url
return self
}
@@ -45,7 +45,7 @@ func (self *testBackend) StorageAt(ca, sa string) (res string) {
func TestNameToContentHash(t *testing.T) {
b := NewTestBackend()
- res := New(b, urlHintContractAddress, nameRegContractAddress)
+ res := New(b, URLHintContractAddress, NameRegContractAddress)
got, err := res.NameToContentHash(codehash)
if err != nil {
t.Errorf("expected no error, got %v", err)
@@ -58,7 +58,7 @@ func TestNameToContentHash(t *testing.T) {
func TestContentHashToUrl(t *testing.T) {
b := NewTestBackend()
- res := New(b, urlHintContractAddress, nameRegContractAddress)
+ res := New(b, URLHintContractAddress, NameRegContractAddress)
chash := common.Hash{}
copy(chash[:], common.Hex2Bytes(hash))
got, err := res.ContentHashToUrl(chash)