Fix flaky boundary test with freezeTime

.forgejo/workflows/ci.yml

@@ -0,0 +1,113 @@
+name: CI
+
+on:
+  push:
+    branches: ['release/*']
+  pull_request:
+    branches: [main]
+
+jobs:
+  ci:
+    runs-on: docker
+    container:
+      image: catthehacker/ubuntu:act-latest
+    steps:
+      - uses: https://data.forgejo.org/actions/checkout@v4
+
+      - name: Set up PHP
+        uses: https://github.com/shivammathur/setup-php@v2
+        with:
+          php-version: '8.3'
+          extensions: pdo_sqlite, mbstring, xml, dom
+          coverage: pcov
+
+      - name: Cache Composer dependencies
+        uses: https://data.forgejo.org/actions/cache@v4
+        with:
+          path: ~/.composer/cache
+          key: composer-${{ hashFiles('composer.lock') }}
+          restore-keys: composer-
+
+      - name: Install dependencies
+        run: composer install --no-interaction --prefer-dist
+
+      - name: Prepare environment
+        run: cp .env.testing .env
+
+      - name: Lint
+        run: vendor/bin/pint --test
+
+      - name: Static analysis
+        run: vendor/bin/phpstan analyse
+
+      - name: Tests
+        run: php artisan test --coverage-clover coverage.xml --coverage-text
+
+      - name: Parse coverage
+        if: github.event_name == 'pull_request'
+        id: coverage
+        run: |
+          COVERAGE=$(php -r '
+            $xml = simplexml_load_file("coverage.xml");
+            if ($xml === false || !isset($xml->project->metrics)) {
+              echo "0";
+              exit;
+            }
+            $metrics = $xml->project->metrics;
+            $statements = (int) $metrics["statements"];
+            $covered = (int) $metrics["coveredstatements"];
+            echo $statements > 0 ? round(($covered / $statements) * 100, 2) : 0;
+          ')
+          echo "percentage=$COVERAGE" >> "$GITHUB_OUTPUT"
+
+      - name: Comment coverage on PR
+        if: github.event_name == 'pull_request'
+        env:
+          FORGEJO_TOKEN: ${{ secrets.FORGEJO_TOKEN }}
+          PR_NUMBER: ${{ github.event.pull_request.number }}
+          COVERAGE: ${{ steps.coverage.outputs.percentage }}
+          REPO: ${{ github.repository }}
+          SERVER_URL: ${{ github.server_url }}
+          COMMIT_SHA: ${{ github.sha }}
+        run: |
+          API_URL="${SERVER_URL}/api/v1/repos/${REPO}/issues/${PR_NUMBER}/comments"
+          MARKER="<!-- ffr-ci-coverage-report -->"
+
+          BODY="${MARKER}
+          ## Code Coverage Report
+
+          | Metric | Value |
+          |--------|-------|
+          | **Line Coverage** | ${COVERAGE}% |
+
+          _Updated by CI — commit ${COMMIT_SHA}_"
+
+          # Find existing coverage comment
+          EXISTING=$(curl -sf -H "Authorization: token ${FORGEJO_TOKEN}" \
+            "${API_URL}?limit=50" | \
+            php -r '
+              $comments = json_decode(file_get_contents("php://stdin"), true);
+              if (!is_array($comments)) exit;
+              foreach ($comments as $c) {
+                if (str_contains($c["body"], "<!-- ffr-ci-coverage-report -->")) {
+                  echo $c["id"];
+                  exit;
+                }
+              }
+            ' || true)
+
+          if [ -n "$EXISTING" ]; then
+            # Update existing comment
+            curl -sf -X PATCH \
+              -H "Authorization: token ${FORGEJO_TOKEN}" \
+              -H "Content-Type: application/json" \
+              -d "$(php -r 'echo json_encode(["body" => $argv[1]]);' "$BODY")" \
+              "${SERVER_URL}/api/v1/repos/${REPO}/issues/comments/${EXISTING}" > /dev/null
+          else
+            # Create new comment
+            curl -sf -X POST \
+              -H "Authorization: token ${FORGEJO_TOKEN}" \
+              -H "Content-Type: application/json" \
+              -d "$(php -r 'echo json_encode(["body" => $argv[1]]);' "$BODY")" \
+              "${API_URL}" > /dev/null
+          fi

app/Actions/CreateFeedAction.php

@@ -15,7 +15,7 @@ public function execute(string $name, string $provider, int $languageId, ?string
 
         $url = config("feed.providers.{$provider}.languages.{$langCode}.url");
 
-        if (!$url) {
+        if (! $url) {
             throw new InvalidArgumentException("Invalid provider and language combination: {$provider}/{$langCode}");
         }
 

app/Actions/CreatePlatformAccountAction.php

@@ -19,7 +19,7 @@ public function __construct(
      */
     public function execute(string $instanceDomain, string $username, string $password, string $platform = 'lemmy'): PlatformAccount
     {
-        $fullInstanceUrl = 'https://' . $instanceDomain;
+        $fullInstanceUrl = 'https://'.$instanceDomain;
 
         // Authenticate first — if this fails, no records are created
         $authResponse = $this->lemmyAuthService->authenticate($fullInstanceUrl, $username, $password);

app/Console/Commands/FetchNewArticlesCommand.php

@@ -15,13 +15,13 @@ class FetchNewArticlesCommand extends Command
 
     public function handle(): int
     {
-        if (!Setting::isArticleProcessingEnabled()) {
+        if (! Setting::isArticleProcessingEnabled()) {
             $this->info('Article processing is disabled. Article discovery skipped.');
 
             return self::SUCCESS;
         }
 
-        if (!Feed::where('is_active', true)->exists()) {
+        if (! Feed::where('is_active', true)->exists()) {
             $this->info('No active feeds found. Article discovery skipped.');
 
             return self::SUCCESS;

app/Contracts/ArticleParserInterface.php

@@ -11,6 +11,7 @@ public function canParse(string $url): bool;
 
     /**
      * Extract article data from HTML
+     *
      * @return array<string, mixed>
      */
     public function extractData(string $html): array;
@@ -19,4 +20,4 @@ public function extractData(string $html): array;
      * Get the source name for this parser
      */
     public function getSourceName(): string;
-}
+}

app/Contracts/HomepageParserInterface.php

@@ -11,6 +11,7 @@ public function canParse(string $url): bool;
 
     /**
      * Extract article URLs from homepage HTML
+     *
      * @return array<int, string>
      */
     public function extractArticleUrls(string $html): array;
@@ -24,4 +25,4 @@ public function getHomepageUrl(): string;
      * Get the source name for this parser
      */
     public function getSourceName(): string;
-}
+}

app/Enums/ApprovalStatusEnum.php

@@ -0,0 +1,10 @@
+<?php
+
+namespace App\Enums;
+
+enum ApprovalStatusEnum: string
+{
+    case PENDING = 'pending';
+    case APPROVED = 'approved';
+    case REJECTED = 'rejected';
+}

app/Enums/NotificationSeverityEnum.php

@@ -0,0 +1,10 @@
+<?php
+
+namespace App\Enums;
+
+enum NotificationSeverityEnum: string
+{
+    case INFO = 'info';
+    case WARNING = 'warning';
+    case ERROR = 'error';
+}

app/Enums/NotificationTypeEnum.php

@@ -0,0 +1,21 @@
+<?php
+
+namespace App\Enums;
+
+enum NotificationTypeEnum: string
+{
+    case GENERAL = 'general';
+    case FEED_STALE = 'feed_stale';
+    case PUBLISH_FAILED = 'publish_failed';
+    case CREDENTIAL_EXPIRED = 'credential_expired';
+
+    public function label(): string
+    {
+        return match ($this) {
+            self::GENERAL => 'General',
+            self::FEED_STALE => 'Feed Stale',
+            self::PUBLISH_FAILED => 'Publish Failed',
+            self::CREDENTIAL_EXPIRED => 'Credential Expired',
+        };
+    }
+}

app/Enums/PlatformEnum.php

@@ -5,4 +5,18 @@
 enum PlatformEnum: string
 {
     case LEMMY = 'lemmy';
-}
+
+    public function channelLabel(): string
+    {
+        return match ($this) {
+            self::LEMMY => 'Community',
+        };
+    }
+
+    public function channelLabelPlural(): string
+    {
+        return match ($this) {
+            self::LEMMY => 'Communities',
+        };
+    }
+}

app/Enums/PublishStatusEnum.php

@@ -0,0 +1,11 @@
+<?php
+
+namespace App\Enums;
+
+enum PublishStatusEnum: string
+{
+    case UNPUBLISHED = 'unpublished';
+    case PUBLISHING = 'publishing';
+    case PUBLISHED = 'published';
+    case ERROR = 'error';
+}

app/Events/ActionPerformed.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace App\Events;
+
+use App\Enums\LogLevelEnum;
+use Illuminate\Foundation\Events\Dispatchable;
+
+class ActionPerformed
+{
+    use Dispatchable;
+
+    public function __construct(
+        public string $message,
+        public LogLevelEnum $level = LogLevelEnum::INFO,
+        /** @var array<string, mixed> */
+        public array $context = [],
+    ) {}
+}

app/Events/ExceptionLogged.php

@@ -12,6 +12,5 @@ class ExceptionLogged
 
     public function __construct(
         public Log $log
-    ) {
-    }
+    ) {}
 }

app/Events/ExceptionOccurred.php

@@ -17,6 +17,5 @@ public function __construct(
         public string $message,
         /** @var array<string, mixed> */
         public array $context = []
-    ) {
-    }
+    ) {}
 }

app/Events/NewArticleFetched.php

@@ -11,7 +11,5 @@ class NewArticleFetched
 {
     use Dispatchable, InteractsWithSockets, SerializesModels;
 
-    public function __construct(public Article $article)
-    {
-    }
+    public function __construct(public Article $article) {}
 }

app/Events/RouteArticleApproved.php

@@ -2,16 +2,13 @@
 
 namespace App\Events;
 
-use App\Models\Article;
+use App\Models\RouteArticle;
 use Illuminate\Foundation\Events\Dispatchable;
 use Illuminate\Queue\SerializesModels;
 
-class ArticleApproved
+class RouteArticleApproved
 {
     use Dispatchable, SerializesModels;
 
-    public function __construct(public Article $article)
-    {
-        //
-    }
+    public function __construct(public RouteArticle $routeArticle) {}
 }

app/Exceptions/ChannelException.php

@@ -4,6 +4,4 @@
 
 use Exception;
 
-class ChannelException extends Exception
-{
-}
+class ChannelException extends Exception {}

app/Exceptions/PublishException.php

@@ -11,7 +11,7 @@ class PublishException extends Exception
 {
     public function __construct(
         private readonly Article $article,
-        private readonly PlatformEnum|null $platform,
+        private readonly ?PlatformEnum $platform,
         ?Throwable $previous = null
     ) {
         $message = "Failed to publish article #$article->id";

app/Exceptions/RoutingException.php

@@ -4,6 +4,4 @@
 
 use Exception;
 
-class RoutingException extends Exception
-{
-}
+class RoutingException extends Exception {}

app/Facades/LogSaver.php

@@ -10,4 +10,4 @@ protected static function getFacadeAccessor()
     {
         return \App\Services\Log\LogSaver::class;
     }
-}
+}

app/Http/Controllers/Api/V1/ArticlesController.php

@@ -3,13 +3,12 @@
 namespace App\Http\Controllers\Api\V1;
 
 use App\Http\Resources\ArticleResource;
+use App\Jobs\ArticleDiscoveryJob;
 use App\Models\Article;
 use App\Models\Setting;
-use App\Jobs\ArticleDiscoveryJob;
 use Exception;
 use Illuminate\Http\JsonResponse;
 use Illuminate\Http\Request;
-use Illuminate\Support\Facades\Artisan;
 
 class ArticlesController extends BaseController
 {
@@ -41,40 +40,6 @@ public function index(Request $request): JsonResponse
         ]);
     }
 
-    /**
-     * Approve an article
-     */
-    public function approve(Article $article): JsonResponse
-    {
-        try {
-            $article->approve('manual');
-
-            return $this->sendResponse(
-                new ArticleResource($article->fresh(['feed', 'articlePublication'])),
-                'Article approved and queued for publishing.'
-            );
-        } catch (Exception $e) {
-            return $this->sendError('Failed to approve article: ' . $e->getMessage(), [], 500);
-        }
-    }
-
-    /**
-     * Reject an article
-     */
-    public function reject(Article $article): JsonResponse
-    {
-        try {
-            $article->reject('manual');
-
-            return $this->sendResponse(
-                new ArticleResource($article->fresh(['feed', 'articlePublication'])),
-                'Article rejected.'
-            );
-        } catch (Exception $e) {
-            return $this->sendError('Failed to reject article: ' . $e->getMessage(), [], 500);
-        }
-    }
-
     /**
      * Manually refresh articles from all active feeds
      */
@@ -88,7 +53,7 @@ public function refresh(): JsonResponse
                 'Article refresh started. New articles will appear shortly.'
             );
         } catch (Exception $e) {
-            return $this->sendError('Failed to start article refresh: ' . $e->getMessage(), [], 500);
+            return $this->sendError('Failed to start article refresh: '.$e->getMessage(), [], 500);
         }
     }
 }

app/Http/Controllers/Api/V1/AuthController.php

@@ -5,7 +5,6 @@
 use App\Models\User;
 use Illuminate\Http\JsonResponse;
 use Illuminate\Http\Request;
-use Illuminate\Support\Facades\Auth;
 use Illuminate\Support\Facades\Hash;
 use Illuminate\Validation\ValidationException;
 
@@ -24,7 +23,7 @@ public function login(Request $request): JsonResponse
 
             $user = User::where('email', $request->email)->first();
 
-            if (!$user || !Hash::check($request->password, $user->password)) {
+            if (! $user || ! Hash::check($request->password, $user->password)) {
                 return $this->sendError('Invalid credentials', [], 401);
             }
 
@@ -42,7 +41,7 @@ public function login(Request $request): JsonResponse
         } catch (ValidationException $e) {
             return $this->sendValidationError($e->errors());
         } catch (\Exception $e) {
-            return $this->sendError('Login failed: ' . $e->getMessage(), [], 500);
+            return $this->sendError('Login failed: '.$e->getMessage(), [], 500);
         }
     }
 
@@ -78,7 +77,7 @@ public function register(Request $request): JsonResponse
         } catch (ValidationException $e) {
             return $this->sendValidationError($e->errors());
         } catch (\Exception $e) {
-            return $this->sendError('Registration failed: ' . $e->getMessage(), [], 500);
+            return $this->sendError('Registration failed: '.$e->getMessage(), [], 500);
         }
     }
 
@@ -92,7 +91,7 @@ public function logout(Request $request): JsonResponse
 
             return $this->sendResponse(null, 'Logged out successfully');
         } catch (\Exception $e) {
-            return $this->sendError('Logout failed: ' . $e->getMessage(), [], 500);
+            return $this->sendError('Logout failed: '.$e->getMessage(), [], 500);
         }
     }
 
@@ -109,4 +108,4 @@ public function me(Request $request): JsonResponse
             ],
         ], 'User retrieved successfully');
     }
-}
+}

app/Http/Controllers/Api/V1/BaseController.php

@@ -23,6 +23,8 @@ public function sendResponse(mixed $result, string $message = 'Success', int $co
 
     /**
      * Error response method
+     *
+     * @param  array<string, mixed>  $errorMessages
      */
     public function sendError(string $error, array $errorMessages = [], int $code = 400): JsonResponse
     {
@@ -31,7 +33,7 @@ public function sendError(string $error, array $errorMessages = [], int $code =
             'message' => $error,
         ];
 
-        if (!empty($errorMessages)) {
+        if (! empty($errorMessages)) {
             $response['errors'] = $errorMessages;
         }
 
@@ -40,6 +42,8 @@ public function sendError(string $error, array $errorMessages = [], int $code =
 
     /**
      * Validation error response method
+     *
+     * @param  array<string, mixed>  $errors
      */
     public function sendValidationError(array $errors): JsonResponse
     {
@@ -61,4 +65,4 @@ public function sendUnauthorized(string $message = 'Unauthorized'): JsonResponse
     {
         return $this->sendError($message, [], 401);
     }
-}
+}

app/Http/Controllers/Api/V1/DashboardController.php

@@ -3,9 +3,6 @@
 namespace App\Http\Controllers\Api\V1;
 
 use App\Models\Article;
-use App\Models\Feed;
-use App\Models\PlatformAccount;
-use App\Models\PlatformChannel;
 use App\Services\DashboardStatsService;
 use Illuminate\Http\JsonResponse;
 use Illuminate\Http\Request;
@@ -40,8 +37,7 @@ public function stats(Request $request): JsonResponse
                 'current_period' => $period,
             ]);
         } catch (\Exception $e) {
-            throw $e;
-            return $this->sendError('Failed to fetch dashboard stats: ' . $e->getMessage(), [], 500);
+            return $this->sendError('Failed to fetch dashboard stats: '.$e->getMessage(), [], 500);
         }
     }
 }

app/Http/Controllers/Api/V1/FeedsController.php

@@ -10,8 +10,8 @@
 use Exception;
 use Illuminate\Http\JsonResponse;
 use Illuminate\Http\Request;
-use InvalidArgumentException;
 use Illuminate\Validation\ValidationException;
+use InvalidArgumentException;
 
 class FeedsController extends BaseController
 {
@@ -21,7 +21,7 @@ class FeedsController extends BaseController
     public function index(Request $request): JsonResponse
     {
         $perPage = min($request->get('per_page', 15), 100);
-        
+
         $feeds = Feed::with(['language'])
             ->withCount('articles')
             ->orderBy('is_active', 'desc')
@@ -37,7 +37,7 @@ public function index(Request $request): JsonResponse
                 'total' => $feeds->total(),
                 'from' => $feeds->firstItem(),
                 'to' => $feeds->lastItem(),
-            ]
+            ],
         ], 'Feeds retrieved successfully.');
     }
 
