Added a schema for products

_config/config.yml

@@ -6,6 +6,8 @@ Dynamic\Shopify\Page\ShopifyProduct:
     - LittleGiant\CatalogManager\Extensions\CatalogPageExtension
   parent_classes:
     - Dynamic\Shopify\Page\ShopifyCollection
+  active_schema:
+    - Dynamic\Shopify\SEO\ProductSchemaBuilder
   sort_column: false
   automatic_live_sort: false
 
@@ -17,6 +19,10 @@ PageController:
   extensions:
     - Dynamic\Shopify\Extension\ShopifyExtension
 
+SilverStripe\SiteConfig\SiteConfig:
+  extensions:
+    - Dynamic\Shopify\Extension\ShopifySiteConfigExtension
+
 SilverStripe\Core\Injector\Injector:
   SilverStripe\Security\MemberAuthenticator\LoginHandler:
     class: Dynamic\Shopify\Extension\ShopifyLoginHandler

composer.json

@@ -13,7 +13,8 @@
         "littlegiant/silverstripe-catalogmanager": "^5.2",
         "silverstripe/recipe-cms": "^4.5",
         "symbiote/silverstripe-gridfieldextensions": "^3.0",
-        "osiset/basic-shopify-api": "^10.0"
+        "osiset/basic-shopify-api": "^10.0",
+        "bramdeleeuw/silverstripe-schema": "^2.0"
     },
     "require-dev": {
         "phpunit/phpunit": "^5.7",

src/Client/ShopifyClient.php

@@ -2,6 +2,7 @@
 
 namespace Dynamic\Shopify\Client;
 
+use Dynamic\Shopify\Extension\ShopifySiteConfigExtension;
 use Exception;
 use GuzzleHttp\Promise\Promise;
 use Osiset\BasicShopifyAPI\BasicShopifyAPI;
@@ -12,6 +13,7 @@
 use SilverStripe\Core\Injector\Injectable;
 use SilverStripe\Dev\Debug;
 use SilverStripe\ORM\ArrayList;
+use SilverStripe\SiteConfig\SiteConfig;
 use SilverStripe\View\ArrayData;
 
 /**
@@ -126,6 +128,7 @@ protected function setClient()
 
         $this->client = $client;
 
+        $this->updateLocalCache();
         return $this;
     }
 
@@ -153,6 +156,34 @@ public static function get_domain()
         return $domain;
     }
 
+    /**
+     * Updates locally stored config options set in shopify
+     */
+    protected function updateLocalCache()
+    {
+        /** @var SiteConfig|ShopifySiteConfigExtension $config */
+        $config = SiteConfig::current_site_config();
+        $config->ShopCurrencyCode = $this->currencyCode();
+
+        if ($config->isChanged()) {
+            $config->write();
+        }
+    }
+
+    /**
+     * Gets the shop's currency code
+     * @return array|Promise
+     * @throws Exception
+     */
+    public function currencyCode()
+    {
+        $result = $this->getClient()->graph('query {shop{currencyCode}}');
+        if ($result && $result['body']) {
+            return $result['body']->data->shop->currencyCode;
+        }
+        return '';
+    }
+
     /**
      * @param array $options
      * @return array|Promise

src/Extension/ShopifySiteConfigExtension.php

@@ -0,0 +1,21 @@
+<?php
+
+namespace Dynamic\Shopify\Extension;
+
+use SilverStripe\ORM\DataExtension;
+
+/**
+ * Class ShopifySiteConfigExtension
+ * @package Dynamic\Shopify\Extension
+ *
+ * @property string ShopCurrencyCode
+ */
+class ShopifySiteConfigExtension extends DataExtension
+{
+    /**
+     * @var string[]
+     */
+    private static $db = [
+        'ShopCurrencyCode' => 'Varchar',
+    ];
+}

src/Page/ShopifyProduct.php

@@ -15,13 +15,16 @@
 use SilverStripe\ORM\FieldType\DBCurrency;
 use SilverStripe\ORM\FieldType\DBField;
 use SilverStripe\ORM\FieldType\DBHTMLText;
+use SilverStripe\ORM\HasManyList;
 use SilverStripe\View\Requirements;
 
 /**
  * Class ShopifyProduct
  * @package Dynamic\Shopify\Page
  *
  * @property string ShopifyID
+ *
+ * @method HasManyList|ShopifyFile[] Files
  */
 class ShopifyProduct extends \Page
 {

src/SEO/ProductSchemaBuilder.php

@@ -0,0 +1,46 @@
+<?php
+
+namespace Dynamic\Shopify\SEO;
+
+use Broarm\Schema\Builder\SchemaBuilder;
+use Broarm\Schema\Type\OfferSchema;
+use Broarm\Schema\Type\ProductSchema;
+use Dynamic\Shopify\Model\ShopifyFile;
+use Dynamic\Shopify\Page\ShopifyProduct;
+use SilverStripe\SiteConfig\SiteConfig;
+
+/**
+ * Class ProductSchemaBuilder
+ * @package Dynamic\Shopify\SEO
+ */
+class ProductSchemaBuilder extends SchemaBuilder
+{
+
+    /**
+     * @inheritDoc
+     */
+    public function getSchema($page)
+    {
+        /** @var ShopifyProduct $page */
+        $images = [];
+        foreach ($page->Files() as $file) {
+            if ($file->Type === ShopifyFile::IMAGE) {
+                $images[] = $file->getURL();
+            }
+        }
+
+        return new ProductSchema(
+            $page->Title,
+            $page->Content,
+            new OfferSchema(
+                number_format($page->getPrice()->getValue(), 2),
+                SiteConfig::current_site_config()->ShopCurrencyCode,
+                $page->ProductActive ? 'https://schema.org/InStock' : 'https://schema.org/OutOfStock'
+            ),
+            $page->getSKU(),
+            null,
+            null,
+            $images
+        );
+    }
+}