Skip to content

Commit 1f876fb

Browse files
committed
Fix prometheus stats
1 parent 0918f88 commit 1f876fb

4 files changed

Lines changed: 10 additions & 5 deletions

File tree

src/API.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ final class API extends AbstractAPI
5151
*
5252
* @var string
5353
*/
54-
public const RELEASE = '8.4.7';
54+
public const RELEASE = '8.4.8';
5555
/**
5656
* We're not logged in.
5757
*

src/Connection.php

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -559,6 +559,7 @@ public function sendMessage(MTProtoOutgoingMessage $message): void
559559
} elseif ($message->specialMethodType === SpecialMethodType::UNAUTHED_METHOD) {
560560
$this->uninitedPendingOutgoing->enqueue($message);
561561
} else {
562+
$this->pendingOutgoingGauge?->inc();
562563
$this->mainPendingOutgoing->enqueue($message);
563564
}
564565
$this->flush();

src/MTProto/MTProtoOutgoingMessage.php

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -205,8 +205,7 @@ public function sent(): void
205205
}
206206
$this->state |= self::STATE_SENT;
207207
if (!$this instanceof Container) {
208-
$this->next->prev = $this->prev;
209-
$this->prev->next = $this->next;
208+
$this->unlink();
210209
}
211210
$this->sent = hrtime(true);
212211
if ($this->contentRelated) {
@@ -221,6 +220,12 @@ public function sent(): void
221220
$sendDeferred->complete();
222221
}
223222
}
223+
public function unlink(): void
224+
{
225+
$this->next->prev = $this->prev;
226+
$this->prev->next = $this->next;
227+
$this->connection->pendingOutgoingGauge?->dec();
228+
}
224229
private function check(): void
225230
{
226231
if ($this->state & self::STATE_REPLIED) {

src/MTProtoSession/CallHandler.php

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -83,8 +83,7 @@ public function methodRecall(MTProtoOutgoingMessage $request, ?int $forceDatacen
8383
/** @var MTProtoOutgoingMessage */
8484
$request->setMsgId(null);
8585
$request->setSeqNo(null);
86-
$request->next->prev = $request->prev;
87-
$request->prev->next = $request->next;
86+
$request->unlink();
8887
}
8988
if ($datacenter === $this->datacenter) {
9089
EventLoop::queue($this->sendMessage(...), $request);

0 commit comments

Comments
 (0)