Method Connect

onchain/eth_proxy.go:124–232

(urls []string, t time.Time)

}

func (e *ethAdaptor) Connect(urls []string, t time.Time) (err error) {
	if e.isConnecting() {
		err = errors.Errorf("connection existing")
		return
	}

	var httpUrls []string
	var wsUrls []string
	for _, url := range urls {
		if strings.Contains(url, "http") {
			httpUrls = append(httpUrls, url)
		} else if strings.Contains(url, "ws") {
			wsUrls = append(wsUrls, url)
		}
	}
	e.wsUrls = wsUrls
	if len(wsUrls) == 0 {
		return errors.New("no web socket URL")
	}

	e.ctx, e.cancelFunc = context.WithCancel(context.Background())
	e.clients = nil
	e.proxies = nil
	e.crs = nil
	e.ctxes = nil
	e.cancels = nil

	dialCtx, dialCancel := context.WithDeadline(e.ctx, t)
	defer dialCancel()

	results := DialToEth(dialCtx, e.wsUrls)
	for result := range results {
		if result.Err != nil {
			e.logger.Error(errors.Errorf(": %w", result.Err))
			continue
		}
		client := result.Client
		bridge, err := dosbridge.NewDosbridge(e.bridgeAddr, client)
		if err != nil {
			e.logger.Error(errors.Errorf(": %w", err))
			client.Close()
			continue
		}
		proxyAddr, err := bridge.GetProxyAddress(&bind.CallOpts{Context: dialCtx})
		if err != nil {
			e.logger.Error(errors.Errorf(": %w", err))
			client.Close()
			continue
		}
		commitRevealAddr, err := bridge.GetCommitRevealAddress(&bind.CallOpts{Context: dialCtx})
		if err != nil {
			e.logger.Error(errors.Errorf(": %w", err))
			client.Close()
			continue
		}

		bootStrapUrl, err := bridge.GetBootStrapUrl(&bind.CallOpts{Context: dialCtx})
		if err != nil {