more phpcs

Author: norareidy

source/includes/monitoring-logging/MyCommandSubscriber.php

@@ -0,0 +1,32 @@
+<?php
+
+namespace Monitor;
+
+// start-command-subscriber
+class MyCommandSubscriber implements MongoDB\Driver\Monitoring\CommandSubscriber
+{
+    /** @param resource $stream */
+    public function __construct(private $stream)
+    {
+    }
+
+    public function commandStarted(MongoDB\Driver\Monitoring\CommandStartedEvent $event): void
+    {
+        fwrite($this->stream, sprintf(
+            'Started command #%d "%s": %s%s',
+            $event->getRequestId(),
+            $event->getCommandName(),
+            MongoDB\BSON\Document::fromPHP($event->getCommand())->toCanonicalExtendedJSON(),
+            PHP_EOL,
+        ));
+    }
+
+    public function commandSucceeded(MongoDB\Driver\Monitoring\CommandSucceededEvent $event): void
+    {
+    }
+
+    public function commandFailed(MongoDB\Driver\Monitoring\CommandFailedEvent $event): void
+    {
+    }
+}
+// end-command-subscriber

source/includes/monitoring-logging/MySdamSubscriber.php

@@ -0,0 +1,56 @@
+<?php
+
+namespace Monitor;
+
+// start-sdam-subscriber
+class MySDAMSubscriber implements MongoDB\Driver\Monitoring\SDAMSubscriber
+{
+    /** @param resource $stream */
+    public function __construct(private $stream)
+    {
+    }
+
+    public function serverOpening(MongoDB\Driver\Monitoring\ServerOpeningEvent $event): void
+    {
+        fprintf(
+            $this->stream,
+            'Server opening on %s:%s\n',
+            $event->getHost(),
+            $event->getPort(),
+            PHP_EOL,
+        );
+    }
+
+    public function serverClosed(MongoDB\Driver\Monitoring\ServerClosedEvent $event): void
+    {
+    }
+
+    public function serverChanged(MongoDB\Driver\Monitoring\ServerChangedEvent $event): void
+    {
+    }
+
+    public function serverHeartbeatFailed(MongoDB\Driver\Monitoring\ServerHeartbeatFailedEvent $event): void
+    {
+    }
+
+    public function serverHeartbeatStarted(MongoDB\Driver\Monitoring\ServerHeartbeatStartedEvent $event): void
+    {
+    }
+
+    public function serverHeartbeatSucceeded(MongoDB\Driver\Monitoring\ServerHeartbeatSucceededEvent $event): void
+    {
+    }
+
+    public function topologyChanged(MongoDB\Driver\Monitoring\TopologyChangedEvent $event): void
+    {
+    }
+
+    public function topologyClosed(MongoDB\Driver\Monitoring\TopologyClosedEvent $event): void
+    {
+    }
+
+    public function topologyOpening(MongoDB\Driver\Monitoring\TopologyOpeningEvent $event): void
+    {
+    }
+}
+// end-sdam-subscriber

source/includes/monitoring-logging/logging.php

@@ -13,9 +13,7 @@
 // end-monolog-logger
 
 // start-custom-logger
-use Psr\Log\AbstractLogger;
-
-class MyLogger extends AbstractLogger
+class MyLogger extends Psr\Log\AbstractLogger
 {
     public array $logs = [];
 

source/includes/monitoring-logging/monitor.php

@@ -2,87 +2,8 @@
 
 require __DIR__ . '/vendor/autoload.php';
 
-// start-command-subscriber
-class MyCommandSubscriber implements MongoDB\Driver\Monitoring\CommandSubscriber
-{
-    /** @param resource $stream */
-    public function __construct(private $stream)
-    {
-    }
-
-    public function commandStarted(MongoDB\Driver\Monitoring\CommandStartedEvent $event): void
-    {
-        fwrite($this->stream, sprintf(
-            'Started command #%d "%s": %s%s',
-            $event->getRequestId(),
-            $event->getCommandName(),
-            MongoDB\BSON\Document::fromPHP($event->getCommand())->toCanonicalExtendedJSON(),
-            PHP_EOL,
-        ));
-    }
-
-    public function commandSucceeded(MongoDB\Driver\Monitoring\CommandSucceededEvent $event): void
-    {
-    }
-
-    public function commandFailed(MongoDB\Driver\Monitoring\CommandFailedEvent $event): void
-    {
-    }
-}
-// end-command-subscriber
-
-// start-sdam-subscriber
-class MySDAMSubscriber implements MongoDB\Driver\Monitoring\SDAMSubscriber
-{
-    /** @param resource $stream */
-    public function __construct(private $stream)
-    {
-    }
-
-    public function serverOpening(MongoDB\Driver\Monitoring\ServerOpeningEvent $event): void
-    {
-        fprintf(
-            $this->stream,
-            'Server opening on %s:%s\n',
-            $event->getHost(),
-            $event->getPort(),
-            PHP_EOL,
-        );
-    }
-
-    public function serverClosed(MongoDB\Driver\Monitoring\ServerClosedEvent $event): void
-    {
-    }
-
-    public function serverChanged(MongoDB\Driver\Monitoring\ServerChangedEvent $event): void
-    {
-    }
-
-    public function serverHeartbeatFailed(MongoDB\Driver\Monitoring\ServerHeartbeatFailedEvent $event): void
-    {
-    }
-
-    public function serverHeartbeatStarted(MongoDB\Driver\Monitoring\ServerHeartbeatStartedEvent $event): void
-    {
-    }
-
-    public function serverHeartbeatSucceeded(MongoDB\Driver\Monitoring\ServerHeartbeatSucceededEvent $event): void
-    {
-    }
-
-    public function topologyChanged(MongoDB\Driver\Monitoring\TopologyChangedEvent $event): void
-    {
-    }
-
-    public function topologyClosed(MongoDB\Driver\Monitoring\TopologyClosedEvent $event): void
-    {
-    }
-
-    public function topologyOpening(MongoDB\Driver\Monitoring\TopologyOpeningEvent $event): void
-    {
-    }
-}
-// end-sdam-subscriber
+use Monitor\MyCommandSubscriber;
+use Monitor\MySdamSubscriber;
 
 $uri = getenv('MONGODB_URI') ?: throw new RuntimeException('Set the MONGODB_URI variable to your connection URI');
 $client = new MongoDB\Client($uri);

source/monitoring-logging/monitoring.txt

@@ -126,7 +126,7 @@ the ``CommandSubscriber`` interface. The class defines each ``CommandSubscriber`
 and includes custom logic for the ``commandStarted()`` method, which prints details
 about each new command that the server receives:
 
-.. literalinclude:: /includes/monitoring-logging/monitor.php
+.. literalinclude:: /includes/monitoring-logging/MyCommandSubscriber.php
    :start-after: start-command-subscriber
    :end-before: end-command-subscriber
    :language: php
@@ -193,7 +193,7 @@ the ``SDAMSubscriber`` interface. The class defines each ``SDAMSubscriber`` meth
 and includes custom logic for the ``serverOpening()`` method, which prints details
 about servers added to the topology:
 
-.. literalinclude:: /includes/monitoring-logging/monitor.php
+.. literalinclude:: /includes/monitoring-logging/MySdamSubscriber.php
    :start-after: start-sdam-subscriber
    :end-before: end-sdam-subscriber
    :language: php