]> git.mxchange.org Git - hub.git/blobdiff - application/hub/main/lookup/peer/class_PeerStateLookupTable.php
'public static final' is the right thing, some variables renamed to make clear what...
[hub.git] / application / hub / main / lookup / peer / class_PeerStateLookupTable.php
index db1481f84a5b85310f0b50a8b4cab4495680370d..afc3654c7c671e733bdb18fa3ecf18625a3732c8 100644 (file)
@@ -21,7 +21,7 @@
  * You should have received a copy of the GNU General Public License
  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  */
-class PeerStateLookupTable extends BaseLookupTable implements Lookupable {
+class PeerStateLookupTable extends BaseLookupTable implements LookupablePeerState {
        /**
         * Protected constructor
         *
@@ -37,7 +37,7 @@ class PeerStateLookupTable extends BaseLookupTable implements Lookupable {
         *
         * @return      $tableInstance  An instance of a Lookupable class
         */
-       public final static function createPeerStateLookupTable () {
+       public static final function createPeerStateLookupTable () {
                // Get new instance
                $tableInstance = new PeerStateLookupTable();
 
@@ -45,7 +45,7 @@ class PeerStateLookupTable extends BaseLookupTable implements Lookupable {
                $wrapperInstance = ObjectFactory::createObjectByConfiguredName('peer_state_lookup_db_wrapper_class');
 
                // Set it for later re-use
-               $tableInstance->setDatabaseInstance($wrapperInstance);
+               $tableInstance->setWrapperInstance($wrapperInstance);
 
                // Return the prepared instance
                return $tableInstance;
@@ -59,11 +59,45 @@ class PeerStateLookupTable extends BaseLookupTable implements Lookupable {
         */
        public function isSenderNewPeer (array $packageData) {
                // Get our wrapper instance and ask for it
-               $isNewPeer = $this->getDatabaseInstance()->isSenderNewPeer($packageData);
+               $isNewPeer = $this->getWrapperInstance()->isSenderNewPeer($packageData);
 
                // Return it
                return $isNewPeer;
        }
+
+       /**
+        * Registers a peer with given package data. We use the session id from it
+        *
+        * @param       $packageData            Valid raw package data
+        * @param       $socketResource         A valid socket resource
+        * @return      void
+        */
+       public function registerPeerByPackageData (array $packageData, $socketResource) {
+               // Just handle it over
+               $this->getWrapperInstance()->registerPeerByPackageData($packageData, $socketResource);
+       }
+
+       /**
+        * Registers the given peer state and raw package data
+        *
+        * @param       $stateInstance  A PeerStateable class instance
+        * @param       $packageData    Valid package data array
+        * @return      void
+        */
+       public function registerPeerState (PeerStateable $stateInstance, array $packageData) {
+               die(__METHOD__."\n");
+       }
+
+       /**
+        * Purges old entries of given socket resource. We use the IP address from that resource.
+        *
+        * @param       $socketResource         A valid socket resource
+        * @return      void
+        */
+       public function purgeOldEntriesBySocketResource ($socketResource) {
+               // Just handle it over
+               $this->getWrapperInstance()->purgeOldEntriesBySocketResource($socketResource);
+       }
 }
 
 // [EOF]