229 lines
11 KiB
PHP
229 lines
11 KiB
PHP
<?php
|
|
|
|
// Vérification cli
|
|
if(php_sapi_name() != 'cli') {
|
|
exit('Vous devez lancer ce script en "cli" (terminal)');
|
|
}
|
|
|
|
// Gestion options
|
|
$options = getopt('d:');
|
|
if (empty($options['d'])) {
|
|
$config['dir']['absolut']='.';
|
|
} else {
|
|
$config['dir']['absolut']=$options['d'];
|
|
}
|
|
|
|
if (!is_readable($config['dir']['absolut'].'/config.yaml')) {
|
|
exit("Error: The configuration file is not present, move config.yaml.default to config.yaml\n");
|
|
}
|
|
if (($config = yaml_parse_file($config['dir']['absolut'].'/config.yaml')) == false) {
|
|
exit("config.yaml syntax error, check with : http://www.yamllint.com/ \n");
|
|
}
|
|
|
|
include($config['dir']['absolut'].'/header.php');
|
|
|
|
// For interpret signal
|
|
declare(ticks = 1);
|
|
|
|
function sig_handler($sig) {
|
|
toLog(1, 'Daemon STOP');
|
|
exit;
|
|
}
|
|
|
|
pcntl_signal(SIGTERM, "sig_handler");
|
|
|
|
toLog(3, "Lancement du daemon");
|
|
|
|
$dayTask=0;
|
|
while (true) {
|
|
try {
|
|
$spoolerNext = $db->prepare("SELECT spooler.id, spooler.session_id, spooler.password, spooler.task, session.user, session.domain, session.dateCreate, session.imap_folder, session.dateStart, session.dateEnd, session.what, session.format, session.total_size, session.total_nb, open.imap_server, open.imap_port, open.imap_user, open.imap_secure, open.imap_auth, open.imap_cert FROM spooler, session, open
|
|
WHERE spooler.session_id = session.id
|
|
AND open.session_id = session.id
|
|
AND status = 2
|
|
ORDER BY date ASC");
|
|
$spoolerNext->bindParam('session_id', $_POST['session_id'], PDO::PARAM_INT);
|
|
$spoolerNext->execute();
|
|
} catch ( PDOException $e ) {
|
|
toLog(1, "SELECT spooler, error : ".$e->getMessage(), 0);
|
|
}
|
|
|
|
$spoolerNextArrayFetch = $spoolerNext->fetchAll();
|
|
if (count($spoolerNextArrayFetch) == 0) {
|
|
toLog(5, "Rien dans le spooler");
|
|
} else {
|
|
|
|
foreach($spoolerNextArrayFetch as $spoolerNextArray) {
|
|
|
|
if ($spoolerNextArray['imap_user'] == '%e') {
|
|
$spoolerNext_user = myDecrypt($spoolerNextArray['user']).'@'.$spoolerNextArray['domain'];
|
|
} else {
|
|
$spoolerNext_user = myDecrypt($spoolerNextArray['user']);
|
|
}
|
|
|
|
$req = $db->prepare("UPDATE spooler SET status = 3 WHERE id = :id");
|
|
$req->bindParam('id', $spoolerNextArray['id'], PDO::PARAM_INT);
|
|
$req->execute();
|
|
|
|
|
|
if ($spoolerNextArray['task'] == 1) {
|
|
toLog(3, "Archive demandé dans le spooler pour la session ".$spoolerNextArray['session_id']);
|
|
|
|
$imapGetData_return = imapGetData('archive', $spoolerNextArray['session_id'], $spoolerNextArray['imap_server'], $spoolerNextArray['imap_port'], $spoolerNext_user, myDecrypt($spoolerNextArray['password']), $spoolerNextArray['imap_secure'], $spoolerNextArray['imap_auth'], $spoolerNextArray['imap_cert'], json_decode($spoolerNextArray['imap_folder']), $spoolerNextArray['dateStart'], $spoolerNextArray['dateEnd'], $spoolerNextArray['what'], $spoolerNextArray['format']);
|
|
|
|
// Si ça c'est bien passé
|
|
if ($imapGetData_return['result'] == true) {
|
|
// Le nom du fichier généré sera :
|
|
$fileNameGen=substr(string2url($spoolerNextArray['session_id'].$spoolerNext_user.'.zip'), 0, 70);
|
|
toLog(5, "Copie du tableau html + des assests");
|
|
// On récupère le dossier "lib" + le "index.html"
|
|
// copy($config['dir']['templateTab']['html'], $config['dir']['archive']."/".$spoolerNextArray['session_id']."/");
|
|
// toLog(5, $config['dir']['templateTab']['html'] . '-'. $config['dir']['archive']."/".$spoolerNextArray['session_id']."/");
|
|
// Copy asset (lib)
|
|
recurse_copy($config['dir']['absolut'].'/'.$config['dir']['templateTab'], $config['dir']['absolut'].'/'.$config['dir']['archive']."/".$spoolerNextArray['session_id']);
|
|
// On zip
|
|
if (Zip($config['dir']['absolut'].'/'.$config['dir']['archive']."/".$spoolerNextArray['session_id']."/", $config['dir']['absolut'].'/'.$config['dir']['archive']."/".$fileNameGen)) {
|
|
toLog(2, "Le ZIP est fait, on l'enregistre : ".$fileNameGen);
|
|
// Enregistrement de l'archive :
|
|
$req = $db->prepare("INSERT INTO archive (session_id, file) VALUES (:session_id, :file)");
|
|
$req->bindParam('session_id', $spoolerNextArray['session_id'], PDO::PARAM_INT);
|
|
$req->bindParam('file', $fileNameGen, PDO::PARAM_STR);
|
|
$req->execute();
|
|
// Changement de status dans la bd
|
|
$req = $db->prepare("UPDATE spooler SET status = 5, password = null WHERE id = :id");
|
|
$req->bindParam('id', $spoolerNextArray['id'], PDO::PARAM_INT);
|
|
$req->execute();
|
|
// Ménage
|
|
rrmdir($config['dir']['absolut'].'/'.$config['dir']['archive']."/".$spoolerNextArray['session_id']."/");
|
|
|
|
// Notification archive prête
|
|
$urlSpool=$config['baseUrl'].'spool_'.$spoolerNextArray['session_id'];
|
|
$deleteApproval='';
|
|
if ($spoolerNextArray['what'] == 1) {
|
|
$deleteApproval='<br /><br />
|
|
|
|
'._('When you have downloaded your archive and you have checked that its content is readable, you can start the cleaning (deletion of archived messages) by this link (irrevocable decision):').' <a href="'.$urlSpool.'_DeleteApproval">'.$urlSpool.'_DeleteApproval</a>';
|
|
}
|
|
$mailSend_return = mailSend(username2email($spoolerNextArray['user'], $spoolerNextArray['domain']), _('Archive ready to download'), _('Hello').'<br /></br>
|
|
|
|
'._('Your archive is available for download until the').' '.date('Y-m-d', time()+$config['archive']['life']*86400).' '._('by this link:').' <a href="'.$config['url']['archive'].$fileNameGen.'">'.$config['url']['archive'].$fileNameGen.'</a>'.$deleteApproval);
|
|
if ($mailSend_return != true) {
|
|
toLog(1, 'Erreur mailSend '.$mailSend_return);
|
|
}
|
|
|
|
} else {
|
|
// Erreur à la création du zip
|
|
toLog(2, "Erreur dans le spooler à la création du ZIP sur la session ".$spoolerNextArray['session_id']);
|
|
$req = $db->prepare("UPDATE spooler SET status = 0 WHERE id = :id");
|
|
$req->bindParam('id', $spoolerNextArray['id'], PDO::PARAM_INT);
|
|
$req->execute();
|
|
$mailSend_return = mailSend(username2email($spoolerNextArray['user'], $spoolerNextArray['domain']), _('Archive error'), _('Hello').'<br /></br>
|
|
|
|
'._('Sorry but the archiving encountered too many errors for you to download.'));
|
|
if ($mailSend_return != true) {
|
|
toLog(1, 'Erreur mailSend '.$mailSend_return);
|
|
}
|
|
}
|
|
} else {
|
|
toLog(2, "Erreur dans le spooler sur la session ".$spoolerNextArray['session_id'].' : '.$imapGetData_return['resultMsg']);
|
|
$req = $db->prepare("UPDATE spooler SET status = 0 WHERE id = :id");
|
|
$req->bindParam('id', $spoolerNextArray['id'], PDO::PARAM_INT);
|
|
$req->execute();
|
|
$mailSend_return = mailSend(username2email($spoolerNextArray['user'], $spoolerNextArray['domain']), _('Archive error'), _('Hello').'<br /></br>
|
|
|
|
'._('Sorry but the archiving encountered too many errors for you to download.'));
|
|
if ($mailSend_return != true) {
|
|
toLog(1, 'Erreur mailSend '.$mailSend_return);
|
|
}
|
|
}
|
|
} else if ($spoolerNextArray['task'] == 2) {
|
|
toLog(3, "Suppression demandé dans le spooler pour la session ".$spoolerNextArray['session_id']);
|
|
$imapDeleteData_return = imapDeleteData($spoolerNextArray['session_id'], $spoolerNextArray['imap_server'], $spoolerNextArray['imap_port'], $spoolerNext_user, myDecrypt($spoolerNextArray['password']), $spoolerNextArray['imap_secure'], $spoolerNextArray['imap_auth'], $spoolerNextArray['imap_cert'], json_decode($spoolerNextArray['imap_folder']), $spoolerNextArray['dateStart'], $spoolerNextArray['dateEnd']);
|
|
// Changement de status dans la bd
|
|
if ($imapDeleteData_return['result'] == true) {
|
|
$req = $db->prepare("UPDATE spooler SET status = 5, password = null WHERE id = :id");
|
|
$req->bindParam('id', $spoolerNextArray['id'], PDO::PARAM_INT);
|
|
$req->execute();
|
|
$mailSend_return = mailSend(username2email($spoolerNextArray['user'], $spoolerNextArray['domain']), _('You have relieved your mailbox'), _('Hello').'<br /></br>
|
|
|
|
'._('Congratulations, you have relieved your mailbox of').' '.$spoolerNextArray['total_nb'].' '._('emails').' ('.convertOctect2humain($spoolerNextArray['total_size']).')');
|
|
if ($mailSend_return != true) {
|
|
toLog(1, 'Erreur mailSend '.$mailSend_return);
|
|
}
|
|
} else {
|
|
$req = $db->prepare("UPDATE spooler SET status = 0 WHERE id = :id");
|
|
$req->bindParam('id', $spoolerNextArray['id'], PDO::PARAM_INT);
|
|
$req->execute();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
# Day task
|
|
if ($dayTask+86400 < time()) {
|
|
toLog(1, 'Lancement des tâches quotidiennes');
|
|
// Ménage dans els
|
|
try {
|
|
$archive = $db->prepare("SELECT session_id, file
|
|
FROM archive
|
|
WHERE dateCreate < '".date('Y-m-d', time()-$config['archive']['life']*86400)."'");
|
|
$archive->execute();
|
|
} catch ( PDOException $e ) {
|
|
toLog(1, "SELECT archive, error : ".$e->getMessage(), 0);
|
|
}
|
|
$archiveArrayFetch = $archive->fetchAll();
|
|
if (count($archiveArrayFetch) == 0) {
|
|
toLog(5, "Rien à supprimer dans les archives");
|
|
} else {
|
|
foreach($archiveArrayFetch as $archiveFetch) {
|
|
toLog(2, 'Suppression de l\'archives expiré : '.$archiveFetch['file']);
|
|
unlink($config['dir']['absolut'].'/'.$config['dir']['archive'].'/'.$archiveFetch['file']);
|
|
$req = $db->prepare("DELETE FROM archive WHERE session_id = :session_id");
|
|
$req->bindParam('session_id', $archiveFetch['session_id'], PDO::PARAM_INT);
|
|
$req->execute();
|
|
}
|
|
}
|
|
// Relance suppression
|
|
try {
|
|
$spoolerWait = $db->prepare("SELECT session.id, spooler.session_id, spooler.date, user, domain, archive.file
|
|
FROM spooler, session, archive
|
|
WHERE spooler.session_id = session.id
|
|
AND spooler.session_id = archive.session_id
|
|
AND what = 1
|
|
AND task = 2
|
|
AND status = 1");
|
|
$spoolerWait->execute();
|
|
} catch ( PDOException $e ) {
|
|
toLog(1, "SELECT archive, error : ".$e->getMessage(), 0);
|
|
}
|
|
$spoolerWaitArrayFetch = $spoolerWait->fetchAll();
|
|
if (count($spoolerWaitArrayFetch) == 0) {
|
|
toLog(5, "Aucune relance à faire");
|
|
} else {
|
|
foreach($spoolerWaitArrayFetch as $spoolerWaitFetch) {
|
|
foreach($config['delete']['relaunch'] as $relaunch) {
|
|
if (date('Y-m-d', strtotime($spoolerWaitFetch['date']. ' + '.$relaunch.' days')) == date('Y-m-d')) {
|
|
toLog(2, 'Relance à +'.$relaunch.' pour la session : '.$spoolerWaitFetch['id']);
|
|
$urlSpool=$config['baseUrl'].'spool_'.$spoolerWaitFetch['session_id'];
|
|
$mailSend_return = mailSend(username2email($spoolerWaitFetch['user'], $spoolerWaitFetch['domain']), '['._('Relaunch').'] '._('Archive ready to download'), _('Hello').'<br /></br>
|
|
|
|
'._('Your archive is available for download until the').' '.date('Y-m-d', time()+$config['archive']['life']*86400).' '._('by this link:').' <a href="'.$config['url']['archive'].$spoolerWaitFetch['file'].'">'.$config['url']['archive'].$spoolerWaitFetch['file'].'</a>'.'<br /><br />
|
|
|
|
'._('And above all, if you have already downloaded it:').'<br /><br />
|
|
|
|
<b>'._('You can start the cleaning (deletion of archived messages) by this link (irrevocable decision):').'</b> <a href="'.$urlSpool.'_DeleteApproval">'.$urlSpool.'_DeleteApproval</a>');
|
|
if ($mailSend_return != true) {
|
|
toLog(1, 'Erreur relance mailSend '.$mailSend_return);
|
|
}
|
|
}
|
|
}
|
|
|
|
}
|
|
}
|
|
|
|
$dayTask=time();
|
|
}
|
|
sleep($config["daemon"]["sleep"]);
|
|
}
|
|
|
|
?>
|