mirror of
https://github.com/multipleof4/ntfy.git
synced 2026-10-08 21:05:21 +00:00
Arrrg
This commit is contained in:
+6
-2
@@ -433,14 +433,18 @@ func (s *Server) Stop() {
|
|||||||
s.attachment.Close()
|
s.attachment.Close()
|
||||||
}
|
}
|
||||||
s.closeDatabases()
|
s.closeDatabases()
|
||||||
close(s.closeChan)
|
if s.closeChan != nil {
|
||||||
|
close(s.closeChan)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *Server) closeDatabases() {
|
func (s *Server) closeDatabases() {
|
||||||
if s.userManager != nil {
|
if s.userManager != nil {
|
||||||
s.userManager.Close()
|
s.userManager.Close()
|
||||||
}
|
}
|
||||||
s.messageCache.Close()
|
if s.messageCache != nil {
|
||||||
|
s.messageCache.Close()
|
||||||
|
}
|
||||||
if s.webPush != nil {
|
if s.webPush != nil {
|
||||||
s.webPush.Close()
|
s.webPush.Close()
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -4195,7 +4195,7 @@ func newTestConfigWithAuthFile(t *testing.T, databaseURL string) *Config {
|
|||||||
func newTestServer(t *testing.T, config *Config) *Server {
|
func newTestServer(t *testing.T, config *Config) *Server {
|
||||||
server, err := New(config)
|
server, err := New(config)
|
||||||
require.Nil(t, err)
|
require.Nil(t, err)
|
||||||
t.Cleanup(server.closeDatabases)
|
t.Cleanup(server.Stop)
|
||||||
return server
|
return server
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user