Browse Source

CMClient: fix identation for _parse_message

pull/18/merge
Rossen Georgiev 9 years ago
parent
commit
fa470a6b24
  1. 54
      steam/core/cm.py

54
steam/core/cm.py

@ -150,37 +150,37 @@ class CMClient(EventEmitter):
gevent.idle() gevent.idle()
def _parse_message(self, message): def _parse_message(self, message):
emsg_id, = struct.unpack_from("<I", message) emsg_id, = struct.unpack_from("<I", message)
emsg = EMsg(clear_proto_bit(emsg_id)) emsg = EMsg(clear_proto_bit(emsg_id))
if not self.connected and emsg != EMsg.ClientLogOnResponse: if not self.connected and emsg != EMsg.ClientLogOnResponse:
return return
if emsg in (EMsg.ChannelEncryptRequest, if emsg in (EMsg.ChannelEncryptRequest,
EMsg.ChannelEncryptResponse, EMsg.ChannelEncryptResponse,
EMsg.ChannelEncryptResult, EMsg.ChannelEncryptResult,
): ):
msg = Msg(emsg, message) msg = Msg(emsg, message)
else: else:
try: try:
if is_proto(emsg_id): if is_proto(emsg_id):
msg = MsgProto(emsg, message) msg = MsgProto(emsg, message)
else: else:
msg = Msg(emsg, message, extended=True) esg = Msg(emsg, message, extended=True)
except Exception as e: except Exception as e:
logger.fatal("Failed to deserialize message: %s (is_proto: %s)", logger.fatal("Failed to deserialize message: %s (is_proto: %s)",
str(emsg), str(emsg),
is_proto(emsg_id) is_proto(emsg_id)
) )
logger.exception(e) logger.exception(e)
if self.verbose_debug: if self.verbose_debug:
logger.debug("Incoming: %s\n%s" % (repr(msg), str(msg))) logger.debug("Incoming: %s\n%s" % (repr(msg), str(msg)))
else: else:
logger.debug("Incoming: %s", repr(msg)) logger.debug("Incoming: %s", repr(msg))
self.emit(emsg, msg) self.emit(emsg, msg)
def _handle_encrypt_request(self, msg): def _handle_encrypt_request(self, msg):
logger.debug("Securing channel") logger.debug("Securing channel")

Loading…
Cancel
Save