tweaks

Author: tymondesigns

src/LLM/Drivers/AnthropicChat.php

@@ -185,10 +185,8 @@ protected function mapStreamResponse(StreamResponse $response): ChatStreamResult
             foreach ($response as $chunk) {
                 $chunkDelta = null;
                 $accumulatedToolCallsSoFar = null;
-
                 $finishReason = static::mapFinishReason($chunk->delta->stop_reason);
 
-                // Handle different event types
                 switch ($chunk->type) {
                     case 'message_start':
                         $messageId = $chunk->message->id;

src/Prompts/Builders/Concerns/BuildsPrompts.php

@@ -122,7 +122,7 @@ public function llm(
     }
 
     /**
-     * Convenience method to build and pipe the prompt template.
+     * Convenience method to build and pipe the prompt template to a given pipeable.
      */
     public function pipe(Pipeable|callable $pipeable): Pipeline
     {

src/Prompts/Contracts/PromptTemplate.php

@@ -7,6 +7,7 @@
 use Closure;
 use Cortex\Pipeline;
 use Cortex\LLM\Contracts\LLM;
+use Cortex\Contracts\Pipeable;
 use Illuminate\Support\Collection;
 
 interface PromptTemplate
@@ -26,7 +27,12 @@ public function format(?array $variables = null): mixed;
     public function variables(): Collection;
 
     /**
-     * Convenience method to pipe the prompt template to an LLM.
+     * Convenience method to build and pipe the prompt template to an LLM.
      */
     public function llm(LLM|string|null $provider = null, Closure|string|null $model = null): Pipeline;
+
+    /**
+     * Convenience method to build and pipe the prompt template to a given pipeable.
+     */
+    public function pipe(Pipeable|callable $pipeable): Pipeline;
 }

src/Prompts/Factories/LangfusePromptFactory.php

@@ -207,19 +207,21 @@ protected function getResponseContent(string $name, array $options = []): array
     protected static function defaultMetadataResolver(): Closure
     {
         return function (array $config): PromptMetadata {
-            $structuredOutput = $config['structuredOutput'] ?? null;
+            $structuredOutput = $config['structured_output'] ?? null;
 
             if (is_string($structuredOutput) || is_array($structuredOutput)) {
                 $structuredOutput = SchemaFactory::fromJson($structuredOutput);
             }
 
+            $structuredOutputMode = StructuredOutputMode::tryFrom($config['structured_output_mode'] ?? '');
+
             return new PromptMetadata(
                 $config['provider'] ?? null,
                 $config['model'] ?? null,
                 $config['parameters'] ?? [],
                 $config['tools'] ?? [],
                 $structuredOutput,
-                StructuredOutputMode::tryFrom($config['structuredOutputMode'] ?? StructuredOutputMode::Auto->value) ?? StructuredOutputMode::Auto,
+                $structuredOutputMode ?? StructuredOutputMode::Auto,
                 $config['additional'] ?? [],
             );
         };

tests/Unit/Experimental/PlaygroundTest.php

@@ -438,11 +438,11 @@ enum Sentiment: string
     );
 
     $result = $prompt->llm()->stream([
-        'topic' => 'dragons',
+        'topic' => 'trolls',
     ]);
 
     foreach ($result as $chunk) {
-        dump($chunk->contentSoFar);
+        dump($chunk->parsedOutput);
     }
 
     dd('done');

tests/Unit/Prompts/Factories/LangfusePromptFactoryTest.php

@@ -259,7 +259,7 @@ function createLangfuseFactory(
                 'max_tokens' => 100,
             ],
             'tools' => ['calculator', 'search'],
-            'structuredOutput' => [
+            'structured_output' => [
                 'type' => 'object',
                 'properties' => [
                     'name' => [
@@ -268,7 +268,7 @@ function createLangfuseFactory(
                 ],
                 'required' => ['name'],
             ],
-            'structuredOutputMode' => StructuredOutputMode::Tool->value,
+            'structured_output_mode' => StructuredOutputMode::Tool->value,
             'additional' => [
                 'custom_field' => 'custom_value',
             ],