Method executeWait

commandline/command_builder.go:370–388

(ctx executor.ExecutionContext, outputFormat string, query string, wait string, waitTimeout int)

}

func (b CommandBuilder) executeWait(ctx executor.ExecutionContext, outputFormat string, query string, wait string, waitTimeout int) error {
	logger := log.NewDefaultLogger(b.StdErr)
	outputWriter := output.NewMemoryOutputWriter()
	for start := time.Now(); time.Since(start) < time.Duration(waitTimeout)*time.Second; {
		err := b.execute(ctx, "json", "", outputWriter)
		result, evaluationErr := b.evaluateWaitCondition(outputWriter.Response(), wait)
		if evaluationErr != nil {
			return evaluationErr
		}
		if result {
			resultWriter := b.outputWriter(b.StdOut, outputFormat, query)
			_ = resultWriter.WriteResponse(outputWriter.Response())
			return err
		}
		logger.LogError("Condition is not met yet. Waiting...\n")
		time.Sleep(1 * time.Second)
	}
	return errors.New("Timed out waiting for condition")
}

func (b CommandBuilder) evaluateWaitCondition(response output.ResponseInfo, wait string) (bool, error) {
	body, err := io.ReadAll(response.Body)