3pp-mirror/pomerium
1
0
Fork 0
mirror of https://github.com/pomerium/pomerium.git synced 2025-08-02 00:10:45 +02:00
Code Issues Projects Releases Packages Wiki Activity

fix test

Browse source
This commit is contained in:
Caleb Doxsey 2023-11-03 13:49:21 -06:00
parent a673a9b5f5
commit 06a1fc77a0
1 changed files with 25 additions and 35 deletions
Download patch file Download diff file Expand all files Collapse all files

60
internal/fileutil/watcher_test.go
View file

@ -25,18 +25,14 @@ func TestWatcher(t *testing.T) {
w.Watch(context.Background(), []string{filepath.Join(tmpdir, "test1.txt")})
ch := w.Bind()
defer w.Unbind(ch)
t.Cleanup(func() { w.Unbind(ch) })
err = os.WriteFile(filepath.Join(tmpdir, "test1.txt"), []byte{5, 6, 7, 8}, 0o666)
if !assert.NoError(t, err) {
return
}
select {
case <-ch:
case <-time.After(time.Second):
t.Error("expected change signal when file is modified")
}
expectChange(t, ch)
}
func TestWatcherSymlink(t *testing.T) {
@ -64,20 +60,12 @@ func TestWatcherSymlink(t *testing.T) {
assert.NoError(t, os.WriteFile(filepath.Join(tmpdir, "test1.txt"), []byte{9, 10, 11}, 0o666))
select {
case <-ch:
case <-time.After(time.Second):
t.Error("expected change signal when underlying file is modified")
}
expectChange(t, ch)
assert.NoError(t, os.Symlink(filepath.Join(tmpdir, "test2.txt"), filepath.Join(tmpdir, "symlink2.txt")))
assert.NoError(t, os.Rename(filepath.Join(tmpdir, "symlink2.txt"), filepath.Join(tmpdir, "symlink1.txt")))
select {
case <-ch:
case <-time.After(10 * time.Second):
t.Error("expected change signal when symlink is changed")
}
expectChange(t, ch)
}
func TestWatcher_FileRemoval(t *testing.T) {
@ -92,31 +80,33 @@ func TestWatcher_FileRemoval(t *testing.T) {
w.Watch(context.Background(), []string{filepath.Join(tmpdir, "test1.txt")})
ch := w.Bind()
defer w.Unbind(ch)
t.Cleanup(func() { w.Unbind(ch) })
err = os.Remove(filepath.Join(tmpdir, "test1.txt"))
require.NoError(t, err)
expectChange := func() {
cnt := 0
loop:
for {
select {
case <-ch:
cnt++
case <-time.After(time.Second):
break loop
}
}
if cnt == 0 {
t.Error("expected change signal")
}
}
expectChange()
expectChange(t, ch)
err = os.WriteFile(filepath.Join(tmpdir, "test1.txt"), []byte{5, 6, 7, 8}, 0o666)
require.NoError(t, err)
expectChange()
expectChange(t, ch)
}
func expectChange(t *testing.T, ch chan context.Context) {
t.Helper()
cnt := 0
loop:
for {
select {
case <-ch:
cnt++
case <-time.After(time.Second):
break loop
}
}
if cnt == 0 {
t.Error("expected change signal")
}
}