diff --git a/synapse/handlers/events.py b/synapse/handlers/events.py
index 72a31a9755..f25a252523 100644
--- a/synapse/handlers/events.py
+++ b/synapse/handlers/events.py
@@ -18,7 +18,6 @@ from twisted.internet import defer
from synapse.util.logutils import log_function
from synapse.types import UserID
from synapse.events.utils import serialize_event
-from synapse.util.logcontext import preserve_context_over_fn
from synapse.api.constants import Membership, EventTypes
from synapse.events import EventBase
@@ -31,20 +30,6 @@ import random
logger = logging.getLogger(__name__)
-def started_user_eventstream(distributor, user):
- return preserve_context_over_fn(
- distributor.fire,
- "started_user_eventstream", user
- )
-
-
-def stopped_user_eventstream(distributor, user):
- return preserve_context_over_fn(
- distributor.fire,
- "stopped_user_eventstream", user
- )
-
-
class EventStreamHandler(BaseHandler):
def __init__(self, hs):
@@ -64,61 +49,6 @@ class EventStreamHandler(BaseHandler):
self.notifier = hs.get_notifier()
@defer.inlineCallbacks
- def started_stream(self, user):
- """Tells the presence handler that we have started an eventstream for
- the user:
-
- Args:
- user (User): The user who started a stream.
- Returns:
- A deferred that completes once their presence has been updated.
- """
- if user not in self._streams_per_user:
- # Make sure we set the streams per user to 1 here rather than
- # setting it to zero and incrementing the value below.
- # Otherwise this may race with stopped_stream causing the
- # user to be erased from the map before we have a chance
- # to increment it.
- self._streams_per_user[user] = 1
- if user in self._stop_timer_per_user:
- try:
- self.clock.cancel_call_later(
- self._stop_timer_per_user.pop(user)
- )
- except:
- logger.exception("Failed to cancel event timer")
- else:
- yield started_user_eventstream(self.distributor, user)
- else:
- self._streams_per_user[user] += 1
-
- def stopped_stream(self, user):
- """If there are no streams for a user this starts a timer that will
- notify the presence handler that we haven't got an event stream for
- the user unless the user starts a new stream in 30 seconds.
-
- Args:
- user (User): The user who stopped a stream.
- """
- self._streams_per_user[user] -= 1
- if not self._streams_per_user[user]:
- del self._streams_per_user[user]
-
- # 30 seconds of grace to allow the client to reconnect again
- # before we think they're gone
- def _later():
- logger.debug("_later stopped_user_eventstream %s", user)
-
- self._stop_timer_per_user.pop(user, None)
-
- return stopped_user_eventstream(self.distributor, user)
-
- logger.debug("Scheduling _later: for %s", user)
- self._stop_timer_per_user[user] = (
- self.clock.call_later(30, _later)
- )
-
- @defer.inlineCallbacks
@log_function
def get_stream(self, auth_user_id, pagin_config, timeout=0,
as_client_event=True, affect_presence=True,
diff --git a/synapse/handlers/presence.py b/synapse/handlers/presence.py
index f6cf343174..d0c8f1328b 100644
--- a/synapse/handlers/presence.py
+++ b/synapse/handlers/presence.py
@@ -73,14 +73,6 @@ FEDERATION_PING_INTERVAL = 25 * 60 * 1000
assert LAST_ACTIVE_GRANULARITY < IDLE_TIMER
-def user_presence_changed(distributor, user, statuscache):
- return distributor.fire("user_presence_changed", user, statuscache)
-
-
-def collect_presencelike_data(distributor, user, content):
- return distributor.fire("collect_presencelike_data", user, content)
-
-
class PresenceHandler(BaseHandler):
def __init__(self, hs):
diff --git a/synapse/storage/roommember.py b/synapse/storage/roommember.py
index 3065b0c1a5..0cd89260f2 100644
--- a/synapse/storage/roommember.py
+++ b/synapse/storage/roommember.py
@@ -252,30 +252,6 @@ class RoomMemberStore(SQLBaseStore):
)
@defer.inlineCallbacks
- def user_rooms_intersect(self, user_id_list):
- """ Checks whether all the users whose IDs are given in a list share a
- room.
-
- This is a "hot path" function that's called a lot, e.g. by presence for
- generating the event stream. As such, it is implemented locally by
- wrapping logic around heavily-cached database queries.
- """
- if len(user_id_list) < 2:
- defer.returnValue(True)
-
- deferreds = [self.get_rooms_for_user(u) for u in user_id_list]
-
- results = yield defer.DeferredList(deferreds, consumeErrors=True)
-
- # A list of sets of strings giving room IDs for each user
- room_id_lists = [set([r.room_id for r in result[1]]) for result in results]
-
- # There isn't a setintersection(*list_of_sets)
- ret = len(room_id_lists.pop(0).intersection(*room_id_lists)) > 0
-
- defer.returnValue(ret)
-
- @defer.inlineCallbacks
def forget(self, user_id, room_id):
"""Indicate that user_id wishes to discard history for room_id."""
def f(txn):
diff --git a/tests/storage/test_roommember.py b/tests/storage/test_roommember.py
index 677d11f68d..b029ff0584 100644
--- a/tests/storage/test_roommember.py
+++ b/tests/storage/test_roommember.py
@@ -91,11 +91,6 @@ class RoomMemberStoreTestCase(unittest.TestCase):
)
)]
)
- self.assertFalse(
- (yield self.store.user_rooms_intersect(
- [self.u_alice.to_string(), self.u_bob.to_string()]
- ))
- )
@defer.inlineCallbacks
def test_two_members(self):
@@ -108,11 +103,6 @@ class RoomMemberStoreTestCase(unittest.TestCase):
yield self.store.get_room_members(self.room.to_string())
)}
)
- self.assertTrue((
- yield self.store.user_rooms_intersect([
- self.u_alice.to_string(), self.u_bob.to_string()
- ])
- ))
@defer.inlineCallbacks
def test_room_hosts(self):
|
