<?php
/**
 * @class AmdaAction

 * @version $Id: AmdaAction.php 2976 2015-07-01 15:05:40Z benjamin $

 * @brief

 */

class AmdaAction

{

	private $xmlFiles  = array('localParam' => 'LocalParams.xml', 'remoteParam' => 'RemoteParams.xml',

										'remoteSimuParam' => 'RemoteParams.xml', 'derivedParam' => 'WsParams.xml', 'myDataParam' => 'WsParams.xml',

										'timeTable' => 'Tt.xml', 'catalog' => 'Tt.xml', 'alias' => 'Alias.xml',
										'myData' => 'Files.xml',

										'request' => 'Request.xml', 'condition' => 'Request.xml',
										'bkgWorks' => 'jobs.xml');

	private $user, $amdaStat;

	public function __construct()
	{

		$dd = new UserMgr();
		$this->user = $dd->user;
		if (!defined('NEWKERNEL_DEBUG') || !NEWKERNEL_DEBUG)
					$this->amdaStat = new AmdaStats($dd->user);
	}

	private function getUrlDirs($url)

	{
		//TODO replace by ftp php class methods: ftp_nlist() etc
		require_once "simple_html_dom.php";

		$url = html_entity_decode($url);

		$trimmed_url = trim($url);

		if (strrpos($trimmed_url, "/") == strlen($trimmed_url) - 1)

		{

			if (file_exists("temp.html")) unlink("temp.html");

			exec("wget -O temp.html ".$url);

			$html = file_get_html('temp.html');
			$dirs = $html->find('a[href]');

			foreach ($dirs as $dir)

			{

				$name =  $dir->innertext; //$dir->href;
				$isLeaf = strrpos($name, "/") !== strlen($name) - 1;

				$childrenToReturn[] = array('text' => $name, 'id' => $trimmed_url.$name, 'nodeType' => 'url', 'leaf' => $isLeaf);

			}

		}

		return $childrenToReturn;

	}

/*****************************************************************
*                           PUBLIC FUNCTIONS

*****************************************************************/

