Refactor CommandObserver to track all three APM events

jmikola · jmikola · commit 0f848cbde7c6 · 2018-06-26T16:14:59.000-04:00
diff --git a/tests/Collection/CollectionFunctionalTest.php b/tests/Collection/CollectionFunctionalTest.php
@@ -123,7 +123,8 @@ function() {
                     ]
                 );
             },
-            function(stdClass $command) {
+            function(array $event) {
+                $command = $event['started']->getCommand();
                 $this->assertObjectHasAttribute('lsid', $command);
                 $this->assertObjectHasAttribute('maxTimeMS', $command);
                 $this->assertObjectHasAttribute('writeConcern', $command);
diff --git a/tests/CommandObserver.php b/tests/CommandObserver.php
@@ -38,14 +38,16 @@ public function observe(callable $execution, callable $commandCallback)
 
     public function commandStarted(CommandStartedEvent $event)
     {
-        $this->commands[] = $event->getCommand();
+        $this->commands[$event->getRequestId()]['started'] = $event;
     }
 
     public function commandSucceeded(CommandSucceededEvent $event)
     {
+        $this->commands[$event->getRequestId()]['succeeded'] = $event;
     }
 
     public function commandFailed(CommandFailedEvent $event)
     {
+        $this->commands[$event->getRequestId()]['failed'] = $event;
     }
 }
diff --git a/tests/GridFS/ReadableStreamFunctionalTest.php b/tests/GridFS/ReadableStreamFunctionalTest.php
@@ -221,8 +221,8 @@ function() use ($stream, $offset, $length, $expectedBytes) {
                 $stream->seek($offset);
                 $this->assertSame($expectedBytes, $stream->readBytes($length));
             },
-            function(stdClass $command) use (&$commands) {
-                $commands[] = key((array) $command);
+            function(array $event) use (&$commands) {
+                $commands[] = $event['started']->getCommandName();
             }
         );
 
@@ -257,8 +257,8 @@ function() use ($stream, $offset, $length, $expectedBytes) {
                 $stream->seek($offset);
                 $this->assertSame($expectedBytes, $stream->readBytes($length));
             },
-            function(stdClass $command) use (&$commands) {
-                $commands[] = key((array) $command);
+            function(array $event) use (&$commands) {
+                $commands[] = $event['started']->getCommandName();
             }
         );
 
@@ -291,8 +291,8 @@ function() use ($stream, $offset, $length, $expectedBytes) {
                 $stream->seek($offset);
                 $this->assertSame($expectedBytes, $stream->readBytes($length));
             },
-            function(stdClass $command) use (&$commands) {
-                $commands[] = key((array) $command);
+            function(array $event) use (&$commands) {
+                $commands[] = $event['started']->getCommandName();
             }
         );
 
diff --git a/tests/Operation/AggregateFunctionalTest.php b/tests/Operation/AggregateFunctionalTest.php
@@ -28,8 +28,8 @@ function() {
 
                 $operation->execute($this->getPrimaryServer());
             },
-            function(stdClass $command) {
-                $this->assertSame(1, $command->aggregate);
+            function(array $event) {
+                $this->assertSame(1, $event['started']->getCommand()->aggregate);
             }
         );
     }
@@ -47,8 +47,8 @@ function() {
 
                 $operation->execute($this->getPrimaryServer());
             },
-            function(stdClass $command) {
-                $this->assertObjectNotHasAttribute('readConcern', $command);
+            function(array $event) {
+                $this->assertObjectNotHasAttribute('readConcern', $event['started']->getCommand());
             }
         );
     }
@@ -66,8 +66,8 @@ function() {
 
                 $operation->execute($this->getPrimaryServer());
             },
-            function(stdClass $command) {
-                $this->assertObjectNotHasAttribute('writeConcern', $command);
+            function(array $event) {
+                $this->assertObjectNotHasAttribute('writeConcern', $event['started']->getCommand());
             }
         );
     }
@@ -112,8 +112,8 @@ function() {
 
                 $operation->execute($this->getPrimaryServer());
             },
-            function(stdClass $command) {
-                $this->assertObjectHasAttribute('lsid', $command);
+            function(array $event) {
+                $this->assertObjectHasAttribute('lsid', $event['started']->getCommand());
             }
         );
     }
