phpmyadmin working

1 files changed, 240 insertions, 0 deletions

diff --git a/srcs/phpmyadmin/libraries/classes/Controllers/Server/Status/ProcessesController.php b/srcs/phpmyadmin/libraries/classes/Controllers/Server/Status/ProcessesController.php
new file mode 100644
index 0000000..9817e1b
--- /dev/null
+++ b/srcs/phpmyadmin/libraries/classes/Controllers/Server/Status/ProcessesController.php
@@ -0,0 +1,240 @@
+<?php
+/* vim: set expandtab sw=4 ts=4 sts=4: */
+/**
+ * Holds the PhpMyAdmin\Controllers\Server\Status\ProcessesController
+ *
+ * @package PhpMyAdmin\Controllers
+ */
+declare(strict_types=1);
+
+namespace PhpMyAdmin\Controllers\Server\Status;
+
+use PhpMyAdmin\Message;
+use PhpMyAdmin\Util;
+
+/**
+ * Class ProcessesController
+ * @package PhpMyAdmin\Controllers\Server\Status
+ */
+class ProcessesController extends AbstractController
+{
+    /**
+     * @param array $params Request parameters
+     * @return string
+     */
+    public function index(array $params): string
+    {
+        $isChecked = false;
+        if (! empty($params['showExecuting'])) {
+            $isChecked = true;
+        }
+
+        $urlParams = [
+            'ajax_request' => true,
+            'full' => $params['full'] ?? '',
+            'column_name' => $params['column_name'] ?? '',
+            'order_by_field' => $params['order_by_field'] ?? '',
+            'sort_order' => $params['sort_order'] ?? '',
+        ];
+
+        $serverProcessList = $this->getList($params);
+
+        return $this->template->render('server/status/processes/index', [
+            'url_params' => $urlParams,
+            'is_checked' => $isChecked,
+            'server_process_list' => $serverProcessList,
+        ]);
+    }
+
+    /**
+     * Only sends the process list table
+     *
+     * @param array $params Request parameters
+     * @return string
+     */
+    public function refresh(array $params): string
+    {
+        return $this->getList($params);
+    }
+
+    /**
+     * @param array $params Request parameters
+     * @return array
+     */
+    public function kill(array $params): array
+    {
+        $kill = (int) $params['kill'];
+        $query = $this->dbi->getKillQuery($kill);
+
+        if ($this->dbi->tryQuery($query)) {
+            $message = Message::success(
+                __('Thread %s was successfully killed.')
+            );
+            $this->response->setRequestStatus(true);
+        } else {
+            $message = Message::error(
+                __(
+                    'phpMyAdmin was unable to kill thread %s.'
+                    . ' It probably has already been closed.'
+                )
+            );
+            $this->response->setRequestStatus(false);
+        }
+        $message->addParam($kill);
+
+        $json = [];
+        $json['message'] = $message;
+
+        return $json;
+    }
+
+    /**
+     * @param array $params Request parameters
+     * @return string
+     */
+    private function getList(array $params): string
+    {
+        $urlParams = [];
+
+        $showFullSql = ! empty($params['full']);
+        if ($showFullSql) {
+            $urlParams['full'] = '';
+        } else {
+            $urlParams['full'] = 1;
+        }
+
+        // This array contains display name and real column name of each
+        // sortable column in the table
+        $sortableColumns = [
+            [
+                'column_name' => __('ID'),
+                'order_by_field' => 'Id',
+            ],
+            [
+                'column_name' => __('User'),
+                'order_by_field' => 'User',
+            ],
+            [
+                'column_name' => __('Host'),
+                'order_by_field' => 'Host',
+            ],
+            [
+                'column_name' => __('Database'),
+                'order_by_field' => 'db',
+            ],
+            [
+                'column_name' => __('Command'),
+                'order_by_field' => 'Command',
+            ],
+            [
+                'column_name' => __('Time'),
+                'order_by_field' => 'Time',
+            ],
+            [
+                'column_name' => __('Status'),
+                'order_by_field' => 'State',
+            ],
+            [
+                'column_name' => __('Progress'),
+                'order_by_field' => 'Progress',
+            ],
+            [
+                'column_name' => __('SQL query'),
+                'order_by_field' => 'Info',
+            ],
+        ];
+        $sortableColCount = count($sortableColumns);
+
+        $sqlQuery = $showFullSql
+            ? 'SHOW FULL PROCESSLIST'
+            : 'SHOW PROCESSLIST';
+        if ((! empty($params['order_by_field'])
+                && ! empty($params['sort_order']))
+            || ! empty($params['showExecuting'])
+        ) {
+            $urlParams['order_by_field'] = $params['order_by_field'];
+            $urlParams['sort_order'] = $params['sort_order'];
+            $urlParams['showExecuting'] = $params['showExecuting'];
+            $sqlQuery = 'SELECT * FROM `INFORMATION_SCHEMA`.`PROCESSLIST` ';
+        }
+        if (! empty($params['showExecuting'])) {
+            $sqlQuery .= ' WHERE state != "" ';
+        }
+        if (! empty($params['order_by_field']) && ! empty($params['sort_order'])) {
+            $sqlQuery .= ' ORDER BY '
+                . Util::backquote($params['order_by_field'])
+                . ' ' . $params['sort_order'];
+        }
+
+        $result = $this->dbi->query($sqlQuery);
+
+        $columns = [];
+        foreach ($sortableColumns as $columnKey => $column) {
+            $is_sorted = ! empty($params['order_by_field'])
+                && ! empty($params['sort_order'])
+                && ($params['order_by_field'] == $column['order_by_field']);
+
+            $column['sort_order'] = 'ASC';
+            if ($is_sorted && $params['sort_order'] === 'ASC') {
+                $column['sort_order'] = 'DESC';
+            }
+            if (isset($params['showExecuting'])) {
+                $column['showExecuting'] = 'on';
+            }
+
+            $columns[$columnKey] = [
+                'name' => $column['column_name'],
+                'params' => $column,
+                'is_sorted' => $is_sorted,
+                'sort_order' => $column['sort_order'],
+                'has_full_query' => false,
+                'is_full' => false,
+            ];
+
+            if (0 === --$sortableColCount) {
+                $columns[$columnKey]['has_full_query'] = true;
+                if ($showFullSql) {
+                    $columns[$columnKey]['is_full'] = true;
+                }
+            }
+        }
+
+        $rows = [];
+        while ($process = $this->dbi->fetchAssoc($result)) {
+            // Array keys need to modify due to the way it has used
+            // to display column values
+            if ((! empty($params['order_by_field']) && ! empty($params['sort_order']))
+                || ! empty($params['showExecuting'])
+            ) {
+                foreach (array_keys($process) as $key) {
+                    $newKey = ucfirst(mb_strtolower($key));
+                    if ($newKey !== $key) {
+                        $process[$newKey] = $process[$key];
+                        unset($process[$key]);
+                    }
+                }
+            }
+
+            $rows[] = [
+                'id' => $process['Id'],
+                'user' => $process['User'],
+                'host' => $process['Host'],
+                'db' => ! isset($process['db']) || strlen($process['db']) === 0 ? '' : $process['db'],
+                'command' => $process['Command'],
+                'time' => $process['Time'],
+                'state' => ! empty($process['State']) ? $process['State'] : '---',
+                'progress' => ! empty($process['Progress']) ? $process['Progress'] : '---',
+                'info' => ! empty($process['Info']) ? Util::formatSql(
+                    $process['Info'],
+                    ! $showFullSql
+                ) : '---',
+            ];
+        }
+
+        return $this->template->render('server/status/processes/list', [
+            'columns' => $columns,
+            'rows' => $rows,
+            'refresh_params' => $urlParams,
+        ]);
+    }
+}