feat: allow mirroring of getPayload calls

Author: 0x416e746f6e

cmd/serve.go

@@ -318,6 +318,14 @@ func CommandServe(cfg *config.Config) *cli.Command {
 			Name:        categoryAuthrpc + "-deduplicate-fcus",
 			Usage:       "deduplicate repetitive fcu messages",
 		},
+
+		&cli.BoolFlag{ // --authrpc-mirror-get-payload
+			Category:    strings.ToUpper(categoryAuthrpc),
+			Destination: &cfg.Authrpc.MirrorGetPayload,
+			EnvVars:     []string{envPrefix + strings.ToUpper(categoryAuthrpc) + "_MIRROR_GET_PAYLOAD"},
+			Name:        categoryAuthrpc + "-mirror-get-payload",
+			Usage:       "mirror getPayload calls as well",
+		},
 	)
 
 	flashblocksFlags := []cli.Flag{ // --flashblocks-xxx

config/authrpc.go

@@ -3,5 +3,6 @@ package config
 type Authrpc struct {
 	*HttpProxy `yaml:"proxy"`
 
-	DeduplicateFCUs bool `yaml:"deduplicate_fcus"`
+	DeduplicateFCUs  bool `yaml:"deduplicate_fcus"`
+	MirrorGetPayload bool `yaml:"mirror_get_payload"`
 }

proxy/authrpc.go

@@ -32,7 +32,8 @@ type Authrpc struct {
 }
 
 type authrpcConfig struct {
-	deduplicateFCUs bool
+	deduplicateFCUs  bool
+	mirrorGetPayload bool
 }
 
 func NewAuthrpc(
@@ -53,7 +54,8 @@ func NewAuthrpc(
 		tickerSeenHeads: time.NewTicker(30 * time.Second),
 
 		cfg: &authrpcConfig{
-			deduplicateFCUs: cfg.DeduplicateFCUs,
+			deduplicateFCUs:  cfg.DeduplicateFCUs,
+			mirrorGetPayload: cfg.MirrorGetPayload,
 		},
 	}
 	ap.proxy.triage = ap.triage
@@ -151,6 +153,7 @@ func (p *Authrpc) triage(ctx *fasthttp.RequestCtx) (
 		return &triaged.Request{
 			Proxy:      true,
 			Prioritise: true,
+			Mirror:     p.cfg.mirrorGetPayload,
 			JrpcID:     call.GetID(),
 			JrpcMethod: call.GetMethod(),
 		}, fasthttp.AcquireResponse()

readme.md

@@ -32,6 +32,7 @@ OPTIONS:
    --authrpc-max-client-connections-per-ip count                                                    maximum authrpc client tcp connections count per ip (0 means unlimited) (default: 0) [$BPROXY_AUTHRPC_MAX_CLIENT_CONNECTIONS_PER_IP]
    --authrpc-max-request-size megabytes                                                             maximum authrpc request payload size in megabytes (default: 15) [$BPROXY_AUTHRPC_MAX_REQUEST_SIZE]
    --authrpc-max-response-size megabytes                                                            maximum authrpc response payload size in megabytes (default: 160) [$BPROXY_AUTHRPC_MAX_RESPONSE_SIZE]
+   --authrpc-mirror-get-payload                                                                     mirror getPayload calls as well (default: false) [$BPROXY_AUTHRPC_MIRROR_GET_PAYLOAD]
    --authrpc-peer-tls-insecure-skip-verify                                                          do not verify authrpc peers' tls certificates (default: false) [$BPROXY_AUTHRPC_PEER_TLS_INSECURE_SKIP_VERIFY]
    --authrpc-peers urls [ --authrpc-peers urls ]                                                    list of authrpc peers urls to mirror the requests to [$BPROXY_AUTHRPC_PEERS]
    --authrpc-remove-backend-from-peers                                                              remove authrpc backend from peers (default: false) [$BPROXY_AUTHRPC_REMOVE_BACKEND_FROM_PEERS]
@@ -46,19 +47,19 @@ OPTIONS:
    --chaos-authrpc-injected-invalid-jrpc-response-probability percent           probability in percent at which to randomly inject invalid jrpc into responses processed by authrpc proxy (default: 0) [$BPROXY_CHAOS_AUTHRPC_INJECTED_INVALID_JRPC_RESPONSE_PROBABILITY]
    --chaos-authrpc-injected-jrpc-error-probability percent                      probability in percent at which to randomly inject jrpc errors into responses processed by authrpc proxy (default: 0) [$BPROXY_CHAOS_AUTHRPC_INJECTED_JRPC_ERROR_PROBABILITY]
    --chaos-authrpc-max-injected-latency latency                                 max latency to randomly enforce on every response processed by authrpc proxy (default: 0s) [$BPROXY_CHAOS_AUTHRPC_MAX_INJECTED_LATENCY]
-   --chaos-authrpc-min-injected-latency latency                                 min latency to enforce on every response processed by authrpc proxy (default: 100ms) [$BPROXY_CHAOS_AUTHRPC_MIN_INJECTED_LATENCY]
+   --chaos-authrpc-min-injected-latency latency                                 min latency to enforce on every response processed by authrpc proxy (default: 0s) [$BPROXY_CHAOS_AUTHRPC_MIN_INJECTED_LATENCY]
    --chaos-flashblocks-dropped-message-probability percent                      probability in percent at which to randomly drop messages processed by flashblocks proxy (default: 0) [$BPROXY_CHAOS_FLASHBLOCKS_DROPPED_MESSAGE_PROBABILITY]
    --chaos-flashblocks-enabled                                                  whether flashblocks proxy should be injecting artificial error conditions (default: false) [$BPROXY_CHAOS_FLASHBLOCKS_ENABLED]
    --chaos-flashblocks-injected-invalid-flashblock-payload-probability percent  probability in percent at which to randomly inject an invalid flashblock (default: 0) [$BPROXY_CHAOS_FLASHBLOCKS_INJECTED_INVALID_FLASHBLOCK_PAYLOAD_PROBABILITY]
    --chaos-flashblocks-injected-malformed-json-message-probability percent      probability in percent at which to randomly inject a malformed json message (default: 0) [$BPROXY_CHAOS_FLASHBLOCKS_INJECTED_MALFORMED_JSON_MESSAGE_PROBABILITY]
    --chaos-flashblocks-max-injected-latency latency                             max latency to randomly enforce on every response processed by flashblocks proxy (default: 0s) [$BPROXY_CHAOS_FLASHBLOCKS_MAX_INJECTED_LATENCY]
-   --chaos-flashblocks-min-injected-latency latency                             min latency to enforce on every response processed by flashblocks proxy (default: 100ms) [$BPROXY_CHAOS_FLASHBLOCKS_MIN_INJECTED_LATENCY]
+   --chaos-flashblocks-min-injected-latency latency                             min latency to enforce on every response processed by flashblocks proxy (default: 0s) [$BPROXY_CHAOS_FLASHBLOCKS_MIN_INJECTED_LATENCY]
    --chaos-rpc-enabled                                                          whether rpc proxy should be injecting artificial error conditions (default: false) [$BPROXY_CHAOS_RPC_ENABLED]
    --chaos-rpc-injected-http-error-probability percent                          probability in percent at which to randomly inject http errors into responses processed by rpc proxy (default: 0) [$BPROXY_CHAOS_RPC_INJECTED_HTTP_ERROR_PROBABILITY]
    --chaos-rpc-injected-invalid-jrpc-response-probability percent               probability in percent at which to randomly inject invalid jrpc into responses processed by rpc proxy (default: 0) [$BPROXY_CHAOS_RPC_INJECTED_INVALID_JRPC_RESPONSE_PROBABILITY]
    --chaos-rpc-injected-jrpc-error-probability percent                          probability in percent at which to randomly inject jrpc errors into responses processed by rpc proxy (default: 0) [$BPROXY_CHAOS_RPC_INJECTED_JRPC_ERROR_PROBABILITY]
    --chaos-rpc-max-injected-latency latency                                     max latency to randomly enforce on every response processed by rpc proxy (default: 0s) [$BPROXY_CHAOS_RPC_MAX_INJECTED_LATENCY]
-   --chaos-rpc-min-injected-latency latency                                     min latency to enforce on every response processed by rpc proxy (default: 100ms) [$BPROXY_CHAOS_RPC_MIN_INJECTED_LATENCY]
+   --chaos-rpc-min-injected-latency latency                                     min latency to enforce on every response processed by rpc proxy (default: 0s) [$BPROXY_CHAOS_RPC_MIN_INJECTED_LATENCY]
 
    FLASHBLOCKS