Introduced (cached) method ifNodeDataIsFound()

[hub.git] / application / hub / main / database / wrapper / node / class_NodeDistributedHashTableDatabaseWrapper.php

diff --git a/application/hub/main/database/wrapper/node/class_NodeDistributedHashTableDatabaseWrapper.php b/application/hub/main/database/wrapper/node/class_NodeDistributedHashTableDatabaseWrapper.php
index b9ea83a50407413b03b5f40e7e7537aa5c6cb3c6..70b5a58a380bb2d44621c54d5e6997c352b96db8 100644 (file)
--- a/application/hub/main/database/wrapper/node/class_NodeDistributedHashTableDatabaseWrapper.php
+++ b/application/hub/main/database/wrapper/node/class_NodeDistributedHashTableDatabaseWrapper.php
@@ -25,6 +25,11 @@ class NodeDistributedHashTableDatabaseWrapper extends BaseDatabaseWrapper implem
        // Constants for database table names
        const DB_TABLE_NODE_DHT = 'node_dht';
 
+       // Constants for database column names
+       const DB_COLUMN_NODE_ID    = 'node_id';
+       const DB_COLUMN_SESSION_ID = 'session_id';
+       const DB_COLUMN_IP_PORT    = 'ip_port';
+
        /**
         * Protected constructor
         *
@@ -50,6 +55,55 @@ class NodeDistributedHashTableDatabaseWrapper extends BaseDatabaseWrapper implem
                // Return the instance
                return $wrapperInstance;
        }
+
+       /**
+        * Checks whether the local (*this*) node is registered in the DHT by
+        * checking if the external ip/port is found.
+        *
+        * @return      $isRegistered   Whether *this* node is registered in the DHT
+        */
+       public function isLocalNodeRegistered () {
+               // Is there cache?
+               if (!isset($GLOBALS[__METHOD__])) {
+                       // Get a search criteria instance
+                       $searchInstance = ObjectFactory::createObjectByConfiguredName('search_criteria_class');
+
+                       // Get node instance
+                       $nodeInstance = Registry::getRegistry()->getInstance('node');
+
+                       // Add ip:port as criteria
+                       $searchInstance->addCriteria(self::DB_COLUMN_IP_PORT, $nodeInstance->getAddressPort());
+                       $searchInstance->setLimit(1);
+
+                       // Query database and get a result instance back
+                       $resultInstance = $this->doSelectByCriteria($searchInstance);
+
+                       // Cache result of if there is an entry, next() will tell us if the next entry is valid
+                       $GLOBALS[__METHOD__] = $resultInstance->next();
+               } // END - if
+
+               // Return result
+               return $GLOBALS[__METHOD__];
+       }
+
+       /**
+        * Registeres the local (*this*) node with its data in the DHT.
+        *
+        * @return      void
+        */
+       public function registerLocalNode () {
+               $this->partialStub('Not implemented yet.');
+       }
+
+       /**
+        * Updates local (*this*) node data in DHT, this is but not limited to the
+        * session id, ip number (and/or hostname) and port number.
+        *
+        * @return      void
+        */
+       public function updateLocalNode () {
+               $this->partialStub('Not implemented yet.');
+       }
 }
 
 // [EOF]