How does a product saving work?

dmitrii_fediuk · January 25, 2016, 4:06pm

magento/magento2/blob/720667e/app/code/Magento/CatalogRule/Plugin/Indexer/Product/Save/ApplyRules.php#L25-L45


/**
 * Apply catalog rules after product resource model save
 *
 * @param \Magento\Catalog\Model\ResourceModel\Product $subject
 * @param callable $proceed
 * @param \Magento\Framework\Model\AbstractModel $product
 * @return \Magento\Catalog\Model\ResourceModel\Product
 *
 * @SuppressWarnings(PHPMD.UnusedFormalParameter)
 */
public function aroundSave(
    \Magento\Catalog\Model\ResourceModel\Product $subject,
    callable $proceed,
    \Magento\Framework\Model\AbstractModel $product
) {
    $productResource = $proceed($product);
    if (!$product->getIsMassupdate()) {
        $this->productRuleProcessor->reindexRow($product->getId());
    }
    return $productResource;
}

github.com

magento/magento2/blob/720667e/app/code/Magento/CatalogSearch/Model/Indexer/Fulltext/Plugin/Product.php#L11-L29


/**
 * Reindex on product save
 *
 * @param \Magento\Catalog\Model\ResourceModel\Product $productResource
 * @param \Closure $proceed
 * @param \Magento\Framework\Model\AbstractModel $product
 * @return \Magento\Catalog\Model\ResourceModel\Product
 * @SuppressWarnings(PHPMD.UnusedFormalParameter)
 */
public function aroundSave(
    \Magento\Catalog\Model\ResourceModel\Product $productResource,
    \Closure $proceed,
    \Magento\Framework\Model\AbstractModel $product
) {
    $productResource->addCommitCallback(function () use ($product) {
        $this->reindexRow($product->getEntityId());
    });
    return $proceed($product);
}

github.com

magento/magento2/blob/720667e/app/code/Magento/Eav/Model/Entity/AbstractEntity.php#L1150-L1157


/**
 * Save entity's attributes into the object's resource
 *
 * @param  \Magento\Framework\Model\AbstractModel $object
 * @return $this
 * @throws \Exception
 */
public function save(\Magento\Framework\Model\AbstractModel $object)

github.com

magento/magento2/blob/720667e/app/code/Magento/Catalog/Model/Product.php#L814-L821


/**
 * Check product options and type options and save them, too
 *
 * @return void
 * @SuppressWarnings(PHPMD.CyclomaticComplexity)
 * @SuppressWarnings(PHPMD.NPathComplexity)
 */
public function beforeSave()

github.com

magento/magento2/blob/720667e/app/code/Magento/Catalog/Model/Product.php#L823-L827


$this->cleanCache();
$this->setTypeHasOptions(false);
$this->setTypeHasRequiredOptions(false);
$this->setHasOptions(false);
$this->setRequiredOptions(false);

github.com

magento/magento2/blob/720667e/app/code/Magento/Catalog/Model/Product/Type/AbstractType.php#L723-L729


/**
 * Before save type related data
 *
 * @param \Magento\Catalog\Model\Product $product
 * @return $this
 */
public function beforeSave($product)

github.com

magento/magento2/blob/720667e/app/code/Magento/Catalog/Model/Product/Type/AbstractType.php#L731-L732


$this->_removeNotApplicableAttributes($product);
$product->canAffectOptions(true);

github.com

magento/magento2/blob/720667e/app/code/Magento/Catalog/Model/AbstractModel.php#L323-L328


/**
 * Before save unlock attributes
 *
 * @return \Magento\Catalog\Model\AbstractModel
 */
public function beforeSave()

github.com

magento/magento2/blob/720667e/lib/internal/Magento/Framework/Model/AbstractModel.php#L651-L656


/**
 * Processing object before save data
 *
 * @return $this
 */
public function beforeSave()

github.com

magento/magento2/blob/720667e/lib/internal/Magento/Framework/Model/AbstractModel.php#L661-L662


