hmm

app/Domains/LlmFunctions/GetContentFromUrl/GetContentFromUrl.php

@@ -33,6 +33,7 @@ public function handle(FunctionCallDto $functionCallDto): Message
         );
 
         $functionCallDto->message->content = $content;
+        $functionCallDto->message->run_functions = false; //just to prevent loops etc
         $functionCallDto->message->updateQuietly();
 
         return $functionCallDto->message->refresh();

app/Domains/Message/MessageRepository.php

@@ -24,16 +24,16 @@ public function __construct(MessageBuilder $messageBuilder = null)
         $this->messageBuilder = $messageBuilder;
     }
 
-    public function handle(Message $message): Response
+    public function handle(Message $message): ?Response
     {
         $this->parent_message = $message;
 
         $this->messageBuilder->setMessages($this->createPrompt());
 
         return ChatClient::setMessage($message)
-            ->chat($this->messageBuilder->getMessagesLimitTokenCount(
+            ->chat(messages: $this->messageBuilder->getMessagesLimitTokenCount(
                 remove_token_count: true
-            ));
+            ), run_functions: $message->run_functions);
     }
 
     protected function createPrompt(): MessagesDto

app/Domains/Scheduling/TaskRepository.php

@@ -3,23 +3,36 @@
 namespace App\Domains\Scheduling;
 
 use App\Domains\Scheduling\Dtos\TasksDto;
+use App\Jobs\MessageCreatedJob;
 use App\Models\Message;
 use App\Models\Task;
+use App\OpenAi\ChatClient;
 use Carbon\Carbon;
 
 class TaskRepository
 {
     public function handle(TasksDto $tasksDto, Message $message): void
     {
+        $summary = [];
         foreach ($tasksDto->tasks as $task) {
             if (! Task::where('description', $task->description)->where('message_id', $message->id)->exists()) {
                 Task::create([
                     'due' => ($task->date) ? Carbon::parse($task->date) : null,
                     'description' => $task->description,
                     'message_id' => $message->id,
                 ]);
+
+                $summary[] = $task->description . ' on ' . $task->date;
             }
         }
 
+        $summary = implode("\n", $summary);
+
+        $summary = sprintf("The following tasks have been created %s\n\n", $summary);
+
+        $message->content = str($message->content)->prepend($summary);
+//        $message->run_functions = false;//prevent a loop
+        $message->updateQuietly();
+//        MessageCreatedJob::dispatchSync($message);
     }
 }

app/Jobs/MessageCreatedJob.php

@@ -34,12 +34,14 @@ public function handle(): void
             MessageStatusEvent::dispatch($this->message);
             /** @var Response $results */
             $results = MessageRepository::handle($this->message);
-            Message::create([
-                'user_id' => $this->message->user_id,
-                'content' => $results->content,
-                'role' => 'assistant',
-                'parent_id' => $this->message->id,
-            ]);
+            if($results != null) {
+                Message::create([
+                    'user_id' => $this->message->user_id,
+                    'content' => $results->content,
+                    'role' => 'assistant',
+                    'parent_id' => $this->message->id,
+                ]);
+            }
             MessageStatusEvent::dispatch($this->message);
         } catch (\Exception $e) {
             logger('Error getting results');

app/Models/Message.php

@@ -13,6 +13,7 @@
  * @property int $id
  * @property string $role
  * @property int $parent_id
+ * @property boolean $run_functions
  * @property int $user_id
  * @property string $content
  * @property array $embedding

app/OpenAi/ChatClient.php

@@ -21,8 +21,9 @@ public function setMessage(Message $message): self
         return $this;
     }
 
-    public function chat(array $messages, bool $run_functions = true): Response
+    public function chat(array $messages, bool $run_functions = true): ?Response
     {
+
         if (config('openai.mock') && ! app()->environment('testing')) {
             logger('Mocking');
             sleep(2);
@@ -68,15 +69,7 @@ public function chat(array $messages, bool $run_functions = true): Response
 
             FunctionCall::handle($name, $dto);
 
-            $messages[] = [
-                'role' => 'assistant',
-                'content' => sprintf('As an assistant I ran the function %s for you with these parameters %s',
-                    $name,
-                    json_encode($dto->arguments)
-                ),
-            ];
-
-            return ChatClientFacade::chat($messages, false);
+            return null;
         } else {
             return Response::from(
                 [

app/OpenAi/FunctionCall.php

@@ -13,7 +13,6 @@ public function handle(string $function_name, FunctionCallDto $callDto): void
         try {
             $function = LlmFunction::where('label', $function_name)->firstOrfail();
             $results = $function_name($callDto);
-
         } catch (ModelNotFoundException $exception) {
             logger('The function does not exist '.$function_name);
         }

database/factories/MessageFactory.php

@@ -25,6 +25,7 @@ public function definition(): array
             'content' => fake()->sentence(4, true),
             'user_id' => User::factory(),
             'parent_id' => null,
+            'run_functions' => true
         ];
     }
 

database/migrations/2023_08_27_173334_add_run_ai_option_to_messages_table.php

@@ -0,0 +1,28 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+return new class extends Migration
+{
+    /**
+     * Run the migrations.
+     */
+    public function up(): void
+    {
+        Schema::table('messages', function (Blueprint $table) {
+            $table->boolean('run_functions')->default(1);
+        });
+    }
+
+    /**
+     * Reverse the migrations.
+     */
+    public function down(): void
+    {
+        Schema::table('messages', function (Blueprint $table) {
+            //
+        });
+    }
+};

tests/Feature/MessageRepositoryTest.php

@@ -14,7 +14,13 @@ class MessageRepositoryTest extends TestCase
     public function test_makes_request()
     {
 
-        ChatClient::shouldReceive('setMessage->chat')->once();
+        $response = Response::from([
+            'content' => "Foo"
+        ]);
+        ChatClient::shouldReceive('setMessage->chat')->once()->andReturn(
+            $response
+        );
+
         $message = Message::factory()->create([
             'role' => 'user']);
         $meta_data1 = MetaData::factory()->create();