mirror of
https://gitlab.com/pulsechaincom/prysm-pulse.git
synced 2024-12-25 21:07:18 +00:00
76 lines
2.5 KiB
Go
76 lines
2.5 KiB
Go
// Package main allows for creation of an HTTP-JSON to gRPC
|
|
// gateway as a binary go process.
|
|
package main
|
|
|
|
import (
|
|
"context"
|
|
"flag"
|
|
"fmt"
|
|
"net/http"
|
|
"strings"
|
|
|
|
joonix "github.com/joonix/log"
|
|
beaconGateway "github.com/prysmaticlabs/prysm/beacon-chain/gateway"
|
|
"github.com/prysmaticlabs/prysm/beacon-chain/rpc/apimiddleware"
|
|
"github.com/prysmaticlabs/prysm/shared/gateway"
|
|
_ "github.com/prysmaticlabs/prysm/shared/maxprocs"
|
|
"github.com/sirupsen/logrus"
|
|
)
|
|
|
|
var (
|
|
beaconRPC = flag.String("beacon-rpc", "localhost:4000", "Beacon chain gRPC endpoint")
|
|
port = flag.Int("port", 8000, "Port to serve on")
|
|
ethApiPort = flag.Int("port", 8001, "Port to serve Ethereum API on")
|
|
host = flag.String("host", "127.0.0.1", "Host to serve on")
|
|
debug = flag.Bool("debug", false, "Enable debug logging")
|
|
allowedOrigins = flag.String("corsdomain", "localhost:4242", "A comma separated list of CORS domains to allow")
|
|
enableDebugRPCEndpoints = flag.Bool("enable-debug-rpc-endpoints", false, "Enable debug rpc endpoints such as /eth/v1alpha1/beacon/state")
|
|
grpcMaxMsgSize = flag.Int("grpc-max-msg-size", 1<<22, "Integer to define max recieve message call size")
|
|
)
|
|
|
|
func init() {
|
|
logrus.SetFormatter(joonix.NewFormatter())
|
|
}
|
|
|
|
func main() {
|
|
flag.Parse()
|
|
if *debug {
|
|
log.SetLevel(logrus.DebugLevel)
|
|
}
|
|
|
|
gatewayConfig := beaconGateway.DefaultConfig(*enableDebugRPCEndpoints)
|
|
|
|
gw := gateway.New(
|
|
context.Background(),
|
|
[]gateway.PbMux{gatewayConfig.V1Alpha1PbMux, gatewayConfig.V1PbMux},
|
|
gatewayConfig.Handler,
|
|
*beaconRPC,
|
|
fmt.Sprintf("%s:%d", *host, *port),
|
|
).WithAllowedOrigins(strings.Split(*allowedOrigins, ",")).
|
|
WithMaxCallRecvMsgSize(uint64(*grpcMaxMsgSize)).
|
|
WithApiMiddleware(fmt.Sprintf("%s:%d", *host, *ethApiPort), &apimiddleware.BeaconEndpointFactory{})
|
|
|
|
mux := http.NewServeMux()
|
|
mux.HandleFunc("/swagger/", gateway.SwaggerServer())
|
|
mux.HandleFunc("/healthz", healthzServer(gw))
|
|
gw = gw.WithMux(mux)
|
|
|
|
gw.Start()
|
|
|
|
select {}
|
|
}
|
|
|
|
// healthzServer returns a simple health handler which returns ok.
|
|
func healthzServer(gw *gateway.Gateway) http.HandlerFunc {
|
|
return func(w http.ResponseWriter, r *http.Request) {
|
|
w.Header().Set("Content-Type", "text/plain")
|
|
if err := gw.Status(); err != nil {
|
|
http.Error(w, err.Error(), http.StatusBadGateway)
|
|
return
|
|
}
|
|
if _, err := fmt.Fprintln(w, "ok"); err != nil {
|
|
log.WithError(err).Error("failed to respond to healthz")
|
|
}
|
|
}
|
|
}
|