NodeManageRequest.inc.php

Go to the documentation of this file.

<?php

namespace HCE\admin {

        require_once __DIR__ . '/../transport/Constants.inc.php';
        require_once __DIR__ . '/../transport/Connection.inc.php';
        require_once __DIR__ . '/../transport/Request.inc.php';

        require_once 'Constants.inc.php';
        require_once 'Node.inc.php';
        require_once 'NodeCommand.inc.php';
        require_once 'NodeManageResponse.inc.php';

        class NodeManageRequest {
                protected $transportRequest = NULL;

                protected $transportConnection = NULL;

                protected $error = 0;

                public function setErrorCode($errorCode) {
                        $this->error = $errorCode;
                }

                public function getErrorCode() {
                        return $this->error;
                }

                public function __construct($transportConnection = null, $transportRequest = null) {
                        // Init transport connection
                        $this->transportConnection = $transportConnection;

                        // Init transport request
                        $this->transportRequest = $transportRequest;
                }

                public function __destruct() {
                        $this->transportRequest = NULL;
                        $this->transportConnection = NULL;
                }

                public function execute($command, $node) {
                        // Make $NodeManageResponse object instance to return
                        $nodeManageResponseObject = new \HCE\admin\NodeManageResponse ();

                        // Create connection with default initialization
                        $connection = new \HCE\transport\Connection ();
                        if (! $connection->error) {
                                // Set connection properties
                                $connection->host = $node->getHost ();
                                $connection->port = $node->getPort ();
                                // Create request with default initialization
                                $request = new \HCE\transport\Request ( $connection );
                                if (! $request->getErrorCode ()) {
                                        // Try to open connection
                                        if ($connection->open ()) {
                                                // Execute request
                                                $response = $request->execute ( $command->getMessageBody (), $node->getTimeout () );
                                                // Check transport request state
                                                if ($response->getErrorCode ()) {
                                                        // Error of transport request execution
                                                        $nodeManageResponseObject->setErrorCode ( ERROR_TRANSPORT_REQUEST );
                                                }
                                                // Set transport response
                                                $nodeManageResponseObject->setResponse ( $response );
                                                // Close connection
                                                $connection->close ();
                                        } else {
                                                // Error open connection
                                                $nodeManageResponseObject->setErrorCode ( ERROR_CONNECTION_OPEN );
                                        }
                                } else {
                                        // Error create request object
                                        $nodeManageResponseObject->setErrorCode ( ERROR_REQUEST_CREATE );
                                }
                        } else {
                                // Error create connection object
                                $nodeManageResponseObject->setErrorCode ( ERROR_CONNECTION_CREATE );
                        }

                        return $nodeManageResponseObject;
                }
        }
}

?>