X-Git-Url: http://git.giacomolli.uk/onechat/blobdiff_plain/c3c7bc90eb73e83f48fbeac6be149ade95a726c0..2ad578a24f252706976cddb41bee6cc969f251cd:/daemon.go?ds=inline

diff --git a/daemon.go b/daemon.go
index 3a54b1a..958d6f7 100644
--- a/daemon.go
+++ b/daemon.go
@@ -364,8 +364,15 @@ func daemonServe(ctx context.Context, listener net.Listener, bot *TelegramBot, w
 		loops = append(loops, loop)
 	}
 
+	messages, err := openDaemonMessages(loops)
+	if err != nil {
+		return errors.Join(fmt.Errorf("open agent messages: %w", err), listener.Close())
+	}
+
 	hub.snapshot = func(ctx context.Context, snapshot func() error) error {
-		return daemonSnapshot(ctx, loops, snapshot)
+		return messages.Snapshot(func() error {
+			return daemonSnapshot(ctx, loops, snapshot)
+		})
 	}
 
 	var workers sync.WaitGroup