TheAentMachine\Helper\ReplyAggregator

Complexity

Total Complexity

14

Size/Duplication

Total Lines	64
Duplicated Lines	0 %

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	5
A	clear()	0	6	3
A	storeReply()	0	4	1
A	getNextFileName()	0	7	2
A	getReplies()	0	13	3

<?php

namespace TheAentMachine\Helper;

/**
 * Class in charge of assembling replies from the different containers.
 */
class ReplyAggregator
{
    /**
     * @var string
     */
    private $replyDirectory;

    public function __construct(string $replyDirectory = null)
    {
        if ($replyDirectory === null) {
            $replyDirectory = \sys_get_temp_dir().'/replies';
        }
        $this->replyDirectory = rtrim($replyDirectory, '/').'/';
        if (!\file_exists($replyDirectory)) {
            if (!mkdir($replyDirectory, 0777, true) && !is_dir($replyDirectory)) {
                throw new \RuntimeException(sprintf('Directory "%s" was not created', $replyDirectory));
            }
        }
    }

    /**
     * Purges all received replies
     */
    public function clear(): void
    {
        $files = glob($this->replyDirectory.'*'); // get all file names
        foreach ($files as $file) { // iterate files
            if (is_file($file)) {
                unlink($file); // delete file
            }
        }
    }

    private function getNextFileName(): string
    {
        $i = 0;
        while (\file_exists($this->replyDirectory.'tmp'.$i)) {
            $i++;
        }
        return 'tmp'.$i;
    }

    public function storeReply(string $payload): void
    {
        $path = $this->replyDirectory.$this->getNextFileName();
        \file_put_contents($path, $payload);
    }

    /**
     * @return string[]
     */
    public function getReplies(): array
    {
        $i = 0;
        $replies = [];
        while (\file_exists($this->replyDirectory.'tmp'.$i)) {
            $content = \file_get_contents($this->replyDirectory.'tmp'.$i);
            if ($content === false) {
                throw new \RuntimeException('Failed to load file '.$this->replyDirectory.'tmp'.$i);
            }
            $replies[] = $content;
            $i++;
        }
        return $replies;
    }
}