Migratio\Resource\PushManager\PushingProcess

Complexity

Total Complexity

12

Size/Duplication

Total Lines	74
Duplicated Lines	0 %

Importance

Changes	4
Bugs	1	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
B	processHandler()	0	38	6
A	errorHandler()	0	20	6

<?php

namespace Migratio\Resource\PushManager;

use Resta\Support\Generator\Generator;
use Resta\Support\Utils;

trait PushingProcess
{
    /**
     * process handler
     *
     * @return mixed|string
     */
    public function processHandler()
    {
        return $this->errorHandler(function(){
            
            $results = [];
            
            foreach ($this->list as $table =>$datas){

                foreach ($datas as $data){
                    
                    $query = $this->queryBuilder($table,$data);

It seems like queryBuilder() must be provided by classes using this trait. How about adding it as abstract method to this trait?

                    $query = $query->handle();
                    
                    
                    if($query===false){
                        $results[] = [];
                    }
                    else{
                        $status =($query['result']!==false) ? true : false;
                        
                        if($status){
                            $this->schema->getConnection()->generateEntity($table);
                        }

                        $results[]= [
                            'success'=>$status,
                            'file'=>$data->getFile(),
                            'table'=>$table,
                            'type'=>$query['type'],
                            'syntax'=>$query['syntax'],
                            'message'=>$query['message']
                        ];
                    }
                }
            }

            return $results;
        });
    }

    /**
     * error handler
     *
     * @param callable $callback
     * @return mixed|string
     */
    public function errorHandler(callable $callback)
    {
        foreach ($this->list as $table => $objects)
        {
            foreach ($objects as $object)
            {
                $alterBinds = $object->getAlterBinds();
                
                if(!is_null($alterBinds) && count($alterBinds)>1){
                    exception()->runtime('Only one command can be applied to alter groups');
                }
                
                if(count($object->getError())){
                    exception()->runtime(''.$object->getFile().' -> '.$object->getError()[0].'');
                }
                
            }
        }

        return call_user_func($callback);
    }
}