<?

//azioni da eseguire una volta in background
//usano APC

//variabili globali

//stati
/*


start_confirm (in attesa di conferma, prima di partire, usato da indi_job_start_bg)
running
finished
error





*/


function indi_job_start($name=NULL,$key=NULL,$status="running",$uid=NULL) {
	
	trigger_error("Jobs ancora in uso?");
	
	if(!$key) $key =  $GLOBALS['CONF']['sito'];
	if(!$key) return false;
	
	$INDI_JOBS = apc_fetch("INDI_JOBS");
	
	//se sono in start_confirm, metto lo stato a running	
	if($INDI_JOBS[$key]['status'] == "start_confirm") {

		//cambio stato
		indi_job_var("status","running",$key);
		indi_job_log("status","running");
		return TRUE;
		
	}	
	
	//se sono in start_confirm, metto lo stato a running	
	if($INDI_JOBS[$key]['status'] == "confirm_timeout") {
		//if($INDI_JOBS[$key]['uid'] == $uid) {
				indi_job_error("Job scaduto $uid ",$key);
				return FALSE;
		//}
	}
		
		
		
		
	if($INDI_JOBS[$key]['status'] == "finish" or $INDI_JOBS[$key]['status'] == "error"  or $INDI_JOBS[$key]['status'] == "confirm_timeout" or !isset($INDI_JOBS[$key])) {
		
		//cancello tutto 
		$INDI_JOBS[$key] = array();
		if($name) $INDI_JOBS[$key]['name'] 	= $name;

		$INDI_JOBS[$key]['status'] 	= $status;
		$INDI_JOBS[$key]['uid'] 		= md5(microtime()); //id univoco
		$INDI_JOBS[$key]['site'] 	= $GLOBALS['CONF']['sito'];

		$INDI_JOBS[$key]['start_time'] 	= time();
		$INDI_JOBS[$key]['start_timeout'] 	= $timeout;
		$INDI_JOBS[$key]['start_url'] 	= indi_get_url();
		unset($INDI_JOBS[$key]['result']);
		unset($INDI_JOBS[$key]['log']);
		apc_store("INDI_JOBS",$INDI_JOBS);
		indi_job_log($status,$key);
		return true;
	} else {
		
			indi_job_log("Errore indi_job_start, JOB già in esecuzione!",$key);
			return false;
	}

}

//metto in stop e non puo' ripartire
function indi_job_stop($key=NULL) {
	if(!$key) $key =  $GLOBALS['CONF']['sito'];
	if(!$key) return false;

	$INDI_JOBS = apc_fetch("INDI_JOBS");
	if(isset($INDI_JOBS[$key])) {
			$INDI_JOBS[$key]['status']	= 'stopped'; //se è stoppato non puo ripartire
			apc_store("INDI_JOBS",$INDI_JOBS);
			indi_job_log("stopped",$key);
	} else {
		return false;
	}
}

function indi_job_finish($result=NULL,$key=NULL) {
	if(!$key) $key =  $GLOBALS['CONF']['sito'];
	if(!$key) return false;
	
	$INDI_JOBS = apc_fetch("INDI_JOBS");
	
	if($INDI_JOBS[$key]['status'] == "confirm_timeout") {
		
		indi_job_log("NON DEVE SUCCEDERE",$key);
	}
	
	if(isset($INDI_JOBS[$key])) {
			//lo cancello
			//unset($INDI_JOBS[$key]);
			//aggiorno
			$INDI_JOBS[$key]['status']	= 'finish';
			$INDI_JOBS[$key]['end_time']	= time();
			$INDI_JOBS[$key]['total_time']	= $INDI_JOBS[$key]['end_time'] - $INDI_JOBS[$key]['start_time'];
			
			if($result) $INDI_JOBS[$key]['result']	= $result;
			apc_store("INDI_JOBS",$INDI_JOBS);
			
			indi_job_log("finished",$key);
	} else {
		return false;
	}
	
}

//rimuove il job 
function indi_job_remove($key=NULL) {
	if(!$key) $key =  $GLOBALS['CONF']['sito'];
	if(!$key) return false;
	$INDI_JOBS = apc_fetch("INDI_JOBS");
	if(isset($INDI_JOBS[$key])) {
			unset($INDI_JOBS[$key]);
			apc_store("INDI_JOBS",$INDI_JOBS);
			indi_log("JOBS($key):removed");
	} else {
		return false;
	}
	
}




//aggiungo o sovrascrivo una variabile al job
function indi_job_var($k,$v,$key=NULL) {
	if(!$key) $key =  $GLOBALS['CONF']['sito'];
	if(!$key) return false;
	$INDI_JOBS = apc_fetch("INDI_JOBS");
	//imposto chiave
	$INDI_JOBS[$key][$k]	=	$v;
	apc_store("INDI_JOBS",$INDI_JOBS);
	
}

