ref

Author: Guikingone

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

@@ -87,29 +87,23 @@ private function doTextToSpeechRequest(Model $model, array|string $payload, arra
         $voice = $options['voice'] ??= $model->getOptions()['voice'];
         $stream = $options['stream'] ??= $model->getOptions()['stream'] ?? false;
 
-        if ($stream) {
-            $streamSource = $this->httpClient->request('POST', \sprintf('%s/text-to-speech/%s/stream', $this->hostUrl, $voice), [
-                'headers' => [
-                    'xi-api-key' => $this->apiKey,
-                ],
-                'json' => [
-                    'text' => $payload['text'],
-                    'model_id' => $model->getName(),
-                ],
-            ]);
-
-            return new RawHttpResult($this->httpClient->stream($streamSource));
-        }
+        $url = $stream
+            ? \sprintf('%s/text-to-speech/%s/stream', $this->hostUrl, $voice)
+            : \sprintf('%s/text-to-speech/%s', $this->hostUrl, $voice);
 
-        return new RawHttpResult($this->httpClient->request('POST', \sprintf('%s/text-to-speech/%s', $this->hostUrl, $voice), [
+        $response = $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

@@ -38,22 +38,27 @@ public function convert(RawResultInterface $result, array $options = []): Result
         $response = $result->getObject();
 
         return match (true) {
-            $response instanceof ResponseStreamInterface => new StreamResult((static function () use ($response): \Generator {
-                foreach ($response as $chunk) {
-                    if ($chunk->isFirst()) {
-                        continue;
-                    }
-
-                    if ('' === $chunk->getContent()) {
-                        continue;
-                    }
-
-                    yield $chunk;
-                }
-            })()),
+            $response instanceof ResponseStreamInterface => 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
+    {
+        return (static function () use ($response): \Generator {
+            foreach ($response as $chunk) {
+                if ($chunk->isFirst()) {
+                    continue;
+                }
+
+                if ('' === $chunk->getContent()) {
+                    continue;
+                }
+
+                yield $chunk;
+            }
+        })();
+    }
 }

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

@@ -30,7 +30,7 @@
 #[UsesClass(Model::class)]
 #[UsesClass(Audio::class)]
 #[UsesClass(AudioNormalizer::class)]
-#[UsesClass(RawHttpStreamResult::class)]
+#[UsesClass(RawHttpResult::class)]
 final class ElevenLabsClientTest extends TestCase
 {
     public function testSupportsModel()