Merge pull request #2 from utopia-php/feat-deepseek-adapter

Feat deepseek adapter

Author: christyjacob4

README.md

@@ -21,10 +21,10 @@ Utopia Framework requires PHP 8.0 or later. We recommend using the latest PHP ve
 
 ## Features
 
-- **Multiple AI Providers** - Support for OpenAI and Anthropic APIs
+- **Multiple AI Providers** - Support for OpenAI, Anthropic, and Deepseek APIs
 - **Flexible Message Types** - Support for text and structured content in messages
 - **Conversation Management** - Easy-to-use conversation handling between agents and users
-- **Model Selection** - Choose from various AI models (GPT-4, Claude 3, etc.)
+- **Model Selection** - Choose from various AI models (GPT-4, Claude 3, Deepseek Chat, etc.)
 - **Parameter Control** - Fine-tune model behavior with temperature and token controls
 
 ## Usage
@@ -93,6 +93,23 @@ Available Anthropic Models:
 - `MODEL_CLAUDE_3_HAIKU`: Fast and efficient
 - `MODEL_CLAUDE_2_1`: Previous generation
 
+#### Deepseek
+
+```php
+use Utopia\Agents\Adapters\Deepseek;
+
+$deepseek = new Deepseek(
+    apiKey: 'your-api-key',
+    model: Deepseek::MODEL_DEEPSEEK_CHAT,
+    maxTokens: 2048,
+    temperature: 0.7
+);
+```
+
+Available Deepseek Models:
+- `MODEL_DEEPSEEK_CHAT`: General-purpose chat model
+- `MODEL_DEEPSEEK_CODER`: Specialized for code-related tasks
+
 ### Managing Conversations
 
 ```php

src/Agents/Adapters/Deepseek.php

@@ -0,0 +1,274 @@
+<?php
+
+namespace Utopia\Agents\Adapters;
+
+use Utopia\Agents\Adapter;
+use Utopia\Agents\Message;
+use Utopia\Agents\Messages\Text;
+use Utopia\Fetch\Chunk;
+use Utopia\Fetch\Client;
+
+class Deepseek extends Adapter
+{
+    /**
+     * Deepseek-Chat - Most powerful model
+     */
+    public const MODEL_DEEPSEEK_CHAT = 'deepseek-chat';
+
+    /**
+     * Deepseek-Coder - Specialized for code
+     */
+    public const MODEL_DEEPSEEK_CODER = 'deepseek-coder';
+
+    /**
+     * @var string
+     */
+    protected string $apiKey;
+
+    /**
+     * @var string
+     */
+    protected string $model;
+
+    /**
+     * @var int
+     */
+    protected int $maxTokens;
+
+    /**
+     * @var float
+     */
+    protected float $temperature;
+
+    /**
+     * Create a new Deepseek adapter
+     *
+     * @param  string  $apiKey
+     * @param  string  $model
+     * @param  int  $maxTokens
+     * @param  float  $temperature
+     *
+     * @throws \Exception
+     */
+    public function __construct(
+        string $apiKey,
+        string $model = self::MODEL_DEEPSEEK_CHAT,
+        int $maxTokens = 1024,
+        float $temperature = 1.0
+    ) {
+        $this->apiKey = $apiKey;
+        $this->maxTokens = $maxTokens;
+        $this->temperature = $temperature;
+        $this->setModel($model);
+    }
+
+    /**
+     * Send a message to the Deepseek API
+     *
+     * @param  array<array<string, mixed>>  $messages
+     * @param  callable|null  $listener
+     * @return Message
+     *
+     * @throws \Exception
+     */
+    public function send(array $messages, ?callable $listener = null): Message
+    {
+        if ($this->getAgent() === null) {
+            throw new \Exception('Agent not set');
+        }
+
+        $client = new \Utopia\Fetch\Client();
+        $client
+            ->setTimeout(90)
+            ->addHeader('authorization', 'Bearer ' . $this->apiKey)
+            ->addHeader('content-type', Client::CONTENT_TYPE_APPLICATION_JSON);
+
+        $formattedMessages = [];
+        foreach ($messages as $message) {
+            if (!isset($message['role']) || !isset($message['content'])) {
+                throw new \Exception('Invalid message format');
+            }
+            $formattedMessages[] = [
+                'role' => $message['role'],
+                'content' => $message['content'],
+            ];
+        }
+
+        $instructions = [];
+        foreach ($this->getAgent()->getInstructions() as $name => $content) {
+            $instructions[] = "# " . $name . "\n\n" . $content;
+        }
+
+        $systemMessage = $this->getAgent()->getDescription() . 
+            (empty($instructions) ? '' : "\n\n" . implode("\n\n", $instructions));
+
+        if (!empty($systemMessage)) {
+            array_unshift($formattedMessages, [
+                'role' => 'system',
+                'content' => $systemMessage
+            ]);
+        }
+
+        $payload = [
+            'model' => $this->model,
+            'messages' => $formattedMessages,
+            'max_tokens' => $this->maxTokens,
+            'temperature' => $this->temperature,
+            'stream' => true,
+        ];
+
+        $content = '';
+        $response = $client->fetch(
+            'https://api.deepseek.com/chat/completions',
+            Client::METHOD_POST,
+            $payload,
+            [],
+            function ($chunk) use (&$content, $listener) {
+                $content .= $this->process($chunk, $listener);
+            }
+        );
+
+        if ($response->getStatusCode() >= 400) {
+            throw new \Exception('Deepseek API error ('.$response->getStatusCode().'): '.$response->getBody());
+        }
+
+        $message = new Text($content);
+
+        return $message;
+    }
+
+    /**
+     * Process a stream chunk from the Deepseek API
+     *
+     * @param  \Utopia\Fetch\Chunk  $chunk
+     * @param  callable|null  $listener
+     * @return string
+     *
+     * @throws \Exception
+     */
+    protected function process(Chunk $chunk, ?callable $listener): string
+    {
+        $block = '';
+        $data = $chunk->getData();
+        $lines = explode("\n", $data);
+
+        foreach ($lines as $line) {
+            if (empty(trim($line))) {
+                continue;
+            }
+
+            if (! str_starts_with($line, 'data: ')) {
+                continue;
+            }
+
+            $line = substr($line, 6);
+            if ($line === '[DONE]') {
+                continue;
+            }
+
+            $json = json_decode($line, true);
+            if (! is_array($json)) {
+                continue;
+            }
+
+            if (isset($json['choices'][0]['delta']['content'])) {
+                $delta = $json['choices'][0]['delta']['content'];
+                if (!empty($delta)) {
+                    $block .= $delta;
+                    if ($listener !== null) {
+                        $listener($delta);
+                    }
+                }
+            }
+
+            if (isset($json['usage'])) {
+                if (isset($json['usage']['prompt_tokens'])) {
+                    $this->countInputTokens($json['usage']['prompt_tokens']);
+                }
+                if (isset($json['usage']['completion_tokens'])) {
+                    $this->countOutputTokens($json['usage']['completion_tokens']);
+                }
+            }
+        }
+
+        return $block;
+    }
+
+    /**
+     * Get available models
+     *
+     * @return array<string>
+     */
+    public function getModels(): array
+    {
+        return [
+            self::MODEL_DEEPSEEK_CHAT,
+            self::MODEL_DEEPSEEK_CODER,
+        ];
+    }
+
+    /**
+     * Get current model
+     *
+     * @return string
+     */
+    public function getModel(): string
+    {
+        return $this->model;
+    }
+
+    /**
+     * Set model to use
+     *
+     * @param  string  $model
+     * @return self
+     *
+     * @throws \Exception
+     */
+    public function setModel(string $model): self
+    {
+        if (! in_array($model, $this->getModels())) {
+            throw new \Exception('Unsupported model: '.$model);
+        }
+
+        $this->model = $model;
+
+        return $this;
+    }
+
+    /**
+     * Set max tokens
+     *
+     * @param  int  $maxTokens
+     * @return self
+     */
+    public function setMaxTokens(int $maxTokens): self
+    {
+        $this->maxTokens = $maxTokens;
+
+        return $this;
+    }
+
+    /**
+     * Set temperature
+     *
+     * @param  float  $temperature
+     * @return self
+     */
+    public function setTemperature(float $temperature): self
+    {
+        $this->temperature = $temperature;
+
+        return $this;
+    }
+
+    /**
+     * Get the adapter name
+     *
+     * @return string
+     */
+    public function getName(): string
+    {
+        return 'deepseek';
+    }
+}