Function handleMessages

modules/smtp/api.go:62–107

handleMessages returns SMTP messages matching the given filter.

(store event.Store)

// handleMessages returns SMTP messages matching the given filter.
func handleMessages(store event.Store) http.HandlerFunc {
	return func(w http.ResponseWriter, r *http.Request) {
		f := parseFilter(r)

		events, err := store.FindAll(r.Context(), event.FindOptions{Type: "smtp", Project: f.Project})
		if err != nil {
			smtpError(w, err.Error(), http.StatusInternalServerError)
			return
		}

		filtered := applyFilter(events, f)

		if f.Order == "asc" {
			// Store returns desc; reverse for asc.
			for i, j := 0, len(filtered)-1; i < j; i, j = i+1, j-1 {
				filtered[i], filtered[j] = filtered[j], filtered[i]
			}
		}

		total := len(filtered)

		// Apply offset/limit after sorting.
		if f.Offset > 0 {
			if f.Offset >= len(filtered) {
				filtered = nil
			} else {
				filtered = filtered[f.Offset:]
			}
		}
		if f.Limit > 0 && len(filtered) > f.Limit {
			filtered = filtered[:f.Limit]
		}
		if filtered == nil {
			filtered = []event.Event{}
		}

		smtpJSON(w, map[string]any{
			"data": filtered,
			"meta": map[string]any{
				"total":  total,
				"limit":  f.Limit,
				"offset": f.Offset,
			},
		})
	}
}

// handleMessagesWait long-polls for a matching SMTP message.
// It holds the connection until a match arrives or the timeout expires.