Download logs (#11)

* Add possibility to download log file

Author: AUDUL

CHANGELOG.md

@@ -1,3 +1,6 @@
+# Version 6.4.0
+* Add the possibility to download the log file
+
 # Version 6.3.0
 * add stream exceptions management
 

src/Controller/JobController.php

@@ -45,9 +45,23 @@ public function displayLog(int $id): Response
         $log = array_map(fn($line) => preg_replace('~#\d+~', "\n$0", (string) $line), $item->getExceptions() ?? []);
 
         if (empty($log) && $item->getStreamExceptions()) {
-            return new StreamedResponse(function () use ($item) {
+            return new StreamedResponse(function () use ($item, $id) {
+                $maxBytes = 1048576;
+                $bytesRead = 0;
+
                 while (($line = fgets($item->getStreamExceptions())) !== false) {
-                    echo "<p>",preg_replace('~#\d+~', "<br>$0", (string) $line),"</p>";
+                    $bytesRead += strlen($line);
+
+                    if ($bytesRead > $maxBytes) {
+                        echo sprintf('<p><strong>[%s]</strong></p><p><a href="%s">%s</a></p>',
+                            $this->translator->trans('coderhapsodie.ibexa_dataflow.logs.trucated'),
+                            $this->generateUrl('coderhapsodie.ibexa_dataflow.job.log.download', ['id' => $id]),
+                            $this->translator->trans('coderhapsodie.ibexa_dataflow.logs.download')
+                        );
+                        break;
+                    }
+
+                    echo "<p>", preg_replace('~#\d+~', "<br>$0", (string)$line), "</p>";
                     flush();
                 }
             });
@@ -58,6 +72,32 @@ public function displayLog(int $id): Response
         ]);
     }
 
+    #[Route(path: '/details/log/{id}/download', name: 'coderhapsodie.ibexa_dataflow.job.log.download', methods: 'GET')]
+    public function downloadLog(int $id): Response
+    {
+        $this->denyAccessUnlessGranted(new Attribute('ibexa_dataflow', 'view'));
+        $item = $this->jobGateway->find($id);
+        $log = array_map(fn($line) => preg_replace('~#\d+~', "\n$0", (string) $line), $item->getExceptions() ?? []);
+
+        if (empty($log) && $item->getStreamExceptions()) {
+            $headers = [
+                'Content-Type' => 'plain/text; charset=utf-8',
+                'Content-Disposition' => sprintf('attachment; filename="%s.log"', $item->getLabel().'-'.$item->getStartTime()->format('Y-m-d-H-i-s')),
+            ];
+
+            return new StreamedResponse(function () use ($item) {
+                while (($line = fgets($item->getStreamExceptions())) !== false) {
+                    echo $line;
+                    flush();
+                }
+            }, headers: $headers);
+        }
+
+        throw $this->createNotFoundException();
+    }
+
+
+
     #[Route(path: '/create', name: 'coderhapsodie.ibexa_dataflow.job.create', methods: ['POST'])]
     public function create(Request $request): Response
     {

src/Resources/translations/messages.en.yaml

@@ -91,3 +91,5 @@ coderhapsodie.ibexa_dataflow.powered_by: 'Powered by'
 coderhapsodie.ibexa_dataflow.made_by: 'Made by'
 coderhapsodie.ibexa_dataflow.dashboard: Dashboard
 coderhapsodie.ibexa_dataflow.dashboard.title: Running or waiting tasks
+coderhapsodie.ibexa_dataflow.logs.trucated: 'Logs are truncated (over 1Mo).'
+coderhapsodie.ibexa_dataflow.logs.download: 'Download full logs'

src/Resources/translations/messages.fr.yaml

@@ -89,3 +89,5 @@ coderhapsodie.ibexa_dataflow.powered_by: 'Propulsé par'
 coderhapsodie.ibexa_dataflow.made_by: 'Fabriqué par'
 coderhapsodie.ibexa_dataflow.dashboard: Dashboard
 coderhapsodie.ibexa_dataflow.dashboard.title: Tâches en cours ou en attente
+coderhapsodie.ibexa_dataflow.logs.trucated: 'Les logs sont tronqués (supérieur à 1Mo).'
+coderhapsodie.ibexa_dataflow.logs.download: 'Télécharger tous les logs'