Add support for invokeWithBusinessConnection

Constantine0808 · Jul 2, 2024 · b4e0a78 · b4e0a78
1 parent 62b06f1
commit b4e0a78
Show file tree

Hide file tree

Showing 4 changed files with 13 additions and 1 deletion.
diff --git a/src/Connection.php b/src/Connection.php
@@ -565,6 +565,11 @@ public function sendMessage(MTProtoOutgoingMessage $message): void
                             'invokeWithTakeout',
                             ['takeout_id' => $message->takeoutId, 'query' => $body],
                         );
+                    } elseif ($message->businessConnectionId !== null) {
+                        $body = $this->API->getTL()->serializeMethod(
+                            'invokeWithBusinessConnection',
+                            ['connection_id' => $message->businessConnectionId, 'query' => $body],
+                        );
                     }
                 } else {
                     $body['_'] = $message->constructor;

diff --git a/src/MTProto/MTProtoOutgoingMessage.php b/src/MTProto/MTProtoOutgoingMessage.php
@@ -124,6 +124,7 @@ public function __construct(
          */
         public readonly ?int $floodWaitLimit = null,
         public readonly ?int $takeoutId = null,
+        public readonly ?string $businessConnectionId = null,
         private ?DeferredFuture $resultDeferred = null,
         public readonly ?Cancellation $cancellation = null
     ) {

diff --git a/src/MTProtoSession/CallHandler.php b/src/MTProtoSession/CallHandler.php
@@ -176,7 +176,8 @@ public function methodCallAsyncWrite(string $method, array $args): WrappedFuture
             floodWaitLimit: $args['floodWaitLimit'] ?? null,
             resultDeferred: $response,
             cancellation: $cancellation,
-            takeoutId: $args['takeoutId'] ?? null
+            takeoutId: $args['takeoutId'] ?? null,
+            businessConnectionId: $args['businessConnectionId'] ?? null,
         );
         if ($queueId !== null) {
             $this->callQueue[$queueId] = $message;

diff --git a/tools/AnnotationsBuilder.php b/tools/AnnotationsBuilder.php
@@ -388,6 +388,11 @@ private function prepareTLParams(array $data): array
             $signature []= "?int \$takeoutId = null";
         }
 
+        if (\in_array($method, ['messages.sendMessage', 'messages.editMessage', 'messages.sendMedia', 'messages.sendMultiMedia', 'messages.setTyping'], true)) {
+            $contents .= "     * @param ?string \$businessConnectionId Business connection ID, received through an updateBotBusinessConnect update.\n";
+            $signature []= "?string \$businessConnectionId = null";
+        }
+
         return [$contents, $signature];
     }
     /**