Use JSON Path to convert responses

Author: chr-hertel

examples/composer.json

@@ -22,6 +22,7 @@
         "symfony/event-dispatcher": "^6.4|^7.0",
         "symfony/filesystem": "^6.4|^7.0",
         "symfony/finder": "^6.4|^7.0",
+        "symfony/json-path": "7.3.*",
         "symfony/process": "^6.4|^7.0",
         "symfony/var-dumper": "^6.4|^7.0"
     },

examples/gemini/server-tools.php

@@ -23,11 +23,11 @@
 $platform = PlatformFactory::create(env('GEMINI_API_KEY'), http_client());
 
 // Available server-side tools as of 2025-06-28: url_context, google_search, code_execution
-$llm = new Gemini('gemini-2.5-pro-preview-03-25', ['server_tools' => ['url_context' => true], 'temperature' => 1.0]);
+$model = new Gemini('gemini-2.5-pro-preview-03-25', ['server_tools' => ['url_context' => true], 'temperature' => 1.0]);
 
 $toolbox = new Toolbox([new Clock()], logger: logger());
 $processor = new AgentProcessor($toolbox);
-$agent = new Agent($platform, $llm, logger: logger());
+$agent = new Agent($platform, $model, logger: logger());
 
 $messages = new MessageBag(
     Message::ofUser(

examples/gemini/toolcall.php

@@ -21,11 +21,11 @@
 require_once dirname(__DIR__).'/bootstrap.php';
 
 $platform = PlatformFactory::create(env('GEMINI_API_KEY'), http_client());
-$llm = new Gemini(Gemini::GEMINI_2_FLASH);
+$model = new Gemini(Gemini::GEMINI_2_FLASH);
 
 $toolbox = new Toolbox([new Clock()], logger: logger());
 $processor = new AgentProcessor($toolbox);
-$agent = new Agent($platform, $llm, [$processor], [$processor], logger());
+$agent = new Agent($platform, $model, [$processor], [$processor], logger());
 
 $messages = new MessageBag(Message::ofUser('What time is it?'));
 $result = $agent->call($messages);

examples/ollama/stream.php

@@ -0,0 +1,35 @@
+<?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\Ollama\Ollama;
+use Symfony\AI\Platform\Bridge\Ollama\PlatformFactory;
+use Symfony\AI\Platform\Message\Message;
+use Symfony\AI\Platform\Message\MessageBag;
+
+require_once dirname(__DIR__).'/bootstrap.php';
+
+$platform = PlatformFactory::create(env('OLLAMA_HOST_URL'), http_client());
+$model = new Ollama();
+
+$agent = new Agent($platform, $model, logger: logger());
+$messages = new MessageBag(
+    Message::forSystem('You are a helpful assistant.'),
+    Message::ofUser('Tina has one brother and one sister. How many sisters do Tina\'s siblings have?'),
+);
+$result = $agent->call($messages, [
+    'stream' => true,
+]);
+
+foreach ($result->getContent() as $word) {
+    echo $word;
+}
+echo \PHP_EOL;

examples/openrouter/stream-gemini.php

@@ -0,0 +1,37 @@
+<?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\OpenRouter\PlatformFactory;
+use Symfony\AI\Platform\Message\Message;
+use Symfony\AI\Platform\Message\MessageBag;
+use Symfony\AI\Platform\Model;
+
+require_once dirname(__DIR__).'/bootstrap.php';
+
+$platform = PlatformFactory::create(env('OPENROUTER_KEY'), http_client());
+// In case free is running into 429 rate limit errors, you can use the paid model:
+// $model = new Model('google/gemini-2.0-flash-lite-001');
+$model = new Model('google/gemini-2.0-flash-exp:free');
+
+$agent = new Agent($platform, $model, logger: logger());
+$messages = new MessageBag(
+    Message::forSystem('You are a helpful assistant and explain your answer lengthy.'),
+    Message::ofUser('Tina has one brother and one sister. How many sisters do Tina\'s siblings have?'),
+);
+$result = $agent->call($messages, [
+    'stream' => true,
+]);
+
+foreach ($result->getContent() as $word) {
+    echo $word;
+}
+echo \PHP_EOL;

src/agent/src/Toolbox/AgentProcessor.php

@@ -23,6 +23,7 @@
 use Symfony\AI\Platform\Capability;
 use Symfony\AI\Platform\Message\AssistantMessage;
 use Symfony\AI\Platform\Message\Message;
+use Symfony\AI\Platform\Result\ChoiceResult;
 use Symfony\AI\Platform\Result\ResultInterface;
 use Symfony\AI\Platform\Result\StreamResult as GenericStreamResponse;
 use Symfony\AI\Platform\Result\ToolCallResult;
@@ -76,6 +77,15 @@ public function processOutput(Output $output): void
             return;
         }
 
+        // Promote ToolCallResult from collection of choices
+        if ($output->result instanceof ChoiceResult) {
+            foreach ($output->result->getContent() as $result) {
+                if ($result instanceof ToolCallResult) {
+                    $output->result = $result;
+                }
+            }
+        }
+
         if (!$output->result instanceof ToolCallResult) {
             return;
         }

src/platform/composer.json

@@ -28,6 +28,7 @@
         "psr/log": "^3.0",
         "symfony/clock": "^6.4 || ^7.1",
         "symfony/http-client": "^6.4 || ^7.1",
+        "symfony/json-path": "7.3.*",
         "symfony/property-access": "^6.4 || ^7.1",
         "symfony/property-info": "^6.4 || ^7.1",
         "symfony/serializer": "^6.4 || ^7.1",

src/platform/phpstan.dist.neon

@@ -7,6 +7,7 @@ parameters:
     paths:
         - src/
         - tests/
+    treatPhpDocTypesAsCertain: false
     ignoreErrors:
         -
             message: "#^Method .*::test.*\\(\\) has no return type specified\\.$#"

src/platform/src/Bridge/Albert/PlatformFactory.php

@@ -11,8 +11,6 @@
 
 namespace Symfony\AI\Platform\Bridge\Albert;
 
-use Symfony\AI\Platform\Bridge\OpenAi\Embeddings;
-use Symfony\AI\Platform\Bridge\OpenAi\Gpt;
 use Symfony\AI\Platform\Contract;
 use Symfony\AI\Platform\Exception\InvalidArgumentException;
 use Symfony\AI\Platform\Platform;
@@ -40,7 +38,7 @@ public static function create(
                 new GptModelClient($httpClient, $apiKey, $baseUrl),
                 new EmbeddingsModelClient($httpClient, $apiKey, $baseUrl),
             ],
-            [new Gpt\ResultConverter(), new Embeddings\ResultConverter()],
+            [Contract\ResultConverter::create()],
             Contract::create(),
         );
     }

