Show what scheme was used

Author: Nyholm

Collector/QueryLogger.php

@@ -4,9 +4,11 @@
 
 namespace Neo4j\Neo4jBundle\Collector;
 
+use GraphAware\Bolt\Result\Result;
 use GraphAware\Common\Cypher\StatementInterface;
 use GraphAware\Common\Result\StatementResult as StatementResultInterface;
 use GraphAware\Common\Result\StatementStatisticsInterface;
+use GraphAware\Neo4j\Client\Exception\Neo4jExceptionInterface;
 
 /**
  * @author Xavier Coureau <[email protected]>
@@ -59,6 +61,11 @@ public function record(StatementInterface $statement)
      */
     public function finish(StatementResultInterface $statementResult)
     {
+        $scheme = 'Http';
+        if ($statementResult instanceof Result) {
+            $scheme = 'Bolt';
+        }
+
         $statement = $statementResult->statement();
         $statementText = $statement->text();
         $statementParams = $statement->parameters();
@@ -77,9 +84,18 @@ public function finish(StatementResultInterface $statementResult)
             'end_time' => microtime(true) * 1000,
             'nb_results' => $statementResult->size(),
             'statistics' => $this->statisticsToArray($statementResult->summarize()->updateStatistics()),
+            'scheme' => $scheme,
         ]);
     }
 
+    /**
+     * @param Neo4jExceptionInterface $exception
+     */
+    public function logException(Neo4jExceptionInterface $exception)
+    {
+        // TODO log exceptions
+    }
+
     /**
      * {@inheritdoc}
      */
@@ -138,7 +154,7 @@ private function statisticsToArray(StatementStatisticsInterface $statementStatis
             'constraints_added' => $statementStatistics->constraintsAdded(),
             'constraints_removed' => $statementStatistics->constraintsRemoved(),
         ];
-        
+
         return $data;
     }
 }

EventSubscriber/LoggerSubscriber.php

@@ -4,6 +4,7 @@
 
 namespace Neo4j\Neo4jBundle\EventSubscriber;
 
+use GraphAware\Neo4j\Client\Event\FailureEvent;
 use GraphAware\Neo4j\Client\Event\PostRunEvent;
 use GraphAware\Neo4j\Client\Event\PreRunEvent;
 use GraphAware\Neo4j\Client\Neo4jClientEvents;
@@ -33,6 +34,7 @@ public static function getSubscribedEvents()
         return [
             Neo4jClientEvents::NEO4J_PRE_RUN => 'onPreRun',
             Neo4jClientEvents::NEO4J_POST_RUN => 'onPostRun',
+            Neo4jClientEvents::NEO4J_ON_FAILURE => 'onFailure',
         ];
     }
 
@@ -55,4 +57,12 @@ public function onPostRun(PostRunEvent $event)
             $this->queryLogger->finish($result);
         }
     }
+
+    /**
+     * @param FailureEvent $event
+     */
+    public function onFailure(FailureEvent $event)
+    {
+        $this->queryLogger->logException($event->getException());
+    }
 }

Resources/views/webprofiler.html.twig

@@ -76,6 +76,9 @@
                     <div>
                         <strong class="font-normal text-small">Number of results</strong>: {{ statement.nb_results }}
                     </div>
+                    <div>
+                        <strong class="font-normal text-small">Scheme</strong>: {{ statement.scheme }}
+                    </div>
                     <div>
                         <strong class="font-normal text-small">Statistics</strong>: {{ statement.statistics|yaml_encode }}
                     </div>