(cfg Configuration)
| 109 | } |
| 110 | |
| 111 | func fetchNetworkIDBytes(cfg Configuration) ([]byte, error) { |
| 112 | cl := NewRPCProxyClient(cfg.Logger, cfg.ProxyURL, cfg.ProxyTimeoutSeconds) |
| 113 | |
| 114 | _req := types.NewJSONRPCRequest(1, "net_version", []interface{}{}) |
| 115 | jsonData, err := json.Marshal(_req) |
| 116 | if err != nil { |
| 117 | return nil, errors.Wrap(err, "network version request failed") |
| 118 | } |
| 119 | httpRes, err := cl.ProxyRequest(jsonData) |
| 120 | if err != nil { |
| 121 | return nil, errors.Wrap(err, "cl.NetworkID error") |
| 122 | } |
| 123 | |
| 124 | resBytes, err := io.ReadAll(httpRes.Body) |
| 125 | httpRes.Body.Close() |
| 126 | if err != nil { |
| 127 | return nil, err |
| 128 | } |
| 129 | _res, err := respBytesToJSONRPCResponse(resBytes) |
| 130 | if err != nil { |
| 131 | return nil, err |
| 132 | } |
| 133 | |
| 134 | return _res.Result, nil |
| 135 | } |
| 136 | |
| 137 | func (s *RPCEndPointServer) Start() { |
| 138 | s.logger.Info("Starting rpc endpoint...", zap.String("version", s.version), zap.String("listenAddress", s.listenAddress)) |
no test coverage detected