diff --git a/docs b/docs index 4ed3a844..dfec70a8 160000 --- a/docs +++ b/docs @@ -1 +1 @@ -Subproject commit 4ed3a8447cf21c69322bcdaf149eb3ce0befe8c0 +Subproject commit dfec70a8c5a6a6eca9e9d47e582141bc8a86aba8 diff --git a/src/danog/MadelineProto/Loop/Connection/CheckLoop.php b/src/danog/MadelineProto/Loop/Connection/CheckLoop.php index e82d7c85..c1c4ce6d 100644 --- a/src/danog/MadelineProto/Loop/Connection/CheckLoop.php +++ b/src/danog/MadelineProto/Loop/Connection/CheckLoop.php @@ -118,7 +118,7 @@ class CheckLoop extends ResumableSignalLoop break; case 4: if ($chr & 32) { - if ($connection->new_outgoing[$message_id]['sent'] + $timeoutResend < \time()) { + if ($connection->outgoing_messages[$message_id]['sent'] + $timeoutResend < \time()) { $API->logger->logger('Message '.$connection->outgoing_messages[$message_id]['_'].' with message ID '.($message_id).' received by server and is being processed for way too long, resending request...', \danog\MadelineProto\Logger::ERROR); $connection->methodRecall('', ['message_id' => $message_id, 'postpone' => true]); } else { diff --git a/src/danog/MadelineProto/MTProtoSession/ResponseHandler.php b/src/danog/MadelineProto/MTProtoSession/ResponseHandler.php index 1268b469..764bf072 100644 --- a/src/danog/MadelineProto/MTProtoSession/ResponseHandler.php +++ b/src/danog/MadelineProto/MTProtoSession/ResponseHandler.php @@ -392,7 +392,7 @@ trait ResponseHandler return; } - if (\in_array($response['error_message'], ['MSGID_DECREASE_RETRY', 'RPC_CALL_FAIL', 'PERSISTENT_TIMESTAMP_OUTDATED', 'RPC_MCGET_FAIL', 'no workers running'])) { + if (\in_array($response['error_message'], ['MSGID_DECREASE_RETRY', 'RPC_CALL_FAIL', 'PERSISTENT_TIMESTAMP_OUTDATED', 'RPC_MCGET_FAIL', 'no workers running', 'No workers running'])) { Loop::delay(1 * 1000, [$this, 'methodRecall'], ['message_id' => $request_id, ]); return; }