Kiosk Mode

.env.example

@@ -63,3 +63,7 @@ AWS_BUCKET=
 AWS_USE_PATH_STYLE_ENDPOINT=false
 
 VITE_APP_NAME="${APP_NAME}"
+
+# Services
+MAPBOX_API_KEY=
+OPENWEATHER_API_KEY=

.git-blame-ignore-revs

@@ -1 +1,4 @@
 24b8f32bcf7e24f999bd8763bc9baca607fad516
+62f533191a8f08fb724b207b4e3f53f9ab2b35bb
+e42a663c237250cc6e17eed50a7e3802d35e6a34
+7dc4a38cd79c5cb74f6d0ababf1ded730ab1d030

app/Actions/Calendars/FetchCalendarEvents.php

@@ -0,0 +1,167 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Actions\Calendars;
+
+use App\Models\CalendarFeed;
+use Carbon\CarbonImmutable;
+use DateTimeInterface;
+use DateTimeZone;
+use Illuminate\Support\Collection;
+use Illuminate\Support\Facades\Cache;
+use Illuminate\Support\Facades\Http;
+use Sabre\VObject\Component\VEvent;
+use Sabre\VObject\DateTimeParser;
+use Sabre\VObject\Reader;
+
+class FetchCalendarEvents
+{
+    /**
+     * @return Collection<int, array{
+     *     feed_id: int,
+     *     feed_name: string,
+     *     feed_color: string,
+     *     title: string,
+     *     location: string|null,
+     *     starts_at: CarbonImmutable,
+     *     ends_at: CarbonImmutable|null,
+     *     all_day: bool,
+     *     response_status: string|null
+     * }>
+     */
+    public function handle(CalendarFeed $feed, int $days = 30, ?CarbonImmutable $from = null): Collection
+    {
+        $body = Cache::remember(
+            key: "calendar-feed:{$feed->id}:" . md5($feed->url),
+            ttl: now()->addMinutes(15),
+            callback: fn () => Http::withHeaders([
+                'Accept' => 'text/calendar,text/plain,*/*',
+                'User-Agent' => 'SunnyCalendar/1.0',
+            ])->timeout(10)->get($feed->url)->throw()->body(),
+        );
+
+        return $this->parse($body, $feed, $from ?? CarbonImmutable::now($this->timezoneName($feed)), $days);
+    }
+
+    /**
+     * @return Collection<int, array{
+     *     feed_id: int,
+     *     feed_name: string,
+     *     feed_color: string,
+     *     title: string,
+     *     location: string|null,
+     *     starts_at: CarbonImmutable,
+     *     ends_at: CarbonImmutable|null,
+     *     all_day: bool,
+     *     response_status: string|null
+     * }>
+     */
+    public function parse(string $ics, CalendarFeed $feed, CarbonImmutable $from, int $days = 30): Collection
+    {
+        $timezone = new DateTimeZone($this->timezoneName($feed));
+        $from = $from->setTimezone($timezone);
+        $until = $from->addDays($days);
+        $calendar = Reader::read($ics);
+        $expandedCalendar = $calendar->expand($from, $until, $timezone);
+
+        return collect($expandedCalendar->select('VEVENT'))
+            ->filter(fn ($event) => $event instanceof VEvent && isset($event->DTSTART))
+            ->map(fn (VEvent $event) => $this->eventData($event, $feed, $timezone))
+            ->sortBy('starts_at')
+            ->values();
+    }
+
+    /**
+     * @return array{
+     *     feed_id: int,
+     *     feed_name: string,
+     *     feed_color: string,
+     *     title: string,
+     *     location: string|null,
+     *     starts_at: CarbonImmutable,
+     *     ends_at: CarbonImmutable|null,
+     *     all_day: bool,
+     *     response_status: string|null
+     * }
+     */
+    private function eventData(VEvent $event, CalendarFeed $feed, DateTimeZone $timezone): array
+    {
+        $responseStatus = $this->responseStatus($event, $feed);
+
+        return [
+            'feed_id' => $feed->id,
+            'feed_name' => $feed->name,
+            'feed_color' => $feed->color,
+            'title' => blank((string) ($event->SUMMARY ?? '')) ? __('Untitled event') : (string) $event->SUMMARY,
+            'location' => blank((string) ($event->LOCATION ?? '')) ? null : (string) $event->LOCATION,
+            'starts_at' => $this->carbon($event->DTSTART->getDateTime($timezone), $timezone),
+            'ends_at' => $this->endDate($event, $timezone),
+            'all_day' => ! $event->DTSTART->hasTime(),
+            'response_status' => $responseStatus,
+        ];
+    }
+
+    private function endDate(VEvent $event, DateTimeZone $timezone): ?CarbonImmutable
+    {
+        if (isset($event->DTEND)) {
+            return $this->carbon($event->DTEND->getDateTime($timezone), $timezone);
+        }
+
+        if (isset($event->DURATION)) {
+            return $this->carbon($event->DTSTART->getDateTime($timezone), $timezone)
+                ->add(DateTimeParser::parseDuration((string) $event->DURATION));
+        }
+
+        return null;
+    }
+
+    private function carbon(DateTimeInterface $dateTime, DateTimeZone $timezone): CarbonImmutable
+    {
+        return CarbonImmutable::instance($dateTime)->setTimezone($timezone);
+    }
+
+    private function responseStatus(VEvent $event, CalendarFeed $feed): ?string
+    {
+        if (! isset($event->ATTENDEE)) {
+            return null;
+        }
+
+        $emails = $this->teamMemberEmails($feed);
+
+        if ($emails->isEmpty()) {
+            return null;
+        }
+
+        foreach ($event->ATTENDEE as $attendee) {
+            $attendeeEmail = mb_strtolower(preg_replace('/^mailto:/i', '', (string) $attendee->getValue()));
+
+            if ($emails->doesntContain($attendeeEmail)) {
+                continue;
+            }
+
+            return isset($attendee['PARTSTAT'])
+                ? strtoupper((string) $attendee['PARTSTAT'])
+                : null;
+        }
+
+        return null;
+    }
+
+    /** @return Collection<int, string> */
+    private function teamMemberEmails(CalendarFeed $feed): Collection
+    {
+        $feed->loadMissing('team.members');
+
+        return $feed->team->members
+            ->pluck('email')
+            ->map(fn (string $email): string => mb_strtolower($email))
+            ->filter()
+            ->values();
+    }
+
+    private function timezoneName(CalendarFeed $feed): string
+    {
+        return $feed->team?->timezone ?: 'America/Chicago';
+    }
+}