	/*
	*   $obj = { id: node.id,  nodeType: node.nodeType }
	*/
	public function getTree($obj) {

		$node = $obj->node;

		$nodeType = $obj->nodeType;

		$remoteBase = false;
		$isRemoteDataSet = false;

		if ($nodeType == 'url')

		{

			$url = $node == 'root' ? $obj->baseId : $node;

			return  $this->getUrlDirs($url);
		}

		if (isset($obj->baseId)) $remoteBase = true;

		if ($node == 'root' && $remoteBase)  $node = $obj->baseId;

		if ($node == 'root' && !$remoteBase)
		{

			if (file_exists(DATAPATH.$nodeType.'.json')) {
				$json_o = json_decode(file_get_contents(DATAPATH.$nodeType.'.json'));
				if (empty($json_o)) {
					$childrenToReturn = array();
				}
				else {
					$childrenToReturn = $json_o->nodes;
				}
			}
			else {
				$childrenToReturn = array();
			}

		}
		else

		{
			$Dom = new DomDocument("1.0");

			switch ($nodeType)

			{
				case 'sharedtimeTable':
				case 'sharedcatalog':
					$xmlName = SHAREDPATH.'/SharedObjectTree.xml';
					break;

				case 'bkgWorks':

					// data/<user>/JOBS/jobs.xml

					$xmlName = USERJOBDIR.$this->xmlFiles[$nodeType];
					break;
				case 'source':

					$xmlName = DATAPATH.'RemoteData/'.$obj->baseId.'/base.xml';
					break;
				case 'destination':
					$xmlName = USERWSDIR.'RemoteParams.xml';

					break;

				default:
					$xmlName = USERWSDIR.$this->xmlFiles[$nodeType];
			}

			if ($remoteBase){

				$nodeType = 'remoteParam';

			}

			@$Dom->load($xmlName);

			if ($node == "myRemoteSimuData-treeRootNode") $node = "myRemoteData-treeRootNode";

			$nodeToOpen = $Dom->getElementById($node);

			$children = empty($nodeToOpen->childNodes) ? array() : $nodeToOpen->childNodes;

			foreach ($children as $child)
				if ($child->nodeType == XML_ELEMENT_NODE)

				{
					$isLeaf = true;

					if ($child->hasChildNodes())

						foreach ($child->childNodes as $grandChild)
							if ($grandChild -> nodeType == XML_ELEMENT_NODE)

							{
									$isLeaf = false;
									break;
							}
					if ($child->tagName == 'folder')  $isLeaf = false;

					//TODO MAKE PROPERLY  as function of nodetype !!!!
					$info = '';

					$id =  $child->getAttribute('xml:id');

					$name = $child->getAttribute('name');

					$help = $child->getAttribute('att');

					$specialNode = false;
					$isParameter = false;
					$isAddable =  false;
					$isSimulation = false;
					$rank = null;

					$skip = FALSE;

					switch ($nodeType)

					{

						case 'bkgWorks':

							$specialNode = true;

							$childrenToReturn[] = [
								'text'     => $name,
								'id'       => $id,
								'nodeType' => $nodeType,
								'leaf'     => $isLeaf,
								'pid'      => $child->getAttribute('pid'),

								'status'   => $child->getAttribute('status'),

								'jobType'  => $child->getAttribute('jobType'),

								'info'     => $child->getAttribute('info')

							];

							break;

						case 'condition':
							$objectMgr = new RequestMgr();

							$info = $objectMgr->getObject($id)->expression;
						break;

						case 'request':

						$objectMgr = new RequestMgr();

						$objplot = $objectMgr->getObject($id);
						for ($i=0; $i < count($objplot->children); $i++)
						{

							for ($j=0; $j < count($objplot->children[$i]->children); $j++) {

								$info = $info.' . '.$objplot->children[$i]->children[$j]->name;

							}
						}

						break;

						case 'alias':

							$info = $id;
							$id = 'alias_'.$id;

							if ($isLeaf) $isParameter = true;

						break;

						case 'timeTable':

						case 'catalog':

							if ($isLeaf) $info = $child->getAttribute('intervals').' intervals';
						break;

						case 'sharedtimeTable':
						case 'sharedcatalog':

							if ($isLeaf)

							{
								$info = '<b>Nb intervals:</b> '.$child->getAttribute('nbIntervals').'<br/>';
								$info .= '<b>Shared by:</b> '.$child->getAttribute('sharedBy').' ('.$child->getAttribute('sharedDate').')<br/>';
								$info .= '<b>Description:</b> '.$child->getAttribute('description');
							}
						break;
						case 'derivedParam':
							$info = $child->getAttribute('buildchain');
							if ($isLeaf) $isParameter = true;
						break;

						case 'localParam':

							$globalStart = null;
							$globalStop = null;
							$timeRestriction = false;
							$specialNode = true;
							$isParameter = false;
							$needsArgs = false;

							$isSpectra = false;

							$isStack = false;

							$not_yet = false;

							if ($child->hasAttribute('desc'))
							{

								$info = $child->getAttribute('desc');

								if ($child->hasAttribute('dataStart') && $child->hasAttribute('dataStop')) {

									$info .= "<br/>Time Range: ".$child->getAttribute('dataStart')."-".$child->getAttribute('dataStop');

								}

								if ($child->getAttribute('dataStart') == 'depending on mission') {

									$info .= "<br/>Time Range: ".$child->getAttribute('dataStart');

								}

// 								if ($child->getAttribute('restriction') > 1) {
// 									$restricted  = $child->getAttribute('restriction');
// 									$info .= "<br/><b>Time Restriction</b>: -$restricted days";
// 								}

							}

							if ($child->hasAttribute('units')) $info = $child->getAttribute('units');

							if ($child->tagName == 'parameter') {

								$isParameter = true;

								if ($child->parentNode->hasAttribute('dataStart')) {

									$globalStart = $child->parentNode->getAttribute('dataStart');

									$globalStop = $child->parentNode->getAttribute('dataStop');

								}

									
								if ($child->parentNode->hasAttribute('restriction')) {
									if ($child->parentNode->getAttribute('restriction') == "plotOnly") {
										$not_yet = true;
									}

								}

// 								if ($child->parentNode->getAttribute('restriction') > 1 ) {
// 									$timeRestriction = true;
// 								}

							}

							$component_info = array();
							if ($child->tagName == 'component')
							{
								$isParameter = true;

								if ($child->parentNode->parentNode->hasAttribute('dataStart')) {

									$globalStart = $child->parentNode->parentNode->getAttribute('dataStart');

									$globalStop = $child->parentNode->parentNode->getAttribute('dataStop');
								}

								
								if ($child->parentNode->parentNode->hasAttribute('restriction')) {
									if ($child->parentNode->parentNode->getAttribute('restriction') == "plotOnly") {
										$not_yet = true;
									}

								}

// 								if ($child->parentNode->parentNode->getAttribute('restriction') > 1) {
// 									$timeRestriction = true;
// 								}

								if ($child->hasAttribute("index1"))
									$component_info["index1"] = $child->getAttribute('index1');
								if ($child->hasAttribute("index2"))
									$component_info["index2"] = $child->getAttribute('index2');

								$component_info["parentId"] = $child->parentNode->getAttribute('xml:id');
							}

							if ($child->tagName == 'parameter' && $child->hasAttribute('display_type')){

								if ($child->getAttribute('display_type') == 'spectrogram') {

										$needsArgs = true;
										$isSpectra = true;

								}

								elseif ($child->getAttribute('display_type') == 'stackplot') {

										$isStack = true;

								}

							}

							if ($isParameter) {

								$objectMgr = new AliasMgr();
								$alias = $objectMgr->getAlias($id);

								$childrenToReturn[] = array('text' => $name,'alias' => $alias,

									'id' => $id,'nodeType' => $nodeType, 'info' => $info, "component_info" => $component_info,
									'globalStart' => $globalStart, 'globalStop' => $globalStop, 'timeRestriction' => $timeRestriction,

									'leaf' => $isLeaf, 'isParameter' => $isParameter,

									'isSpectra' => $isSpectra,'isStack' => $isStack, 'needsArgs' => $needsArgs, 'help' => $help, 'notyet' => $not_yet);
							}

							else {

								if ($child->tagName == 'mission' || $child->tagName == 'observatory') {

									$rank = $child->getAttribute('rank');
								}

								$disable = $child->hasAttribute('group');

								if ($disable) {

									if ($child->getAttribute("group") !== "TBD") {

											$info .=  "<br/><b>Restricted Access</b>";
										}

									else {

										$info .=  "<br/><b>Sorry! Not finished yet...</b>";

									}

								} 
								else {
									if ($child->hasAttribute('restriction') && $child->getAttribute('restriction') == 'plotOnly')
										$info .=  "<br/><b>Plot Only!!!</b>";

								}

								$childrenToReturn[] = array('text' => $name, 'id' => $id,'nodeType' => $nodeType,  'info' => $info,
									'leaf' => false, 'help' => $help, 'disable' => $disable, 'rank' => $rank);

							}
						break;

						case 'remoteSimuParam' :

							$globalStart = null;

							$service_down = false;

							$isSimulation = true;

			            if ($child->getAttribute('isAddable')) // 'spase://IMPEX/SimulationModel/FMI/GUMICS'

							{
								$isLeaf = false;
								$isAddable = true;
							}

							if ($child->tagName == 'dataCenter')

							{

								if ($child->getAttribute('isSimulation'))

								{

									$service_down = !($child->getAttribute('available'));
									break;

								}

								else

								{
									$skip = true;
									break;
								}
							}

							if ($child->hasAttribute('rank'))

							{
								$rank = $child->getAttribute('rank');
							}

							if ( $child->tagName == 'parameter')
							{

								if ($child->parentNode->hasAttribute('globalStart'))

									{

										$globalStart = $child->parentNode->getAttribute('globalStart');
										$globalStop = $child->parentNode->getAttribute('globalStop');

									}
							}

							if ( $child->tagName == 'component')
							{

								if ($child->parentNode->parentNode->hasAttribute('globalStart'))

									{

										$globalStart = $child->parentNode->parentNode->getAttribute('globalStart');
										$globalStop = $child->parentNode->parentNode->getAttribute('globalStop');

									}
							}

						case 'remoteParam' :

							if ($child->getAttribute('isSimulation') && $child->tagName == 'dataCenter')

							{
								$skip = true;
								break;
							}

							$isDeletable = $child->hasAttribute('isDeletable');
							$specialNode = true;

							$isParameter = false;

							$isSpectra = false;

							switch ($id)

							{

								case 'CDAWEB'  :

								case 'THEMIS' :
									$rank = 5;
									break;

								default:
							}

							$info = $child->getAttribute('desc');

							if ($info && !$isSimulation)
							{

								$info = str_replace(';', "<br/>Time Range: ", $info);

							}

							if (($child->tagName == 'parameter') || ($child->tagName == 'component'))

							{
								$isParameter = true;

							}

							$needsArgs =  $child->getAttribute('needsArgs');

							if ($remoteBase)

							{

								if ($child->tagName == 'dataset') $isRemoteDataSet = true;

							}

							
							if ($child->tagName == 'parameter'){
								if ($child->parentNode->hasAttribute('dataStart')){
									$globalStart = date('Y-m-d\TH:i:s\Z', strtotime($child->parentNode->getAttribute('dataStart')));
									$globalStop = date('Y-m-d\TH:i:s\Z',  strtotime($child->parentNode->getAttribute('dataStop')));
								}
							}

							if ( $child->tagName == 'component'){
								if ($child->parentNode->parentNode->hasAttribute('dataStart')){
									$globalStart = date('Y-m-d\TH:i:s\Z', strtotime($child->parentNode->getAttribute('dataStart')));
									$globalStop = date('Y-m-d\TH:i:s\Z',  strtotime($child->parentNode->getAttribute('dataStop')));
								}
							}
							

							if ($isParameter)

							{

								$disable = $child->parentNode->getAttribute('disabled');

								$objectMgr = new AliasMgr();
								$alias = $objectMgr->getAlias($id);

								if ($child->hasAttribute('display_type') && $child->getAttribute('display_type') == 'spectrogram')
								{

									$needsArgs = true;

									$isSpectra = true;

								}

								if ($globalStart)

								 $childrenToReturn[] = array('text' => $name,'alias' => $alias,

										'id' => $id,'nodeType' => $nodeType,  'info' => $info, 'help' => $help,  'globalStart' => $globalStart,

										'globalStop' => $globalStop, 'leaf' => $isLeaf, 'disable' => $disable, 'isParameter' => $isParameter,

										'isSpectra' => $isSpectra, 'needsArgs' => $needsArgs, "component_info" => isset($component_info) ? $component_info : NULL);

								else

									$childrenToReturn[] = array('text' => $name,'alias' => $alias,

										'id' => $id,'nodeType' => $nodeType,  'info' => $info, 'help' => $help,

										'leaf' => $isLeaf, 'disable' => $disable, 'isParameter' => $isParameter,

										'isSpectra' => $isSpectra, 'needsArgs' => $needsArgs, "component_info" => $component_info);

							}

							else
							{

								$restricted = FALSE;

								if ($child->tagName == 'dataset')

								{

									$nonavailable = ($child->getAttribute('disabled'));

								}

								else

								{

									$nonavailable = false;

								}

								if ($nonavailable)
									$info .= "<br/><b>Not available yet</b>";

								if ($child->getAttribute('url'))
									$info .= "<br/>".$child->getAttribute('url');

								if ($child->hasAttribute('obsolete'))

								{
									$info = $child->getAttribute('desc');
									$obsolete = true;
								}
								else
									$obsolete = false;

								$disable = $restricted || $nonavailable || $obsolete;

								$childrenToReturn[] = array('text' => $name, 'id' => $id,'nodeType' => $nodeType,  'isAddable' => $isAddable,

								'info' => $info, 'leaf' => false, 'isRemoteDataSet' => $isRemoteDataSet, 'disable' => $disable,
								'isSimulation' => $isSimulation, 'rank' => $rank, 'isDeletable' => $isDeletable, 'help' => $help);
							}

						break;

						case 'myData' :
							$info = $child->hasAttribute('info') ? $child->getAttribute('info') : $child->nodeValue;

						break;

						case 'myDataParam' :

							$globalStart = null;
							$globalStop = null;
							$specialNode = true;
							$size = $child->getAttribute('size');

							$mask = $child->getAttribute('mask');

							$sampling = null;
							if ($child->hasAttribute('minsampling')) 
								$sampling = $child->getAttribute('minsampling');

							$isSpectra = false;

							if ($isLeaf)

							{
									$isParameter = true;
									$info = "Size: ".$size."<br/>".$child->getAttribute('desc')."<br/> Mask: ".$mask;

									if ($sampling)
										$info .= "<br/> Sampling : ".$sampling;

									$isSpectra = $child->getAttribute('plottype') === 'Spectra';
							}

							if ($child->hasAttribute('desc'))

							{
									$globalStart = substr($child->getAttribute('desc'), 0, 19);
									$globalStop =  substr($child->getAttribute('desc'), 20);
							}

							$childrenToReturn[] = array('text' => $name, 'size' =>  $size, 'id' => $id,

								'globalStart' => $globalStart, 'globalStop' => $globalStop,

								'nodeType' => $nodeType, 'info' => $info,  'leaf' => $isLeaf,

								'isParameter' => $isParameter, 'linkedMask' => $mask, 'isSpectra' => $isSpectra);

						break;

						default:

					}

					if (!$specialNode && !$skip)

					{

						if ($child->hasAttribute('desc'))

							$info = $child->getAttribute('desc');

						if ($isSimulation && $service_down)

						{
							$info = "<b>Service is currently down</b>";
						}

						$childrenToReturn[] = array('text' => $name, 'id' => $id, 'nodeType' => $nodeType, 'info' => $info,

													'help' => $help, 'leaf' => $isLeaf, 'isParameter' => $isParameter);

					}
				}
				// if $childrenToReturn we have to return []

				if (empty($childrenToReturn))

				{

					$childrenToReturn = array('nodeType' => $nodeType, 'text' => null);
				}
			}

      return  $childrenToReturn;

	}

