mikopbx / Core

etc/asterisk/agi-bin/cdr_connector.php

Indentation +215 added lines, -215 removed lines

@@ -18,12 +18,12 @@ 
  * @return array
  */
 function Event_dial($agi, $action){
-	$now = Util::get_now_date();
+    $now = Util::get_now_date();
     $data = array();
 	
-	// Уточним канал, на случай очереди.
+    // Уточним канал, на случай очереди.
     $QUEUE_SRC_CHAN = $agi->get_variable("QUEUE_SRC_CHAN", true);
-	$orign_chan     = $agi->get_variable("orign_chan",     true);
+    $orign_chan     = $agi->get_variable("orign_chan",     true);
     $id   	        = $agi->get_variable("pt1c_UNIQUEID",  true);
     $IS_ORGNT   	= $agi->get_variable("IS_ORGNT",       true);
     if($id == '' || !empty($QUEUE_SRC_CHAN)){
@@ -31,13 +31,13 @@ 
         // Если это новый вызов $id == ''.
         $id   = $agi->request['agi_uniqueid'] .'_'. Util::generateRandomString();
     }
-	// Канал, AGI скрипта.
-	$channel 		= $agi->request['agi_channel'];
+    // Канал, AGI скрипта.
+    $channel 		= $agi->request['agi_channel'];
     $is_local       = !(stripos($channel, 'local/') === false);
-	if($QUEUE_SRC_CHAN != '' && $is_local){
-		// Это LOCAL, Переопределим на исходный. 
-		$channel = $QUEUE_SRC_CHAN;
-	}else if($is_local && (stripos($orign_chan, 'local/') === false)){
+    if($QUEUE_SRC_CHAN != '' && $is_local){
+        // Это LOCAL, Переопределим на исходный. 
+        $channel = $QUEUE_SRC_CHAN;
+    }else if($is_local && (stripos($orign_chan, 'local/') === false)){
         $channel = $orign_chan;
     }
 
@@ -68,20 +68,20 @@ 
         $dst_num  	 = $agi->request['agi_extension'];
     }
 
-	$data['src_chan'] 	 = $channel;
-	$data['src_num']  	 = $src_num;
-	$data['dst_num']  	 = $dst_num;
-	$data['start']  	 = $now;
-	$data['linkedid']  	 = $agi->get_variable("CDR(linkedid)", true);
-	$data['UNIQUEID']  	 = $id;
-	$data['transfer']  	 = '0';
-	$data['agi_channel'] = $agi->request['agi_channel'];;
-	$data['did']		 = $agi->get_variable("FROM_DID",  true);
-	$data['from_account']= $from_account;
-	$data['IS_ORGNT']    = !empty($IS_ORGNT);
-
- 	$agi->set_variable("__pt1c_UNIQUEID", "$id");		
-	return $data;
+    $data['src_chan'] 	 = $channel;
+    $data['src_num']  	 = $src_num;
+    $data['dst_num']  	 = $dst_num;
+    $data['start']  	 = $now;
+    $data['linkedid']  	 = $agi->get_variable("CDR(linkedid)", true);
+    $data['UNIQUEID']  	 = $id;
+    $data['transfer']  	 = '0';
+    $data['agi_channel'] = $agi->request['agi_channel'];;
+    $data['did']		 = $agi->get_variable("FROM_DID",  true);
+    $data['from_account']= $from_account;
+    $data['IS_ORGNT']    = !empty($IS_ORGNT);
+
+        $agi->set_variable("__pt1c_UNIQUEID", "$id");		
+    return $data;
 }
 
 /**
@@ -92,17 +92,17 @@ 
  */
 function Event_dial_create_chan($agi, $action){
     $now = Util::get_now_date();
-	$data 	    = [];
-	$id   	    = $agi->get_variable("pt1c_UNIQUEID", true);
-	$data['action']  	 = "$action";
-	$data['dst_chan']	 = $agi->request['agi_channel'];
-	$data['UNIQUEID']	 = $id;
-	$data['linkedid']  	 = $agi->get_variable("CDR(linkedid)", true);
+    $data 	    = [];
+    $id   	    = $agi->get_variable("pt1c_UNIQUEID", true);
+    $data['action']  	 = "$action";
+    $data['dst_chan']	 = $agi->request['agi_channel'];
+    $data['UNIQUEID']	 = $id;
+    $data['linkedid']  	 = $agi->get_variable("CDR(linkedid)", true);
     $data['event_time']  = $now;
 
-	if( stripos($data['dst_chan'], 'local/') === false ){
+    if( stripos($data['dst_chan'], 'local/') === false ){
         $data['to_account']  	= $agi->get_variable('CUT(CUT(CHANNEL(name),,1),/,2)', true);
-	}
+    }
 
     $IS_ORGNT   = $agi->get_variable("IS_ORGNT",       true);
     if(!empty($IS_ORGNT)){
@@ -128,16 +128,16 @@ 
 function Event_dial_answer($agi, $action){
     $now = Util::get_now_date();
 
-	$id   = $agi->get_variable("pt1c_UNIQUEID", true);
-	$data = [];
-	$data['action']  	= "$action";
-	$data['answer']  	= $now;
-	$data['id'] 		= $id;
+    $id   = $agi->get_variable("pt1c_UNIQUEID", true);
+    $data = [];
+    $data['action']  	= "$action";
+    $data['answer']  	= $now;
+    $data['id'] 		= $id;
     $data['dst_num']	= $agi->request['agi_callerid'];
-	$data['agi_channel']= $agi->request['agi_channel'];
-	$data['linkedid']  	= $agi->get_variable("CDR(linkedid)", true);
+    $data['agi_channel']= $agi->request['agi_channel'];
+    $data['linkedid']  	= $agi->get_variable("CDR(linkedid)", true);
 
-	$data['ENDCALLONANSWER']= $agi->get_variable("ENDCALLONANSWER", true);
+    $data['ENDCALLONANSWER']= $agi->get_variable("ENDCALLONANSWER", true);
     $data['BRIDGEPEER']     = $agi->get_variable("FROM_CHAN", true);
 
     $IS_ORGNT   = $agi->get_variable("IS_ORGNT",       true);
@@ -174,7 +174,7 @@ 
     }
     $agi->set_variable("__pt1c_UNIQUEID", "$id");
 
-	return $data;
+    return $data;
 }
 
 /**
@@ -186,17 +186,17 @@ 
 function Event_dial_hangup_DEPRECATED($agi, $action){
     // TODO Удалить эту функцию в будущем.
     $now    = Util::get_now_date();
-	$data 	= array();
-	$data['action']  	 = "$action";
-	$data['end']  		 = $now;
-	$data['id'] 		 = $agi->get_variable("pt1c_UNIQUEID", true);
-	$data['agi_channel'] = $agi->request['agi_channel'];
-	$data['linkedid']  	 = $agi->get_variable("CDR(linkedid)", true);
-	$data['did']		 = $agi->get_variable("FROM_DID", true);
+    $data 	= array();
+    $data['action']  	 = "$action";
+    $data['end']  		 = $now;
+    $data['id'] 		 = $agi->get_variable("pt1c_UNIQUEID", true);
+    $data['agi_channel'] = $agi->request['agi_channel'];
+    $data['linkedid']  	 = $agi->get_variable("CDR(linkedid)", true);
+    $data['did']		 = $agi->get_variable("FROM_DID", true);
 
-	$data['agi_threadid'] = $agi->request['agi_uniqueid'] .'_'. Util::generateRandomString();
+    $data['agi_threadid'] = $agi->request['agi_uniqueid'] .'_'. Util::generateRandomString();
 
-	return $data;
+    return $data;
 }
 
 /**
@@ -207,12 +207,12 @@ 
  */
 function Event_transfer_dial($agi, $action){
     $now = Util::get_now_date();
-	$id   = $agi->request['agi_uniqueid'] .'_'. Util::generateRandomString();
+    $id   = $agi->request['agi_uniqueid'] .'_'. Util::generateRandomString();
 
-	// Пытаемся определить канал.
+    // Пытаемся определить канал.
     $TRANSFERERNAME = $agi->get_variable("TRANSFERERNAME", true);
-	$QUEUE_SRC_CHAN = $agi->get_variable("QUEUE_SRC_CHAN", true);
-	$is_local       = !(stripos($TRANSFERERNAME, 'local/') === false);
+    $QUEUE_SRC_CHAN = $agi->get_variable("QUEUE_SRC_CHAN", true);
+    $is_local       = !(stripos($TRANSFERERNAME, 'local/') === false);
     if( $QUEUE_SRC_CHAN != '' && $is_local ){
         // Это LOCAL, Переопределим на исходный.
         $channel = $QUEUE_SRC_CHAN;
@@ -225,21 +225,21 @@ 
         $channel = $TRANSFERERNAME;
     }
 
-	$data   = array();
-	$data['action']  	= "$action";
-	$data['agi_channel']= $channel;// $agi->request['agi_channel'];
-	$data['linkedid']  	= $agi->get_variable("CDR(linkedid)", true);
-	$data['src_chan'] 	= $channel;
-	$data['did']		= $agi->get_variable("FROM_DID", true);;
-	$data['start']  	= $now;
-	$data['UNIQUEID']  	= $id;	
-	$data['transfer']  	= ($TRANSFERERNAME == '')?'0':'1';
-	$data['src_num']  	= $agi->request['agi_callerid'];
-	$data['dst_num']  	= $agi->request['agi_extension'];
+    $data   = array();
+    $data['action']  	= "$action";
+    $data['agi_channel']= $channel;// $agi->request['agi_channel'];
+    $data['linkedid']  	= $agi->get_variable("CDR(linkedid)", true);
+    $data['src_chan'] 	= $channel;
+    $data['did']		= $agi->get_variable("FROM_DID", true);;
+    $data['start']  	= $now;
+    $data['UNIQUEID']  	= $id;	
+    $data['transfer']  	= ($TRANSFERERNAME == '')?'0':'1';
+    $data['src_num']  	= $agi->request['agi_callerid'];
+    $data['dst_num']  	= $agi->request['agi_extension'];
 
     $agi->set_variable("__transfer_UNIQUEID", $id);
 
-	return $data;
+    return $data;
 }
 
 /**
@@ -249,14 +249,14 @@ 
  * @return array
  */
 function Event_transfer_dial_create_chan($agi, $action){
-	$id  	= $agi->get_variable("transfer_UNIQUEID", true);
-	$data   = array();
-	$data['dst_chan'] 			= $agi->request['agi_channel'];
-	$data['transfer_UNIQUEID'] 	= "$id";
-	$data['action']  			= "$action";
-	$data['linkedid']  			= $agi->get_variable("CDR(linkedid)", true);
-
-	return $data;
+    $id  	= $agi->get_variable("transfer_UNIQUEID", true);
+    $data   = array();
+    $data['dst_chan'] 			= $agi->request['agi_channel'];
+    $data['transfer_UNIQUEID'] 	= "$id";
+    $data['action']  			= "$action";
+    $data['linkedid']  			= $agi->get_variable("CDR(linkedid)", true);
+
+    return $data;
 }
 
 /**
@@ -266,16 +266,16 @@ 
  * @return array
  */
 function Event_transfer_dial_answer($agi, $action){
-	$data 	= array();
+    $data 	= array();
     $now    = Util::get_now_date();
-	$id   	= $agi->get_variable("transfer_UNIQUEID", true);
-	$data['answer'] 			= $now;
-	$data['transfer_UNIQUEID'] 	= "$id";
-	$data['action']  			= "$action";
-	$data['agi_channel']		= $agi->request['agi_channel'];
-	$data['linkedid']  			= $agi->get_variable("CDR(linkedid)", true);
-
-	return $data;
+    $id   	= $agi->get_variable("transfer_UNIQUEID", true);
+    $data['answer'] 			= $now;
+    $data['transfer_UNIQUEID'] 	= "$id";
+    $data['action']  			= "$action";
+    $data['agi_channel']		= $agi->request['agi_channel'];
+    $data['linkedid']  			= $agi->get_variable("CDR(linkedid)", true);
+
+    return $data;
 }
 
 /**
@@ -286,25 +286,25 @@ 
  */
 function Event_transfer_dial_hangup($agi, $action){
     $now    = Util::get_now_date();
-	$data 	= array();
-	$data['end']  		  = $now;
-	$data['linkedid']  	  = $agi->get_variable("CDR(linkedid)", true);
-	$data['did']		  = $agi->get_variable("FROM_DID", true);;
-	$data['action']  	  = "$action";
-	$data['agi_channel']  = $agi->request['agi_channel'];
-	$data['agi_threadid'] = $agi->request['agi_uniqueid'] .'_'. Util::generateRandomString();
-
-	$pos = stripos( $data['agi_channel'], 'local/');
-	if($pos === false){
-		// Если это завершение переадресации (консультативной). Создадим новую строку CDR.
-	}else{
-		// Если пришел локальный канал:
-		$data['TRANSFERERNAME'] = $agi->get_variable("TRANSFERERNAME", 	true);
-		$data['ANSWEREDTIME'] 	= $agi->get_variable("ANSWEREDTIME", 	true);
-		$data['dst_chan'] 		= $agi->get_variable("CDR(dstchannel)", true);
-	}
-
-	return $data;
+    $data 	= array();
+    $data['end']  		  = $now;
+    $data['linkedid']  	  = $agi->get_variable("CDR(linkedid)", true);
+    $data['did']		  = $agi->get_variable("FROM_DID", true);;
+    $data['action']  	  = "$action";
+    $data['agi_channel']  = $agi->request['agi_channel'];
+    $data['agi_threadid'] = $agi->request['agi_uniqueid'] .'_'. Util::generateRandomString();
+
+    $pos = stripos( $data['agi_channel'], 'local/');
+    if($pos === false){
+        // Если это завершение переадресации (консультативной). Создадим новую строку CDR.
+    }else{
+        // Если пришел локальный канал:
+        $data['TRANSFERERNAME'] = $agi->get_variable("TRANSFERERNAME", 	true);
+        $data['ANSWEREDTIME'] 	= $agi->get_variable("ANSWEREDTIME", 	true);
+        $data['dst_chan'] 		= $agi->get_variable("CDR(dstchannel)", true);
+    }
+
+    return $data;
 }
 
 /**
@@ -315,23 +315,23 @@ 
  */
 function Event_hangup_chan($agi, $action){
     $now    = Util::get_now_date();
-	$data 	= [];
+    $data 	= [];
     $data['action']  	    = "$action";
     $data['did']		    = $agi->get_variable("FROM_DID", true);;
     $data['agi_threadid'] = $agi->request['agi_uniqueid'] .'_'. Util::generateRandomString();
 
-	$data['linkedid']  	    = $agi->get_variable("CDR(linkedid)", true);
-	$data['dialstatus']     = $agi->get_variable("DIALSTATUS", true);
-	if('ANSWER' == $data['dialstatus']){
+    $data['linkedid']  	    = $agi->get_variable("CDR(linkedid)", true);
+    $data['dialstatus']     = $agi->get_variable("DIALSTATUS", true);
+    if('ANSWER' == $data['dialstatus']){
         $data['dialstatus'] = "ANSWERED";
     }
-	$data['agi_channel']    = $agi->request['agi_channel'];
-	$data['end']  		    = $now;
+    $data['agi_channel']    = $agi->request['agi_channel'];
+    $data['end']  		    = $now;
 
     $data['OLD_LINKEDID']   = $agi->get_variable("OLD_LINKEDID", true);
     $data['UNIQUEID']  	    = $agi->get_variable("pt1c_UNIQUEID", true);
 
-	return $data;
+    return $data;
 }
 
 /**
@@ -342,64 +342,64 @@ 
  */
 function Event_unpark_call($agi, $action){
     $now    = Util::get_now_date();
-	// Обработка данных парковки. 
-	$exten	= $agi->get_variable("EXTEN", 	true);
-	$park_row = p_Park::get_parkslot_data($exten);
+    // Обработка данных парковки. 
+    $exten	= $agi->get_variable("EXTEN", 	true);
+    $park_row = p_Park::get_parkslot_data($exten);
 	
-	$agi->set_variable("__pt1c_IS_PARK", "1");		
-	$agi->set_variable("pt1c_PARK_CHAN", $park_row['ParkeeChannel']);
+    $agi->set_variable("__pt1c_IS_PARK", "1");		
+    $agi->set_variable("pt1c_PARK_CHAN", $park_row['ParkeeChannel']);
 	
-	// Сбор данных для генерации CDR.
-	$id   	= $agi->request['agi_uniqueid'] .'_'. Util::generateRandomString();
-	$channel= $agi->request['agi_channel'];
- 	$agi->set_variable("__pt1c_UNIQUEID", "$id");		
-	$data 	= array();
-	$data['action']  	 = "$action";
-	$data['UNIQUEID']  	 = $id;
-	$data['linkedid_old']= $agi->get_variable("CDR(linkedid)", true);
-	$data['agi_channel'] = $channel;
-	$data['linkedid']  	 = $park_row['ParkeeLinkedid'];
-	$data['start']  	 = $now;
-	$data['transfer']  	 = '0';
-	$data['did']		 = $agi->get_variable("FROM_DID", true);
-	$data['answer']  	 = $data['start'];
+    // Сбор данных для генерации CDR.
+    $id   	= $agi->request['agi_uniqueid'] .'_'. Util::generateRandomString();
+    $channel= $agi->request['agi_channel'];
+        $agi->set_variable("__pt1c_UNIQUEID", "$id");		
+    $data 	= array();
+    $data['action']  	 = "$action";
+    $data['UNIQUEID']  	 = $id;
+    $data['linkedid_old']= $agi->get_variable("CDR(linkedid)", true);
+    $data['agi_channel'] = $channel;
+    $data['linkedid']  	 = $park_row['ParkeeLinkedid'];
+    $data['start']  	 = $now;
+    $data['transfer']  	 = '0';
+    $data['did']		 = $agi->get_variable("FROM_DID", true);
+    $data['answer']  	 = $data['start'];
 	
-	if(null == $park_row){
-		$data['src_chan'] 	= $channel;
-		$data['src_num']  	= $agi->request['agi_callerid'];
-		$data['dst_num']  	= $agi->request['agi_extension'];
-		$data['dst_chan'] 	= 'Park:'.$agi->request['agi_extension'];
-	}else if(true == $park_row['pt1c_is_dst']){
-		$data['src_chan'] 	= $channel;
-		$data['dst_chan'] 	= $park_row['ParkeeChannel'];
-		$data['src_num']  	= $agi->request['agi_callerid'];
-		$data['dst_num']  	= $park_row['ParkeeCallerIDNum'];
-	}else{
-		$data['src_chan'] 	= $park_row['ParkeeChannel'];
-		$data['dst_chan'] 	= $channel;
-		$data['src_num']  	= $park_row['ParkeeCallerIDNum'];
-		$data['dst_num']  	= $agi->request['agi_callerid'];
-	}
+    if(null == $park_row){
+        $data['src_chan'] 	= $channel;
+        $data['src_num']  	= $agi->request['agi_callerid'];
+        $data['dst_num']  	= $agi->request['agi_extension'];
+        $data['dst_chan'] 	= 'Park:'.$agi->request['agi_extension'];
+    }else if(true == $park_row['pt1c_is_dst']){
+        $data['src_chan'] 	= $channel;
+        $data['dst_chan'] 	= $park_row['ParkeeChannel'];
+        $data['src_num']  	= $agi->request['agi_callerid'];
+        $data['dst_num']  	= $park_row['ParkeeCallerIDNum'];
+    }else{
+        $data['src_chan'] 	= $park_row['ParkeeChannel'];
+        $data['dst_chan'] 	= $channel;
+        $data['src_num']  	= $park_row['ParkeeCallerIDNum'];
+        $data['dst_num']  	= $agi->request['agi_callerid'];
+    }
 	
-	if(trim($park_row['ParkingDuration'])!=''){
-		$time_start = date("Y-m-d H:i:s", time() - 1*($park_row['ParkingDuration']) );
-		$data_parking = array(
-		    'UNIQUEID' => $id .'_'. Util::generateRandomString(3),
-			'src_chan' => $park_row['ParkeeChannel'],
-			'src_num'  => $park_row['ParkeeCallerIDNum'],
-			'dst_num'  => $park_row['ParkingSpace'],
-			'dst_chan' => 'Park:'.$park_row['ParkingSpace'],
-			'start'    => $time_start,
-			'answer'   => $time_start,
-			'endtime'  => $now,
-			'did'	   => $data['did'],
-			'transfer' => '0',
-			'linkedid' => $data['linkedid']
-		);
-		$data['data_parking'] = $data_parking;
-	}
-
-	return $data;	
+    if(trim($park_row['ParkingDuration'])!=''){
+        $time_start = date("Y-m-d H:i:s", time() - 1*($park_row['ParkingDuration']) );
+        $data_parking = array(
+            'UNIQUEID' => $id .'_'. Util::generateRandomString(3),
+            'src_chan' => $park_row['ParkeeChannel'],
+            'src_num'  => $park_row['ParkeeCallerIDNum'],
+            'dst_num'  => $park_row['ParkingSpace'],
+            'dst_chan' => 'Park:'.$park_row['ParkingSpace'],
+            'start'    => $time_start,
+            'answer'   => $time_start,
+            'endtime'  => $now,
+            'did'	   => $data['did'],
+            'transfer' => '0',
+            'linkedid' => $data['linkedid']
+        );
+        $data['data_parking'] = $data_parking;
+    }
+
+    return $data;	
 }
 
 /**
@@ -410,28 +410,28 @@ 
  */
 function Event_unpark_call_timeout($agi, $action){
     $now  = Util::get_now_date();
-	$id   = $agi->request['agi_uniqueid'] .'_'. Util::generateRandomString();
-	// PARKER=SIP/206
-	$PARKING_DURATION = $agi->get_variable("PARKING_DURATION", true);
-	$PARKING_DURATION = ($PARKING_DURATION == '')?45:$PARKING_DURATION;
+    $id   = $agi->request['agi_uniqueid'] .'_'. Util::generateRandomString();
+    // PARKER=SIP/206
+    $PARKING_DURATION = $agi->get_variable("PARKING_DURATION", true);
+    $PARKING_DURATION = ($PARKING_DURATION == '')?45:$PARKING_DURATION;
 		
-	$time_start = date("Y-m-d H:i:s", time() - 1*($PARKING_DURATION));
-	$PARKING_SPACE = $agi->get_variable("PARKING_SPACE", true);
-	$data = array(
-		'action'   => "$action",
-		'src_chan' => $agi->request['agi_channel'], // $agi->get_variable("PARKER", true), // ???
-		'src_num'  => $agi->request['agi_callerid'],
-		'dst_num'  => $PARKING_SPACE,
-		'dst_chan' => 'Park:'.$PARKING_SPACE,
-		'start'    => $time_start,
-		'answer'   => $time_start,
-		'endtime'  => $now,
-		'did'	   => $agi->get_variable("FROM_DID", true),
-		'UNIQUEID' => $id,
-		'transfer' => '0',
-		'linkedid' => $agi->get_variable("CDR(linkedid)", true),
+    $time_start = date("Y-m-d H:i:s", time() - 1*($PARKING_DURATION));
+    $PARKING_SPACE = $agi->get_variable("PARKING_SPACE", true);
+    $data = array(
+        'action'   => "$action",
+        'src_chan' => $agi->request['agi_channel'], // $agi->get_variable("PARKER", true), // ???
+        'src_num'  => $agi->request['agi_callerid'],
+        'dst_num'  => $PARKING_SPACE,
+        'dst_chan' => 'Park:'.$PARKING_SPACE,
+        'start'    => $time_start,
+        'answer'   => $time_start,
+        'endtime'  => $now,
+        'did'	   => $agi->get_variable("FROM_DID", true),
+        'UNIQUEID' => $id,
+        'transfer' => '0',
+        'linkedid' => $agi->get_variable("CDR(linkedid)", true),
         'PARKER'   => $agi->get_variable("PARKER", true),
-	);
+    );
 
 
     $id2   = $agi->request['agi_uniqueid'] .'_'. Util::generateRandomString();
@@ -458,18 +458,18 @@ 
     }
 
     $data = array(
-		'action'   => "$action",
-		// 'src_chan' => $agi->request['agi_channel'],
-		// 'src_num'  => $agi->request['agi_callerid'],
-		'dst_num'  => $agi->request['agi_extension'],
-		'dst_chan' => 'Queue:'.$agi->request['agi_extension'],
-		// 'answer'   => $time_start,
-		// 'end'  	   => $now,
-		'did'	   => $agi->get_variable("FROM_DID", true),
-		'is_app' => '1',
-		'UNIQUEID' => $id,
-		'linkedid' => $agi->get_variable("CDR(linkedid)", true)
-	);
+        'action'   => "$action",
+        // 'src_chan' => $agi->request['agi_channel'],
+        // 'src_num'  => $agi->request['agi_callerid'],
+        'dst_num'  => $agi->request['agi_extension'],
+        'dst_chan' => 'Queue:'.$agi->request['agi_extension'],
+        // 'answer'   => $time_start,
+        // 'end'  	   => $now,
+        'did'	   => $agi->get_variable("FROM_DID", true),
+        'is_app' => '1',
+        'UNIQUEID' => $id,
+        'linkedid' => $agi->get_variable("CDR(linkedid)", true)
+    );
     if(!empty($time_start)){
         $data['src_chan'] = $agi->get_variable("QUEUE_SRC_CHAN", true);
         $data['src_num']  = $agi->request['agi_callerid'];
@@ -484,7 +484,7 @@ 
         $data['transfer']  	= '0';
     }
 
-	return $data;	
+    return $data;	
 }
 
 /**
@@ -495,15 +495,15 @@ 
  */
 function Event_queue_answer($agi, $action){
     $now  = Util::get_now_date();
-	$id   = $agi->get_variable("pt1c_q_UNIQUEID", true);
-	$data = array();
-	$data['action']  	= "$action";
-	$data['answer']  	= $now;
-	$data['id'] 		= $id;
-	$data['agi_channel']= $agi->request['agi_channel'];
-	$data['linkedid']  	= $agi->get_variable("CDR(linkedid)", true);
-
-	return $data;	
+    $id   = $agi->get_variable("pt1c_q_UNIQUEID", true);
+    $data = array();
+    $data['action']  	= "$action";
+    $data['answer']  	= $now;
+    $data['id'] 		= $id;
+    $data['agi_channel']= $agi->request['agi_channel'];
+    $data['linkedid']  	= $agi->get_variable("CDR(linkedid)", true);
+
+    return $data;	
 }
 
 /**
@@ -514,16 +514,16 @@ 
  */
 function Event_queue_end($agi, $action){
     $now  = Util::get_now_date();
-	$id   = $agi->get_variable("pt1c_q_UNIQUEID", true);
-	$data = array();
-	$data['action']  	= "$action";
-	$data['end']  		= $now;
-	$data['id'] 		= $id;
-	$data['dialstatus'] = $agi->get_variable("QUEUESTATUS", true);
-	$data['agi_channel']= $agi->request['agi_channel'];
-	$data['linkedid']  	= $agi->get_variable("CDR(linkedid)", true);
-
-	return $data;	
+    $id   = $agi->get_variable("pt1c_q_UNIQUEID", true);
+    $data = array();
+    $data['action']  	= "$action";
+    $data['end']  		= $now;
+    $data['id'] 		= $id;
+    $data['dialstatus'] = $agi->get_variable("QUEUESTATUS", true);
+    $data['agi_channel']= $agi->request['agi_channel'];
+    $data['linkedid']  	= $agi->get_variable("CDR(linkedid)", true);
+
+    return $data;	
 }
 
 /**
@@ -672,7 +672,7 @@ 
 if( function_exists($func_name) ){
     $agi = new AGI();
     // Сбор сведений по каналу.
-	$result = $func_name($agi, $action);
+    $result = $func_name($agi, $action);
     // Оповещение без задержек.
     $data = base64_encode(json_encode($result));
     $agi->exec("UserEvent", "CdrConnector,AgiData:".base64_encode(json_encode($result)));

Spacing +174 added lines, -174 removed lines

@@ -17,53 +17,53 @@ 
  * @param string $action
  * @return array
  */
