Add packet search

carlbennett · carlbennett · commit 54743c2e1fbc · 2016-07-28T04:11:00.000Z
diff --git a/src/controllers/Packet/Search.php b/src/controllers/Packet/Search.php
@@ -5,6 +5,7 @@
 use \BNETDocs\Libraries\Common;
 use \BNETDocs\Libraries\Controller;
 use \BNETDocs\Libraries\Exceptions\UnspecifiedViewException;
+use \BNETDocs\Libraries\Packet;
 use \BNETDocs\Libraries\Router;
 use \BNETDocs\Libraries\UserSession;
 use \BNETDocs\Models\Packet\Search as PacketSearchModel;
@@ -20,8 +21,35 @@ public function run(Router &$router) {
       default:
         throw new UnspecifiedViewException();
     }
+
     $model = new PacketSearchModel();
+
+    $data = $router->getRequestQueryArray();
+
+    $model->query = (isset($data["q"]) ? (string) $data["q"] : null);
+
+    if (!empty($model->query)) {
+      $model->packets = Packet::getAllPacketsBySearch($model->query);
+    }
+
     $model->user_session = UserSession::load($router);
+
+    // Remove packets that are not published
+    if ($model->packets) {
+      $i = count($model->packets) - 1;
+      while ($i >= 0) {
+        if (!($model->packets[$i]->getOptionsBitmask()
+          & Packet::OPTION_PUBLISHED)) {
+          unset($model->packets[$i]);
+        }
+        --$i;
+      }
+    }
+
+    if ($model->packets) {
+      $model->sum_packets = count($model->packets);
+    }
+
     ob_start();
     $view->render($model);
     $router->setResponseCode(200);
