MongoSyncTrait::processOneEmbededRelationship() - Code Metrics - Inspection of "[GF] Fix and remove comments" - offline-agency/laravel-mongo-auto-sync - Measure and Improve Code Quality continuously with Scrutinizer

Passed
Push — master ( 4fb543...e7c8f8 )

by Giacomo
created 2020-01-23 17:05 UTC
MongoSyncTrait::processOneEmbededRelationship() C

↳ Parent: MongoSyncTrait
Complexity

Conditions	14
Paths	64
Size

Total Lines	70
Code Lines	39
Duplication

Lines	0
Ratio	0 %
Importance

Changes	3
Bugs	1	Features	0
Metric	Value
cc	14
eloc	39
c	3
b	1
f	0
nc	64
nop	14
dl	0
loc	70
rs	6.2666
How to fix Long Method Complexity Many Parameters

<?php

namespace OfflineAgency\MongoAutoSync\Traits;

use DateTime;
use Exception;
use Illuminate\Http\Request;
use MongoDB\BSON\UTCDateTime;

trait MongoSyncTrait
{
    /**
     * @param Request $request
     * @param array $additionalData
     * @param array $options
     * @return $this
     * @throws Exception
     */
    public function storeWithSync(Request $request, array $additionalData = [], array $options = [])
    {
        $request = $request->merge($additionalData);

        $this->storeEditAllItems($request, "add", $options);
        $this->processAllRelationships($request, "add", "", "", $options);

        //Dispatch the creation event
        $this->fireModelEvent('storeWithSync');
               fireModelEvent('storeWithSync');

        return $this;
    }

    /**
     * @param Request $request
     * @param string $event
     * @param array $options
     * @throws Exception
     */
    public function storeEditAllItems(Request $request, string $event, array $options)
    {
        //Get the item name
        $items = $this->getItems();
        $items = $this->getItems();
        $is_skippable = $this->getOptionValue($options, 'request_type');
        //Current Obj Create
        foreach ($items as $key => $item) {
            $is_ML = isML($item);
            $is_MD = isMD($item);

            $is_fillable = isFillable($item, $event);
            if ( is_null($request->input($key)) && $is_skippable ) { continue; }//Skip with partial request type

            if ($is_fillable) {
                if ($is_ML) {
                    if (is_null($this->$key)) {
                        $old_value = array();
                    } else {
                        $old_value = $this->$key;
                    }
                    $this->$key = ml($old_value, $request->input($key));
                } elseif ($is_MD) {
                    if ($request->input($key) == "" || $request->input($key) == null) {
                        $this->$key = null;
                    } else {
                        $this->$key = new UTCDateTime(new DateTime($request->input($key)));
                        $this->$key = new UTCDateTime(/** @scrutinizer ignore-type */ new DateTime($request->input($key)));
                    }
                } else {
                    $this->$key = $request->input($key);
                }
            }
        }

        $this->save();
               save();
    }

    /**
     * @param Request $request
     * @param string $event
     * @param string $parent
     * @param string $counter
     * @param array $options
     * @throws Exception
     */
    public function processAllRelationships(Request $request, string $event, string $parent, string $counter, array $options)
    {
        //Get the relation info
        $relations = $this->getMongoRelation();
        $relations = $this->getMongoRelation();

        //Process all relationships
        foreach ($relations as $method => $relation) {
            //Get Relation Save Mode
            $type = $relation['type'];
            $model = $relation['model'];
            $hasTarget = hasTarget($relation);
            if ($hasTarget) {
                $modelTarget = $relation['modelTarget'];
                $methodOnTarget = $relation['methodOnTarget'];
                $modelOnTarget = $relation['modelOnTarget'];
            } else {
                $modelTarget = "";
                $methodOnTarget = "";
                $modelOnTarget = "";
            }

            $is_EO = is_EO($type);
            $is_EM = is_EM($type);
            $is_skippable = $this->getOptionValue($options, 'request_type');

            $key = $parent . $method . $counter;
            $value = $request->input($key);
            if ( is_null($value) && $is_skippable ) { continue; }//Skip with partial request type

            if (!is_null($value) && !($value == "") && !($value == "[]")) {
                $objs = json_decode($value);
            } else {
                $objs = getArrayWithEmptyObj($model, $is_EO, $is_EM);
            }

            if ($is_EO || $is_EM) {//EmbedsOne Create - EmbedsMany Create
                if ($event == "update") {

                    //Delete EmbedsMany or EmbedsOne on Target
                    if ($hasTarget) {
                        $this->deleteTargetObj($method, $modelTarget, $methodOnTarget, $is_EO);
                    }
                    //Delete EmbedsMany or EmbedsOne on current object
                    if ($is_EM) {
                        $this->$method()->delete();
                    }
                }

                if (!empty($objs)) {
                    $i = 0;
                    foreach ($objs as $obj) {
                        $this->processOneEmbededRelationship(
                            $request,
                            $obj,
                            $type,
                            $model,
                            $method,
                            $modelTarget,
                            $methodOnTarget,
                            $modelOnTarget, $event,
                            $hasTarget,
                            $is_EO,
                            $is_EM,
                            $i,
                            $options);
                        $i++;
                    }
                } else {
                    $this->$method = [];
                    $this->save();
                }
            }
        }
    }

