Setup Cloudinary

.env

@@ -32,3 +32,8 @@ AKENEO_CLIENT_ID=
 AKENEO_SECRET=
 AKENEO_USERNAME=
 AKENEO_PASSWORD=
+
+# Cloudinary credentials
+CLOUDINARY_CLOUD_NAME=
+CLOUDINARY_API_KEY=
+CLOUDINARY_API_SECRET=

.php_cd.php

@@ -32,6 +32,11 @@
     /**
      * INFRASTRUCTURE
      */
+    $builder->only([
+        'AkeneoDAMConnector\Application\DamAdapter',
+        'AkeneoDAMConnector\Domain',
+    ])->in('AkeneoDAMConnector\Infrastructure\DAM\Cloudinary'),
+
     $builder->only([
         'AkeneoDAMConnector\Application\DamAdapter',
         'AkeneoDAMConnector\Domain',

composer.json

@@ -13,8 +13,9 @@
         "php": "^7.1.3",
         "ext-ctype": "*",
         "ext-iconv": "*",
-        "akeneo/api-php-client-ee": "dev-asset-family@dev",
         "akeneo/api-php-client": "dev-master@dev",
+        "akeneo/api-php-client-ee": "dev-asset-family@dev",
+        "cloudinary/cloudinary_php": "1.14.*",
         "doctrine/dbal": "2.9.*",
         "http-interop/http-factory-guzzle": "^1.0",
         "php-http/guzzle6-adapter": "^2.0",

config/services/cloudinary.yaml

@@ -0,0 +1,20 @@
+parameters:
+    app.pim_structure.config_path: '%kernel.project_dir%/config/resources/cloudinary/structure.yaml'
+    app.dam_to_pim_mapping.config_path: '%kernel.project_dir%/config/resources/cloudinary/mapping.yaml'
+
+services:
+    _defaults:
+        autowire: true
+        autoconfigure: true
+        public: false
+
+    AkeneoDAMConnector\Infrastructure\DAM\Cloudinary\:
+        resource: '../../src/Infrastructure/DAM/Cloudinary/*'
+
+    AkeneoDAMConnector\Infrastructure\DAM\Cloudinary\Search:
+        arguments:
+            $cloudName: '%env(CLOUDINARY_CLOUD_NAME)%'
+            $apiKey: '%env(CLOUDINARY_API_KEY)%'
+            $apiSecret: '%env(CLOUDINARY_API_SECRET)%'
+
+    AkeneoDAMConnector\Application\DamAdapter\FetchAssets: '@AkeneoDAMConnector\Infrastructure\DAM\Cloudinary\FetchAssets'

src/Infrastructure/DAM/Cloudinary/FetchAssets.php

@@ -0,0 +1,55 @@
+<?php
+
+declare(strict_types=1);
+
+namespace AkeneoDAMConnector\Infrastructure\DAM\Cloudinary;
+
+use AkeneoDAMConnector\Application\DamAdapter\FetchAssets as FetchAssetsInterface;
+use AkeneoDAMConnector\Domain\Asset\DamAsset;
+use AkeneoDAMConnector\Domain\Asset\DamAssetCollection;
+use AkeneoDAMConnector\Domain\Asset\DamAssetIdentifier;
+use AkeneoDAMConnector\Domain\AssetFamilyCode;
+use AkeneoDAMConnector\Domain\Locale;
+use AkeneoDAMConnector\Domain\ResourceType;
+
+class FetchAssets implements FetchAssetsInterface
+{
+    /** @var Search */
+    private $search;
+
+    public function __construct(Search $search)
+    {
+        $this->search = $search;
+    }
+
+    public function fetch(\DateTime $lastFetchDate, AssetFamilyCode $assetFamilyCode): DamAssetCollection
+    {
+        $expression = sprintf('tags:akeneo AND folder="%s"', (string) $assetFamilyCode);
+        $response = $this->search->search($expression, ['tags', 'context']);
+
+        $staticAttributes = ['filename', 'url', 'secure_url', 'status', 'public_id'];
+        $damAssets = new DamAssetCollection();
+        $assets = $response['resources'] ?? [];
+        foreach ($assets as $asset) {
+            $damAsset = new DamAsset(
+                new DamAssetIdentifier($asset['filename']),
+                $assetFamilyCode,
+                new Locale('en_US'),
+                new ResourceType($asset['resource_type'])
+            );
+
+            foreach ($staticAttributes as $staticAttribute) {
+                $damAsset->addValue($staticAttribute, $asset[$staticAttribute]);
+            }
+
+            foreach ($asset['context'] as $property => $value) {
+                $damAsset->addValue($property, $value);
+            }
+            $damAsset->addValue('tags', implode(', ', $asset['tags']));
+
+            $damAssets->addAsset($damAsset);
+        }
+
+        return $damAssets;
+    }
+}

src/Infrastructure/DAM/Cloudinary/Search.php

@@ -0,0 +1,31 @@
+<?php
+
+declare(strict_types=1);
+
+namespace AkeneoDAMConnector\Infrastructure\DAM\Cloudinary;
+
+class Search
+{
+    public function __construct(string $cloudName, string $apiKey, string $apiSecret)
+    {
+        \Cloudinary::config(array(
+            'cloud_name' => $cloudName,
+            'api_key' => $apiKey,
+            'api_secret' => $apiSecret,
+            'secure' => true
+        ));
+    }
+
+    public function search(string $expression, array $withFields)
+    {
+        $searchEngine = new \Cloudinary\Search();
+        $searchEngine->expression($expression);
+        if (!empty($withFields)) {
+            foreach ($withFields as $field) {
+                $searchEngine->with_field($field);
+            }
+        }
+
+        return $searchEngine->execute();
+    }
+}

symfony.lock

@@ -8,6 +8,9 @@
     "akeneo/php-coupling-detector": {
         "version": "0.3.1"
     },
+    "cloudinary/cloudinary_php": {
+        "version": "1.14.0"
+    },
     "composer/semver": {
         "version": "1.x-dev"
     },