laravel-liberu / genealogy

app/Jobs/ImportGedcom.php

<?php

namespace App\Jobs;

use App\Models\ImportJob;
use App\Models\User;
use App\Tenant\Manager;
use FamilyTree365\LaravelGedcom\Utils\GedcomParser;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Facades\File;
use Illuminate\Support\Str;

class ImportGedcom implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

The trait Illuminate\Queue\SerializesModels requires some properties which are not provided by App\Jobs\ImportGedcom: $collectionClass, $id, $relations, $class, $keyBy

    public int $timeout = 0;
    public int $tries = 1;

    public function __construct(protected User $user, protected string $filePath, protected ?string $slug = null)
    {
    }

    public function handle(): int
    {
        throw_unless(File::isFile($this->filePath), \Exception::class, "{$this->filePath} does not exist.");

        $tenant = Manager::fromModel($this->user->company(), $this->user);

It seems like $this->user->company() can also be of type null; however, parameter $model of App\Tenant\Manager::fromModel() does only seem to accept Illuminate\Database\Eloquent\Model, maybe add an additional type check?

        if (! $tenant->databaseExists()) {
            //$tenant->dropDatabase();
            $tenant->createDatabase();
            $tenant->connect();
            $tenant->migrateDatabase();
        }
        $tenant->connect();
        $slug = $this->slug ?? Str::uuid();

        $job = ImportJob::on($tenant->connectionName())->create([
            'user_id' => $this->user->getKey(),
            'status' => 'queue',
            'slug' => $slug,
        ]);
        $parser = new GedcomParser();

        $parser->parse($tenant->connectionName(), $this->filePath, $slug, true);
        // with(new GedcomParser())->parse($tenant->connectionName(), $this->filePath, $slug, true);

        File::delete($this->filePath);

        $job->update(['status' => 'complete']);

        $tenant->disconnect();

        return 0;
    }
}