Function remoteRepositoryNotificationTest

internal/server/server_test.go:270–320

nolint:thelper

(t *testing.T, ctx context.Context, rep repo.Repository, rw repo.RepositoryWriter)

//nolint:thelper
func remoteRepositoryNotificationTest(t *testing.T, ctx context.Context, rep repo.Repository, rw repo.RepositoryWriter) {
	require.Implements(t, (*repo.RemoteNotifications)(nil), rep)

	mux := http.NewServeMux()

	var numRequestsReceived atomic.Int32

	mux.HandleFunc("/some-path", func(w http.ResponseWriter, r *http.Request) {
		numRequestsReceived.Add(1)
	})

	server := httptest.NewServer(mux)
	defer server.Close()

	require.NoError(t, notifyprofile.SaveProfile(ctx, rw, notifyprofile.Config{
		ProfileName: "my-profile",
		MethodConfig: sender.MethodConfig{
			Type: "webhook",
			Config: &webhook.Options{
				Endpoint: server.URL + "/some-path",
				Method:   "POST",
			},
		},
	}))
	require.NoError(t, rw.Flush(ctx))

	notification.Send(ctx, rep, notifytemplate.TestNotification, notifydata.EmptyEventData{}, notification.SeverityError, notifytemplate.DefaultOptions)
	require.Equal(t, int32(1), numRequestsReceived.Load())

	// another webhook which fails

	require.NoError(t, notifyprofile.SaveProfile(ctx, rw, notifyprofile.Config{
		ProfileName: "my-profile",
		MethodConfig: sender.MethodConfig{
			Type: "webhook",
			Config: &webhook.Options{
				Endpoint: server.URL + "/some-nonexistent-path",
				Method:   "POST",
			},
		},
	}))

	require.NoError(t, rw.Flush(ctx))

	t0 := clock.Now()
	t1 := clock.Now().Add(10 * time.Second)

	notification.Send(ctx, rep, "generic-error",
		notifydata.NewErrorInfo("op", "some error occurred", t0, t1, errors.New("some error")), notification.SeverityError, notifytemplate.DefaultOptions)
	require.Equal(t, int32(1), numRequestsReceived.Load())
}

func mustWriteObject(ctx context.Context, t *testing.T, w repo.RepositoryWriter, data []byte) object.ID {
	t.Helper()