ProductInventoryObserver::process() - Code Metrics - Inspection of "Refactoring cache integration" - techdivision/import-product - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — 19.x ( 8328ae...eef76a )

by Tim

created 2019-11-14 21:42 UTC

ProductInventoryObserver::process() A

↳ Parent: ProductInventoryObserver

Complexity

Conditions	3
Paths	3

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	3
CRAP Score	3

Importance

Changes

Metric	Value
dl	0
loc	13
ccs	3
cts	3
cp	1
rs	9.8333
c	0
b	0
f	0
cc	3
nc	3
nop	0
crap	3

<?php

/**
 * TechDivision\Import\Product\Observers\ProductInventoryObserver
 *
 * NOTICE OF LICENSE
 *
 * This source file is subject to the Open Software License (OSL 3.0)
 * that is available through the world-wide-web at this URL:
 * http://opensource.org/licenses/osl-3.0.php
 *
 * PHP version 5
 *
 * @author    Tim Wagner <[email protected]>
 * @copyright 2016 TechDivision GmbH <[email protected]>
 * @license   http://opensource.org/licenses/osl-3.0.php Open Software License (OSL 3.0)
 * @link      https://github.com/techdivision/import-product
 * @link      http://www.techdivision.com
 */

namespace TechDivision\Import\Product\Observers;

use TechDivision\Import\Observers\StateDetectorInterface;
use TechDivision\Import\Observers\AttributeLoaderInterface;
use TechDivision\Import\Observers\DynamicAttributeObserverInterface;
use TechDivision\Import\Product\Utils\ColumnKeys;
use TechDivision\Import\Product\Utils\MemberNames;
use TechDivision\Import\Product\Services\ProductBunchProcessorInterface;
use TechDivision\Import\Subjects\SubjectInterface;
use TechDivision\Import\Observers\ObserverFactoryInterface;
use TechDivision\Import\Observers\StateDetectorAwareObserverInterface;

/**
 * Observer that creates/updates the product's inventory.
 *
 * @author    Tim Wagner <[email protected]>
 * @copyright 2016 TechDivision GmbH <[email protected]>
 * @license   http://opensource.org/licenses/osl-3.0.php Open Software License (OSL 3.0)
 * @link      https://github.com/techdivision/import-product
 * @link      http://www.techdivision.com
 */
class ProductInventoryObserver extends AbstractProductImportObserver implements DynamicAttributeObserverInterface, StateDetectorAwareObserverInterface, ObserverFactoryInterface
{

    /**
     * The product bunch processor instance.
     *
     * @var \TechDivision\Import\Product\Services\ProductBunchProcessorInterface
     */
    protected $productBunchProcessor;

    /**
     * The attribute loader instance.
     *
     * @var \TechDivision\Import\Observers\AttributeLoaderInterface
     */
    protected $attributeLoader;

    /**
     * The array with the column mappings that has to be computed.
     *
     * @var array
     */
    protected $columns = array();

    /**
     * Initialize the observer with the passed product bunch processor instance.
     *
     * @param \TechDivision\Import\Product\Services\ProductBunchProcessorInterface $productBunchProcessor The product bunch processor instance
     * @param \TechDivision\Import\Observers\StateDetectorInterface|null           $stateDetector         The state detector instance to use
     */
    public function __construct(
        ProductBunchProcessorInterface $productBunchProcessor,
        AttributeLoaderInterface $attributeLoader,
        StateDetectorInterface $stateDetector = null
    ) {

        // initialize the bunch processor and the attribute loader instance
        $this->productBunchProcessor = $productBunchProcessor;
        $this->attributeLoader = $attributeLoader;

        // pass the state detector to the parent method
        parent::__construct($stateDetector);
abstract class User
{
    /** @return string */
    abstract public function getPassword();
}

class MyUser extends User
{
    public function getPassword()
    {
        // return something
    }

    public function getDisplayName()
    {
        // return some name.
    }
}

class AuthSystem
{
    public function authenticate(User $user)
    {
        $this->logger->info(sprintf('Authenticating %s.', $user->getDisplayName()));
        // do something.
    }
}
    }

