database = $freepbx->Database; $this->config = $freepbx->Config; $this->freepbx = $freepbx; $this->astman = $freepbx->astman; //load drivers $this->loadDrivers(); } /** * Get Right Nav * @param array $request The request * @return string The Right nav html */ public function getRightNav($request) { $display_mode = "advanced"; $mode = $this->freepbx->Config()->get("FPBXOPMODE"); if(!empty($mode)) { $display_mode = $mode; } switch($request['display']){ case 'extensions': case 'devices': $popover = isset($request['fw_popover']) ? "&fw_popover=".$request['fw_popover'] : ''; $show = isset($request['tech_hardware']) || (isset($request['view']) && $request['view'] == "add") || (isset($request['extdisplay']) && trim($request['extdisplay']) != ""); if($display_mode == "basic" && (!isset($request['extdisplay']) || trim($request['extdisplay']) == "")) { return array(); } return load_view(__DIR__."/views/rnav.php",array("show" => $show, "display" => $request['display'], "popover"=>$popover)); break; case 'trunks': if(isset($request['tech'])||(isset($request['extdisplay']) && !empty($request['extdisplay']))){ $html = load_view(__DIR__.'/views/trunks/bootnav.php', array('trunk_types' => \FreePBX::Core()->listTrunkTypes())); return $html; } break; case 'did': if(isset($request['view'])){ $html = load_view(__DIR__.'/views/did/rnav.php'); return $html; } break; case 'routing': if(isset($request['view'])){ $html = load_view(__DIR__.'/views/routing/bootnav.php'); return $html; } break; case 'dahdichandids': if(isset($request['view'])){ $html = load_view(__DIR__.'/views/dahdichandids/bootnav.php'); return $html; } break; case 'ampusers': $html = load_view(__DIR__.'/views/ampusers/bootnav.php'); return $html; break; } } /** * Get all drivers from the private handler * this is so they cant be modified by some outside source */ public function getAllDrivers() { return $this->drivers; } /** * Get a single driver object * @param string $driver The driver name * @return object The driver Object */ public function getDriver($driver) { return isset($this->drivers[$driver]) ? $this->drivers[$driver] : false; } /** * Load all "core" drivers */ public function loadDrivers() { if(!class_exists("FreePBX\Modules\Core\Driver",false)) { include(__DIR__."/functions.inc/Driver.class.php"); } $driverNamespace = "\\FreePBX\\Modules\\Core\\Drivers"; foreach(glob(__DIR__."/functions.inc/drivers/*.class.php") as $driver) { if(preg_match("/\/([a-z1-9]*)\.class\.php$/i",$driver,$matches)) { $name = $matches[1]; $class = $driverNamespace . "\\" . $name; if(!class_exists($class,false)) { include($driver); } if(class_exists($class,false)) { $this->drivers[strtolower($name)] = new $class($this->freepbx); } else { throw new \Exception("Invalid Class inside the drivers folder"); } } } } /** * Get all information about all drivers */ public function getAllDriversInfo() { $final = array(); foreach($this->drivers as $driver) { $info = $driver->getInfo(); if($info === false) { continue; } $rn = $info['rawName']; $final[$rn] = $info; } return $final; } /** * Quick Extension Create Display */ public function getQuickCreateDisplay() { $sql = "SELECT extension FROM users ORDER BY extension DESC LIMIT 1"; $lastExension = $this->freepbx->Database->query($sql)->fetchColumn(); $startExt = !empty($lastExension) ? $lastExension + 1 : 1; $pages = array(); $pages[0][] = array( 'html' => load_view(__DIR__.'/views/quickCreate.php',array('startExt' => $startExt)), 'validate' => 'if($("#extension").val().trim() == "") {warnInvalid($("#extension"),"'._("Extension can not be blank!").'");return false}if(typeof extmap[$("#extension").val().trim()] !== "undefined") {warnInvalid($("#extension"),"'._("Extension already in use!").'");return false}if($("#name").val().trim() == "") {warnInvalid($("#name"),"'._("Display Name can not be blank!").'");return false}' ); $modules = $this->freepbx->Hooks->processHooks(); foreach($modules as $module) { foreach($module as $page => $datas) { foreach($datas as $html) { $pages[$page][] = $html; } } } return $pages; } /** * Process the Quick Extension Create Display * @param string $tech The tech type (provided by the driver) * @param int $extension The extension number * @param array $data Data passed from $_POST on submit */ public function processQuickCreate($tech, $extension, $data) { if(!is_numeric($extension)) { return array("status" => false, "message" => _("Extension was not numeric!")); } $settings = $this->generateDefaultDeviceSettings($tech,$extension,$data['name']); if(!$this->addDevice($extension,$tech,$settings)) { return array("status" => false, "message" => _("Device was not added!")); } $settings = $this->generateDefaultUserSettings($extension,$data['name']); $settings['outboundcid'] = $data['outboundcid']; try { if(!$this->addUser($extension, $settings)) { //cleanup $this->delDevice($extension); return array("status" => false, "message" => _("There was an unknown error creating this extension")); } } catch(\Exception $e) { //cleanup $this->delDevice($extension); throw $e; } try { $modules = $this->freepbx->Hooks->processHooks($tech, $extension, $data); } catch(\Exception $e) { //cleanup $this->delDevice($extension); $this->delUser($extension); throw $e; } needreload(); return array("status" => true, "ext" => $extension, "name" => $data['name']); } /* this is useful only for emergencydevice creation*/ public function emergencyProcessQuickCreate($tech, $extension, $data) { if(!is_numeric($extension)) { return array("status" => false, "message" => _("Extension was not numeric!")); } $settings = $this->generateDefaultDeviceSettings($tech,$extension,$data['name']); $settings['emergency_cid']['value'] = $data['emergency_cid']; $settings['context']['value'] = $data['context']; $settings['callerid']['value'] = $data['emergency_cid']; $settings['calleridname']['value'] = $data['name']; if(strtolower($tech) == 'pjsip') { $settings['max_contacts']['value'] = $data['max_contacts']; } if(!$this->emergencyAddDevice($extension,$tech,$settings)) { return array("status" => false, "message" => _("Device was not added!")); } // we dont want to do the userthings for emergency needreload(); return array("status" => true, "ext" => $extension, "name" => $data['name']); } /** * Propagator for genConfig() from BMO that is passed on * to child drivers */ public function genConfig() { $conf = array(); foreach($this->drivers as $driver) { $c = $driver->genConfig(); if(!empty($c)) { $conf = array_merge($c, $conf); } } return $conf; } /** * Propagator for writeConfig() from BMO that is passed on * to child drivers * @param array $config Config Array */ public function writeConfig($config) { foreach($this->drivers as $driver) { $config = $driver->writeConfig($config); } return $config; } public function getActionBar($request) { $buttons = array(); switch($request['display']) { case 'ampusers': $buttons = array( 'delete' => array( 'name' => 'delete', 'id' => 'delete', 'value' => _('Delete') ), 'reset' => array( 'name' => 'reset', 'id' => 'reset', 'value' => _('Reset') ), 'submit' => array( 'name' => 'submit', 'id' => 'submit', 'value' => _('Submit') ) ); if (empty($request['userdisplay'])) { unset($buttons['delete']); } break; case 'users': case 'devices': $buttons = array( 'delete' => array( 'name' => 'delete', 'id' => 'delete', 'value' => _('Delete') ), 'reset' => array( 'name' => 'reset', 'id' => 'reset', 'value' => _('Reset') ), 'submit' => array( 'name' => 'submit', 'id' => 'submit', 'value' => _('Submit') ) ); if($request['view'] == 'add' || !empty($request['tech_hardware'])) { unset($buttons['delete']); } elseif(!isset($request['extdisplay']) || trim($request['extdisplay']) == '') { $buttons = array(); } break; case 'extensions': $buttons = array( 'delete' => array( 'name' => 'delete', 'id' => 'delete', 'value' => _('Delete') ), 'reset' => array( 'name' => 'reset', 'id' => 'reset', 'value' => _('Reset') ), 'submit' => array( 'name' => 'submit', 'id' => 'submit', 'value' => _('Submit') ) ); if(!empty($request['tech_hardware'])) { unset($buttons['delete']); } elseif(!isset($request['extdisplay']) || trim($request['extdisplay']) == '') { $buttons = array(); } break; case 'advancedsettings': $buttons = array( 'reset' => array( 'name' => 'reset', 'id' => 'reset', 'value' => _('Reset') ), 'submit' => array( 'name' => 'submit', 'id' => 'submit', 'value' => _('Submit') ) ); break; case 'dahdichandids': $buttons = array( 'delete' => array( 'name' => 'delete', 'id' => 'delete', 'value' => _('Delete') ), 'reset' => array( 'name' => 'reset', 'id' => 'reset', 'value' => _('Reset') ), 'submit' => array( 'name' => 'submit', 'id' => 'submit', 'value' => _('Submit') ) ); if (empty($request['extdisplay'])) { unset($buttons['delete']); } case 'did': $buttons = array( 'delete' => array( 'name' => 'delete', 'id' => 'delete', 'value' => _('Delete') ), 'reset' => array( 'name' => 'reset', 'id' => 'reset', 'value' => _('Reset') ), 'submit' => array( 'name' => 'submit', 'id' => 'submit', 'value' => _('Submit') ) ); if (empty($request['extdisplay'])) { unset($buttons['delete']); } if(!isset($request['view'])||$request['view'] == ''){ $buttons = array(); } break; case 'routing': $buttons = array( 'delete' => array( 'name' => 'delete', 'id' => 'delete', 'value' => _('Delete') ), 'duplicate' => array( 'name' => 'duplicate', 'id' => 'duplicate', 'value' => _('Duplicate') ), 'reset' => array( 'name' => 'reset', 'id' => 'reset', 'value' => _('Reset') ), 'submit' => array( 'name' => 'submit', 'id' => 'submit', 'value' => _('Submit') ) ); if (empty($request['id'])) { unset($buttons['delete'], $buttons['duplicate']); } if (empty($request['view'])){ $buttons = array(); } break; case 'trunks': $tmpButtons = array( 'delete' => array( 'name' => 'delete', 'id' => 'delete', 'value' => _('Delete') ), 'duplicate' => array( 'name' => 'duplicate', 'id' => 'duplicate', 'value' => _('Duplicate') ), 'reset' => array( 'name' => 'reset', 'id' => 'reset', 'value' => _('Reset') ), 'submit' => array( 'name' => 'submit', 'id' => 'submit', 'value' => _('Submit') ) ); if (!empty($request['extdisplay'])) { $buttons = $tmpButtons; } else if (!empty($request['tech'])) { unset($tmpButtons['delete'], $tmpButtons['duplicate']); $buttons = $tmpButtons; } break; case 'dahdichandids': $buttons = array( 'delete' => array( 'name' => 'delete', 'id' => 'delete', 'value' => _('Delete') ), 'reset' => array( 'name' => 'reset', 'id' => 'reset', 'value' => _('Reset') ), 'submit' => array( 'name' => 'submit', 'id' => 'submit', 'value' => _('Submit') ) ); if ($request['view'] == 'add') { unset($buttons['delete']); } break; } return $buttons; } public function install() { } public function uninstall() { } public function backup() { } public function restore($backup) { } public function doTests($db) { return true; } public function ajaxRequest($req, &$setting) { switch($req) { case "delastmodule": case "addastmodule": case "quickcreate": case "delete": case "getJSON": case "getExtensionGrid": case "getDeviceGrid": case "getUserGrid": case "updateRoutes": case "delroute": case "getnpanxxjson": case "populatenpanxx": return true; break; } return false; } public function ajaxHandler() { $request = freepbxGetSanitizedRequest(); switch($request['command']) { case "addastmodule": $section = isset($request['section'])?$request['section']:''; $module = isset($request['astmod'])?$request['astmod']:''; switch($section){ case 'amodload': return $this->ModulesConf->load($module); break; case 'amodnoload': return $this->ModulesConf->noload($module); break; case 'amodpreload': return $this->ModulesConf->preload($module); break; } break; case "delastmodule": $section = isset($request['section'])?$request['section']:''; $module = isset($request['astmod'])?$request['astmod']:''; switch($section){ case 'amodload': return $this->ModulesConf->removeload($module); break; case 'amodnoload': return $this->ModulesConf->removenoload($module); break; case 'amodpreload': return $this->ModulesConf->removepreload($module); break; } break; case "delroute": if (!function_exists('core_routing_delbyid')) { if (file_exists(__DIR__."/functions.inc.php")) { include __DIR__."/functions.inc.php"; } } $ret = core_routing_delbyid($_POST['id']); // re-order the routes to make sure that there are no skipped numbers. // example if we have 001-test1, 002-test2, and 003-test3 then delete 002-test2 // we do not want to have our routes as 001-test1, 003-test3 we need to reorder them // so we are left with 001-test1, 002-test3 needreload(); return $ret; break; case "updateRoutes": $order = $request['data']; array_shift($order); return $this->setRouteOrder($order); break; case "getUserGrid": $users = $this->getAllUsers(); if(empty($users)) { return array(); } $ampuser = $this->astman->database_show("AMPUSER"); // Get all CW settings $cwsetting = $this->astman->database_show("CW"); // get all CF settings $cfsetting = $this->astman->database_show("CF"); // get all CFB settings $cfbsetting = $this->astman->database_show("CFB"); // get all CFU settings $cfusetting = $this->astman->database_show("CFU"); // get all DND settings $dndsetting = $this->astman->database_show("DND"); foreach($users as &$user) { $exten = $user['extension']; $user['settings'] = array( 'cw' => (isset($cwsetting['/CW/'.$exten]) && $cwsetting['/CW/'.$exten] == "ENABLED"), 'dnd' => (isset($dndsetting['/DND/'.$exten]) && $dndsetting['/DND/'.$exten] == "YES"), 'cf' => (isset($cfsetting['/CF/'.$exten])), 'cfb' => (isset($cfbsetting['/CFB/'.$exten])), 'cfu' => (isset($cfusetting['/CFU/'.$exten])), 'fmfm' => (isset($ampuser['/AMPUSER/'.$exten.'/followme/ddial']) && $ampuser['/AMPUSER/'.$exten.'/followme/ddial'] == "DIRECT") ); $user['actions'] = ''; } return array_values($users); break; case "getExtensionGrid": $ampuser = $this->astman->database_show("AMPUSER"); // Get all CW settings $cwsetting = $this->astman->database_show("CW"); // get all CF settings $cfsetting = $this->astman->database_show("CF"); // get all CFB settings $cfbsetting = $this->astman->database_show("CFB"); // get all CFU settings $cfusetting = $this->astman->database_show("CFU"); // get all DND settings $dndsetting = $this->astman->database_show("DND"); if($request['type'] == "all") { $devices = $this->getAllUsersByDeviceType(); if(empty($devices)) { return array(); } foreach($devices as &$device) { $exten = $device['extension']; $device['settings'] = array( 'cw' => (isset($cwsetting['/CW/'.$exten]) && $cwsetting['/CW/'.$exten] == "ENABLED"), 'dnd' => (isset($dndsetting['/DND/'.$exten]) && $dndsetting['/DND/'.$exten] == "YES"), 'cf' => (isset($cfsetting['/CF/'.$exten])), 'cfb' => (isset($cfbsetting['/CFB/'.$exten])), 'cfu' => (isset($cfusetting['/CFU/'.$exten])), 'fmfm' => (isset($ampuser['/AMPUSER/'.$exten.'/followme/ddial']) && $ampuser['/AMPUSER/'.$exten.'/followme/ddial'] == "DIRECT") ); $device['actions'] = ''; } return $devices; } else { $devices = $this->getAllUsersByDeviceType($request['type']); if(empty($devices)) { return array(); } foreach($devices as &$device) { $exten = $device['extension']; $device['settings'] = array( 'cw' => (isset($cwsetting['/CW/'.$exten]) && $cwsetting['/CW/'.$exten] == "ENABLED"), 'dnd' => (isset($dndsetting['/DND/'.$exten]) && $dndsetting['/DND/'.$exten] == "YES"), 'cf' => (isset($cfsetting['/CF/'.$exten])), 'cfb' => (isset($cfbsetting['/CFB/'.$exten])), 'cfu' => (isset($cfusetting['/CFU/'.$exten])) ); $device['actions'] = ''; } return $devices; } break; case "getDeviceGrid": if($request['type'] == "all") { $devices = $this->getAllDevicesByType(); if(empty($devices)) { return array(); } foreach($devices as &$device) { $exten = $device['id']; $device['actions'] = ''; } return $devices; } else { $devices = $this->getAllDevicesByType($request['type']); if(empty($devices)) { return array(); } foreach($devices as &$device) { $exten = $device['id']; $device['actions'] = ''; } return $devices; } break; case "delete": if(!empty($_POST['extensions'])) { switch($_POST['type']) { case "extensions": foreach($_POST['extensions'] as $ext) { $this->delUser($ext); $this->delDevice($ext); } return array("status" => true); break; case "users": foreach($_POST['extensions'] as $ext) { $this->delUser($ext); } return array("status" => true); break; case "devices": foreach($_POST['extensions'] as $ext) { $this->delDevice($ext); } return array("status" => true); break; } } break; case "quickcreate": $status = $this->processQuickCreate($_POST['tech'], $_POST['extension'], $_POST); return $status; break; case "getJSON": switch ($request['jdata']) { case 'allDID': $dids = $this->getAllDIDs(); $dids = is_array($dids)?$dids:array(); foreach ($dids as $key => $value) { $dids[$key]['cidnum'] = urlencode($value['cidnum']); $dids[$key]['extension'] = urlencode($value['extension']); } return array_values($dids); break; case 'allTrunks': return array_values($this->listTrunks()); break; case 'routingrnav': return array_values($this->getAllRoutes()); break; case 'dahdichannels': return array_values($this->listDahdiChannels()); break; case 'ampusers': return array_values($this->listAMPUsers('assoc')); break; } break; case 'getnpanxxjson': try { $npa = $request['npa']; $nxx = $request['nxx']; $request = new \Pest('http://www.localcallingguide.com/xmllocalprefix.php'); $request->curl_opts[CURLOPT_FOLLOWLOCATION] = true; $data = $request->get('?npa='.$npa.'&nxx='.$nxx); $xml = new \SimpleXMLElement($data); $pfdata = $xml->xpath('//lca-data/prefix'); $retdata = array(); foreach($pfdata as $item){ $inpa = (string)$item->npa; $inxx = (string)$item->nxx; $retdata[$inpa.$inxx] = array('npa' => $inpa, 'nxx' => $inxx); } return $retdata; }catch(Pest_NotFound $e){ return array('error' => $e); } break; case 'populatenpanxx': $dialpattern_array = $dialpattern_insert; if (preg_match("/^([2-9]\d\d)-?([2-9]\d\d)$/", $request["npanxx"], $matches)) { // first thing we do is grab the exch: $ch = curl_init(); curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); curl_setopt($ch, CURLOPT_URL, "http://www.localcallingguide.com/xmllocalprefix.php?npa=".$matches[1]."&nxx=".$matches[2]); curl_setopt($ch, CURLOPT_USERAGENT, "Mozilla/5.0 (Linux; FreePBX Local Trunks Configuration)"); $str = curl_exec($ch); curl_close($ch); // quick 'n dirty - nabbed from PEAR global $amp_conf; require_once($amp_conf['AMPWEBROOT'] . '/admin/modules/core/XML_Parser.php'); require_once($amp_conf['AMPWEBROOT'] . '/admin/modules/core/XML_Unserializer.php'); $xml = new xml_unserializer; $xml->unserialize($str); $xmldata = $xml->getUnserializedData(); $hash_filter = array(); //avoid duplicates if (isset($xmldata['lca-data']['prefix'])) { // we do the loops separately so patterns are grouped together // match 1+NPA+NXX (dropping 1) foreach ($xmldata['lca-data']['prefix'] as $prefix) { if (isset($hash_filter['1'.$prefix['npa'].$prefix['nxx']])) { continue; } else { $hash_filter['1'.$prefix['npa'].$prefix['nxx']] = true; } $dialpattern_array[] = array( 'prepend_digits' => '', 'match_pattern_prefix' => '1', 'match_pattern_pass' => htmlspecialchars($prefix['npa'].$prefix['nxx']).'XXXX', 'match_cid' => '', ); } // match NPA+NXX foreach ($xmldata['lca-data']['prefix'] as $prefix) { if (isset($hash_filter[$prefix['npa'].$prefix['nxx']])) { continue; } else { $hash_filter[$prefix['npa'].$prefix['nxx']] = true; } $dialpattern_array[] = array( 'prepend_digits' => '', 'match_pattern_prefix' => '', 'match_pattern_pass' => htmlspecialchars($prefix['npa'].$prefix['nxx']).'XXXX', 'match_cid' => '', ); } // match 7-digits foreach ($xmldata['lca-data']['prefix'] as $prefix) { if (isset($hash_filter[$prefix['nxx']])) { continue; } else { $hash_filter[$prefix['nxx']] = true; } $dialpattern_array[] = array( 'prepend_digits' => '', 'match_pattern_prefix' => '', 'match_pattern_pass' => htmlspecialchars($prefix['nxx']).'XXXX', 'match_cid' => '', ); } unset($hash_filter); } else { $errormsg = _("Error fetching prefix list for: "). $request["npanxx"]; } } else { // what a horrible error message... :p $errormsg = _("Invalid format for NPA-NXX code (must be format: NXXNXX)"); } if (isset($errormsg)) { return array('error' => ""); unset($errormsg); } break; } } public function doConfigPageInit($page) { //Reassign $_REQUEST as it will be immutable in the future. $request = freepbxGetSanitizedRequest(); $unsanitized = array( 'CC_AGENT_ALERT_INFO_DEFAULT', 'CC_MONITOR_ALERT_INFO_DEFAULT', 'ATTTRANSALERTINFO' ,'BLINDTRANSALERTINFO', 'INTERNALALERTINFO' ); foreach($unsanitized as $s) { if(isset($_POST[$s])) { $request[$s] = $_POST[$s]; } } global $amp_conf; if ($page == "advancedsettings"){ $freepbx_conf = $this->config; $settings = $freepbx_conf->get_conf_settings(); foreach($request as $key => $val){ if (isset($settings[$key])) { if($key == 'CRONMAN_UPDATES_CHECK') { $cm = \cronmanager::create($db); if($val == 'true') { $cm->enable_updates(); } else { $cm->disable_updates(); } } switch($settings[$key]['type']) { case CONF_TYPE_BOOL: $val = ($val == 'true') ? 1 : 0; break; default: $val = trim($val); break; } //FREEPBX-11431 Call Forward Ringtimer Default - Setting does not work // lets add CFRINGTIMERDEFAULT value in to asteriskDB so that we can use latter in the dialplan if($key === 'CFRINGTIMERDEFAULT'){ $astman = $this->FreePBX->astman; if ($astman->connected()){ $astman->database_put("FREEPBXCONF",'CFRINGTIMERDEFAULT',$val); } } $freepbx_conf->set_conf_values(array($key => $val),true,$amp_conf['AS_OVERRIDE_READONLY']); $status = $freepbx_conf->get_last_update_status(); if ($status[$key]['saved']) { //debug(sprintf(_("Advanced Settings changed freepbx_conf setting: [$key] => [%s]"),$val)); needreload(); } } } }// $page == "advancedsettings" if ($page == "dahdichandids"){ if(!isset($_REQUEST['action'])){ return; } $type = isset($request['type']) ? $request['type'] : 'setup'; $action = isset($request['action']) ? $request['action'] : ''; if (isset($request['delete'])) $action = 'delete'; $extdisplay = isset($request['extdisplay']) ? $request['extdisplay'] : ''; $channel = isset($request['channel']) ? $request['channel'] : false; $description = isset($request['description']) ? $request['description'] : ''; $did = isset($request['did']) ? $request['did'] : ''; switch ($action) { case 'add': if (core_dahdichandids_add($description, $channel, $did)) { needreload(); $_REQUEST['extdisplay'] = $channel; unset($_REQUEST['view']); } break; case 'edit': if (core_dahdichandids_edit($description, $channel, $did)) { needreload(); unset($_REQUEST['view']); } break; case 'delete': core_dahdichandids_delete($channel); needreload(); break; } }// $page == "dahdichandids" if ($page == "routing") { $display='routing'; $extdisplay=isset($request['extdisplay'])?$request['extdisplay']:''; $action = isset($request['action'])?$request['action']:''; if (isset($request['copyroute'])) { $action = 'copyroute'; } $repotrunkdirection = isset($request['repotrunkdirection'])?$request['repotrunkdirection']:''; //this was effectively the sequence, now it becomes the route_id and the value past will have to change $repotrunkkey = isset($request['repotrunkkey'])?$request['repotrunkkey']:''; // Check if they uploaded a CSV file for their route patterns // if (isset($_FILES['pattern_file']) && $_FILES['pattern_file']['tmp_name'] != '') { $mimes = array('text/csv'); if (!in_array($_FILES['pattern_file']['type'], $mimes)) { echo ""; return; } $fh = fopen($_FILES['pattern_file']['tmp_name'], 'r'); if ($fh !== false) { $csv_file = array(); $index = array(); // Check first row, ingoring empty rows and get indices setup // while (($row = fgetcsv($fh, 5000, ",", "\"")) !== false) { if (count($row) == 1 && $row[0] == '') { continue; } else { $count = count($row) > 4 ? 4 : count($row); for ($i=0;$i<$count;$i++) { switch (strtolower($row[$i])) { case 'prepend': case 'prefix': case 'match pattern': case 'callerid': $index[strtolower($row[$i])] = $i; break; default: break; } } // If no headers then assume standard order if (count($index) == 0) { $index['prepend'] = 0; $index['prefix'] = 1; $index['match pattern'] = 2; $index['callerid'] = 3; if ($count == 4) { $csv_file[] = $row; } } break; } } $row_count = count($index); while (($row = fgetcsv($fh, 5000, ",", "\"")) !== false) { if (count($row) == $row_count) { $csv_file[] = $row; } } } } // If we have a CSV file it replaces any existing patterns // if (!empty($csv_file)) { foreach ($csv_file as $row) { $this_prepend = isset($index['prepend']) ? htmlspecialchars(trim($row[$index['prepend']])) : ''; $this_prefix = isset($index['prefix']) ? htmlspecialchars(trim($row[$index['prefix']])) : ''; $this_match_pattern = isset($index['match pattern']) ? htmlspecialchars(trim($row[$index['match pattern']])) : ''; $this_callerid = isset($index['callerid']) ? htmlspecialchars(trim($row[$index['callerid']])) : ''; if ($this_prepend != '' || $this_prefix != '' || $this_match_pattern != '' || $this_callerid != '') { $dialpattern_insert[] = array( 'prepend_digits' => $this_prepend, 'match_pattern_prefix' => $this_prefix, 'match_pattern_pass' => $this_match_pattern, 'match_cid' => $this_callerid, ); } } } else if (isset($request["bulk_patterns"])) { $prepend = '/^([^+]*)\+/'; $prefix = '/^([^|]*)\|/'; $match_pattern = '/([^/]*)/'; $callerid = '/\/(.*)$/'; $data = explode("\n",$request['bulk_patterns']); foreach($data as $list) { if (preg_match('/^\s*$/', $list)) { continue; } $this_prepend = $this_prefix = $this_callerid = ''; if (preg_match($prepend, $list, $matches)) { $this_prepend = $matches[1]; $list = preg_replace($prepend, '', $list); } if (preg_match($prefix, $list, $matches)) { $this_prefix = $matches[1]; $list = preg_replace($prefix, '', $list); } if (preg_match($callerid, $list, $matches)) { $this_callerid = $matches[1]; $list = preg_replace($callerid, '', $list); } $dialpattern_insert[] = array( 'prepend_digits' => htmlspecialchars(trim($this_prepend)), 'match_pattern_prefix' => htmlspecialchars(trim($this_prefix)), 'match_pattern_pass' => htmlspecialchars(trim($list)), 'match_cid' => htmlspecialchars(trim($this_callerid)), ); $i++; } } else if (isset($_REQUEST["dialpatterndata"])) { $dp = json_decode($_REQUEST['dialpatterndata'],true); $dp = is_array($dp) ? $dp : array(); foreach ($dp as $pattern) { if ($pattern['prepend_digit'] !='' || $pattern['pattern_prefix']!='' || $pattern['pattern_pass'] !='' || $pattern['match_cid'] !='') { $dialpattern_insert[] = array( 'prepend_digits' => htmlspecialchars(trim($pattern['prepend_digit'])), 'match_pattern_prefix' => htmlspecialchars(trim($pattern['pattern_prefix'])), 'match_pattern_pass' => htmlspecialchars(trim($pattern['pattern_pass'])), 'match_cid' => htmlspecialchars(trim($pattern['match_cid'])), ); } } } if ( isset($request['reporoutedirection']) && $request['reporoutedirection'] != '' && isset($request['reporoutekey']) && $request['reporoutekey'] != '') { $request['route_seq'] = core_routing_setrouteorder($request['reporoutekey'], $request['reporoutedirection']); } $trunkpriority = array(); if (isset($request["trunkpriority"])) { $trunkpriority = $request["trunkpriority"]; if (!$trunkpriority) { $trunkpriority = array(); } // delete blank entries and reorder foreach (array_keys($trunkpriority) as $key) { if ($trunkpriority[$key] == '') { // delete this empty unset($trunkpriority[$key]); } else if (($key==($repotrunkkey-1)) && ($repotrunkdirection=="up")) { // swap this one with the one before (move up) $temptrunk = $trunkpriority[$key]; $trunkpriority[ $key ] = $trunkpriority[ $key+1 ]; $trunkpriority[ $key+1 ] = $temptrunk; } else if (($key==($repotrunkkey)) && ($repotrunkdirection=="down")) { // swap this one with the one after (move down) $temptrunk = $trunkpriority[ $key+1 ]; $trunkpriority[ $key+1 ] = $trunkpriority[ $key ]; $trunkpriority[ $key ] = $temptrunk; } } unset($temptrunk); $trunkpriority = array_unique(array_values($trunkpriority)); // resequence our numbers if ($action == '') { $action = "updatetrunks"; } } $routename = isset($request['routename']) ? $request['routename'] : ''; $routepass = isset($request['routepass']) ? $request['routepass'] : ''; $emergency = isset($request['emergency']) ? $request['emergency'] : ''; $intracompany = isset($request['intracompany']) ? $request['intracompany'] : ''; $mohsilence = isset($request['mohsilence']) ? $request['mohsilence'] : ''; $outcid = isset($_REQUEST['outcid']) ? $_REQUEST['outcid'] : ''; $outcid_mode = isset($request['outcid_mode']) ? $request['outcid_mode'] : ''; $time_group_id = isset($request['time_group_id']) ? $request['time_group_id'] : ''; $route_seq = isset($request['route_seq']) ? $request['route_seq'] : ''; //email values will be taken from _POST because we don't want the sanitized //values(from freepbxGetSanitizedRequest), where stuff between angle brackets were removed. $emailfrom = isset($_POST['emailfrom']) ? $_POST['emailfrom'] : ''; $emailto = isset($_POST['emailto']) ? $_POST['emailto'] : ''; $emailsubject = isset($_POST['emailsubject']) ? $_POST['emailsubject'] : ''; $emailbody = isset($_POST['emailbody']) ? $_POST['emailbody'] : ''; $goto = isset($request['goto0'])?$request['goto0']:''; $dest = $goto ? $request[$goto . '0'] : ''; //if submitting form, update database switch ($action) { case 'ajaxroutepos': $ret = core_routing_setrouteorder($repotrunkkey, $repotrunkdirection); needreload(); header("Content-type: application/json"); echo json_encode(array('position' => $ret)); exit; break; case "copyroute": $routename .= "_copy_$extdisplay"; $extdisplay=''; $route_seq++; // Fallthrough to addtrunk now... // case "addroute": $extdisplay = core_routing_addbyid($routename, $outcid, $outcid_mode, $routepass, $emergency, $intracompany, $mohsilence, $time_group_id, $dialpattern_insert, $trunkpriority, $route_seq, $dest, $emailfrom, $emailto, $emailsubject, $emailbody); needreload(); break; case "editroute": $extdisplay = $_REQUEST['id']; core_routing_editbyid($extdisplay, $routename, $outcid, $outcid_mode, $routepass, $emergency, $intracompany, $mohsilence, $time_group_id, $dialpattern_insert, $trunkpriority, $route_seq, $dest, $emailfrom, $emailto, $emailsubject, $emailbody); needreload(); break; case "delroute": if (!function_exists('core_routing_delbyid')) { if (file_exists(__DIR__."/functions.inc.php")) { include __DIR__."/functions.inc.php"; } } $ret = core_routing_delbyid($_REQUEST['id']); // re-order the routes to make sure that there are no skipped numbers. // example if we have 001-test1, 002-test2, and 003-test3 then delete 002-test2 // we do not want to have our routes as 001-test1, 003-test3 we need to reorder them // so we are left with 001-test1, 002-test3 needreload(); return $ret; break; case "updatetrunks": $ret = core_routing_updatetrunks($extdisplay, $trunkpriority, true); header("Content-type: application/json"); echo json_encode(array('result' => $ret)); needreload(); exit; break; case 'prioritizeroute': needreload(); break; case 'getnpanxxjson': try { $npa = $request['npa']; $nxx = $request['nxx']; $url = 'http://www.localcallingguide.com/xmllocalprefix.php?npa=602&nxx=930'; $request = new \Pest('http://www.localcallingguide.com/xmllocalprefix.php'); $data = $request->get('?npa='.$npa.'&nxx='.$nxx); $xml = new \SimpleXMLElement($data); $pfdata = $xml->xpath('//lca-data/prefix'); $retdata = array(); foreach($pfdata as $item){ $inpa = (string)$item->npa; $inxx = (string)$item->nxx; $retdata[$inpa.$inxx] = array('npa' => $inpa, 'nxx' => $inxx); } $ret = json_encode($retdata); header("Content-type: application/json"); echo $ret; exit; }catch(Pest_NotFound $e){ header("Content-type: application/json"); echo json_encode(array('error' => $e)); exit; } break; case 'populatenpanxx': $dialpattern_array = $dialpattern_insert; if (preg_match("/^([2-9]\d\d)-?([2-9]\d\d)$/", $_REQUEST["npanxx"], $matches)) { // first thing we do is grab the exch: $ch = curl_init(); curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); curl_setopt($ch, CURLOPT_URL, "http://www.localcallingguide.com/xmllocalprefix.php?npa=".$matches[1]."&nxx=".$matches[2]); curl_setopt($ch, CURLOPT_USERAGENT, "Mozilla/5.0 (Linux; FreePBX Local Trunks Configuration)"); $str = curl_exec($ch); curl_close($ch); // quick 'n dirty - nabbed from PEAR global $amp_conf; require_once($amp_conf['AMPWEBROOT'] . '/admin/modules/core/XML_Parser.php'); require_once($amp_conf['AMPWEBROOT'] . '/admin/modules/core/XML_Unserializer.php'); $xml = new xml_unserializer; $xml->unserialize($str); $xmldata = $xml->getUnserializedData(); $hash_filter = array(); //avoid duplicates if (isset($xmldata['lca-data']['prefix'])) { // we do the loops separately so patterns are grouped together // match 1+NPA+NXX (dropping 1) foreach ($xmldata['lca-data']['prefix'] as $prefix) { if (isset($hash_filter['1'.$prefix['npa'].$prefix['nxx']])) { continue; } else { $hash_filter['1'.$prefix['npa'].$prefix['nxx']] = true; } $dialpattern_array[] = array( 'prepend_digits' => '', 'match_pattern_prefix' => '1', 'match_pattern_pass' => htmlspecialchars($prefix['npa'].$prefix['nxx']).'XXXX', 'match_cid' => '', ); } // match NPA+NXX foreach ($xmldata['lca-data']['prefix'] as $prefix) { if (isset($hash_filter[$prefix['npa'].$prefix['nxx']])) { continue; } else { $hash_filter[$prefix['npa'].$prefix['nxx']] = true; } $dialpattern_array[] = array( 'prepend_digits' => '', 'match_pattern_prefix' => '', 'match_pattern_pass' => htmlspecialchars($prefix['npa'].$prefix['nxx']).'XXXX', 'match_cid' => '', ); } // match 7-digits foreach ($xmldata['lca-data']['prefix'] as $prefix) { if (isset($hash_filter[$prefix['nxx']])) { continue; } else { $hash_filter[$prefix['nxx']] = true; } $dialpattern_array[] = array( 'prepend_digits' => '', 'match_pattern_prefix' => '', 'match_pattern_pass' => htmlspecialchars($prefix['nxx']).'XXXX', 'match_cid' => '', ); } unset($hash_filter); } else { $errormsg = _("Error fetching prefix list for: "). $request["npanxx"]; } } else { // what a horrible error message... :p $errormsg = _("Invalid format for NPA-NXX code (must be format: NXXNXX)"); } if (isset($errormsg)) { echo ""; unset($errormsg); } break; } }// $page == "routing" if ($page == "did") { $extdisplay= htmlspecialchars(isset($request['extdisplay'])?$request['extdisplay']:''); $old_extdisplay = $extdisplay; $dispnum = 'did'; //used for switch on config.php $action = isset($request['action'])?$request['action']:''; $rnavsort = isset($request['rnavsort'])?$request['rnavsort']:'description'; $didfilter = isset($request['didfilter'])?$request['didfilter']:''; if (isset($request['submitclear']) && isset($request['goto0'])) { $request[$request['goto0'].'0'] = ''; } if (isset($request['extension']) && isset($request['cidnum'])) { $extdisplay = $request['extension']."/".$request['cidnum']; } if (isset($request['old_extension']) && isset($request['old_cidnum'])) { $old_extdisplay = $request['old_extension']."/".$request['old_cidnum']; } //update db if submiting form switch ($action) { case 'addIncoming': //create variables from request extract($request, EXTR_SKIP); //add details to the 'incoming' table if (core_did_add($request)) { needreload(); $_REQUEST['extdisplay'] = $_REQUEST['extension']."/".$_REQUEST['cidnum']; $this->freepbx->View->redirect_standard('extdisplay', 'didfilter', 'rnavsort'); } break; case 'delIncoming': $extarray=explode('/',$extdisplay,2); core_did_del($extarray[0],$extarray[1]); needreload(); break; case 'edtIncoming': $extarray=explode('/',$old_extdisplay,2); if (core_did_edit($extarray[0],$extarray[1],$_REQUEST)) { needreload(); } break; } }// $page == "did" if ($page == "astmodules") { $action = !empty($request['action']) ? $request['action'] : ""; $section = !empty($request['section']) ? $request['section'] : ""; if(empty($request['module'])){ return false; } $modinfo = new \SplFileInfo($module); if($modinfo->getExtension() !== 'so'){ return false; } $module = $modinfo->getBasename(); unset($modinfo); switch($action){ case 'add': switch($section){ case 'amodload': $this->ModulesConf->load($module); return true; break; case 'amodnoload': $this->ModulesConf->noload($module); return true; break; case 'amodpreload': $this->ModulesConf->preload($module); return true; break; default: return false; break; } break; case 'del': switch($section){ case 'amodnoload': $this->ModulesConf->removenoload($module); return true; break; case 'amodpreload': $this->ModulesConf->removepreload($module); return true; break; default: return false; break; } break; default: return false; break; } } // $page == "astmodules" } /** * Converts a request into an array that core wants. * @param {int} $account The Account Number * @param {string} The TECH type * @param {int} &$flag The Flag Number */ public function convertRequest2Array($account,$tech,&$flag = 2) { if(!isset($account) || (trim($account) === "") || !ctype_digit($account)) { throw new \Exception("Account must be set!"); } if(empty($tech)) { throw new \Exception("tech must be set!"); } $flag = !empty($flag) ? $flag : 2; $fields = array(); $tech = strtoupper($tech); foreach ($_REQUEST as $req=>$data) { if ( substr($req, 0, 8) == 'devinfo_' ) { $keyword = substr($req, 8); $data = trim($data); if ( $keyword == 'dial' && $data == '' ) { if($tech == 'ZAP' || $tech == 'DAHDI') { $chan = $_REQUEST['devinfo_channel'] != '' ? $_REQUEST['devinfo_channel'] : $_REQUEST['channel']; $fields[$keyword] = array("value" => $tech.'/'.$chan, "flag" => $flag++); } else { $fields[$keyword] = array("value" => $tech.'/'.$account, "flag" => $flag++); } } elseif ($keyword == 'mailbox' && $data == '') { if($_REQUEST['vm'] == 'enabled') { $fields['mailbox'] = array("value" => $account.'@device', "flag" => $flag++); } } elseif ($keyword == 'vmexten' && $data == '') { // don't add it } else { $fields[$keyword] = array("value" => $data, "flag" => $flag++); } } } if(empty($fields)) { die_freepbx('Fields are empty'); } $fields['account'] = array("value" => $account, "flag" => $flag++); $fields['callerid'] = array("value" => (isset($_REQUEST['description']) && $_REQUEST['description']) ? $_REQUEST['description']." <".$account.'>' : 'device'." <".$account.'>', "flag" => $flag++); return $fields; } /** * Generate the default settings when creating a user * @param int $number The exten or device number * @param string $displayname The displayname */ public function generateDefaultUserSettings($number,$displayname) { return array( "extension" => $number, "name" => $displayname, "outboundcid" => "", "password" => "", "sipname" => "", "ringtimer" => 0, "callwaiting" => "enabled", "pinless" => "disabled", "recording_in_external" => "dontcare", "recording_out_external" => "dontcare", "recording_in_internal" => "dontcare", "recording_out_internal" => "dontcare", "recording_ondemand" => "disabled", "recording_priority" => "10", "answermode" => "disabled", "intercom" => "enabled", "cid_masquerade" => "", "noanswer_dest" => "", "busy_dest" => "", "concurrency_limit" => "", "chanunavail_dest" => "" ); } /** * Generate a secret to be used as a password Up to the SIPSECRETSIZE */ public function generateSecret(){ global $amp_conf; $secret = md5(uniqid());//32 char if(isset($amp_conf['SIPSECRETSIZE']) && $amp_conf['SIPSECRETSIZE'] < 32){ $secret = substr($secret, 0, $amp_conf['SIPSECRETSIZE']); } return $secret; } /** * Generate the default settings when creating a device * @param {string} The TECH * @param {int} The exten or device number * @param {string} $displayname The displayname */ public function generateDefaultDeviceSettings($tech,$number,$displayname,&$flag = 2) { $flag = !empty($flag) ? $flag : 2; $dial = ''; $settings = array(); //Ask our tech if it has default settings if(isset($this->drivers[$tech])) { $settings = $this->drivers[$tech]->getDefaultDeviceSettings($number, $displayname, $flag); if(empty($settings)) { return array(); } } $gsettings = array( "devicetype" => array( "value" => "fixed" ), "user" => array( "value" => $number ), "description" => array( "value" => $displayname ), "emergency_cid" => array( "value" => '', ), "dial" => array( "value" => $settings['dial']."/".$number, "flag" => $flag++ ), "secret" => array( "value" => $this->generateSecret(), "flag" => $flag++ ), "context" => array( "value" => "from-internal", "flag" => $flag++ ), "mailbox" => array( "value" => $number."@device", "flag" => $flag++ ), "account" => array( "value" => $number, "flag" => $flag++ ), "callerid" => array( "value" => "device <".$number.">", "flag" => $flag++ ), "outbound_proxy" => array( "value" => '', "flag" => $flag++ ) ); return array_merge($settings['settings'],$gsettings); } /** * Add Device * @param {int} The Device Number * @param {string} The TECH type * @param {array} $settings=array() Array with all settings * @param {bool} $editmode=false If edited, (this is so it doesnt destroy the AsteriskDB) */ public function addDevice($id,$tech,$settings=array(),$editmode=false) { if ($tech == '' || trim($tech) == 'virtual') { return true; } if (trim($id) == '' || empty($settings)) { throw new \Exception(_("Device Extension was blank or there were no settings defined")); return false; } //ensure this id is not already in use $dev = $this->getDevice($id); if(!empty($dev)) { throw new \Exception(_("This device id is already in use")); } //unless defined, $dial is TECH/id if ($settings['dial']['value'] == '') { //zap, dahdi are exceptions if (strtolower($tech) == "zap" || strtolower($tech) == 'dahdi') { $thischan = $settings['devinfo_channel']['value'] != '' ? $settings['devinfo_channel']['value'] : $settings['channel']['value']; $settings['dial']['value'] = strtoupper($tech).'/'.$thischan; //------------------------------------------------------------------------------------------------- // Added to enable the unsupported misdn module // } else if (strtolower($tech) == "misdn") { $settings['dial']['value'] = $settings['devinfo_port']['value'].'/'.($settings['devinfo_msn']['value'] ? $settings['devinfo_msn']['value'] : $id); //------------------------------------------------------------------------------------------------- } else { $settings['dial']['value'] = strtoupper($tech)."/".$id; } } $settings['user']['value'] = ($settings['user']['value'] == 'new') ? $id : $settings['user']['value']; $settings['emergency_cid']['value'] = trim($settings['emergency_cid']['value']); $settings['description']['value'] = trim($settings['description']['value']); $settings['hint_override']['value'] = isset($settings['hint_override']['value'])?trim($settings['hint_override']['value']) : null; //insert into devices table $sql="INSERT INTO devices (id,tech,dial,devicetype,user,description,emergency_cid,hint_override) values (?,?,?,?,?,?,?,?)"; $sth = $this->database->prepare($sql); try { $sth->execute(array($id,$tech,$settings['dial']['value'],$settings['devicetype']['value'],$settings['user']['value'],$settings['description']['value'],$settings['emergency_cid']['value'],$settings['hint_override']['value'])); } catch(\Exception $e) { die_freepbx("Could Not Insert Device", $e->getMessage()); return false; } $astman = $this->FreePBX->astman; //add details to astdb if ($astman->connected()) { // if adding or editting a fixed device, user property should always be set if ($settings['devicetype']['value'] == 'fixed' || !$editmode) { $astman->database_put("DEVICE",$id."/user",$settings['user']['value']); } // If changing from a fixed to an adhoc, the user property should be intialized // to the new default, not remain as the previous fixed user if ($editmode) { $previous_type = $astman->database_get("DEVICE",$id."/type"); if ($previous_type == 'fixed' && $settings['devicetype']['value'] == 'adhoc') { $astman->database_put("DEVICE",$id."/user",$settings['user']['value']); } } $astman->database_put("DEVICE",$id."/dial",$settings['dial']['value']); $astman->database_put("DEVICE",$id."/type",$settings['devicetype']['value']); $astman->database_put("DEVICE",$id."/default_user",$settings['user']['value']); if($settings['emergency_cid']['value'] != '') { $astman->database_put("DEVICE",$id."/emergency_cid",$settings['emergency_cid']['value']); } else { $astman->database_del("DEVICE",$id."/emergency_cid"); } $apparent_connecteduser = ($editmode && $settings['user']['value'] != "none") ? $astman->database_get("DEVICE",$id."/user") : $settings['user']['value']; if ($settings['user']['value'] != "none" && $apparent_connecteduser == $settings['user']['value']) { $existingdevices = $astman->database_get("AMPUSER",$settings['user']['value']."/device"); if (empty($existingdevices)) { $astman->database_put("AMPUSER",$settings['user']['value']."/device",$id); } else { $existingdevices_array = explode('&',$existingdevices); if (!in_array($id, $existingdevices_array)) { $existingdevices_array[]=$id; $existingdevices = implode('&',$existingdevices_array); $astman->database_put("AMPUSER",$settings['user']['value']."/device",$existingdevices); } } } } else { die_freepbx("Cannot connect to Asterisk Manager with ".$this->config->get('AMPMGRUSER')."/".$this->config->get('AMPMGRPASS')); } if ( $this->FreePBX->Modules->moduleHasMethod('Voicemail','mapMailBox') ) { $this->FreePBX->Voicemail->mapMailBox($settings['user']['value']); } // before calling device specifc funcitions, get rid of any bogus fields in the array // if (isset($settings['devinfo_secret_origional'])) { unset($settings['devinfo_secret_origional']); } unset($settings['devicetype']); unset($settings['user']); unset($settings['description']); unset($settings['emergency_cid']); unset($settings['changecdriver']); unset($settings['hint_override']); //take care of sip/iax/zap config $tech = strtolower($tech); if(isset($this->drivers[$tech])) { return $this->drivers[$tech]->addDevice($id, $settings); } $this->deviceCache = array(); return true; } /* create emergency Device * Allowed only sip and Pjsip */ public function emergencyAddDevice($id,$tech,$settings=array(),$editmode=false) { if ($tech == '' || trim($tech) == 'virtual') { return true; } if (trim($id) == '' || empty($settings)) { throw new \Exception(_("Device Extension was blank or there were no settings defined")); return false; } //ensure this id is not already in use $dev = $this->getEmergencyDevice($id); if(!empty($dev)) { throw new \Exception(_("This device id is already in use")); } //unless defined, $dial is TECH/id if ($settings['dial']['value'] == '') { $settings['dial']['value'] = strtoupper($tech)."/".$id; } $settings['user']['value'] = 'DummyUser'; $settings['emergency_cid']['value'] = trim($settings['emergency_cid']['value']); $settings['description']['value'] = trim($settings['calleridname']['value']); $settings['hint_override']['value'] = isset($settings['hint_override']['value'])?trim($settings['hint_override']['value']) : null; //insert into devices table $sql="INSERT INTO emergencydevices (id,tech,dial,devicetype,user,description,emergency_cid,hint_override) values (?,?,?,?,?,?,?,?)"; $sth = $this->database->prepare($sql); try { $sth->execute(array($id,$tech,$settings['dial']['value'],$settings['devicetype']['value'],$settings['user']['value'],$settings['description']['value'],$settings['emergency_cid']['value'],$settings['hint_override']['value'])); } catch(\Exception $e) { die_freepbx("Could Not Insert Device", $e->getMessage()); return false; } $astman = $this->FreePBX->astman; //add details to astdb if ($astman->connected()) { // if adding or editting a fixed device, user property should always be set if ($settings['devicetype']['value'] == 'fixed' || !$editmode) { $astman->database_put("EDEVICE",$id."/user",$settings['user']['value']); } // If changing from a fixed to an adhoc, the user property should be intialized // to the new default, not remain as the previous fixed user if ($editmode) { $previous_type = $astman->database_get("EDEVICE",$id."/type"); if ($previous_type == 'fixed' && $settings['devicetype']['value'] == 'adhoc') { $astman->database_put("EDEVICE",$id."/user",$settings['user']['value']); } } $astman->database_put("EDEVICE",$id."/dial",$settings['dial']['value']); $astman->database_put("EDEVICE",$id."/type",$settings['devicetype']['value']); $astman->database_put("EDEVICE",$id."/default_user",$settings['user']['value']); $astman->database_put("EDEVICE",$id."/location",$settings['description']['value']); if($settings['emergency_cid']['value'] != '') { $astman->database_put("EDEVICE",$id."/emergency_cid",$settings['emergency_cid']['value']); } else { $astman->database_del("EDEVICE",$id."/emergency_cid"); } } else { die_freepbx("Cannot connect to Asterisk Manager with ".$this->config->get('AMPMGRUSER')."/".$this->config->get('AMPMGRPASS')); } unset($settings['devinfo_secret_origional']); unset($settings['devicetype']); unset($settings['user']); unset($settings['description']); unset($settings['emergency_cid']); unset($settings['changecdriver']); unset($settings['hint_override']); //take care of sip/iax/zap config $tech = strtolower($tech); if($tech == 'sip' || $tech == 'pjsip') { $sql = 'INSERT INTO sip (id, keyword, data, flags) values (?,?,?,?)'; $sth = $this->database->prepare($sql); $settings = is_array($settings)?$settings:array(); foreach($settings as $key => $setting) { if($key == 'calleridname') { continue; // addtional param we dont want this in sip table But need it in astDB } $sth->execute(array($id,$key,$setting['value'],$setting['flag'])); } } $this->deviceCache = array(); return true; } /** * List All DAHDi Channels * @return array Array of DAHDi Channels */ public function listDahdiChannels(){ $sql = "SELECT * FROM dahdichandids ORDER BY channel"; $stmt = $this->database->prepare($sql); $stmt->execute(); $results = $stmt->fetchAll(\PDO::FETCH_ASSOC); return $results; } /** * Delete trunk from inbound route by id. * @param int $trunk_id id of the trunk * @return bool Return from db call */ public function delRouteTrunkByID($trunk_id){ $sql ='DELETE FROM outbound_route_trunks WHERE trunk_id = :trunk_id'; $stmt = $this->database->prepare($sql); return $stmt->execute(array(':trunk_id' => $trunk_id)); } /** * Delete Trunk * @param string $trunknum Trunk ID * @param srting $tech Trunk tech * @return mixed Return (bool) true on success or array on failure. */ public function deleteTrunk($trunknum, $tech = null, $edit = false){ if ($tech === null) { // in EditTrunk, we get this info anyways $tech = $this->getTrunkTech($trunknum); } // conditionally, delete from iax or sip switch (strtolower($tech)) { case "iax2": $tech = "iax"; // fall through case "iax": case "sip": $sql = "DELETE FROM $tech WHERE id IN (:trunknum1, :trunknum2, :trunknum3)"; $stmt = $this->database->prepare($sql); $ret1 = $stmt->execute(array(':trunknum1'=>'tr-peer-'.$trunknum,':trunknum2' => 'tr-user-'.$trunknum, ':trunknum3' => 'tr-reg-'.$trunknum)); break; case "pjsip": $sql = "DELETE FROM pjsip WHERE id = :trunknum"; $stmt = $this->database->prepare($sql); $ret1 = $stmt->execute(array(':trunknum'=>$trunknum)); break; } $sql = "DELETE FROM trunks WHERE trunkid = :trunknum"; $stmt = $this->database->prepare($sql); $ret = $stmt->execute(array(':trunknum'=>$trunknum)); if ($this->astman) { $this->astman->database_del("TRUNK", $trunknum . '/dialopts'); } //Handle hooks $this->freepbx->Hooks->processHooks($trunknum, $tech); //Remove trunk from inbound routes if(!$edit){ $this->delRouteTrunkByID($trunknum); } if($ret & $ret1){ return true; }else{ return array('status' => false, 'techdelete' => $ret1, 'trunksdel' => $ret); } } /** * List All Trunks * @return array Array of Trunks */ public function listTrunks() { $sql = 'SELECT * from `trunks` ORDER BY `trunkid`'; $stmt = $this->database->prepare($sql); $ret = $stmt->execute(); $result = $stmt->fetchAll(\PDO::FETCH_ASSOC); $trunk_list = array(); foreach ($result as $trunk) { if ($trunk['name'] == '') { $tech = strtoupper($trunk['tech']); switch ($tech) { case 'CUSTOM': $trunk['name'] = 'AMP:'.$trunk['channelid']; break; default: $trunk['name'] = $tech.'/'.$trunk['channelid']; break; } } $trunk['dialopts'] = $this->freepbx->astman->database_get("TRUNK",$trunk['trunkid'] . "/dialopts"); $trunk_list[$trunk['trunkid']] = $trunk; } return $trunk_list; } public function trunkHasRegistrations($type = ''){ $types = array( 'zap', 'dahdi', 'custom', '' ); return !in_array($type, $types); } public function deleteTrunkDialRulesByID($trunknum) { $sql = "DELETE FROM `trunk_dialpatterns` WHERE `trunkid` = ?"; $sth = $this->database->prepare($sql); $sth->execute(array($trunknum)); } public function getTrunkRoutesByID($trunknum) { $sql = 'SELECT a.seq, b.name FROM outbound_route_trunks a JOIN outbound_routes b ON a.route_id = b.route_id WHERE trunk_id = ?'; $sth = $this->database->prepare($sql); $sth->execute(array($trunknum)); $results = $sth->fetchAll(\PDO::FETCH_ASSOC); $routes = array(); foreach ($results as $entry) { $routes[$entry['name']] = $entry['seq']; } return $routes; } public function updateRouteTrunks($route_id, &$trunks, $delete = false) { $insert_trunk = array(); $seq = 0; foreach ($trunks as $trunk) { $insert_trunk[] = array( $route_id,$trunk, $seq); $seq++; } if ($delete) { $sth = $this->database->prepare("DELETE FROM `outbound_route_trunks` WHERE `route_id`= ?"); $sth->execute(array($route_id)); } $stmt = $this->database->prepare('INSERT INTO `outbound_route_trunks` (`route_id`, `trunk_id`, `seq`) VALUES (?,?,?)'); $ret = array(); foreach($insert_trunk as $t){ $ret[] = $stmt->execute($t); } return $ret; } public function updateTrunkDialRules($trunknum, &$patterns, $delete = false) { $filter_prepend = '/[^0-9+*#wW]/'; $filter_prefix = '/[^0-9*#+xnzXNZ\-\[\]]/'; $filter_match = '/[^0-9.*#+xnzXNZ\-\[\]]/'; $insert_pattern = array(); $seq = 0; foreach ($patterns as $pattern) { $match_pattern_prefix = preg_replace($filter_prefix,'',strtoupper(trim($pattern['match_pattern_prefix']))); $match_pattern_pass = preg_replace($filter_match,'',strtoupper(trim($pattern['match_pattern_pass']))); $prepend_digits = str_replace('W', 'w', preg_replace($filter_prepend,'',strtoupper(trim($pattern['prepend_digits'])))); if ($match_pattern_prefix.$match_pattern_pass == '') { continue; } // if duplicate prepend, get rid of subsequent since they will never be checked $hash_index = md5($match_pattern_prefix.$match_pattern_pass); if (!isset($insert_pattern[$hash_index])) { $insert_pattern[$hash_index] = array($match_pattern_prefix, $match_pattern_pass, $prepend_digits, $seq); $seq++; } } if ($delete) { $sth = $this->database->prepare("DELETE FROM `trunk_dialpatterns` WHERE `trunkid`= ?"); $sth->execute(array($trunknum)); } $sth = $this->database->prepare('INSERT INTO `trunk_dialpatterns` (`trunkid`, `match_pattern_prefix`, `match_pattern_pass`, `prepend_digits`, `seq`) VALUES (?,?,?,?,?)'); foreach($insert_pattern as $pattern) { array_unshift($pattern, $trunknum); $sth->execute($pattern); } } public function getRouteByID($route_id) { $sql = 'SELECT a.*, b.seq FROM `outbound_routes` a JOIN `outbound_route_sequence` b ON a.route_id = b.route_id WHERE a.route_id=?'; $sth = $this->database->prepare($sql); $sth->execute(array($route_id)); return $sth->fetch(\PDO::FETCH_ASSOC); } public function getAllTrunkDialRules() { $sql = "SELECT * FROM `trunk_dialpatterns` ORDER BY `trunkid`, `seq`"; $sth = $this->database->prepare($sql); $sth->execute(); return $sth->fetchAll(\PDO::FETCH_ASSOC); } public function getRouteTrunksByID($route_id) { $sql = "SELECT `trunk_id` FROM `outbound_route_trunks` WHERE `route_id` = ? ORDER BY `seq`"; $sth = $this->database->prepare($sql); $sth->execute(array($route_id)); $res = $sth->fetchAll(\PDO::FETCH_COLUMN); return $res; } public function getRoutePatternsByID($route_id) { $sql = "SELECT * FROM `outbound_route_patterns` WHERE `route_id` = ? ORDER BY `match_pattern_prefix`, `match_pattern_pass`"; $sth = $this->database->prepare($sql); $sth->execute(array($route_id)); return $sth->fetchAll(\PDO::FETCH_ASSOC); } public function getRouteEmailByID($route_id) { $sql = "SELECT * FROM `outbound_route_email` WHERE `route_id` = ?"; $sth = $this->database->prepare($sql); $sth->execute(array($route_id)); $res = $sth->fetch(\PDO::FETCH_ASSOC); return $res; } public function getTrunkDialRulesByID($trunkid) { $sql = "SELECT * FROM `trunk_dialpatterns` WHERE `trunkid` = ? ORDER BY `seq`"; $sth = $this->database->prepare($sql); $sth->execute(array($trunkid)); return $sth->fetchAll(\PDO::FETCH_ASSOC); } public function getTrunkTrunkNameByID() { $name = "SELECT `name` FROM `trunks` WHERE `trunkid` = ?"; $sth = $this->database->prepare($name); $sth->execute(array($trunknum)); $results = $sth->fetch(\PDO::FETCH_ASSOC); return isset($results['name']) ? $results['name'] : false; } public function getTrunkPeerDetailsByID($trunkid) { $tech = $this->getTrunkTech($trunkid); if (!$this->trunkHasRegistrations($tech)){ return ''; } $sql = "SELECT keyword,data FROM $tech WHERE `id` = ? ORDER BY flags, keyword DESC"; $sth = $this->database->prepare($sql); $sth->execute(array('tr-peer-'.$trunkid)); $results = $sth->fetchAll(\PDO::FETCH_ASSOC); foreach ($results as $result) { if ($result['keyword'] != 'account') { if (isset($confdetail)) { $confdetail .= $result['keyword'] .'='. $result['data'] . "\n"; } else { $confdetail = $result['keyword'] .'='. $result['data'] . "\n"; } } } return isset($confdetail)?$confdetail:null; } public function getTrunkUserContext($trunkid) { $sql = "SELECT `usercontext` FROM `trunks` WHERE `trunkid` = ?"; $sth = $this->database->prepare($sql); $sth->execute(array($trunkid)); $results = $sth->fetch(\PDO::FETCH_ASSOC); return ((isset($results['usercontext'])) ? $results['usercontext'] : ''); } public function getTrunkUserConfigByID($trunkid) { $tech = $this->getTrunkTech($trunkid); if (!$this->trunkHasRegistrations($tech)){ return ''; } $sql = "SELECT keyword,data FROM $tech WHERE `id` = ? ORDER BY flags, keyword DESC"; $sth = $this->database->prepare($sql); $sth->execute(array('tr-user-'.$trunkid)); $results = $sth->fetchAll(\PDO::FETCH_ASSOC); foreach ($results as $result) { if ($result['keyword'] != 'account') { if (isset($confdetail)) { $confdetail .= $result['keyword'] .'='. $result['data'] . "\n"; } else { $confdetail = $result['keyword'] .'='. $result['data'] . "\n"; } } } return isset($confdetail)?$confdetail:null; } public function getTrunkRegisterStringByID($trunkid) { $tech = $this->getTrunkTech($trunkid); if (!$this->trunkHasRegistrations($tech)){ return ''; } // TODO: These should be deferred to their respective driver if('pjsip' == $tech){ $sql = "SELECT `data` FROM pjsip WHERE `id` = :trunkid and `keyword` = 'registration'"; $sth = $this->database->prepare($sql); $sth->execute(array(':trunkid' => $trunkid)); $result = $sth->fetchColumn(); return in_array($result,array('send','receive'))?$result:null; } $sql = "SELECT `data` FROM $tech WHERE `id` = ? "; $sth = $this->database->prepare($sql); $sth->execute(array('tr-reg-'.$trunkid)); $result = $sth->fetch(\PDO::FETCH_ASSOC); return isset($result['data'])?$result['data']:null; } public function getTrunkByID($trunkid) { $sql = 'SELECT * from `trunks` WHERE `trunkid` = ?'; $stmt = $this->database->prepare($sql); $ret = $stmt->execute(array($trunkid)); $trunk = $stmt->fetch(\PDO::FETCH_ASSOC); if(empty($trunk)) { return false; } if ($trunk['name'] == '') { $tech = strtoupper($trunk['tech']); switch ($tech) { case 'CUSTOM': $trunk['name'] = 'AMP:'.$trunk['channelid']; break; default: $trunk['name'] = $tech.'/'.$trunk['channelid']; break; } } $trunk['dialopts'] = $this->freepbx->astman->database_get("TRUNK",$trunkid . "/dialopts"); return $trunk; } public function getTrunkByChannelID($trunkid) { $sql = 'SELECT * from `trunks` WHERE `channelid` = ?'; $stmt = $this->database->prepare($sql); $ret = $stmt->execute(array($trunkid)); $result = $stmt->fetch(\PDO::FETCH_ASSOC); return $result; } public function addRoute($name, $outcid, $outcid_mode, $password, $emergency_route, $intracompany_route, $mohclass, $time_group_id, $patterns, $trunks, $seq = 'new', $dest = '') { $sql = "INSERT INTO `outbound_routes` (`name`, `outcid`, `outcid_mode`, `password`, `emergency_route`, `intracompany_route`, `mohclass`, `time_group_id`, `dest`) VALUES (:name, :outcid, :outcid_mode, :password, :emergency_route, :intracompany_route, :mohclass, :time_group_id, :dest)"; $sth = \FreePBX::Database()->prepare($sql); $sth->execute(array( ":name" => $name, ":outcid" => $outcid, ":outcid_mode" => trim($outcid) == '' ? '' : $outcid_mode, ":password" => $password, ":emergency_route" => strtoupper($emergency_route), ":intracompany_route" => strtoupper($intracompany_route), ":mohclass" => $mohclass, ":time_group_id" => $time_group_id == '' ? NULL : $time_group_id, ":dest" => $dest )); $route_id = \FreePBX::Database()->lastInsertId(); $this->updatePatterns($route_id, $patterns); $this->updateRouteTrunks($route_id, $trunks); $this->setOutboundRouteOrder($route_id, 'new'); // this is lame, should change to do as a single call but for now this expects route_id to be in array for anything but new if ($seq != 'new') { $this->setOutboundRouteOrder($route_id, $seq); } return ($route_id); } public function updatePatterns($route_id, &$patterns, $delete = false) { $filter = '/[^0-9\*\#\+\-\.\[\]xXnNzZ]/'; $insert_pattern = array(); foreach ($patterns as $pattern) { $match_pattern_prefix = preg_replace($filter,'',strtoupper(trim($pattern['match_pattern_prefix']))); $match_pattern_pass = preg_replace($filter,'',strtoupper(trim($pattern['match_pattern_pass']))); $match_cid = preg_replace($filter,'',strtoupper(trim($pattern['match_cid']))); $prepend_digits = preg_replace($filter,'',strtoupper(trim($pattern['prepend_digits']))); if ($match_pattern_prefix.$match_pattern_pass.$match_cid == '') { continue; } $hash_index = md5($match_pattern_prefix.$match_pattern_pass.$match_cid); if (!isset($insert_pattern[$hash_index])) { $insert_pattern[$hash_index] = array($match_pattern_prefix, $match_pattern_pass, $match_cid, $prepend_digits); } } if ($delete) { sql('DELETE FROM `outbound_route_patterns` WHERE `route_id`='.q($route_id)); } $stmt = \FreePBX::Database()->prepare('INSERT INTO `outbound_route_patterns` (`route_id`, `match_pattern_prefix`, `match_pattern_pass`, `match_cid`, `prepend_digits`) VALUES ('.$route_id.',?,?,?,?)'); foreach ($insert_pattern as $pattern) { $stmt->execute($pattern); } } public function setOutboundRouteOrder($route_id, $seq) { $sql = "SELECT `route_id` FROM `outbound_route_sequence` ORDER BY `seq`"; $sequence = $this->Database->query($sql)->fetchAll(\PDO::FETCH_COLUMN, 0); if ($seq != 'new') { $key = array_search($route_id,$sequence); if ($key === false) { return(false); } } switch ("$seq") { case 'up': if (!isset($sequence[$key-1])) break; $previous = $sequence[$key-1]; $sequence[$key-1] = $route_id; $sequence[$key] = $previous; break; case 'down': if (!isset($sequence[$key+1])) break; $previous = $sequence[$key+1]; $sequence[$key+1] = $route_id; $sequence[$key] = $previous; break; case 'top': unset($sequence[$key]); array_unshift($sequence,$route_id); break; case 'bottom': unset($sequence[$key]); case 'new': // fallthrough, no break $sequence[]=$route_id; break; case '0': unset($sequence[$key]); array_unshift($sequence,$route_id); break; default: if (!ctype_digit($seq)) { return false; } if ($seq > count($sequence)-1) { unset($sequence[$key]); $sequence[] = $route_id; break; } if ($sequence[$seq] == $route_id) { break; } $sequence[$key] = "bookmark"; $remainder = array_slice($sequence,$seq); array_unshift($remainder,$route_id); $sequence = array_merge(array_slice($sequence,0,$seq), $remainder); unset($sequence[array_search("bookmark",$sequence)]); break; } $seq = 0; $final_seq = false; sql('DELETE FROM `outbound_route_sequence` WHERE 1'); $stmt = \FreePBX::Database()->prepare('INSERT INTO `outbound_route_sequence` (`route_id`, `seq`) VALUES (?,?)'); foreach($sequence as $rid) { $stmt->execute(array($rid, $seq)); if ($rid === $route_id) { $final_seq = $seq; } $seq++; } return $final_seq; } /** * Get all the users * @param {bool} $get_all=false Whether to get all of check in the range */ function listUsers($get_all=false) { if (empty($this->listUsersCache)) { $sql = 'SELECT extension,name,voicemail FROM users ORDER BY extension'; $sth = $this->database->prepare($sql); $sth->execute(); $results = $sth->fetchAll(\PDO::FETCH_BOTH); $this->listUsersCache = $results; } else { $results = $this->listUsersCache; } //only allow extensions that are within administrator's allowed range foreach($results as $result){ if ($get_all || \checkRange($result[0])){ $extens[] = array($result[0],$result[1],$result[2]); } } if (isset($extens)) { sort($extens); return $extens; } else { return array(); } } /** * Delete a Device * @param {int} The Device ID * @param {bool} $editmode=false If in edit mode (this is so it doesnt destroy the AsteriskDB) */ public function delDevice($account,$editmode=false) { $astman = $this->FreePBX->astman; //get all info about device $devinfo = $this->getDevice($account); if (empty($devinfo)) { //FREEPBX-15389 calling processHooks for Virtual extension $this->freepbx->Hooks->processHooks($account, $editmode); return true; } //delete details to astdb if ($astman->connected()) { // If a user was selected, remove this device from the user $deviceuser = $astman->database_get("DEVICE",$account."/user"); if (isset($deviceuser) && $deviceuser != "none") { // Remove the device record from the user's device list $userdevices = $astman->database_get("AMPUSER",$deviceuser."/device"); // We need to remove just this user and leave the rest alone $userdevicesarr = explode("&", $userdevices); $userdevicesarr_hash = array_flip($userdevicesarr); unset($userdevicesarr_hash[$account]); $userdevicesarr = array_flip($userdevicesarr_hash); $userdevices = implode("&", $userdevicesarr); if (empty($userdevices)) { $astman->database_del("AMPUSER",$deviceuser."/device"); } else { $astman->database_put("AMPUSER",$deviceuser."/device",$userdevices); } } if (!$editmode) { $astman->database_del("DEVICE",$account."/dial"); $astman->database_del("DEVICE",$account."/type"); $astman->database_del("DEVICE",$account."/user"); $astman->database_del("DEVICE",$account."/default_user"); $astman->database_del("DEVICE",$account."/emergency_cid"); } //delete from devices table $sql = "DELETE FROM devices WHERE id = ?"; $sth = $this->database->prepare($sql); try { $sth->execute(array($account)); } catch(\Exception $e) { } //voicemail symlink $spooldir = $this->config->get('ASTSPOOLDIR'); $account = preg_replace("/\D/","",$account); if(trim($account) !== "" && file_exists($spooldir."/voicemail/device/".$account)) { exec("rm -f ".escapeshellarg($spooldir."/voicemail/device/".$account)); } } else { die_freepbx("Cannot connect to Asterisk Manager with ".$this->config->get("AMPMGRUSER")."/".$this->config->get("AMPMGRPASS")); } $tech = $devinfo['tech']; //TODO should only delete the record for this device buuuutttt...... if(isset($this->drivers[$tech])) { $this->drivers[$tech]->delDevice($account); } $this->freepbx->Hooks->processHooks($account, $editmode); $this->getDeviceHeadersCache = array(); $this->deviceCache = array(); $this->getDeviceCache = array(); return true; } /** * Delete a emergencyDevice * @param {int} The Device ID * @param {bool} $editmode=false If in edit mode (this is so it doesnt destroy the AsteriskDB) */ public function delEmergencyDevice($account,$editmode=false) { $astman = $this->FreePBX->astman; //get all info about device $devinfo = $this->getEmergencyDevice($account); if(!isset($devinfo['id'])) { return; } //delete details to astdb if ($astman->connected()) { if (!$editmode) { $astman->database_del("EDEVICE",$account."/dial"); $astman->database_del("EDEVICE",$account."/type"); $astman->database_del("EDEVICE",$account."/user"); $astman->database_del("EDEVICE",$account."/default_user"); $astman->database_del("EDEVICE",$account."/location"); $astman->database_del("EDEVICE",$account."/emergency_cid"); } //delete from devices table $sql = "DELETE FROM emergencydevices WHERE id = ?"; $sth = $this->database->prepare($sql); try { $sth->execute(array($account)); } catch(\Exception $e) { } } else { die_freepbx("Cannot connect to Asterisk Manager with ".$this->config->get("AMPMGRUSER")."/".$this->config->get("AMPMGRPASS")); } $tech = $devinfo['tech']; if(isset($this->drivers[$tech])&& isset($devinfo['id'])) { $this->drivers[$tech]->delDevice($account); } needreload(); return true; } /** * Get all devices by type * @param string $type The device type */ public function getAllDevicesByType($type="") { if(empty($type)) { if (empty($this->deviceCache['full'])) { $sql = "SELECT * FROM devices ORDER BY id"; $sth = $this->database->prepare($sql); try { $sth->execute(); $results = $sth->fetchAll(\PDO::FETCH_ASSOC); } catch(\Exception $e) { return array(); } $this->deviceCache['full'] = $results; } else { $results = $this->deviceCache['full']; } } else { if (empty($this->deviceCache[$type])) { $sql = "SELECT * FROM devices WHERE tech = ? ORDER BY id"; $sth = $this->database->prepare($sql); try { $sth->execute(array($type)); $results = $sth->fetchAll(\PDO::FETCH_ASSOC); } catch(\Exception $e) { return array(); } $this->deviceCache[$type] = $results; } else { $results = $this->deviceCache[$type]; } } return $results; } /** * Get All Routes */ public function getAllRoutes(){ $sql = "SELECT a.*, b.seq FROM `outbound_routes` a JOIN `outbound_route_sequence` b ON a.route_id = b.route_id ORDER BY `seq`"; $stmt = $this->database->prepare($sql); $stmt->execute(); $routes = $stmt->fetchAll(\PDO::FETCH_ASSOC); return $routes; } /** * Get all Users */ public function getAllUsers() { if (empty($this->allUsersCache)) { $sql = 'SELECT extension,name,voicemail FROM users ORDER BY extension'; $sth = $this->database->prepare($sql); try { $sth->execute(); $results = $sth->fetchAll(\PDO::FETCH_ASSOC); $final = array(); foreach($results as $res) { $ext = $res['extension']; $ret = checkRange($ext); if($ret){ $final[$ext] = $res; } } $this->allUsersCache = $final; } catch(\Exception $e) { return array(); } } else { $final = $this->allUsersCache; } return $final; } /** * Get all Users by Device Type * @param string $type A specific device type to get */ public function getAllUsersByDeviceType($type="") { if(empty($type) || $type == "virtual") { $sql = "SELECT * FROM users LEFT JOIN devices ON users.extension = devices.id ORDER BY users.extension"; $sth = $this->database->prepare($sql); try { $sth->execute(); $results = $sth->fetchAll(\PDO::FETCH_ASSOC); } catch(\Exception $e) { return array(); } } else { $sql = "SELECT * FROM users LEFT JOIN devices ON users.extension = devices.id WHERE devices.tech = ? ORDER BY users.extension"; $sth = $this->database->prepare($sql); try { $sth->execute(array($type)); $results = $sth->fetchAll(\PDO::FETCH_ASSOC); } catch(\Exception $e) { return array(); } } $astman = $this->FreePBX->astman; $dbfamily = $astman->connected() ? $astman->database_show("AMPUSER") : array(); //Virtual Extensions are strange $final = array(); foreach($results as $result) { if(!checkRange($result['extension'])){ continue; } if(empty($result['tech'])) { $result['tech'] = 'virtual'; } elseif(!empty($result['tech']) && $type == "virtual") { continue; } $result['recording_in_external'] = isset($dbfamily['/AMPUSER/'.$result['extension'].'/recording/in/external']) ? $dbfamily['/AMPUSER/'.$result['extension'].'/recording/in/external'] : ""; $result['recording_out_external'] = isset($dbfamily['/AMPUSER/'.$result['extension'].'/recording/out/external']) ? $dbfamily['/AMPUSER/'.$result['extension'].'/recording/out/external'] : ""; $result['recording_in_internal'] = isset($dbfamily['/AMPUSER/'.$result['extension'].'/recording/in/internal']) ? $dbfamily['/AMPUSER/'.$result['extension'].'/recording/in/internal'] : ""; $result['recording_out_internal'] = isset($dbfamily['/AMPUSER/'.$result['extension'].'/recording/out/internal']) ? $dbfamily['/AMPUSER/'.$result['extension'].'/recording/out/internal'] : ""; $result['recording_ondemand'] = isset($dbfamily['/AMPUSER/'.$result['extension'].'/recording/ondemand']) ? $dbfamily['/AMPUSER/'.$result['extension'].'/recording/ondemand'] : ""; $result['recording_priority'] = isset($dbfamily['/AMPUSER/'.$result['extension'].'/recording/priority']) ? (int) $dbfamily['/AMPUSER/'.$result['extension'].'/recording/priority'] : "10"; $result['answermode'] = $this->FreePBX->Modules->checkStatus("paging") && isset($dbfamily['/AMPUSER/'.$result['extension'].'/answermode']) ? $dbfamily['/AMPUSER/'.$result['extension'].'/answermode'] : ""; $result['intercom'] = $this->FreePBX->Modules->checkStatus("paging") && isset($dbfamily['/AMPUSER/'.$result['extension'].'/intercom']) ? $dbfamily['/AMPUSER/'.$result['extension'].'/intercom'] : ""; $final[] = $result; } return $final; } /** * Check if a SIP Name is in use * For SIP Alias/Direct SIP dialing * @param string $sipname The SIP Name to check * @param int $extension The Extension to check against */ public function checkSipnameInUse($sipname, $extension) { if (!isset($sipname) || trim($sipname)=='') { return true; } $sql = "SELECT sipname FROM users WHERE sipname = ? AND extension != ?"; $sth = $this->database->prepare($sql); $sth->execute(array($sipname, $extension)); try { $results = $sth->fetch(\PDO::FETCH_ASSOC); } catch(\Exception $e) { die_freepbx($e->getMessage().$sql); } if (isset($results['sipname']) && trim($results['sipname']) == $sipname) { return false; } else { return true; } } /** * Get Inbound Routes (DIDs) * @param string $order Whether to order results by extension or description */ public function getAllDIDs($order='extension') { switch ($order) { case 'description': $sql = "SELECT * FROM incoming ORDER BY description,extension,cidnum"; break; case 'extension': default: $sql = "SELECT * FROM incoming ORDER BY extension,cidnum"; } $sth = $this->database->prepare($sql); $sth->execute(); try { $results = $sth->fetchAll(\PDO::FETCH_ASSOC); } catch(\Exception $e) { return array(); } return $results; } /** * Add Inbound Route * @param array $settings Array of Inbound Route Settings */ public function addDID($settings) { //Strip <> just to be on the safe side otherwise this is not deleteable from the GUI $invalidDIDChars = array('<', '>'); $settings['extension'] = trim(str_replace($invalidDIDChars, "", $settings['extension'])); $settings['cidnum'] = trim(str_replace($invalidDIDChars, "", $settings['cidnum'])); $settings['rvolume'] = isset($settings['rvolume']) ? $settings['rvolume'] : ""; // XXX: Kludge for empty value if ($settings['delay_answer'] == '') { $settings['delay_answer'] = '0'; } // Check to make sure the did is not being used elsewhere // $existing = $this->getDID($settings['extension'], $settings['cidnum']); if (empty($existing)) { $sql="INSERT INTO incoming (rvolume, cidnum, extension, destination, privacyman, pmmaxretries, pmminlength, alertinfo, ringing, reversal, mohclass, description, grppre, delay_answer, pricid) VALUES (:rvolume, :cidnum, :extension, :destination, :privacyman, :pmmaxretries, :pmminlength, :alertinfo, :ringing, :reversal, :mohclass, :description, :grppre, :delay_answer, :pricid)"; $sth = $this->database->prepare($sql); $sth->execute(array(':rvolume' => $settings['rvolume'], ':cidnum' => $settings['cidnum'], ':extension' => $settings['extension'], ':destination' => $settings['destination'], ':privacyman' => $settings['privacyman'], ':pmmaxretries' => $settings['pmmaxretries'], ':pmminlength' => $settings['pmminlength'], ':alertinfo' => $settings['alertinfo'], ':ringing' => $settings['ringing'], ':reversal' => $settings['reversal'], ':mohclass' => $settings['mohclass'], ':description' => $settings['description'], ':grppre' => $settings['grppre'], ':delay_answer' => $settings['delay_answer'], ':pricid' => $settings['pricid'])); $this->freepbx->Hooks->processHooks($settings); return true; } else { return false; } } /** * Delete a DID * @param string $extension The DID Extension * @param string $cidnum The DID cidnum */ public function delDID($extension,$cidnum) { $sql = "DELETE FROM incoming WHERE cidnum = ? AND extension = ?"; $sth = $this->database->prepare($sql); $sth->execute(array($cidnum, $extension)); $this->freepbx->Hooks->processHooks($extension, $cidnum); } /** * Get Inbound Route (DID) based on extension (DID) or CID Number * @param int $extension Inbound Route DID * @param int $cidnum The CID Number */ public function getDID($extension="",$cidnum="") { $sql = "SELECT * FROM incoming WHERE cidnum = ? AND extension = ?"; $sth = $this->database->prepare($sql); $sth->execute(array($cidnum, $extension)); try { $results = $sth->fetch(\PDO::FETCH_ASSOC); } catch(\Exception $e) { return array(); } return $results; } /** * Edit DID * @param string $oldExtension The old extension * @param string $oldCidnum The old CID Num * @param array $incoming Array of new data to use */ public function editDID($oldExtension,$oldCidnum, $incoming) { $extension = trim($incoming['extension']); $cidnum = trim($incoming['cidnum']); // if did or cid changed, then check to make sure that this pair is not already being used. // if (($extension != $oldExtension) || ($cidnum != $oldCidnum)) { $existing = $this->getDID($extension,$cidnum); } if (empty($existing)) { $this->delDID($oldExtension,$oldCidnum); $this->addDID($incoming); return true; } else { return false; } } /** * Create a new did with values passed into $did_vars and defaults used otherwise * @param array $did_vars Array of new values */ public function createUpdateDID($did_vars) { $did_create['extension'] = isset($did_vars['extension']) ? $did_vars['extension'] : ''; $did_create['cidnum'] = isset($did_vars['cidnum']) ? $did_vars['cidnum'] : ''; $coredid = $this->getDID($did_create['extension'], $did_create['cidnum']); if (!empty($coredid) && count($coredid)) { return $this->editDIDProperties($did_vars); //already exists so just edit properties } else { $did_create['privacyman'] = isset($did_vars['privacyman']) ? $did_vars['privacyman'] : ''; $did_create['pmmaxretries'] = isset($did_vars['pmmaxretries']) ? $did_vars['pmmaxretries'] : ''; $did_create['pmminlength'] = isset($did_vars['pmminlength']) ? $did_vars['pmminlength'] : ''; $did_create['alertinfo'] = isset($did_vars['alertinfo']) ? $did_vars['alertinfo'] : ''; $did_create['ringing'] = isset($did_vars['ringing']) ? $did_vars['ringing'] : ''; $did_create['reversal'] = isset($did_vars['reversal']) ? $did_vars['reversal'] : ''; $did_create['mohclass'] = isset($did_vars['mohclass']) ? $did_vars['mohclass'] : 'default'; $did_create['description'] = isset($did_vars['description']) ? $did_vars['description'] : ''; $did_create['grppre'] = isset($did_vars['grppre']) ? $did_vars['grppre'] : ''; $did_create['delay_answer']= isset($did_vars['delay_answer'])? $did_vars['delay_answer']: '0'; $did_create['pricid'] = isset($did_vars['pricid']) ? $did_vars['pricid'] : ''; $did_create['destination'] = isset($did_vars['destination']) ? $did_vars['destination'] : ''; return $this->addDID($did_create); } } /** * Edits the poperties of a did * but not the did or cid nums since those could of course be in conflict * @param array $did_vars Array of variables * @return [type] [description] */ public function editDIDProperties($did_vars) { if (!is_array($did_vars)) { return false; } $extension = isset($did_vars['extension']) ? $did_vars['extension'] : ''; $cidnum = isset($did_vars['cidnum']) ? $did_vars['cidnum'] : ''; $sql = ""; foreach ($did_vars as $key => $value) { switch ($key) { case 'privacyman': case 'pmmaxretries': case 'pmminlength': case 'alertinfo': case 'ringing': case 'reversal': case 'mohclass': case 'description': case 'grppre': case 'delay_answer': case 'pricid': case 'destination': $sql_value = $this->database->escapeSimple($value); $sql .= " `$key` = $sql_value,"; break; default: } } if ($sql == '') { return false; } $sql = substr($sql,0,(strlen($sql)-1)); //strip off tailing ',' $sql_update = "UPDATE `incoming` SET"."$sql WHERE `extension` = ? AND `cidnum` = ?"; $sth = $this->database->prepare($sql_update); return $sth->execute(array($extension, $cidnum)); } /** * Add user (Part of Users/Devices) * @param int $extension The exten numer * @param array $settings Array of settings to pass in * @param bool $editmode If in edit mode (So that the AsteriskDB is not destroyed) */ public function addUser($extension, $settings, $editmode=false) { if (trim($extension) == '' ) { throw new \Exception(_("You must put in an extension (or user) number")); } //ensure this id is not already in use $extens = $this->listUsers(); if(is_array($extens)) { foreach($extens as $exten) { if ($exten[0]===$extension) { throw new \Exception(sprintf(_("This user/extension %s is already in use"),$extension)); } } } $settings['newdid_name'] = isset($settings['newdid_name']) ? $settings['newdid_name'] : ''; $settings['newdid'] = isset($settings['newdid']) ? preg_replace("/[^0-9._XxNnZz\[\]\-\+]/" ,"", trim($settings['newdid'])) : ''; $settings['newdidcid'] = isset($settings['newdidcid']) ? trim($settings['newdidcid']) : ''; if (!preg_match('/^priv|^block|^unknown|^restrict|^unavail|^anonym|^withheld/',strtolower($settings['newdidcid']))) { $settings['newdidcid'] = preg_replace("/[^0-9._XxNnZz\[\]\-\+]/" ,"", $settings['newdidcid']); } if ($settings['newdid'] != '' || $settings['newdidcid'] != '') { $existing = $this->getDID($settings['newdid'], $settings['newdidcid']); if (!empty($existing)) { throw new \Exception(sprintf(_("A route with this DID/CID: %s/%s already exists"),$existing['extension'],$existing['cidnum'])); } } $settings['sipname'] = isset($settings['sipname']) ? preg_replace("/\s/" ,"", trim($settings['sipname'])) : ''; if (!$this->checkSipnameInUse($settings['sipname'], $extension)) { throw new \Exception(_("This sipname: {$sipname} is already in use")); } // strip the ugly return of the gui radio funciton which comes back as "recording_out_internal=always" for example // TODO this should be done with a hook if (isset($settings['recording_in_external'])) { $rec_tmp = explode('=',$settings['recording_in_external'],2); $settings['recording_in_external'] = count($rec_tmp) == 2 ? $rec_tmp[1] : $rec_tmp[0]; } else { $settings['recording_in_external'] = 'dontcare'; } if (isset($settings['recording_out_external'])) { $rec_tmp = explode('=',$settings['recording_out_external'],2); $settings['recording_out_external'] = count($rec_tmp) == 2 ? $rec_tmp[1] : $rec_tmp[0]; } else { $settings['recording_out_external'] = 'dontcare'; } if (isset($settings['recording_in_internal'])) { $rec_tmp = explode('=',$settings['recording_in_internal'],2); $settings['recording_in_internal'] = count($rec_tmp) == 2 ? $rec_tmp[1] : $rec_tmp[0]; } else { $settings['recording_in_internal'] = 'dontcare'; } if (isset($settings['recording_out_internal'])) { $rec_tmp = explode('=',$settings['recording_out_internal'],2); $settings['recording_out_internal'] = count($rec_tmp) == 2 ? $rec_tmp[1] : $rec_tmp[0]; } else { $settings['recording_out_internal'] = 'dontcare'; } if (isset($settings['recording_ondemand'])) { $rec_tmp = explode('=',$settings['recording_ondemand'],2); $settings['recording_ondemand'] = count($rec_tmp) == 2 ? $rec_tmp[1] : $rec_tmp[0]; } else { $settings['recording_ondemand'] = 'disabled'; } //if voicemail is enabled, set the box@context to use //TODO use a hook here if ( $this->FreePBX->Modules->moduleHasMethod('Voicemail','getMailbox') ) { $vmbox = $this->FreePBX->Voicemail->getMailbox($extension); if ( $vmbox == null ) { $settings['voicemail'] = "novm"; } else { $settings['voicemail'] = $vmbox['vmcontext']; } } $sql = "INSERT INTO users (extension,password,name,voicemail,ringtimer,noanswer,recording,outboundcid,sipname,noanswer_cid,busy_cid,chanunavail_cid,noanswer_dest,busy_dest,chanunavail_dest) " . "VALUES (:extension, :password, :name, :voicemail, :ringtimer, :noanswer, :recording, :outboundcid, :sipname, :noanswer_cid, :busy_cid, :chanunavail_cid, :noanswer_dest, :busy_dest, :chanunavail_dest)"; $sth = $this->database->prepare($sql); try { $sth->execute(array( "extension" => $extension, "password" => isset($settings['password']) ? $settings['password'] : '', "name" => isset($settings['name']) ? preg_replace(array('//'), array('(',')'), trim($settings['name'])) : '', "voicemail" => isset($settings['voicemail']) ? $settings['voicemail'] : 'default', "ringtimer" => isset($settings['ringtimer']) ? $settings['ringtimer'] : '', "noanswer" => isset($settings['noanswer']) ? $settings['noanswer'] : '', "recording" => isset($settings['recording']) ? $settings['recording'] : '', "outboundcid" => isset($settings['outboundcid']) ? $settings['outboundcid'] : '', "sipname" => isset($settings['sipname']) ? $settings['sipname'] : '', "noanswer_cid" => isset($settings['noanswer_cid']) ? $settings['noanswer_cid'] : "", "busy_cid" => isset($settings['busy_cid']) ? $settings['busy_cid'] : "", "chanunavail_cid" => isset($settings['chanunavail_cid']) ? $settings['chanunavail_cid'] : "", "noanswer_dest" => !empty($settings['noanswer_dest'])? $settings['noanswer_dest']: "", "busy_dest" => !empty($settings['busy_dest']) ? $settings['busy_dest'] : "", "chanunavail_dest" => !empty($settings['chanunavail_dest']) ? $settings['chanunavail_dest'] : "" )); } catch(\Exception $e) { throw new \Exception("Unable to insert into users: ".addSlashes($e->getMessage())); } //write to astdb $astman = $this->FreePBX->astman; $fpc = $this->FreePBX->Config(); if ($astman->connected()) { $astman->database_put("AMPUSER",$extension."/accountcode",!empty($settings["devinfo_accountcode"]) ? $settings["devinfo_accountcode"] : ''); $astman->database_put("AMPUSER",$extension."/rvolume",isset($settings['rvolume']) ? $settings['rvolume'] : ''); $astman->database_put("AMPUSER",$extension."/password",isset($settings['password']) ? $settings['password'] : ''); $astman->database_put("AMPUSER",$extension."/ringtimer",isset($settings['ringtimer']) ? $settings['ringtimer'] : $fpc->get('RINGTIMER')); $astman->database_put("AMPUSER",$extension."/cfringtimer",isset($settings['cfringtimer']) ? $settings['cfringtimer'] : $fpc->get('CFRINGTIMERDEFAULT')); $astman->database_put("AMPUSER",$extension."/concurrency_limit",isset($settings['concurrency_limit']) ? $settings['concurrency_limit'] : $fpc->get('CONCURRENCYLIMITDEFAULT')); $astman->database_put("AMPUSER",$extension."/noanswer",isset($settings['noanswer']) ? $settings['noanswer'] : ''); $astman->database_put("AMPUSER",$extension."/recording",isset($settings['recording']) ? $settings['recording'] : ''); $astman->database_put("AMPUSER",$extension."/outboundcid",isset($settings['outboundcid']) ? $settings['outboundcid'] : ''); $astman->database_put("AMPUSER",$extension."/cidname",isset($settings['name']) ? $settings['name'] : ''); $astman->database_put("AMPUSER",$extension."/cidnum",(isset($settings['cid_masquerade']) && trim($settings['cid_masquerade']) != "") ? trim($settings['cid_masquerade']) : $extension); $astman->database_put("AMPUSER",$extension."/voicemail",isset($settings['voicemail']) ? $settings['voicemail'] : ''); //TODO need to be in paging soon $astman->database_put("AMPUSER",$extension."/answermode",isset($settings['answermode']) ? $settings['answermode']: 'disabled'); $astman->database_put("AMPUSER",$extension."/intercom",isset($settings['intercom']) ? $settings['intercom']: 'enabled'); $astman->database_put("AMPUSER",$extension."/recording/in/external",$settings['recording_in_external']); $astman->database_put("AMPUSER",$extension."/recording/out/external",$settings['recording_out_external']); $astman->database_put("AMPUSER",$extension."/recording/in/internal",$settings['recording_in_internal']); $astman->database_put("AMPUSER",$extension."/recording/out/internal",$settings['recording_out_internal']); $astman->database_put("AMPUSER",$extension."/recording/ondemand",$settings['recording_ondemand']); $astman->database_put("AMPUSER",$extension."/recording/priority",isset($settings['recording_priority']) ? $settings['recording_priority'] : '10'); // If not set then we are using system default so delete the tree all-together // if (isset($settings['dialopts'])) { $astman->database_put("AMPUSER",$extension."/dialopts", $settings['dialopts']); } else { $astman->database_del("AMPUSER",$extension."/dialopts"); } $call_screen = isset($settings['call_screen']) ? $settings['call_screen'] : '0'; switch ($call_screen) { case '0': $astman->database_del("AMPUSER",$extension."/screen"); break; case 'nomemory': $astman->database_put("AMPUSER",$extension."/screen",'nomemory'); break; case 'memory': $astman->database_put("AMPUSER",$extension."/screen",'memory'); break; default: break; } if (!$editmode) { $astman->database_put("AMPUSER",$extension."/device",isset($settings['device']) ? $settings['device'] : $extension); } if (trim($settings['callwaiting']) == 'enabled') { $astman->database_put("CW",$extension,"ENABLED"); } else if (trim($settings['callwaiting']) == 'disabled') { $astman->database_del("CW",$extension); } if (trim($settings['pinless']) == 'enabled') { $astman->database_put("AMPUSER",$extension."/pinless","NOPASSWD"); } else if (trim($settings['pinless']) == 'disabled') { $astman->database_del("AMPUSER",$extension."/pinless"); } } else { die_freepbx("Cannot connect to Asterisk Manager with ".$this->FreePBX->Config->get("AMPMGRUSER")."/".$this->FreePBX->Config->get("AMPMGRPASS")); } // OK - got this far, if they entered a new inbound DID/CID let's deal with it now // remember - in the nice and ugly world of this old code, $vars has been extracted // newdid and newdidcid // Now if $newdid is set we need to add the DID to the routes // if ($settings['newdid'] != '' || $settings['newdidcid'] != '') { $did_dest = 'from-did-direct,'.$extension.',1'; $did_vars = array(); $did_vars['extension'] = $settings['newdid']; $did_vars['cidnum'] = $settings['newdidcid']; $did_vars['privacyman'] = ''; $did_vars['alertinfo'] = ''; $did_vars['ringing'] = ''; $did_vars['reversal'] = ''; $did_vars['mohclass'] = 'default'; $did_vars['description'] = $settings['newdid_name']; $did_vars['grppre'] = ''; $did_vars['delay_answer']= '0'; $did_vars['pricid']= ''; core_did_add($did_vars, $did_dest); } $this->getUserCache = array(); $this->listUsersCache = array(); $this->freepbx->Hooks->processHooks($extension, $settings, $editmode); return true; } /** * Delete a User * @param int $extension The user extension * @param {bool} $editmode=false If in edit mode (this is so it doesnt destroy the AsteriskDB) */ public function delUser($extension, $editmode=false) { global $db; global $amp_conf; global $astman; //delete from devices table $sql = "DELETE FROM users WHERE extension = ?"; $sth = $this->database->prepare($sql); $sth->execute(array($extension)); //delete details to astdb $astman = $this->FreePBX->astman; if($astman->connected()) { $astman->database_del("AMPUSER",$extension."/screen"); } if ($astman->connected() && !$editmode) { // TODO just change this to delete everything $astman->database_deltree("AMPUSER/".$extension); } $astman->database_del("CW",$extension); //TODO: Should only delete it's reference //but the array is multidimensional and sucks //OUT > Array //( // [0] => Array // ( // [extension] => 1005 // [0] => 1005 // [name] => WTF // [1] => WTF // [voicemail] => novm // [2] => novm // ) // //) $this->getUserCache = array(); $this->listUsersCache = array(); $this->freepbx->Hooks->processHooks($extension, $editmode); return true; } /** * Get User Details * @param int $extension The user number (extension) */ public function getUser($extension) { if (!empty($this->getUserCache[$extension])) { return $this->getUserCache[$extension]; } $sql = "SELECT * FROM users WHERE extension = ?"; $sth = $this->database->prepare($sql); try { $sth->execute(array($extension)); $results = $sth->fetch(\PDO::FETCH_ASSOC); } catch(\Exception $e) { return array(); } if(empty($results)) { return array(); } $astman = $this->FreePBX->astman; if ($astman->connected()) { if ($this->FreePBX->Modules->checkStatus("paging")) { $answermode=$astman->database_get("AMPUSER",$extension."/answermode"); $results['answermode'] = (trim($answermode) == '') ? $this->freepbx->Config->get("DEFAULT_INTERNAL_AUTO_ANSWER") : $answermode; $astman->database_put("AMPUSER",$extension."/answermode",$results['answermode']); //incase it was updated from above $intercom=$astman->database_get("AMPUSER",$extension."/intercom"); $results['intercom'] = (trim($intercom) == '') ? 'enabled' : $intercom; } $cw = $astman->database_get("CW",$extension); $results['callwaiting'] = (trim($cw) == 'ENABLED') ? 'enabled' : 'disabled'; $cid_masquerade=$astman->database_get("AMPUSER",$extension."/cidnum"); $results['cid_masquerade'] = (trim($cid_masquerade) != "")?$cid_masquerade:$extension; $call_screen=$astman->database_get("AMPUSER",$extension."/screen"); $results['call_screen'] = (trim($call_screen) != "")?$call_screen:'0'; $pinless=$astman->database_get("AMPUSER",$extension."/pinless"); $results['pinless'] = (trim($pinless) == 'NOPASSWD') ? 'enabled' : 'disabled'; $results['ringtimer'] = (int) $astman->database_get("AMPUSER",$extension."/ringtimer"); $results['cfringtimer'] = (int) $astman->database_get("AMPUSER",$extension."/cfringtimer"); $results['concurrency_limit'] = (int) $astman->database_get("AMPUSER",$extension."/concurrency_limit"); $results['dialopts'] = $astman->database_get("AMPUSER",$extension."/dialopts"); $results['recording_in_external'] = strtolower($astman->database_get("AMPUSER",$extension."/recording/in/external")); $results['recording_out_external'] = strtolower($astman->database_get("AMPUSER",$extension."/recording/out/external")); $results['recording_in_internal'] = strtolower($astman->database_get("AMPUSER",$extension."/recording/in/internal")); $results['recording_out_internal'] = strtolower($astman->database_get("AMPUSER",$extension."/recording/out/internal")); $results['recording_ondemand'] = strtolower($astman->database_get("AMPUSER",$extension."/recording/ondemand")); $results['recording_priority'] = (int) $astman->database_get("AMPUSER",$extension."/recording/priority"); $results['rvolume'] = strtolower($astman->database_get("AMPUSER",$extension."/rvolume")); } else { throw new \Exception("Cannot connect to Asterisk Manager with ".$this->FreePBX->Config->get("AMPMGRUSER")."/".$this->FreePBX->Config->get("AMPMGRPASS")); } $this->getUserCache[$extension] = $results; return $results; } /** * Get Device Details * @param {int} $account The Device ID */ public function getDevice($account) { if (!empty($this->getDeviceCache[$account])) { return $this->getDeviceCache[$account]; } $sql = "SELECT * FROM devices WHERE id = ?"; $sth = $this->database->prepare($sql); try { $sth->execute(array($account)); $device = $sth->fetch(\PDO::FETCH_ASSOC); } catch(\Exception $e) { return array(); } if (empty($device)) { return array(); } $t = $device['tech']; $tech = array(); if(isset($this->drivers[$t])) { $tech = $this->drivers[$t]->getDevice($account); } $results = array_merge($device,$tech); $this->getDeviceCache[$account] = $results; return $this->getDeviceCache[$account]; } /* * Get emergencyDevice */ public function getEmergencyDevice($account) { $sql = "SELECT * FROM emergencydevices WHERE id = ?"; $sth = $this->database->prepare($sql); try { $sth->execute(array($account)); $device = $sth->fetch(\PDO::FETCH_ASSOC); } catch(\Exception $e) { return array(); } if (empty($device)) { return array(); } $t = $device['tech']; $tech = array(); if(isset($this->drivers[$t])) { $tech = $this->drivers[$t]->getDevice($account); } $results = array_merge($device,$tech); return $results; } /** * Hook Tabs for hooking * @param [type] $page [description] * @return [type] [description] */ public function hookTabs($page){ $module_hook = \moduleHook::create(); $mods = $this->freepbx->Hooks->processHooks($page); $sections = array(); foreach($mods as $mod => $contents) { if(empty($contents)) { continue; } if(is_array($contents)) { foreach($contents as $content) { if(!isset($sections[$content['rawname']])) { $sections[$content['rawname']] = array( "title" => $content['title'], "rawname" => $content['rawname'], "content" => $content['content'] ); } else { $sections[$content['rawname']]['content'] .= $content['content']; } } } else { if(!isset($sections[$mod])) { $sections[$mod] = array( "title" => ucfirst(strtolower($mod)), "rawname" => $mod, "content" => $contents ); } else { $sections[$mod]['content'] .= $contents; } } } $hookTabs = $hookcontent = ''; foreach ($sections as $data) { $hookTabs .= '
  • '.$data['title'].'
    • '; $hookcontent .= '
    '; $hookcontent .= $data['content']; $hookcontent .= '
    '; } return array("hookTabs" => $hookTabs, "hookContent" => $hookcontent, "oldHooks" => $module_hook->hookHtml); } public function bulkhandlerGetTypes() { return array( 'extensions' => array( 'name' => _('Extensions'), 'description' => _('Extensions') ), 'dids' => array( 'name' => _('DIDs'), 'description' => _('DIDs / Inbound Routes') ) ); } /** * Bulk Handler Get headers * @param string $type The type of bulk handler * @return array Array of headers */ public function bulkhandlerGetHeaders($type) { switch ($type) { case 'extensions': $headers = array( 'extension' => array( 'required' => true, 'identifier' => _('Extension'), 'description' => _('Extension'), ), 'name' => array( 'identifier' => _('Name'), 'description' => _('Name'), ), 'description' => array( 'identifier' => _('Description'), 'description' => _('Description'), ), 'tech' => array( 'required' => true, 'identifier' => _('Device Technology'), 'description' => _('Device Technology'), ), ); foreach($this->drivers as $driver) { if (method_exists($driver, 'getDeviceHeaders')) { $driverheaders = $driver->getDeviceHeaders(); if ($driverheaders) { $headers = array_merge($headers, $driverheaders); } } } return $headers; break; case 'dids': $headers = array( 'description' => array( 'identifier' => _('Description'), 'description' => _('Description'), ), 'extension' => array( 'identifier' => _('Incoming DID'), 'description' => _('Incoming DID') ), 'cidnum' => array( 'identifier' => _('Caller ID'), 'description' => _('Caller ID Number') ), 'destination' => array( 'identifier' => _('Destination'), 'description' => _('The context, extension, priority to go to when this DID is matched. Example: app-daynight,0,1'), 'type' => 'destination', ), ); return $headers; break; } } /** * Used to Validate bulk handler items * @param string $type The bulk handler item * @param array $rawData Array of data to import * @return array Message containing status */ public function bulkhandlerValidate($type, $rawData) { $ret = NULL; $techType = array('pjsip', 'sip', 'virtual', 'iax2', 'dahdi', 'custom'); switch ($type) { case 'extensions': foreach ($rawData as $data) { if (empty($data['extension'])) { return array("status" => false, "message" => _("Extension is missing.")); } if (!is_numeric($data['extension'])) { return array("status" => false, "message" => _("Extension is not numeric.")); } if(empty($data['name'])){ return array("status" => false, "message" => _("Extension name is blank.")); } if(!empty($data['tech']) && !in_array($data['tech'], $techType)) { return array("status" => false, "message" => _("Please provide valid device technology")); } } break; } return $ret; } /** * Bulk Handler import * @param string $type The type of import * @param array $rawData Array of data to import * @param boolean $replaceExisting Should we replace existing data? * @return array Message containing status */ public function bulkhandlerImport($type, $rawData, $replaceExisting = true) { $ret = NULL; switch ($type) { case 'extensions': $defaulttech = \FreePBX::Sipsettings()->getSipPortOwner(); foreach ($rawData as $data) { array_change_key_case($data, CASE_LOWER); if (!is_numeric($data['extension'])) { return array("status" => false, "message" => _("Extension is not numeric.")); } if(empty($data['tech'])) { if ($defaulttech == "none") { $data['tech'] = 'sip'; } else { $data['tech'] = $defaulttech; } } if(empty($data['name'])) { return array("status" => false, "message" => _("Device 'name' can not be blank.")); } $settings = $this->generateDefaultDeviceSettings($data['tech'], $data['extension'], $data['name']); foreach ($settings as $key => $value) { if (isset($data[$key])) { /* Override default setting with our value. */ if($key == "secret" && $data[$key] == "REGEN"){ continue; } $settings[$key]['value'] = $data[$key]; } } $device = $this->getDevice($data['extension']); if($replaceExisting && !empty($device)) { $this->delDevice($data['extension'],true); } $user = $this->getUser($data['extension']); if($replaceExisting && !empty($user)) { $this->delUser($data['extension'],true); } try { if (!$this->addDevice($data['extension'], $data['tech'], $settings)) { return array("status" => false, "message" => _("Device could not be added.")); } } catch(\Exception $e) { return array("status" => false, "message" => $e->getMessage()); } $settings = $this->generateDefaultUserSettings($data['extension'], $data['name']); foreach ($settings as $key => $value) { if (isset($data[$key])) { /* Override default setting with our value. */ // if concurrency_limit is "" dont override if ($key == 'concurrency_limit') { if ($data[$key] != "") {// there is some valid value $settings[$key] = $data[$key]; } else { // unsetting.. So while adding it will set default value unset($settings[$key]); } } else { $settings[$key] = $data[$key]; } } } try { if (!$this->addUser($data['extension'], $settings)) { //cleanup $this->delDevice($data['extension'], $replaceExisting); return array("status" => false, "message" => _("User could not be added.")); } } catch(\Exception $e) { //cleanup $this->delDevice($data['extension'], $replaceExisting); return array("status" => false, "message" => $e->getMessage()); } } needreload(); $ret = array( 'status' => true, ); break; case "dids": foreach ($rawData as $data) { $exists = $this->getDID($data['extension'], $data['cidnum']); if(!$replaceExisting && !empty($exists)) { return array("status" => false, "message" => _("DID already exists")); } elseif($replaceExisting && !empty($exists)) { $this->delDID($data['extension'], $data['cidnum']); } $this->addDID($data); } needreload(); $ret = array( 'status' => true, ); break; } return $ret; } /** * Bulk Handler Export hook * @param string $type The type of bulk handling * @return array Array of data */ public function bulkhandlerExport($type) { $data = NULL; switch ($type) { case 'extensions': $users = $this->getAllUsersByDeviceType(); foreach ($users as $user) { $device = $this->getDevice($user['extension']); if (isset($device['secret_origional'])) { /* Don't expose our typo laden craziness to users. We like our users! */ unset($device['secret_origional']); } if (isset($device['vm'])) { /* This value doesnt make sense since we control vm externally through voicemail */ unset($device['vm']); } $du = $this->freepbx->Config->get("AMPEXTENSIONS"); if($du != "deviceanduser") { unset($device['password']); unset($device['devicetype']); unset($device['user']); unset($device['id']); unset($device['name']); unset($device['account']); } $tmp_user_data = $this->getUser($user['extension']); if(isset($tmp_user_data['cid_masquerade'])) { $user['cid_masquerade'] = $tmp_user_data['cid_masquerade']; } if(isset($tmp_user_data['concurrency_limit'])) { $user['concurrency_limit'] = $tmp_user_data['concurrency_limit'];; } $data[$user['extension']] = array_merge($user, $device); } break; case 'dids': $dids = $this->getAllDIDs(); $data = array(); foreach($dids as $did) { $key = $did['extension']."/".$did["cidnum"]; $data[$key] = $did; } break; } return $data; } /** * Set Outbound Routes Order */ public function setRouteOrder($routes){ $dbh = $this->database(); $stmt = $dbh->prepare('DELETE FROM `outbound_route_sequence` WHERE 1'); $stmt->execute(); $stmt = $dbh->prepare('INSERT INTO outbound_route_sequence (route_id, seq) VALUES (?,?)'); $ret = array(); foreach ($routes as $key => $value) { $seq = ($key+1); $ret[] = $stmt->execute(array($value,$seq)); } needreload(); return $ret; } /** * List Admin Users * @param string $datatype The type of data to return * @return array Return Array */ public function listAMPUsers($datatype = ''){ $sql = "SELECT username FROM ampusers ORDER BY username"; $stmt = $this->database->prepare($sql); $stmt->execute(); switch ($datatype) { case 'assoc': return $stmt->fetchall(\PDO::FETCH_ASSOC); break; default: return $stmt->fetchall(\PDO::FETCH_BOTH); break; } } /** * Add Admin User * @param string $username The username * @param string $password The password * @param integer $extension_low The lowest extension * @param integer $extension_high The highest extension * @param string $deptname The department name * @param array $sections Sections to allow */ public function addAMPUser($username, $password, $extension_low, $extension_high, $deptname, $sections){ if (strlen($password) == 40 && ctype_xdigit($password)) { $password_sha1 = $password; }else { $password_sha1 = sha1($password); } $sections = implode(";",$sections); $vars = array( ':username' => $username, ':password_sha1' => $password_sha1, ':extension_low' => $extension_low, ':extension_high' => $extension_high, ':deptname' => $deptname, ':sections' => $sections, ); $sql = "INSERT INTO ampusers (username, password_sha1, extension_low, extension_high, deptname, sections) VALUES (:username, :password_sha1, :extension_low, :extension_high, :deptname, :sections)"; $stmt = $this->database->prepare($sql); try{ $stmt->execute($vars); return true; }catch(\PDOException $e){ //data colission if($e->getCode() == '23000'){ return false; }else{ echo $e->getMessage(); throw $e; } } } /** * List Trunk Types * @return array Array of Trunk Types */ public function listTrunkTypes(){ $sipdriver = \FreePBX::create()->Config->get_conf_setting('ASTSIPDRIVER'); $default_trunk_types = array( "DAHDI" => 'DAHDi', "IAX2" => 'IAX2', "ENUM" => 'ENUM', "DUNDI" => 'DUNDi', "CUSTOM" => 'Custom' ); $sip = ($sipdriver == 'both' || $sipdriver == 'chan_sip') ? array("SIP" => sprintf(_('SIP (%s)'),'chan_sip')) : array(); $pjsip = ($sipdriver == 'both' || $sipdriver == 'chan_pjsip') ? array("PJSIP" => sprintf(_('SIP (%s)'),'chan_pjsip')) : array(); $trunk_types = $pjsip+$sip+$default_trunk_types; // Added to enable the unsupported misdn module if (function_exists('misdn_ports_list_trunks') && count(misdn_ports_list_trunks())) { $trunk_types['MISDN'] = 'mISDN'; } return $trunk_types; } /** * Search query for global search * @param string $query The query * @param array $results Results */ public function search($query, &$results) { if($this->freepbx->Config->get('AMPEXTENSIONS') == "extensions") { $sql = "SELECT * FROM devices WHERE id LIKE ? or description LIKE ?"; $sth = $this->database->prepare($sql); $sth->execute(array("%".$query."%","%".$query."%")); $rows = $sth->fetchAll(\PDO::FETCH_ASSOC); foreach($rows as $row) { if(ctype_digit($query)) { $results[] = array("text" => _("Extension")." ".$row['id'], "type" => "get", "dest" => "?display=extensions&extdisplay=".$row['id']); } else { $results[] = array("text" => $row['description']." (".$row['id'].")", "type" => "get", "dest" => "?display=extensions&extdisplay=".$row['id']); } } } else { $sql = "SELECT * FROM devices WHERE id LIKE ? or description LIKE ?"; $sth = $this->database->prepare($sql); $sth->execute(array("%".$query."%","%".$query."%")); $rows = $sth->fetchAll(\PDO::FETCH_ASSOC); foreach($rows as $row) { if(ctype_digit($query)) { $results[] = array("text" => _("Device")." ".$row['id'], "type" => "get", "dest" => "?display=extensions&extdisplay=".$row['id']); } else { $results[] = array("text" => $row['description']." (".$row['id'].")", "type" => "get", "dest" => "?display=extensions&extdisplay=".$row['id']); } } $sql = "SELECT * FROM users WHERE extension LIKE ? or name LIKE ?"; $sth = $this->database->prepare($sql); $sth->execute(array("%".$query."%","%".$query."%")); $rows = $sth->fetchAll(\PDO::FETCH_ASSOC); foreach($rows as $row) { if(ctype_digit($query)) { $results[] = array("text" => _("User")." ".$row['extension'], "type" => "get", "dest" => "?display=extensions&extdisplay=".$row['extension']); } else { $results[] = array("text" => $row['name']." (".$row['extension'].")", "type" => "get", "dest" => "?display=extensions&extdisplay=".$row['extension']); } } } if(!ctype_digit($query)) { $sql = "SELECT * FROM outbound_routes WHERE name LIKE ?"; $sth = $this->database->prepare($sql); $sth->execute(array("%".$query."%")); $rows = $sth->fetchAll(\PDO::FETCH_ASSOC); foreach($rows as $row) { $results[] = array("text" => _("Outbound Route:")." ".$row['name'], "type" => "get", "dest" => "?display=routing&view=form&id=".$row['route_id']); } $sql = "SELECT * FROM trunks WHERE name LIKE ?"; $sth = $this->database->prepare($sql); $sth->execute(array("%".$query."%")); $rows = $sth->fetchAll(\PDO::FETCH_ASSOC); foreach($rows as $row) { $results[] = array("text" => _("Trunk:")." ".$row['name'], "type" => "get", "dest" => "?display=trunks&tech=".$row['tech']."&extdisplay=OUT_".$row['trunkid']); } $sql = "SELECT * FROM incoming WHERE description LIKE ?"; $sth = $this->database->prepare($sql); $sth->execute(array("%".$query."%")); $rows = $sth->fetchAll(\PDO::FETCH_ASSOC); foreach($rows as $row) { $display = urlencode($row['extension']."/".$row['cidnum']); $results[] = array("text" => _("Inbound Route:")." ".$row['description'], "type" => "get", "dest" => "?display=did&view=form&extdisplay=".$display); } } else { $sql = "SELECT * FROM incoming WHERE cidnum LIKE :search OR extension LIKE :search"; $sth = $this->database->prepare($sql); $sth->execute(array("search" => "%".$query."%")); $rows = $sth->fetchAll(\PDO::FETCH_ASSOC); foreach($rows as $row) { $display = urlencode($row['extension']."/".$row['cidnum']); $results[] = array("text" => _("Inbound Route:")." ".$row['extension']."/".$row['cidnum'], "type" => "get", "dest" => "?display=did&view=form&extdisplay=".$display); } } } /** * Disable Trunk * @method disableTrunk * @param string $id The trunk ID * @return boolean Result of execute */ public function disableTrunk($id){ $tech = $this->getTrunkTech($id); if(!$tech){ return false; } $sql = "UPDATE trunks set disabled = 'on' WHERE trunkid = ?"; $ob = $this->database->prepare($sql); $ret = $ob->execute(array($id)); if ($ret && $tech == 'pjsip') { $sql = "UPDATE pjsip SET data = 'on' WHERE id = ? AND keyword = 'disabletrunk'"; $ob = $this->database->prepare($sql); $ret = $ob->execute(array($id)); } return $ret; } /** * Enable Trunk * @method enableTrunk * @param string $id The trunk ID * @return boolean Result of execute */ public function enableTrunk($id){ $tech = $this->getTrunkTech($id); $sql = "UPDATE trunks set disabled = 'off' WHERE trunkid = ?"; $ob = $this->database->prepare($sql); $ret = $ob->execute(array($id)); if ($ret && $tech == 'pjsip') { $sql = "UPDATE pjsip SET data = 'off' WHERE id = ? AND keyword = 'disabletrunk'"; $ob = $this->database->prepare($sql); $ret = $ob->execute(array($id)); } return $ret; } /** * Get Trunk Tech * @method getTrunkTech * @param string $trunknum The trunk id * @return string The trunk tech */ public function getTrunkTech($trunknum) { $sql = "SELECT tech FROM trunks WHERE trunkid = ?"; $ob = $this->database->prepare($sql); $ob->execute(array($trunknum)); $tech = $ob->fetchColumn(); if (!$tech) { return false; } $tech = strtolower($tech); if ($tech == "iax2") { $tech = "iax"; // same thing, here } return $tech; } /** * Filter valid codecs from list * @method filterValidCodecs * @param string $codecs List of codecs to check * @return string The filtered codecs */ public function filterValidCodecs($codecs) { $codecs = str_replace('&', ',', $codecs); //remove invalid & joiner if its there $codecs = explode(",",$codecs); $validCodecs = array_merge( array_keys($this->freepbx->Codecs->getAudio()), array_keys($this->freepbx->Codecs->getVideo()), array_keys($this->freepbx->Codecs->getText()), array_keys($this->freepbx->Codecs->getImage()), array('all','!all') ); $final = array(); foreach($codecs as $codec) { if(preg_match("/([a-z0-9]+):?/i", $codec, $match) && isset($match[1]) && in_array($match[1],$validCodecs)) { $final[] = $codec; } } $codecs = implode(",",$final); return $codecs; } // this function rebuilds the astdb based on device table contents // used on devices.php if action=resetall function devices2astdb(){ $devresults = $this->database->query("SELECT * FROM devices")->fetchAll(\PDO::FETCH_ASSOC); $uservoicemails = $this->database->query("SELECT extension, voicemail FROM users")->fetchAll(\PDO::FETCH_KEY_PAIR); //add details to astdb if ($this->astman->connected()) { $this->astman->database_deltree("DEVICE"); foreach ($devresults as $dev) { $this->astman->database_put("DEVICE",$dev['id']."/dial",$dev['dial']); $this->astman->database_put("DEVICE",$dev['id']."/type",$dev['devicetype']); $this->astman->database_put("DEVICE",$dev['id']."/user",$dev['user']); $this->astman->database_put("DEVICE",$dev['id']."/default_user",$dev['user']); if(trim($emergency_cid) != '') { $this->astman->database_put("DEVICE",$dev['id']."/emergency_cid",$dev['emergency_cid']); } // If a user is selected, add this device to the user if ($user != "none") { $existingdevices = $this->astman->database_get("AMPUSER",$dev['user']."/device"); if (empty($existingdevices)) { $this->astman->database_put("AMPUSER",$dev['user']."/device",$dev['id']); } else { $existingdevices_array = explode('&',$existingdevices); if (!in_array($dev['id'], $existingdevices_array)) { $existingdevices_array[] = $dev['id']; $existingdevices = implode('&',$existingdevices_array); $this->astman->database_put("AMPUSER",$dev['user']."/device",$existingdevices); } } } // create a voicemail symlink if needed if(isset($uservoicemails[$dev['user']]['voicemail']) && ($uservoicemails[$dev['user']]['voicemail'] != "novm") && $this->freepbx->Modules->checkStatus('voicemail')) { $this->freepbx->Voicemail->mapMailBox($dev['user']); } } return true; } else { return false; } } // this function rebuilds the astdb based on users table contents // used on devices.php if action=resetall function users2astdb(){ $userresults = $this->database->query("SELECT * FROM users")->fetchAll(\PDO::FETCH_ASSOC); //add details to astdb if ($this->astman->connected()) { foreach($userresults as $usr) { $this->astman->database_put("AMPUSER",$usr['extension']."/password",$usr['password']); $this->astman->database_put("AMPUSER",$usr['extension']."/ringtimer",$usr['ringtimer']); $this->astman->database_put("AMPUSER",$usr['extension']."/noanswer",$usr['noanswer']); $this->astman->database_put("AMPUSER",$usr['extension']."/recording",$usr['recording']); $this->astman->database_put("AMPUSER",$usr['extension']."/outboundcid",$usr['outboundcid']); $this->astman->database_put("AMPUSER",$usr['extension']."/cidname",$usr['name']); $this->astman->database_put("AMPUSER",$usr['extension']."/voicemail",$usr['voicemail']); } return true; } else { return false; } } }