mirror of
https://github.com/element-hq/synapse
synced 2024-09-06 01:50:08 +00:00
When presence is enabled don't send over replication
This commit is contained in:
parent
7590e9fa28
commit
1e315017d3
2 changed files with 8 additions and 2 deletions
|
@ -886,6 +886,9 @@ class ReplicationFederationHandlerRegistry(FederationHandlerRegistry):
|
||||||
def on_edu(self, edu_type, origin, content):
|
def on_edu(self, edu_type, origin, content):
|
||||||
"""Overrides FederationHandlerRegistry
|
"""Overrides FederationHandlerRegistry
|
||||||
"""
|
"""
|
||||||
|
if not self.config.use_presence and edu_type == "m.presence":
|
||||||
|
return
|
||||||
|
|
||||||
handler = self.edu_handlers.get(edu_type)
|
handler = self.edu_handlers.get(edu_type)
|
||||||
if handler:
|
if handler:
|
||||||
return super(ReplicationFederationHandlerRegistry, self).on_edu(
|
return super(ReplicationFederationHandlerRegistry, self).on_edu(
|
||||||
|
|
|
@ -54,8 +54,11 @@ class SlavedPresenceStore(BaseSlavedStore):
|
||||||
|
|
||||||
def stream_positions(self):
|
def stream_positions(self):
|
||||||
result = super(SlavedPresenceStore, self).stream_positions()
|
result = super(SlavedPresenceStore, self).stream_positions()
|
||||||
position = self._presence_id_gen.get_current_token()
|
|
||||||
result["presence"] = position
|
if self.hs.config.use_presence:
|
||||||
|
position = self._presence_id_gen.get_current_token()
|
||||||
|
result["presence"] = position
|
||||||
|
|
||||||
return result
|
return result
|
||||||
|
|
||||||
def process_replication_rows(self, stream_name, token, rows):
|
def process_replication_rows(self, stream_name, token, rows):
|
||||||
|
|
Loading…
Reference in a new issue