Coco\SourceWatcher\Core\Transformers\JavaTransformer

Complexity

Total Complexity

15

Size/Duplication

Total Lines	79
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	transform()	0	25	6
A	getArguments()	0	19	5
A	setLogHandler()	0	7	2
A	__construct()	0	3	1
A	getCommand()	0	3	1

<?php

namespace Coco\SourceWatcher\Core\Transformers;

use Coco\SourceWatcher\Core\Row;
use Coco\SourceWatcher\Core\Transformer;
use Coco\SourceWatcher\Utils\FileUtils;
use Monolog\Handler\StreamHandler;
use Monolog\Logger;

/**
 * Class JavaTransformer
 *
 * @package Coco\SourceWatcher\Core\Transformers
 */
class JavaTransformer extends Transformer
{
    protected string $classpath = "";
    protected string $classname = "";
    protected array $arguments = [];
    protected string $resultType = "";

    protected array $availableOptions = [ "classpath", "classname", "arguments", "resultType" ];

    private Logger $logger;

    public function __construct ()
    {
        $this->logger = new Logger( "JavaTransformer" );
    }

    private function getArguments ( Row $row ) : string
    {
        $arguments = "";

        foreach ( $this->arguments as $currentArgument ) {
            if ( $currentArgument->getType() == JavaTransformerArgumentType::ARG_TYPE_COLUMN ) {
                $arguments .= " " . $row[$currentArgument->getColumnValue()];
            }

            if ( $currentArgument->getType() == JavaTransformerArgumentType::ARG_TYPE_STRING ) {
                $arguments .= " " . $currentArgument->getStringValue();
            }

            if ( $currentArgument->getType() == JavaTransformerArgumentType::ARG_TYPE_MIXED ) {
                $arguments .= " " . $currentArgument->getMixedKey() . "=" . $row[$currentArgument->getMixedVal()];
            }
        }

        return trim( $arguments );
    }

    private function getCommand ( Row $row ) : string
    {
        return "java -cp " . $this->classpath . " " . $this->classname . " " . $this->getArguments( $row );
    }

    private bool $logHasBeenSet = false;

    private function setLogHandler () : void
    {
        if ( !$this->logHasBeenSet ) {
            $streamPath = FileUtils::file_build_path( __DIR__, "..", "..", "..", "logs",
                $this->classname . "-" . gmdate( "Y-m-d-H-i-s", time() ) . "-" . getmypid() . ".txt" );
            $this->logger->pushHandler( new StreamHandler( $streamPath ), Logger::DEBUG );

The call to Monolog\Logger::pushHandler() has too many arguments starting with Monolog\Logger::DEBUG.

            $this->logHasBeenSet = true;
        }
    }

    public function transform ( Row $row )
    {
        $this->setLogHandler();

        $command = $this->getCommand( $row );
        $this->logger->debug( $command );

        exec( $command, $output, $returnValue );

        $this->logger->debug( $returnValue );

        if ( $returnValue == 0 ) {
            if ( $this->resultType == JavaTransformerResultType::RESULT_TYPE_JSON ) {
                $this->logger->debug( $output[0] );

                $array = json_decode( $output[0], true );

                if ( !empty( $array ) && is_array( $array ) ) {
                    foreach ( $array as $key => $val ) {
                        $row->set( $key, $val );
                    }
                }
            }
        } else {
            echo "returnValue = $returnValue for " . print_r( $row, true ) . PHP_EOL;
        }
    }
}