Prozorov\DataVerification\Transport\DebugTransport

Complexity

Total Complexity

10

Size/Duplication

Total Lines	84
Duplicated Lines	0 %

Test Coverage

Coverage

96%

Importance

Changes	4
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	2
A	putContents()	0	3	1
A	getTimestamp()	0	3	1
A	send()	0	15	3
A	ensureDirectoryExists()	0	4	2
A	getPath()	0	3	1

<?php

declare(strict_types=1);

namespace Prozorov\DataVerification\Transport;

use Prozorov\DataVerification\Contracts\TransportInterface;
use Prozorov\DataVerification\Messages\AbstractMessage;
use Prozorov\DataVerification\Exceptions\TransportException;

class DebugTransport implements TransportInterface
{
    /**
     * @var string $path
     */
    protected $path;

    public function __construct(string $path = null)
    {
        if (empty($path)) {
            $path = realpath(__DIR__ . '/../../tests/data');
        }

        $this->path = $path;
    }

    /**
     * @inheritDoc
     */
    public function send(AbstractMessage $message): void
    {
        try {
            $text = $message->render();
            $address = $message->getAddress();

            $filename = $this->getPath() . '/' . $address->__toString() . '_' . $this->getTimestamp() . '.txt';

            $this->ensureDirectoryExists(dirname($filename));

            if (! $this->putContents($filename, $text)) {
                throw new \RuntimeException('Unable to write data');
            }
        } catch (\Exception $exception) {
            throw new TransportException('Unable to send message', 1, $exception);
        }
    }

    /**
     * putContents wrapper
     *
     * @access	protected
     * @param	string	$filename	
     * @param	mixed 	$content 	
     * @return	int|bool
     */
    protected function putContents(string $filename, $content)
    {
        return file_put_contents($filename, $content);
    }

    /**
     * mkdir.
     *
     * @access	protected
     * @param	string	$path
     * @return	void
     */
    protected function ensureDirectoryExists(string $path): void
    {
        if (! is_dir($path)) {
            mkdir($path, 0755, true);
        }
    }

    /**
     * getTimestamp.
     *
     * @access	protected
     * @return	string
     */
    protected function getTimestamp(): string
    {
        return (string) strtotime('now');
    }

    /**
     * getPath.
     *
     * @access	protected
     * @return	string
     */
    protected function getPath(): string
    {
        return (string) $this->path;
    }
}