src/EventListener/AssetEventListener.php line 81

Open in your IDE?
  1. <?php
  3. namespace App\EventListener;
  5. use Aws\S3\S3Client;
  6. use Pimcore\Event\AssetEvents;
  7. use Pimcore\Event\Model\AssetEvent;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. class AssetEventListener implements EventSubscriberInterface
  11. {
  12.     /**
  13.      * @var S3Client
  14.      */
  15.     private $s3Client;
  16.     /**
  17.      * @var string
  18.      */
  19.     private $s3TmpUrlPrefix;
  21.     private $s3BaseUrl;
  23.     /**
  24.      * @var string
  25.      */
  26.     private $s3AssetUrlPrefix;
  28.     /**
  29.      * @var Pimcore\Model\Asset
  30.      */
  31.     private $asset;
  33.     public function __construct()
  34.     {
  35.         $this->s3BaseUrl = S3_ASSET_URL_PIMCORE;
  36.         $this->s3TmpUrlPrefix = $this->s3BaseUrl . str_replace('s3:/', '', PIMCORE_TEMPORARY_DIRECTORY);
  37.         $this->s3AssetUrlPrefix = $this->s3BaseUrl . str_replace('s3:/', '', PIMCORE_ASSET_DIRECTORY);
  38.         $this->s3Client = $this->getS3Client();
  39.     }
  41.     /**
  42.      * @inheritDoc
  43.      */
  44.     public static function getSubscribedEvents()
  45.     {
  46.         return [
  47.         AssetEvents::POST_ADD => 'onPostAdd',
  48.         AssetEvents::POST_UPDATE => 'onPostUpdate',
  49.     ];
  50.     }
  52.     /**
  53.      * Create a new s3 client object
  54.      *
  55.      * @return S3Client
  56.      */
  57.     protected function getS3Client()
  58.     {
  59.         $s3ConfigSettings = [
  60.             'version' => 'latest',
  61.             'region' => AMAZON_S3_REGION,
  62.             'credentials' => [
  63.                 'key' => AMAZON_S3_KEY,
  64.                 'secret' => AMAZON_S3_SECRET
  65.             ],
  66.         ];
  68.         return new S3Client($s3ConfigSettings);
  69.     }
  71.     public function onPostAdd(AssetEvent $event)
  72.     {
  73.         $this->asset = $event->getAsset();
  74.         if ($this->asset->getType() == 'folder') {
  75.             return false;
  76.         }
  77.         $key = $this->asset->getRealFullPath();
  78.         $this->makeAssetPublicInS3('assets'.$key);
  79.     }
  81.     public function onPostUpdate(AssetEvent $event)
  82.     {
  83.         $this->asset = $event->getAsset();
  84.         if ($this->asset->getType() == 'folder') {
  85.             return false;
  86.         }
  87.         $key = $this->asset->getRealFullPath();
  88.         $this->makeAssetPublicInS3('assets'.$key);
  89.     }
  91.     /**
  92.      * Make s3 bucket asset publicly available
  93.      *
  94.      * @param $assetPath
  95.      * @param bool $isTmp
  96.      */
  97.     protected function makeAssetPublicInS3($assetPath, $isTmp = false)
  98.     {
  99.         $this->s3Client->putObjectAcl([
  100.             'ACL' => 'public-read-write',
  101.             'Grants' => [
  102.                 [
  103.                     'Grantee' => [
  104.                         'DisplayName' => 'public-read-write',
  105.                         'EmailAddress' => 'fyzalam@gmail.com',
  106.                         'Type' => 'CanonicalUser'],
  107.                         'Permission' => 'READ',
  108.                 ],
  109.             ],
  110.             'Owner' => ['DisplayName' => AMAZON_S3_BUCKET, ],
  111.             'Bucket' => AMAZON_S3_BUCKET,
  112.             'Key' => $assetPath,
  113.             'RequestPayer' => AMAZON_S3_BUCKET,
  114.         ]);
  115.         if ($isTmp === false) {
  116.             $this->asset->update(true);
  117.         }
  118.     }
  119. }