feature #284 [Platform] Add Cerebras (junaidbinfarooq)

This PR was squashed before being merged into the main branch.

Discussion
----------

[Platform] Add Cerebras

| Q             | A
| ------------- | ---
| Bug fix?      | no
| New feature?  | yes
| Docs?         | yes
| Issues        | #16
| License       | MIT

This PR adds support for the [Cerebras](https://inference-docs.cerebras.ai/) platform

Commits
-------

a9954c1 [Platform] Add Cerebras

Author: chr-hertel

examples/.env

@@ -104,3 +104,6 @@ NEO4J_PASSWORD=symfonyai
 # Typesense
 TYPESENSE_HOST=http://127.0.0.1:8108
 TYPESENSE_API_KEY=changeMe
+
+# Cerebras
+CEREBRAS_API_KEY=

examples/cerebras/chat.php

@@ -0,0 +1,29 @@
+<?php
+
+/*
+ * This file is part of the Symfony package.
+ *
+ * (c) Fabien Potencier <[email protected]>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+use Symfony\AI\Agent\Agent;
+use Symfony\AI\Platform\Bridge\Cerebras\Model;
+use Symfony\AI\Platform\Bridge\Cerebras\PlatformFactory;
+use Symfony\AI\Platform\Message\Message;
+use Symfony\AI\Platform\Message\MessageBag;
+
+require_once dirname(__DIR__).'/bootstrap.php';
+
+$platform = PlatformFactory::create(env('CEREBRAS_API_KEY'), http_client());
+
+$agent = new Agent($platform, new Model(), logger: logger());
+$messages = new MessageBag(
+    Message::forSystem('You are a helpful assistant.'),
+    Message::ofUser('How is the weather in Tokyo today?'),
+);
+$result = $agent->call($messages);
+
+echo $result->getContent().\PHP_EOL;

examples/cerebras/stream.php

@@ -0,0 +1,36 @@
+<?php
+
+/*
+ * This file is part of the Symfony package.
+ *
+ * (c) Fabien Potencier <[email protected]>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+use Symfony\AI\Agent\Agent;
+use Symfony\AI\Platform\Bridge\Cerebras\Model;
+use Symfony\AI\Platform\Bridge\Cerebras\PlatformFactory;
+use Symfony\AI\Platform\Message\Message;
+use Symfony\AI\Platform\Message\MessageBag;
+
+require_once dirname(__DIR__).'/bootstrap.php';
+
+$platform = PlatformFactory::create(env('CEREBRAS_API_KEY'), http_client());
+
+$agent = new Agent($platform, new Model(), logger: logger());
+
+$messages = new MessageBag(
+    Message::forSystem('You are an expert in places and geography who always responds concisely.'),
+    Message::ofUser('What are the top three destinations in France?'),
+);
+
+$result = $agent->call($messages, [
+    'stream' => true,
+]);
+
+foreach ($result->getContent() as $word) {
+    echo $word;
+}
+echo \PHP_EOL;

src/ai-bundle/src/AiBundle.php

@@ -33,6 +33,7 @@
 use Symfony\AI\Platform\Bridge\Ollama\PlatformFactory as OllamaPlatformFactory;
 use Symfony\AI\Platform\Bridge\OpenAi\PlatformFactory as OpenAiPlatformFactory;
 use Symfony\AI\Platform\Bridge\OpenRouter\PlatformFactory as OpenRouterPlatformFactory;
+use Symfony\AI\Platform\Bridge\Cerebras\PlatformFactory as CerebrasPlatformFactory;
 use Symfony\AI\Platform\Model;
 use Symfony\AI\Platform\ModelClientInterface;
 use Symfony\AI\Platform\Platform;
@@ -316,6 +317,23 @@ private function processPlatformConfig(string $type, array $platform, ContainerB
             return;
         }
 
+        if ('cerebras' === $type && isset($platform['api_key'])) {
+            $platformId = 'ai.platform.cerebras';
+            $definition = (new Definition(Platform::class))
+                ->setFactory(CerebrasPlatformFactory::class.'::create')
+                ->setLazy(true)
+                ->addTag('proxy', ['interface' => PlatformInterface::class])
+                ->setArguments([
+                    $platform['api_key'],
+                    new Reference('http_client', ContainerInterface::NULL_ON_INVALID_REFERENCE),
+                ])
+                ->addTag('ai.platform');
+
+            $container->setDefinition($platformId, $definition);
+
+            return;
+        }
+
         throw new InvalidArgumentException(\sprintf('Platform "%s" is not supported for configuration via bundle at this point.', $type));
     }
 

src/platform/CHANGELOG.md

@@ -21,6 +21,7 @@ CHANGELOG
    - HuggingFace (extensive model support with multiple tasks)
    - TransformersPHP (local PHP-based transformer models)
    - LM Studio (local model hosting)
+   - Cerebras (language models like Llama 4, Qwen 3, and more)
  * Add comprehensive message system with role-based messaging:
    - `UserMessage` for user inputs with multi-modal content
    - `SystemMessage` for system instructions

src/platform/doc/index.rst

@@ -346,6 +346,8 @@ This allows fast and isolated testing of AI-powered features without relying on
 
 * `Parallel GPT Calls`_
 * `Parallel Embeddings Calls`_
+* `Cerebras Chat`_
+* `Cerebras Streaming`_
 
 .. note::
 
@@ -392,3 +394,5 @@ This allows fast and isolated testing of AI-powered features without relying on
 .. _`Parallel Embeddings Calls`: https://github.com/symfony/ai/blob/main/examples/misc/parallel-embeddings.php
 .. _`LM Studio`: https://lmstudio.ai/
 .. _`LM Studio Catalog`: https://lmstudio.ai/models
+.. _`Cerebras Chat`: https://github.com/symfony/ai/blob/main/examples/cerebras/chat.php
+.. _`Cerebras Streaming`: https://github.com/symfony/ai/blob/main/examples/cerebras/stream.php

src/platform/src/Bridge/Cerebras/Model.php

@@ -0,0 +1,39 @@
+<?php
+
+namespace Symfony\AI\Platform\Bridge\Cerebras;
+
+use Symfony\AI\Platform\Capability;
+use \Symfony\AI\Platform\Model as BaseModel;
+
+/**
+ * @author Junaid Farooq <[email protected]>
+ */
+final class Model extends BaseModel
+{
+    public const LLAMA_4_SCOUT_17B_16E_INSTRUCT = 'llama-4-scout-17b-16e-instruct';
+    public const LLAMA3_1_8B = 'llama3.1-8b';
+    public const LLAMA_3_3_70B = 'llama-3.3-70b';
+    public const LLAMA_4_MAVERICK_17B_128E_INSTRUCT = 'llama-4-maverick-17b-128e-instruct';
+    public const QWEN_3_32B = 'qwen-3-32b';
+    public const QWEN_3_235B_A22B_INSTRUCT_2507 = 'qwen-3-235b-a22b-instruct-2507';
+    public const QWEN_3_235B_A22B_THINKING_2507 = 'qwen-3-235b-a22b-thinking-2507';
+    public const QWEN_3_CODER_480B = 'qwen-3-coder-480b';
+    public const GPT_OSS_120B = 'gpt-oss-120b';
+
+    public const CAPABILITIES = [
+        Capability::INPUT_MESSAGES,
+        Capability::OUTPUT_TEXT,
+        Capability::OUTPUT_STREAMING,
+    ];
+
+    /**
+     * @see https://inference-docs.cerebras.ai/api-reference/chat-completions for details like options
+     */
+    public function __construct(
+        string $name = self::LLAMA3_1_8B,
+        array $capabilities = self::CAPABILITIES,
+        array $options = [],
+    ) {
+        parent::__construct($name, $capabilities, $options);
+    }
+}

src/platform/src/Bridge/Cerebras/ModelClient.php

@@ -0,0 +1,64 @@
+<?php
+
+/*
+ * This file is part of the Symfony package.
+ *
+ * (c) Fabien Potencier <[email protected]>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Symfony\AI\Platform\Bridge\Cerebras;
+
+use Symfony\AI\Platform\Exception\InvalidArgumentException;
+use Symfony\AI\Platform\Model as BaseModel;
+use Symfony\AI\Platform\ModelClientInterface;
+use Symfony\AI\Platform\Result\RawHttpResult;
+use Symfony\Component\HttpClient\EventSourceHttpClient;
+use Symfony\Contracts\HttpClient\HttpClientInterface;
+
+/**
+ * @author Junaid Farooq <[email protected]>
+ */
+final readonly class ModelClient implements ModelClientInterface
+{
+    private EventSourceHttpClient $httpClient;
+
+    public function __construct(
+        HttpClientInterface $httpClient,
+        #[\SensitiveParameter] private string $apiKey,
+    ) {
+        if ('' === $apiKey) {
+            throw new InvalidArgumentException('The API key must not be empty.');
+        }
+
+        if (!str_starts_with($apiKey, 'csk-')) {
+            throw new InvalidArgumentException('The API key must start with "csk-".');
+        }
+
+        $this->httpClient = $httpClient instanceof EventSourceHttpClient ? $httpClient : new EventSourceHttpClient($httpClient);
+    }
+
+    public function supports(BaseModel $model): bool
+    {
+        return $model instanceof Model;
+    }
+
+    public function request(BaseModel $model, array|string $payload, array $options = []): RawHttpResult
+    {
+        return new RawHttpResult(
+            $this->httpClient->request(
+                'POST', 'https://api.cerebras.ai/v1/chat/completions',
+                [
+                    'headers' => [
+                        'Content-Type' => 'application/json',
+                        'Authorization' => sprintf('Bearer %s', $this->apiKey),
+                    ],
+                    'json' => \is_array($payload) ? array_merge($payload, $options) : $payload,
+                ]
+            )
+        );
+    }
+}
+

src/platform/src/Bridge/Cerebras/PlatformFactory.php

@@ -0,0 +1,34 @@
+<?php
+
+/*
+ * This file is part of the Symfony package.
+ *
+ * (c) Fabien Potencier <[email protected]>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Symfony\AI\Platform\Bridge\Cerebras;
+
+use Symfony\AI\Platform\Platform;
+use Symfony\Component\HttpClient\EventSourceHttpClient;
+use Symfony\Contracts\HttpClient\HttpClientInterface;
+
+/**
+ * @author Junaid Farooq <[email protected]>
+ */
+final readonly class PlatformFactory
+{
+    public static function create(
+        #[\SensitiveParameter] string $apiKey,
+        ?HttpClientInterface $httpClient = null,
+    ): Platform {
+        $httpClient = $httpClient instanceof EventSourceHttpClient ? $httpClient : new EventSourceHttpClient($httpClient);
+
+        return new Platform(
+            [new ModelClient($httpClient, $apiKey)],
+            [new ResultConverter()],
+        );
+    }
+}

src/platform/src/Bridge/Cerebras/ResultConverter.php

@@ -0,0 +1,77 @@
+<?php
+
+/*
+ * This file is part of the Symfony package.
+ *
+ * (c) Fabien Potencier <[email protected]>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Symfony\AI\Platform\Bridge\Cerebras;
+
+use Symfony\AI\Platform\Exception\RuntimeException;
+use Symfony\AI\Platform\Model as BaseModel;
+use Symfony\AI\Platform\Result\RawHttpResult;
+use Symfony\AI\Platform\Result\RawResultInterface;
+use Symfony\AI\Platform\Result\ResultInterface;
+use Symfony\AI\Platform\Result\StreamResult;
+use Symfony\AI\Platform\Result\TextResult;
+use Symfony\AI\Platform\ResultConverterInterface;
+use Symfony\Component\HttpClient\Chunk\ServerSentEvent;
+use Symfony\Component\HttpClient\EventSourceHttpClient;
+use Symfony\Component\HttpClient\Exception\JsonException;
+use Symfony\Contracts\HttpClient\ResponseInterface as HttpResponse;
+
+/**
+ * @author Junaid Farooq <[email protected]>
+ */
+final readonly class ResultConverter implements ResultConverterInterface
+{
+    public function supports(BaseModel $model): bool
+    {
+        return $model instanceof Model;
+    }
+
+    public function convert(RawHttpResult|RawResultInterface $result, array $options = []): ResultInterface
+    {
+        if ($options['stream'] ?? false) {
+            return new StreamResult($this->convertStream($result->getObject()));
+        }
+
+        $data = $result->getData();
+
+        if (!isset($data['choices'][0]['message']['content'])) {
+            if (isset($data['type'], $data['message']) && str_ends_with($data['type'], 'error')) {
+                throw new RuntimeException(sprintf('Cerebras API error: %s', $data['message']));
+            }
+
+            throw new RuntimeException('Response does not contain output.');
+        }
+
+        return new TextResult($data['choices'][0]['message']['content']);
+    }
+
+    private function convertStream(HttpResponse $result): \Generator
+    {
+        foreach ((new EventSourceHttpClient())->stream($result) as $chunk) {
+            if (!$chunk instanceof ServerSentEvent || '[DONE]' === $chunk->getData()) {
+                continue;
+            }
+
+            try {
+                $data = $chunk->getArrayData();
+            } catch (JsonException) {
+                continue;
+            }
+
+            if (!isset($data['choices'][0]['delta']['content'])) {
+                continue;
+            }
+
+            yield $data['choices'][0]['delta']['content'];
+        }
+    }
+}
+