Method Finish

tracer/parser.go:375–489

()

}

func (p *Parser) Finish() error {
	if sendReflector {
		DefaultPublisher.inflight.Add(1)
		defer DefaultPublisher.inflight.Done()
	}

	p.wg.Wait()
	if err := errors.Join(<-p.errs, <-p.errs); err != nil {
		return err
	}

	var logidx uint64
	var loglines []string
	if journal.Enabled {
		logidx, loglines = p.global.Journal.CopyFrom(p.journalIdx)
	}

	entry := &extendedHarEntry{
		Entry: &har.Entry{
			ID:              p.event.Get("event_id"),
			StartedDateTime: p.begin.UTC(),
			Time:            time.Since(p.begin).Milliseconds(),
			Request:         p.request,
			Response:        p.response,
			Timings:         &p.timings,
		},
		WebSocketMessages: p.websocketMessages,
	}

	for k, v := range stats.Load() {
		p.event.Set(k, v)
	}

	tags := p.global.Config.GetEventTemplate()
	tags.CopyFrom(p.event)
	tags.Set("event_id", p.event.Get("event_id"))
	tags.Set("time", p.event.Get("time"))

	// HAR v1.2 doesn't support trailers so for now we just set the counts as a
	// way to indicate to the user that there were trailers.
	if p.requestTrailer != nil {
		tags.Set("request_trailer_count", fmt.Sprintf("%d", len(p.requestTrailer)))
	}
	if p.responseTrailer != nil {
		tags.Set("response_trailer_count", fmt.Sprintf("%d", len(p.responseTrailer)))
	}

	{
		begin := time.Now()
		match, err := p.global.Config.GetMatchingFilter(tags.Map(), entry.Entry)
		slog.Debug("evaluated filters", "eventID", p.event.Get("event_id"), "match", match, "err", err, "took", time.Since(begin).Round(time.Nanosecond))
		switch {
		case err != nil:
			fallthrough // fallthrough to ActionInclude if filter eval fails
		case match == nil:
			break
		case match.Action == filter.ActionInclude:
			break