@@ -32,14 +32,14 @@ |
||
32 | 32 | * @since 9.1.0 |
33 | 33 | */ |
34 | 34 | class OCSBadRequestException extends OCSException { |
35 | - /** |
|
36 | - * OCSBadRequestException constructor. |
|
37 | - * |
|
38 | - * @param string $message |
|
39 | - * @param Exception|null $previous |
|
40 | - * @since 9.1.0 |
|
41 | - */ |
|
42 | - public function __construct($message = '', Exception $previous = null) { |
|
43 | - parent::__construct($message, Http::STATUS_BAD_REQUEST, $previous); |
|
44 | - } |
|
35 | + /** |
|
36 | + * OCSBadRequestException constructor. |
|
37 | + * |
|
38 | + * @param string $message |
|
39 | + * @param Exception|null $previous |
|
40 | + * @since 9.1.0 |
|
41 | + */ |
|
42 | + public function __construct($message = '', Exception $previous = null) { |
|
43 | + parent::__construct($message, Http::STATUS_BAD_REQUEST, $previous); |
|
44 | + } |
|
45 | 45 | } |
@@ -51,7 +51,7 @@ discard block |
||
51 | 51 | $this->file = $file; |
52 | 52 | $this->setStatus($statusCode); |
53 | 53 | $this->setHeaders(array_merge($this->getHeaders(), $headers)); |
54 | - $this->addHeader('Content-Disposition', 'inline; filename="' . rawurldecode($file->getName()) . '"'); |
|
54 | + $this->addHeader('Content-Disposition', 'inline; filename="'.rawurldecode($file->getName()).'"'); |
|
55 | 55 | |
56 | 56 | $this->setETag($file->getEtag()); |
57 | 57 | $lastModified = new \DateTime(); |
@@ -65,7 +65,7 @@ discard block |
||
65 | 65 | */ |
66 | 66 | public function callback(IOutput $output) { |
67 | 67 | if ($output->getHttpResponseCode() !== Http::STATUS_NOT_MODIFIED) { |
68 | - $output->setHeader('Content-Length: ' . $this->file->getSize()); |
|
68 | + $output->setHeader('Content-Length: '.$this->file->getSize()); |
|
69 | 69 | $output->setOutput($this->file->getContent()); |
70 | 70 | } |
71 | 71 | } |
@@ -32,40 +32,40 @@ |
||
32 | 32 | */ |
33 | 33 | class FileDisplayResponse extends Response implements ICallbackResponse { |
34 | 34 | |
35 | - /** @var \OCP\Files\File|\OCP\Files\SimpleFS\ISimpleFile */ |
|
36 | - private $file; |
|
35 | + /** @var \OCP\Files\File|\OCP\Files\SimpleFS\ISimpleFile */ |
|
36 | + private $file; |
|
37 | 37 | |
38 | - /** |
|
39 | - * FileDisplayResponse constructor. |
|
40 | - * |
|
41 | - * @param \OCP\Files\File|\OCP\Files\SimpleFS\ISimpleFile $file |
|
42 | - * @param int $statusCode |
|
43 | - * @param array $headers |
|
44 | - * @since 11.0.0 |
|
45 | - */ |
|
46 | - public function __construct($file, $statusCode = Http::STATUS_OK, |
|
47 | - $headers = []) { |
|
48 | - parent::__construct(); |
|
38 | + /** |
|
39 | + * FileDisplayResponse constructor. |
|
40 | + * |
|
41 | + * @param \OCP\Files\File|\OCP\Files\SimpleFS\ISimpleFile $file |
|
42 | + * @param int $statusCode |
|
43 | + * @param array $headers |
|
44 | + * @since 11.0.0 |
|
45 | + */ |
|
46 | + public function __construct($file, $statusCode = Http::STATUS_OK, |
|
47 | + $headers = []) { |
|
48 | + parent::__construct(); |
|
49 | 49 | |
50 | - $this->file = $file; |
|
51 | - $this->setStatus($statusCode); |
|
52 | - $this->setHeaders(array_merge($this->getHeaders(), $headers)); |
|
53 | - $this->addHeader('Content-Disposition', 'inline; filename="' . rawurldecode($file->getName()) . '"'); |
|
50 | + $this->file = $file; |
|
51 | + $this->setStatus($statusCode); |
|
52 | + $this->setHeaders(array_merge($this->getHeaders(), $headers)); |
|
53 | + $this->addHeader('Content-Disposition', 'inline; filename="' . rawurldecode($file->getName()) . '"'); |
|
54 | 54 | |
55 | - $this->setETag($file->getEtag()); |
|
56 | - $lastModified = new \DateTime(); |
|
57 | - $lastModified->setTimestamp($file->getMTime()); |
|
58 | - $this->setLastModified($lastModified); |
|
59 | - } |
|
55 | + $this->setETag($file->getEtag()); |
|
56 | + $lastModified = new \DateTime(); |
|
57 | + $lastModified->setTimestamp($file->getMTime()); |
|
58 | + $this->setLastModified($lastModified); |
|
59 | + } |
|
60 | 60 | |
61 | - /** |
|
62 | - * @param IOutput $output |
|
63 | - * @since 11.0.0 |
|
64 | - */ |
|
65 | - public function callback(IOutput $output) { |
|
66 | - if ($output->getHttpResponseCode() !== Http::STATUS_NOT_MODIFIED) { |
|
67 | - $output->setHeader('Content-Length: ' . $this->file->getSize()); |
|
68 | - $output->setOutput($this->file->getContent()); |
|
69 | - } |
|
70 | - } |
|
61 | + /** |
|
62 | + * @param IOutput $output |
|
63 | + * @since 11.0.0 |
|
64 | + */ |
|
65 | + public function callback(IOutput $output) { |
|
66 | + if ($output->getHttpResponseCode() !== Http::STATUS_NOT_MODIFIED) { |
|
67 | + $output->setHeader('Content-Length: ' . $this->file->getSize()); |
|
68 | + $output->setOutput($this->file->getContent()); |
|
69 | + } |
|
70 | + } |
|
71 | 71 | } |
@@ -43,7 +43,7 @@ |
||
43 | 43 | $this->filename = $filename; |
44 | 44 | $this->contentType = $contentType; |
45 | 45 | |
46 | - $this->addHeader('Content-Disposition', 'attachment; filename="' . $filename . '"'); |
|
46 | + $this->addHeader('Content-Disposition', 'attachment; filename="'.$filename.'"'); |
|
47 | 47 | $this->addHeader('Content-Type', $contentType); |
48 | 48 | } |
49 | 49 | } |
@@ -30,22 +30,22 @@ |
||
30 | 30 | * @since 7.0.0 |
31 | 31 | */ |
32 | 32 | class DownloadResponse extends Response { |
33 | - private $filename; |
|
34 | - private $contentType; |
|
33 | + private $filename; |
|
34 | + private $contentType; |
|
35 | 35 | |
36 | - /** |
|
37 | - * Creates a response that prompts the user to download the file |
|
38 | - * @param string $filename the name that the downloaded file should have |
|
39 | - * @param string $contentType the mimetype that the downloaded file should have |
|
40 | - * @since 7.0.0 |
|
41 | - */ |
|
42 | - public function __construct($filename, $contentType) { |
|
43 | - parent::__construct(); |
|
36 | + /** |
|
37 | + * Creates a response that prompts the user to download the file |
|
38 | + * @param string $filename the name that the downloaded file should have |
|
39 | + * @param string $contentType the mimetype that the downloaded file should have |
|
40 | + * @since 7.0.0 |
|
41 | + */ |
|
42 | + public function __construct($filename, $contentType) { |
|
43 | + parent::__construct(); |
|
44 | 44 | |
45 | - $this->filename = $filename; |
|
46 | - $this->contentType = $contentType; |
|
45 | + $this->filename = $filename; |
|
46 | + $this->contentType = $contentType; |
|
47 | 47 | |
48 | - $this->addHeader('Content-Disposition', 'attachment; filename="' . $filename . '"'); |
|
49 | - $this->addHeader('Content-Type', $contentType); |
|
50 | - } |
|
48 | + $this->addHeader('Content-Disposition', 'attachment; filename="' . $filename . '"'); |
|
49 | + $this->addHeader('Content-Type', $contentType); |
|
50 | + } |
|
51 | 51 | } |
@@ -68,7 +68,7 @@ |
||
68 | 68 | public function render() { |
69 | 69 | $response = json_encode($this->data, JSON_HEX_TAG); |
70 | 70 | if ($response === false) { |
71 | - throw new \Exception(sprintf('Could not json_encode due to invalid ' . |
|
71 | + throw new \Exception(sprintf('Could not json_encode due to invalid '. |
|
72 | 72 | 'non UTF-8 characters in the array: %s', var_export($this->data, true))); |
73 | 73 | } |
74 | 74 |
@@ -41,64 +41,64 @@ |
||
41 | 41 | */ |
42 | 42 | class JSONResponse extends Response { |
43 | 43 | |
44 | - /** |
|
45 | - * response data |
|
46 | - * @var array|object |
|
47 | - */ |
|
48 | - protected $data; |
|
44 | + /** |
|
45 | + * response data |
|
46 | + * @var array|object |
|
47 | + */ |
|
48 | + protected $data; |
|
49 | 49 | |
50 | 50 | |
51 | - /** |
|
52 | - * constructor of JSONResponse |
|
53 | - * @param array|object $data the object or array that should be transformed |
|
54 | - * @param int $statusCode the Http status code, defaults to 200 |
|
55 | - * @since 6.0.0 |
|
56 | - */ |
|
57 | - public function __construct($data = [], $statusCode = Http::STATUS_OK) { |
|
58 | - parent::__construct(); |
|
51 | + /** |
|
52 | + * constructor of JSONResponse |
|
53 | + * @param array|object $data the object or array that should be transformed |
|
54 | + * @param int $statusCode the Http status code, defaults to 200 |
|
55 | + * @since 6.0.0 |
|
56 | + */ |
|
57 | + public function __construct($data = [], $statusCode = Http::STATUS_OK) { |
|
58 | + parent::__construct(); |
|
59 | 59 | |
60 | - $this->data = $data; |
|
61 | - $this->setStatus($statusCode); |
|
62 | - $this->addHeader('Content-Type', 'application/json; charset=utf-8'); |
|
63 | - } |
|
60 | + $this->data = $data; |
|
61 | + $this->setStatus($statusCode); |
|
62 | + $this->addHeader('Content-Type', 'application/json; charset=utf-8'); |
|
63 | + } |
|
64 | 64 | |
65 | 65 | |
66 | - /** |
|
67 | - * Returns the rendered json |
|
68 | - * @return string the rendered json |
|
69 | - * @since 6.0.0 |
|
70 | - * @throws \Exception If data could not get encoded |
|
71 | - */ |
|
72 | - public function render() { |
|
73 | - $response = json_encode($this->data, JSON_HEX_TAG); |
|
74 | - if ($response === false) { |
|
75 | - throw new \Exception(sprintf('Could not json_encode due to invalid ' . |
|
76 | - 'non UTF-8 characters in the array: %s', var_export($this->data, true))); |
|
77 | - } |
|
66 | + /** |
|
67 | + * Returns the rendered json |
|
68 | + * @return string the rendered json |
|
69 | + * @since 6.0.0 |
|
70 | + * @throws \Exception If data could not get encoded |
|
71 | + */ |
|
72 | + public function render() { |
|
73 | + $response = json_encode($this->data, JSON_HEX_TAG); |
|
74 | + if ($response === false) { |
|
75 | + throw new \Exception(sprintf('Could not json_encode due to invalid ' . |
|
76 | + 'non UTF-8 characters in the array: %s', var_export($this->data, true))); |
|
77 | + } |
|
78 | 78 | |
79 | - return $response; |
|
80 | - } |
|
79 | + return $response; |
|
80 | + } |
|
81 | 81 | |
82 | - /** |
|
83 | - * Sets values in the data json array |
|
84 | - * @param array|object $data an array or object which will be transformed |
|
85 | - * to JSON |
|
86 | - * @return JSONResponse Reference to this object |
|
87 | - * @since 6.0.0 - return value was added in 7.0.0 |
|
88 | - */ |
|
89 | - public function setData($data) { |
|
90 | - $this->data = $data; |
|
82 | + /** |
|
83 | + * Sets values in the data json array |
|
84 | + * @param array|object $data an array or object which will be transformed |
|
85 | + * to JSON |
|
86 | + * @return JSONResponse Reference to this object |
|
87 | + * @since 6.0.0 - return value was added in 7.0.0 |
|
88 | + */ |
|
89 | + public function setData($data) { |
|
90 | + $this->data = $data; |
|
91 | 91 | |
92 | - return $this; |
|
93 | - } |
|
92 | + return $this; |
|
93 | + } |
|
94 | 94 | |
95 | 95 | |
96 | - /** |
|
97 | - * Used to get the set parameters |
|
98 | - * @return array the data |
|
99 | - * @since 6.0.0 |
|
100 | - */ |
|
101 | - public function getData() { |
|
102 | - return $this->data; |
|
103 | - } |
|
96 | + /** |
|
97 | + * Used to get the set parameters |
|
98 | + * @return array the data |
|
99 | + * @since 6.0.0 |
|
100 | + */ |
|
101 | + public function getData() { |
|
102 | + return $this->data; |
|
103 | + } |
|
104 | 104 | } |
@@ -72,7 +72,7 @@ discard block |
||
72 | 72 | $result = $this->zip->addFromString($path, $source); |
73 | 73 | } |
74 | 74 | if ($result) { |
75 | - $this->zip->close();//close and reopen to save the zip |
|
75 | + $this->zip->close(); //close and reopen to save the zip |
|
76 | 76 | $this->zip->open($this->path); |
77 | 77 | } |
78 | 78 | return $result; |
@@ -130,7 +130,7 @@ discard block |
||
130 | 130 | public function getFiles() { |
131 | 131 | $fileCount = $this->zip->numFiles; |
132 | 132 | $files = []; |
133 | - for ($i = 0;$i < $fileCount;$i++) { |
|
133 | + for ($i = 0; $i < $fileCount; $i++) { |
|
134 | 134 | $files[] = $this->zip->getNameIndex($i); |
135 | 135 | } |
136 | 136 | return $files; |
@@ -204,7 +204,7 @@ discard block |
||
204 | 204 | $this->extractFile($path, $tmpFile); |
205 | 205 | } |
206 | 206 | $handle = fopen($tmpFile, $mode); |
207 | - return CallbackWrapper::wrap($handle, null, null, function () use ($path, $tmpFile) { |
|
207 | + return CallbackWrapper::wrap($handle, null, null, function() use ($path, $tmpFile) { |
|
208 | 208 | $this->writeBack($tmpFile, $path); |
209 | 209 | }); |
210 | 210 | } |
@@ -36,199 +36,199 @@ |
||
36 | 36 | use OCP\ILogger; |
37 | 37 | |
38 | 38 | class ZIP extends Archive { |
39 | - /** |
|
40 | - * @var \ZipArchive zip |
|
41 | - */ |
|
42 | - private $zip = null; |
|
43 | - private $path; |
|
39 | + /** |
|
40 | + * @var \ZipArchive zip |
|
41 | + */ |
|
42 | + private $zip = null; |
|
43 | + private $path; |
|
44 | 44 | |
45 | - /** |
|
46 | - * @param string $source |
|
47 | - */ |
|
48 | - public function __construct($source) { |
|
49 | - $this->path = $source; |
|
50 | - $this->zip = new \ZipArchive(); |
|
51 | - if ($this->zip->open($source, \ZipArchive::CREATE)) { |
|
52 | - } else { |
|
53 | - \OCP\Util::writeLog('files_archive', 'Error while opening archive '.$source, ILogger::WARN); |
|
54 | - } |
|
55 | - } |
|
56 | - /** |
|
57 | - * add an empty folder to the archive |
|
58 | - * @param string $path |
|
59 | - * @return bool |
|
60 | - */ |
|
61 | - public function addFolder($path) { |
|
62 | - return $this->zip->addEmptyDir($path); |
|
63 | - } |
|
64 | - /** |
|
65 | - * add a file to the archive |
|
66 | - * @param string $path |
|
67 | - * @param string $source either a local file or string data |
|
68 | - * @return bool |
|
69 | - */ |
|
70 | - public function addFile($path, $source = '') { |
|
71 | - if ($source and $source[0] == '/' and file_exists($source)) { |
|
72 | - $result = $this->zip->addFile($source, $path); |
|
73 | - } else { |
|
74 | - $result = $this->zip->addFromString($path, $source); |
|
75 | - } |
|
76 | - if ($result) { |
|
77 | - $this->zip->close();//close and reopen to save the zip |
|
78 | - $this->zip->open($this->path); |
|
79 | - } |
|
80 | - return $result; |
|
81 | - } |
|
82 | - /** |
|
83 | - * rename a file or folder in the archive |
|
84 | - * @param string $source |
|
85 | - * @param string $dest |
|
86 | - * @return boolean|null |
|
87 | - */ |
|
88 | - public function rename($source, $dest) { |
|
89 | - $source = $this->stripPath($source); |
|
90 | - $dest = $this->stripPath($dest); |
|
91 | - $this->zip->renameName($source, $dest); |
|
92 | - } |
|
93 | - /** |
|
94 | - * get the uncompressed size of a file in the archive |
|
95 | - * @param string $path |
|
96 | - * @return int |
|
97 | - */ |
|
98 | - public function filesize($path) { |
|
99 | - $stat = $this->zip->statName($path); |
|
100 | - return $stat['size']; |
|
101 | - } |
|
102 | - /** |
|
103 | - * get the last modified time of a file in the archive |
|
104 | - * @param string $path |
|
105 | - * @return int |
|
106 | - */ |
|
107 | - public function mtime($path) { |
|
108 | - return filemtime($this->path); |
|
109 | - } |
|
110 | - /** |
|
111 | - * get the files in a folder |
|
112 | - * @param string $path |
|
113 | - * @return array |
|
114 | - */ |
|
115 | - public function getFolder($path) { |
|
116 | - $files = $this->getFiles(); |
|
117 | - $folderContent = []; |
|
118 | - $pathLength = strlen($path); |
|
119 | - foreach ($files as $file) { |
|
120 | - if (substr($file, 0, $pathLength) == $path and $file != $path) { |
|
121 | - if (strrpos(substr($file, 0, -1), '/') <= $pathLength) { |
|
122 | - $folderContent[] = substr($file, $pathLength); |
|
123 | - } |
|
124 | - } |
|
125 | - } |
|
126 | - return $folderContent; |
|
127 | - } |
|
128 | - /** |
|
129 | - * get all files in the archive |
|
130 | - * @return array |
|
131 | - */ |
|
132 | - public function getFiles() { |
|
133 | - $fileCount = $this->zip->numFiles; |
|
134 | - $files = []; |
|
135 | - for ($i = 0;$i < $fileCount;$i++) { |
|
136 | - $files[] = $this->zip->getNameIndex($i); |
|
137 | - } |
|
138 | - return $files; |
|
139 | - } |
|
140 | - /** |
|
141 | - * get the content of a file |
|
142 | - * @param string $path |
|
143 | - * @return string |
|
144 | - */ |
|
145 | - public function getFile($path) { |
|
146 | - return $this->zip->getFromName($path); |
|
147 | - } |
|
148 | - /** |
|
149 | - * extract a single file from the archive |
|
150 | - * @param string $path |
|
151 | - * @param string $dest |
|
152 | - * @return boolean|null |
|
153 | - */ |
|
154 | - public function extractFile($path, $dest) { |
|
155 | - $fp = $this->zip->getStream($path); |
|
156 | - file_put_contents($dest, $fp); |
|
157 | - } |
|
158 | - /** |
|
159 | - * extract the archive |
|
160 | - * @param string $dest |
|
161 | - * @return bool |
|
162 | - */ |
|
163 | - public function extract($dest) { |
|
164 | - return $this->zip->extractTo($dest); |
|
165 | - } |
|
166 | - /** |
|
167 | - * check if a file or folder exists in the archive |
|
168 | - * @param string $path |
|
169 | - * @return bool |
|
170 | - */ |
|
171 | - public function fileExists($path) { |
|
172 | - return ($this->zip->locateName($path) !== false) or ($this->zip->locateName($path.'/') !== false); |
|
173 | - } |
|
174 | - /** |
|
175 | - * remove a file or folder from the archive |
|
176 | - * @param string $path |
|
177 | - * @return bool |
|
178 | - */ |
|
179 | - public function remove($path) { |
|
180 | - if ($this->fileExists($path.'/')) { |
|
181 | - return $this->zip->deleteName($path.'/'); |
|
182 | - } else { |
|
183 | - return $this->zip->deleteName($path); |
|
184 | - } |
|
185 | - } |
|
186 | - /** |
|
187 | - * get a file handler |
|
188 | - * @param string $path |
|
189 | - * @param string $mode |
|
190 | - * @return bool|resource |
|
191 | - */ |
|
192 | - public function getStream($path, $mode) { |
|
193 | - if ($mode == 'r' or $mode == 'rb') { |
|
194 | - return $this->zip->getStream($path); |
|
195 | - } else { |
|
196 | - //since we can't directly get a writable stream, |
|
197 | - //make a temp copy of the file and put it back |
|
198 | - //in the archive when the stream is closed |
|
199 | - if (strrpos($path, '.') !== false) { |
|
200 | - $ext = substr($path, strrpos($path, '.')); |
|
201 | - } else { |
|
202 | - $ext = ''; |
|
203 | - } |
|
204 | - $tmpFile = \OC::$server->getTempManager()->getTemporaryFile($ext); |
|
205 | - if ($this->fileExists($path)) { |
|
206 | - $this->extractFile($path, $tmpFile); |
|
207 | - } |
|
208 | - $handle = fopen($tmpFile, $mode); |
|
209 | - return CallbackWrapper::wrap($handle, null, null, function () use ($path, $tmpFile) { |
|
210 | - $this->writeBack($tmpFile, $path); |
|
211 | - }); |
|
212 | - } |
|
213 | - } |
|
45 | + /** |
|
46 | + * @param string $source |
|
47 | + */ |
|
48 | + public function __construct($source) { |
|
49 | + $this->path = $source; |
|
50 | + $this->zip = new \ZipArchive(); |
|
51 | + if ($this->zip->open($source, \ZipArchive::CREATE)) { |
|
52 | + } else { |
|
53 | + \OCP\Util::writeLog('files_archive', 'Error while opening archive '.$source, ILogger::WARN); |
|
54 | + } |
|
55 | + } |
|
56 | + /** |
|
57 | + * add an empty folder to the archive |
|
58 | + * @param string $path |
|
59 | + * @return bool |
|
60 | + */ |
|
61 | + public function addFolder($path) { |
|
62 | + return $this->zip->addEmptyDir($path); |
|
63 | + } |
|
64 | + /** |
|
65 | + * add a file to the archive |
|
66 | + * @param string $path |
|
67 | + * @param string $source either a local file or string data |
|
68 | + * @return bool |
|
69 | + */ |
|
70 | + public function addFile($path, $source = '') { |
|
71 | + if ($source and $source[0] == '/' and file_exists($source)) { |
|
72 | + $result = $this->zip->addFile($source, $path); |
|
73 | + } else { |
|
74 | + $result = $this->zip->addFromString($path, $source); |
|
75 | + } |
|
76 | + if ($result) { |
|
77 | + $this->zip->close();//close and reopen to save the zip |
|
78 | + $this->zip->open($this->path); |
|
79 | + } |
|
80 | + return $result; |
|
81 | + } |
|
82 | + /** |
|
83 | + * rename a file or folder in the archive |
|
84 | + * @param string $source |
|
85 | + * @param string $dest |
|
86 | + * @return boolean|null |
|
87 | + */ |
|
88 | + public function rename($source, $dest) { |
|
89 | + $source = $this->stripPath($source); |
|
90 | + $dest = $this->stripPath($dest); |
|
91 | + $this->zip->renameName($source, $dest); |
|
92 | + } |
|
93 | + /** |
|
94 | + * get the uncompressed size of a file in the archive |
|
95 | + * @param string $path |
|
96 | + * @return int |
|
97 | + */ |
|
98 | + public function filesize($path) { |
|
99 | + $stat = $this->zip->statName($path); |
|
100 | + return $stat['size']; |
|
101 | + } |
|
102 | + /** |
|
103 | + * get the last modified time of a file in the archive |
|
104 | + * @param string $path |
|
105 | + * @return int |
|
106 | + */ |
|
107 | + public function mtime($path) { |
|
108 | + return filemtime($this->path); |
|
109 | + } |
|
110 | + /** |
|
111 | + * get the files in a folder |
|
112 | + * @param string $path |
|
113 | + * @return array |
|
114 | + */ |
|
115 | + public function getFolder($path) { |
|
116 | + $files = $this->getFiles(); |
|
117 | + $folderContent = []; |
|
118 | + $pathLength = strlen($path); |
|
119 | + foreach ($files as $file) { |
|
120 | + if (substr($file, 0, $pathLength) == $path and $file != $path) { |
|
121 | + if (strrpos(substr($file, 0, -1), '/') <= $pathLength) { |
|
122 | + $folderContent[] = substr($file, $pathLength); |
|
123 | + } |
|
124 | + } |
|
125 | + } |
|
126 | + return $folderContent; |
|
127 | + } |
|
128 | + /** |
|
129 | + * get all files in the archive |
|
130 | + * @return array |
|
131 | + */ |
|
132 | + public function getFiles() { |
|
133 | + $fileCount = $this->zip->numFiles; |
|
134 | + $files = []; |
|
135 | + for ($i = 0;$i < $fileCount;$i++) { |
|
136 | + $files[] = $this->zip->getNameIndex($i); |
|
137 | + } |
|
138 | + return $files; |
|
139 | + } |
|
140 | + /** |
|
141 | + * get the content of a file |
|
142 | + * @param string $path |
|
143 | + * @return string |
|
144 | + */ |
|
145 | + public function getFile($path) { |
|
146 | + return $this->zip->getFromName($path); |
|
147 | + } |
|
148 | + /** |
|
149 | + * extract a single file from the archive |
|
150 | + * @param string $path |
|
151 | + * @param string $dest |
|
152 | + * @return boolean|null |
|
153 | + */ |
|
154 | + public function extractFile($path, $dest) { |
|
155 | + $fp = $this->zip->getStream($path); |
|
156 | + file_put_contents($dest, $fp); |
|
157 | + } |
|
158 | + /** |
|
159 | + * extract the archive |
|
160 | + * @param string $dest |
|
161 | + * @return bool |
|
162 | + */ |
|
163 | + public function extract($dest) { |
|
164 | + return $this->zip->extractTo($dest); |
|
165 | + } |
|
166 | + /** |
|
167 | + * check if a file or folder exists in the archive |
|
168 | + * @param string $path |
|
169 | + * @return bool |
|
170 | + */ |
|
171 | + public function fileExists($path) { |
|
172 | + return ($this->zip->locateName($path) !== false) or ($this->zip->locateName($path.'/') !== false); |
|
173 | + } |
|
174 | + /** |
|
175 | + * remove a file or folder from the archive |
|
176 | + * @param string $path |
|
177 | + * @return bool |
|
178 | + */ |
|
179 | + public function remove($path) { |
|
180 | + if ($this->fileExists($path.'/')) { |
|
181 | + return $this->zip->deleteName($path.'/'); |
|
182 | + } else { |
|
183 | + return $this->zip->deleteName($path); |
|
184 | + } |
|
185 | + } |
|
186 | + /** |
|
187 | + * get a file handler |
|
188 | + * @param string $path |
|
189 | + * @param string $mode |
|
190 | + * @return bool|resource |
|
191 | + */ |
|
192 | + public function getStream($path, $mode) { |
|
193 | + if ($mode == 'r' or $mode == 'rb') { |
|
194 | + return $this->zip->getStream($path); |
|
195 | + } else { |
|
196 | + //since we can't directly get a writable stream, |
|
197 | + //make a temp copy of the file and put it back |
|
198 | + //in the archive when the stream is closed |
|
199 | + if (strrpos($path, '.') !== false) { |
|
200 | + $ext = substr($path, strrpos($path, '.')); |
|
201 | + } else { |
|
202 | + $ext = ''; |
|
203 | + } |
|
204 | + $tmpFile = \OC::$server->getTempManager()->getTemporaryFile($ext); |
|
205 | + if ($this->fileExists($path)) { |
|
206 | + $this->extractFile($path, $tmpFile); |
|
207 | + } |
|
208 | + $handle = fopen($tmpFile, $mode); |
|
209 | + return CallbackWrapper::wrap($handle, null, null, function () use ($path, $tmpFile) { |
|
210 | + $this->writeBack($tmpFile, $path); |
|
211 | + }); |
|
212 | + } |
|
213 | + } |
|
214 | 214 | |
215 | - /** |
|
216 | - * write back temporary files |
|
217 | - */ |
|
218 | - public function writeBack($tmpFile, $path) { |
|
219 | - $this->addFile($path, $tmpFile); |
|
220 | - unlink($tmpFile); |
|
221 | - } |
|
215 | + /** |
|
216 | + * write back temporary files |
|
217 | + */ |
|
218 | + public function writeBack($tmpFile, $path) { |
|
219 | + $this->addFile($path, $tmpFile); |
|
220 | + unlink($tmpFile); |
|
221 | + } |
|
222 | 222 | |
223 | - /** |
|
224 | - * @param string $path |
|
225 | - * @return string |
|
226 | - */ |
|
227 | - private function stripPath($path) { |
|
228 | - if (!$path || $path[0] == '/') { |
|
229 | - return substr($path, 1); |
|
230 | - } else { |
|
231 | - return $path; |
|
232 | - } |
|
233 | - } |
|
223 | + /** |
|
224 | + * @param string $path |
|
225 | + * @return string |
|
226 | + */ |
|
227 | + private function stripPath($path) { |
|
228 | + if (!$path || $path[0] == '/') { |
|
229 | + return substr($path, 1); |
|
230 | + } else { |
|
231 | + return $path; |
|
232 | + } |
|
233 | + } |
|
234 | 234 | } |
@@ -35,17 +35,17 @@ |
||
35 | 35 | } |
36 | 36 | |
37 | 37 | $excludedFolders = [ |
38 | - rtrim($root . '/data', '/'), |
|
39 | - rtrim($root . '/themes', '/'), |
|
40 | - rtrim($root . '/config', '/'), |
|
41 | - rtrim($root . '/apps', '/'), |
|
42 | - rtrim($root . '/assets', '/'), |
|
43 | - rtrim($root . '/lost+found', '/'), |
|
38 | + rtrim($root.'/data', '/'), |
|
39 | + rtrim($root.'/themes', '/'), |
|
40 | + rtrim($root.'/config', '/'), |
|
41 | + rtrim($root.'/apps', '/'), |
|
42 | + rtrim($root.'/assets', '/'), |
|
43 | + rtrim($root.'/lost+found', '/'), |
|
44 | 44 | // Ignore folders generated by updater since the updater is replaced |
45 | 45 | // after the integrity check is run. |
46 | 46 | // See https://github.com/owncloud/updater/issues/318#issuecomment-212497846 |
47 | - rtrim($root . '/updater', '/'), |
|
48 | - rtrim($root . '/_oc_upgrade', '/'), |
|
47 | + rtrim($root.'/updater', '/'), |
|
48 | + rtrim($root.'/_oc_upgrade', '/'), |
|
49 | 49 | ]; |
50 | 50 | $customDataDir = \OC::$server->getConfig()->getSystemValue('datadirectory', ''); |
51 | 51 | if ($customDataDir !== '') { |
@@ -28,45 +28,45 @@ |
||
28 | 28 | namespace OC\IntegrityCheck\Iterator; |
29 | 29 | |
30 | 30 | class ExcludeFoldersByPathFilterIterator extends \RecursiveFilterIterator { |
31 | - private $excludedFolders; |
|
31 | + private $excludedFolders; |
|
32 | 32 | |
33 | - public function __construct(\RecursiveIterator $iterator, $root = '') { |
|
34 | - parent::__construct($iterator); |
|
33 | + public function __construct(\RecursiveIterator $iterator, $root = '') { |
|
34 | + parent::__construct($iterator); |
|
35 | 35 | |
36 | - $appFolders = \OC::$APPSROOTS; |
|
37 | - foreach ($appFolders as $key => $appFolder) { |
|
38 | - $appFolders[$key] = rtrim($appFolder['path'], '/'); |
|
39 | - } |
|
36 | + $appFolders = \OC::$APPSROOTS; |
|
37 | + foreach ($appFolders as $key => $appFolder) { |
|
38 | + $appFolders[$key] = rtrim($appFolder['path'], '/'); |
|
39 | + } |
|
40 | 40 | |
41 | - $excludedFolders = [ |
|
42 | - rtrim($root . '/data', '/'), |
|
43 | - rtrim($root . '/themes', '/'), |
|
44 | - rtrim($root . '/config', '/'), |
|
45 | - rtrim($root . '/apps', '/'), |
|
46 | - rtrim($root . '/assets', '/'), |
|
47 | - rtrim($root . '/lost+found', '/'), |
|
48 | - // Ignore folders generated by updater since the updater is replaced |
|
49 | - // after the integrity check is run. |
|
50 | - // See https://github.com/owncloud/updater/issues/318#issuecomment-212497846 |
|
51 | - rtrim($root . '/updater', '/'), |
|
52 | - rtrim($root . '/_oc_upgrade', '/'), |
|
53 | - ]; |
|
54 | - $customDataDir = \OC::$server->getConfig()->getSystemValue('datadirectory', ''); |
|
55 | - if ($customDataDir !== '') { |
|
56 | - $excludedFolders[] = rtrim($customDataDir, '/'); |
|
57 | - } |
|
41 | + $excludedFolders = [ |
|
42 | + rtrim($root . '/data', '/'), |
|
43 | + rtrim($root . '/themes', '/'), |
|
44 | + rtrim($root . '/config', '/'), |
|
45 | + rtrim($root . '/apps', '/'), |
|
46 | + rtrim($root . '/assets', '/'), |
|
47 | + rtrim($root . '/lost+found', '/'), |
|
48 | + // Ignore folders generated by updater since the updater is replaced |
|
49 | + // after the integrity check is run. |
|
50 | + // See https://github.com/owncloud/updater/issues/318#issuecomment-212497846 |
|
51 | + rtrim($root . '/updater', '/'), |
|
52 | + rtrim($root . '/_oc_upgrade', '/'), |
|
53 | + ]; |
|
54 | + $customDataDir = \OC::$server->getConfig()->getSystemValue('datadirectory', ''); |
|
55 | + if ($customDataDir !== '') { |
|
56 | + $excludedFolders[] = rtrim($customDataDir, '/'); |
|
57 | + } |
|
58 | 58 | |
59 | - $this->excludedFolders = array_merge($excludedFolders, $appFolders); |
|
60 | - } |
|
59 | + $this->excludedFolders = array_merge($excludedFolders, $appFolders); |
|
60 | + } |
|
61 | 61 | |
62 | - /** |
|
63 | - * @return bool |
|
64 | - */ |
|
65 | - public function accept() { |
|
66 | - return !\in_array( |
|
67 | - $this->current()->getPathName(), |
|
68 | - $this->excludedFolders, |
|
69 | - true |
|
70 | - ); |
|
71 | - } |
|
62 | + /** |
|
63 | + * @return bool |
|
64 | + */ |
|
65 | + public function accept() { |
|
66 | + return !\in_array( |
|
67 | + $this->current()->getPathName(), |
|
68 | + $this->excludedFolders, |
|
69 | + true |
|
70 | + ); |
|
71 | + } |
|
72 | 72 | } |
@@ -32,7 +32,7 @@ |
||
32 | 32 | * @return bool |
33 | 33 | */ |
34 | 34 | private function isValidVersionString($versionString) { |
35 | - return (bool)preg_match('/^[0-9.]+$/', $versionString); |
|
35 | + return (bool) preg_match('/^[0-9.]+$/', $versionString); |
|
36 | 36 | } |
37 | 37 | |
38 | 38 | /** |
@@ -30,56 +30,56 @@ |
||
30 | 30 | * @package OC\App\AppStore |
31 | 31 | */ |
32 | 32 | class VersionParser { |
33 | - /** |
|
34 | - * @param string $versionString |
|
35 | - * @return bool |
|
36 | - */ |
|
37 | - private function isValidVersionString($versionString) { |
|
38 | - return (bool)preg_match('/^[0-9.]+$/', $versionString); |
|
39 | - } |
|
33 | + /** |
|
34 | + * @param string $versionString |
|
35 | + * @return bool |
|
36 | + */ |
|
37 | + private function isValidVersionString($versionString) { |
|
38 | + return (bool)preg_match('/^[0-9.]+$/', $versionString); |
|
39 | + } |
|
40 | 40 | |
41 | - /** |
|
42 | - * Returns the version for a version string |
|
43 | - * |
|
44 | - * @param string $versionSpec |
|
45 | - * @return Version |
|
46 | - * @throws \Exception If the version cannot be parsed |
|
47 | - */ |
|
48 | - public function getVersion($versionSpec) { |
|
49 | - // * indicates that the version is compatible with all versions |
|
50 | - if ($versionSpec === '*') { |
|
51 | - return new Version('', ''); |
|
52 | - } |
|
41 | + /** |
|
42 | + * Returns the version for a version string |
|
43 | + * |
|
44 | + * @param string $versionSpec |
|
45 | + * @return Version |
|
46 | + * @throws \Exception If the version cannot be parsed |
|
47 | + */ |
|
48 | + public function getVersion($versionSpec) { |
|
49 | + // * indicates that the version is compatible with all versions |
|
50 | + if ($versionSpec === '*') { |
|
51 | + return new Version('', ''); |
|
52 | + } |
|
53 | 53 | |
54 | - // Count the amount of =, if it is one then it's either maximum or minimum |
|
55 | - // version. If it is two then it is maximum and minimum. |
|
56 | - $versionElements = explode(' ', $versionSpec); |
|
57 | - $firstVersion = isset($versionElements[0]) ? $versionElements[0] : ''; |
|
58 | - $firstVersionNumber = substr($firstVersion, 2); |
|
59 | - $secondVersion = isset($versionElements[1]) ? $versionElements[1] : ''; |
|
60 | - $secondVersionNumber = substr($secondVersion, 2); |
|
54 | + // Count the amount of =, if it is one then it's either maximum or minimum |
|
55 | + // version. If it is two then it is maximum and minimum. |
|
56 | + $versionElements = explode(' ', $versionSpec); |
|
57 | + $firstVersion = isset($versionElements[0]) ? $versionElements[0] : ''; |
|
58 | + $firstVersionNumber = substr($firstVersion, 2); |
|
59 | + $secondVersion = isset($versionElements[1]) ? $versionElements[1] : ''; |
|
60 | + $secondVersionNumber = substr($secondVersion, 2); |
|
61 | 61 | |
62 | - switch (count($versionElements)) { |
|
63 | - case 1: |
|
64 | - if (!$this->isValidVersionString($firstVersionNumber)) { |
|
65 | - break; |
|
66 | - } |
|
67 | - if (strpos($firstVersion, '>') === 0) { |
|
68 | - return new Version($firstVersionNumber, ''); |
|
69 | - } |
|
70 | - return new Version('', $firstVersionNumber); |
|
71 | - case 2: |
|
72 | - if (!$this->isValidVersionString($firstVersionNumber) || !$this->isValidVersionString($secondVersionNumber)) { |
|
73 | - break; |
|
74 | - } |
|
75 | - return new Version($firstVersionNumber, $secondVersionNumber); |
|
76 | - } |
|
62 | + switch (count($versionElements)) { |
|
63 | + case 1: |
|
64 | + if (!$this->isValidVersionString($firstVersionNumber)) { |
|
65 | + break; |
|
66 | + } |
|
67 | + if (strpos($firstVersion, '>') === 0) { |
|
68 | + return new Version($firstVersionNumber, ''); |
|
69 | + } |
|
70 | + return new Version('', $firstVersionNumber); |
|
71 | + case 2: |
|
72 | + if (!$this->isValidVersionString($firstVersionNumber) || !$this->isValidVersionString($secondVersionNumber)) { |
|
73 | + break; |
|
74 | + } |
|
75 | + return new Version($firstVersionNumber, $secondVersionNumber); |
|
76 | + } |
|
77 | 77 | |
78 | - throw new \Exception( |
|
79 | - sprintf( |
|
80 | - 'Version cannot be parsed: %s', |
|
81 | - $versionSpec |
|
82 | - ) |
|
83 | - ); |
|
84 | - } |
|
78 | + throw new \Exception( |
|
79 | + sprintf( |
|
80 | + 'Version cannot be parsed: %s', |
|
81 | + $versionSpec |
|
82 | + ) |
|
83 | + ); |
|
84 | + } |
|
85 | 85 | } |
@@ -24,36 +24,36 @@ |
||
24 | 24 | use OCP\IL10N; |
25 | 25 | |
26 | 26 | abstract class Bundle { |
27 | - /** @var IL10N */ |
|
28 | - protected $l10n; |
|
27 | + /** @var IL10N */ |
|
28 | + protected $l10n; |
|
29 | 29 | |
30 | - /** |
|
31 | - * @param IL10N $l10n |
|
32 | - */ |
|
33 | - public function __construct(IL10N $l10n) { |
|
34 | - $this->l10n = $l10n; |
|
35 | - } |
|
30 | + /** |
|
31 | + * @param IL10N $l10n |
|
32 | + */ |
|
33 | + public function __construct(IL10N $l10n) { |
|
34 | + $this->l10n = $l10n; |
|
35 | + } |
|
36 | 36 | |
37 | - /** |
|
38 | - * Get the identifier of the bundle |
|
39 | - * |
|
40 | - * @return string |
|
41 | - */ |
|
42 | - final public function getIdentifier() { |
|
43 | - return substr(strrchr(get_class($this), '\\'), 1); |
|
44 | - } |
|
37 | + /** |
|
38 | + * Get the identifier of the bundle |
|
39 | + * |
|
40 | + * @return string |
|
41 | + */ |
|
42 | + final public function getIdentifier() { |
|
43 | + return substr(strrchr(get_class($this), '\\'), 1); |
|
44 | + } |
|
45 | 45 | |
46 | - /** |
|
47 | - * Get the name of the bundle |
|
48 | - * |
|
49 | - * @return string |
|
50 | - */ |
|
51 | - abstract public function getName(); |
|
46 | + /** |
|
47 | + * Get the name of the bundle |
|
48 | + * |
|
49 | + * @return string |
|
50 | + */ |
|
51 | + abstract public function getName(); |
|
52 | 52 | |
53 | - /** |
|
54 | - * Get the list of app identifiers in the bundle |
|
55 | - * |
|
56 | - * @return array |
|
57 | - */ |
|
58 | - abstract public function getAppIdentifiers(); |
|
53 | + /** |
|
54 | + * Get the list of app identifiers in the bundle |
|
55 | + * |
|
56 | + * @return array |
|
57 | + */ |
|
58 | + abstract public function getAppIdentifiers(); |
|
59 | 59 | } |
@@ -66,7 +66,7 @@ |
||
66 | 66 | /** @var IShare[] $deletedShares */ |
67 | 67 | $deletedShares = $e->getArgument('deletedShares'); |
68 | 68 | |
69 | - $formattedDeletedShares = array_map(function ($share) { |
|
69 | + $formattedDeletedShares = array_map(function($share) { |
|
70 | 70 | return $this->formatHookParams($share); |
71 | 71 | }, $deletedShares); |
72 | 72 |
@@ -34,144 +34,144 @@ |
||
34 | 34 | |
35 | 35 | class LegacyHooks { |
36 | 36 | |
37 | - /** @var EventDispatcherInterface */ |
|
38 | - private $eventDispatcher; |
|
39 | - |
|
40 | - /** |
|
41 | - * LegacyHooks constructor. |
|
42 | - * |
|
43 | - * @param EventDispatcherInterface $eventDispatcher |
|
44 | - */ |
|
45 | - public function __construct(EventDispatcherInterface $eventDispatcher) { |
|
46 | - $this->eventDispatcher = $eventDispatcher; |
|
47 | - |
|
48 | - $this->eventDispatcher->addListener('OCP\Share::preUnshare', [$this, 'preUnshare']); |
|
49 | - $this->eventDispatcher->addListener('OCP\Share::postUnshare', [$this, 'postUnshare']); |
|
50 | - $this->eventDispatcher->addListener('OCP\Share::postUnshareFromSelf', [$this, 'postUnshareFromSelf']); |
|
51 | - $this->eventDispatcher->addListener('OCP\Share::preShare', [$this, 'preShare']); |
|
52 | - $this->eventDispatcher->addListener('OCP\Share::postShare', [$this, 'postShare']); |
|
53 | - } |
|
54 | - |
|
55 | - /** |
|
56 | - * @param GenericEvent $e |
|
57 | - */ |
|
58 | - public function preUnshare(GenericEvent $e) { |
|
59 | - /** @var IShare $share */ |
|
60 | - $share = $e->getSubject(); |
|
61 | - |
|
62 | - $formatted = $this->formatHookParams($share); |
|
63 | - \OC_Hook::emit(Share::class, 'pre_unshare', $formatted); |
|
64 | - } |
|
65 | - |
|
66 | - /** |
|
67 | - * @param GenericEvent $e |
|
68 | - */ |
|
69 | - public function postUnshare(GenericEvent $e) { |
|
70 | - /** @var IShare $share */ |
|
71 | - $share = $e->getSubject(); |
|
72 | - |
|
73 | - $formatted = $this->formatHookParams($share); |
|
74 | - |
|
75 | - /** @var IShare[] $deletedShares */ |
|
76 | - $deletedShares = $e->getArgument('deletedShares'); |
|
77 | - |
|
78 | - $formattedDeletedShares = array_map(function ($share) { |
|
79 | - return $this->formatHookParams($share); |
|
80 | - }, $deletedShares); |
|
81 | - |
|
82 | - $formatted['deletedShares'] = $formattedDeletedShares; |
|
83 | - |
|
84 | - \OC_Hook::emit(Share::class, 'post_unshare', $formatted); |
|
85 | - } |
|
86 | - |
|
87 | - /** |
|
88 | - * @param GenericEvent $e |
|
89 | - */ |
|
90 | - public function postUnshareFromSelf(GenericEvent $e) { |
|
91 | - /** @var IShare $share */ |
|
92 | - $share = $e->getSubject(); |
|
93 | - |
|
94 | - $formatted = $this->formatHookParams($share); |
|
95 | - $formatted['itemTarget'] = $formatted['fileTarget']; |
|
96 | - $formatted['unsharedItems'] = [$formatted]; |
|
97 | - |
|
98 | - \OC_Hook::emit(Share::class, 'post_unshareFromSelf', $formatted); |
|
99 | - } |
|
100 | - |
|
101 | - private function formatHookParams(IShare $share) { |
|
102 | - // Prepare hook |
|
103 | - $shareType = $share->getShareType(); |
|
104 | - $sharedWith = ''; |
|
105 | - if ($shareType === IShare::TYPE_USER || |
|
106 | - $shareType === IShare::TYPE_GROUP || |
|
107 | - $shareType === IShare::TYPE_REMOTE) { |
|
108 | - $sharedWith = $share->getSharedWith(); |
|
109 | - } |
|
110 | - |
|
111 | - $hookParams = [ |
|
112 | - 'id' => $share->getId(), |
|
113 | - 'itemType' => $share->getNodeType(), |
|
114 | - 'itemSource' => $share->getNodeId(), |
|
115 | - 'shareType' => $shareType, |
|
116 | - 'shareWith' => $sharedWith, |
|
117 | - 'itemparent' => method_exists($share, 'getParent') ? $share->getParent() : '', |
|
118 | - 'uidOwner' => $share->getSharedBy(), |
|
119 | - 'fileSource' => $share->getNodeId(), |
|
120 | - 'fileTarget' => $share->getTarget() |
|
121 | - ]; |
|
122 | - return $hookParams; |
|
123 | - } |
|
124 | - |
|
125 | - public function preShare(GenericEvent $e) { |
|
126 | - /** @var IShare $share */ |
|
127 | - $share = $e->getSubject(); |
|
128 | - |
|
129 | - // Pre share hook |
|
130 | - $run = true; |
|
131 | - $error = ''; |
|
132 | - $preHookData = [ |
|
133 | - 'itemType' => $share->getNode() instanceof File ? 'file' : 'folder', |
|
134 | - 'itemSource' => $share->getNode()->getId(), |
|
135 | - 'shareType' => $share->getShareType(), |
|
136 | - 'uidOwner' => $share->getSharedBy(), |
|
137 | - 'permissions' => $share->getPermissions(), |
|
138 | - 'fileSource' => $share->getNode()->getId(), |
|
139 | - 'expiration' => $share->getExpirationDate(), |
|
140 | - 'token' => $share->getToken(), |
|
141 | - 'itemTarget' => $share->getTarget(), |
|
142 | - 'shareWith' => $share->getSharedWith(), |
|
143 | - 'run' => &$run, |
|
144 | - 'error' => &$error, |
|
145 | - ]; |
|
146 | - \OC_Hook::emit(Share::class, 'pre_shared', $preHookData); |
|
147 | - |
|
148 | - if ($run === false) { |
|
149 | - $e->setArgument('error', $error); |
|
150 | - $e->stopPropagation(); |
|
151 | - } |
|
152 | - |
|
153 | - return $e; |
|
154 | - } |
|
155 | - |
|
156 | - public function postShare(GenericEvent $e) { |
|
157 | - /** @var IShare $share */ |
|
158 | - $share = $e->getSubject(); |
|
159 | - |
|
160 | - $postHookData = [ |
|
161 | - 'itemType' => $share->getNode() instanceof File ? 'file' : 'folder', |
|
162 | - 'itemSource' => $share->getNode()->getId(), |
|
163 | - 'shareType' => $share->getShareType(), |
|
164 | - 'uidOwner' => $share->getSharedBy(), |
|
165 | - 'permissions' => $share->getPermissions(), |
|
166 | - 'fileSource' => $share->getNode()->getId(), |
|
167 | - 'expiration' => $share->getExpirationDate(), |
|
168 | - 'token' => $share->getToken(), |
|
169 | - 'id' => $share->getId(), |
|
170 | - 'shareWith' => $share->getSharedWith(), |
|
171 | - 'itemTarget' => $share->getTarget(), |
|
172 | - 'fileTarget' => $share->getTarget(), |
|
173 | - ]; |
|
174 | - |
|
175 | - \OC_Hook::emit(Share::class, 'post_shared', $postHookData); |
|
176 | - } |
|
37 | + /** @var EventDispatcherInterface */ |
|
38 | + private $eventDispatcher; |
|
39 | + |
|
40 | + /** |
|
41 | + * LegacyHooks constructor. |
|
42 | + * |
|
43 | + * @param EventDispatcherInterface $eventDispatcher |
|
44 | + */ |
|
45 | + public function __construct(EventDispatcherInterface $eventDispatcher) { |
|
46 | + $this->eventDispatcher = $eventDispatcher; |
|
47 | + |
|
48 | + $this->eventDispatcher->addListener('OCP\Share::preUnshare', [$this, 'preUnshare']); |
|
49 | + $this->eventDispatcher->addListener('OCP\Share::postUnshare', [$this, 'postUnshare']); |
|
50 | + $this->eventDispatcher->addListener('OCP\Share::postUnshareFromSelf', [$this, 'postUnshareFromSelf']); |
|
51 | + $this->eventDispatcher->addListener('OCP\Share::preShare', [$this, 'preShare']); |
|
52 | + $this->eventDispatcher->addListener('OCP\Share::postShare', [$this, 'postShare']); |
|
53 | + } |
|
54 | + |
|
55 | + /** |
|
56 | + * @param GenericEvent $e |
|
57 | + */ |
|
58 | + public function preUnshare(GenericEvent $e) { |
|
59 | + /** @var IShare $share */ |
|
60 | + $share = $e->getSubject(); |
|
61 | + |
|
62 | + $formatted = $this->formatHookParams($share); |
|
63 | + \OC_Hook::emit(Share::class, 'pre_unshare', $formatted); |
|
64 | + } |
|
65 | + |
|
66 | + /** |
|
67 | + * @param GenericEvent $e |
|
68 | + */ |
|
69 | + public function postUnshare(GenericEvent $e) { |
|
70 | + /** @var IShare $share */ |
|
71 | + $share = $e->getSubject(); |
|
72 | + |
|
73 | + $formatted = $this->formatHookParams($share); |
|
74 | + |
|
75 | + /** @var IShare[] $deletedShares */ |
|
76 | + $deletedShares = $e->getArgument('deletedShares'); |
|
77 | + |
|
78 | + $formattedDeletedShares = array_map(function ($share) { |
|
79 | + return $this->formatHookParams($share); |
|
80 | + }, $deletedShares); |
|
81 | + |
|
82 | + $formatted['deletedShares'] = $formattedDeletedShares; |
|
83 | + |
|
84 | + \OC_Hook::emit(Share::class, 'post_unshare', $formatted); |
|
85 | + } |
|
86 | + |
|
87 | + /** |
|
88 | + * @param GenericEvent $e |
|
89 | + */ |
|
90 | + public function postUnshareFromSelf(GenericEvent $e) { |
|
91 | + /** @var IShare $share */ |
|
92 | + $share = $e->getSubject(); |
|
93 | + |
|
94 | + $formatted = $this->formatHookParams($share); |
|
95 | + $formatted['itemTarget'] = $formatted['fileTarget']; |
|
96 | + $formatted['unsharedItems'] = [$formatted]; |
|
97 | + |
|
98 | + \OC_Hook::emit(Share::class, 'post_unshareFromSelf', $formatted); |
|
99 | + } |
|
100 | + |
|
101 | + private function formatHookParams(IShare $share) { |
|
102 | + // Prepare hook |
|
103 | + $shareType = $share->getShareType(); |
|
104 | + $sharedWith = ''; |
|
105 | + if ($shareType === IShare::TYPE_USER || |
|
106 | + $shareType === IShare::TYPE_GROUP || |
|
107 | + $shareType === IShare::TYPE_REMOTE) { |
|
108 | + $sharedWith = $share->getSharedWith(); |
|
109 | + } |
|
110 | + |
|
111 | + $hookParams = [ |
|
112 | + 'id' => $share->getId(), |
|
113 | + 'itemType' => $share->getNodeType(), |
|
114 | + 'itemSource' => $share->getNodeId(), |
|
115 | + 'shareType' => $shareType, |
|
116 | + 'shareWith' => $sharedWith, |
|
117 | + 'itemparent' => method_exists($share, 'getParent') ? $share->getParent() : '', |
|
118 | + 'uidOwner' => $share->getSharedBy(), |
|
119 | + 'fileSource' => $share->getNodeId(), |
|
120 | + 'fileTarget' => $share->getTarget() |
|
121 | + ]; |
|
122 | + return $hookParams; |
|
123 | + } |
|
124 | + |
|
125 | + public function preShare(GenericEvent $e) { |
|
126 | + /** @var IShare $share */ |
|
127 | + $share = $e->getSubject(); |
|
128 | + |
|
129 | + // Pre share hook |
|
130 | + $run = true; |
|
131 | + $error = ''; |
|
132 | + $preHookData = [ |
|
133 | + 'itemType' => $share->getNode() instanceof File ? 'file' : 'folder', |
|
134 | + 'itemSource' => $share->getNode()->getId(), |
|
135 | + 'shareType' => $share->getShareType(), |
|
136 | + 'uidOwner' => $share->getSharedBy(), |
|
137 | + 'permissions' => $share->getPermissions(), |
|
138 | + 'fileSource' => $share->getNode()->getId(), |
|
139 | + 'expiration' => $share->getExpirationDate(), |
|
140 | + 'token' => $share->getToken(), |
|
141 | + 'itemTarget' => $share->getTarget(), |
|
142 | + 'shareWith' => $share->getSharedWith(), |
|
143 | + 'run' => &$run, |
|
144 | + 'error' => &$error, |
|
145 | + ]; |
|
146 | + \OC_Hook::emit(Share::class, 'pre_shared', $preHookData); |
|
147 | + |
|
148 | + if ($run === false) { |
|
149 | + $e->setArgument('error', $error); |
|
150 | + $e->stopPropagation(); |
|
151 | + } |
|
152 | + |
|
153 | + return $e; |
|
154 | + } |
|
155 | + |
|
156 | + public function postShare(GenericEvent $e) { |
|
157 | + /** @var IShare $share */ |
|
158 | + $share = $e->getSubject(); |
|
159 | + |
|
160 | + $postHookData = [ |
|
161 | + 'itemType' => $share->getNode() instanceof File ? 'file' : 'folder', |
|
162 | + 'itemSource' => $share->getNode()->getId(), |
|
163 | + 'shareType' => $share->getShareType(), |
|
164 | + 'uidOwner' => $share->getSharedBy(), |
|
165 | + 'permissions' => $share->getPermissions(), |
|
166 | + 'fileSource' => $share->getNode()->getId(), |
|
167 | + 'expiration' => $share->getExpirationDate(), |
|
168 | + 'token' => $share->getToken(), |
|
169 | + 'id' => $share->getId(), |
|
170 | + 'shareWith' => $share->getSharedWith(), |
|
171 | + 'itemTarget' => $share->getTarget(), |
|
172 | + 'fileTarget' => $share->getTarget(), |
|
173 | + ]; |
|
174 | + |
|
175 | + \OC_Hook::emit(Share::class, 'post_shared', $postHookData); |
|
176 | + } |
|
177 | 177 | } |