DP\Core\CoreBundle\Behat\ServerContext

Complexity

Total Complexity

46

Size/Duplication

Total Lines	418
Duplicated Lines	22.25 %

Coupling/Cohesion

Components	1
Dependencies	11

Importance

Changes	5
Bugs	1	Features	0

24 Methods

Rating	Name	Duplication	Size	Complexity
A	iAmOnTheVoipPage()	0	8	1
A	iShouldBeOnTheVoipPage()	9	9	1
A	iAmOnTheInstancePageByName()	0	6	1
A	iAmDoingSomethingWithVoipResourceByName()	7	7	1
A	iShouldBeDoingSomethingWithVoipResourceByName()	8	8	1
A	iShouldBeOnTheServerPageByName()	0	4	1
A	iShouldBeOnTheInstancePageByName()	8	8	1
A	iAmOnTheInstanceIndex()	0	8	1
A	iShouldBeOnTheInstanceIndexPage()	9	9	1
A	iAmDoingSomethingWithVoipServer()	11	11	1
A	iShouldBeDoingSomethingWithVoipServer()	12	12	1
A	iClickNear()	13	13	2
A	iShouldBeOnTheFtpPage()	8	8	1
A	iShouldSeeThatMuchInstancesInTheList()	8	8	2
A	thereAreMinecraftServers()	0	22	3
B	thereIsMinecraftServer()	0	34	4
A	thereAreSteamServers()	0	18	3
B	thereIsSteamServer()	0	30	4
A	thereAreTeamspeakServers()	0	14	3
B	thereIsTeamspeakServer()	0	25	4
A	thereAreTeamspeakInstances()	0	15	2
B	thereIsTeamspeakInstance()	0	26	3
A	getRepository()	0	10	2
A	findOneBy()	0	15	2

<?php