$this->_eventManager->dispatch('model_save_before', ['object' => $this]);
$this->_eventManager->dispatch($this->_eventPrefix . '_save_before', $this->_getEventData());

github.com

magento/magento2/blob/720667e/app/code/Magento/CatalogUrlRewrite/Observer/ProductUrlKeyAutogeneratorObserver.php#L33-L34


$product = $observer->getEvent()->getProduct();
$product->setUrlKey($this->productUrlPathGenerator->getUrlKey($product));

github.com

magento/magento2/blob/720667e/app/code/Magento/NewRelicReporting/Model/Observer/ReportProductSaved.php#L47-L53


/**
 * Reports any products created or updated to the database reporting_system_updates table
 *
 * @param Observer $observer
 * @return void
 */
public function execute(Observer $observer)

github.com

magento/magento2/blob/720667e/app/code/Magento/NewRelicReporting/Model/Observer/ReportProductSavedToNewRelic.php#L40-L46


/**
 * Reports any products created or updated to New Relic
 *
 * @param Observer $observer
 * @return void
 */
public function execute(Observer $observer)

github.com

magento/magento2/blob/720667e/app/code/Magento/Eav/Model/Entity/AbstractEntity.php#L1173-L1175


if (!$this->isPartialSave()) {
    $this->loadAllAttributes($object);
}

github.com

magento/magento2/blob/720667e/app/code/Magento/Eav/Model/Entity/AbstractEntity.php#L531-L537


/**
 * Retrieve configuration for all attributes
 *
 * @param null|\Magento\Framework\DataObject $object
 * @return $this
 */
public function loadAllAttributes($object = null)

How is \Magento\Framework\DataObject\AttributeLoaderInterface::loadAllAttributes() implemented?
How does \Magento\Eav\Model\Entity\AttributeLoader::loadAllAttributes() work?

github.com

magento/magento2/blob/720667e/app/code/Magento/Catalog/Model/ResourceModel/Product.php#L255-L261


/**
 * Process product data before save
 *
 * @param \Magento\Framework\DataObject $object
 * @return $this
 */
protected function _beforeSave(\Magento\Framework\DataObject $object)

github.com

magento/magento2/blob/720667e/app/code/Magento/Eav/Model/Entity/AbstractEntity.php#L1819-L1819


$this->walkAttributes('backend/beforeSave', [$object]);

github.com

magento/magento2/blob/720667e/app/code/Magento/Eav/Model/Entity/Attribute/Backend/AbstractBackend.php#L265-L279


/**
 * Before save method
 *
 * @param \Magento\Framework\DataObject $object
 * @return $this
 */
public function beforeSave($object)
{
    $attrCode = $this->getAttribute()->getAttributeCode();
    if (!$object->hasData($attrCode) && $this->getDefaultValue()) {
        $object->setData($attrCode, $this->getDefaultValue());
    }


    return $this;
}

github.com

magento/magento2/blob/720667e/app/code/Magento/Eav/Model/Entity/Attribute/Backend/Time/Created.php#L27-L42


/**
 * Set created date
 *
 * @param \Magento\Framework\Model\AbstractModel $object
 * @return $this
 */
public function beforeSave($object)
{
    $attributeCode = $this->getAttribute()->getAttributeCode();
    if ($object->isObjectNew() && $object->getData($attributeCode) === null) {
        //$object->setData($attributeCode, $this->dateTime->gmtDate());
        $object->setData($attributeCode, gmdate('Y-m-d H:i:s'));
    }


    return $this;
}

github.com

magento/magento2/blob/720667e/app/code/Magento/Eav/Model/Entity/Attribute/Backend/Time/Updated.php#L27-L40


/**
 * Set modified date
 *
 * @param \Magento\Framework\DataObject $object
 * @return $this
 */
public function beforeSave($object)
{
    $object->setData(
        $this->getAttribute()->getAttributeCode(),
        (new \DateTime())->format(\Magento\Framework\Stdlib\DateTime::DATETIME_PHP_FORMAT)
    );
    return $this;
}

