Method StartCommitReveal

onchain/eth_set.go:461–490

(startBlock int64, commitDuration int64, revealDuration int64, revealThreshold int64)

}

func (e *ethAdaptor) StartCommitReveal(startBlock int64, commitDuration int64, revealDuration int64, revealThreshold int64) (err error) {
	if !e.isConnecting() {
		err = errors.New("not connecting to geth")
		return
	}

	// define how to parse parameters and execute proxy function
	opCtx, opCancel := context.WithTimeout(e.ctx, e.setTimeout)
	defer opCancel()
	crs := e.crs

	f := func(ctx context.Context) (tx *types.Transaction, err error) {
		idx := getIndex(ctx)
		if idx == -1 {
			err = errors.New("no client index in context")
		} else {
			tx, err = crs[idx].StartCommitReveal(big.NewInt(startBlock), big.NewInt(commitDuration), big.NewInt(revealDuration), big.NewInt(revealThreshold))
			if err != nil {
				err = &OnchainError{err: errors.Errorf(": %w", err), Idx: idx}
			} else {
				e.logger.Info(fmt.Sprintf("StartCommitReveal %x", tx.Hash()))
			}
		}
		if err != nil {
			e.logger.Error(err)
		}
		return
	}
	return e.waitForReply(&request{opCtx: opCtx, f: f, reply: make(chan *response)})
}

func (e *ethAdaptor) Commit(cid *big.Int, commitment [32]byte) (err error) {
	if !e.isConnecting() {