Package data 'recipient', 'sender' and 'content' are now replaceable

[hub.git] / application / hub / main / handler / network / class_BaseNetworkPackageHandler.php

diff --git a/application/hub/main/handler/network/class_BaseNetworkPackageHandler.php b/application/hub/main/handler/network/class_BaseNetworkPackageHandler.php
index 8d13405f66d463c49b05d73a8259fb40cc69dc31..3e63996459fdb345cd876e6ff04f5c74b3fb712d 100644 (file)
--- a/application/hub/main/handler/network/class_BaseNetworkPackageHandler.php
+++ b/application/hub/main/handler/network/class_BaseNetworkPackageHandler.php
@@ -4,7 +4,7 @@
  *
  * @author             Roland Haeder <webmaster@ship-simu.org>
  * @version            0.0.0
- * @copyright  Copyright (c) 2007, 2008 Roland Haeder, 2009 Hub Developer Team
+ * @copyright  Copyright (c) 2007, 2008 Roland Haeder, 2009 - 2011 Hub Developer Team
  * @license            GNU GPL 3.0 or any newer version
  * @link               http://www.ship-simu.org
  *
@@ -22,13 +22,21 @@
  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  */
 class BaseNetworkPackageHandler extends BaseHandler {
-       // Error codes
-       const SOCKET_ERROR_GENERAL            = 'general_error';
-       const SOCKET_ERROR_TRANSPORT_ENDPOINT = 'transport_endpoint';
-       const SOCKET_ERROR_UNHANDLED          = 'unhandled_package';
-       const SOCKET_ERROR_EMPTY_DATA         = 'empty_data';
-       const PACKAGE_ERROR_INVALID_DATA      = 'invalid_data';
-       const PACKAGE_LEVEL_CHECK_OKAY        = 'checked_package';
+       // Error codes:
+       // - Socket raw data stream errors
+       const SOCKET_ERROR_UNKNOWN                = 'unknown_error';      // Unknown error (should not happen)
+       const SOCKET_ERROR_TRANSPORT_ENDPOINT     = 'transport_endpoint'; // Transport endpoint has closed
+       const SOCKET_ERROR_EMPTY_DATA             = 'empty_data';         // Other peer has sent nothing
+       const SOCKET_ERROR_INVALID_BASE64_MODULO  = 'base64_modulo';      // Length is not modulo 4
+       const SOCKET_ERROR_INVALID_BASE64_MESSAGE = 'base64_message';     // Raw data is not Base64-encoded
+       const SOCKET_ERROR_UNHANDLED              = 'unhandled_package';  // Unhandled raw data (not bad)
+
+       // - Package errors
+       const PACKAGE_ERROR_INVALID_DATA         = 'invalid_data';    // Invalid data in package found
+       const PACKAGE_ERROR_INCOMPLETE_DATA      = 'incomplete_data'; // Incomplete data sent (e.g. field is missing)
+       const PACKAGE_ERROR_INVALID_CONTENT      = 'invalid_content'; // Content is invalid (e.g. not well-formed)
+       const PACKAGE_ERROR_RECIPIENT_MISMATCH   = 'recipient_error'; // Recipient is not us
+       const PACKAGE_LEVEL_CHECK_OKAY           = 'checked_package'; // Package is fine
 
        /**
         * Error code from socket
@@ -44,6 +52,31 @@ class BaseNetworkPackageHandler extends BaseHandler {
        protected function __construct ($className) {
                // Call parent constructor
                parent::__construct($className);
+
+               // Get an input stream instance
+               $streamInstance = ObjectFactory::createObjectByConfiguredName('node_raw_data_input_stream_class', array($this));
+
+               // Set it in this network-package handler
+               $this->setInputStreamInstance($streamInstance);
+       }
+
+       /**
+        * Checks wether the 'recipient' field matches our own address:port
+        * combination.
+        *
+        * @param       $packageData    Raw package data
+        * @return      $matches                Wether it matches
+        */
+       protected function ifRecipientMatchesOwnAddress (array $packageData) {
+               // Construct own address first,
+               $ownAddress = Registry::getRegistry()->getInstance('node')->getAddressPort($this);
+
+               // Does it match?
+               // @TODO Numeric or alpha-numeric index?
+               $matches = ($ownAddress === $packageData[NetworkPackage::INDEX_PACKAGE_RECIPIENT]);
+
+               // Return result
+               return $matches;
        }
 
        /**