Jabe\Engine\Impl\Db\DbIdGenerator

Complexity

Total Complexity

9

Size/Duplication

Total Lines	59
Duplicated Lines	0 %

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	getIdBlockSize()	0	3	1
A	reset()	0	4	1
A	setCommandExecutor()	0	3	1
A	getNewBlock()	0	6	1
A	getCommandExecutor()	0	3	1
A	getNextId()	0	8	2
A	setIdBlockSize()	0	3	1

<?php

namespace Jabe\Engine\Impl\Db;

use Jabe\Engine\Impl\Cfg\IdGeneratorInterface;
use Jabe\Engine\Impl\Cmd\GetNextIdBlockCmd;
use Jabe\Engine\Impl\Interceptor\CommandExecutorInterface;

class DbIdGenerator implements IdGeneratorInterface
{
    protected $idBlockSize;
    protected $nextId;
    protected $lastId;

    protected $commandExecutor;

    public function __construct()
    {
        $this->reset();
    }

    public function getNextId(): string
    {
        if ($this->lastId < $this->nextId) {
            $this->getNewBlock();
        }
        $this->nextId += 1;
        $_nextId = $this->nextId;
        return strval($_nextId);
    }

    protected function getNewBlock(): void
    {
        // TODO http://jira.codehaus.org/browse/ACT-45 use a separate 'requiresNew' command executor
        $idBlock = $this->commandExecutor->execute(new GetNextIdBlockCmd($idBlockSize));

The variable $idBlockSize does not exist. Did you maybe mean $idBlock?

        $this->nextId = $idBlock->getNextId();
        $this->lastId = $idBlock->getLastId();
    }

    public function getIdBlockSize(): int
    {
        return $this->idBlockSize;
    }

    public function setIdBlockSize(int $idBlockSize): void
    {
        $this->idBlockSize = $idBlockSize;
    }

    public function getCommandExecutor(): CommandExecutorInterface
    {
        return $this->commandExecutor;
    }

    public function setCommandExecutor(CommandExecutorInterface $commandExecutor): void
    {
        $this->commandExecutor = $commandExecutor;
    }

    /**
     * Reset inner state so that the generator fetches a new block of IDs from the database
     * when the next ID generation request is received.
     */
    public function reset(): void
    {
        $this->nextId = 0;
        $this->lastId = -1;
    }
}