* @version 0.0.0 * @copyright Copyright (c) 2007, 2008 Roland Haeder, 2009 Developer Team * @license GNU GPL 3.0 or any newer version * @link http://www.ship-simu.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 * the Free Software Foundation, either version 3 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program. If not, see . */ class RawDataInputStream extends BaseStream implements InputStreamable { /** * Protected constructor * * @return void */ protected function __construct () { // Call parent constructor parent::__construct(__CLASS__); } /** * Creates an instance of this node class * * @param $handlerInstance An instance of a Networkable class * @return $streamInstance An instance of this node class */ public final static function createRawDataInputStream (Networkable $handlerInstance) { // Get a new instance $streamInstance = new RawDataInputStream(); // Set the handler instance $streamInstance->setHandlerInstance($handlerInstance); // Return the instance return $streamInstance; } /** * Streams the data and maybe does something to it * * @param $data The data (string mostly) to "stream" * @return $data The data (string mostly) to "stream" * @todo Do we need to do something more here? */ public function streamData ($data) { // Can it be validated? if ((strlen($data) % 4) != 0) { // Length modulo 4 must be zero, else it is an invalid Base64 message $this->getHandlerInstance()->setErrorCode(BaseNetworkPackageHandler::SOCKET_ERROR_INVALID_BASE64_MODULO); $data = false; } elseif (!$this->isBase64Encoded($data)) { // Is not a valid Base64-encoded message $this->getHandlerInstance()->setErrorCode(BaseNetworkPackageHandler::SOCKET_ERROR_INVALID_BASE64_MESSAGE); $data = false; } else { // Decode the data with BASE64-encoding $data = base64_decode($data); } // Return it return $data; } } // [EOF] ?>