Method Call

executor/http_executor.go:291–332

(ctx ExecutionContext, writer output.OutputWriter, logger log.Logger)

}

func (e HttpExecutor) Call(ctx ExecutionContext, writer output.OutputWriter, logger log.Logger) error {
	uri, err := e.formatUri(ctx.BaseUri, ctx.Route, e.pathParameters(ctx), ctx.Parameters.Query())
	if err != nil {
		return err
	}
	context, cancel := context.WithCancelCause(context.Background())
	bodyReader, contentType, contentLength, size := e.writeBody(ctx, cancel)
	uploadBar := visualization.NewProgressBar(logger)
	uploadReader := e.progressReader("uploading...", "completing  ", bodyReader, size, uploadBar)
	defer uploadBar.Remove()

	auth, err := e.executeAuthenticators(ctx, logger, uri.String())
	if err != nil {
		return err
	}

	header := http.Header{}
	if contentType != "" {
		header.Set("Content-Type", contentType)
	}
	e.addHeaders(header, ctx.Parameters.Header())
	request := network.NewHttpRequest(ctx.Method, uri.String(), e.toAuthorization(auth.Token), header, uploadReader, contentLength)

	client := network.NewHttpClient(logger, e.httpClientSettings(ctx))
	response, err := client.SendWithContext(request, context)
	if err != nil {
		return err
	}
	defer func() { _ = response.Body.Close() }()
	downloadBar := visualization.NewProgressBar(logger)
	downloadReader := e.progressReader("downloading...", "completing    ", response.Body, response.ContentLength, downloadBar)
	defer downloadBar.Remove()
	body, err := io.ReadAll(downloadReader)
	if err != nil {
		return fmt.Errorf("Error reading response body: %w", err)
	}
	err = writer.WriteResponse(*output.NewResponseInfo(response.StatusCode, response.Status, response.Proto, response.Header, bytes.NewReader(body)))
	if err != nil {
		return err
	}
	return nil
}

func NewHttpExecutor(authenticators []auth.Authenticator) *HttpExecutor {
	return &HttpExecutor{authenticators}