poslop/PC-Contact-Sync
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: poslop/PC-Contact-Sync:6e87b01e726643e8258bd576d606ac5486ac05ca
Branches Tags
poslop/PC-Contact-Sync:main
..
compare: poslop/PC-Contact-Sync:main
Branches Tags
poslop/PC-Contact-Sync:main

4 Commits
6e87b01e72 .. main

Author SHA1 Message Date
poslop 5768f75f29 formatting 2026-04-23 15:05:06 -05:00
poslop 034d05eb81 rename config 2026-04-22 13:45:17 -05:00
poslop b0f277d57b readme update 2026-04-22 13:27:00 -05:00
poslop b1a380e3fd rename scripts 2026-04-22 13:25:56 -05:00
5 changed files with 395 additions and 394 deletions
Expand all files Collapse all files
gen_polycom_directory.php → directory.php
+30 -11
View File
@@ -1,5 +1,6 @@
#!/usr/bin/php -q #!/usr/bin/php -q
<?php <?php
/** /**
* Generate Polycom-compatible global directory XML (000000000000-directory.xml) * Generate Polycom-compatible global directory XML (000000000000-directory.xml)
* from PBXact/FreePBX extensions. * from PBXact/FreePBX extensions.
@@ -14,7 +15,7 @@
*/ */
$bootstrap_settings['freepbx_auth'] = false; $bootstrap_settings['freepbx_auth'] = false;
require_once('/etc/freepbx.conf'); require_once '/etc/freepbx.conf';
$provision_dir = '/tftpboot'; // <-- adjust if needed $provision_dir = '/tftpboot'; // <-- adjust if needed
$out_file = $provision_dir . '/000000000000-directory.xml'; $out_file = $provision_dir . '/000000000000-directory.xml';
@@ -39,17 +40,18 @@ try {
/** Fall back to PJSIP ps_endpoints (id is ext; parse callerid "Name <1001>") */ /** Fall back to PJSIP ps_endpoints (id is ext; parse callerid "Name <1001>") */
if (!$rows) { if (!$rows) {
$stmt = $db->prepare(" $stmt = $db->prepare('
SELECT id AS extension, callerid SELECT id AS extension, callerid
FROM ps_endpoints FROM ps_endpoints
ORDER BY CAST(id AS UNSIGNED) ORDER BY CAST(id AS UNSIGNED)
"); ');
$stmt->execute(); $stmt->execute();
$tmp = $stmt->fetchAll(PDO::FETCH_ASSOC); $tmp = $stmt->fetchAll(PDO::FETCH_ASSOC);
foreach ($tmp as $r) { foreach ($tmp as $r) {
$ext = trim((string)$r['extension']); $ext = trim((string) $r['extension']);
if (!preg_match('/^[0-9]+$/', $ext)) continue; // only numeric extensions if (!preg_match('/^[0-9]+$/', $ext))
$cid = trim((string)($r['callerid'] ?? '')); continue; // only numeric extensions
$cid = trim((string) ($r['callerid'] ?? ''));
// Try to parse descriptive name from callerid // Try to parse descriptive name from callerid
$name = 'Ext ' . $ext; $name = 'Ext ' . $ext;
if ($cid !== '') { if ($cid !== '') {
@@ -79,9 +81,10 @@ $root = $xml->createElement('directory');
$xml->appendChild($root); $xml->appendChild($root);
foreach ($rows as $r) { foreach ($rows as $r) {
$name = trim((string)($r['name'] ?? '')); $name = trim((string) ($r['name'] ?? ''));
$ext = trim((string)($r['extension'] ?? '')); $ext = trim((string) ($r['extension'] ?? ''));
if ($ext === '') continue; if ($ext === '')
continue;
// Split name into fn/ln if possible // Split name into fn/ln if possible
$fn = $name; $fn = $name;
@@ -128,7 +131,23 @@ if ($do_notify) {
$asteriskBin = '/usr/sbin/asterisk'; $asteriskBin = '/usr/sbin/asterisk';
$excludedEndpoints = [ $excludedEndpoints = [
'101', '102', '103', '104', '105', '106', '107', '108', '109', '110', '111', '112', '113', '114', '900', 'Voyant', '<Endpoint dpma_endpoint' '101',
'102',
'103',
'104',
'105',
'106',
'107',
'108',
'109',
'110',
'111',
'112',
'113',
'114',
'900',
'Voyant',
'<Endpoint dpma_endpoint',
]; ];
// Get all endpoints from Asterisk CLI // Get all endpoints from Asterisk CLI
@@ -158,7 +177,7 @@ if ($do_notify) {
$notifyCmd = sprintf( $notifyCmd = sprintf(
'%s -rx "pjsip send notify polycom-check-cfg endpoint %s"', '%s -rx "pjsip send notify polycom-check-cfg endpoint %s"',
escapeshellarg($asteriskBin), escapeshellarg($asteriskBin),
escapeshellarg($ep) escapeshellarg($ep),
); );
exec($notifyCmd); exec($notifyCmd);
} }
example-config.json
+8 -38
View File
@@ -1,46 +1,16 @@
{ {
"target_extensions": ["334", "338", "227", "228"], "target_extensions": ["101", "202", "303"],
"list_filter_type": "blacklist", "list_filter_type": "blacklist",
"extension_filter_list": [ "extension_filter_list": [
"209", "111",
"214", "222",
"220", "333"
"234",
"254",
"333",
"344",
"348",
"355",
"365",
"370",
"371",
"372",
"373",
"374",
"375",
"377",
"378",
"379",
"383",
"384",
"390",
"391",
"393",
"397",
"398",
"529"
], ],
"blacklisted_terms": ["vesibule", "inpatient"], "blacklisted_terms": ["accounting", "inpatient"],
"prepend_extensions": [ "prepend_extensions": [
{"name": "Night Hours", "extension": "*271"}, {"name": "Park 300", "extension": "300"},
{"name": "Overhead Page", "extension": "900"}, {"name": "Park 301", "extension": "300"},
{"name": "All page", "extension": "300"},
{"name": "Park 71", "extension": "71"},
{"name": "Park 72", "extension": "72"},
{"name": "OR", "extension": "356"},
{"name": "Lab", "extension": "340"}, {"name": "Lab", "extension": "340"},
{"name": "Business", "extension": "249"}, {"name": "Business", "extension": "249"}
{"name": "OP Nurse", "extension": "336"}
] ]
} }
gen_pc_sidecar.php
-340
View File
@@ -1,340 +0,0 @@
#!/usr/bin/php -q
<?php
$PROVISION_DIR = '/tftpboot';
$bootstrap_settings['freepbx_auth'] = false;
require_once('/etc/freepbx.conf');
$DB = FreePBX::Database();
$CONFIG_PATH = "./config.json";
$CONFIG = read_config_json_file($CONFIG_PATH);
$TARGET_EXTENSIONS = read_config_json("target_extensions");
$LIST_FILTER_TYPE = read_config_json_string("list_filter_type");
$EXTENSION_FILTER_LIST = read_config_json("extension_filter_list");
$BLACKLISTED_TERMS = read_config_json("blacklisted_terms");
$PREPEND_EXTENSIONS = read_config_json_object_list("prepend_extensions");
function main(): void {
global $TARGET_EXTENSIONS;
global $PROVISION_DIR;
$argv = $_SERVER['argv'] ?? [];
$do_notify = in_array('--notify', $argv, true);
$pbdb = pull_db();
blacklist_terms($pbdb);
filter_extensions($pbdb);
prepend_contact_list($pbdb);
$mac_list = pull_mac_list();
foreach ($TARGET_EXTENSIONS as $ext) {
$mac = strtolower($mac_list[$ext]) ?? null;
if (!$mac) { echo "Mac for $ext not found\n"; continue; }
$file = $PROVISION_DIR . '/' . $mac . '-features.cfg';
$xml = pull_xml_file($file);
$attendants = remove_attendants($xml);
write_attendants($attendants, $pbdb);
write_to_file($file, $xml);
}
if ($do_notify) {
notify($pbdb);
}
}
function pull_db(): array {
global $DB;
$pbdb = [];
try {
$stmt = $DB->prepare("
SELECT name, extension
FROM users
WHERE extension REGEXP '^[0-9]+$'
ORDER BY CAST(extension AS UNSIGNED)
");
$stmt->execute();
$pbdb = $stmt->fetchAll(PDO::FETCH_ASSOC);
} catch (Exception $e) {
}
if (!$pbdb) {
fwrite(STDERR, "No extensions found (users/ps_endpoints returned no pbdb).\n");
exit(1);
}
usort($pbdb, function ($a, $b) {
return strcasecmp($a['name'], $b['name']);
});
return $pbdb;
}
function filter_extensions(array &$pbdb) {
global $LIST_FILTER_TYPE;
if ($LIST_FILTER_TYPE == "whitelist") {
whitelist_extension_filter($pbdb);
} elseif ($LIST_FILTER_TYPE == "blacklist") {
blacklist_extension_filter($pbdb);
} else {
fwrite(STDERR, "Filter type invalid: $LIST_FILTER_TYPE");
fwrite(STDERR, "Use either whitelist or blacklist");
}
}
function blacklist_terms(array &$pbdb) {
global $BLACKLISTED_TERMS;
$pbdb = array_values(array_filter($pbdb, function ($item) use ($BLACKLISTED_TERMS) {
if (!is_array($item) || !isset($item['name'])) {
return true;
}
$name = ltrim($item['name']);
foreach ($BLACKLISTED_TERMS as $term) {
if (stripos($name, $term) === 0) {
return false;
}
}
return true;
}));
}
function whitelist_extension_filter(array &$pbdb) {
global $EXTENSION_FILTER_LIST;
$allowed = array_fill_keys(
array_map('trim', array_map('strval', $EXTENSION_FILTER_LIST)),
true
);
$pbdb = array_values(array_filter($pbdb, function ($item) use ($allowed) {
if (!is_array($item) || !isset($item['extension'])) {
return false;
}
$ext = trim((string)$item['extension']);
return isset($allowed[$ext]);
}));
}
function blacklist_extension_filter(array &$pbdb) {
global $EXTENSION_FILTER_LIST;
$blocked = array_fill_keys(
array_map('trim', array_map('strval', $EXTENSION_FILTER_LIST)),
true
);
$pbdb = array_values(array_filter($pbdb, function ($item) use ($blocked) {
if (!is_array($item) || !isset($item['extension'])) {
return true;
}
$ext = trim((string)$item['extension']);
return !isset($blocked[$ext]);
}));
}
function prepend_contact_list(array &$pbdb) {
global $PREPEND_EXTENSIONS;
array_unshift($pbdb, ...$PREPEND_EXTENSIONS);
}
function pull_mac_list(): array {
global $DB;
$mac_db = [];
try {
$stmt = $DB->prepare("
SELECT mac, SUBSTRING_INDEX(ext, '-', 1) AS ext
FROM endpoint_extensions
ORDER BY CAST(ext AS UNSIGNED)
");
$stmt->execute();
$mac_db = $stmt->fetchAll(PDO::FETCH_ASSOC);
} catch (Exception $e) {
echo $e;
}
return array_column($mac_db, 'mac', 'ext');
}
function read_config_json_file(string $path): array {
$json = file_get_contents($path);
$data = json_decode($json, true);
if ($data === null && json_last_error() !== JSON_ERROR_NONE) {
throw new RuntimeException("JSON decode error: " . json_last_error_msg());
}
return $data;
}
function read_config_json(string $key): array {
global $CONFIG;
$value = $CONFIG[$key] ?? [];
if (is_string($value)) {
$items = preg_split('/\s*,\s*/', $value, -1, PREG_SPLIT_NO_EMPTY);
} elseif (is_array($value)) {
$items = $value;
} else {
$items = [];
}
$items = array_values(array_filter($items, fn($v) => is_scalar($v)));
$items = array_map(
fn($v) => strtolower(trim((string)$v)),
$items
);
return array_values(array_filter($items, fn($v) => $v !== ''));
}
function read_config_json_string(string $key): string {
global $CONFIG;
$value = $CONFIG[$key] ?? '';
return strtolower(trim((string)$value));
}
function read_config_json_object_list(string $key): array {
global $CONFIG;
$value = $CONFIG[$key] ?? [];
if (!is_array($value)) return [];
$out = [];
foreach ($value as $row) {
if (is_array($row) && isset($row['name'], $row['extension'])) {
$out[] = [
'name' => (string)$row['name'],
'extension' => (string)$row['extension'],
];
}
}
return $out;
}
function pull_xml_file(string $file): DOMDocument {
if (!file_exists($file)) {
$file = '/tftpboot/000000000000-features.cfg';
}
$xmlString = file_get_contents($file);
if ($xmlString === false) {
throw new RuntimeException("Unable to read file: {$file}");
}
$xmlString = preg_replace('/^\xEF\xBB\xBF/', '', $xmlString); // BOM
$xmlString = ltrim($xmlString);
$firstAngle = strpos($xmlString, '<');
if ($firstAngle !== false && $firstAngle > 0) {
$xmlString = substr($xmlString, $firstAngle);
}
$xml = new DOMDocument('1.0', 'UTF-8');
$xml->preserveWhiteSpace = true;
$xml->formatOutput = true;
$xml->xmlStandalone = true;
if (!$xml->loadXML($xmlString)) {
$errs = libxml_get_errors();
libxml_clear_errors();
$msg = "Failed to parse XML.\n";
foreach ($errs as $e) {
$msg .= "[level {$e->level}] {$e->message} at line {$e->line}\n";
}
throw new RuntimeException($msg);
}
return $xml;
}
function remove_attendants(DOMDocument $xml): DOMElement {
$xpath = new DOMXPath($xml);
$attendantNodes = $xpath->query('/polycomConfig/attendant');
if ($attendantNodes->length === 0) {
throw new RuntimeException("No <attendant> element found at /polycomConfig/attendant");
}
$attendant = $attendantNodes->item(0);
$toRemove = [];
foreach ($attendant->attributes as $attr) {
if (strpos($attr->nodeName, 'attendant.resourceList.') === 0) {
$toRemove[] = $attr->nodeName;
}
}
foreach ($toRemove as $name) {
$attendant->removeAttribute($name);
}
return $attendant;
}
function write_attendants(DOMElement $attendant, array $pbdb): void {
$index = 1;
foreach ($pbdb as $r) {
$label = trim((string)($r['name'] ?? ''));
$address = trim((string)($r['extension'] ?? ''));
$type = trim((string)("normal"));
$attendant->setAttribute("attendant.resourceList.{$index}.address", $address);
$attendant->setAttribute("attendant.resourceList.{$index}.label", $label);
$attendant->setAttribute("attendant.resourceList.{$index}.type", $type);
$index++;
}
}
function write_to_file(string $file, DOMDocument $xml): void {
global $PROVISION_DIR;
if (!is_dir($PROVISION_DIR)) {
fwrite(STDERR, "Provisioning directory not found: $PROVISION_DIR\n");
exit(2);
}
$tmpfile = $file . '.tmp';
if ($xml->save($tmpfile) === false) {
fwrite(STDERR, "Failed to write temporary file $tmpfile\n");
exit(3);
}
if (!@rename($tmpfile, $file)) {
@unlink($tmpfile);
fwrite(STDERR, "Failed to move $tmpfile to $file (permissions?)\n");
exit(4);
}
if (!chown($file, 'asterisk')) {
error_log("chown failed for $file");
}
if (!chgrp($file, 'asterisk')) {
error_log("chgrp failed for $file");
}
echo "Wrote $file \n";
}
function notify(array $pbdb): void {
$notified = 0;
foreach ($pbdb as $r) {
$ext = trim((string)$r['extension']);
if ($ext === '') continue;
$cmd = "asterisk -rx \"pjsip send notify polycom-check-cfg endpoint " . escapeshellarg($ext) . "\"";
exec($cmd, $o, $rc);
if ($rc === 0) $notified++;
}
echo "Sent check-sync to $notified endpoints\n";
}
main();
readme.md
+2 -2
View File
@@ -45,10 +45,10 @@ Append this to the crontab
``` ```
# Run Polycom directory sync every 4 hours at :00 # Run Polycom directory sync every 4 hours at :00
0 */4 * * * /usr/bin/php /var/lib/asterisk/PC-Contact-Sync/gen_polycom_directory.php --notify >> /var/log/gen_polycom_directory.log 2>&1 0 */4 * * * /usr/bin/php /var/lib/asterisk/PC-Contact-Sync/directory.php --notify >> /var/log/directory.log 2>&1
# Run PC sidecar sync every 4 hours at :05 (5 mins after) # Run PC sidecar sync every 4 hours at :05 (5 mins after)
5 */4 * * * /usr/bin/php /var/lib/asterisk/PC-Contact-Sync/gen_pc_sidecar.php >> /var/log/gen_pc_sidecar.log 2>&1 5 */4 * * * /usr/bin/php /var/lib/asterisk/PC-Contact-Sync/sidecar.php >> /var/log/sidecar.log 2>&1
``` ```
<br> <br>
sidecar.php
Executable
+352
View File
@@ -0,0 +1,352 @@
#!/usr/bin/php -q
<?php
$PROVISION_DIR = '/tftpboot';
$bootstrap_settings['freepbx_auth'] = false;
require_once '/etc/freepbx.conf';
$DB = FreePBX::Database();
$CONFIG_PATH = './config.json';
$CONFIG = read_config_json_file($CONFIG_PATH);
$TARGET_EXTENSIONS = read_config_json('target_extensions');
$LIST_FILTER_TYPE = read_config_json_string('list_filter_type');
$EXTENSION_FILTER_LIST = read_config_json('extension_filter_list');
$BLACKLISTED_TERMS = read_config_json('blacklisted_terms');
$PREPEND_EXTENSIONS = read_config_json_object_list('prepend_extensions');
function main(): void
{
global $TARGET_EXTENSIONS;
global $PROVISION_DIR;
$argv = $_SERVER['argv'] ?? [];
$do_notify = in_array('--notify', $argv, true);
$pbdb = pull_db();
blacklist_terms($pbdb);
filter_extensions($pbdb);
prepend_contact_list($pbdb);
$mac_list = pull_mac_list();
foreach ($TARGET_EXTENSIONS as $ext) {
$mac = strtolower($mac_list[$ext]) ?? null;
if (!$mac) {
echo "Mac for $ext not found\n";
continue;
}
$file = $PROVISION_DIR . '/' . $mac . '-features.cfg';
$xml = pull_xml_file($file);
$attendants = remove_attendants($xml);
write_attendants($attendants, $pbdb);
write_to_file($file, $xml);
}
if ($do_notify) {
notify($pbdb);
}
}
function pull_db(): array
{
global $DB;
$pbdb = [];
try {
$stmt = $DB->prepare("
SELECT name, extension
FROM users
WHERE extension REGEXP '^[0-9]+$'
ORDER BY CAST(extension AS UNSIGNED)
");
$stmt->execute();
$pbdb = $stmt->fetchAll(PDO::FETCH_ASSOC);
} catch (Exception $e) {
}
if (!$pbdb) {
fwrite(STDERR, "No extensions found (users/ps_endpoints returned no pbdb).\n");
exit(1);
}
usort($pbdb, function ($a, $b) {
return strcasecmp($a['name'], $b['name']);
});
return $pbdb;
}
function filter_extensions(array &$pbdb)
{
global $LIST_FILTER_TYPE;
if ($LIST_FILTER_TYPE == 'whitelist') {
whitelist_extension_filter($pbdb);
} elseif ($LIST_FILTER_TYPE == 'blacklist') {
blacklist_extension_filter($pbdb);
} else {
fwrite(STDERR, "Filter type invalid: $LIST_FILTER_TYPE");
fwrite(STDERR, 'Use either whitelist or blacklist');
}
}
function blacklist_terms(array &$pbdb)
{
global $BLACKLISTED_TERMS;
$pbdb = array_values(array_filter($pbdb, function ($item) use ($BLACKLISTED_TERMS) {
if (!is_array($item) || !isset($item['name'])) {
return true;
}
$name = ltrim($item['name']);
foreach ($BLACKLISTED_TERMS as $term) {
if (stripos($name, $term) === 0) {
return false;
}
}
return true;
}));
}
function whitelist_extension_filter(array &$pbdb)
{
global $EXTENSION_FILTER_LIST;
$allowed = array_fill_keys(array_map('trim', array_map('strval', $EXTENSION_FILTER_LIST)), true);
$pbdb = array_values(array_filter($pbdb, function ($item) use ($allowed) {
if (!is_array($item) || !isset($item['extension'])) {
return false;
}
$ext = trim((string) $item['extension']);
return isset($allowed[$ext]);
}));
}
function blacklist_extension_filter(array &$pbdb)
{
global $EXTENSION_FILTER_LIST;
$blocked = array_fill_keys(array_map('trim', array_map('strval', $EXTENSION_FILTER_LIST)), true);
$pbdb = array_values(array_filter($pbdb, function ($item) use ($blocked) {
if (!is_array($item) || !isset($item['extension'])) {
return true;
}
$ext = trim((string) $item['extension']);
return !isset($blocked[$ext]);
}));
}
function prepend_contact_list(array &$pbdb)
{
global $PREPEND_EXTENSIONS;
array_unshift($pbdb, ...$PREPEND_EXTENSIONS);
}
function pull_mac_list(): array
{
global $DB;
$mac_db = [];
try {
$stmt = $DB->prepare("
SELECT mac, SUBSTRING_INDEX(ext, '-', 1) AS ext
FROM endpoint_extensions
ORDER BY CAST(ext AS UNSIGNED)
");
$stmt->execute();
$mac_db = $stmt->fetchAll(PDO::FETCH_ASSOC);
} catch (Exception $e) {
echo $e;
}
return array_column($mac_db, 'mac', 'ext');
}
function read_config_json_file(string $path): array
{
$json = file_get_contents($path);
$data = json_decode($json, true);
if ($data === null && json_last_error() !== JSON_ERROR_NONE) {
throw new RuntimeException('JSON decode error: ' . json_last_error_msg());
}
return $data;
}
function read_config_json(string $key): array
{
global $CONFIG;
$value = $CONFIG[$key] ?? [];
if (is_string($value)) {
$items = preg_split('/\s*,\s*/', $value, -1, PREG_SPLIT_NO_EMPTY);
} elseif (is_array($value)) {
$items = $value;
} else {
$items = [];
}
$items = array_values(array_filter($items, fn($v) => is_scalar($v)));
$items = array_map(fn($v) => strtolower(trim((string) $v)), $items);
return array_values(array_filter($items, fn($v) => $v !== ''));
}
function read_config_json_string(string $key): string
{
global $CONFIG;
$value = $CONFIG[$key] ?? '';
return strtolower(trim((string) $value));
}
function read_config_json_object_list(string $key): array
{
global $CONFIG;
$value = $CONFIG[$key] ?? [];
if (!is_array($value))
return [];
$out = [];
foreach ($value as $row) {
if (is_array($row) && isset($row['name'], $row['extension'])) {
$out[] = [
'name' => (string) $row['name'],
'extension' => (string) $row['extension'],
];
}
}
return $out;
}
function pull_xml_file(string $file): DOMDocument
{
if (!file_exists($file)) {
$file = '/tftpboot/000000000000-features.cfg';
}
$xmlString = file_get_contents($file);
if ($xmlString === false) {
throw new RuntimeException("Unable to read file: {$file}");
}
$xmlString = preg_replace('/^\xEF\xBB\xBF/', '', $xmlString); // BOM
$xmlString = ltrim($xmlString);
$firstAngle = strpos($xmlString, '<');
if ($firstAngle !== false && $firstAngle > 0) {
$xmlString = substr($xmlString, $firstAngle);
}
$xml = new DOMDocument('1.0', 'UTF-8');
$xml->preserveWhiteSpace = true;
$xml->formatOutput = true;
$xml->xmlStandalone = true;
if (!$xml->loadXML($xmlString)) {
$errs = libxml_get_errors();
libxml_clear_errors();
$msg = "Failed to parse XML.\n";
foreach ($errs as $e) {
$msg .= "[level {$e->level}] {$e->message} at line {$e->line}\n";
}
throw new RuntimeException($msg);
}
return $xml;
}
function remove_attendants(DOMDocument $xml): DOMElement
{
$xpath = new DOMXPath($xml);
$attendantNodes = $xpath->query('/polycomConfig/attendant');
if ($attendantNodes->length === 0) {
throw new RuntimeException('No <attendant> element found at /polycomConfig/attendant');
}
$attendant = $attendantNodes->item(0);
$toRemove = [];
foreach ($attendant->attributes as $attr) {
if (strpos($attr->nodeName, 'attendant.resourceList.') === 0) {
$toRemove[] = $attr->nodeName;
}
}
foreach ($toRemove as $name) {
$attendant->removeAttribute($name);
}
return $attendant;
}
function write_attendants(DOMElement $attendant, array $pbdb): void
{
$index = 1;
foreach ($pbdb as $r) {
$label = trim((string) ($r['name'] ?? ''));
$address = trim((string) ($r['extension'] ?? ''));
$type = trim((string) 'normal');
$attendant->setAttribute("attendant.resourceList.{$index}.address", $address);
$attendant->setAttribute("attendant.resourceList.{$index}.label", $label);
$attendant->setAttribute("attendant.resourceList.{$index}.type", $type);
$index++;
}
}
function write_to_file(string $file, DOMDocument $xml): void
{
global $PROVISION_DIR;
if (!is_dir($PROVISION_DIR)) {
fwrite(STDERR, "Provisioning directory not found: $PROVISION_DIR\n");
exit(2);
}
$tmpfile = $file . '.tmp';
if ($xml->save($tmpfile) === false) {
fwrite(STDERR, "Failed to write temporary file $tmpfile\n");
exit(3);
}
if (!@rename($tmpfile, $file)) {
@unlink($tmpfile);
fwrite(STDERR, "Failed to move $tmpfile to $file (permissions?)\n");
exit(4);
}
if (!chown($file, 'asterisk')) {
error_log("chown failed for $file");
}
if (!chgrp($file, 'asterisk')) {
error_log("chgrp failed for $file");
}
echo "Wrote $file \n";
}
function notify(array $pbdb): void
{
$notified = 0;
foreach ($pbdb as $r) {
$ext = trim((string) $r['extension']);
if ($ext === '')
continue;
$cmd = 'asterisk -rx "pjsip send notify polycom-check-cfg endpoint ' . escapeshellarg($ext) . '"';
exec($cmd, $o, $rc);
if ($rc === 0)
$notified++;
}
echo "Sent check-sync to $notified endpoints\n";
}
main();