<?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";

	}
}

?>