Coco\SourceWatcher\Core\Extractors\JsonExtractor

Complexity

Total Complexity

13

Size/Duplication

Total Lines	76
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	43	8

<?php

namespace Coco\SourceWatcher\Core\Extractors;

use Coco\SourceWatcher\Core\Extractor;
use Coco\SourceWatcher\Core\IO\Inputs\FileInput;
use Coco\SourceWatcher\Core\Row;
use Coco\SourceWatcher\Core\SourceWatcherException;
use Coco\SourceWatcher\Utils\Internationalization;
use Flow\JSONPath\JSONPath;
use Flow\JSONPath\JSONPathException;

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

    protected array $availableOptions = [ "columns" ];

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

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

    /**
     * @return array
     * @throws SourceWatcherException
     */
    public function extract () : array
    {
        if ( $this->input == null ) {
            throw new SourceWatcherException( Internationalization::getInstance()->getText( JsonExtractor::class,
                "No_Input_Provided" ) );
        }

        $inputIsFileInput = $this->input instanceof FileInput;

        if ( !$inputIsFileInput ) {
            throw new SourceWatcherException( sprintf( Internationalization::getInstance()->getText( JsonExtractor::class,
                "Input_Not_Instance_Of_File_Input" ), FileInput::class ) );
        }

        $this->result = [];

        if ( !file_exists( $this->input->getInput() ) ) {
            throw new SourceWatcherException( sprintf( Internationalization::getInstance()->getText( JsonExtractor::class,
                "File_Input_File_Not_Found" ), $this->input->getInput() ) );
        }

        $data = json_decode( file_get_contents( $this->input->getInput() ), 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.

            $jsonPath = new JSONPath( $data );

            try {
                foreach ( $this->columns as $key => $path ) {
                    $this->columns[$key] = $jsonPath->find( $path )->getData();
                }
            } catch ( JSONPathException $jsonPathException ) {
                throw new SourceWatcherException( sprintf( Internationalization::getInstance()->getText( JsonExtractor::class,
                    "JSON_Path_Exception" ), $jsonPathException->getMessage() ) );
            }

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

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

        return $this->result;
    }

    private function transpose ( $columns ) : array
    {
        $data = [];

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

        return $data;
    }
}