    /**
     * @param Request $request
     * @param $methodOnTarget
     * @param $modelOnTarget
     * @throws Exception
     */
    public function updateRelationWithSync(Request $request, $methodOnTarget, $modelOnTarget)
    {
        $embededModel = new $modelOnTarget;
        //Get the item name
        $items = $embededModel->getItems();
        $embededObj = $request->input($methodOnTarget);
        $embededObj = json_decode($embededObj);

        //Current Obj Create
        foreach ($items as $key => $item) {
            $is_ML = isML($item);
            $is_MD = isMD($item);

            if ($is_ML) {
                $embededModel->$key = ml(array(), $embededObj->$key);
            } elseif ($is_MD) {
                if ($embededObj->$key == "" || $embededObj->$key == null) {
                    $embededModel->$key = null;
                } else {
                    $embededModel->$key = new UTCDateTime(new DateTime($embededObj->$key));
                    $embededModel->$key = new UTCDateTime(/** @scrutinizer ignore-type */ new DateTime($embededObj->$key));
                }
            } else {
                $embededModel->$key = $embededObj->$key;
            }
        }
        $this->$methodOnTarget()->associate($embededModel);
        $this->save();
    }

    /**
     * @param Request $request
     * @param $obj
     * @param $type
     * @param $model
     * @param $method
     * @param $modelTarget
     * @param $methodOnTarget
     * @param $modelOnTarget
     * @param $event
     * @param $hasTarget
     * @param $is_EO
     * @param $is_EM
     * @param $i
     * @throws Exception
     */
    public function processOneEmbededRelationship(Request $request, $obj, $type, $model, $method, $modelTarget, $methodOnTarget, $modelOnTarget, $event, $hasTarget, $is_EO, $is_EM, $i, $options)
    {
        //Init the embedone model
        $embedObj = new $model;

        $EOitems = $embedObj->getItems();
        //Current Obj Create
        foreach ($EOitems as $EOkey => $item) {
            if (!is_null($obj)) {
                $is_ML = isML($item);
                $is_MD = isMD($item);

                if ($is_ML) {
                    $embedObj->$EOkey = ml(array(), $obj->$EOkey);
                } elseif ($EOkey == "updated_at" || $EOkey == "created_at") {
                    $embedObj->$EOkey = now();
                } elseif ($is_MD) {
                    if ($obj->$EOkey == "" ||  $obj->$EOkey == null) {
                        $embedObj->$EOkey = null;
                    } else {
                        $embedObj->$EOkey = new UTCDateTime(new DateTime($obj->$EOkey));
                        $embedObj->$EOkey = new UTCDateTime(/** @scrutinizer ignore-type */ new DateTime($obj->$EOkey));
                    }
                } else {
                    if (!property_exists($obj, $EOkey)) {
                        $msg = ('Error - ' . $EOkey . ' attribute not found on obj ' . json_encode($obj));
                        (new Exception($msg) );
                    }
                    $embedObj->$EOkey = $obj->$EOkey;
                }
            }
        }

        //else if($is_EM){//To be implemented}
        //else if($is_HM){//To be implemented}
        //else if($is_HO){//To be implemented}

        //Get counter for embeds many with level > 1
        $counter = getCounterForRelationships($method, $is_EO, $is_EM, $i);
        //Check for another Level of Relationship
        $embedObj->processAllRelationships($request, $event, $method . "-", $counter, $options);

        if ($is_EO) {
            $this->$method = $embedObj->attributes;
        } else {
            $this->$method()->associate($embedObj);
        }
        $this->save();

        //dd($embedObj, $this);

        if ($hasTarget) {
            //sync Permission to Permissiongroup
            //Init the Target Model
            $target_model = new $modelTarget;


            if (!property_exists($obj, 'ref_id')) {
                $msg = ('Error - ref_id attribute not found on obj ' . json_encode($obj));
                throw (new \Exception($msg) );
            }

            $target_id = $obj->ref_id;

            $ref_id = $this->getId();
            $ref_id = $this->getId();

            $requestToBeSync = getRequestToBeSync($ref_id, $modelOnTarget, $request, $methodOnTarget);

            $modelToBeSync = new $modelTarget;
            $modelToBeSync = $modelToBeSync->find($target_id);
            if (!is_null($modelToBeSync)) {
                $modelToBeSync->updateRelationWithSync($requestToBeSync, $methodOnTarget, $modelOnTarget);
                //TODO:Sync target on level > 1
                //$modelToBeSync->processAllRelationships($request, $event, $methodOnTarget, $methodOnTarget . "-");
            }
        }
    }


