Version 1

[yaffs-website] / vendor / drupal / console / src / Command / Database / LogPollCommand.php

diff --git a/vendor/drupal/console/src/Command/Database/LogPollCommand.php b/vendor/drupal/console/src/Command/Database/LogPollCommand.php
new file mode 100644 (file)
index 0000000..46a0d62
--- /dev/null
+++ b/vendor/drupal/console/src/Command/Database/LogPollCommand.php
@@ -0,0 +1,87 @@
+<?php
+
+namespace Drupal\Console\Command\Database;
+
+use Drupal\Console\Core\Style\DrupalStyle;
+use Symfony\Component\Console\Input\InputArgument;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Output\OutputInterface;
+
+/**
+ * Class LogPollCommand
+ *
+ * @package Drupal\Console\Command\Database
+ */
+class LogPollCommand extends DatabaseLogBase
+{
+    /**
+     * @var
+     */
+    protected $duration;
+
+    /**
+     * {@inheritdoc}
+     */
+    protected function execute(InputInterface $input, OutputInterface $output)
+    {
+        $io = new DrupalStyle($input, $output);
+
+        $io->note($this->trans('commands.database.log.poll.messages.warning'));
+
+        $this->getDefaultOptions($input);
+        $this->duration = $input->getArgument('duration');
+
+        $this->pollForEvents($io);
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    protected function configure()
+    {
+        $this
+            ->setName('database:log:poll')
+            ->setDescription($this->trans('commands.database.log.poll.description'));
+
+        $this->addDefaultLoggingOptions();
+
+        $this->addArgument(
+            'duration',
+            InputArgument::OPTIONAL,
+            $this->trans('commands.database.log.poll.arguments.duration'),
+            '10'
+        );
+    }
+
+    /**
+     * @param DrupalStyle $io
+     */
+    protected function pollForEvents(DrupalStyle $io)
+    {
+        $query = $this->makeQuery($io)->countQuery();
+        $results = $query->execute()->fetchAssoc();
+        $count = $results['expression'] - 1;//minus 1 so the newest message always prints
+
+        $tableHeader = $this->createTableHeader();
+
+        //Poll, force no wait on first loop
+        $lastExec = time() - $this->duration;
+        while (1) {
+            if (time() > $lastExec + $this->duration) {
+                //Print out any new db logs
+                $query = $this->makeQuery($io, $count);
+                $results = $query->execute()->fetchAll();
+                $count += count($results);
+                $tableRows = [];
+                foreach ($results as $r) {
+                    $tableRows[] = $this->createTableRow($r);
+                }
+                if (!empty($tableRows)) {
+                    $io->table($tableHeader, $tableRows);
+                }
+                //update the last exec time
+                $lastExec = time();
+            }
+        }
+    }
+}