Function getQuerySnippetFromBody

utils.go:86–129

(req *http.Request)

}

func getQuerySnippetFromBody(req *http.Request) string {
	if req.Body == nil {
		return ""
	}

	crc, ok := req.Body.(*cachedReadCloser)
	if !ok {
		crc = &cachedReadCloser{
			ReadCloser: req.Body,
		}
	}

	// 'read' request body, so it traps into to crc.
	// Ignore any errors, since getQuerySnippet is called only
	// during error reporting.
	// Temporary solution: Quick and dirty way to work with the request body.
	// TODO: Create an original copy of req.Body and work with the copy to avoid altering the original request.
	// This current approach consumes the req.Body content with io.Copy(io.Discard, crc) to reset the internal state of crc.
	// However, it is not the most efficient or safest method, as it modifies the original req.Body.
	io.Copy(io.Discard, crc) // nolint
	data := crc.String()

	// Here, we attempt to restore req.Body by wrapping the string data in a ReadCloser.
	// This is part of the temporary solution and should be replaced with a more robust method that does not consume the original req.Body.
	req.Body = io.NopCloser(strings.NewReader(data))

	u := getDecompressor(req)
	if u == nil {
		return data
	}
	bs := bytes.NewBufferString(data)
	b, err := u.decompress(bs)
	if err == nil {
		return string(b)
	}
	// It is better to return partially decompressed data instead of an empty string.
	if len(b) > 0 {
		return string(b)
	}

	// The data failed to be decompressed. Return compressed data
	// instead of an empty string.
	return data
}

// getFullQuery returns full query from req.
func getFullQuery(req *http.Request) ([]byte, error) {