tileradotorg/synapse
1
0
Fork 0
forked from MirrorHub/synapse
Code Pull requests Activity

Remove redundant token_id parameter to create_event

Browse source 
this is always the same as requester.access_token_id.
This commit is contained in:
Richard van der Hoff 2020-10-13 23:06:36 +01:00
parent 629a951b49
commit d9d86c2996
4 changed files with 3 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
synapse/handlers/message.py
View file

@ -437,7 +437,6 @@ class EventCreationHandler:
self, self,
requester: Requester, requester: Requester,
event_dict: dict, event_dict: dict,
token_id: Optional[str] = None,
txn_id: Optional[str] = None, txn_id: Optional[str] = None,
prev_event_ids: Optional[List[str]] = None, prev_event_ids: Optional[List[str]] = None,
require_consent: bool = True, require_consent: bool = True,
@ -453,7 +452,6 @@ class EventCreationHandler:
Args: Args:
requester requester
event_dict: An entire event event_dict: An entire event
token_id
txn_id txn_id
prev_event_ids: prev_event_ids:
the forward extremities to use as the prev_events for the the forward extremities to use as the prev_events for the
@ -511,8 +509,8 @@ class EventCreationHandler:
if require_consent and not is_exempt: if require_consent and not is_exempt:
await self.assert_accepted_privacy_policy(requester) await self.assert_accepted_privacy_policy(requester)
if token_id is not None: if requester.access_token_id is not None:
builder.internal_metadata.token_id = token_id builder.internal_metadata.token_id = requester.access_token_id
if txn_id is not None: if txn_id is not None:
builder.internal_metadata.txn_id = txn_id builder.internal_metadata.txn_id = txn_id
@ -726,7 +724,7 @@ class EventCreationHandler:
return event, event.internal_metadata.stream_ordering return event, event.internal_metadata.stream_ordering
event, context = await self.create_event( event, context = await self.create_event(
requester, event_dict, token_id=requester.access_token_id, txn_id=txn_id requester, event_dict, txn_id=txn_id
) )
assert self.hs.is_mine_id(event.sender), "User must be our own: %s" % ( assert self.hs.is_mine_id(event.sender), "User must be our own: %s" % (

1
synapse/handlers/room.py
View file

@ -214,7 +214,6 @@ class RoomCreationHandler(BaseHandler):
"replacement_room": new_room_id, "replacement_room": new_room_id,
}, },
}, },
token_id=requester.access_token_id,
) )
old_room_version = await self.store.get_room_version_id(old_room_id) old_room_version = await self.store.get_room_version_id(old_room_id)
await self.auth.check_from_context( await self.auth.check_from_context(

1
synapse/handlers/room_member.py
View file

@ -193,7 +193,6 @@ class RoomMemberHandler(metaclass=abc.ABCMeta):
# For backwards compatibility: # For backwards compatibility:
"membership": membership, "membership": membership,
}, },
token_id=requester.access_token_id,
txn_id=txn_id, txn_id=txn_id,
prev_event_ids=prev_event_ids, prev_event_ids=prev_event_ids,
require_consent=require_consent, require_consent=require_consent,

1
tests/handlers/test_message.py
View file

@ -66,7 +66,6 @@ class EventCreationTestCase(unittest.HomeserverTestCase):
"sender": self.requester.user.to_string(), "sender": self.requester.user.to_string(),
"content": {"msgtype": "m.text", "body": random_string(5)}, "content": {"msgtype": "m.text", "body": random_string(5)},
}, },
token_id=self.token_id,
txn_id=txn_id, txn_id=txn_id,
) )
) )