NodeManager.inc.php

Go to the documentation of this file.

<?php

namespace HCE\admin {

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

        class NodeManager {
                protected $nodes = array ();

                protected $responses = array ();

                protected $error = 0;

                public function setNodes($nodes) {
                        $this->nodes = $nodes;
                }

                public function getNodes() {
                        return $this->nodes;
                }

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

                public function getErrorCode() {
                        return $this->error;
                }
                public function addResponseItem($responseItem) {
                        if ($responseItem !== NULL) {
                                $this->responses [] = $responseItem;
                        }
                }

                public function deleteResponseItem($index) {
                        if (isset ( $this->responses [$index] )) {
                                unset ( $this->responses [$index] );
                        }
                }

                public function setResponses($responses) {
                        $this->responses = $responses;
                }

                public function getResponseItem($index = NULL) {
                        if ($index === NULL) {
                                return count ( $this->responses );
                        } else {
                                return $this->responses [$index];
                        }
                }

                public function getResponses() {
                        return $this->responses;
                }

                public function __construct($nodes = null) {
                        // Set nodes
                        if ($nodes !== null) {
                                $this->setNodes ( $nodes );
                        }
                }

                public function __destruct() {
                        $this->nodes = null;
                        $this->responses = null;
                }

                public function execute($commandObject) {
                        $ret = true;

                        // Make $NodeManageResponse object instance to return
                        $request = new NodeManageRequest ();

                        // For each node
                        foreach ( $this->nodes as $node ) {
                                // Execute command for node
                                $response = $request->execute ( $commandObject, $node );
                                // accumulate response item
                                $this->addResponseItem ( $response );
                                if ($response->getErrorCode ()) {
                                        $ret = false;
                                }
                        }

                        return $ret;
                }

                public function getResponsesDump() {
                        $ret = '';

                        // Process all responses
                        foreach ( $this->responses as $response ) {
                                if ($response->getErrorCode ()) {
                                        $ret .= MSG_NODE_MANAGE_RESPONSE_ITEM_ERROR . $response->getErrorCode () . PHP_EOL;
                                } else {
                                        $transportResponse = $response->getResponse ();
                                        if ($transportResponse->getErrorCode ()) {
                                                $ret .= MSG_TRANSPORT_RESPONSE_ITEM_ERROR . $transportResponse->getErrorCode () . PHP_EOL;
                                        } else {
                                                // Get transport response items from transport response object
                                                $transportResponsesItems = $transportResponse->getResponses ();
                                                // Dump all items data
                                                foreach ( $transportResponsesItems as $transportResponseItem ) {
                                                        $ret .= var_export ( $transportResponseItem, true );
                                                }
                                        }
                                }
                        }

                        return $ret;
                }

                public function getResponsesData() {
                        $ret = array ();

                        // Process all responses
                        foreach ( $this->responses as $response ) {
                                $ret [] = array (
                                                $response->getResponseMessageErrorCode (),
                                                $response->getResponseMessageId (),
                                                $response->getResponseMessageBody ()
                                );
                        }

                        return $ret;
                }

                public function getResponsesFields() {
                        $ret = array ();

                        // Process all responses
                        foreach ( $this->responses as $response ) {
                                $ret [] = $response->getResponseCommandFields ();
                        }

                        return $ret;
                }
        }
}

?>