    /**
     * Will be invoked by the observer visitor when a factory has been defined to create the observer instance.
     *
     * @param \TechDivision\Import\Subjects\SubjectInterface $subject The subject instance
     *
     * @return \TechDivision\Import\Observers\ObserverInterface The observer instance
     */
    public function createObserver(SubjectInterface $subject)
    {

        // load the header stock mappings from the subject
        $headerStockMappings = $subject->getHeaderStockMappings();


        // prepare the array with column name => type mapping
        foreach ($headerStockMappings as $columnName => $mappings) {
            // explode the mapping details
            list (, $type) = $mappings;
            // add the column name => type mapping
            $this->columns[$columnName] = $type;
        }

        // return the instance itself
        return $this;
    }

    /**
     * Returns an array of the columns with their types to detect state.
     *
     * @return array The array with the column names as key and their type as value
     */
    public function getColumns()
    {
        return array_intersect_key($this->columns, $this->getHeaders());
    }

    /**
     * Return's the product bunch processor instance.
     *
     * @return \TechDivision\Import\Product\Services\ProductBunchProcessorInterface The product bunch processor instance
     */
    protected function getProductBunchProcessor()
    {
        return $this->productBunchProcessor;
    }

    /**
     * Process the observer's business logic.
     *
     * @return array The processed row
     */
    protected function process()
    {

        // query whether or not, we've found a new SKU => means we've found a new product
        if ($this->hasBeenProcessed($this->getValue(ColumnKeys::SKU))) {
            return;
        }

        // prepare, initialize and persist the stock status/item
        if ($this->hasChanges($entity = $this->initializeStockItem($this->prepareStockItemAttributes()))) {
            $this->persistStockItem($entity);
        }
    }

    /**
     * Prepare the basic attributes of the stock status/item entity that has to be persisted.
     *
     * @return array The prepared stock status/item attributes
     */
    protected function prepareAttributes()
    {

        // load the ID of the product that has been created recently
        $lastEntityId = $this->getSubject()->getLastEntityId();
interface User
{
    /** @return string */
    public function getPassword();
}

class MyUser implements User
{
    public function getPassword()
    {
        // return something
    }

    public function getDisplayName()
    {
        // return some name.
    }
}

class AuthSystem
{
    public function authenticate(User $user)
    {
        $this->logger->info(sprintf('Authenticating %s.', $user->getDisplayName()));
        // do something.
    }
}

        // initialize the stock status data
        $websiteId =  $this->getValue(ColumnKeys::WEBSITE_ID, 0);

        // return the prepared stock status
        return $this->initializeEntity(
            array(
                MemberNames::PRODUCT_ID   => $lastEntityId,
                MemberNames::WEBSITE_ID   => $websiteId,
                MemberNames::STOCK_ID     => 1
            )
        );
    }

    /**
     * Prepare the stock item attributes of the entity that has to be persisted.
     *
     * @return array The prepared stock status item
     */
    protected function prepareStockItemAttributes()
    {
        return array_merge($this->prepareAttributes(), $this->attributeLoader->load($this, $this->getHeaderStockMappings()));
    }

    /**
     * Initialize the stock item with the passed attributes and returns an instance.
     *
     * @param array $attr The stock item attributes
     *
     * @return array The initialized stock item
     */
    protected function initializeStockItem(array $attr)
    {
        return $attr;
    }

    /**
     * Return's the appings for the table column => CSV column header.
     *
     * @return array The header stock mappings
     */
    protected function getHeaderStockMappings()
    {
        return $this->getSubject()->getHeaderStockMappings();

    }

    /**
     * Persist's the passed stock item data and return's the ID.
     *
     * @param array $stockItem The stock item data to persist
     *
     * @return void
     */
    protected function persistStockItem($stockItem)
    {
        $this->getProductBunchProcessor()->persistStockItem($stockItem);
    }
}


Push — 19.x ( 8328ae...eef76a )

ProductInventoryObserver::process() A

Complexity

Size

Duplication

Code Coverage

Importance

Available Fixes

Available Fixes