@@ -185,8 +185,8 @@ function() use ($pipeline, $options) {
                 $this->assertCount(1, $results);
                 $this->assertObjectHasAttribute('stages', current($results));
             },
-            function(stdClass $command) {
-                $this->assertObjectNotHasAttribute('writeConcern', $command);
+            function(array $event) {
+                $this->assertObjectNotHasAttribute('writeConcern', $event['started']->getCommand());
             }
         );
 
diff --git a/tests/Operation/BulkWriteFunctionalTest.php b/tests/Operation/BulkWriteFunctionalTest.php
@@ -299,8 +299,8 @@ function() {
 
                 $operation->execute($this->getPrimaryServer());
             },
-            function(stdClass $command) {
-                $this->assertObjectHasAttribute('lsid', $command);
+            function(array $event) {
+                $this->assertObjectHasAttribute('lsid', $event['started']->getCommand());
             }
         );
     }
diff --git a/tests/Operation/CountFunctionalTest.php b/tests/Operation/CountFunctionalTest.php
@@ -23,8 +23,8 @@ function() {
 
                 $operation->execute($this->getPrimaryServer());
             },
-            function(stdClass $command) {
-                $this->assertObjectNotHasAttribute('readConcern', $command);
+            function(array $event) {
+                $this->assertObjectNotHasAttribute('readConcern', $event['started']->getCommand());
             }
         );
     }
@@ -87,8 +87,8 @@ function() {
 
                 $operation->execute($this->getPrimaryServer());
             },
-            function(stdClass $command) {
-                $this->assertObjectHasAttribute('lsid', $command);
+            function(array $event) {
+                $this->assertObjectHasAttribute('lsid', $event['started']->getCommand());
             }
         );
     }
diff --git a/tests/Operation/CreateCollectionFunctionalTest.php b/tests/Operation/CreateCollectionFunctionalTest.php
@@ -20,8 +20,8 @@ function() {
 
                 $operation->execute($this->getPrimaryServer());
             },
-            function(stdClass $command) {
-                $this->assertObjectNotHasAttribute('writeConcern', $command);
+            function(array $event) {
+                $this->assertObjectNotHasAttribute('writeConcern', $event['started']->getCommand());
             }
         );
     }
@@ -42,8 +42,8 @@ function() {
 
                 $operation->execute($this->getPrimaryServer());
             },
-            function(stdClass $command) {
-                $this->assertObjectHasAttribute('lsid', $command);
+            function(array $event) {
+                $this->assertObjectHasAttribute('lsid', $event['started']->getCommand());
             }
         );
     }
diff --git a/tests/Operation/CreateIndexesFunctionalTest.php b/tests/Operation/CreateIndexesFunctionalTest.php
@@ -140,8 +140,8 @@ function() {
 
                 $operation->execute($this->getPrimaryServer());
             },
-            function(stdClass $command) {
-                $this->assertObjectNotHasAttribute('writeConcern', $command);
+            function(array $event) {
+                $this->assertObjectNotHasAttribute('writeConcern', $event['started']->getCommand());
             }
         );
     }
@@ -163,8 +163,8 @@ function() {
 
                 $operation->execute($this->getPrimaryServer());
             },
-            function(stdClass $command) {
-                $this->assertObjectHasAttribute('lsid', $command);
+            function(array $event) {
+                $this->assertObjectHasAttribute('lsid', $event['started']->getCommand());
             }
         );
     }
diff --git a/tests/Operation/DatabaseCommandFunctionalTest.php b/tests/Operation/DatabaseCommandFunctionalTest.php
@@ -24,8 +24,8 @@ function() {
 
                 $operation->execute($this->getPrimaryServer());
             },
-            function(stdClass $command) {
-                $this->assertObjectHasAttribute('lsid', $command);
+            function(array $event) {
+                $this->assertObjectHasAttribute('lsid', $event['started']->getCommand());
             }
         );
     }
diff --git a/tests/Operation/DeleteFunctionalTest.php b/tests/Operation/DeleteFunctionalTest.php
@@ -79,8 +79,8 @@ function() {
 
                 $operation->execute($this->getPrimaryServer());
             },
-            function(stdClass $command) {
-                $this->assertObjectHasAttribute('lsid', $command);
+            function(array $event) {
+                $this->assertObjectHasAttribute('lsid', $event['started']->getCommand());
             }
         );
     }
