email checker

app/Console/Commands/CheckEmailCommand.php

@@ -0,0 +1,35 @@
+<?php
+
+namespace App\Console\Commands;
+
+use Facades\App\Domains\EmailParser\Client;
+use Illuminate\Console\Command;
+
+class CheckEmailCommand extends Command
+{
+    /**
+     * The name and signature of the console command.
+     *
+     * @var string
+     */
+    protected $signature = 'llm_assistant:check_email';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = 'This will check email make sure the llm_assistant.check_email is true';
+
+    /**
+     * Execute the console command.
+     */
+    public function handle()
+    {
+        logger('Checking Email');
+        $this->info('Checking Email');
+        Client::handle();
+        logger('Done Checking Email');
+        $this->info('Done Checking Email');
+    }
+}

app/Console/Kernel.php

@@ -12,7 +12,7 @@ class Kernel extends ConsoleKernel
      */
     protected function schedule(Schedule $schedule): void
     {
-        // $schedule->command('inspire')->hourly();
+        $schedule->command('llm_assistant:check_email')->everyMinute();
         $schedule->command('security-portal-client:sync')->environments('production')->hourly();
     }
 

app/Domains/EmailParser/Client.php

@@ -0,0 +1,41 @@
+<?php
+
+namespace App\Domains\EmailParser;
+
+use App\Jobs\MailBoxParserJob;
+use Webklex\IMAP\Facades\Client as ClientFacade;
+
+class Client
+{
+    public function handle(): void
+    {
+        $client = ClientFacade::account('default');
+        $client->connect();
+
+        $folders = $client->getFolders(false);
+
+        foreach ($folders as $folder) {
+            $messages = $folder->messages()->all()->limit(3, 0)->get();
+
+            logger('Emails', [
+                $messages->count(),
+            ]);
+
+            foreach ($messages as $message) {
+                logger('Getting Message');
+
+                $messageDto = MailDto::from([
+                    'to' => $message->getTo(),
+                    'from' => $message->getFrom(),
+                    'body' => $message->getTextBody(),
+                    'subject' => $message->getSubject(),
+                    'header' => $message->getHeader()->raw,
+                ]);
+
+                MailBoxParserJob::dispatch($messageDto);
+
+                $message->delete(expunge: true);
+            }
+        }
+    }
+}

app/Domains/EmailParser/MailDto.php

@@ -0,0 +1,17 @@
+<?php
+
+namespace App\Domains\EmailParser;
+
+use Spatie\LaravelData\Data;
+
+class MailDto extends Data
+{
+    public function __construct(
+        public ?string $subject,
+        public ?string $from,
+        public ?string $to,
+        public ?string $body,
+        public ?string $header
+    ) {
+    }
+}

app/Jobs/MailBoxParserJob.php

@@ -0,0 +1,60 @@
+<?php
+
+namespace App\Jobs;
+
+use App\Domains\EmailParser\MailDto;
+use App\Models\Message;
+use App\Models\Tag;
+use App\Models\User;
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Queue\SerializesModels;
+
+class MailBoxParserJob implements ShouldQueue
+{
+    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
+
+    /**
+     * Create a new job instance.
+     */
+    public function __construct(public MailDto $mailDto)
+    {
+        //
+    }
+
+    /**
+     * Execute the job.
+     */
+    public function handle(): void
+    {
+        try {
+
+            $tag = Tag::firstOrCreate([
+                'label' => 'email',
+            ], [
+                'active' => 1,
+            ]);
+
+            $message = Message::create([
+                'role' => 'user',
+                'user_id' => User::first()->id,
+                'content' => sprintf("subject: %s \n body: %s",
+                    $this->mailDto->subject,
+                    $this->mailDto->body),
+            ]);
+
+            $message->tags()->attach($tag->id);
+
+            /**
+             * If tons of text we tldr it
+             * If a url we go get it then tldr it
+             * can make that a function?
+             */
+        } catch (\Exception $e) {
+            logger('Email error', [$e->getMessage()]);
+            $this->fail();
+        }
+    }
+}

composer.json

@@ -29,7 +29,8 @@
         "symfony/postmark-mailer": "^6.2",
         "tightenco/ziggy": "^1.0",
         "voku/stop-words": "^2.0",
-        "wamania/php-stemmer": "^3.0"
+        "wamania/php-stemmer": "^3.0",
+        "webklex/laravel-imap": "^5.3"
     },
     "require-dev": {
         "fakerphp/faker": "^1.9.1",