1: | <?php |
2: | |
3: | |
4: | |
5: | |
6: | |
7: | |
8: | namespace Aurora\Modules\PersonalFiles; |
9: | |
10: | use Afterlogic\DAV\Constants; |
11: | use Afterlogic\DAV\FS\Directory; |
12: | use Afterlogic\DAV\FS\File; |
13: | use Afterlogic\DAV\FS\Shared\File as SharedFile; |
14: | use Afterlogic\DAV\FS\Shared\Directory as SharedDirectory; |
15: | use Afterlogic\DAV\Server; |
16: | use Aurora\Api; |
17: | use Aurora\Modules\Core\Module as CoreModule; |
18: | use Aurora\Modules\Files\Classes\FileItem; |
19: | use Aurora\Modules\Files\Enums\ErrorCodes; |
20: | use Aurora\Modules\Files\Module as FilesModule; |
21: | use Aurora\System\Exceptions\ApiException; |
22: | |
23: | |
24: | |
25: | |
26: | |
27: | |
28: | |
29: | |
30: | |
31: | |
32: | class Module extends \Aurora\System\Module\AbstractModule |
33: | { |
34: | protected static $sStorageType = 'personal'; |
35: | protected static $iStorageOrder = 0; |
36: | |
37: | |
38: | |
39: | |
40: | |
41: | protected static $bIsDroppable = true; |
42: | |
43: | protected $oBeforeDeleteUserRootPath = ''; |
44: | protected $oBeforeDeleteUser = null; |
45: | |
46: | |
47: | |
48: | |
49: | public $oManager = null; |
50: | |
51: | |
52: | |
53: | |
54: | |
55: | protected $oMinModuleDecorator = null; |
56: | |
57: | public function getManager() |
58: | { |
59: | if ($this->oManager === null) { |
60: | $this->oManager = new Manager($this); |
61: | } |
62: | |
63: | return $this->oManager; |
64: | } |
65: | |
66: | |
67: | |
68: | |
69: | public static function getInstance() |
70: | { |
71: | return parent::getInstance(); |
72: | } |
73: | |
74: | |
75: | |
76: | |
77: | public static function Decorator() |
78: | { |
79: | return parent::Decorator(); |
80: | } |
81: | |
82: | |
83: | |
84: | |
85: | public function getModuleSettings() |
86: | { |
87: | return $this->oModuleSettings; |
88: | } |
89: | |
90: | |
91: | |
92: | |
93: | |
94: | |
95: | public function init() |
96: | { |
97: | ini_set('default_charset', 'UTF-8'); |
98: | |
99: | $this->subscribeEvent('Files::GetFile', array($this, 'onGetFile')); |
100: | $this->subscribeEvent('Files::CreateFile', array($this, 'onCreateFile')); |
101: | $this->subscribeEvent('Files::GetLinkType', array($this, 'onGetLinkType')); |
102: | $this->subscribeEvent('Files::CheckUrl', array($this, 'onCheckUrl')); |
103: | |
104: | $this->subscribeEvent('Files::GetStorages::after', array($this, 'onAfterGetStorages')); |
105: | $this->subscribeEvent('Files::GetFileInfo::after', array($this, 'onAfterGetFileInfo'), 10); |
106: | $this->subscribeEvent('Files::GetItems', array($this, 'onGetItems')); |
107: | $this->subscribeEvent('Files::CreateFolder::after', array($this, 'onAfterCreateFolder')); |
108: | $this->subscribeEvent('Files::Copy::after', array($this, 'onAfterCopy')); |
109: | $this->subscribeEvent('Files::Move::after', array($this, 'onAfterMove')); |
110: | $this->subscribeEvent('Files::Rename::after', array($this, 'onAfterRename')); |
111: | $this->subscribeEvent('Files::Delete::after', array($this, 'onAfterDelete')); |
112: | $this->subscribeEvent('Files::GetQuota::after', array($this, 'onAfterGetQuota')); |
113: | $this->subscribeEvent('Files::CreateLink::after', array($this, 'onAfterCreateLink')); |
114: | $this->subscribeEvent('Files::CreatePublicLink::after', array($this, 'onAfterCreatePublicLink')); |
115: | $this->subscribeEvent('Files::GetFileContent::after', array($this, 'onAfterGetFileContent')); |
116: | $this->subscribeEvent('Files::IsFileExists::after', array($this, 'onAfterIsFileExists')); |
117: | $this->subscribeEvent('Files::PopulateFileItem::after', array($this, 'onAfterPopulateFileItem')); |
118: | $this->subscribeEvent('Files::CheckQuota::after', array($this, 'onAfterCheckQuota')); |
119: | $this->subscribeEvent('Files::DeletePublicLink::after', array($this, 'onAfterDeletePublicLink')); |
120: | $this->subscribeEvent('Files::GetSubModules::after', array($this, 'onAfterGetSubModules')); |
121: | $this->subscribeEvent('Files::UpdateExtendedProps::after', array($this, 'onAfterUpdateExtendedProps')); |
122: | $this->subscribeEvent('Files::GetExtendedProps::after', array($this, 'onAfterGetExtendedProps')); |
123: | |
124: | $this->subscribeEvent('Core::DeleteUser::before', array($this, 'onBeforeDeleteUser')); |
125: | $this->subscribeEvent('Core::DeleteUser::after', array($this, 'onAfterDeleteUser')); |
126: | |
127: | $this->subscribeEvent('Files::GetNonExistentFileName::after', array($this, 'onAfterGetNonExistentFileName')); |
128: | |
129: | $this->subscribeEvent('Files::GetAccessInfoForPath::after', array($this, 'onAfterGetAccessInfoForPath')); |
130: | } |
131: | |
132: | |
133: | |
134: | |
135: | |
136: | |
137: | public function GetSettings() |
138: | { |
139: | Api::checkUserRoleIsAtLeast(\Aurora\System\Enums\UserRole::Anonymous); |
140: | |
141: | return array( |
142: | 'UserSpaceLimitMb' => $this->getUserSpaceLimitMb(), |
143: | ); |
144: | } |
145: | |
146: | |
147: | |
148: | |
149: | |
150: | |
151: | |
152: | public function UpdateSettings($UserSpaceLimitMb) |
153: | { |
154: | Api::checkUserRoleIsAtLeast(\Aurora\System\Enums\UserRole::TenantAdmin); |
155: | |
156: | FilesModule::getInstance()->setConfig('UserSpaceLimitMb', $UserSpaceLimitMb); |
157: | return (bool) FilesModule::getInstance()->saveModuleConfig(); |
158: | } |
159: | |
160: | public function UpdateUsedSpace() |
161: | { |
162: | $iResult = 0; |
163: | Api::checkUserRoleIsAtLeast(\Aurora\System\Enums\UserRole::NormalUser); |
164: | $oUser = Api::getAuthenticatedUser(); |
165: | |
166: | if ($oUser) { |
167: | $iResult = $this->getManager()->getUserSpaceUsed($oUser->PublicId, [\Aurora\System\Enums\FileStorageType::Personal]); |
168: | $oUser->setExtendedProp(self::GetName() . '::UsedSpace', $iResult); |
169: | $oUser->save(); |
170: | } |
171: | |
172: | return $iResult; |
173: | } |
174: | |
175: | |
176: | |
177: | |
178: | |
179: | |
180: | private function getMinModuleDecorator() |
181: | { |
182: | return Api::GetModuleDecorator('Min'); |
183: | } |
184: | |
185: | |
186: | |
187: | |
188: | |
189: | |
190: | |
191: | protected function checkStorageType($Type) |
192: | { |
193: | return $Type === static::$sStorageType; |
194: | } |
195: | |
196: | |
197: | |
198: | |
199: | |
200: | |
201: | protected function getHtmlTitle($sUrl) |
202: | { |
203: | $oCurl = curl_init(); |
204: | \curl_setopt_array($oCurl, array( |
205: | CURLOPT_URL => $sUrl, |
206: | CURLOPT_FOLLOWLOCATION => true, |
207: | CURLOPT_ENCODING => '', |
208: | CURLOPT_RETURNTRANSFER => true, |
209: | CURLOPT_AUTOREFERER => true, |
210: | CURLOPT_SSL_VERIFYPEER => false, |
211: | CURLOPT_CONNECTTIMEOUT => 5, |
212: | CURLOPT_TIMEOUT => 5, |
213: | CURLOPT_MAXREDIRS => 5 |
214: | )); |
215: | $sContent = curl_exec($oCurl); |
216: | |
217: | curl_close($oCurl); |
218: | |
219: | preg_match('/<title>(.*?)<\/title>/s', $sContent, $aTitle); |
220: | return isset($aTitle['1']) ? trim($aTitle['1']) : ''; |
221: | } |
222: | |
223: | |
224: | |
225: | |
226: | |
227: | |
228: | |
229: | |
230: | protected function isFileAllowed($FileName) |
231: | { |
232: | $forbiddenFileList = [ |
233: | '.sabredav' |
234: | ]; |
235: | |
236: | $FileName = \trim(\MailSo\Base\Utils::ClearFileName($FileName)); |
237: | |
238: | $result = !in_array($FileName, $forbiddenFileList); |
239: | |
240: | return $result; |
241: | } |
242: | |
243: | |
244: | |
245: | |
246: | |
247: | |
248: | |
249: | public function onGetFile($aArgs, &$mResult) |
250: | { |
251: | if ($this->checkStorageType($aArgs['Type'])) { |
252: | $UserId = $aArgs['UserId']; |
253: | |
254: | $sUserPiblicId = Api::getUserPublicIdById($UserId); |
255: | $iOffset = isset($aArgs['Offset']) ? $aArgs['Offset'] : 0; |
256: | $iChunkSizet = isset($aArgs['ChunkSize']) ? $aArgs['ChunkSize'] : 0; |
257: | |
258: | try { |
259: | $mResult = $this->getManager()->getFile($sUserPiblicId, $aArgs['Type'], $aArgs['Path'], $aArgs['Id'], $iOffset, $iChunkSizet); |
260: | } catch (\Sabre\DAV\Exception\NotFound $oEx) { |
261: | $mResult = false; |
262: | |
263: | $this->oHttp->StatusHeader(404); |
264: | exit; |
265: | } |
266: | |
267: | return true; |
268: | } |
269: | } |
270: | |
271: | |
272: | |
273: | |
274: | |
275: | |
276: | |
277: | public function onCreateFile($aArgs, &$mResult) |
278: | { |
279: | if ($this->checkStorageType($aArgs['Type'])) { |
280: | if (!self::isFileAllowed($aArgs['Name'])) { |
281: | throw new \Aurora\System\Exceptions\ApiException(\Aurora\System\Notifications::CanNotUploadFileErrorData); |
282: | } |
283: | |
284: | $UserId = $aArgs['UserId']; |
285: | Api::CheckAccess($UserId); |
286: | |
287: | $currentUser = Server::getUser(); |
288: | Server::setUser(Api::getUserPublicIdById($UserId)); |
289: | $mResult = $this->getManager()->createFile( |
290: | Api::getUserPublicIdById($UserId), |
291: | isset($aArgs['Type']) ? $aArgs['Type'] : null, |
292: | isset($aArgs['Path']) ? $aArgs['Path'] : null, |
293: | isset($aArgs['Name']) ? $aArgs['Name'] : null, |
294: | isset($aArgs['Data']) ? $aArgs['Data'] : null, |
295: | isset($aArgs['Overwrite']) ? $aArgs['Overwrite'] : null, |
296: | isset($aArgs['RangeType']) ? $aArgs['RangeType'] : null, |
297: | isset($aArgs['Offset']) ? $aArgs['Offset'] : null, |
298: | isset($aArgs['ExtendedProps']) ? $aArgs['ExtendedProps'] : null |
299: | ); |
300: | Server::setUser($currentUser); |
301: | |
302: | self::Decorator()->UpdateUsedSpace(); |
303: | return true; |
304: | } |
305: | } |
306: | |
307: | |
308: | |
309: | |
310: | |
311: | |
312: | public function onGetLinkType($aArgs, &$mResult) |
313: | { |
314: | $mResult = ''; |
315: | } |
316: | |
317: | |
318: | |
319: | |
320: | |
321: | |
322: | public function onCheckUrl($aArgs, &$mResult) |
323: | { |
324: | $iUserId = Api::getAuthenticatedUserId(); |
325: | |
326: | if ($iUserId) { |
327: | if (!empty($aArgs['Url'])) { |
328: | $sUrl = $aArgs['Url']; |
329: | if ($sUrl) { |
330: | $aRemoteFileInfo = \Aurora\System\Utils::GetRemoteFileInfo($sUrl); |
331: | if ((int)$aRemoteFileInfo['code'] > 0) { |
332: | $sFileName = basename($sUrl); |
333: | $sFileExtension = \Aurora\System\Utils::GetFileExtension($sFileName); |
334: | |
335: | if (empty($sFileExtension)) { |
336: | $sFileExtension = \Aurora\System\Utils::GetFileExtensionFromMimeContentType($aRemoteFileInfo['content-type']); |
337: | $sFileName .= '.' . $sFileExtension; |
338: | } |
339: | |
340: | if ($sFileExtension === 'htm' || $sFileExtension === 'html') { |
341: | $sTitle = $this->getHtmlTitle($sUrl); |
342: | } |
343: | |
344: | $mResult['Name'] = isset($sTitle) && strlen($sTitle) > 0 ? $sTitle : urldecode($sFileName); |
345: | $mResult['Size'] = $aRemoteFileInfo['size']; |
346: | } |
347: | } |
348: | } |
349: | } |
350: | } |
351: | |
352: | |
353: | |
354: | |
355: | |
356: | |
357: | |
358: | public function onAfterPopulateFileItem($aArgs, &$oItem) |
359: | { |
360: | if ($oItem->IsLink) { |
361: | $sFileName = basename($oItem->LinkUrl); |
362: | $sFileExtension = \Aurora\System\Utils::GetFileExtension($sFileName); |
363: | if ($sFileExtension === 'htm' || $sFileExtension === 'html') { |
364: | |
365: | return true; |
366: | } |
367: | } |
368: | |
369: | return false; |
370: | } |
371: | |
372: | |
373: | |
374: | |
375: | |
376: | |
377: | public function onBeforeDeleteUser($aArgs, &$mResult) |
378: | { |
379: | if (isset($aArgs['UserId'])) { |
380: | $this->oBeforeDeleteUser = Api::getUserById($aArgs['UserId']); |
381: | if ($this->oBeforeDeleteUser) { |
382: | $this->oBeforeDeleteUserRootPath = $this->getManager()->oStorage->getRootPath($this->oBeforeDeleteUser->PublicId, \Aurora\System\Enums\FileStorageType::Personal, true); |
383: | } |
384: | } |
385: | } |
386: | |
387: | |
388: | |
389: | |
390: | |
391: | |
392: | public function onAfterDeleteUser($aArgs, $mResult) |
393: | { |
394: | if ($mResult && !empty($this->oBeforeDeleteUserRootPath)) { |
395: | \Aurora\System\Utils::RecRmdir($this->oBeforeDeleteUserRootPath); |
396: | $this->oBeforeDeleteUserRootPath = ''; |
397: | } |
398: | } |
399: | |
400: | |
401: | |
402: | |
403: | |
404: | |
405: | public function onAfterGetStorages($aArgs, &$mResult) |
406: | { |
407: | array_unshift($mResult, [ |
408: | 'Type' => static::$sStorageType, |
409: | 'DisplayName' => $this->i18N('LABEL_STORAGE'), |
410: | 'IsExternal' => false, |
411: | 'Order' => static::$iStorageOrder, |
412: | 'IsDroppable' => static::$bIsDroppable |
413: | ]); |
414: | } |
415: | |
416: | |
417: | |
418: | |
419: | |
420: | |
421: | public function onAfterGetSubModules($aArgs, &$mResult) |
422: | { |
423: | array_unshift($mResult, 'local.' . static::$sStorageType); |
424: | } |
425: | |
426: | |
427: | |
428: | |
429: | |
430: | |
431: | public function onGetItems($aArgs, &$mResult) |
432: | { |
433: | if ($this->checkStorageType($aArgs['Type'])) { |
434: | $UserId = $aArgs['UserId']; |
435: | Api::CheckAccess($UserId); |
436: | |
437: | $sUserPiblicId = Api::getUserPublicIdById($UserId); |
438: | $sHash = isset($aArgs['PublicHash']) ? $aArgs['PublicHash'] : null; |
439: | $bIsShared = isset($aArgs['Shared']) ? !!$aArgs['Shared'] : false; |
440: | $mResult = array_merge( |
441: | $mResult, |
442: | $this->getManager()->getFiles( |
443: | $sUserPiblicId, |
444: | $aArgs['Type'], |
445: | $aArgs['Path'], |
446: | $aArgs['Pattern'], |
447: | $sHash, |
448: | $bIsShared |
449: | ) |
450: | ); |
451: | } |
452: | } |
453: | |
454: | |
455: | |
456: | |
457: | |
458: | |
459: | public function onAfterGetFileContent($aArgs, &$mResult) |
460: | { |
461: | $UserId = $aArgs['UserId']; |
462: | Api::CheckAccess($UserId); |
463: | |
464: | $sUUID = Api::getUserPublicIdById($UserId); |
465: | $Type = $aArgs['Type']; |
466: | $Path = $aArgs['Path']; |
467: | $Name = $aArgs['Name']; |
468: | |
469: | $mFile = $this->getManager()->getFile($sUUID, $Type, $Path, $Name); |
470: | if (is_resource($mFile)) { |
471: | $mResult = stream_get_contents($mFile); |
472: | } |
473: | } |
474: | |
475: | |
476: | |
477: | |
478: | |
479: | |
480: | public function onAfterGetFileInfo($aArgs, &$mResult) |
481: | { |
482: | if ($this->checkStorageType($aArgs['Type'])) { |
483: | $UserId = $aArgs['UserId']; |
484: | Api::CheckAccess($UserId); |
485: | |
486: | $sUserPiblicId = Api::getUserPublicIdById($UserId); |
487: | $mResult = $this->getManager()->getFileInfo($sUserPiblicId, $aArgs['Type'], $aArgs['Path'], $aArgs['Id']); |
488: | |
489: | |
490: | } |
491: | } |
492: | |
493: | |
494: | |
495: | |
496: | |
497: | |
498: | public function onAfterCreateFolder(&$aArgs, &$mResult) |
499: | { |
500: | $UserId = $aArgs['UserId']; |
501: | Api::CheckAccess($UserId); |
502: | $sUserPiblicId = Api::getUserPublicIdById($UserId); |
503: | if ($this->checkStorageType($aArgs['Type'])) { |
504: | $mResult = $this->getManager()->createFolder($sUserPiblicId, $aArgs['Type'], $aArgs['Path'], $aArgs['FolderName']); |
505: | return true; |
506: | } |
507: | } |
508: | |
509: | |
510: | |
511: | |
512: | |
513: | |
514: | public function onAfterCreateLink($aArgs, &$mResult) |
515: | { |
516: | Api::checkUserRoleIsAtLeast(\Aurora\System\Enums\UserRole::NormalUser); |
517: | |
518: | if ($this->checkStorageType($aArgs['Type'])) { |
519: | $Type = $aArgs['Type']; |
520: | $UserId = $aArgs['UserId']; |
521: | $Path = $aArgs['Path']; |
522: | $Name = $aArgs['Name']; |
523: | $Link = $aArgs['Link']; |
524: | |
525: | Api::CheckAccess($UserId); |
526: | |
527: | if (substr($Link, 0, 11) === 'javascript:') { |
528: | $Link = substr($Link, 11); |
529: | } |
530: | |
531: | $sUserPiblicId = Api::getUserPublicIdById($UserId); |
532: | if ($this->checkStorageType($Type)) { |
533: | $Name = \trim(\MailSo\Base\Utils::ClearFileName($Name)); |
534: | $mResult = $this->getManager()->createLink($sUserPiblicId, $Type, $Path, $Link, $Name); |
535: | self::Decorator()->UpdateUsedSpace(); |
536: | } |
537: | } |
538: | } |
539: | |
540: | |
541: | |
542: | |
543: | |
544: | |
545: | public function onAfterDelete(&$aArgs, &$mResult) |
546: | { |
547: | $UserId = $aArgs['UserId']; |
548: | Api::CheckAccess($UserId); |
549: | if ($this->checkStorageType($aArgs['Type'])) { |
550: | $mResult = false; |
551: | |
552: | foreach ($aArgs['Items'] as $aItem) { |
553: | try { |
554: | $oNode = Server::getNodeForPath(Constants::FILESTORAGE_PATH_ROOT . '/' . $aArgs['Type'] . '/' . $aItem['Path'] . '/' . $aItem['Name']); |
555: | } catch (\Exception $oEx) { |
556: | Api::LogException($oEx); |
557: | throw new ApiException(ErrorCodes::NotFound, $oEx, "Node not found"); |
558: | } |
559: | |
560: | if (!$oNode) { |
561: | throw new ApiException(ErrorCodes::NotFound, null, "Node not found"); |
562: | } |
563: | |
564: | if ($oNode instanceof \Afterlogic\DAV\FS\Shared\File || $oNode instanceof \Afterlogic\DAV\FS\Shared\Directory) { |
565: | if (!$oNode->isInherited()) { |
566: | throw new ApiException(ErrorCodes::CantDeleteSharedItem); |
567: | } |
568: | } |
569: | |
570: | \Afterlogic\DAV\Server::deleteNode('files/' . $aArgs['Type'] . '/' . $aItem['Path'] . '/' . $aItem['Name']); |
571: | |
572: | $oItem = new FileItem(); |
573: | $oItem->Id = $aItem['Name']; |
574: | $oItem->Name = $aItem['Name']; |
575: | $oItem->TypeStr = $aArgs['Type']; |
576: | $oItem->Path = $aItem['Path']; |
577: | |
578: | FilesModule::Decorator()->DeletePublicLink($UserId, $aArgs['Type'], $aItem['Path'], $aItem['Name']); |
579: | \Aurora\System\Managers\Thumb::RemoveFromCache($UserId, $oItem->getHash(), $aItem['Name']); |
580: | |
581: | $mResult = true; |
582: | } |
583: | |
584: | self::Decorator()->UpdateUsedSpace(); |
585: | } |
586: | } |
587: | |
588: | |
589: | |
590: | |
591: | |
592: | |
593: | public function onAfterRename(&$aArgs, &$mResult) |
594: | { |
595: | if ($this->checkStorageType($aArgs['Type'])) { |
596: | $UserId = $aArgs['UserId']; |
597: | Api::CheckAccess($UserId); |
598: | |
599: | if (!self::isFileAllowed($aArgs['Name'])) { |
600: | throw new \Aurora\System\Exceptions\ApiException(\Aurora\System\Notifications::CanNotUploadFileErrorData); |
601: | } |
602: | |
603: | $sUserPiblicId = Api::getUserPublicIdById($UserId); |
604: | $sNewName = \trim(\MailSo\Base\Utils::ClearFileName($aArgs['NewName'])); |
605: | |
606: | |
607: | $bIsLink = isset($aArgs['IsLink']) ? $aArgs['IsLink'] : false; |
608: | $mResult = $this->getManager()->rename($sUserPiblicId, $aArgs['Type'], $aArgs['Path'], $aArgs['Name'], $sNewName, $bIsLink); |
609: | } |
610: | } |
611: | |
612: | |
613: | |
614: | |
615: | |
616: | |
617: | public function onAfterCopy(&$aArgs, &$mResult) |
618: | { |
619: | $UserId = $aArgs['UserId']; |
620: | Api::CheckAccess($UserId); |
621: | |
622: | $sUserPiblicId = Api::getUserPublicIdById($UserId); |
623: | |
624: | if ($this->checkStorageType($aArgs['FromType'])) { |
625: | foreach ($aArgs['Files'] as $aItem) { |
626: | $bFolderIntoItself = isset($aItem['IsFolder']) && $aItem['IsFolder'] && $aArgs['ToPath'] === $aItem['FromPath'] . '/' . $aItem['Name']; |
627: | if (!$bFolderIntoItself) { |
628: | $sNewName = isset($aItem['NewName']) ? $aItem['NewName'] : $aItem['Name']; |
629: | $mResult = $this->getManager()->copy( |
630: | $sUserPiblicId, |
631: | $aItem['FromType'], |
632: | $aArgs['ToType'], |
633: | $aItem['FromPath'], |
634: | $aArgs['ToPath'], |
635: | $aItem['Name'], |
636: | $this->getManager()->getNonExistentFileName( |
637: | $sUserPiblicId, |
638: | $aArgs['ToType'], |
639: | $aArgs['ToPath'], |
640: | $sNewName |
641: | ) |
642: | ); |
643: | } |
644: | } |
645: | self::Decorator()->UpdateUsedSpace(); |
646: | } |
647: | } |
648: | |
649: | |
650: | |
651: | |
652: | |
653: | |
654: | public function onAfterMove(&$aArgs, &$mResult) |
655: | { |
656: | if ($this->checkStorageType($aArgs['FromType'])) { |
657: | $UserId = $aArgs['UserId']; |
658: | Api::CheckAccess($UserId); |
659: | |
660: | $sUserPiblicId = Api::getUserPublicIdById($UserId); |
661: | foreach ($aArgs['Files'] as $key => $aItem) { |
662: | $bIntoItself = $aArgs['ToType'] . '/' . $aArgs['ToPath'] === $aItem['FromType'] . '/' . $aItem['FromPath']; |
663: | |
664: | if (!$bIntoItself) { |
665: | $sNewName = isset($aItem['NewName']) ? $aItem['NewName'] : $aItem['Name']; |
666: | |
667: | if (!self::IsFileAllowed(basename($sNewName))) { |
668: | throw new \Aurora\System\Exceptions\ApiException(\Aurora\System\Notifications::CanNotUploadFileErrorData); |
669: | } |
670: | |
671: | $sNewName = $this->getManager()->getNonExistentFileName( |
672: | $sUserPiblicId, |
673: | $aArgs['ToType'], |
674: | $aArgs['ToPath'], |
675: | $sNewName |
676: | ); |
677: | $aArgs['Files'][$key]['NewName'] = $sNewName; |
678: | $mResult = $this->getManager()->copy( |
679: | $sUserPiblicId, |
680: | $aItem['FromType'], |
681: | $aArgs['ToType'], |
682: | $aItem['FromPath'], |
683: | $aArgs['ToPath'], |
684: | $aItem['Name'], |
685: | $sNewName, |
686: | true |
687: | ); |
688: | } else { |
689: | throw new ApiException(ErrorCodes::CannotCopyOrMoveItemToItself); |
690: | } |
691: | } |
692: | |
693: | self::Decorator()->UpdateUsedSpace(); |
694: | } |
695: | } |
696: | |
697: | protected function getUserSpaceLimitMb() |
698: | { |
699: | $iSpaceLimitMb = FilesModule::getInstance()->oModuleSettings->UserSpaceLimitMb; |
700: | |
701: | $iUserId = Api::getAuthenticatedUserId(); |
702: | $oUser = CoreModule::Decorator()->GetUserWithoutRoleCheck($iUserId); |
703: | |
704: | if ($oUser) { |
705: | $iSpaceLimitMb = $oUser->getExtendedProp('Files::UserSpaceLimitMb'); |
706: | } |
707: | |
708: | $aArgs = [ |
709: | 'UserId' => $iUserId |
710: | ]; |
711: | $this->broadcastEvent( |
712: | 'GetUserSpaceLimitMb', |
713: | $aArgs, |
714: | $iSpaceLimitMb |
715: | ); |
716: | return $iSpaceLimitMb; |
717: | } |
718: | |
719: | |
720: | |
721: | |
722: | |
723: | |
724: | public function onAfterGetQuota($aArgs, &$mResult) |
725: | { |
726: | if ($this->checkStorageType($aArgs['Type'])) { |
727: | $iSize = 0; |
728: | |
729: | $oUser = CoreModule::Decorator()->GetUserWithoutRoleCheck($aArgs['UserId']); |
730: | |
731: | if ($oUser) { |
732: | $iSize = null !== $oUser->getExtendedProp(self::GetName() . '::UsedSpace') ? $oUser->getExtendedProp(self::GetName() . '::UsedSpace') : 0; |
733: | } |
734: | |
735: | $mResult = array( |
736: | 'Used' => (int) $iSize, |
737: | 'Limit' => $this->getUserSpaceLimitMb() * 1024 * 1024 |
738: | ); |
739: | } |
740: | } |
741: | |
742: | |
743: | |
744: | |
745: | |
746: | |
747: | |
748: | public function onAfterCreatePublicLink($aArgs, &$mResult) |
749: | { |
750: | if ($this->checkStorageType($aArgs['Type'])) { |
751: | $UserId = (int) $aArgs['UserId']; |
752: | $Type = $aArgs['Type']; |
753: | $Path = $aArgs['Path']; |
754: | $Name = $aArgs['Name']; |
755: | $Size = $aArgs['Size']; |
756: | $IsFolder = $aArgs['IsFolder']; |
757: | |
758: | Api::CheckAccess($UserId); |
759: | |
760: | Api::checkUserRoleIsAtLeast(\Aurora\System\Enums\UserRole::NormalUser); |
761: | $sUserPiblicId = Api::getUserPublicIdById($UserId); |
762: | $bFolder = (bool) $IsFolder; |
763: | $mResult = $this->getManager()->createPublicLink($sUserPiblicId, $Type, $Path, $Name, $Size, $bFolder); |
764: | self::Decorator()->UpdateUsedSpace(); |
765: | } |
766: | } |
767: | |
768: | |
769: | |
770: | |
771: | |
772: | |
773: | |
774: | public function onAfterDeletePublicLink($aArgs, &$mResult) |
775: | { |
776: | if ($this->checkStorageType($aArgs['Type'])) { |
777: | $UserId = $aArgs['UserId']; |
778: | $Type = $aArgs['Type']; |
779: | $Path = $aArgs['Path']; |
780: | $Name = $aArgs['Name']; |
781: | |
782: | Api::CheckAccess($UserId); |
783: | |
784: | Api::checkUserRoleIsAtLeast(\Aurora\System\Enums\UserRole::NormalUser); |
785: | |
786: | $sUserPiblicId = Api::getUserPublicIdById($UserId); |
787: | |
788: | $mResult = $this->getManager()->deletePublicLink($sUserPiblicId, $Type, $Path, $Name); |
789: | self::Decorator()->UpdateUsedSpace(); |
790: | } |
791: | } |
792: | |
793: | |
794: | |
795: | |
796: | |
797: | |
798: | public function onAfterIsFileExists($aArgs, &$mResult) |
799: | { |
800: | if (isset($aArgs['Type']) && $this->checkStorageType($aArgs['Type'])) { |
801: | $UserId = $aArgs['UserId']; |
802: | Api::CheckAccess($UserId); |
803: | |
804: | $mResult = $this->getManager()->isFileExists( |
805: | Api::getUserPublicIdById($UserId), |
806: | $aArgs['Type'], |
807: | $aArgs['Path'], |
808: | $aArgs['Name'] |
809: | ); |
810: | } |
811: | } |
812: | |
813: | |
814: | |
815: | |
816: | |
817: | |
818: | public function onAfterCheckQuota($aArgs, &$mResult) |
819: | { |
820: | $Type = $aArgs['Type']; |
821: | if ($this->checkStorageType($Type)) { |
822: | $sUserId = $aArgs['UserId']; |
823: | $iSize = (int) $aArgs['Size']; |
824: | $aQuota = FilesModule::Decorator()->GetQuota($sUserId, $Type); |
825: | $Limit = (int) $aQuota['Limit']; |
826: | $Used = (int) $aQuota['Used']; |
827: | $mResult = !($Limit > 0 && $Used + $iSize > $Limit); |
828: | return true; |
829: | } |
830: | } |
831: | |
832: | |
833: | |
834: | |
835: | |
836: | |
837: | public function onAfterUpdateExtendedProps(&$aArgs, &$mResult) |
838: | { |
839: | if ($this->checkStorageType($aArgs['Type'])) { |
840: | $UserId = $aArgs['UserId']; |
841: | Api::CheckAccess($UserId); |
842: | $sUserPiblicId = Api::getUserPublicIdById($UserId); |
843: | $mResult = $this->getManager()->updateExtendedProps( |
844: | $sUserPiblicId, |
845: | $aArgs['Type'], |
846: | $aArgs['Path'], |
847: | $aArgs['Name'], |
848: | $aArgs['ExtendedProps'] |
849: | ); |
850: | } |
851: | } |
852: | |
853: | |
854: | |
855: | |
856: | |
857: | |
858: | public function onAfterGetExtendedProps(&$aArgs, &$mResult) |
859: | { |
860: | $bCorrectArgs = isset($aArgs['Type']) && isset($aArgs['Path']) && isset($aArgs['Name']); |
861: | if ($bCorrectArgs && $this->checkStorageType($aArgs['Type'])) { |
862: | $UserId = $aArgs['UserId']; |
863: | Api::CheckAccess($UserId); |
864: | $sUserPiblicId = Api::getUserPublicIdById($UserId); |
865: | $mResult = $this->getManager()->getExtendedProps( |
866: | $sUserPiblicId, |
867: | $aArgs['Type'], |
868: | $aArgs['Path'], |
869: | $aArgs['Name'] |
870: | ); |
871: | } |
872: | } |
873: | |
874: | public function onAfterGetNonExistentFileName(&$aArgs, &$mResult) |
875: | { |
876: | if ($this->checkStorageType($aArgs['Type'])) { |
877: | $UserId = $aArgs['UserId']; |
878: | Api::CheckAccess($UserId); |
879: | $sUserPiblicId = Api::getUserPublicIdById($UserId); |
880: | $mResult = $this->getManager()->getNonExistentFileName( |
881: | $sUserPiblicId, |
882: | $aArgs['Type'], |
883: | $aArgs['Path'], |
884: | $aArgs['Name'], |
885: | $aArgs['WithoutGroup'] |
886: | ); |
887: | } |
888: | } |
889: | |
890: | public function onAfterGetAccessInfoForPath(&$aArgs, &$mResult) |
891: | { |
892: | if ($this->checkStorageType($aArgs['Type'])) { |
893: | $UserId = $aArgs['UserId']; |
894: | Api::CheckAccess($UserId); |
895: | $sUserPiblicId = Api::getUserPublicIdById($UserId); |
896: | |
897: | $aItems = []; |
898: | $sPath = $aArgs['Path']; |
899: | $aPaths = explode('/', $sPath); |
900: | do { |
901: | $oNode = Server::getNodeForPath('files/' . $aArgs['Type'] . '/' . $sPath, $sUserPiblicId); |
902: | if (!empty($sPath) && ($oNode instanceof SharedFile || $oNode instanceof SharedDirectory)) { |
903: | $aItems[$sPath] = $oNode->getAccess(); |
904: | } |
905: | array_pop($aPaths); |
906: | $sPath = implode('/', $aPaths); |
907: | } while (count($aPaths) > 0); |
908: | $mResult = $aItems; |
909: | } |
910: | } |
911: | } |
912: | |