ref

Author: Guikingone

examples/elevenlabs/text-to-speech-as-stream.php

@@ -29,7 +29,7 @@
 $content = '';
 
 foreach ($result->asStream() as $chunk) {
-    $content .= $chunk->getContent();
+    echo $chunk;
 }
 
-echo $content.\PHP_EOL;
+echo \PHP_EOL;

src/platform/src/Bridge/ElevenLabs/ElevenLabsClient.php

@@ -91,19 +91,15 @@ private function doTextToSpeechRequest(Model $model, array|string $payload, arra
             ? \sprintf('%s/text-to-speech/%s/stream', $this->hostUrl, $voice)
             : \sprintf('%s/text-to-speech/%s', $this->hostUrl, $voice);
 
-        $response = $this->httpClient->request('POST', $url, [
+        return new RawHttpResult($this->httpClient->request('POST', $url, [
             'headers' => [
                 'xi-api-key' => $this->apiKey,
             ],
             'json' => [
                 'text' => $payload['text'],
                 'model_id' => $model->getName(),
             ],
-        ]);
-
-        return $stream
-            ? new RawHttpResult($this->httpClient->stream($response))
-            : new RawHttpResult($response);
+        ]));
     }
 
     /**

src/platform/src/Bridge/ElevenLabs/ElevenLabsResultConverter.php

@@ -19,46 +19,49 @@
 use Symfony\AI\Platform\Result\StreamResult;
 use Symfony\AI\Platform\Result\TextResult;
 use Symfony\AI\Platform\ResultConverterInterface;
+use Symfony\Contracts\HttpClient\HttpClientInterface;
 use Symfony\Contracts\HttpClient\ResponseInterface;
-use Symfony\Contracts\HttpClient\ResponseStreamInterface;
 
 /**
  * @author Guillaume Loulier <[email protected]>
  */
 final readonly class ElevenLabsResultConverter implements ResultConverterInterface
 {
+    public function __construct(
+        private HttpClientInterface $httpClient,
+    ) {
+    }
+
     public function supports(Model $model): bool
     {
         return $model instanceof ElevenLabs;
     }
 
     public function convert(RawResultInterface $result, array $options = []): ResultInterface
     {
-        /** @var ResponseInterface|ResponseStreamInterface $response */
+        /** @var ResponseInterface $response */
         $response = $result->getObject();
 
         return match (true) {
-            $response instanceof ResponseStreamInterface => new StreamResult($this->convertToGenerator($response)),
+            \array_key_exists('stream', $options) && $options['stream'] => new StreamResult($this->convertToGenerator($response)),
             str_contains($response->getInfo('url'), 'speech-to-text') => new TextResult($result->getData()['text']),
             str_contains($response->getInfo('url'), 'text-to-speech') => new BinaryResult($result->getObject()->getContent(), 'audio/mpeg'),
             default => throw new RuntimeException('Unsupported ElevenLabs response.'),
         };
     }
 
-    private function convertToGenerator(ResponseStreamInterface $response): \Generator
+    private function convertToGenerator(ResponseInterface $response): \Generator
     {
-        return (static function () use ($response): \Generator {
-            foreach ($response as $chunk) {
-                if ($chunk->isFirst()) {
-                    continue;
-                }
-
-                if ('' === $chunk->getContent()) {
-                    continue;
-                }
+        foreach ($this->httpClient->stream($response) as $chunk) {
+            if ($chunk->isFirst() || $chunk->isLast()) {
+                continue;
+            }
 
-                yield $chunk;
+            if ('' === $chunk->getContent()) {
+                continue;
             }
-        })();
+
+            yield $chunk->getContent();
+        }
     }
 }

src/platform/src/Bridge/ElevenLabs/PlatformFactory.php

@@ -32,7 +32,7 @@ public static function create(
 
         return new Platform(
             [new ElevenLabsClient($httpClient, $apiKey, $hostUrl)],
-            [new ElevenLabsResultConverter()],
+            [new ElevenLabsResultConverter($httpClient)],
             $contract ?? ElevenLabsContract::create(),
         );
     }

src/platform/src/Result/RawHttpResult.php

@@ -12,28 +12,23 @@
 namespace Symfony\AI\Platform\Result;
 
 use Symfony\Contracts\HttpClient\ResponseInterface;
-use Symfony\Contracts\HttpClient\ResponseStreamInterface;
 
 /**
  * @author Christopher Hertel <[email protected]
  */
 final readonly class RawHttpResult implements RawResultInterface
 {
     public function __construct(
-        private ResponseInterface|ResponseStreamInterface $response,
+        private ResponseInterface $response,
     ) {
     }
 
     public function getData(): array
     {
-        if ($this->response instanceof ResponseStreamInterface) {
-            return [];
-        }
-
         return $this->response->toArray(false);
     }
 
-    public function getObject(): ResponseInterface|ResponseStreamInterface
+    public function getObject(): ResponseInterface
     {
         return $this->response;
     }

src/platform/tests/Bridge/ElevenLabs/ElevenLabsConverterTest.php

@@ -20,6 +20,7 @@
 use Symfony\AI\Platform\Result\BinaryResult;
 use Symfony\AI\Platform\Result\InMemoryRawResult;
 use Symfony\AI\Platform\Result\TextResult;
+use Symfony\Component\HttpClient\MockHttpClient;
 
 #[CoversClass(ElevenLabsResultConverter::class)]
 #[UsesClass(ElevenLabs::class)]
@@ -31,15 +32,15 @@ final class ElevenLabsConverterTest extends TestCase
 {
     public function testSupportsModel()
     {
-        $converter = new ElevenLabsResultConverter();
+        $converter = new ElevenLabsResultConverter(new MockHttpClient());
 
         $this->assertTrue($converter->supports(new ElevenLabs()));
         $this->assertFalse($converter->supports(new Model('any-model')));
     }
 
     public function testConvertSpeechToTextResponse()
     {
-        $converter = new ElevenLabsResultConverter();
+        $converter = new ElevenLabsResultConverter(new MockHttpClient());
         $rawResult = new InMemoryRawResult([
             'text' => 'Hello there',
         ], new class {
@@ -57,7 +58,7 @@ public function getInfo(): string
 
     public function testConvertTextToSpeechResponse()
     {
-        $converter = new ElevenLabsResultConverter();
+        $converter = new ElevenLabsResultConverter(new MockHttpClient());
         $rawResult = new InMemoryRawResult([], new class {
             public function getInfo(): string
             {