Comodojo\RpcClient\Processor\XmlProcessor

Complexity

Total Complexity

20

Size/Duplication

Total Lines	159
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes	3
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	11	1
A	encode()	0	19	4
A	decode()	0	17	4
B	encodeSingleCall()	0	29	3
B	encodeMulticall()	0	33	4
A	normalizeContent()	0	17	4

<?php namespace Comodojo\RpcClient\Processor;

use \Psr\Log\LoggerInterface;
use \Comodojo\Exception\RpcException;
use \Comodojo\RpcClient\RpcRequest;
use \Comodojo\Xmlrpc\XmlrpcEncoder;
use \Comodojo\Xmlrpc\XmlrpcDecoder;
use \Exception;

class XmlProcessor implements ProcessorInterface {

    private $encoding;

    private $logger;

    private $encoder;

    private $decoder;

    private $requests;

The property $requests is not used and could be removed.

    private $isMulticall = false;

    public function __construct($encoding, LoggerInterface $logger) {

        $this->encoding = $encoding;

        $this->logger = $logger;

        $this->encoder = new XmlrpcEncoder();

        $this->decoder = new XmlrpcDecoder();

    }

    public function encode($requests) {

        $requests = array_values($requests);

        $this->isMulticall = sizeof($requests) > 1 ? true : false;

        try {

            $payload = $this->isMulticall ? $this->encodeMulticall($requests) : $this->encodeSingleCall($requests[0]);

        } catch (XmlrpcException $xe) {

The class Comodojo\RpcClient\Processor\XmlrpcException does not exist. Did you forget a USE statement, or did you not list all dependencies?

            throw $xe;

        }

        return $payload;

    }

    public function decode($response) {

        try {

            $content = $this->decoder->decodeResponse($response);

            if ( $this->decoder->isFault() ) throw new RpcException($content['faultString'], $content['faultCode']);

        } catch (XmlrpcException $xe) {

The class Comodojo\RpcClient\Processor\XmlrpcException does not exist. Did you forget a USE statement, or did you not list all dependencies?

            throw $xe;

        }

        return $this->isMulticall ? self::normalizeContent($content) : $content;

    }

    private function encodeSingleCall(RpcRequest $request) {

        $this->logger->notice("Performing a single XML call");

    	$this->logger->debug("Data dump before encoding", $request->toArray());

        try {

        	// encoding

        	foreach ( $request->getSpecialTypes() as $key => $value ) {

                $this->encoder->setValueType($key, $value);

            }

            $encoded_request = $this->encoder->encodeCall($request->getMethod(), $request->getParameters());

        } catch (XmlrpcException $xe) {

The class Comodojo\RpcClient\Processor\XmlrpcException does not exist. Did you forget a USE statement, or did you not list all dependencies?

            throw $xe;

        }

        $this->logger->debug("Data dump after encoding: ".$encoded_request);

        return $encoded_request;

    }

    /**
     * Perform an xml multicall
     *
     * @param   array   $requests
     *
     * @return  array
     *
     * @throws \Comodojo\Exception\RpcException
     * @throws \Comodojo\Exception\HttpException
     * @throws \Comodojo\Exception\XmlrpcException
     * @throws \Exception
     */
    private function encodeMulticall($requests) {

        $composed_requests = array();

    	$this->logger->notice("Performing an XML multicall");

    	$this->logger->debug("Data dump before encoding", $requests);

        foreach ($requests as $request) {

            $composed_requests[] = array($request->getMethod(), $request->getParameters());

            foreach ( $request->getSpecialTypes() as $key => $value ) {

                $this->encoder->setValueType($key, $value);

            }

        }

        try {

            $encoded_requests = $this->encoder->setEncoding($this->encoding)->encodeMulticall($composed_requests);

        } catch (XmlrpcException $xe) {

The class Comodojo\RpcClient\Processor\XmlrpcException does not exist. Did you forget a USE statement, or did you not list all dependencies?

            throw $xe;

        }

        return $encoded_requests;

    }

    private static function normalizeContent($content) {

        return array_map(function($value) {

            if (
                is_array($value) &&
                sizeof($value) == 1 &&
                isset($value[0])
            ) {
                return $value[0];
            }

            return $value;

        }, $content);

    }

}