60 lines
1.9 KiB
PHP
60 lines
1.9 KiB
PHP
<?php
|
|
declare(strict_types=1);
|
|
|
|
/**
|
|
* NexusPBX HA - Synchronisation périodique du cluster par cron
|
|
* Exécuté automatiquement pour s'assurer que le nœud Backup reste 100% synchronisé.
|
|
*/
|
|
|
|
require_once __DIR__ . '/../src/Database.php';
|
|
require_once __DIR__ . '/../src/ClusterManager.php';
|
|
require_once __DIR__ . '/../src/ConfigGenerator.php';
|
|
|
|
use App\Database;
|
|
use App\ClusterManager;
|
|
|
|
try {
|
|
// Mode réconciliation immédiate au Failback (appelé par notify_master.sh)
|
|
if (in_array('--failback-check', $argv ?? [], true)) {
|
|
$db = Database::getConnection();
|
|
$cm = new ClusterManager($db);
|
|
$res = $cm->failbackReconcileWithPeer();
|
|
echo date('[Y-m-d H:i:s] ') . "[CLUSTER-FAILBACK] " . ($res['message'] ?? 'OK') . "\n";
|
|
exit(0);
|
|
}
|
|
|
|
// 0. Verrou d'exécution exclusif pour éviter les chevauchements
|
|
$lockFp = @fopen('/tmp/nexus_cluster_cron.lock', 'c+');
|
|
if (!$lockFp || !@flock($lockFp, LOCK_EX | LOCK_NB)) {
|
|
exit(0);
|
|
}
|
|
|
|
$db = Database::getConnection();
|
|
$cm = new ClusterManager($db);
|
|
$st = $cm->getSettings();
|
|
|
|
// 1. Si le cluster n'est pas activé ou que l'auto-sync est désactivée
|
|
if (empty($st['enabled']) || empty($st['auto_sync'])) {
|
|
exit(0);
|
|
}
|
|
|
|
// 2. Règle d'or HA : SEUL le nœud qui détient l'IP Virtuelle active (VIP) émet la réplication
|
|
// Un nœud passif/standby ne doit JAMAIS écraser le nœud actif ni émettre en boucle croisée
|
|
$vip = $st['virtual_ip'] ?? '';
|
|
if (empty($vip) || !$cm->isVirtualIpActive($vip)) {
|
|
exit(0);
|
|
}
|
|
|
|
if (empty($st['peer_ip'])) {
|
|
exit(0);
|
|
}
|
|
|
|
// 3. Déclenchement de la réplication vers le pair
|
|
$result = $cm->pushSyncToPeer();
|
|
echo date('[Y-m-d H:i:s] ') . "[CLUSTER-CRON] " . ($result['message'] ?? 'Synchronisation OK') . "\n";
|
|
} catch (\Throwable $e) {
|
|
echo date('[Y-m-d H:i:s] ') . "[CLUSTER-CRON-ERROR] " . $e->getMessage() . "\n";
|
|
exit(1);
|
|
}
|
|
|