Method UseRequest

tracer/parser.go:200–276

(req *http.Request)

}

func (p *Parser) UseRequest(req *http.Request) {
	sampler := newSampler(req.Body)
	req.Body = sampler

	p.wg.Add(1)
	go func() {
		defer p.wg.Done()

		h, err := har.NewRequest(req, false)
		if err != nil {
			p.errs <- fmt.Errorf("parse HAR request: %w", err)
			return
		}

		for i := range h.Headers {
			switch strings.ToLower(h.Headers[i].Name) {
			case "authorization", "cookie":
				h.Headers[i].Value = p.global.Config.SantizeCredential(h.Headers[i].Value)
			}
		}

		for i := range h.Cookies {
			h.Cookies[i].Value = p.global.Config.SantizeCredential(h.Cookies[i].Value)
		}

		start := time.Now()
		if err := <-sampler.errs; err != nil {
			p.errs <- fmt.Errorf("read request body: %w", err)
			return
		}
		p.timings.Send = time.Since(start).Milliseconds()

		text := sampler.data[:sampler.used]
		if !sampler.over {
			switch req.Header.Get("content-encoding") {
			case "gzip":
				gr, err := gzip.NewReader(bytes.NewBuffer(text))
				if err != nil {
					p.errs <- fmt.Errorf("create gzip reader: %w", err)
					return
				}
				if raw, err := io.ReadAll(gr); err != nil {
					p.errs <- fmt.Errorf("read gzip: %w", err)
					return
				} else {
					text = raw
				}
			case "br":
				if raw, err := io.ReadAll(brotli.NewReader(bytes.NewBuffer(text))); err != nil {
					p.errs <- fmt.Errorf("decode brotli: %w", err)
					return
				} else {
					text = raw
				}
			}
		}

		h.PostData = &har.PostData{