Function WaitBPChainService

test/helper.go:36–57

WaitBPChainService waits until BP chain service is ready.

(ctx context.Context, period time.Duration)

// WaitBPChainService waits until BP chain service is ready.
func WaitBPChainService(ctx context.Context, period time.Duration) (err error) {
	var (
		ticker = time.NewTicker(period)
		req    = &types.FetchBlockReq{
			Height: 0, // Genesis block
		}
	)
	defer ticker.Stop()
	for {
		select {
		case <-ticker.C:
			if err = rpc.RequestBP(
				route.MCCFetchBlock.String(), req, nil,
			); err == nil || !strings.Contains(err.Error(), "can't find service") {
				return
			}
		case <-ctx.Done():
			err = ctx.Err()
			return
		}
	}
}

// Create allocates new database.
func Create(