danog/MadelineProto
2
2
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Small workaround

Browse Source
This commit is contained in:
Daniil Gentili 2019-06-25 18:11:42 +02:00
parent 214fc0d0f9
commit eafa19eb4e
1 changed files with 17 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/danog/MadelineProto/MTProtoTools/ResponseHandler.php
View File

@ -312,7 +312,15 @@ trait ResponseHandler
if (isset($request['promise'])) {
$promise = $request['promise'];
unset($request['promise']);
$promise->fail($data);
try {
$promise->fail($data);
} catch (\Error $e) {
if (strpos($e->getMessage(), "Promise has already been resolved") !== 0) {
throw $e;
}
$this->logger->logger("Got promise already resolved error", \danog\MadelineProto\Logger::FATAL_ERROR);
}
} else {
$this->logger->logger('Rejecting: already got response for '.(isset($request['_']) ? $request['_'] : '-'));
$this->logger->logger("Rejecting: $data");
@ -576,7 +584,14 @@ trait ResponseHandler
if (isset($this->datacenter->sockets[$datacenter]->outgoing_messages[$request_id]['promise'])) { // This should not happen but happens, should debug
$promise = $this->datacenter->sockets[$datacenter]->outgoing_messages[$request_id]['promise'];
unset($this->datacenter->sockets[$datacenter]->outgoing_messages[$request_id]['promise']);
$promise->resolve($response);
try {
$promise->resolve($response);
} catch (\Error $e) {
if (strpos($e->getMessage(), "Promise has already been resolved") !== 0) {
throw $e;
}
$this->logger->logger("Got promise already resolved error", \danog\MadelineProto\Logger::FATAL_ERROR);
}
}
}
)());