Continued with hub:

[hub.git] / application / hub / main / tasks / node / dht / class_NodeDhtQueryTask.php

diff --git a/application/hub/main/tasks/node/dht/class_NodeDhtQueryTask.php b/application/hub/main/tasks/node/dht/class_NodeDhtQueryTask.php
index 1baa4d65907bcfc12d9928742126c6a868cc1c2c..2a6491c88bbfe10755e2ac601952ab2aee35b58f 100644 (file)
--- a/application/hub/main/tasks/node/dht/class_NodeDhtQueryTask.php
+++ b/application/hub/main/tasks/node/dht/class_NodeDhtQueryTask.php
@@ -2,11 +2,11 @@
 /**
  * A DhtQuery node-task
  *
- * @author             Roland Haeder <webmaster@ship-simu.org>
+ * @author             Roland Haeder <webmaster@shipsimu.org>
  * @version            0.0.0
- * @copyright  Copyright (c) 2007, 2008 Roland Haeder, 2009 - 2012 Hub Developer Team
+ * @copyright  Copyright (c) 2007, 2008 Roland Haeder, 2009 - 2014 Hub Developer Team
  * @license            GNU GPL 3.0 or any newer version
- * @link               http://www.ship-simu.org
+ * @link               http://www.shipsimu.org
  *
  * This program is free software: you can redistribute it and/or modify
  * it under the terms of the GNU General Public License as published by
@@ -41,6 +41,12 @@ class NodeDhtQueryTask extends BaseTask implements Taskable, Visitable {
                // Get new instance
                $taskInstance = new NodeDhtQueryTask();
 
+               // Get a DHT instance
+               $dhtInstance = DhtObjectFactory::createDhtInstance('node');
+
+               // Set the DHT instance here
+               $taskInstance->setDhtInstance($dhtInstance);
+
                // Return the prepared instance
                return $taskInstance;
        }
@@ -60,10 +66,17 @@ class NodeDhtQueryTask extends BaseTask implements Taskable, Visitable {
         * Executes the task
         *
         * @return      void
-        * @todo        0% done
+        * @todo        ~5% done
         */
        public function executeTask () {
-               $this->partialStub('Unimplemented task.');
+               // Get DHT instance
+               $dhtInstance = $this->getDhtInstance();
+
+               // Are there "INSERT" node data entries?
+               if ($dhtInstance->ifInsertNodeDataPending()) {
+                       // Then insert a single entry
+                       $dhtInstance->insertSingleNodeData();
+               } // END - if
        }
 }