diff --git a/tests/Operation/DistinctFunctionalTest.php b/tests/Operation/DistinctFunctionalTest.php
@@ -22,8 +22,8 @@ function() {
 
                 $operation->execute($this->getPrimaryServer());
             },
-            function(stdClass $command) {
-                $this->assertObjectNotHasAttribute('readConcern', $command);
+            function(array $event) {
+                $this->assertObjectNotHasAttribute('readConcern', $event['started']->getCommand());
             }
         );
     }
@@ -46,8 +46,8 @@ function() {
 
                 $operation->execute($this->getPrimaryServer());
             },
-            function(stdClass $command) {
-                $this->assertObjectHasAttribute('lsid', $command);
+            function(array $event) {
+                $this->assertObjectHasAttribute('lsid', $event['started']->getCommand());
             }
         );
     }
diff --git a/tests/Operation/DropCollectionFunctionalTest.php b/tests/Operation/DropCollectionFunctionalTest.php
@@ -22,8 +22,8 @@ function() {
 
                 $operation->execute($this->getPrimaryServer());
             },
-            function(stdClass $command) {
-                $this->assertObjectNotHasAttribute('writeConcern', $command);
+            function(array $event) {
+                $this->assertObjectNotHasAttribute('writeConcern', $event['started']->getCommand());
             }
         );
     }
@@ -69,8 +69,8 @@ function() {
 
                 $operation->execute($this->getPrimaryServer());
             },
-            function(stdClass $command) {
-                $this->assertObjectHasAttribute('lsid', $command);
+            function(array $event) {
+                $this->assertObjectHasAttribute('lsid', $event['started']->getCommand());
             }
         );
     }
diff --git a/tests/Operation/DropDatabaseFunctionalTest.php b/tests/Operation/DropDatabaseFunctionalTest.php
@@ -22,8 +22,8 @@ function() {
 
                 $operation->execute($this->getPrimaryServer());
             },
-            function(stdClass $command) {
-                $this->assertObjectNotHasAttribute('writeConcern', $command);
+            function(array $event) {
+                $this->assertObjectNotHasAttribute('writeConcern', $event['started']->getCommand());
             }
         );
     }
@@ -73,8 +73,8 @@ function() {
 
                 $operation->execute($this->getPrimaryServer());
             },
-            function(stdClass $command) {
-                $this->assertObjectHasAttribute('lsid', $command);
+            function(array $event) {
+                $this->assertObjectHasAttribute('lsid', $event['started']->getCommand());
             }
         );
     }
diff --git a/tests/Operation/DropIndexesFunctionalTest.php b/tests/Operation/DropIndexesFunctionalTest.php
@@ -28,8 +28,8 @@ function() {
 
                 $operation->execute($this->getPrimaryServer());
             },
-            function(stdClass $command) {
-                $this->assertObjectNotHasAttribute('writeConcern', $command);
+            function(array $event) {
+                $this->assertObjectNotHasAttribute('writeConcern', $event['started']->getCommand());
             }
         );
     }
@@ -137,8 +137,8 @@ function() {
 
                 $operation->execute($this->getPrimaryServer());
             },
-            function(stdClass $command) {
-                $this->assertObjectHasAttribute('lsid', $command);
+            function(array $event) {
+                $this->assertObjectHasAttribute('lsid', $event['started']->getCommand());
             }
         );
     }
diff --git a/tests/Operation/ExplainFunctionalTest.php b/tests/Operation/ExplainFunctionalTest.php
@@ -182,7 +182,8 @@ function() use ($operation) {
                 $explainOperation = new Explain($this->getDatabaseName(), $operation, ['typeMap' => ['root' => 'array', 'document' => 'array']]);
                 $explainOperation->execute($this->getPrimaryServer());
             },
