diff --git a/src/danog/MadelineProto/MTProtoTools/CallHandler.php b/src/danog/MadelineProto/MTProtoTools/CallHandler.php index 8bf9fb18..9f5bf842 100644 --- a/src/danog/MadelineProto/MTProtoTools/CallHandler.php +++ b/src/danog/MadelineProto/MTProtoTools/CallHandler.php @@ -59,6 +59,7 @@ class CallHandler extends AuthKeyHandler if ($server_answer == null) { throw new Exception('An error occurred while calling method '.$method.'.'); } + return $server_answer; } throw new Exception('An error occurred while calling method '.$method.'.'); diff --git a/src/danog/MadelineProto/MTProtoTools/MsgIdHandler.php b/src/danog/MadelineProto/MTProtoTools/MsgIdHandler.php index 2a5ad76b..4214ca84 100644 --- a/src/danog/MadelineProto/MTProtoTools/MsgIdHandler.php +++ b/src/danog/MadelineProto/MTProtoTools/MsgIdHandler.php @@ -41,7 +41,7 @@ class MsgIdHandler extends MessageHandler if ($container) { asort($keys); if ($new_message_id >= end($keys)) { - throw new Exception('Given message id ('.$new_message_id.') is bigger than or equal than the current limit ('.end($keys).').'); + throw new Exception('Given message id ('.$new_message_id.') is bigger than or equal than the current limit ('.end($keys).').'); } } else { asort($keys); diff --git a/src/danog/MadelineProto/MTProtoTools/ResponseHandler.php b/src/danog/MadelineProto/MTProtoTools/ResponseHandler.php index face08fe..22f45cc2 100644 --- a/src/danog/MadelineProto/MTProtoTools/ResponseHandler.php +++ b/src/danog/MadelineProto/MTProtoTools/ResponseHandler.php @@ -97,6 +97,7 @@ class ResponseHandler extends MsgIdHandler } else { $this->check_message_id($message['orig_message']['msg_id'], false, true); $this->incoming_messages[$message['orig_message']['msg_id']] = ['content' => $response['orig_message']]; + return $this->handle_message($last_sent, $message['orig_message']['msg_id']); } break; @@ -106,6 +107,7 @@ class ResponseHandler extends MsgIdHandler break; case 'gzip_packed': $this->incoming_messages[$last_received]['content'] = gzdecode($response); + return $this->handle_message($last_sent, $last_received); break; case 'rpc_answer_dropped_running':