Method connectServer

cmd/cql-eth-exchange/exchange.go:188–226

(ctx context.Context)

}

func (e *Exchange) connectServer(ctx context.Context) (err error) {
	e.stopPreviousSubscribe()

	e.rawClient, err = rpc.DialContext(ctx, e.cfg.Endpoint)
	if err != nil {
		return
	}

	e.client = ethclient.NewClient(e.rawClient)

	e.subClient, err = ethclient.DialContext(ctx, e.cfg.Endpoint)
	if err != nil {
		return
	}

	e.subscription, err = e.subClient.SubscribeNewHead(ctx, e.newBlockHeaderCh)
	if err != nil {
		return
	}

	e.chainID, err = e.getChainID()
	if err != nil {
		return
	}
	switch e.chainID {
	case params.MainnetChainConfig.ChainID.Int64():
		e.chainCfg = params.MainnetChainConfig
	case params.TestnetChainConfig.ChainID.Int64():
		e.chainCfg = params.TestnetChainConfig
	case params.RinkebyChainConfig.ChainID.Int64():
		e.chainCfg = params.RinkebyChainConfig
	case params.GoerliChainConfig.ChainID.Int64():
		e.chainCfg = params.GoerliChainConfig
	default:
		e.chainCfg = params.AllEthashProtocolChanges
	}

	return
}

func (e *Exchange) fetchOldBlocks(ctx context.Context) (err error) {
	var blk *types.Block