mirror of https://github.com/status-im/op-geth.git
191 lines
4.2 KiB
Go
191 lines
4.2 KiB
Go
package comms
|
|
|
|
import (
|
|
"fmt"
|
|
"net/http"
|
|
"strings"
|
|
|
|
"bytes"
|
|
"io/ioutil"
|
|
|
|
"github.com/ethereum/go-ethereum/logger"
|
|
"github.com/ethereum/go-ethereum/logger/glog"
|
|
"github.com/ethereum/go-ethereum/rpc/codec"
|
|
"github.com/ethereum/go-ethereum/rpc/shared"
|
|
"github.com/rs/cors"
|
|
)
|
|
|
|
var (
|
|
// main HTTP rpc listener
|
|
httpListener *stoppableTCPListener
|
|
listenerStoppedError = fmt.Errorf("Listener has stopped")
|
|
)
|
|
|
|
type HttpConfig struct {
|
|
ListenAddress string
|
|
ListenPort uint
|
|
CorsDomain string
|
|
}
|
|
|
|
func StartHttp(cfg HttpConfig, codec codec.Codec, api shared.EthereumApi) error {
|
|
if httpListener != nil {
|
|
if fmt.Sprintf("%s:%d", cfg.ListenAddress, cfg.ListenPort) != httpListener.Addr().String() {
|
|
return fmt.Errorf("RPC service already running on %s ", httpListener.Addr().String())
|
|
}
|
|
return nil // RPC service already running on given host/port
|
|
}
|
|
|
|
l, err := newStoppableTCPListener(fmt.Sprintf("%s:%d", cfg.ListenAddress, cfg.ListenPort))
|
|
if err != nil {
|
|
glog.V(logger.Error).Infof("Can't listen on %s:%d: %v", cfg.ListenAddress, cfg.ListenPort, err)
|
|
return err
|
|
}
|
|
httpListener = l
|
|
|
|
var handler http.Handler
|
|
if len(cfg.CorsDomain) > 0 {
|
|
var opts cors.Options
|
|
opts.AllowedMethods = []string{"POST"}
|
|
opts.AllowedOrigins = strings.Split(cfg.CorsDomain, " ")
|
|
|
|
c := cors.New(opts)
|
|
handler = newStoppableHandler(c.Handler(gethHttpHandler(codec, api)), l.stop)
|
|
} else {
|
|
handler = newStoppableHandler(gethHttpHandler(codec, api), l.stop)
|
|
}
|
|
|
|
go http.Serve(l, handler)
|
|
|
|
return nil
|
|
}
|
|
|
|
func StopHttp() {
|
|
if httpListener != nil {
|
|
httpListener.Stop()
|
|
httpListener = nil
|
|
}
|
|
}
|
|
|
|
type httpClient struct {
|
|
address string
|
|
port uint
|
|
codec codec.ApiCoder
|
|
lastRes interface{}
|
|
lastErr error
|
|
}
|
|
|
|
// Create a new in process client
|
|
func NewHttpClient(cfg HttpConfig, c codec.Codec) *httpClient {
|
|
return &httpClient{
|
|
address: cfg.ListenAddress,
|
|
port: cfg.ListenPort,
|
|
codec: c.New(nil),
|
|
}
|
|
}
|
|
|
|
func (self *httpClient) Close() {
|
|
// do nothing
|
|
}
|
|
|
|
func (self *httpClient) Send(req interface{}) error {
|
|
var body []byte
|
|
var err error
|
|
|
|
self.lastRes = nil
|
|
self.lastErr = nil
|
|
|
|
if body, err = self.codec.Encode(req); err != nil {
|
|
return err
|
|
}
|
|
|
|
httpReq, err := http.NewRequest("POST", fmt.Sprintf("%s:%d", self.address, self.port), bytes.NewBuffer(body))
|
|
if err != nil {
|
|
return err
|
|
}
|
|
httpReq.Header.Set("Content-Type", "application/json")
|
|
|
|
client := http.Client{}
|
|
resp, err := client.Do(httpReq)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
defer resp.Body.Close()
|
|
|
|
if resp.Status == "200 OK" {
|
|
reply, _ := ioutil.ReadAll(resp.Body)
|
|
var rpcSuccessResponse shared.SuccessResponse
|
|
if err = self.codec.Decode(reply, &rpcSuccessResponse); err == nil {
|
|
self.lastRes = rpcSuccessResponse.Result
|
|
self.lastErr = err
|
|
return nil
|
|
} else {
|
|
var rpcErrorResponse shared.ErrorResponse
|
|
if err = self.codec.Decode(reply, &rpcErrorResponse); err == nil {
|
|
self.lastRes = rpcErrorResponse.Error
|
|
self.lastErr = err
|
|
return nil
|
|
} else {
|
|
return err
|
|
}
|
|
}
|
|
}
|
|
|
|
return fmt.Errorf("Not implemented")
|
|
}
|
|
|
|
func (self *httpClient) Recv() (interface{}, error) {
|
|
return self.lastRes, self.lastErr
|
|
}
|
|
|
|
func (self *httpClient) SupportedModules() (map[string]string, error) {
|
|
var body []byte
|
|
var err error
|
|
|
|
payload := shared.Request{
|
|
Id: 1,
|
|
Jsonrpc: "2.0",
|
|
Method: "modules",
|
|
}
|
|
|
|
if body, err = self.codec.Encode(payload); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
req, err := http.NewRequest("POST", fmt.Sprintf("%s:%d", self.address, self.port), bytes.NewBuffer(body))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
req.Header.Set("Content-Type", "application/json")
|
|
|
|
client := http.Client{}
|
|
resp, err := client.Do(req)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
defer resp.Body.Close()
|
|
|
|
if resp.Status == "200 OK" {
|
|
reply, _ := ioutil.ReadAll(resp.Body)
|
|
var rpcRes shared.SuccessResponse
|
|
if err = self.codec.Decode(reply, &rpcRes); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
result := make(map[string]string)
|
|
if modules, ok := rpcRes.Result.(map[string]interface{}); ok {
|
|
for a, v := range modules {
|
|
result[a] = fmt.Sprintf("%s", v)
|
|
}
|
|
return result, nil
|
|
}
|
|
err = fmt.Errorf("Unable to parse module response - %v", rpcRes.Result)
|
|
} else {
|
|
fmt.Printf("resp.Status = %s\n", resp.Status)
|
|
fmt.Printf("err = %v\n", err)
|
|
}
|
|
|
|
return nil, err
|
|
}
|