|
| 1 | +<?php |
| 2 | + |
| 3 | +declare(strict_types=1); |
| 4 | + |
| 5 | +/** |
| 6 | + * @copyright Copyright (c) 2022 Louis Chmn <louis@chmn.me> |
| 7 | + * |
| 8 | + * @author Louis Chmn <louis@chmn.me> |
| 9 | + * |
| 10 | + * @license GNU AGPL version 3 or any later version |
| 11 | + * |
| 12 | + * This program is free software: you can redistribute it and/or modify |
| 13 | + * it under the terms of the GNU Affero General Public License as |
| 14 | + * published by the Free Software Foundation, either version 3 of the |
| 15 | + * License, or (at your option) any later version. |
| 16 | + * |
| 17 | + * This program is distributed in the hope that it will be useful, |
| 18 | + * but WITHOUT ANY WARRANTY; without even the implied warranty of |
| 19 | + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
| 20 | + * GNU Affero General Public License for more details. |
| 21 | + * |
| 22 | + * You should have received a copy of the GNU Affero General Public License |
| 23 | + * along with this program. If not, see <http://www.gnu.org/licenses/>. |
| 24 | + * |
| 25 | + */ |
| 26 | + |
| 27 | +namespace OCA\Files\Controller; |
| 28 | + |
| 29 | +use OC\AppFramework\Bootstrap\Coordinator; |
| 30 | +use OCP\AppFramework\Http\ZipResponse; |
| 31 | +use OCP\AppFramework\Controller; |
| 32 | +use OCP\Files\File; |
| 33 | +use OCP\Files\Folder; |
| 34 | +use OCP\Files\IFileDownloadProvider; |
| 35 | +use OCP\Files\Node; |
| 36 | +use OCP\IRequest; |
| 37 | +use Psr\Log\LoggerInterface; |
| 38 | + |
| 39 | +class DownloadController extends Controller { |
| 40 | + private Coordinator $coordinator; |
| 41 | + private LoggerInterface $logger; |
| 42 | + |
| 43 | + public function __construct( |
| 44 | + string $appName, |
| 45 | + IRequest $request, |
| 46 | + Coordinator $coordinator, |
| 47 | + LoggerInterface $logger |
| 48 | + ) { |
| 49 | + parent::__construct($appName, $request); |
| 50 | + |
| 51 | + $this->request = $request; |
| 52 | + $this->coordinator = $coordinator; |
| 53 | + $this->logger = $logger; |
| 54 | + } |
| 55 | + |
| 56 | + /** |
| 57 | + * @NoAdminRequired |
| 58 | + * @NoCSRFRequired |
| 59 | + * @PublicPage |
| 60 | + */ |
| 61 | + public function index(string $files): ZipResponse { |
| 62 | + $response = new ZipResponse($this->request, 'download'); |
| 63 | + |
| 64 | + /** @var string[] */ |
| 65 | + $files = json_decode($files); |
| 66 | + |
| 67 | + if (count($files) === 0) { |
| 68 | + return $response; |
| 69 | + } |
| 70 | + |
| 71 | + $commonPrefix = $files[0]; |
| 72 | + foreach ($files as $filePath) { |
| 73 | + $commonPrefix = $this->getCommonPrefix($filePath, $commonPrefix); |
| 74 | + } |
| 75 | + |
| 76 | + $context = $this->coordinator->getRegistrationContext(); |
| 77 | + if ($context === null) { |
| 78 | + throw new \Exception("Can't get download providers"); |
| 79 | + } |
| 80 | + $providerRegistrations = $context->getFileDownloadProviders(); |
| 81 | + |
| 82 | + foreach ($files as $filePath) { |
| 83 | + $node = null; |
| 84 | + |
| 85 | + foreach ($providerRegistrations as $registration) { |
| 86 | + try { |
| 87 | + /** @var IFileDownloadProvider */ |
| 88 | + $provider = \OCP\Server::get($registration->getService()); |
| 89 | + $node = $provider->getNode($filePath); |
| 90 | + if ($node !== null) { |
| 91 | + break; |
| 92 | + } |
| 93 | + } catch (\Throwable $ex) { |
| 94 | + $providerClass = $registration->getService(); |
| 95 | + $this->logger->warning("Error while getting file content from $providerClass", ['exception' => $ex]); |
| 96 | + } |
| 97 | + } |
| 98 | + |
| 99 | + if ($node === null) { |
| 100 | + continue; |
| 101 | + } |
| 102 | + |
| 103 | + $this->addNode($response, $node, str_replace($commonPrefix, '', $filePath)); |
| 104 | + } |
| 105 | + |
| 106 | + return $response; |
| 107 | + } |
| 108 | + |
| 109 | + private function getCommonPrefix(string $str1, string $str2): string { |
| 110 | + $mbStr1 = mb_str_split($str1); |
| 111 | + $mbStr2 = mb_str_split($str2); |
| 112 | + |
| 113 | + for ($i = 0; $i < count($mbStr1); $i++) { |
| 114 | + if ($mbStr1[$i] !== $mbStr2[$i]) { |
| 115 | + $i--; |
| 116 | + break; |
| 117 | + } |
| 118 | + } |
| 119 | + |
| 120 | + if ($i < 0) { |
| 121 | + return ''; |
| 122 | + } else { |
| 123 | + return join(array_slice($mbStr1, 0, $i)); |
| 124 | + } |
| 125 | + } |
| 126 | + |
| 127 | + private function addNode(ZipResponse $response, Node $node, string $path): void { |
| 128 | + if ($node instanceof File) { |
| 129 | + $response->addResource($node->fopen('r'), $path, $node->getSize()); |
| 130 | + } |
| 131 | + |
| 132 | + if ($node instanceof Folder) { |
| 133 | + foreach ($node->getDirectoryListing() as $subnode) { |
| 134 | + $this->addNode($response, $subnode, $path.'/'.$subnode->getName()); |
| 135 | + } |
| 136 | + } |
| 137 | + } |
| 138 | +} |
0 commit comments