Function TestWatchNotify

internal/reloader/reloader_test.go:124–605

(t *testing.T)

}

func TestWatchNotify(t *testing.T) {
	ctx, cancel := context.WithTimeout(context.Background(), time.Second*10)
	defer cancel()

	t.Run("IsWatchable", func(t *testing.T) {
		dir, cleanup := helpTestDir(t)
		defer cleanup()

		invalidDir := path.Join(dir, "__not_found__")
		require.False(t, isWatchable(invalidDir))

		name := helpWriteEnvFile(t, dir, "05_example.env", map[string]string{
			"GOTRUE_SMTP_PORT": "2222",
		})
		require.False(t, isWatchable(name))

	})

	t.Run("AllDisabled", func(t *testing.T) {
		dir, cleanup := helpTestDir(t)
		defer cleanup()

		rr := mockReloadRecorder()

		cfg := e2e.Must(e2e.Config()).Reloading
		cfg.NotifyEnabled = false
		cfg.SignalEnabled = false
		cfg.PollerEnabled = false

		rl := NewReloader(cfg, dir)

		err := rl.Watch(ctx, rr.configFn)
		require.NoError(t, err)
	})

	t.Run("BrokenWatcher", func(t *testing.T) {
		dir, cleanup := helpTestDir(t)
		defer cleanup()

		sentinelErr := errors.New("sentinel")
		rr := mockReloadRecorder()

		cfg := e2e.Must(e2e.Config()).Reloading
		cfg.SignalEnabled = false
		cfg.PollerEnabled = false

		rl := NewReloader(cfg, dir)
		rl.watchFn = func() (watcher, error) { return nil, sentinelErr }

		err := rl.Watch(ctx, rr.configFn)
		if exp, got := sentinelErr, err; exp != got {
			require.Equal(t, exp, got)
		}
	})

	t.Run("InvalidDir", func(t *testing.T) {
		dir, cleanup := helpTestDir(t)
		defer cleanup()