-            function(stdClass $command) {
+            function(array $event) {
+                $command = $event['started']->getCommand();
                 $this->assertObjectNotHasAttribute('maxAwaitTimeMS', $command->explain);
                 $this->assertObjectHasAttribute('tailable', $command->explain);
                 $this->assertObjectHasAttribute('awaitData', $command->explain);
@@ -206,7 +207,8 @@ function() use ($operation) {
                 $explainOperation = new Explain($this->getDatabaseName(), $operation, ['typeMap' => ['root' => 'array', 'document' => 'array']]);
                 $explainOperation->execute($this->getPrimaryServer());
             },
-            function(stdClass $command) {
+            function(array $event) {
+                $command = $event['started']->getCommand();
                 $this->assertObjectHasAttribute('sort', $command->explain);
                 $this->assertObjectNotHasAttribute('modifiers', $command->explain);
             }
diff --git a/tests/Operation/FindAndModifyFunctionalTest.php b/tests/Operation/FindAndModifyFunctionalTest.php
@@ -30,8 +30,8 @@ function() use ($server) {
 
                 $operation->execute($server);
             },
-            function(stdClass $command) {
-                $this->assertObjectNotHasAttribute('readConcern', $command);
+            function(array $event) {
+                $this->assertObjectNotHasAttribute('readConcern', $event['started']->getCommand());
             }
         );
     }
@@ -48,8 +48,8 @@ function() {
 
                 $operation->execute($this->getPrimaryServer());
             },
-            function(stdClass $command) {
-                $this->assertObjectNotHasAttribute('writeConcern', $command);
+            function(array $event) {
+                $this->assertObjectNotHasAttribute('writeConcern', $event['started']->getCommand());
             }
         );
     }
@@ -70,8 +70,8 @@ function() {
 
                 $operation->execute($this->getPrimaryServer());
             },
-            function(stdClass $command) {
-                $this->assertObjectHasAttribute('lsid', $command);
+            function(array $event) {
+                $this->assertObjectHasAttribute('lsid', $event['started']->getCommand());
             }
         );
     }
diff --git a/tests/Operation/FindFunctionalTest.php b/tests/Operation/FindFunctionalTest.php
@@ -25,8 +25,8 @@ function() {
 
                 $operation->execute($this->getPrimaryServer());
             },
-            function(stdClass $command) {
-                $this->assertObjectNotHasAttribute('readConcern', $command);
+            function(array $event) {
+                $this->assertObjectNotHasAttribute('readConcern', $event['started']->getCommand());
             }
         );
     }
@@ -99,8 +99,8 @@ function() {
 
                 $operation->execute($this->getPrimaryServer());
             },
-            function(stdClass $command) {
-                $this->assertObjectHasAttribute('lsid', $command);
+            function(array $event) {
+                $this->assertObjectHasAttribute('lsid', $event['started']->getCommand());
             }
         );
     }
diff --git a/tests/Operation/InsertManyFunctionalTest.php b/tests/Operation/InsertManyFunctionalTest.php
@@ -70,8 +70,8 @@ function() {
 
                 $operation->execute($this->getPrimaryServer());
             },
-            function(stdClass $command) {
-                $this->assertObjectHasAttribute('lsid', $command);
+            function(array $event) {
+                $this->assertObjectHasAttribute('lsid', $event['started']->getCommand());
             }
         );
     }
diff --git a/tests/Operation/InsertOneFunctionalTest.php b/tests/Operation/InsertOneFunctionalTest.php
@@ -85,8 +85,8 @@ function() {
 
                 $operation->execute($this->getPrimaryServer());
             },
-            function(stdClass $command) {
-                $this->assertObjectHasAttribute('lsid', $command);
+            function(array $event) {
+                $this->assertObjectHasAttribute('lsid', $event['started']->getCommand());
             }
         );
     }
diff --git a/tests/Operation/ListCollectionsFunctionalTest.php b/tests/Operation/ListCollectionsFunctionalTest.php
diff --git a/tests/Operation/ListDatabasesFunctionalTest.php b/tests/Operation/ListDatabasesFunctionalTest.php
diff --git a/tests/Operation/ListIndexesFunctionalTest.php b/tests/Operation/ListIndexesFunctionalTest.php
diff --git a/tests/Operation/MapReduceFunctionalTest.php b/tests/Operation/MapReduceFunctionalTest.php
diff --git a/tests/Operation/UpdateFunctionalTest.php b/tests/Operation/UpdateFunctionalTest.php
diff --git a/tests/Operation/WatchFunctionalTest.php b/tests/Operation/WatchFunctionalTest.php

Original file line number	Diff line number	Diff line change
`@@ -38,14 +38,16 @@ public function observe(callable $execution, callable $commandCallback)`
`38`	`38`
`39`	`39`	`public function commandStarted(CommandStartedEvent $event)`
`40`	`40`	`{`
`41`		`- $this->commands[] = $event->getCommand();`
	`41`	`+ $this->commands[$event->getRequestId()]['started'] = $event;`
