Function handleExceptionsChronological

modules/sentry/api_exceptions.go:124–208

(db *sql.DB, w http.ResponseWriter, r *http.Request)

}

func handleExceptionsChronological(db *sql.DB, w http.ResponseWriter, r *http.Request) {
	limit, offset := pagination(r, 50)
	q := r.URL.Query()

	query := `SELECT
		e.id, e.event_id, e.fingerprint,
		(SELECT COUNT(*) FROM sentry_error_events e2 WHERE e2.fingerprint = e.fingerprint) as occurrence_count,
		(SELECT se.exception_type FROM sentry_exceptions se WHERE se.error_event_id = e.id AND se.position = 0 LIMIT 1) as exception_type,
		(SELECT se.exception_value FROM sentry_exceptions se WHERE se.error_event_id = e.id AND se.position = 0 LIMIT 1) as exception_value,
		e.level, e.handled, e."transaction", e.received_at, e.trace_id
	FROM sentry_error_events e`

	countQuery := `SELECT COUNT(*) FROM sentry_error_events e`

	var conditions []string
	var args []any

	if v := q.Get("level"); v != "" {
		conditions = append(conditions, "e.level = ?")
		args = append(args, v)
	}
	if v := q.Get("handled"); v != "" {
		if v == "true" {
			conditions = append(conditions, "e.handled = 1")
		} else {
			conditions = append(conditions, "e.handled = 0")
		}
	}

	where := ""
	if len(conditions) > 0 {
		where = " WHERE " + strings.Join(conditions, " AND ")
	}

	query += where + " ORDER BY e.received_at DESC LIMIT ? OFFSET ?"
	countQuery += where

	var total int
	db.QueryRow(countQuery, args...).Scan(&total)

	queryArgs := append(args, limit, offset)
	rows, err := db.Query(query, queryArgs...)
	if err != nil {
		apiError(w, err.Error(), http.StatusInternalServerError)
		return
	}
	defer rows.Close()

	var data []map[string]any
	for rows.Next() {
		var (
			id, eventID, fingerprint string
			occurrenceCount          int
			excType, excValue        sql.NullString
			level                    string
			handled                  sql.NullBool
			txn                      sql.NullString
			receivedAt               string