function indi_job_get_var($k,$key=NULL) {
	if(!$key) $key =  $GLOBALS['CONF']['sito'];
	if(!$key) return false;
	$INDI_JOBS = apc_fetch("INDI_JOBS");
	//imposto chiave
	return $INDI_JOBS[$key][$k];

}


function indi_job_log($log,$key=NULL) {
	if(!$key) $key =  $GLOBALS['CONF']['sito'];
	if(!$key) return false;
	$INDI_JOBS = apc_fetch("INDI_JOBS");
	if(isset($INDI_JOBS[$key])) {
			$INDI_JOBS[$key]['log'][] = date("Y-m-d g:i:s")." - ".$log;
			apc_store("INDI_JOBS",$INDI_JOBS);
			indi_log("JOBS($key): $log (".$INDI_JOBS[$key]['name'].")");
	} else {
		return false;
	}

}
function indi_job_error($errore=NULL,$key=NULL,$status="error") {
	if(!$key) $key =  $GLOBALS['CONF']['sito'];
	if(!$key) return false;

	$INDI_JOBS = apc_fetch("INDI_JOBS");
	if(isset($INDI_JOBS[$key])) {
			$INDI_JOBS[$key]['status']	= $status;
			apc_store("INDI_JOBS",$INDI_JOBS);
			if($errore) {
				indi_job_log($errore,$key);
				d_err($errore." key($key)");
				
			}
	} else {
		return false;
	}
}



function indi_job_get_all() {
	return apc_fetch("INDI_JOBS"); //variabile globale dove salvo tutti i jpb
}



//non usata 
function indi_job_get_key() {
	$INDI_JOBS =  apc_fetch("INDI_JOBS");
	if(!$INDI_JOBS) return NULL;
	foreach($INDI_JOBS as $k => $v) {
		$key[]	=	$k;
	}
	return $key;
}




//funzioni per eseguire un processo lungo da eseguire senza timeout
//start_confirm_timeout = N (secondi)
//Controlla e aspetta la conferma che il job  parte entro N secondi viene impostato nello stato

function indi_job_start_bg($pagina=NULL,$key=NULL,$start_confirm=TRUE,$start_confirm_timeout=5) {
	
	//if(!$key) $key =  md5($GLOBALS['CONF']['sito']."-".$pagina);
	$time	=	0;
	$c = 0;
	
	if($pagina != NULL) {
	
		
		//start con conferma
		if($start_confirm and $start_confirm_timeout) {
			
			//pare in modalita start confirm
			$ret = indi_job_start($pagina,$key,"start_confirm");
			
			
		} else {
			//start senza conferma
			$ret = indi_job_start($pagina,$key);
		}
		
		if($ret) {

			
			//faccio partire il lavoro
			$URL	=	parse_url($pagina);
			
			$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
			
			if($socket) {
				//socket_set_nonblock($socket);
				
				socket_connect($socket, $URL['host'], 80);
				socket_set_nonblock($socket);
				$output .=  'GET '.$URL['path'].(isset($URL['query']) ? '?'.$URL['query']."&job=$key&job_uid=".indi_job_get_var("uid",$key) : '?job=$key&job_uid=".indi_job_get_var(')." HTTP/1.1\r\n";
				$output .=  'Host: '.$URL['host']."\r\n";;
				$output .=  'Connection: Close'."\r\n\r\n";
				
				$write = socket_write($socket, $output, strlen($output) );
				
				socket_set_block($socket);
				//$data = socket_read($socket, 4096) ;
				socket_close($socket);
						
				
				if($write) {
							
							if($start_confirm and $start_confirm_timeout) {

							  //da rivedere non è preciso perche' il controllo rallenta il ciclo
							 while($time < $start_confirm_timeout and $c < $start_confirm_timeout/0.2) {
							  	  $c++;
								  usleep(1000000/5); //due decimi di secondo
								  $time	=	$time+0.2;
								//  indi_job_log("$time ".$start_confirm_timeout/0.2);
								  //controllo quando va in running
								  indi_job_log("Bg. Confirm attempt N. $c - ".time());
								  
								  if(indi_job_get_var("status",$key) == "running") {
									  indi_job_log("Bg. Confirmed");
									  return TRUE;
								  }
							}  
								 
						     indi_job_error("Timeout attesa di conferma",$key,"confirm_timeout");
							 
							 return FALSE;
							
							} else {
								
								return TRUE;
								
							}
	
				} else {
						indi_job_finish("Errore 'socket_write'url($pagina)",$key);
						//indi_job_log("Errore apertura socket url: '$paagina'",$key);
						
						return FALSE;	
						
				}
			} else {
				
				indi_job_finish("Errore 'socket_connect' url($pagina)",$key);
				return FALSE;
			
			}
			
			
		} else {
				//l' errore è gestito da indi_job_start

		}
	
	
	} else {
		indi_job_log("Errore, url non presente!",$key);
		
	}
	return $ret;
}



?>