app/Actions/Kiosk/CreateFeed.php

@@ -0,0 +1,17 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Actions\Kiosk;
+
+use App\Models\CalendarFeed;
+use App\Models\Team;
+
+class CreateFeed
+{
+    /** @param  array<string, mixed>  $data */
+    public function handle(Team $team, array $data): CalendarFeed
+    {
+        return $team->calendarFeeds()->create($data);
+    }
+}

app/Actions/Kiosk/UpdateFeed.php

@@ -0,0 +1,18 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Actions\Kiosk;
+
+use App\Models\CalendarFeed;
+
+class UpdateFeed
+{
+    /** @param  array<string, mixed>  $data */
+    public function handle(CalendarFeed $feed, array $data): CalendarFeed
+    {
+        $feed->update($data);
+
+        return $feed;
+    }
+}

app/Enums/CalendarColor.php

@@ -0,0 +1,17 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Enums;
+
+enum CalendarColor: string
+{
+    case Blue = '#2563eb';
+    case Green = '#16a34a';
+    case Red = '#dc2626';
+    case Purple = '#9333ea';
+    case Orange = '#ea580c';
+    case Cyan = '#0891b2';
+    case Gold = '#ca8a04';
+    case Indigo = '#4f46e5';
+}

app/Http/Integrations/OpenWeather/OpenWeatherConnector.php

@@ -0,0 +1,28 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Http\Integrations\OpenWeather;
+
+use Saloon\Http\Connector;
+use Saloon\Traits\Plugins\AcceptsJson;
+use Saloon\Traits\Plugins\AlwaysThrowOnErrors;
+
+class OpenWeatherConnector extends Connector
+{
+    use AcceptsJson;
+    use AlwaysThrowOnErrors;
+
+    public function resolveBaseUrl(): string
+    {
+        return 'https://api.openweathermap.org/data/3.0/';
+    }
+
+    protected function defaultQuery(): array
+    {
+        return [
+            'appid' => config('services.openweather.key'),
+            'units' => 'imperial',
+        ];
+    }
+}

app/Http/Integrations/OpenWeather/Requests/OneCall.php

@@ -0,0 +1,33 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Http\Integrations\OpenWeather\Requests;
+
+use Saloon\Enums\Method;
+use Saloon\Http\Request;
+
+class OneCall extends Request
+{
+    protected Method $method = Method::GET;
+
+    public function __construct(
+        public readonly float $lat,
+        public readonly float $lon,
+        public readonly ?string $exclude = null
+    ) {}
+
+    public function resolveEndpoint(): string
+    {
+        return '/onecall';
+    }
+
+    public function defaultQuery(): array
+    {
+        return array_filter([
+            'lat' => $this->lat,
+            'lon' => $this->lon,
+            'exclude' => $this->exclude,
+        ]);
+    }
+}

app/Http/Middleware/RestrictKioskSession.php

@@ -0,0 +1,43 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Http\Middleware;
+
+use Closure;
+use Illuminate\Http\Request;
+use Symfony\Component\HttpFoundation\Response;
+
+class RestrictKioskSession
+{
+    /** @param  Closure(Request): (Response)  $next */
+    public function handle(Request $request, Closure $next): Response
+    {
+        if (! $request->session()->has('kiosk_device_id')) {
+            return $next($request);
+        }
+
+        if ($this->isKioskPath($request)) {
+            return $next($request);
+        }
+
+        abort(403, 'This kiosk session is restricted to kiosk pages.');
+    }
+
+    protected function isKioskPath(Request $request): bool
+    {
+        $path = '/' . ltrim($request->path(), '/');
+
+        if (str_starts_with($path, '/livewire/') || str_starts_with($path, '/livewire-')) {
+            return true;
+        }
+
+        if ($path === '/kiosk' || str_starts_with($path, '/kiosk/')) {
+            return true;
+        }
+
+        $segments = explode('/', trim($path, '/'));
+
+        return count($segments) >= 2 && $segments[1] === 'kiosk';
+    }
+}