| 469 | } |
| 470 | |
| 471 | func BodyBytesFromHTTPGRPCResponse(res *httpgrpc.HTTPResponse, logger log.Logger) ([]byte, error) { |
| 472 | headers := http.Header{} |
| 473 | for _, h := range res.Headers { |
| 474 | headers[h.Key] = h.Values |
| 475 | } |
| 476 | |
| 477 | // Handle decoding response if it was compressed |
| 478 | encoding := headers.Get("Content-Encoding") |
| 479 | buf := bytes.NewBuffer(res.Body) |
| 480 | return decode(buf, encoding, logger) |
| 481 | } |
| 482 | |
| 483 | func decode(buf *bytes.Buffer, encoding string, logger log.Logger) ([]byte, error) { |
| 484 | // if the response is gzipped, lets unzip it here |