mirrors/ntfy
1
0
Fork 0
mirror of https://github.com/binwiederhier/ntfy.git synced 2025-04-04 13:47:36 +03:00
Code Issues Projects Releases Packages Wiki Activity

Docs

Browse source
This commit is contained in:
binwiederhier 2024-09-29 13:12:51 -04:00
parent fc3624cd50
commit d38c149263
7 changed files with 55 additions and 19 deletions
Download patch file Download diff file Expand all files Collapse all files

18
server/server_test.go
View file

@ -1277,6 +1277,7 @@ func TestServer_PublishEmailNoMailer_Fail(t *testing.T) {
func TestServer_PublishAndExpungeTopicAfter16Hours(t *testing.T) {
t.Parallel()
s := newTestServer(t, newTestConfig(t))
defer s.messageCache.Close()
subFn := func(v *visitor, msg *message) error {
return nil
@ -1288,13 +1289,22 @@ func TestServer_PublishAndExpungeTopicAfter16Hours(t *testing.T) {
})
require.Equal(t, 200, response.Code)
waitFor(t, func() bool {
s.mu.Lock()
tp, exists := s.topics["mytopic"]
s.mu.Unlock()
if !exists {
return false
}
// .lastAccess set in t.Publish() -> t.Keepalive() in Goroutine
s.topics["mytopic"].mu.RLock()
defer s.topics["mytopic"].mu.RUnlock()
return s.topics["mytopic"].lastAccess.Unix() >= time.Now().Unix()-2 &&
s.topics["mytopic"].lastAccess.Unix() <= time.Now().Unix()+2
tp.mu.RLock()
defer tp.mu.RUnlock()
return tp.lastAccess.Unix() >= time.Now().Unix()-2 &&
tp.lastAccess.Unix() <= time.Now().Unix()+2
})
// Hack!
time.Sleep(time.Second)
// Topic won't get pruned
s.execManager()
require.NotNil(t, s.topics["mytopic"])