Coco\SourceWatcher\Core\Loaders\DatabaseLoader

Complexity

Total Complexity

13

Size/Duplication

Total Lines	57
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	load()	0	3	1
B	insert()	0	20	9
A	getArrayRepresentation()	0	18	3

<?php

namespace Coco\SourceWatcher\Core\Loaders;

use Coco\SourceWatcher\Core\IO\Outputs\DatabaseOutput;
use Coco\SourceWatcher\Core\Loader;
use Coco\SourceWatcher\Core\Row;
use Coco\SourceWatcher\Core\SourceWatcherException;

/**
 * Class DatabaseLoader
 *
 * @package Coco\SourceWatcher\Core\Loaders
 */
class DatabaseLoader extends Loader
{
    /**
     * @param Row $row
     * @throws SourceWatcherException
     */
    public function load ( Row $row )
    {
        $this->insert( $row );
    }

    /**
     * @param Row $row
     * @throws SourceWatcherException
     */
    protected function insert ( Row $row ) : void
    {
        if ( $this->output == null ) {
            throw new SourceWatcherException( "An output must be provided" );
        }

        if ( !( $this->output instanceof DatabaseOutput ) ) {
            throw new SourceWatcherException( sprintf( "The output must be an instance of %s",
                DatabaseOutput::class ) );
        }

        $output = $this->output->getOutput();

        if ( $output == null || empty( $output ) || ( sizeof( $output ) == 1 && $output[0] == null ) ) {
            throw new SourceWatcherException( "No database connector found. Set a connector before trying to insert a row" );
        }

        foreach ( $output as $currentConnector ) {
            if ( $currentConnector != null ) {
                $currentConnector->insert( $row );
            }
        }
    }

    public function getArrayRepresentation () : array
    {
        $result = parent::getArrayRepresentation();

        $result["output"] = [];

        $output = $this->output->getOutput();

The method getOutput() does not exist on null.

        foreach ( $output as $currentConnector ) {
            if ( $currentConnector != null ) {
                $result["output"][] = [
                    "class" => get_class( $currentConnector ),
                    "parameters" => $currentConnector->getConnectionParameters()
                ];
            }
        }

        return $result;
    }
}