Zemit\Mvc\Model\Relationship::preSaveRelatedRecords()

Complexity

Conditions	10
Paths	16

Size

Total Lines	91
Code Lines	27

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	110

Importance

Changes	1
Bugs	1	Features	0

<?php
    protected function preSaveRelatedRecords(\Phalcon\Db\Adapter\AdapterInterface $connection, $related): bool
    {
        $nesting = false;
        
        /**
         * Start an implicit transaction
         */
        $connection->begin($nesting);
        
        $className = get_class($this);
        
        /** @var ManagerInterface $manager */
        $manager = $this->getModelsManager();
        
        /**
         * @var string $alias alias
         * @var ModelInterface $record
         */
        foreach ($related as $alias => $record) {
            /**
             * Try to get a relation with the same name
             */
            $relation = $manager->getRelationByAlias($className, $alias);
            
            if ($relation) {
                /**
                 * Get the relation type
                 */
                $type = $relation->getType();
                
                /**
                 * Only belongsTo are stored before save the master record
                 */
                if ($type === Relation::BELONGS_TO) {
                    
                    /**
                     * We only support model interface for the belongs-to relation
                     */
                    if (!($record instanceof ModelInterface)) {
                        $connection->rollback($nesting);
                        throw new Exception(
                            'Instance of `' . get_class($record) . '` received on model `' . $className . '` in alias `' . $alias .
                            ', expected instance of `' . ModelInterface::class . '` as part of the belongs-to relation',
                            400
                        );
                    }
                    
                    /**
                     * Get columns and referencedFields as array
                     */
                    $referencedFields = $relation->getReferencedFields();
                    $columns = $relation->getFields();
                    $referencedFields = is_array($referencedFields) ? $referencedFields : [$referencedFields];
                    $columns = is_array($columns) ? $columns : [$columns];
                    
                    /**
                     * Set the relationship context
                     */
                    $record->_setRelationshipContext($this->_getRelationshipContext() . '.' . $alias);
                    
                    /**
                     * If dynamic update is enabled, saving the record must not take any action
                     * Only save if the model is dirty to prevent circular relations causing an infinite loop
                     */
                    if ($record->getDirtyState() !== Model::DIRTY_STATE_PERSISTENT && !$record->save()) {
                        
                        /**
                         * Append messages with context
                         */
                        $this->appendMessagesFromRecord($record, $alias);
                        
                        /**
                         * Rollback the implicit transaction
                         */
                        $connection->rollback($nesting);
                        
                        return false;
                    }
                    
                    /**
                     * Read the attributes from the referenced model and assign
                     * it to the current model
                     */
                    foreach ($referencedFields as $key => $referencedField) {
                        $this->{$columns[$key]} = $record->readAttribute($referencedField);
                    }
                }
            }
        }
        
        return true;
    }