Http\Client\Plugin\Vcr\Recorder\FilesystemRecorder

Complexity

Total Complexity

9

Size/Duplication

Total Lines	81
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

83.87%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	16	3
A	replay()	0	19	3
A	record()	0	13	2
A	log()	0	4	1

<?php

declare(strict_types=1);

namespace Http\Client\Plugin\Vcr\Recorder;

use GuzzleHttp\Psr7\Message;
use Psr\Http\Message\ResponseInterface;
use Psr\Log\LoggerAwareInterface;
use Psr\Log\LoggerAwareTrait;
use Psr\Log\NullLogger;
use Symfony\Component\Filesystem\Exception\IOException;
use Symfony\Component\Filesystem\Filesystem;

/**
 * Stores responses using the `guzzlehttp/psr7` library to serialize and deserialize the response.
 * Target directory should be part of your VCS.
 *
 * @author Gary PEGEOT <garypegeot@gmail.com>
 */
final class FilesystemRecorder implements RecorderInterface, PlayerInterface, LoggerAwareInterface
{
    use LoggerAwareTrait;

    /**
     * @var string
     */
    private $directory;

    /**
     * @var Filesystem
     */
    private $filesystem;

    /**
     * @var array<string, string>
     */
    private $filters;

    /**
     * @param array<string, string> $filters
     */
    public function __construct(string $directory, ?Filesystem $filesystem = null, array $filters = [])
    {
        $this->filesystem = $filesystem ?? new Filesystem();

        if (!$this->filesystem->exists($directory)) {
            try {
                $this->filesystem->mkdir($directory);
            } catch (IOException $e) {
                throw new \InvalidArgumentException("Unable to create directory \"$directory\"/: {$e->getMessage()}", $e->getCode(), $e);
            }
        }

        $this->directory = realpath($directory).\DIRECTORY_SEPARATOR;
        $this->filters = $filters;
        $this->logger = new NullLogger();
    }

    public function replay(string $name): ?ResponseInterface
    {
        $filename = "{$this->directory}$name.txt";
        $context = compact('filename');

        if (!$this->filesystem->exists($filename)) {
            $this->log('Unable to replay {filename}', $context);

            return null;
        }

        $this->log('Response replayed from {filename}', $context);

        if (false === $content = file_get_contents($filename)) {
            throw new \RuntimeException(sprintf('Unable to read "%s" file content', $filename));
        }

        return Message::parseResponse($content);
    }

    public function record(string $name, ResponseInterface $response): void
    {
        $filename = "{$this->directory}$name.txt";
        $context = compact('name', 'filename');

        if (null === $content = preg_replace(array_keys($this->filters), array_values($this->filters), Message::toString($response))) {
            throw new \RuntimeException('Some of the provided response filters are invalid.');
        }

        $this->filesystem->dumpFile($filename, $content);

        $this->log('Response for {name} stored into {filename}', $context);
    }

    /**
     * @param array<string, string> $context
     */
    private function log(string $message, array $context = []): void
    {
        $this->logger->debug("[VCR-PLUGIN][FilesystemRecorder] $message", $context);
    }
}