Method submit

core/transact.go:299–334

POST /submit-transaction

(ctx context.Context, x submitArg)

// POST /submit-transaction
func (a *API) submit(ctx context.Context, x submitArg) (interface{}, error) {
	if a.leader.State() != leader.Leading {
		var resp json.RawMessage
		err := a.forwardToLeader(ctx, "/submit-transaction", x, &resp)
		return resp, err
	}

	// Setup a timeout for the provided wait duration.
	timeout := x.wait.Duration
	if timeout <= 0 {
		timeout = 30 * time.Second
	}
	ctx, cancel := context.WithTimeout(ctx, timeout)
	defer cancel()

	responses := make([]interface{}, len(x.Transactions))
	var wg sync.WaitGroup
	wg.Add(len(responses))
	for i := range responses {
		go func(i int) {
			subctx := reqid.NewSubContext(ctx, reqid.New())
			defer wg.Done()
			defer batchRecover(subctx, &responses[i])

			tx, err := a.submitSingle(subctx, &x.Transactions[i], x.WaitUntil)
			if err != nil {
				responses[i] = err
			} else {
				responses[i] = tx
			}
		}(i)
	}

	wg.Wait()
	return responses, nil
}