diff --git a/synapse/handlers/message.py b/synapse/handlers/message.py
index 42dc4d46f3..13fa0be7b4 100644
--- a/synapse/handlers/message.py
+++ b/synapse/handlers/message.py
@@ -15,7 +15,7 @@
from twisted.internet import defer
-from synapse.api.constants import Membership
+from synapse.api.constants import EventTypes, Membership
from synapse.api.errors import RoomError
from synapse.streams.config import PaginationConfig
from synapse.util.logcontext import PreserveLoggingContext
@@ -79,7 +79,7 @@ class MessageHandler(BaseHandler):
self.ratelimit(event.user_id)
# TODO(paul): Why does 'event' not have a 'user' object?
user = self.hs.parse_userid(event.user_id)
- assert user.is_mine, "User must be our own: %s" % (user,)
+ assert self.hs.is_mine(user), "User must be our own: %s" % (user,)
snapshot = yield self.store.snapshot_room(event)
@@ -134,6 +134,38 @@ class MessageHandler(BaseHandler):
defer.returnValue(chunk)
@defer.inlineCallbacks
+ def handle_event(self, event_dict):
+ builder = self.event_builder_factory.new(event_dict)
+
+ if builder.type == EventTypes.Member:
+ membership = builder.content.get("membership", None)
+ if membership == Membership.JOIN:
+ joinee = self.hs.parse_userid(builder.state_key)
+ # If event doesn't include a display name, add one.
+ yield self.distributor.fire(
+ "collect_presencelike_data",
+ joinee,
+ builder.content
+ )
+
+ event, context = yield self._create_new_client_event(
+ builder=builder,
+ )
+
+ # TODO: self.validator.validate(event)
+
+ if event.type == EventTypes.Member:
+ member_handler = self.hs.get_handlers().room_member_handler
+ yield member_handler.change_membership(event, context)
+ else:
+ yield self.handle_new_client_event(
+ event=event,
+ context=context,
+ )
+
+ defer.returnValue(event)
+
+ @defer.inlineCallbacks
def store_room_data(self, event=None):
""" Stores data for a room.
|