/**
 * This file is part of Dedipanel project
 *
 * (c) 2010-2015 Dedipanel <http://www.dedicated-panel.net>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace DP\Core\CoreBundle\Behat;

use Behat\Behat\Hook\Scope\BeforeFeatureScope;
use Behat\Gherkin\Node\TableNode;
use DP\GameServer\MinecraftServerBundle\Entity\MinecraftServer;
use DP\GameServer\SteamServerBundle\Entity\SteamServer;
use DP\VoipServer\TeamspeakServerBundle\Entity\TeamspeakServer;
use DP\VoipServer\TeamspeakServerBundle\Entity\TeamspeakServerInstance;

class ServerContext extends DefaultContext
{
    /**
     * @Given /^I am on the (teamspeak) instance creation page for "([^""]*)"$/
     * @When /^I go to the (teamspeak) instance creation page for "([^""]*)"$/
     */
    public function iAmOnTheVoipPage($type, $value)
    {
        $parts   = explode('@', $value);
        $machine = $this->findOneBy('machine', array('username' => $parts[0]));
        $server  = $this->findOneBy($type, array('machine' => $machine->getId()));

        $this->getSession()->visit($this->generatePageUrl($type . ' instance creation', array('serverId' => $server->getId())));
    }

    /**
     * @Given /^I should be on the (teamspeak) instance creation page for "([^""]*)"$/
     * @Given /^I should still be on the (teamspeak) instance creation page for "([^""]*)"$/
     */
    public function iShouldBeOnTheVoipPage($type, $value)
    {
        $parts   = explode('@', $value);
        $machine = $this->findOneBy('machine', array('username' => $parts[0]));
        $server  = $this->findOneBy($type, array('machine' => $machine->getId()));

        $this->assertSession()->addressEquals($this->generatePageUrl($type . ' instance creation', array('serverId' => $server->getId())));
        $this->assertStatusCodeEquals(200);
    }

    /**
     * @Given /^I am on the page of (teamspeak) instance "([^""]*)"$/
     * @Given /^I go to the page of (teamspeak) instance "([^""]*)"$/
     */
    public function iAmOnTheInstancePageByName($type, $name)
    {
        $resource = $this->findOneBy('instance', array('name' => $name), $type);

        $this->getSession()->visit($this->generatePageUrl(sprintf('%s_instance_show', $type), array('id' => $resource->getId(), 'serverId' => $resource->getServer()->getId())));
    }

    /**
     * @Given /^I am (building|viewing|editing) (teamspeak) instance "([^""]*)"$/
     */
    public function iAmDoingSomethingWithVoipResourceByName($action, $type, $name)
    {
        $action = str_replace(array_keys($this->actions), array_values($this->actions), $action);
        $resource = $this->findOneBy('instance', array('name' => $name), $type);

        $this->getSession()->visit($this->generatePageUrl(sprintf('%s_instance_%s', $type, $action), array('id' => $resource->getId(), 'serverId' => $resource->getServer()->getId())));
    }

    /**
     * @Then /^I should be (building|viewing|editing) (teamspeak) instance "([^""]*)"$/
     * @Then /^I should still be (building|viewing|editing) (teamspeak) instance "([^""]*)"$/
     */
    public function iShouldBeDoingSomethingWithVoipResourceByName($action, $type, $name)
    {
        $action = str_replace(array_keys($this->actions), array_values($this->actions), $action);
        $resource = $this->findOneBy('instance', array('name' => $name), $type);

        $this->assertSession()->addressEquals($this->generatePageUrl(sprintf('%s_instance_%s', $type, $action), array('id' => $resource->getId(), 'serverId' => $resource->getServer()->getId())));
        $this->assertStatusCodeEquals(200);
    }

    /**
     * @Then /^I should be on the page of ([^""(w)]*) server "([^""]*)"$/
     * @Then /^I should still be on the page of ([^""(w)]*) server "([^""]*)"$/
     */
    public function iShouldBeOnTheServerPageByName($type, $name)
    {
        $this->iShouldBeOnTheResourcePage($type, 'name', $name);
    }

    /**
     * @Then /^I should be on the page of (teamspeak) instance "([^""]*)"$/
     * @Then /^I should still be on the page of (teamspeak) instance "([^""]*)"$/
     */
    public function iShouldBeOnTheInstancePageByName($type, $name)
    {
        $type = str_replace(' ', '_', $type);
        $resource = $this->findOneBy('instance', array('name' => $name), $type);

        $this->assertSession()->addressEquals($this->generatePageUrl(sprintf('%s_instance_show', $type), array('id' => $resource->getId(), 'serverId' => $resource->getServer()->getId())));
        $this->assertStatusCodeEquals(200);
    }

    /**
     * @Given /^I am on the (teamspeak) "([^""]*)" instance index$/
     * @TODO: Refactorer comme iAmOnTheVoipPage()
     */
    public function iAmOnTheInstanceIndex($type, $value)
    {
        $parts   = explode('@', $value);
        $machine = $this->findOneBy('machine', array('username' => $parts[0]));
        $server  = $this->findOneBy($type, array('machine' => $machine->getId()));

        $this->getSession()->visit($this->generatePageUrl(sprintf('dedipanel_%s_instance_index', $type), array('serverId' => $server->getId())));
    }

    /**
     * @Then /^I should be on the (teamspeak) "([^"]*)" instance index$/
     */
    public function iShouldBeOnTheInstanceIndexPage($type, $value)
    {
        $parts   = explode('@', $value);
        $machine = $this->findOneBy('machine', array('username' => $parts[0]));
        $server  = $this->findOneBy($type, array('machine' => $machine->getId()));

        $this->assertSession()->addressEquals($this->generatePageUrl(sprintf('dedipanel_%s_instance_index', $type), array('serverId' => $server->getId())));
        $this->assertStatusCodeEquals(200);
    }

    /**
     * @Given /^I am (building|viewing|editing) (teamspeak) "([^""]*)"$/
     */
    public function iAmDoingSomethingWithVoipServer($action, $type, $value)
    {
        $type = str_replace(' ', '_', $type);

        $action = str_replace(array_keys($this->actions), array_values($this->actions), $action);
        $parts   = explode('@', $value);
        $machine = $this->findOneBy('machine', array('username' => $parts[0]));
        $server  = $this->findOneBy($type, array('machine' => $machine->getId()));

        $this->getSession()->visit($this->generatePageUrl(sprintf('dedipanel_%s_%s', $type, $action), array('id' => $server->getId())));
    }

    /**
     * @Then /^I should be (building|viewing|editing|testing) (teamspeak) "([^""]*)"$/
     */
    public function iShouldBeDoingSomethingWithVoipServer($action, $type, $value)
    {
        $type = str_replace(' ', '_', $type);

        $action  = str_replace(array_keys($this->actions), array_values($this->actions), $action);
        $parts   = explode('@', $value);
        $machine = $this->findOneBy('machine', array('username' => $parts[0]));
        $server  = $this->findOneBy($type, array('machine' => $machine->getId()));

        $this->assertSession()->addressEquals($this->generatePageUrl(sprintf('dedipanel_%s_%s', $type, $action), array('id' => $server->getId())));
        $this->assertStatusCodeEquals(200);
    }

    /**
     * @When /^I (?:click|press|follow) "([^"]*)" near "([^"]*)"$/
     */
    public function iClickNear($button, $value)
    {
        $selector = sprintf('.server-list .server-item:contains("%s")', $value);
        $item = $this->assertSession()->elementExists('css', $selector);

        $locator = sprintf('button:contains("%s")', $button);

        if ($item->has('css', $locator)) {
            $item->find('css', $locator)->press();
        } else {
            $item->clickLink($button);
        }
    }

    /**
     * @Then /^I should be on the ftp page of ([^""]*) "([^""]*)"$/
     */
    public function iShouldBeOnTheFtpPage($type, $name)
    {
        $type = str_replace(' ', '_', $type);
        $resource = $this->findOneBy($type, array('name' => $name));

        $this->assertSession()->addressEquals($this->generatePageUrl(sprintf('%s_ftp_show', $type), array('id' => $resource->getId())));
        $this->assertStatusCodeEquals(200);
    }

    /**
     * @Then /^I should see (\d+) ([^" ]*) instances in (that|the) list$/
     */
    public function iShouldSeeThatMuchInstancesInTheList($amount, $type)
    {
        if (1 === count($this->getSession()->getPage()->findAll('css', '.instance-list'))) {
            $this->assertSession()->elementsCount('css', '.instance-list > .instance-item', $amount);
        } else {
            $this->assertSession()->elementsCount('css', sprintf('#%s.instance-list > .instance-item', $type), $amount);
        }
    }

    /**
     * @Given /^there are following minecraft servers:$/
     */
    public function thereAreMinecraftServers(TableNode $table)
    {
        foreach ($table->getHash() as $data) {
            $this->thereIsMinecraftServer(
                $data['name'],
                $data['machine'],
                $data['port'],
                $data['queryPort'],
                $data['rconPort'],
                $data['rconPassword'],
                $data['game'],
                $data['installDir'],
                $data['maxplayers'],
                $data['minHeap'],
                $data['maxHeap'],
                (isset($data['installed']) && $data['installed'] == 'yes'),
                false
            );
        }

        $this->getEntityManager()->flush();
    }

    public function thereIsMinecraftServer($name, $machine = null, $port = 25565, $queryPort = 25565, $rconPort = 25575, $rconPassword = 'test', $game = 'minecraft', $installDir = 'test', $maxplayers = 2, $minHeap = 128, $maxHeap = 256, $installed = true, $flush = true)
    {
        if (null === $server = $this->getRepository('minecraft')->findOneBy(array('name' => $name))) {
            $game    = $this->thereIsGame($game);
            $machine = $this->thereIsMachine($machine);

            $server = new MinecraftServer();
            $server->setName($name);
            $server->setMachine($machine);
            $server->setPort($port);
            $server->setQueryPort($queryPort);
            $server->setRconPort($rconPort);
            $server->setRconPassword($rconPassword);
            $server->setGame($game);
            $server->setDir($installDir);
            $server->setMaxplayers($maxplayers);
            $server->setMinHeap($minHeap);
            $server->setMaxHeap($maxHeap);

            if ($installed) {
                $server->setInstallationStatus(101);
            }

            $this->validate($server);

            $this->getEntityManager()->persist($server);

            if ($flush) {
                $this->getEntityManager()->flush();
            }
        }

        return $server;
    }

    /**
     * @Given /^there are following steam servers:$/
     */
    public function thereAreSteamServers(TableNode $table)
    {
        foreach ($table->getHash() as $data) {
            $this->thereIsSteamServer(
                $data['name'],
                $data['machine'],
                $data['port'],
                $data['rconPassword'],
                $data['game'],
                $data['installDir'],
                $data['maxplayers'],
                (isset($data['installed']) && $data['installed'] == 'yes'),
                false
            );
        }

        $this->getEntityManager()->flush();
    }

    public function thereIsSteamServer($name, $machine = null, $port = 27025, $rconPassword = 'test', $game = 'Counter-Strike', $installDir = 'test', $maxplayers = 2, $installed = true, $flush = true)
    {
        if (null === $server = $this->getRepository('steam')->findOneBy(array('name' => $name))) {
            $game    = $this->thereIsGame($game);
            $machine = $this->thereIsMachine($machine);

            $server = new SteamServer();
            $server->setName($name);
            $server->setMachine($machine);
            $server->setPort($port);
            $server->setRconPassword($rconPassword);
            $server->setGame($game);
            $server->setDir($installDir);
            $server->setMaxplayers($maxplayers);

            if ($installed) {
                $server->setInstallationStatus(101);
            }

            $this->validate($server);

            $this->getEntityManager()->persist($server);

            if ($flush) {
                $this->getEntityManager()->flush();
            }
        }

        return $server;
    }

    /**
     * @Given /^there are following teamspeak servers:$/
     */
    public function thereAreTeamspeakServers(TableNode $table)
    {
        foreach ($table->getHash() as $data) {
            $this->thereIsTeamspeakServer(
                $data['machine'],
                $data['queryPassword'],
                $data['installDir'],
                (isset($data['installed']) && $data['installed'] == 'yes'),
                false
            );
        }

        $this->getEntityManager()->flush();
    }

    public function thereIsTeamspeakServer($machine, $queryPassword = 'test', $installDir = 'test', $installed = true, $flush = true)
    {
        $machine = $this->thereIsMachine($machine);

        if (null === $server = $this->getRepository('teamspeak')->findOneBy(array('machine' => $machine))) {
            $server = new TeamspeakServer();
            $server->setMachine($machine);
            $server->setQueryPassword($queryPassword);
            $server->setDir($installDir);

            if ($installed) {
                $server->setInstallationStatus(101);
            }

            $this->validate($server);

            $this->getEntityManager()->persist($server);

            if ($flush) {
                $this->getEntityManager()->flush();
            }
        }

        return $server;
    }

    /**
     * @Given /^there are following teamspeak instances:$/
     */
    public function thereAreTeamspeakInstances(TableNode $table)
    {
        foreach ($table->getHash() as $data) {
            $this->thereIsTeamspeakInstance(
                $data['instanceId'],
                $data['name'],
                $data['server'],
                $data['port'],
                $data['slots'],
                false
            );
        }

        $this->getEntityManager()->flush();
    }

    public function thereIsTeamspeakInstance($instanceId, $name = 'Test', $server = 'test4@127.0.0.1', $port = 9887, $slots = 2, $flush = true)
    {
        $parts   = explode('@', $server);
        $machine = $this->findOneBy('machine', array('username' => $parts[0]));
        $server  = $this->findOneBy('teamspeak', array('machine' => $machine->getId()));

        if (null === $instance = $this->getRepository('instance', 'teamspeak')->findOneBy(array('server' => $server->getId()))) {
            $instance = new TeamspeakServerInstance($server);
            $instance->setInstanceId($instanceId);
            $instance->setName($name);
            $instance->setPort($port);
            $instance->setMaxClients($slots);
            $instance->setAdminToken('test');
            $instance->setAutostart(true);

            $this->validate($server);

            $this->getEntityManager()->persist($server);

            if ($flush) {
                $this->getEntityManager()->flush();
            }
        }

        return $instance;
    }

    /**
     * @param string $baseName
     */
    protected function getRepository($resource, $baseName = null)
    {
        $service = 'dedipanel.';

        if (!empty($baseName)) {
            $service .= $baseName . '.';
        }

        return $this->getService($service . 'repository.'.$resource);
    }

    protected function findOneBy($type, array $criteria, $repoPrefix = '')
    {
        $resource = $this
            ->getRepository($type, $repoPrefix)
            ->findOneBy($criteria)
        ;

        if (null === $resource) {
            throw new \InvalidArgumentException(
                sprintf('%s for criteria "%s" was not found.', str_replace('_', ' ', ucfirst($type)), serialize($criteria))
            );
        }

        return $resource;
    }
}