<?php

/**
 * @class IHMInputOutputRunningInfoProcessClass
 * @brief Implementation of a IHMInputOutputInfoProcessAbstractClass used to treat a request to get the status of all running process
 * @details
 */
class IHMInputOutputRunningInfoProcessClass extends IHMInputOutputInfoProcessAbstractClass
{
	/*
	 * @brief get the list of running job
	*/
	public function getJobIds($input)
	{
		return $this->jobsManager->getJobsByStatus('in_progress');
	}

	/*
	 * @brief method to marshall the result
	*/
	public function marshallResult($data)
	{
		$nFinished   = 0;
		$nError      = 0;
		$nInProgress = 0;
		$jobsFinished = null;
		$jobsInProgress = null;

		foreach ($data as $d)
		{
			if (!$d->getSuccess())
				continue;

			$jobInfo = $this->jobsManager->updateJobStatus(
					$d->getId(),
					$d->getStatus() == ProcessStatusEnumClass::RUNNING,
					$d->getErrorCode());

			if (!$jobInfo['success'])
				continue;

			switch ($jobInfo['status'])
			{
				case 'in_progress' :
					if (!isset($jobsInProgress))
						$jobsInProgress = array();
					$jobsInProgress[] = $jobInfo;
					++$nInProgress;
					break;
				case 'done' :
					if (!isset($jobsFinished))
						$jobsFinished = array();
					$jobsFinished[] = $jobInfo;
					++$nFinished;
					break;
				default :
					if (!isset($jobsFinished))
						$jobsFinished = array();
					$jobsFinished[] = $jobInfo;
					++$nError;
			}
		}

		return array(
				'success'        => true,
				'nFinished'      => $nFinished,
				'nError'         => $nError,
				'nInProgress'    => $nInProgress,
				'jobsFinished'   => $jobsFinished,
				'jobsInProgress' => $jobsInProgress);
	}
}

?>