Client::getRequestHandler() - Code Metrics - Inspection of "remove dependency to guzzle http" - dmt-software/insolvency-client - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( b07112...16f901 )

by Bas

created 2022-07-19 19:08 UTC

Client::getRequestHandler() A

↳ Parent: Client

Complexity

Conditions	2
Paths	2

Size

Total Lines	11
Code Lines	5

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	6

Importance

Changes

Metric	Value
eloc	5
c	0
b	0
f	0
dl	0
loc	11
ccs	0
cts	5
cp	0
rs	10
cc	2
nc	2
nop	1
crap	6

<?php


namespace DMT\Insolvency;

use DateTime;
use DMT\CommandBus\Validator\ValidationMiddleware;
use DMT\Http\Client\RequestHandler;
use DMT\Insolvency\Exception\Exception;
use DMT\Insolvency\Exception\ExceptionMiddleware;
use DMT\Insolvency\Http\GetReportHandler;
use DMT\Insolvency\Http\Middleware\ExceptionMiddleware as HttpExceptionMiddleware;
use DMT\Insolvency\Http\Middleware\SoapActionMiddleware;
use DMT\Insolvency\Http\Request\GetReport;
use DMT\Insolvency\Http\Response\GetReportResponse;
use DMT\Insolvency\Model\BeschikbareVerslagen;
use DMT\Insolvency\Model\Document;
use DMT\Insolvency\Model\Insolvente;
use DMT\Insolvency\Model\LastUpdate;
use DMT\Insolvency\Model\PublicatieLijst;
use DMT\Insolvency\Model\VerwijderdePublicatieLijst;
use DMT\Insolvency\Soap\Handler as SoapHandler;
use DMT\Insolvency\Soap\Request;
use DMT\Insolvency\Soap\Request as SoapRequest;
use DMT\Insolvency\Soap\Response;
use DMT\Insolvency\Soap\Serializer\SoapSerializer;
use GuzzleHttp\Client as HttpClient;
use JMS\Serializer\SerializerInterface;
use League\Tactician\CommandBus;
use League\Tactician\Handler\CommandHandlerMiddleware;
use League\Tactician\Handler\CommandNameExtractor\ClassNameExtractor;
use League\Tactician\Handler\Locator\CallableLocator;
use League\Tactician\Handler\MethodNameInflector\HandleInflector;
use League\Tactician\Plugins\LockingMiddleware;
use Psr\Http\Client\ClientInterface;
use Psr\Http\Message\RequestFactoryInterface;

/**
 * Class Client
 */

class Client
{
    private Config $config;

    private ClientInterface $client;

    private RequestFactoryInterface $requestFactory;

    private SerializerInterface $serializer;

    private CommandBus $commandBus;


    /**

     * @param Config $config

     * @param ClientInterface $client

     * @param RequestFactoryInterface $requestFactory

     * @param SoapSerializer|null $serializer

     */
    public function __construct(
        Config $config,
        ClientInterface $client,
        RequestFactoryInterface $requestFactory,
        SoapSerializer $serializer = null
    ) {
        $this->config = $config;
        $this->client = $client;
        $this->requestFactory = $requestFactory;
        $this->serializer = $serializer ?? new SoapSerializer($this, $config);

        $this->commandBus = new CommandBus([

            new LockingMiddleware(),
            new ExceptionMiddleware(),
            new ValidationMiddleware(),
            new CommandHandlerMiddleware(
                new ClassNameExtractor(),
                new CallableLocator([$this, 'getHandler']),
                new HandleInflector()
            )
        ]);
someFunctionCall(
    $firstArgument,
    $secondArgument,
    $thirdArgument
); // Closing parenthesis on a new line.
    }

    /**
     * Search for publications of a specific insolvency.
     *
     * @param string $insolvencyID the insolvency identification.

     * @param string|null $court the count (number) where the insolvency is registered.

     *
     * @return PublicatieLijst
     * @throws Exception
     */
    public function searchInsolvencyId(string $insolvencyID, string $court = null): PublicatieLijst
    {
        $request = new Request\SearchInsolvencyID();
        $request->insolvencyID = $insolvencyID;
        $request->court = $court;

        /** @var Response\SearchInsolvencyIDResponse $response */

        $response = $this->process($request);

        return $response->result->publicatieLijst;
    }

