* 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
*
*
* @return $tableInstance An instance of a Lookupable class
*/
- public final static function createPeerStateLookupTable () {
+ public static final function createPeerStateLookupTable () {
// Get new instance
$tableInstance = new PeerStateLookupTable();
$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;
*/
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]