patrickpr / trapdirector

bin/trap_class.php

Indentation +575 added lines, -575 removed lines

@@ -88,24 +88,24 @@ 
 	 */
 	protected function getOptionIfSet($option_array,$option_category,$option_name, &$option_var, $log_level = 2, $message = null)
 	{
-	    if (!isset($option_array[$option_category][$option_name]))
-	    {
-	        if ($message === null)
-	        {
-	            $message='No ' . $option_name . ' in config file: '. $this->trap_module_config;
-	        }
-	        $this->trapLog($message,$log_level,'syslog');
-	        return false;
-	    }
-	    else
-	    {
-	        $option_var=$option_array[$option_category][$option_name];
-	        return true;
-	    }
+		if (!isset($option_array[$option_category][$option_name]))
+		{
+			if ($message === null)
+			{
+				$message='No ' . $option_name . ' in config file: '. $this->trap_module_config;
+			}
+			$this->trapLog($message,$log_level,'syslog');
+			return false;
+		}
+		else
+		{
+			$option_var=$option_array[$option_category][$option_name];
+			return true;
+		}
 	}
 	
 	/** Get options from ini file and database
-	*/
+	 */
 	protected function getOptions()
 	{
 		$trap_config=parse_ini_file($this->trap_module_config,true);
@@ -128,10 +128,10 @@ 
 		// API options
 		if ($this->getOptionIfSet($trap_config,'config','icingaAPI_host', $this->api_hostname))
 		{
-		    $this->api_use=true;
-		    $this->getOptionIfSet($trap_config,'config','icingaAPI_port', $this->api_port);
-		    $this->getOptionIfSet($trap_config,'config','icingaAPI_user', $this->api_username);
-		    $this->getOptionIfSet($trap_config,'config','icingaAPI_password', $this->api_password);
+			$this->api_use=true;
+			$this->getOptionIfSet($trap_config,'config','icingaAPI_port', $this->api_port);
+			$this->getOptionIfSet($trap_config,'config','icingaAPI_user', $this->api_username);
+			$this->getOptionIfSet($trap_config,'config','icingaAPI_password', $this->api_password);
 		}
 				
 		/***** Database options :  ***/
@@ -148,9 +148,9 @@ 
 	}
 	
 	/** Get data from db_config
-	*	@param $element string name of param
-	*	@return mixed : value (or null)
-	*/	
+	 *	@param $element string name of param
+	 *	@return mixed : value (or null)
+	 */	
 	protected function getDBConfig($element)
 	{
 		$db_conn=$this->db_connect_trap();
@@ -168,11 +168,11 @@ 
 	}
 	
 	/** Send log. Throws exception on critical error
-	*	@param	string $message Message to log
-	*	@param	int $level 1=critical 2=warning 3=trace 4=debug
-	*	@param  string $destination file/syslog/display
-	*	@return void
-	**/	
+	 *	@param	string $message Message to log
+	 *	@param	int $level 1=critical 2=warning 3=trace 4=debug
+	 *	@param  string $destination file/syslog/display
+	 *	@return void
+	 **/	
 	public function trapLog( $message, $level, $destination ='')
 	{	
 		if ($this->debug_level >= $level) 
@@ -217,7 +217,7 @@ 
 		switch ($output_type)
 		{
 			case 'file':
-			    if ($output_option == null) throw new Exception("File logging without file !");
+				if ($output_option == null) throw new Exception("File logging without file !");
 				$this->debug_file=$output_option;
 				$this->alert_output='file';
 				break;
@@ -234,30 +234,30 @@ 
 	
 	protected function getAPI()
 	{
-	    if ($this->icinga2api == null)
-	    {
-	        $this->icinga2api = new Icinga2API($this->api_hostname,$this->api_port);
-	    }
-	    return $this->icinga2api;
+		if ($this->icinga2api == null)
+		{
+			$this->icinga2api = new Icinga2API($this->api_hostname,$this->api_port);
+		}
+		return $this->icinga2api;
 	}
 
 	/** Connects to trapdb 
-	*	@return mixed : PDO connection or null
-	*/
+	 *	@return mixed : PDO connection or null
+	 */
 	public function db_connect_trap() 
 	{
 		if ($this->trapDB != null) {
-		    // Check if connection is still alive
-		    try {
-		        $this->trapDB->query('select 1')->fetchColumn();
-		        return $this->trapDB;
-		    } catch (Exception $e) {
-		        // select 1 failed, try to reconnect.
-		        $this->trapDB=null;
+			// Check if connection is still alive
+			try {
+				$this->trapDB->query('select 1')->fetchColumn();
+				return $this->trapDB;
+			} catch (Exception $e) {
+				// select 1 failed, try to reconnect.
+				$this->trapDB=null;
 				$this->trapDB=$this->db_connect('traps');
-		        $this->trapLog('Database connection lost, reconnecting',WARN,'');
+				$this->trapLog('Database connection lost, reconnecting',WARN,'');
 				return $this->trapDB;
-		    }
+			}
 		     
 		}
 		$this->trapDB=$this->db_connect('traps');
@@ -266,8 +266,8 @@ 
 	
 
 	/** Connects to idodb 
-	*	@return PDO connection
-	*/
+	 *	@return PDO connection
+	 */
 	public function db_connect_ido() 
 	{
 		if ($this->idoDB != null) { return $this->idoDB; }
@@ -276,9 +276,9 @@ 
 	}	
 	
 	/** connects to database named by parameter
-	*	@param string $database : 'traps' for traps database, 'ido' for ido database
-	*	@return PDO connection
-	**/
+	 *	@param string $database : 'traps' for traps database, 'ido' for ido database
+	 *	@return PDO connection
+	 **/
 	protected function db_connect($database) {
 		$confarray=$this->get_database($database);
 		//	$dsn = 'mysql:dbname=traps;host=127.0.0.1';
@@ -295,9 +295,9 @@ 
 	}
 
 	/** Get database connexion options
-	*	@param string $database : 'traps' for traps database, 'ido' for ido database
-	*	@return mixed : null or array( DB type (mysql, pgsql.) , db_host, database name , db_user, db_pass)
-	**/
+	 *	@param string $database : 'traps' for traps database, 'ido' for ido database
+	 *	@return mixed : null or array( DB type (mysql, pgsql.) , db_host, database name , db_user, db_pass)
+	 **/
 	protected function get_database($database) {
 
 		$trap_config=parse_ini_file($this->trap_module_config,true);
@@ -349,9 +349,9 @@ 
 	}	
 	
 	/** read data from stream
-	*	@param $stream string input stream, defaults to "php://stdin"
-	*	@return mixed array trap data or exception with error
-	*/
+	 *	@param $stream string input stream, defaults to "php://stdin"
+	 *	@return mixed array trap data or exception with error
+	 */
 	public function read_trap($stream='php://stdin')
 	{
 		//Read data from snmptrapd from stdin
@@ -359,7 +359,7 @@ 
 
 		if ($input_stream === false)
 		{
-		    $this->writeTrapErrorToDB("Error reading trap (code 1/Stdin)");
+			$this->writeTrapErrorToDB("Error reading trap (code 1/Stdin)");
 			$this->trapLog("Error reading stdin !",ERROR,'');
 			return null; // note : exception thrown by traplog
 		}
@@ -368,21 +368,21 @@ 
 		$this->receivingHost=chop(fgets($input_stream));
 		if ($this->receivingHost === false)
 		{
-		    $this->writeTrapErrorToDB("Error reading trap (code 1/Line Host)");
+			$this->writeTrapErrorToDB("Error reading trap (code 1/Line Host)");
 			$this->trapLog("Error reading Host !",ERROR,''); 
 		}
 		// line 2 IP:port=>IP:port
 		$IP=chop(fgets($input_stream));
 		if ($IP === false)
 		{
-		    $this->writeTrapErrorToDB("Error reading trap (code 1/Line IP)");
+			$this->writeTrapErrorToDB("Error reading trap (code 1/Line IP)");
 			$this->trapLog("Error reading IP !",ERROR,''); 
 		}
 		$matches=array();
 		$ret_code=preg_match('/.DP: \[(.*)\]:(.*)->\[(.*)\]:(.*)/',$IP,$matches);
 		if ($ret_code===0 || $ret_code===false) 
 		{
-		    $this->writeTrapErrorToDB("Error parsing trap (code 2/IP)");
+			$this->writeTrapErrorToDB("Error parsing trap (code 2/IP)");
 			$this->trapLog('Error parsing IP : '.$IP,ERROR,'');
 		} 
 		else 
@@ -403,7 +403,7 @@ 
 			}
 			else 
 			{
-			    if (($matches[1]=='.1.3.6.1.6.3.1.1.4.1.0') || ($matches[1]=='.1.3.6.1.6.3.1.1.4.1'))
+				if (($matches[1]=='.1.3.6.1.6.3.1.1.4.1.0') || ($matches[1]=='.1.3.6.1.6.3.1.1.4.1'))
 				{
 					$this->trap_data['trap_oid']=$matches[2];				
 				}
@@ -419,7 +419,7 @@ 
 
 		if ($this->trap_data['trap_oid']=='unknown') 
 		{
-		    $this->writeTrapErrorToDB("No trap oid found : check snmptrapd configuration (code 3/OID)",$this->trap_data['source_ip']);
+			$this->writeTrapErrorToDB("No trap oid found : check snmptrapd configuration (code 3/OID)",$this->trap_data['source_ip']);
 			$this->trapLog('no trap oid found',ERROR,'');
 		} 
 
@@ -448,9 +448,9 @@ 
 	}
 
 	/** Translate oid into array(MIB,Name)
-	* @param $oid string oid to translate
-	* @return mixed : null if not found or array(MIB,Name)
-	*/
+	 * @param $oid string oid to translate
+	 * @return mixed : null if not found or array(MIB,Name)
+	 */
 	public function translateOID($oid)
 	{
 		// try from database
@@ -483,7 +483,7 @@ 
 		
 		// Try to get oid name from snmptranslate
 		$translate=exec($this->snmptranslate . ' -m ALL -M +'.$this->snmptranslate_dirs.
-		    ' '.$oid);
+			' '.$oid);
 		$matches=array();
 		$ret_code=preg_match('/(.*)::(.*)/',$translate,$matches);
 		if ($ret_code===0 || $ret_code === false) {
@@ -495,9 +495,9 @@ 
 	}
 	
 	/** Erase old trap records 
-	*	@param integer $days : erase traps when more than $days old
-	*	@return integer : number of lines deleted
-	**/
+	 *	@param integer $days : erase traps when more than $days old
+	 *	@return integer : number of lines deleted
+	 **/
 	public function eraseOldTraps($days=0)
 	{
 		if ($days==0)
@@ -522,72 +522,72 @@ 
 	public function writeTrapErrorToDB($message,$sourceIP=null,$trapoid=null)
 	{
 	    
-	    $db_conn=$this->db_connect_trap();
+		$db_conn=$this->db_connect_trap();
 	    
-	    // add date time
-	    $insert_col ='date_received,status';
-	    $insert_val = "'" . date("Y-m-d H:i:s")."','error'";
+		// add date time
+		$insert_col ='date_received,status';
+		$insert_val = "'" . date("Y-m-d H:i:s")."','error'";
         
-	    if ($sourceIP !=null)
-	    {
-	        $insert_col .=',source_ip';
-	        $insert_val .=",'". $sourceIP ."'";
-	    }
-	    if ($trapoid !=null)
-	    {
-	        $insert_col .=',trap_oid';
-	        $insert_val .=",'". $trapoid ."'";
-	    }
-	    $insert_col .=',status_detail';
-	    $insert_val .=",'". $message ."'";
+		if ($sourceIP !=null)
+		{
+			$insert_col .=',source_ip';
+			$insert_val .=",'". $sourceIP ."'";
+		}
+		if ($trapoid !=null)
+		{
+			$insert_col .=',trap_oid';
+			$insert_val .=",'". $trapoid ."'";
+		}
+		$insert_col .=',status_detail';
+		$insert_val .=",'". $message ."'";
 	    
-	    $sql= 'INSERT INTO '.$this->db_prefix.'received (' . $insert_col . ') VALUES ('.$insert_val.')';
+		$sql= 'INSERT INTO '.$this->db_prefix.'received (' . $insert_col . ') VALUES ('.$insert_val.')';
 	    
-	    switch ($this->trapDBType)
-	    {
-	        case 'pgsql':
-	            $sql .= ' RETURNING id;';
-	            $this->trapLog('sql : '.$sql,INFO);
-	            if (($ret_code=$db_conn->query($sql)) === false) {
-	                $this->trapLog('Error SQL insert : '.$sql,1,'');
-	            }
-	            $this->trapLog('SQL insertion OK',INFO );
-	            // Get last id to insert oid/values in secondary table
-	            if (($inserted_id_ret=$ret_code->fetch(PDO::FETCH_ASSOC)) === false) {
+		switch ($this->trapDBType)
+		{
+			case 'pgsql':
+				$sql .= ' RETURNING id;';
+				$this->trapLog('sql : '.$sql,INFO);
+				if (($ret_code=$db_conn->query($sql)) === false) {
+					$this->trapLog('Error SQL insert : '.$sql,1,'');
+				}
+				$this->trapLog('SQL insertion OK',INFO );
+				// Get last id to insert oid/values in secondary table
+				if (($inserted_id_ret=$ret_code->fetch(PDO::FETCH_ASSOC)) === false) {
 	                
-	                $this->trapLog('Erreur recuperation id',1,'');
-	            }
-	            if (! isset($inserted_id_ret['id'])) {
-	                $this->trapLog('Error getting id',1,'');
-	            }
-	            $this->trap_id=$inserted_id_ret['id'];
-	            break;
-	        case 'mysql':
-	            $sql .= ';';
-	            $this->trapLog('sql : '.$sql,INFO );
-	            if ($db_conn->query($sql) === false) {
-	                $this->trapLog('Error SQL insert : '.$sql,1,'');
-	            }
-	            $this->trapLog('SQL insertion OK',INFO );
-	            // Get last id to insert oid/values in secondary table
-	            $sql='SELECT LAST_INSERT_ID();';
-	            if (($ret_code=$db_conn->query($sql)) === false) {
-	                $this->trapLog('Erreur recuperation id',1,'');
-	            }
+					$this->trapLog('Erreur recuperation id',1,'');
+				}
+				if (! isset($inserted_id_ret['id'])) {
+					$this->trapLog('Error getting id',1,'');
+				}
+				$this->trap_id=$inserted_id_ret['id'];
+				break;
+			case 'mysql':
+				$sql .= ';';
+				$this->trapLog('sql : '.$sql,INFO );
+				if ($db_conn->query($sql) === false) {
+					$this->trapLog('Error SQL insert : '.$sql,1,'');
+				}
+				$this->trapLog('SQL insertion OK',INFO );
+				// Get last id to insert oid/values in secondary table
+				$sql='SELECT LAST_INSERT_ID();';
+				if (($ret_code=$db_conn->query($sql)) === false) {
+					$this->trapLog('Erreur recuperation id',1,'');
+				}
 	            
-	            $inserted_id=$ret_code->fetch(PDO::FETCH_ASSOC)['LAST_INSERT_ID()'];
-	            if ($inserted_id==false) throw new Exception("Weird SQL error : last_insert_id returned false : open issue");
-	            $this->trap_id=$inserted_id;
-	            break;
-	        default:
-	            $this->trapLog('Error SQL type  : '.$this->trapDBType,1,'');
-	    }
+				$inserted_id=$ret_code->fetch(PDO::FETCH_ASSOC)['LAST_INSERT_ID()'];
+				if ($inserted_id==false) throw new Exception("Weird SQL error : last_insert_id returned false : open issue");
+				$this->trap_id=$inserted_id;
+				break;
+			default:
+				$this->trapLog('Error SQL type  : '.$this->trapDBType,1,'');
+		}
 	    
-	    $this->trapLog('id found: '. $this->trap_id,INFO );    
+		$this->trapLog('id found: '. $this->trap_id,INFO );    
 	}
 	
 	/** Write trap data to trap database
-	*/
+	 */
 	public function writeTrapToDB()
 	{
 		
@@ -685,10 +685,10 @@ 
 	}
 
 	/** Get rules from rule database with ip and oid
-	*	@param $ip string ipv4 or ipv6
-	*	@param $oid string oid in numeric
-	*	@return mixed : PDO object or false
-	*/	
+	 *	@param $ip string ipv4 or ipv6
+	 *	@param $oid string oid in numeric
+	 *	@return mixed : PDO object or false
+	 */	
 	protected function getRules($ip,$oid)
 	{
 		$db_conn=$this->db_connect_trap();
@@ -747,9 +747,9 @@ 
 	}
 
 	/** Add rule match to rule
-	*	@param id int : rule id
-	*   @param set int : value to set
-	*/
+	 *	@param id int : rule id
+	 *   @param set int : value to set
+	 */
 	protected function add_rule_match($id, $set)
 	{
 		$db_conn=$this->db_connect_trap();
@@ -766,53 +766,53 @@ 
 	 * @param integer $state numerical staus 
 	 * @param string $display
 	 * @returnn bool true is service check was sent without error
-	*/
+	 */
 	public function serviceCheckResult($host,$service,$state,$display)
 	{
-	    if ($this->api_use === false)
-	    {
-    		$send = '[' . date('U') .'] PROCESS_SERVICE_CHECK_RESULT;' .
-    			$host.';' .$service .';' . $state . ';'.$display;
-    		$this->trapLog( $send." : to : " .$this->icinga2cmd,INFO );
+		if ($this->api_use === false)
+		{
+			$send = '[' . date('U') .'] PROCESS_SERVICE_CHECK_RESULT;' .
+				$host.';' .$service .';' . $state . ';'.$display;
+			$this->trapLog( $send." : to : " .$this->icinga2cmd,INFO );
     		
-    		// TODO : file_put_contents & fopen (,'w' or 'a') does not work. See why. Or not as using API will be by default....
-    		exec('echo "'.$send.'" > ' .$this->icinga2cmd);
-    		return true;
-	    }
-	    else
-	    {
-	        $api = $this->getAPI();
-	        $api->setCredentials($this->api_username, $this->api_password);
-	        list($retcode,$retmessage)=$api->serviceCheckResult($host,$service,$state,$display);
-	        if ($retcode == false)
-	        {
-	            $this->trapLog( "Error sending result : " .$retmessage,WARN,'');
-	            return false;
-	        }
-	        else 
-	        {
-	            $this->trapLog( "Sent result : " .$retmessage,INFO );
-	            return true;
-	        }
-	    }
+			// TODO : file_put_contents & fopen (,'w' or 'a') does not work. See why. Or not as using API will be by default....
+			exec('echo "'.$send.'" > ' .$this->icinga2cmd);
+			return true;
+		}
+		else
+		{
+			$api = $this->getAPI();
+			$api->setCredentials($this->api_username, $this->api_password);
+			list($retcode,$retmessage)=$api->serviceCheckResult($host,$service,$state,$display);
+			if ($retcode == false)
+			{
+				$this->trapLog( "Error sending result : " .$retmessage,WARN,'');
+				return false;
+			}
+			else 
+			{
+				$this->trapLog( "Sent result : " .$retmessage,INFO );
+				return true;
+			}
+		}
 	}
 	
 	public function getHostByIP($ip)
 	{
-	    $api = $this->getAPI();
-	    $api->setCredentials($this->api_username, $this->api_password);
-	    return $api->getHostByIP($ip);
+		$api = $this->getAPI();
+		$api->setCredentials($this->api_username, $this->api_password);
+		return $api->getHostByIP($ip);
 	}
 	
 	/** Resolve display. 
-	*	Changes OID(<oid>) to value if found or text "<not in trap>"
-	*	@param $display string
-	*	@return string display
-	*/
+	 *	Changes OID(<oid>) to value if found or text "<not in trap>"
+	 *	@param $display string
+	 *	@return string display
+	 */
 	protected function applyDisplay($display)
 	{
-	    $matches=array();
-	    while (preg_match('/_OID\(([0-9\.]+)\)/',$display,$matches) == 1)
+		$matches=array();
+		while (preg_match('/_OID\(([0-9\.]+)\)/',$display,$matches) == 1)
 		{
 			$oid=$matches[1];
 			$found=0;
@@ -872,11 +872,11 @@ 
 		
 		if ($rule[$item] == '(')
 		{ // grouping
-		    $item++;
+			$item++;
 			$start=$item;
 			$parenthesis_count=0; 
 			while (($item < strlen($rule)) // Not end of string AND
-			      && ( ($rule[$item] != ')' ) || $parenthesis_count > 0) ) // Closing ')' or embeded ()
+				  && ( ($rule[$item] != ')' ) || $parenthesis_count > 0) ) // Closing ')' or embeded ()
 			{ 
 				if ($rule[$item] == '"' )
 				{ // pass through string
@@ -884,14 +884,14 @@ 
 					$item=$this->eval_getNext($rule,$item,'"');
 				} 
 				else{
-				    if ($rule[$item] == '(')
-				    {
-				        $parenthesis_count++;
-				    }
-				    if ($rule[$item] == ')')
-				    {
-				        $parenthesis_count--;
-				    }
+					if ($rule[$item] == '(')
+					{
+						$parenthesis_count++;
+					}
+					if ($rule[$item] == ')')
+					{
+						$parenthesis_count--;
+					}
 					$item++;
 				}
 			}
@@ -943,24 +943,24 @@ 
 	}
 	
 	/** Evaluation : makes token and evaluate. 
-	*	Public function for expressions testing
-	*	accepts : < > = <= >= !=  (typec = 0)
-	*	operators : & | (typec=1)
-	*	with : integers/float  (type 0) or strings "" (type 1) or results (type 2)
-	*   comparison int vs strings will return null (error)
-	*	return : bool or null on error
-	*/
+	 *	Public function for expressions testing
+	 *	accepts : < > = <= >= !=  (typec = 0)
+	 *	operators : & | (typec=1)
+	 *	with : integers/float  (type 0) or strings "" (type 1) or results (type 2)
+	 *   comparison int vs strings will return null (error)
+	 *	return : bool or null on error
+	 */
 	public function evaluation($rule,&$item)
 	{
-	    //echo "Evaluation of ".substr($rule,$item)."\n";
+		//echo "Evaluation of ".substr($rule,$item)."\n";
 		if ( $rule[$item] == '!') // If '!' found, negate next expression.
 		{
-		    $negate=true;
-		    $item++;
+			$negate=true;
+			$item++;
 		}
 		else
 		{
-		    $negate=false;
+			$negate=false;
 		}
 		// First element : number, string or ()
 		list($type1,$val1) = $this->eval_getElement($rule,$item);
@@ -980,24 +980,24 @@ 
 		// Third element : number, string or ()
 		if ( $rule[$item] == '!') // starts with a ! so evaluate whats next
 		{
-		    $item++;
-		    if ($typec != 1) throw new Exception("Mixing boolean and comparison : ".$rule);
-		    $val2= ! $this->evaluation($rule,$item);
-		    $type2=2; // result is a boolean 
+			$item++;
+			if ($typec != 1) throw new Exception("Mixing boolean and comparison : ".$rule);
+			$val2= ! $this->evaluation($rule,$item);
+			$type2=2; // result is a boolean 
 		}
 		else 
 		{
-		    list($type2,$val2) = $this->eval_getElement($rule,$item);
+			list($type2,$val2) = $this->eval_getElement($rule,$item);
 		}
 		//echo "Elmt2: ".$val2."/".$type2." : ".substr($rule,$item)."\n";
 		
 		if ($type1!=$type2)  // cannot compare different types
 		{ 
-		    throw new Exception("Cannot compare string & number : ".$rule);
+			throw new Exception("Cannot compare string & number : ".$rule);
 		}
 		if ($typec==1 && $type1 !=2) // cannot use & or | with string/number
 		{
-		    throw new Exception("Cannot use boolean operators with string & number : ".$rule);
+			throw new Exception("Cannot use boolean operators with string & number : ".$rule);
 		}
 		
 		switch ($comp){
@@ -1055,9 +1055,9 @@ 
 	}		
 	
 	/** Evaluation rule (uses eval_* functions recursively)
-	*	@param $rule string rule ( _OID(.1.3.6.1.4.1.8072.2.3.2.1)=_OID(.1.3.6.1.2.1.1.3.0) )
-	*	@return bool : true : rule match, false : rule don't match , throw exception on error.
-	*/
+	 *	@param $rule string rule ( _OID(.1.3.6.1.4.1.8072.2.3.2.1)=_OID(.1.3.6.1.2.1.1.3.0) )
+	 *	@return bool : true : rule match, false : rule don't match , throw exception on error.
+	 */
 	
 	protected function eval_rule($rule)
 	{
@@ -1102,7 +1102,7 @@ 
 			}
 			if ($found==0)
 			{	// OID not found : throw error
-			    throw new Exception('OID '.$oid.' not found in trap');
+				throw new Exception('OID '.$oid.' not found in trap');
 			}
 		}
 		$item=0;
@@ -1113,7 +1113,7 @@ 
 	}
 	
 	/** Match rules for current trap and do action
-	*/
+	 */
 	public function applyRules()
 	{
 		$rules = $this->getRules($this->trap_data['source_ip'],$this->trap_data['trap_oid']);
@@ -1150,12 +1150,12 @@ 
 					{
 						if ($this->serviceCheckResult($host_name,$service_name,$action,$display) == false)
 						{
-						    $this->trap_action.='Error sending status : check cmd/API';
+							$this->trap_action.='Error sending status : check cmd/API';
 						}
 						else
 						{
-						    $this->add_rule_match($rule['id'],$rule['num_match']+1);
-						    $this->trap_action.='Status '.$action.' to '.$host_name.'/'.$service_name;
+							$this->add_rule_match($rule['id'],$rule['num_match']+1);
+							$this->trap_action.='Status '.$action.' to '.$host_name.'/'.$service_name;
 						}
 					}
 					else
@@ -1172,15 +1172,15 @@ 
 					$this->trapLog('action NOK : '.$action,INFO );
 					if ($action >= 0)
 					{
-					    if ($this->serviceCheckResult($host_name,$service_name,$action,$display)==false)
-					    {
-					        $this->trap_action.='Error sending status : check cmd/API';
-					    }
-					    else
-					    {
-    						$this->add_rule_match($rule['id'],$rule['num_match']+1);
-    						$this->trap_action.='Status '.$action.' to '.$host_name.'/'.$service_name;
-					    }
+						if ($this->serviceCheckResult($host_name,$service_name,$action,$display)==false)
+						{
+							$this->trap_action.='Error sending status : check cmd/API';
+						}
+						else
+						{
+							$this->add_rule_match($rule['id'],$rule['num_match']+1);
+							$this->trap_action.='Status '.$action.' to '.$host_name.'/'.$service_name;
+						}
 					}
 					else
 					{
@@ -1203,9 +1203,9 @@ 
 			}
 			catch (Exception $e) 
 			{ 
-			    $this->trapLog('Error in rule eval : '.$e->getMessage(),WARN,'');
-			    $this->trap_action.=' ERR : '.$e->getMessage();
-			    $this->trap_data['status']='error';
+				$this->trapLog('Error in rule eval : '.$e->getMessage(),WARN,'');
+				$this->trap_action.=' ERR : '.$e->getMessage();
+				$this->trap_data['status']='error';
 			}
 			
 		}
@@ -1220,8 +1220,8 @@ 
 	}
 
 	/** Add Time a action to rule
-	*	@param string $time : time to process to insert in SQL
-	*/
+	 *	@param string $time : time to process to insert in SQL
+	 */
 	public function add_rule_final($time)
 	{
 		$db_conn=$this->db_connect_trap();
@@ -1238,9 +1238,9 @@ 
 	/*********** UTILITIES *********************/
 	
 	/** Create database schema 
-	*	@param $schema_file	string File to read schema from
-	*	@param $table_prefix string to replace #PREFIX# in schema file by this
-	*/
+	 *	@param $schema_file	string File to read schema from
+	 *	@param $table_prefix string to replace #PREFIX# in schema file by this
+	 */
 	public function create_schema($schema_file,$table_prefix)
 	{
 		//Read data from snmptrapd from stdin
@@ -1260,30 +1260,30 @@ 
 		{
 			$newline.=chop(preg_replace('/#PREFIX#/',$table_prefix,$line));
 			if (preg_match('/; *$/', $newline)) 
-            {
-                $sql= $newline;
-                if ($db_conn->query($sql) === false) {
-                    $this->trapLog('Error create schema : '.$sql,ERROR,'');
-                }
-                if (preg_match('/^ *CREATE TABLE ([^ ]+)/',$newline,$cur_table_array))
-                {
-                    $cur_table='table '.$cur_table_array[1];
-                }
-                else
-                {
-                    $cur_table='secret SQL stuff :-)';
-                }
-                $this->trapLog('Creating : ' . $cur_table,INFO );
-                $newline='';
-            }
+			{
+				$sql= $newline;
+				if ($db_conn->query($sql) === false) {
+					$this->trapLog('Error create schema : '.$sql,ERROR,'');
+				}
+				if (preg_match('/^ *CREATE TABLE ([^ ]+)/',$newline,$cur_table_array))
+				{
+					$cur_table='table '.$cur_table_array[1];
+				}
+				else
+				{
+					$cur_table='secret SQL stuff :-)';
+				}
+				$this->trapLog('Creating : ' . $cur_table,INFO );
+				$newline='';
+			}
 		}
 		
 		$sql= $newline;
 		if ($sql != '')
 		{
-    		if ($db_conn->query($sql) === false) {
-    			$this->trapLog('Error create schema : '.$sql,ERROR,'');
-    		}
+			if ($db_conn->query($sql) === false) {
+				$this->trapLog('Error create schema : '.$sql,ERROR,'');
+			}
 		}
 		$this->trapLog('Schema created',INFO);		
 	}
@@ -1298,113 +1298,113 @@ 
 	 */
 	public function update_schema($prefix,$target_version,$table_prefix,$getmsg=false)
 	{
-	    // Get current db number
-	    $db_conn=$this->db_connect_trap();
-	    $sql='SELECT id,value from '.$this->db_prefix.'db_config WHERE name=\'db_version\' ';
-	    $this->trapLog('SQL query : '.$sql,DEBUG );
-	    if (($ret_code=$db_conn->query($sql)) === false) {
-	        $this->trapLog('Cannot get db version. Query : ' . $sql,2,'');
-	        return;
-	    }
-	    $version=$ret_code->fetchAll();
-	    $cur_version=$version[0]['value'];
-	    $db_version_id=$version[0]['id'];
+		// Get current db number
+		$db_conn=$this->db_connect_trap();
+		$sql='SELECT id,value from '.$this->db_prefix.'db_config WHERE name=\'db_version\' ';
+		$this->trapLog('SQL query : '.$sql,DEBUG );
+		if (($ret_code=$db_conn->query($sql)) === false) {
+			$this->trapLog('Cannot get db version. Query : ' . $sql,2,'');
+			return;
+		}
+		$version=$ret_code->fetchAll();
+		$cur_version=$version[0]['value'];
+		$db_version_id=$version[0]['id'];
 	    
-	    if ($this->trapDBType == 'pgsql')
-	    {
-	        $prefix .= 'update_pgsql/schema_';
-	    }
-	    else
-	    {
-	        $prefix .= 'update_sql/schema_';
-	    }
-	    //echo "version all :\n";print_r($version);echo " \n $cur_ver \n";
-	    if ($getmsg === true)
-	    {
-	        $message='';
-	        $this->trapLog('getting message for upgrade',DEBUG );
-	        while($cur_version<$target_version)
-	        {
-	            $cur_version++;
-	            $updateFile=$prefix.'v'.($cur_version-1).'_v'.$cur_version.'.sql';
-	            $input_stream=fopen($updateFile, 'r');
-	            if ($input_stream=== false)
-	            {
-	                $this->trapLog("Error reading update file ". $updateFile,2,'');
-	                return;
-	            }
-	            do { $line=fgets($input_stream); }
-	            while ($line !== false && !preg_match('/#MESSAGE/',$line));
-	            if ($line === false)
-	            {
-	                $this->trapLog("No message in file ". $updateFile,2,'');
-	                return;
-	            }
-	            $message .= ($cur_version-1) . '->' . $cur_version. ' : ' . preg_replace('/#MESSAGE : /','',$line)."\n";
-	        }
-	        return $message;
-	    }
-	    while($cur_version<$target_version)
-	    { // tODO : execute pre & post scripts
-	       $cur_version++;
-	       $this->trapLog('Updating to version : ' .$cur_version ,INFO );
-	       $updateFile=$prefix.'v'.($cur_version-1).'_v'.$cur_version.'.sql';
-	       $input_stream=fopen($updateFile, 'r');
-	       if ($input_stream=== false)
-	       {
-	           $this->trapLog("Error reading update file ". $updateFile,2,'');
-	           return;
-	       }
-	       $newline='';
-	       $db_conn=$this->db_connect_trap();
-	       $db_conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
-	       while (($line=fgets($input_stream)) !== false)
-	       {
-	           if (preg_match('/^#/', $line)) continue; // ignore comment lines
-	           $newline.=chop(preg_replace('/#PREFIX#/',$table_prefix,$line));
-	           if (preg_match('/; *$/', $newline))
-	           {
-	               $sql_req=$db_conn->prepare($newline);
-	               if ($sql_req->execute() === false) {
-	                   $this->trapLog('Error create schema : '.$newline,1,'');
-	               }
-	               $cur_table_array=array();
-	               if (preg_match('/^ *([^ ]+) TABLE ([^ ]+)/',$newline,$cur_table_array))
-	               {
-	                   $cur_table=$cur_table_array[1] . ' SQL table '.$cur_table_array[2];
-	               }
-	               else
-	               {
-	                   $cur_table='secret SQL stuff :-)';
-	                   //$cur_table=$newline;
-	               }
-	               $this->trapLog('Doing : ' . $cur_table,INFO );
+		if ($this->trapDBType == 'pgsql')
+		{
+			$prefix .= 'update_pgsql/schema_';
+		}
+		else
+		{
+			$prefix .= 'update_sql/schema_';
+		}
+		//echo "version all :\n";print_r($version);echo " \n $cur_ver \n";
+		if ($getmsg === true)
+		{
+			$message='';
+			$this->trapLog('getting message for upgrade',DEBUG );
+			while($cur_version<$target_version)
+			{
+				$cur_version++;
+				$updateFile=$prefix.'v'.($cur_version-1).'_v'.$cur_version.'.sql';
+				$input_stream=fopen($updateFile, 'r');
+				if ($input_stream=== false)
+				{
+					$this->trapLog("Error reading update file ". $updateFile,2,'');
+					return;
+				}
+				do { $line=fgets($input_stream); }
+				while ($line !== false && !preg_match('/#MESSAGE/',$line));
+				if ($line === false)
+				{
+					$this->trapLog("No message in file ". $updateFile,2,'');
+					return;
+				}
+				$message .= ($cur_version-1) . '->' . $cur_version. ' : ' . preg_replace('/#MESSAGE : /','',$line)."\n";
+			}
+			return $message;
+		}
+		while($cur_version<$target_version)
+		{ // tODO : execute pre & post scripts
+		   $cur_version++;
+		   $this->trapLog('Updating to version : ' .$cur_version ,INFO );
+		   $updateFile=$prefix.'v'.($cur_version-1).'_v'.$cur_version.'.sql';
+		   $input_stream=fopen($updateFile, 'r');
+		   if ($input_stream=== false)
+		   {
+			   $this->trapLog("Error reading update file ". $updateFile,2,'');
+			   return;
+		   }
+		   $newline='';
+		   $db_conn=$this->db_connect_trap();
+		   $db_conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
+		   while (($line=fgets($input_stream)) !== false)
+		   {
+			   if (preg_match('/^#/', $line)) continue; // ignore comment lines
+			   $newline.=chop(preg_replace('/#PREFIX#/',$table_prefix,$line));
+			   if (preg_match('/; *$/', $newline))
+			   {
+				   $sql_req=$db_conn->prepare($newline);
+				   if ($sql_req->execute() === false) {
+					   $this->trapLog('Error create schema : '.$newline,1,'');
+				   }
+				   $cur_table_array=array();
+				   if (preg_match('/^ *([^ ]+) TABLE ([^ ]+)/',$newline,$cur_table_array))
+				   {
+					   $cur_table=$cur_table_array[1] . ' SQL table '.$cur_table_array[2];
+				   }
+				   else
+				   {
+					   $cur_table='secret SQL stuff :-)';
+					   //$cur_table=$newline;
+				   }
+				   $this->trapLog('Doing : ' . $cur_table,INFO );
 	               
-	               $newline='';
-	           }
-	       }
-	       fclose($input_stream);
+				   $newline='';
+			   }
+		   }
+		   fclose($input_stream);
 	       
-	       //$sql= $newline;
-	       //if ($db_conn->query($sql) === false) {
-	       //    $this->trapLog('Error updating schema : '.$sql,1,'');
-	       //}
+		   //$sql= $newline;
+		   //if ($db_conn->query($sql) === false) {
+		   //    $this->trapLog('Error updating schema : '.$sql,1,'');
+		   //}
 	       
-	       $sql='UPDATE '.$this->db_prefix.'db_config SET value='.$cur_version.' WHERE ( id = '.$db_version_id.' )';
-	       $this->trapLog('SQL query : '.$sql,DEBUG );
-	       if ($db_conn->query($sql) === false) {
-	           $this->trapLog('Cannot update db version. Query : ' . $sql,2);
-	           return;
-	       }
+		   $sql='UPDATE '.$this->db_prefix.'db_config SET value='.$cur_version.' WHERE ( id = '.$db_version_id.' )';
+		   $this->trapLog('SQL query : '.$sql,DEBUG );
+		   if ($db_conn->query($sql) === false) {
+			   $this->trapLog('Cannot update db version. Query : ' . $sql,2);
+			   return;
+		   }
 	       
-	       $this->trapLog('Schema updated to version : '.$cur_version ,INFO);
-	    }
+		   $this->trapLog('Schema updated to version : '.$cur_version ,INFO);
+		}
 	}
 	
 	/** reset service to OK after time defined in rule
-	*	TODO logic is : get all service in error + all rules, see if getting all rules then select services is better 
-	*	@return : like a plugin : status code (0->3) <message> | <perfdata>
-	**/
+	 *	TODO logic is : get all service in error + all rules, see if getting all rules then select services is better 
+	 *	@return : like a plugin : status code (0->3) <message> | <perfdata>
+	 **/
 	public function reset_services()
 	{
 		// Get all services not in 'ok' state
@@ -1474,105 +1474,105 @@ 
 		$description=$db_conn->quote($description);
 		if (isset($this->dbOidIndex[$oid]))
 		{
-		    if ($this->dbOidIndex[$oid]['key'] == -1)
-		    { // newly created.
-		        return 0;
-		    }
+			if ($this->dbOidIndex[$oid]['key'] == -1)
+			{ // newly created.
+				return 0;
+			}
 			if ( $name != $this->dbOidAll[$this->dbOidIndex[$oid]['key']]['name'] ||
-			    $mib != $this->dbOidAll[$this->dbOidIndex[$oid]['key']]['mib'] ||
-			    $type != $this->dbOidAll[$this->dbOidIndex[$oid]['key']]['type'] //||
-			    //$textConv != $this->dbOidAll[$this->dbOidIndex[$oid]['key']]['textual_convention'] //||
-			    //$dispHint != $this->dbOidAll[$this->dbOidIndex[$oid]['key']]['display_hint'] ||
-			    //$syntax != $this->dbOidAll[$this->dbOidIndex[$oid]['key']]['syntax'] ||
-			    //$type_enum != $this->dbOidAll[$this->dbOidIndex[$oid]['key']]['type_enum'] ||
-			    //$description != $this->dbOidAll[$this->dbOidIndex[$oid]['key']]['description']
-			    )
+				$mib != $this->dbOidAll[$this->dbOidIndex[$oid]['key']]['mib'] ||
+				$type != $this->dbOidAll[$this->dbOidIndex[$oid]['key']]['type'] //||
+				//$textConv != $this->dbOidAll[$this->dbOidIndex[$oid]['key']]['textual_convention'] //||
+				//$dispHint != $this->dbOidAll[$this->dbOidIndex[$oid]['key']]['display_hint'] ||
+				//$syntax != $this->dbOidAll[$this->dbOidIndex[$oid]['key']]['syntax'] ||
+				//$type_enum != $this->dbOidAll[$this->dbOidIndex[$oid]['key']]['type_enum'] ||
+				//$description != $this->dbOidAll[$this->dbOidIndex[$oid]['key']]['description']
+				)
 			{ // Do update
-			    $sql='UPDATE '.$this->db_prefix.'mib_cache SET '.
- 			    'name = :name , type = :type , mib = :mib , textual_convention = :tc , display_hint = :display_hint'. 
- 			    ', syntax = :syntax, type_enum = :type_enum, description = :description '.
- 			    ' WHERE id= :id';
-			    $sqlQuery=$db_conn->prepare($sql);
+				$sql='UPDATE '.$this->db_prefix.'mib_cache SET '.
+ 				'name = :name , type = :type , mib = :mib , textual_convention = :tc , display_hint = :display_hint'. 
+ 				', syntax = :syntax, type_enum = :type_enum, description = :description '.
+ 				' WHERE id= :id';
+				$sqlQuery=$db_conn->prepare($sql);
 			    
-			    $sqlParam=array(
-			        ':name' => $name,
-			        ':type' => $type, 
-			        ':mib' => $mib, 
-			        ':tc' =>  ($textConv==null)?'null':$textConv , 
-			        ':display_hint' => ($dispHint==null)?'null':$dispHint ,
-			        ':syntax' => ($syntax==null)?'null':$syntax,
-			        ':type_enum' => ($type_enum==null)?'null':$type_enum, 
-			        ':description' => ($description==null)?'null':$description,
-			        ':id' => $this->dbOidAll[$this->dbOidIndex[$oid]['id']]
-			    );
+				$sqlParam=array(
+					':name' => $name,
+					':type' => $type, 
+					':mib' => $mib, 
+					':tc' =>  ($textConv==null)?'null':$textConv , 
+					':display_hint' => ($dispHint==null)?'null':$dispHint ,
+					':syntax' => ($syntax==null)?'null':$syntax,
+					':type_enum' => ($type_enum==null)?'null':$type_enum, 
+					':description' => ($description==null)?'null':$description,
+					':id' => $this->dbOidAll[$this->dbOidIndex[$oid]['id']]
+				);
 			    
-			    if ($sqlQuery->execute($sqlParam) === false) {
-			        $this->trapLog('Error in query : ' . $sql,ERROR,'');
-			    }
-			    $this->trapLog('Trap updated : '.$name . ' / OID : '.$oid,DEBUG );
+				if ($sqlQuery->execute($sqlParam) === false) {
+					$this->trapLog('Error in query : ' . $sql,ERROR,'');
+				}
+				$this->trapLog('Trap updated : '.$name . ' / OID : '.$oid,DEBUG );
 				return 1;
 			}
 			else
 			{
-			    $this->trapLog('Trap unchanged : '.$name . ' / OID : '.$oid,DEBUG );
-			    return 0;
+				$this->trapLog('Trap unchanged : '.$name . ' / OID : '.$oid,DEBUG );
+				return 0;
 			}
 		}
-        // create new OID.
+		// create new OID.
 			
 		// Insert data
 
 		$sql='INSERT INTO '.$this->db_prefix.'mib_cache '.
-		      '(oid, name, type , mib, textual_convention, display_hint '.
-              ', syntax, type_enum , description ) ' . 
-              'values (:oid, :name , :type ,:mib ,:tc , :display_hint'.
-              ', :syntax, :type_enum, :description )';
+			  '(oid, name, type , mib, textual_convention, display_hint '.
+			  ', syntax, type_enum , description ) ' . 
+			  'values (:oid, :name , :type ,:mib ,:tc , :display_hint'.
+			  ', :syntax, :type_enum, :description )';
         
 		if ($this->trapDBType == 'pgsql') $sql .= 'RETURNING id';
 		
 		$sqlQuery=$db_conn->prepare($sql);
 		
 		$sqlParam=array(
-		    ':oid' => $oid,
-		    ':name' => $name,
-		    ':type' => $type,
-		    ':mib' => $mib,
-		    ':tc' =>  ($textConv==null)?'null':$textConv ,
-		    ':display_hint' => ($dispHint==null)?'null':$dispHint ,
-		    ':syntax' => ($syntax==null)?'null':$syntax,
-		    ':type_enum' => ($type_enum==null)?'null':$type_enum,
-		    ':description' => ($description==null)?'null':$description
+			':oid' => $oid,
+			':name' => $name,
+			':type' => $type,
+			':mib' => $mib,
+			':tc' =>  ($textConv==null)?'null':$textConv ,
+			':display_hint' => ($dispHint==null)?'null':$dispHint ,
+			':syntax' => ($syntax==null)?'null':$syntax,
+			':type_enum' => ($type_enum==null)?'null':$type_enum,
+			':description' => ($description==null)?'null':$description
 		);
 		
 		if ($sqlQuery->execute($sqlParam) === false) {
-		    $this->trapLog('Error in query : ' . $sql,1,'');
+			$this->trapLog('Error in query : ' . $sql,1,'');
 		}
 		
 		switch ($this->trapDBType)
 		{
-		    case 'pgsql':
-		        // Get last id to insert oid/values in secondary table
-		        if (($inserted_id_ret=$sqlQuery->fetch(PDO::FETCH_ASSOC)) === false) {		            
-		            $this->trapLog('Error getting id - pgsql - ',1,'');
-		        }
-		        if (! isset($inserted_id_ret['id'])) {
-		            $this->trapLog('Error getting id - pgsql - empty.',1,'');
-		        }
-		        $this->dbOidIndex[$oid]['id']=$inserted_id_ret['id'];
-		        break;
-		    case 'mysql':
-		        // Get last id to insert oid/values in secondary table
-		        $sql='SELECT LAST_INSERT_ID();';
-		        if (($ret_code=$db_conn->query($sql)) === false) {
-		            $this->trapLog('Erreur getting id - mysql - ',1,'');
-		        }
+			case 'pgsql':
+				// Get last id to insert oid/values in secondary table
+				if (($inserted_id_ret=$sqlQuery->fetch(PDO::FETCH_ASSOC)) === false) {		            
+					$this->trapLog('Error getting id - pgsql - ',1,'');
+				}
+				if (! isset($inserted_id_ret['id'])) {
+					$this->trapLog('Error getting id - pgsql - empty.',1,'');
+				}
+				$this->dbOidIndex[$oid]['id']=$inserted_id_ret['id'];
+				break;
+			case 'mysql':
+				// Get last id to insert oid/values in secondary table
+				$sql='SELECT LAST_INSERT_ID();';
+				if (($ret_code=$db_conn->query($sql)) === false) {
+					$this->trapLog('Erreur getting id - mysql - ',1,'');
+				}
 		        
-		        $inserted_id=$ret_code->fetch(PDO::FETCH_ASSOC)['LAST_INSERT_ID()'];
-		        if ($inserted_id==false) throw new Exception("Weird SQL error : last_insert_id returned false : open issue");
-		        $this->dbOidIndex[$oid]['id']=$inserted_id;
-		        break;
-		    default:
-		        $this->trapLog('Error SQL type  : '.$this->trapDBType,1,'');
+				$inserted_id=$ret_code->fetch(PDO::FETCH_ASSOC)['LAST_INSERT_ID()'];
+				if ($inserted_id==false) throw new Exception("Weird SQL error : last_insert_id returned false : open issue");
+				$this->dbOidIndex[$oid]['id']=$inserted_id;
+				break;
+			default:
+				$this->trapLog('Error SQL type  : '.$this->trapDBType,1,'');
 		}
 
 		// Set as newly created.
@@ -1580,148 +1580,148 @@ 
 		return 2;
 	}
 
-    /**
-     * create or update (with check_existing = true) objects of trap
-     * @param string $trapOID : trap oid
-     * @param string $trapmib : mib of trap
-     * @param array $objects : array of objects name (without MIB)
-     * @param bool $check_existing : check instead of create
-     */
+	/**
+	 * create or update (with check_existing = true) objects of trap
+	 * @param string $trapOID : trap oid
+	 * @param string $trapmib : mib of trap
+	 * @param array $objects : array of objects name (without MIB)
+	 * @param bool $check_existing : check instead of create
+	 */
 	public function trap_objects($trapOID,$trapmib,$objects,$check_existing)
 	{
-	    $dbObjects=null; // cache of objects for trap in db
-	    $db_conn=$this->db_connect_trap();
+		$dbObjects=null; // cache of objects for trap in db
+		$db_conn=$this->db_connect_trap();
 	    
-	    // Get id of trapmib.
+		// Get id of trapmib.
 
-	    $trapId = $this->dbOidIndex[$trapOID]['id'];
-	    if ($check_existing === true)
-	    {
-	        // Get all objects
-	        $sql='SELECT * FROM '.$this->db_prefix.'mib_cache_trap_object where trap_id='.$trapId.';';
-	        $this->trapLog('SQL query get all traps: '.$sql,DEBUG );
-	        if (($ret_code=$db_conn->query($sql)) === false) {
-	            $this->trapLog('No result in query : ' . $sql,1,'');
-	        }
-	        $dbObjectsRaw=$ret_code->fetchAll();
+		$trapId = $this->dbOidIndex[$trapOID]['id'];
+		if ($check_existing === true)
+		{
+			// Get all objects
+			$sql='SELECT * FROM '.$this->db_prefix.'mib_cache_trap_object where trap_id='.$trapId.';';
+			$this->trapLog('SQL query get all traps: '.$sql,DEBUG );
+			if (($ret_code=$db_conn->query($sql)) === false) {
+				$this->trapLog('No result in query : ' . $sql,1,'');
+			}
+			$dbObjectsRaw=$ret_code->fetchAll();
 	        
-	        foreach ($dbObjectsRaw as $val)
-	        {
-	            $dbObjects[$val['object_id']]=1;
-	        }
-	    }
-	    foreach ($objects as $object)
-	    {
-	        $match=$snmptrans=array();
-	        $retVal=0;
-	        $objOid=$objTc=$objDispHint=$objSyntax=$objDesc=$objEnum=NULL;
-	        $tmpdesc='';$indesc=false;
+			foreach ($dbObjectsRaw as $val)
+			{
+				$dbObjects[$val['object_id']]=1;
+			}
+		}
+		foreach ($objects as $object)
+		{
+			$match=$snmptrans=array();
+			$retVal=0;
+			$objOid=$objTc=$objDispHint=$objSyntax=$objDesc=$objEnum=NULL;
+			$tmpdesc='';$indesc=false;
 	        
-	        $objMib=$trapmib;
-	        exec($this->snmptranslate . ' -m ALL -M +'.$this->snmptranslate_dirs.
-	            ' -On -Td '.$objMib.'::'.$object . ' 2>/dev/null',$snmptrans,$retVal);
-	        if ($retVal!=0)
-	        {
-	            // Maybe not trap mib, search with IR
-	            exec($this->snmptranslate . ' -m ALL -M +'.$this->snmptranslate_dirs.
-	                ' -IR '.$object . ' 2>/dev/null',$snmptrans,$retVal);
-	            if ($retVal != 0 || !preg_match('/(.*)::(.*)/',$snmptrans[0],$match))
-	            { // Not found -> continue with warning
-	               $this->trapLog('Error finding trap object : '.$trapmib.'::'.$object,2,'');
-	               continue;
-	            }
-	            $objMib=$match[1];
+			$objMib=$trapmib;
+			exec($this->snmptranslate . ' -m ALL -M +'.$this->snmptranslate_dirs.
+				' -On -Td '.$objMib.'::'.$object . ' 2>/dev/null',$snmptrans,$retVal);
+			if ($retVal!=0)
+			{
+				// Maybe not trap mib, search with IR
+				exec($this->snmptranslate . ' -m ALL -M +'.$this->snmptranslate_dirs.
+					' -IR '.$object . ' 2>/dev/null',$snmptrans,$retVal);
+				if ($retVal != 0 || !preg_match('/(.*)::(.*)/',$snmptrans[0],$match))
+				{ // Not found -> continue with warning
+				   $this->trapLog('Error finding trap object : '.$trapmib.'::'.$object,2,'');
+				   continue;
+				}
+				$objMib=$match[1];
 	            
-	            // Do the snmptranslate again.
-	            exec($this->snmptranslate . ' -m ALL -M +'.$this->snmptranslate_dirs.
-	                ' -On -Td '.$objMib.'::'.$object,$snmptrans,$retVal);
-	            if ($retVal!=0) {
-	                $this->trapLog('Error finding trap object : '.$objMib.'::'.$object,2,'');
-	            }
+				// Do the snmptranslate again.
+				exec($this->snmptranslate . ' -m ALL -M +'.$this->snmptranslate_dirs.
+					' -On -Td '.$objMib.'::'.$object,$snmptrans,$retVal);
+				if ($retVal!=0) {
+					$this->trapLog('Error finding trap object : '.$objMib.'::'.$object,2,'');
+				}
 	            
-	        }
-	        foreach ($snmptrans as $line)
-	        {
-	            if ($indesc===true)
-	            {
-	                $line=preg_replace('/[\t ]+/',' ',$line);
-	                if (preg_match('/(.*)"$/', $line,$match))
-	                {
-	                    $objDesc = $tmpdesc . $match[1];
-	                    $indesc=false;
-	                }
-	                $tmpdesc.=$line;
-	                continue;
-	            }
-	            if (preg_match('/^\.[0-9\.]+$/', $line))
-	            {
-	                $objOid=$line;
-	                continue;
-	            }
-	            if (preg_match('/^[\t ]+SYNTAX[\t ]+([^{]*) \{(.*)\}/',$line,$match))
-	            {
-	                $objSyntax=$match[1];
-                    $objEnum=$match[2];
-	                continue;
-	            }
-	            if (preg_match('/^[\t ]+SYNTAX[\t ]+(.*)/',$line,$match))
-	            {
-	                $objSyntax=$match[1];
-	                continue;
-	            }
-	            if (preg_match('/^[\t ]+DISPLAY-HINT[\t ]+"(.*)"/',$line,$match))
-	            {
-	                $objDispHint=$match[1];
-	                continue;
-	            }
-	            if (preg_match('/^[\t ]+DESCRIPTION[\t ]+"(.*)"/',$line,$match))
-	            {
-	                $objDesc=$match[1];
-	                continue;
-	            }
-	            if (preg_match('/^[\t ]+DESCRIPTION[\t ]+"(.*)/',$line,$match))
-	            {
-	                $tmpdesc=$match[1];
-	                $indesc=true;
-	                continue;
-	            }
-	            if (preg_match('/^[\t ]+-- TEXTUAL CONVENTION[\t ]+(.*)/',$line,$match))
-	            {
-	                $objTc=$match[1];
-	                continue;
-	            }
-	        }
-	        $this->trapLog("Adding trap $object : $objOid / $objSyntax / $objEnum / $objDispHint / $objTc",DEBUG );
-	        //echo "$object : $objOid / $objSyntax / $objEnum / $objDispHint / $objTc / $objDesc\n";
-	        // Update 
-	        $this->update_oid($objOid, $objMib, $object, '3', $objTc, $objDispHint, $objSyntax, $objEnum,$objDesc);
+			}
+			foreach ($snmptrans as $line)
+			{
+				if ($indesc===true)
+				{
+					$line=preg_replace('/[\t ]+/',' ',$line);
+					if (preg_match('/(.*)"$/', $line,$match))
+					{
+						$objDesc = $tmpdesc . $match[1];
+						$indesc=false;
+					}
+					$tmpdesc.=$line;
+					continue;
+				}
+				if (preg_match('/^\.[0-9\.]+$/', $line))
+				{
+					$objOid=$line;
+					continue;
+				}
+				if (preg_match('/^[\t ]+SYNTAX[\t ]+([^{]*) \{(.*)\}/',$line,$match))
+				{
+					$objSyntax=$match[1];
+					$objEnum=$match[2];
+					continue;
+				}
+				if (preg_match('/^[\t ]+SYNTAX[\t ]+(.*)/',$line,$match))
+				{
+					$objSyntax=$match[1];
+					continue;
+				}
+				if (preg_match('/^[\t ]+DISPLAY-HINT[\t ]+"(.*)"/',$line,$match))
+				{
+					$objDispHint=$match[1];
+					continue;
+				}
+				if (preg_match('/^[\t ]+DESCRIPTION[\t ]+"(.*)"/',$line,$match))
+				{
+					$objDesc=$match[1];
+					continue;
+				}
+				if (preg_match('/^[\t ]+DESCRIPTION[\t ]+"(.*)/',$line,$match))
+				{
+					$tmpdesc=$match[1];
+					$indesc=true;
+					continue;
+				}
+				if (preg_match('/^[\t ]+-- TEXTUAL CONVENTION[\t ]+(.*)/',$line,$match))
+				{
+					$objTc=$match[1];
+					continue;
+				}
+			}
+			$this->trapLog("Adding trap $object : $objOid / $objSyntax / $objEnum / $objDispHint / $objTc",DEBUG );
+			//echo "$object : $objOid / $objSyntax / $objEnum / $objDispHint / $objTc / $objDesc\n";
+			// Update 
+			$this->update_oid($objOid, $objMib, $object, '3', $objTc, $objDispHint, $objSyntax, $objEnum,$objDesc);
             
-	        if (isset($dbObjects[$this->dbOidIndex[$objOid]['id']]))
-	        {   // if link exists, continue
-	            $dbObjects[$this->dbOidIndex[$objOid]['id']]=2;
-	            continue;
-	        }
-	        if ($check_existing === true) 
-	        {
-	            // TODO : check link trap - objects exists, mark them.
-	        }
-	        // Associate in object table
-	        $sql='INSERT INTO '.$this->db_prefix.'mib_cache_trap_object (trap_id,object_id) '.
-	   	        'values (:trap_id, :object_id)';	        
-	        $sqlQuery=$db_conn->prepare($sql);	        
-	        $sqlParam=array(
-	            ':trap_id' => $trapId,
-	            ':object_id' => $this->dbOidIndex[$objOid]['id'],
-	        );
+			if (isset($dbObjects[$this->dbOidIndex[$objOid]['id']]))
+			{   // if link exists, continue
+				$dbObjects[$this->dbOidIndex[$objOid]['id']]=2;
+				continue;
+			}
+			if ($check_existing === true) 
+			{
+				// TODO : check link trap - objects exists, mark them.
+			}
+			// Associate in object table
+			$sql='INSERT INTO '.$this->db_prefix.'mib_cache_trap_object (trap_id,object_id) '.
+	   			'values (:trap_id, :object_id)';	        
+			$sqlQuery=$db_conn->prepare($sql);	        
+			$sqlParam=array(
+				':trap_id' => $trapId,
+				':object_id' => $this->dbOidIndex[$objOid]['id'],
+			);
 	        
-	        if ($sqlQuery->execute($sqlParam) === false) {
-	            $this->trapLog('Error adding trap object : ' . $sql . ' / ' . $trapId . '/'. $this->dbOidIndex[$objOid]['id'] ,1,'');
-	        }
-	    }
-	    if ($check_existing === true)
-	    {
-	        // TODO : remove link trap - objects that wasn't marked.
-	    }
+			if ($sqlQuery->execute($sqlParam) === false) {
+				$this->trapLog('Error adding trap object : ' . $sql . ' / ' . $trapId . '/'. $this->dbOidIndex[$objOid]['id'] ,1,'');
+			}
+		}
+		if ($check_existing === true)
+		{
+			// TODO : remove link trap - objects that wasn't marked.
+		}
 	    
 	}
 	
@@ -1731,7 +1731,7 @@ 
 	 * @param boolean $check_change : Force check of trap params & objects
 	 * @param boolean $onlyTraps : only cache traps and objects (true) or all (false)
 	 * @param string $startOID : only cache under startOID (NOT IMPLEMENTED)
-	*/	
+	 */	
 	public function update_mib_database($display_progress=false,$check_change=false,$onlyTraps=true,$startOID='.1')
 	{
 		// Timing 
@@ -1783,7 +1783,7 @@ 
 		
 		for ($curElement=0;$curElement < $numElements;$curElement++)
 		{
-		    $time_1= microtime(true);
+			$time_1= microtime(true);
 			if ((microtime(true)-$timeFiveSec) > 2 && $display_progress)
 			{ // echo a . every 2 sec
 				echo '.';
@@ -1801,8 +1801,8 @@ 
 			// Get oid or pass if not found
 			if (!preg_match('/^\.[0-9\.]+$/',$this->objectsAll[$curElement]))
 			{
-			    $time_parse1 += microtime(true) - $time_1;
-			    $time_parse1N ++;
+				$time_parse1 += microtime(true) - $time_1;
+				$time_parse1N ++;
 				continue;
 			}
 			$oid=$this->objectsAll[$curElement];
@@ -1813,7 +1813,7 @@ 
 			if (!preg_match('/ +([^\(]+)\(.+\) type=([0-9]+)( tc=([0-9]+))?( hint=(.+))?/',
 						$this->objectsAll[$curElement],$match))
 			{
-			    $time_check1 += microtime(true) - $time_1;
+				$time_check1 += microtime(true) - $time_1;
 				$time_check1N++;
 				continue;
 			}
@@ -1826,8 +1826,8 @@ 
 				// Check if next is suboid -> in that case is cannot be a trap
 				if (preg_match("/^$oid/",$this->objectsAll[$curElement+1]))
 				{
-				    $time_check2 += microtime(true) - $time_1;
-				    $time_check2N++;
+					$time_check2 += microtime(true) - $time_1;
+					$time_check2N++;
 					continue;
 				}		
 				unset($snmptrans);
@@ -1835,8 +1835,8 @@ 
 					' -Td '.$oid . ' | grep OBJECTS ',$snmptrans,$retVal);
 				if ($retVal!=0)
 				{
-				    $time_check2 += microtime(true) - $time_1;
-				    $time_check2N++;
+					$time_check2 += microtime(true) - $time_1;
+					$time_check2N++;
 					continue;
 				}
 				//echo "\n v1 trap found : $oid \n";
@@ -1845,7 +1845,7 @@ 
 			}
 			if ($onlyTraps===true && $type!=21) // if only traps and not a trap, continue
 			{
-			    $time_check3 += microtime(true) - $time_1;
+				$time_check3 += microtime(true) - $time_1;
 				$time_check3N++;
 				continue;
 			}
@@ -1866,7 +1866,7 @@ 
 			
 			if (!preg_match('/^(.*)::/',$snmptrans[0],$match))
 			{
-			    $this->trapLog('Error getting mib from trap '.$oid.' : ' . $snmptrans[0],1,'');
+				$this->trapLog('Error getting mib from trap '.$oid.' : ' . $snmptrans[0],1,'');
 			}
 			$trapMib=$match[1];
 			
@@ -1874,17 +1874,17 @@ 
 			while (isset($snmptrans[$numLine]) && !preg_match('/^[\t ]+DESCRIPTION[\t ]+"(.*)/',$snmptrans[$numLine],$match)) $numLine++;
 			if (isset($snmptrans[$numLine]))
 			{
-			    $snmptrans[$numLine] = preg_replace('/^[\t ]+DESCRIPTION[\t ]+"/','',$snmptrans[$numLine]);
+				$snmptrans[$numLine] = preg_replace('/^[\t ]+DESCRIPTION[\t ]+"/','',$snmptrans[$numLine]);
 
-			    while (isset($snmptrans[$numLine]) && !preg_match('/"/',$snmptrans[$numLine]))
-			    {
-			        $trapDesc.=preg_replace('/[\t ]+/',' ',$snmptrans[$numLine]);
-			        $numLine++;
-			    }
-			    if (isset($snmptrans[$numLine])) {
-			        $trapDesc.=preg_replace('/".*/','',$snmptrans[$numLine]);
-			        $trapDesc=preg_replace('/[\t ]+/',' ',$trapDesc);
-			    }
+				while (isset($snmptrans[$numLine]) && !preg_match('/"/',$snmptrans[$numLine]))
+				{
+					$trapDesc.=preg_replace('/[\t ]+/',' ',$snmptrans[$numLine]);
+					$numLine++;
+				}
+				if (isset($snmptrans[$numLine])) {
+					$trapDesc.=preg_replace('/".*/','',$snmptrans[$numLine]);
+					$trapDesc=preg_replace('/[\t ]+/',' ',$trapDesc);
+				}
 
 			}
 			$update=$this->update_oid($oid,$trapMib,$name,$type,NULL,NULL,NULL,NULL,$trapDesc);
@@ -1892,23 +1892,23 @@ 
 			
 			if (($update==0) && ($check_change===false))
 			{ // Trapd didn't change & force check disabled
-			    $time_objects += microtime(true) - $time_1;
-			    if ($display_progress) echo "C";
-			    continue;
+				$time_objects += microtime(true) - $time_1;
+				if ($display_progress) echo "C";
+				continue;
 			}
 			
 			$synt=null;
 			foreach ($snmptrans as $line)
 			{	
-    			if (preg_match('/OBJECTS.*\{([^\}]+)\}/',$line,$match))
-    				{
-    					$synt=$match[1];
-    				}
+				if (preg_match('/OBJECTS.*\{([^\}]+)\}/',$line,$match))
+					{
+						$synt=$match[1];
+					}
 			}
 			if ($synt == null) 
 			{
 				//echo "No objects for $trapOID\n";
-			    $time_objects += microtime(true) - $time_1;
+				$time_objects += microtime(true) - $time_1;
 				continue;
 			}
 			//echo "$synt \n";
@@ -1927,18 +1927,18 @@ 
 		
 		if ($display_progress)
 		{
-    		echo "\nNumber of processed traps : $time_num_traps \n";
-    		echo "\nParsing : " . number_format($time_parse1+$time_check1,1) ." sec / " . ($time_parse1N+ $time_check1N)  . " occurences\n";
-    		echo "Detecting traps : " . number_format($time_check2+$time_check3,1) . " sec / " . ($time_check2N+$time_check3N) ." occurences\n";
-    		echo "Trap processing ($time_updateN): ".number_format($time_update,1)." sec , ";
-    		echo "Objects processing ($time_objectsN) : ".number_format($time_objects,1)." sec \n";
+			echo "\nNumber of processed traps : $time_num_traps \n";
+			echo "\nParsing : " . number_format($time_parse1+$time_check1,1) ." sec / " . ($time_parse1N+ $time_check1N)  . " occurences\n";
+			echo "Detecting traps : " . number_format($time_check2+$time_check3,1) . " sec / " . ($time_check2N+$time_check3N) ." occurences\n";
+			echo "Trap processing ($time_updateN): ".number_format($time_update,1)." sec , ";
+			echo "Objects processing ($time_objectsN) : ".number_format($time_objects,1)." sec \n";
 		}
 		
 		// Timing ends
 		$timeTaken=microtime(true) - $timeTaken;
 		if ($display_progress)
 		{
-		    echo "Global time : ".round($timeTaken)." seconds\n";
+			echo "Global time : ".round($timeTaken)." seconds\n";
 		}
 		
 	}

Spacing +431 added lines, -431 removed lines

@@ -7,7 +7,7 @@ 
 
 use Icinga\Module\Trapdirector\Icinga2API;
 
-define("ERROR", 1);define("WARN", 2);define("INFO", 3);define("DEBUG", 4);
+define("ERROR", 1); define("WARN", 2); define("INFO", 3); define("DEBUG", 4);
 
 class Trap
 {
@@ -31,10 +31,10 @@ 
 
 	//**** Options from config database
 	// Logs 
-	protected $debug_level=2;  // 0=No output 1=critical 2=warning 3=trace 4=ALL
+	protected $debug_level=2; // 0=No output 1=critical 2=warning 3=trace 4=ALL
 	protected $alert_output='display'; // alert type : file, syslog, display
 	protected $debug_file="/tmp/trapdebug.txt";
-	protected $debug_text=array("","Error","Warning","Info","Debug");
+	protected $debug_text=array("", "Error", "Warning", "Info", "Debug");
 	
 	//**** End options from database
 	
@@ -86,15 +86,15 @@ 
 	 * @param string $message warning message if not found
 	 * @return boolean true if found, or false
 	 */
-	protected function getOptionIfSet($option_array,$option_category,$option_name, &$option_var, $log_level = 2, $message = null)
+	protected function getOptionIfSet($option_array, $option_category, $option_name, &$option_var, $log_level=2, $message=null)
 	{
 	    if (!isset($option_array[$option_category][$option_name]))
 	    {
 	        if ($message === null)
 	        {
-	            $message='No ' . $option_name . ' in config file: '. $this->trap_module_config;
+	            $message='No '.$option_name.' in config file: '.$this->trap_module_config;
 	        }
-	        $this->trapLog($message,$log_level,'syslog');
+	        $this->trapLog($message, $log_level, 'syslog');
 	        return false;
 	    }
 	    else
@@ -108,40 +108,40 @@ 
 	*/
 	protected function getOptions()
 	{
-		$trap_config=parse_ini_file($this->trap_module_config,true);
+		$trap_config=parse_ini_file($this->trap_module_config, true);
 		if ($trap_config == false) 
 		{
-			$this->trapLog("Error reading ini file : ".$this->trap_module_config,ERROR,'syslog'); 
+			$this->trapLog("Error reading ini file : ".$this->trap_module_config, ERROR, 'syslog'); 
 		}
 		// Snmptranslate binary path
-		$this->getOptionIfSet($trap_config,'config','snmptranslate', $this->snmptranslate);
+		$this->getOptionIfSet($trap_config, 'config', 'snmptranslate', $this->snmptranslate);
 
 		// mibs path
-		$this->getOptionIfSet($trap_config,'config','snmptranslate_dirs', $this->snmptranslate_dirs);
+		$this->getOptionIfSet($trap_config, 'config', 'snmptranslate_dirs', $this->snmptranslate_dirs);
 
 		// icinga2cmd path
-		$this->getOptionIfSet($trap_config,'config','icingacmd', $this->icinga2cmd);
+		$this->getOptionIfSet($trap_config, 'config', 'icingacmd', $this->icinga2cmd);
 		
 		// table prefix
-		$this->getOptionIfSet($trap_config,'config','database_prefix', $this->db_prefix);
+		$this->getOptionIfSet($trap_config, 'config', 'database_prefix', $this->db_prefix);
 
 		// API options
-		if ($this->getOptionIfSet($trap_config,'config','icingaAPI_host', $this->api_hostname))
+		if ($this->getOptionIfSet($trap_config, 'config', 'icingaAPI_host', $this->api_hostname))
 		{
 		    $this->api_use=true;
-		    $this->getOptionIfSet($trap_config,'config','icingaAPI_port', $this->api_port);
-		    $this->getOptionIfSet($trap_config,'config','icingaAPI_user', $this->api_username);
-		    $this->getOptionIfSet($trap_config,'config','icingaAPI_password', $this->api_password);
+		    $this->getOptionIfSet($trap_config, 'config', 'icingaAPI_port', $this->api_port);
+		    $this->getOptionIfSet($trap_config, 'config', 'icingaAPI_user', $this->api_username);
+		    $this->getOptionIfSet($trap_config, 'config', 'icingaAPI_password', $this->api_password);
 		}
 				
 		/***** Database options :  ***/
-		$this->getDBConfigIfSet('log_level',$this->debug_level);
-		$this->getDBConfigIfSet('log_destination',$this->alert_output);
-		$this->getDBConfigIfSet('log_file',$this->debug_file);
+		$this->getDBConfigIfSet('log_level', $this->debug_level);
+		$this->getDBConfigIfSet('log_destination', $this->alert_output);
+		$this->getDBConfigIfSet('log_file', $this->debug_file);
 		$this->getAPI();
 	}
 
-	protected function getDBConfigIfSet($element,&$variable)
+	protected function getDBConfigIfSet($element, &$variable)
 	{
 		$value=$this->getDBConfig($element);
 		if ($value != 'null') $variable=$value;
@@ -156,7 +156,7 @@ 
 		$db_conn=$this->db_connect_trap();
 		$sql='SELECT value from '.$this->db_prefix.'db_config WHERE ( name=\''.$element.'\' )';
 		if (($ret_code=$db_conn->query($sql)) === false) {
-			$this->trapLog('No result in query : ' . $sql,WARN,'');
+			$this->trapLog('No result in query : '.$sql, WARN, '');
 			return null;
 		}
 		$value=$ret_code->fetch();
@@ -173,30 +173,30 @@ 
 	*	@param  string $destination file/syslog/display
 	*	@return void
 	**/	
-	public function trapLog( $message, $level, $destination ='')
+	public function trapLog($message, $level, $destination='')
 	{	
 		if ($this->debug_level >= $level) 
 		{
-			$message = '['.  date("Y/m/d H:i:s") . '] ' .
-				'['. basename(__FILE__) . '] ['.$this->debug_text[$level].']: ' .$message . "\n";
+			$message='['.date("Y/m/d H:i:s").'] '.
+				'['.basename(__FILE__).'] ['.$this->debug_text[$level].']: '.$message."\n";
 			
-			if ( $destination != '' ) $output=$destination;
+			if ($destination != '') $output=$destination;
 			else $output=$this->alert_output;
 			switch ($output)
 			{
 				case 'file':
-					file_put_contents ($this->debug_file, $message , FILE_APPEND);
+					file_put_contents($this->debug_file, $message, FILE_APPEND);
 					break;
 				case 'syslog':
-					switch($level)
+					switch ($level)
 					{
-						case 1 : $prio = LOG_ERR;break;
-						case 2 : $prio = LOG_WARNING;break;
-						case 3 : $prio = LOG_INFO;break;
-						case 4 : $prio = LOG_DEBUG;break;
-						default: $prio = LOG_ERR;
+						case 1 : $prio=LOG_ERR; break;
+						case 2 : $prio=LOG_WARNING; break;
+						case 3 : $prio=LOG_INFO; break;
+						case 4 : $prio=LOG_DEBUG; break;
+						default: $prio=LOG_ERR;
 					}
-					syslog($prio,$message);
+					syslog($prio, $message);
 					break;
 				case 'display':
 					echo $message;
@@ -211,7 +211,7 @@ 
 		}
 	}
 	
-	public function setLogging($debug_lvl,$output_type,$output_option=null)
+	public function setLogging($debug_lvl, $output_type, $output_option=null)
 	{
 		$this->debug_level=$debug_lvl;
 		switch ($output_type)
@@ -228,7 +228,7 @@ 
 				$this->alert_output='display';
 				break;
 			default : // syslog should always work....
-				$this->trapLog("Error in log output : ".$output_type,ERROR,'syslog');
+				$this->trapLog("Error in log output : ".$output_type, ERROR, 'syslog');
 		}
 	}
 	
@@ -236,7 +236,7 @@ 
 	{
 	    if ($this->icinga2api == null)
 	    {
-	        $this->icinga2api = new Icinga2API($this->api_hostname,$this->api_port);
+	        $this->icinga2api=new Icinga2API($this->api_hostname, $this->api_port);
 	    }
 	    return $this->icinga2api;
 	}
@@ -255,7 +255,7 @@ 
 		        // select 1 failed, try to reconnect.
 		        $this->trapDB=null;
 				$this->trapDB=$this->db_connect('traps');
-		        $this->trapLog('Database connection lost, reconnecting',WARN,'');
+		        $this->trapLog('Database connection lost, reconnecting', WARN, '');
 				return $this->trapDB;
 		    }
 		     
@@ -282,14 +282,14 @@ 
 	protected function db_connect($database) {
 		$confarray=$this->get_database($database);
 		//	$dsn = 'mysql:dbname=traps;host=127.0.0.1';
-		$dsn= $confarray[0].':dbname='.$confarray[2].';host='.$confarray[1];
-		$user = $confarray[3];
-		$password = $confarray[4];
-		$this->trapLog('DSN : '.$dsn,INFO);
+		$dsn=$confarray[0].':dbname='.$confarray[2].';host='.$confarray[1];
+		$user=$confarray[3];
+		$password=$confarray[4];
+		$this->trapLog('DSN : '.$dsn, INFO);
 		try {
-			$dbh = new PDO($dsn, $user, $password);
+			$dbh=new PDO($dsn, $user, $password);
 		} catch (PDOException $e) {
-			$this->trapLog('Connection failed : ' . $e->getMessage(),ERROR,'');
+			$this->trapLog('Connection failed : '.$e->getMessage(), ERROR, '');
 		}
 		return $dbh;
 	}
@@ -300,16 +300,16 @@ 
 	**/
 	protected function get_database($database) {
 
-		$trap_config=parse_ini_file($this->trap_module_config,true);
+		$trap_config=parse_ini_file($this->trap_module_config, true);
 		if ($trap_config == false) 
 		{
-			$this->trapLog("Error reading ini file : ".$this->trap_module_config,ERROR,''); 
+			$this->trapLog("Error reading ini file : ".$this->trap_module_config, ERROR, ''); 
 		}
 		if ($database == 'traps')
 		{
 			if (!isset($trap_config['config']['database'])) 
 			{
-				$this->trapLog("No Config/database in config file: ".$this->trap_module_config,ERROR,''); 
+				$this->trapLog("No Config/database in config file: ".$this->trap_module_config, ERROR, ''); 
 			}
 			$db_name=$trap_config['config']['database'];
 		} 
@@ -317,35 +317,35 @@ 
 		{
 			if (!isset($trap_config['config']['IDOdatabase'])) 
 			{
-				$this->trapLog("No Config/IDOdatabase in config file: ".$this->trap_module_config,ERROR,''); 
+				$this->trapLog("No Config/IDOdatabase in config file: ".$this->trap_module_config, ERROR, ''); 
 			}
 			$db_name=$trap_config['config']['IDOdatabase'];		
 		}
 		else
 		{
-			$this->trapLog("Unknown database type : ".$database,ERROR,'');
+			$this->trapLog("Unknown database type : ".$database, ERROR, '');
 			return null;
 		}	
-		$this->trapLog("Found database in config file: ".$db_name,INFO ); 
-		$db_config=parse_ini_file($this->icingaweb2_ressources,true);
+		$this->trapLog("Found database in config file: ".$db_name, INFO); 
+		$db_config=parse_ini_file($this->icingaweb2_ressources, true);
 		if ($db_config == false) 
 		{
-			$this->trapLog("Error reading ini file : ".$this->icingaweb2_ressources,ERROR,''); 
+			$this->trapLog("Error reading ini file : ".$this->icingaweb2_ressources, ERROR, ''); 
 		}
 		if (!isset($db_config[$db_name])) 
 		{
-			$this->trapLog("No Config/database in config file: ".$this->icingaweb2_ressources,ERROR,''); 
+			$this->trapLog("No Config/database in config file: ".$this->icingaweb2_ressources, ERROR, ''); 
 		}
 		$db_type=$db_config[$db_name]['db'];
 		$db_host=$db_config[$db_name]['host'];
 		$db_sql_name=$db_config[$db_name]['dbname'];
 		$db_user=$db_config[$db_name]['username'];
 		$db_pass=$db_config[$db_name]['password'];
-		if ($database == 'traps') $this->trapDBType = $db_type;
-		if ($database == 'ido') $this->idoDBType = $db_type;
+		if ($database == 'traps') $this->trapDBType=$db_type;
+		if ($database == 'ido') $this->idoDBType=$db_type;
 		
-		$this->trapLog( "DB selected : $db_type $db_host $db_sql_name $db_user",INFO ); 
-		return array($db_type,$db_host,$db_sql_name,$db_user,$db_pass);
+		$this->trapLog("DB selected : $db_type $db_host $db_sql_name $db_user", INFO); 
+		return array($db_type, $db_host, $db_sql_name, $db_user, $db_pass);
 	}	
 	
 	/** read data from stream
@@ -360,7 +360,7 @@ 
 		if ($input_stream === false)
 		{
 		    $this->writeTrapErrorToDB("Error reading trap (code 1/Stdin)");
-			$this->trapLog("Error reading stdin !",ERROR,'');
+			$this->trapLog("Error reading stdin !", ERROR, '');
 			return null; // note : exception thrown by traplog
 		}
 
@@ -369,21 +369,21 @@ 
 		if ($this->receivingHost === false)
 		{
 		    $this->writeTrapErrorToDB("Error reading trap (code 1/Line Host)");
-			$this->trapLog("Error reading Host !",ERROR,''); 
+			$this->trapLog("Error reading Host !", ERROR, ''); 
 		}
 		// line 2 IP:port=>IP:port
 		$IP=chop(fgets($input_stream));
 		if ($IP === false)
 		{
 		    $this->writeTrapErrorToDB("Error reading trap (code 1/Line IP)");
-			$this->trapLog("Error reading IP !",ERROR,''); 
+			$this->trapLog("Error reading IP !", ERROR, ''); 
 		}
 		$matches=array();
-		$ret_code=preg_match('/.DP: \[(.*)\]:(.*)->\[(.*)\]:(.*)/',$IP,$matches);
-		if ($ret_code===0 || $ret_code===false) 
+		$ret_code=preg_match('/.DP: \[(.*)\]:(.*)->\[(.*)\]:(.*)/', $IP, $matches);
+		if ($ret_code === 0 || $ret_code === false) 
 		{
 		    $this->writeTrapErrorToDB("Error parsing trap (code 2/IP)");
-			$this->trapLog('Error parsing IP : '.$IP,ERROR,'');
+			$this->trapLog('Error parsing IP : '.$IP, ERROR, '');
 		} 
 		else 
 		{		
@@ -393,34 +393,34 @@ 
 			$this->trap_data['destination_port']=$matches[4];
 		}
 
-		while (($vars=fgets($input_stream)) !==false)
+		while (($vars=fgets($input_stream)) !== false)
 		{
 			$vars=chop($vars);
-			$ret_code=preg_match('/^([^ ]+) (.*)$/',$vars,$matches);
-			if ($ret_code===0 || $ret_code===false) 
+			$ret_code=preg_match('/^([^ ]+) (.*)$/', $vars, $matches);
+			if ($ret_code === 0 || $ret_code === false) 
 			{
-				$this->trapLog('No match on trap data : '.$vars,WARN,'');
+				$this->trapLog('No match on trap data : '.$vars, WARN, '');
 			}
 			else 
 			{
-			    if (($matches[1]=='.1.3.6.1.6.3.1.1.4.1.0') || ($matches[1]=='.1.3.6.1.6.3.1.1.4.1'))
+			    if (($matches[1] == '.1.3.6.1.6.3.1.1.4.1.0') || ($matches[1] == '.1.3.6.1.6.3.1.1.4.1'))
 				{
 					$this->trap_data['trap_oid']=$matches[2];				
 				}
 				else
 				{
-					$object= new stdClass;
-					$object->oid =$matches[1];
-					$object->value = $matches[2];
-					array_push($this->trap_data_ext,$object);
+					$object=new stdClass;
+					$object->oid=$matches[1];
+					$object->value=$matches[2];
+					array_push($this->trap_data_ext, $object);
 				}
 			}
 		}
 
-		if ($this->trap_data['trap_oid']=='unknown') 
+		if ($this->trap_data['trap_oid'] == 'unknown') 
 		{
-		    $this->writeTrapErrorToDB("No trap oid found : check snmptrapd configuration (code 3/OID)",$this->trap_data['source_ip']);
-			$this->trapLog('no trap oid found',ERROR,'');
+		    $this->writeTrapErrorToDB("No trap oid found : check snmptrapd configuration (code 3/OID)", $this->trap_data['source_ip']);
+			$this->trapLog('no trap oid found', ERROR, '');
 		} 
 
 		// Translate oids.
@@ -442,7 +442,7 @@ 
 		}
 		
 
-		$this->trap_data['status']= 'waiting';
+		$this->trap_data['status']='waiting';
 		
 		return $this->trap_data;
 	}
@@ -457,40 +457,40 @@ 
 		$db_conn=$this->db_connect_trap();
 		
 		$sql='SELECT mib,name from '.$this->db_prefix.'mib_cache WHERE oid=\''.$oid.'\';';
-		$this->trapLog('SQL query : '.$sql,DEBUG );
+		$this->trapLog('SQL query : '.$sql, DEBUG);
 		if (($ret_code=$db_conn->query($sql)) === false) {
-			$this->trapLog('No result in query : ' . $sql,ERROR,'');
+			$this->trapLog('No result in query : '.$sql, ERROR, '');
 		}
 		$name=$ret_code->fetch();
 		if ($name['name'] != null)
 		{
-			return array('trap_name_mib'=>$name['mib'],'trap_name'=>$name['name']);
+			return array('trap_name_mib'=>$name['mib'], 'trap_name'=>$name['name']);
 		}
 		
 		// Also check if it is an instance of OID
-		$oid_instance=preg_replace('/\.[0-9]+$/','',$oid);
+		$oid_instance=preg_replace('/\.[0-9]+$/', '', $oid);
 		
 		$sql='SELECT mib,name from '.$this->db_prefix.'mib_cache WHERE oid=\''.$oid_instance.'\';';
-		$this->trapLog('SQL query : '.$sql,DEBUG );
+		$this->trapLog('SQL query : '.$sql, DEBUG);
 		if (($ret_code=$db_conn->query($sql)) === false) {
-			$this->trapLog('No result in query : ' . $sql,ERROR,'');
+			$this->trapLog('No result in query : '.$sql, ERROR, '');
 		}
 		$name=$ret_code->fetch();
 		if ($name['name'] != null)
 		{
-			return array('trap_name_mib'=>$name['mib'],'trap_name'=>$name['name']);
+			return array('trap_name_mib'=>$name['mib'], 'trap_name'=>$name['name']);
 		}
 		
 		// Try to get oid name from snmptranslate
-		$translate=exec($this->snmptranslate . ' -m ALL -M +'.$this->snmptranslate_dirs.
+		$translate=exec($this->snmptranslate.' -m ALL -M +'.$this->snmptranslate_dirs.
 		    ' '.$oid);
 		$matches=array();
-		$ret_code=preg_match('/(.*)::(.*)/',$translate,$matches);
-		if ($ret_code===0 || $ret_code === false) {
+		$ret_code=preg_match('/(.*)::(.*)/', $translate, $matches);
+		if ($ret_code === 0 || $ret_code === false) {
 			return NULL;
 		} else {
-			$this->trapLog('Found name with snmptrapd and not in DB for oid='.$oid,INFO);
-			return array('trap_name_mib'=>$matches[1],'trap_name'=>$matches[2]);
+			$this->trapLog('Found name with snmptrapd and not in DB for oid='.$oid, INFO);
+			return array('trap_name_mib'=>$matches[1], 'trap_name'=>$matches[2]);
 		}	
 	}
 	
@@ -500,90 +500,90 @@ 
 	**/
 	public function eraseOldTraps($days=0)
 	{
-		if ($days==0)
+		if ($days == 0)
 		{
 			if (($days=$this->getDBConfig('db_remove_days')) == null)
 			{
-				$this->trapLog('No days specified & no db value : no tap erase' ,WARN,'');
+				$this->trapLog('No days specified & no db value : no tap erase', WARN, '');
 				return;
 			}
 		}
 		$db_conn=$this->db_connect_trap();
-		$daysago = strtotime("-".$days." day");
-		$sql= 'delete from '.$this->db_prefix.'received where date_received < \''.date("Y-m-d H:i:s",$daysago).'\';';
+		$daysago=strtotime("-".$days." day");
+		$sql='delete from '.$this->db_prefix.'received where date_received < \''.date("Y-m-d H:i:s", $daysago).'\';';
 		if ($db_conn->query($sql) === false) {
-			$this->trapLog('Error erasing traps : '.$sql,ERROR,'');
+			$this->trapLog('Error erasing traps : '.$sql, ERROR, '');
 		}
-		$this->trapLog('Erased traps older than '.$days.' day(s) : '.$sql,INFO);
+		$this->trapLog('Erased traps older than '.$days.' day(s) : '.$sql, INFO);
 	}
 
 	/** Write error to received trap database
 	 */
-	public function writeTrapErrorToDB($message,$sourceIP=null,$trapoid=null)
+	public function writeTrapErrorToDB($message, $sourceIP=null, $trapoid=null)
 	{
 	    
 	    $db_conn=$this->db_connect_trap();
 	    
 	    // add date time
-	    $insert_col ='date_received,status';
-	    $insert_val = "'" . date("Y-m-d H:i:s")."','error'";
+	    $insert_col='date_received,status';
+	    $insert_val="'".date("Y-m-d H:i:s")."','error'";
         
-	    if ($sourceIP !=null)
+	    if ($sourceIP != null)
 	    {
-	        $insert_col .=',source_ip';
-	        $insert_val .=",'". $sourceIP ."'";
+	        $insert_col.=',source_ip';
+	        $insert_val.=",'".$sourceIP."'";
 	    }
-	    if ($trapoid !=null)
+	    if ($trapoid != null)
 	    {
-	        $insert_col .=',trap_oid';
-	        $insert_val .=",'". $trapoid ."'";
+	        $insert_col.=',trap_oid';
+	        $insert_val.=",'".$trapoid."'";
 	    }
-	    $insert_col .=',status_detail';
-	    $insert_val .=",'". $message ."'";
+	    $insert_col.=',status_detail';
+	    $insert_val.=",'".$message."'";
 	    
-	    $sql= 'INSERT INTO '.$this->db_prefix.'received (' . $insert_col . ') VALUES ('.$insert_val.')';
+	    $sql='INSERT INTO '.$this->db_prefix.'received ('.$insert_col.') VALUES ('.$insert_val.')';
 	    
 	    switch ($this->trapDBType)
 	    {
 	        case 'pgsql':
-	            $sql .= ' RETURNING id;';
-	            $this->trapLog('sql : '.$sql,INFO);
+	            $sql.=' RETURNING id;';
+	            $this->trapLog('sql : '.$sql, INFO);
 	            if (($ret_code=$db_conn->query($sql)) === false) {
-	                $this->trapLog('Error SQL insert : '.$sql,1,'');
+	                $this->trapLog('Error SQL insert : '.$sql, 1, '');
 	            }
-	            $this->trapLog('SQL insertion OK',INFO );
+	            $this->trapLog('SQL insertion OK', INFO);
 	            // Get last id to insert oid/values in secondary table
 	            if (($inserted_id_ret=$ret_code->fetch(PDO::FETCH_ASSOC)) === false) {
 	                
-	                $this->trapLog('Erreur recuperation id',1,'');
+	                $this->trapLog('Erreur recuperation id', 1, '');
 	            }
-	            if (! isset($inserted_id_ret['id'])) {
-	                $this->trapLog('Error getting id',1,'');
+	            if (!isset($inserted_id_ret['id'])) {
+	                $this->trapLog('Error getting id', 1, '');
 	            }
 	            $this->trap_id=$inserted_id_ret['id'];
 	            break;
 	        case 'mysql':
-	            $sql .= ';';
-	            $this->trapLog('sql : '.$sql,INFO );
+	            $sql.=';';
+	            $this->trapLog('sql : '.$sql, INFO);
 	            if ($db_conn->query($sql) === false) {
-	                $this->trapLog('Error SQL insert : '.$sql,1,'');
+	                $this->trapLog('Error SQL insert : '.$sql, 1, '');
 	            }
-	            $this->trapLog('SQL insertion OK',INFO );
+	            $this->trapLog('SQL insertion OK', INFO);
 	            // Get last id to insert oid/values in secondary table
 	            $sql='SELECT LAST_INSERT_ID();';
 	            if (($ret_code=$db_conn->query($sql)) === false) {
-	                $this->trapLog('Erreur recuperation id',1,'');
+	                $this->trapLog('Erreur recuperation id', 1, '');
 	            }
 	            
 	            $inserted_id=$ret_code->fetch(PDO::FETCH_ASSOC)['LAST_INSERT_ID()'];
-	            if ($inserted_id==false) throw new Exception("Weird SQL error : last_insert_id returned false : open issue");
+	            if ($inserted_id == false) throw new Exception("Weird SQL error : last_insert_id returned false : open issue");
 	            $this->trap_id=$inserted_id;
 	            break;
 	        default:
-	            $this->trapLog('Error SQL type  : '.$this->trapDBType,1,'');
+	            $this->trapLog('Error SQL type  : '.$this->trapDBType, 1, '');
 	    }
 	    
-	    $this->trapLog('id found: '. $this->trap_id,INFO );    
+	    $this->trapLog('id found: '.$this->trap_id, INFO);    
 	}
 	
 	/** Write trap data to trap database
@@ -600,86 +600,86 @@ 
 		$insert_col='';
 		$insert_val='';
 		// add date time
-		$this->trap_data['date_received'] = date("Y-m-d H:i:s");
+		$this->trap_data['date_received']=date("Y-m-d H:i:s");
 
 		$firstcol=1;
 		foreach ($this->trap_data as $col => $val)
 		{
-			if ($firstcol==0) 
+			if ($firstcol == 0) 
 			{
-				$insert_col .=',';
-				$insert_val .=',';
+				$insert_col.=',';
+				$insert_val.=',';
 			}
-			$insert_col .= $col ;
-			$insert_val .= ($val==null)? 'NULL' : $db_conn->quote($val);
+			$insert_col.=$col;
+			$insert_val.=($val == null) ? 'NULL' : $db_conn->quote($val);
 			$firstcol=0;
 		}
 		
-		$sql= 'INSERT INTO '.$this->db_prefix.'received (' . $insert_col . ') VALUES ('.$insert_val.')';
+		$sql='INSERT INTO '.$this->db_prefix.'received ('.$insert_col.') VALUES ('.$insert_val.')';
 		switch ($this->trapDBType)
 		{
 			case 'pgsql': 
-				$sql .= ' RETURNING id;';
-				$this->trapLog('sql : '.$sql,INFO );
+				$sql.=' RETURNING id;';
+				$this->trapLog('sql : '.$sql, INFO);
 				if (($ret_code=$db_conn->query($sql)) === false) {
-					$this->trapLog('Error SQL insert : '.$sql,ERROR,'');
+					$this->trapLog('Error SQL insert : '.$sql, ERROR, '');
 				}
-				$this->trapLog('SQL insertion OK',INFO );
+				$this->trapLog('SQL insertion OK', INFO);
 				// Get last id to insert oid/values in secondary table
 				if (($inserted_id_ret=$ret_code->fetch(PDO::FETCH_ASSOC)) === false) {
 														   
-					$this->trapLog('Erreur recuperation id',ERROR,'');
+					$this->trapLog('Erreur recuperation id', ERROR, '');
 				}
-				if (! isset($inserted_id_ret['id'])) {
-					$this->trapLog('Error getting id',ERROR,'');
+				if (!isset($inserted_id_ret['id'])) {
+					$this->trapLog('Error getting id', ERROR, '');
 				}
 				$this->trap_id=$inserted_id_ret['id'];
 			break;
 			case 'mysql': 
-				$sql .= ';';
-				$this->trapLog('sql : '.$sql,INFO );
+				$sql.=';';
+				$this->trapLog('sql : '.$sql, INFO);
 				if ($db_conn->query($sql) === false) {
-					$this->trapLog('Error SQL insert : '.$sql,ERROR,'');
+					$this->trapLog('Error SQL insert : '.$sql, ERROR, '');
 				}
-				$this->trapLog('SQL insertion OK',INFO );
+				$this->trapLog('SQL insertion OK', INFO);
 				// Get last id to insert oid/values in secondary table
 				$sql='SELECT LAST_INSERT_ID();';
 				if (($ret_code=$db_conn->query($sql)) === false) {
-					$this->trapLog('Erreur recuperation id',ERROR,'');
+					$this->trapLog('Erreur recuperation id', ERROR, '');
 				}
 
 				$inserted_id=$ret_code->fetch(PDO::FETCH_ASSOC)['LAST_INSERT_ID()'];
-				if ($inserted_id==false) throw new Exception("Weird SQL error : last_insert_id returned false : open issue");
+				if ($inserted_id == false) throw new Exception("Weird SQL error : last_insert_id returned false : open issue");
 				$this->trap_id=$inserted_id;
 			break;
 			default: 
-				$this->trapLog('Error SQL type  : '.$this->trapDBType,ERROR,'');
+				$this->trapLog('Error SQL type  : '.$this->trapDBType, ERROR, '');
 		}
-		$this->trapLog('id found: '.$this->trap_id,INFO );
+		$this->trapLog('id found: '.$this->trap_id, INFO);
 		
 		// Fill trap extended data table
 		foreach ($this->trap_data_ext as $value) {			
 			// TODO : detect if trap value is encoded and decode it to UTF-8 for database
 			$firstcol=1;
-			$value->trap_id = $this->trap_id;
+			$value->trap_id=$this->trap_id;
 			$insert_col='';
 			$insert_val='';
 			foreach ($value as $col => $val)
 			{
-				if ($firstcol==0) 
+				if ($firstcol == 0) 
 				{
-					$insert_col .=',';
-					$insert_val .=',';
+					$insert_col.=',';
+					$insert_val.=',';
 				}
-				$insert_col .= $col;
-				$insert_val .= ($val==null)? 'NULL' : $db_conn->quote($val);
+				$insert_col.=$col;
+				$insert_val.=($val == null) ? 'NULL' : $db_conn->quote($val);
 				$firstcol=0;
 			}
 
-			$sql= 'INSERT INTO '.$this->db_prefix.'received_data (' . $insert_col . ') VALUES ('.$insert_val.');';			
+			$sql='INSERT INTO '.$this->db_prefix.'received_data ('.$insert_col.') VALUES ('.$insert_val.');';			
 
 			if (($ret_code=$db_conn->query($sql)) === false) {
-				$this->trapLog('Erreur insertion data : ' . $sql,WARN,'');
+				$this->trapLog('Erreur insertion data : '.$sql, WARN, '');
 			}	
 		}	
 	}
@@ -689,14 +689,14 @@ 
 	*	@param $oid string oid in numeric
 	*	@return mixed : PDO object or false
 	*/	
-	protected function getRules($ip,$oid)
+	protected function getRules($ip, $oid)
 	{
 		$db_conn=$this->db_connect_trap();
 		// fetch rules based on IP in rule and OID
 		$sql='SELECT * from '.$this->db_prefix.'rules WHERE trap_oid=\''.$oid.'\' ';
-		$this->trapLog('SQL query : '.$sql,DEBUG );
+		$this->trapLog('SQL query : '.$sql, DEBUG);
 		if (($ret_code=$db_conn->query($sql)) === false) {
-			$this->trapLog('No result in query : ' . $sql,WARN,'');
+			$this->trapLog('No result in query : '.$sql, WARN, '');
 			return false;
 		}
 		$rules_all=$ret_code->fetchAll();
@@ -705,7 +705,7 @@ 
 		$rule_ret_key=0;
 		foreach ($rules_all as $key => $rule)
 		{
-			if ($rule['ip4']==$ip || $rule['ip6']==$ip)
+			if ($rule['ip4'] == $ip || $rule['ip6'] == $ip)
 			{
 				$rules_ret[$rule_ret_key]=$rules_all[$key];
 				//TODO : get host name by API (and check if correct in rule).
@@ -713,7 +713,7 @@ 
 				continue;
 			}
 			// TODO : get hosts IP by API
-			if (isset($rule['host_group_name']) && $rule['host_group_name']!=null)
+			if (isset($rule['host_group_name']) && $rule['host_group_name'] != null)
 			{ // get ips of group members by oid
 				$db_conn2=$this->db_connect_ido();
 				$sql="SELECT m.host_object_id, a.address as ip4, a.address6 as ip6, b.name1 as host_name
@@ -724,15 +724,15 @@ 
 						LEFT JOIN icinga_objects as b ON b.object_id = a.host_object_id
 						WHERE o.name1='".$rule['host_group_name']."';";
 				if (($ret_code2=$db_conn2->query($sql)) === false) {
-					$this->trapLog('No result in query : ' . $sql,WARN,'');
+					$this->trapLog('No result in query : '.$sql, WARN, '');
 					continue;
 				}
 				$grouphosts=$ret_code2->fetchAll();
 				//echo "rule grp :\n";print_r($grouphosts);echo "\n";
-				foreach ( $grouphosts as $host)
+				foreach ($grouphosts as $host)
 				{
 					//echo $host['ip4']."\n";
-					if ($host['ip4']==$ip || $host['ip6']==$ip)
+					if ($host['ip4'] == $ip || $host['ip6'] == $ip)
 					{
 						//echo "Rule added \n";
 						$rules_ret[$rule_ret_key]=$rules_all[$key];
@@ -755,7 +755,7 @@ 
 		$db_conn=$this->db_connect_trap();
 		$sql="UPDATE ".$this->db_prefix."rules SET num_match = '".$set."' WHERE (id = '".$id."');";
 		if ($db_conn->query($sql) === false) {
-			$this->trapLog('Error in update query : ' . $sql,WARN,'');
+			$this->trapLog('Error in update query : '.$sql, WARN, '');
 		}
 	}
 	
@@ -767,31 +767,31 @@ 
 	 * @param string $display
 	 * @returnn bool true is service check was sent without error
 	*/
-	public function serviceCheckResult($host,$service,$state,$display)
+	public function serviceCheckResult($host, $service, $state, $display)
 	{
 	    if ($this->api_use === false)
 	    {
-    		$send = '[' . date('U') .'] PROCESS_SERVICE_CHECK_RESULT;' .
-    			$host.';' .$service .';' . $state . ';'.$display;
-    		$this->trapLog( $send." : to : " .$this->icinga2cmd,INFO );
+    		$send='['.date('U').'] PROCESS_SERVICE_CHECK_RESULT;'.
+    			$host.';'.$service.';'.$state.';'.$display;
+    		$this->trapLog($send." : to : ".$this->icinga2cmd, INFO);
     		
     		// TODO : file_put_contents & fopen (,'w' or 'a') does not work. See why. Or not as using API will be by default....
-    		exec('echo "'.$send.'" > ' .$this->icinga2cmd);
+    		exec('echo "'.$send.'" > '.$this->icinga2cmd);
     		return true;
 	    }
 	    else
 	    {
-	        $api = $this->getAPI();
+	        $api=$this->getAPI();
 	        $api->setCredentials($this->api_username, $this->api_password);
-	        list($retcode,$retmessage)=$api->serviceCheckResult($host,$service,$state,$display);
+	        list($retcode, $retmessage)=$api->serviceCheckResult($host, $service, $state, $display);
 	        if ($retcode == false)
 	        {
-	            $this->trapLog( "Error sending result : " .$retmessage,WARN,'');
+	            $this->trapLog("Error sending result : ".$retmessage, WARN, '');
 	            return false;
 	        }
 	        else 
 	        {
-	            $this->trapLog( "Sent result : " .$retmessage,INFO );
+	            $this->trapLog("Sent result : ".$retmessage, INFO);
 	            return true;
 	        }
 	    }
@@ -799,7 +799,7 @@ 
 	
 	public function getHostByIP($ip)
 	{
-	    $api = $this->getAPI();
+	    $api=$this->getAPI();
 	    $api->setCredentials($this->api_username, $this->api_password);
 	    return $api->getHostByIP($ip);
 	}
@@ -812,32 +812,32 @@ 
 	protected function applyDisplay($display)
 	{
 	    $matches=array();
-	    while (preg_match('/_OID\(([0-9\.]+)\)/',$display,$matches) == 1)
+	    while (preg_match('/_OID\(([0-9\.]+)\)/', $display, $matches) == 1)
 		{
 			$oid=$matches[1];
 			$found=0;
-			foreach($this->trap_data_ext as $val)
+			foreach ($this->trap_data_ext as $val)
 			{
 				if ($oid == $val->oid)
 				{
-					$val->value=preg_replace('/"/','',$val->value);
+					$val->value=preg_replace('/"/', '', $val->value);
 					$rep=0;
-					$display=preg_replace('/_OID\('.$oid.'\)/',$val->value,$display,-1,$rep);
-					if ($rep==0)
+					$display=preg_replace('/_OID\('.$oid.'\)/', $val->value, $display, -1, $rep);
+					if ($rep == 0)
 					{
-						$this->trapLog("Error in display",WARN,'');
+						$this->trapLog("Error in display", WARN, '');
 						return $display;
 					}
 					$found=1;
 					break;
 				}
 			}
-			if ($found==0)
+			if ($found == 0)
 			{
-				$display=preg_replace('/_OID\('.$oid.'\)/','<not in trap>',$display,-1,$rep);
-				if ($rep==0)
+				$display=preg_replace('/_OID\('.$oid.'\)/', '<not in trap>', $display, -1, $rep);
+				if ($rep == 0)
 				{
-					$this->trapLog("Error in display",WARN,'');
+					$this->trapLog("Error in display", WARN, '');
 					return $display;
 				}				
 			}
@@ -847,27 +847,27 @@ 
 
 	
 	/***************** Eval & tokenizer functions ****************/
-	protected function eval_getElement($rule,&$item)
+	protected function eval_getElement($rule, &$item)
 	{
-		while ($rule[$item]==' ') $item++;
-		if (preg_match('/[0-9\.]/',$rule[$item]))
+		while ($rule[$item] == ' ') $item++;
+		if (preg_match('/[0-9\.]/', $rule[$item]))
 		{ // number
 	
-			$item2=$item+1; 
-			while (($item2!=strlen($rule)) && (preg_match('/[0-9\.]/',$rule[$item2]))) { $item2++ ;}
-			$val=substr($rule,$item,$item2-$item);
+			$item2=$item + 1; 
+			while (($item2 != strlen($rule)) && (preg_match('/[0-9\.]/', $rule[$item2]))) { $item2++; }
+			$val=substr($rule, $item, $item2 - $item);
 			$item=$item2;
 			//echo "number ".$val."\n";
-			return array(0,$val);
+			return array(0, $val);
 		}
 		if ($rule[$item] == '"')
 		{ // string
 			$item++;
-			$item2=$this->eval_getNext($rule,$item,'"');
-			$val=substr($rule,$item,$item2-$item-1);
+			$item2=$this->eval_getNext($rule, $item, '"');
+			$val=substr($rule, $item, $item2 - $item - 1);
 			$item=$item2;
 			//echo "string : ".$val."\n";
-			return array(1,$val);
+			return array(1, $val);
 		}
 		
 		if ($rule[$item] == '(')
@@ -876,14 +876,14 @@ 
 			$start=$item;
 			$parenthesis_count=0; 
 			while (($item < strlen($rule)) // Not end of string AND
-			      && ( ($rule[$item] != ')' ) || $parenthesis_count > 0) ) // Closing ')' or embeded ()
+			      && (($rule[$item] != ')') || $parenthesis_count > 0)) // Closing ')' or embeded ()
 			{ 
-				if ($rule[$item] == '"' )
+				if ($rule[$item] == '"')
 				{ // pass through string
 					$item++;
-					$item=$this->eval_getNext($rule,$item,'"');
+					$item=$this->eval_getNext($rule, $item, '"');
 				} 
-				else{
+				else {
 				    if ($rule[$item] == '(')
 				    {
 				        $parenthesis_count++;
@@ -896,49 +896,49 @@ 
 				}
 			}
 			
-			if ($item==strlen($rule)) {throw new Exception("no closing () in ".$rule ." at " .$item);}
-			$val=substr($rule,$start,$item-$start);
+			if ($item == strlen($rule)) {throw new Exception("no closing () in ".$rule." at ".$item); }
+			$val=substr($rule, $start, $item - $start);
 			$item++;
 			$start=0;
 			//echo "group : ".$val."\n";
 			// returns evaluation of group as type 2 (boolean)
-			return array(2,$this->evaluation($val,$start));		
+			return array(2, $this->evaluation($val, $start));		
 		}
-		throw new Exception("number/string not found in ".$rule ." at " .$item . ' : ' .$rule[$item]);
+		throw new Exception("number/string not found in ".$rule." at ".$item.' : '.$rule[$item]);
 		
 	}
 	
-	protected function eval_getNext($rule,$item,$tok)
+	protected function eval_getNext($rule, $item, $tok)
 	{
-		while (($rule[$item] != $tok ) && ($item < strlen($rule))) { $item++;}
-		if ($item==strlen($rule)) throw new Exception("closing '".$tok."' not found in ".$rule ." at " .$item);
-		return $item+1;
+		while (($rule[$item] != $tok) && ($item < strlen($rule))) { $item++; }
+		if ($item == strlen($rule)) throw new Exception("closing '".$tok."' not found in ".$rule." at ".$item);
+		return $item + 1;
 	}
 	
-	protected function eval_getOper($rule,&$item)
+	protected function eval_getOper($rule, &$item)
 	{
-		while ($rule[$item]==' ') $item++;
+		while ($rule[$item] == ' ') $item++;
 		switch ($rule[$item])
 		{
 			case '<':
-				if ($rule[$item+1]=='=') { $item+=2; return array(0,"<=");}
-				$item++; return array(0,"<");
+				if ($rule[$item + 1] == '=') { $item+=2; return array(0, "<="); }
+				$item++; return array(0, "<");
 			case '>':
-				if ($rule[$item+1]=='=') { $item+=2; return array(0,">=");}
-				$item++; return array(0,">");
+				if ($rule[$item + 1] == '=') { $item+=2; return array(0, ">="); }
+				$item++; return array(0, ">");
 			case '=':
-				$item++; return array(0,"=");	
+				$item++; return array(0, "=");	
 			case '!':
-				if ($rule[$item+1]=='=') { $item+=2; return array(0,"!=");}
-				throw new Exception("Erreur in expr - incorrect operator '!'  found in ".$rule ." at " .$item);
+				if ($rule[$item + 1] == '=') { $item+=2; return array(0, "!="); }
+				throw new Exception("Erreur in expr - incorrect operator '!'  found in ".$rule." at ".$item);
 			case '~':
-				$item++; return array(0,"~");	
+				$item++; return array(0, "~");	
 			case '|':
-				$item++; return array(1,"|");	
+				$item++; return array(1, "|");	
 			case '&':
-				$item++; return array(1,"&");
+				$item++; return array(1, "&");
 			default	:
-				throw new Exception("Erreur in expr - operator not found in ".$rule ." at " .$item);
+				throw new Exception("Erreur in expr - operator not found in ".$rule." at ".$item);
 		}
 	}
 	
@@ -950,10 +950,10 @@ 
 	*   comparison int vs strings will return null (error)
 	*	return : bool or null on error
 	*/
-	public function evaluation($rule,&$item)
+	public function evaluation($rule, &$item)
 	{
 	    //echo "Evaluation of ".substr($rule,$item)."\n";
-		if ( $rule[$item] == '!') // If '!' found, negate next expression.
+		if ($rule[$item] == '!') // If '!' found, negate next expression.
 		{
 		    $negate=true;
 		    $item++;
@@ -963,63 +963,63 @@ 
 		    $negate=false;
 		}
 		// First element : number, string or ()
-		list($type1,$val1) = $this->eval_getElement($rule,$item);
+		list($type1, $val1)=$this->eval_getElement($rule, $item);
 		//echo "Elmt1: ".$val1."/".$type1." : ".substr($rule,$item)."\n";
 		
-		if ($item==strlen($rule)) // If only element, return value, but only boolean
+		if ($item == strlen($rule)) // If only element, return value, but only boolean
 		{
 		  if ($type1 != 2) throw new Exception("Cannot use num/string as boolean : ".$rule);
-		  if ($negate === true) $val1= ! $val1;
+		  if ($negate === true) $val1=!$val1;
 		  return $val1;
 		}  
 		
 		// Second element : operator
-		list($typec,$comp) = $this->eval_getOper($rule,$item);
+		list($typec, $comp)=$this->eval_getOper($rule, $item);
 		//echo "Comp : ".$comp." : ".substr($rule,$item)."\n";
         
 		// Third element : number, string or ()
-		if ( $rule[$item] == '!') // starts with a ! so evaluate whats next
+		if ($rule[$item] == '!') // starts with a ! so evaluate whats next
 		{
 		    $item++;
 		    if ($typec != 1) throw new Exception("Mixing boolean and comparison : ".$rule);
-		    $val2= ! $this->evaluation($rule,$item);
+		    $val2=!$this->evaluation($rule, $item);
 		    $type2=2; // result is a boolean 
 		}
 		else 
 		{
-		    list($type2,$val2) = $this->eval_getElement($rule,$item);
+		    list($type2, $val2)=$this->eval_getElement($rule, $item);
 		}
 		//echo "Elmt2: ".$val2."/".$type2." : ".substr($rule,$item)."\n";
 		
-		if ($type1!=$type2)  // cannot compare different types
+		if ($type1 != $type2)  // cannot compare different types
 		{ 
 		    throw new Exception("Cannot compare string & number : ".$rule);
 		}
-		if ($typec==1 && $type1 !=2) // cannot use & or | with string/number
+		if ($typec == 1 && $type1 != 2) // cannot use & or | with string/number
 		{
 		    throw new Exception("Cannot use boolean operators with string & number : ".$rule);
 		}
 		
-		switch ($comp){
-			case '<':	$retVal= ($val1 < $val2); break;
-			case '<=':	$retVal= ($val1 <= $val2); break;
-			case '>':	$retVal= ($val1 > $val2); break;
-			case '>=':	$retVal= ($val1 >= $val2); break;
-			case '=':	$retVal= ($val1 == $val2); break;
-			case '!=':	$retVal= ($val1 != $val2); break;
-			case '~':	$retVal= (preg_match('/'.preg_replace('/"/','',$val2).'/',$val1)); break;
-			case '|':	$retVal= ($val1 || $val2); break;
-			case '&':	$retVal= ($val1 && $val2); break;
+		switch ($comp) {
+			case '<':	$retVal=($val1 < $val2); break;
+			case '<=':	$retVal=($val1 <= $val2); break;
+			case '>':	$retVal=($val1 > $val2); break;
+			case '>=':	$retVal=($val1 >= $val2); break;
+			case '=':	$retVal=($val1 == $val2); break;
+			case '!=':	$retVal=($val1 != $val2); break;
+			case '~':	$retVal=(preg_match('/'.preg_replace('/"/', '', $val2).'/', $val1)); break;
+			case '|':	$retVal=($val1 || $val2); break;
+			case '&':	$retVal=($val1 && $val2); break;
 			default:  throw new Exception("Error in expression - unknown comp : ".$comp);
 		}
-		if ($negate === true) $retVal = ! $retVal; // Inverse result if negate before expression
+		if ($negate === true) $retVal=!$retVal; // Inverse result if negate before expression
 		
-		if ($item==strlen($rule)) return $retVal; // End of string : return evaluation
+		if ($item == strlen($rule)) return $retVal; // End of string : return evaluation
 		// check for logical operator :
 		switch ($rule[$item])
 		{
-			case '|':	$item++; return ($retVal || $this->evaluation($rule,$item) );
-			case '&':	$item++; return ($retVal && $this->evaluation($rule,$item) );
+			case '|':	$item++; return ($retVal || $this->evaluation($rule, $item));
+			case '&':	$item++; return ($retVal && $this->evaluation($rule, $item));
 			
 			default:  throw new Exception("Erreur in expr - garbadge at end of expression : ".$rule[$item]);
 		}
@@ -1031,17 +1031,17 @@ 
 		$rule2='';
 		while ($item < strlen($rule))
 		{
-			if ($rule[$item]==' ') { $item++; continue; }
-			if ($rule[$item]=='"')
+			if ($rule[$item] == ' ') { $item++; continue; }
+			if ($rule[$item] == '"')
 			{
 				$rule2.=$rule[$item];
 				$item++;
-				while (($rule[$item]!='"') && ($item < strlen($rule)))
+				while (($rule[$item] != '"') && ($item < strlen($rule)))
 				{
 					$rule2.=$rule[$item];
 					$item++;
 				}
-				if ($item == strlen ($rule)) throw new Exception("closing '\"' not found in ".$rule ." at " .$item);
+				if ($item == strlen($rule)) throw new Exception("closing '\"' not found in ".$rule." at ".$item);
 				$rule2.=$rule[$item];
 				$item++;
 				continue;
@@ -1061,12 +1061,12 @@ 
 	
 	protected function eval_rule($rule)
 	{
-		if ($rule==null || $rule == '') // Empty rule is always true
+		if ($rule == null || $rule == '') // Empty rule is always true
 		{
 			return true;
 		}
 		$matches=array();
-		while (preg_match('/_OID\(([0-9\.\*]+)\)/',$rule,$matches) == 1)
+		while (preg_match('/_OID\(([0-9\.\*]+)\)/', $rule, $matches) == 1)
 		{
 			$oid=$matches[1];
 			$found=0;
@@ -1078,49 +1078,49 @@ 
 			// replace * with \* in oid for preg_replace
 			$oid=preg_replace('/\*/', '\*', $oid);
 			
-			$this->trapLog('OID in rule : '.$oid.' / '.$oidR,DEBUG );
+			$this->trapLog('OID in rule : '.$oid.' / '.$oidR, DEBUG);
 			
-			foreach($this->trap_data_ext as $val)
+			foreach ($this->trap_data_ext as $val)
 			{
-				if (preg_match("/^$oidR$/",$val->oid) == 1)
+				if (preg_match("/^$oidR$/", $val->oid) == 1)
 				{
-					if (!preg_match('/^[0-9]*\.?[0-9]+$/',$val->value))
+					if (!preg_match('/^[0-9]*\.?[0-9]+$/', $val->value))
 					{ // If not a number, change " to ' and put " around it
-						$val->value=preg_replace('/"/',"'",$val->value);
+						$val->value=preg_replace('/"/', "'", $val->value);
 						$val->value='"'.$val->value.'"';
 					}
 					$rep=0;
-					$rule=preg_replace('/_OID\('.$oid.'\)/',$val->value,$rule,-1,$rep);
-					if ($rep==0)
+					$rule=preg_replace('/_OID\('.$oid.'\)/', $val->value, $rule, -1, $rep);
+					if ($rep == 0)
 					{
-						$this->trapLog("Error in rule_eval",WARN,'');
+						$this->trapLog("Error in rule_eval", WARN, '');
 						return false;
 					}
 					$found=1;
 					break;
 				}
 			}
-			if ($found==0)
+			if ($found == 0)
 			{	// OID not found : throw error
 			    throw new Exception('OID '.$oid.' not found in trap');
 			}
 		}
 		$item=0;
 		$rule=$this->eval_cleanup($rule);
-		$this->trapLog('Rule after clenup: '.$rule,INFO );
+		$this->trapLog('Rule after clenup: '.$rule, INFO);
 		
-		return  $this->evaluation($rule,$item);
+		return  $this->evaluation($rule, $item);
 	}
 	
 	/** Match rules for current trap and do action
 	*/
 	public function applyRules()
 	{
-		$rules = $this->getRules($this->trap_data['source_ip'],$this->trap_data['trap_oid']);
+		$rules=$this->getRules($this->trap_data['source_ip'], $this->trap_data['trap_oid']);
 		
-		if ($rules===false || count($rules)==0)
+		if ($rules === false || count($rules) == 0)
 		{
-			$this->trapLog('No rules found for this trap',INFO );
+			$this->trapLog('No rules found for this trap', INFO);
 			$this->trap_data['status']='unknown';
 			$this->trap_to_db=true;
 			return;
@@ -1135,58 +1135,58 @@ 
 			$service_name=$rule['service_name'];
 			
 			$display=$this->applyDisplay($rule['display']);
-			$this->trap_action = ($this->trap_action==null)? '' : $this->trap_action . ', ';
+			$this->trap_action=($this->trap_action == null) ? '' : $this->trap_action.', ';
 			try
 			{
-				$this->trapLog('Rule to eval : '.$rule['rule'],INFO );
+				$this->trapLog('Rule to eval : '.$rule['rule'], INFO);
 				$evalr=$this->eval_rule($rule['rule']);
 				
 				if ($evalr == true)
 				{
 					//$this->trapLog('rules OOK: '.print_r($rule),INFO );
 					$action=$rule['action_match'];
-					$this->trapLog('action OK : '.$action,INFO );
+					$this->trapLog('action OK : '.$action, INFO);
 					if ($action >= 0)
 					{
-						if ($this->serviceCheckResult($host_name,$service_name,$action,$display) == false)
+						if ($this->serviceCheckResult($host_name, $service_name, $action, $display) == false)
 						{
 						    $this->trap_action.='Error sending status : check cmd/API';
 						}
 						else
 						{
-						    $this->add_rule_match($rule['id'],$rule['num_match']+1);
+						    $this->add_rule_match($rule['id'], $rule['num_match'] + 1);
 						    $this->trap_action.='Status '.$action.' to '.$host_name.'/'.$service_name;
 						}
 					}
 					else
 					{
-						$this->add_rule_match($rule['id'],$rule['num_match']+1);
+						$this->add_rule_match($rule['id'], $rule['num_match'] + 1);
 					}
-					$this->trap_to_db=($action==-2)?false:true;
+					$this->trap_to_db=($action == -2) ?false:true;
 				}
 				else
 				{
 					//$this->trapLog('rules KOO : '.print_r($rule),INFO );
 					
 					$action=$rule['action_nomatch'];
-					$this->trapLog('action NOK : '.$action,INFO );
+					$this->trapLog('action NOK : '.$action, INFO);
 					if ($action >= 0)
 					{
-					    if ($this->serviceCheckResult($host_name,$service_name,$action,$display)==false)
+					    if ($this->serviceCheckResult($host_name, $service_name, $action, $display) == false)
 					    {
 					        $this->trap_action.='Error sending status : check cmd/API';
 					    }
 					    else
 					    {
-    						$this->add_rule_match($rule['id'],$rule['num_match']+1);
+    						$this->add_rule_match($rule['id'], $rule['num_match'] + 1);
     						$this->trap_action.='Status '.$action.' to '.$host_name.'/'.$service_name;
 					    }
 					}
 					else
 					{
-						$this->add_rule_match($rule['id'],$rule['num_match']+1);
+						$this->add_rule_match($rule['id'], $rule['num_match'] + 1);
 					}
-					$this->trap_to_db=($action==-2)?false:true;					
+					$this->trap_to_db=($action == -2) ?false:true;					
 				}
 				// Put name in source_name
 				if (!isset($this->trap_data['source_name']))
@@ -1195,7 +1195,7 @@ 
 				}
 				else
 				{
-					if (!preg_match('/'.$rule['host_name'].'/',$this->trap_data['source_name']))
+					if (!preg_match('/'.$rule['host_name'].'/', $this->trap_data['source_name']))
 					{ // only add if not present
 						$this->trap_data['source_name'].=','.$rule['host_name'];
 					}
@@ -1203,13 +1203,13 @@ 
 			}
 			catch (Exception $e) 
 			{ 
-			    $this->trapLog('Error in rule eval : '.$e->getMessage(),WARN,'');
+			    $this->trapLog('Error in rule eval : '.$e->getMessage(), WARN, '');
 			    $this->trap_action.=' ERR : '.$e->getMessage();
 			    $this->trap_data['status']='error';
 			}
 			
 		}
-		if ($this->trap_data['status']=='error')
+		if ($this->trap_data['status'] == 'error')
 		{
 		  $this->trap_to_db=true; // Always put errors in DB for the use can see
 		}
@@ -1225,13 +1225,13 @@ 
 	public function add_rule_final($time)
 	{
 		$db_conn=$this->db_connect_trap();
-		if ($this->trap_action==null) 
+		if ($this->trap_action == null) 
 		{
 			$this->trap_action='No action';
 		}
 		$sql="UPDATE ".$this->db_prefix."received SET process_time = '".$time."' , status_detail='".$this->trap_action."'  WHERE (id = '".$this->trap_id."');";
 		if ($db_conn->query($sql) === false) {
-			$this->trapLog('Error in update query : ' . $sql,WARN,'');
+			$this->trapLog('Error in update query : '.$sql, WARN, '');
 		}
 	}
 	
@@ -1241,14 +1241,14 @@ 
 	*	@param $schema_file	string File to read schema from
 	*	@param $table_prefix string to replace #PREFIX# in schema file by this
 	*/
-	public function create_schema($schema_file,$table_prefix)
+	public function create_schema($schema_file, $table_prefix)
 	{
 		//Read data from snmptrapd from stdin
 		$input_stream=fopen($schema_file, 'r');
 
-		if ($input_stream=== false)
+		if ($input_stream === false)
 		{
-			$this->trapLog("Error reading schema !",ERROR,''); 
+			$this->trapLog("Error reading schema !", ERROR, ''); 
 			return;
 		}
 		$newline='';
@@ -1258,14 +1258,14 @@ 
 		
 		while (($line=fgets($input_stream)) !== false)
 		{
-			$newline.=chop(preg_replace('/#PREFIX#/',$table_prefix,$line));
+			$newline.=chop(preg_replace('/#PREFIX#/', $table_prefix, $line));
 			if (preg_match('/; *$/', $newline)) 
             {
-                $sql= $newline;
+                $sql=$newline;
                 if ($db_conn->query($sql) === false) {
-                    $this->trapLog('Error create schema : '.$sql,ERROR,'');
+                    $this->trapLog('Error create schema : '.$sql, ERROR, '');
                 }
-                if (preg_match('/^ *CREATE TABLE ([^ ]+)/',$newline,$cur_table_array))
+                if (preg_match('/^ *CREATE TABLE ([^ ]+)/', $newline, $cur_table_array))
                 {
                     $cur_table='table '.$cur_table_array[1];
                 }
@@ -1273,19 +1273,19 @@ 
                 {
                     $cur_table='secret SQL stuff :-)';
                 }
-                $this->trapLog('Creating : ' . $cur_table,INFO );
+                $this->trapLog('Creating : '.$cur_table, INFO);
                 $newline='';
             }
 		}
 		
-		$sql= $newline;
+		$sql=$newline;
 		if ($sql != '')
 		{
     		if ($db_conn->query($sql) === false) {
-    			$this->trapLog('Error create schema : '.$sql,ERROR,'');
+    			$this->trapLog('Error create schema : '.$sql, ERROR, '');
     		}
 		}
-		$this->trapLog('Schema created',INFO);		
+		$this->trapLog('Schema created', INFO);		
 	}
 
 	/** 
@@ -1296,14 +1296,14 @@ 
 	 *     @param bool $getmsg : only get messages from version upgrades
 	 *     @return string : if $getmsg=true, return messages.
 	 */
-	public function update_schema($prefix,$target_version,$table_prefix,$getmsg=false)
+	public function update_schema($prefix, $target_version, $table_prefix, $getmsg=false)
 	{
 	    // Get current db number
 	    $db_conn=$this->db_connect_trap();
 	    $sql='SELECT id,value from '.$this->db_prefix.'db_config WHERE name=\'db_version\' ';
-	    $this->trapLog('SQL query : '.$sql,DEBUG );
+	    $this->trapLog('SQL query : '.$sql, DEBUG);
 	    if (($ret_code=$db_conn->query($sql)) === false) {
-	        $this->trapLog('Cannot get db version. Query : ' . $sql,2,'');
+	        $this->trapLog('Cannot get db version. Query : '.$sql, 2, '');
 	        return;
 	    }
 	    $version=$ret_code->fetchAll();
@@ -1312,47 +1312,47 @@ 
 	    
 	    if ($this->trapDBType == 'pgsql')
 	    {
-	        $prefix .= 'update_pgsql/schema_';
+	        $prefix.='update_pgsql/schema_';
 	    }
 	    else
 	    {
-	        $prefix .= 'update_sql/schema_';
+	        $prefix.='update_sql/schema_';
 	    }
 	    //echo "version all :\n";print_r($version);echo " \n $cur_ver \n";
 	    if ($getmsg === true)
 	    {
 	        $message='';
-	        $this->trapLog('getting message for upgrade',DEBUG );
-	        while($cur_version<$target_version)
+	        $this->trapLog('getting message for upgrade', DEBUG);
+	        while ($cur_version < $target_version)
 	        {
 	            $cur_version++;
-	            $updateFile=$prefix.'v'.($cur_version-1).'_v'.$cur_version.'.sql';
+	            $updateFile=$prefix.'v'.($cur_version - 1).'_v'.$cur_version.'.sql';
 	            $input_stream=fopen($updateFile, 'r');
-	            if ($input_stream=== false)
+	            if ($input_stream === false)
 	            {
-	                $this->trapLog("Error reading update file ". $updateFile,2,'');
+	                $this->trapLog("Error reading update file ".$updateFile, 2, '');
 	                return;
 	            }
 	            do { $line=fgets($input_stream); }
-	            while ($line !== false && !preg_match('/#MESSAGE/',$line));
+	            while ($line !== false && !preg_match('/#MESSAGE/', $line));
 	            if ($line === false)
 	            {
-	                $this->trapLog("No message in file ". $updateFile,2,'');
+	                $this->trapLog("No message in file ".$updateFile, 2, '');
 	                return;
 	            }
-	            $message .= ($cur_version-1) . '->' . $cur_version. ' : ' . preg_replace('/#MESSAGE : /','',$line)."\n";
+	            $message.=($cur_version - 1).'->'.$cur_version.' : '.preg_replace('/#MESSAGE : /', '', $line)."\n";
 	        }
 	        return $message;
 	    }
-	    while($cur_version<$target_version)
+	    while ($cur_version < $target_version)
 	    { // tODO : execute pre & post scripts
 	       $cur_version++;
-	       $this->trapLog('Updating to version : ' .$cur_version ,INFO );
-	       $updateFile=$prefix.'v'.($cur_version-1).'_v'.$cur_version.'.sql';
+	       $this->trapLog('Updating to version : '.$cur_version, INFO);
+	       $updateFile=$prefix.'v'.($cur_version - 1).'_v'.$cur_version.'.sql';
 	       $input_stream=fopen($updateFile, 'r');
-	       if ($input_stream=== false)
+	       if ($input_stream === false)
 	       {
-	           $this->trapLog("Error reading update file ". $updateFile,2,'');
+	           $this->trapLog("Error reading update file ".$updateFile, 2, '');
 	           return;
 	       }
 	       $newline='';
@@ -1361,24 +1361,24 @@ 
 	       while (($line=fgets($input_stream)) !== false)
 	       {
 	           if (preg_match('/^#/', $line)) continue; // ignore comment lines
-	           $newline.=chop(preg_replace('/#PREFIX#/',$table_prefix,$line));
+	           $newline.=chop(preg_replace('/#PREFIX#/', $table_prefix, $line));
 	           if (preg_match('/; *$/', $newline))
 	           {
 	               $sql_req=$db_conn->prepare($newline);
 	               if ($sql_req->execute() === false) {
-	                   $this->trapLog('Error create schema : '.$newline,1,'');
+	                   $this->trapLog('Error create schema : '.$newline, 1, '');
 	               }
 	               $cur_table_array=array();
-	               if (preg_match('/^ *([^ ]+) TABLE ([^ ]+)/',$newline,$cur_table_array))
+	               if (preg_match('/^ *([^ ]+) TABLE ([^ ]+)/', $newline, $cur_table_array))
 	               {
-	                   $cur_table=$cur_table_array[1] . ' SQL table '.$cur_table_array[2];
+	                   $cur_table=$cur_table_array[1].' SQL table '.$cur_table_array[2];
 	               }
 	               else
 	               {
 	                   $cur_table='secret SQL stuff :-)';
 	                   //$cur_table=$newline;
 	               }
-	               $this->trapLog('Doing : ' . $cur_table,INFO );
+	               $this->trapLog('Doing : '.$cur_table, INFO);
 	               
 	               $newline='';
 	           }
@@ -1391,13 +1391,13 @@ 
 	       //}
 	       
 	       $sql='UPDATE '.$this->db_prefix.'db_config SET value='.$cur_version.' WHERE ( id = '.$db_version_id.' )';
-	       $this->trapLog('SQL query : '.$sql,DEBUG );
+	       $this->trapLog('SQL query : '.$sql, DEBUG);
 	       if ($db_conn->query($sql) === false) {
-	           $this->trapLog('Cannot update db version. Query : ' . $sql,2);
+	           $this->trapLog('Cannot update db version. Query : '.$sql, 2);
 	           return;
 	       }
 	       
-	       $this->trapLog('Schema updated to version : '.$cur_version ,INFO);
+	       $this->trapLog('Schema updated to version : '.$cur_version, INFO);
 	    }
 	}
 	
@@ -1418,7 +1418,7 @@ 
     WHERE s.current_state != 0;";
 		$db_conn=$this->db_connect_ido();
 		if (($services_db=$db_conn->query($sql_query)) === false) { // set err to 1 to throw exception.
-			$this->trapLog('No result in query : ' . $sql_query,ERROR,'');
+			$this->trapLog('No result in query : '.$sql_query, ERROR, '');
 		}
 		$services=$services_db->fetchAll();
 		
@@ -1426,7 +1426,7 @@ 
 		$sql_query="SELECT host_name, service_name, revert_ok FROM ".$this->db_prefix."rules where revert_ok != 0;";
 		$db_conn2=$this->db_connect_trap();
 		if (($rules_db=$db_conn2->query($sql_query)) === false) {
-			$this->trapLog('No result in query : ' . $sql_query,ERROR,''); 
+			$this->trapLog('No result in query : '.$sql_query, ERROR, ''); 
 		}
 		$rules=$rules_db->fetchAll();
 		
@@ -1441,13 +1441,13 @@ 
 					$service['host_name'] == $rule['host_name'] &&
 					($service['last_check'] + $rule['revert_ok']) < $now)
 				{
-					$this->serviceCheckResult($service['host_name'],$service['service_name'],0,'Reset service to OK after '.$rule['revert_ok'].' seconds');
+					$this->serviceCheckResult($service['host_name'], $service['service_name'], 0, 'Reset service to OK after '.$rule['revert_ok'].' seconds');
 					$numreset++;
 				}
 			}
 		}
 		echo "\n";
-		echo $numreset . " service(s) reset to OK\n";
+		echo $numreset." service(s) reset to OK\n";
 		return 0;
 		
 	}
@@ -1468,7 +1468,7 @@ 
 	 * @param string $description
 	 * @return number : 0=unchanged, 1 = changed, 2=created
 	 */
-	public function update_oid($oid,$mib,$name,$type,$textConv,$dispHint,$syntax,$type_enum,$description=NULL)
+	public function update_oid($oid, $mib, $name, $type, $textConv, $dispHint, $syntax, $type_enum, $description=NULL)
 	{
 		$db_conn=$this->db_connect_trap();
 		$description=$db_conn->quote($description);
@@ -1478,7 +1478,7 @@ 
 		    { // newly created.
 		        return 0;
 		    }
-			if ( $name != $this->dbOidAll[$this->dbOidIndex[$oid]['key']]['name'] ||
+			if ($name != $this->dbOidAll[$this->dbOidIndex[$oid]['key']]['name'] ||
 			    $mib != $this->dbOidAll[$this->dbOidIndex[$oid]['key']]['mib'] ||
 			    $type != $this->dbOidAll[$this->dbOidIndex[$oid]['key']]['type'] //||
 			    //$textConv != $this->dbOidAll[$this->dbOidIndex[$oid]['key']]['textual_convention'] //||
@@ -1498,23 +1498,23 @@ 
 			        ':name' => $name,
 			        ':type' => $type, 
 			        ':mib' => $mib, 
-			        ':tc' =>  ($textConv==null)?'null':$textConv , 
-			        ':display_hint' => ($dispHint==null)?'null':$dispHint ,
-			        ':syntax' => ($syntax==null)?'null':$syntax,
-			        ':type_enum' => ($type_enum==null)?'null':$type_enum, 
-			        ':description' => ($description==null)?'null':$description,
+			        ':tc' =>  ($textConv == null) ? 'null' : $textConv, 
+			        ':display_hint' => ($dispHint == null) ? 'null' : $dispHint,
+			        ':syntax' => ($syntax == null) ? 'null' : $syntax,
+			        ':type_enum' => ($type_enum == null) ? 'null' : $type_enum, 
+			        ':description' => ($description == null) ? 'null' : $description,
 			        ':id' => $this->dbOidAll[$this->dbOidIndex[$oid]['id']]
 			    );
 			    
 			    if ($sqlQuery->execute($sqlParam) === false) {
-			        $this->trapLog('Error in query : ' . $sql,ERROR,'');
+			        $this->trapLog('Error in query : '.$sql, ERROR, '');
 			    }
-			    $this->trapLog('Trap updated : '.$name . ' / OID : '.$oid,DEBUG );
+			    $this->trapLog('Trap updated : '.$name.' / OID : '.$oid, DEBUG);
 				return 1;
 			}
 			else
 			{
-			    $this->trapLog('Trap unchanged : '.$name . ' / OID : '.$oid,DEBUG );
+			    $this->trapLog('Trap unchanged : '.$name.' / OID : '.$oid, DEBUG);
 			    return 0;
 			}
 		}
@@ -1524,11 +1524,11 @@ 
 
 		$sql='INSERT INTO '.$this->db_prefix.'mib_cache '.
 		      '(oid, name, type , mib, textual_convention, display_hint '.
-              ', syntax, type_enum , description ) ' . 
+              ', syntax, type_enum , description ) '. 
               'values (:oid, :name , :type ,:mib ,:tc , :display_hint'.
               ', :syntax, :type_enum, :description )';
         
-		if ($this->trapDBType == 'pgsql') $sql .= 'RETURNING id';
+		if ($this->trapDBType == 'pgsql') $sql.='RETURNING id';
 		
 		$sqlQuery=$db_conn->prepare($sql);
 		
@@ -1537,15 +1537,15 @@ 
 		    ':name' => $name,
 		    ':type' => $type,
 		    ':mib' => $mib,
-		    ':tc' =>  ($textConv==null)?'null':$textConv ,
-		    ':display_hint' => ($dispHint==null)?'null':$dispHint ,
-		    ':syntax' => ($syntax==null)?'null':$syntax,
-		    ':type_enum' => ($type_enum==null)?'null':$type_enum,
-		    ':description' => ($description==null)?'null':$description
+		    ':tc' =>  ($textConv == null) ? 'null' : $textConv,
+		    ':display_hint' => ($dispHint == null) ? 'null' : $dispHint,
+		    ':syntax' => ($syntax == null) ? 'null' : $syntax,
+		    ':type_enum' => ($type_enum == null) ? 'null' : $type_enum,
+		    ':description' => ($description == null) ? 'null' : $description
 		);
 		
 		if ($sqlQuery->execute($sqlParam) === false) {
-		    $this->trapLog('Error in query : ' . $sql,1,'');
+		    $this->trapLog('Error in query : '.$sql, 1, '');
 		}
 		
 		switch ($this->trapDBType)
@@ -1553,10 +1553,10 @@ 
 		    case 'pgsql':
 		        // Get last id to insert oid/values in secondary table
 		        if (($inserted_id_ret=$sqlQuery->fetch(PDO::FETCH_ASSOC)) === false) {		            
-		            $this->trapLog('Error getting id - pgsql - ',1,'');
+		            $this->trapLog('Error getting id - pgsql - ', 1, '');
 		        }
-		        if (! isset($inserted_id_ret['id'])) {
-		            $this->trapLog('Error getting id - pgsql - empty.',1,'');
+		        if (!isset($inserted_id_ret['id'])) {
+		            $this->trapLog('Error getting id - pgsql - empty.', 1, '');
 		        }
 		        $this->dbOidIndex[$oid]['id']=$inserted_id_ret['id'];
 		        break;
@@ -1564,15 +1564,15 @@ 
 		        // Get last id to insert oid/values in secondary table
 		        $sql='SELECT LAST_INSERT_ID();';
 		        if (($ret_code=$db_conn->query($sql)) === false) {
-		            $this->trapLog('Erreur getting id - mysql - ',1,'');
+		            $this->trapLog('Erreur getting id - mysql - ', 1, '');
 		        }
 		        
 		        $inserted_id=$ret_code->fetch(PDO::FETCH_ASSOC)['LAST_INSERT_ID()'];
-		        if ($inserted_id==false) throw new Exception("Weird SQL error : last_insert_id returned false : open issue");
+		        if ($inserted_id == false) throw new Exception("Weird SQL error : last_insert_id returned false : open issue");
 		        $this->dbOidIndex[$oid]['id']=$inserted_id;
 		        break;
 		    default:
-		        $this->trapLog('Error SQL type  : '.$this->trapDBType,1,'');
+		        $this->trapLog('Error SQL type  : '.$this->trapDBType, 1, '');
 		}
 
 		// Set as newly created.
@@ -1587,21 +1587,21 @@ 
      * @param array $objects : array of objects name (without MIB)
      * @param bool $check_existing : check instead of create
      */
-	public function trap_objects($trapOID,$trapmib,$objects,$check_existing)
+	public function trap_objects($trapOID, $trapmib, $objects, $check_existing)
 	{
 	    $dbObjects=null; // cache of objects for trap in db
 	    $db_conn=$this->db_connect_trap();
 	    
 	    // Get id of trapmib.
 
-	    $trapId = $this->dbOidIndex[$trapOID]['id'];
+	    $trapId=$this->dbOidIndex[$trapOID]['id'];
 	    if ($check_existing === true)
 	    {
 	        // Get all objects
 	        $sql='SELECT * FROM '.$this->db_prefix.'mib_cache_trap_object where trap_id='.$trapId.';';
-	        $this->trapLog('SQL query get all traps: '.$sql,DEBUG );
+	        $this->trapLog('SQL query get all traps: '.$sql, DEBUG);
 	        if (($ret_code=$db_conn->query($sql)) === false) {
-	            $this->trapLog('No result in query : ' . $sql,1,'');
+	            $this->trapLog('No result in query : '.$sql, 1, '');
 	        }
 	        $dbObjectsRaw=$ret_code->fetchAll();
 	        
@@ -1615,39 +1615,39 @@ 
 	        $match=$snmptrans=array();
 	        $retVal=0;
 	        $objOid=$objTc=$objDispHint=$objSyntax=$objDesc=$objEnum=NULL;
-	        $tmpdesc='';$indesc=false;
+	        $tmpdesc=''; $indesc=false;
 	        
 	        $objMib=$trapmib;
-	        exec($this->snmptranslate . ' -m ALL -M +'.$this->snmptranslate_dirs.
-	            ' -On -Td '.$objMib.'::'.$object . ' 2>/dev/null',$snmptrans,$retVal);
-	        if ($retVal!=0)
+	        exec($this->snmptranslate.' -m ALL -M +'.$this->snmptranslate_dirs.
+	            ' -On -Td '.$objMib.'::'.$object.' 2>/dev/null', $snmptrans, $retVal);
+	        if ($retVal != 0)
 	        {
 	            // Maybe not trap mib, search with IR
-	            exec($this->snmptranslate . ' -m ALL -M +'.$this->snmptranslate_dirs.
-	                ' -IR '.$object . ' 2>/dev/null',$snmptrans,$retVal);
-	            if ($retVal != 0 || !preg_match('/(.*)::(.*)/',$snmptrans[0],$match))
+	            exec($this->snmptranslate.' -m ALL -M +'.$this->snmptranslate_dirs.
+	                ' -IR '.$object.' 2>/dev/null', $snmptrans, $retVal);
+	            if ($retVal != 0 || !preg_match('/(.*)::(.*)/', $snmptrans[0], $match))
 	            { // Not found -> continue with warning
-	               $this->trapLog('Error finding trap object : '.$trapmib.'::'.$object,2,'');
+	               $this->trapLog('Error finding trap object : '.$trapmib.'::'.$object, 2, '');
 	               continue;
 	            }
 	            $objMib=$match[1];
 	            
 	            // Do the snmptranslate again.
-	            exec($this->snmptranslate . ' -m ALL -M +'.$this->snmptranslate_dirs.
-	                ' -On -Td '.$objMib.'::'.$object,$snmptrans,$retVal);
-	            if ($retVal!=0) {
-	                $this->trapLog('Error finding trap object : '.$objMib.'::'.$object,2,'');
+	            exec($this->snmptranslate.' -m ALL -M +'.$this->snmptranslate_dirs.
+	                ' -On -Td '.$objMib.'::'.$object, $snmptrans, $retVal);
+	            if ($retVal != 0) {
+	                $this->trapLog('Error finding trap object : '.$objMib.'::'.$object, 2, '');
 	            }
 	            
 	        }
 	        foreach ($snmptrans as $line)
 	        {
-	            if ($indesc===true)
+	            if ($indesc === true)
 	            {
-	                $line=preg_replace('/[\t ]+/',' ',$line);
-	                if (preg_match('/(.*)"$/', $line,$match))
+	                $line=preg_replace('/[\t ]+/', ' ', $line);
+	                if (preg_match('/(.*)"$/', $line, $match))
 	                {
-	                    $objDesc = $tmpdesc . $match[1];
+	                    $objDesc=$tmpdesc.$match[1];
 	                    $indesc=false;
 	                }
 	                $tmpdesc.=$line;
@@ -1658,43 +1658,43 @@ 
 	                $objOid=$line;
 	                continue;
 	            }
-	            if (preg_match('/^[\t ]+SYNTAX[\t ]+([^{]*) \{(.*)\}/',$line,$match))
+	            if (preg_match('/^[\t ]+SYNTAX[\t ]+([^{]*) \{(.*)\}/', $line, $match))
 	            {
 	                $objSyntax=$match[1];
                     $objEnum=$match[2];
 	                continue;
 	            }
-	            if (preg_match('/^[\t ]+SYNTAX[\t ]+(.*)/',$line,$match))
+	            if (preg_match('/^[\t ]+SYNTAX[\t ]+(.*)/', $line, $match))
 	            {
 	                $objSyntax=$match[1];
 	                continue;
 	            }
-	            if (preg_match('/^[\t ]+DISPLAY-HINT[\t ]+"(.*)"/',$line,$match))
+	            if (preg_match('/^[\t ]+DISPLAY-HINT[\t ]+"(.*)"/', $line, $match))
 	            {
 	                $objDispHint=$match[1];
 	                continue;
 	            }
-	            if (preg_match('/^[\t ]+DESCRIPTION[\t ]+"(.*)"/',$line,$match))
+	            if (preg_match('/^[\t ]+DESCRIPTION[\t ]+"(.*)"/', $line, $match))
 	            {
 	                $objDesc=$match[1];
 	                continue;
 	            }
-	            if (preg_match('/^[\t ]+DESCRIPTION[\t ]+"(.*)/',$line,$match))
+	            if (preg_match('/^[\t ]+DESCRIPTION[\t ]+"(.*)/', $line, $match))
 	            {
 	                $tmpdesc=$match[1];
 	                $indesc=true;
 	                continue;
 	            }
-	            if (preg_match('/^[\t ]+-- TEXTUAL CONVENTION[\t ]+(.*)/',$line,$match))
+	            if (preg_match('/^[\t ]+-- TEXTUAL CONVENTION[\t ]+(.*)/', $line, $match))
 	            {
 	                $objTc=$match[1];
 	                continue;
 	            }
 	        }
-	        $this->trapLog("Adding trap $object : $objOid / $objSyntax / $objEnum / $objDispHint / $objTc",DEBUG );
+	        $this->trapLog("Adding trap $object : $objOid / $objSyntax / $objEnum / $objDispHint / $objTc", DEBUG);
 	        //echo "$object : $objOid / $objSyntax / $objEnum / $objDispHint / $objTc / $objDesc\n";
 	        // Update 
-	        $this->update_oid($objOid, $objMib, $object, '3', $objTc, $objDispHint, $objSyntax, $objEnum,$objDesc);
+	        $this->update_oid($objOid, $objMib, $object, '3', $objTc, $objDispHint, $objSyntax, $objEnum, $objDesc);
             
 	        if (isset($dbObjects[$this->dbOidIndex[$objOid]['id']]))
 	        {   // if link exists, continue
@@ -1715,7 +1715,7 @@ 
 	        );
 	        
 	        if ($sqlQuery->execute($sqlParam) === false) {
-	            $this->trapLog('Error adding trap object : ' . $sql . ' / ' . $trapId . '/'. $this->dbOidIndex[$objOid]['id'] ,1,'');
+	            $this->trapLog('Error adding trap object : '.$sql.' / '.$trapId.'/'.$this->dbOidIndex[$objOid]['id'], 1, '');
 	        }
 	    }
 	    if ($check_existing === true)
@@ -1732,19 +1732,19 @@ 
 	 * @param boolean $onlyTraps : only cache traps and objects (true) or all (false)
 	 * @param string $startOID : only cache under startOID (NOT IMPLEMENTED)
 	*/	
-	public function update_mib_database($display_progress=false,$check_change=false,$onlyTraps=true,$startOID='.1')
+	public function update_mib_database($display_progress=false, $check_change=false, $onlyTraps=true, $startOID='.1')
 	{
 		// Timing 
-		$timeTaken = microtime(true);
+		$timeTaken=microtime(true);
 		$retVal=0;
 		// Get all mib objects from all mibs
-		$snmpCommand=$this->snmptranslate . ' -m ALL -M +'.$this->snmptranslate_dirs.' -On -Tto 2>/dev/null';
-		$this->trapLog('Getting all traps : '.$snmpCommand,DEBUG );
+		$snmpCommand=$this->snmptranslate.' -m ALL -M +'.$this->snmptranslate_dirs.' -On -Tto 2>/dev/null';
+		$this->trapLog('Getting all traps : '.$snmpCommand, DEBUG);
 		unset($this->objectsAll);
-		exec($snmpCommand,$this->objectsAll,$retVal);		
-		if ($retVal!=0)
+		exec($snmpCommand, $this->objectsAll, $retVal);		
+		if ($retVal != 0)
 		{
-			$this->trapLog('error executing snmptranslate',ERROR,'');
+			$this->trapLog('error executing snmptranslate', ERROR, '');
 		}
 		
 		// Get all mibs from databse to have a memory index
@@ -1752,14 +1752,14 @@ 
 		$db_conn=$this->db_connect_trap();
 		
 		$sql='SELECT * from '.$this->db_prefix.'mib_cache;';
-		$this->trapLog('SQL query : '.$sql,DEBUG );
+		$this->trapLog('SQL query : '.$sql, DEBUG);
 		if (($ret_code=$db_conn->query($sql)) === false) {
-			$this->trapLog('No result in query : ' . $sql,ERROR,'');
+			$this->trapLog('No result in query : '.$sql, ERROR, '');
 		}
 		$this->dbOidAll=$ret_code->fetchAll();
 		$this->dbOidIndex=array();
 		// Create the index for db;
-		foreach($this->dbOidAll as $key=>$val)
+		foreach ($this->dbOidAll as $key=>$val)
 		{
 			$this->dbOidIndex[$val['oid']]['key']=$key;
 			$this->dbOidIndex[$val['oid']]['id']=$val['id'];
@@ -1767,11 +1767,11 @@ 
 		
 		// Count elements to show progress
 		$numElements=count($this->objectsAll);
-		$this->trapLog('Total snmp objects returned by snmptranslate : '.$numElements,INFO );
+		$this->trapLog('Total snmp objects returned by snmptranslate : '.$numElements, INFO);
 		
-		$step=$basestep=$numElements/10; // output display of % done
+		$step=$basestep=$numElements / 10; // output display of % done
 		$num_step=0;
-		$timeFiveSec = microtime(true); // Used for display a '.' every <n> seconds
+		$timeFiveSec=microtime(true); // Used for display a '.' every <n> seconds
 		
 		// Create index for trap objects
 		$this->trapObjectsIndex=array();
@@ -1781,28 +1781,28 @@ 
 		$time_parse1N=$time_check1N=$time_check2N=$time_check3N=$time_updateN=$time_objectsN=0;
 		$time_num_traps=0;
 		
-		for ($curElement=0;$curElement < $numElements;$curElement++)
+		for ($curElement=0; $curElement < $numElements; $curElement++)
 		{
-		    $time_1= microtime(true);
-			if ((microtime(true)-$timeFiveSec) > 2 && $display_progress)
+		    $time_1=microtime(true);
+			if ((microtime(true) - $timeFiveSec) > 2 && $display_progress)
 			{ // echo a . every 2 sec
 				echo '.';
-				$timeFiveSec = microtime(true);
+				$timeFiveSec=microtime(true);
 			}
-			if ($curElement>$step) 
+			if ($curElement > $step) 
 			{ // display progress
 				$num_step++;
 				$step+=$basestep;
 				if ($display_progress)
 				{				
-					echo "\n" . ($num_step*10). '% : ';
+					echo "\n".($num_step * 10).'% : ';
 				}
 			}
 			// Get oid or pass if not found
-			if (!preg_match('/^\.[0-9\.]+$/',$this->objectsAll[$curElement]))
+			if (!preg_match('/^\.[0-9\.]+$/', $this->objectsAll[$curElement]))
 			{
-			    $time_parse1 += microtime(true) - $time_1;
-			    $time_parse1N ++;
+			    $time_parse1+=microtime(true) - $time_1;
+			    $time_parse1N++;
 				continue;
 			}
 			$oid=$this->objectsAll[$curElement];
@@ -1811,9 +1811,9 @@ 
 			$curElement++;
 			$match=$snmptrans=array();
 			if (!preg_match('/ +([^\(]+)\(.+\) type=([0-9]+)( tc=([0-9]+))?( hint=(.+))?/',
-						$this->objectsAll[$curElement],$match))
+						$this->objectsAll[$curElement], $match))
 			{
-			    $time_check1 += microtime(true) - $time_1;
+			    $time_check1+=microtime(true) - $time_1;
 				$time_check1N++;
 				continue;
 			}
@@ -1821,21 +1821,21 @@ 
 			$name=$match[1]; // Name 
 			$type=$match[2]; // type (21=trap, 0: may be trap, else : not trap
 			
-			if ($type==0) // object type=0 : check if v1 trap
+			if ($type == 0) // object type=0 : check if v1 trap
 			{
 				// Check if next is suboid -> in that case is cannot be a trap
-				if (preg_match("/^$oid/",$this->objectsAll[$curElement+1]))
+				if (preg_match("/^$oid/", $this->objectsAll[$curElement + 1]))
 				{
-				    $time_check2 += microtime(true) - $time_1;
+				    $time_check2+=microtime(true) - $time_1;
 				    $time_check2N++;
 					continue;
 				}		
 				unset($snmptrans);
-				exec($this->snmptranslate . ' -m ALL -M +'.$this->snmptranslate_dirs.
-					' -Td '.$oid . ' | grep OBJECTS ',$snmptrans,$retVal);
-				if ($retVal!=0)
+				exec($this->snmptranslate.' -m ALL -M +'.$this->snmptranslate_dirs.
+					' -Td '.$oid.' | grep OBJECTS ', $snmptrans, $retVal);
+				if ($retVal != 0)
 				{
-				    $time_check2 += microtime(true) - $time_1;
+				    $time_check2+=microtime(true) - $time_1;
 				    $time_check2N++;
 					continue;
 				}
@@ -1843,56 +1843,56 @@ 
 				// Force as trap.
 				$type=21;
 			}
-			if ($onlyTraps===true && $type!=21) // if only traps and not a trap, continue
+			if ($onlyTraps === true && $type != 21) // if only traps and not a trap, continue
 			{
-			    $time_check3 += microtime(true) - $time_1;
+			    $time_check3+=microtime(true) - $time_1;
 				$time_check3N++;
 				continue;
 			}
 			
 			$time_num_traps++;
 			
-			$this->trapLog('Found trap : '.$match[1] . ' / OID : '.$oid,INFO );
+			$this->trapLog('Found trap : '.$match[1].' / OID : '.$oid, INFO);
 			if ($display_progress) echo '#'; // echo a # when trap found
 				
 			// get trap objects & source MIB
 			unset($snmptrans);
-			exec($this->snmptranslate . ' -m ALL -M +'.$this->snmptranslate_dirs.
-					' -Td '.$oid,$snmptrans,$retVal);
-			if ($retVal!=0)
+			exec($this->snmptranslate.' -m ALL -M +'.$this->snmptranslate_dirs.
+					' -Td '.$oid, $snmptrans, $retVal);
+			if ($retVal != 0)
 			{
-				$this->trapLog('error executing snmptranslate',ERROR,'');
+				$this->trapLog('error executing snmptranslate', ERROR, '');
 			}
 			
-			if (!preg_match('/^(.*)::/',$snmptrans[0],$match))
+			if (!preg_match('/^(.*)::/', $snmptrans[0], $match))
 			{
-			    $this->trapLog('Error getting mib from trap '.$oid.' : ' . $snmptrans[0],1,'');
+			    $this->trapLog('Error getting mib from trap '.$oid.' : '.$snmptrans[0], 1, '');
 			}
 			$trapMib=$match[1];
 			
-			$numLine=1;$trapDesc='';
-			while (isset($snmptrans[$numLine]) && !preg_match('/^[\t ]+DESCRIPTION[\t ]+"(.*)/',$snmptrans[$numLine],$match)) $numLine++;
+			$numLine=1; $trapDesc='';
+			while (isset($snmptrans[$numLine]) && !preg_match('/^[\t ]+DESCRIPTION[\t ]+"(.*)/', $snmptrans[$numLine], $match)) $numLine++;
 			if (isset($snmptrans[$numLine]))
 			{
-			    $snmptrans[$numLine] = preg_replace('/^[\t ]+DESCRIPTION[\t ]+"/','',$snmptrans[$numLine]);
+			    $snmptrans[$numLine]=preg_replace('/^[\t ]+DESCRIPTION[\t ]+"/', '', $snmptrans[$numLine]);
 
-			    while (isset($snmptrans[$numLine]) && !preg_match('/"/',$snmptrans[$numLine]))
+			    while (isset($snmptrans[$numLine]) && !preg_match('/"/', $snmptrans[$numLine]))
 			    {
-			        $trapDesc.=preg_replace('/[\t ]+/',' ',$snmptrans[$numLine]);
+			        $trapDesc.=preg_replace('/[\t ]+/', ' ', $snmptrans[$numLine]);
 			        $numLine++;
 			    }
 			    if (isset($snmptrans[$numLine])) {
-			        $trapDesc.=preg_replace('/".*/','',$snmptrans[$numLine]);
-			        $trapDesc=preg_replace('/[\t ]+/',' ',$trapDesc);
+			        $trapDesc.=preg_replace('/".*/', '', $snmptrans[$numLine]);
+			        $trapDesc=preg_replace('/[\t ]+/', ' ', $trapDesc);
 			    }
 
 			}
-			$update=$this->update_oid($oid,$trapMib,$name,$type,NULL,NULL,NULL,NULL,$trapDesc);
-			$time_update += microtime(true) - $time_1; $time_1= microtime(true);
+			$update=$this->update_oid($oid, $trapMib, $name, $type, NULL, NULL, NULL, NULL, $trapDesc);
+			$time_update+=microtime(true) - $time_1; $time_1=microtime(true);
 			
-			if (($update==0) && ($check_change===false))
+			if (($update == 0) && ($check_change === false))
 			{ // Trapd didn't change & force check disabled
-			    $time_objects += microtime(true) - $time_1;
+			    $time_objects+=microtime(true) - $time_1;
 			    if ($display_progress) echo "C";
 			    continue;
 			}
@@ -1900,7 +1900,7 @@ 
 			$synt=null;
 			foreach ($snmptrans as $line)
 			{	
-    			if (preg_match('/OBJECTS.*\{([^\}]+)\}/',$line,$match))
+    			if (preg_match('/OBJECTS.*\{([^\}]+)\}/', $line, $match))
     				{
     					$synt=$match[1];
     				}
@@ -1908,30 +1908,30 @@ 
 			if ($synt == null) 
 			{
 				//echo "No objects for $trapOID\n";
-			    $time_objects += microtime(true) - $time_1;
+			    $time_objects+=microtime(true) - $time_1;
 				continue;
 			}
 			//echo "$synt \n";
 			$trapObjects=array();
-			while (preg_match('/ *([^ ,]+) *,* */',$synt,$match))
+			while (preg_match('/ *([^ ,]+) *,* */', $synt, $match))
 			{
-				array_push($trapObjects,$match[1]);
-				$synt=preg_replace('/'.$match[0].'/','',$synt);
+				array_push($trapObjects, $match[1]);
+				$synt=preg_replace('/'.$match[0].'/', '', $synt);
 			}
 			
 			$this->trap_objects($oid, $trapMib, $trapObjects, false);
 			
-			$time_objects += microtime(true) - $time_1;
+			$time_objects+=microtime(true) - $time_1;
 			$time_objectsN++;
 		}
 		
 		if ($display_progress)
 		{
     		echo "\nNumber of processed traps : $time_num_traps \n";
-    		echo "\nParsing : " . number_format($time_parse1+$time_check1,1) ." sec / " . ($time_parse1N+ $time_check1N)  . " occurences\n";
-    		echo "Detecting traps : " . number_format($time_check2+$time_check3,1) . " sec / " . ($time_check2N+$time_check3N) ." occurences\n";
-    		echo "Trap processing ($time_updateN): ".number_format($time_update,1)." sec , ";
-    		echo "Objects processing ($time_objectsN) : ".number_format($time_objects,1)." sec \n";
+    		echo "\nParsing : ".number_format($time_parse1 + $time_check1, 1)." sec / ".($time_parse1N + $time_check1N)." occurences\n";
+    		echo "Detecting traps : ".number_format($time_check2 + $time_check3, 1)." sec / ".($time_check2N + $time_check3N)." occurences\n";
+    		echo "Trap processing ($time_updateN): ".number_format($time_update, 1)." sec , ";
+    		echo "Objects processing ($time_objectsN) : ".number_format($time_objects, 1)." sec \n";
 		}
 		
 		// Timing ends