-function Event_dial($agi, $action){
+function Event_dial($agi, $action) {
 	$now = Util::get_now_date();
     $data = array();
 	
 	// Уточним канал, на случай очереди.
     $QUEUE_SRC_CHAN = $agi->get_variable("QUEUE_SRC_CHAN", true);
-	$orign_chan     = $agi->get_variable("orign_chan",     true);
-    $id   	        = $agi->get_variable("pt1c_UNIQUEID",  true);
-    $IS_ORGNT   	= $agi->get_variable("IS_ORGNT",       true);
-    if($id == '' || !empty($QUEUE_SRC_CHAN)){
+	$orign_chan     = $agi->get_variable("orign_chan", true);
+    $id = $agi->get_variable("pt1c_UNIQUEID", true);
+    $IS_ORGNT   	= $agi->get_variable("IS_ORGNT", true);
+    if ($id == '' || !empty($QUEUE_SRC_CHAN)) {
         // Если это вызов на агента очереди !empty($QUEUE_SRC_CHAN).
         // Если это новый вызов $id == ''.
-        $id   = $agi->request['agi_uniqueid'] .'_'. Util::generateRandomString();
+        $id = $agi->request['agi_uniqueid'].'_'.Util::generateRandomString();
     }
 	// Канал, AGI скрипта.
-	$channel 		= $agi->request['agi_channel'];
-    $is_local       = !(stripos($channel, 'local/') === false);
-	if($QUEUE_SRC_CHAN != '' && $is_local){
+	$channel = $agi->request['agi_channel'];
+    $is_local = !(stripos($channel, 'local/') === false);
+	if ($QUEUE_SRC_CHAN != '' && $is_local) {
 		// Это LOCAL, Переопределим на исходный. 
 		$channel = $QUEUE_SRC_CHAN;
-	}else if($is_local && (stripos($orign_chan, 'local/') === false)){
+	} else if ($is_local && (stripos($orign_chan, 'local/') === false)) {
         $channel = $orign_chan;
     }
 
     // Получим ID исходного канала.
     $from_account = $agi->get_variable("FROM_PEER", true);
-    if( $from_account == '' && stripos($agi->request['agi_channel'], 'local/') === false ){
-        $from_account  	= $agi->get_variable('CUT(CUT(CHANNEL(name),,1),/,2)', true);
+    if ($from_account == '' && stripos($agi->request['agi_channel'], 'local/') === false) {
+        $from_account = $agi->get_variable('CUT(CUT(CHANNEL(name),,1),/,2)', true);
     }
 
-    $data['action']  	 = "$action";
-    if(!empty($IS_ORGNT)){
+    $data['action'] = "$action";
+    if (!empty($IS_ORGNT)) {
         $dst_num  	        = $agi->request['agi_callerid'];
         $src_num  	        = $agi->request['agi_extension'];
         $data['dialstatus'] = 'ORIGINATE';
-        $from_account='';
+        $from_account = '';
 
-        $p_start = strpos($agi->request['agi_channel'],'/')+1;
-        $p_end   = strpos($agi->request['agi_channel'],'@') - $p_start;
+        $p_start = strpos($agi->request['agi_channel'], '/') + 1;
+        $p_end   = strpos($agi->request['agi_channel'], '@') - $p_start;
         $num     = substr($agi->request['agi_channel'], $p_start, $p_end);
 
-        $p_start = strpos($agi->request['agi_channel'],';');
-        $dst_chan= substr($agi->request['agi_channel'], 0, $p_start).';1';
+        $p_start = strpos($agi->request['agi_channel'], ';');
+        $dst_chan = substr($agi->request['agi_channel'], 0, $p_start).';1';
 
-        $id   = substr($agi->request['agi_uniqueid'],0, 16) .'_'.$num.'_'. $IS_ORGNT;
-        $data['dst_chan'] 	 = $dst_chan;
-    }else{
+        $id = substr($agi->request['agi_uniqueid'], 0, 16).'_'.$num.'_'.$IS_ORGNT;
+        $data['dst_chan'] = $dst_chan;
+    } else {
         $src_num  	 = $agi->request['agi_callerid'];
         $dst_num  	 = $agi->request['agi_extension'];
     }
@@ -71,13 +71,13 @@ 
 	$data['src_chan'] 	 = $channel;
 	$data['src_num']  	 = $src_num;
 	$data['dst_num']  	 = $dst_num;
-	$data['start']  	 = $now;
+	$data['start'] = $now;
 	$data['linkedid']  	 = $agi->get_variable("CDR(linkedid)", true);
 	$data['UNIQUEID']  	 = $id;
 	$data['transfer']  	 = '0';
-	$data['agi_channel'] = $agi->request['agi_channel'];;
-	$data['did']		 = $agi->get_variable("FROM_DID",  true);
-	$data['from_account']= $from_account;
+	$data['agi_channel'] = $agi->request['agi_channel']; ;
+	$data['did'] = $agi->get_variable("FROM_DID", true);
+	$data['from_account'] = $from_account;
 	$data['IS_ORGNT']    = !empty($IS_ORGNT);
 
  	$agi->set_variable("__pt1c_UNIQUEID", "$id");		
@@ -90,28 +90,28 @@ 
  * @param string $action
  * @return array
  */
-function Event_dial_create_chan($agi, $action){
+function Event_dial_create_chan($agi, $action) {
     $now = Util::get_now_date();
 	$data 	    = [];
 	$id   	    = $agi->get_variable("pt1c_UNIQUEID", true);
 	$data['action']  	 = "$action";
 	$data['dst_chan']	 = $agi->request['agi_channel'];
 	$data['UNIQUEID']	 = $id;
-	$data['linkedid']  	 = $agi->get_variable("CDR(linkedid)", true);
-    $data['event_time']  = $now;
+	$data['linkedid'] = $agi->get_variable("CDR(linkedid)", true);
+    $data['event_time'] = $now;
 
-	if( stripos($data['dst_chan'], 'local/') === false ){
-        $data['to_account']  	= $agi->get_variable('CUT(CUT(CHANNEL(name),,1),/,2)', true);
+	if (stripos($data['dst_chan'], 'local/') === false) {
+        $data['to_account'] = $agi->get_variable('CUT(CUT(CHANNEL(name),,1),/,2)', true);
 	}
 
-    $IS_ORGNT   = $agi->get_variable("IS_ORGNT",       true);
-    if(!empty($IS_ORGNT)){
+    $IS_ORGNT = $agi->get_variable("IS_ORGNT", true);
+    if (!empty($IS_ORGNT)) {
         // Вероятно необходимо переопределить искать по двум ID.
         // Применимо только для Originate, когда в качестве звонящего используем два канала
         // мобильный и внутренний номер.
-        $peer_mobile= $agi->get_variable("peer_mobile", true);
-        if( !empty($peer_mobile) && stripos($id, $peer_mobile) === false ) {
-            $id   = substr($agi->request['agi_uniqueid'],0, 16) .'_'.$peer_mobile.'_'. $IS_ORGNT;
+        $peer_mobile = $agi->get_variable("peer_mobile", true);
+        if (!empty($peer_mobile) && stripos($id, $peer_mobile) === false) {
+            $id = substr($agi->request['agi_uniqueid'], 0, 16).'_'.$peer_mobile.'_'.$IS_ORGNT;
             $data['org_id'] = $id;
         }
     }
@@ -125,52 +125,52 @@ 
  * @param string $action
  * @return array
  */
-function Event_dial_answer($agi, $action){
+function Event_dial_answer($agi, $action) {
     $now = Util::get_now_date();
 
 	$id   = $agi->get_variable("pt1c_UNIQUEID", true);
 	$data = [];
 	$data['action']  	= "$action";
 	$data['answer']  	= $now;
-	$data['id'] 		= $id;
+	$data['id'] = $id;
     $data['dst_num']	= $agi->request['agi_callerid'];
-	$data['agi_channel']= $agi->request['agi_channel'];
+	$data['agi_channel'] = $agi->request['agi_channel'];
 	$data['linkedid']  	= $agi->get_variable("CDR(linkedid)", true);
 
-	$data['ENDCALLONANSWER']= $agi->get_variable("ENDCALLONANSWER", true);
-    $data['BRIDGEPEER']     = $agi->get_variable("FROM_CHAN", true);
+	$data['ENDCALLONANSWER'] = $agi->get_variable("ENDCALLONANSWER", true);
+    $data['BRIDGEPEER'] = $agi->get_variable("FROM_CHAN", true);
 
-    $IS_ORGNT   = $agi->get_variable("IS_ORGNT",       true);
-    if(!empty($IS_ORGNT)){
+    $IS_ORGNT = $agi->get_variable("IS_ORGNT", true);
+    if (!empty($IS_ORGNT)) {
         // Вероятно необходимо переопределить ID.
         // Применимо только для Originate, когда в качестве звонящего используем два канала
         // мобильный и внутренний номер.
-        $peer_mobile= $agi->get_variable("peer_mobile", true);
-        if( !empty($peer_mobile) && stripos($id, $peer_mobile) === false ) {
-            $id   = substr($agi->request['agi_uniqueid'],0, 16) .'_'.$peer_mobile.'_'. $IS_ORGNT;
+        $peer_mobile = $agi->get_variable("peer_mobile", true);
+        if (!empty($peer_mobile) && stripos($id, $peer_mobile) === false) {
+            $id = substr($agi->request['agi_uniqueid'], 0, 16).'_'.$peer_mobile.'_'.$IS_ORGNT;
             $data['org_id'] = $id;
         }
     }
 
-    if(!empty($data['ENDCALLONANSWER'])){
+    if (!empty($data['ENDCALLONANSWER'])) {
         $agi->set_variable("__ENDCALLONANSWER", "");
     }
 
     $PICKUPEER      = trim(''.$agi->get_variable("PICKUPEER", true));
     $data['dnid']   = $agi->request['agi_dnid'];
     $pickupexten = Config::get_pickupexten();
-    if('unknown' == $data['dnid'] && $PICKUPEER != ''){
+    if ('unknown' == $data['dnid'] && $PICKUPEER != '') {
         // Скорее всего ответ на вызов из 1С.
         $data['dnid']   = $pickupexten;
-    }elseif ($pickupexten == substr($data['dnid'], 0, 2) && $PICKUPEER != ''){
+    }elseif ($pickupexten == substr($data['dnid'], 0, 2) && $PICKUPEER != '') {
         // Это перехват при наборе номера *8XXX.
         $data['dnid']   = $pickupexten;
     }
-    if(trim($data['dnid']) == $pickupexten ) {
+    if (trim($data['dnid']) == $pickupexten) {
         // Очищаем переменную канала. Больше не требуется.
         $agi->set_variable("PICKUPEER", "");
         $data['old_id'] = $id;
-        $data['id'] 	= $agi->request['agi_uniqueid'] .'_'. Util::generateRandomString();
+        $data['id'] = $agi->request['agi_uniqueid'].'_'.Util::generateRandomString();
     }
     $agi->set_variable("__pt1c_UNIQUEID", "$id");
 
@@ -183,18 +183,18 @@ 
  * @param string $action
  * @return array
  */
-function Event_dial_hangup_DEPRECATED($agi, $action){
+function Event_dial_hangup_DEPRECATED($agi, $action) {
     // TODO Удалить эту функцию в будущем.
-    $now    = Util::get_now_date();
-	$data 	= array();
-	$data['action']  	 = "$action";
-	$data['end']  		 = $now;
+    $now = Util::get_now_date();
+	$data = array();
+	$data['action'] = "$action";
+	$data['end'] = $now;
 	$data['id'] 		 = $agi->get_variable("pt1c_UNIQUEID", true);
 	$data['agi_channel'] = $agi->request['agi_channel'];
 	$data['linkedid']  	 = $agi->get_variable("CDR(linkedid)", true);
 	$data['did']		 = $agi->get_variable("FROM_DID", true);
 
-	$data['agi_threadid'] = $agi->request['agi_uniqueid'] .'_'. Util::generateRandomString();
+	$data['agi_threadid'] = $agi->request['agi_uniqueid'].'_'.Util::generateRandomString();
 
 	return $data;
 }
@@ -205,35 +205,35 @@ 
  * @param string $action
  * @return array
  */
-function Event_transfer_dial($agi, $action){
+function Event_transfer_dial($agi, $action) {
     $now = Util::get_now_date();
-	$id   = $agi->request['agi_uniqueid'] .'_'. Util::generateRandomString();
+	$id = $agi->request['agi_uniqueid'].'_'.Util::generateRandomString();
 
 	// Пытаемся определить канал.
     $TRANSFERERNAME = $agi->get_variable("TRANSFERERNAME", true);
 	$QUEUE_SRC_CHAN = $agi->get_variable("QUEUE_SRC_CHAN", true);
 	$is_local       = !(stripos($TRANSFERERNAME, 'local/') === false);
-    if( $QUEUE_SRC_CHAN != '' && $is_local ){
+    if ($QUEUE_SRC_CHAN != '' && $is_local) {
         // Это LOCAL, Переопределим на исходный.
         $channel = $QUEUE_SRC_CHAN;
-    }else if( $QUEUE_SRC_CHAN != '' && $TRANSFERERNAME == '' ){
+    } else if ($QUEUE_SRC_CHAN != '' && $TRANSFERERNAME == '') {
         // Это редирект на очередь.
         $channel = $QUEUE_SRC_CHAN;
-    }else if($TRANSFERERNAME == ''){
+    } else if ($TRANSFERERNAME == '') {
         $channel = $agi->request['agi_channel'];
-    }else{
+    } else {
         $channel = $TRANSFERERNAME;
     }
 
-	$data   = array();
-	$data['action']  	= "$action";
-	$data['agi_channel']= $channel;// $agi->request['agi_channel'];
+	$data = array();
+	$data['action'] = "$action";
+	$data['agi_channel'] = $channel; // $agi->request['agi_channel'];
 	$data['linkedid']  	= $agi->get_variable("CDR(linkedid)", true);
-	$data['src_chan'] 	= $channel;
-	$data['did']		= $agi->get_variable("FROM_DID", true);;
-	$data['start']  	= $now;
+	$data['src_chan'] = $channel;
+	$data['did'] = $agi->get_variable("FROM_DID", true); ;
+	$data['start'] = $now;
 	$data['UNIQUEID']  	= $id;	
-	$data['transfer']  	= ($TRANSFERERNAME == '')?'0':'1';
+	$data['transfer']  	= ($TRANSFERERNAME == '') ? '0' : '1';
 	$data['src_num']  	= $agi->request['agi_callerid'];
 	$data['dst_num']  	= $agi->request['agi_extension'];
 
@@ -248,13 +248,13 @@ 
  * @param string $action
  * @return array
  */
-function Event_transfer_dial_create_chan($agi, $action){
-	$id  	= $agi->get_variable("transfer_UNIQUEID", true);
-	$data   = array();
-	$data['dst_chan'] 			= $agi->request['agi_channel'];
-	$data['transfer_UNIQUEID'] 	= "$id";
-	$data['action']  			= "$action";
-	$data['linkedid']  			= $agi->get_variable("CDR(linkedid)", true);
+function Event_transfer_dial_create_chan($agi, $action) {
+	$id = $agi->get_variable("transfer_UNIQUEID", true);
+	$data = array();
+	$data['dst_chan'] = $agi->request['agi_channel'];
+	$data['transfer_UNIQUEID'] = "$id";
+	$data['action'] = "$action";
+	$data['linkedid'] = $agi->get_variable("CDR(linkedid)", true);
 
 	return $data;
 }
@@ -265,13 +265,13 @@ 
  * @param string $action
  * @return array
  */
-function Event_transfer_dial_answer($agi, $action){
+function Event_transfer_dial_answer($agi, $action) {
 	$data 	= array();
-    $now    = Util::get_now_date();
+    $now = Util::get_now_date();
 	$id   	= $agi->get_variable("transfer_UNIQUEID", true);
-	$data['answer'] 			= $now;
-	$data['transfer_UNIQUEID'] 	= "$id";
-	$data['action']  			= "$action";
+	$data['answer'] = $now;
+	$data['transfer_UNIQUEID'] = "$id";
+	$data['action'] = "$action";
 	$data['agi_channel']		= $agi->request['agi_channel'];
 	$data['linkedid']  			= $agi->get_variable("CDR(linkedid)", true);
 
@@ -284,24 +284,24 @@ 
  * @param string $action
  * @return array
  */
-function Event_transfer_dial_hangup($agi, $action){
-    $now    = Util::get_now_date();
-	$data 	= array();
-	$data['end']  		  = $now;
+function Event_transfer_dial_hangup($agi, $action) {
+    $now = Util::get_now_date();
+	$data = array();
+	$data['end'] = $now;
 	$data['linkedid']  	  = $agi->get_variable("CDR(linkedid)", true);
-	$data['did']		  = $agi->get_variable("FROM_DID", true);;
-	$data['action']  	  = "$action";
+	$data['did'] = $agi->get_variable("FROM_DID", true); ;
+	$data['action'] = "$action";
 	$data['agi_channel']  = $agi->request['agi_channel'];
-	$data['agi_threadid'] = $agi->request['agi_uniqueid'] .'_'. Util::generateRandomString();
+	$data['agi_threadid'] = $agi->request['agi_uniqueid'].'_'.Util::generateRandomString();
 
-	$pos = stripos( $data['agi_channel'], 'local/');
-	if($pos === false){
+	$pos = stripos($data['agi_channel'], 'local/');
+	if ($pos === false) {
 		// Если это завершение переадресации (консультативной). Создадим новую строку CDR.
-	}else{
+	} else {
 		// Если пришел локальный канал:
-		$data['TRANSFERERNAME'] = $agi->get_variable("TRANSFERERNAME", 	true);
-		$data['ANSWEREDTIME'] 	= $agi->get_variable("ANSWEREDTIME", 	true);
-		$data['dst_chan'] 		= $agi->get_variable("CDR(dstchannel)", true);
+		$data['TRANSFERERNAME'] = $agi->get_variable("TRANSFERERNAME", true);
+		$data['ANSWEREDTIME'] = $agi->get_variable("ANSWEREDTIME", true);
+		$data['dst_chan'] = $agi->get_variable("CDR(dstchannel)", true);
 	}
 
 	return $data;
@@ -313,20 +313,20 @@ 
  * @param string $action
  * @return array
  */
-function Event_hangup_chan($agi, $action){
-    $now    = Util::get_now_date();
-	$data 	= [];
+function Event_hangup_chan($agi, $action) {
+    $now = Util::get_now_date();
+	$data = [];
     $data['action']  	    = "$action";
-    $data['did']		    = $agi->get_variable("FROM_DID", true);;
-    $data['agi_threadid'] = $agi->request['agi_uniqueid'] .'_'. Util::generateRandomString();
+    $data['did'] = $agi->get_variable("FROM_DID", true); ;
+    $data['agi_threadid'] = $agi->request['agi_uniqueid'].'_'.Util::generateRandomString();
 
 	$data['linkedid']  	    = $agi->get_variable("CDR(linkedid)", true);
 	$data['dialstatus']     = $agi->get_variable("DIALSTATUS", true);
-	if('ANSWER' == $data['dialstatus']){
+	if ('ANSWER' == $data['dialstatus']) {
         $data['dialstatus'] = "ANSWERED";
     }
-	$data['agi_channel']    = $agi->request['agi_channel'];
-	$data['end']  		    = $now;
+	$data['agi_channel'] = $agi->request['agi_channel'];
+	$data['end'] = $now;
 
     $data['OLD_LINKEDID']   = $agi->get_variable("OLD_LINKEDID", true);
     $data['UNIQUEID']  	    = $agi->get_variable("pt1c_UNIQUEID", true);
@@ -340,51 +340,51 @@ 
  * @param string $action
  * @return array
  */
-function Event_unpark_call($agi, $action){
-    $now    = Util::get_now_date();
+function Event_unpark_call($agi, $action) {
+    $now = Util::get_now_date();
 	// Обработка данных парковки. 
-	$exten	= $agi->get_variable("EXTEN", 	true);
+	$exten = $agi->get_variable("EXTEN", true);
 	$park_row = p_Park::get_parkslot_data($exten);
 	
 	$agi->set_variable("__pt1c_IS_PARK", "1");		
 	$agi->set_variable("pt1c_PARK_CHAN", $park_row['ParkeeChannel']);
 	
 	// Сбор данных для генерации CDR.
-	$id   	= $agi->request['agi_uniqueid'] .'_'. Util::generateRandomString();
-	$channel= $agi->request['agi_channel'];
+	$id   	= $agi->request['agi_uniqueid'].'_'.Util::generateRandomString();
+	$channel = $agi->request['agi_channel'];
  	$agi->set_variable("__pt1c_UNIQUEID", "$id");		
 	$data 	= array();
-	$data['action']  	 = "$action";
+	$data['action'] = "$action";
 	$data['UNIQUEID']  	 = $id;
-	$data['linkedid_old']= $agi->get_variable("CDR(linkedid)", true);
+	$data['linkedid_old'] = $agi->get_variable("CDR(linkedid)", true);
 	$data['agi_channel'] = $channel;
 	$data['linkedid']  	 = $park_row['ParkeeLinkedid'];
-	$data['start']  	 = $now;
+	$data['start'] = $now;
 	$data['transfer']  	 = '0';
-	$data['did']		 = $agi->get_variable("FROM_DID", true);
-	$data['answer']  	 = $data['start'];
+	$data['did'] = $agi->get_variable("FROM_DID", true);
+	$data['answer'] = $data['start'];
 	
-	if(null == $park_row){
+	if (null == $park_row) {
 		$data['src_chan'] 	= $channel;
 		$data['src_num']  	= $agi->request['agi_callerid'];
 		$data['dst_num']  	= $agi->request['agi_extension'];
 		$data['dst_chan'] 	= 'Park:'.$agi->request['agi_extension'];
-	}else if(true == $park_row['pt1c_is_dst']){
+	} else if (true == $park_row['pt1c_is_dst']) {
 		$data['src_chan'] 	= $channel;
 		$data['dst_chan'] 	= $park_row['ParkeeChannel'];
 		$data['src_num']  	= $agi->request['agi_callerid'];
 		$data['dst_num']  	= $park_row['ParkeeCallerIDNum'];
-	}else{
+	} else {
 		$data['src_chan'] 	= $park_row['ParkeeChannel'];
 		$data['dst_chan'] 	= $channel;
 		$data['src_num']  	= $park_row['ParkeeCallerIDNum'];
 		$data['dst_num']  	= $agi->request['agi_callerid'];
 	}
 	
-	if(trim($park_row['ParkingDuration'])!=''){
-		$time_start = date("Y-m-d H:i:s", time() - 1*($park_row['ParkingDuration']) );
+	if (trim($park_row['ParkingDuration']) != '') {
+		$time_start = date("Y-m-d H:i:s", time() - 1 * ($park_row['ParkingDuration']));
 		$data_parking = array(
-		    'UNIQUEID' => $id .'_'. Util::generateRandomString(3),
+		    'UNIQUEID' => $id.'_'.Util::generateRandomString(3),
 			'src_chan' => $park_row['ParkeeChannel'],
 			'src_num'  => $park_row['ParkeeCallerIDNum'],
 			'dst_num'  => $park_row['ParkingSpace'],
@@ -408,14 +408,14 @@ 
  * @param string $action
  * @return array
  */
-function Event_unpark_call_timeout($agi, $action){
-    $now  = Util::get_now_date();
-	$id   = $agi->request['agi_uniqueid'] .'_'. Util::generateRandomString();
+function Event_unpark_call_timeout($agi, $action) {
+    $now = Util::get_now_date();
+	$id = $agi->request['agi_uniqueid'].'_'.Util::generateRandomString();
 	// PARKER=SIP/206
 	$PARKING_DURATION = $agi->get_variable("PARKING_DURATION", true);
-	$PARKING_DURATION = ($PARKING_DURATION == '')?45:$PARKING_DURATION;
+	$PARKING_DURATION = ($PARKING_DURATION == '') ? 45 : $PARKING_DURATION;
 		
-	$time_start = date("Y-m-d H:i:s", time() - 1*($PARKING_DURATION));
+	$time_start = date("Y-m-d H:i:s", time() - 1 * ($PARKING_DURATION));
 	$PARKING_SPACE = $agi->get_variable("PARKING_SPACE", true);
 	$data = array(
 		'action'   => "$action",
@@ -434,7 +434,7 @@ 
 	);
 
 
-    $id2   = $agi->request['agi_uniqueid'] .'_'. Util::generateRandomString();
+    $id2 = $agi->request['agi_uniqueid'].'_'.Util::generateRandomString();
     $agi->set_variable("__pt1c_UNIQUEID", "$id2");
 
     return $data;
@@ -446,13 +446,13 @@ 
  * @param string $action
  * @return array
  */
-function Event_queue_start($agi, $action){
-    $now  = Util::get_now_date();
+function Event_queue_start($agi, $action) {
+    $now = Util::get_now_date();
     $time_start = null;
-    $id = $agi->get_variable("pt1c_UNIQUEID",  true);
-    $ISTRANSFER = $agi->get_variable("ISTRANSFER",  true);
+    $id = $agi->get_variable("pt1c_UNIQUEID", true);
+    $ISTRANSFER = $agi->get_variable("ISTRANSFER", true);
 
-    if(empty($id) || !empty($ISTRANSFER)) {
+    if (empty($id) || !empty($ISTRANSFER)) {
         $id = $agi->request['agi_uniqueid'].'_'.Util::generateRandomString();
         $time_start = $now;
     }
@@ -470,7 +470,7 @@ 
 		'UNIQUEID' => $id,
 		'linkedid' => $agi->get_variable("CDR(linkedid)", true)
 	);
-    if(!empty($time_start)){
+    if (!empty($time_start)) {
         $data['src_chan'] = $agi->get_variable("QUEUE_SRC_CHAN", true);
         $data['src_num']  = $agi->request['agi_callerid'];
         $data['start']    = $time_start;
@@ -478,9 +478,9 @@ 
         $data['transfer'] = '0';
         $agi->set_variable("__pt1c_q_UNIQUEID", "$id");
     }
-    if(!empty($ISTRANSFER)){
+    if (!empty($ISTRANSFER)) {
         $data['transfer']  	= '1';
-    }else{
+    } else {
         $data['transfer']  	= '0';
     }
 
@@ -493,14 +493,14 @@ 
  * @param string $action
  * @return array
  */
-function Event_queue_answer($agi, $action){
-    $now  = Util::get_now_date();
+function Event_queue_answer($agi, $action) {
+    $now = Util::get_now_date();
 	$id   = $agi->get_variable("pt1c_q_UNIQUEID", true);
 	$data = array();
 	$data['action']  	= "$action";
 	$data['answer']  	= $now;
-	$data['id'] 		= $id;
-	$data['agi_channel']= $agi->request['agi_channel'];
+	$data['id'] = $id;
+	$data['agi_channel'] = $agi->request['agi_channel'];
 	$data['linkedid']  	= $agi->get_variable("CDR(linkedid)", true);
 
 	return $data;	
@@ -512,15 +512,15 @@ 
  * @param string $action
  * @return array
  */
-function Event_queue_end($agi, $action){
-    $now  = Util::get_now_date();
+function Event_queue_end($agi, $action) {
+    $now = Util::get_now_date();
 	$id   = $agi->get_variable("pt1c_q_UNIQUEID", true);
 	$data = array();
-	$data['action']  	= "$action";
-	$data['end']  		= $now;
-	$data['id'] 		= $id;
+	$data['action'] = "$action";
+	$data['end'] = $now;
+	$data['id'] = $id;
 	$data['dialstatus'] = $agi->get_variable("QUEUESTATUS", true);
-	$data['agi_channel']= $agi->request['agi_channel'];
+	$data['agi_channel'] = $agi->request['agi_channel'];
 	$data['linkedid']  	= $agi->get_variable("CDR(linkedid)", true);
 
 	return $data;	
@@ -532,52 +532,52 @@ 
  * @param string $action
  * @return array
  */
-function Event_meetme_dial($agi, $action){
+function Event_meetme_dial($agi, $action) {
     $now        = Util::get_now_date();
     $id         = '';
     $time_start = $now;
     $exten      = $agi->request['agi_extension'];
 
-    $not_local       = (stripos($agi->request['agi_channel'], 'local/') === false);
-    if($not_local){
+    $not_local = (stripos($agi->request['agi_channel'], 'local/') === false);
+    if ($not_local) {
         $am     = Util::get_am();
         $res    = $am->meetMeCollectInfo($exten, ['conf_1c']);
         $callid = $agi->request['agi_callerid'];
-        $users_nums   = [ [$callid] ];
-        foreach ($res as $row){
+        $users_nums = [[$callid]];
+        foreach ($res as $row) {
             $users_nums[] = explode('_', $row['conf_1c']);
         }
         $users = implode('_', array_unique(array_merge(... $users_nums)));
         $agi->set_variable('conf_1c', $users);
-        $agi->set_variable('CALLERID(num)','Conference_Room');
+        $agi->set_variable('CALLERID(num)', 'Conference_Room');
         $agi->set_variable('CALLERID(name)', $callid);
-        $agi->set_variable('mikoconfcid',    $exten);
-        $agi->set_variable('mikoidconf',     $exten);
+        $agi->set_variable('mikoconfcid', $exten);
+        $agi->set_variable('mikoidconf', $exten);
 
         $mikoidconf = $exten;
-        $BLINDTRANSFER  = $agi->get_variable("BLINDTRANSFER", true);
-        if(empty($BLINDTRANSFER)){
+        $BLINDTRANSFER = $agi->get_variable("BLINDTRANSFER", true);
+        if (empty($BLINDTRANSFER)) {
             $id     = $agi->get_variable('pt1c_UNIQUEID', true);
         }
-        $src_num= $callid;
-        $dst_num= $exten;
-    }else{
+        $src_num = $callid;
+        $dst_num = $exten;
+    } else {
         $mikoidconf     = $agi->get_variable('mikoidconf', true);
-        if(empty($mikoidconf)){
+        if (empty($mikoidconf)) {
             $mikoidconf = $exten;
         }
-        $src_num    = $agi->get_variable('mikoconfcid', true);
+        $src_num = $agi->get_variable('mikoconfcid', true);
         // Отсечем все до "/".
         $tmp_arr = explode('/', $mikoidconf);
-        if(count($tmp_arr)>1){
+        if (count($tmp_arr) > 1) {
             unset($tmp_arr[0]);
             $mikoidconf = implode('/', $tmp_arr);
         }
-        $dst_num    = substr($mikoidconf, 4);
+        $dst_num = substr($mikoidconf, 4);
     }
 
-    if(empty($id)){
-        $id         = $agi->request['agi_uniqueid'] .'_'. Util::generateRandomString();
+    if (empty($id)) {
+        $id = $agi->request['agi_uniqueid'].'_'.Util::generateRandomString();
     }
 
     $recordingfile = Cdr::MeetMeSetRecFilename($id);
@@ -595,8 +595,8 @@ 
         'UNIQUEID'      => $id,
         'linkedid'      => $agi->get_variable('CDR(linkedid)', true)
     ];
-    $agi->set_variable('MEETME_RECORDINGFILE',  $recordingfile);
-    $agi->set_variable('__pt1c_q_UNIQUEID',     $id);
+    $agi->set_variable('MEETME_RECORDINGFILE', $recordingfile);
+    $agi->set_variable('__pt1c_q_UNIQUEID', $id);
 
     return $data;
 }
@@ -610,11 +610,11 @@ 
 function Event_hangup_chan_meetme($agi, $action):array {
     $now  = Util::get_now_date();
     $data = [];
-    $data['action']  	= $action;
+    $data['action'] = $action;
     $data['linkedid']  	= $agi->get_variable('CDR(linkedid)', true);
     $data['src_chan']   = $agi->request['agi_channel'];
-    $data['agi_channel']= $agi->request['agi_channel'];
-    $data['end']  		= $now;
+    $data['agi_channel'] = $agi->request['agi_channel'];
+    $data['end'] = $now;
     $data['meetme_id'] 	= $agi->get_variable('MEETMEUNIQUEID', true);
     $data['conference'] = $agi->get_variable('mikoidconf', true);
     $data['UNIQUEID']   = $agi->get_variable('pt1c_q_UNIQUEID', true);
@@ -632,10 +632,10 @@ 
  * @param string $action
  * @return array
  */
-function Event_dial_app($agi, $action){
-    $id         = $agi->request['agi_uniqueid'] .'_'. Util::generateRandomString();
+function Event_dial_app($agi, $action) {
+    $id         = $agi->request['agi_uniqueid'].'_'.Util::generateRandomString();
     $extension 	= $agi->get_variable("APPEXTEN", true);
-    if(empty($extension)){
+    if (empty($extension)) {
         $extension = $agi->request['agi_extension'];
     }
 
@@ -655,21 +655,21 @@ 
  * @param string $action
  * @return array
  */
-function Event_dial_outworktimes($agi, $action){
+function Event_dial_outworktimes($agi, $action) {
     $data = Event_dial($agi, $action);
     $data['dst_chan']   = 'App:outworktimes';
-    $data['dst_num']  	= 'outworktimes';
+    $data['dst_num'] = 'outworktimes';
     $data['is_app']     = 1;
     return $data;
 }
 
 // Должны быть переданы параметры.
-if(count($argv)==1) exit;
+if (count($argv) == 1) exit;
 
 $action	    = trim($argv[1]);
 $func_name 	= "Event_$action";
 
-if( function_exists($func_name) ){
+if (function_exists($func_name)) {
     $agi = new AGI();
     // Сбор сведений по каналу.
 	$result = $func_name($agi, $action);

Braces +48 added lines, -29 removed lines

@@ -17,7 +17,8 @@ 
  * @param string $action
  * @return array
  */
-function Event_dial($agi, $action){
+function Event_dial($agi, $action)
+{
 	$now = Util::get_now_date();
     $data = array();
 	
@@ -37,7 +38,7 @@ 
 	if($QUEUE_SRC_CHAN != '' && $is_local){
 		// Это LOCAL, Переопределим на исходный. 
 		$channel = $QUEUE_SRC_CHAN;
-	}else if($is_local && (stripos($orign_chan, 'local/') === false)){
+	} else if($is_local && (stripos($orign_chan, 'local/') === false)){
         $channel = $orign_chan;
     }
 
@@ -63,7 +64,7 @@ 
 
         $id   = substr($agi->request['agi_uniqueid'],0, 16) .'_'.$num.'_'. $IS_ORGNT;
         $data['dst_chan'] 	 = $dst_chan;
-    }else{
+    } else{
         $src_num  	 = $agi->request['agi_callerid'];
         $dst_num  	 = $agi->request['agi_extension'];
     }
@@ -90,7 +91,8 @@ 
  * @param string $action
  * @return array
  */
-function Event_dial_create_chan($agi, $action){
+function Event_dial_create_chan($agi, $action)
+{
     $now = Util::get_now_date();
 	$data 	    = [];
 	$id   	    = $agi->get_variable("pt1c_UNIQUEID", true);
@@ -125,7 +127,8 @@ 
  * @param string $action
  * @return array
  */
-function Event_dial_answer($agi, $action){
+function Event_dial_answer($agi, $action)
+{
     $now = Util::get_now_date();
 
 	$id   = $agi->get_variable("pt1c_UNIQUEID", true);
@@ -162,7 +165,7 @@ 
     if('unknown' == $data['dnid'] && $PICKUPEER != ''){
         // Скорее всего ответ на вызов из 1С.
         $data['dnid']   = $pickupexten;
-    }elseif ($pickupexten == substr($data['dnid'], 0, 2) && $PICKUPEER != ''){
+    } elseif ($pickupexten == substr($data['dnid'], 0, 2) && $PICKUPEER != ''){
         // Это перехват при наборе номера *8XXX.
         $data['dnid']   = $pickupexten;
     }
@@ -183,7 +186,8 @@ 
  * @param string $action
  * @return array
  */
-function Event_dial_hangup_DEPRECATED($agi, $action){
+function Event_dial_hangup_DEPRECATED($agi, $action)
+{
     // TODO Удалить эту функцию в будущем.
     $now    = Util::get_now_date();
 	$data 	= array();
@@ -205,7 +209,8 @@ 
  * @param string $action
  * @return array
  */
-function Event_transfer_dial($agi, $action){
+function Event_transfer_dial($agi, $action)
+{
     $now = Util::get_now_date();
 	$id   = $agi->request['agi_uniqueid'] .'_'. Util::generateRandomString();
 
@@ -216,12 +221,12 @@ 
     if( $QUEUE_SRC_CHAN != '' && $is_local ){
         // Это LOCAL, Переопределим на исходный.
         $channel = $QUEUE_SRC_CHAN;
-    }else if( $QUEUE_SRC_CHAN != '' && $TRANSFERERNAME == '' ){
+    } else if( $QUEUE_SRC_CHAN != '' && $TRANSFERERNAME == '' ){
         // Это редирект на очередь.
         $channel = $QUEUE_SRC_CHAN;
-    }else if($TRANSFERERNAME == ''){
+    } else if($TRANSFERERNAME == ''){
         $channel = $agi->request['agi_channel'];
-    }else{
+    } else{
         $channel = $TRANSFERERNAME;
     }
 
@@ -248,7 +253,8 @@ 
  * @param string $action
  * @return array
  */
-function Event_transfer_dial_create_chan($agi, $action){
+function Event_transfer_dial_create_chan($agi, $action)
+{
 	$id  	= $agi->get_variable("transfer_UNIQUEID", true);
 	$data   = array();
 	$data['dst_chan'] 			= $agi->request['agi_channel'];
@@ -265,7 +271,8 @@ 
  * @param string $action
  * @return array
  */
-function Event_transfer_dial_answer($agi, $action){
+function Event_transfer_dial_answer($agi, $action)
+{
 	$data 	= array();
     $now    = Util::get_now_date();
 	$id   	= $agi->get_variable("transfer_UNIQUEID", true);
@@ -284,7 +291,8 @@ 
  * @param string $action
  * @return array
  */
-function Event_transfer_dial_hangup($agi, $action){
+function Event_transfer_dial_hangup($agi, $action)
+{
     $now    = Util::get_now_date();
 	$data 	= array();
 	$data['end']  		  = $now;
@@ -297,7 +305,7 @@ 
 	$pos = stripos( $data['agi_channel'], 'local/');
 	if($pos === false){
 		// Если это завершение переадресации (консультативной). Создадим новую строку CDR.
-	}else{
+	} else{
 		// Если пришел локальный канал:
 		$data['TRANSFERERNAME'] = $agi->get_variable("TRANSFERERNAME", 	true);
 		$data['ANSWEREDTIME'] 	= $agi->get_variable("ANSWEREDTIME", 	true);
@@ -313,7 +321,8 @@ 
  * @param string $action
  * @return array
  */
-function Event_hangup_chan($agi, $action){
+function Event_hangup_chan($agi, $action)
+{
     $now    = Util::get_now_date();
 	$data 	= [];
     $data['action']  	    = "$action";
@@ -340,7 +349,8 @@ 
  * @param string $action
  * @return array
  */
-function Event_unpark_call($agi, $action){
+function Event_unpark_call($agi, $action)
+{
     $now    = Util::get_now_date();
 	// Обработка данных парковки. 
 	$exten	= $agi->get_variable("EXTEN", 	true);
@@ -369,12 +379,12 @@ 
 		$data['src_num']  	= $agi->request['agi_callerid'];
 		$data['dst_num']  	= $agi->request['agi_extension'];
 		$data['dst_chan'] 	= 'Park:'.$agi->request['agi_extension'];
-	}else if(true == $park_row['pt1c_is_dst']){
+	} else if(true == $park_row['pt1c_is_dst']){
 		$data['src_chan'] 	= $channel;
 		$data['dst_chan'] 	= $park_row['ParkeeChannel'];
 		$data['src_num']  	= $agi->request['agi_callerid'];
 		$data['dst_num']  	= $park_row['ParkeeCallerIDNum'];
-	}else{
+	} else{
 		$data['src_chan'] 	= $park_row['ParkeeChannel'];
 		$data['dst_chan'] 	= $channel;
 		$data['src_num']  	= $park_row['ParkeeCallerIDNum'];
@@ -408,7 +418,8 @@ 
  * @param string $action
  * @return array
  */
-function Event_unpark_call_timeout($agi, $action){
+function Event_unpark_call_timeout($agi, $action)
+{
     $now  = Util::get_now_date();
 	$id   = $agi->request['agi_uniqueid'] .'_'. Util::generateRandomString();
 	// PARKER=SIP/206
@@ -446,7 +457,8 @@ 
  * @param string $action
  * @return array
  */
-function Event_queue_start($agi, $action){
+function Event_queue_start($agi, $action)
+{
     $now  = Util::get_now_date();
     $time_start = null;
     $id = $agi->get_variable("pt1c_UNIQUEID",  true);
@@ -480,7 +492,7 @@ 
     }
     if(!empty($ISTRANSFER)){
         $data['transfer']  	= '1';
-    }else{
+    } else{
         $data['transfer']  	= '0';
     }
 
@@ -493,7 +505,8 @@ 
  * @param string $action
  * @return array
  */
-function Event_queue_answer($agi, $action){
+function Event_queue_answer($agi, $action)
+{
     $now  = Util::get_now_date();
 	$id   = $agi->get_variable("pt1c_q_UNIQUEID", true);
 	$data = array();
@@ -512,7 +525,8 @@ 
  * @param string $action
  * @return array
  */
-function Event_queue_end($agi, $action){
+function Event_queue_end($agi, $action)
+{
     $now  = Util::get_now_date();
 	$id   = $agi->get_variable("pt1c_q_UNIQUEID", true);
 	$data = array();
@@ -532,7 +546,8 @@ 
  * @param string $action
  * @return array
  */
-function Event_meetme_dial($agi, $action){
+function Event_meetme_dial($agi, $action)
+{
     $now        = Util::get_now_date();
     $id         = '';
     $time_start = $now;
@@ -561,7 +576,7 @@ 
         }
         $src_num= $callid;
         $dst_num= $exten;
-    }else{
+    } else{
         $mikoidconf     = $agi->get_variable('mikoidconf', true);
         if(empty($mikoidconf)){
             $mikoidconf = $exten;
@@ -632,7 +647,8 @@ 
  * @param string $action
  * @return array
  */
-function Event_dial_app($agi, $action){
+function Event_dial_app($agi, $action)
+{
     $id         = $agi->request['agi_uniqueid'] .'_'. Util::generateRandomString();
     $extension 	= $agi->get_variable("APPEXTEN", true);
     if(empty($extension)){
@@ -655,7 +671,8 @@ 
  * @param string $action
  * @return array
  */
-function Event_dial_outworktimes($agi, $action){
+function Event_dial_outworktimes($agi, $action)
+{
     $data = Event_dial($agi, $action);
     $data['dst_chan']   = 'App:outworktimes';
     $data['dst_num']  	= 'outworktimes';
@@ -664,7 +681,9 @@ 
 }
 
 // Должны быть переданы параметры.
-if(count($argv)==1) exit;
+if(count($argv)==1) {
+    exit;
+}
 
 $action	    = trim($argv[1]);
 $func_name 	= "Event_$action";

etc/asterisk/agi-bin/phpagi-asmanager.php

Spacing +109 added lines, -109 removed lines

@@ -88,7 +88,7 @@ 
      * @param string $config is the name of the config file to parse or a parent agi from which to read the config
      * @param array  $optconfig is an array of configuration vars and vals, stuffed into $this->config['asmanager']
      */
-    function __construct($config = NULL, $optconfig = array()){
+    function __construct($config = NULL, $optconfig = array()) {
         // load config
         if (!is_null($config) && file_exists($config)) $this->config = parse_ini_file($config, true); elseif (file_exists(DEFAULT_PHPAGI_CONFIG)) $this->config = parse_ini_file(DEFAULT_PHPAGI_CONFIG, true);
 
@@ -109,11 +109,11 @@ 
      * @param array  $parameters
      * @return array of parameters
      */
-    function send_request($action, $parameters = array()){
+    function send_request($action, $parameters = array()) {
         $req = "Action: $action\r\n";
         foreach ($parameters as $var => $val) $req .= "$var: $val\r\n";
         $req .= "\r\n";
-        if(!is_resource($this->socket)){
+        if (!is_resource($this->socket)) {
             return array();
         }
         @fwrite($this->socket, $req);
@@ -127,11 +127,11 @@ 
      * @param array  $parameters
      * @return array of parameters
      */
-    function send_request_timeout($action, $parameters = array()){
+    function send_request_timeout($action, $parameters = array()) {
         $req = "Action: $action\r\n";
         foreach ($parameters as $var => $val) $req .= "$var: $val\r\n";
         $req .= "\r\n";
-        if(!is_resource($this->socket)){
+        if (!is_resource($this->socket)) {
             return array();
         }
         @fwrite($this->socket, $req);
@@ -143,9 +143,9 @@ 
      * @param string $pingname
      * @return array|bool
      */
-    function ping_ami_listner($pingname = 'CdrConnector'){
+    function ping_ami_listner($pingname = 'CdrConnector') {
         // Установим фильтр на события.
-        $params   = ['Operation'=>'Add', 'Filter' => 'Event: UserEvent'];
+        $params = ['Operation'=>'Add', 'Filter' => 'Event: UserEvent'];
         $this->send_request_timeout('Filter', $params);
         // Отправим пинг.
         $req = '';
@@ -155,7 +155,7 @@ 
         );
         foreach ($parameters as $var => $val) $req .= "$var: $val\r\n";
         $req .= "\r\n";
-        if(!is_resource($this->socket)){
+        if (!is_resource($this->socket)) {
             return array();
         }
         @fwrite($this->socket, $req);
@@ -169,14 +169,14 @@ 
         do {
             $type       = '';
             $parameters = [];
-            if(!is_resource($this->socket)){
+            if (!is_resource($this->socket)) {
                 return false;
             }
             $buffer = trim(@fgets($this->socket, 4096));
             while ($buffer != '') {
                 $a = strpos($buffer, ':');
                 if ($a) {
-                    if (!count($parameters)){
+                    if (!count($parameters)) {
                         $type = strtolower(substr($buffer, 0, $a));
                     }
                     $parameters[substr($buffer, 0, $a)] = substr($buffer, $a + 2);
@@ -184,16 +184,16 @@ 
                 $buffer = trim(fgets($this->socket, 4096));
             }
 
-            if($type == '' && count($this->Ping())==0){
+            if ($type == '' && count($this->Ping()) == 0) {
                 $timeout = true;
             }
-            else if('event' == $type && $parameters['Event'] == 'UserEvent' && "{$pingname}Pong" == $parameters['UserEvent']){
+            else if ('event' == $type && $parameters['Event'] == 'UserEvent' && "{$pingname}Pong" == $parameters['UserEvent']) {
                 // Ответ получен.
                 $result = true;
                 break;
             }
             $time = $this->microtime_float() - $time_start;
-            if($time > 2){
+            if ($time > 2) {
                 // Таймаут ожидания.
                 break;
             }
@@ -203,11 +203,11 @@ 
         return $result;
     }
 
-    private function wait_response_get_sub_data(&$parameters, $end_string = '', $event_as_array=true):void {
-        if(!is_array($parameters)){
+    private function wait_response_get_sub_data(&$parameters, $end_string = '', $event_as_array = true):void {
+        if (!is_array($parameters)) {
             $parameters = [];
         }
-        if(empty($end_string)){
+        if (empty($end_string)) {
             return;
         }
         $parameters['data'] = array();
@@ -218,10 +218,10 @@ 
             $buff   = fgets($this->socket, 4096);
             $a_pos  = strpos($buff, ':');
             if (!$a_pos) {
-                if (count($m)>0) {
-                    if($event_as_array){
+                if (count($m) > 0) {
+                    if ($event_as_array) {
                         $parameters['data'][$m['Event']][] = $m;
-                    }else{
+                    } else {
                         $parameters['data'][$m['Event']] = $m;
                     }
                 }
@@ -251,7 +251,7 @@ 
         do {
             $type = NULL;
             $parameters = array();
-            if(!is_resource($this->socket)){
+            if (!is_resource($this->socket)) {
                 return $parameters;
             }
             $buffer = trim(@fgets($this->socket, 4096));
@@ -260,7 +260,7 @@ 
                 if ($a) {
                     $key = ''; $value = '';
                     $event_text = substr($buffer, $a + 2);
-                    if (!count($parameters)){
+                    if (!count($parameters)) {
                         $type = strtolower(substr($buffer, 0, $a));
                         if ($event_text === 'Follows') {
                             // A follows response means there is a miltiline field that follows.
@@ -308,7 +308,7 @@ 
                         // MeetmeList
                         $this->wait_response_get_sub_data($parameters, 'MeetmeListRoomsComplete');
                     }
-                    unset($key,$value);
+                    unset($key, $value);
                     // store parameter in $parameters
                     $parameters[substr($buffer, 0, $a)] = $event_text;
                 }
@@ -327,7 +327,7 @@ 
                 case 'response':
                     break;
                 default:
-                    $this->log('Unhandled response packet from Manager: ' . print_r($parameters, true));
+                    $this->log('Unhandled response packet from Manager: '.print_r($parameters, true));
                     break;
             }
         } while ($type !== 'response' && !$timeout);
@@ -339,30 +339,30 @@ 
      * @param $allow_timeout bool
      * @return array of parameters, empty on timeout
      */
-    function wait_user_event($allow_timeout = false){
+    function wait_user_event($allow_timeout = false) {
         $timeout = false;
         do {
             $type       = '';
             $parameters = [];
-            try{
+            try {
                 $buffer = trim(@fgets($this->socket, 4096));
-            }catch (Exception $e){
+            } catch (Exception $e) {
                 return false;
             }
             while ($buffer != '') {
                 $a = strpos($buffer, ':');
                 if ($a) {
-                    if (!count($parameters)){
+                    if (!count($parameters)) {
                         $type = strtolower(substr($buffer, 0, $a));
                     }
                     $parameters[substr($buffer, 0, $a)] = substr($buffer, $a + 2);
                 }
                 $buffer = trim(fgets($this->socket, 4096));
             }
-            if($type == '' && count($this->Ping())==0){
+            if ($type == '' && count($this->Ping()) == 0) {
                 $timeout = $allow_timeout;
             }
-            else if('event' == $type){
+            else if ('event' == $type) {
                 $this->process_event($parameters);
             }
         } while (!$timeout);
@@ -380,7 +380,7 @@ 
      * @param string $events
      * @return boolean true on success
      */
-    function connect($server = NULL, $username = NULL, $secret = NULL, $events = 'on'){
+    function connect($server = NULL, $username = NULL, $secret = NULL, $events = 'on') {
         // use config if not specified
         if (is_null($server)) $server = $this->config['asmanager']['server'];
         if (is_null($username)) $username = $this->config['asmanager']['username'];
@@ -428,7 +428,7 @@ 
         return true;
     }
 
-    public function logged_in(){
+    public function logged_in() {
         return $this->_logged_in;
     }
 
@@ -437,9 +437,9 @@ 
      *
      * @example examples/sip_show_peer.php Get information about a sip peer
      */
-    function disconnect(){
+    function disconnect() {
         if ($this->_logged_in == TRUE) $this->logoff();
-        if(is_resource($this->socket)){
+        if (is_resource($this->socket)) {
             fclose($this->socket);
         }
     }
@@ -458,7 +458,7 @@ 
      * @param integer $timeout Maximum duration of the call (sec)
      * @return array
      */
-    function AbsoluteTimeout($channel, $timeout){
+    function AbsoluteTimeout($channel, $timeout) {
         return $this->send_request('AbsoluteTimeout', array('Channel' => $channel, 'Timeout' => $timeout));
     }
 
@@ -470,7 +470,7 @@ 
      * @param string $file the new name of the file created in the monitor spool directory.
      * @return array
      */
-    function ChangeMonitor($channel, $file){
+    function ChangeMonitor($channel, $file) {
         return $this->send_request('ChangeMontior', array('Channel' => $channel, 'File' => $file));
     }
 
@@ -484,7 +484,7 @@ 
      * @param string $actionid message matching variable
      * @return array
      */
-    function Command($command, $actionid = NULL){
+    function Command($command, $actionid = NULL) {
         $parameters = array('Command' => $command);
         if ($actionid) $parameters['ActionID'] = $actionid;
         return $this->send_request('Command', $parameters);
@@ -497,7 +497,7 @@ 
      * @param string $eventmask is either 'on', 'off', or 'system,call,log'
      * @return array
      */
-    function Events($eventmask){
+    function Events($eventmask) {
         return $this->send_request('Events', array('EventMask' => $eventmask));
     }
 
@@ -510,7 +510,7 @@ 
      * @param string $actionid message matching variable
      * @return array
      */
-    function ExtensionState($exten, $context, $actionid = NULL){
+    function ExtensionState($exten, $context, $actionid = NULL) {
         $parameters = array('Exten' => $exten, 'Context' => $context);
         if ($actionid) $parameters['ActionID'] = $actionid;
         return $this->send_request('ExtensionState', $parameters);
@@ -527,15 +527,15 @@ 
      * @param boolean $ret_array
      * @return string | array
      */
-    function GetVar($channel, $variable, $actionid = NULL, $ret_array = true){
+    function GetVar($channel, $variable, $actionid = NULL, $ret_array = true) {
         $parameters = array('Channel' => $channel, 'Variable' => $variable);
-        if ($actionid){
+        if ($actionid) {
             $parameters['ActionID'] = $actionid;
         }
 
         $data = $this->send_request('GetVar', $parameters);
-        if($ret_array != true){
-            $data = (isset($data['Value']) && $data['Value'] )?$data['Value']:'';
+        if ($ret_array != true) {
+            $data = (isset($data['Value']) && $data['Value']) ? $data['Value'] : '';
         }
         return $data;
     }
@@ -545,21 +545,21 @@ 
      * @param boolean $group
      * @return array
      */
-    public function GetChannels($group = true){
-        $res 	  = $this->send_request_timeout('CoreShowChannels');
+    public function GetChannels($group = true) {
+        $res = $this->send_request_timeout('CoreShowChannels');
         $channels = null;
-        if(isset($res['data']['CoreShowChannel'])){
+        if (isset($res['data']['CoreShowChannel'])) {
             $channels = $res['data']['CoreShowChannel'];
         }
         $channels_id = array();
-        if(null != $channels){
-            foreach($channels as $chan){
-                if($group == true){
-                    if(! isset($chan['Linkedid']) ){
+        if (null != $channels) {
+            foreach ($channels as $chan) {
+                if ($group == true) {
+                    if (!isset($chan['Linkedid'])) {
                         continue;
                     }
                     $channels_id[$chan['Linkedid']][] = $chan['Channel'];
-                }else{
+                } else {
                     $channels_id[] = $chan['Channel'];
                 }
             }
@@ -575,7 +575,7 @@ 
      * @param string $channel The channel name to be hungup
      * @return array
      */
-    function Hangup($channel){
+    function Hangup($channel) {
         return $this->send_request('Hangup', array('Channel' => $channel));
     }
 
@@ -585,10 +585,10 @@ 
      * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+IAXpeers
      * @return array
      */
-    function IAXpeerlist(){
+    function IAXpeerlist() {
         $result = $this->send_request('IAXpeerlist');
-        $data = (isset($result['data']) && is_array($result['data']))?$result['data']:[];
-        $arr_peer = (isset($data['PeerEntry']) && is_array($data['PeerEntry']))?$data['PeerEntry']:[];
+        $data = (isset($result['data']) && is_array($result['data'])) ? $result['data'] : [];
+        $arr_peer = (isset($data['PeerEntry']) && is_array($data['PeerEntry'])) ? $data['PeerEntry'] : [];
         return $arr_peer;
     }
 
@@ -596,10 +596,10 @@ 
      * Возвращает регистрации пиров.
      * @return array
      */
-    function IAXregistry(){
+    function IAXregistry() {
         $result = $this->send_request('IAXregistry');
-        $data = (isset($result['data']) && is_array($result['data']))?$result['data']:[];
-        $arr_peer = (isset($data['RegistryEntry']) && is_array($data['RegistryEntry']))?$data['RegistryEntry']:[];
+        $data = (isset($result['data']) && is_array($result['data'])) ? $result['data'] : [];
+        $arr_peer = (isset($data['RegistryEntry']) && is_array($data['RegistryEntry'])) ? $data['RegistryEntry'] : [];
         return $arr_peer;
     }
 
@@ -610,7 +610,7 @@ 
      * @param string $actionid message matching variable
      * @return array
      */
-    function ListCommands($actionid = NULL){
+    function ListCommands($actionid = NULL) {
         if ($actionid) return $this->send_request('ListCommands', array('ActionID' => $actionid)); else
             return $this->send_request('ListCommands');
     }
@@ -621,7 +621,7 @@ 
      * @param  array  $headers
      * @return array
      */
-    function UserEvent($name, $headers){
+    function UserEvent($name, $headers) {
         $headers['UserEvent'] = $name;
         return $this->send_request_timeout('UserEvent', $headers);
     }
@@ -631,7 +631,7 @@ 
      *
      * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+Logoff
      */
-    function Logoff(){
+    function Logoff() {
         return $this->send_request_timeout('Logoff');
     }
 
@@ -649,7 +649,7 @@ 
      * @param string $actionid message matching variable
      * @return array
      */
-    function MailboxCount($mailbox, $actionid = NULL){
+    function MailboxCount($mailbox, $actionid = NULL) {
         $parameters = array('Mailbox' => $mailbox);
         if ($actionid) $parameters['ActionID'] = $actionid;
         return $this->send_request('MailboxCount', $parameters);
@@ -668,7 +668,7 @@ 
      * @param string $actionid message matching variable
      * @return array
      */
-    function MailboxStatus($mailbox, $actionid = NULL){
+    function MailboxStatus($mailbox, $actionid = NULL) {
         $parameters = array('Mailbox' => $mailbox);
         if ($actionid) $parameters['ActionID'] = $actionid;
         return $this->send_request('MailboxStatus', $parameters);
@@ -684,7 +684,7 @@ 
      * @param boolean $mix
      * @return array
      */
-    function Monitor($channel, $file = NULL, $format = NULL, $mix = NULL){
+    function Monitor($channel, $file = NULL, $format = NULL, $mix = NULL) {
         $parameters = array('Channel' => $channel);
         if ($file) $parameters['File'] = $file;
         if ($format) $parameters['Format'] = $format;
@@ -702,7 +702,7 @@ 
      * @param string $command
      * @return array
      */
-    function MixMonitor($channel, $file, $options, $command){
+    function MixMonitor($channel, $file, $options, $command) {
         $parameters = array('Channel' => $channel);
         $parameters['File'] = $file;
         $parameters['options'] = $options;
@@ -717,7 +717,7 @@ 
      * @param string $channel
      * @return array
      */
-    function StopMixMonitor($channel){
+    function StopMixMonitor($channel) {
         $parameters = array('Channel' => $channel);
         return $this->send_request_timeout('StopMixMonitor', $parameters);
     }
@@ -730,7 +730,7 @@ 
      * @param string $Val
      * @return array
      */
-    function DBPut($Family, $Key, $Val = ''){
+    function DBPut($Family, $Key, $Val = '') {
         $parameters = array('Family' => $Family, 'Key' => $Key, 'Val' => $Val);
         $res_data = $this->send_request_timeout('DBPut', $parameters);
         return $res_data;
@@ -742,8 +742,8 @@ 
      * @param $ActionID
      * @return array
      */
-    public function MeetmeList($Conference, $ActionID=''):array {
-        if(empty($ActionID)){
+    public function MeetmeList($Conference, $ActionID = ''):array {
+        if (empty($ActionID)) {
             $ActionID = Util::generateRandomString(5);
         }
         $parameters = [
@@ -758,8 +758,8 @@ 
      * @param $ActionID
      * @return array
      */
-    public function MeetmeListRooms($ActionID=''):array {
-        if(empty($ActionID)){
+    public function MeetmeListRooms($ActionID = ''):array {
+        if (empty($ActionID)) {
             $ActionID = Util::generateRandomString(5);
         }
         $parameters = [
@@ -775,7 +775,7 @@ 
      * @param string $Key
      * @return array
      */
-    function DBGet($Family, $Key){
+    function DBGet($Family, $Key) {
         $parameters = array('Family' => $Family, 'Key' => $Key);
         return $this->send_request_timeout('DBGet', $parameters);
     }
@@ -798,7 +798,7 @@ 
      * @param string  $actionid message matching variable
      * @return array
      */
-    function Originate($channel, $exten = NULL, $context = NULL, $priority = NULL, $application = NULL, $data = NULL, $timeout = NULL, $callerid = NULL, $variable = NULL, $account = NULL, $async = NULL, $actionid = NULL){
+    function Originate($channel, $exten = NULL, $context = NULL, $priority = NULL, $application = NULL, $data = NULL, $timeout = NULL, $callerid = NULL, $variable = NULL, $account = NULL, $async = NULL, $actionid = NULL) {
         $parameters = array('Channel' => $channel);
 
         if ($exten) $parameters['Exten'] = $exten;
@@ -826,12 +826,12 @@ 
      * @param string $parkinglot message matching variable
      * @return array
      */
-    function ParkedCalls($parkinglot = NULL, $actionid = NULL){
+    function ParkedCalls($parkinglot = NULL, $actionid = NULL) {
         $parameters = [];
-        if ($actionid){
+        if ($actionid) {
             $parameters['ActionID'] = $actionid;
         }
-        if ($parkinglot){
+        if ($parkinglot) {
             $parameters['ParkingLot'] = $parkinglot;
         }
         $result = $this->send_request_timeout('ParkedCalls', $parameters);
@@ -844,7 +844,7 @@ 
      *
      * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+Ping
      */
-    function Ping(){
+    function Ping() {
         return $this->send_request_timeout('Ping');
     }
 
@@ -857,7 +857,7 @@ 
      * @param integer $penalty
      * @return array
      */
-    function QueueAdd($queue, $interface, $penalty = 0){
+    function QueueAdd($queue, $interface, $penalty = 0) {
         $parameters = array('Queue' => $queue, 'Interface' => $interface);
         if ($penalty) $parameters['Penalty'] = $penalty;
         return $this->send_request('QueueAdd', $parameters);
@@ -871,7 +871,7 @@ 
      * @param string $interface
      * @return array
      */
-    function QueueRemove($queue, $interface){
+    function QueueRemove($queue, $interface) {
         return $this->send_request('QueueRemove', array('Queue' => $queue, 'Interface' => $interface));
     }
 
@@ -880,7 +880,7 @@ 
      *
      * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+Queues
      */
-    function Queues(){
+    function Queues() {
         return $this->send_request('Queues');
     }
 
@@ -891,7 +891,7 @@ 
      * @param string $actionid message matching variable
      * @return array
      */
-    function QueueStatus($actionid = NULL){
+    function QueueStatus($actionid = NULL) {
         if ($actionid) return $this->send_request('QueueStatus', array('ActionID' => $actionid)); else
             return $this->send_request('QueueStatus');
     }
@@ -907,7 +907,7 @@ 
      * @param string $priority
      * @return array
      */
-    function Redirect($channel, $extrachannel, $exten, $context, $priority){
+    function Redirect($channel, $extrachannel, $exten, $context, $priority) {
         return $this->send_request('Redirect', array('Channel' => $channel, 'ExtraChannel' => $extrachannel, 'Exten' => $exten, 'Context' => $context, 'Priority' => $priority));
     }
 
@@ -920,7 +920,7 @@ 
      * @param string $append
      * @return array
      */
-    function SetCDRUserField($userfield, $channel, $append = NULL){
+    function SetCDRUserField($userfield, $channel, $append = NULL) {
         $parameters = array('UserField' => $userfield, 'Channel' => $channel);
         if ($append) $parameters['Append'] = $append;
         return $this->send_request('SetCDRUserField', $parameters);
@@ -935,7 +935,7 @@ 
      * @param string $value
      * @return array
      */
-    function SetVar($channel, $variable, $value){
+    function SetVar($channel, $variable, $value) {
         return $this->send_request('SetVar', array('Channel' => $channel, 'Variable' => $variable, 'Value' => $value));
     }
 
@@ -947,7 +947,7 @@ 
      * @param string $actionid message matching variable
      * @return array
      */
-    function Status($channel, $actionid = NULL){
+    function Status($channel, $actionid = NULL) {
         $parameters = array('Channel' => $channel);
         if ($actionid) $parameters['ActionID'] = $actionid;
         return $this->send_request('Status', $parameters);
@@ -960,7 +960,7 @@ 
      * @param string $channel
      * @return array
      */
-    function StopMonitor($channel){
+    function StopMonitor($channel) {
         return $this->send_request('StopMonitor', array('Channel' => $channel));
     }
 
@@ -972,7 +972,7 @@ 
      * Полученире текущих регистраций.
      * @return array
      */
-    public function get_sip_registry(){
+    public function get_sip_registry() {
         $peers = array();
         $result = $this->send_request_timeout('SIPshowregistry');
         if ($result['data'] !== null && $result['data']['RegistryEntry'] !== null) {
@@ -995,7 +995,7 @@ 
     public function get_pj_sip_registry():array {
         $peers  = [];
         $result = $this->send_request_timeout('PJSIPShowRegistrationsOutbound');
-        if ( isset($result['data']['OutboundRegistrationDetail']) ) {
+        if (isset($result['data']['OutboundRegistrationDetail'])) {
             foreach ($result['data']['OutboundRegistrationDetail'] as $peer) {
                 [$sip, $host, $port] = explode(':', $peer['ServerUri']);
                 $peers[] = array(
@@ -1017,9 +1017,9 @@ 
     public function get_pj_sip_peers():array {
         $peers = [];
         $result = $this->send_request_timeout('PJSIPShowEndpoints');
-        if ( isset($result['data']['EndpointList']) ) {
+        if (isset($result['data']['EndpointList'])) {
             foreach ($result['data']['EndpointList'] as $peer) {
-                if($peer['ObjectName'] === 'anonymous'){
+                if ($peer['ObjectName'] === 'anonymous') {
                     continue;
                 }
 
@@ -1042,7 +1042,7 @@ 
      * Получение статусов пиров.
      * @return array
      */
-    function get_sip_peers(){
+    function get_sip_peers() {
         $peers = array();
         $res = $this->send_request_timeout('SIPpeers');
         if (isset($res['data']) && $res['data'] != null && $res['data']['PeerEntry'] != null) {
@@ -1061,12 +1061,12 @@ 
      * @param $peer
      * @return array
      */
-    function get_sip_peer($peer){
+    function get_sip_peer($peer) {
         $parameters = ['Peer' => trim($peer)];
         $res = $this->send_request_timeout('SIPshowpeer', $parameters);
         $arr_status          = explode(' ', $res['Status']);
         $res['state']        = strtoupper($arr_status[0]);
-        $res['time-response']= strtoupper(str_replace(['(', ')'],'',$arr_status[1]));
+        $res['time-response'] = strtoupper(str_replace(['(', ')'], '', $arr_status[1]));
         return $res;
     }
 
@@ -1075,15 +1075,15 @@ 
      * @param $peer
      * @return array
      */
-    function get_pj_sip_peer($peer){
+    function get_pj_sip_peer($peer) {
         $result = [];
         $parameters = ['Endpoint' => trim($peer)];
         $res = $this->send_request_timeout('PJSIPShowEndpoint', $parameters);
 
-        if(isset($res['data']['ContactStatusDetail'])){
+        if (isset($res['data']['ContactStatusDetail'])) {
             $result = $res['data']['ContactStatusDetail'];
         }
-        $result['state']  = isset($result['URI']) && !empty($result['URI']) ? 'OK' : 'UNKNOWN';
+        $result['state'] = isset($result['URI']) && !empty($result['URI']) ? 'OK' : 'UNKNOWN';
         return $result;
     }
 
@@ -1092,17 +1092,17 @@ 
      * @param array $vars
      * @return array
      */
-    public function meetMeCollectInfo($conference, $vars=[]):array {
+    public function meetMeCollectInfo($conference, $vars = []):array {
         $result = [];
         $conf_data = $this->MeetmeList($conference);
-        if(!isset($conf_data['data']['MeetmeList'])){
+        if (!isset($conf_data['data']['MeetmeList'])) {
             return $result;
         }
-        foreach ($conf_data['data']['MeetmeList'] as $user_data){
-            $user_data['linkedid']  = $this->GetVar($user_data['Channel'], 'CDR(linkedid)',  null, false);
+        foreach ($conf_data['data']['MeetmeList'] as $user_data) {
+            $user_data['linkedid']  = $this->GetVar($user_data['Channel'], 'CDR(linkedid)', null, false);
             $user_data['meetme_id'] = $this->GetVar($user_data['Channel'], 'MEETMEUNIQUEID', null, false);
 
-            foreach ($vars as $var){
+            foreach ($vars as $var) {
                 $user_data[$var] = $this->GetVar($user_data['Channel'], $var, null, false);
             }
 
@@ -1127,14 +1127,14 @@ 
      * @param string $message
      * @param integer $level from 1 to 4
      */
-    function log($message, $level = 1){
+    function log($message, $level = 1) {
         if ($this->pagi != false) $this->pagi->conlog($message, $level);
 
     }
 
-    function microtime_float(){
+    function microtime_float() {
         list($usec, $sec) = explode(" ", microtime());
-        return ((float)$usec + (float)$sec);
+        return ((float) $usec + (float) $sec);
     }
 
     /**
@@ -1177,7 +1177,7 @@ 
      * @param string | array $callback function
      * @return boolean sucess
      */
-    function add_event_handler($event, $callback){
+    function add_event_handler($event, $callback) {
         $event = strtolower($event);
         if (isset($this->event_handlers[$event])) {
             $this->log("$event handler is already defined, not over-writing.");
@@ -1194,21 +1194,21 @@ 
      * @param array $parameters
      * @return mixed result of event handler or false if no handler was found
      */
-    function process_event($parameters){
+    function process_event($parameters) {
         $ret = false;
         $e = strtolower($parameters['Event']);
         $this->log("Got event.. $e");
 
         $handler = '';
-        if (isset($this->event_handlers[$e])){
+        if (isset($this->event_handlers[$e])) {
             $handler = $this->event_handlers[$e];
         }
-        elseif (isset($this->event_handlers['*'])){
+        elseif (isset($this->event_handlers['*'])) {
             $handler = $this->event_handlers['*'];
         }
-        if(is_array($handler)){
+        if (is_array($handler)) {
             call_user_func($handler, $parameters);
-        }else if (function_exists($handler)) {
+        } else if (function_exists($handler)) {
             $this->log("Execute handler $handler");
             $ret = $handler($e, $parameters, $this->server, $this->port);
         } else

Braces +228 added lines, -101 removed lines

@@ -26,7 +26,8 @@ 
  * @example examples/sip_show_peer.php Get information about a sip peer
  * @package phpAGI
  */
-class AGI_AsteriskManager {
+class AGI_AsteriskManager
+{
     /**
      * Config variables
      *
@@ -88,18 +89,33 @@ 
      * @param string $config is the name of the config file to parse or a parent agi from which to read the config
      * @param array  $optconfig is an array of configuration vars and vals, stuffed into $this->config['asmanager']
      */
-    function __construct($config = NULL, $optconfig = array()){
+    function __construct($config = NULL, $optconfig = array())
+    {
         // load config
-        if (!is_null($config) && file_exists($config)) $this->config = parse_ini_file($config, true); elseif (file_exists(DEFAULT_PHPAGI_CONFIG)) $this->config = parse_ini_file(DEFAULT_PHPAGI_CONFIG, true);
+        if (!is_null($config) && file_exists($config)) {
+            $this->config = parse_ini_file($config, true);
+        } elseif (file_exists(DEFAULT_PHPAGI_CONFIG)) {
+            $this->config = parse_ini_file(DEFAULT_PHPAGI_CONFIG, true);
+        }
 
         // If optconfig is specified, stuff vals and vars into 'asmanager' config array.
-        foreach ($optconfig as $var => $val) $this->config['asmanager'][$var] = $val;
+        foreach ($optconfig as $var => $val) {
+            $this->config['asmanager'][$var] = $val;
+        }
 
         // add default values to config for uninitialized values
-        if (!isset($this->config['asmanager']['server'])) $this->config['asmanager']['server'] = 'localhost';
-        if (!isset($this->config['asmanager']['port'])) $this->config['asmanager']['port'] = 5038;
-        if (!isset($this->config['asmanager']['username'])) $this->config['asmanager']['username'] = 'phpagi';
-        if (!isset($this->config['asmanager']['secret'])) $this->config['asmanager']['secret'] = 'phpagi';
+        if (!isset($this->config['asmanager']['server'])) {
+            $this->config['asmanager']['server'] = 'localhost';
+        }
+        if (!isset($this->config['asmanager']['port'])) {
+            $this->config['asmanager']['port'] = 5038;
+        }
+        if (!isset($this->config['asmanager']['username'])) {
+            $this->config['asmanager']['username'] = 'phpagi';
+        }
+        if (!isset($this->config['asmanager']['secret'])) {
+            $this->config['asmanager']['secret'] = 'phpagi';
+        }
     }
 
     /**
@@ -109,9 +125,12 @@ 
      * @param array  $parameters
      * @return array of parameters
      */
-    function send_request($action, $parameters = array()){
+    function send_request($action, $parameters = array())
+    {
         $req = "Action: $action\r\n";
-        foreach ($parameters as $var => $val) $req .= "$var: $val\r\n";
+        foreach ($parameters as $var => $val) {
+            $req .= "$var: $val\r\n";
+        }
         $req .= "\r\n";
         if(!is_resource($this->socket)){
             return array();
@@ -127,9 +146,12 @@ 
      * @param array  $parameters
      * @return array of parameters
      */
-    function send_request_timeout($action, $parameters = array()){
+    function send_request_timeout($action, $parameters = array())
+    {
         $req = "Action: $action\r\n";
-        foreach ($parameters as $var => $val) $req .= "$var: $val\r\n";
+        foreach ($parameters as $var => $val) {
+            $req .= "$var: $val\r\n";
+        }
         $req .= "\r\n";
         if(!is_resource($this->socket)){
             return array();
@@ -143,7 +165,8 @@ 
      * @param string $pingname
      * @return array|bool
      */
-    function ping_ami_listner($pingname = 'CdrConnector'){
+    function ping_ami_listner($pingname = 'CdrConnector')
+    {
         // Установим фильтр на события.
         $params   = ['Operation'=>'Add', 'Filter' => 'Event: UserEvent'];
         $this->send_request_timeout('Filter', $params);
@@ -153,7 +176,9 @@ 
             'Action'    => 'UserEvent',
             'UserEvent' => "{$pingname}Ping"
         );
-        foreach ($parameters as $var => $val) $req .= "$var: $val\r\n";
+        foreach ($parameters as $var => $val) {
+            $req .= "$var: $val\r\n";
+        }
         $req .= "\r\n";
         if(!is_resource($this->socket)){
             return array();
@@ -186,8 +211,7 @@ 
 
             if($type == '' && count($this->Ping())==0){
                 $timeout = true;
-            }
-            else if('event' == $type && $parameters['Event'] == 'UserEvent' && "{$pingname}Pong" == $parameters['UserEvent']){
+            } else if('event' == $type && $parameters['Event'] == 'UserEvent' && "{$pingname}Pong" == $parameters['UserEvent']){
                 // Ответ получен.
                 $result = true;
                 break;
@@ -221,7 +245,7 @@ 
                 if (count($m)>0) {
                     if($event_as_array){
                         $parameters['data'][$m['Event']][] = $m;
-                    }else{
+                    } else{
                         $parameters['data'][$m['Event']] = $m;
                     }
                 }
@@ -339,14 +363,15 @@ 
      * @param $allow_timeout bool
      * @return array of parameters, empty on timeout
      */
-    function wait_user_event($allow_timeout = false){
+    function wait_user_event($allow_timeout = false)
+    {
         $timeout = false;
         do {
             $type       = '';
             $parameters = [];
             try{
                 $buffer = trim(@fgets($this->socket, 4096));
-            }catch (Exception $e){
+            } catch (Exception $e){
                 return false;
             }
             while ($buffer != '') {
@@ -361,8 +386,7 @@ 
             }
             if($type == '' && count($this->Ping())==0){
                 $timeout = $allow_timeout;
-            }
-            else if('event' == $type){
+            } else if('event' == $type){
                 $this->process_event($parameters);
             }
         } while (!$timeout);
@@ -380,11 +404,18 @@ 
      * @param string $events
      * @return boolean true on success
      */
-    function connect($server = NULL, $username = NULL, $secret = NULL, $events = 'on'){
+    function connect($server = NULL, $username = NULL, $secret = NULL, $events = 'on')
+    {
         // use config if not specified
-        if (is_null($server)) $server = $this->config['asmanager']['server'];
-        if (is_null($username)) $username = $this->config['asmanager']['username'];
-        if (is_null($secret)) $secret = $this->config['asmanager']['secret'];
+        if (is_null($server)) {
+            $server = $this->config['asmanager']['server'];
+        }
+        if (is_null($username)) {
+            $username = $this->config['asmanager']['username'];
+        }
+        if (is_null($secret)) {
+            $secret = $this->config['asmanager']['secret'];
+        }
 
         // get port from server if specified
         if (strpos($server, ':') !== false) {
@@ -428,7 +459,8 @@ 
         return true;
     }
 
-    public function logged_in(){
+    public function logged_in()
+    {
         return $this->_logged_in;
     }
 
@@ -437,8 +469,11 @@ 
      *
      * @example examples/sip_show_peer.php Get information about a sip peer
      */
-    function disconnect(){
-        if ($this->_logged_in == TRUE) $this->logoff();
+    function disconnect()
+    {
+        if ($this->_logged_in == TRUE) {
+            $this->logoff();
+        }
         if(is_resource($this->socket)){
             fclose($this->socket);
         }
@@ -458,7 +493,8 @@ 
      * @param integer $timeout Maximum duration of the call (sec)
      * @return array
      */
-    function AbsoluteTimeout($channel, $timeout){
+    function AbsoluteTimeout($channel, $timeout)
+    {
         return $this->send_request('AbsoluteTimeout', array('Channel' => $channel, 'Timeout' => $timeout));
     }
 
@@ -470,7 +506,8 @@ 
      * @param string $file the new name of the file created in the monitor spool directory.
      * @return array
      */
-    function ChangeMonitor($channel, $file){
+    function ChangeMonitor($channel, $file)
+    {
         return $this->send_request('ChangeMontior', array('Channel' => $channel, 'File' => $file));
     }
 
@@ -484,9 +521,12 @@ 
      * @param string $actionid message matching variable
      * @return array
      */
-    function Command($command, $actionid = NULL){
+    function Command($command, $actionid = NULL)
+    {
         $parameters = array('Command' => $command);
-        if ($actionid) $parameters['ActionID'] = $actionid;
+        if ($actionid) {
+            $parameters['ActionID'] = $actionid;
+        }
         return $this->send_request('Command', $parameters);
     }
 
@@ -497,7 +537,8 @@ 
      * @param string $eventmask is either 'on', 'off', or 'system,call,log'
      * @return array
      */
-    function Events($eventmask){
+    function Events($eventmask)
+    {
         return $this->send_request('Events', array('EventMask' => $eventmask));
     }
 
@@ -510,9 +551,12 @@ 
      * @param string $actionid message matching variable
      * @return array
      */
-    function ExtensionState($exten, $context, $actionid = NULL){
+    function ExtensionState($exten, $context, $actionid = NULL)
+    {
         $parameters = array('Exten' => $exten, 'Context' => $context);
-        if ($actionid) $parameters['ActionID'] = $actionid;
+        if ($actionid) {
+            $parameters['ActionID'] = $actionid;
+        }
         return $this->send_request('ExtensionState', $parameters);
     }
 
@@ -527,7 +571,8 @@ 
      * @param boolean $ret_array
      * @return string | array
      */
-    function GetVar($channel, $variable, $actionid = NULL, $ret_array = true){
+    function GetVar($channel, $variable, $actionid = NULL, $ret_array = true)
+    {
         $parameters = array('Channel' => $channel, 'Variable' => $variable);
         if ($actionid){
             $parameters['ActionID'] = $actionid;
@@ -545,7 +590,8 @@ 
      * @param boolean $group
      * @return array
      */
-    public function GetChannels($group = true){
+    public function GetChannels($group = true)
+    {
         $res 	  = $this->send_request_timeout('CoreShowChannels');
         $channels = null;
         if(isset($res['data']['CoreShowChannel'])){
@@ -559,7 +605,7 @@ 
                         continue;
                     }
                     $channels_id[$chan['Linkedid']][] = $chan['Channel'];
-                }else{
+                } else{
                     $channels_id[] = $chan['Channel'];
                 }
             }
@@ -575,7 +621,8 @@ 
      * @param string $channel The channel name to be hungup
      * @return array
      */
-    function Hangup($channel){
+    function Hangup($channel)
+    {
         return $this->send_request('Hangup', array('Channel' => $channel));
     }
 
@@ -585,7 +632,8 @@ 
      * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+IAXpeers
      * @return array
      */
-    function IAXpeerlist(){
+    function IAXpeerlist()
+    {
         $result = $this->send_request('IAXpeerlist');
         $data = (isset($result['data']) && is_array($result['data']))?$result['data']:[];
         $arr_peer = (isset($data['PeerEntry']) && is_array($data['PeerEntry']))?$data['PeerEntry']:[];
@@ -596,7 +644,8 @@ 
      * Возвращает регистрации пиров.
      * @return array
      */
-    function IAXregistry(){
+    function IAXregistry()
+    {
         $result = $this->send_request('IAXregistry');
         $data = (isset($result['data']) && is_array($result['data']))?$result['data']:[];
         $arr_peer = (isset($data['RegistryEntry']) && is_array($data['RegistryEntry']))?$data['RegistryEntry']:[];
@@ -610,9 +659,13 @@ 
      * @param string $actionid message matching variable
      * @return array
      */
-    function ListCommands($actionid = NULL){
-        if ($actionid) return $this->send_request('ListCommands', array('ActionID' => $actionid)); else
-            return $this->send_request('ListCommands');
+    function ListCommands($actionid = NULL)
+    {
+        if ($actionid) {
+            return $this->send_request('ListCommands', array('ActionID' => $actionid));
+        } else {
+                    return $this->send_request('ListCommands');
+        }
     }
 
     /**
@@ -621,7 +674,8 @@ 
      * @param  array  $headers
      * @return array
      */
-    function UserEvent($name, $headers){
+    function UserEvent($name, $headers)
+    {
         $headers['UserEvent'] = $name;
         return $this->send_request_timeout('UserEvent', $headers);
     }
@@ -631,7 +685,8 @@ 
      *
      * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+Logoff
      */
-    function Logoff(){
+    function Logoff()
+    {
         return $this->send_request_timeout('Logoff');
     }
 
@@ -649,9 +704,12 @@ 
      * @param string $actionid message matching variable
      * @return array
      */
-    function MailboxCount($mailbox, $actionid = NULL){
+    function MailboxCount($mailbox, $actionid = NULL)
+    {
         $parameters = array('Mailbox' => $mailbox);
-        if ($actionid) $parameters['ActionID'] = $actionid;
+        if ($actionid) {
+            $parameters['ActionID'] = $actionid;
+        }
         return $this->send_request('MailboxCount', $parameters);
     }
 
@@ -668,9 +726,12 @@ 
      * @param string $actionid message matching variable
      * @return array
      */
-    function MailboxStatus($mailbox, $actionid = NULL){
+    function MailboxStatus($mailbox, $actionid = NULL)
+    {
         $parameters = array('Mailbox' => $mailbox);
-        if ($actionid) $parameters['ActionID'] = $actionid;
+        if ($actionid) {
+            $parameters['ActionID'] = $actionid;
+        }
         return $this->send_request('MailboxStatus', $parameters);
     }
 
@@ -684,11 +745,18 @@ 
      * @param boolean $mix
      * @return array
      */
-    function Monitor($channel, $file = NULL, $format = NULL, $mix = NULL){
+    function Monitor($channel, $file = NULL, $format = NULL, $mix = NULL)
+    {
         $parameters = array('Channel' => $channel);
-        if ($file) $parameters['File'] = $file;
-        if ($format) $parameters['Format'] = $format;
-        if (!is_null($file)) $parameters['Mix'] = ($mix) ? 'true' : 'false';
+        if ($file) {
+            $parameters['File'] = $file;
+        }
+        if ($format) {
+            $parameters['Format'] = $format;
+        }
+        if (!is_null($file)) {
+            $parameters['Mix'] = ($mix) ? 'true' : 'false';
+        }
         return $this->send_request('Monitor', $parameters);
     }
 
@@ -702,7 +770,8 @@ 
      * @param string $command
      * @return array
      */
-    function MixMonitor($channel, $file, $options, $command){
+    function MixMonitor($channel, $file, $options, $command)
+    {
         $parameters = array('Channel' => $channel);
         $parameters['File'] = $file;
         $parameters['options'] = $options;
@@ -717,7 +786,8 @@ 
      * @param string $channel
      * @return array
      */
-    function StopMixMonitor($channel){
+    function StopMixMonitor($channel)
+    {
         $parameters = array('Channel' => $channel);
         return $this->send_request_timeout('StopMixMonitor', $parameters);
     }
@@ -730,7 +800,8 @@ 
      * @param string $Val
      * @return array
      */
-    function DBPut($Family, $Key, $Val = ''){
+    function DBPut($Family, $Key, $Val = '')
+    {
         $parameters = array('Family' => $Family, 'Key' => $Key, 'Val' => $Val);
         $res_data = $this->send_request_timeout('DBPut', $parameters);
         return $res_data;
@@ -775,7 +846,8 @@ 
      * @param string $Key
      * @return array
      */
-    function DBGet($Family, $Key){
+    function DBGet($Family, $Key)
+    {
         $parameters = array('Family' => $Family, 'Key' => $Key);
         return $this->send_request_timeout('DBGet', $parameters);
     }
@@ -798,22 +870,45 @@ 
      * @param string  $actionid message matching variable
      * @return array
      */
-    function Originate($channel, $exten = NULL, $context = NULL, $priority = NULL, $application = NULL, $data = NULL, $timeout = NULL, $callerid = NULL, $variable = NULL, $account = NULL, $async = NULL, $actionid = NULL){
+    function Originate($channel, $exten = NULL, $context = NULL, $priority = NULL, $application = NULL, $data = NULL, $timeout = NULL, $callerid = NULL, $variable = NULL, $account = NULL, $async = NULL, $actionid = NULL)
+    {
         $parameters = array('Channel' => $channel);
 
-        if ($exten) $parameters['Exten'] = $exten;
-        if ($context) $parameters['Context'] = $context;
-        if ($priority) $parameters['Priority'] = $priority;
+        if ($exten) {
+            $parameters['Exten'] = $exten;
+        }
+        if ($context) {
+            $parameters['Context'] = $context;
+        }
+        if ($priority) {
+            $parameters['Priority'] = $priority;
+        }
 
-        if ($application) $parameters['Application'] = $application;
-        if ($data) $parameters['Data'] = $data;
+        if ($application) {
+            $parameters['Application'] = $application;
+        }
+        if ($data) {
+            $parameters['Data'] = $data;
+        }
 
-        if ($timeout) $parameters['Timeout'] = $timeout;
-        if ($callerid) $parameters['CallerID'] = $callerid;
-        if ($variable) $parameters['Variable'] = $variable;
-        if ($account) $parameters['Account'] = $account;
-        if (!is_null($async)) $parameters['Async'] = ($async) ? 'true' : 'false';
-        if ($actionid) $parameters['ActionID'] = $actionid;
+        if ($timeout) {
+            $parameters['Timeout'] = $timeout;
+        }
+        if ($callerid) {
+            $parameters['CallerID'] = $callerid;
+        }
+        if ($variable) {
+            $parameters['Variable'] = $variable;
+        }
+        if ($account) {
+            $parameters['Account'] = $account;
+        }
+        if (!is_null($async)) {
+            $parameters['Async'] = ($async) ? 'true' : 'false';
+        }
+        if ($actionid) {
+            $parameters['ActionID'] = $actionid;
+        }
 
         return $this->send_request('Originate', $parameters);
     }
@@ -826,7 +921,8 @@ 
      * @param string $parkinglot message matching variable
      * @return array
      */
-    function ParkedCalls($parkinglot = NULL, $actionid = NULL){
+    function ParkedCalls($parkinglot = NULL, $actionid = NULL)
+    {
         $parameters = [];
         if ($actionid){
             $parameters['ActionID'] = $actionid;
@@ -844,7 +940,8 @@ 
      *
      * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+Ping
      */
-    function Ping(){
+    function Ping()
+    {
         return $this->send_request_timeout('Ping');
     }
 
@@ -857,9 +954,12 @@ 
      * @param integer $penalty
      * @return array
      */
-    function QueueAdd($queue, $interface, $penalty = 0){
+    function QueueAdd($queue, $interface, $penalty = 0)
+    {
         $parameters = array('Queue' => $queue, 'Interface' => $interface);
-        if ($penalty) $parameters['Penalty'] = $penalty;
+        if ($penalty) {
+            $parameters['Penalty'] = $penalty;
+        }
         return $this->send_request('QueueAdd', $parameters);
     }
 
@@ -871,7 +971,8 @@ 
      * @param string $interface
      * @return array
      */
-    function QueueRemove($queue, $interface){
+    function QueueRemove($queue, $interface)
+    {
         return $this->send_request('QueueRemove', array('Queue' => $queue, 'Interface' => $interface));
     }
 
@@ -880,7 +981,8 @@ 
      *
      * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+Queues
      */
-    function Queues(){
+    function Queues()
+    {
         return $this->send_request('Queues');
     }
 
@@ -891,9 +993,13 @@ 
      * @param string $actionid message matching variable
      * @return array
      */
-    function QueueStatus($actionid = NULL){
-        if ($actionid) return $this->send_request('QueueStatus', array('ActionID' => $actionid)); else
-            return $this->send_request('QueueStatus');
+    function QueueStatus($actionid = NULL)
+    {
+        if ($actionid) {
+            return $this->send_request('QueueStatus', array('ActionID' => $actionid));
+        } else {
+                    return $this->send_request('QueueStatus');
+        }
     }
 
     /**
@@ -907,7 +1013,8 @@ 
      * @param string $priority
      * @return array
      */
-    function Redirect($channel, $extrachannel, $exten, $context, $priority){
+    function Redirect($channel, $extrachannel, $exten, $context, $priority)
+    {
         return $this->send_request('Redirect', array('Channel' => $channel, 'ExtraChannel' => $extrachannel, 'Exten' => $exten, 'Context' => $context, 'Priority' => $priority));
     }
 
@@ -920,9 +1027,12 @@ 
      * @param string $append
      * @return array
      */
-    function SetCDRUserField($userfield, $channel, $append = NULL){
+    function SetCDRUserField($userfield, $channel, $append = NULL)
+    {
         $parameters = array('UserField' => $userfield, 'Channel' => $channel);
-        if ($append) $parameters['Append'] = $append;
+        if ($append) {
+            $parameters['Append'] = $append;
+        }
         return $this->send_request('SetCDRUserField', $parameters);
     }
 
@@ -935,7 +1045,8 @@ 
      * @param string $value
      * @return array
      */
-    function SetVar($channel, $variable, $value){
+    function SetVar($channel, $variable, $value)
+    {
         return $this->send_request('SetVar', array('Channel' => $channel, 'Variable' => $variable, 'Value' => $value));
     }
 
@@ -947,9 +1058,12 @@ 
      * @param string $actionid message matching variable
      * @return array
      */
-    function Status($channel, $actionid = NULL){
+    function Status($channel, $actionid = NULL)
+    {
         $parameters = array('Channel' => $channel);
-        if ($actionid) $parameters['ActionID'] = $actionid;
+        if ($actionid) {
+            $parameters['ActionID'] = $actionid;
+        }
         return $this->send_request('Status', $parameters);
     }
 
@@ -960,7 +1074,8 @@ 
      * @param string $channel
      * @return array
      */
-    function StopMonitor($channel){
+    function StopMonitor($channel)
+    {
         return $this->send_request('StopMonitor', array('Channel' => $channel));
     }
 
@@ -972,7 +1087,8 @@ 
      * Полученире текущих регистраций.
      * @return array
      */
-    public function get_sip_registry(){
+    public function get_sip_registry()
+    {
         $peers = array();
         $result = $this->send_request_timeout('SIPshowregistry');
         if ($result['data'] !== null && $result['data']['RegistryEntry'] !== null) {
@@ -1042,12 +1158,15 @@ 
      * Получение статусов пиров.
      * @return array
      */
-    function get_sip_peers(){
+    function get_sip_peers()
+    {
         $peers = array();
         $res = $this->send_request_timeout('SIPpeers');
         if (isset($res['data']) && $res['data'] != null && $res['data']['PeerEntry'] != null) {
             foreach ($res['data']['PeerEntry'] as $peer) {
-                if (!is_numeric($peer['ObjectName'])) continue;
+                if (!is_numeric($peer['ObjectName'])) {
+                    continue;
+                }
                 // if ('Unmonitored' == $peer['Status']) continue;
                 $arr_status = explode(' ', $peer['Status']);
                 $peers[] = array('id' => $peer['ObjectName'], 'state' => strtoupper($arr_status[0]),);
@@ -1061,7 +1180,8 @@ 
      * @param $peer
      * @return array
      */
-    function get_sip_peer($peer){
+    function get_sip_peer($peer)
+    {
         $parameters = ['Peer' => trim($peer)];
         $res = $this->send_request_timeout('SIPshowpeer', $parameters);
         $arr_status          = explode(' ', $res['Status']);
@@ -1075,7 +1195,8 @@ 
      * @param $peer
      * @return array
      */
-    function get_pj_sip_peer($peer){
+    function get_pj_sip_peer($peer)
+    {
         $result = [];
         $parameters = ['Endpoint' => trim($peer)];
         $res = $this->send_request_timeout('PJSIPShowEndpoint', $parameters);
@@ -1127,12 +1248,16 @@ 
      * @param string $message
      * @param integer $level from 1 to 4
      */
-    function log($message, $level = 1){
-        if ($this->pagi != false) $this->pagi->conlog($message, $level);
+    function log($message, $level = 1)
+    {
+        if ($this->pagi != false) {
+            $this->pagi->conlog($message, $level);
+        }
 
     }
 
-    function microtime_float(){
+    function microtime_float()
+    {
         list($usec, $sec) = explode(" ", microtime());
         return ((float)$usec + (float)$sec);
     }
@@ -1177,7 +1302,8 @@ 
      * @param string | array $callback function
      * @return boolean sucess
      */
-    function add_event_handler($event, $callback){
+    function add_event_handler($event, $callback)
+    {
         $event = strtolower($event);
         if (isset($this->event_handlers[$event])) {
             $this->log("$event handler is already defined, not over-writing.");
@@ -1194,7 +1320,8 @@ 
      * @param array $parameters
      * @return mixed result of event handler or false if no handler was found
      */
-    function process_event($parameters){
+    function process_event($parameters)
+    {
         $ret = false;
         $e = strtolower($parameters['Event']);
         $this->log("Got event.. $e");
@@ -1202,17 +1329,17 @@ 
         $handler = '';
         if (isset($this->event_handlers[$e])){
             $handler = $this->event_handlers[$e];
-        }
-        elseif (isset($this->event_handlers['*'])){
+        } elseif (isset($this->event_handlers['*'])){
             $handler = $this->event_handlers['*'];
         }
         if(is_array($handler)){
             call_user_func($handler, $parameters);
-        }else if (function_exists($handler)) {
+        } else if (function_exists($handler)) {
             $this->log("Execute handler $handler");
             $ret = $handler($e, $parameters, $this->server, $this->port);
-        } else
-            $this->log("No event handler for event '$e'");
+        } else {
+                    $this->log("No event handler for event '$e'");
+        }
         return $ret;
     }
 }

Upper-Lower-Casing +23 added lines, -23 removed lines

@@ -40,7 +40,7 @@ 
      *
      * @access public
      */
-    public $socket = NULL;
+    public $socket = null;
 
     /**
      * Server we are connected to
@@ -80,7 +80,7 @@ 
      * @access private
      * @var boolean
      */
-    private $_logged_in = FALSE;
+    private $_logged_in = false;
 
     /**
      * Constructor
@@ -88,7 +88,7 @@ 
      * @param string $config is the name of the config file to parse or a parent agi from which to read the config
      * @param array  $optconfig is an array of configuration vars and vals, stuffed into $this->config['asmanager']
      */
-    function __construct($config = NULL, $optconfig = array()){
+    function __construct($config = null, $optconfig = array()){
         // load config
         if (!is_null($config) && file_exists($config)) $this->config = parse_ini_file($config, true); elseif (file_exists(DEFAULT_PHPAGI_CONFIG)) $this->config = parse_ini_file(DEFAULT_PHPAGI_CONFIG, true);
 
@@ -151,7 +151,7 @@ 
         $req = '';
         $parameters = array(
             'Action'    => 'UserEvent',
-            'UserEvent' => "{$pingname}Ping"
+            'UserEvent' => "{$pingname}ping"
         );
         foreach ($parameters as $var => $val) $req .= "$var: $val\r\n";
         $req .= "\r\n";
@@ -187,7 +187,7 @@ 
             if($type == '' && count($this->Ping())==0){
                 $timeout = true;
             }
-            else if('event' == $type && $parameters['Event'] == 'UserEvent' && "{$pingname}Pong" == $parameters['UserEvent']){
+            else if('event' == $type && $parameters['Event'] == 'UserEvent' && "{$pingname}pong" == $parameters['UserEvent']){
                 // Ответ получен.
                 $result = true;
                 break;
@@ -249,7 +249,7 @@ 
     public function wait_response($allow_timeout = false):array {
         $timeout = false;
         do {
-            $type = NULL;
+            $type = null;
             $parameters = array();
             if(!is_resource($this->socket)){
                 return $parameters;
@@ -380,7 +380,7 @@ 
      * @param string $events
      * @return boolean true on success
      */
-    function connect($server = NULL, $username = NULL, $secret = NULL, $events = 'on'){
+    function connect($server = null, $username = null, $secret = null, $events = 'on'){
         // use config if not specified
         if (is_null($server)) $server = $this->config['asmanager']['server'];
         if (is_null($username)) $username = $this->config['asmanager']['username'];
@@ -397,7 +397,7 @@ 
         }
 
         // connect the socket
-        $errno = $errstr = NULL;
+        $errno = $errstr = null;
         $timeout = 2;
 
         $this->socket = @fsockopen($this->server, $this->port, $errno, $errstr, $timeout);
@@ -419,12 +419,12 @@ 
         // login
         $res = $this->send_request('login', array('Username' => $username, 'Secret' => $secret, 'Events' => $events));
         if ($res['Response'] != 'Success') {
-            $this->_logged_in = FALSE;
+            $this->_logged_in = false;
             $this->log("Failed to login.");
             $this->disconnect();
             return false;
         }
-        $this->_logged_in = TRUE;
+        $this->_logged_in = true;
         return true;
     }
 
@@ -438,7 +438,7 @@ 
      * @example examples/sip_show_peer.php Get information about a sip peer
      */
     function disconnect(){
-        if ($this->_logged_in == TRUE) $this->logoff();
+        if ($this->_logged_in == true) $this->logoff();
         if(is_resource($this->socket)){
             fclose($this->socket);
         }
@@ -484,7 +484,7 @@ 
      * @param string $actionid message matching variable
      * @return array
      */
-    function Command($command, $actionid = NULL){
+    function Command($command, $actionid = null){
         $parameters = array('Command' => $command);
         if ($actionid) $parameters['ActionID'] = $actionid;
         return $this->send_request('Command', $parameters);
@@ -510,7 +510,7 @@ 
      * @param string $actionid message matching variable
      * @return array
      */
-    function ExtensionState($exten, $context, $actionid = NULL){
+    function ExtensionState($exten, $context, $actionid = null){
         $parameters = array('Exten' => $exten, 'Context' => $context);
         if ($actionid) $parameters['ActionID'] = $actionid;
         return $this->send_request('ExtensionState', $parameters);
@@ -527,7 +527,7 @@ 
      * @param boolean $ret_array
      * @return string | array
      */
-    function GetVar($channel, $variable, $actionid = NULL, $ret_array = true){
+    function GetVar($channel, $variable, $actionid = null, $ret_array = true){
         $parameters = array('Channel' => $channel, 'Variable' => $variable);
         if ($actionid){
             $parameters['ActionID'] = $actionid;
@@ -610,7 +610,7 @@ 
      * @param string $actionid message matching variable
      * @return array
      */
-    function ListCommands($actionid = NULL){
+    function ListCommands($actionid = null){
         if ($actionid) return $this->send_request('ListCommands', array('ActionID' => $actionid)); else
             return $this->send_request('ListCommands');
     }
@@ -649,7 +649,7 @@ 
      * @param string $actionid message matching variable
      * @return array
      */
-    function MailboxCount($mailbox, $actionid = NULL){
+    function MailboxCount($mailbox, $actionid = null){
         $parameters = array('Mailbox' => $mailbox);
         if ($actionid) $parameters['ActionID'] = $actionid;
         return $this->send_request('MailboxCount', $parameters);
@@ -668,7 +668,7 @@ 
      * @param string $actionid message matching variable
      * @return array
      */
-    function MailboxStatus($mailbox, $actionid = NULL){
+    function MailboxStatus($mailbox, $actionid = null){
         $parameters = array('Mailbox' => $mailbox);
         if ($actionid) $parameters['ActionID'] = $actionid;
         return $this->send_request('MailboxStatus', $parameters);
@@ -684,7 +684,7 @@ 
      * @param boolean $mix
      * @return array
      */
-    function Monitor($channel, $file = NULL, $format = NULL, $mix = NULL){
+    function Monitor($channel, $file = null, $format = null, $mix = null){
         $parameters = array('Channel' => $channel);
         if ($file) $parameters['File'] = $file;
         if ($format) $parameters['Format'] = $format;
@@ -798,7 +798,7 @@ 
      * @param string  $actionid message matching variable
      * @return array
      */
-    function Originate($channel, $exten = NULL, $context = NULL, $priority = NULL, $application = NULL, $data = NULL, $timeout = NULL, $callerid = NULL, $variable = NULL, $account = NULL, $async = NULL, $actionid = NULL){
+    function Originate($channel, $exten = null, $context = null, $priority = null, $application = null, $data = null, $timeout = null, $callerid = null, $variable = null, $account = null, $async = null, $actionid = null){
         $parameters = array('Channel' => $channel);
 
         if ($exten) $parameters['Exten'] = $exten;
@@ -826,7 +826,7 @@ 
      * @param string $parkinglot message matching variable
      * @return array
      */
-    function ParkedCalls($parkinglot = NULL, $actionid = NULL){
+    function ParkedCalls($parkinglot = null, $actionid = null){
         $parameters = [];
         if ($actionid){
             $parameters['ActionID'] = $actionid;
@@ -891,7 +891,7 @@ 
      * @param string $actionid message matching variable
      * @return array
      */
-    function QueueStatus($actionid = NULL){
+    function QueueStatus($actionid = null){
         if ($actionid) return $this->send_request('QueueStatus', array('ActionID' => $actionid)); else
             return $this->send_request('QueueStatus');
     }
@@ -920,7 +920,7 @@ 
      * @param string $append
      * @return array
      */
-    function SetCDRUserField($userfield, $channel, $append = NULL){
+    function SetCDRUserField($userfield, $channel, $append = null){
         $parameters = array('UserField' => $userfield, 'Channel' => $channel);
         if ($append) $parameters['Append'] = $append;
         return $this->send_request('SetCDRUserField', $parameters);
@@ -947,7 +947,7 @@ 
      * @param string $actionid message matching variable
      * @return array
      */
-    function Status($channel, $actionid = NULL){
+    function Status($channel, $actionid = null){
         $parameters = array('Channel' => $channel);
         if ($actionid) $parameters['ActionID'] = $actionid;
         return $this->send_request('Status', $parameters);

etc/asterisk/agi-bin/check_redirect.php

Indentation +1 added lines, -1 removed lines

@@ -14,7 +14,7 @@
 $DIALSTATUS = $agi->get_variable('DIALSTATUS', true);
 $linkedid   = $agi->get_variable('CDR(linkedid)', true);
 if($chan === '' && 'ANSWER' === $DIALSTATUS) {
-	exit;
+    exit;
 }
 // Обнуляем значение переменной.
 $agi->set_variable('BLINDTRANSFER', '');

Spacing +7 added lines, -7 removed lines

@@ -13,13 +13,13 @@ 
 $agi 		= new AGI();
 $DIALSTATUS = $agi->get_variable('DIALSTATUS', true);
 $linkedid   = $agi->get_variable('CDR(linkedid)', true);
-if($chan === '' && 'ANSWER' === $DIALSTATUS) {
+if ($chan === '' && 'ANSWER' === $DIALSTATUS) {
 	exit;
 }
 // Обнуляем значение переменной.
 $agi->set_variable('BLINDTRANSFER', '');
 
-try{
+try {
     $filter = [
         '(dst_chan=:chan: OR src_chan=:chan:) AND linkedid=:linkedid:',
         'bind'  => ['chan' => $chan, 'linkedid' => $linkedid],
@@ -28,18 +28,18 @@ 
     ];
     $client  = new BeanstalkClient('select_cdr');
     $message = $client->request(json_encode($filter), 2);
-    if($message !== false){
+    if ($message !== false) {
         $res = json_decode($client->getBody(), true);
-        if(count($res) === 1){
-            $exten = ($res[0]['src_chan'] === $chan)?$res[0]['src_num']:$res[0]['dst_num'];
+        if (count($res) === 1) {
+            $exten = ($res[0]['src_chan'] === $chan) ? $res[0]['src_num'] : $res[0]['dst_num'];
             sleep(2);
             $agi->set_variable('pt1c_UNIQUEID', '');
             $agi->exec_goto('internal', $exten, '1');
         }
-    }else{
+    } else {
         Util::sys_log_msg('CheckRedirect', "Error get data from queue 'select_cdr'. ");
     }
 
-}catch (Exception $e){
+} catch (Exception $e) {
     Util::sys_log_msg('CheckRedirect', $e->getMessage());
 }

Braces +2 added lines, -2 removed lines

@@ -36,10 +36,10 @@
             $agi->set_variable('pt1c_UNIQUEID', '');
             $agi->exec_goto('internal', $exten, '1');
         }
-    }else{
+    } else{
         Util::sys_log_msg('CheckRedirect', "Error get data from queue 'select_cdr'. ");
     }
 
-}catch (Exception $e){
+} catch (Exception $e){
     Util::sys_log_msg('CheckRedirect', $e->getMessage());
 }

etc/asterisk/agi-bin/phpagi-fastagi.php

Indentation +52 added lines, -52 removed lines

@@ -1,79 +1,79 @@
 #!/usr/local/bin/php -q
 <?php
- /**
-  * phpagi-fastagi.php : PHP FastAGI bootstrap
-  * Website: http://phpagi.sourceforge.net
-  *
-  * $Id: phpagi-fastagi.php,v 1.2 2005/05/25 18:43:48 pinhole Exp $
-  *
-  * Copyright (c) 2004, 2005 Matthew Asham <matthewa@bcwireless.net>, David Eder <david@eder.us>
-  * All Rights Reserved.
-  *
-  * This software is released under the terms of the GNU Lesser General Public License v2.1
-  * A copy of which is available from http://www.gnu.org/copyleft/lesser.html
-  *
-  * We would be happy to list your phpagi based application on the phpagi
-  * website.  Drop me an Email if you'd like us to list your program.
-  *
-  * @package phpAGI
-  * @version 2.0
-  * @example docs/fastagi.xinetd Example xinetd config file
-  */
+    /**
+     * phpagi-fastagi.php : PHP FastAGI bootstrap
+     * Website: http://phpagi.sourceforge.net
+     *
+     * $Id: phpagi-fastagi.php,v 1.2 2005/05/25 18:43:48 pinhole Exp $
+     *
+     * Copyright (c) 2004, 2005 Matthew Asham <matthewa@bcwireless.net>, David Eder <david@eder.us>
+     * All Rights Reserved.
+     *
+     * This software is released under the terms of the GNU Lesser General Public License v2.1
+     * A copy of which is available from http://www.gnu.org/copyleft/lesser.html
+     *
+     * We would be happy to list your phpagi based application on the phpagi
+     * website.  Drop me an Email if you'd like us to list your program.
+     *
+     * @package phpAGI
+     * @version 2.0
+     * @example docs/fastagi.xinetd Example xinetd config file
+     */
 
- /**
-  * Written for PHP 4.3.4, should work with older PHP 4.x versions.
-  * Please submit bug reports, patches, etc to http://sourceforge.net/projects/phpagi/
-  * Gracias. :)
-  *
-  */
+    /**
+     * Written for PHP 4.3.4, should work with older PHP 4.x versions.
+     * Please submit bug reports, patches, etc to http://sourceforge.net/projects/phpagi/
+     * Gracias. :)
+     *
+     */
 
-  require_once(dirname(__FILE__) . DIRECTORY_SEPARATOR . 'phpagi.php');
+    require_once(dirname(__FILE__) . DIRECTORY_SEPARATOR . 'phpagi.php');
 
-  $fastagi = new AGI();
+    $fastagi = new AGI();
 
-  $fastagi->verbose(print_r($fastagi, true));
+    $fastagi->verbose(print_r($fastagi, true));
 
-  if(!isset($fastagi->config['fastagi']['basedir']))
+    if(!isset($fastagi->config['fastagi']['basedir']))
     $fastagi->config['fastagi']['basedir'] = dirname(__FILE__);
 
-  // perform some security checks
+    // perform some security checks
 
-  $script = $fastagi->config['fastagi']['basedir'] . DIRECTORY_SEPARATOR . $fastagi->request['agi_network_script'];
+    $script = $fastagi->config['fastagi']['basedir'] . DIRECTORY_SEPARATOR . $fastagi->request['agi_network_script'];
 
-  // in the same directory (or subdirectory)
-  $mydir = dirname($fastagi->config['fastagi']['basedir']) . DIRECTORY_SEPARATOR;
-  $dir = dirname($script) . DIRECTORY_SEPARATOR;
-  if(substr($dir, 0, strlen($mydir)) != $mydir)
-  {
+    // in the same directory (or subdirectory)
+    $mydir = dirname($fastagi->config['fastagi']['basedir']) . DIRECTORY_SEPARATOR;
+    $dir = dirname($script) . DIRECTORY_SEPARATOR;
+    if(substr($dir, 0, strlen($mydir)) != $mydir)
+    {
     $fastagi->conlog("$script is not allowed to execute.");
     exit;
-  }
+    }
 
-  // make sure it exists
-  if(!file_exists($script))
-  {
+    // make sure it exists
+    if(!file_exists($script))
+    {
     $fastagi->conlog("$script does not exist.");
     exit;
-  }
+    }
 
-  // drop privileges
-  if(isset($fastagi->config['fastagi']['setuid']) && $fastagi->config['fastagi']['setuid'])
-  {
+    // drop privileges
+    if(isset($fastagi->config['fastagi']['setuid']) && $fastagi->config['fastagi']['setuid'])
+    {
     $owner = fileowner($script);
     $group = filegroup($script);
     if(!posix_setgid($group) || !posix_setegid($group) || !posix_setuid($owner) || !posix_seteuid($owner))
     {
-      $fastagi->conlog("failed to lower privileges.");
-      exit;      
+        $fastagi->conlog("failed to lower privileges.");
+        exit;      
+    }
     }
-  }
 
-  // make sure script is still readable
-  if(!is_readable($script))
-  {
+    // make sure script is still readable
+    if(!is_readable($script))
+    {
     $fastagi->conlog("$script is not readable.");
     exit;
-  }
+    }
 
-  require_once($script);
+    require_once($script);
 ?>

Spacing +10 added lines, -10 removed lines

@@ -27,41 +27,41 @@ 
   *
   */
 
-  require_once(dirname(__FILE__) . DIRECTORY_SEPARATOR . 'phpagi.php');
+  require_once(dirname(__FILE__).DIRECTORY_SEPARATOR.'phpagi.php');
 
   $fastagi = new AGI();
 
   $fastagi->verbose(print_r($fastagi, true));
 
-  if(!isset($fastagi->config['fastagi']['basedir']))
+  if (!isset($fastagi->config['fastagi']['basedir']))
     $fastagi->config['fastagi']['basedir'] = dirname(__FILE__);
 
   // perform some security checks
 
-  $script = $fastagi->config['fastagi']['basedir'] . DIRECTORY_SEPARATOR . $fastagi->request['agi_network_script'];
+  $script = $fastagi->config['fastagi']['basedir'].DIRECTORY_SEPARATOR.$fastagi->request['agi_network_script'];
 
   // in the same directory (or subdirectory)
-  $mydir = dirname($fastagi->config['fastagi']['basedir']) . DIRECTORY_SEPARATOR;
-  $dir = dirname($script) . DIRECTORY_SEPARATOR;
-  if(substr($dir, 0, strlen($mydir)) != $mydir)
+  $mydir = dirname($fastagi->config['fastagi']['basedir']).DIRECTORY_SEPARATOR;
+  $dir = dirname($script).DIRECTORY_SEPARATOR;
+  if (substr($dir, 0, strlen($mydir)) != $mydir)
   {
     $fastagi->conlog("$script is not allowed to execute.");
     exit;
   }
 
   // make sure it exists
-  if(!file_exists($script))
+  if (!file_exists($script))
   {
     $fastagi->conlog("$script does not exist.");
     exit;
   }
 
   // drop privileges
-  if(isset($fastagi->config['fastagi']['setuid']) && $fastagi->config['fastagi']['setuid'])
+  if (isset($fastagi->config['fastagi']['setuid']) && $fastagi->config['fastagi']['setuid'])
   {
     $owner = fileowner($script);
     $group = filegroup($script);
-    if(!posix_setgid($group) || !posix_setegid($group) || !posix_setuid($owner) || !posix_seteuid($owner))
+    if (!posix_setgid($group) || !posix_setegid($group) || !posix_setuid($owner) || !posix_seteuid($owner))
     {
       $fastagi->conlog("failed to lower privileges.");
       exit;      
@@ -69,7 +69,7 @@ 
   }
 
   // make sure script is still readable
-  if(!is_readable($script))
+  if (!is_readable($script))
   {
     $fastagi->conlog("$script is not readable.");
     exit;

Braces +3 added lines, -2 removed lines

@@ -33,8 +33,9 @@
 
   $fastagi->verbose(print_r($fastagi, true));
 
-  if(!isset($fastagi->config['fastagi']['basedir']))
-    $fastagi->config['fastagi']['basedir'] = dirname(__FILE__);
+  if(!isset($fastagi->config['fastagi']['basedir'])) {
+      $fastagi->config['fastagi']['basedir'] = dirname(__FILE__);
+  }
 
   // perform some security checks
 

etc/asterisk/agi-bin/clean_timeout.php

Spacing +3 added lines, -3 removed lines

@@ -10,12 +10,12 @@
 require_once 'phpagi.php';
 
 $agi = new AGI();
-$channel	= $agi->get_variable('MASTER_CHANNEL(M_TIMEOUT_CHANNEL)', 	true);
-$FROM_CHAN	= $agi->get_variable('FROM_CHAN', 	true);
+$channel = $agi->get_variable('MASTER_CHANNEL(M_TIMEOUT_CHANNEL)', true);
+$FROM_CHAN = $agi->get_variable('FROM_CHAN', true);
 
 /** @var AGI_AsteriskManager $am */
 $am = Util::get_am('off');
-$am->SetVar($channel,   'TIMEOUT(absolute)', '0');
+$am->SetVar($channel, 'TIMEOUT(absolute)', '0');
 $am->SetVar($FROM_CHAN, "MASTER_CHANNEL(M_DIALSTATUS)", 'ANSWER');
 
 // Перестрахова на случай с перехватом звонка через *8.

etc/asterisk/agi-bin/phpagi-debug.php

Indentation +77 added lines, -77 removed lines

@@ -10,83 +10,83 @@
 *  Заглушка для отладки скрипта. 
 */
 class _AGI {
-	public function exec($v1, $v2){
-		echo "exec($v1, $v2)\n";	
-	}
-	public function answer(){
-		echo "answer()\n";	
-	}
-	public function get_variable($_varName){
+    public function exec($v1, $v2){
+        echo "exec($v1, $v2)\n";	
+    }
+    public function answer(){
+        echo "answer()\n";	
+    }
+    public function get_variable($_varName){
 		
-		$value = array();
-		$value['result']=1;
+        $value = array();
+        $value['result']=1;
 		
-		if('10000666' == PT1C_SKRIPTNAME){
-			switch ($_varName) {
-			    case 'v1':
-					$value['data']='SIP/204';
-			        break;
-			    case 'v2':
-					$value['data']='mikopbx-1558444069.34';
-			        break;
-			    case 'v3':
-					$value['data']='';
-			        break;
-			    case 'v6':
-					$value['data']='Records';
-			        break;
-			    case 'ASTSPOOLDIR':
-					$value['data']='/var/spool/asterisk';
-			        break;
-			    default:
-					$value['data']='';
-			}	
-		}else if('10000555' == PT1C_SKRIPTNAME){
-			switch ($_varName) {
-			    case 'v1':
-					$value['data']='SIP/201';
-			        break;
-			    case 'v2':
-					$value['data']='2017-01-01';
-			        break;
-			    case 'v3':
-					$value['data']='2019-01-01';
-			        break;
-			    case 'v4':
-					$value['data']='201-89257184254';
-			        break;
-			    default:
-					$value['data']='';
-			}	
-		}else if('1C_HistoryFax.php' == PT1C_SKRIPTNAME){
-			switch ($_varName) {
-			    case 'v1':
-					$value['data']='SIP/1000';
-			        break;
-			    case 'v2':
-					$value['data']='2017-01-01';
-			        break;
-			    case 'v3':
-					$value['data']='2019-01-01';
-			        break;
-			    default:
-					$value['data']='';
-			}	
-		}else if('10000777' == PT1C_SKRIPTNAME){
-			switch ($_varName) {
-			    case 'chan':
-					$value['data']='SIP/204';
-			        break;
-			    case 'uniqueid1c':
-					$value['data']='mikopbx-1519992881.0';
-			        break;
-			    case 'ASTSPOOLDIR':
-					$value['data']='/var/spool/asterisk';
-			        break;
-			    default:
-					$value['data']='';
-			}	
-		}
-		return $value['data'];
-	}
+        if('10000666' == PT1C_SKRIPTNAME){
+            switch ($_varName) {
+                case 'v1':
+                    $value['data']='SIP/204';
+                    break;
+                case 'v2':
+                    $value['data']='mikopbx-1558444069.34';
+                    break;
+                case 'v3':
+                    $value['data']='';
+                    break;
+                case 'v6':
+                    $value['data']='Records';
+                    break;
+                case 'ASTSPOOLDIR':
+                    $value['data']='/var/spool/asterisk';
+                    break;
+                default:
+                    $value['data']='';
+            }	
+        }else if('10000555' == PT1C_SKRIPTNAME){
+            switch ($_varName) {
+                case 'v1':
+                    $value['data']='SIP/201';
+                    break;
+                case 'v2':
+                    $value['data']='2017-01-01';
+                    break;
+                case 'v3':
+                    $value['data']='2019-01-01';
+                    break;
+                case 'v4':
+                    $value['data']='201-89257184254';
+                    break;
+                default:
+                    $value['data']='';
+            }	
+        }else if('1C_HistoryFax.php' == PT1C_SKRIPTNAME){
+            switch ($_varName) {
+                case 'v1':
+                    $value['data']='SIP/1000';
+                    break;
+                case 'v2':
+                    $value['data']='2017-01-01';
+                    break;
+                case 'v3':
+                    $value['data']='2019-01-01';
+                    break;
+                default:
+                    $value['data']='';
+            }	
+        }else if('10000777' == PT1C_SKRIPTNAME){
+            switch ($_varName) {
+                case 'chan':
+                    $value['data']='SIP/204';
+                    break;
+                case 'uniqueid1c':
+                    $value['data']='mikopbx-1519992881.0';
+                    break;
+                case 'ASTSPOOLDIR':
+                    $value['data']='/var/spool/asterisk';
+                    break;
+                default:
+                    $value['data']='';
+            }	
+        }
+        return $value['data'];
+    }
 }

Spacing +27 added lines, -27 removed lines

@@ -10,81 +10,81 @@
 *  Заглушка для отладки скрипта. 
 */
 class _AGI {
-	public function exec($v1, $v2){
+	public function exec($v1, $v2) {
 		echo "exec($v1, $v2)\n";	
 	}
-	public function answer(){
+	public function answer() {
 		echo "answer()\n";	
 	}
-	public function get_variable($_varName){
+	public function get_variable($_varName) {
 		
 		$value = array();
-		$value['result']=1;
+		$value['result'] = 1;
 		
-		if('10000666' == PT1C_SKRIPTNAME){
+		if ('10000666' == PT1C_SKRIPTNAME) {
 			switch ($_varName) {
 			    case 'v1':
-					$value['data']='SIP/204';
+					$value['data'] = 'SIP/204';
 			        break;
 			    case 'v2':
-					$value['data']='mikopbx-1558444069.34';
+					$value['data'] = 'mikopbx-1558444069.34';
 			        break;
 			    case 'v3':
-					$value['data']='';
+					$value['data'] = '';
 			        break;
 			    case 'v6':
-					$value['data']='Records';
+					$value['data'] = 'Records';
 			        break;
 			    case 'ASTSPOOLDIR':
-					$value['data']='/var/spool/asterisk';
+					$value['data'] = '/var/spool/asterisk';
 			        break;
 			    default:
-					$value['data']='';
+					$value['data'] = '';
 			}	
-		}else if('10000555' == PT1C_SKRIPTNAME){
+		} else if ('10000555' == PT1C_SKRIPTNAME) {
 			switch ($_varName) {
 			    case 'v1':
-					$value['data']='SIP/201';
+					$value['data'] = 'SIP/201';
 			        break;
 			    case 'v2':
-					$value['data']='2017-01-01';
+					$value['data'] = '2017-01-01';
 			        break;
 			    case 'v3':
-					$value['data']='2019-01-01';
+					$value['data'] = '2019-01-01';
 			        break;
 			    case 'v4':
-					$value['data']='201-89257184254';
+					$value['data'] = '201-89257184254';
 			        break;
 			    default:
-					$value['data']='';
+					$value['data'] = '';
 			}	
-		}else if('1C_HistoryFax.php' == PT1C_SKRIPTNAME){
+		} else if ('1C_HistoryFax.php' == PT1C_SKRIPTNAME) {
 			switch ($_varName) {
 			    case 'v1':
-					$value['data']='SIP/1000';
+					$value['data'] = 'SIP/1000';
 			        break;
 			    case 'v2':
-					$value['data']='2017-01-01';
+					$value['data'] = '2017-01-01';
 			        break;
 			    case 'v3':
-					$value['data']='2019-01-01';
+					$value['data'] = '2019-01-01';
 			        break;
 			    default:
-					$value['data']='';
+					$value['data'] = '';
 			}	
-		}else if('10000777' == PT1C_SKRIPTNAME){
+		} else if ('10000777' == PT1C_SKRIPTNAME) {
 			switch ($_varName) {
 			    case 'chan':
-					$value['data']='SIP/204';
+					$value['data'] = 'SIP/204';
 			        break;
 			    case 'uniqueid1c':
-					$value['data']='mikopbx-1519992881.0';
+					$value['data'] = 'mikopbx-1519992881.0';
 			        break;
 			    case 'ASTSPOOLDIR':
-					$value['data']='/var/spool/asterisk';
+					$value['data'] = '/var/spool/asterisk';
 			        break;
 			    default:
-					$value['data']='';
+					$value['data'] = '';
 			}	
 		}
 		return $value['data'];

Braces +11 added lines, -7 removed lines

@@ -9,14 +9,18 @@ 
 /**
 *  Заглушка для отладки скрипта. 
 */
-class _AGI {
-	public function exec($v1, $v2){
+class _AGI
+{
+	public function exec($v1, $v2)
+	{
 		echo "exec($v1, $v2)\n";	
 	}
-	public function answer(){
+	public function answer()
+	{
 		echo "answer()\n";	
 	}
-	public function get_variable($_varName){
+	public function get_variable($_varName)
+	{
 		
 		$value = array();
 		$value['result']=1;
@@ -41,7 +45,7 @@ 
 			    default:
 					$value['data']='';
 			}	
-		}else if('10000555' == PT1C_SKRIPTNAME){
+		} else if('10000555' == PT1C_SKRIPTNAME){
 			switch ($_varName) {
 			    case 'v1':
 					$value['data']='SIP/201';
@@ -58,7 +62,7 @@ 
 			    default:
 					$value['data']='';
 			}	
-		}else if('1C_HistoryFax.php' == PT1C_SKRIPTNAME){
+		} else if('1C_HistoryFax.php' == PT1C_SKRIPTNAME){
 			switch ($_varName) {
 			    case 'v1':
 					$value['data']='SIP/1000';
@@ -72,7 +76,7 @@ 
 			    default:
 					$value['data']='';
 			}	
-		}else if('10000777' == PT1C_SKRIPTNAME){
+		} else if('10000777' == PT1C_SKRIPTNAME){
 			switch ($_varName) {
 			    case 'chan':
 					$value['data']='SIP/204';

etc/rc/vendor/autoload.php

Spacing +1 added lines, -1 removed lines

@@ -8,6 +8,6 @@
 
 // autoload.php @generated by Composer
 
-require_once __DIR__ . '/composer/autoload_real.php';
+require_once __DIR__.'/composer/autoload_real.php';
 
 return ComposerAutoloaderInit6670dab4b71421eb4b91561314912df5::getLoader();

etc/rc/vendor/php-school/terminal/src/InputCharacter.php

Spacing +1 added lines, -1 removed lines

@@ -74,7 +74,7 @@
      */
     public function isNotControl() : bool
     {
-        return ! $this->isControl();
+        return !$this->isControl();
     }
 
     /**

etc/rc/vendor/php-school/terminal/src/UnixTerminal.php

Spacing +2 added lines, -2 removed lines

@@ -161,7 +161,7 @@ 
      */
     public function restoreOriginalConfiguration() : void
     {
-        exec('stty ' . $this->getOriginalConfiguration());
+        exec('stty '.$this->getOriginalConfiguration());
     }
 
     /**
@@ -269,7 +269,7 @@ 
     public function read(int $bytes): string
     {
         $buffer = '';
-        $this->input->read($bytes, function ($data) use (&$buffer) {
+        $this->input->read($bytes, function($data) use (&$buffer) {
             $buffer .= $data;
         });
         return $buffer;

Braces +2 added lines, -1 removed lines

@@ -269,7 +269,8 @@
     public function read(int $bytes): string
     {
         $buffer = '';
-        $this->input->read($bytes, function ($data) use (&$buffer) {
+        $this->input->read($bytes, function ($data) use (&$buffer)
+        {
             $buffer .= $data;
         });
         return $buffer;