SalsifyFetchExtension::getImporterKey() - Code Metrics - dynamic/silverstripe-salsify - Measure and Improve Code Quality continuously with Scrutinizer

SalsifyFetchExtension::getImporterKey() A
last analyzed 2021-10-21 15:43 UTC

↳ Parent: SalsifyFetchExtension
Complexity

Conditions	1
Paths	1
Size

Total Lines	3
Code Lines	1
Duplication

Lines	0
Ratio	0 %
Importance

Changes
Metric	Value
eloc	1
dl	0
loc	3
rs	10
c	0
b	0
f	0
cc	1
nc	1
nop	0
<?php

namespace Dynamic\Salsify\ORM;

use Dynamic\Salsify\Model\Fetcher;
use Dynamic\Salsify\Model\Mapper;
use Dynamic\Salsify\Task\ImportTask;
use Dynamic\Salsify\Traits\InstanceCreator;
use GuzzleHttp\Client;
use SilverStripe\Admin\LeftAndMainExtension;
filter:
    dependency_paths: ["lib/*"]
use SilverStripe\Core\Config\Config;
use SilverStripe\Forms\Form;
use SilverStripe\ORM\DataObject;
use SilverStripe\Security\Security;

/**
 * Class LeftAndMainExtension
 * @package Dynamic\Salsify\ORM
 * @property-read \SilverStripe\Admin\LeftAndMain|\Dynamic\Salsify\ORM\SalsifyFetchExtension $owner
 */
class SalsifyFetchExtension extends LeftAndMainExtension
{
    use InstanceCreator;

    /**
     * @var bool
     */
    private $noChannel = true;


    /**
     * @var array
     */
    private static $allowed_actions = [

        'salsifyFetch',
    ];

    /**
     * @return string
     */
    protected function getImporterKey()
    {
        return 'single';
    }

    /**
     *
     */
    public function onBeforeInit()
    {
        $this->createServices();
    }

    /**
     * @return boolean
     * @throws \Exception
     */
    public function canFetchSalsify()
    {
        $className = $this->owner->currentPage()->getClassName();

        // Only allow when product has a salsify id and has a single mapping config
        if (
            $this->owner->currentPage()->SalsifyID &&
            $this->hasService(Mapper::class) &&
            $this->configContainsMapping($className) &&
            $this->getFetcher()->config()->get('organizationID')
        ) {
            return true;
        }
        return false;
    }

    /**
     * @param string $className
     *
     * @return boolean
     * @throws \Exception
     */
    private function configContainsMapping($className)
    {
        if (!$this->getMapper()->config()->get('mapping')) {
            return false;
        }

        if (!$this->getClassMapping($className)) {
            return false;
        }

        return true;
    }

    /**
     * @param string $className
     * @return bool|array
     * @throws \Exception
     */
    private function getClassMapping($className)
    {
        $mapping = $this->getMapper()->config()->get('mapping');
        if (array_key_exists($className, $mapping)) {
            return $mapping[$className];
        }
        if (array_key_exists('\\' . $className, $mapping)) {
            return $mapping['\\' . $className];
        }
        return false;
    }

    /**
     * @param array $data
     * @param Form $form
     * @return \SilverStripe\Control\HTTPResponse
     * @throws \Exception
     */
    public function salsifyFetch($data, $form)
    {
        $className = $this->owner->currentPage()->getClassName();

        $id = $data['ID'];
        /** @var DataObject|\Dynamic\Salsify\ORM\SalsifyIDExtension $record */
        $record = DataObject::get_by_id($className, $id);
        if ($record && !$record->canEdit()) {
            return Security::permissionFailure();
        }

        if (!$record || !$record->SalsifyID) {

            $this->owner->httpError(404, "Bad salsify ID: $id");
        }

        ImportTask::config()->remove('output');
        $data = $this->fetchProduct($record->SalsifyID);
        if (array_key_exists('salsify:parent_id', $data)) {
            $parent = $this->fetchProduct($data['salsify:parent_id']);
            $data = array_merge($parent, $data);
            $data = array_merge(/** @scrutinizer ignore-type */ $parent, $data);
        }

        $this->changeToSalsifyUser();
        $this->mapData($record, $data);
        $this->changeToPreviousUser();

        $this->owner->getResponse()->addHeader(
            'X-Status',
            rawurlencode(_t(__CLASS__ . '.UPDATED', 'Updated.'))
        );
        return $this->owner->getResponseNegotiator()->respond($this->owner->getRequest());
    }

    /**
     * @param string $salsifyID
     * @return array|NULL
     * @throws \Exception
     */
    private function fetchProduct($salsifyID)
    {

        $apiKey = $this->getFetcher()->config()->get('apiKey');
        $timeout = $this->getFetcher()->config()->get('timeout');
        $orgID = $this->getFetcher()->config()->get('organizationID');

        $url = "v1/orgs/{$orgID}/products/{$salsifyID}";

        $client = new Client([
            'base_uri' => Fetcher::API_BASE_URL,
            'timeout' => $timeout,
            'http_errors' => false,
            'verify' => true,
            'headers' => [
                'Authorization' => 'Bearer ' . $apiKey,
                'Content-Type' => 'application/json',
            ],
        ]);

        $response = $client->get($url);

        if ($response->getStatusCode() == 404) {
            $this->owner->httpError(404, "Bad salsify ID: $salsifyID");
        }

        return json_decode($response->getBody(), true);
    }

    /**
     * @param DataObject $record
     * @param array $data
     * @throws \Exception
     */
    private function mapData($record, $data)
    {
        $forceUpdate = Config::inst()->get(
            $this->owner->currentPage()->getClassName(),
            'refetch_force_update'
        );

        $this->getFetcher()->config()->set('useLatest', true);
        $this->getFetcher()->startExportRun();
        $this->getFetcher()->waitForExportRunToComplete();
        $file = $this->getFetcher()->getExportUrl();

        $this->getMapper()->extend('onBeforeMap', $file, Mapper::$SINGLE);

        $this->getMapper()->mapToObject(
            $record->getClassName(),
            $this->getClassMapping($record->getClassName()),
            /** @scrutinizer ignore-type */ $this->getClassMapping($record->getClassName()),
            $data,
            $record,
            false,
            $forceUpdate
        );

        $forceUpdateRelations = Config::inst()->get(
            $this->owner->currentPage()->getClassName(),
            'refetch_force_update_relations'
        );
        $this->getMapper()->mapToObject(
            $record->getClassName(),
            $this->getClassMapping($record->getClassName()),
            $data,
            $record,
            true,
            $forceUpdateRelations
        );

        $this->getMapper()->extend('onAfterMap', $file, Mapper::$SINGLE);
    }
}

dynamic / silverstripe-salsify

SalsifyFetchExtension::getImporterKey() A last analyzed 2021-10-21 15:43 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

SalsifyFetchExtension::getImporterKey() A
last analyzed 2021-10-21 15:43 UTC
