Upgrade of BloomFeed v0.1

2026-07-03 21:46:06 +02:00
parent 7a7440daab
commit c549e9cfc0
24 changed files with 591 additions and 6 deletions
@@ -0,0 +1,24 @@
+<?php
+
+namespace App\Http\Controllers;
+
+use App\Services\FluxCatalogService;
+use Illuminate\Http\Request;
+use Illuminate\View\View;
+
+class CatalogController extends Controller
+{
+    public function index(Request $request, FluxCatalogService $catalog): View
+    {
+        $result = $catalog->getCatalog();
+
+        $subscribedUrls = $request->user()->feeds()->pluck('url')->all();
+
+        return view('catalog', [
+            'feeds' => collect($result['feeds'])->groupBy('category'),
+            'fromCache' => $result['fromCache'],
+            'updatedAt' => $result['updatedAt'],
+            'subscribedUrls' => $subscribedUrls,
+        ]);
+    }
+}
@@ -0,0 +1,54 @@
+<?php
+
+namespace App\Services;
+
+use Illuminate\Support\Carbon;
+use Illuminate\Support\Facades\Cache;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Facades\Log;
+use Throwable;
+
+class FluxCatalogService
+{
+    private const CACHE_KEY = 'bloomflux.catalog';
+
+    private const CACHE_TIME_KEY = 'bloomflux.catalog_updated_at';
+
+    /**
+     * Retourne le catalogue BloomFluxDB, en le rafraîchissant depuis le serveur
+     * distant quand il est joignable, sinon en servant la dernière copie en cache.
+     *
+     * @return array{feeds: list<array{title: string, url: string, category: string, lang: string, description: ?string}>, fromCache: bool, updatedAt: ?Carbon}
+     */
+    public function getCatalog(): array
+    {
+        try {
+            $rows = DB::connection('bloomflux')
+                ->table('feeds')
+                ->where('is_active', 1)
+                ->orderBy('category')
+                ->orderBy('title')
+                ->get(['title', 'url', 'category', 'lang', 'description'])
+                ->map(fn ($row) => (array) $row)
+                ->all();
+
+            Cache::forever(self::CACHE_KEY, $rows);
+            Cache::forever(self::CACHE_TIME_KEY, now()->toIso8601String());
+
+            return ['feeds' => $rows, 'fromCache' => false, 'updatedAt' => now()];
+        } catch (Throwable $e) {
+            Log::warning('BloomFluxDB unreachable, serving cached catalog', [
+                'error' => $e->getMessage(),
+            ]);
+
+            $cached = Cache::get(self::CACHE_KEY, []);
+            $updatedAt = Cache::get(self::CACHE_TIME_KEY);
+
+            return [
+                'feeds' => $cached,
+                'fromCache' => true,
+                'updatedAt' => $updatedAt ? Carbon::parse($updatedAt) : null,
+            ];
+        }
+    }
+}