fix objects handler; add support for throttling

Author: maximerenou

README.md

@@ -1,7 +1,5 @@
 # Bing AI client
 
-> For now you need to have access to Bing Chat open beta. Or grab the cookie from someone who has access.
-
 This is an unofficial Composer package for using Bing AI technology.
 
 It comes with no warranty of continuous stability.
@@ -50,6 +48,18 @@ $identifiers = $conversation->getIdentifiers();
 $conversation = $ai->createChatConversation($cookie, $identifiers, 1);
 ```
 
+#### Throttling
+
+Bing is limiting messages count per conversations. You can monitor it by calling `getRemainingMessages()` after every interaction.
+
+```php
+$remaining = $conversation->getRemainingMessages();
+
+if ($remaining === 0) {
+    // You reached the limit
+}
+```
+
 #### Text generation
 
 Note: to prevent answers like "I have already written \[...]", you can disable cache for your prompt with `withoutCache()`.
@@ -68,4 +78,4 @@ $conversation->ask($prompt->withoutCache(), ...)
 ---------------------------------------
 
 Using Bing AI API outside bing.com may violate Bing AI terms. Use it at your own risk.
-Bing is a trademark of Microsoft.
+Bing is a trademark of Microsoft.

examples/chat.php

@@ -13,7 +13,6 @@
 
 \MaximeRenou\BingAI\Tools::$debug = false; // Set true for verbose
 
-echo "Warning: Bing AI is currently limited to 5 questions per sessions." . PHP_EOL;
 echo 'Type "q" to quit' . PHP_EOL;
 
 while (true) {
@@ -42,6 +41,15 @@
 
     // Print final answer
     echo "- $text" . PHP_EOL;
+
+    $remaining = $conversation->getRemainingMessages();
+
+    if ($remaining != 0) {
+        echo "[$remaining remaining messages]" . PHP_EOL;
+    } else {
+        echo "[Limit reached]" . PHP_EOL;
+        break;
+    }
 }
 
 exit(0);

src/Chat/Conversation.php

@@ -36,6 +36,10 @@ class Conversation
 
     protected $current_messages;
 
+    protected $user_messages_count;
+
+    protected $max_messages_count;
+
     //
 
     public function __construct($cookie, $identifiers = null, $invocations = 0)
@@ -72,6 +76,14 @@ public function withLocation($latitude, $longitude, $radius = 1000)
         return $this;
     }
 
+    public function getRemainingMessages()
+    {
+        if (is_null($this->max_messages_count))
+            return 1;
+
+        return $this->max_messages_count - $this->user_messages_count;
+    }
+
     public function createIdentifiers($cookie)
     {
         $request = curl_init();
@@ -253,8 +265,20 @@ public function handleObject($object, $callback = null)
                 $messages = [];
 
                 foreach ($object['arguments'] as $argument) {
-                    foreach ($argument['messages'] as $messageData) {
-                        $messages[] = Message::fromData($messageData);
+                    if (isset($argument['messages']) && is_array($argument['messages'])) {
+                        foreach ($argument['messages'] as $messageData) {
+                            $messages[] = Message::fromData($messageData);
+                        }
+                    }
+
+                    if (isset($argument['throttling']) && is_array($argument['throttling'])) {
+                        if (isset($argument['throttling']['maxNumUserMessagesInConversation'])) {
+                            $this->max_messages_count = $argument['throttling']['maxNumUserMessagesInConversation'];
+                        }
+
+                        if (isset($argument['throttling']['numUserMessagesInConversation'])) {
+                            $this->user_messages_count = $argument['throttling']['numUserMessagesInConversation'];
+                        }
                     }
                 }
 
@@ -278,8 +302,20 @@ public function handleObject($object, $callback = null)
             case 2: // Global result
                 $this->current_messages = [];
 
-                foreach ($object['item']['messages'] as $messageData) {
-                    $this->current_messages[] = Message::fromData($messageData);
+                if (isset($object['item']['messages']) && is_array($object['item']['messages'])) {
+                    foreach ($object['item']['messages'] as $messageData) {
+                        $this->current_messages[] = Message::fromData($messageData);
+                    }
+                }
+
+                if (isset($object['item']['throttling']) && is_array($object['item']['throttling'])) {
+                    if (isset($object['item']['throttling']['maxNumUserMessagesInConversation'])) {
+                        $this->max_messages_count = $object['item']['throttling']['maxNumUserMessagesInConversation'];
+                    }
+
+                    if (isset($object['item']['throttling']['numUserMessagesInConversation'])) {
+                        $this->user_messages_count = $object['item']['throttling']['numUserMessagesInConversation'];
+                    }
                 }
                 break;
             case 3: // Answer ended