diff --git a/src/danog/MadelineProto/MTProtoSession/CallHandler.php b/src/danog/MadelineProto/MTProtoSession/CallHandler.php index 2103540f..e92b4f15 100644 --- a/src/danog/MadelineProto/MTProtoSession/CallHandler.php +++ b/src/danog/MadelineProto/MTProtoSession/CallHandler.php @@ -50,14 +50,16 @@ trait CallHandler foreach ($message_ids as $message_id) { if (isset($this->outgoing_messages[$message_id]['body'])) { if ($datacenter) { + unset($this->outgoing_messages[$message_id]['msg_id']); + unset($this->outgoing_messages[$message_id]['seqno']); Tools::call($this->API->datacenter->waitGetConnection($datacenter))->onResolve(function ($e, $r) use ($message_id) { Tools::callFork($r->sendMessage($this->outgoing_messages[$message_id], false)); }); + $this->ackOutgoingMessageId($message_id); + $this->gotResponseForOutgoingMessageId($message_id); } else { Tools::callFork($this->sendMessage($this->outgoing_messages[$message_id], false)); } - //$this->ackOutgoingMessageId($message_id); - //$this->gotResponseForOutgoingMessageId($message_id); } else { $this->logger->logger('Could not resend '.(isset($this->outgoing_messages[$message_id]['_']) ? $this->outgoing_messages[$message_id]['_'] : $message_id)); }