$columnMap * @param array $formats * @param array $options */ public function __construct( protected Export $export, protected array $columnMap, protected array $formats, protected array $options, protected string $authGuard, ) { $this->exporter = $this->export->getExporter( $this->columnMap, $this->options, ); } public function handle(): void { $this->export->touch('completed_at'); if (! $this->export->user instanceof Authenticatable) { /** @phpstan-ignore instanceof.alwaysTrue */ return; } $this->export->columnMap($this->columnMap); $this->export->options($this->options); $failedRowsCount = $this->export->getFailedRowsCount(); $isSynchronous = ($this->connection === 'sync') || (blank($this->connection) && (config('queue.default') === 'sync')); $notification = Notification::make() ->title($this->exporter::getCompletedNotificationTitle($this->export)) ->body($this->exporter::getCompletedNotificationBody($this->export)) ->when( ! $failedRowsCount, fn (Notification $notification) => $notification->success(), ) ->when( $failedRowsCount && ($failedRowsCount < $this->export->total_rows), fn (Notification $notification) => $notification->warning(), ) ->when( $failedRowsCount === $this->export->total_rows, fn (Notification $notification) => $notification->danger(), ) ->when( $failedRowsCount < $this->export->total_rows, fn (Notification $notification) => $notification->actions(array_map( fn (ExportFormat $format): Action => $format->getDownloadNotificationAction($this->export, $this->authGuard), $this->formats, )), ) ->when( $isSynchronous, fn (Notification $notification) => $notification->persistent(), ); $notification = $this->exporter::modifyCompletedNotification($notification, $this->export); if ($isSynchronous) { $notification->send(); } else { $notification->sendToDatabase($this->export->user, isEventDispatched: true); } } }