Function newHTTPFromResponse

decoder/stream/http/utils.go:132–182

(res *http.Response)

}

func newHTTPFromResponse(res *http.Response) *types.HTTP {
	var (
		detected      string
		contentLength = int32(res.ContentLength)
	)

	// read body data
	body, err := ioutil.ReadAll(res.Body)
	if err == nil {

		if contentLength == -1 {
			// determine length manually
			contentLength = int32(len(body))
		}

		// decompress payload if required
		if res.Header.Get(headerContentEncoding) == "gzip" {
			r, errReader := gzip.NewReader(bytes.NewReader(body))
			if errReader == nil {
				body, err = ioutil.ReadAll(r)
				if err == nil {
					detected = http.DetectContentType(body)
				}
			}
		} else {
			detected = http.DetectContentType(body)
		}
	}

	return &types.HTTP{
		ResContentLength:       contentLength,
		ResContentType:         res.Header.Get(headerContentType),
		StatusCode:             int32(res.StatusCode),
		ServerName:             res.Header.Get("Server"),
		ResContentEncoding:     res.Header.Get(headerContentEncoding),
		ResContentTypeDetected: detected,
		ResCookies:             readCookies(res.Cookies()),
		ResponseHeader:         readHeader(res.Header),
		// Security headers from response
		StrictTransportSecurity:  res.Header.Get("Strict-Transport-Security"),
		ContentSecurityPolicy:    res.Header.Get("Content-Security-Policy"),
		XContentTypeOptions:      res.Header.Get("X-Content-Type-Options"),
		XFrameOptions:            res.Header.Get("X-Frame-Options"),
		XXSSProtection:           res.Header.Get("X-XSS-Protection"),
		ReferrerPolicy:           res.Header.Get("Referrer-Policy"),
		AccessControlAllowOrigin: res.Header.Get("Access-Control-Allow-Origin"),
		HasServerTiming:          res.Header.Get("Server-Timing") != "",
		Server:                   res.Header.Get("Server"),
		XPoweredBy:               res.Header.Get("X-Powered-By"),
	}
}

// extractAuthType extracts the authorization type from the Authorization header
func extractAuthType(authHeader string) string {