@@ -64,7 +64,7 @@ public function store(StoreFeedRequest $request, CreateFeedAction $createFeedAct
         } catch (InvalidArgumentException $e) {
             return $this->sendError($e->getMessage(), [], 422);
         } catch (Exception $e) {
-            return $this->sendError('Failed to create feed: ' . $e->getMessage(), [], 500);
+            return $this->sendError('Failed to create feed: '.$e->getMessage(), [], 500);
         }
     }
 
@@ -97,7 +97,7 @@ public function update(UpdateFeedRequest $request, Feed $feed): JsonResponse
         } catch (ValidationException $e) {
             return $this->sendValidationError($e->errors());
         } catch (Exception $e) {
-            return $this->sendError('Failed to update feed: ' . $e->getMessage(), [], 500);
+            return $this->sendError('Failed to update feed: '.$e->getMessage(), [], 500);
         }
     }
 
@@ -114,7 +114,7 @@ public function destroy(Feed $feed): JsonResponse
                 'Feed deleted successfully!'
             );
         } catch (Exception $e) {
-            return $this->sendError('Failed to delete feed: ' . $e->getMessage(), [], 500);
+            return $this->sendError('Failed to delete feed: '.$e->getMessage(), [], 500);
         }
     }
 
@@ -124,7 +124,7 @@ public function destroy(Feed $feed): JsonResponse
     public function toggle(Feed $feed): JsonResponse
     {
         try {
-            $newStatus = !$feed->is_active;
+            $newStatus = ! $feed->is_active;
             $feed->update(['is_active' => $newStatus]);
 
             $status = $newStatus ? 'activated' : 'deactivated';
@@ -134,7 +134,7 @@ public function toggle(Feed $feed): JsonResponse
                 "Feed {$status} successfully!"
             );
         } catch (Exception $e) {
-            return $this->sendError('Failed to toggle feed status: ' . $e->getMessage(), [], 500);
+            return $this->sendError('Failed to toggle feed status: '.$e->getMessage(), [], 500);
         }
     }
-}
+}

app/Http/Controllers/Api/V1/KeywordsController.php

@@ -62,7 +62,7 @@ public function store(Request $request, Feed $feed, PlatformChannel $channel): J
         } catch (ValidationException $e) {
             return $this->sendValidationError($e->errors());
         } catch (\Exception $e) {
-            return $this->sendError('Failed to create keyword: ' . $e->getMessage(), [], 500);
+            return $this->sendError('Failed to create keyword: '.$e->getMessage(), [], 500);
         }
     }
 
@@ -90,7 +90,7 @@ public function update(Request $request, Feed $feed, PlatformChannel $channel, K
         } catch (ValidationException $e) {
             return $this->sendValidationError($e->errors());
         } catch (\Exception $e) {
-            return $this->sendError('Failed to update keyword: ' . $e->getMessage(), [], 500);
+            return $this->sendError('Failed to update keyword: '.$e->getMessage(), [], 500);
         }
     }
 
@@ -112,7 +112,7 @@ public function destroy(Feed $feed, PlatformChannel $channel, Keyword $keyword):
                 'Keyword deleted successfully!'
             );
         } catch (\Exception $e) {
-            return $this->sendError('Failed to delete keyword: ' . $e->getMessage(), [], 500);
+            return $this->sendError('Failed to delete keyword: '.$e->getMessage(), [], 500);
         }
     }
 
@@ -127,7 +127,7 @@ public function toggle(Feed $feed, PlatformChannel $channel, Keyword $keyword):
                 return $this->sendNotFound('Keyword not found for this route.');
             }
 
-            $newStatus = !$keyword->is_active;
+            $newStatus = ! $keyword->is_active;
             $keyword->update(['is_active' => $newStatus]);
 
             $status = $newStatus ? 'activated' : 'deactivated';
@@ -137,7 +137,7 @@ public function toggle(Feed $feed, PlatformChannel $channel, Keyword $keyword):
                 "Keyword {$status} successfully!"
             );
         } catch (\Exception $e) {
-            return $this->sendError('Failed to toggle keyword status: ' . $e->getMessage(), [], 500);
+            return $this->sendError('Failed to toggle keyword status: '.$e->getMessage(), [], 500);
         }
     }
-}
+}

app/Http/Controllers/Api/V1/LogsController.php

@@ -49,7 +49,7 @@ public function index(Request $request): JsonResponse
                 ],
             ], 'Logs retrieved successfully.');
         } catch (\Exception $e) {
-            return $this->sendError('Failed to retrieve logs: ' . $e->getMessage(), [], 500);
+            return $this->sendError('Failed to retrieve logs: '.$e->getMessage(), [], 500);
         }
     }
 }

app/Http/Controllers/Api/V1/OnboardingController.php

@@ -31,18 +31,18 @@ public function status(): JsonResponse
         // 1. They haven't completed or skipped onboarding AND
         // 2. They don't have all required components
         $hasAllComponents = $hasPlatformAccount && $hasFeed && $hasChannel && $hasRoute;
-        $needsOnboarding = !$onboardingCompleted && !$onboardingSkipped && !$hasAllComponents;
+        $needsOnboarding = ! $onboardingCompleted && ! $onboardingSkipped && ! $hasAllComponents;
 
         // Determine current step
         $currentStep = null;
         if ($needsOnboarding) {
-            if (!$hasPlatformAccount) {
+            if (! $hasPlatformAccount) {
                 $currentStep = 'platform';
-            } elseif (!$hasFeed) {
+            } elseif (! $hasFeed) {
                 $currentStep = 'feed';
-            } elseif (!$hasChannel) {
+            } elseif (! $hasChannel) {
                 $currentStep = 'channel';
-            } elseif (!$hasRoute) {
+            } elseif (! $hasRoute) {
                 $currentStep = 'route';
             }
         }
@@ -56,7 +56,7 @@ public function status(): JsonResponse
             'has_route' => $hasRoute,
             'onboarding_skipped' => $onboardingSkipped,
             'onboarding_completed' => $onboardingCompleted,
-            'missing_components' => !$hasAllComponents && $onboardingCompleted,
+            'missing_components' => ! $hasAllComponents && $onboardingCompleted,
         ], 'Onboarding status retrieved successfully.');
     }
 
@@ -84,8 +84,10 @@ public function options(): JsonResponse
             ->get(['id', 'platform_instance_id', 'name', 'display_name', 'description']);
 
         // Get feed providers from config
-        $feedProviders = collect(config('feed.providers', []))
-            ->filter(fn($provider) => $provider['is_active'])
+        /** @var array<string, array<string, mixed>> $providers */
+        $providers = config('feed.providers', []);
+        $feedProviders = collect($providers)
+            ->filter(fn (array $provider) => $provider['is_active'])
             ->values();
 
         return $this->sendResponse([

app/Http/Controllers/Api/V1/PlatformAccountsController.php

@@ -53,6 +53,7 @@ public function store(StorePlatformAccountRequest $request, CreatePlatformAccoun
             if (str_contains($e->getMessage(), 'Rate limited by')) {
                 return $this->sendError($e->getMessage(), [], 429);
             }
+
             return $this->sendError('Invalid username or password. Please check your credentials and try again.', [], 422);
         } catch (Exception $e) {
             return $this->sendError('Unable to connect to the Lemmy instance. Please check the URL and try again.', [], 422);
@@ -97,7 +98,7 @@ public function update(Request $request, PlatformAccount $platformAccount): Json
         } catch (ValidationException $e) {
             return $this->sendValidationError($e->errors());
         } catch (Exception $e) {
-            return $this->sendError('Failed to update platform account: ' . $e->getMessage(), [], 500);
+            return $this->sendError('Failed to update platform account: '.$e->getMessage(), [], 500);
         }
     }
 
@@ -114,7 +115,7 @@ public function destroy(PlatformAccount $platformAccount): JsonResponse
                 'Platform account deleted successfully!'
             );
         } catch (Exception $e) {
-            return $this->sendError('Failed to delete platform account: ' . $e->getMessage(), [], 500);
+            return $this->sendError('Failed to delete platform account: '.$e->getMessage(), [], 500);
         }
     }
 
@@ -131,7 +132,7 @@ public function setActive(PlatformAccount $platformAccount): JsonResponse
                 "Set {$platformAccount->username}@{$platformAccount->instance_url} as active for {$platformAccount->platform->value}!"
             );
         } catch (Exception $e) {
-            return $this->sendError('Failed to set platform account as active: ' . $e->getMessage(), [], 500);
+            return $this->sendError('Failed to set platform account as active: '.$e->getMessage(), [], 500);
         }
     }
-}
+}

app/Http/Controllers/Api/V1/PlatformChannelsController.php

@@ -5,8 +5,8 @@
 use App\Actions\CreateChannelAction;
 use App\Http\Requests\StorePlatformChannelRequest;
 use App\Http\Resources\PlatformChannelResource;
-use App\Models\PlatformChannel;
 use App\Models\PlatformAccount;
+use App\Models\PlatformChannel;
 use Exception;
 use Illuminate\Http\JsonResponse;
 use Illuminate\Http\Request;
@@ -54,7 +54,7 @@ public function store(StorePlatformChannelRequest $request, CreateChannelAction
         } catch (RuntimeException $e) {
             return $this->sendError($e->getMessage(), [], 422);
         } catch (Exception $e) {
-            return $this->sendError('Failed to create platform channel: ' . $e->getMessage(), [], 500);
+            return $this->sendError('Failed to create platform channel: '.$e->getMessage(), [], 500);
         }
     }
 
@@ -91,7 +91,7 @@ public function update(Request $request, PlatformChannel $platformChannel): Json
         } catch (ValidationException $e) {
             return $this->sendValidationError($e->errors());
         } catch (Exception $e) {
-            return $this->sendError('Failed to update platform channel: ' . $e->getMessage(), [], 500);
+            return $this->sendError('Failed to update platform channel: '.$e->getMessage(), [], 500);
         }
     }
 
@@ -108,7 +108,7 @@ public function destroy(PlatformChannel $platformChannel): JsonResponse
                 'Platform channel deleted successfully!'
             );
         } catch (Exception $e) {
-            return $this->sendError('Failed to delete platform channel: ' . $e->getMessage(), [], 500);
+            return $this->sendError('Failed to delete platform channel: '.$e->getMessage(), [], 500);
         }
     }
 
@@ -118,7 +118,7 @@ public function destroy(PlatformChannel $platformChannel): JsonResponse
     public function toggle(PlatformChannel $channel): JsonResponse
     {
         try {
-            $newStatus = !$channel->is_active;
+            $newStatus = ! $channel->is_active;
             $channel->update(['is_active' => $newStatus]);
 
             $status = $newStatus ? 'activated' : 'deactivated';
@@ -128,7 +128,7 @@ public function toggle(PlatformChannel $channel): JsonResponse
                 "Platform channel {$status} successfully!"
             );
         } catch (Exception $e) {
-            return $this->sendError('Failed to toggle platform channel status: ' . $e->getMessage(), [], 500);
+            return $this->sendError('Failed to toggle platform channel status: '.$e->getMessage(), [], 500);
         }
     }
 
@@ -144,6 +144,7 @@ public function attachAccount(PlatformChannel $channel, Request $request): JsonR
                 'priority' => 'nullable|integer|min:1|max:100',
             ]);
 
+            /** @var PlatformAccount $platformAccount */
             $platformAccount = PlatformAccount::findOrFail($validated['platform_account_id']);
 
             // Check if account is already attached
@@ -165,7 +166,7 @@ public function attachAccount(PlatformChannel $channel, Request $request): JsonR
         } catch (ValidationException $e) {
             return $this->sendValidationError($e->errors());
         } catch (Exception $e) {
-            return $this->sendError('Failed to attach platform account: ' . $e->getMessage(), [], 500);
+            return $this->sendError('Failed to attach platform account: '.$e->getMessage(), [], 500);
         }
     }
 
@@ -175,7 +176,7 @@ public function attachAccount(PlatformChannel $channel, Request $request): JsonR
     public function detachAccount(PlatformChannel $channel, PlatformAccount $account): JsonResponse
     {
         try {
-            if (!$channel->platformAccounts()->where('platform_account_id', $account->id)->exists()) {
+            if (! $channel->platformAccounts()->where('platform_account_id', $account->id)->exists()) {
                 return $this->sendError('Platform account is not attached to this channel.', [], 422);
             }
 
@@ -186,7 +187,7 @@ public function detachAccount(PlatformChannel $channel, PlatformAccount $account
                 'Platform account detached from channel successfully!'
             );
         } catch (Exception $e) {
-            return $this->sendError('Failed to detach platform account: ' . $e->getMessage(), [], 500);
+            return $this->sendError('Failed to detach platform account: '.$e->getMessage(), [], 500);
         }
     }
 
@@ -201,7 +202,7 @@ public function updateAccountRelation(PlatformChannel $channel, PlatformAccount
                 'priority' => 'nullable|integer|min:1|max:100',
             ]);
 
-            if (!$channel->platformAccounts()->where('platform_account_id', $account->id)->exists()) {
+            if (! $channel->platformAccounts()->where('platform_account_id', $account->id)->exists()) {
                 return $this->sendError('Platform account is not attached to this channel.', [], 422);
             }
 
@@ -218,7 +219,7 @@ public function updateAccountRelation(PlatformChannel $channel, PlatformAccount
         } catch (ValidationException $e) {
             return $this->sendValidationError($e->errors());
         } catch (Exception $e) {
-            return $this->sendError('Failed to update platform account relationship: ' . $e->getMessage(), [], 500);
+            return $this->sendError('Failed to update platform account relationship: '.$e->getMessage(), [], 500);
         }
     }
-}
+}

app/Http/Controllers/Api/V1/RouteArticlesController.php

@@ -0,0 +1,101 @@
+<?php
+
+namespace App\Http\Controllers\Api\V1;
+
+use App\Enums\ApprovalStatusEnum;
+use App\Http\Resources\RouteArticleResource;
+use App\Models\RouteArticle;
+use Exception;
+use Illuminate\Http\JsonResponse;
+use Illuminate\Http\Request;
+
+class RouteArticlesController extends BaseController
+{
+    public function index(Request $request): JsonResponse
+    {
+        $perPage = min($request->get('per_page', 15), 100);
+
+        $query = RouteArticle::with(['article.feed', 'feed', 'platformChannel'])
+            ->orderBy('created_at', 'desc');
+
+        if ($request->has('status')) {
+            $status = ApprovalStatusEnum::tryFrom($request->get('status'));
+            if ($status) {
+                $query->where('approval_status', $status);
+            }
+        }
+
+        $routeArticles = $query->paginate($perPage);
+
+        return $this->sendResponse([
+            'route_articles' => RouteArticleResource::collection($routeArticles->items()),
+            'pagination' => [
+                'current_page' => $routeArticles->currentPage(),
+                'last_page' => $routeArticles->lastPage(),
+                'per_page' => $routeArticles->perPage(),
+                'total' => $routeArticles->total(),
+                'from' => $routeArticles->firstItem(),
+                'to' => $routeArticles->lastItem(),
+            ],
+        ]);
+    }
+
+    public function approve(RouteArticle $routeArticle): JsonResponse
+    {
+        try {
+            $routeArticle->approve();
+
+            return $this->sendResponse(
+                new RouteArticleResource($routeArticle->fresh(['article.feed', 'feed', 'platformChannel'])),
+                'Route article approved and queued for publishing.'
+            );
+        } catch (Exception $e) {
+            return $this->sendError('Failed to approve route article: '.$e->getMessage(), [], 500);
+        }
+    }
+
+    public function reject(RouteArticle $routeArticle): JsonResponse
+    {
+        try {
+            $routeArticle->reject();
+
+            return $this->sendResponse(
+                new RouteArticleResource($routeArticle->fresh(['article.feed', 'feed', 'platformChannel'])),
+                'Route article rejected.'
+            );
+        } catch (Exception $e) {
+            return $this->sendError('Failed to reject route article: '.$e->getMessage(), [], 500);
+        }
+    }
+
+    public function restore(RouteArticle $routeArticle): JsonResponse
+    {
+        try {
+            $routeArticle->update(['approval_status' => ApprovalStatusEnum::PENDING]);
+
+            return $this->sendResponse(
+                new RouteArticleResource($routeArticle->fresh(['article.feed', 'feed', 'platformChannel'])),
+                'Route article restored to pending.'
+            );
+        } catch (Exception $e) {
+            return $this->sendError('Failed to restore route article: '.$e->getMessage(), [], 500);
+        }
+    }
+
+    public function clear(): JsonResponse
+    {
+        try {
+            $count = RouteArticle::where('approval_status', ApprovalStatusEnum::PENDING)->count();
+
+            RouteArticle::where('approval_status', ApprovalStatusEnum::PENDING)
+                ->update(['approval_status' => ApprovalStatusEnum::REJECTED]);
+
+            return $this->sendResponse(
+                ['rejected_count' => $count],
+                "Rejected {$count} pending route articles."
+            );
+        } catch (Exception $e) {
+            return $this->sendError('Failed to clear pending route articles: '.$e->getMessage(), [], 500);
+        }
+    }
+}

app/Http/Controllers/Api/V1/RoutingController.php

@@ -52,7 +52,7 @@ public function store(StoreRouteRequest $request, CreateRouteAction $createRoute
                 201
             );
         } catch (Exception $e) {
-            return $this->sendError('Failed to create routing configuration: ' . $e->getMessage(), [], 500);
+            return $this->sendError('Failed to create routing configuration: '.$e->getMessage(), [], 500);
         }
     }
 
