Function storeErrorEvent

modules/sentry/store_error.go:15–134

storeErrorEvent stores a parsed error event with its exceptions and breadcrumbs in a single DB transaction.

(db *sql.DB, ev *ErrorEvent, payload json.RawMessage, projectID string)

// storeErrorEvent stores a parsed error event with its exceptions and breadcrumbs
// in a single DB transaction.
func storeErrorEvent(db *sql.DB, ev *ErrorEvent, payload json.RawMessage, projectID string) (string, error) {
	tx, err := db.Begin()
	if err != nil {
		return "", err
	}
	defer tx.Rollback()

	id := event.GenerateUUID()
	fingerprint := computeFingerprint(ev)

	level := ev.Level
	if level == "" {
		level = "error"
	}

	var handled *int
	if ev.Exception != nil && len(ev.Exception.Values) > 0 {
		if m := ev.Exception.Values[0].Mechanism; m != nil && m.Handled != nil {
			v := 0
			if *m.Handled {
				v = 1
			}
			handled = &v
		}
	}

	eventTS := parseTimestamp(ev.Timestamp.Number())

	_, err = tx.Exec(
		`INSERT INTO sentry_error_events
			(id, event_id, project_id, trace_id, span_id, level, environment, release, server_name, platform, "transaction", fingerprint, handled, event_ts, payload)
		VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,
		id,
		ev.EventID,
		nullIfEmpty(projectID),
		nullIfEmpty(ev.traceID()),
		nullIfEmpty(ev.spanID()),
		level,
		nullIfEmpty(ev.Environment),
		nullIfEmpty(ev.Release),
		nullIfEmpty(ev.ServerName),
		nullIfEmpty(ev.Platform),
		nullIfEmpty(ev.Transaction),
		fingerprint,
		handled,
		eventTS,
		string(payload),
	)
	if err != nil {
		return "", fmt.Errorf("insert sentry_error_events: %w", err)
	}

	// Insert exceptions.
	if ev.Exception != nil {
		for i, exc := range ev.Exception.Values {
			excID := event.GenerateUUID()
			var excHandled *int
			if exc.Mechanism != nil && exc.Mechanism.Handled != nil {