	/*
	*  add Remote Parameter to user RemoteParams.xml
	*  send request to DDServer to AddVi if Vi doesn't exist
	*  create Remote Parameter Description	
	*/

	public  function saveTree($obj)

	{

		$paramMgr = new RemoteParamManager();

		$res = $paramMgr->init();
		
		if ($res['success'])
			return $paramMgr->saveTree($obj);
		else 
			return $res;

	}

	
	/*
	*  delete Remote Parameter from user RemoteParams.xml
	*/

	public  function deleteFromTree($obj)
	{

		$paramMgr = new RemoteParamManager();

		$res = $paramMgr->init();
		
		if ($res['success'])
			return $paramMgr->deleteFromTree($obj);
		else 
			return $res;

	}

		
	public  function doNothing($obj)
	{
		return array("res" => 'ok');
	}

	/*
	*  get temporary object from Upload
	*/

	public  function getUploadedObject($name, $format, $nodeType)

	{

		$fileContent = preg_replace(['~\R~u', "/\t/"], ["\n", ' '], trim(file_get_contents(USERTEMPDIR . $name)));
		file_put_contents(USERTEMPDIR . $name, $fileContent);

		switch ($nodeType)

		{

			case 'timeTable' :
				$objectMgr = new TimeTableMgr();

				break;

			case 'myDataParam' :
				$objectMgr = new FilesMgr();
				break;
			case 'catalog' :
				$objectMgr = new CatalogMgr();

				break;

			default:
				return array("error" => $nodeType." NOT_IMPLEMENTED_YET");
		}

		return  $objectMgr->getUploadedObject($name, $format, true);

	}

