diff options
author | zelig <viktor.tron@gmail.com> | 2015-10-27 05:24:09 +0800 |
---|---|---|
committer | zelig <viktor.tron@gmail.com> | 2015-10-27 05:24:09 +0800 |
commit | 4d005a2c1d2929dc770acd3a2bfed59495c70557 (patch) | |
tree | 0442ccefd85cc8b692c2c58a5916bc997909657a /common | |
parent | 3b4ffacd0c63952ceda96b3fafb050c91e72b420 (diff) | |
download | go-tangerine-4d005a2c1d2929dc770acd3a2bfed59495c70557.tar.gz go-tangerine-4d005a2c1d2929dc770acd3a2bfed59495c70557.tar.zst go-tangerine-4d005a2c1d2929dc770acd3a2bfed59495c70557.zip |
rpc api: eth_getNatSpec
* xeth, rpc: implement eth_getNatSpec for tx confirmations
* rename silly docserver -> httpclient
* eth/backend: httpclient now accessible via eth.Ethereum init-d via config.DocRoot
* cmd: introduce separate CLI flag for DocRoot (defaults to homedir)
* common/path: delete unused assetpath func, separate HomeDir func
Diffstat (limited to 'common')
-rw-r--r-- | common/httpclient/httpclient.go (renamed from common/docserver/docserver.go) | 48 | ||||
-rw-r--r-- | common/httpclient/httpclient_test.go (renamed from common/docserver/docserver_test.go) | 20 | ||||
-rw-r--r-- | common/natspec/natspec.go | 14 | ||||
-rw-r--r-- | common/natspec/natspec_e2e_test.go | 6 | ||||
-rw-r--r-- | common/path.go | 44 |
5 files changed, 52 insertions, 80 deletions
diff --git a/common/docserver/docserver.go b/common/httpclient/httpclient.go index cfc4e3b26..23373ecaf 100644 --- a/common/docserver/docserver.go +++ b/common/httpclient/httpclient.go @@ -14,7 +14,7 @@ // You should have received a copy of the GNU Lesser General Public License // along with the go-ethereum library. If not, see <http://www.gnu.org/licenses/>. -package docserver +package httpclient import ( "fmt" @@ -26,14 +26,14 @@ import ( "github.com/ethereum/go-ethereum/crypto" ) -type DocServer struct { +type HTTPClient struct { *http.Transport DocRoot string schemes []string } -func New(docRoot string) (self *DocServer) { - self = &DocServer{ +func New(docRoot string) (self *HTTPClient) { + self = &HTTPClient{ Transport: &http.Transport{}, DocRoot: docRoot, schemes: []string{"file"}, @@ -46,18 +46,18 @@ func New(docRoot string) (self *DocServer) { // A Client is higher-level than a RoundTripper (such as Transport) and additionally handles HTTP details such as cookies and redirects. -func (self *DocServer) Client() *http.Client { +func (self *HTTPClient) Client() *http.Client { return &http.Client{ Transport: self, } } -func (self *DocServer) RegisterScheme(scheme string, rt http.RoundTripper) { +func (self *HTTPClient) RegisterScheme(scheme string, rt http.RoundTripper) { self.schemes = append(self.schemes, scheme) self.RegisterProtocol(scheme, rt) } -func (self *DocServer) HasScheme(scheme string) bool { +func (self *HTTPClient) HasScheme(scheme string) bool { for _, s := range self.schemes { if s == scheme { return true @@ -66,43 +66,41 @@ func (self *DocServer) HasScheme(scheme string) bool { return false } -func (self *DocServer) GetAuthContent(uri string, hash common.Hash) (content []byte, err error) { +func (self *HTTPClient) GetAuthContent(uri string, hash common.Hash) ([]byte, error) { // retrieve content - content, err = self.Get(uri, "") + content, err := self.Get(uri, "") if err != nil { - return + return nil, err } // check hash to authenticate content chash := crypto.Sha3Hash(content) if chash != hash { - content = nil - err = fmt.Errorf("content hash mismatch %x != %x (exp)", hash[:], chash[:]) + return nil, fmt.Errorf("content hash mismatch %x != %x (exp)", hash[:], chash[:]) } - return + return content, nil } // Get(uri, path) downloads the document at uri, if path is non-empty it // is interpreted as a filepath to which the contents are saved -func (self *DocServer) Get(uri, path string) (content []byte, err error) { +func (self *HTTPClient) Get(uri, path string) ([]byte, error) { // retrieve content resp, err := self.Client().Get(uri) - + if err != nil { + return nil, err + } defer func() { if resp != nil { resp.Body.Close() } }() - if err != nil { - return - } - + var content []byte content, err = ioutil.ReadAll(resp.Body) if err != nil { - return + return nil, err } if resp.StatusCode/100 != 2 { @@ -112,9 +110,15 @@ func (self *DocServer) Get(uri, path string) (content []byte, err error) { if path != "" { var abspath string abspath, err = filepath.Abs(path) - ioutil.WriteFile(abspath, content, 0700) + if err != nil { + return nil, err + } + err = ioutil.WriteFile(abspath, content, 0600) + if err != nil { + return nil, err + } } - return + return content, nil } diff --git a/common/docserver/docserver_test.go b/common/httpclient/httpclient_test.go index 632603add..6c3782e15 100644 --- a/common/docserver/docserver_test.go +++ b/common/httpclient/httpclient_test.go @@ -14,7 +14,7 @@ // You should have received a copy of the GNU Lesser General Public License // along with the go-ethereum library. If not, see <http://www.gnu.org/licenses/>. -package docserver +package httpclient import ( "io/ioutil" @@ -28,19 +28,19 @@ import ( ) func TestGetAuthContent(t *testing.T) { - dir, err := ioutil.TempDir("", "docserver-test") + dir, err := ioutil.TempDir("", "httpclient-test") if err != nil { t.Fatal("cannot create temporary directory:", err) } defer os.RemoveAll(dir) - ds := New(dir) + client := New(dir) text := "test" hash := crypto.Sha3Hash([]byte(text)) if err := ioutil.WriteFile(path.Join(dir, "test.content"), []byte(text), os.ModePerm); err != nil { t.Fatal("could not write test file", err) } - content, err := ds.GetAuthContent("file:///test.content", hash) + content, err := client.GetAuthContent("file:///test.content", hash) if err != nil { t.Errorf("no error expected, got %v", err) } @@ -49,7 +49,7 @@ func TestGetAuthContent(t *testing.T) { } hash = common.Hash{} - content, err = ds.GetAuthContent("file:///test.content", hash) + content, err = client.GetAuthContent("file:///test.content", hash) expected := "content hash mismatch 0000000000000000000000000000000000000000000000000000000000000000 != 9c22ff5f21f0b81b113e63f7db6da94fedef11b2119b4088b89664fb9a3cb658 (exp)" if err == nil { t.Errorf("expected error, got nothing") @@ -66,12 +66,12 @@ type rt struct{} func (rt) RoundTrip(req *http.Request) (resp *http.Response, err error) { return } func TestRegisterScheme(t *testing.T) { - ds := New("/tmp/") - if ds.HasScheme("scheme") { + client := New("/tmp/") + if client.HasScheme("scheme") { t.Errorf("expected scheme not to be registered") } - ds.RegisterScheme("scheme", rt{}) - if !ds.HasScheme("scheme") { + client.RegisterScheme("scheme", rt{}) + if !client.HasScheme("scheme") { t.Errorf("expected scheme to be registered") } -}
\ No newline at end of file +} diff --git a/common/natspec/natspec.go b/common/natspec/natspec.go index 0265c2e13..d9627b4e1 100644 --- a/common/natspec/natspec.go +++ b/common/natspec/natspec.go @@ -23,7 +23,7 @@ import ( "strings" "github.com/ethereum/go-ethereum/common" - "github.com/ethereum/go-ethereum/common/docserver" + "github.com/ethereum/go-ethereum/common/httpclient" "github.com/ethereum/go-ethereum/common/registrar" "github.com/ethereum/go-ethereum/crypto" "github.com/ethereum/go-ethereum/xeth" @@ -43,7 +43,7 @@ type NatSpec struct { // the implementation is frontend friendly in that it always gives back // a notice that is safe to display // :FIXME: the second return value is an error, which can be used to fine-tune bahaviour -func GetNotice(xeth *xeth.XEth, tx string, http *docserver.DocServer) (notice string) { +func GetNotice(xeth *xeth.XEth, tx string, http *httpclient.HTTPClient) (notice string) { ns, err := New(xeth, tx, http) if err != nil { if ns == nil { @@ -83,7 +83,7 @@ type contractInfo struct { DeveloperDoc json.RawMessage `json:"developerDoc"` } -func New(xeth *xeth.XEth, jsontx string, http *docserver.DocServer) (self *NatSpec, err error) { +func New(xeth *xeth.XEth, jsontx string, http *httpclient.HTTPClient) (self *NatSpec, err error) { // extract contract address from tx var tx jsonTx @@ -104,7 +104,7 @@ func New(xeth *xeth.XEth, jsontx string, http *docserver.DocServer) (self *NatSp } // also called by admin.contractInfo.get -func FetchDocsForContract(contractAddress string, xeth *xeth.XEth, ds *docserver.DocServer) (content []byte, err error) { +func FetchDocsForContract(contractAddress string, xeth *xeth.XEth, client *httpclient.HTTPClient) (content []byte, err error) { // retrieve contract hash from state codehex := xeth.CodeAt(contractAddress) codeb := xeth.CodeAtBytes(contractAddress) @@ -122,8 +122,8 @@ func FetchDocsForContract(contractAddress string, xeth *xeth.XEth, ds *docserver if err != nil { return } - if ds.HasScheme("bzz") { - content, err = ds.Get("bzz://"+hash.Hex()[2:], "") + if client.HasScheme("bzz") { + content, err = client.Get("bzz://"+hash.Hex()[2:], "") if err == nil { // non-fatal return } @@ -137,7 +137,7 @@ func FetchDocsForContract(contractAddress string, xeth *xeth.XEth, ds *docserver } // get content via http client and authenticate content using hash - content, err = ds.GetAuthContent(uri, hash) + content, err = client.GetAuthContent(uri, hash) if err != nil { return } diff --git a/common/natspec/natspec_e2e_test.go b/common/natspec/natspec_e2e_test.go index 4149314c3..706a294ec 100644 --- a/common/natspec/natspec_e2e_test.go +++ b/common/natspec/natspec_e2e_test.go @@ -28,7 +28,7 @@ import ( "github.com/ethereum/go-ethereum/accounts" "github.com/ethereum/go-ethereum/common" - "github.com/ethereum/go-ethereum/common/docserver" + "github.com/ethereum/go-ethereum/common/httpclient" "github.com/ethereum/go-ethereum/common/registrar" "github.com/ethereum/go-ethereum/core" "github.com/ethereum/go-ethereum/crypto" @@ -113,8 +113,8 @@ func (self *testFrontend) UnlockAccount(acc []byte) bool { func (self *testFrontend) ConfirmTransaction(tx string) bool { if self.wantNatSpec { - ds := docserver.New("/tmp/") - self.lastConfirm = GetNotice(self.xeth, tx, ds) + client := httpclient.New("/tmp/") + self.lastConfirm = GetNotice(self.xeth, tx, client) } return true } diff --git a/common/path.go b/common/path.go index 1253c424c..39eacacee 100644 --- a/common/path.go +++ b/common/path.go @@ -23,8 +23,6 @@ import ( "path/filepath" "runtime" "strings" - - "github.com/kardianos/osext" ) // MakeName creates a node name that follows the ethereum convention @@ -65,48 +63,18 @@ func AbsolutePath(Datadir string, filename string) string { return filepath.Join(Datadir, filename) } -func DefaultAssetPath() string { - var assetPath string - pwd, _ := os.Getwd() - srcdir := filepath.Join(os.Getenv("GOPATH"), "src", "github.com", "ethereum", "go-ethereum", "cmd", "mist") - - // If the current working directory is the go-ethereum dir - // assume a debug build and use the source directory as - // asset directory. - if pwd == srcdir { - assetPath = filepath.Join(pwd, "assets") +func HomeDir() (home string) { + if usr, err := user.Current(); err == nil { + home = usr.HomeDir } else { - switch runtime.GOOS { - case "darwin": - // Get Binary Directory - exedir, _ := osext.ExecutableFolder() - assetPath = filepath.Join(exedir, "..", "Resources") - case "linux": - assetPath = filepath.Join("usr", "share", "mist") - case "windows": - assetPath = filepath.Join(".", "assets") - default: - assetPath = "." - } - } - - // Check if the assetPath exists. If not, try the source directory - // This happens when binary is run from outside cmd/mist directory - if _, err := os.Stat(assetPath); os.IsNotExist(err) { - assetPath = filepath.Join(srcdir, "assets") + home = os.Getenv("HOME") } - - return assetPath + return } func DefaultDataDir() string { // Try to place the data folder in the user's home dir - var home string - if usr, err := user.Current(); err == nil { - home = usr.HomeDir - } else { - home = os.Getenv("HOME") - } + home := HomeDir() if home != "" { if runtime.GOOS == "darwin" { return filepath.Join(home, "Library", "Ethereum") |