`42`	`42`	`}`
`43`	`43`
`44`	`44`	`public function commandSucceeded(CommandSucceededEvent $event)`
`45`	`45`	`{`
	`46`	`+ $this->commands[$event->getRequestId()]['succeeded'] = $event;`
`46`	`47`	`}`
`47`	`48`
`48`	`49`	`public function commandFailed(CommandFailedEvent $event)`
`49`	`50`	`{`
	`51`	`+ $this->commands[$event->getRequestId()]['failed'] = $event;`
`50`	`52`	`}`
`51`	`53`	`}`
Original file line number	Diff line number	Diff line change
`@@ -28,8 +28,8 @@ function() {`
`28`	`28`
`29`	`29`	`$operation->execute($this->getPrimaryServer());`
`30`	`30`	`},`
`31`		`- function(stdClass $command) {`
`32`		`- $this->assertSame(1, $command->aggregate);`
	`31`	`+ function(array $event) {`
	`32`	`+ $this->assertSame(1, $event['started']->getCommand()->aggregate);`
`33`	`33`	`}`
`34`	`34`	`);`
`35`	`35`	`}`
`@@ -47,8 +47,8 @@ function() {`
`47`	`47`
`48`	`48`	`$operation->execute($this->getPrimaryServer());`
`49`	`49`	`},`
`50`		`- function(stdClass $command) {`
`51`		`- $this->assertObjectNotHasAttribute('readConcern', $command);`
	`50`	`+ function(array $event) {`
	`51`	`+ $this->assertObjectNotHasAttribute('readConcern', $event['started']->getCommand());`
`52`	`52`	`}`
`53`	`53`	`);`
`54`	`54`	`}`
`@@ -66,8 +66,8 @@ function() {`
`66`	`66`
`67`	`67`	`$operation->execute($this->getPrimaryServer());`
`68`	`68`	`},`
`69`		`- function(stdClass $command) {`
`70`		`- $this->assertObjectNotHasAttribute('writeConcern', $command);`
	`69`	`+ function(array $event) {`
	`70`	`+ $this->assertObjectNotHasAttribute('writeConcern', $event['started']->getCommand());`
`71`	`71`	`}`
`72`	`72`	`);`
`73`	`73`	`}`
`@@ -112,8 +112,8 @@ function() {`
`112`	`112`
`113`	`113`	`$operation->execute($this->getPrimaryServer());`
`114`	`114`	`},`
`115`		`- function(stdClass $command) {`
`116`		`- $this->assertObjectHasAttribute('lsid', $command);`
	`115`	`+ function(array $event) {`
	`116`	`+ $this->assertObjectHasAttribute('lsid', $event['started']->getCommand());`
`117`	`117`	`}`
`118`	`118`	`);`
`119`	`119`	`}`
`@@ -185,8 +185,8 @@ function() use ($pipeline, $options) {`
`185`	`185`	`$this->assertCount(1, $results);`
`186`	`186`	`$this->assertObjectHasAttribute('stages', current($results));`
`187`	`187`	`},`
`188`		`- function(stdClass $command) {`
`189`		`- $this->assertObjectNotHasAttribute('writeConcern', $command);`
	`188`	`+ function(array $event) {`
	`189`	`+ $this->assertObjectNotHasAttribute('writeConcern', $event['started']->getCommand());`
`190`	`190`	`}`
`191`	`191`	`);`
`192`	`192`
Original file line number	Diff line number	Diff line change
`@@ -299,8 +299,8 @@ function() {`
`299`	`299`
`300`	`300`	`$operation->execute($this->getPrimaryServer());`
`301`	`301`	`},`
`302`		`- function(stdClass $command) {`
`303`		`- $this->assertObjectHasAttribute('lsid', $command);`
	`302`	`+ function(array $event) {`
	`303`	`+ $this->assertObjectHasAttribute('lsid', $event['started']->getCommand());`
`304`	`304`	`}`
`305`	`305`	`);`
`306`	`306`	`}`
Original file line number	Diff line number	Diff line change
`@@ -23,8 +23,8 @@ function() {`
`23`	`23`
`24`	`24`	`$operation->execute($this->getPrimaryServer());`
`25`	`25`	`},`
`26`		`- function(stdClass $command) {`
`27`		`- $this->assertObjectNotHasAttribute('readConcern', $command);`
	`26`	`+ function(array $event) {`
	`27`	`+ $this->assertObjectNotHasAttribute('readConcern', $event['started']->getCommand());`
