wip

app/Concerns/Enums/Arrayable.php

@@ -6,20 +6,29 @@
 
 trait Arrayable
 {
+    /**
+     * @return array<int|string, string>
+     */
     public static function names(): array
     {
         return collect(self::cases())
             ->pluck('name')
             ->all();
     }
 
+    /**
+     * @return array<int|string, string>
+     */
     public static function values(): array
     {
         return collect(self::cases())
             ->pluck('value')
             ->all();
     }
 
+    /**
+     * @return array<int|string, string|null>
+     */
     public static function options(): array
     {
         return collect(self::cases())

app/Events/CountryCodeNotFound.php

@@ -0,0 +1,31 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Events;
+
+use App\Models\Election;
+use Illuminate\Broadcasting\InteractsWithSockets;
+use Illuminate\Broadcasting\PrivateChannel;
+use Illuminate\Foundation\Events\Dispatchable;
+use Illuminate\Queue\SerializesModels;
+
+class CountryCodeNotFound
+{
+    use Dispatchable;
+    use InteractsWithSockets;
+    use SerializesModels;
+
+    public string $country;
+
+    public Election $election;
+
+    /**
+     * Create a new event instance.
+     */
+    public function __construct(string $country, Election $election)
+    {
+        $this->country = $country;
+        $this->election = $election;
+    }
+}

app/Jobs/Europarl240609/Turnout/ImportAbroadTurnoutJob.php

@@ -4,6 +4,7 @@
 
 namespace App\Jobs\Europarl240609\Turnout;
 
+use App\Events\CountryCodeNotFound;
 use App\Exceptions\CountryCodeNotFoundException;
 use App\Exceptions\MissingSourceFileException;
 use App\Models\Country;
@@ -16,7 +17,6 @@
 use Illuminate\Queue\InteractsWithQueue;
 use Illuminate\Queue\SerializesModels;
 use League\Csv\Reader;
-use Throwable;
 
 class ImportAbroadTurnoutJob implements ShouldQueue
 {
@@ -65,19 +65,31 @@ public function handle(): void
                     'mobile' => $record['UM'],
 
                     'area' => $record['Mediu'],
+                    'has_issues' => $this->determineIfHasIssues($record),
 
                     ...$segments->map(fn (string $segment) => $record[$segment]),
                 ]);
             } catch (CountryCodeNotFoundException $th) {
-                logger()->info($th->getMessage());
-            } catch (Throwable $th) {
-                // TODO: filament notification
+                CountryCodeNotFound::dispatch($record['UAT'], $this->scheduledJob->election);
             }
         }
 
         Turnout::saveToTemporaryTable($values->all());
     }
 
+    protected function determineIfHasIssues(array $record): bool
+    {
+        $computedTotal = collect(['LP', 'LC', 'LS', 'UM'])
+            ->map(fn (string $key) => $record[$key])
+            ->sum();
+
+        if ($computedTotal !== $record['LT']) {
+            return true;
+        }
+
+        return false;
+    }
+
     protected function getCountryId(string $name): string
     {
         $country = Country::search($name)->first();

app/Jobs/Europarl240609/Turnout/ImportCountyTurnoutJob.php

@@ -66,6 +66,7 @@ public function handle(): void
                 'mobile' => $record['UM'],
 
                 'area' => $record['Mediu'],
+                'has_issues' => $this->determineIfHasIssues($record),
 
                 ...$segments->map(fn (string $segment) => $record[$segment]),
             ]);
@@ -74,6 +75,19 @@ public function handle(): void
         Turnout::saveToTemporaryTable($values->all());
     }
 