	/*
	*  fill ascii file into grid
	*/

	public  function getAsciiFile($obj)
	{
		$objectMgr = new FilesMgr();

		return  $objectMgr->getAsciiFile($obj->fileName);

	}

	public function getMyParamInfo($object)
	{
		$objectMgr = new FilesMgr();

		return  $objectMgr->getParamInfo($object);

	}

	/*
	*  get temporary object from Search
	*/

	public  function getTmpObject($folderId, $name, $nodeType)
	{
		switch ($nodeType)

		{

			case 'timeTable' :
				$objectMgr = new TimeTableMgr();
			break;

			case 'catalog' :

				$objectMgr = new CatalogMgr();
			break;

			default:
				return array("error" => $nodeType." NOT_IMPLEMENTED_YET");
		}

		return  $objectMgr->getTmpObject($folderId, $name, true);

	}

	public  function getObject($id, $nodeType)
	{
		switch ($nodeType)

		{
			case 'myDataParam':

			case 'derivedParam' :
				$objectMgr = new DerivedParamMgr($nodeType);

				break;

			case 'timeTable' :

			case 'sharedtimeTable' :

				$objectMgr = new TimeTableMgr();
				break;

			case 'catalog' :
			case 'sharedcatalog' :

				$objectMgr = new CatalogMgr();
				break;
			case 'condition' :

			case 'request' :

				$objectMgr = new RequestMgr($nodeType);
				break;

			case 'bkgWorks' :	

				return $this->executeRequest($id, FunctionTypeEnumClass::PROCESSGETINFO);
				break;
			case 'myData' :

				$objectMgr = new FilesMgr();

				break;

			default:

				return array("error" => $nodeType." NOT_IMPLEMENTED_YET");
		}

		return  $objectMgr->getObject($id, $nodeType);

	}

/*
*   $obj = { id: node.id, leaf: node.leaf, nodeType: node.nodeType }
*/