diff --git a/src/libraries/Document.php b/src/libraries/Document.php
@@ -60,7 +60,7 @@ public function __construct($data) {
   public static function getAllDocuments() {
     $cache_key = "bnetdocs-documents";
     $cache_val = Common::$cache->get($cache_key);
-    if ($cache_val !== false) {
+    if ($cache_val !== false && !empty($cache_val)) {
       $ids     = explode(",", $cache_val);
       $objects = [];
       foreach ($ids as $id) {
diff --git a/src/libraries/NewsCategory.php b/src/libraries/NewsCategory.php
@@ -45,7 +45,7 @@ public function __construct($data) {
   public static function getAll() {
     $cache_key = "bnetdocs-newscategories";
     $cache_val = Common::$cache->get($cache_key);
-    if ($cache_val !== false) {
+    if ($cache_val !== false && !empty($cache_val)) {
       $ids     = explode(",", $cache_val);
       $objects = [];
       foreach ($ids as $id) {
diff --git a/src/libraries/NewsPost.php b/src/libraries/NewsPost.php
@@ -122,7 +122,7 @@ public static function delete($id) {
   public static function getAllNews($reverse) {
     $cache_key = "bnetdocs-newsposts";
     $cache_val = Common::$cache->get($cache_key);
-    if ($cache_val !== false) {
+    if ($cache_val !== false && !empty($cache_val)) {
       $ids     = explode(",", $cache_val);
       $objects = [];
       foreach ($ids as $id) {
diff --git a/src/libraries/Packet.php b/src/libraries/Packet.php
@@ -82,7 +82,7 @@ public function __construct($data) {
   public static function getAllPackets() {
     $cache_key = "bnetdocs-packets";
     $cache_val = Common::$cache->get($cache_key);
-    if ($cache_val !== false) {
+    if ($cache_val !== false && !empty($cache_val)) {
       $ids     = explode(",", $cache_val);
       $objects = [];
       foreach ($ids as $id) {
@@ -133,6 +133,65 @@ public static function getAllPackets() {
     return null;
   }
 
+  public static function getAllPacketsBySearch($query) {
+    $cache_key = "bnetdocs-packetsearch-" . hash("md5", $query);
+    $cache_val = Common::$cache->get($cache_key);
+    if ($cache_val !== false && !empty($cache_val)) {
+      $ids     = explode(",", $cache_val);
+      $objects = [];
+      foreach ($ids as $id) {
+        $objects[] = new self($id);
+      }
+      return $objects;
+    }
+    if (!isset(Common::$database)) {
+      Common::$database = DatabaseDriver::getDatabaseObject();
+    }
+    try {
+      $stmt = Common::$database->prepare("
+        SELECT
+          `created_datetime`,
+          `edited_count`,
+          `edited_datetime`,
+          `id`,
+          `options_bitmask`,
+          `packet_application_layer_id`,
+          `packet_direction_id`,
+          `packet_format`,
+          `packet_id`,
+          `packet_name`,
+          `packet_remarks`,
+          `packet_transport_layer_id`,
+          `user_id`
+        FROM `packets`
+        WHERE
+          MATCH (`packet_remarks`, `packet_format`, `packet_name`)
+          AGAINST (:query IN NATURAL LANGUAGE MODE WITH QUERY EXPANSION)
+        ;
+      ");
+      $stmt->bindParam(":query", $query, PDO::PARAM_STR);
+      if (!$stmt->execute()) {
+        throw new QueryException("Cannot search packets");
+      }
+      $ids     = [];
+      $objects = [];
+      while ($row = $stmt->fetch(PDO::FETCH_OBJ)) {
+        $ids[]     = (int) $row->id;
+        $objects[] = new self($row);
+        Common::$cache->set(
+          "bnetdocs-packet-" . $row->id, serialize($row), 300
+        );
+      }
+      $stmt->closeCursor();
+      Common::$cache->set($cache_key, implode(",", $ids), 300);
+      return $objects;
+    } catch (PDOException $e) {
+      var_dump($e);die();
+      throw new QueryException("Cannot search packets", $e);
+    }
+    return null;
+  }
+
   public function getCreatedDateTime() {
     if (is_null($this->created_datetime)) {
       return $this->created_datetime;
diff --git a/src/libraries/PacketApplicationLayer.php b/src/libraries/PacketApplicationLayer.php
@@ -38,7 +38,7 @@ public function __construct($data) {
   public static function getAllPacketApplicationLayers() {
     $cache_key = "bnetdocs-packetapplicationlayers";
     $cache_val = Common::$cache->get($cache_key);
-    if ($cache_val !== false) {
+    if ($cache_val !== false && !empty($cache_val)) {
       $ids     = explode(",", $cache_val);
       $objects = [];
       foreach ($ids as $id) {
diff --git a/src/libraries/PacketTransportLayer.php b/src/libraries/PacketTransportLayer.php
@@ -38,7 +38,7 @@ public function __construct($data) {
   public static function getAllPacketTransportLayers() {
     $cache_key = "bnetdocs-packettransportlayers";
     $cache_val = Common::$cache->get($cache_key);
-    if ($cache_val !== false) {
+    if ($cache_val !== false && !empty($cache_val)) {
       $ids     = explode(",", $cache_val);
       $objects = [];
       foreach ($ids as $id) {
diff --git a/src/libraries/Product.php b/src/libraries/Product.php
@@ -47,7 +47,7 @@ public function __construct($data) {
   public static function getAllProducts() {
     $cache_key = "bnetdocs-products";
     $cache_val = Common::$cache->get($cache_key);
-    if ($cache_val !== false) {
+    if ($cache_val !== false && !empty($cache_val)) {
       $ids     = explode(",", $cache_val);
       $objects = [];
       foreach ($ids as $id) {
diff --git a/src/libraries/Server.php b/src/libraries/Server.php
@@ -66,7 +66,7 @@ public function getAddress() {
   public static function getAllServers() {
     $cache_key = "bnetdocs-servers";
     $cache_val = Common::$cache->get($cache_key);
-    if ($cache_val !== false) {
+    if ($cache_val !== false && !empty($cache_val)) {
       $ids     = explode(",", $cache_val);
       $objects = [];
       foreach ($ids as $id) {
diff --git a/src/libraries/ServerType.php b/src/libraries/ServerType.php
@@ -35,7 +35,7 @@ public function __construct($data) {
   public static function getAllServerTypes() {
     $cache_key = "bnetdocs-servertypes";
     $cache_val = Common::$cache->get($cache_key);
-    if ($cache_val !== false) {
+    if ($cache_val !== false && !empty($cache_val)) {
       $ids     = explode(",", $cache_val);
       $objects = [];
       foreach ($ids as $id) {
diff --git a/src/models/Packet/Search.php b/src/models/Packet/Search.php
@@ -6,10 +6,16 @@
 
 class Search extends Model {
 
+  public $packets;
+  public $query;
+  public $sum_packets;
   public $user_session;
 
   public function __construct() {
     parent::__construct();
+    $this->packets      = null;
+    $this->query        = null;
+    $this->sum_packets  = null;
     $this->user_session = null;
   }
 
diff --git a/src/templates/Packet/Search.phtml b/src/templates/Packet/Search.phtml
@@ -2,18 +2,58 @@
 namespace BNETDocs\Templates;
 
 use \BNETDocs\Libraries\Common;
+use \BNETDocs\Libraries\Packet;
+use \BNETDocs\Libraries\Gravatar;
 use \BNETDocs\Libraries\Pair;
+use \BNETDocs\Libraries\User;
 
 $title       = "Search Packets";
 $description = "Search the packets on BNETDocs";
 $this->opengraph->attach(new Pair("url", "/packet/search"));
 
+$avatars = [];
+$getAvatar = function(&$avatars, &$user) {
+  $user_id = $user->getId();
+  if (isset($avatars[$user_id])) {
+    return $avatars[$user_id];
+  }
+  $avatars[$user_id] = new Gravatar($user->getEmail());
+  return $avatars[$user_id];
+};
+
+$this->additional_css[] = "/a/forms.css";
 require("./header.inc.phtml");
 ?>
       <article>
         <header>Search Packets</header>
         <section>
-          <?php require("./NYI.inc.phtml"); ?>
+          <form method="GET">
+            <input type="text" name="q" id="q" value="<?php echo htmlentities($this->getContext()->query, ENT_HTML5, "UTF-8"); ?>" tabindex="1" autofocus="autofocus"/>
+            <input type="submit" value="Submit"/>
+          </form>
+<?php if (!is_null($this->getContext()->packets)) { ?>
+          <table>
+            <thead>
+              <tr>
+                <th class="left">Found <?php echo number_format($this->getContext()->sum_packets); ?> packet<?php echo ($this->getContext()->sum_packets != 1 ? "s" : ""); ?> matching: <?php echo htmlentities($this->getContext()->query, ENT_HTML5, "UTF-8"); ?></th>
+                <th class="left">Author</th>
+              </tr>
+            </thead><tbody>
+<?php foreach ($this->getContext()->packets as $packet) {
+        $user         = $packet->getUser();
+        if ($user) {
+          $user_url   = $user->getURI();
+          $avatar_url = "https:" . $getAvatar($avatars, $user)->getUrl(22, "identicon");
+        }
+        $packet_id = $packet->getPacketId(true);
+?>
+              <tr>
+                <td><a href="<?php echo $packet->getURI(); ?>"><?php echo htmlspecialchars($packet->getPacketDirectionTag() . " " . $packet_id . " " . $packet->getPacketName(), ENT_HTML5, "UTF-8"); ?></a></td>
+                <td><?php if ($user) { ?><a href="<?php echo $user_url; ?>"><img class="avatar" src="<?php echo $avatar_url; ?>"/> <?php echo htmlspecialchars($user->getName(), ENT_HTML5, "UTF-8"); ?></a><?php } else { ?>Anonymous<?php } ?></td>
+              </tr>
+<?php } ?>
+          </tbody></table>
+<?php } ?>
         </section>
       </article>
       <article>
