Function TestWebhook

coderd/notifications/dispatch/webhook_test.go:26–157

(t *testing.T)

)

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

	const (
		titlePlaintext = "this is the title"
		titleMarkdown  = "this *is* _the_ title"
		bodyPlaintext  = "this is the body"
		bodyMarkdown   = "~this~ is the `body`"
	)

	msgPayload := types.MessagePayload{
		Version:          "1.0",
		NotificationName: "test",
	}

	tests := []struct {
		name           string
		serverURL      string
		serverDeadline time.Time
		serverFn       func(uuid.UUID, http.ResponseWriter, *http.Request)

		expectSuccess   bool
		expectRetryable bool
		expectErr       string
	}{
		{
			name: "successful",
			serverFn: func(msgID uuid.UUID, w http.ResponseWriter, r *http.Request) {
				var payload dispatch.WebhookPayload
				err := json.NewDecoder(r.Body).Decode(&payload)
				assert.NoError(t, err)
				assert.Equal(t, "application/json", r.Header.Get("Content-Type"))
				assert.Equal(t, msgID, payload.MsgID)
				assert.Equal(t, msgID.String(), r.Header.Get("X-Message-Id"))

				assert.Equal(t, titlePlaintext, payload.Title)
				assert.Equal(t, titleMarkdown, payload.TitleMarkdown)
				assert.Equal(t, bodyPlaintext, payload.Body)
				assert.Equal(t, bodyMarkdown, payload.BodyMarkdown)

				w.WriteHeader(http.StatusOK)
				_, err = w.Write([]byte(fmt.Sprintf("received %s", payload.MsgID)))
				assert.NoError(t, err)
			},
			expectSuccess: true,
		},
		{
			name: "invalid endpoint",
			// Build a deliberately invalid URL to fail validation.
			serverURL:       "invalid .com",
			expectSuccess:   false,
			expectErr:       "invalid URL escape",
			expectRetryable: false,
		},
		{
			name:            "timeout",
			serverDeadline:  time.Now().Add(-time.Hour),
			expectSuccess:   false,