Added:

- Messenger, Mercure
- chapter download flow (lelscan only)

src/Controller/MangaController.php

@@ -3,17 +3,22 @@
 namespace App\Controller;
 
 use App\Entity\Manga;
+use App\Message\DownloadChapter;
+use App\Repository\ChapterRepository;
 use App\Repository\MangaRepository;
 use App\Service\MangaExportService;
 use App\Service\LelScansProviderService;
 use App\Service\MangaScraperServiceOld;
 use App\Service\MangaUpdatesMetadataProvider;
+use Doctrine\ORM\NonUniqueResultException;
 use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
 use Symfony\Component\HttpFoundation\BinaryFileResponse;
+use Symfony\Component\HttpFoundation\JsonResponse;
 use Symfony\Component\HttpFoundation\Request;
 use Symfony\Component\HttpFoundation\Response;
 use Symfony\Component\HttpFoundation\ResponseHeaderBag;
 use Symfony\Component\HttpKernel\Exception\NotFoundHttpException;
+use Symfony\Component\Messenger\MessageBusInterface;
 use Symfony\Component\Routing\Annotation\Route;
 use Symfony\Component\String\Slugger\AsciiSlugger;
 
@@ -24,7 +29,9 @@ class MangaController extends AbstractController
         private readonly MangaExportService      $mangaExportService,
         private readonly LelScansProviderService $mangaProviderService,
         private readonly MangaRepository         $mangaRepository,
-        private MangaUpdatesMetadataProvider     $mangaUpdatesDbProvider
+        private ChapterRepository               $chapterRepository,
+        private MangaUpdatesMetadataProvider     $mangaUpdatesDbProvider,
+        private MessageBusInterface              $bus
     )
     {
     }
@@ -39,9 +46,13 @@ class MangaController extends AbstractController
         ]);
     }
 
+    /**
+     * @throws NonUniqueResultException
+     */
     #[Route('/manga/{mangaSlug}', name: 'manga_show')]
     public function showChapters(string $mangaSlug): Response
     {
+//        $manga = $this->mangaRepository->findOneWithChapterBy(['slug' => $mangaSlug]);
         $manga = $this->mangaRepository->findOneBy(['slug' => $mangaSlug]);
 
         if (!$manga) {
@@ -52,6 +63,9 @@ class MangaController extends AbstractController
         foreach ($manga->getChapters() as $chapter) {
             $volume = $chapter->getVolume() ?? 'Not Found';
             $chaptersByVolume[$volume][] = $chapter;
+            usort($chaptersByVolume[$volume], function ($a, $b) {
+                return $a->getNumber() <=> $b->getNumber();
+            });
         }
 
         $chaptersByVolume = array_map('array_reverse', array_reverse($chaptersByVolume, true));
@@ -105,6 +119,21 @@ class MangaController extends AbstractController
         ]);
     }
 
+    #[Route('/addChapter/{id}', name: 'add_chapter')]
+    public function addChapterMessenger(int $id): JsonResponse
+    {
+        $chapter = $this->chapterRepository->find($id);
+        if (!$chapter) {
+            return new JsonResponse(['error' => 'Chapter Not Found.'], 400);
+        }elseif ($chapter->getLocalPath() !== null){
+           return new JsonResponse(['error' => 'Chapter already scraped.'], 400);
+        }
+
+        $this->bus->dispatch(new DownloadChapter($id));
+
+        return new JsonResponse(['success' => 'Scrapping started...'], 200);
+    }
+
     #[Route('/manga/{mangaSlug}/chapter/{chapterNumber}/download', name: 'download_chapter')]
     public function downloadChapter(string $mangaSlug, float $chapterNumber): BinaryFileResponse
     {