fix(worker): Fix worker HttpResponse header handling.

nitrictech · Jun 27, 2021 · dc0a937 · dc0a937
1 parent 86769cf
commit dc0a937
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/triggers/http_response.go b/triggers/http_response.go
@@ -49,7 +49,7 @@ func FromTriggerResponse(triggerResponse *pb.TriggerResponse) (*HttpResponse, er
 
 		if httpContext.GetHeaders() != nil {
 			for key, val := range httpContext.GetHeaders() {
-				fasthttpHeader.Add(key, val)
+				fasthttpHeader.Set(key, val)
 			}
 		}
 

diff --git a/worker/faas_worker.go b/worker/faas_worker.go
@@ -122,7 +122,7 @@ func (s *FaasWorker) HandleHttpRequest(trigger *triggers.HttpRequest) (*triggers
 	fasthttpHeader := &fasthttp.ResponseHeader{}
 
 	for key, val := range httpResponse.GetHeaders() {
-		fasthttpHeader.Add(key, val)
+		fasthttpHeader.Set(key, val)
 	}
 
 	response := &triggers.HttpResponse{

diff --git a/worker/http_worker.go b/worker/http_worker.go
@@ -67,7 +67,7 @@ func (h *HttpWorker) HandleHttpRequest(trigger *triggers.HttpRequest) (*triggers
 	}
 
 	for key, val := range trigger.Header {
-		httpRequest.Header.Add(key, val)
+		httpRequest.Header.Set(key, val)
 	}
 
 	httpRequest.Header.Del("Content-Length")