Get rid of extra_data in the MatrixMessage class.

This commit is contained in:
poljar (Damir Jelić) 2018-02-08 14:40:20 +01:00
parent 39c8591926
commit ef99a13806
2 changed files with 15 additions and 13 deletions

View file

@ -224,7 +224,6 @@ class MatrixMessage:
message_type, # type: MessageType message_type, # type: MessageType
room_id=None, # type: str room_id=None, # type: str
data={}, # type: Dict[str, Any] data={}, # type: Dict[str, Any]
extra_data=None, # type: Dict[str, Any]
**kwargs **kwargs
): ):
# type: (...) -> None # type: (...) -> None
@ -236,7 +235,7 @@ class MatrixMessage:
self.request = None # type: HttpRequest self.request = None # type: HttpRequest
self.response = None # type: HttpResponse self.response = None # type: HttpResponse
self.extra_data = extra_data # type: Dict[str, Any] self.decoded_response = None # type: Dict[Any, Any]
self.creation_time = time.time() # type: float self.creation_time = time.time() # type: float
self.send_time = None # type: float self.send_time = None # type: float
@ -267,6 +266,7 @@ class MatrixMessage:
data["formatted_content"] = formatted_to_html( data["formatted_content"] = formatted_to_html(
self.formatted_message) self.formatted_message)
self.room_id = room_id
self.request = server.client.room_send_message(room_id, **data) self.request = server.client.room_send_message(room_id, **data)
elif message_type == MessageType.TOPIC: elif message_type == MessageType.TOPIC:

View file

@ -676,11 +676,11 @@ def matrix_handle_old_messages(server, room_id, events):
def matrix_handle_message( def matrix_handle_message(
server, # type: MatrixServer server, # type: MatrixServer
message_type, # type: MessageType message, # type: MatrixMessage
response, # type: Dict[str, Any]
extra_data # type: Dict[str, Any]
): ):
# type: (...) -> None # type: (...) -> None
message_type = message.type
response = message.decoded_response
if message_type is MessageType.LOGIN: if message_type is MessageType.LOGIN:
server.access_token = response["access_token"] server.access_token = response["access_token"]
@ -706,9 +706,13 @@ def matrix_handle_message(
matrix_sync(server) matrix_sync(server)
elif message_type is MessageType.SEND: elif message_type is MessageType.SEND:
author = extra_data["author"] room_id = message.room_id
message = extra_data["message"] author = server.user
room_id = extra_data["room_id"] weechat_message = colors.formatted_to_weechat(
W,
message.formatted_message
)
date = int(time.time()) date = int(time.time())
# TODO the event_id can be missing if sending has failed for # TODO the event_id can be missing if sending has failed for
# some reason # some reason
@ -725,7 +729,7 @@ def matrix_handle_message(
color=color_for_tags("weechat.color.chat_nick_self"), color=color_for_tags("weechat.color.chat_nick_self"),
event_id=event_id) event_id=event_id)
data = "{author}\t{msg}".format(author=author, msg=message) data = "{author}\t{msg}".format(author=author, msg=weechat_message)
buf = server.buffers[room_id] buf = server.buffers[room_id]
W.prnt_date_tags(buf, date, tag, data) W.prnt_date_tags(buf, date, tag, data)
@ -775,7 +779,7 @@ def handle_http_response(server, message):
return None return None
if status_code == 200: if status_code == 200:
response = decode_json(server, message.response.body) message.decoded_response = decode_json(server, message.response.body)
# if not response: # if not response:
# # Resend the message # # Resend the message
@ -785,9 +789,7 @@ def handle_http_response(server, message):
matrix_handle_message( matrix_handle_message(
server, server,
message.type, message,
response,
message.extra_data
) )
# TODO handle try again response # TODO handle try again response