Method IsPendingNode

onchain/eth_get.go:488–528

(id []byte)

	return
}
func (e *ethAdaptor) IsPendingNode(id []byte) (result bool, err error) {
	if !e.isConnecting() {
		err = errors.New("not connecting to geth")
	}
	proxies := e.proxies
	addr := common.Address{}
	addr.SetBytes(id)
	f := func(ctx context.Context) (chan interface{}, chan error) {
		outc := make(chan interface{})
		errc := make(chan error)
		go func() {
			defer close(outc)
			defer close(errc)
			idx := getIndex(ctx)
			if idx == -1 {
				err = errors.New("no client index in context")
			} else {
				if val, err := proxies[idx].PendingNodeList(addr); err != nil {
					replyError(ctx, errc, &OnchainError{err: errors.Errorf("get err : %w", err), Idx: idx})
				} else {
					utils.ReportResult(ctx, outc, val)
				}
			}
		}()
		return outc, errc
	}
	var r interface{}
	if r, err = e.get(f); err != nil {
		return
	}
	if v, ok := r.(common.Address); ok {
		if v.Big().Cmp(big.NewInt(0)) == 0 {
			result = false
		} else {
			result = true
		}
	} else {
		err = errors.New("casting error")
	}
	return
}
func (e *ethAdaptor) BootstrapRound() (result uint64, err error) {
	if !e.isConnecting() {
		err = errors.New("not connecting to geth")