	public  function deleteObject($obj)
	{
		switch ($obj->nodeType)
		{
			case 'myDataParam' :
			case 'derivedParam' :
				$objectMgr = new DerivedParamMgr($obj->nodeType);

				break;

			case 'timeTable' :
				$objectMgr = new TimeTableMgr();
				break;
			case 'catalog' :
				$objectMgr = new CatalogMgr();

				break;

			case 'condition' :

			case 'request' :

				$objectMgr = new RequestMgr($obj->nodeType);

				break;
			case 'alias' :
				$objectMgr = new AliasMgr();
				$obj->id = substr($obj->id,strlen('alias_'));

				break;

			case 'bkgWorks' :

				return $this->executeRequest($obj, FunctionTypeEnumClass::PROCESSDELETE);

			case 'myData' :

				$objectMgr = new FilesMgr();

				break;
			default:
					return array("error" => $obj->nodeType." NOT_IMPLEMENTED_YET");
		}
		return  $objectMgr -> deleteObject($obj);
	}

/*
*   $obj = { id: node.id, old_name: node.text, name: value,  parent : node.parentNode.id, leaf: node.leaf, nodeType: node.nodeType }
*/

	public  function renameObject($obj)
	{
		switch ($obj->nodeType)

		{

		  case 'myDataParam' :

		  case 'derivedParam' :
			   $objectMgr = new DerivedParamMgr($obj->nodeType);
			   break;
		  case 'timeTable' :
			   $objectMgr = new TimeTableMgr();

			   break;

		  case 'catalog' :
			   $objectMgr = new CatalogMgr();

			   break;

		  case 'condition' :
		  case 'request' :
			   $objectMgr = new RequestMgr($obj->nodeType);

			   break;
		  case 'alias' :

		  	   $objectMgr = new AliasMgr();
		  	   break;

		  default:
			    return array("error" => $obj->nodeType." NOT_IMPLEMENTED_YET");

		}

		return  $objectMgr -> renameObject($obj);
	}

/*

*   $obj = { name: obj.name, obj.nodeType, obj.leaf (??), OBJ DEPENDENT ATTRIBUTES }
*/