    /**
     * Search for publications for a person.
     *
     * @param DateTime|null $dateOfBirth the date of birth of the person.
     * @param string|null $prefix the surname prefix.

     * @param string|null $surname the surname of the person.

     * @param int|null $houseNumber the house number of the person's address.

     * @param string|null $postalCode the postcode of the person's address.

     *
     * @return PublicatieLijst
     * @throws Exception
     */
    public function searchNaturalPerson(
        DateTime $dateOfBirth = null,
        string $prefix = null,
        string $surname = null,
        int $houseNumber = null,
        string $postalCode = null
    ): PublicatieLijst {
        $request = new Request\SearchNaturalPerson();
        $request->dateOfBirth = $dateOfBirth;
        $request->prefix = $prefix;
        $request->surname = $surname;
        $request->houseNumber = $houseNumber;
        $request->postalCode = $postalCode;

        /** @var Response\SearchNaturalPersonResponse $response */

        $response = $this->process($request);

        return $response->result->publicatieLijst;
    }

    /**
     * Search for publications of an undertaking.
     *
     * @param string|null $name the name of the undertaking.

     * @param string|null $commercialRegisterID the chamber of commerce number.
     * @param string|null $postalCode the postcode of the undertaking's address.

     * @param int|null $houseNumber the house number of the undertaking' address.

     *
     * @return PublicatieLijst
     * @throws Exception
     */
    public function searchUndertaking(
        string $name = null,
        string $commercialRegisterID = null,
        string $postalCode = null,
        int $houseNumber = null
    ): PublicatieLijst {
        $request = new Request\SearchUndertaking();
        $request->name = $name;
        $request->commercialRegisterID = $commercialRegisterID;
        $request->postalCode = $postalCode;
        $request->houseNumber = $houseNumber;

        /** @var Response\SearchUndertakingResponse $response */

        $response = $this->process($request);

        return $response->result->publicatieLijst;
    }

    /**
     * Get insolvency case.
     *
     * @param string $publicationNumber the publication number of the case.
     * @param bool $includeReports set to true to include reports.

     *
     * @return Insolvente
     * @throws Exception
     */
    public function getCase(string $publicationNumber, bool $includeReports = false): Insolvente
    {
        $request = $includeReports ? new Request\GetCaseWithReports() : new Request\GetCase();
        $request->publicationNumber = $publicationNumber;

        /** @var Response\GetCaseResponse $response */

        $response = $this->process($request);

        return $response->result->inspubWebserviceInsolvente->insolvente;
    }

    /**
     * Get a report for an insolvency.
     *
     * @param string $reportId the report identification number.
     *
     * @return Document
     * @throws Exception
     */
    public function getReport(string $reportId): Document
    {
        $request = new GetReport();
        $request->reportId = $reportId;

        /** @var GetReportResponse $response */

        $response = $this->process($request);

        return $response->result->report;

    }

    /**
     * Get the date when the latest publication is added.
     *
     * @return LastUpdate
     * @throws Exception
     */
    public function getLastUpdate(): LastUpdate
    {
        /** @var Response\GetLastUpdateResponse $response */

        $response = $this->process(new Request\GetLastUpdate());

        return $response->result->lastUpdate;
    }

    /**
     * Search for publications of a specific date.
     *
     * @param DateTime $date tne date of the publications to look up.

     * @param string $court the court (number) where the publications are registered.

     * @param string|null $pubType the type of publication.
     *
     * @return PublicatieLijst
     * @throws Exception
     */
    public function searchByDate(DateTime $date, string $court, string $pubType = null): PublicatieLijst
    {
        $request = new Request\SearchByDate();
        $request->date = $date;
        $request->court = $court;
        $request->pubType = $pubType;

        /** @var Response\SearchByDateResponse $response */

        $response = $this->process($request);

        return $response->result->publicatieLijst;
    }

    /**
     * Search for publications of the last mutated/added insolvencies for data replication.
     *
     * @param DateTime $modifyDate the modified date since.
     *
     * @return PublicatieLijst
     * @throws Exception
     */
    public function searchModifiedSince(DateTime $modifyDate): PublicatieLijst
    {
        $request = new Request\SearchModifiedSince();
        $request->modifyDate = $modifyDate;

        /** @var Response\SearchModifiedSinceResponse $response */

        $response = $this->process($request);

        return $response->result->publicatieLijst;
    }

    /**
     * Search for removed publications for data replication.
     *
     * @param DateTime $modifyDate the modified date since.
     *
     * @return VerwijderdePublicatieLijst
     * @throws Exception
     */
    public function searchRemovedSince(DateTime $modifyDate): VerwijderdePublicatieLijst
    {
        $request = new Request\SearchRemovedSince();
        $request->modifyDate = $modifyDate;

        /** @var Response\SearchRemovedSinceResponse $response */

        $response = $this->process($request);

        return $response->result->verwijderdePublicatieLijst;
    }

