MirrorHub/synapse
0
0
Fork 1
mirror of https://mau.dev/maunium/synapse.git synced 2024-12-21 11:03:54 +01:00
Code Issues Projects Releases Wiki Activity

Err, defer.gatherResults ftw

Browse source
This commit is contained in:
Erik Johnston 2015-05-15 15:20:29 +01:00
parent acb12cc811
commit 807229f2f2
1 changed files with 12 additions and 21 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

33
synapse/handlers/message.py
View file

@ -303,27 +303,18 @@ class MessageHandler(BaseHandler):
if event.membership != Membership.JOIN: if event.membership != Membership.JOIN:
return return
try: try:
# (messages, token), current_state = yield defer.gatherResults( (messages, token), current_state = yield defer.gatherResults(
# [ [
# self.store.get_recent_events_for_room( self.store.get_recent_events_for_room(
# event.room_id, event.room_id,
# limit=limit, limit=limit,
# end_token=now_token.room_key, end_token=now_token.room_key,
# ), ),
# self.state_handler.get_current_state( self.state_handler.get_current_state(
# event.room_id event.room_id
# ), ),
# ] ]
# ).addErrback(unwrapFirstError) ).addErrback(unwrapFirstError)
messages, token = yield self.store.get_recent_events_for_room(
event.room_id,
limit=limit,
end_token=now_token.room_key,
)
current_state = yield self.state_handler.get_current_state(
event.room_id
)
start_token = now_token.copy_and_replace("room_key", token[0]) start_token = now_token.copy_and_replace("room_key", token[0])
end_token = now_token.copy_and_replace("room_key", token[1]) end_token = now_token.copy_and_replace("room_key", token[1])