	public  function createObject($obj, $folder)
	{
		switch ($obj->nodeType)

		{

			case 'myDataParam' :

			case 'derivedParam' :

				if ($obj->nodeType == 'derivedParam' &&  $this->amdaStat->success)

						$this->amdaStat->addTask('create', $this->user, null);

				$objectMgr = new DerivedParamMgr($obj->nodeType);
				break;
			case 'timeTable' :
				$objectMgr = new TimeTableMgr();
				break;
			case 'catalog' :
				$objectMgr = new CatalogMgr();

			   break;

			case 'condition' :

			case 'request' :
				$objectMgr = new RequestMgr($obj->nodeType);
				break;

			case 'alias' :

				$objectMgr = new AliasMgr();
				break;

			default:
				return array("error" => $obj->nodeType." NOT_IMPLEMENTED_YET");
		}
		return  $objectMgr -> createObject($obj, $folder);
	}

/*

*   $obj = { id:obj.id, name: obj.name, obj.nodeType, obj.leaf (??), OBJ DEPENDENT ATTRIBUTES }
*/

	public  function modifyObject($obj)

	{

		switch ($obj->nodeType)
		{
			case 'myDataParam' :
			case 'derivedParam' :
				$objectMgr = new DerivedParamMgr($obj->nodeType);

				break;

			case 'timeTable' :
				$objectMgr = new TimeTableMgr();

				break;

			case 'catalog' :
				$objectMgr = new CatalogMgr();
				break;
			case 'condition' :

			case 'request' :

				$objectMgr = new RequestMgr($obj->nodeType);

				break;
			default:
				return array("error" => $obj->nodeType." NOT_IMPLEMENTED_YET");
		}
		return  $objectMgr -> modifyObject($obj);

	}

/*
 * {obj.name, obj.nodeType, obj.leaf}
 */
    public function validNameObject($obj) {
		switch ($obj->nodeType) {
			case 'myDataParam' :
			case 'derivedParam' :
				$objectMgr = new DerivedParamMgr($obj->nodeType);
				break;
			case 'timeTable' :

			case 'sharedtimeTable' :

				$objectMgr = new TimeTableMgr();
				break;

			case 'catalog' :

			case 'sharedcatalog' :

				$objectMgr = new CatalogMgr();
				break;

			case 'condition' :
			case 'request' :
				$objectMgr = new RequestMgr($obj->nodeType);
				break;
			default:
				return array("error" => $obj->nodeType." NOT_IMPLEMENTED_YET");
		}

		return  $objectMgr -> validNameObject($obj);
    }

/*

*   Get running jobs

*/

	public function getJobs($obj = null)

	{

		$obj = (object) array();

		return $this->executeRequest($obj, FunctionTypeEnumClass::PROCESSRUNNINGINFO);

	}