github.com

magento/magento2/blob/720667e/app/code/Magento/Catalog/Model/Product/Attribute/Backend/Sku.php#L88-L98


/**
 * Make SKU unique before save
 *
 * @param Product $object
 * @return $this
 */
public function beforeSave($object)
{
    $this->_generateUniqueSku($object);
    return parent::beforeSave($object);
}

github.com

magento/magento2/blob/720667e/app/code/Magento/Catalog/Model/Product/Attribute/Backend/Boolean.php#L15-L28


/**
 * Set attribute default value if value empty
 *
 * @param \Magento\Framework\DataObject $object
 * @return $this
 */
public function beforeSave($object)
{
    $attributeCode = $this->getAttribute()->getName();
    if ($object->getData('use_config_' . $attributeCode)) {
        $object->setData($attributeCode, '');
    }
    return $this;
}

github.com

magento/magento2/blob/720667e/app/code/Magento/Catalog/Model/Product/Attribute/Backend/Stock.php#L50-L67


/**
 * Prepare inventory data from custom attribute
 *
 * @param Product $object
 * @return void
 */
public function beforeSave($object)
{
    $stockData = $object->getData($this->getAttribute()->getAttributeCode());
    if (isset($stockData['qty']) && $stockData['qty'] === '') {
        $stockData['qty'] = null;
    }
    if ($object->getStockData() !== null || $stockData !== null) {
        $object->setStockData(array_replace((array)$object->getStockData(), (array)$stockData));
    }
    $object->unsetData($this->getAttribute()->getAttributeCode());
    parent::beforeSave($object);
}

github.com

magento/magento2/blob/720667e/app/code/Magento/Catalog/Model/ResourceModel/Product.php#L659-L662


$this->entityManager->save(
    \Magento\Catalog\Api\Data\ProductInterface::class,
    $object
);

github.com

magento/magento2/blob/720667e/lib/internal/Magento/Framework/Model/EntityManager.php#L52-L58


/**
 * @param string $entityType
 * @param object $entity
 * @return bool|object
 * @throws \Exception
 */
public function save($entityType, $entity)

github.com

magento/magento2/blob/720667e/lib/internal/Magento/Framework/Model/EntityManager.php#L60-L60


$hydrator = $this->metadataPool->getHydrator($entityType);

The $hydrator is an instance of the \Magento\Framework\Model\Entity\EntityHydrator class.

github.com

magento/magento2/blob/720667e/lib/internal/Magento/Framework/Model/EntityManager.php#L61-L61


$metadata = $this->metadataPool->getMetadata($entityType);

Details: How does \Magento\Framework\EntityManager\MetadataPool::getMetadata() work?

The $metadata is an instance of the \Magento\Framework\Model\Entity\EntityMetadata class.

github.com

magento/magento2/blob/720667e/lib/internal/Magento/Framework/Model/Entity/EntityHydrator.php#L18-L22


public function extract($entity)
{
    //TODO: refactor with using API data interfaces
    return $entity->getData();
}

github.com

magento/magento2/blob/720667e/lib/internal/Magento/Framework/Model/EntityManager.php#L63-L69


if (!empty($entityData[$metadata->getIdentifierField()])
    && $metadata->checkIsEntityExists($entityData[$metadata->getIdentifierField()])
) {
    $operation = $this->orchestratorPool->getWriteOperation($entityType, 'update');
} else {
    $operation = $this->orchestratorPool->getWriteOperation($entityType, 'create');
}

github.com

magento/magento2/blob/720667e/lib/internal/Magento/Framework/Model/EntityManager.php#L66-L66


$operation = $this->orchestratorPool->getWriteOperation($entityType, 'update');

github.com

magento/magento2/blob/720667e/lib/internal/Magento/Framework/Model/EntityManager.php#L70-L70


return $operation->execute($entityType, $entity);

github.com

magento/magento2/blob/720667e/lib/internal/Magento/Framework/Model/Operation/Write/Update.php#L49-L61


