| 24 | ) |
| 25 | |
| 26 | func ConvertProxyRequestToHTTP(reqInfo *RequestInfo) (request *http.Request, cancel func()) { |
| 27 | req := reqInfo.Input.Request |
| 28 | ctx, cancel := context.WithCancel(context.Background()) |
| 29 | request, _ = http.NewRequestWithContext(ctx, "POST", "http://unix", reqInfo.Input.Request.BodyStream) |
| 30 | for k, v := range req.Headers { |
| 31 | request.Header.Set(k, v) |
| 32 | } |
| 33 | // TODO: add client context |
| 34 | request.Header.Set(api.HeaderXRequestID, reqInfo.RequestID) |
| 35 | return request, cancel |
| 36 | } |
| 37 | |
| 38 | func ConvertHTTPResponseToProxy(rsp *http.Response, reqInfo *RequestInfo) { |
| 39 | output := reqInfo.Output.Output |