Method UseResponse

tracer/parser.go:278–361

(resp *http.Response)

}

func (p *Parser) UseResponse(resp *http.Response) {
	sampler := newSampler(resp.Body)
	resp.Body = sampler

	p.wg.Add(1)
	go func() {
		defer p.wg.Done()
		start := time.Now()

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

		// TODO: does the "wait" timer start before or after the request is fully
		// sent (including body)?
		p.timings.Wait = time.Since(start).Milliseconds()

		for i := range h.Headers {
			switch strings.ToLower(h.Headers[i].Name) {
			case "set-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("parse HAR response: %w", err)
			return
		}
		p.timings.Receive = time.Since(start).Milliseconds()

		text := sampler.data[:sampler.used]
		if !sampler.over {
			switch resp.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