etna-alternance / composer-rabbitmq-service-provider

features/bootstrap/FeatureContext.php

<?php

For compatibility and reusability of your code, PSR1 recommends that a file should introduce either new symbols (like classes, functions, etc.) or have side-effects (like outputting something, or including other files), but not both at the same time. The first symbol is defined on line 25 and the first side effect is on line 10.

use Behat\Behat\Context\ClosuredContextInterface,
    Behat\Behat\Context\TranslatedContextInterface,
    Behat\Behat\Context\BehatContext,
    Behat\Behat\Exception\PendingException;
use Behat\Gherkin\Node\PyStringNode,
    Behat\Gherkin\Node\TableNode;

require __DIR__ . "/../../vendor/autoload.php";

//
// Require 3rd-party libraries here:
//
//   require_once 'PHPUnit/Autoload.php';
//   require_once 'PHPUnit/Framework/Assert/Functions.php';
//

use ETNA\Silex\Provider\RabbitMQ\RabbitMQServiceProvider;
use Silex\Application;

/**
 * Features context.
 */
class FeatureContext extends BehatContext

PSR1 recommends that each class must be in a namespace of at least one level to avoid collisions.

{
    /**
     * Initializes context.
     * Every scenario gets its own context object.
     *
     * @param array $parameters context parameters (set them up through behat.yml)
     */
    public function __construct(array $parameters)

The parameter $parameters is not used and could be removed.

    {
        // Initialize your context here
    }

    static private $vhosts = ["/test-behat", "/test-behat-named"];

The property $vhosts is not used and could be removed.

    use ETNA\FeatureContext\RabbitMQ;

    /**
     * @Given /^une application Silex$/
     */
    public function uneApplicationSilex()
    {
        $this->app = new Application();

The property app does not exist. Did you maybe forget to declare it?

        $this->app->register(new RabbitMQServiceProvider());
    }

    /**
     * @Given /^la configuration suivante :$/
     */
    public function laConfigurationSuivante(PyStringNode $config)
    {
        $config = json_decode($config->getRaw(), true);
        if (!$config && json_last_error()) {
            throw new PendingException("Invalid JSON");
        }
        foreach ($config as $key => $value) {
            $this->app[$key] = $value;
        }
    }

    /**
     * @Given /^\$app\["amqp\.chan"\] == \$app\["amqp\.chans"\]\["default"\]$/
     */
    public function chanEstUnAliasVersDefault()
    {
        if ($this->app["amqp.chan"] !== $this->app["amqp.chans"]["default"]) {
            throw new Exception('$app["amqp.chan"] != $app["amqp.chans"]["default"]');
        }
    }

    /**
     * @Given /^\$app\["amqp\.(\w+)"\]\["(\w+)"\] est du type ([\w\\]+)$/
     */
    public function checkClass($type, $name, $class)
    {
        if (!is_a($this->app["amqp.{$type}"][$name], $class)) {
            throw new Exception("\$app['amqp.{$type}']['{$name}'] n'est pas une instance de {$class}");
        }
    }

    /**
     * @Given /^\$app\["amqp\.(\w+)"\]\["(\w+)"\]->(\w+)\(\) == "([^"]*)"$/
     */
    public function checkGetterString($type, $name, $method, $value)

This method seems to be duplicated in your project.

    {
        if ($this->app["amqp.{$type}"][$name]->$method() != $value) {
            $value = $this->app["amqp.{$type}"][$name]->$method();
            throw new Exception("\$app['amqp.{$type}'['{$name}']]->{$method}() = " . var_export($value, true));
        }
    }

    /**
     * @Given /^\$app\["amqp\.(\w+)"\]\["(\w+)"\]->(\w+)\(\) == (true|false)$/
     */
    public function checkGetterBoolean($type, $name, $method, $value)

This method seems to be duplicated in your project.

    {
        if ($this->app["amqp.{$type}"][$name]->$method() != (strtolower($value) == "true")) {
            $value = $this->app["amqp.{$type}"][$name]->$method();
            throw new Exception("\$app['amqp.{$type}'['{$name}']]->{$method}() = " . var_export($value, true));
        }
    }

    /**
     * @Given /^que je bind une file sur l\'exchange "([^"]*)"$/
     */
    public function queJeBindUneFileSurLExchange($exchange)
    {
        $this->channel = $this->app["amqp.exchanges"][$exchange]->getChannel();

The property channel does not exist. Did you maybe forget to declare it?

Equals sign not aligned with surrounding assignments; expected 3 spaces but found 1 space

        $this->tmp_queue = $this->channel->queue_declare()[0];

The property tmp_queue does not exist. Did you maybe forget to declare it?

        $this->channel->queue_bind($this->tmp_queue, $exchange);
    }

     /**
     * @Given /^que "([^"]*)" est (un exchange|une queue) réservé$/
     */
    public function queEstUnTrucReserve($name, $type)
    {
        try {
            $type = $type == 'un exchange' ? "amqp.exchanges" : "amqp.queues";
            $this->app[$type][$name]->getChannel();
        } catch (Exception $e) {
            $this->exception = $e->getMessage();

The property exception does not exist. Did you maybe forget to declare it?

        }
    }

    /**
     * @Given /^je devrais avoir une exception "([^"]*)"$/
     */
    public function jeDevraisAvoirUneException($exception)
    {
        if ($exception != $this->exception) {
            throw new Exception("Expected: '{$exception}'; got: '{$this->exception}'");
        }
    }

    /**
     * @Given /^j\'envoie un message "(\w+)" dans l\'exchange "(\w+)"$/
     */
    public function jEnvoieUnMessage($message, $exchange)
    {
        $this->app["amqp.exchanges"][$exchange]->send($message);
    }

    /**
     * @Given /^j\'envoie un message "(\w+)" dans la file "([^"]*)"$/
     */
    public function jEnvoieUnMessageDansLaFile($message, $queue)
    {
        $this->channel = $this->app["amqp.queues"][$queue]->getChannel();

Equals sign not aligned with surrounding assignments; expected 3 spaces but found 1 space

        $this->tmp_queue = $queue;
        $this->app["amqp.queues"][$queue]->send($message);
    }

    /**
     * @Given /^il doit y avoir un message "([^"]*)" dans la file( "(\w+)")?$/
     */
    public function ilDoitYAvoirUnMessageDansLaFile($message, $queue = null)

The parameter $queue is not used and could be removed.

    {
        $this->channel->basic_consume($this->tmp_queue, "behat", false, false, false, false, function ($msg) use ($message) {

This line exceeds maximum limit of 120 characters; contains 125 characters

            $msg->delivery_info['channel']->basic_cancel($msg->delivery_info['consumer_tag']);

            if (json_decode($msg->body) != $message) {
                throw new Exception("{$msg->body} != {$message}");
            }
        });
        $this->channel->wait();
    }

    /**
     * @Given /^je fais un listen ma callback doit être appelé (\d+) fois$/
     */
    public function jeFaisUnListen($nb)
    {
        $this->app["amqp.queues"][$this->tmp_queue]->send("__QUIT__");
        $nb++;

        $count = 0;

Equals sign not aligned with surrounding assignments; expected 8 spaces but found 1 space

        $last_message = null;
        $this->app["amqp.queues"][$this->tmp_queue]->listen(function ($msg) use ($count, &$last_message) {
            $count++;
            $last_message = json_decode($msg->body);
        });
        while ($nb--) {
            $this->channel->wait();
        }
        if ($last_message != "__QUIT__") {
            throw new Exception("Il y a trop de message");
        }
    }
}