@@ -62,11 +62,11 @@ public function store(StoreRouteRequest $request, CreateRouteAction $createRoute
     public function show(Feed $feed, PlatformChannel $channel): JsonResponse
     {
         $route = $this->findRoute($feed, $channel);
-        
-        if (!$route) {
+
+        if (! $route) {
             return $this->sendNotFound('Routing configuration not found.');
         }
-        
+
         $route->load(['feed', 'platformChannel', 'keywords']);
 
         return $this->sendResponse(
@@ -83,7 +83,7 @@ public function update(Request $request, Feed $feed, PlatformChannel $channel):
         try {
             $route = $this->findRoute($feed, $channel);
 
-            if (!$route) {
+            if (! $route) {
                 return $this->sendNotFound('Routing configuration not found.');
             }
 
@@ -103,7 +103,7 @@ public function update(Request $request, Feed $feed, PlatformChannel $channel):
         } catch (ValidationException $e) {
             return $this->sendValidationError($e->errors());
         } catch (Exception $e) {
-            return $this->sendError('Failed to update routing configuration: ' . $e->getMessage(), [], 500);
+            return $this->sendError('Failed to update routing configuration: '.$e->getMessage(), [], 500);
         }
     }
 
@@ -115,7 +115,7 @@ public function destroy(Feed $feed, PlatformChannel $channel): JsonResponse
         try {
             $route = $this->findRoute($feed, $channel);
 
-            if (!$route) {
+            if (! $route) {
                 return $this->sendNotFound('Routing configuration not found.');
             }
 
@@ -128,7 +128,7 @@ public function destroy(Feed $feed, PlatformChannel $channel): JsonResponse
                 'Routing configuration deleted successfully!'
             );
         } catch (Exception $e) {
-            return $this->sendError('Failed to delete routing configuration: ' . $e->getMessage(), [], 500);
+            return $this->sendError('Failed to delete routing configuration: '.$e->getMessage(), [], 500);
         }
     }
 
@@ -140,11 +140,11 @@ public function toggle(Feed $feed, PlatformChannel $channel): JsonResponse
         try {
             $route = $this->findRoute($feed, $channel);
 
-            if (!$route) {
+            if (! $route) {
                 return $this->sendNotFound('Routing configuration not found.');
             }
 
-            $newStatus = !$route->is_active;
+            $newStatus = ! $route->is_active;
             Route::where('feed_id', $feed->id)
                 ->where('platform_channel_id', $channel->id)
                 ->update(['is_active' => $newStatus]);
@@ -156,7 +156,7 @@ public function toggle(Feed $feed, PlatformChannel $channel): JsonResponse
                 "Routing configuration {$status} successfully!"
             );
         } catch (Exception $e) {
-            return $this->sendError('Failed to toggle routing configuration status: ' . $e->getMessage(), [], 500);
+            return $this->sendError('Failed to toggle routing configuration status: '.$e->getMessage(), [], 500);
         }
     }
 
@@ -169,4 +169,4 @@ private function findRoute(Feed $feed, PlatformChannel $channel): ?Route
             ->where('platform_channel_id', $channel->id)
             ->first();
     }
-}
+}

app/Http/Controllers/Api/V1/SettingsController.php

@@ -23,7 +23,7 @@ public function index(): JsonResponse
 
             return $this->sendResponse($settings, 'Settings retrieved successfully.');
         } catch (\Exception $e) {
-            return $this->sendError('Failed to retrieve settings: ' . $e->getMessage(), [], 500);
+            return $this->sendError('Failed to retrieve settings: '.$e->getMessage(), [], 500);
         }
     }
 
@@ -64,7 +64,7 @@ public function update(Request $request): JsonResponse
         } catch (ValidationException $e) {
             return $this->sendValidationError($e->errors());
         } catch (\Exception $e) {
-            return $this->sendError('Failed to update settings: ' . $e->getMessage(), [], 500);
+            return $this->sendError('Failed to update settings: '.$e->getMessage(), [], 500);
         }
     }
 }

app/Http/Controllers/Auth/NewPasswordController.php

@@ -11,6 +11,7 @@
 use Illuminate\Support\Facades\Password;
 use Illuminate\Support\Str;
 use Illuminate\Validation\Rules;
+use Illuminate\Validation\ValidationException;
 use Illuminate\View\View;
 
 class NewPasswordController extends Controller
@@ -26,7 +27,7 @@ public function create(Request $request): View
     /**
      * Handle an incoming new password request.
      *
-     * @throws \Illuminate\Validation\ValidationException
+     * @throws ValidationException
      */
     public function store(Request $request): RedirectResponse
     {

app/Http/Controllers/Auth/PasswordResetLinkController.php

@@ -6,6 +6,7 @@
 use Illuminate\Http\RedirectResponse;
 use Illuminate\Http\Request;
 use Illuminate\Support\Facades\Password;
+use Illuminate\Validation\ValidationException;
 use Illuminate\View\View;
 
 class PasswordResetLinkController extends Controller
@@ -21,7 +22,7 @@ public function create(): View
     /**
      * Handle an incoming password reset link request.
      *
-     * @throws \Illuminate\Validation\ValidationException
+     * @throws ValidationException
      */
     public function store(Request $request): RedirectResponse
     {

app/Http/Controllers/Auth/RegisteredUserController.php

@@ -10,6 +10,7 @@
 use Illuminate\Support\Facades\Auth;
 use Illuminate\Support\Facades\Hash;
 use Illuminate\Validation\Rules;
+use Illuminate\Validation\ValidationException;
 use Illuminate\View\View;
 
 class RegisteredUserController extends Controller
@@ -25,7 +26,7 @@ public function create(): View
     /**
      * Handle an incoming registration request.
      *
-     * @throws \Illuminate\Validation\ValidationException
+     * @throws ValidationException
      */
     public function store(Request $request): RedirectResponse
     {

app/Http/Controllers/Auth/VerifyEmailController.php

@@ -4,6 +4,7 @@
 
 use App\Http\Controllers\Controller;
 use Illuminate\Auth\Events\Verified;
+use Illuminate\Contracts\Auth\MustVerifyEmail;
 use Illuminate\Foundation\Auth\EmailVerificationRequest;
 use Illuminate\Http\RedirectResponse;
 
@@ -19,7 +20,9 @@ public function __invoke(EmailVerificationRequest $request): RedirectResponse
         }
 
         if ($request->user()->markEmailAsVerified()) {
-            event(new Verified($request->user()));
+            /** @var MustVerifyEmail $user */
+            $user = $request->user();
+            event(new Verified($user));
         }
 
         return redirect()->intended(route('dashboard', absolute: false).'?verified=1');

app/Http/Middleware/EnsureOnboardingComplete.php

@@ -26,4 +26,4 @@ public function handle(Request $request, Closure $next): Response
 
         return $next($request);
     }
-}
+}

app/Http/Middleware/HandleAppearance.php

@@ -12,7 +12,7 @@ class HandleAppearance
     /**
      * Handle an incoming request.
      *
-     * @param  \Closure(\Illuminate\Http\Request): (\Symfony\Component\HttpFoundation\Response)  $next
+     * @param  Closure(Request): (Response)  $next
      */
     public function handle(Request $request, Closure $next): Response
     {

app/Http/Middleware/HandleInertiaRequests.php

@@ -39,4 +39,4 @@ public function share(Request $request): array
             //
         ]);
     }
-}
+}

app/Http/Middleware/RedirectIfOnboardingComplete.php

@@ -20,10 +20,10 @@ public function __construct(
      */
     public function handle(Request $request, Closure $next): Response
     {
-        if (!$this->onboardingService->needsOnboarding()) {
+        if (! $this->onboardingService->needsOnboarding()) {
             return redirect()->route('dashboard');
         }
 
         return $next($request);
     }
-}
+}

app/Http/Requests/Auth/LoginRequest.php

@@ -3,6 +3,7 @@
 namespace App\Http\Requests\Auth;
 
 use Illuminate\Auth\Events\Lockout;
+use Illuminate\Contracts\Validation\ValidationRule;
 use Illuminate\Foundation\Http\FormRequest;
 use Illuminate\Support\Facades\Auth;
 use Illuminate\Support\Facades\RateLimiter;
@@ -22,7 +23,7 @@ public function authorize(): bool
     /**
      * Get the validation rules that apply to the request.
      *
-     * @return array<string, \Illuminate\Contracts\Validation\ValidationRule|array<mixed>|string>
+     * @return array<string, ValidationRule|array<mixed>|string>
      */
     public function rules(): array
     {
@@ -35,7 +36,7 @@ public function rules(): array
     /**
      * Attempt to authenticate the request's credentials.
      *
-     * @throws \Illuminate\Validation\ValidationException
+     * @throws ValidationException
      */
     public function authenticate(): void
     {
@@ -55,7 +56,7 @@ public function authenticate(): void
     /**
      * Ensure the login request is not rate limited.
      *
-     * @throws \Illuminate\Validation\ValidationException
+     * @throws ValidationException
      */
     public function ensureIsNotRateLimited(): void
     {

app/Http/Requests/ProfileUpdateRequest.php

@@ -3,6 +3,7 @@
 namespace App\Http\Requests;
 
 use App\Models\User;
+use Illuminate\Contracts\Validation\ValidationRule;
 use Illuminate\Foundation\Http\FormRequest;
 use Illuminate\Validation\Rule;
 
@@ -11,7 +12,7 @@ class ProfileUpdateRequest extends FormRequest
     /**
      * Get the validation rules that apply to the request.
      *
-     * @return array<string, \Illuminate\Contracts\Validation\ValidationRule|array<mixed>|string>
+     * @return array<string, ValidationRule|array<mixed>|string>
      */
     public function rules(): array
     {

app/Http/Requests/StoreFeedRequest.php

@@ -23,7 +23,7 @@ public function rules(): array
             'provider' => "required|in:{$providers}",
             'language_id' => 'required|exists:languages,id',
             'description' => 'nullable|string',
-            'is_active' => 'boolean'
+            'is_active' => 'boolean',
         ];
     }
-}
+}

app/Http/Requests/UpdateFeedRequest.php

@@ -19,11 +19,11 @@ public function rules(): array
     {
         return [
             'name' => 'required|string|max:255',
-            'url' => 'required|url|unique:feeds,url,' . ($this->route('feed') instanceof Feed ? (string)$this->route('feed')->id : (string)$this->route('feed')),
+            'url' => 'required|url|unique:feeds,url,'.($this->route('feed') instanceof Feed ? (string) $this->route('feed')->id : (string) $this->route('feed')),
             'type' => 'required|in:website,rss',
             'language_id' => 'required|exists:languages,id',
             'description' => 'nullable|string',
-            'is_active' => 'boolean'
+            'is_active' => 'boolean',
         ];
     }
-}
+}

app/Http/Resources/ArticlePublicationResource.php

@@ -2,9 +2,13 @@
 
 namespace App\Http\Resources;
 
+use App\Models\ArticlePublication;
 use Illuminate\Http\Request;
 use Illuminate\Http\Resources\Json\JsonResource;
 