`28`	`28`	`}`
`29`	`29`	`);`
`30`	`30`	`}`
`@@ -87,8 +87,8 @@ function() {`
`87`	`87`
`88`	`88`	`$operation->execute($this->getPrimaryServer());`
`89`	`89`	`},`
`90`		`- function(stdClass $command) {`
`91`		`- $this->assertObjectHasAttribute('lsid', $command);`
	`90`	`+ function(array $event) {`
	`91`	`+ $this->assertObjectHasAttribute('lsid', $event['started']->getCommand());`
`92`	`92`	`}`
`93`	`93`	`);`
`94`	`94`	`}`
Original file line number	Diff line number	Diff line change
`@@ -20,8 +20,8 @@ function() {`
`20`	`20`
`21`	`21`	`$operation->execute($this->getPrimaryServer());`
`22`	`22`	`},`
`23`		`- function(stdClass $command) {`
`24`		`- $this->assertObjectNotHasAttribute('writeConcern', $command);`
	`23`	`+ function(array $event) {`
	`24`	`+ $this->assertObjectNotHasAttribute('writeConcern', $event['started']->getCommand());`
`25`	`25`	`}`
`26`	`26`	`);`
`27`	`27`	`}`
`@@ -42,8 +42,8 @@ function() {`
`42`	`42`
`43`	`43`	`$operation->execute($this->getPrimaryServer());`
`44`	`44`	`},`
`45`		`- function(stdClass $command) {`
`46`		`- $this->assertObjectHasAttribute('lsid', $command);`
	`45`	`+ function(array $event) {`
	`46`	`+ $this->assertObjectHasAttribute('lsid', $event['started']->getCommand());`
`47`	`47`	`}`
`48`	`48`	`);`
`49`	`49`	`}`
Original file line number	Diff line number	Diff line change
`@@ -140,8 +140,8 @@ function() {`
`140`	`140`
`141`	`141`	`$operation->execute($this->getPrimaryServer());`
`142`	`142`	`},`
`143`		`- function(stdClass $command) {`
`144`		`- $this->assertObjectNotHasAttribute('writeConcern', $command);`
	`143`	`+ function(array $event) {`
	`144`	`+ $this->assertObjectNotHasAttribute('writeConcern', $event['started']->getCommand());`
`145`	`145`	`}`
`146`	`146`	`);`
`147`	`147`	`}`
`@@ -163,8 +163,8 @@ function() {`
`163`	`163`
`164`	`164`	`$operation->execute($this->getPrimaryServer());`
`165`	`165`	`},`
`166`		`- function(stdClass $command) {`
`167`		`- $this->assertObjectHasAttribute('lsid', $command);`
	`166`	`+ function(array $event) {`
	`167`	`+ $this->assertObjectHasAttribute('lsid', $event['started']->getCommand());`
`168`	`168`	`}`
`169`	`169`	`);`
`170`	`170`	`}`
Original file line number	Diff line number	Diff line change
`@@ -24,8 +24,8 @@ function() {`
`24`	`24`
`25`	`25`	`$operation->execute($this->getPrimaryServer());`
`26`	`26`	`},`
`27`		`- function(stdClass $command) {`
`28`		`- $this->assertObjectHasAttribute('lsid', $command);`
	`27`	`+ function(array $event) {`
	`28`	`+ $this->assertObjectHasAttribute('lsid', $event['started']->getCommand());`
`29`	`29`	`}`
`30`	`30`	`);`
`31`	`31`	`}`
Original file line number	Diff line number	Diff line change
`@@ -79,8 +79,8 @@ function() {`
`79`	`79`
`80`	`80`	`$operation->execute($this->getPrimaryServer());`
`81`	`81`	`},`
`82`		`- function(stdClass $command) {`
`83`		`- $this->assertObjectHasAttribute('lsid', $command);`
	`82`	`+ function(array $event) {`
	`83`	`+ $this->assertObjectHasAttribute('lsid', $event['started']->getCommand());`
`84`	`84`	`}`
`85`	`85`	`);`
`86`	`86`	`}`