1		<?php
2
3		/**
4		* TechDivision\Import\Product\Observers\ProductInventoryObserver
5		*
6		* NOTICE OF LICENSE
7		*
8		* This source file is subject to the Open Software License (OSL 3.0)
9		* that is available through the world-wide-web at this URL:
10		* http://opensource.org/licenses/osl-3.0.php
11		*
12		* PHP version 5
13		*
14		* @author Tim Wagner <[email protected]>
15		* @copyright 2016 TechDivision GmbH <[email protected]>
16		* @license http://opensource.org/licenses/osl-3.0.php Open Software License (OSL 3.0)
17		* @link https://github.com/techdivision/import-product
18		* @link http://www.techdivision.com
19		*/
20
21		namespace TechDivision\Import\Product\Observers;
22
23		use TechDivision\Import\Observers\StateDetectorInterface;
24		use TechDivision\Import\Observers\AttributeLoaderInterface;
25		use TechDivision\Import\Observers\DynamicAttributeObserverInterface;
26		use TechDivision\Import\Product\Utils\ColumnKeys;
27		use TechDivision\Import\Product\Utils\MemberNames;
28		use TechDivision\Import\Product\Services\ProductBunchProcessorInterface;
29		use TechDivision\Import\Subjects\SubjectInterface;
30		use TechDivision\Import\Observers\ObserverFactoryInterface;
31		use TechDivision\Import\Observers\StateDetectorAwareObserverInterface;
32
33		/**
34		* Observer that creates/updates the product's inventory.
35		*
36		* @author Tim Wagner <[email protected]>
37		* @copyright 2016 TechDivision GmbH <[email protected]>
38		* @license http://opensource.org/licenses/osl-3.0.php Open Software License (OSL 3.0)
39		* @link https://github.com/techdivision/import-product
40		* @link http://www.techdivision.com
41		*/
42		class ProductInventoryObserver extends AbstractProductImportObserver implements DynamicAttributeObserverInterface, StateDetectorAwareObserverInterface, ObserverFactoryInterface
43		{
44
45		/**
46		* The product bunch processor instance.
47		*
48		* @var \TechDivision\Import\Product\Services\ProductBunchProcessorInterface
49		*/
50		protected $productBunchProcessor;
51
52		/**
53		* The attribute loader instance.
54		*
55		* @var \TechDivision\Import\Observers\AttributeLoaderInterface
56		*/
57		protected $attributeLoader;
58
59		/**
60		* The array with the column mappings that has to be computed.
61	2	*
62		* @var array
63		*/
64		protected $columns = array();
65	2
66	2	/**
67	2	* Initialize the observer with the passed product bunch processor instance.
68		*
69		* @param \TechDivision\Import\Product\Services\ProductBunchProcessorInterface $productBunchProcessor The product bunch processor instance
70		* @param \TechDivision\Import\Observers\StateDetectorInterface\|null $stateDetector The state detector instance to use
71		*/
72		public function __construct(
73		ProductBunchProcessorInterface $productBunchProcessor,
74	1	AttributeLoaderInterface $attributeLoader,
75		StateDetectorInterface $stateDetector = null
76	1	) {
77
78		// initialize the bunch processor and the attribute loader instance
79		$this->productBunchProcessor = $productBunchProcessor;
80		$this->attributeLoader = $attributeLoader;
81
82		// pass the state detector to the parent method
83		parent::__construct($stateDetector);
		0 ignored issues – show Bug introduced 2019-11-14 21:48 UTC by Report Bug Copy Issue Report It seems like you code against a specific sub-type and not the parent class `TechDivision\Import\Prod...ctProductImportObserver` as the method `__construct()` does only exist in the following sub-classes of `TechDivision\Import\Prod...ctProductImportObserver`: `TechDivision\Import\Prod...ProductRelationObserver`, `TechDivision\Import\Prod...tRelationUpdateObserver`, `TechDivision\Import\Prod...CategoryProductObserver`, `TechDivision\Import\Prod...ryProductUpdateObserver`, `TechDivision\Import\Prod...servers\CleanUpObserver`, `TechDivision\Import\Prod...rs\ClearProductObserver`, `TechDivision\Import\Prod...EntityIdMappingObserver`, `TechDivision\Import\Prod...rs\LastEntityIdObserver`, `TechDivision\Import\Prod...PreLoadEntityIdObserver`, `TechDivision\Import\Prod...roductInventoryObserver`, `TechDivision\Import\Prod...InventoryUpdateObserver`, `TechDivision\Import\Prod...servers\ProductObserver`, `TechDivision\Import\Prod...\ProductWebsiteObserver`, `TechDivision\Import\Prod...ctWebsiteUpdateObserver`, `TechDivision\Import\Prod...bservers\UrlKeyObserver`. Maybe you want to `instanceof` check for one of these explicitly? Let’s take a look at an example: abstract class User { /** @return string / abstract public function getPassword(); } class MyUser extends User { public function getPassword() { // return something } public function getDisplayName() { // return some name. } } class AuthSystem { public function authenticate(User $user) { $this->logger->info(sprintf('Authenticating %s.', $user->getDisplayName())); // do something. } } In the above example, the authenticate() method works fine as long as you just pass instances of MyUser. However, if you now also want to pass a different sub-classes of User which does not have a getDisplayName() method, the code will break. Available Fixes Change the type-hint for the parameter: class AuthSystem { public function authenticate(MyUser $user) { / ... / } } Add an additional type-check: class AuthSystem { public function authenticate(User $user) { if ($user instanceof MyUser) { $this->logger->info(/* ... /); } // or alternatively if ( ! $user instanceof MyUser) { throw new \LogicException( '$user must be an instance of MyUser, ' .'other instances are not supported.' ); } } } Note:* PHP Analyzer uses reverse abstract interpretation to narrow down the types inside the if block in such a case. Add the method to the parent class: abstract class User { /** @return string / abstract public function getPassword(); /* @return string */ abstract public function getDisplayName(); } Loading history...
84	2	}
85
86		/**
87		* Will be invoked by the observer visitor when a factory has been defined to create the observer instance.
88	2	*
89	1	* @param \TechDivision\Import\Subjects\SubjectInterface $subject The subject instance
90		*
91		* @return \TechDivision\Import\Observers\ObserverInterface The observer instance
92		*/
93	1	public function createObserver(SubjectInterface $subject)
94	1	{
95
96		// load the header stock mappings from the subject
97		$headerStockMappings = $subject->getHeaderStockMappings();
		0 ignored issues – show Bug introduced 2019-11-14 21:48 UTC by Report Bug Copy Issue Report The method `getHeaderStockMappings()` does not exist on `TechDivision\Import\Subjects\SubjectInterface`. Did you maybe mean `getHeader()`? This check marks calls to methods that do not seem to exist on an object. This is most likely the result of a method being renamed without all references to it being renamed likewise. Loading history...
98
99		// prepare the array with column name => type mapping
100		foreach ($headerStockMappings as $columnName => $mappings) {
101	1	// explode the mapping details
102		list (, $type) = $mappings;
103		// add the column name => type mapping
104		$this->columns[$columnName] = $type;
105	1	}
106
107		// return the instance itself
108	1	return $this;
109		}
110
111	1	/**
112		* Returns an array of the columns with their types to detect state.
113	1	*
114	1	* @return array The array with the column names as key and their type as value
115	1	*/
116		public function getColumns()
117		{
118		return array_intersect_key($this->columns, $this->getHeaders());
119		}
120
121		/**
122		* Return's the product bunch processor instance.
123		*
124		* @return \TechDivision\Import\Product\Services\ProductBunchProcessorInterface The product bunch processor instance
125	1	*/
126		protected function getProductBunchProcessor()
127	1	{
128		return $this->productBunchProcessor;
129		}
130
131		/**
132		* Process the observer's business logic.
133		*
134		* @return array The processed row
135		*/
136		protected function process()
137	1	{
138
139	1	// query whether or not, we've found a new SKU => means we've found a new product
140		if ($this->hasBeenProcessed($this->getValue(ColumnKeys::SKU))) {
141		return;
142		}
143
144		// prepare, initialize and persist the stock status/item
145		if ($this->hasChanges($entity = $this->initializeStockItem($this->prepareStockItemAttributes()))) {
146		$this->persistStockItem($entity);
147	1	}
148		}
149	1
150		/**
151		* Prepare the basic attributes of the stock status/item entity that has to be persisted.
152		*
153		* @return array The prepared stock status/item attributes
154		*/
155		protected function prepareAttributes()
156		{
157
158		// load the ID of the product that has been created recently
159	1	$lastEntityId = $this->getSubject()->getLastEntityId();
		0 ignored issues – show Bug introduced 2017-09-20 14:48 UTC by Report Bug Copy Issue Report It seems like you code against a concrete implementation and not the interface `TechDivision\Import\Subjects\SubjectInterface` as the method `getLastEntityId()` does only exist in the following implementations of said interface: `TechDivision\Import\Observers\EntitySubjectImpl`, `TechDivision\Import\Plugins\ExportableSubjectImpl`, `TechDivision\Import\Prod...\AbstractProductSubject`, `TechDivision\Import\Product\Subjects\BunchSubject`, `TechDivision\Import\Subjects\ExportableTraitImpl`. Let’s take a look at an example: interface User { /** @return string / public function getPassword(); } class MyUser implements User { public function getPassword() { // return something } public function getDisplayName() { // return some name. } } class AuthSystem { public function authenticate(User $user) { $this->logger->info(sprintf('Authenticating %s.', $user->getDisplayName())); // do something. } } In the above example, the authenticate() method works fine as long as you just pass instances of MyUser. However, if you now also want to pass a different implementation of User which does not have a getDisplayName() method, the code will break. Available Fixes Change the type-hint for the parameter: class AuthSystem { public function authenticate(MyUser $user) { / ... / } } Add an additional type-check: class AuthSystem { public function authenticate(User $user) { if ($user instanceof MyUser) { $this->logger->info(/* ... /); } // or alternatively if ( ! $user instanceof MyUser) { throw new \LogicException( '$user must be an instance of MyUser, ' .'other instances are not supported.' ); } } } Note:* PHP Analyzer uses reverse abstract interpretation to narrow down the types inside the if block in such a case. Add the method to the interface: interface User { /** @return string / public function getPassword(); /* @return string */ public function getDisplayName(); } Loading history...
160
161	1	// initialize the stock status data
162	1	$websiteId = $this->getValue(ColumnKeys::WEBSITE_ID, 0);
163
164		// return the prepared stock status
165		return $this->initializeEntity(
166		array(
167		MemberNames::PRODUCT_ID => $lastEntityId,
168		MemberNames::WEBSITE_ID => $websiteId,
169		MemberNames::STOCK_ID => 1
170		)
171		);
172		}
173
174		/**
175		* Prepare the stock item attributes of the entity that has to be persisted.
176		*
177		* @return array The prepared stock status item
178		*/
179		protected function prepareStockItemAttributes()
180		{
181		return array_merge($this->prepareAttributes(), $this->attributeLoader->load($this, $this->getHeaderStockMappings()));
182		}
183
184		/**
185		* Initialize the stock item with the passed attributes and returns an instance.
186		*
187		* @param array $attr The stock item attributes
188		*
189		* @return array The initialized stock item
190		*/
191		protected function initializeStockItem(array $attr)
192		{
193		return $attr;
194		}
195
196		/**
197		* Return's the appings for the table column => CSV column header.
198		*
199		* @return array The header stock mappings
200		*/
201		protected function getHeaderStockMappings()
202		{
203		return $this->getSubject()->getHeaderStockMappings();
		0 ignored issues – show Bug introduced 2017-07-18 12:51 UTC by Report Bug Copy Issue Report The method `getHeaderStockMappings()` does not exist on `TechDivision\Import\Subjects\SubjectInterface`. Did you maybe mean `getHeader()`? This check marks calls to methods that do not seem to exist on an object. This is most likely the result of a method being renamed without all references to it being renamed likewise. Loading history...
204		}
205
206		/**
207		* Persist's the passed stock item data and return's the ID.
208		*
209		* @param array $stockItem The stock item data to persist
210		*
211		* @return void
212		*/
213		protected function persistStockItem($stockItem)
214		{
215		$this->getProductBunchProcessor()->persistStockItem($stockItem);
216		}
217		}
218

techdivision / import-product

Push — 19.x ( 8328ae...eef76a )

ProductInventoryObserver::process() A

Complexity

Size

Duplication

Code Coverage

Importance

Available Fixes

Available Fixes

Duplication Side-by-Side

Filter issues like