	/* AKKA-KERNEL-INT
	Move user check from RequestMgr.php to AmdaAction.php
	*/
	private function checkUser($obj)
	{

		if (defined('NEWKERNEL_DEBUG') && NEWKERNEL_DEBUG){

			$this->user = NEWKERNEL_DEBUG_USER;
			return array('success' => true);
		}

		if (isset($obj->username) && isset($obj->password) && isset($obj->sessionID))

		{

			$dd = new WSUserMgr();

			$dd->init($obj->username,$obj->password,$obj->sessionID, false);

		}

		else {

			$dd = new UserMgr();

			$dd->setSpecialSettings();
		}

		//TODO error handling

		if (($res = $dd->ddCheckUser()) != 0) {

			if ($res == 156)

				return array('success' => false, 'message' => 'Your AMDA session is expired.<br/> Login please!');

			return array('success' => false, 'message' => 'ddLogin error: '.$res);
		}

		if ($dd->user == 'impex')

		{
			//if ($dd->getWsSize() > DISK_QUOTA * 100)
			//	error_log('Natacha! It is time to CLEAN UP IMPEX WS!',1,'nbourrel@irap.omp.eu');

//			return array('success' => false, "message" => "AKKA-KERNEL-INT - WS support for IMPEx not implemented");

		}

		else {

			// check disk space 

			if ($dd->getWsSize() > DISK_QUOTA) {
				//Try to delete log files - cf. #6245
				if ($dd->getWsSize(TRUE) > DISK_QUOTA) {
					return array('success' => false, 'message' => 'Please clean up your workspace.<br/>No more space is available');
				}
			}

		}

		$this->user = $dd->user;

		return array('success' => true, 'userHost' => $dd->getIPclient());

	}

	private function executeRequest($obj, $function)

	{ 

		// Check user if access to DD Server and / or possible 'space consuming' action
		if (  $function == FunctionTypeEnumClass::PARAMS ||
				$function == FunctionTypeEnumClass::ACTION ||
				$function == FunctionTypeEnumClass::PARAMSGEN )
		{

			$res = $this->checkUser($obj);
			if (!$res['success']) return $res;
		}
		

		$requestManager = new RequestManagerClass();

		try {

			$res = $requestManager->runIHMRequest($this->user, !empty($res['userHost']) ? $res['userHost'] : NULL, $function, $obj);

		} catch (Exception $e) {

			return array('success' => false, 'message' => 'Exception detected : '.$e->getMessage());

		}

		return $res;
	}

/*
*    Main EXECUTE PROCEDURE

*/

	public  function execute($node, $obj)
	{

		// just convert TT / Catalog
		if ($obj->nodeType == "download" &&  $obj->downloadSrc == "1")
			return $this->executeRequest($obj, FunctionTypeEnumClass::TTCONVERT);
		else if (isset($obj->action))

			return $this->executeRequest($obj, FunctionTypeEnumClass::ACTION);

		else
		{

			$res = RequestMgr::checkRequest($obj);
			if (!$res['success']) return $res;

			return $this->executeRequest($obj, FunctionTypeEnumClass::PARAMS);

		}

	}

/*

 * Generate derived parameter compilation
 */

	public function compilParam($obj)
	{

		return $this->executeRequest($obj, FunctionTypeEnumClass::PARAMSGEN);
	}

/*
 * Delete derived parameter compilation
 */

	public function compilParamDelete($obj)
	{

		$res = $this->checkUser($obj);

		if (!$res['success'])
			return $res;

		IHMConfigClass::setUserName($this->user);
		$libParamPath = IHMConfigClass::getCompilationPath()."lib/".$obj->paramId.".so";
		if (file_exists($libParamPath))
			unlink($libParamPath);

		return array("success" => true);
	}

/*

 * kill plot process

 */

	public function killPlotRequest()

	{

		return $this->executeRequest((object) array('nodeType' => 'killplot'), FunctionTypeEnumClass::PARAMS);
	}

/*
 * merge time tables
 */

	public  function merge($obj)

	{
		if ($this->amdaStat->success)
			$this->amdaStat->addTask('ttoper', $this->user, null);

		$objectMgr = new TimeTableMgr();

		return  $objectMgr -> merge($obj);
	}

/*
 * intersect time tables
 */

	public  function intersect($obj)

	{
		if ($this->amdaStat->success)
				$this->amdaStat->addTask('ttoper', $this->user, null);

		$objectMgr = new TimeTableMgr();
		$result = $objectMgr -> intersect($obj);

		return  $result;
	}

