Function TestHTTPHandlerProcessesPush

internal/gmailwatch/http_test.go:15–43

(t *testing.T)

)

func TestHTTPHandlerProcessesPush(t *testing.T) {
	t.Parallel()

	handler := &HTTPHandler{
		Config: HTTPConfig{
			Path:      "/hook",
			Account:   "a@example.com",
			BodyLimit: 1024,
			HasHook:   true,
		},
		Authorize: func(*http.Request) bool {
			return true
		},
		Process: func(_ context.Context, notification Notification) (*ProcessedPayload, error) {
			if notification.HistoryID != "200" || notification.MessageID != "push-1" {
				t.Fatalf("notification = %#v", notification)
			}

			return &ProcessedPayload{Payload: &Payload{HistoryID: "200"}}, nil
		},
	}

	response := httptest.NewRecorder()
	handler.ServeHTTP(response, pushRequest(t, "a@example.com", "200", "push-1"))

	if response.Code != http.StatusOK {
		t.Fatalf("status = %d", response.Code)
	}
}

func TestHTTPHandlerMapsNoMessagesAndRateLimit(t *testing.T) {
	t.Parallel()