    /**
     * @param Request $request
     * @param array $additionalData
     * @param array $options
     * @return $this
     * @throws Exception
     */
    public function updateWithSync(Request $request, array $additionalData = [], array $options)
    {
        $request = $request->merge($additionalData);
        $this->storeEditAllItems($request, "update", $options);
        $this->processAllRelationships($request, "update", "", "", $options);

        //Dispatch the update event
        $this->fireModelEvent('updateWithSync');

        return $this;
    }

    /**
     * @param $method
     * @param $modelTarget
     * @param $methodOnTarget
     * @param $id
     */
    public function deleteTargetObj($method, $modelTarget, $methodOnTarget, $is_EO)
    {
        if ($is_EO) {
            $embedObj = $this->$method;
            if (!is_null($embedObj)) {
                $target_id = $embedObj->ref_id;
                $this->handleSubTarget($target_id, $modelTarget, $methodOnTarget);
            }
        } else {
            foreach ($this->$method as $target) {
                $this->handleSubTarget($target->ref_id, $modelTarget, $methodOnTarget);
            }
        }
    }

    /**
     * @param $target_id
     * @param $modelTarget
     * @param $methodOnTarget
     */
    public function handleSubTarget($target_id, $modelTarget, $methodOnTarget)
    {
        $id = $this->getId();
        $target = new $modelTarget;
        $target = $target->all()->where('id', $target_id)->first();
        if (!is_null($target)) {
            $subTarget = $target->$methodOnTarget()->where('ref_id', $id)->first();
            $temps = $target->$methodOnTarget()->where('ref_id', '!=', $id);
            $target->$methodOnTarget()->delete($subTarget);
            foreach ($temps as $temp) {
                $target->$methodOnTarget()->associate($temp);
                $target->save();
            }
        }
    }

    /**
     * @return $this
     */
    public function destroyWithSync()
    {
        //Get the relation info
        $relations = $this->getMongoRelation();

        //Process all relationships
        foreach ($relations as $method => $relation) {
            //Get Relation Save Mode
            $type = $relation['type'];
            $hasTarget = hasTarget($relation);
            if ($hasTarget) {
                $modelTarget = $relation['modelTarget'];
                $methodOnTarget = $relation['methodOnTarget'];
                $modelOnTarget = $relation['modelOnTarget'];


                $is_EO = is_EO($type);
                $is_EM = is_EM($type);
                $is_HO = is_HO($type);

                $is_HM = is_HM($type);



                if ($is_EO || $is_EM) {//EmbedsOne Create - EmbedsMany Create
                    //Delete EmbedsMany or EmbedsOne on Target
                    $this->deleteTargetObj($method, $modelTarget, $methodOnTarget, $is_EO);
                }

                //TODO: Need to be implemented
               /* elseif ($is_HM) {//HasMany
                } elseif ($is_HO) {//HasOne Create
                }*/
            }
        }
        //Delete current object
        $this->delete();
               delete();

        //Dispatch the destroy event
        $this->fireModelEvent('destroyWithSync');

        return $this;
    }

    /**
     * @param array $options
     * @param string $key
     * @return bool|mixed
     */
    private function getOptionValue(array $options, string $key){
        return array_key_exists('',  $options) ?   $options[$key] : false;
    }
}

offline-agency / laravel-mongo-auto-sync

Push — master ( 4fb543...e7c8f8 )

MongoSyncTrait::processOneEmbededRelationship() C

Complexity

Size

Duplication

Importance

How to fix Long Method Complexity Many Parameters

Long Method

Many Parameters

Duplication Side-by-Side

Filter issues like
