forked from ethereum-optimism/optimism
-
Notifications
You must be signed in to change notification settings - Fork 3
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #14 from EspressoSystems/proxy
Forward OP transactions to sequencer
- Loading branch information
Showing
4 changed files
with
155 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,15 @@ | ||
| Simple proxy service that parses payload data from an `eth_sendRawTransacton` RPC request and forwards it to Espresso sequencer. | ||
|
|
||
| ### Usage | ||
| Default configuration: | ||
| ``` bash | ||
| go run get-proxy.go | ||
| ``` | ||
| With CLI flags: | ||
| ```bash | ||
| go run geth-proxy.go -listen-addr "127.0.0.1:9091" -vm-id 2 | ||
| ``` | ||
| With env vars: | ||
| ``` | ||
| OP_GETH_PROXY_LISTEN_ADDR=127.0.0.1:9095 go run geth-proxy.go | ||
| ``` |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,126 @@ | ||
| package main | ||
|
|
||
| import ( | ||
| "bytes" | ||
| "encoding/hex" | ||
| "encoding/json" | ||
| "flag" | ||
| "io" | ||
| "log" | ||
| "net/http" | ||
| "net/http/httputil" | ||
| "net/url" | ||
| "os" | ||
|
|
||
| "github.com/peterbourgon/ff/v3" | ||
| ) | ||
|
|
||
| // Environment variables beginning with this prefix can be used to instantiate command line flags | ||
| const ENV_PREFIX = "OP_GETH_PROXY" | ||
|
|
||
| var ( | ||
| fs = flag.NewFlagSet("proxy", flag.ContinueOnError) | ||
| fromAddr = fs.String("listen-addr", "127.0.0.1:9090", "proxy's listening adress") | ||
| sequencerAddr = fs.String("seq-addr", "http://127.0.0.1:50000", "address of espresso sequencer") | ||
| gethAddr = fs.String("geth-addr", "http://127.0.0.1:8545", "address of the op-geth node") | ||
| vm_id = fs.Int("vm-id", 1, "VM ID of the OP rollup instance") | ||
| ) | ||
|
|
||
| type Transaction struct { | ||
| Vm int `json:"vm"` | ||
| Payload []int `json:"payload"` | ||
| } | ||
|
|
||
| type rpcMessage struct { | ||
| Params []json.RawMessage `json:"params,omitempty"` | ||
| Method string `json:"method,omitempty"` | ||
| } | ||
|
|
||
| func ForwardToSequencer(message rpcMessage) { | ||
| var hexString string | ||
| if err := json.Unmarshal(message.Params[0], &hexString); err != nil { | ||
| log.Println("Error decoding params field of the rpc message.") | ||
| return | ||
| } | ||
| var txnBytes, err = hex.DecodeString(hexString[2:]) | ||
| if err != nil { | ||
| log.Println("Error decoding hex string. The first raw transaction parameter must be valid hex.") | ||
| return | ||
| } | ||
|
|
||
| // json.RawMessage is a []byte array, which is marshalled | ||
| // As a base64-encoded string. Our sequencer API expects a JSON array. | ||
| payload := make([]int, len(txnBytes)) | ||
| for i := range payload { | ||
| payload[i] = int(txnBytes[i]) | ||
| } | ||
|
|
||
| // Construct a transaction and send it to the sequencer | ||
| txn := Transaction{ | ||
| Vm: *vm_id, | ||
| Payload: payload, | ||
| } | ||
| marshalled, err := json.Marshal(txn) | ||
| if err != nil { | ||
| panic(err) | ||
| } | ||
| request, err := http.NewRequest("POST", *sequencerAddr+"/submit/submit", bytes.NewBuffer(marshalled)) | ||
| if err != nil { | ||
| panic(err) | ||
| } | ||
| request.Header.Set("Content-Type", "application/json") | ||
| client := &http.Client{} | ||
| log.Println("Transaction recieved, forwarding to sequencer.") | ||
| response, err := client.Do(request) | ||
| if err != nil { | ||
| log.Println("Failed to connect to the sequencer: ", err) | ||
| return | ||
| } | ||
| if response.StatusCode != 200 { | ||
| log.Println("Request failed. Here is the response: ", err) | ||
| } | ||
| } | ||
|
|
||
| type baseHandle struct{} | ||
|
|
||
| func (h *baseHandle) ServeHTTP(w http.ResponseWriter, r *http.Request) { | ||
| toUrl, err := url.Parse(*gethAddr) | ||
| if err != nil { | ||
| panic(err) | ||
| } | ||
| proxy := httputil.NewSingleHostReverseProxy(toUrl) | ||
| body, err := io.ReadAll(r.Body) | ||
| if err != nil { | ||
| panic(err) | ||
| } | ||
| // Once we've read the body, we need to replace it with another reader because | ||
| // ReadAll can only be called once: https://blog.flexicondev.com/read-go-http-request-body-multiple-times | ||
| r.Body = io.NopCloser(bytes.NewBuffer(body)) | ||
|
|
||
| var message rpcMessage | ||
| if err := json.Unmarshal(body, &message); err != nil { | ||
| log.Println("Invalid request: expected RPC message") | ||
| return | ||
| } | ||
| // Check for sendRawTransaction | ||
| if message.Method == "eth_sendRawTransaction" { | ||
| ForwardToSequencer(message) | ||
| } | ||
| proxy.ServeHTTP(w, r) | ||
| } | ||
|
|
||
| func main() { | ||
| if err := ff.Parse(fs, os.Args[1:], ff.WithEnvVarPrefix(ENV_PREFIX)); err != nil { | ||
| panic(err) | ||
| } | ||
|
|
||
| h := &baseHandle{} | ||
| http.Handle("/", h) | ||
|
|
||
| log.Println("Starting proxy server on", *fromAddr) | ||
| server := &http.Server{ | ||
| Addr: *fromAddr, | ||
| Handler: h, | ||
| } | ||
| log.Fatal(server.ListenAndServe()) | ||
| } |