Function writeHTTP

decoder/stream/http/http_reader.go:232–278

(h *types.HTTP, ident string)

}

func writeHTTP(h *types.HTTP, ident string) {
	// TODO: this kills performance, make configurable
	// updateHTTPStore(h)

	if decoderconfig.Instance.IncludePayloads {
		// TODO: only include request body, not the entire stream contents...
		// h.RequestBody = t.client.DataSlice().bytes()
		// h.ResponseBody = t.server.DataSlice().bytes()
	}

	// export metrics if configured
	if decoderconfig.Instance.ExportMetrics {
		h.Inc()
	}

	// write record to disk
	atomic.AddInt64(&Decoder.NumRecordsWritten, 1)
	err := Decoder.Writer.Write(h)
	if err != nil {
		decoderutils.ErrorMap.Inc(err.Error())
	}

	soft := software.WhatSoftwareHTTP(ident, h)

	if len(soft) == 0 {
		return
	}

	communityID := h.CommunityID
	software.WriteSoftware(soft, func(s *software.AtomicSoftware) {
		s.Lock()
		// Check if flow already exists
		flowExists := slices.Contains(s.Flows, ident)
		// Add flow if not exists
		if !flowExists {
			s.Flows = append(s.Flows, ident)
		}
		// Add community ID if not exists
		if communityID != "" {
			cidExists := slices.Contains(s.CommunityIDs, communityID)
			if !cidExists {
				s.CommunityIDs = append(s.CommunityIDs, communityID)
			}
		}
		s.Unlock()
	})
}

// HTTP Response