Fix message duplication due to a race-condition

1 files changed, 4 insertions, 0 deletions

diff --git a/server.go b/server.go
index b982e15..1654971 100644
--- a/server.go
+++ b/server.go
@@ -165,6 +165,10 @@ func handleTxnEvent(e *mxlib.Event) error {
 			if acct != nil {
 				ev.Author = acct.Conn.User()
 				ev.Room = room.RoomID
+
+				dbLockSlot(e.RoomId)
+				defer dbUnlockSlot(e.RoomId)
+
 				created_ev_id, err := acct.Conn.Send(ev)
 				if err == nil && created_ev_id != "" {
 					cache_key := fmt.Sprintf("%s/event_seen/%s/%s",