diff --git a/src/danog/MadelineProto/MTProtoTools/MessageHandler.php b/src/danog/MadelineProto/MTProtoTools/MessageHandler.php index 61ce324e..b0dd839b 100644 --- a/src/danog/MadelineProto/MTProtoTools/MessageHandler.php +++ b/src/danog/MadelineProto/MTProtoTools/MessageHandler.php @@ -20,7 +20,7 @@ trait MessageHandler { public function send_unencrypted_message($type, $message_data, $message_id, $datacenter) { - \danog\MadelineProto\Logger::log(["Sending $type as unencrypted message"], \danog\MadelineProto\Logger::ULTRA_VERBOSE); + \danog\MadelineProto\Logger::log(["Sending $type as unencrypted message to DC $datacenter"], \danog\MadelineProto\Logger::ULTRA_VERBOSE); $message_data = "\0\0\0\0\0\0\0\0".$message_id.$this->pack_unsigned_int(strlen($message_data)).$message_data; $this->datacenter->sockets[$datacenter]->outgoing_messages[$message_id] = ['response' => -1]; $this->datacenter->sockets[$datacenter]->send_message($message_data); @@ -32,13 +32,13 @@ trait MessageHandler if (count($this->datacenter->sockets[$datacenter]->object_queue) > 1) { $messages = []; - \danog\MadelineProto\Logger::log(['Sending msg_container as encrypted message'], \danog\MadelineProto\Logger::ULTRA_VERBOSE); + \danog\MadelineProto\Logger::log(["Sending msg_container as encrypted message to DC $datacenter"], \danog\MadelineProto\Logger::ULTRA_VERBOSE); foreach ($this->datacenter->sockets[$datacenter]->object_queue as $message) { $message['seqno'] = $this->generate_out_seq_no($datacenter, $message['content_related']); $message['bytes'] = strlen($message['body']); $has_ack = $has_ack || $message['_'] === 'msgs_ack'; - \danog\MadelineProto\Logger::log(["Inside of msg_container, sending {$message['_']} as encrypted message"], \danog\MadelineProto\Logger::ULTRA_VERBOSE); + \danog\MadelineProto\Logger::log(["Inside of msg_container, sending {$message['_']} as encrypted message to DC $datacenter"], \danog\MadelineProto\Logger::ULTRA_VERBOSE); $message['_'] = 'MTmessage'; $messages[] = $message; $this->datacenter->sockets[$datacenter]->outgoing_messages[$message['msg_id']] = ['seq_no' => $message['seqno'], 'response' => -1, 'content' => $this->deserialize($message['body'], ['type' => '', 'datacenter' => $datacenter])]; @@ -48,7 +48,7 @@ trait MessageHandler $seq_no = $this->generate_out_seq_no($datacenter, false); } elseif (count($this->datacenter->sockets[$datacenter]->object_queue)) { $message = array_shift($this->datacenter->sockets[$datacenter]->object_queue); - \danog\MadelineProto\Logger::log(["Sending {$message['_']} as encrypted message"], \danog\MadelineProto\Logger::ULTRA_VERBOSE); + \danog\MadelineProto\Logger::log(["Sending {$message['_']} as encrypted message to DC $datacenter"], \danog\MadelineProto\Logger::ULTRA_VERBOSE); $message_data = $message['body']; $message_id = $message['msg_id']; $seq_no = $this->generate_out_seq_no($datacenter, $message['content_related']); @@ -92,7 +92,7 @@ trait MessageHandler $payload = $this->datacenter->sockets[$datacenter]->read_message(); if (strlen($payload) === 4) { $payload = $this->unpack_signed_int($payload); - \danog\MadelineProto\Logger::log(["Received $payload"], \danog\MadelineProto\Logger::ULTRA_VERBOSE); + \danog\MadelineProto\Logger::log(["Received $payload from DC $datacenter"], \danog\MadelineProto\Logger::ULTRA_VERBOSE); return $payload; } diff --git a/src/danog/MadelineProto/MTProtoTools/ResponseHandler.php b/src/danog/MadelineProto/MTProtoTools/ResponseHandler.php index 8b173226..193f9b4c 100644 --- a/src/danog/MadelineProto/MTProtoTools/ResponseHandler.php +++ b/src/danog/MadelineProto/MTProtoTools/ResponseHandler.php @@ -48,7 +48,7 @@ trait ResponseHandler $only_updates = true; foreach ($this->datacenter->sockets[$datacenter]->new_incoming as $current_msg_id) { $unset = false; - \danog\MadelineProto\Logger::log([(isset($this->datacenter->sockets[$datacenter]->incoming_messages[$current_msg_id]['from_container']) ? 'Inside of container, received ' : 'Received ').$this->datacenter->sockets[$datacenter]->incoming_messages[$current_msg_id]['content']['_'].'.'], \danog\MadelineProto\Logger::ULTRA_VERBOSE); + \danog\MadelineProto\Logger::log([(isset($this->datacenter->sockets[$datacenter]->incoming_messages[$current_msg_id]['from_container']) ? 'Inside of container, received ' : 'Received ').$this->datacenter->sockets[$datacenter]->incoming_messages[$current_msg_id]['content']['_'].' from DC '.$datacenter], \danog\MadelineProto\Logger::ULTRA_VERBOSE); //\danog\MadelineProto\Logger::log([$this->datacenter->sockets[$datacenter]->incoming_messages[$current_msg_id]['content']], \danog\MadelineProto\Logger::ULTRA_VERBOSE); if (\danog\MadelineProto\Logger::$has_thread && is_object(\Thread::getCurrentThread())) { if (!$this->synchronized(function ($zis, $datacenter, $current_msg_id) {