Changeset 6833

Show
Ignore:
Timestamp:
09/22/08 12:10:27 (3 years ago)
Author:
sasargen
Message:

ARI: update callme feature to use phpagi-asmanager for Asterisk Manager Interface

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved

  • freepbx/branches/ari_changes/amp_conf/htdocs/recordings/includes/callme.php

    r6421 r6833  
    99 
    1010/* 
     11 * 
     12 * Include admin/functions.inc.php for our call to parse_amportal_conf() 
     13 * Include admin/common/php-asmanager.php to use the AGI_AsteriskManager class for accessing the AMI 
     14 * 
     15 */ 
     16require_once('../admin/functions.inc.php'); 
     17require_once('../admin/common/php-asmanager.php'); 
     18 
     19$amp_conf   = parse_amportal_conf("/etc/amportal.conf"); 
     20$asm    = new AGI_AsteriskManager(); 
     21// attempt to connect to asterisk manager proxy 
     22if (!isset($amp_conf["ASTMANAGERPROXYPORT"]) || !$res = $asm->connect("127.0.0.1:".$amp_conf["ASTMANAGERPROXYPORT"], $amp_conf["AMPMGRUSER"] , $amp_conf["AMPMGRPASS"], 'off')) 
     23{ 
     24  // attempt to connect directly to asterisk, if no proxy or if proxy failed 
     25  if (!$res = $asm->connect("127.0.0.1:".$amp_conf["ASTMANAGERPORT"], $amp_conf["AMPMGRUSER"] , $amp_conf["AMPMGRPASS"], 'off')) 
     26  { 
     27    // couldn't connect at all 
     28    unset( $asm ); 
     29    $_SESSION['ari_error'] = 
     30    _("ARI does not appear to have access to the Asterisk Manager.") . " ($errno)<br>" . 
     31    _("Check the ARI 'main.conf.php' configuration file to set the Asterisk Manager Account.") . "<br>" . 
     32    _("Check /etc/asterisk/manager.conf for a proper Asterisk Manager Account") . "<br>" . 
     33    _("make sure [general] enabled = yes and a 'permit=' line for localhost or the webserver."); 
     34  } 
     35} 
     36 
     37function callme_close() 
     38{ 
     39  global $asm; 
     40  if (is_object($asm)) 
     41  { 
     42    $asm->logoff(); 
     43    $asm->disconnect(); 
     44  } 
     45  unset($asm); 
     46} 
     47/* 
    1148 * Call Me functions 
    1249 */ 
    13 /* Return the call me number stored in the database. */ 
     50 /* Return the call me number stored in the database. */ 
    1451function callme_getnum($exten) 
    1552{ 
    16         global $asterisk_manager_interface; 
     53        global $asm; 
     54        $cmd    = "database get AMPUSER $exten/callmenum"; 
     55  $callme_num   = ''; 
     56        $results  = $asm->Command($cmd); 
    1757 
    18         $action = "Action: Command\r\nCommand: database get AMPUSER $exten/callmenum\r\n\r\n"; 
    19         $callme_num = $asterisk_manager_interface->Command($action); 
     58  if (is_array($results)) 
     59  { 
     60    foreach ($results as $results_elem) 
     61    { 
     62      if (preg_match('/Value: [^\s]*/', $results_elem, $matches) != 0) 
     63      { 
     64        $parts = split(' ', trim($matches[0])); 
     65        $callme_num = $parts[1]; 
     66      } 
     67 
     68    } 
     69  } 
     70 
    2071        return $callme_num; 
    2172} 
    …… 
    2475function callme_setnum($exten, $callme_num) 
    2576{ 
    26         global $asterisk_manager_interface; 
     77        global $asm; 
    2778 
    28         $action = "Action: Command\r\nCommand: database put AMPUSER $exten/callmenum $callme_num\r\n\r\n"; 
    29         $asterisk_manager_interface->Command($action); 
     79        $cmd = "database put AMPUSER $exten/callmenum $callme_num"; 
     80        $asm->Command($cmd); 
    3081        return; 
    31 } 
    32  
    33 /* Send an action directly to the ami.  No return value.*/ 
    34 function callme_sendcmd($action) 
    35 { 
    36   global $asterisk_manager_interface; 
    37   $socket = $asterisk_manager_interface->socket; 
    38    
    39   fwrite($socket, $action); 
    40   fflush($socket); 
    41   return; 
    4282} 
    4383 
    …… 
    4686function callme_startcall($to, $from, $new_path) 
    4787{ 
    48         $action = "Action: Originate\r\n"; 
    49         $action .= "Channel: Local/$to@from-internal/n\r\n"; 
    50         $action .= "Context: custom-callme\r\n"; 
    51         $action .= "Exten: s\r\n"; 
    52         $action .= "Priority: 1\r\n"; 
    53         $action .= "CallerID: VMAIL/$from\r\n"; 
    54         $action .= "Variable: MSG=$new_path\r\n"; 
    55         $action .= "Variable: MBOX=$from\r\n\r\n"; 
    56  
    57   $status = callme_originate($action); 
    58         return $status; 
     88  global $asm; 
     89  $channel  = "Local/$to@from-internal/n"; 
     90  $context  = "custom-callme"; 
     91  $extension  = "s"; 
     92  $priority = "1"; 
     93  $callerid = "VMAIL/$from"; 
     94  $variable = "MSG=$new_path|MBOX=$from"; 
     95  /* Arguments to Originate: channel, extension, context, priority, timeout, callerid, variable, account, application, data */ 
     96  $status = $asm->Originate($channel, $extension, $context, $priority, NULL, $callerid, $variable, NULL, NULL, NULL); 
     97  if (is_array($status)) 
     98  { 
     99    foreach ($status as $status_elem) 
     100    { 
     101      if (preg_match('/Originate successfully queued/', $status_elem, $matches) != 0) 
     102      { 
     103        return CALLME_SUCCESS; 
     104      } 
     105    } 
     106  }  
     107  return CALLME_FAILURE; 
    59108} 
    60109 
    61 /* Turns event monitoring off for our ami instance, thereby     */ 
    62 /* facilitating retrieval of responses to actions sent to       */ 
    63 /* the ami (with events off, we can safely expect to only       */ 
    64 /* see results from our actions over the ami and no more).      */ 
    65 /* Called by callme_originate().  Assumed to have been          */ 
    66 /* called BEFORE callme_hangup() is called (see callme_hangup). */ 
    67110function callme_eventsoff() 
    68111{ 
    69   global $asterisk_manager_interface; 
    70   $socket = $asterisk_manager_interface->socket; 
    71   $action = "Action: Events\r\n"; 
    72   $action .= "Eventmask: off\r\n\r\n"; 
    73  
    74   callme_sendcmd($action); 
    75    
    76   /* Take the action's response out of the socket's buffer; do nothing with the response. */ 
    77   while (($buffer=fgets($socket)) && (!preg_match('/Response: Events Off/', $buffer))); 
     112  global $asm; 
     113  $asm->Events("off"); 
    78114  return; 
    79 } 
    80  
    81 /* Helper function called by callme_startcall().  Sends the ORIGINATE action */ 
    82 /* passed to it (this *must* be an Originate action) to the ami via          */ 
    83 /* callme_sendcmd().  Retrieves the Originate response and parses that       */ 
    84 /* response in order to determine state of call (success/failure/error).     */ 
    85 /* Returns state of call.                                                    */ 
    86 function callme_originate($action) 
    87 { 
    88   global $asterisk_manager_interface; 
    89   $socket = $asterisk_manager_interface->socket; 
    90  
    91   $error_pat = '/Response: Error[\s]*/'; 
    92   $success_pat = '/Response: Success[\s]*/'; 
    93   $r = ""; 
    94   $buffer = ""; 
    95   callme_eventsoff(); 
    96   callme_sendcmd($action); 
    97    
    98   /* Continue polling for a result from the action until we get it. */ 
    99   /* (For example, it may take a long time to get a result back     */ 
    100   /* from the Originate action in the case where the phone rings    */ 
    101   /* until the call times out.)  Pull the entire Originate response */ 
    102   /* from the socket's buffer.            */ 
    103   while (!preg_match('/Message: Originate[a-zA-Z\s]*/', $buffer)) 
    104   { 
    105     $buffer = fgets($socket); 
    106     $r .= $buffer;     
    107   } 
    108  
    109   if (preg_match($error_pat, $r)) 
    110   { 
    111     return CALLME_FAILURE; 
    112   } else if (preg_match($success_pat, $r)) 
    113   { 
    114     return CALLME_SUCCESS; 
    115   } else 
    116   { 
    117     return CALLME_ERROR; 
    118   } 
    119    
    120 } 
    121  
    122 /* Logs us off the ami. */ 
    123 function callme_logoff() 
    124 { 
    125   $action = "Action: Logoff\r\n\r\n"; 
    126         callme_sendcmd($action); 
    127         return; 
    128115} 
    129116 
    …… 
    140127function callme_hangup($exten) 
    141128{ 
    142   global $asterisk_manager_interface; 
    143   $socket = $asterisk_manager_interface->socket; 
    144   $action = "Action: Command\r\nCommand: local show channels\r\n\r\n"; 
    145         $chan_pat = '/[\s]*Local\/' . trim($exten) . '@from\-internal\-[a-zA-Z0-9]*,(1|2)[\s]*/'; 
    146   $matches[0] = ""; 
    147   $response = ""; 
    148   /* Events must be off for callme_sendcmd() to work, but   */ 
    149   /* callme_eventsoff() is called in callme_startcall(), and  */ 
    150   /* callme_hangup() should not be called unless      */ 
    151   /* callme_startcall() was called first!       */ 
    152   callme_sendcmd($action); 
    153  
    154   /* Read in entire response belonging to our ami command action. */ 
    155   while (($buffer=fgets($socket)) && (!preg_match('/\-\-END COMMAND\-\-/', $buffer))) 
    156     $response .= $buffer; 
     129  global $asm; 
     130  $cmd    = "local show channels"; 
     131        $chan_pat   = '/[\s]*Local\/' . trim($exten) . '@from\-internal\-[a-zA-Z0-9]*,(1|2)[\s]*/'; 
     132  $matches[0]   = ""; 
     133  $response   = ""; 
     134  $channel  = ""; 
     135  $local_channels = $asm->Command($cmd); 
    157136 
    158137  /* Look for our local channel. */ 
    159   preg_match($chan_pat, $response, $matches); 
     138  if (is_array($local_channels)) 
     139  { 
     140    foreach ($local_channels as $local_channels_elem) 
     141    { 
     142      preg_match($chan_pat, $local_channels_elem, $matches); 
     143      if ($matches[0] != "") 
     144      { 
     145        $channel = $matches[0]; 
     146        break; 
     147      } 
     148    } 
     149  } else 
     150  { 
     151    $channel = ""; 
     152  } 
    160153 
    161154  /* If the channel was still up, hang it up. */  
    162   if ($matches[0] != "") 
     155  if ($channel != "") 
    163156  { 
    164     $action = "Action: Hangup\r\nChannel: " . trim($matches[0]) . "\r\n\r\n"; 
    165     callme_sendcmd($action); 
    166   }  
    167  
     157    $asm->Hangup(trim($channel)); 
     158  } 
    168159  return;  
    169  
    170160} 
    171161?> 

  • freepbx/branches/ari_changes/amp_conf/htdocs/recordings/misc/callme_page.php

    r6650 r6833  
    1010include_once("./includes/common.php"); 
    1111 
    12 function cmpage_ami_open() { 
    13   global $asterisk_manager_interface; 
    14   global $ASTERISKMGR_DBHOST; 
    15   global $STANDALONE; 
    16   global $AMP_FUNCTIONS_FILES; 
    17   global $AMPORTAL_CONF_FILE; 
    18         global $amp_conf_defaults; 
    19   $asterisk_manager_interface = new AsteriskManagerInterface(); 
    20   /* get login credentials */ 
    21   if ($STANDALONE['use']) { 
    22     $mgrhost = $ASTERISKMGR_DBHOST; 
    23     $mgruser = $STANDALONE['asterisk_mgruser']; 
    24     $mgrpass = $STANDALONE['asterisk_mgrpass']; 
    25   } else { 
    26     $include = 0; 
    27     $files = split(';',$AMP_FUNCTIONS_FILES); 
    28     foreach ($files as $file) { 
    29       if (is_file($file)) { 
    30         include_once($file); 
    31         $include = 1; 
    32       } 
    33     } 
    34  
    35     if ($include) { 
    36       $amp_conf = parse_amportal_conf($AMPORTAL_CONF_FILE); 
    37       $mgrhost = $ASTERISKMGR_DBHOST; 
    38       $mgruser = $amp_conf['AMPMGRUSER']; 
    39       $mgrpass = $amp_conf['AMPMGRPASS']; 
    40       unset($amp_conf); 
    41     } 
    42   } 
    43  
    44   $success = $asterisk_manager_interface->Connect($mgrhost,$mgruser,$mgrpass); 
    45   if (!$success) { 
    46     $_SESSION['ari_error'] = 
    47     _("ARI does not appear to have access to the Asterisk Manager.") . " ($errno)<br>" . 
    48     _("Check the ARI 'main.conf.php' configuration file to set the Asterisk Manager Account.") . "<br>" . 
    49     _("Check /etc/asterisk/manager.conf for a proper Asterisk Manager Account") . "<br>" . 
    50     _("make sure [general] enabled = yes and a 'permit=' line for localhost or the webserver."); 
    51     return FALSE; /* exit */ 
    52   } 
    53 } 
    54  
    55 function cmpage_ami_close() { 
    56  
    57   global $asterisk_manager_interface; 
    58   $action = "Action: Logoff\r\n\r\n"; 
    59   //$asterisk_manager_interface->Command($action); 
    60   callme_sendcmd($action); 
    61   $asterisk_manager_interface->Disconnect(); 
    62   unset($asterisk_manager_interface); 
    63 } 
    6412?> 
    6513 
    …… 
    7321 
    7422<?php 
    75   global $ARI_CRYPT_PASSWORD; 
    76   $crypt = new Crypt(); 
    77   $path   = $crypt->decrypt($_REQUEST['recording'],$ARI_CRYPT_PASSWORD); 
    78   $to     = $crypt->decrypt($_REQUEST['callmenum'],$ARI_CRYPT_PASSWORD); 
    79   $pageaction = $_REQUEST['action']; 
    80   $msgFrom  = $crypt->decrypt($_REQUEST['msgFrom'],$ARI_CRYPT_PASSWORD); 
    81   $new_path = substr($path, 0, -4);   /* Without the sound file extension. */ 
     23  $path       = $_SESSION['ari_user']['recfiles'][$_REQUEST['recindex']]; 
     24  $pageaction = $_REQUEST['action']; 
     25  $to         = $_REQUEST['callmenum']; 
     26  $msgFrom    = $_REQUEST['msgFrom']; 
     27  $new_path   = substr($path, 0, -4);   /* Without the sound file extension. */ 
    8228  $matches[0] = ''; /* init the $matches array. */ 
    8329  /* Either start or end the call me call */ 
    …… 
    8632    case "c": 
    8733      /* Call me. */ 
    88       cmpage_ami_open(); 
    8934      $call_status = callme_startcall($to, $msgFrom, $new_path); 
    9035      echo("<table class='voicemail' style='width: 100%; height: 100%; margin: 0 0 0 0; border: 0px; padding: 0px'><tr><td valign='middle' style='border: 0px'>"); 
    …… 
    9237      if (callme_succeeded($call_status)) 
    9338      { 
    94         echo("<a href='callme_page.php?action=h&callmenum=" . urlencode($crypt->encrypt($to, $ARI_CRYPT_PASSWORD)) . "'>Click here to hang up.</a>"); 
     39        echo("<a href='callme_page.php?action=h&callmenum=" . $to . "'>Click here to hang up.</a>"); 
    9540      } 
    9641      echo("</td></tr></table>"); 
    9742      echo("<script language='javascript'>parent.document.getElementById('callme_status').innerHTML = '" . _("$call_status") . "';</script>"); 
    98       cmpage_ami_close(); 
    9943      echo("<script language='javascript'>parent.document.getElementById('pb_load_inprogress').value='false';</script>"); 
    10044                  echo("<script language='javascript'>parent.document.getElementById('callme_status').parentNode.style.backgroundColor = 'white';</script>"); 
    …… 
    10246    case "h": 
    10347      /* Hang up. */ 
    104       cmpage_ami_open(); 
    10548      /* Find the channel and hang it up if it still exists. */ 
    10649      callme_hangup($to); 
    107       cmpage_ami_close(); 
    10850      echo("<script language='javascript'>parent.document.getElementById('callme_status').innerHTML = '" . _("The call was terminated.") . "';</script>"); 
    10951      break;