+    protected function determineIfHasIssues(array $record): bool
+    {
+        $computedTotal = collect(['LP', 'LC', 'LS', 'UM'])
+            ->map(fn (string $key) => $record[$key])
+            ->sum();
+
+        if ($computedTotal !== $record['LT']) {
+            return true;
+        }
+
+        return false;
+    }
+
     /**
      * Get the tags that should be assigned to the job.
      *

app/Providers/Filament/AdminPanelProvider.php

@@ -86,7 +86,8 @@ public function panel(Panel $panel): Panel
                     ->icon('heroicon-o-cog')
                     ->url(fn () => ElectionResource::getUrl('view', ['record' => Filament::getTenant()])),
             ])
-            ->collapsibleNavigationGroups(false);
+            ->collapsibleNavigationGroups(false)
+            ->databaseNotifications();
     }
 
     public function register(): void

database/migrations/0001_01_01_000005_create_personal_access_tokens_table.php

@@ -8,9 +8,6 @@
 
 return new class extends Migration
 {
-    /**
-     * Run the migrations.
-     */
     public function up(): void
     {
         Schema::create('personal_access_tokens', function (Blueprint $table) {

database/migrations/0001_01_01_000020_create_notifications_table.php

@@ -0,0 +1,22 @@
+<?php
+
+declare(strict_types=1);
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+return new class extends Migration
+{
+    public function up(): void
+    {
+        Schema::create('notifications', function (Blueprint $table) {
+            $table->uuid('id')->primary();
+            $table->string('type');
+            $table->morphs('notifiable');
+            $table->text('data');
+            $table->timestamp('read_at')->nullable();
+            $table->timestamps();
+        });
+    }
+};

database/migrations/0001_01_02_000000_create_siruta_tables.php

@@ -8,6 +8,7 @@
 use Illuminate\Database\Schema\Blueprint;
 use Illuminate\Support\Facades\DB;
 use Illuminate\Support\Facades\Schema;
+use Illuminate\Support\Facades\Storage;
 use Maatwebsite\Excel\Facades\Excel;
 
 return new class extends Migration

database/migrations/0001_01_02_000005_create_scheduled_jobs_table.php

@@ -9,9 +9,6 @@
 
 return new class extends Migration
 {
-    /**
-     * Run the migrations.
-     */
     public function up(): void
     {
         Schema::create('scheduled_jobs', function (Blueprint $table) {

database/migrations/0001_01_02_000010_create_parties_table.php

@@ -9,9 +9,6 @@
 
 return new class extends Migration
 {
-    /**
-     * Run the migrations.
-     */
     public function up(): void
     {
         Schema::create('parties', function (Blueprint $table) {

database/migrations/0001_01_10_000000_create_turnouts_table.php

@@ -10,9 +10,6 @@
 
 return new class extends Migration
 {
-    /**
-     * Run the migrations.
-     */
     public function up(): void
     {
         Schema::create('turnouts', function (Blueprint $table) {

docker-compose.yml

@@ -0,0 +1,36 @@
+services:
+  typesense:
+    image: typesense/typesense:27.1
+    ports:
+      - ${FORWARD_TYPESENSE_PORT:-8108}:8108
+    environment:
+      TYPESENSE_DATA_DIR: ${TYPESENSE_DATA_DIR:-/typesense-data}
+      TYPESENSE_API_KEY: ${TYPESENSE_API_KEY:-xyz}
+      TYPESENSE_ENABLE_CORS: ${TYPESENSE_ENABLE_CORS:-true}
+    volumes:
+      - sail-typesense:/typesense-data
+    healthcheck:
+      test:
+        - CMD
+        - wget
+        - '--no-verbose'
+        - '--spider'
+        - 'http://localhost:8108/health'
+      retries: 5
+      timeout: 7s
+
+  soketi:
+    image: quay.io/soketi/soketi:latest-16-alpine
+    environment:
+      SOKETI_DEBUG: ${SOKETI_DEBUG:-1}
+      SOKETI_METRICS_SERVER_PORT: 9601
+      SOKETI_DEFAULT_APP_ID: ${PUSHER_APP_ID}
+      SOKETI_DEFAULT_APP_KEY: ${PUSHER_APP_KEY}
+      SOKETI_DEFAULT_APP_SECRET: ${PUSHER_APP_SECRET}
+    ports:
+      - ${PUSHER_PORT:-6001}:6001
+      - ${PUSHER_METRICS_PORT:-9601}:9601
+
+volumes:
+  sail-typesense:
+    driver: local