    /**
     * Search for added and modified reposts in a given time period.
     *
     * @param DateTime $datetimeFrom the start date.

     * @param DateTime|null $datetimeTo the end date.

     *
     * @return BeschikbareVerslagen
     * @throws Exception
     */
    public function searchReportsSince(DateTime $datetimeFrom, DateTime $datetimeTo = null): BeschikbareVerslagen
    {
        $request = new Request\SearchReportsSince();
        $request->datetimeFrom = $datetimeFrom;
        $request->datetimeTo = $datetimeTo ?? new DateTime();

        /** @var Response\SearchReportsSinceResponse $response */

        $response = $this->process($request);

        return $response->result->beschikbareVerslagen;
    }

    /**

     * @param string $request

     * @return SoapHandler|object

     * @internal

     */
    public function getHandler(string $request)
    {
        if (is_a($request, SoapRequest::class, true)) {
            return new SoapHandler($this->config, $this->getRequestHandler(), $this->requestFactory, $this->serializer);
        }

        return new GetReportHandler($this->config, $this->getRequestHandler(false), $this->requestFactory);
    }

    /**
     * Process a request.
     *
     * @param Request|GetReport $request

     *
     * @return Response|GetReportResponse
     * @throws Exception
     */
    protected function process($request)
    {
        if (!$request instanceof Request && !$request instanceof GetReport) {

            throw new \TypeError('Invalid request');
        }

        return $this->commandBus->handle($request);
    }

    /**
     * Get http client.
     *
     * @param bool $forSoap

     * @return HttpClient

     */
    protected function getRequestHandler(bool $forSoap = true): RequestHandler
    {
        $middleware = [
            new HttpExceptionMiddleware(),
        ];

        if ($forSoap) {
            $middleware[] = new SoapActionMiddleware();
        }

        return new RequestHandler($this->client, ...$middleware);

    }
}


1			<?php
2
			0 ignored issues – show Coding Style introduced 2021-05-24 15:44 UTC by Report Bug Copy Issue Report Missing file doc comment Loading history...
3			namespace DMT\Insolvency;
4
5			use DateTime;
6			use DMT\CommandBus\Validator\ValidationMiddleware;
7			use DMT\Http\Client\RequestHandler;
8			use DMT\Insolvency\Exception\Exception;
9			use DMT\Insolvency\Exception\ExceptionMiddleware;
10			use DMT\Insolvency\Http\GetReportHandler;
11			use DMT\Insolvency\Http\Middleware\ExceptionMiddleware as HttpExceptionMiddleware;
12			use DMT\Insolvency\Http\Middleware\SoapActionMiddleware;
13			use DMT\Insolvency\Http\Request\GetReport;
14			use DMT\Insolvency\Http\Response\GetReportResponse;
15			use DMT\Insolvency\Model\BeschikbareVerslagen;
16			use DMT\Insolvency\Model\Document;
17			use DMT\Insolvency\Model\Insolvente;
18			use DMT\Insolvency\Model\LastUpdate;
19			use DMT\Insolvency\Model\PublicatieLijst;
20			use DMT\Insolvency\Model\VerwijderdePublicatieLijst;
21			use DMT\Insolvency\Soap\Handler as SoapHandler;
22			use DMT\Insolvency\Soap\Request;
23			use DMT\Insolvency\Soap\Request as SoapRequest;
24			use DMT\Insolvency\Soap\Response;
25			use DMT\Insolvency\Soap\Serializer\SoapSerializer;
26			use GuzzleHttp\Client as HttpClient;
27			use JMS\Serializer\SerializerInterface;
28			use League\Tactician\CommandBus;
29			use League\Tactician\Handler\CommandHandlerMiddleware;
30			use League\Tactician\Handler\CommandNameExtractor\ClassNameExtractor;
31			use League\Tactician\Handler\Locator\CallableLocator;
32			use League\Tactician\Handler\MethodNameInflector\HandleInflector;
33			use League\Tactician\Plugins\LockingMiddleware;
34			use Psr\Http\Client\ClientInterface;
35			use Psr\Http\Message\RequestFactoryInterface;
36
37			/**
38			* Class Client
39			*/

dmt-software / insolvency-client

Push — master ( b07112...16f901 )

Client::getRequestHandler() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like