	public function initTTCache($isCatalog = false, $nparams)
	{
		if (!$isCatalog) $cacheMgr = new TimeTableCacheMgr();
		else              $cacheMgr = new CatalogCacheMgr();

		return $cacheMgr->initTTCache($nparams);
	}

	public function initTTCacheFromTT($id, $type)
	{
		if ($type == 'catalog' || $type == 'sharedcatalog') $cacheMgr = new CatalogCacheMgr();
		else $cacheMgr = new TimeTableCacheMgr();

		return $cacheMgr->initFromTT($id, $type);
	}

	public function initForChart($id, $name, $isTmpObject, $type)
	{

		if ($isTmpObject && $type == 'catalog' && $id == 'cacheCat')
			return array('success' => true, 'cache' => $id);
			

		if ($type == 'catalog' || $type == 'sharedcatalog') $objMgr = new CatalogMgr();

		return $objMgr->initForChart($id, $name, $isTmpObject, $type);
	}

	public function initTTCacheFromTmpObject($folderId, $name, $isCatalog = false)
	{

		if (!$isCatalog) $cacheMgr = new TimeTableCacheMgr();

		else  $cacheMgr = new CatalogCacheMgr();

		return $cacheMgr->initFromTmpObject($folderId, $name);
	}

	public function initTTCacheFromUploadedFile($name, $format, $isCatalog = false)

	{

		if (!$isCatalog) $cacheMgr = new TimeTableCacheMgr();
		else  $cacheMgr = new CatalogCacheMgr();

		return $cacheMgr->initFromUploadedFile($name, $format);
	}

	public function readTTCacheIntervals($o)
	{

		if (isset($o->typeTT) && ($o->typeTT == 'catalog' || $o->typeTT == 'sharedcatalog')) $cacheMgr = new CatalogCacheMgr();

		else $cacheMgr = new TimeTableCacheMgr();

		return $cacheMgr->getIntervals($o->start,$o->limit,isset($o->sort) ? $o->sort : NULL, isset($o->filter) ? $o->filter : NULL);

	}

	public function readIntervalsForChart($o)
	{

		if (isset($o->typeTT) && ($o->typeTT == 'catalog' || $o->typeTT == 'sharedcatalog')) {

				
				if ($o->fromPlugin && $o->id == 'cacheCat') {
					$objMgr = new CatalogCacheMgr();
					
					return $objMgr->getIntervals();
				}
				
				$objMgr = new CatalogMgr();
		}

		return $objMgr->getIntervalsForChart($o->id, $o->name, $o->fromPlugin, $o->typeTT);
	}

	public function saveTTCacheIntervalsInTT($o)
	{
		$cacheMgr = new TimeTableCacheMgr();
		return $cacheMgr->saveInTT($o->ttId,$o->action,$o->cacheToken);
	}

	public function addTTCacheInterval($o)
	{
		if ($o->isCatalog) $cacheMgr = new CatalogCacheMgr();
		else $cacheMgr = new TimeTableCacheMgr();

		return $cacheMgr->addInterval($o->index, $o->start, $o->stop);
	}

	public function removeTTCacheIntervalFromId($id, $isCatalog = false)
	{
		if ($isCatalog) $cacheMgr = new CatalogCacheMgr();
		else $cacheMgr = new TimeTableCacheMgr();

		return $cacheMgr->removeIntervalFromId($id);
	}

	public function modifyTTCacheInterval($o)
	{

		if ($o->isCatalog)

		{

			$cacheMgr = new CatalogCacheMgr();

			return $cacheMgr->modifyIntervalFromId($o);

		}

		else $cacheMgr = new TimeTableCacheMgr();

		return $cacheMgr->modifyIntervalFromId($o->cacheId, $o->start, $o->stop);
	}

	public function operationTTCacheIntervals($extendTime, $shiftTime)
	{
		$cacheMgr = new TimeTableCacheMgr();
		return $cacheMgr->operationIntervals($extendTime, $shiftTime);
	}

	public function mergeTTCacheIntervals()
	{
		$cacheMgr = new TimeTableCacheMgr();
		return $cacheMgr->mergeIntervals();
	}

	public function getTTCacheStatistics()
	{
		$cacheMgr = new TimeTableCacheMgr();
		return $cacheMgr->getStatistics();
	}

	public function getTTCacheStatus()
	{
		$cacheMgr = new TimeTableCacheMgr();
		return $cacheMgr->getStatus();
	}

/*
 * Send a feedback

 *

 */