/**
 * @param string $entityType
 * @param object $entity
 * @return object
 * @throws \Exception
 */
public function execute($entityType, $entity)
{
    $entity = $this->updateMain->execute($entityType, $entity);
    $entity = $this->updateExtension->execute($entityType, $entity);
    $entity = $this->updateRelation->execute($entityType, $entity);
    return $entity;
}

github.com

magento/magento2/blob/720667e/lib/internal/Magento/Framework/Model/Operation/Write/Update.php#L57-L57


$entity = $this->updateMain->execute($entityType, $entity);

github.com

magento/magento2/blob/720667e/lib/internal/Magento/Framework/Model/Entity/Action/UpdateMain.php#L39-L52


/**
 * @param string $entityType
 * @param object $entity
 * @param array $data
 * @return object
 */
public function execute($entityType, $entity, $data = [])
{
    $hydrator = $this->metadataPool->getHydrator($entityType);
    $entityData = array_merge($hydrator->extract($entity), $data);
    $this->updateEntityRow->execute($entityType, $entityData);
    $hydrator->hydrate($entity, $entityData);
    return $entity;
}

github.com

magento/magento2/blob/720667e/lib/internal/Magento/Framework/Model/Entity/Action/UpdateMain.php#L49-L49


$this->updateEntityRow->execute($entityType, $entityData);

github.com

magento/magento2/blob/720667e/lib/internal/Magento/Framework/Model/ResourceModel/Db/UpdateEntityRow.php#L51-L66


/**
 * @param string $entityType
 * @param array $data
 * @return bool
 * @throws \Exception
 */
public function execute($entityType, $data)
{
    $metadata = $this->metadataPool->getMetadata($entityType);
    $connection = $metadata->getEntityConnection();
    return $connection->update(
        $metadata->getEntityTable(),
        $this->prepareData($metadata, $data),
        [$metadata->getLinkField() . ' = ?' => $data[$metadata->getLinkField()]]
    );
}

github.com

magento/magento2/blob/720667e/lib/internal/Magento/Framework/Model/Entity/Action/UpdateMain.php#L50-L50


$hydrator->hydrate($entity, $entityData);

github.com

magento/magento2/blob/720667e/lib/internal/Magento/Framework/Model/Entity/EntityHydrator.php#L24-L34


/**
 * @param object $entity
 * @param array $data
 * @return object
 */
public function hydrate($entity, array $data)
{
    //TODO: refactor with using API data interfaces
    $entity->setData(array_merge($entity->getData(), $data));
    return $entity;
}

github.com

magento/magento2/blob/720667e/lib/internal/Magento/Framework/Model/Operation/Write/Update.php#L58-L58


$entity = $this->updateExtension->execute($entityType, $entity);

github.com

magento/magento2/blob/720667e/lib/internal/Magento/Framework/Model/Entity/Action/UpdateExtension.php#L39-L56


/**
 * @param string $entityType
 * @param object $entity
 * @param array $data
 * @return object
 * @throws \Exception
 */
public function execute($entityType, $entity, $data = [])
{
    $hydrator = $this->metadataPool->getHydrator($entityType);
    $entityData = array_merge($hydrator->extract($entity), $data);
    $actions = $this->extensionPool->getActions($entityType, 'update');
    foreach ($actions as $action) {
        $action->execute($entityType, $entityData);
        $entity = $hydrator->hydrate($entity, $entityData);
    }
    return $entity;
}

github.com

magento/magento2/blob/720667e/lib/internal/Magento/Framework/Model/Entity/Action/UpdateExtension.php#L50-L50


$actions = $this->extensionPool->getActions($entityType, 'update');

github.com

magento/magento2/blob/720667e/app/code/Magento/Eav/etc/di.xml#L65-L77


