package main import ( "fmt" "os" "path" "testing" "github.com/robertkrimen/otto" "github.com/ethereum/go-ethereum/accounts" "github.com/ethereum/go-ethereum/common" "github.com/ethereum/go-ethereum/crypto" "github.com/ethereum/go-ethereum/eth" ) var port = 30300 func testJEthRE(t *testing.T) (repl *jsre, 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 } // FIXME: this does not work ATM ks := crypto.NewKeyStorePlain("/tmp/eth/keys") common.WriteFile("/tmp/eth/keys/e273f01c99144c438695e10f24926dc1f9fbf62d/e273f01c99144c438695e10f24926dc1f9fbf62d", []byte(`{"Id":"RhRXD+fNRKS4jx+7ZfEsNA==","Address":"4nPwHJkUTEOGleEPJJJtwfn79i0=","PrivateKey":"h4ACVpe74uIvi5Cg/2tX/Yrm2xdr3J7QoMbMtNX2CNc="}`)) port++ ethereum, err = eth.New(ð.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 } assetPath := path.Join(os.Getenv("GOPATH"), "src", "github.com", "ethereum", "go-ethereum", "cmd", "mist", "assets", "ext") repl = newJSRE(ethereum, assetPath) return } func TestNodeInfo(t *testing.T) { repl, 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() val, err := repl.re.Run("admin.nodeInfo()") if err != nil { t.Errorf("expected no error, got %v", err) } exp, err := val.Export() if err != nil { t.Errorf("expected no error, got %v", err) } nodeInfo, ok := exp.(*eth.NodeInfo) if !ok { t.Errorf("expected nodeInfo, got %v", err) } exp = "test" got := nodeInfo.Name if exp != got { t.Errorf("expected %v, got %v", exp, got) } exp = 30301 port := nodeInfo.DiscPort if exp != port { t.Errorf("expected %v, got %v", exp, port) } exp = 30301 port = nodeInfo.TCPPort if exp != port { t.Errorf("expected %v, got %v", exp, port) } } func TestAccounts(t *testing.T) { repl, 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() val, err := repl.re.Run("eth.coinbase") if err != nil { t.Errorf("expected no error, got %v", err) } pp, err := repl.re.PrettyPrint(val) if err != nil { t.Errorf("%v", err) } if !val.IsString() { t.Errorf("incorrect type, expected string, got %v: %v", val, pp) } strVal, _ := val.ToString() expected := "0xe273f01c99144c438695e10f24926dc1f9fbf62d" if strVal != expected { t.Errorf("incorrect result, expected %s, got %v", expected, strVal) } val, err = repl.re.Run(`admin.newAccount("password")`) if err != nil { t.Errorf("expected no error, got %v", err) } addr, err := val.ToString() if err != nil { t.Errorf("expected string, got %v", err) } val, err = repl.re.Run("eth.accounts") if err != nil { t.Errorf("expected no error, got %v", err) } exp, err := val.Export() if err != nil { t.Errorf("expected no error, got %v", err) } interfaceAddr, ok := exp.([]interface{}) if !ok { t.Errorf("expected []string, got %T", exp) } addrs := make([]string, len(interfaceAddr)) for i, addr := range interfaceAddr { var ok bool if addrs[i], ok = addr.(string); !ok { t.Errorf("expected addrs[%d] to be string. Got %T instead", i, addr) } } if len(addrs) != 2 || (addr != addrs[0][2:] && addr != addrs[1][2:]) { t.Errorf("expected addrs == [, ], got %v (%v)", addrs, addr) } } func TestBlockChain(t *testing.T) { repl, 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() // should get current block val0, err := repl.re.Run("admin.dumpBlock()") if err != nil { t.Errorf("expected no error, got %v", err) } fn := "/tmp/eth/data/blockchain.0" _, err = repl.re.Run("admin.export(\"" + fn + "\")") if err != nil { t.Errorf("expected no error, got %v", err) } if _, err = os.Stat(fn); err != nil { t.Errorf("expected no error on file, got %v", err) } _, err = repl.re.Run("admin.import(\"" + fn + "\")") if err != nil { t.Errorf("expected no error, got %v", err) } var val1 otto.Value // should get current block val1, err = repl.re.Run("admin.dumpBlock()") if err != nil { t.Errorf("expected no error, got %v", err) } // FIXME: neither != , nor reflect.DeepEqual works, doing string comparison v0 := fmt.Sprintf("%v", val0) v1 := fmt.Sprintf("%v", val1) if v0 != v1 { t.Errorf("expected same head after export-import, got %v (!=%v)", v1, v0) } } func TestMining(t *testing.T) { repl, 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() val, err := repl.re.Run("eth.mining") if err != nil { t.Errorf("expected no error, got %v", err) } var mining bool mining, err = val.ToBoolean() if err != nil { t.Errorf("expected boolean, got %v", err) } if mining { t.Errorf("expected false (not mining), got true") } } func TestRPC(t *testing.T) { repl, 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() val, err := repl.re.Run(`admin.startRPC("127.0.0.1", 5004)`) if err != nil { t.Errorf("expected no error, got %v", err) } success, _ := val.ToBoolean() if !success { t.Errorf("expected true (started), got false") } }