update command

Aggrego · Jan 8, 2019 · d2f1e8d · d2f1e8d
1 parent 7854946
commit d2f1e8d
Show file tree

Hide file tree

Showing 3 changed files with 19 additions and 5 deletions.
diff --git a/spec/Api/Command/RunCommand/CommandSpec.php b/spec/Api/Command/RunCommand/CommandSpec.php
@@ -19,7 +19,7 @@ class CommandSpec extends ObjectBehavior
 {
     function let()
     {
-        $this->beConstructedWith('test');
+        $this->beConstructedWith('test', ['test']);
     }
 
     function it_is_initializable()
@@ -28,8 +28,12 @@ function it_is_initializable()
         $this->shouldHaveType(CommandConsumer::class);
     }
 
-    function it_should_have_data(): void
+    function it_should_have_query(): void
     {
         $this->getCypherQuery()->shouldBeString();
     }
+    function it_should_have_parameters(): void
+    {
+        $this->getParameters()->shouldBeArray();
+    }
 }
diff --git a/src/Api/Command/RunCommand/Command.php b/src/Api/Command/RunCommand/Command.php
@@ -22,10 +22,14 @@ class Command implements CommandConsumer
     /** @var string */
     private $query;
 
-    public function __construct(string $query)
+    /** @var array */
+    private $parameters;
+
+    public function __construct(string $query, array $parameters = [])
     {
         Assertion::notEmpty($query);
         $this->query = $query;
+        $this->parameters = $parameters;
     }
 
     public function getName(): Name
@@ -36,12 +40,18 @@ public function getName(): Name
     public function getPayload(): array
     {
         return [
-            'query' => $this->query
+            'query' => $this->query,
+            'parameters' => $this->parameters
         ];
     }
 
     public function getCypherQuery(): string
     {
         return $this->query;
     }
+
+    public function getParameters(): array
+    {
+        return $this->parameters;
+    }
 }
diff --git a/src/Api/Command/RunCommand/UseCase.php b/src/Api/Command/RunCommand/UseCase.php
@@ -27,7 +27,7 @@ public function __construct(Client $client)
     public function handle(Command $command): Response
     {
         try {
-            $this->client->run($command->getCypherQuery());
+            $this->client->run($command->getCypherQuery(), $command->getParameters());
         } catch (Neo4jExceptionInterface $e) {
             return Response::fail($e->getMessage());
         }