<type name="Magento\Framework\Model\ResourceModel\Db\ExtensionPool">
    <arguments>
        <argument name="extensionActions" xsi:type="array">
            <item name="eav" xsi:type="array">
                <item name="default" xsi:type="array">
                    <item name="read" xsi:type="string">Magento\Eav\Model\ResourceModel\ReadHandler</item>
                    <item name="create" xsi:type="string">Magento\Eav\Model\ResourceModel\CreateHandler</item>
                    <item name="update" xsi:type="string">Magento\Eav\Model\ResourceModel\UpdateHandler</item>
                </item>
            </item>
        </argument>
    </arguments>
</type>

github.com

magento/magento2/blob/720667e/app/code/Magento/CatalogRule/etc/di.xml#L90-L102


<type name="Magento\Framework\Model\ResourceModel\Db\ExtensionPool">
    <arguments>
        <argument name="extensionActions" xsi:type="array">
            <item name="catalogRule" xsi:type="array">
                <item name="Magento\CatalogRule\Api\Data\RuleInterface" xsi:type="array">
                    <item name="read" xsi:type="string">Magento\CatalogRule\Model\ResourceModel\ReadHandler</item>
                    <item name="create" xsi:type="string">Magento\CatalogRule\Model\ResourceModel\SaveHandler</item>
                    <item name="update" xsi:type="string">Magento\CatalogRule\Model\ResourceModel\SaveHandler</item>
                </item>
            </item>
        </argument>
    </arguments>
</type>

github.com

magento/magento2/blob/720667e/lib/internal/Magento/Framework/Model/Entity/Action/UpdateExtension.php#L52-L52


$action->execute($entityType, $entityData);

github.com

magento/magento2/blob/720667e/app/code/Magento/Eav/Model/ResourceModel/UpdateHandler.php#L103-L111


/**
 * @param string $entityType
 * @param array $data
 * @return array
 * @throws \Exception
 * @SuppressWarnings(PHPMD.CyclomaticComplexity)
 * @SuppressWarnings(PHPMD.NPathComplexity)
 */
public function execute($entityType, $data)

github.com

magento/magento2/blob/720667e/app/code/Magento/Eav/Model/ResourceModel/UpdateHandler.php#L116-L116


$context = $this->getActionContext($entityType, $data);

github.com

magento/magento2/blob/720667e/app/code/Magento/Eav/Model/ResourceModel/UpdateHandler.php#L117-L117


$snapshot = $this->readSnapshot->execute($entityType, $data);

github.com

magento/magento2/blob/720667e/app/code/Magento/Eav/Model/ResourceModel/ReadHandler.php#L94-L101


/**
 * @param string $entityType
 * @param array $entityData
 * @return array
 * @throws \Exception
 * @throws \Magento\Framework\Exception\LocalizedException
 */
public function execute($entityType, $entityData)

github.com

magento/magento2/blob/720667e/app/code/Magento/Eav/Model/ResourceModel/ReadHandler.php#L109-L113


foreach ($this->getAttributes($entityType) as $attribute) {
    if (!$attribute->isStatic()) {
        $attributeTables[$attribute->getBackend()->getTable()][] = $attribute->getAttributeId();
    }
}

github.com

magento/magento2/blob/720667e/app/code/Magento/Eav/Model/ResourceModel/ReadHandler.php#L114-L134


$selects = [];
foreach ($attributeTables as $attributeTable => $attributeCodes) {
    $select = $metadata->getEntityConnection()->select()
        ->from(['t' => $attributeTable], ['value' => 't.value'])
        ->join(
            ['a' => $this->appResource->getTableName('eav_attribute')],
            'a.attribute_id = t.attribute_id',
            ['attribute_code' => 'a.attribute_code']
        )
        ->where($metadata->getLinkField() . ' = ?', $entityData[$metadata->getLinkField()])
        ->where('t.attribute_id IN (?)', $attributeCodes)
        ->order('a.attribute_id');
    foreach ($context as $field => $value) {
        //TODO: if (in table exists context field)
        $select->where(
            $metadata->getEntityConnection()->quoteIdentifier($field) . ' IN (?)',
            $value
        )->order('t.' . $field . ' DESC');
    }
    $selects[] = $select;
}

