From f4118d9f3c0f06dc635e4201956e47f82dcd623f Mon Sep 17 00:00:00 2001
From: ghost <localhost>
Date: Sun, 13 Aug 2023 19:48:49 +0300
Subject: [PATCH] implement SphinxQL driver

---
 src/library/sphinxql.php | 65 ++++++++++++++++++++++++++++++++++++++++
 1 file changed, 65 insertions(+)
 create mode 100644 src/library/sphinxql.php

diff --git a/src/library/sphinxql.php b/src/library/sphinxql.php
new file mode 100644
index 0000000..be4c93c
--- /dev/null
+++ b/src/library/sphinxql.php
@@ -0,0 +1,65 @@
+<?php
+
+class SphinxQL {
+
+  private $_sphinx;
+
+  public function __construct(string $host, int $port) {
+
+    $this->_sphinx = new PDO('mysql:host=' . $host . ';port=' . $port . ';charset=utf8', false, false, [PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES utf8']);
+    $this->_sphinx->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
+    $this->_sphinx->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_OBJ);
+  }
+
+  public function searchPeersTotal(string $keyword) {
+
+    $query = $this->_sphinx->prepare('SELECT COUNT(*) AS `total` FROM `peer` WHERE MATCH(?)');
+
+    $query->execute(
+      [
+        self::_match($keyword)
+      ]
+    );
+
+    return $query->fetch()->total;
+  }
+
+  public function searchPeers(string $keyword, int $start, int $limit, int $maxMatches) {
+
+    $query = $this->_sphinx->prepare("SELECT *
+
+                                      FROM `peer`
+
+                                      WHERE MATCH(?)
+
+                                      ORDER BY WEIGHT() DESC
+
+                                      LIMIT " . (int) ($start >= $maxMatches ? ($maxMatches > 0 ? $maxMatches - 1 : 0) : $start) . "," . (int) $limit . "
+
+                                      OPTION `max_matches`=" . (int) ($maxMatches >= 1 ? $maxMatches : 1));
+
+    $query->execute(
+      [
+        self::_match($keyword)
+      ]
+    );
+
+    return $query->fetchAll();
+  }
+
+  private static function _match(string $keyword) : string {
+
+    $keyword = preg_replace('/[\:]+/', ':', $keyword);
+
+    return sprintf(
+      '@peerAddress "%s" | @peerKey "%s" | @peerCoordinatePort "%s" | @peerCoordinateRoute "%s" | @peerRemoteScheme "%s" | @peerRemoteHost "%s" | @peerRemotePort "%s"',
+      preg_replace('/[^A-z0-9\:]/',   '', $keyword),
+      preg_replace('/[^A-z0-9]/',     '', $keyword),
+      preg_replace('/[^\d]/',         '', $keyword),
+      preg_replace('/[^\d]/',         '', $keyword),
+      preg_replace('/[^A-z]/',        '', $keyword),
+      preg_replace('/[^A-z0-9\.\:]/', '', $keyword),
+      preg_replace('/[^\d]/',         '', $keyword),
+    );
+  }
+}