Gica\Cqrs\Saga\SagaPersistence\ToJsonFilePersistence

Complexity

Total Complexity

6

Size/Duplication

Total Lines	41
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
A	loadData()	0	10	3
A	saveData()	0	4	1
A	getFilePath()	0	4	1

<?php
/**
 * Copyright (c) 2017 Constantin Galbenu <xprt64@gmail.com>
 */

namespace Gica\Cqrs\Saga\SagaPersistence;


use Gica\Cqrs\Saga\SagaPersistence;
use Gica\FileSystem\FileSystemInterface;

class ToJsonFilePersistence implements SagaPersistence
{
    /**
     * @var FileSystemInterface
     */
    private $fileSystem;
    /**
     * @var string
     */
    private $directory;

    public function __construct(
        FileSystemInterface $fileSystem,
        string $directory
    )
    {
        $this->fileSystem = $fileSystem;
        $this->directory = $directory;
    }

    public function loadData(string $sagaId)
    {
        try {
            $fileContents = $this->fileSystem->fileGetContents($this->getFilePath($sagaId));
            return null !== $fileContents ? json_decode($fileContents, true) : null;

        } catch (\Throwable $exception) {
            return null;
        }
    }

    public function saveData(string $sagaId, $data)
    {
        $this->fileSystem->filePutContents($this->getFilePath($sagaId), json_encode($data));
    }

    private function getFilePath(string $sagaId): string
    {
        return $this->directory . DIRECTORY_SEPARATOR . $sagaId;
    }
}