kopia lustrzana https://github.com/bugout-dev/moonstream
71 wiersze
2.1 KiB
Go
71 wiersze
2.1 KiB
Go
package cmd
|
|
|
|
import (
|
|
"bytes"
|
|
"encoding/json"
|
|
"fmt"
|
|
"io/ioutil"
|
|
"log"
|
|
"net/http"
|
|
"strconv"
|
|
"strings"
|
|
|
|
settings "github.com/bugout-dev/moonstream/nodes/server/configs"
|
|
)
|
|
|
|
func pingRoute(w http.ResponseWriter, req *http.Request) {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
response := PingResponse{Status: "ok"}
|
|
json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
// Fetch latest block from Geth
|
|
func (es *extendedServer) pingGethRoute(w http.ResponseWriter, req *http.Request) {
|
|
postBody, err := json.Marshal(map[string]interface{}{
|
|
"jsonrpc": "2.0",
|
|
"method": "eth_blockNumber",
|
|
"params": []string{},
|
|
"id": 1,
|
|
})
|
|
if err != nil {
|
|
log.Printf("An error occurred due marshal postBody, error: %s", err)
|
|
http.Error(w, http.StatusText(500), http.StatusInternalServerError)
|
|
return
|
|
}
|
|
if es.blockchain != "ethereum" && es.blockchain != "polygon" {
|
|
log.Printf("Unaccepted blockchain type: %s", es.blockchain)
|
|
http.Error(w, http.StatusText(400), http.StatusBadRequest)
|
|
return
|
|
}
|
|
MOONSTREAM_WEB3_PROVIDER_URI := fmt.Sprintf("http://%s:8545", settings.LOCAL_IPV4)
|
|
gethResponse, err := http.Post(MOONSTREAM_WEB3_PROVIDER_URI, "application/json",
|
|
bytes.NewBuffer(postBody))
|
|
if err != nil {
|
|
log.Printf("Unable to request geth, error: %s", err)
|
|
http.Error(w, http.StatusText(500), http.StatusInternalServerError)
|
|
return
|
|
}
|
|
defer gethResponse.Body.Close()
|
|
|
|
gethResponseBody, err := ioutil.ReadAll(gethResponse.Body)
|
|
if err != nil {
|
|
log.Printf("Unable to read geth response, error: %s", err)
|
|
http.Error(w, http.StatusText(500), http.StatusInternalServerError)
|
|
return
|
|
}
|
|
var obj GethResponse
|
|
_ = json.Unmarshal(gethResponseBody, &obj)
|
|
|
|
blockNumberHex := strings.Replace(obj.Result, "0x", "", -1)
|
|
blockNumberStr, err := strconv.ParseUint(blockNumberHex, 16, 64)
|
|
if err != nil {
|
|
log.Printf("Unable to parse block number from hex to string, error: %s", err)
|
|
http.Error(w, http.StatusText(500), http.StatusInternalServerError)
|
|
return
|
|
}
|
|
|
|
w.Header().Set("Content-Type", "application/json")
|
|
response := PingGethResponse{CurrentBlock: blockNumberStr}
|
|
json.NewEncoder(w).Encode(response)
|
|
}
|