+/**
+ * @mixin ArticlePublication
+ */
 class ArticlePublicationResource extends JsonResource
 {
     /**
@@ -17,10 +21,10 @@ public function toArray(Request $request): array
         return [
             'id' => $this->id,
             'article_id' => $this->article_id,
-            'status' => $this->status,
-            'published_at' => $this->published_at?->toISOString(),
+            'platform' => $this->platform,
+            'published_at' => $this->published_at->toISOString(),
             'created_at' => $this->created_at->toISOString(),
             'updated_at' => $this->updated_at->toISOString(),
         ];
     }
-}
+}

app/Http/Resources/ArticleResource.php

@@ -2,14 +2,18 @@
 
 namespace App\Http\Resources;
 
+use App\Models\Article;
 use Illuminate\Http\Request;
 use Illuminate\Http\Resources\Json\JsonResource;
 
 /**
- * @property int $id
+ * @mixin Article
  */
 class ArticleResource extends JsonResource
 {
+    /**
+     * @return array<string, mixed>
+     */
     public function toArray(Request $request): array
     {
         return [
@@ -18,13 +22,6 @@ public function toArray(Request $request): array
             'url' => $this->url,
             'title' => $this->title,
             'description' => $this->description,
-            'is_valid' => $this->is_valid,
-            'is_duplicate' => $this->is_duplicate,
-            'approval_status' => $this->approval_status,
-            'publish_status' => $this->publish_status,
-            'approved_at' => $this->approved_at?->toISOString(),
-            'approved_by' => $this->approved_by,
-            'fetched_at' => $this->fetched_at?->toISOString(),
             'validated_at' => $this->validated_at?->toISOString(),
             'is_published' => $this->relationLoaded('articlePublication') && $this->articlePublication !== null,
             'created_at' => $this->created_at->toISOString(),

app/Http/Resources/FeedResource.php

@@ -2,9 +2,13 @@
 
 namespace App\Http\Resources;
 
+use App\Models\Feed;
 use Illuminate\Http\Request;
 use Illuminate\Http\Resources\Json\JsonResource;
 
+/**
+ * @mixin Feed
+ */
 class FeedResource extends JsonResource
 {
     /**
@@ -26,9 +30,9 @@ public function toArray(Request $request): array
             'created_at' => $this->created_at->toISOString(),
             'updated_at' => $this->updated_at->toISOString(),
             'articles_count' => $this->when(
-                $request->routeIs('api.feeds.*') && isset($this->articles_count), 
+                $request->routeIs('api.feeds.*') && isset($this->articles_count),
                 $this->articles_count
             ),
         ];
     }
-}
+}

app/Http/Resources/PlatformAccountResource.php

@@ -2,9 +2,16 @@
 
 namespace App\Http\Resources;
 
+use App\Models\PlatformAccount;
 use Illuminate\Http\Request;
 use Illuminate\Http\Resources\Json\JsonResource;
 
+/**
+ * @mixin PlatformAccount
+ */
+/**
+ * @mixin PlatformAccount
+ */
 class PlatformAccountResource extends JsonResource
 {
     /**
@@ -28,4 +35,4 @@ public function toArray(Request $request): array
             'channels' => PlatformChannelResource::collection($this->whenLoaded('channels')),
         ];
     }
-}
+}

app/Http/Resources/PlatformChannelResource.php

@@ -2,9 +2,13 @@
 
 namespace App\Http\Resources;
 
+use App\Models\PlatformChannel;
 use Illuminate\Http\Request;
 use Illuminate\Http\Resources\Json\JsonResource;
 
+/**
+ * @mixin PlatformChannel
+ */
 class PlatformChannelResource extends JsonResource
 {
     /**
@@ -30,4 +34,4 @@ public function toArray(Request $request): array
             'routes' => RouteResource::collection($this->whenLoaded('routes')),
         ];
     }
-}
+}

app/Http/Resources/PlatformInstanceResource.php

@@ -2,9 +2,13 @@
 
 namespace App\Http\Resources;
 
+use App\Models\PlatformInstance;
 use Illuminate\Http\Request;
 use Illuminate\Http\Resources\Json\JsonResource;
 
+/**
+ * @mixin PlatformInstance
+ */
 class PlatformInstanceResource extends JsonResource
 {
     /**
@@ -24,4 +28,4 @@ public function toArray(Request $request): array
             'updated_at' => $this->updated_at->toISOString(),
         ];
     }
-}
+}

app/Http/Resources/RouteArticleResource.php

@@ -0,0 +1,39 @@
+<?php
+
+namespace App\Http\Resources;
+
+use App\Models\RouteArticle;
+use Illuminate\Http\Request;
+use Illuminate\Http\Resources\Json\JsonResource;
+
+/**
+ * @mixin RouteArticle
+ */
+class RouteArticleResource extends JsonResource
+{
+    /**
+     * @return array<string, mixed>
+     */
+    public function toArray(Request $request): array
+    {
+        return [
+            'id' => $this->id,
+            'feed_id' => $this->feed_id,
+            'platform_channel_id' => $this->platform_channel_id,
+            'article_id' => $this->article_id,
+            'approval_status' => $this->approval_status->value,
+            'publish_status' => $this->publish_status->value,
+            'validated_at' => $this->validated_at?->toISOString(),
+            'created_at' => $this->created_at->toISOString(),
+            'updated_at' => $this->updated_at->toISOString(),
+            'article' => [
+                'id' => $this->article->id,
+                'title' => $this->article->title,
+                'url' => $this->article->url,
+                'description' => $this->article->description,
+                'feed_name' => $this->article->feed->name,
+            ],
+            'route_name' => $this->feed->name.' → '.$this->platformChannel->name,
+        ];
+    }
+}

app/Http/Resources/RouteResource.php

@@ -2,9 +2,13 @@
 
 namespace App\Http\Resources;
 
+use App\Models\Route;
 use Illuminate\Http\Request;
 use Illuminate\Http\Resources\Json\JsonResource;
 
+/**
+ * @mixin Route
+ */
 class RouteResource extends JsonResource
 {
     /**
@@ -15,7 +19,6 @@ class RouteResource extends JsonResource
     public function toArray(Request $request): array
     {
         return [
-            'id' => $this->id,
             'feed_id' => $this->feed_id,
             'platform_channel_id' => $this->platform_channel_id,
             'is_active' => $this->is_active,
@@ -35,4 +38,4 @@ public function toArray(Request $request): array
             }),
         ];
     }
-}
+}

app/Jobs/ArticleDiscoveryForFeedJob.php

@@ -25,7 +25,7 @@ public function handle(LogSaver $logSaver, ArticleFetcher $articleFetcher): void
         $logSaver->info('Starting feed article fetch', null, [
             'feed_id' => $this->feed->id,
             'feed_name' => $this->feed->name,
-            'feed_url' => $this->feed->url
+            'feed_url' => $this->feed->url,
         ]);
 
         $articles = $articleFetcher->getArticlesFromFeed($this->feed);
@@ -33,7 +33,7 @@ public function handle(LogSaver $logSaver, ArticleFetcher $articleFetcher): void
         $logSaver->info('Feed article fetch completed', null, [
             'feed_id' => $this->feed->id,
             'feed_name' => $this->feed->name,
-            'articles_count' => $articles->count()
+            'articles_count' => $articles->count(),
         ]);
 
         $this->feed->update(['last_fetched_at' => now()]);
@@ -42,7 +42,7 @@ public function handle(LogSaver $logSaver, ArticleFetcher $articleFetcher): void
     public static function dispatchForAllActiveFeeds(): void
     {
         $logSaver = app(LogSaver::class);
-        
+
         Feed::where('is_active', true)
             ->get()
             ->each(function (Feed $feed, $index) use ($logSaver) {
@@ -56,7 +56,7 @@ public static function dispatchForAllActiveFeeds(): void
                 $logSaver->info('Dispatched feed discovery job', null, [
                     'feed_id' => $feed->id,
                     'feed_name' => $feed->name,
-                    'delay_minutes' => $delayMinutes
+                    'delay_minutes' => $delayMinutes,
                 ]);
             });
     }

app/Jobs/ArticleDiscoveryJob.php

@@ -18,7 +18,7 @@ public function __construct()
 
     public function handle(LogSaver $logSaver): void
     {
-        if (!Setting::isArticleProcessingEnabled()) {
+        if (! Setting::isArticleProcessingEnabled()) {
             $logSaver->info('Article processing is disabled. Article discovery skipped.');
 
             return;

app/Jobs/CheckFeedStalenessJob.php

@@ -0,0 +1,51 @@
+<?php
+
+namespace App\Jobs;
+
+use App\Enums\NotificationSeverityEnum;
+use App\Enums\NotificationTypeEnum;
+use App\Models\Feed;
+use App\Models\Notification;
+use App\Models\Setting;
+use App\Services\Notification\NotificationService;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Queue\Queueable;
+
+class CheckFeedStalenessJob implements ShouldQueue
+{
+    use Queueable;
+
+    public function handle(NotificationService $notificationService): void
+    {
+        $thresholdHours = Setting::getFeedStalenessThreshold();
+
+        if ($thresholdHours === 0) {
+            return;
+        }
+
+        $staleFeeds = Feed::stale($thresholdHours)->get();
+
+        foreach ($staleFeeds as $feed) {
+            $alreadyNotified = Notification::query()
+                ->where('type', NotificationTypeEnum::FEED_STALE)
+                ->where('notifiable_type', $feed->getMorphClass())
+                ->where('notifiable_id', $feed->getKey())
+                ->unread()
+                ->exists();
+
+            if ($alreadyNotified) {
+                continue;
+            }
+
+            $notificationService->send(
+                type: NotificationTypeEnum::FEED_STALE,
+                severity: NotificationSeverityEnum::WARNING,
+                title: "Feed \"{$feed->name}\" is stale",
+                message: $feed->last_fetched_at
+                    ? "Last fetched {$feed->last_fetched_at->diffForHumans()}. Threshold is {$thresholdHours} hours."
+                    : "This feed has never been fetched. Threshold is {$thresholdHours} hours.",
+                notifiable: $feed,
+            );
+        }
+    }
+}

app/Jobs/CleanupArticlesJob.php

@@ -0,0 +1,25 @@
+<?php
+
+namespace App\Jobs;
+
+use App\Enums\ApprovalStatusEnum;
+use App\Models\Article;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Queue\Queueable;
+
+class CleanupArticlesJob implements ShouldQueue
+{
+    use Queueable;
+
+    private const RETENTION_DAYS = 30;
+
+    public function handle(): void
+    {
+        Article::where('created_at', '<', now()->subDays(self::RETENTION_DAYS))
+            ->whereDoesntHave('routeArticles', fn ($q) => $q->whereIn('approval_status', [
+                ApprovalStatusEnum::PENDING,
+                ApprovalStatusEnum::APPROVED,
+            ]))
+            ->delete();
+    }
+}

app/Jobs/PublishNextArticleJob.php

@@ -2,17 +2,24 @@
 
 namespace App\Jobs;
 
+use App\Enums\ApprovalStatusEnum;
+use App\Enums\LogLevelEnum;
+use App\Enums\NotificationSeverityEnum;
+use App\Enums\NotificationTypeEnum;
+use App\Enums\PublishStatusEnum;
+use App\Events\ActionPerformed;
 use App\Exceptions\PublishException;
-use App\Models\Article;
 use App\Models\ArticlePublication;
+use App\Models\RouteArticle;
 use App\Models\Setting;
 use App\Services\Article\ArticleFetcher;
+use App\Services\Notification\NotificationService;
 use App\Services\Publishing\ArticlePublishingService;
 use Illuminate\Contracts\Queue\ShouldBeUnique;
 use Illuminate\Contracts\Queue\ShouldQueue;
 use Illuminate\Foundation\Queue\Queueable;
 
-class PublishNextArticleJob implements ShouldQueue, ShouldBeUnique
+class PublishNextArticleJob implements ShouldBeUnique, ShouldQueue
 {
     use Queueable;
 
@@ -28,9 +35,10 @@ public function __construct()
 
     /**
      * Execute the job.
+     *
      * @throws PublishException
      */
-    public function handle(ArticleFetcher $articleFetcher, ArticlePublishingService $publishingService): void
+    public function handle(ArticleFetcher $articleFetcher, ArticlePublishingService $publishingService, NotificationService $notificationService): void
     {
         $interval = Setting::getArticlePublishingInterval();
 
@@ -42,40 +50,74 @@ public function handle(ArticleFetcher $articleFetcher, ArticlePublishingService
             }
         }
 
-        // Get the oldest approved article that hasn't been published yet
-        $article = Article::where('approval_status', 'approved')
-            ->whereDoesntHave('articlePublication')
-            ->oldest('created_at')
+        // Get the oldest approved route_article that hasn't been published to its channel yet
+        $routeArticle = RouteArticle::where('approval_status', ApprovalStatusEnum::APPROVED)
+            ->whereDoesntHave('article.articlePublications', function ($query) {
+                $query->whereColumn('article_publications.platform_channel_id', 'route_articles.platform_channel_id');
+            })
+            ->oldest('route_articles.created_at')
+            ->with(['article', 'platformChannel.platformInstance', 'platformChannel.activePlatformAccounts'])
             ->first();
 
-        if (! $article) {
+        if (! $routeArticle) {
             return;
         }
 
-        logger()->info('Publishing next article from scheduled job', [
+        $article = $routeArticle->article;
+
+        ActionPerformed::dispatch('Publishing next article from scheduled job', LogLevelEnum::INFO, [
             'article_id' => $article->id,
             'title' => $article->title,
             'url' => $article->url,
-            'created_at' => $article->created_at
+            'route' => $routeArticle->feed_id.'-'.$routeArticle->platform_channel_id,
         ]);
 
-        // Fetch article data
-        $extractedData = $articleFetcher->fetchArticleData($article);
+        $routeArticle->update(['publish_status' => PublishStatusEnum::PUBLISHING]);
 
         try {
-            $publishingService->publishToRoutedChannels($article, $extractedData);
-            
-            logger()->info('Successfully published article', [
-                'article_id' => $article->id,
-                'title' => $article->title
-            ]);
+            $extractedData = $articleFetcher->fetchArticleData($article);
+            $publication = $publishingService->publishRouteArticle($routeArticle, $extractedData);
+
+            if ($publication) {
+                $routeArticle->update(['publish_status' => PublishStatusEnum::PUBLISHED]);
+
+                ActionPerformed::dispatch('Successfully published article', LogLevelEnum::INFO, [
+                    'article_id' => $article->id,
+                    'title' => $article->title,
+                ]);
+            } else {
+                $routeArticle->update(['publish_status' => PublishStatusEnum::ERROR]);
+
+                ActionPerformed::dispatch('No publication created for article', LogLevelEnum::WARNING, [
+                    'article_id' => $article->id,
+                    'title' => $article->title,
+                ]);
+
+                $notificationService->send(
+                    NotificationTypeEnum::PUBLISH_FAILED,
+                    NotificationSeverityEnum::WARNING,
+                    "Publish failed: {$article->title}",
+                    'No publication was created for this article. Check channel routing configuration.',
+                    $article,
+                );
+            }
         } catch (PublishException $e) {
-            logger()->error('Failed to publish article', [
+            $routeArticle->update(['publish_status' => PublishStatusEnum::ERROR]);
+
+            ActionPerformed::dispatch('Failed to publish article', LogLevelEnum::ERROR, [
                 'article_id' => $article->id,
-                'error' => $e->getMessage()
+                'error' => $e->getMessage(),
             ]);
-            
+
+            $notificationService->send(
+                NotificationTypeEnum::PUBLISH_FAILED,
+                NotificationSeverityEnum::ERROR,
+                "Publish failed: {$article->title}",
+                $e->getMessage(),
+                $article,
+            );
+
             throw $e;
         }
     }
-}
+}

app/Jobs/SyncChannelPostsJob.php

@@ -15,7 +15,7 @@
 use Illuminate\Foundation\Queue\Queueable;
 use Illuminate\Support\Facades\Cache;
 
-class SyncChannelPostsJob implements ShouldQueue, ShouldBeUnique
+class SyncChannelPostsJob implements ShouldBeUnique, ShouldQueue
 {
     use Queueable;
 
@@ -28,7 +28,7 @@ public function __construct(
     public static function dispatchForAllActiveChannels(): void
     {
         $logSaver = app(LogSaver::class);
-        
+
         PlatformChannel::with(['platformInstance', 'platformAccounts'])
             ->whereHas('platformInstance', fn ($query) => $query->where('platform', PlatformEnum::LEMMY))
             ->whereHas('platformAccounts', fn ($query) => $query->where('platform_accounts.is_active', true))
@@ -78,7 +78,7 @@ private function syncLemmyChannelPosts(LogSaver $logSaver): void
 
         } catch (Exception $e) {
             $logSaver->error('Failed to sync channel posts', $this->channel, [
-                'error' => $e->getMessage()
+                'error' => $e->getMessage(),
             ]);
 
             throw $e;
@@ -97,13 +97,13 @@ private function getAuthToken(LemmyApiService $api, PlatformAccount $account): s
             return $cachedToken;
         }
 
-        if (!$account->username || !$account->password) {
+        if (! $account->username || ! $account->password) {
             throw new PlatformAuthException(PlatformEnum::LEMMY, 'Missing credentials for account');
         }
 
         $token = $api->login($account->username, $account->password);
 
-        if (!$token) {
+        if (! $token) {
             throw new PlatformAuthException(PlatformEnum::LEMMY, 'Login failed for account');
         }
 

app/Listeners/LogActionListener.php

@@ -0,0 +1,21 @@
+<?php
+
+namespace App\Listeners;
+
+use App\Events\ActionPerformed;
+use App\Services\Log\LogSaver;
+use Exception;
+
+class LogActionListener
+{
+    public function __construct(private LogSaver $logSaver) {}
+
+    public function handle(ActionPerformed $event): void
+    {
+        try {
+            $this->logSaver->log($event->level, $event->message, context: $event->context);
+        } catch (Exception $e) {
+            error_log('Failed to log action to database: '.$e->getMessage());
+        }
+    }
+}

app/Listeners/LogExceptionToDatabase.php

@@ -5,14 +5,14 @@
 use App\Events\ExceptionLogged;
 use App\Events\ExceptionOccurred;
 use App\Models\Log;
+
 class LogExceptionToDatabase
 {
-
     public function handle(ExceptionOccurred $event): void
     {
         // Truncate the message to prevent database errors
-        $message = strlen($event->message) > 255 
-            ? substr($event->message, 0, 252) . '...' 
+        $message = strlen($event->message) > 255
+            ? substr($event->message, 0, 252).'...'
             : $event->message;
 
         try {
@@ -24,15 +24,15 @@ public function handle(ExceptionOccurred $event): void
                     'file' => $event->exception->getFile(),
                     'line' => $event->exception->getLine(),
                     'trace' => $event->exception->getTraceAsString(),
-                    ...$event->context
-                ]
+                    ...$event->context,
+                ],
             ]);
 
             ExceptionLogged::dispatch($log);
         } catch (\Exception $e) {
             // Prevent infinite recursion by not logging this exception
             // Optionally log to file or other non-database destination
-            error_log("Failed to log exception to database: " . $e->getMessage());
+            error_log('Failed to log exception to database: '.$e->getMessage());
         }
     }
 }

app/Listeners/PublishApprovedArticleListener.php

@@ -2,8 +2,14 @@
 
 namespace App\Listeners;
 
-use App\Events\ArticleApproved;
+use App\Enums\LogLevelEnum;
+use App\Enums\NotificationSeverityEnum;
+use App\Enums\NotificationTypeEnum;
+use App\Enums\PublishStatusEnum;
+use App\Events\ActionPerformed;
+use App\Events\RouteArticleApproved;
 use App\Services\Article\ArticleFetcher;
+use App\Services\Notification\NotificationService;
 use App\Services\Publishing\ArticlePublishingService;
 use Exception;
 use Illuminate\Contracts\Queue\ShouldQueue;
@@ -14,51 +20,67 @@ class PublishApprovedArticleListener implements ShouldQueue
 
     public function __construct(
         private ArticleFetcher $articleFetcher,
-        private ArticlePublishingService $publishingService
+        private ArticlePublishingService $publishingService,
+        private NotificationService $notificationService,
     ) {}
 
-    public function handle(ArticleApproved $event): void
+    public function handle(RouteArticleApproved $event): void
     {
-        $article = $event->article->fresh();
+        $routeArticle = $event->routeArticle;
+        $article = $routeArticle->article;
 
-        // Skip if already published
-        if ($article->articlePublication()->exists()) {
+        // Skip if already published to this channel
+        if ($article->articlePublications()
+            ->where('platform_channel_id', $routeArticle->platform_channel_id)
+            ->exists()
+        ) {
             return;
         }
 
-        // Skip if not approved (safety check)
-        if (! $article->isApproved()) {
-            return;
-        }
-
-        $article->update(['publish_status' => 'publishing']);
+        $routeArticle->update(['publish_status' => PublishStatusEnum::PUBLISHING]);
 
         try {
             $extractedData = $this->articleFetcher->fetchArticleData($article);
-            $publications = $this->publishingService->publishToRoutedChannels($article, $extractedData);
+            $publication = $this->publishingService->publishRouteArticle($routeArticle, $extractedData);
 
-            if ($publications->isNotEmpty()) {
-                $article->update(['publish_status' => 'published']);
+            if ($publication) {
+                $routeArticle->update(['publish_status' => PublishStatusEnum::PUBLISHED]);
 
-                logger()->info('Published approved article', [
+                ActionPerformed::dispatch('Published approved article', LogLevelEnum::INFO, [
                     'article_id' => $article->id,
                     'title' => $article->title,
                 ]);
             } else {
-                $article->update(['publish_status' => 'error']);
+                $routeArticle->update(['publish_status' => PublishStatusEnum::ERROR]);
 
-                logger()->warning('No publications created for approved article', [
+                ActionPerformed::dispatch('No publication created for approved article', LogLevelEnum::WARNING, [
                     'article_id' => $article->id,
                     'title' => $article->title,
                 ]);
+
+                $this->notificationService->send(
+                    NotificationTypeEnum::PUBLISH_FAILED,
+                    NotificationSeverityEnum::WARNING,
+                    "Publish failed: {$article->title}",
+                    'No publication was created for this article. Check channel routing configuration.',
+                    $article,
+                );
             }
         } catch (Exception $e) {
-            $article->update(['publish_status' => 'error']);
+            $routeArticle->update(['publish_status' => PublishStatusEnum::ERROR]);
 
-            logger()->error('Failed to publish approved article', [
+            ActionPerformed::dispatch('Failed to publish approved article', LogLevelEnum::ERROR, [
                 'article_id' => $article->id,
                 'error' => $e->getMessage(),
             ]);
+
+            $this->notificationService->send(
+                NotificationTypeEnum::PUBLISH_FAILED,
+                NotificationSeverityEnum::ERROR,
+                "Publish failed: {$article->title}",
+                $e->getMessage(),
+                $article,
+            );
         }
     }
 }

app/Listeners/ValidateArticleListener.php

@@ -2,8 +2,9 @@
 
 namespace App\Listeners;
 
+use App\Enums\LogLevelEnum;
+use App\Events\ActionPerformed;
 use App\Events\NewArticleFetched;
-use App\Models\Setting;
 use App\Services\Article\ValidationService;
 use Exception;
 use Illuminate\Contracts\Queue\ShouldQueue;
@@ -24,37 +25,18 @@ public function handle(NewArticleFetched $event): void
             return;
         }
 
-        // Only validate articles that are still pending
-        if (! $article->isPending()) {
-            return;
-        }
-
         // Skip if already has publication (prevents duplicate processing)
         if ($article->articlePublication()->exists()) {
             return;
         }
 
         try {
-            $article = $this->validationService->validate($article);
+            $this->validationService->validate($article);
         } catch (Exception $e) {
-            logger()->error('Article validation failed', [
+            ActionPerformed::dispatch('Article validation failed', LogLevelEnum::ERROR, [
                 'article_id' => $article->id,
                 'error' => $e->getMessage(),
             ]);
-            return;
-        }
-
-        if ($article->isValid()) {
-            // Double-check publication doesn't exist (race condition protection)
-            if ($article->articlePublication()->exists()) {
-                return;
-            }
-
-            // If approvals are enabled, article waits for manual approval.
-            // If approvals are disabled, auto-approve and publish.
-            if (! Setting::isPublishingApprovalsEnabled()) {
-                $article->approve();
-            }
         }
     }
 }

app/Livewire/Articles.php

@@ -2,9 +2,10 @@
 
 namespace App\Livewire;
 
-use App\Models\Article;
-use App\Models\Setting;
+use App\Enums\ApprovalStatusEnum;
 use App\Jobs\ArticleDiscoveryJob;
+use App\Models\RouteArticle;
+use Illuminate\Contracts\View\View;
 use Livewire\Component;
 use Livewire\WithPagination;
 
@@ -12,22 +13,44 @@ class Articles extends Component
 {
     use WithPagination;
 
+    public string $tab = 'pending';
+
+    public string $search = '';
+
     public bool $isRefreshing = false;
 
-    public function approve(int $articleId): void
+    public function setTab(string $tab): void
     {
-        $article = Article::findOrFail($articleId);
-        $article->approve();
-
-        $this->dispatch('article-updated');
+        $this->tab = $tab;
+        $this->search = '';
+        $this->resetPage();
     }
 
-    public function reject(int $articleId): void
+    public function updatedSearch(): void
     {
-        $article = Article::findOrFail($articleId);
-        $article->reject();
+        $this->resetPage();
+    }
 
-        $this->dispatch('article-updated');
+    public function approve(int $routeArticleId): void
+    {
+        RouteArticle::findOrFail($routeArticleId)->approve();
+    }
+
+    public function reject(int $routeArticleId): void
+    {
+        RouteArticle::findOrFail($routeArticleId)->reject();
+    }
+
+    public function restore(int $routeArticleId): void
+    {
+        $routeArticle = RouteArticle::findOrFail($routeArticleId);
+        $routeArticle->update(['approval_status' => ApprovalStatusEnum::PENDING]);
+    }
+
+    public function clear(): void
+    {
+        RouteArticle::where('approval_status', ApprovalStatusEnum::PENDING)
+            ->update(['approval_status' => ApprovalStatusEnum::REJECTED]);
     }
 
     public function refresh(): void
@@ -39,17 +62,28 @@ public function refresh(): void
         $this->dispatch('refresh-started');
     }
 
-    public function render()
+    public function render(): View
     {
-        $articles = Article::with(['feed', 'articlePublication'])
-            ->orderBy('created_at', 'desc')
-            ->paginate(15);
+        $query = RouteArticle::with(['article.feed', 'feed', 'platformChannel'])
+            ->orderBy('created_at', 'desc');
 
-        $approvalsEnabled = Setting::isPublishingApprovalsEnabled();
+        if ($this->tab === 'pending') {
+            $query->where('approval_status', ApprovalStatusEnum::PENDING);
+        } elseif ($this->search !== '') {
+            $search = $this->search;
+            $query->whereHas('article', function ($q) use ($search) {
+                $q->where('title', 'like', "%{$search}%")
+                    ->orWhere('description', 'like', "%{$search}%");
+            });
+        }
+
+        $routeArticles = $query->paginate(15);
+
+        $pendingCount = RouteArticle::where('approval_status', ApprovalStatusEnum::PENDING)->count();
 
         return view('livewire.articles', [
-            'articles' => $articles,
-            'approvalsEnabled' => $approvalsEnabled,
+            'routeArticles' => $routeArticles,
+            'pendingCount' => $pendingCount,
         ])->layout('layouts.app');
     }
 }

app/Livewire/Channels.php

@@ -4,6 +4,7 @@
 
 use App\Models\PlatformAccount;
 use App\Models\PlatformChannel;
+use Illuminate\Contracts\View\View;
 use Livewire\Component;
 
 class Channels extends Component
@@ -13,7 +14,7 @@ class Channels extends Component
     public function toggle(int $channelId): void
     {
         $channel = PlatformChannel::findOrFail($channelId);
-        $channel->is_active = !$channel->is_active;
+        $channel->is_active = ! $channel->is_active;
         $channel->save();
     }
 
@@ -29,13 +30,13 @@ public function closeAccountModal(): void
 
     public function attachAccount(int $accountId): void
     {
-        if (!$this->managingChannelId) {
+        if (! $this->managingChannelId) {
             return;
         }
 
         $channel = PlatformChannel::findOrFail($this->managingChannelId);
 
-        if (!$channel->platformAccounts()->where('platform_account_id', $accountId)->exists()) {
+        if (! $channel->platformAccounts()->where('platform_account_id', $accountId)->exists()) {
             $channel->platformAccounts()->attach($accountId, [
                 'is_active' => true,
                 'priority' => 1,
@@ -51,7 +52,7 @@ public function detachAccount(int $channelId, int $accountId): void
         $channel->platformAccounts()->detach($accountId);
     }
 
-    public function render()
+    public function render(): View
     {
         $channels = PlatformChannel::with(['platformInstance', 'platformAccounts'])->orderBy('name')->get();
         $allAccounts = PlatformAccount::where('is_active', true)->get();
@@ -61,7 +62,7 @@ public function render()
             : null;
 
         $availableAccounts = $managingChannel
-            ? $allAccounts->filter(fn($account) => !$managingChannel->platformAccounts->contains('id', $account->id))
+            ? $allAccounts->filter(fn ($account) => ! $managingChannel->platformAccounts->contains('id', $account->id))
             : collect();
 
         return view('livewire.channels', [

app/Livewire/Dashboard.php

@@ -3,6 +3,7 @@
 namespace App\Livewire;
 
 use App\Services\DashboardStatsService;
+use Illuminate\Contracts\View\View;
 use Livewire\Component;
 
 class Dashboard extends Component
@@ -19,7 +20,7 @@ public function setPeriod(string $period): void
         $this->period = $period;
     }
 
-    public function render()
+    public function render(): View
     {
         $service = app(DashboardStatsService::class);
 

app/Livewire/Feeds.php

@@ -3,6 +3,7 @@
 namespace App\Livewire;
 
 use App\Models\Feed;
+use Illuminate\Contracts\View\View;
 use Livewire\Component;
 
 class Feeds extends Component
@@ -10,11 +11,11 @@ class Feeds extends Component
     public function toggle(int $feedId): void
     {
         $feed = Feed::findOrFail($feedId);
-        $feed->is_active = !$feed->is_active;
+        $feed->is_active = ! $feed->is_active;
         $feed->save();
     }
 
-    public function render()
+    public function render(): View
     {
         $feeds = Feed::orderBy('name')->get();
 

app/Livewire/NotificationBell.php

@@ -0,0 +1,42 @@
+<?php
+
+namespace App\Livewire;
+
+use App\Models\Notification;
+use Illuminate\Contracts\View\View;
+use Illuminate\Database\Eloquent\Collection;
+use Livewire\Attributes\Computed;
+use Livewire\Component;
+
+class NotificationBell extends Component
+{
+    public function markAsRead(int $id): void
+    {
+        Notification::findOrFail($id)->markAsRead();
+    }
+
+    public function markAllAsRead(): void
+    {
+        Notification::markAllAsRead();
+    }
+
+    #[Computed]
+    public function unreadCount(): int
+    {
+        return Notification::unread()->count();
+    }
+
+    /**
+     * @return Collection<int, Notification>
+     */
+    #[Computed]
+    public function notifications(): Collection
+    {
+        return Notification::recent()->get();
+    }
+
+    public function render(): View
+    {
+        return view('livewire.notification-bell');
+    }
+}

app/Livewire/Onboarding.php

@@ -18,7 +18,9 @@
 use App\Models\Setting;
 use App\Services\OnboardingService;
 use Exception;
+use Illuminate\Contracts\View\View;
 use InvalidArgumentException;
+use Livewire\Attributes\Locked;
 use Livewire\Component;
 use RuntimeException;
 
@@ -29,36 +31,54 @@ class Onboarding extends Component
 
     // Platform form
     public string $instanceUrl = '';
+
     public string $username = '';
+
     public string $password = '';
+
+    /** @var array<string, mixed>|null */
     public ?array $existingAccount = null;
 
     // Feed form
     public string $feedName = '';
+
     public string $feedProvider = 'vrt';
+
     public ?int $feedLanguageId = null;
+
     public string $feedDescription = '';
 
     // Channel form
     public string $channelName = '';
+
     public ?int $platformInstanceId = null;
+
     public ?int $channelLanguageId = null;
+
     public string $channelDescription = '';
 
     // Route form
     public ?int $routeFeedId = null;
+
     public ?int $routeChannelId = null;
+
     public int $routePriority = 50;
 
     // State
+    /** @var array<string, string> */
     public array $formErrors = [];
+
     public bool $isLoading = false;
-    #[\Livewire\Attributes\Locked]
+
+    #[Locked]
     public ?int $previousChannelLanguageId = null;
 
     protected CreatePlatformAccountAction $createPlatformAccountAction;
+
     protected CreateFeedAction $createFeedAction;
+
     protected CreateChannelAction $createChannelAction;
+
     protected CreateRouteAction $createRouteAction;
 
     public function boot(
@@ -188,7 +208,7 @@ public function createPlatformAccount(): void
             }
         } catch (Exception $e) {
             logger()->error('Lemmy platform account creation failed', [
-                'instance_url' => 'https://' . $this->instanceUrl,
+                'instance_url' => 'https://'.$this->instanceUrl,
                 'username' => $this->username,
                 'error' => $e->getMessage(),
                 'class' => get_class($e),
@@ -319,17 +339,20 @@ public function completeOnboarding(): void
     /**
      * Get language codes that have at least one active provider.
      */
+    /**
+     * @return list<string>
+     */
     public function getAvailableLanguageCodes(): array
     {
         $providers = config('feed.providers', []);
         $languageCodes = [];
 
         foreach ($providers as $provider) {
-            if (!($provider['is_active'] ?? false)) {
+            if (! ($provider['is_active'] ?? false)) {
                 continue;
             }
             foreach (array_keys($provider['languages'] ?? []) as $code) {
-                $languageCodes[$code] = true;
+                $languageCodes[(string) $code] = true;
             }
         }
 
@@ -339,14 +362,17 @@ public function getAvailableLanguageCodes(): array
     /**
      * Get providers available for the current channel language.
      */
+    /**
+     * @return array<int, array<string, string>>
+     */
     public function getProvidersForLanguage(): array
     {
-        if (!$this->channelLanguageId) {
+        if (! $this->channelLanguageId) {
             return [];
         }
 
         $language = Language::find($this->channelLanguageId);
-        if (!$language) {
+        if (! $language) {
             return [];
         }
 
@@ -355,7 +381,7 @@ public function getProvidersForLanguage(): array
         $available = [];
 
         foreach ($providers as $key => $provider) {
-            if (!($provider['is_active'] ?? false)) {
+            if (! ($provider['is_active'] ?? false)) {
                 continue;
             }
             if (isset($provider['languages'][$langCode])) {
@@ -375,13 +401,14 @@ public function getProvidersForLanguage(): array
      */
     public function getChannelLanguage(): ?Language
     {
-        if (!$this->channelLanguageId) {
+        if (! $this->channelLanguageId) {
             return null;
         }
+
         return Language::find($this->channelLanguageId);
     }
 
-    public function render()
+    public function render(): View
     {
         // For channel step: only show languages that have providers
         $availableCodes = $this->getAvailableLanguageCodes();

app/Livewire/Routes.php

@@ -6,24 +6,32 @@
 use App\Models\Keyword;
 use App\Models\PlatformChannel;
 use App\Models\Route;
+use Illuminate\Contracts\View\View;
 use Livewire\Component;
 
 class Routes extends Component
 {
     public bool $showCreateModal = false;
+
     public ?int $editingFeedId = null;
+
     public ?int $editingChannelId = null;
 
     // Create form
     public ?int $newFeedId = null;
+
     public ?int $newChannelId = null;
+
     public int $newPriority = 50;
 
     // Edit form
     public int $editPriority = 50;
 
+    public string $editAutoApprove = '';
+
     // Keyword management
     public string $newKeyword = '';
+
     public bool $showKeywordInput = false;
 
     public function openCreateModal(): void
@@ -53,6 +61,7 @@ public function createRoute(): void
 
         if ($exists) {
             $this->addError('newFeedId', 'This route already exists.');
+
             return;
         }
 
@@ -75,6 +84,7 @@ public function openEditModal(int $feedId, int $channelId): void
         $this->editingFeedId = $feedId;
         $this->editingChannelId = $channelId;
         $this->editPriority = $route->priority;
+        $this->editAutoApprove = $route->auto_approve === null ? '' : ($route->auto_approve ? '1' : '0');
         $this->newKeyword = '';
         $this->showKeywordInput = false;
     }
@@ -87,7 +97,7 @@ public function closeEditModal(): void
 
     public function updateRoute(): void
     {
-        if (!$this->editingFeedId || !$this->editingChannelId) {
+        if (! $this->editingFeedId || ! $this->editingChannelId) {
             return;
         }
 
@@ -95,9 +105,18 @@ public function updateRoute(): void
             'editPriority' => 'required|integer|min:0',
         ]);
 
+        $autoApprove = match ($this->editAutoApprove) {
+            '1' => true,
+            '0' => false,
+            default => null,
+        };
+
         Route::where('feed_id', $this->editingFeedId)
             ->where('platform_channel_id', $this->editingChannelId)
-            ->update(['priority' => $this->editPriority]);
+            ->update([
+                'priority' => $this->editPriority,
+                'auto_approve' => $autoApprove,
+            ]);
 
         $this->closeEditModal();
     }
@@ -108,7 +127,7 @@ public function toggle(int $feedId, int $channelId): void
             ->where('platform_channel_id', $channelId)
             ->firstOrFail();
 
-        $route->is_active = !$route->is_active;
+        $route->is_active = ! $route->is_active;
         $route->save();
     }
 
@@ -126,7 +145,7 @@ public function delete(int $feedId, int $channelId): void
 
     public function addKeyword(): void
     {
-        if (!$this->editingFeedId || !$this->editingChannelId || empty(trim($this->newKeyword))) {
+        if (! $this->editingFeedId || ! $this->editingChannelId || empty(trim($this->newKeyword))) {
             return;
         }
 
@@ -144,7 +163,7 @@ public function addKeyword(): void
     public function toggleKeyword(int $keywordId): void
     {
         $keyword = Keyword::findOrFail($keywordId);
-        $keyword->is_active = !$keyword->is_active;
+        $keyword->is_active = ! $keyword->is_active;
         $keyword->save();
     }
 
@@ -153,22 +172,23 @@ public function deleteKeyword(int $keywordId): void
         Keyword::destroy($keywordId);
     }
 
-    public function render()
+    public function render(): View
     {
-        $routes = Route::with(['feed', 'platformChannel'])
+        $routes = Route::with(['feed', 'platformChannel.platformInstance'])
             ->orderBy('priority', 'desc')
             ->get();
 
         // Batch load keywords for all routes to avoid N+1 queries
-        $routeKeys = $routes->map(fn($r) => $r->feed_id . '-' . $r->platform_channel_id);
+        $routeKeys = $routes->map(fn ($r) => $r->feed_id.'-'.$r->platform_channel_id);
         $allKeywords = Keyword::whereIn('feed_id', $routes->pluck('feed_id'))
             ->whereIn('platform_channel_id', $routes->pluck('platform_channel_id'))
             ->get()
-            ->groupBy(fn($k) => $k->feed_id . '-' . $k->platform_channel_id);
+            ->groupBy(fn ($k) => $k->feed_id.'-'.$k->platform_channel_id);
 
         $routes = $routes->map(function ($route) use ($allKeywords) {
-            $key = $route->feed_id . '-' . $route->platform_channel_id;
-            $route->keywords = $allKeywords->get($key, collect());
+            $key = $route->feed_id.'-'.$route->platform_channel_id;
+            $route->setRelation('keywords', $allKeywords->get($key, collect()));
+
             return $route;
         });
 
@@ -179,7 +199,7 @@ public function render()
         $editingKeywords = collect();
 
         if ($this->editingFeedId && $this->editingChannelId) {
-            $editingRoute = Route::with(['feed', 'platformChannel'])
+            $editingRoute = Route::with(['feed', 'platformChannel.platformInstance'])
                 ->where('feed_id', $this->editingFeedId)
                 ->where('platform_channel_id', $this->editingChannelId)
                 ->first();

app/Livewire/Settings.php

@@ -3,15 +3,21 @@
 namespace App\Livewire;
 
 use App\Models\Setting;
+use Illuminate\Contracts\View\View;
 use Livewire\Component;
 
 class Settings extends Component
 {
     public bool $articleProcessingEnabled = true;
+
     public bool $publishingApprovalsEnabled = false;
+
     public int $articlePublishingInterval = 5;
 
+    public int $feedStalenessThreshold = 48;
+
     public ?string $successMessage = null;
+
     public ?string $errorMessage = null;
 
     public function mount(): void
@@ -19,18 +25,19 @@ public function mount(): void
         $this->articleProcessingEnabled = Setting::isArticleProcessingEnabled();
         $this->publishingApprovalsEnabled = Setting::isPublishingApprovalsEnabled();
         $this->articlePublishingInterval = Setting::getArticlePublishingInterval();
+        $this->feedStalenessThreshold = Setting::getFeedStalenessThreshold();
     }
 
     public function toggleArticleProcessing(): void
     {
-        $this->articleProcessingEnabled = !$this->articleProcessingEnabled;
+        $this->articleProcessingEnabled = ! $this->articleProcessingEnabled;
         Setting::setArticleProcessingEnabled($this->articleProcessingEnabled);
         $this->showSuccess();
     }
 
     public function togglePublishingApprovals(): void
     {
-        $this->publishingApprovalsEnabled = !$this->publishingApprovalsEnabled;
+        $this->publishingApprovalsEnabled = ! $this->publishingApprovalsEnabled;
         Setting::setPublishingApprovalsEnabled($this->publishingApprovalsEnabled);
         $this->showSuccess();
     }
@@ -45,6 +52,16 @@ public function updateArticlePublishingInterval(): void
         $this->showSuccess();
     }
 
+    public function updateFeedStalenessThreshold(): void
+    {
+        $this->validate([
+            'feedStalenessThreshold' => 'required|integer|min:0',
+        ]);
+
+        Setting::setFeedStalenessThreshold($this->feedStalenessThreshold);
+        $this->showSuccess();
+    }
+
     protected function showSuccess(): void
     {
         $this->successMessage = 'Settings updated successfully!';
@@ -60,7 +77,7 @@ public function clearMessages(): void
         $this->errorMessage = null;
     }
 
-    public function render()
+    public function render(): View
     {
         return view('livewire.settings')->layout('layouts.app');
     }

app/Models/Article.php

@@ -2,12 +2,12 @@
 
 namespace App\Models;
 
-use App\Events\ArticleApproved;
 use App\Events\NewArticleFetched;
 use Database\Factories\ArticleFactory;
 use Illuminate\Database\Eloquent\Factories\HasFactory;
 use Illuminate\Database\Eloquent\Model;
 use Illuminate\Database\Eloquent\Relations\BelongsTo;
+use Illuminate\Database\Eloquent\Relations\HasMany;
 use Illuminate\Database\Eloquent\Relations\HasOne;
 use Illuminate\Support\Carbon;
 
@@ -15,15 +15,17 @@
  * @method static firstOrCreate(array<string, mixed> $array)
  * @method static where(string $string, string $url)
  * @method static create(array<string, mixed> $array)
- * @property integer $id
+ *
+ * @property int $id
  * @property int $feed_id
  * @property Feed $feed
  * @property string $url
- * @property bool|null $is_valid
+ * @property string $title
+ * @property string|null $description
  * @property Carbon|null $validated_at
  * @property Carbon $created_at
  * @property Carbon $updated_at
- * @property ArticlePublication $articlePublication
+ * @property ArticlePublication|null $articlePublication
  */
 class Article extends Model
 {
@@ -39,9 +41,7 @@ class Article extends Model
         'image_url',
         'published_at',
         'author',
-        'approval_status',
         'validated_at',
-        'publish_status',
     ];
 
     /**
@@ -50,8 +50,6 @@ class Article extends Model
     public function casts(): array
     {
         return [
-            'approval_status' => 'string',
-            'publish_status' => 'string',
             'published_at' => 'datetime',
             'validated_at' => 'datetime',
             'created_at' => 'datetime',
@@ -59,58 +57,6 @@ public function casts(): array
         ];
     }
 
-    public function isValid(): bool
-    {
-        return $this->validated_at !== null && ! $this->isRejected();
-    }
-
-    public function isApproved(): bool
-    {
-        return $this->approval_status === 'approved';
-    }
-
-    public function isPending(): bool
-    {
-        return $this->approval_status === 'pending';
-    }
-
-    public function isRejected(): bool
-    {
-        return $this->approval_status === 'rejected';
-    }
-
-    public function approve(string $approvedBy = null): void
-    {
-        $this->update([
-            'approval_status' => 'approved',
-        ]);
-
-        // Fire event to trigger publishing
-        event(new ArticleApproved($this));
-    }
-
-    public function reject(string $rejectedBy = null): void
-    {
-        $this->update([
-            'approval_status' => 'rejected',
-        ]);
-    }
-
-    public function canBePublished(): bool
-    {
-        if (!$this->isValid()) {
-            return false;
-        }
-
-        // If approval system is disabled, auto-approve valid articles
-        if (!\App\Models\Setting::isPublishingApprovalsEnabled()) {
-            return true;
-        }
-
-        // If approval system is enabled, only approved articles can be published
-        return $this->isApproved();
-    }
-
     public function getIsPublishedAttribute(): bool
     {
         return $this->articlePublication()->exists();
@@ -124,6 +70,14 @@ public function articlePublication(): HasOne
         return $this->hasOne(ArticlePublication::class);
     }
 
+    /**
+     * @return HasMany<ArticlePublication, $this>
+     */
+    public function articlePublications(): HasMany
+    {
+        return $this->hasMany(ArticlePublication::class);
+    }
+
     /**
      * @return BelongsTo<Feed, $this>
      */
@@ -132,6 +86,14 @@ public function feed(): BelongsTo
         return $this->belongsTo(Feed::class);
     }
 
+    /**
+     * @return HasMany<RouteArticle, $this>
+     */
+    public function routeArticles(): HasMany
+    {
+        return $this->hasMany(RouteArticle::class);
+    }
+
     public function dispatchFetchedEvent(): void
     {
         event(new NewArticleFetched($this));

app/Models/ArticlePublication.php

@@ -6,11 +6,19 @@
 use Illuminate\Database\Eloquent\Factories\HasFactory;
 use Illuminate\Database\Eloquent\Model;
 use Illuminate\Database\Eloquent\Relations\BelongsTo;
+use Illuminate\Support\Carbon;
 
 /**
- * @property integer $article_id
- * @property integer $platform_channel_id
- * @property integer $post_id
+ * @property int $id
+ * @property int $article_id
+ * @property int $platform_channel_id
+ * @property string $post_id
+ * @property string $platform
+ * @property string $published_by
+ * @property array<string, mixed>|null $publication_data
+ * @property Carbon $published_at
+ * @property Carbon $created_at
+ * @property Carbon $updated_at
  *
  * @method static create(array<string, mixed> $array)
  */
@@ -18,7 +26,7 @@ class ArticlePublication extends Model
 {
     /** @use HasFactory<ArticlePublicationFactory> */
     use HasFactory;
-    
+
     protected $fillable = [
         'article_id',
         'platform_channel_id',

app/Models/Feed.php

@@ -3,6 +3,7 @@
 namespace App\Models;
 
 use Database\Factories\FeedFactory;
+use Illuminate\Database\Eloquent\Builder;
 use Illuminate\Database\Eloquent\Factories\HasFactory;
 use Illuminate\Database\Eloquent\Model;
 use Illuminate\Database\Eloquent\Relations\BelongsTo;
@@ -16,7 +17,7 @@
  * @property string $url
  * @property string $type
  * @property string $provider
- * @property int $language_id
+ * @property int|null $language_id
  * @property Language|null $language
  * @property string $description
  * @property array<string, mixed> $settings
@@ -24,6 +25,7 @@
  * @property Carbon|null $last_fetched_at
  * @property Carbon $created_at
  * @property Carbon $updated_at
+ *
  * @method static orderBy(string $string, string $string1)
  * @method static where(string $string, true $true)
  * @method static findOrFail(mixed $feed_id)
@@ -32,7 +34,9 @@ class Feed extends Model
 {
     /** @use HasFactory<FeedFactory> */
     use HasFactory;
+
     private const RECENT_FETCH_THRESHOLD_HOURS = 2;
+
     private const DAILY_FETCH_THRESHOLD_HOURS = 24;
 
     protected $fillable = [
@@ -44,13 +48,13 @@ class Feed extends Model
         'description',
         'settings',
         'is_active',
-        'last_fetched_at'
+        'last_fetched_at',
     ];
 
     protected $casts = [
         'settings' => 'array',
         'is_active' => 'boolean',
-        'last_fetched_at' => 'datetime'
+        'last_fetched_at' => 'datetime',
     ];
 
     public function getTypeDisplayAttribute(): string
@@ -64,11 +68,11 @@ public function getTypeDisplayAttribute(): string
 
     public function getStatusAttribute(): string
     {
-        if (!$this->is_active) {
+        if (! $this->is_active) {
             return 'Inactive';
         }
 
-        if (!$this->last_fetched_at) {
+        if (! $this->last_fetched_at) {
             return 'Never fetched';
         }
 
@@ -79,12 +83,25 @@ public function getStatusAttribute(): string
         } elseif ($hoursAgo < self::DAILY_FETCH_THRESHOLD_HOURS) {
             return "Fetched {$hoursAgo}h ago";
         } else {
-            return "Fetched " . $this->last_fetched_at->diffForHumans();
+            return 'Fetched '.$this->last_fetched_at->diffForHumans();
         }
     }
 
     /**
-     * @return BelongsToMany<PlatformChannel, $this, Route>
+     * @param  Builder<Feed>  $query
+     * @return Builder<Feed>
+     */
+    public function scopeStale(Builder $query, int $thresholdHours): Builder
+    {
+        return $query->where('is_active', true)
+            ->where(function (Builder $query) use ($thresholdHours) {
+                $query->whereNull('last_fetched_at')
+                    ->orWhere('last_fetched_at', '<', now()->subHours($thresholdHours));
+            });
+    }
+
+    /**
+     * @return BelongsToMany<PlatformChannel, $this>
      */
     public function channels(): BelongsToMany
     {
@@ -94,7 +111,7 @@ public function channels(): BelongsToMany
     }
 
     /**
-     * @return BelongsToMany<PlatformChannel, $this, Route>
+     * @return BelongsToMany<PlatformChannel, $this>
      */
     public function activeChannels(): BelongsToMany
     {

app/Models/Keyword.php

@@ -2,6 +2,7 @@
 
 namespace App\Models;
 
+use Database\Factories\KeywordFactory;
 use Illuminate\Database\Eloquent\Factories\HasFactory;
 use Illuminate\Database\Eloquent\Model;
 use Illuminate\Database\Eloquent\Relations\BelongsTo;
@@ -20,17 +21,18 @@
  */
 class Keyword extends Model
 {
+    /** @use HasFactory<KeywordFactory> */
     use HasFactory;
 
     protected $fillable = [
         'feed_id',
         'platform_channel_id',
         'keyword',
-        'is_active'
+        'is_active',
     ];
 
     protected $casts = [
-        'is_active' => 'boolean'
+        'is_active' => 'boolean',
     ];
 
     /**
@@ -48,5 +50,4 @@ public function platformChannel(): BelongsTo
     {
         return $this->belongsTo(PlatformChannel::class);
     }
-
 }

app/Models/Language.php

@@ -15,13 +15,13 @@ class Language extends Model
 
     protected $fillable = [
         'short_code',
-        'name', 
+        'name',
         'native_name',
-        'is_active'
+        'is_active',
     ];
 
     protected $casts = [
-        'is_active' => 'boolean'
+        'is_active' => 'boolean',
     ];
 
     /**

app/Models/Log.php

@@ -3,12 +3,14 @@
 namespace App\Models;
 
 use App\Enums\LogLevelEnum;
+use Database\Factories\LogFactory;
 use Illuminate\Database\Eloquent\Factories\HasFactory;
 use Illuminate\Database\Eloquent\Model;
 use Illuminate\Support\Carbon;
 
 /**
- * @method static create(array $array)
+ * @method static create(array<string, mixed> $array)
+ *
  * @property LogLevelEnum $level
  * @property string $message
  * @property array<string, mixed> $context
@@ -17,6 +19,7 @@
  */
 class Log extends Model
 {
+    /** @use HasFactory<LogFactory> */
     use HasFactory;
 
     protected $table = 'logs';

app/Models/Notification.php

@@ -0,0 +1,92 @@
+<?php
+
+namespace App\Models;
+
+use App\Enums\NotificationSeverityEnum;
+use App\Enums\NotificationTypeEnum;
+use Database\Factories\NotificationFactory;
+use Illuminate\Database\Eloquent\Builder;
+use Illuminate\Database\Eloquent\Factories\HasFactory;
+use Illuminate\Database\Eloquent\Model;
+use Illuminate\Database\Eloquent\Relations\MorphTo;
+use Illuminate\Support\Carbon;
+
+/**
+ * @property int $id
+ * @property NotificationTypeEnum $type
+ * @property NotificationSeverityEnum $severity
+ * @property string $title
+ * @property string $message
+ * @property array<string, mixed>|null $data
+ * @property string|null $notifiable_type
+ * @property int|null $notifiable_id
+ * @property Carbon|null $read_at
+ * @property Carbon $created_at
+ * @property Carbon $updated_at
+ */
+class Notification extends Model
+{
+    /** @use HasFactory<NotificationFactory> */
+    use HasFactory;
+
+    protected $fillable = [
+        'type',
+        'severity',
+        'title',
+        'message',
+        'data',
+        'notifiable_type',
+        'notifiable_id',
+        'read_at',
+    ];
+
+    protected $casts = [
+        'type' => NotificationTypeEnum::class,
+        'severity' => NotificationSeverityEnum::class,
+        'data' => 'array',
+        'read_at' => 'datetime',
+        'created_at' => 'datetime',
+        'updated_at' => 'datetime',
+    ];
+
+    /**
+     * @return MorphTo<Model, $this>
+     */
+    public function notifiable(): MorphTo
+    {
+        return $this->morphTo();
+    }
+
+    public function isRead(): bool
+    {
+        return $this->read_at !== null;
+    }
+
+    public function markAsRead(): void
+    {
+        $this->update(['read_at' => now()]);
+    }
+
+    /**
+     * @param  Builder<Notification>  $query
+     * @return Builder<Notification>
+     */
+    public function scopeUnread(Builder $query): Builder
+    {
+        return $query->whereNull('read_at');
+    }
+
+    /**
+     * @param  Builder<Notification>  $query
+     * @return Builder<Notification>
+     */
+    public function scopeRecent(Builder $query): Builder
+    {
+        return $query->latest()->limit(50);
+    }
+
+    public static function markAllAsRead(): void
+    {
+        static::unread()->update(['read_at' => now()]);
+    }
+}

app/Models/PlatformAccount.php

@@ -2,15 +2,15 @@
 
 namespace App\Models;
 
+use App\Enums\PlatformEnum;
 use Database\Factories\PlatformAccountFactory;
-use Illuminate\Database\Eloquent\Factories\HasFactory;
-use Illuminate\Database\Eloquent\Model;
 use Illuminate\Database\Eloquent\Casts\Attribute;
 use Illuminate\Database\Eloquent\Collection;
+use Illuminate\Database\Eloquent\Factories\HasFactory;
+use Illuminate\Database\Eloquent\Model;
 use Illuminate\Database\Eloquent\Relations\BelongsToMany;
 use Illuminate\Support\Carbon;
 use Illuminate\Support\Facades\Crypt;
-use App\Enums\PlatformEnum;
 
 /**
  * @property int $id
@@ -18,13 +18,14 @@
  * @property string $instance_url
  * @property string $username
  * @property string $password
- * @property string $settings
+ * @property array<string, mixed> $settings
  * @property bool $is_active
- * @property Carbon $last_tested_at
+ * @property Carbon|null $last_tested_at
  * @property string $status
  * @property Carbon $created_at
  * @property Carbon $updated_at
  * @property Collection<int, PlatformChannel> $activeChannels
+ *
  * @method static where(string $string, PlatformEnum $platform)
  * @method static orderBy(string $string)
  * @method static create(array<string, mixed> $validated)
@@ -42,14 +43,14 @@ class PlatformAccount extends Model
         'settings',
         'is_active',
         'last_tested_at',
-        'status'
+        'status',
     ];
 
     protected $casts = [
         'platform' => PlatformEnum::class,
         'settings' => 'array',
         'is_active' => 'boolean',
-        'last_tested_at' => 'datetime'
+        'last_tested_at' => 'datetime',
     ];
 
     // Encrypt password when storing
@@ -64,12 +65,12 @@ protected function password(): Attribute
                 if (is_null($value)) {
                     return null;
                 }
-                
+
                 // Return empty string if value is empty
                 if (empty($value)) {
                     return '';
                 }
-                
+
                 try {
                     return Crypt::decryptString($value);
                 } catch (\Exception $e) {
@@ -82,18 +83,17 @@ protected function password(): Attribute
                 if (is_null($value)) {
                     return null;
                 }
-                
+
                 // Store empty string as null
                 if (empty($value)) {
                     return null;
                 }
-                
+
                 return Crypt::encryptString($value);
             },
         )->withoutObjectCaching();
     }
 
-
     // Get the active accounts for a platform (returns collection)
     /**
      * @return Collection<int, PlatformAccount>

app/Models/PlatformChannel.php

@@ -10,15 +10,16 @@
 
 /**
  * @method static findMany(mixed $channel_ids)
- * @method static create(array $array)
- * @property integer $id
- * @property integer $platform_instance_id
+ * @method static create(array<string, mixed> $array)
+ *
+ * @property int $id
+ * @property int $platform_instance_id
  * @property PlatformInstance $platformInstance
- * @property integer $channel_id
+ * @property int $channel_id
  * @property string $name
  * @property int $language_id
  * @property Language|null $language
- * @property boolean $is_active
+ * @property bool $is_active
  */
 class PlatformChannel extends Model
 {
@@ -34,11 +35,11 @@ class PlatformChannel extends Model
         'channel_id',
         'description',
         'language_id',
-        'is_active'
+        'is_active',
     ];
 
     protected $casts = [
-        'is_active' => 'boolean'
+        'is_active' => 'boolean',
     ];
 
     /**
@@ -70,11 +71,11 @@ public function activePlatformAccounts(): BelongsToMany
     public function getFullNameAttribute(): string
     {
         // For Lemmy, use /c/ prefix
-        return $this->platformInstance->url . '/c/' . $this->name;
+        return $this->platformInstance->url.'/c/'.$this->name;
     }
 
     /**
-     * @return BelongsToMany<Feed, $this, Route>
+     * @return BelongsToMany<Feed, $this>
      */
     public function feeds(): BelongsToMany
     {
@@ -84,7 +85,7 @@ public function feeds(): BelongsToMany
     }
 
     /**
-     * @return BelongsToMany<Feed, $this, Route>
+     * @return BelongsToMany<Feed, $this>
      */
     public function activeFeeds(): BelongsToMany
     {

app/Models/PlatformChannelPost.php

@@ -3,6 +3,7 @@
 namespace App\Models;
 
 use App\Enums\PlatformEnum;
+use Illuminate\Database\Eloquent\Factories\Factory;
 use Illuminate\Database\Eloquent\Factories\HasFactory;
 use Illuminate\Database\Eloquent\Model;
 
@@ -12,7 +13,9 @@
  */
 class PlatformChannelPost extends Model
 {
+    /** @use HasFactory<Factory<PlatformChannelPost>> */
     use HasFactory;
+
     protected $fillable = [
         'platform',
         'channel_id',
@@ -44,7 +47,7 @@ public static function urlExists(PlatformEnum $platform, string $channelId, stri
 
     public static function duplicateExists(PlatformEnum $platform, string $channelId, ?string $url, ?string $title): bool
     {
-        if (!$url && !$title) {
+        if (! $url && ! $title) {
             return false;
         }
 

app/Models/PlatformInstance.php

@@ -12,28 +12,29 @@
 /**
  * @method static updateOrCreate(array<string, mixed> $array, $instanceData)
  * @method static where(string $string, mixed $operator)
+ *
  * @property PlatformEnum $platform
  * @property string $url
  * @property string $name
  * @property string $description
- * @property boolean $is_active
+ * @property bool $is_active
  */
 class PlatformInstance extends Model
 {
     /** @use HasFactory<PlatformInstanceFactory> */
     use HasFactory;
-    
+
     protected $fillable = [
         'platform',
         'url',
         'name',
         'description',
-        'is_active'
+        'is_active',
     ];
 
     protected $casts = [
         'platform' => PlatformEnum::class,
-        'is_active' => 'boolean'
+        'is_active' => 'boolean',
     ];
 
     /**

app/Models/Route.php

@@ -4,9 +4,9 @@
 
 use Database\Factories\RouteFactory;
 use Illuminate\Database\Eloquent\Factories\HasFactory;
+use Illuminate\Database\Eloquent\Model;
 use Illuminate\Database\Eloquent\Relations\BelongsTo;
 use Illuminate\Database\Eloquent\Relations\HasMany;
-use Illuminate\Database\Eloquent\Model;
 use Illuminate\Support\Carbon;
 
 /**
@@ -14,6 +14,7 @@
  * @property int $platform_channel_id
  * @property bool $is_active
  * @property int $priority
+ * @property bool|null $auto_approve
  * @property Carbon $created_at
  * @property Carbon $updated_at
  */
@@ -21,22 +22,25 @@ class Route extends Model
 {
     /** @use HasFactory<RouteFactory> */
     use HasFactory;
-    
+
     protected $table = 'routes';
-    
+
     // Laravel doesn't handle composite primary keys well, so we'll use regular queries
     protected $primaryKey = null;
+
     public $incrementing = false;
 
     protected $fillable = [
         'feed_id',
         'platform_channel_id',
         'is_active',
-        'priority'
+        'priority',
+        'auto_approve',
     ];
 
     protected $casts = [
-        'is_active' => 'boolean'
+        'is_active' => 'boolean',
+        'auto_approve' => 'boolean',
     ];
 
     /**
@@ -63,4 +67,13 @@ public function keywords(): HasMany
         return $this->hasMany(Keyword::class, 'feed_id', 'feed_id')
             ->where('platform_channel_id', $this->platform_channel_id);
     }
+
+    /**
+     * @return HasMany<RouteArticle, $this>
+     */
+    public function routeArticles(): HasMany
+    {
+        return $this->hasMany(RouteArticle::class, 'feed_id', 'feed_id')
+            ->where('platform_channel_id', $this->platform_channel_id);
+    }
 }

app/Models/RouteArticle.php

@@ -0,0 +1,104 @@
+<?php
+
+namespace App\Models;
+
+use App\Enums\ApprovalStatusEnum;
+use App\Enums\PublishStatusEnum;
+use App\Events\RouteArticleApproved;
+use Database\Factories\RouteArticleFactory;
+use Illuminate\Database\Eloquent\Factories\HasFactory;
+use Illuminate\Database\Eloquent\Model;
+use Illuminate\Database\Eloquent\Relations\BelongsTo;
+use Illuminate\Support\Carbon;
+
+/**
+ * @property int $id
+ * @property int $feed_id
+ * @property int $platform_channel_id
+ * @property int $article_id
+ * @property ApprovalStatusEnum $approval_status
+ * @property PublishStatusEnum $publish_status
+ * @property Carbon|null $validated_at
+ * @property Carbon $created_at
+ * @property Carbon $updated_at
+ */
+class RouteArticle extends Model
+{
+    /** @use HasFactory<RouteArticleFactory> */
+    use HasFactory;
+
+    protected $fillable = [
+        'feed_id',
+        'platform_channel_id',
+        'article_id',
+        'approval_status',
+        'publish_status',
+        'validated_at',
+    ];
+
+    protected $casts = [
+        'approval_status' => ApprovalStatusEnum::class,
+        'publish_status' => PublishStatusEnum::class,
+        'validated_at' => 'datetime',
+    ];
+
+    /**
+     * @return BelongsTo<Route, $this>
+     */
+    public function route(): BelongsTo
+    {
+        return $this->belongsTo(Route::class, 'feed_id', 'feed_id')
+            ->where('platform_channel_id', $this->platform_channel_id);
+    }
+
+    /**
+     * @return BelongsTo<Article, $this>
+     */
+    public function article(): BelongsTo
+    {
+        return $this->belongsTo(Article::class);
+    }
+
+    /**
+     * @return BelongsTo<Feed, $this>
+     */
+    public function feed(): BelongsTo
+    {
+        return $this->belongsTo(Feed::class);
+    }
+
+    /**
+     * @return BelongsTo<PlatformChannel, $this>
+     */
+    public function platformChannel(): BelongsTo
+    {
+        return $this->belongsTo(PlatformChannel::class);
+    }
+
+    public function isPending(): bool
+    {
+        return $this->approval_status === ApprovalStatusEnum::PENDING;
+    }
+
+    public function isApproved(): bool
+    {
+        return $this->approval_status === ApprovalStatusEnum::APPROVED;
+    }
+
+    public function isRejected(): bool
+    {
+        return $this->approval_status === ApprovalStatusEnum::REJECTED;
+    }
+
+    public function approve(): void
+    {
+        $this->update(['approval_status' => ApprovalStatusEnum::APPROVED]);
+
+        event(new RouteArticleApproved($this));
+    }
+
+    public function reject(): void
+    {
+        $this->update(['approval_status' => ApprovalStatusEnum::REJECTED]);
+    }
+}

app/Models/Setting.php

@@ -2,16 +2,18 @@
 
 namespace App\Models;
 
+use Database\Factories\SettingFactory;
 use Illuminate\Database\Eloquent\Factories\HasFactory;
 use Illuminate\Database\Eloquent\Model;
 
 /**
- * @method static updateOrCreate(string[] $array, array $array1)
- * @method static create(string[] $array)
+ * @method static updateOrCreate(array<string, string> $array, array<string, mixed> $array1)
+ * @method static create(array<string, string> $array)
  * @method static where(string $string, string $key)
  */
 class Setting extends Model
 {
+    /** @use HasFactory<SettingFactory> */
     use HasFactory;
 
     protected $fillable = ['key', 'value'];
@@ -69,4 +71,14 @@ public static function setArticlePublishingInterval(int $minutes): void
     {
         static::set('article_publishing_interval', (string) $minutes);
     }
+
+    public static function getFeedStalenessThreshold(): int
+    {
+        return (int) static::get('feed_staleness_threshold', 48);
+    }
+
+    public static function setFeedStalenessThreshold(int $hours): void
+    {
+        static::set('feed_staleness_threshold', (string) $hours);
+    }
 }

app/Models/User.php

@@ -3,6 +3,7 @@
 namespace App\Models;
 
 // use Illuminate\Contracts\Auth\MustVerifyEmail;
+use Database\Factories\UserFactory;
 use Illuminate\Database\Eloquent\Factories\HasFactory;
 use Illuminate\Foundation\Auth\User as Authenticatable;
 use Illuminate\Notifications\Notifiable;
@@ -10,8 +11,8 @@
 
 class User extends Authenticatable
 {
-    /** @use HasFactory<\Database\Factories\UserFactory> */
-    use HasFactory, Notifiable, HasApiTokens;
+    /** @use HasFactory<UserFactory> */
+    use HasApiTokens, HasFactory, Notifiable;
 
     /**
      * The attributes that are mass assignable.

app/Modules/Lemmy/LemmyRequest.php

@@ -2,13 +2,15 @@
 
 namespace App\Modules\Lemmy;
 
-use Illuminate\Support\Facades\Http;
 use Illuminate\Http\Client\Response;
+use Illuminate\Support\Facades\Http;
 
 class LemmyRequest
 {
     private string $instance;
+
     private ?string $token;
+
     private string $scheme = 'https';
 
     public function __construct(string $instance, ?string $token = null)
@@ -45,11 +47,12 @@ public function withScheme(string $scheme): self
         if (in_array($scheme, ['http', 'https'], true)) {
             $this->scheme = $scheme;
         }
+
         return $this;
     }
 
     /**
-     * @param array<string, mixed> $params
+     * @param  array<string, mixed>  $params
      */
     public function get(string $endpoint, array $params = []): Response
     {
@@ -65,7 +68,7 @@ public function get(string $endpoint, array $params = []): Response
     }
 
     /**
-     * @param array<string, mixed> $data
+     * @param  array<string, mixed>  $data
      */
     public function post(string $endpoint, array $data = []): Response
     {
@@ -83,6 +86,7 @@ public function post(string $endpoint, array $data = []): Response
     public function withToken(string $token): self
     {
         $this->token = $token;
+
         return $this;
     }
 }

app/Modules/Lemmy/Services/LemmyApiService.php

@@ -39,7 +39,7 @@ public function login(string $username, string $password): ?string
                     'password' => $password,
                 ]);
 
-                if (!$response->successful()) {
+                if (! $response->successful()) {
                     $responseBody = $response->body();
                     logger()->error('Lemmy login failed', [
                         'status' => $response->status(),
@@ -61,6 +61,7 @@ public function login(string $username, string $password): ?string
                 }
 
                 $data = $response->json();
+
                 return $data['jwt'] ?? null;
             } catch (Exception $e) {
                 // Re-throw rate limit exceptions immediately
@@ -74,7 +75,7 @@ public function login(string $username, string $password): ?string
                     continue;
                 }
                 // Connection failed - throw exception to distinguish from auth failure
-                throw new Exception('Connection failed: ' . $e->getMessage());
+                throw new Exception('Connection failed: '.$e->getMessage());
             }
         }
 
@@ -88,11 +89,12 @@ public function getCommunityId(string $communityName, string $token): int
             $request = new LemmyRequest($this->instance, $token);
             $response = $request->get('community', ['name' => $communityName]);
 
-            if (!$response->successful()) {
-                throw new Exception('Failed to fetch community: ' . $response->status());
+            if (! $response->successful()) {
+                throw new Exception('Failed to fetch community: '.$response->status());
             }
 
             $data = $response->json();
+
             return $data['community_view']['community']['id'] ?? throw new Exception('Community not found');
         } catch (Exception $e) {
             logger()->error('Community lookup failed', ['error' => $e->getMessage()]);
@@ -107,14 +109,15 @@ public function syncChannelPosts(string $token, int $platformChannelId, string $
             $response = $request->get('post/list', [
                 'community_id' => $platformChannelId,
                 'limit' => 50,
-                'sort' => 'New'
+                'sort' => 'New',
             ]);
 
-            if (!$response->successful()) {
+            if (! $response->successful()) {
                 logger()->warning('Failed to sync channel posts', [
                     'status' => $response->status(),
-                    'platform_channel_id' => $platformChannelId
+                    'platform_channel_id' => $platformChannelId,
                 ]);
+
                 return;
             }
 
@@ -137,13 +140,13 @@ public function syncChannelPosts(string $token, int $platformChannelId, string $
 
             logger()->info('Synced channel posts', [
                 'platform_channel_id' => $platformChannelId,
-                'posts_count' => count($posts)
+                'posts_count' => count($posts),
             ]);
 
         } catch (Exception $e) {
             logger()->error('Exception while syncing channel posts', [
                 'error' => $e->getMessage(),
-                'platform_channel_id' => $platformChannelId
+                'platform_channel_id' => $platformChannelId,
             ]);
         }
     }
@@ -176,8 +179,8 @@ public function createPost(string $token, string $title, string $body, int $plat
 
             $response = $request->post('post', $postData);
 
-            if (!$response->successful()) {
-                throw new Exception('Failed to create post: ' . $response->status() . ' - ' . $response->body());
+            if (! $response->successful()) {
+                throw new Exception('Failed to create post: '.$response->status().' - '.$response->body());
             }
 
             return $response->json();
@@ -196,19 +199,22 @@ public function getLanguages(): array
             $request = new LemmyRequest($this->instance);
             $response = $request->get('site');
 
-            if (!$response->successful()) {
+            if (! $response->successful()) {
                 logger()->warning('Failed to fetch site languages', [
-                    'status' => $response->status()
+                    'status' => $response->status(),
                 ]);
+
                 return [];
             }
 
             $data = $response->json();
+
             return $data['all_languages'] ?? [];
         } catch (Exception $e) {
             logger()->error('Exception while fetching languages', [
-                'error' => $e->getMessage()
+                'error' => $e->getMessage(),
             ]);
+
             return [];
         }
     }

app/Modules/Lemmy/Services/LemmyPublisher.php

@@ -12,6 +12,7 @@
 class LemmyPublisher
 {
     private LemmyApiService $api;
+
     private PlatformAccount $account;
 
     public function __construct(PlatformAccount $account)
@@ -21,8 +22,9 @@ public function __construct(PlatformAccount $account)
     }
 
     /**
-     * @param array<string, mixed> $extractedData
+     * @param  array<string, mixed>  $extractedData
      * @return array<string, mixed>
+     *
      * @throws PlatformAuthException
      * @throws Exception
      */
@@ -37,6 +39,7 @@ public function publishToChannel(Article $article, array $extractedData, Platfor
             // If the cached token was stale, refresh and retry once
             if (str_contains($e->getMessage(), 'not_logged_in') || str_contains($e->getMessage(), 'Unauthorized')) {
                 $token = $authService->refreshToken($this->account);
+
                 return $this->createPost($token, $extractedData, $channel, $article);
             }
             throw $e;
@@ -44,7 +47,7 @@ public function publishToChannel(Article $article, array $extractedData, Platfor
     }
 
     /**
-     * @param array<string, mixed> $extractedData
+     * @param  array<string, mixed>  $extractedData
      * @return array<string, mixed>
      */
     private function createPost(string $token, array $extractedData, PlatformChannel $channel, Article $article): array
@@ -65,5 +68,4 @@ private function createPost(string $token, array $extractedData, PlatformChannel
             $languageId
         );
     }
-
 }

app/Providers/AppServiceProvider.php

@@ -3,8 +3,14 @@
 namespace App\Providers;
 
 use App\Enums\LogLevelEnum;
+use App\Events\ActionPerformed;
 use App\Events\ExceptionOccurred;
+use App\Events\NewArticleFetched;
+use App\Events\RouteArticleApproved;
+use App\Listeners\LogActionListener;
 use App\Listeners\LogExceptionToDatabase;
+use App\Listeners\PublishApprovedArticleListener;
+use App\Listeners\ValidateArticleListener;
 use Error;
 use Illuminate\Contracts\Debug\ExceptionHandler;
 use Illuminate\Support\Facades\Event;
@@ -14,25 +20,28 @@
 
 class AppServiceProvider extends ServiceProvider
 {
-    public function register(): void
-    {
-    }
+    public function register(): void {}
 
     public function boot(): void
     {
+        Event::listen(
+            ActionPerformed::class,
+            LogActionListener::class,
+        );
+
         Event::listen(
             ExceptionOccurred::class,
             LogExceptionToDatabase::class,
         );
 
         Event::listen(
-            \App\Events\NewArticleFetched::class,
-            \App\Listeners\ValidateArticleListener::class,
+            NewArticleFetched::class,
+            ValidateArticleListener::class,
         );
 
         Event::listen(
-            \App\Events\ArticleApproved::class,
-            \App\Listeners\PublishApprovedArticleListener::class,
+            RouteArticleApproved::class,
+            PublishApprovedArticleListener::class,
         );
 
         app()->make(ExceptionHandler::class)

app/Services/Article/ArticleFetcher.php

@@ -4,9 +4,9 @@
 
 use App\Models\Article;
 use App\Models\Feed;
-use App\Services\Http\HttpFetcher;
 use App\Services\Factories\ArticleParserFactory;
 use App\Services\Factories\HomepageParserFactory;
+use App\Services\Http\HttpFetcher;
 use App\Services\Log\LogSaver;
 use Exception;
 use Illuminate\Support\Collection;
@@ -28,9 +28,9 @@ public function getArticlesFromFeed(Feed $feed): Collection
             return $this->getArticlesFromWebsiteFeed($feed);
         }
 
-        $this->logSaver->warning("Unsupported feed type", null, [
+        $this->logSaver->warning('Unsupported feed type', null, [
             'feed_id' => $feed->id,
-            'feed_type' => $feed->type
+            'feed_type' => $feed->type,
         ]);
 
         return collect();
@@ -53,8 +53,8 @@ private function getArticlesFromRssFeed(Feed $feed): Collection
                 libxml_use_internal_errors($previousUseErrors);
             }
 
-            if ($rss === false || !isset($rss->channel->item)) {
-                $this->logSaver->warning("Failed to parse RSS feed XML", null, [
+            if ($rss === false || ! isset($rss->channel->item)) {
+                $this->logSaver->warning('Failed to parse RSS feed XML', null, [
                     'feed_id' => $feed->id,
                     'feed_url' => $feed->url,
                 ]);
@@ -72,7 +72,7 @@ private function getArticlesFromRssFeed(Feed $feed): Collection
 
             return $articles;
         } catch (Exception $e) {
-            $this->logSaver->error("Failed to fetch articles from RSS feed", null, [
+            $this->logSaver->error('Failed to fetch articles from RSS feed', null, [
                 'feed_id' => $feed->id,
                 'feed_url' => $feed->url,
                 'error' => $e->getMessage(),
@@ -92,9 +92,9 @@ private function getArticlesFromWebsiteFeed(Feed $feed): Collection
             $parser = HomepageParserFactory::getParserForFeed($feed);
 
             if (! $parser) {
-                $this->logSaver->warning("No parser available for feed URL", null, [
+                $this->logSaver->warning('No parser available for feed URL', null, [
                     'feed_id' => $feed->id,
-                    'feed_url' => $feed->url
+                    'feed_url' => $feed->url,
                 ]);
 
                 return collect();
@@ -107,10 +107,10 @@ private function getArticlesFromWebsiteFeed(Feed $feed): Collection
                 ->map(fn (string $url) => $this->saveArticle($url, $feed->id));
 
         } catch (Exception $e) {
-            $this->logSaver->error("Failed to fetch articles from website feed", null, [
+            $this->logSaver->error('Failed to fetch articles from website feed', null, [
                 'feed_id' => $feed->id,
                 'feed_url' => $feed->url,
-                'error' => $e->getMessage()
+                'error' => $e->getMessage(),
             ]);
 
             return collect();
@@ -130,7 +130,7 @@ public function fetchArticleData(Article $article): array
         } catch (Exception $e) {
             $this->logSaver->error('Exception while fetching article data', null, [
                 'url' => $article->url,
-                'error' => $e->getMessage()
+                'error' => $e->getMessage(),
             ]);
 
             return [];
@@ -155,8 +155,8 @@ private function saveArticle(string $url, ?int $feedId = null): Article
             }
 
             return $article;
-        } catch (\Exception $e) {
-            $this->logSaver->error("Failed to create article", null, [
+        } catch (Exception $e) {
+            $this->logSaver->error('Failed to create article', null, [
                 'url' => $url,
                 'feed_id' => $feedId,
                 'error' => $e->getMessage(),

app/Services/Article/ValidationService.php

@@ -2,7 +2,13 @@
 
 namespace App\Services\Article;
 
+use App\Enums\ApprovalStatusEnum;
 use App\Models\Article;
+use App\Models\Keyword;
+use App\Models\Route;
+use App\Models\RouteArticle;
+use App\Models\Setting;
+use Illuminate\Support\Collection;
 
 class ValidationService
 {
@@ -12,70 +18,99 @@ public function __construct(
 
     public function validate(Article $article): Article
     {
-        logger('Checking keywords for article: ' . $article->id);
+        logger('Validating article for routes: '.$article->id);
 
         $articleData = $this->articleFetcher->fetchArticleData($article);
 
-        // Update article with fetched metadata (title, description)
         $updateData = [];
 
-        if (!empty($articleData)) {
+        if (! empty($articleData)) {
             $updateData['title'] = $articleData['title'] ?? $article->title;
             $updateData['description'] = $articleData['description'] ?? $article->description;
             $updateData['content'] = $articleData['full_article'] ?? null;
         }
 
-        if (!isset($articleData['full_article']) || empty($articleData['full_article'])) {
+        if (! isset($articleData['full_article']) || empty($articleData['full_article'])) {
             logger()->warning('Article data missing full_article content', [
                 'article_id' => $article->id,
-                'url' => $article->url
+                'url' => $article->url,
             ]);
 
-            $updateData['approval_status'] = 'rejected';
+            $updateData['validated_at'] = now();
             $article->update($updateData);
 
             return $article->refresh();
         }
 
-        // Validate content against keywords. If validation fails, reject.
-        // If validation passes, leave approval_status as-is (pending) —
-        // the listener decides whether to auto-approve based on settings.
-        $validationResult = $this->validateByKeywords($articleData['full_article']);
-
-        if (! $validationResult) {
-            $updateData['approval_status'] = 'rejected';
-        }
-
         $updateData['validated_at'] = now();
         $article->update($updateData);
 
+        $this->createRouteArticles($article, $articleData['full_article']);
+
         return $article->refresh();
     }
 
-    private function validateByKeywords(string $full_article): bool
+    private function createRouteArticles(Article $article, string $content): void
     {
-        // Belgian news content keywords - broader set for Belgian news relevance
-        $keywords = [
-            // Political parties and leaders
-            'N-VA', 'Bart De Wever', 'Frank Vandenbroucke', 'Alexander De Croo',
-            'Vooruit', 'Open Vld', 'CD&V', 'Vlaams Belang', 'PTB', 'PVDA',
+        $activeRoutes = Route::where('feed_id', $article->feed_id)
+            ->where('is_active', true)
+            ->get();
 
-            // Belgian locations and institutions
-            'Belgium', 'Belgian', 'Flanders', 'Flemish', 'Wallonia', 'Brussels',
-            'Antwerp', 'Ghent', 'Bruges', 'Leuven', 'Mechelen', 'Namur', 'Liège', 'Charleroi',
-            'parliament', 'government', 'minister', 'policy', 'law', 'legislation',
+        // Batch-load all active keywords for this feed, grouped by channel
+        $keywordsByChannel = Keyword::where('feed_id', $article->feed_id)
+            ->where('is_active', true)
+            ->get()
+            ->groupBy('platform_channel_id');
 
-            // Common Belgian news topics
-            'economy', 'economic', 'education', 'healthcare', 'transport', 'climate', 'energy',
-            'European', 'EU', 'migration', 'security', 'justice', 'culture', 'police'
-        ];
+        // Match keywords against full article content, title, and description
+        $searchableContent = $content.' '.$article->title.' '.$article->description;
+
+        foreach ($activeRoutes as $route) {
+            $routeKeywords = $keywordsByChannel->get($route->platform_channel_id, collect());
+            $status = $this->evaluateKeywords($routeKeywords, $searchableContent);
+
+            if ($status === ApprovalStatusEnum::PENDING && $this->shouldAutoApprove($route)) {
+                $status = ApprovalStatusEnum::APPROVED;
+            }
+
+            RouteArticle::firstOrCreate(
+                [
+                    'feed_id' => $route->feed_id,
+                    'platform_channel_id' => $route->platform_channel_id,
+                    'article_id' => $article->id,
+                ],
+                [
+                    'approval_status' => $status,
+                    'validated_at' => now(),
+                ]
+            );
+        }
+    }
+
+    /**
+     * @param  Collection<int, Keyword>  $keywords
+     */
+    private function evaluateKeywords(Collection $keywords, string $content): ApprovalStatusEnum
+    {
+        if ($keywords->isEmpty()) {
+            return ApprovalStatusEnum::PENDING;
+        }
 
         foreach ($keywords as $keyword) {
-            if (stripos($full_article, $keyword) !== false) {
-                return true;
+            if (stripos($content, $keyword->keyword) !== false) {
+                return ApprovalStatusEnum::PENDING;
             }
         }
 
-        return false;
+        return ApprovalStatusEnum::REJECTED;
+    }
+
+    private function shouldAutoApprove(Route $route): bool
+    {
+        if ($route->auto_approve !== null) {
+            return $route->auto_approve;
+        }
+
+        return ! Setting::isPublishingApprovalsEnabled();
     }
 }

app/Services/Auth/LemmyAuthService.php

@@ -32,14 +32,14 @@ public function getToken(PlatformAccount $account): string
     public function refreshToken(PlatformAccount $account): string
     {
         if (! $account->username || ! $account->password || ! $account->instance_url) {
-            throw new PlatformAuthException(PlatformEnum::LEMMY, 'Missing credentials for account: ' . $account->username);
+            throw new PlatformAuthException(PlatformEnum::LEMMY, 'Missing credentials for account: '.$account->username);
         }
 
         $api = new LemmyApiService($account->instance_url);
         $token = $api->login($account->username, $account->password);
 
-        if (!$token) {
-            throw new PlatformAuthException(PlatformEnum::LEMMY, 'Login failed for account: ' . $account->username);
+        if (! $token) {
+            throw new PlatformAuthException(PlatformEnum::LEMMY, 'Login failed for account: '.$account->username);
         }
 
         // Cache the token for future use
@@ -52,15 +52,19 @@ public function refreshToken(PlatformAccount $account): string
 
     /**
      * Authenticate with Lemmy API and return user data with JWT
+     *
      * @throws PlatformAuthException
      */
+    /**
+     * @return array<string, mixed>
+     */
     public function authenticate(string $instanceUrl, string $username, string $password): array
     {
         try {
             $api = new LemmyApiService($instanceUrl);
             $token = $api->login($username, $password);
 
-            if (!$token) {
+            if (! $token) {
                 // Throw a clean exception that will be caught and handled by the controller
                 throw new PlatformAuthException(PlatformEnum::LEMMY, 'Invalid credentials');
             }
@@ -75,8 +79,8 @@ public function authenticate(string $instanceUrl, string $username, string $pass
                         'id' => 0, // Would need API call to get actual user info
                         'display_name' => null,
                         'bio' => null,
-                    ]
-                ]
+                    ],
+                ],
             ];
         } catch (PlatformAuthException $e) {
             // Re-throw PlatformAuthExceptions as-is to avoid nesting

app/Services/DashboardStatsService.php

@@ -9,10 +9,12 @@
 use App\Models\PlatformChannel;
 use App\Models\Route;
 use Carbon\Carbon;
-use Illuminate\Support\Facades\DB;
 
 class DashboardStatsService
 {
+    /**
+     * @return array<string, mixed>
+     */
     public function getStats(string $period = 'today'): array
     {
         $dateRange = $this->getDateRange($period);
@@ -73,6 +75,9 @@ private function getDateRange(string $period): ?array
         };
     }
 
+    /**
+     * @return array<string, int>
+     */
     public function getSystemStats(): array
     {
         $totalFeeds = Feed::query()->count();

app/Services/Factories/ArticleParserFactory.php

@@ -4,9 +4,9 @@
 
 use App\Contracts\ArticleParserInterface;
 use App\Models\Feed;
-use App\Services\Parsers\VrtArticleParser;
 use App\Services\Parsers\BelgaArticleParser;
 use App\Services\Parsers\GuardianArticleParser;
+use App\Services\Parsers\VrtArticleParser;
 use Exception;
 
 class ArticleParserFactory
@@ -26,7 +26,7 @@ class ArticleParserFactory
     public static function getParser(string $url): ArticleParserInterface
     {
         foreach (self::$parsers as $parserClass) {
-            $parser = new $parserClass();
+            $parser = new $parserClass;
 
             if ($parser->canParse($url)) {
                 return $parser;
@@ -38,21 +38,22 @@ public static function getParser(string $url): ArticleParserInterface
 
     public static function getParserForFeed(Feed $feed, string $parserType = 'article'): ?ArticleParserInterface
     {
-        if (!$feed->provider) {
+        if (! $feed->provider) {
             return null;
         }
 
         $providerConfig = config("feed.providers.{$feed->provider}");
-        if (!$providerConfig || !isset($providerConfig['parsers'][$parserType])) {
+        if (! $providerConfig || ! isset($providerConfig['parsers'][$parserType])) {
             return null;
         }
 
+        /** @var class-string<ArticleParserInterface> $parserClass */
         $parserClass = $providerConfig['parsers'][$parserType];
-        if (!class_exists($parserClass)) {
+        if (! class_exists($parserClass)) {
             return null;
         }
 
-        return new $parserClass();
+        return new $parserClass;
     }
 
     /**
@@ -60,18 +61,19 @@ public static function getParserForFeed(Feed $feed, string $parserType = 'articl
      */
     public static function getSupportedSources(): array
     {
-        return array_map(function($parserClass) {
-            $parser = new $parserClass();
+        return array_map(function ($parserClass) {
+            $parser = new $parserClass;
+
             return $parser->getSourceName();
         }, self::$parsers);
     }
 
     /**
-     * @param class-string<ArticleParserInterface> $parserClass
+     * @param  class-string<ArticleParserInterface>  $parserClass
      */
     public static function registerParser(string $parserClass): void
     {
-        if (!in_array($parserClass, self::$parsers)) {
+        if (! in_array($parserClass, self::$parsers)) {
             self::$parsers[] = $parserClass;
         }
     }

app/Services/Factories/HomepageParserFactory.php

@@ -9,21 +9,22 @@ class HomepageParserFactory
 {
     public static function getParserForFeed(Feed $feed): ?HomepageParserInterface
     {
-        if (!$feed->provider) {
+        if (! $feed->provider) {
             return null;
         }
 
         $providerConfig = config("feed.providers.{$feed->provider}");
-        if (!$providerConfig || !isset($providerConfig['parsers']['homepage'])) {
+        if (! $providerConfig || ! isset($providerConfig['parsers']['homepage'])) {
             return null;
         }
 
+        /** @var class-string<HomepageParserInterface> $parserClass */
         $parserClass = $providerConfig['parsers']['homepage'];
-        if (!class_exists($parserClass)) {
+        if (! class_exists($parserClass)) {
             return null;
         }
 
-        $language = $feed->language?->short_code ?? 'en';
+        $language = $feed->language->short_code ?? 'en';
 
         return new $parserClass($language);
     }

app/Services/Http/HttpFetcher.php

@@ -2,8 +2,9 @@
 
 namespace App\Services\Http;
 
-use Illuminate\Support\Facades\Http;
 use Exception;
+use Illuminate\Http\Client\Response;
+use Illuminate\Support\Facades\Http;
 
 class HttpFetcher
 {
@@ -15,7 +16,7 @@ public static function fetchHtml(string $url): string
         try {
             $response = Http::get($url);
 
-            if (!$response->successful()) {
+            if (! $response->successful()) {
                 throw new Exception("Failed to fetch URL: {$url} - Status: {$response->status()}");
             }
 
@@ -23,7 +24,7 @@ public static function fetchHtml(string $url): string
         } catch (Exception $e) {
             logger()->error('HTTP fetch failed', [
                 'url' => $url,
-                'error' => $e->getMessage()
+                'error' => $e->getMessage(),
             ]);
 
             throw $e;
@@ -31,7 +32,7 @@ public static function fetchHtml(string $url): string
     }
 
     /**
-     * @param array<int, string> $urls
+     * @param  array<int, string>  $urls
      * @return array<int, array<string, mixed>>
      */
     public static function fetchMultipleUrls(array $urls): array
@@ -44,24 +45,24 @@ public static function fetchMultipleUrls(array $urls): array
             });
 
             return collect($responses)
-                ->filter(fn($response, $index) => isset($urls[$index]))
-                ->reject(fn($response, $index) => $response instanceof Exception)
+                ->filter(fn ($response, $index) => isset($urls[$index]))
+                ->reject(fn ($response, $index) => $response instanceof Exception)
                 ->map(function ($response, $index) use ($urls) {
                     $url = $urls[$index];
-
+                    /** @var Response $response */
                     try {
                         if ($response->successful()) {
                             return [
                                 'url' => $url,
                                 'html' => $response->body(),
-                                'success' => true
+                                'success' => true,
                             ];
                         } else {
                             return [
                                 'url' => $url,
                                 'html' => null,
                                 'success' => false,
-                                'status' => $response->status()
+                                'status' => $response->status(),
                             ];
                         }
                     } catch (Exception) {
@@ -69,11 +70,10 @@ public static function fetchMultipleUrls(array $urls): array
                             'url' => $url,
                             'html' => null,
                             'success' => false,
-                            'error' => 'Exception occurred'
+                            'error' => 'Exception occurred',
                         ];
                     }
                 })
-                ->filter(fn($result) => $result !== null)
                 ->toArray();
         } catch (Exception $e) {
             logger()->error('Multiple URL fetch failed', ['error' => $e->getMessage()]);

app/Services/Log/LogSaver.php

@@ -9,7 +9,7 @@
 class LogSaver
 {
     /**
-     * @param array<string, mixed> $context
+     * @param  array<string, mixed>  $context
      */
     public function info(string $message, ?PlatformChannel $channel = null, array $context = []): void
     {
@@ -17,7 +17,7 @@ public function info(string $message, ?PlatformChannel $channel = null, array $c
     }
 
     /**
-     * @param array<string, mixed> $context
+     * @param  array<string, mixed>  $context
      */
     public function error(string $message, ?PlatformChannel $channel = null, array $context = []): void
     {
@@ -25,7 +25,7 @@ public function error(string $message, ?PlatformChannel $channel = null, array $
     }
 
     /**
-     * @param array<string, mixed> $context
+     * @param  array<string, mixed>  $context
      */
     public function warning(string $message, ?PlatformChannel $channel = null, array $context = []): void
     {
@@ -33,7 +33,7 @@ public function warning(string $message, ?PlatformChannel $channel = null, array
     }
 
     /**
-     * @param array<string, mixed> $context
+     * @param  array<string, mixed>  $context
      */
     public function debug(string $message, ?PlatformChannel $channel = null, array $context = []): void
     {
@@ -41,9 +41,9 @@ public function debug(string $message, ?PlatformChannel $channel = null, array $
     }
 
     /**
-     * @param array<string, mixed> $context
+     * @param  array<string, mixed>  $context
      */
-    private function log(LogLevelEnum $level, string $message, ?PlatformChannel $channel = null, array $context = []): void
+    public function log(LogLevelEnum $level, string $message, ?PlatformChannel $channel = null, array $context = []): void
     {
         $logContext = $context;
 

app/Services/Notification/NotificationService.php

@@ -0,0 +1,69 @@
+<?php
+
+namespace App\Services\Notification;
+
+use App\Enums\NotificationSeverityEnum;
+use App\Enums\NotificationTypeEnum;
+use App\Models\Notification;
+use Illuminate\Database\Eloquent\Model;
+
+class NotificationService
+{
+    /**
+     * @param  array<string, mixed>  $data
+     */
+    public function send(
+        NotificationTypeEnum $type,
+        NotificationSeverityEnum $severity,
+        string $title,
+        string $message,
+        ?Model $notifiable = null,
+        array $data = [],
+    ): Notification {
+        return Notification::create([
+            'type' => $type,
+            'severity' => $severity,
+            'title' => $title,
+            'message' => $message,
+            'data' => $data ?: null,
+            'notifiable_type' => $notifiable?->getMorphClass(),
+            'notifiable_id' => $notifiable?->getKey(),
+        ]);
+    }
+
+    /**
+     * @param  array<string, mixed>  $data
+     */
+    public function info(
+        string $title,
+        string $message,
+        ?Model $notifiable = null,
+        array $data = [],
+    ): Notification {
+        return $this->send(NotificationTypeEnum::GENERAL, NotificationSeverityEnum::INFO, $title, $message, $notifiable, $data);
+    }
+
+    /**
+     * @param  array<string, mixed>  $data
+     */
+    public function warning(
+        string $title,
+        string $message,
+        ?Model $notifiable = null,
+        array $data = [],
+    ): Notification {
+        return $this->send(NotificationTypeEnum::GENERAL, NotificationSeverityEnum::WARNING, $title, $message, $notifiable, $data);
+    }
+
+    /**
+     * @param  array<string, mixed>  $data
+     */
+    public function error(
+        string $title,
+        string $message,
+        ?Model $notifiable = null,
+        array $data = [],
+    ): Notification {
+        return $this->send(NotificationTypeEnum::GENERAL, NotificationSeverityEnum::ERROR, $title, $message, $notifiable, $data);
+    }
+}

app/Services/OnboardingService.php

@@ -41,6 +41,6 @@ private function checkOnboardingStatus(): bool
 
         $hasAllComponents = $hasPlatformAccount && $hasFeed && $hasChannel && $hasRoute;
 
-        return !$hasAllComponents;
+        return ! $hasAllComponents;
     }
-}
+}