Coco\SourceWatcher\Core\Extractors\JsonExtractor

Complexity

Total Complexity

13

Size/Duplication

Total Lines	85
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	setColumns()	0	3	1
A	getColumns()	0	3	1
A	transpose()	0	11	3
B	extract()	0	35	8

<?php

namespace Coco\SourceWatcher\Core\Extractors;

use Coco\SourceWatcher\Core\Extractor;
use Coco\SourceWatcher\Core\Row;
use Coco\SourceWatcher\Core\SourceWatcherException;
use Flow\JSONPath\JSONPath;
use Flow\JSONPath\JSONPathException;

/**
 * Class JsonExtractor
 * @package Coco\SourceWatcher\Core\Extractors
 */
class JsonExtractor extends Extractor
{
    /**
     * @var array
     */
    private array $columns = [];

    /**
     * @var array
     */
    protected array $availableOptions = [ "columns" ];

    /**
     * @return array
     */
    public function getColumns () : array
    {
        return $this->columns;
    }

    /**
     * @param array $columns
     */
    public function setColumns ( array $columns ) : void
    {
        $this->columns = $columns;
    }

    /**
     * @return array|mixed
     * @throws JSONPathException
     * @throws SourceWatcherException
     */
    public function extract ()
    {
        if ( $this->input == null ) {
            throw new SourceWatcherException( "An input must be provided." );
        }

        $result = array();

        if ( !file_exists( $this->input ) ) {
            throw new SourceWatcherException( "The file " . $this->input . " could not be found." );
        }

        $data = json_decode( file_get_contents( $this->input ), true );

        if ( $this->columns ) {

The expression $this->columns of type array is implicitly converted to a boolean; are you sure this is intended? If so, consider using ! empty($expr) instead to make it clear that you intend to check for an array without elements.

            try {
                $jsonPath = new JSONPath( $data );
            } catch ( JSONPathException $jsonPathException ) {
                throw new SourceWatcherException( "Something went wrong trying to extract the JSON file: " . $jsonPathException->getMessage() );
            } catch ( Exception $exception ) {

The type Coco\SourceWatcher\Core\Extractors\Exception was not found. Did you mean Exception? If so, make sure to prefix the type with \.

                throw new SourceWatcherException( "Something unexpected went wrong trying to extract the JSON file: " . $exception->getMessage() );
            }

            foreach ( $this->columns as $key => $path ) {
                $this->columns[$key] = $jsonPath->find( $path )->data();
            }

            $data = $this->transpose( $this->columns );
        }

        foreach ( $data as $row ) {
            array_push( $result, new Row( $row ) );
        }

        return $result;
    }

    /**
     * @param $columns
     * @return array
     */
    private function transpose ( $columns )
    {
        $data = [];

        foreach ( $columns as $column => $items ) {
            foreach ( $items as $row => $item ) {
                $data[$row][$column] = $item;
            }
        }

        return $data;
    }
}