src/platform/src/Bridge/Anthropic/PlatformFactory.php

@@ -13,6 +13,9 @@
 
 use Symfony\AI\Platform\Bridge\Anthropic\Contract\AnthropicContract;
 use Symfony\AI\Platform\Contract;
+use Symfony\AI\Platform\Contract\ResultExtractor\StreamResultExtractor;
+use Symfony\AI\Platform\Contract\ResultExtractor\TextResultExtractor;
+use Symfony\AI\Platform\Contract\ResultExtractor\ToolCallResultExtractor;
 use Symfony\AI\Platform\Platform;
 use Symfony\Component\HttpClient\EventSourceHttpClient;
 use Symfony\Contracts\HttpClient\HttpClientInterface;
@@ -33,7 +36,20 @@ public static function create(
 
         return new Platform(
             [new ModelClient($httpClient, $apiKey, $version)],
-            [new ResultConverter()],
+            [Contract\ResultConverter::create([
+                new TextResultExtractor('$.content[[email protected] == "text"].text'),
+                new ToolCallResultExtractor(
+                    '$.content[[email protected] == "tool_use"]',
+                    '$.content[[email protected] == "tool_use"].id',
+                    '$.content[[email protected] == "tool_use"].name',
+                    '$.content[[email protected] == "tool_use"].input',
+                ),
+                new StreamResultExtractor(
+                    '$.delta.text',
+                    '$.delta[[email protected] == "tool_use"]',
+                    '$.delta.stop_reason',
+                ),
+            ])],
             $contract ?? AnthropicContract::create(),
         );
     }