Method handleEventItem

modules/sentry/handler.go:188–219

handleEventItem processes an "event" envelope item (error/message event). envelopeEventID is the event_id from the envelope header — Sentry SDK v4+ omits event_id from the item payload, so we inject it when missing.

(item EnvelopeItem, envelopeEventID string, project string)

// envelopeEventID is the event_id from the envelope header — Sentry SDK v4+
// omits event_id from the item payload, so we inject it when missing.
func (h *handler) handleEventItem(item EnvelopeItem, envelopeEventID string, project string) (string, json.RawMessage) {
	var ev ErrorEvent
	if err := json.Unmarshal(item.Payload, &ev); err != nil {
		slog.Warn("sentry: failed to parse error event", "err", err)
		return "", item.Payload
	}

	// Sentry SDK v4+ sends event_id only in the envelope header, not in
	// the item payload. Inject it so downstream consumers (frontend, API)
	// always see it in the payload.
	uuid := ev.EventID
	payload := item.Payload
	if uuid == "" && envelopeEventID != "" {
		uuid = envelopeEventID
		ev.EventID = envelopeEventID
		payload = injectEventID(payload, envelopeEventID)
	}

	// Resolve source code for browser/JS frames that only carry file+line.
	if enriched, changed := enrichSourceContext(payload, nil); changed {
		payload = enriched
		_ = json.Unmarshal(payload, &ev) // re-parse so structured storage carries the code too
	}

	if h.db != nil {
		if _, err := storeErrorEvent(h.db, &ev, payload, project); err != nil {
			slog.Warn("sentry: failed to store structured error event", "err", err)
		}
	}

	return uuid, payload
}

// handleTransactionItem processes a "transaction" envelope item.
func (h *handler) handleTransactionItem(item EnvelopeItem) (string, json.RawMessage) {