*/ public function getVisibleImports(): Collection { return $this->queryVisible()->get(); } /** * @return Builder */ public function queryVisible(): Builder { $query = Import::query(); if (!userCan(Permission::SettingsManage)) { $query->where('created_by', user()->id); } return $query; } public function findVisible(int $id): Import { $query = Import::query(); if (!userCan(Permission::SettingsManage)) { $query->where('created_by', user()->id); } return $query->findOrFail($id); } /** * @throws FileUploadException * @throws ZipValidationException * @throws ZipExportException */ public function storeFromUpload(UploadedFile $file): Import { $zipPath = $file->getRealPath(); $reader = new ZipExportReader($zipPath); $errors = (new ZipExportValidator($reader))->validate(); if ($errors) { throw new ZipValidationException($errors); } $exportModel = $reader->decodeDataToExportModel(); $import = new Import(); $import->type = match (get_class($exportModel)) { ZipExportPage::class => 'page', ZipExportChapter::class => 'chapter', ZipExportBook::class => 'book', }; $import->name = $exportModel->name; $import->created_by = user()->id; $import->size = filesize($zipPath); $exportModel->metadataOnly(); $import->metadata = json_encode($exportModel); $path = $this->storage->uploadFile( $file, 'uploads/files/imports/', '', 'zip' ); $import->path = $path; $import->save(); Activity::add(ActivityType::IMPORT_CREATE, $import); return $import; } /** * @throws ZipImportException */ public function runImport(Import $import, ?string $parent = null): Entity { $parentModel = null; if ($import->type === 'page' || $import->type === 'chapter') { $parentModel = $parent ? $this->entityQueries->findVisibleByStringIdentifier($parent) : null; if ($parentModel && !($parentModel instanceof Book || $parentModel instanceof Chapter)) { throw new ZipImportException(['Selected parent is not a book or chapter']); } } DB::beginTransaction(); try { $model = $this->importer->run($import, $parentModel); } catch (ZipImportException $e) { DB::rollBack(); $this->importer->revertStoredFiles(); throw $e; } DB::commit(); $this->deleteImport($import); Activity::add(ActivityType::IMPORT_RUN, $import); return $model; } public function deleteImport(Import $import): void { $this->storage->delete($import->path); $import->delete(); Activity::add(ActivityType::IMPORT_DELETE, $import); } }