[Agent] Code groming arround tall call

Author: lyrixx

src/agent/src/Toolbox/AgentProcessor.php

@@ -78,7 +78,10 @@ public function processOutput(Output $output): void
     {
         if ($output->getResult() instanceof GenericStreamResponse) {
             $output->setResult(
-                new ToolboxStreamResponse($output->getResult()->getContent(), $this->handleToolCallsCallback($output))
+                new ToolboxStreamResponse(
+                    $output->getResult()->getContent(),
+                    fn (ToolCallResult $result, ?AssistantMessage $streamedAssistantResponse = null) => $this->handleToolCallsCallback($output, $result, $streamedAssistantResponse)
+                )
             );
 
             return;
@@ -88,7 +91,7 @@ public function processOutput(Output $output): void
             return;
         }
 
-        $output->setResult($this->handleToolCallsCallback($output)($output->getResult()));
+        $output->setResult($this->handleToolCallsCallback($output, $output->getResult()));
     }
 
     /**
@@ -99,40 +102,39 @@ private function isFlatStringArray(array $tools): bool
         return array_reduce($tools, fn (bool $carry, mixed $item) => $carry && \is_string($item), true);
     }
 
-    private function handleToolCallsCallback(Output $output): \Closure
+    private function handleToolCallsCallback(Output $output, ToolCallResult $result, ?AssistantMessage $streamedAssistantResponse = null): ResultInterface
     {
-        return function (ToolCallResult $result, ?AssistantMessage $streamedAssistantResponse = null) use ($output): ResultInterface {
-            ++$this->nestingLevel;
-            $messages = $this->keepToolMessages ? $output->getMessageBag() : clone $output->getMessageBag();
+        ++$this->nestingLevel;
+        $messages = $this->keepToolMessages ? $output->getMessageBag() : clone $output->getMessageBag();
 
-            if (null !== $streamedAssistantResponse && '' !== $streamedAssistantResponse->getContent()) {
-                $messages->add($streamedAssistantResponse);
-            }
+        if (null !== $streamedAssistantResponse && '' !== $streamedAssistantResponse->getContent()) {
+            $messages->add($streamedAssistantResponse);
+        }
 
-            do {
-                $toolCalls = $result->getContent();
-                $messages->add(Message::ofAssistant(toolCalls: $toolCalls));
+        do {
+            $toolCalls = $result->getContent();
+            $messages->add(Message::ofAssistant(toolCalls: $toolCalls));
 
-                $results = [];
-                foreach ($toolCalls as $toolCall) {
-                    $results[] = $toolResult = $this->toolbox->execute($toolCall);
-                    $messages->add(Message::ofToolCall($toolCall, $this->resultConverter->convert($toolResult)));
-                    array_push($this->sources, ...$toolResult->getSources());
-                }
+            $results = [];
+            foreach ($toolCalls as $toolCall) {
+                $results[] = $toolResult = $this->toolbox->execute($toolCall);
+                // dd($toolResult);
+                $messages->add(Message::ofToolCall($toolCall, $this->resultConverter->convert($toolResult)));
+                array_push($this->sources, ...$toolResult->getSources());
+            }
 
-                $event = new ToolCallsExecuted(...$results);
-                $this->eventDispatcher?->dispatch($event);
+            $event = new ToolCallsExecuted(...$results);
+            $this->eventDispatcher?->dispatch($event);
 
-                $result = $event->hasResult() ? $event->getResult() : $this->agent->call($messages, $output->getOptions());
-            } while ($result instanceof ToolCallResult);
+            $result = $event->hasResult() ? $event->getResult() : $this->agent->call($messages, $output->getOptions());
+        } while ($result instanceof ToolCallResult);
 
-            --$this->nestingLevel;
-            if ($this->includeSources && 0 === $this->nestingLevel) {
-                $result->getMetadata()->add('sources', $this->sources);
-                $this->sources = [];
-            }
+        --$this->nestingLevel;
+        if ($this->includeSources && 0 === $this->nestingLevel) {
+            $result->getMetadata()->add('sources', $this->sources);
+            $this->sources = [];
+        }
 
-            return $result;
-        };
+        return $result;
     }
 }

src/agent/src/Toolbox/ToolFactory/MemoryToolFactory.php

@@ -33,16 +33,16 @@ public function addTool(string|object $class, string $name, string $description,
     }
 
     /**
-     * @param class-string $reference
+     * @param class-string $className
      */
-    public function getTool(string $reference): iterable
+    public function getTool(string $className): iterable
     {
-        if (!isset($this->tools[$reference])) {
-            throw ToolException::invalidReference($reference);
+        if (!isset($this->tools[$className])) {
+            throw ToolException::invalidReference($className);
         }
 
-        foreach ($this->tools[$reference] as $tool) {
-            yield $this->convertAttribute($reference, $tool);
+        foreach ($this->tools[$className] as $tool) {
+            yield $this->convertAttribute($className, $tool);
         }
     }
 }

src/agent/src/Toolbox/Toolbox.php

@@ -34,7 +34,7 @@ final class Toolbox implements ToolboxInterface
     /**
      * List of executable tools.
      *
-     * @var list<mixed>
+     * @var list<object>
      */
     private readonly array $tools;
 
@@ -43,10 +43,10 @@ final class Toolbox implements ToolboxInterface
      *
      * @var Tool[]
      */
-    private array $map;
+    private array $toolsMetadata;
 
     /**
-     * @param iterable<mixed> $tools
+     * @param iterable<object> $tools
      */
     public function __construct(
         iterable $tools,
@@ -60,18 +60,18 @@ public function __construct(
 
     public function getTools(): array
     {
-        if (isset($this->map)) {
-            return $this->map;
+        if (isset($this->toolsMetadata)) {
+            return $this->toolsMetadata;
         }
 
-        $map = [];
+        $toolsMetadata = [];
         foreach ($this->tools as $tool) {
             foreach ($this->toolFactory->getTool($tool::class) as $metadata) {
-                $map[] = $metadata;
+                $toolsMetadata[] = $metadata;
             }
         }
 
-        return $this->map = $map;
+        return $this->toolsMetadata = $toolsMetadata;
     }
 
     public function execute(ToolCall $toolCall): ToolResult

src/platform/src/Bridge/OpenAi/Gpt/ResultConverter.php

@@ -173,7 +173,7 @@ private function isToolCallsStreamFinished(array $data): bool
     private function convertChoice(array $choice): ToolCallResult|TextResult
     {
         if ('tool_calls' === $choice['finish_reason']) {
-            return new ToolCallResult(...array_map([$this, 'convertToolCall'], $choice['message']['tool_calls']));
+            return new ToolCallResult(...array_map($this->convertToolCall(...), $choice['message']['tool_calls']));
         }
 
         if (\in_array($choice['finish_reason'], ['stop', 'length'], true)) {