eXpansion\Bundle\VoteManager\Services\VoteService

Complexity

Total Complexity

23

Size/Duplication

Total Lines	183
Duplicated Lines	9.84 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

92.21%

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	20	3
A	reset()	0	7	2
A	castVote()	0	13	4
B	update()	18	28	5
A	cancel()	0	9	2
A	pass()	0	9	2
A	getCurrentVote()	0	4	1
B	startVote()	0	25	4

<?php

namespace eXpansion\Bundle\VoteManager\Services;

use eXpansion\Bundle\VoteManager\Plugins\Votes\AbstractVotePlugin;
use eXpansion\Bundle\VoteManager\Structures\Vote;
use eXpansion\Framework\Core\Helpers\ChatNotification;
use eXpansion\Framework\Core\Services\Application\Dispatcher;
use eXpansion\Framework\Core\Services\Console;
use eXpansion\Framework\Core\Storage\Data\Player;
use Maniaplanet\DedicatedServer\Connection;

class VoteService
{
    /** @var Console */
    protected $console;

    /** @var Connection */
    protected $connection;

    /** @var ChatNotification */
    protected $chatNotification;

    /** @var Dispatcher */
    protected $dispatcher;

    /** @var AbstractVotePlugin[] */
    protected $votePlugins = [];

    /** @var array mapping between native MP votes and equivalent expansion votes. */
    protected $voteMapping = [];

    /** @var AbstractVotePlugin */
    protected $currentVote = null;

    /**
     * VoteManager constructor.
     * @param Console $console
     * @param Connection $connection
     * @param ChatNotification $chatNotification
     * @param Dispatcher $dispatcher
     * @param AbstractVotePlugin[] $voteFactories
     */
    public function __construct(
        Console $console,
        Connection $connection,
        ChatNotification $chatNotification,
        Dispatcher $dispatcher,
        $voteFactories
    ) {
        $this->console = $console;
        $this->connection = $connection;
        $this->dispatcher = $dispatcher;
        $this->chatNotification = $chatNotification;

        foreach ($voteFactories as $voteFactory) {
            $this->votePlugins[$voteFactory->getCode()] = $voteFactory;

            foreach ($voteFactory->getReplacementTypes() as $replaces) {
                $this->voteMapping[$replaces] = $voteFactory->getCode();
            }
        }
    }

    /**
     * Reset ongoing vote.
     */
    public function reset()
    {
        if ($this->currentVote) {
            $this->currentVote->reset();
        }
        $this->currentVote = null;
    }

    /**
     * Cast vote
     *
     * @param string $login
     * @param string $type
     */
    public function castVote($login, $type)
    {
        if ($this->currentVote instanceof AbstractVotePlugin) {
            switch ($type) {
                case Vote::VOTE_YES:
                    $this->currentVote->castYes($login);
                    break;
                case Vote::VOTE_NO:
                    $this->currentVote->castNo($login);
                    break;
            }
        }
    }

    /**
     * Update the status of the vote.
     */
    public function update()
    {
        if ($this->currentVote) {
            $vote = $this->currentVote->getCurrentVote();
            $this->currentVote->update(time());

            switch ($vote->getStatus()) {
                case Vote::STATUS_CANCEL:

This code seems to be duplicated across your project.

                    $this->dispatcher->dispatch("votemanager.votecancelled",
                        [$vote->getPlayer(), $vote->getType(), $vote]);
                    $this->currentVote = null;
                    $this->reset();
                    break;
                case Vote::STATUS_FAILED:

This code seems to be duplicated across your project.

                    $this->dispatcher->dispatch("votemanager.votefailed",
                        [$vote->getPlayer(), $vote->getType(), $vote]);
                    $this->currentVote = null;
                    $this->reset();
                    break;
                case Vote::STATUS_PASSED:

This code seems to be duplicated across your project.

                    $this->dispatcher->dispatch("votemanager.votepassed",
                        [$vote->getPlayer(), $vote->getType(), $vote]);
                    $this->currentVote = null;
                    $this->reset();
                    break;
            }
        }
    }

    /**
     * Cancel ongoing vote.
     */
    public function cancel()
    {
        if (!$this->currentVote) {
            return;
        }

        $this->currentVote->cancel();
        $this->update();
    }

    /**
     * Pass ongoing vote.
     */
    public function pass()
    {
        if (!$this->currentVote) {
            return;
        }

        $this->currentVote->pass();
        $this->update();
    }


    /**
     * @return AbstractVotePlugin
     */
    public function getCurrentVote()
    {
        return $this->currentVote;
    }

    /**
     * Start a vote.
     *
     * @param Player $player
     * @param string $typeCode
     * @param array  $params
     */
    public function startVote(Player $player, $typeCode, $params)
    {
        if ($this->getCurrentVote() !== null) {
            $this->chatNotification->sendMessage("expansion_votemanager.error.in_progress");
            return;
        }

        if (isset($this->voteMapping[$typeCode])) {
            $typeCode = $this->voteMapping[$typeCode];
        }

        if (!isset($this->votePlugins[$typeCode])) {
            // no vote-plugin found for native vote, so return silently
            return;
        }

        $this->currentVote = $this->votePlugins[$typeCode];
        $this->currentVote->start($player, $params);
        $this->connection->cancelVote();

        $this->dispatcher->dispatch(
            "votemanager.votenew",
            [$player, $this->currentVote->getCode(), $this->currentVote->getCurrentVote()]
        );
    }
}