<?php
/**
 * @class ParamsRequestClass
 * @brief Treats a param request. This class inherits from ProcessRequestClass
 * @details
 */
class ParamsRequestClass extends ProcessRequestClass
{
	/*
	 * @brief Init a params request
	*/
	public function init()
	{
		if (!isset($this->requestData))
			return false;
			
		if ($this->requestData->getType(ProcessTypeEnumClass::KILL))
			return true;
		
		$this->requestData->setType(ProcessTypeEnumClass::RUN);
		
		switch ($this->requestData->getRequestType())
		{
			case ParamsRequestTypeEnumClass::XMLREQUEST :
				$cmd = "";
				foreach ($this->requestData->getRequestNodes() as $request_index => $requestNode)
				{
					if ($cmd != "")
						$cmd .= " && ";
					$cmd .= KernelConfigClass::getKernelBinPath()."amdaXMLRequestorTool ".$this->getRequestFilePath($request_index);
				}
				$this->requestData->setCmd($cmd);
				break;
			case ParamsRequestTypeEnumClass::PARAMGEN :
				$this->requestData->setCmd(KernelConfigClass::getKernelBinPath()."amdaParameterGenerator -p ".$this->requestData->getParamId());
				break;
			case ParamsRequestTypeEnumClass::PARAMSINFOGEN :
                                $this->requestData->setCmd(KernelConfigClass::getKernelBinPath()."amdaParameterInfo -p ".$this->requestData->getParamId());
                                break;
		}
		$this->requestData->setEnvVars(KernelConfigClass::getExecEnvVarArray());
			
		if (!parent::init())
			return false;
			
		$this->requestData->setSuccess(false);
		$this->requestData->setLastErrorMessage('Cannot init params request');

		if ($this->requestData->getCompilationPath() == '')
		{
			$this->requestData->setLastErrorMessage('Compilation path for params request not defined');
			return false;
		}

		if (!is_dir($this->requestData->getCompilationPath()))
		{
			if (!mkdir($this->requestData->getCompilationPath(),0777))
			{
				$this->requestData->setLastErrorMessage('Cannot create compilation path for params request');
				return false;
			}
		}

		if ($this->requestData->getRequestType() == ParamsRequestTypeEnumClass::XMLREQUEST)
		{
			foreach ($this->requestData->getRequestNodes() as $request_index => $requestNode)
			{
				//inject time restriction
				if (count($this->requestData->getParamsTimeRestrictions()) > 0) {
					//Here
					foreach ($this->requestData->getParamsTimeRestrictions() as $paramId => $timeRestriction)
					{
						$requestNode->getParamsTimeRestrictions()->addParamTimeRestriction($paramId, strtotime($timeRestriction));
					}
				}

				//create XML request file
				$doc = new DOMDocument("1.0", "UTF-8");
				$doc->preserveWhiteSpace = false;
				$doc->formatOutput = true;

				if (!$xmlNode = $requestNode->toXMLNode($doc))
				{
					$this->requestData->setLastErrorMessage('Cannot create params request XML file for request');
					return false;
				}
			
				$doc->appendChild($xmlNode);

				if (!$doc->save($this->getRequestFilePath($request_index)))
				{
					$this->requestData->setLastErrorMessage('Cannot save params request XML file for request');
					return false;
				}
				
				//libxml_use_internal_errors(true);
				if (!$doc->schemaValidate(KernelConfigClass::getXSDRequestFilePath()))
				{
					//$error_msg = "";
					//$errors = libxml_get_errors();
					//foreach ($errors as $error) {
					//	if ($error_msg != "")
					//		$error_msg .= PHP_EOL;
					//	$error_msg .= 'XML error "'.$error->message.'" ['.$error->level.'] (Code '.$error->code.') in '.$error->file.' on line '.$error->line.' column '.$error->column;
					//}
					//libxml_clear_errors();
					
					$this->requestData->setLastErrorMessage('Params request XML file not valid for request'/*.' ('.$error_msg.')'*/);
					return false;
				}
				//libxml_use_internal_errors(false);
			}
		}

		//create config files
		KernelConfigClass::write($this->requestData->getWorkingPath(), $this->requestData->getCompilationPath(), $this->requestData->getLocalBasePath());

		//copy parameters files
		foreach ($this->requestData->getParamsToCopy() as $key => $value)
		{
			if (!file_exists($value))
			{
				$this->requestData->setLastErrorMessage('Cannot find param definition file for '.$key);
				return false;
			}
				
			$destinationFile = KernelConfigClass::getRequestParamsPath($this->requestData->getWorkingPath()).$key.".xml";
			if (!copy($value,$destinationFile))
			{
				$this->requestData->setLastErrorMessage('Cannot copy param definition file for '.$key);
				return false;
			}
			// get datasetID for statistics
			$doc = new DOMDocument("1.0", "UTF-8"); 
			if (@$doc->load($value)) {
				$dsID = $doc->getElementsByTagName('dataset_id');
				if ($dsID->length > 0) {
					if ($dsID->item(0)->nodeValue)
						$dsName = $dsID->item(0)->nodeValue;
					elseif (strpos($key, 'spase_') !== false)
						$dsName = 'impex';
					else
						$dsName = 'unknown';
						
					$this->requestData->addDatasetForStat($dsName);
				}
			}
			
			touch($destinationFile, filemtime($value));
		}

		//create processed params files
		foreach ($this->requestData->getProcessParamsToCreate() as $key => $value)
		{
			$doc = new DOMDocument("1.0", "UTF-8");
			$doc->preserveWhiteSpace = false;
			$doc->formatOutput = true;

			if (!$xmlNode = $value["param"]->toXMLNode($doc))
			{
				$this->requestData->setLastErrorMessage('Cannot create params XML file for '.$key);
				return false;
			}
				
			$doc->appendChild($xmlNode);

			/*if (!$doc->schemaValidate(KernelConfigClass::getXSDParameterFilePath()))
			 {
			$this->requestData->setLastErrorMessage('Params XML file not valid for '.$key);
			return false;
			}*/

			$destinationFile = KernelConfigClass::getRequestParamsPath($this->requestData->getWorkingPath()).$key.".xml";
			if (!$doc->save($destinationFile))
			{
				$this->requestData->setLastErrorMessage('Cannot save params XML file for '.$key);
				return false;
			}
			
			touch($destinationFile, $value["dateModif"]);
		}
		
		//create local params files
		foreach ($this->requestData->getLocalParamsToCreate() as $key => $value)
		{
			$doc = new DOMDocument("1.0", "UTF-8");
			$doc->preserveWhiteSpace = false;
			$doc->formatOutput = true;


			if (!$xmlNode = $value["param"]->toXMLNode($doc))
			{
				$this->requestData->setLastErrorMessage('Cannot create params XML file for '.$key);
				return false;
			}
				
			$doc->appendChild($xmlNode);

			$destinationFile = KernelConfigClass::getRequestParamsPath($this->requestData->getWorkingPath()).$key.".xml";
			if (!$doc->save($destinationFile))
			{
				$this->requestData->setLastErrorMessage('Cannot save params XML file for '.$key);
				return false;
			}
			
			$this->requestData->addDatasetForStat('uploadedData');
			
			touch($destinationFile, $value["dateModif"]);
		}
		//create and copy local params files
		foreach ($this->requestData->getLocalParamsToCreateAndCopy() as $key => $value)
		{
			$doc = new DOMDocument("1.0", "UTF-8");
			$doc->preserveWhiteSpace = false;
			$doc->formatOutput = true;

			if (!$xmlNode = $value["param"]->toXMLNode($doc))
			{
				$this->requestData->setLastErrorMessage('Cannot create params XML file for '.$key);
				return false;
			}
				
			$doc->appendChild($xmlNode);
			
			$originFile =  IHMConfigClass::getUserWSPath().$key.".xml";
			$destinationFile = KernelConfigClass::getRequestParamsPath($this->requestData->getWorkingPath()).$key.".xml";
			
			if (!$doc->save($destinationFile) || !$doc->save($originFile))
			{
				$this->requestData->setLastErrorMessage('Cannot save params XML file for '.$key);
				return false;
			}
			
			touch($originFile, $value["dateModif"]);
			touch($destinationFile, $value["dateModif"]);
		}
		return true;
	}
	/*
	 * @brief Run a params request
	*/
	public function run()
	{
		$amdaStat = new AmdaStats($this->requestData->getUser());
		
		if (count($this->requestData->getDatasetForStat()) > 0)
			$amdaStat->addTask(IHMConfigClass::getUserName(), $this->requestData->getTask(), $this->requestData->getDatasetForStat());
		
		return parent::run();
	}

	/*
	 * @brief Get the request file path for AMDA_Kernel
	*/
	private function getRequestFilePath($request_index)
	{
		return $this->requestData->getWorkingPath()."request_".$request_index.".xml";
	}
}
?>