-
-
Notifications
You must be signed in to change notification settings - Fork 3
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
d4bec1a
commit e670873
Showing
2 changed files
with
337 additions
and
1 deletion.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,332 @@ | ||
| <?php | ||
|
|
||
| namespace thomasvantuycom\craftcloudinary\controllers; | ||
|
|
||
| use Cloudinary\Configuration\Configuration; | ||
| use Cloudinary\Utils\SignatureVerifier; | ||
| use Craft; | ||
| use craft\db\Query; | ||
| use craft\db\Table; | ||
| use craft\elements\Asset; | ||
| use craft\helpers\App; | ||
| use craft\helpers\Assets; | ||
| use craft\records\VolumeFolder as VolumeFolderRecord; | ||
| use craft\web\Controller; | ||
| use InvalidArgumentException; | ||
| use thomasvantuycom\craftcloudinary\fs\CloudinaryFs; | ||
| use yii\web\BadRequestHttpException; | ||
| use yii\web\NotFoundHttpException; | ||
| use yii\web\Response; | ||
|
|
||
| class NotificationsController extends Controller | ||
| { | ||
| public $enableCsrfValidation = false; | ||
|
|
||
| protected array|bool|int $allowAnonymous = ['process']; | ||
|
|
||
| public function actionProcess(): Response | ||
| { | ||
| $this->requirePostRequest(); | ||
|
|
||
| // Verify volume | ||
| $volumeId = $this->request->getRequiredQueryParam('volume'); | ||
|
|
||
| $volume = Craft::$app->getVolumes()->getVolumeById($volumeId); | ||
|
|
||
| if ($volume === null) { | ||
| throw new NotFoundHttpException('Volume not found'); | ||
| } | ||
|
|
||
| $fs = $volume->getFs(); | ||
|
|
||
| if (!$fs instanceof CloudinaryFs) { | ||
| throw new BadRequestHttpException('Invalid volume'); | ||
| } | ||
|
|
||
| // Verify signature | ||
| Configuration::instance()->cloud->apiSecret = App::parseEnv($fs->apiSecret); | ||
|
|
||
| $body = $this->request->getRawBody(); | ||
| $timestamp = $this->request->getHeaders()->get('X-Cld-Timestamp'); | ||
| $signature = $this->request->getHeaders()->get('X-Cld-Signature'); | ||
|
|
||
| try { | ||
| if (SignatureVerifier::verifyNotificationSignature($body, $timestamp, $signature) === false) { | ||
| throw new BadRequestHttpException('Invalid signature'); | ||
| } | ||
| } catch (InvalidArgumentException $error) { | ||
| throw new BadRequestHttpException($error->getMessage(), 0, $error); | ||
| } | ||
|
|
||
| // Process notification | ||
| $notificationType = $this->request->getRequiredBodyParam('notification_type'); | ||
| $baseFolder = App::parseEnv($fs->baseFolder); | ||
|
|
||
| switch ($notificationType) { | ||
| case 'create_folder': | ||
| return $this->_processCreateFolder($volumeId, $baseFolder); | ||
| case 'delete_folder': | ||
| return $this->_processDeleteFolder($volumeId, $baseFolder); | ||
| case 'upload': | ||
| return $this->_processUpload($volumeId, $baseFolder); | ||
| case 'delete': | ||
| return $this->_processDelete($volumeId, $baseFolder); | ||
| case 'rename': | ||
| return $this->_processRename($volumeId, $baseFolder); | ||
| default: | ||
| return $this->asSuccess(); | ||
| } | ||
| } | ||
|
|
||
| private function _processCreateFolder($volumeId, $baseFolder): Response | ||
| { | ||
| $name = $this->request->getRequiredBodyParam('folder_name'); | ||
| $path = $this->request->getRequiredBodyParam('folder_path'); | ||
|
|
||
| if (!empty($baseFolder)) { | ||
| if (!str_starts_with($path, $baseFolder . '/')) { | ||
| return $this->asSuccess(); | ||
| } | ||
|
|
||
| $path = substr($path, strlen($baseFolder) + 1); | ||
| } | ||
|
|
||
| // Check if folder exists | ||
| $existingFolderQuery = (new Query()) | ||
| ->from([Table::VOLUMEFOLDERS]) | ||
| ->where([ | ||
| 'volumeId' => $volumeId, | ||
| 'path' => $path . '/', | ||
| ]); | ||
|
|
||
| if ($existingFolderQuery->exists()) { | ||
| return $this->asSuccess(); | ||
| } | ||
|
|
||
| // Get parent folder ID | ||
| $parentId = (new Query()) | ||
| ->select('id') | ||
| ->from(Table::VOLUMEFOLDERS) | ||
| ->where([ | ||
| 'volumeId' => $volumeId, | ||
| 'path' => ($name === $path) ? '' : dirname($path) . '/', | ||
| ]) | ||
| ->scalar(); | ||
|
|
||
| // Store folder | ||
| $record = new VolumeFolderRecord([ | ||
| 'parentId' => $parentId, | ||
| 'volumeId' => $volumeId, | ||
| 'name' => $name, | ||
| 'path' => $path . '/', | ||
| ]); | ||
| $record->save(); | ||
|
|
||
| return $this->asSuccess(); | ||
| } | ||
|
|
||
| private function _processDeleteFolder($volumeId, $baseFolder): Response | ||
| { | ||
| $path = $this->request->getRequiredBodyParam('folder_path'); | ||
|
|
||
| if (!empty($baseFolder)) { | ||
| if (!str_starts_with($path, $baseFolder . '/')) { | ||
| return $this->asSuccess(); | ||
| } | ||
|
|
||
| $path = substr($path, strlen($baseFolder) + 1); | ||
| } | ||
|
|
||
| // Delete folder | ||
| VolumeFolderRecord::deleteAll([ | ||
| 'volumeId' => $volumeId, | ||
| 'path' => $path . '/', | ||
| ]); | ||
|
|
||
| return $this->asSuccess(); | ||
| } | ||
|
|
||
| private function _processUpload($volumeId, $baseFolder): Response | ||
| { | ||
| $publicId = $this->request->getRequiredBodyParam('public_id'); | ||
| $folder = $this->request->getRequiredBodyParam('folder'); | ||
| $size = $this->request->getRequiredBodyParam('bytes'); | ||
|
|
||
| if (!empty($baseFolder)) { | ||
| if ($folder !== $baseFolder && !str_starts_with($folder, $baseFolder . '/')) { | ||
| return $this->asSuccess(); | ||
| } | ||
|
|
||
| $folder = substr($folder, strlen($baseFolder) + 1); | ||
| } | ||
|
|
||
| // Get folder ID | ||
| $folderId = (new Query()) | ||
| ->select('id') | ||
| ->from(Table::VOLUMEFOLDERS) | ||
| ->where([ | ||
| 'volumeId' => $volumeId, | ||
| 'path' => $folder === '' ? '' : $folder . '/', | ||
| ]) | ||
| ->scalar(); | ||
|
|
||
| // Check if asset exists | ||
| $filename = basename($publicId); | ||
|
|
||
| $resourceType = $this->request->getRequiredBodyParam('resource_type'); | ||
|
|
||
| if ($resourceType !== 'raw') { | ||
| $format = $this->request->getRequiredBodyParam('format'); | ||
|
|
||
| $filename = $filename . '.' . $format; | ||
| } | ||
|
|
||
| $existingAssetQuery = (new Query()) | ||
| ->from(['assets' => Table::ASSETS]) | ||
| ->innerJoin(['elements' => Table::ELEMENTS], '[[elements.id]] = [[assets.id]]') | ||
| ->where([ | ||
| 'assets.volumeId' => $volumeId, | ||
| 'assets.folderId' => $folderId, | ||
| 'assets.filename' => $filename, | ||
| 'elements.dateDeleted' => null, | ||
| ]); | ||
|
|
||
| if ($existingAssetQuery->exists()) { | ||
| return $this->asSuccess(); | ||
| } | ||
|
|
||
| // Store Asset | ||
| $kind = Assets::getFileKindByExtension($filename); | ||
|
|
||
| $asset = new Asset([ | ||
| 'volumeId' => $volumeId, | ||
| 'folderId' => $folderId, | ||
| 'filename' => $filename, | ||
| 'kind' => $kind, | ||
| 'size' => $size, | ||
| ]); | ||
|
|
||
| if ($kind === Asset::KIND_IMAGE) { | ||
| $asset->width = $this->request->getRequiredBodyParam('width'); | ||
| $asset->height = $this->request->getRequiredBodyParam('height'); | ||
| } | ||
|
|
||
| $asset->setScenario(Asset::SCENARIO_INDEX); | ||
| Craft::$app->getElements()->saveElement($asset); | ||
|
|
||
| return $this->asSuccess(); | ||
| } | ||
|
|
||
| private function _processDelete($volumeId, $baseFolder): Response | ||
| { | ||
| $resources = $this->request->getRequiredBodyParam('resources'); | ||
|
|
||
| foreach ($resources as $resource) { | ||
| $resourceType = $resource['resource_type']; | ||
| $publicId = $resource['public_id']; | ||
| $folder = $resource['folder']; | ||
|
|
||
| if (!empty($baseFolder)) { | ||
| if ($folder !== $baseFolder && !str_starts_with($folder, $baseFolder . '/')) { | ||
| return $this->asSuccess(); | ||
| } | ||
|
|
||
| $folder = substr($folder, strlen($baseFolder) + 1); | ||
| } | ||
|
|
||
| $filename = basename($publicId); | ||
| $folderPath = $folder === '' ? '' : $folder . '/'; | ||
|
|
||
| $assetQuery = Asset::find() | ||
| ->volumeId($volumeId) | ||
| ->folderPath($folderPath); | ||
|
|
||
| if ($resourceType === 'raw') { | ||
| $assetQuery->filename($filename); | ||
| } else { | ||
| $assetQuery->filename("$filename.*"); | ||
| if ($resourceType === 'image') { | ||
| $assetQuery->kind('image'); | ||
| } else { | ||
| $assetQuery->kind(['video', 'audio']); | ||
| } | ||
| } | ||
|
|
||
| $asset = $assetQuery->one(); | ||
|
|
||
| if ($asset !== null) { | ||
| Craft::$app->getElements()->deleteElement($asset); | ||
| } | ||
| } | ||
|
|
||
| return $this->asSuccess(); | ||
| } | ||
|
|
||
| private function _processRename($volumeId, $baseFolder): Response | ||
| { | ||
| $resourceType = $this->request->getRequiredBodyParam('resource_type'); | ||
| $fromPublicId = $this->request->getRequiredBodyParam('from_public_id'); | ||
| $toPublicId = $this->request->getRequiredBodyParam('to_public_id'); | ||
| $folder = $this->request->getRequiredBodyParam('folder'); | ||
|
|
||
| $fromFilename = basename($fromPublicId); | ||
| $fromFolder = dirname($fromPublicId); | ||
| $fromFolderPath = $fromFolder === '.' ? '' : $fromFolder . '/'; | ||
| $toFilename = basename($toPublicId); | ||
| $toFolderPath = $folder === '' ? '' : $folder . '/'; | ||
|
|
||
| if (!empty($baseFolder)) { | ||
| if ($fromFolder !== $baseFolder && !str_starts_with($fromFolder, $baseFolder . '/')) { | ||
| return $this->asSuccess(); | ||
| } | ||
|
|
||
| if ($folder !== $baseFolder && !str_starts_with($folder, $baseFolder . '/')) { | ||
| return $this->asSuccess(); | ||
| } | ||
|
|
||
| $fromFolderPath = substr($fromFolderPath, strlen($baseFolder) + 1); | ||
| $toFolderPath = substr($toFolderPath, strlen($baseFolder) + 1); | ||
| } | ||
|
|
||
| $assetQuery = Asset::find() | ||
| ->volumeId($volumeId) | ||
| ->folderPath($fromFolderPath); | ||
|
|
||
| if ($resourceType === 'raw') { | ||
| $assetQuery->filename($fromFilename); | ||
| } else { | ||
| $assetQuery->filename("$fromFilename.*"); | ||
| if ($resourceType === 'image') { | ||
| $assetQuery->kind('image'); | ||
| } else { | ||
| $assetQuery->kind(['video', 'audio']); | ||
| } | ||
| } | ||
|
|
||
| $asset = $assetQuery->one(); | ||
|
|
||
| if ($asset !== null) { | ||
| if ($fromFolderPath !== $toFolderPath) { | ||
| $folderRecord = VolumeFolderRecord::findOne([ | ||
| 'volumeId' => $volumeId, | ||
| 'path' => $toFolderPath, | ||
| ]); | ||
|
|
||
| $asset->folderId = $folderRecord->id; | ||
| } | ||
|
|
||
| if ($fromFilename !== $toFilename) { | ||
| if ($resourceType === 'raw') { | ||
| $asset->filename = $toFilename; | ||
| } else { | ||
| $extension = pathinfo($asset->filename, PATHINFO_EXTENSION); | ||
| $asset->filename = "$toFilename.$extension"; | ||
| } | ||
| } | ||
|
|
||
| Craft::$app->getElements()->saveElement($asset); | ||
| } | ||
|
|
||
| return $this->asSuccess(); | ||
| } | ||
| } |