[FIX] Replace toArray methods

Author: Iyadhfaleh

src/Bridge/Anthropic/ModelHandler.php

@@ -4,6 +4,7 @@
 
 namespace PhpLlm\LlmChain\Bridge\Anthropic;
 
+use http\Exception\RuntimeException;
 use PhpLlm\LlmChain\Model\Message\MessageBag;
 use PhpLlm\LlmChain\Model\Model;
 use PhpLlm\LlmChain\Model\Response\ResponseInterface as LlmResponse;
@@ -14,6 +15,10 @@
 use Symfony\Component\HttpClient\Chunk\ServerSentEvent;
 use Symfony\Component\HttpClient\EventSourceHttpClient;
 use Symfony\Component\HttpClient\Exception\JsonException;
+use Symfony\Contracts\HttpClient\Exception\ClientExceptionInterface;
+use Symfony\Contracts\HttpClient\Exception\RedirectionExceptionInterface;
+use Symfony\Contracts\HttpClient\Exception\ServerExceptionInterface;
+use Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface;
 use Symfony\Contracts\HttpClient\HttpClientInterface;
 use Symfony\Contracts\HttpClient\ResponseInterface;
 use Webmozart\Assert\Assert;
@@ -55,13 +60,27 @@ public function request(Model $model, object|array|string $input, array $options
         ]);
     }
 
+    /**
+     * @throws TransportExceptionInterface
+     * @throws ServerExceptionInterface
+     * @throws RedirectionExceptionInterface
+     * @throws ClientExceptionInterface
+     */
     public function convert(ResponseInterface $response, array $options = []): LlmResponse
     {
         if ($options['stream'] ?? false) {
             return new StreamResponse($this->convertStream($response));
         }
 
-        $data = $response->toArray();
+        $data = json_decode($response->getContent(false), true);
+
+        if (!isset($data['content']) || !count($data['content'])) {
+            throw new RuntimeException('Response does not contain any content');
+        }
+
+        if (!isset($data['content'][0]['text'])) {
+            throw new RuntimeException('Response content does not contain any text');
+        }
 
         return new TextResponse($data['content'][0]['text']);
     }

src/Bridge/Ollama/LlamaModelHandler.php

@@ -4,6 +4,7 @@
 
 namespace PhpLlm\LlmChain\Bridge\Ollama;
 
+use http\Exception\RuntimeException;
 use PhpLlm\LlmChain\Bridge\Meta\Llama;
 use PhpLlm\LlmChain\Model\Message\MessageBag;
 use PhpLlm\LlmChain\Model\Model;
@@ -41,7 +42,15 @@ public function request(Model $model, object|array|string $input, array $options
 
     public function convert(ResponseInterface $response, array $options = []): LlmResponse
     {
-        $data = $response->toArray();
+        $data = json_decode($response->getContent(false), true);
+
+        if (!isset($data['message'])) {
+            throw new RuntimeException('Response does not contain message');
+        }
+
+        if (!isset($data['message']['content'])) {
+            throw new RuntimeException('Message does not contain content');
+        }
 
         return new TextResponse($data['message']['content']);
     }

src/Bridge/OpenAI/Embeddings/ResponseConverter.php

@@ -6,6 +6,7 @@
 
 use PhpLlm\LlmChain\Bridge\OpenAI\Embeddings;
 use PhpLlm\LlmChain\Document\Vector;
+use PhpLlm\LlmChain\Exception\RuntimeException;
 use PhpLlm\LlmChain\Model\Model;
 use PhpLlm\LlmChain\Model\Response\VectorResponse;
 use PhpLlm\LlmChain\Platform\ResponseConverter as PlatformResponseConverter;
@@ -20,7 +21,11 @@ public function supports(Model $model, array|string|object $input): bool
 
     public function convert(ResponseInterface $response, array $options = []): VectorResponse
     {
-        $data = $response->toArray();
+        $data = json_decode($response->getContent(false), true);
+
+        if (!isset($data['data'])) {
+            throw new RuntimeException('Response does not contain data');
+        }
 
         return new VectorResponse(
             ...\array_map(

src/Bridge/OpenAI/GPT/ResponseConverter.php

@@ -33,7 +33,7 @@ public function convert(HttpResponse $response, array $options = []): LlmRespons
             return $this->convertStream($response);
         }
 
-        $data = $response->toArray();
+        $data = json_decode($response->getContent(false), true);
 
         if (!isset($data['choices'])) {
             throw new RuntimeException('Response does not contain choices');

src/Bridge/Replicate/LlamaResponseConverter.php

@@ -4,6 +4,7 @@
 
 namespace PhpLlm\LlmChain\Bridge\Replicate;
 
+use http\Exception\RuntimeException;
 use PhpLlm\LlmChain\Bridge\Meta\Llama;
 use PhpLlm\LlmChain\Model\Message\MessageBag;
 use PhpLlm\LlmChain\Model\Model;
@@ -21,7 +22,11 @@ public function supports(Model $model, object|array|string $input): bool
 
     public function convert(HttpResponse $response, array $options = []): LlmResponse
     {
-        $data = $response->toArray();
+        $data = json_decode($response->getContent(false), true);
+
+        if (!isset($data['output'])) {
+            throw new RuntimeException('Response does not contain output');
+        }
 
         return new TextResponse(implode('', $data['output']));
     }

src/Bridge/Voyage/ModelHandler.php

@@ -4,6 +4,7 @@
 
 namespace PhpLlm\LlmChain\Bridge\Voyage;
 
+use http\Exception\RuntimeException;
 use PhpLlm\LlmChain\Document\Vector;
 use PhpLlm\LlmChain\Model\Model;
 use PhpLlm\LlmChain\Model\Response\ResponseInterface as LlmResponse;
@@ -39,7 +40,11 @@ public function request(Model $model, object|string|array $input, array $options
 
     public function convert(ResponseInterface $response, array $options = []): LlmResponse
     {
-        $response = $response->toArray();
+        $response = json_decode($response->getContent(false), true);
+
+        if (!isset($data['embedding']) || !isset($data['data'])) {
+            throw new RuntimeException('Response does not contain embedding data');
+        }
 
         $vectors = array_map(fn (array $data) => new Vector($data['embedding']), $response['data']);
 

tests/Bridge/OpenAI/Embeddings/ResponseConverterTest.php

@@ -20,8 +20,8 @@ public function itConvertsAResponseToAVectorResponse(): void
     {
         $response = $this->createStub(ResponseInterface::class);
         $response
-            ->method('toArray')
-            ->willReturn(\json_decode($this->getEmbeddingStub(), true));
+            ->method('getContent')
+            ->willReturn($this->getEmbeddingStub());
 
         $vectorResponse = (new ResponseConverter())->convert($response);
         $convertedContent = $vectorResponse->getContent();