diff --git a/eduserver/cache/cache.go b/eduserver/cache/cache.go index d2fd26302..f637d7c97 100644 --- a/eduserver/cache/cache.go +++ b/eduserver/cache/cache.go @@ -161,11 +161,10 @@ func (t *EDUCache) RemoveUser(userID, roomID string) int64 { return t.latestSyncPosition } - t.latestSyncPosition++ - timer.Stop() delete(roomData.userSet, userID) + t.latestSyncPosition++ t.data[roomID].syncPosition = t.latestSyncPosition return t.latestSyncPosition diff --git a/syncapi/consumers/eduserver_typing.go b/syncapi/consumers/eduserver_typing.go index 234ec8d21..ead6c7a88 100644 --- a/syncapi/consumers/eduserver_typing.go +++ b/syncapi/consumers/eduserver_typing.go @@ -16,7 +16,6 @@ package consumers import ( "encoding/json" - "fmt" "github.com/Shopify/sarama" "github.com/matrix-org/dendrite/eduserver/api" @@ -98,9 +97,7 @@ func (s *OutputTypingEventConsumer) onMessage(msg *sarama.ConsumerMessage) error ) } - fmt.Println("Advancing typing position to", typingPos) s.streams.TypingStreamProvider.Advance(typingPos) - fmt.Println("Advanced typing position to", typingPos) return nil }