github.com

magento/magento2/blob/720667e/app/code/Magento/Eav/Model/ResourceModel/ReadHandler.php#L136-L143


$unionSelect = new \Magento\Framework\DB\Sql\UnionExpression(
    $selects,
    \Magento\Framework\DB\Select::SQL_UNION_ALL
);
$attributeValues = $metadata->getEntityConnection()->fetchAll((string)$unionSelect);
foreach ($attributeValues as $attributeValue) {
    $data[$attributeValue['attribute_code']] = $attributeValue['value'];
}

github.com

magento/magento2/blob/720667e/app/code/Magento/Eav/Model/ResourceModel/UpdateHandler.php#L119-L119


foreach ($this->getAttributes($entityType) as $attribute) {

github.com

magento/magento2/blob/720667e/app/code/Magento/Eav/Model/ResourceModel/UpdateHandler.php#L123-L133


if (isset($snapshot[$attribute->getAttributeCode()])
    && $snapshot[$attribute->getAttributeCode()] !== false
    && (array_key_exists($attribute->getAttributeCode(), $data)
        && $attribute->isValueEmpty($data[$attribute->getAttributeCode()]))
) {
    $this->attributePersistor->registerDelete(
        $entityType,
        $data[$metadata->getLinkField()],
        $attribute->getAttributeCode()
    );
}

github.com

magento/magento2/blob/720667e/app/code/Magento/Eav/Model/ResourceModel/UpdateHandler.php#L134-L146


if ((!array_key_exists($attribute->getAttributeCode(), $snapshot)
    || $snapshot[$attribute->getAttributeCode()] === false)
    && !empty($data[$attribute->getAttributeCode()])
    && !$attribute->isValueEmpty($data[$attribute->getAttributeCode()])
) {
    $this->attributePersistor->registerInsert(
        $entityType,
        $data[$metadata->getLinkField()],
        $attribute->getAttributeCode(),
        $data[$attribute->getAttributeCode()]
    );
    $processed[$attribute->getAttributeCode()] = $data[$attribute->getAttributeCode()];
}

github.com

magento/magento2/blob/720667e/app/code/Magento/Eav/Model/ResourceModel/UpdateHandler.php#L147-L160


if (array_key_exists($attribute->getAttributeCode(), $snapshot)
    && $snapshot[$attribute->getAttributeCode()] !== false
    && !empty($data[$attribute->getAttributeCode()])
    && $snapshot[$attribute->getAttributeCode()] != $data[$attribute->getAttributeCode()]
    && !$attribute->isValueEmpty($data[$attribute->getAttributeCode()])
) {
    $this->attributePersistor->registerUpdate(
        $entityType,
        $data[$metadata->getLinkField()],
        $attribute->getAttributeCode(),
        $data[$attribute->getAttributeCode()]
    );
    $processed[$attribute->getAttributeCode()] = $data[$attribute->getAttributeCode()];
}

github.com

magento/magento2/blob/720667e/app/code/Magento/Eav/Model/ResourceModel/UpdateHandler.php#L162-L162


$this->attributePersistor->flush($entityType, $context);

github.com

magento/magento2/blob/720667e/app/code/Magento/Eav/Model/ResourceModel/AttributePersistor.php#L206-L220


/**
 * Flush attributes to storage
 *
 * @param string $entityType
 * @param array $context
 * @return void
 */
public function flush($entityType, $context)
{
    $this->processDeletes($entityType, $context);
    $this->processInserts($entityType, $context);
    $this->processUpdates($entityType, $context);


    unset($this->delete, $this->insert, $this->update);
}

github.com

magento/magento2/blob/720667e/lib/internal/Magento/Framework/Model/Entity/Action/UpdateExtension.php#L53-L53


$entity = $hydrator->hydrate($entity, $entityData);

github.com

magento/magento2/blob/720667e/lib/internal/Magento/Framework/Model/Operation/Write/Update.php#L59-L59


$entity = $this->updateRelation->execute($entityType, $entity);

github.com

magento/magento2/blob/720667e/lib/internal/Magento/Framework/Model/Entity/Action/UpdateRelation.php#L39-L52


/**
 * @param string $entityType
 * @param object $entity
 * @return object
 * @throws \Exception
 */
public function execute($entityType, $entity)
{
    $actions = $this->relationActionPool->getActions($entityType, 'update');
    foreach ($actions as $action) {
        $entity = $action->execute($entityType, $entity);
    }
    return $entity;
}

github.com

magento/magento2/blob/720667e/lib/internal/Magento/Framework/Model/Entity/Action/UpdateRelation.php#L47-L47


$actions = $this->relationActionPool->getActions($entityType, 'update');

github.com

magento/magento2/blob/720667e/app/code/Magento/Catalog/etc/di.xml#L567-L586


<type name="Magento\Framework\Model\ResourceModel\Db\Relation\ActionPool">
    <arguments>
        <argument name="relationActions" xsi:type="array">
            <item name="Magento\Catalog\Api\Data\ProductInterface" xsi:type="array">
                <item name="read" xsi:type="array">
                    <item name="optionReader" xsi:type="string">Magento\Catalog\Model\Product\Option\ReadHandler</item>
                    <item name="mediaGalleryRead" xsi:type="string">Magento\Catalog\Model\Product\Gallery\ReadHandler</item>
                </item>
                <item name="create" xsi:type="array">
                    <item name="custom_options" xsi:type="string">Magento\Catalog\Model\Product\Option\SaveHandler</item>
                    <item name="mediaGalleryCreate" xsi:type="string">Magento\Catalog\Model\Product\Gallery\CreateHandler</item>
                </item>
                <item name="update" xsi:type="array">
                    <item name="optionUpdater" xsi:type="string">Magento\Catalog\Model\Product\Option\SaveHandler</item>
                    <item name="mediaGalleryUpdate" xsi:type="string">Magento\Catalog\Model\Product\Gallery\UpdateHandler</item>
                </item>
            </item>
        </argument>
    </arguments>
</type>

github.com

magento/magento2/blob/720667e/app/code/Magento/Bundle/etc/di.xml#L83-L99


<type name="Magento\Framework\Model\ResourceModel\Db\Relation\ActionPool">
    <arguments>
        <argument name="relationActions" xsi:type="array">
            <item name="Magento\Catalog\Api\Data\ProductInterface" xsi:type="array">
                <item name="create" xsi:type="array">
                    <item name="create_bundle_options" xsi:type="string">Magento\Bundle\Model\Product\SaveHandler</item>
                </item>
                <item name="update" xsi:type="array">
                    <item name="update_bundle_options" xsi:type="string">Magento\Bundle\Model\Product\SaveHandler</item>
                </item>
                <item name="read" xsi:type="array">
                    <item name="read_bundle_options" xsi:type="string">Magento\Bundle\Model\Product\ReadHandler</item>
                </item>
            </item>
        </argument>
    </arguments>
</type>

github.com

magento/magento2/blob/720667e/app/code/Magento/Downloadable/etc/di.xml#L78-L100


<type name="Magento\Framework\Model\ResourceModel\Db\Relation\ActionPool">
    <arguments>
        <argument name="relationActions" xsi:type="array">
            <item name="Magento\Catalog\Api\Data\ProductInterface" xsi:type="array">
                <item name="read" xsi:type="array">
                    <item name="downloadable_link_read" xsi:type="string">Magento\Downloadable\Model\Link\ReadHandler</item>
                    <item name="downloadable_sample_read" xsi:type="string">Magento\Downloadable\Model\Sample\ReadHandler</item>
                </item>
                <item name="create" xsi:type="array">
                    <item name="downloadable_link_create" xsi:type="string">Magento\Downloadable\Model\Link\SaveHandler</item>
                    <item name="downloadable_sample_create" xsi:type="string">Magento\Downloadable\Model\Sample\SaveHandler</item>
                </item>
                <item name="update" xsi:type="array">
                    <item name="downloadable_link_update" xsi:type="string">Magento\Downloadable\Model\Sample\SaveHandler</item>
                    <item name="downloadable_sample_update" xsi:type="string">Magento\Downloadable\Model\Link\SaveHandler</item>
                </item>
                <item name="delete" xsi:type="array">
                    <item name="downloadable_link_delete" xsi:type="string">Magento\Downloadable\Model\Sample\DeleteHandler</item>
                    <item name="downloadable_sample_delete" xsi:type="string">Magento\Downloadable\Model\Link\DeleteHandler</item>
                </item>
            </item>
        </argument>
    </arguments>

github.com

magento/magento2/blob/720667e/lib/internal/Magento/Framework/Model/Entity/Action/UpdateRelation.php#L49-L49


$entity = $action->execute($entityType, $entity);

github.com

magento/magento2/blob/720667e/app/code/Magento/Catalog/Model/Product/Option/SaveHandler.php#L39-L57


/**
 * @param string $entityType
 * @param object $entity
 * @return object
 * @SuppressWarnings(PHPMD.UnusedFormalParameter)
 */
public function execute($entityType, $entity)
{
    /** @var \Magento\Catalog\Api\Data\ProductInterface $entity */
    foreach ($this->optionRepository->getProductOptions($entity) as $option) {
        $this->optionRepository->delete($option);
    }
    if ($entity->getOptions()) {
        foreach ($entity->getOptions() as $option) {
            $this->optionRepository->save($option);
        }
    }
    return $entity;
}

github.com

magento/magento2/blob/720667e/app/code/Magento/ProductVideo/Model/Plugin/Catalog/Product/Gallery/CreateHandler.php#L27-L44


public function beforeExecute(
    \Magento\Catalog\Model\Product\Gallery\CreateHandler $mediaGalleryCreateHandler,
    $entityType,
    \Magento\Catalog\Model\Product $product
) {
    $attribute = $mediaGalleryCreateHandler->getAttribute();
    $mediaCollection = $this->getMediaEntriesDataCollection($product, $attribute);
    if (!empty($mediaCollection)) {
        $storeDataCollection = $this->loadStoreViewVideoData($mediaCollection, $product->getStoreId());
        $mediaCollection = $this->addAdditionalStoreData($mediaCollection, $storeDataCollection);
        $product->setData(
            $attribute->getAttributeCode(),
            $mediaCollection + $product->getData($attribute->getAttributeCode())
        );
    }


    return [$entityType, $product];
}

github.com

magento/magento2/blob/720667e/app/code/Magento/Catalog/Model/Product/Gallery/CreateHandler.php#L86-L94


/**
 * @param string $entityType
 * @param \Magento\Catalog\Model\Product $product
 * @return \Magento\Catalog\Model\Product
 * @SuppressWarnings(PHPMD.CyclomaticComplexity)
 * @SuppressWarnings(PHPMD.UnusedFormalParameter)
 * @SuppressWarnings(PHPMD.NPathComplexity)
 */
public function execute($entityType, $product)

github.com

magento/magento2/blob/720667e/app/code/Magento/Catalog/Model/Product/Gallery/CreateHandler.php#L180-L180


$this->processDeletedImages($product, $value['images']);

github.com

magento/magento2/blob/720667e/app/code/Magento/Catalog/Model/Product/Gallery/UpdateHandler.php#L16-L16


protected function processDeletedImages($product, array &$images)

github.com

magento/magento2/blob/720667e/app/code/Magento/Catalog/Model/Product/Gallery/UpdateHandler.php#L26-L33


foreach ($images as &$image) {
    if (!empty($image['removed'])) {
        if (!empty($image['value_id']) && !isset($picturesInOtherStores[$image['file']])) {
            $recordsToDelete[] = $image['value_id'];
            $filesToDelete[] = ltrim($image['file'], '/');
        }
    }
}

dmitrii_fediuk · April 23, 2016, 9:42pm