Presence is supposed to be disabled on matrix.org, so we shouldn't send a load of USER_SYNC commands every time the synchrotron reconnects to the master.
@@ -215,6 +215,8 @@ class SynchrotronPresence(object):
yield self.notify_from_replication(states, stream_id)
def get_currently_syncing_users(self):
+ # presence is disabled on matrix.org, so we return the empty set
+ return set()
return [
user_id for user_id, count in self.user_to_num_current_syncs.iteritems()
if count > 0
@@ -445,6 +445,7 @@ class PresenceHandler(object):
Returns:
set(str): A set of user_id strings.
"""
return set()
syncing_user_ids = {
user_id for user_id, count in self.user_to_num_current_syncs.items()