Extend Http Request Executor Parameters With Response Body Transformer (#10)

Author: Nizamski

internal/executors/http/http_executor.go

@@ -192,6 +192,7 @@ func execute(c http.Client, p *HttpRequestParameters, authHeader AuthorizationHe
 		Content(string(body)),
 		Headers(resp.Header),
 		StatusCode(resp.StatusCode),
+		ResponseBodyTransformer(p.responseBodyTransformer),
 		IsSuccessfulBasedOnSuccessResponseCodes(resp.StatusCode, p.successResponseCodes),
 		Time(<-timeCh),
 	)

internal/executors/http/http_executor_parameters.go

@@ -7,47 +7,49 @@ import (
 )
 
 const (
-	METHOD                 string = "method"
-	URL                    string = "url"
-	TOKEN_URL              string = "tokenUrl"
-	CSRF_URL               string = "csrfUrl"
-	CLIENT_ID              string = "clientId"
-	CLIENT_SECRET          string = "clientSecret"
-	REFRESH_TOKEN          string = "refreshToken"
-	HEADERS                string = "headers"
-	BODY                   string = "body"
-	USER                   string = "user"
-	PASSWORD               string = "password"
-	TIMEOUT                string = "timeout"
-	SUCCESS_RESPONSE_CODES string = "successResponseCodes"
-	SUCCEED_ON_TIMEOUT     string = "succeedOnTimeout"
-	TRUSTED_CERTS          string = "trustedCerts"
-	CLIENT_CERT            string = "clientCert"
-	TRUST_ANY_CERT         string = "trustAnyCert"
-	AUTHORIZATION_HEADER   string = "authorizationHeader"
+	METHOD                    string = "method"
+	URL                       string = "url"
+	TOKEN_URL                 string = "tokenUrl"
+	CSRF_URL                  string = "csrfUrl"
+	CLIENT_ID                 string = "clientId"
+	CLIENT_SECRET             string = "clientSecret"
+	REFRESH_TOKEN             string = "refreshToken"
+	RESPONSE_BODY_TRANSFORMER string = "responseBodyTransformer"
+	HEADERS                   string = "headers"
+	BODY                      string = "body"
+	USER                      string = "user"
+	PASSWORD                  string = "password"
+	TIMEOUT                   string = "timeout"
+	SUCCESS_RESPONSE_CODES    string = "successResponseCodes"
+	SUCCEED_ON_TIMEOUT        string = "succeedOnTimeout"
+	TRUSTED_CERTS             string = "trustedCerts"
+	CLIENT_CERT               string = "clientCert"
+	TRUST_ANY_CERT            string = "trustAnyCert"
+	AUTHORIZATION_HEADER      string = "authorizationHeader"
 )
 
 var (
 	defaultSuccessResponseCodes [1]string = [...]string{"2xx"}
 )
 
 type HttpRequestParameters struct {
-	method               string
-	url                  string
-	tokenUrl             string
-	csrfUrl              string
-	clientId             string
-	clientSecret         string
-	refreshToken         string
-	headers              map[string]string
-	body                 string
-	user                 string
-	password             string
-	timeout              uint64
-	successResponseCodes []string
-	succeedOnTimeout     bool
-	certAuthentication   *tls.CertificateAuthentication
-	authorizationHeader  string
+	method                  string
+	url                     string
+	tokenUrl                string
+	csrfUrl                 string
+	clientId                string
+	clientSecret            string
+	refreshToken            string
+	responseBodyTransformer string
+	headers                 map[string]string
+	body                    string
+	user                    string
+	password                string
+	timeout                 uint64
+	successResponseCodes    []string
+	succeedOnTimeout        bool
+	certAuthentication      *tls.CertificateAuthentication
+	authorizationHeader     string
 }
 
 func NewHttpRequestParametersFromContext(ctx executors.ExecutorContext) *HttpRequestParameters {
@@ -59,6 +61,7 @@ func NewHttpRequestParametersFromContext(ctx executors.ExecutorContext) *HttpReq
 		withClientIdFromContext(&ctx),
 		withClientSecretFromContext(&ctx),
 		withRefreshTokenFromContext(&ctx),
+		withResponseBodyTransformerFromContext(&ctx),
 		withHeadersFromContext(&ctx),
 		withBodyFromContext(&ctx),
 		withUserFromContext(&ctx),
@@ -318,6 +321,15 @@ func withRefreshTokenFromContext(ctx *executors.ExecutorContext) functional.Opti
 	}
 }
 
+func withResponseBodyTransformerFromContext(ctx *executors.ExecutorContext) functional.OptionWithError[HttpRequestParameters] {
+	return func(hrp *HttpRequestParameters) error {
+		t := ctx.GetString(RESPONSE_BODY_TRANSFORMER)
+
+		hrp.responseBodyTransformer = t
+		return nil
+	}
+}
+
 func withHeadersFromContext(ctx *executors.ExecutorContext) functional.OptionWithError[HttpRequestParameters] {
 	return func(hrp *HttpRequestParameters) error {
 		h, err := ctx.GetMap(HEADERS)

internal/executors/http/http_response.go

@@ -14,14 +14,15 @@ import (
 type HttpHeaders map[string]string
 
 type HttpResponse struct {
-	Url         string      `json:"url"`
-	Method      string      `json:"method"`
-	Content     string      `json:"body"`
-	Headers     HttpHeaders `json:"headers"`
-	StatusCode  string      `json:"status"`
-	SizeInBytes uint        `json:"size"`
-	Time        int64       `json:"time"`
-	successful  bool
+	Url                     string      `json:"url"`
+	Method                  string      `json:"method"`
+	Content                 string      `json:"body"`
+	Headers                 HttpHeaders `json:"headers"`
+	StatusCode              string      `json:"status"`
+	SizeInBytes             uint        `json:"size"`
+	Time                    int64       `json:"time"`
+	ResponseBodyTransformer string      `json:"responseBodyTransformer"`
+	successful              bool
 }
 
 func NewHttpResponse(opts ...functional.OptionWithError[HttpResponse]) (*HttpResponse, error) {
@@ -106,6 +107,13 @@ func Time(time int64) functional.OptionWithError[HttpResponse] {
 	}
 }
 
+func ResponseBodyTransformer(transformer string) functional.OptionWithError[HttpResponse] {
+	return func(hr *HttpResponse) error {
+		hr.ResponseBodyTransformer = transformer
+		return nil
+	}
+}
+
 func IsSuccessfulBasedOnSuccessResponseCodes(statusCode int, successResponseCodes []string) functional.OptionWithError[HttpResponse] {
 	return func(hr *HttpResponse) error {
 		isSuccessful, err4 := isSuccessfulResponseCode(uint16(statusCode), successResponseCodes...)