src/AppBundle/EventListener/AssetPreUpdateListener.php line 26

Open in your IDE?
  1. <?php
  4. namespace AppBundle\EventListener;
  7. use AppBundle\Exception\AssetDeployerException;
  8. use AppBundle\Services\SftpFileTransferService;
  9. use Exception;
  10. use Pimcore;
  11. use Pimcore\Event\Model\AssetEvent;
  12. use Pimcore\Model\Asset;
  13. use Pimcore\Model\WebsiteSetting;
  15. class AssetPreUpdateListener
  16. {
  18.     const TWIST_INTERNAL_DEPLOY_FOLDER_NAME = "Dossier pimcore d'assets transferable vers twist (usage interne)";
  19.     const IS_DEPLOYED = 'Fichier transféré';
  20.     const TARGET_FOLDER = 'Dossier distant de dépot du fichier (pour twist)';
  22.     /**
  23.      * @param AssetEvent $event
  24.      * @throws AssetDeployerException
  25.      */
  26.     public function onSaveTwistInternalAsset(AssetEvent $event)
  27.     {
  28.         if (Pimcore::inAdmin()) {
  29.             $asset = $event->getAsset();
  30.             if ($this->isAssetInTwistDeployFolder($asset)) {
  31.                 if (!$this->hasDeployProperties($asset)) {
  32.                     $this->addDeployProperties($asset);
  33.                 } else {
  34.                     if (!$this->isAlreadySent($asset)) {
  35.                         $this->sendToTwist($asset);
  36.                     }
  37.                 }
  38.             }
  39.         }
  40.     }
  42.     /**
  43.      * @param Asset $asset
  44.      * @return bool
  45.      */
  46.     protected function isAssetInTwistDeployFolder(Asset $asset): bool
  47.     {
  48.         $twistDeployFolder = WebsiteSetting::getByName(self::TWIST_INTERNAL_DEPLOY_FOLDER_NAME)->getData();
  49.         if ($twistDeployFolder) {
  50.             $parent = $asset->getParent();
  51.             while ($parent->getId() !== 1) {
  52.                 if ($parent->getId() === $twistDeployFolder->getId()) {
  53.                     return true;
  54.                 }
  55.                 $parent = $parent->getParent();
  56.             }
  57.         }
  58.         return false;
  59.     }
  61.     /**
  62.      * @param Asset $asset
  63.      * @return bool
  64.      */
  65.     protected function hasDeployProperties(Asset $asset): bool
  66.     {
  67.         return $asset->hasProperty(self::IS_DEPLOYED) && $asset->hasProperty(self::TARGET_FOLDER);
  68.     }
  70.     /**
  71.      * @param Asset $asset
  72.      */
  73.     protected function addDeployProperties(Asset $asset)
  74.     {
  75.         $asset->setProperty(self::IS_DEPLOYED, 'bool', false);
  76.         $asset->setProperty(self::TARGET_FOLDER, 'text', '');
  77.     }
  79.     /**
  80.      * @param Asset $asset
  81.      * @return bool
  82.      */
  83.     protected function isAlreadySent(Asset $asset): bool
  84.     {
  85.         return $asset->getProperty(self::IS_DEPLOYED);
  86.     }
  88.     /**
  89.      * @param Asset $asset
  90.      * @throws AssetDeployerException
  91.      * @throws Exception
  92.      */
  93.     protected function sendToTwist(Asset $asset)
  94.     {
  95.         $destination = $asset->getProperty(self::TARGET_FOLDER);
  96.         if ($destination === '') {
  97.             throw new AssetDeployerException('you need to define target path for this feature');
  98.         }
  99.         SftpFileTransferService::transferFileToTwist($asset->getFileSystemPath(), $destination, $asset->getFilename());
  100.         $asset->setProperty(self::IS_DEPLOYED, 'bool', true);
  101.     }
  102. }