Ratsit.php

<?php

declare(strict_types=1);

namespace JGI\Ratsit;

use Http\Client\HttpClient;
use Http\Discovery\MessageFactoryDiscovery;
use Http\Message\RequestFactory;
use JGI\Ratsit\Event\CompanyInformationResultEvent;
use JGI\Ratsit\Event\PersonInformationResultEvent;
use JGI\Ratsit\Event\PersonSearchResultEvent;
use JGI\Ratsit\Model\Company;
use JGI\Ratsit\Model\SearchResult;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;

class Ratsit
{
    /**
     * @var HttpClient
     */
    private $httpClient;

    /**
     * @var RequestFactory
     */
    private $messageFactory;

    /**
     * @var array
     */
    private $options = [];

    /**
     * @var Denormalizer
     */
    private $denormalizer;

    /**
     * @var EventDispatcherInterface|null
     */
    private $eventDispatcher;

    /**
     * @var array
     */
    private static $defaultOptions = [
        'url' => 'https://api.checkbiz.se/api/v1/',
        'token' => '',
    ];

    /**
     * @param string $token
     * @param array $options
     */
    public function __construct(string $token, array $options = [])
    {
        $options['token'] = $token;
        $this->setOptions($options);
    }

    /**
     * @param HttpClient $httpClient
     */
    public function setHttpClient(HttpClient $httpClient): void
    {
        $this->httpClient = $httpClient;
    }

    /**
     * @param null|EventDispatcherInterface $eventDispatcher
     */
    public function setEventDispatcher(?EventDispatcherInterface $eventDispatcher): void
    {
        $this->eventDispatcher = $eventDispatcher;
    }

    /**
     * @param array $options
     */
    private function setOptions(array $options)
    {
        $this->options = self::$defaultOptions;
        $this->options = array_merge($this->options, $options);
    }

    /**
     * @return RequestFactory
     */
    private function getMessageFactory()
    {
        if (!$this->messageFactory) {
            $this->messageFactory = MessageFactoryDiscovery::find();
        }

        return $this->messageFactory;
    }

    /**
     * @return Denormalizer
     */
    private function getDenormalizer()
    {
        if (!$this->denormalizer) {
            $this->denormalizer = new Denormalizer();
        }

        return $this->denormalizer;
    }

    /**
     * @param string $method
     * @param string $package
     * @param array $parameters
     *
     * @return \Psr\Http\Message\ResponseInterface
     * @throws \Exception
     * @throws \Http\Client\Exception
     */
    private function request(string $method, string $package, array $parameters = [])
    {
        $request = call_user_func_array(
            [$this, 'buildRequestInstance'],
            [$method, $package, $parameters]
        );

        return $this->httpClient->sendRequest($request);
    }

    /**
     * @param string $method
     * @param string $package
     * @param array $parameters
     *
     * @return \Psr\Http\Message\RequestInterface
     */
    public function buildRequestInstance(string $method, string $package, array $parameters)
    {
        $uri = $this->options['url'] . $method . '?' . http_build_query($parameters);
        return $this->getMessageFactory()->createRequest('GET', $uri, [
            'Authorization' => sprintf('Basic %s', $this->options['token']),
            'package' => $package,
        ]);
    }

    /**
     * @param string|null $ssn
     *
     * @return Model\Person
     */
    public function findPersonBySocialSecurityNumber(?string $ssn)
    {
        $json = $this->request('personinformation', 'personinformation', ['ssn' => $ssn])->getBody()->getContents();

        $person = $this->getDenormalizer()->denormalizerPersonInformation(json_decode($json, true));

        if ($person && $this->eventDispatcher) {
            $this->eventDispatcher->dispatch(
                new PersonInformationResultEvent($person), PersonInformationResultEvent::NAME
            );
        }

        return $person;
    }

    /**
     * @param null|string $who
     * @param null|string $where
     *
     * @return Model\Person[]|SearchResult
     */
    public function searchPerson(?string $who, ?string $where = null)
    {
        $json = $this->request('personsearch', 'personsok', ['who' => $who, 'where' => $where])->getBody()->getContents();

        $searchResult = $this->getDenormalizer()->denormalizerPersonSearch(json_decode($json, true));

        if ($this->eventDispatcher) {
            $this->eventDispatcher->dispatch(
                new PersonSearchResultEvent($searchResult), PersonSearchResultEvent::NAME
            );
        }

        return $searchResult;
    }

    /**
     * @param string|null $organisationNumber
     *
     * @return Model\Company|null
     */
    public function findCompanyByOrganisationNumber(?string $organisationNumber): ?Company
    {
        $json = $this->request('companyinformation', 'companyinformation', ['OrganizationNumber' => $organisationNumber])->getBody()->getContents();

        $company = $this->getDenormalizer()->denormalizerCompanyInformation(json_decode($json, true));

        if ($company && $this->eventDispatcher) {
            $this->eventDispatcher->dispatch(
                new CompanyInformationResultEvent($company), CompanyInformationResultEvent::NAME
            );
        }

        return $company;
    }
}