✨ Export watched show based on nfo files

Still a work in progress. But enough to get me going now.

app/Data/DataPipes/GetSeasonEp.php

@@ -0,0 +1,44 @@
+<?php
+
+namespace App\Data\DataPipes;
+
+use Illuminate\Support\Collection;
+use SimpleXMLElement;
+use Spatie\LaravelData\DataPipes\DataPipe;
+use Spatie\LaravelData\Support\DataClass;
+
+use function file_exists;
+use function pathinfo;
+use function simplexml_load_file;
+
+
+class GetSeasonEp implements DataPipe
+{
+    public function handle(mixed $payload, DataClass $class, Collection $properties): Collection
+    {
+        $path = $properties->get('path');
+        $pi   = pathinfo($path);
+
+        $nfo = "{$pi['dirname']}/{$pi['filename']}.nfo";
+        if (file_exists($nfo)) {
+            $properties['epNfo'] = $nfo;
+
+            return $this->getEpFromNfo($properties, $nfo);
+        }
+
+        return $properties;
+    }
+
+    protected function getEpFromNfo(Collection $properties, string $nfo): Collection
+    {
+        $xml = simplexml_load_file($nfo);
+        if ($xml->season) {
+            $properties['season'] = (int) $xml->season;
+        }
+        if ($xml->episode) {
+            $properties['episode'] = (int) $xml->episode;
+        }
+
+        return $properties;
+    }
+}

app/Data/DataPipes/GetShowTmdb.php

@@ -0,0 +1,44 @@
+<?php
+
+namespace App\Data\DataPipes;
+
+use Illuminate\Support\Collection;
+use SimpleXMLElement;
+use Spatie\LaravelData\DataPipes\DataPipe;
+use Spatie\LaravelData\Support\DataClass;
+
+use function dirname;
+use function file_exists;
+use function simplexml_load_file;
+
+class GetShowTmdb implements DataPipe
+{
+    public function handle(mixed $payload, DataClass $class, Collection $properties): Collection
+    {
+        $path = $properties->get('path');
+
+        $dir = dirname($path);
+        do {
+            $nfo = "$dir/tvshow.nfo";
+            $dir = dirname($dir);
+        } while (!file_exists($nfo) && $dir !== '/');
+
+        if (!file_exists($nfo)) {
+            return $properties;
+        }
+
+        $properties['showNfo'] = $nfo;
+
+        $xml = simplexml_load_file($nfo);
+        $properties['showTmdb'] = $this->getProp($xml, 'tmdbid');
+        $properties['showImdb'] = $this->getProp($xml, 'imdb_id');
+        $properties['showTitle'] = $this->getProp($xml, 'title');
+
+        return $properties;
+    }
+
+    protected function getProp(SimpleXMLElement $xml, string $prop): ?string
+    {
+        return $xml->$prop ? (string) $xml->$prop : null;
+    }
+}

app/Data/DataPipes/ParseWatchFile.php

@@ -0,0 +1,30 @@
+<?php
+
+namespace App\Data\DataPipes;
+
+use App\Data\FileData;
+use Illuminate\Support\Carbon;
+use Illuminate\Support\Collection;
+use Spatie\LaravelData\DataPipes\DataPipe;
+use Spatie\LaravelData\Lazy;
+use Spatie\LaravelData\Optional;
+use Spatie\LaravelData\Support\DataClass;
+use Spatie\LaravelData\Support\DataConfig;
+use Spatie\LaravelData\Support\DataProperty;
+use Illuminate\Support\Str;
+
+class ParseWatchFile implements DataPipe
+{
+    public function handle(mixed $payload, DataClass $class, Collection $properties): Collection
+    {
+        $properties['watched'] = Carbon::now();
+        $properties['output'] = sprintf(
+            '%s-%dx%02d.json',
+            Str::slug($properties['showTitle']),
+            $properties['season'],
+            $properties['episode']
+        );
+
+        return $properties;
+    }
+}

app/Data/WatchFile.php

@@ -0,0 +1,36 @@
+<?php
+
+namespace App\Data;
+
+use Illuminate\Support\Carbon;
+use Spatie\LaravelData\Attributes\WithCast;
+use Spatie\LaravelData\DataPipeline;
+
+class WatchFile extends Data
+{
+    #[WithCast(Casts\File::class)]
+    public string $path;
+    public ?string $output = null;
+    public ?string $showNfo = null;
+    public ?string $showTmdb = null;
+    public ?string $showImdb = null;
+    public ?string $showTitle = null;
+    public ?string $epNfo = null;
+    public int $season = 0;
+    public int $episode = 0;
+    public Carbon $watched;
+
+    public static function fromPath(string $path): static
+    {
+        return static::from(['path' => $path]);
+    }
+
+    public static function pipeline(): DataPipeline
+    {
+        return parent::pipeline()
+            ->through(DataPipes\GetShowTmdb::class)
+            ->through(DataPipes\GetSeasonEp::class)
+            ->through(DataPipes\ParseWatchFile::class)
+            ;
+    }
+}