Notify users of document import progress and errors in IngestFileListener.

Author: csavelief

app/Listeners/IngestFileListener.php

@@ -10,6 +10,7 @@
 use App\Models\Collection;
 use App\Models\File;
 use App\Models\Vector;
+use App\Notifications\Notification;
 use App\Rules\IsValidCollectionName;
 use Illuminate\Support\Facades\Log;
 use Illuminate\Support\Facades\Storage;
@@ -47,6 +48,8 @@ protected function handle2($event)
                 throw new \Exception("Invalid file id : {$event->fileId}");
             }
 
+            $event->user->notify(new Notification(__("Import of document :document started.", ['document' => $file->name])));
+
             // webm to mp3
             if ($file->mime_type === 'audio/webm') {
 
@@ -396,8 +399,16 @@ protected function handle2($event)
                 $file->is_embedded = true;
                 $file->save();
             }
+
+            $event->user->notify(new Notification(__("Import of document :document finished successfully.", ['document' => $file->name])));
+
         } catch (\Exception $exception) {
+
             Log::error($exception->getMessage());
+
+            if (isset($file)) {
+                $event->user->notify(new Notification(__("Import of document :document failed: :error", ['document' => $file->name, 'error' => $exception->getMessage()])));
+            }
         }
     }
 

lang/fr.json

@@ -4,6 +4,9 @@
   "Import of table :table started.": "L'importation de la table :table a commencé.",
   "Import of table :table finished successfully.": "L'importation de la table :table s'est terminée avec succès.",
   "Import of table :table failed: :error": "L'importation de la table :table a échoué : :error",
+  "Import of document :document started.": "L'importation du document :document a commencé.",
+  "Import of document :document finished successfully.": "L'importation du document :document s'est terminée avec succès.",
+  "Import of document :document failed: :error": "L'importation du document :document a échoué : :error",
   "2.2 What are the credentials for your AWS S3 Bucket?": "2.2 Quels sont les identifiants de votre bucket S3 AWS ?",
   "2.2 What are the credentials for your Azure Blob Storage?": "2.2 Quels sont les identifiants de votre Blob Storage Azure ?",
   "3. Which table would you like to import?": "3. Quelle table souhaitez-vous importer ?",