From 95bcbcd9a529c5da8fe0551ee27759dabe7e0e19 Mon Sep 17 00:00:00 2001
From: Sergey Cherepanov <cheggaaa@gmail.com>
Date: Tue, 14 Feb 2023 21:18:25 +0300
Subject: [PATCH] cleanup thread on error

---
 commonspace/space.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/commonspace/space.go b/commonspace/space.go
index 7188b67a..c481a912 100644
--- a/commonspace/space.go
+++ b/commonspace/space.go
@@ -392,6 +392,10 @@ func (s *space) handleMessage(msg HandleMessage) {
 	}
 
 	if err := s.objectSync.HandleMessage(ctx, msg.SenderId, msg.Message); err != nil {
+		if msg.Message.ObjectId != "" {
+			// cleanup thread on error
+			_ = s.handleQueue.CloseThread(msg.Message.ObjectId)
+		}
 		log.InfoCtx(ctx, "handleMessage error", zap.Error(err))
 	}
 }