#!/usr/bin/php
<?php
// -*- php -*-
$prefix = '/var/spool/mlmmj/';
$startdir = getcwd();
$hm = '/usr/bin/hypermail';
//chdir('');

putenv('LC_TIME=en_GB');
$lists = array();
$domains = array();

echo "looking for domains in ".$prefix."\n";
// all lists with the webarchive tunable will be processed

$tmp = scandir($prefix);
foreach($tmp as $t) {
    if(is_dir($prefix.$t) && !is_link($prefix.$t) && (substr_compare($t, '.', 0, 1) != 0)) {
	echo "adding ".$t." as a domain\n";
	$domains[] = $t;
    }
}
foreach($domains as $domain) {
    echo "looking for lists for ".$domain."\n";
    $tmp = scandir($prefix.$domain);
    foreach($tmp as $list) {
	if(file_exists($prefix.$domain.'/'.$list.'/control/webarchive')) {
	    echo "adding ".$list." as a list\n";
	    $lists[$domain][] = $list;
	}
    }
}

foreach($lists as $domain => $lists) {
    foreach($lists as $list) {

	$listpath = $prefix.$domain.'/'.$list;
	if (file_exists($listpath.'/control/webarchiveindex')) {
	    $lastindex = trim(file_get_contents($listpath.'/control/webarchiveindex'));
	}
	else {
	    $lastindex = 1;
	}
	$lastmessage = 0;
	$tmp = scandir($listpath.'/archive');
	foreach($tmp as $t) {
	    if(($t != '.') && ($t != '..') && ($t > $lastmessage)) {
		$lastmessage = $t;
	    }
	}
	if($lastindex >= $lastmessage) {
	    print("\tNo new messages to process. ($lastindex/$lastmessage)\n");
	    break;
	}
	print("\tProcessing messages ".$lastindex.' - '.$lastmessage.' for '.$list.'@'.$domain."\n");
	for($msg=$lastindex+1; $msg<=$lastmessage;$msg++) {
	    if(file_exists($listpath.'/archive/'.$msg)) {
		print("\t\tArchiving message ".$msg.' of '.$list.'@'.$domain."\n");
		$command = $hm.' -u -M -l '.$list.' -L en -c '.$listpath.'/control/webarchive -i <'.$listpath.'/archive/'.$msg;
		exec($command);
		$lastindex = $msg;
	    }
	    else {
		print("\t\tNo message ".$msg.' in archive of '.$list.'@'.$domain."\n");
	    }
	}
	file_put_contents($listpath.'/control/webarchiveindex', $lastindex);
    }
}
?>