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

Fix

Browse Source
This commit is contained in:
Daniil Gentili 2019-06-08 00:21:38 +00:00
parent a64e55cbd8
commit 7929e8053e
3 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
docs

@ -1 +1 @@
Subproject commit d06f79a1848bd380d6ad9a71a3ead0c2c2ded4a1 Subproject commit dc05dc5cebfcec90ac7851928c522a4d635dbab6

4
src/danog/MadelineProto/Loop/Update/UpdateLoop.php
View File

@ -93,17 +93,17 @@ class UpdateLoop extends ResumableSignalLoop
return true; return true;
} }
throw $e;
} catch (Exception $e) { } catch (Exception $e) {
if (in_array($e->getMessage(), ['This peer is not present in the internal peer database'])) { if (in_array($e->getMessage(), ['This peer is not present in the internal peer database'])) {
$feeder->signal(true); $feeder->signal(true);
//$API->getChannelStates()->remove($this->channelId); $API->getChannelStates()->remove($this->channelId);
unset($API->updaters[$this->channelId]); unset($API->updaters[$this->channelId]);
unset($API->feeders[$this->channelId]); unset($API->feeders[$this->channelId]);
$API->logger->logger("Channel private, exiting $this"); $API->logger->logger("Channel private, exiting $this");
return true; return true;
} }
throw $e; throw $e;
} }
if (isset($difference['timeout'])) { if (isset($difference['timeout'])) {

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

@ -296,6 +296,7 @@ trait ResponseHandler
break; break;
} }
} }
if ($this->datacenter->sockets[$datacenter]->pending_outgoing)
$this->datacenter->sockets[$datacenter]->writer->resume(); $this->datacenter->sockets[$datacenter]->writer->resume();
//$this->n--; //$this->n--;
@ -359,6 +360,7 @@ trait ResponseHandler
} }
switch ($response['error_code']) { switch ($response['error_code']) {
case 500: case 500:
case -500:
if ($response['error_message'] === 'MSG_WAIT_FAILED') { if ($response['error_message'] === 'MSG_WAIT_FAILED') {
$this->datacenter->sockets[$datacenter]->call_queue[$request['queue']] = []; $this->datacenter->sockets[$datacenter]->call_queue[$request['queue']] = [];
$this->method_recall('', ['message_id' => $request_id, 'datacenter' => $datacenter, 'postpone' => true]); $this->method_recall('', ['message_id' => $request_id, 'datacenter' => $datacenter, 'postpone' => true]);