&1", "r"); while (!feof($pd)) { $line = chop( fgets($pd, 4096) ); if ($b == "qrowEven") { $b = "qrowOdd"; } else { $b = "qrowEven"; } $line = preg_replace('/:/', ' ', $line); list($username, , $sl, , $il, , $fp, , $sm, , $sc, , $ic) = (preg_split('/\s+/', $line)); if ($username == "" && $sl == "") { /* we do not want to display data that * does not bleong to any user */ continue; } else if ($sl == "") { $line = fgets($pd, 4096); $line = preg_replace('/:/', ' ', $line); list(, , $sl, , $il, , $fp, , $sm, , $sc, , $ic) = (preg_split('/\s+/', $line)); } $PREFS =& GetPrefs($username, GetPath($username).".prefs"); if ($PREFS['enableBNR'] == "on") { $PREFS['enableBNR'] = "OFF"; } if ($PREFS['enableWhitelist'] == "on") { $PREFS['enableWhitelist'] = "OFF"; } $PREFS['spamAction'] = ucfirst($PREFS['spamAction']); $PREFS['enableBNR'] = strtoupper($PREFS['enableBNR']); $PREFS['enableWhitelist'] = strtoupper($PREFS['enableWhitelist']); $mailbox = GetPath($username).".mbox"; if ( file_exists($mailbox) ) { $mailbox_size = filesize($mailbox); $mailbox_display = sprintf("%2.1f KB", ($mailbox_size / 1024)); $mailbox_total += $mailbox_size; } else { $mailbox_display = "--"; } $sl_total += $sl; $il_total += $il; $sm_total += $sm; $fp_total += $fp; $sc_total += $sc; $ic_total += $ic; $DATA['TABLE'] .= "{$username}" . " {$mailbox_display}" . " {$sl}" . " {$il}" . " {$fp}" . " {$sm}" . " {$sc}" . " {$ic}" . " {$PREFS['trainingMode']}" . " {$PREFS['spamAction']}" . " {$PREFS['enableBNR']}" . " {$PREFS['enableWhitelist']}" . " {$PREFS['statisticalSedation']}" . " {$PREFS['signatureLocation']}" . "\n"; } pclose($pd); $mailbox_total_display = sprintf("%2.1f KB", ($mailbox_total / 1024)); $b = "listhdrr"; $DATA['TABLE'] .= "Total". " {$mailbox_total_display}". " {$sl_total}". " {$il_total}". " {$sm_total}". " {$fp_total}". " {$sc_total}". " {$ic_total}". "  ". "  ". "  ". "  ". "  ". "  ". "\n"; } function &DisplayStatus() { global $CONFIG, $DATA; $LOG = "{$CONFIG['DSPAM_HOME']}/system.log"; $spam_daily = array(); $nonspam_daily = array(); $period_daily = array(); $fp_daily = array(); $sm_daily = array(); $inoc_daily = array(); $whitelist_daily = array(); $spam_weekly = array(); $nonspam_weekly = array(); $period_weekly = array(); $fp_weekly = array(); $sm_weekly = array(); $inoc_weekly = array(); $$whitelist_weekly = array(); $msgpersecond = array(); $classes = array(); list (, $min, $hour, $mday, $mon, $year, , ,) = (localtime(time())); $hmstart = time() - 60; $daystart = mktime(0, 0, 0, $mon, $mday, $year); $periodstart = $daystart - (3600*24*24); /* 2 Weeks ago */ $dailystart = time() - (3600*23); $c_weekly = 0; /* Cursor to most recent time slot */ $c_daily = 0; if (! file_exists($LOG)) { return $input_errors[] = "No historical data is available (log file »{$LOG}« does not exist)."; } /* Initialize each individual time period */ for ($i = 0; $i <= 23; $i++) { $h = To12Hour($hour - (23-$i)); $period_daily[$i] = $h; $spam_daily[$i] = 0; $nonspam_daily[$i] = 0; $sm_daily[$i] = 0; $fp_daily[$i] = 0; $inoc_daily[$i] = 0; } for ($i = 0; $i <= 23; $i++) { $d = $daystart - (3600 * 24 * (24 - $i)); list (, , , $lday, $lmon, $lyear, , ,) = (localtime($d)); $lmon++; $lyear += 1900; $period_weekly[$i] = "{$lmon}/{$lday}/{$lyear}"; $spam_weekly[$i] = 0; $nonspam_weekly[$i] = 0; $sm_weekly[$i] = 0; $fp_weekly[$i] = 0; $inoc_weekly[$i] = 0; } if($fd = @fopen("{$LOG}", "r")) { while (!feof($fd)) { $line = fgets($fd, 4096); list ($t_log, $c_log, , $signature, , $e_log) = preg_split('/\t/', $line); if ($t_log > time()) { continue; } $last_message = $t_log; /* Only Parse Log Data in our Time Period */ if ($t_log >= $periodstart) { list (, $tmin, $thour, $tday, $tmon, $tyear) = (localtime($t_log)); $tmon++; $tyear += 1900; /* Weekly Graph */ $c_weekly = 0; while($period_weekly[$c_weekly] <> "{$tmon}/{$tday}/{$tyear}" && $c_weekly < 24) { $c_weekly++; } if ($c_log == "E") { if ($classes[$signature] == "S") { $spam_weekly[$c_weekly]--; if ($spam_weekly[$c_weekly] < 0) { $spam_weekly[$c_weekly] = 0; } } else if ($classes[$signature] == "I") { $nonspam_weekly[$c_weekly]--; if ($nonspam_weekly[$c_weekly] < 0) { $nonspam_weekly[$c_weekly] = 0; } } else if ($classes[$signature] == "W") { $whitelist_weekly[$c_weekly]--; if ($whitelist_weekly[$c_weekly] < 0) { $whitelist_weekly[$c_weekly] = 0; } } else if ($classes[$signature] == "F") { $spam_weekly[$c_weekly]++; $fp_weekly[$c_weekly]--; if ($fp_weekly[$c_weekly] < 0) { $fp_weekly[$c_weekly] = 0; } } else if ($classes[$signature] == "M") { $sm_weekly[$c_weekly]--; $nonspam_weekly[$c_weekly]++; if ($sm_weekly[$c_weekly] < 0) { $sm_weekly[$c_weekly] = 0; } } else if ($classes[$signature] == "N") { $inoc_weekly[$c_weekly]--; if ($inoc_weekly[$c_weekly] < 0) { $inoc_weekly[$c_weekly] = 0; } } } else { $classes[$signature] = $c_log; } if ($c_log == "S") { $spam_weekly[$c_weekly]++; } if ($c_log == "I") { $nonspam_weekly[$c_weekly]++; } if ($c_log == "W") { $whitelist_weekly[$c_weekly]++; } if ($c_log == "F") { $spam_weekly[$c_weekly]--; $fp_weekly[$c_weekly]++; if ($spam_weekly[$c_weekly] < 0) { $spam_weekly[$c_weekly] = 0; } } if ($c_log == "M") { $sm_weekly[$c_weekly]++; $nonspam_weekly[$c_weekly]--; if ($nonspam_weekly[$c_weekly] < 0) { $nonspam_weekly[$c_weekly] = 0; } } if ($c_log == "N") { $inoc_weekly[$c_weekly]++; } /* Daily Graph */ if ($t_log >= $dailystart) { while($period_daily[$c_daily] <> To12Hour($thour) && $c_daily < 24) { $c_daily++; } if ($c_log == "E") { if ($classes[$signature] == "S") { $spam_daily[$c_daily]--; if ($spam_daily[$c_daily] < 0) { $spam_daily[$c_daily] = 0; } } else if ($classes[$signature] == "I") { $nonspam_daily[$c_daily]--; if ($nonspam_daily[$c_daily] < 0) { $nonspam_daily[$c_daily] = 0; } } else if ($classes[$signature] == "W") { $whitelist_daily[$c_daily]--; if ($whitelist_daily[$c_daily] < 0) { $whitelist_daily[$c_daily] = 0; } } else if ($classes[$signature] == "F") { $spam_daily[$c_daily]++; $fp_daily[$c_daily]--; if ($fp_daily[$c_daily] < 0) { $fp_daily[$c_daily] = 0; } } else if ($classes[$signature] == "M") { $sm_daily[$c_daily]--; $nonspam_daily[$c_daily]++; if ($sm_daily[$c_daily] < 0) { $sm_daily[$c_daily] = 0; } } else if ($classes[$signature] == "N") { $inoc_daily[$c_daily]--; if ($inoc_daily[$c_daily] < 0) { $inoc_daily[$c_daily] = 0; } } } if ($c_log == "S") { $spam_daily[$c_daily]++; } if ($c_log == "I") { $nonspam_daily[$c_daily]++; } if ($c_log == "W") { $whitelist_daily[$c_daily]++; } if ($c_log == "F") { $spam_daily[$c_daily]--; $fp_daily[$c_daily]++; if ($spam_daily[$c_daily] < 0) { $spam_daily[$c_daily] = 0; } } if ($c_log == "M") { $sm_daily[$c_daily]++; $nonspam_daily[$c_daily]--; if ($nonspam_daily[$c_daily] < 0) { $nonspam_daily[$c_daily] = 0; } } if ($c_log == "N") { $inoc_daily[$c_daily]++; } } /* Last Half-Minute */ if ($t_log >= $hmstart) { $msgpersecond[$t_log]++; $DATA['AVG_PROCESSING_TIME'] += $e_log; $keycount_exectime++; } } } // end while fclose($fd); } else { return $input_errors[] = "Unable to open logfile: {$LOG}."; } // end if /* Calculate Avg. Messages Per Second */ foreach(array_values($msgpersecond) as $el) { $DATA['AVG_MSG_PER_SECOND'] += $el; } $DATA['AVG_MSG_PER_SECOND'] /= 60; $DATA['AVG_MSG_PER_SECOND'] = sprintf("%2.2f", $DATA['AVG_MSG_PER_SECOND']); /* Calculate Avg. Processing Time */ if ($keycount_exectime == 0) { $DATA['AVG_PROCESSING_TIME'] = 0; } else { $DATA['AVG_PROCESSING_TIME'] /= $keycount_exectime; } $DATA['AVG_PROCESSING_TIME'] = sprintf("%01.6f", $DATA['AVG_PROCESSING_TIME']); /* Calculate Number of processes, Uptime and Mail Queue length */ $pd = popen("{$CONFIG['ALL_PROCS']} | grep dspam | grep -v grep | grep -v cgi | grep -v sock | wc -l", "r"); $DATA['DSPAM_PROCESSES'] = fgets($pd, 4096); pclose($pd); $pd = popen("uptime", "r"); $DATA['UPTIME'] = fgets($pd, 4096); pclose($pd); $pd = popen("{$CONFIG['MAIL_QUEUE']}", "r"); $DATA['MAIL_QUEUE'] = fgets($pd, 4096); pclose($pd); /* Calculate Graphs */ $DATA['SPAM_TODAY'] = $spam_weekly[24]; $DATA['NONSPAM_TODAY'] = $nonspam_weekly[24]; $DATA['SM_TODAY'] = $sm_weekly[24]; $DATA['FP_TODAY'] = $fp_weekly[24]; $DATA['INOC_TODAY'] = $inoc_weekly[24]; $DATA['TOTAL_TODAY'] = $DATA['SPAM_TODAY'] + $DATA['NONSPAM_TODAY'] + $DATA['SM_TODAY'] + $DATA['FP_TODAY'] + $DATA['INOC_TODAY']; $DATA['SPAM_THIS_HOUR'] = $spam_daily[23]; $DATA['NONSPAM_THIS_HOUR'] = $nonspam_daily[23]; $DATA['SM_THIS_HOUR'] = $sm_daily[23]; $DATA['FP_THIS_HOUR'] = $fp_daily[23]; $DATA['INOC_THIS_HOUR'] = $inoc_daily[23]; $DATA['TOTAL_THIS_HOUR'] = $DATA['SPAM_THIS_HOUR'] + + $DATA['NONSPAM_THIS_HOUR'] + $DATA['SM_THIS_HOUR'] + $DATA['FP_THIS_HOUR'] + $DATA['INOC_THIS_HOUR']; if (is_array($spam_daily) && is_array($nonspam_daily) && is_array($sm_daily) && is_array($fp_daily) && is_array($inoc_daily) && is_array($whitelist_daily) && is_array($period_daily)) { $DATA['DATA_DAILY'] = join(",", $spam_daily) . "_" . join(",", $nonspam_daily) . "_" . join(",", $sm_daily) . "_" . join(",", $fp_daily) . "_" . join(",", $inoc_daily) . "_" . join(",", $whitelist_daily) . "_" . join(",", $period_daily); foreach($spam_daily as $el){ $DATA['TS_DAILY'] += $el; }; foreach($nonspam_daily as $el){ $DATA['TI_DAILY'] += $el; } foreach($sm_daily as $el){ $DATA['SM_DAILY'] += $el; } foreach($fp_daily as $el){ $DATA['FP_DAILY'] += $el; } foreach($inoc_daily as $el){ $DATA['INOC_DAILY'] += $el; } foreach($whitelist_daily as $el){ $DATA['TI_DAILY'] += $el; } } if (is_array($spam_weekly) && is_array($nonspam_weekly) && is_array($sm_weekly) && is_array($fp_weekly) && is_array($inoc_weekly) && is_array($whitelist_weekly) && is_array($period_weekly)) { $DATA['DATA_WEEKLY'] = join(",", $spam_weekly) . "_" . join(",", $nonspam_weekly) . "_" . join(",", $sm_weekly) . "_" . join(",", $fp_weekly) . "_" . join(",", $inoc_weekly) . "_" . join(",", $whitelist_weekly) . "_" . join(",", $period_weekly); foreach($spam_weekly as $el){ $DATA['TS_WEEKLY'] += $el; } foreach($nonspam_weekly as $el){ $DATA['TI_WEEKLY'] += $el; } foreach($sm_weekly as $el){ $DATA['SM_WEEKLY'] += $el; } foreach($fp_weekly as $el){ $DATA['FP_WEEKLY'] += $el; } foreach($inoc_weekly as $el){ $DATA['INOC_WEEKLY'] += $el; } foreach($whitelist_weekly as $el){ $DATA['TI_WEEKLY'] += $el; } } } function &DisplayInfos() { global $CONFIG, $DATA, $g; $validity = "valide"; $pd = @popen("{$CONFIG['DSPAM']} --version", "r"); fgets($pd, 4096); // ignore 1st line $DATA['DSPAM_VERSION'] = fgets($pd, 4096); fgets($pd, 4096); // ignore next line $DATA['DSPAM_COPYRIGHT'] = fgets($pd, 4096); $DATA['DSPAM_WEBSITE'] = fgets($pd, 4096); fgets($pd, 4096); // ignore next line $DATA['DSPAM_COPYRIGHT_TEXT'] = fgets($pd, 4096); $DATA['DSPAM_COPYRIGHT_TEXT'] .= " " . fgets($pd, 4096); fgets($pd, 4096); // ignore next line $DATA['DSPAM_CONFIGURE_ARGS'] = str_replace("Configuration parameters: ", "", fgets($pd, 4096)); pclose($pd); if (file_exists("{$g['conf_path']}/nione.lic") && file_exists("{$g['conf_path']}/nione.lic.sha1")) { if ($fd = @fopen("{$g['conf_path']}/nione.lic", "r")) { $owneru = str_replace("Licensed User: ", "", fgets($fd, 4096)); if ($owneru == "") { $validity = "invalide (owner data not found)"; } $ownerc = str_replace("Company: ", "", fgets($fd, 4096)); if ($ownerc == "") { $validity = "invalide (company not found)"; } $lkey = str_replace("License Key: ", "", fgets($fd, 4096)); if ($lkey == "") { $validity = "invalide (license key not found)"; } $pdate = strtotime( str_replace("Purchase Date: ", "", fgets($fd, 4096)) ); if ($pdate == "") { $validity = "invalide (purchase date not found)"; } fclose($fd); } else { $validity = "invalide (license files not found)"; } if(! extension_loaded( 'bcompiler' )) { if(@dl( 'bcompiler.so' )) { require_once ("knione"); $gen_lkey = getNIONEKey(trim($owneru), trim($ownerc)); if (trim($lkey) <> $gen_lkey) { $validity = "invalide (wrong license key)"; } $cdate = mktime(0, 0, 0, date("m"), date("d"), date("Y")); $edate = mktime(0, 0, 0, date("m", $pdate), date("d", $pdate), date("Y", $pdate)+1); if ($edate < $cdate || $pdate > $cdate) { $validity = "invalide (license expired)"; } if ($fd = @fopen("{$g['conf_path']}/nione.lic.sha1", "r")) { $chksum = str_replace("SHA1 (nione.lic) = ", "", fgets($fd, 4096)); $chksum_new = sha1_file("{$g['conf_path']}/nione.lic"); if (trim($chksum) !== trim($chksum_new)) { $validity = "invalide (wrong license file checksum)"; } fclose($fd); } else { $validity = "invalide (license files not found)"; } } else { $validity = "invalide (extension missing, which is necessary to validate license data.)"; } } } else { $validity = "invalide (license files not found)"; } $DATA['OWNER'] = $owneru; $DATA['COMPANY'] = $ownerc; $DATA['LICENSE_KEY'] = $lkey; $DATA['LICENSE_VALIDITY'] = $validity; $DATA['PURCHASE_DATE'] = date("F j, Y", $pdate); $DATA['EXPIRY_DATE'] = date("F j, Y", $edate); } /* ========================================================================== */ /* = H I S T O R Y F U N C T I O N S = */ /* ========================================================================== */ function &DisplayFragment($sigID = "", $from = "", $subject = "", $info = "", $time = "") { global $DATA, $USER; $sigID = preg_replace('/\/', '///', $sigID); $DATA['FROM'] = $from; $DATA['SUBJECT'] = $subject; $DATA['INFO'] = $info; $DATA['TIME'] = $time; if($fd = @fopen("{$USER}.frag/{$sigID}.frag", "r")) { while (!feof($fd)) { /* sanitize HTML markup */ $line = preg_replace("//e", "'>'", $line); $DATA['MESSAGE'] .= $line; } fclose($fd); } else { return $input_errors[] = "Unable to open file {$USER}.frag/{$sigID}.frag."; } } function &DisplayHistory($command = "", $sigID= "", $retrainChecked = array(), $username = "", $retrainParam = "", $currentPage = 1, $hPerPage = 0) { global $CONFIG, $USER, $CURRENT_USER, $DATA; $buffer = array(); $history = array(); $rec = array(); $rowclass = "rowEven"; if ($command == "retrainChecked" && count ($retrainChecked) > 0) { foreach($retrainChecked as $el) { list ($retrain, $signature) = split(":", $el); if ($retrain == "innocent") { ProcessFalsePositive(quotemeta($signature)); } else if ($retrain == "innocent" || $retrain == "spam") { system("{$CONFIG['DSPAM']} --source=error --class=" . quotemeta($retrain) . " --signature=" . quotemeta($signature) . " --user " . quotemeta($CURRENT_USER)); } } // TODO: Do we need the other params which were submited during the current // POS/GET request? pfSenseHeader("/dspam-history.php?user={$username}&page={$currentPage}&hperpage={$hPerPage}"); } else { if ($retrainParam <> "") { if ($retrainParam == "innocent") { ProcessFalsePositive(); } else { system("{$CONFIG['DSPAM']} --source=error --class=" . quotemeta($retrainParam) . " --signature=" . quotemeta($sigID) . " --user " . quotemeta($CURRENT_USER)); } // TODO: Do we need the other params which were submited during the current // POS/GET request? pfSenseHeader("/dspam-history.php?user={$username}&page={$currentPage}&hperpage={$hPerPage}"); } } $LOG = "{$USER}.log"; if (! file_exists($LOG)) { return $input_errors[] = "No historical data is available (log file »{$USER}.log« does not exist)."; } /* Preseed retraining information and delivery errors */ $fd = fopen($LOG, "r"); while (!feof($fd)) { /* TODO: If the subject line contains a , the below array would * contain more then seven elements and thus would be invalide. * * The below code is some kind of a bug fix. */ $cline = fgets($fd, 4096); $log_columns = preg_split("/\t/", $cline); list($time, $class, $from, $signature, $subject, $info, $messageid) = $log_columns; if (count ($log_columns) > 7) { /* get values from the array beginning */ $time = array_shift($log_columns); $class = array_shift($log_columns); $from = array_shift($log_columns); $signature = array_shift($log_columns); /* get msgid and info from the array end */ $messageid = array_pop($log_columns); $info = array_pop($log_columns); /* the remaining parts are belonging to the subject */ $subject = implode(" ", $log_columns); } if ($signature == "") { continue; } if ($class == "M" || $class == "F" || $class == "E") { if ($class == "E") { $rec[$signature]['info'] = $info; } else if ($class == "F" || $class == "M") { $rec[$signature]['class'] = $class; $rec[$signature]['count']++; if ($rec[$signature]['info'] == "") { $rec[$signature]['info'] = $info; } } /* filter out resents if there are any. Since it's the same * message we only allow retraining on the 1st occurence of it. */ } else if ($messageid == "" || $rec[$signature]['messageid'] != $messageid || $CONFIG['HISTORY_DUPLICATES'] <> "no") { $rec[$signature]['time'] = $time; $rec[$signature]['class'] = $class; $rec[$signature]['from'] = $from; $rec[$signature]['signature'] = $signature; $rec[$signature]['subject'] = $subject; $rec[$signature]['info'] = $info; $rec[$signature]['messageid'] = $messageid; array_unshift($buffer, $rec[$signature]); } } // end while fclose($fd); /* if the page size wasn't specified, set a default one */ if ($CONFIG['HISTORY_PER_PAGE'] == 0) { $CONFIG['HISTORY_PER_PAGE'] = 50; } if (isset($hPerPage) && $hPerPage > 0) { $CONFIG['HISTORY_PER_PAGE'] = $hPerPage; } if (isset($currentPage) && isset($CONFIG['HISTORY_PER_PAGE'])) { $pages = ceil( (count ($buffer) / $CONFIG['HISTORY_PER_PAGE']) ); $begin = (($currentPage - 1) * $CONFIG['HISTORY_PER_PAGE']); $ranges = ceil ($pages / $CONFIG['HNAV_BUTTONS']); /* Now lets just keep the information that we really need. */ $buffer = array_splice($buffer, $begin, $CONFIG['HISTORY_PER_PAGE']); } $retrain_checked_msg_no = 0; while ($rec = array_pop($buffer)) { $time = $rec['time']; $class = $rec['class']; $from = $rec['from']; $signature = $rec['signature']; $subject = $rec['subject']; $info = $rec['info']; $messageid = $rec['messageid']; if ($signature == "") { continue; } if ($rec[$signature]['displayed'] <> "") { continue; } if ($class == "E") { continue; } $rec[$signature]['displayed'] = 1; /* Resends of retrained messages will need the original from/subject line */ if ($messageid <> "") { if ($from == "") { $from = $rec[$messageid]['from']; } if ($subject == "") { $subject = $rec[$messageid]['subject']; } if ($rec[$messageid]['from'] == "") { $rec[$messageid]['from'] = $from; } if ($rec[$messageid]['subject'] == "") { $rec[$messageid]['subject'] = $subject; } } if ($from == "") { $from = ""; } if ($subject == "") { $subject = ""; } $ctime = ""; if(isset($CONFIG["DATE_FORMAT"])) { $ctime = strftime($CONFIG["DATE_FORMAT"], localtime($time)); } else { /* date format was taken from ctime.pl */ $ctime = date ("D M d H:i:s TY",$time); $ttmp = preg_split("/\s+/", $ctime); $t = preg_split("/\:/", $ttmp[3]); $xtmp = preg_split("/\s+/", $ctime); $x = $xtmp[0]; $m = "a"; if ($t[0] > 12) { $t[0] -= 12; $m = "p"; } if ($t[0] == 0) { $t[0] = 12; } $ctime = "{$x} {$t[0]}:{$t[1]}{$m}"; } /* Set the appropriate type and label for this message */ $cl = ""; $cllabel = ""; if ($rec[$signature]['class'] <> "") { $class = $rec[$signature]['class']; } if ($class == "S") { $cl = "spam"; $cllabel="SPAM"; } else if ($class == "I") { $cl = "innocent"; $cllabel="Good"; } else if ($class == "F") { if (fmod($rec[$signature]['count'], 2) != 0) { $cl = "false"; $cllabel="Miss"; } else { $cl = "innocent"; $cllabel="Good"; } } else if ($class == "M") { if (fmod($rec[$signature]['count'], 2) != 0) { $cl = "missed"; $cllabel="Miss"; } else { $cl = "spam"; $cllabel="SPAM"; } } else if ($class == "N") { $cl = "inoculation"; $cllabel="Spam"; } else if ($class == "C") { $cl = "blacklisted"; $cllabel="RBL"; } else if ($class == "W") { $cl = "whitelisted"; $cllabel="Whitelist"; } if ($messageid <> "") { if ($rec[$messageid]['resend'] <> "") { $cl = "relay"; $cllabel = "Resend"; } $rec[$messageid]['resend'] = $signature; } if ($rec[$signature]['info'] <> "") { $info = $rec[$signature]['info']; } /* sanitize HTML markup */ $from = preg_replace("//e", "'>'", $from); $subject = preg_replace('//e', "'>'", $subject); if (strlen($from) > $CONFIG['MAX_COL_LEN']) { $from = substr($from, 0, $CONFIG['MAX_COL_LEN']) . "..."; } if (strlen($subject) > $CONFIG['MAX_COL_LEN']) { $subject = substr($subject, 0, $CONFIG['MAX_COL_LEN']) . "..."; } $rclass = ""; if ($class == "I" || $class == "W" || $class == "F") { $rclass = "spam"; } if ($class == "S" || $class == "M") { $rclass = "innocent"; } $retrain = ""; if (preg_match('/^(M|F)$/', $rec[$signature]['class']) > 0 && fmod($rec[$signature]['count'], 2) != 0) { $retrain = "Retrained"; } if ($retrain == "") { $retrain = "As " . ucfirst($rclass) . ""; } else { $retrain .= "(Undo)"; } $path = "{$USER}.frag/{$signature}.frag"; if (file_exists($path)) { $pairs = array(); $pairs['template'] = "fragment"; $pairs['signatureID'] = $signature; $sub = $subject; $sub = preg_replace('/#/e', '//', $sub); $sub = preg_replace("/(['])/e", '/\\$1/', $sub); $pairs['subject'] = $sub; $pairs['from'] = $from; $pairs['info'] = $info; $pairs['time'] = $ctime; $pairs['user'] = $username; $pairs['page'] = $currentPage; $pairs['hperpage'] = $hPerPage; $url = SafeVars($pairs); $from = "{$from}"; } $entry = << {$cllabel} {$ctime} {$from} {$subject} {$info} EOD; $retrain_checked_msg_no++; array_push($history, $entry); if ($rowclass == "qrowEven") { $rowclass = "qrowOdd"; } else { $rowclass = "qrowEven"; } $hurtz++; } // end while $entry = << EOD; array_push($history, $entry); while($line = array_pop($history)) { $DATA['HISTORY'] .= $line; } if ($CONFIG['HISTORY_PER_PAGE'] > 0) { /* prepare quarantine navbar */ if (($currentPage - 1) >= 1) { $previousPage = $currentPage - 1; } else { $previousPage = 1; } if (($currentPage + 1) <= $pages) { $nextPage = $currentPage + 1; } else { $nextPage = $pages; } $historyFooterBegin = << |<  <  EOD; $historyFooterEnd = <<>  >| EOD; $ranges_array = array(); $rpages = $pages; for ($i = 0; $i < $ranges; $i++) { $range = array(); $range['start'] = (($i + 1)* $CONFIG['HNAV_BUTTONS']) - ($CONFIG['HNAV_BUTTONS'] - 1); if (($i + 1) == $ranges) { $range['end'] = ($range['start'] + $rpages) - 1; } else { $range['end'] = (($i + 1)* $CONFIG['HNAV_BUTTONS']); $rpages -= $CONFIG['HNAV_BUTTONS']; } $ranges_array[$i] = $range; } /* generate nav buttons */ foreach($ranges_array as $range){ if ($currentPage >= $range['start'] && $currentPage <= $range['end']) { for ($i = $range['start']; ; $i++) { if ($i > $range['end']) { break; } else { if ($i == $currentPage) { $historyFooter .= "{$i} \n"; } else { $historyFooter .= "{$i} \n"; } } } } } $DATA['HISTORY_FOOTER'] = $historyFooterBegin . $historyFooter .$historyFooterEnd; $DATA['HPAGES'] = $pages; $DATA['HPAGE'] = $currentPage; /* $DATA['HISTORY'] .= "
["; if (($history_pages > 1) && ($history_page > 1)) { $i = $history_page - 1; $DATA['HISTORY'] .= " < "; } for($i = 1; $i <= $history_pages; $i++) { if ($i == $history_page) { $DATA['HISTORY'] .= " $i "; } else { $DATA['HISTORY'] .= " {$i} "; } } if (($history_pages > 1) && ($history_page < $history_pages)) { $i = $history_page + 1; $DATA['HISTORY'] .= " > "; } $DATA['HISTORY'] .= "]
"; */ } // end if } /* ========================================================================== */ /* = A N A L Y S I S F U N C T I O N S = */ /* ========================================================================== */ function &DisplayAnalysis() { global $USER, $CURRENT_USER, $CONFIG, $DATA; $LOG = "{$USER}.log"; $Stats = array( "daily" => array(), "weekly" => array() ); list(, $min, $hour, $mday, $mon, $year, , ,) = (localtime(time())); $daystart = mktime(0, 0, 0, $mon, $mday, $year); $periodstart = $daystart - (3600 * 24 * 13); /* 2 Weeks ago */ $dailystart = time() - (3600 * 23); /* TODO: There's an issue that the Perl timelocal returns * different values compared to PHP's mktime. There's a * difference of 2678400, which will be added manually below. */ $daystart += 2678400; $periodstart += 2678400; if (file_exists($LOG)) { if ($fd = @fopen($LOG, "r")) { $scount = 0; $icount = 0; $wcount = 0; $fcount = 0; $mcount = 0; while(!feof($fd)) { $buffer = fgets($fd, 4096); /* drop blank lines */ if (strlen($buffer) == 0) { continue; } list($t_log, $c_log) = preg_split("/\t/", $buffer); /* Only Parse Log Data in our Time Period */ /* TODO: The below if should evaluate to true at least for some data */ if ($t_log >= $periodstart) { list(, $tmin, $thour, $tday, $tmon, , , ,) = (localtime($t_log)); $tmon++; foreach (array('weekly', 'daily') as $period) { $idx = 0; if ($period == "weekly") { $idx= "{$tmon}/{$tday}"; } else { if ($t_log <= $dailystart) { continue; } $idx = To12Hour($thour); } if (is_array($Stats[$period]) && ! array_key_exists ($idx, $Stats[$period])) { $Stats[$period][$idx] = array( 'nonspam' => 0, 'spam' => 0, 'title' => $idx, 'idx' => $t_log); } /* TODO: Is passing by reference here correct? */ $hr =& $Stats[$period][$idx]; /* S => spam */ if ($c_log== "S") { $hr['spam']++; $scount++; } /* I => innocent W => whitelisted */ if ($c_log == "I" || $c_log == "W") { $hr['nonspam']++; if ($c_log == "I") { $icount++; } else { $wcount++; } } /* F => false positive */ if ($c_log == "F") { $hr['spam']--; if ($hr['spam'] < 0) { $hr['spam'] = 0; } $hr['nonspam']++; $fcount++; } /* M => spam miss */ if ($c_log == "M") { $hr['nonspam']--; if ($hr['nonspam'] < 0) { $hr['nonspam'] = 0; } $hr['spam']++; $mcount++; } } } } fclose($fd); } else { return $input_errors[] = "Unable to open log file: {$LOG}."; } usort ((array_values ($Stats[$period])), "cmpArrayValues"); foreach (array('weekly', 'daily') as $period) { $uc_period = strtoupper($period); $hk = "DATA_{$uc_period}"; $lst = array(); foreach (array_values($Stats[$period]) as $hr) { foreach (array('spam', 'nonspam', 'title') as $type ) { if (empty($lst[$type])) { $lst[$type] = array(); } /* populate (newly) created array */ $lst[$type][] = $hr[$type]; $totk=""; if ($type == "spam") { $totk="S"; } else if ($type == "nonspam") { $totk="I"; } if ($totk == "") { continue; } $sk="T{$totk}_{$uc_period}"; if (empty($DATA[$sk])) { $DATA[$sk] = 0; } $DATA[$sk] += $hr[$type]; } } // end foreach $DATA[$hk] = @join(",",$lst['spam']) . "_" . @join(",",$lst['nonspam']) . "_" . @join(",",$lst['title']); } // end foreach } else { return $input_errors[] = "No historical data is available (log file »{$LOG}« does not exist)."; } // end if } function cmpArrayValues($a, $b) { if ($a['idx'] == $b['idx']) return 0; return ($a['idx'] < $b['idx']) ? -1 : 1; } /* ========================================================================== */ /* = P E R E F E R E N C E S F U N C T I O N S = */ /* ========================================================================== */ function &DisplayPreferences($mode = "", &$statusmsg){ global $USER, $CURRENT_USER, $CONFIG, $DATA; $FILE = "{$USER}.prefs"; $username = $CURRENT_USER; if ($_POST) { $pconfig = $_POST; if ($pconfig['chk_feature_nr'] <> "on") { $pconfig['chk_feature_nr'] = "off"; } if ($pconfig['chk_feature_optin'] <> "on") { $pconfig['chk_feature_optin'] = "off"; } if ($pconfig['chk_feature_optout'] <> "on") { $pconfig['chk_feature_optout'] = "off"; } if ($pconfig['chk_feature_at'] <> "on") { $pconfig['chk_feature_at'] = "off"; } if ($pconfig['chk_feature_aw'] <> "on") { $pconfig['chk_feature_aw'] = "off"; } if ($CONFIG['PREFERENCES_EXTENSION'] == 1) { if ($pconfig['msgtag'] == "") { $pconfig['msgtag'] = "''"; } else { $pconfig['msgtag'] = quotemeta($pconfig['msgtag']); } exec("{$CONFIG['DSPAM_BIN']}/dspam_admin ch pref " . quotemeta($username) . " trainingMode " . quotemeta($pconfig['rad_train']) . " > /dev/null"); exec("{$CONFIG['DSPAM_BIN']}/dspam_admin ch pref " . quotemeta($username) . " spamAction " . quotemeta($pconfig['rad_train_action']) . " > /dev/null"); exec("{$CONFIG['DSPAM_BIN']}/dspam_admin ch pref " . quotemeta($username) . " signatureLocation " . quotemeta($pconfig['signatureLocation']) . " > /dev/null"); exec("{$CONFIG['DSPAM_BIN']}/dspam_admin ch pref " . quotemeta($username) . " spamSubject " . quotemeta($pconfig['msgtag']) . " > /dev/null"); exec("{$CONFIG['DSPAM_BIN']}/dspam_admin ch pref " . quotemeta($username) . " statisticalSedation " . quotemeta($pconfig['rad_filter_sens']) . " > /dev/null"); exec("{$CONFIG['DSPAM_BIN']}/dspam_admin ch pref " . quotemeta($username) . " enableBNR " . quotemeta($pconfig['chk_feature_nr']) . " > /dev/null"); exec("{$CONFIG['DSPAM_BIN']}/dspam_admin ch pref " . quotemeta($username) . " optOut " . quotemeta($pconfig['chk_feature_optout']) . " >/dev/null"); exec("{$CONFIG['DSPAM_BIN']}/dspam_admin ch pref " . quotemeta($username) . " optIn " . quotemeta($pconfig['chk_feature_optin']) . " >/dev/null"); exec("{$CONFIG['DSPAM_BIN']}/dspam_admin ch pref " . quotemeta($username) . " showFactors " . quotemeta($pconfig['chk_feature_at']) . " > /dev/null"); exec("{$CONFIG['DSPAM_BIN']}/dspam_admin ch pref " . quotemeta($username) . " enableWhitelist " . quotemeta($pconfig['chk_feature_aw']) . " > /dev/null"); } else { $prefsstr = << 0) { if ($mode == 0) { $mode = 1; } else { continue; } } $buff = array_shift($buffer); if (preg_match('/^From /', $buff) == 0) { array_push($temp, $buff); } continue; } foreach($temp as $tempel) { if ($tempel == "") { break; } list($key, $val) = preg_split('/\: ?/', $tempel, 2); $head[$key] = $val; } if ($head['X-DSPAM-Signature'] == $sigID) { $found = 1; $old_erep = error_reporting(E_ALL); if ($pd = @popen("|{$CONFIG['DSPAM']} {$CONFIG['DSPAM_ARGS']} >{$TMPFILE} 2>&1", "w")) { $pdresult = fread($handle, 2096); foreach($temp as $tempel) { fwrite($pd, "{$tempel}\n"); } pclose($pd); error_reporting($old_erep); } else { $error = true; $input_errors[] = "Unable to ope process pipe in function ProcessFalsePositive."; } } } /* Couldn't find the message, so just retrain on signature */ if (!$found) { system("$CONFIG{'DSPAM'} --source=error --class=innocent --signature=" . quotemeta($sigID) . " --user " . quotemeta($CURRENT_USER)); } if ($error) { $log = array(); $fd = fopen("{$TMPFILE}", "r"); while (!feof($handle)) { $log .= fgets($fd, 4096); } fclose($fd); unlink("{$TMPFILE}"); return $input_errors[] = $log; } unlink("{$TMPFILE}"); $signatures[$sigID] = "on"; return QuarantineDeleteSpam("", $signatures, $sortBy, $currentPage, $qPerPage); } function &QuarantineManyNotSpam($signatures = array(), $sortBy = "Rating", $currentPage = 1, $qPerPage = 0){ global $MAILBOX, $USER; $buffer = array(); $errors = array(); /* read the user's mailbox line by line into a buffer */ $fd = fopen("{$MAILBOX}", "r"); while (!feof($fd)) { $line = chop(fgets($fd, 4096)); array_push($buffer, $line); } fclose ($fd); if ($fd_FILE = @fopen("{$MAILBOX}", "w")) { $fd_RETRAIN = fopen("{$USER}.retrain.log", "a"); /* iterate over the mailbox buffer */ reset($buffer); $i = 0; while ($i < count($buffer)) { $temp = array(); $head = array(); $mode = 0; $buff = ""; /* this while tries to iterate over one single mesage including * the message header and the message body. */ while((preg_match('/^From /', $buff) == 0) && ($i < count($buffer))) { $buff = $buffer[0]; /* switch mode if we are hitting DSPAMs * pseudo From QUARANTINE line (without a * colon after the From). */ if (preg_match('/^From /', $buff) > 0) { if ($mode == 0) { $mode = 1; $buff = array_shift($buffer); array_push($temp, $buff); $buff = ""; continue; } else { continue; } } $buff = array_shift($buffer); array_push($temp, $buff); continue; } /* populate the header array with header fields */ foreach($temp as $tempel) { if ($tempel == "") { break; } list($key, $val) = preg_split('/\: ?/', $tempel, 2); $head[$key] = $val; } $delivered = 0; if ($signatures["chkmsg-{$head['X-DSPAM-Signature']}"] <> "") { $err = Deliver($temp); if ($err == "") { $delivered = 1; } else { array_push($errors, $err); } } if (!$delivered) { foreach($temp as $tempel) { fwrite($fd_FILE, "{$tempel}\n"); } } else { fwrite($fd_RETRAIN, strval(time()) . "\t{$head['X-DSPAM-Signature']}\tinnocent\n"); } $i++; } // end while fclose($fd_FILE); fclose($fd_RETRAIN); } else { return $input_errors[] = "Unable to open mailbox file: {$MAILBOX}."; } if (count($errors) > 0) { return $errors; } return DisplayQuarantine($sortBy, $currentPage, $qPerPage); } function Deliver($temp = array()) { global $CONFIG; if (! file_exists("/tmp/dspam-error-output.txt")) { touch("/tmp/dspam-error-output.txt"); } $descriptorspec = array( 0 => array("pipe", "r"), // stdin is a pipe that the child will read from 1 => array("pipe", "w"), // stdout is a pipe that the child will write to 2 => array("file", "/tmp/dspam-error-output.txt", "a") // stderr is a file to write to ); list($dev,$ino,$mode,$nlink,$uid,$gid,$rdev,$sizeb, $atime,$mtimeb,$ctime,$blksize,$blocks) = stat("/tmp/dspam-error-output.txt"); clearstatcache(); $cwd = '/tmp'; $process = @proc_open("{$CONFIG['DSPAM']} {$CONFIG['DSPAM_ARGS']}", $descriptorspec, $pipes); if (is_resource($process)) { foreach($temp as $tempel) { if (! @fwrite($pipes[0], "{$tempel}\n")) { return "error while writting to pipe."; } } fclose($pipes[0]); fclose($pipes[1]); $return_value = proc_close($process); /* this isn't an elegant solution to determine whether * DSPAM did report some errors, but it works for now */ list($dev,$ino,$mode,$nlink,$uid,$gid,$rdev,$sizea, $atime,$mtimea,$ctime,$blksize,$blocks) = stat("/tmp/dspam-error-output.txt"); if ($mtimeb <> $mtimea) { return "DSPAM did report some errors to /tmp/dspam-error-output.txt.\n" . "Please check this particular file."; } } else { return "process is not a resource type."; } return ""; } function getLayoutedMessage($msgbuffer = "", $sigID = "", $showpart = 0, $ctype = 0){ if ($msgbuffer == "") { return 'An error occured while parsing the message (no message).'; } if ($sigID == "") { return 'An error occured while parsing the message (no signature).'; } if( extension_loaded( 'mailparse' ) ) { $msgdate = "N/A"; $msgfrom = "N/A"; $msgsub = "N/A"; $msgto = "N/A"; $mime = mailparse_msg_create(); mailparse_msg_parse($mime, $msgbuffer); /* return an array of message parts - this contsists of the * names of the parts only. */ $struct = mailparse_msg_get_structure($mime); $htmlstr = << Message Infos Date: %MSGDATE% From: %MSGFROM% Subject: %MSGSUB% To: %MSGTO%   Message Part Part Type Part Encoding EOD; /* print a choice of sections */ foreach($struct as $st) { /* get a handle on the message resource for a subsection */ $section = mailparse_msg_get_part($mime, $st); /* get content-type, encoding and header information for that section */ $info = mailparse_msg_get_part_data($section); /* replace placeholder with real data */ if ($info['headers']['date'] <> "") { $htmlstr = str_replace("%MSGDATE%", $info['headers']['date'], $htmlstr); } if ($info['headers']['from'] <> "") { $htmlstr = str_replace("%MSGFROM%", $info['headers']['from'], $htmlstr); } if ($info['headers']['subject'] <> "") { $htmlstr = str_replace("%MSGSUB%", $info['headers']['subject'], $htmlstr); } if ($info['headers']['to'] <> "") { $htmlstr = str_replace("%MSGTO%", $info['headers']['to'], $htmlstr); } $fontStyle = ""; if ($showpart && $showpart == $st) { $fontStyle = " style=\"font-weight: bolder;\""; } if ($info["content-type"] == "text/html") { $htmlstr .= "" . "{$st}" . "\n"; } else { $htmlstr .= "" . "{$st}" . "\n"; } $htmlstr .= <<{$info["content-type"]} {$info["charset"]} EOD; } // end foreach /* if we were called to display a part, do so now */ if ($showpart) { /* get a handle on the message resource for the desired part */ $sec = mailparse_msg_get_part($mime, $showpart); $htmlstr .= <<   Section {$showpart} EOD; ob_start(); mailparse_msg_extract_part($sec, $msgbuffer); $contents = ob_get_contents(); ob_end_clean(); $contents = wordwrap( str_replace(">", ">\n", $contents), 100, "\n" ); /* quote the message for safe display in a browser */ if ($ctype = 1) { /* a html email message */ $htmlstr .= "
" . $contents . "
\n\n"; } else { /* an ASCII (text) email message */ $htmlstr .= htmlentities($contents) . "\n\n"; } } return $htmlstr; } else { return 'Could not load mailparse extension.'; } } function &QuarantineViewMessage($sigID = "", $showpart = 0, $ctype = 0, $sortBy = "Rating", $currentPage = 1, $qPerPage = 0) { global $MAILBOX, $DATA; $buffer = array(); // mailbox buffer if ($sigID == "") { return $input_errors[] = "No Message ID Specified."; } /* save data to be displayed as HTML form data */ $DATA['MESSAGE_ID'] = $sigID; $DATA['SHOWPART'] = $showpart; $DATA['CONTENT_TYPE'] = $ctype; $DATA['QPAGE'] = $currentPage; $DATA['SORTBY'] = $sortBy; if ($qPerPage > 0) { $CONFIG['QUARANTINE_PER_PAGE'] = $qPerPage; } /* read the user's mailbox line by line into a buffer */ $fd = fopen("{$MAILBOX}", "r"); while (!feof($fd)) { $line = chop(fgets($fd, 4096)); array_push($buffer, $line); } fclose ($fd); /* iterate over the mailbox buffer */ reset($buffer); $i = 0; while ($i < count($buffer)) { $temp = array(); $head = array(); $mode = 0; $buff = ""; /* this while tries to iterate over one single mesage including * the message header and the message body. */ while((preg_match('/^From /', $buff) == 0) && ($i < count($buffer))) { $buff = $buffer[0]; /* switch mode if we are hitting DSPAMs * pseudo From QUARANTINE line (without a * colon after the From). */ if (preg_match('/^From /', $buff) > 0) { if ($mode == 0) { $mode = 1; } else { continue; } } $buff = array_shift($buffer); if (preg_match('/^From /', $buff) == 0) { array_push($temp, $buff); } continue; } /* populate the header array with header fields */ foreach($temp as $tempel) { if ($tempel == "") { break; } list($key, $val) = preg_split('/\: ?/', $tempel, 2); $head[$key] = $val; } if ($head['X-DSPAM-Signature'] == $sigID) { foreach($temp as $tempel) { $tempel = preg_replace("//e", "'>'", $tempel); $DATA['MESSAGE'] .= "{$tempel}\n"; } } $i ++; } // end while } function QuarantineDeleteSpam($deleteAll = "", $signatures = array(), $sortBy = "Rating", $currentPage = 1, $qPerPage = 0){ global $USER, $MAILBOX; $buffer = array(); /* this is the most easiest operation: If the user wants * to completly delete any quarantined message, simply * open his mailbox in write mode, which empties the * user's mailbox file. */ if ($deleteAll <> "") { list($dev,$ino,$mode,$nlink,$uid,$gid,$rdev,$size, $atime,$mtime,$ctime,$blksize,$blocks) = stat("{$USER}.mbox"); $fd = fopen("{$USER}.mbox.size", "r"); $sz = chop(fgets($fd, 4096)); fclose($fd); if ($sz == $size) { $fd = fopen("{$MAILBOX}", "w"); fclose($fd); unlink("{$USER}.mbox.size"); unlink("{$USER}.mboxwarn"); } else { return DisplayQuarantine($sortBy, $currentPage, $qPerPage); } //$FORM{'template'} = "performance"; CheckQuarantine(); return DisplayIndex(); } /* iterate over the user's mailbox and store its contents in a buffer */ $fd = fopen("{$MAILBOX}", "r"); while (!feof($fd)) { $line = chop(fgets($fd, 4096)); array_push($buffer, $line); } fclose($fd); /* open the user's mailbox in write mode. This empties the mailbox! */ fopen("{$MAILBOX}", "w"); /* iterate over the mailbox buffer */ reset($buffer); $i = 0; while ($i < count($buffer)) { $temp = array(); $head = array(); $mode = 0; /* this while tries to iterate over one single mesage including * the message header and the message body. */ while((preg_match('/^From /', $buff) == 0) && ($i < count($buffer))) { $buff = $buffer[0]; /* switch mode if we are hitting DSPAMs * pseude From QUARANTINE line (without a * colon after the From). */ if (preg_match('/^From /', $buff) > 0) { if ($mode == 0) { $mode = 1; $buff = array_shift($buffer); array_push($temp, $buff); $buff = ""; continue; } else { continue; } } $buff = array_shift($buffer); array_push($temp, $buff); continue; } /* populate the header array with header fields */ foreach($temp as $tempel) { if ($tempel == "") { break; } list($key, $val) = preg_split('/\: ?/', $tempel, 2); $head[$key] = $val; } /* if the current DSPAM signature wasn't selected by the * user to be deleted, write it back to the user's mailbox. */ if ($signatures["chkmsg-{$head['X-DSPAM-Signature']}"] == "") { foreach($temp as $tempel) { fwrite($fd, "{$tempel}\n"); } } $i++; } // end while fclose($fd); return; } function sortBySubject($a, $b){ $lca = strtolower ($a['Subject']); $lcb = strtolower ($b['Subject']); return strcmp($lca, $lcb); } function sortByFrom($a, $b){ $lca = strtolower ($a['From']); $lcb = strtolower ($b['From']); return strcmp($lca, $lcb); } function &DisplayQuarantine($sortBy = "Rating", $currentPage = 1, $qPerPage = 0) { global $USER, $CURRENT_USER, $CONFIG, $DATA, $MAILBOX; $alertcfg = &$config['installedpackages']['dspamalerts']['config']; $alerts = array(); if (file_exists("{$USER}.mbox")) { list($dev,$ino,$mode,$nlink,$uid,$gid,$rdev,$size, $atime,$mtime,$ctime,$blksize,$blocks) = stat("{$USER}.mbox"); $fd = fopen("{$USER}.mbox.size", "w"); fwrite($fd, "{$size}"); fclose($fd); $fd = fopen("{$MAILBOX}.stamp", "a+"); fclose($fd); chmod("{$MAILBOX}.stamp", 0660); /* process alert names */ if (is_array($alertcfg)) { $alert_counter = 0; foreach ($alertcfg as $alert) { $alerts[$alert_counter] = $alert['alertname']; $alert_counter++; } } $mode = ""; $buffer = array(); $headings = array(); $rowclass = "qrowEven"; $fd = fopen("{$MAILBOX}", "r"); while (!feof($fd)) { $mbxline = chop(fgets($fd, 4096)); if ($mbxline <> "") { if (($mode == "")) { if (preg_match('/^From /', $mbxline) > 0) { $mode = 1; } else { continue; } } array_push($buffer, $mbxline); continue; } if ($mode == "") { continue; } $alert = 0; $new = array(); foreach($buffer as $buf_element){ foreach($alerts as $al){ if (preg_match("/{$al}/i", $buf_element) > 0) { $alert = 1; } } if (preg_match('/^From /', $buf_element) > 0) { $a = split(' ', $buf_element); $x = 2; for ($i = 0; $i < count ($a); $i++) { if ((preg_match('/\@|>/', $a[$i]) > 0) && $i > $x) { $x = $i + 1; } } for ($i = 1; $i < $x; $i++) { array_shift($a); } $start = join(" ", $a); } else { list($key, $val) = preg_split('/\: ?/', $buf_element, 2); $new[$key] = $val; } } if ($rowclass == "qrowEven") { $rowclass = "qrowOdd"; } else { $rowclass = "qrowEven"; } $new['alert'] = $alert; if ($alert) { $rowclass="qrowAlert"; } $new['Sub2'] = $new['X-DSPAM-Signature']; if (strlen($new['Subject']) > $CONFIG['MAX_COL_LEN']) { $new['Subject'] = substr($new['Subject'], 0, $CONFIG['MAX_COL_LEN']) . "..."; } if (strlen($new['From']) > $CONFIG['MAX_COL_LEN']) { $new['From'] = substr($new['From'], 0, $CONFIG['MAX_COL_LEN']) . "..."; } if ($new['Subject'] == "") { $new['Subject'] = ""; } //$new->{'rating'} = $new->{'X-DSPAM-Probability'} * $new->{'X-DSPAM-Confidence'}; $new['rating'] = $new['X-DSPAM-Confidence']; foreach(array_keys($new) as $key) { if ($key == "X-DSPAM-Signature") { continue; } preg_replace('//', '/\>\;/', $new[$key]); } array_push($headings, $new); $buffer = array(); $mode = ""; continue; } // end while (!feof($fd)) if (! isset($sortBy) || $sortBy == "") { $sortBy = $CONFIG['SORT_DEFAULT']; } if ($sortBy == "Rating") { usort($headings, "sortByRating"); } if ($sortBy == "Subject") { usort($headings, "sortBySubject"); } if ($sortBy == "From") { usort($headings, "sortByFrom"); } if ($sortBy == "Date") { array_reverse ($headings); } /*   Rating Date From Subject */ $DATA['SORTBY'] = $sortBy; $DATA['SORT_SELECTOR'] .= <<   EOD; if ($sortBy == "Rating") { $DATA{'SORT_SELECTOR'} .= "Rating  ◊"; } else { $DATA{'SORT_SELECTOR'} .= "Rating"; } if ($sortBy == "Date") { $DATA{'SORT_SELECTOR'} .= "Date  ◊"; } else { $DATA{'SORT_SELECTOR'} .= "Date"; } if ($sortBy == "Subject") { $DATA{'SORT_SELECTOR'} .= "Subject  ◊"; } else { $DATA{'SORT_SELECTOR'} .= "Subject"; } if ($sortBy == "From") { $DATA{'SORT_SELECTOR'} .= "From  ◊"; } else { $DATA{'SORT_SELECTOR'} .= "From"; } $DATA{'SORT_SELECTOR'} .= "\n "; if (isset($qPerPage) && $qPerPage > 0) { $CONFIG['QUARANTINE_PER_PAGE'] = $qPerPage; } if (isset($currentPage) && isset($CONFIG['QUARANTINE_PER_PAGE'])) { $pages = ceil( (count ($headings) / $CONFIG['QUARANTINE_PER_PAGE']) ); $begin = (($currentPage - 1) * $CONFIG['QUARANTINE_PER_PAGE']); $ranges = ceil ($pages / $CONFIG['QNAV_BUTTONS']); /* Now lets just keep the information that we really need. */ $headings = array_splice ($headings, $begin, $CONFIG['QUARANTINE_PER_PAGE']); } $rowclass = "qrowEven"; foreach ($headings as $row) { $rating = sprintf("%3.0f%%", $row['rating'] * 100.0); if ($row['rating'] > 0.8) { $markclass = "high"; } else { if ($row['rating'] < 0.7) { $markclass = "low"; } else { $markclass = "medium"; } } $PAIRS = array(); $PAIRS['signatureID'] = $row['X-DSPAM-Signature']; $PAIRS['command'] = "viewMessage"; $PAIRS['user'] = $CURRENT_USER; $PAIRS['page'] = $currentPage; $PAIRS['sortby'] = $sortBy; $PAIRS['qperpage'] = $CONFIG['QUARANTINE_PER_PAGE']; // $PAIRS['template'] = "quarantine"; $url = SafeVars($PAIRS); $sender = htmlentities ($row['From']); $rsubject = htmlentities ($row['Subject']); if ($row['alert']) { $outclass = "qrowAlert"; } else { $outclass = $rowclass; } $ptfields = preg_split('/\s+/', $row['X-DSPAM-Processed']); $times = preg_split('/\:/', $ptfields[3]); $ptime = ""; if($CONFIG["DATE_FORMAT"]) { $month = array(); $month['Jan'] = 0; $month['Feb'] = 1; $month['Mar'] = 2; $month['Apr'] = 3; $month['May'] = 4; $month['Jun'] = 5; $month['Jul'] = 6; $month['Aug'] = 7; $month['Sep'] = 8; $month['Oct'] = 9; $month['Nov'] = 10; $month['Dec'] = 11; $ptime = strftime($CONFIG["DATE_FORMAT"], mktime($times[2], $times[1], $times[0], $ptfields[2], $month[$ptfields[1]], $ptfields[4] - 1900)); } else { $mer = "a"; if ($times[0] > 12) { $times[0] -= 12; $mer = "p"; } if ($times[0] == 0) { $times[0] = "12"; } $ptime = "{$ptfields[1]} {$ptfields[2]} {$times[0]}:{$times[1]}{$mer}"; } /* 50% Apr 1 05:59a Mar 30 11:08a Last chance to register for Frankfurt, 4 April BEA... {$rating} {$ptime} {$row['From']} {$row['Subject']} */ $DATA['QUARANTINE'] .= << {$rating} {$ptime} {$sender} {$rsubject} EOD; if ($rowclass == "qrowEven") { $rowclass = "qrowOdd"; } else { $rowclass = "qrowEven"; } } // end foreach ($headings as $row) /* prepare quarantine navbar */ if (($currentPage - 1) >= 1) { $previousPage = $currentPage - 1; } else { $previousPage = 1; } if (($currentPage + 1) <= $pages) { $nextPage = $currentPage + 1; } else { $nextPage = $pages; } $quarantineFooterBegin = << |<  <  EOD; $quarantineFooterEnd = <<>  >| EOD; $ranges_array = array(); $rpages = $pages; for ($i = 0; $i < $ranges; $i++) { $range = array(); $range['start'] = (($i + 1)* $CONFIG['QNAV_BUTTONS']) - ($CONFIG['QNAV_BUTTONS'] - 1); if (($i + 1) == $ranges) { $range['end'] = ($range['start'] + $rpages) - 1; } else { $range['end'] = (($i + 1)* $CONFIG['QNAV_BUTTONS']); $rpages -= $CONFIG['QNAV_BUTTONS']; } $ranges_array[$i] = $range; } /* generate nav buttons */ foreach($ranges_array as $range){ if ($currentPage >= $range['start'] && $currentPage <= $range['end']) { for ($i = $range['start']; ; $i++) { if ($i > $range['end']) { break; } else { if ($i == $currentPage) { $quarantineFooter .= "{$i} \n"; } else { $quarantineFooter .= "{$i} \n"; } } } } } $DATA['QUARANTINE_FOOTER'] = $quarantineFooterBegin . $quarantineFooter .$quarantineFooterEnd; $DATA['QPAGES'] = $pages; $DATA['QPAGE'] = $currentPage; } else { $input_errors[] = "Unable to open DSPAM quarantine mailbox at »{$USER}.mbox«. " . "If you are a DSPAM admin user you can savely " . "ignore this error because such users usually do not " . "have a DSPAM mailbox/quarantine."; } return $input_errors; } /* ========================================================================== */ /* = P E R F O R M A N C E F U N C T I O N S = */ /* ========================================================================== */ function ResetStats() { global $USER; $fd = fopen("{$USER}.stats", "r"); $ts = chop(fgets($fd, 4096)); $group = chop(fgets($fd, 4096)); fclose($fd); list($ts, $ti, $tm, $fp, $sc, $ic) = split(",", $ts); if ($group <> "") { $GROUP = GetPath($group) . ".stats"; $fd = fopen("{$GROUP}", "r"); $gts = chop(fgets($fd, 4096)); fclose($fd); list ($gts, $gti, $gtm, $gfp, $gsc, $gic) = split(",", $gts); $ts -= $gts; $ti -= $gti; $tm -= $gtm; $fp -= $gfp; $sc -= $gsc; $ic -= $gic; } $fd = fopen("{$USER}.rstats", "w"); fputs($fd, "{$ts}" . "," . "{$ti}" . "," . "{$tm}" . "," . "{$fp}" . "," . "{$sc}" . "," . "{$ic}\n"); fclose($fd); } function Tweak() { global $USER; $fd = fopen("{$USER}.rstats", "r"); $ts = chop(fgets($fd, 4096)); $group = chop($fgets($fd, 4096)); fclose($fd); list($ts, $ti, $tm, $fp, $sc, $ic) = split(",", $ts); $tm++; $fd = fopen("{$USER}.rstats", "w"); fputs($fd, "{$ts},{$ti},{$tm},{$fp},{$sc},{$ic}\n"); fclose($fd); } function &DisplayIndex() { global $USER, $CONFIG, $DATA, $CURRENT_STORE, $CURRENT_USER; if (strpos ($CURRENT_USER, "@") === false) { if (GetDomain($CURRENT_STORE) <> "") $domain = GetDomain($CURRENT_STORE); else $domain = $config['system']['domain']; $spamalias = "spam-{$CURRENT_USER}@{$domain}"; } else { $spamalias = "spam-{$CURRENT_USER}"; } if ($handle = @fopen ("{$USER}.stats", "r")) { $spam .= chop(fgets($handle, 4096)); $group .= chop(fgets($handle, 4096)); fclose($handle); list($spam, $innocent, $misses, $fp, $sc, $ic) = split(",", $spam); if ($group <> "") { $GROUP = GetPath($group) . ".stats"; $fd = fopen("{$GROUP}", "r"); $gspam = chop(fgets($fd, 4096)); fclose($fd); list($gspam, $ginnocent, $gfp, $gmisses, $gsc, $gic) = preg_split('/\,/', $gspam); $spam -= $gspam; $innocent -= $ginnocent; $misses -= $gmisses; $fp -= $gfp; $sc -= $gsc; $ic -= $gic; } if ($spam + $innocent > 0) { $ratio = sprintf("%2.3f", (($spam+$misses)/($spam+$misses+$fp+$innocent)*100)); } else { $ratio = 0; } if (file_exists("{$USER}.rstats")) { $handle = fopen ("{$USER}.rstats", "r"); $buffer = chop(fgets($handle, 4096)); fclose ($handle); list($rts, $rti, $rtm, $rfp) = split(",", $buffer); $real_missed = $misses - $rtm; $real_caught = $spam - $rts; $real_fp = $fp - $rfp; if ($real_fp < 0) { $real_fp = 0; } $real_innocent = $innocent - $rti; if (($spam - $rts > 0) && ($spam - $rts + $misses - $rtm != 0) && ($real_caught + $real_missed > 0) && ($real_fp + $real_innocent > 0)) { $monthly = sprintf("%2.3f", (100.0-(($real_missed)/($real_caught+$real_missed))*100.0)); $overall = sprintf("%2.3f", (100-((($real_missed+$real_fp) / ($real_fp+$real_innocent+$real_caught+$real_missed))*100))); } else { if ($real_caught == 0 && $real_missed > 0) { $monthly = 0; $overall = 0; } else { $monthly = 100; $overall = 100; } } if ($real_fp + $real_innocent > 0) { $fpratio = sprintf("%2.3f", ($real_fp/($real_fp+$real_innocent)*100)); } else { $fpratio = 0; } } else { $rts = $spam + $misses; $rti = $innocent; $rtm = $misses; $rfp = $fp; $handle = fopen ("{$USER}.rstats", "w"); fwrite("{$rts},{$rti},{$rtm},{$rfp}\n"); fclose($handle); $monthly = "N/A"; $fpratio = "N/A"; $overall = "N/A"; } $DATA['TIME'] = $time; $DATA['TOTAL_SPAM_SCANNED'] = $spam; $DATA['TOTAL_SPAM_LEARNED'] = $misses; $DATA['TOTAL_NONSPAM_SCANNED'] = $innocent; $DATA['TOTAL_NONSPAM_LEARNED'] = $fp; $DATA['SPAM_RATIO'] = $ratio; $DATA['SPAM_ACCURACY'] = $monthly; $DATA['NONSPAM_ERROR_RATE'] = $fpratio; $DATA['OVERALL_ACCURACY'] = $overall; $DATA['TOTAL_SPAM_CORPUSFED'] = $sc; $DATA['TOTAL_NONSPAM_CORPUSFED'] = $ic; $DATA['TOTAL_SPAM_MISSED'] = $real_missed; $DATA['TOTAL_SPAM_CAUGHT'] = $real_caught; $DATA['TOTAL_NONSPAM_MISSED'] = $real_fp; $DATA['TOTAL_NONSPAM_CAUGHT'] = $real_innocent; $DATA['SPAM_ALIAS'] = $spamalias; $DATA['LOCAL_DOMAIN'] = $CONFIG['LOCAL_DOMAIN']; } else { $DATA['SPAM_ACCURACY'] = "N/A"; $DATA['NONSPAM_ERROR_RATE'] = "N/A"; $DATA['OVERALL_ACCURACY'] = "N/A"; $DATA['SPAM_RATIO'] = "N/A"; $DATA['TOTAL_SPAM_MISSED'] = 0; $DATA['TOTAL_SPAM_CAUGHT'] = 0; $DATA['SPAM_RATIO'] = "N/A"; $DATA['TOTAL_NONSPAM_MISSED'] = 0; $DATA['TOTAL_NONSPAM_CAUGHT'] = 0; $DATA['NONSPAM_ERROR_RATE'] = "N/A"; $DATA['TOTAL_SPAM_LEARNED'] = 0; $DATA['TOTAL_SPAM_SCANNED'] = 0; $DATA['TOTAL_NONSPAM_LEARNED'] = 0; $DATA['TOTAL_NONSPAM_SCANNED'] = 0; $DATA['TOTAL_SPAM_CORPUSFED'] = 0; $DATA['TOTAL_NONSPAM_CORPUSFED'] = 0; $DATA['SPAM_ALIAS'] = $spamalias; $input_errors[] = "Unable to open DSPAM stats at »{$USER}.stats«. " . "If you are a DSPAM admin user you can savely " . "ignore this error because such users usually do not " . "have a DSPAM mailbox/quarantine."; } return $input_errors; } function getJScriptFunction($whichOne = 0) { $changeuser_msg = gettext("Do you realy want to change the current user?") . "\\n" . gettext("This requires a logout followed by a login."); switch ($whichOne) { case 0: $scriptstr = ' /* applicable for almost any dspam related page */ function changeuser() { check = confirm("' . $changeuser_msg . '"); if (check == true) window.location.href = "/index.php?logout=true"; } '; break; case 1: $scriptstr = ' /* applicable for dspam-quarantine.php */ function checkallmsgs(enable) { var endis = (document.iform.checkall.checked || enable); var elem = document.iform.elements.length; for (i = 0; i < elem; i++) { if (document.iform.elements[i].name.indexOf("chkmsg") >= 0) { document.iform.elements[i].checked = endis; } } } '; break; case 2: $scriptstr = ' /* applicable for dspam-quarantine.php */ function sortmsg(criterion) { var baseURL = "/dspam-quarantine.php?page=" + document.iform.qpage.value; var qperpage = document.getElementsByName("qperpage")[0].value; window.location.href = baseURL + "&qperpage=" + qperpage + "&sortby=" + criterion; } '; break; case 3: $scriptstr = ' /* applicable for dspam-quarantine.php */ function processmsg(what) { var elem = document.iform.elements.length; var checked = false; switch (what) { case 0: for (i = 0; i < elem; i++) { if (document.iform.elements[i].name.indexOf("chkmsg") >= 0 && document.iform.elements[i].checked == true) { checked = true; break; } } if (checked) { document.iform.processAction.value = "manyNotSpam"; } else { alert("You did not select any message that should be processed as not beeing Spam."); return false; } break; case 1: for (i = 0; i < elem; i++) { if (document.iform.elements[i].name.indexOf("chkmsg") >= 0 && document.iform.elements[i].checked == true) { checked = true; break; } } if (checked) { if (confirm("Are you sure you want to delete SELECTED messages in quarantine?") == false) { return false; } else { document.iform.processAction.value = "manySpam"; } } else { alert("You did not select any message that should be processed as beeing Spam."); return false; } break; case 2: if (confirm("Are you sure you want to delete ALL messages in quarantine?") == false) { return false; } else { document.iform.processAction.value = "deleteAll"; } break; } document.iform.submit(); } '; break; case 4: $scriptstr = ' /* applicable for dspam-quarantine.php nad dspam-history.php */ function changeQPerPage(originator) { var elementName = ""; var baseURL = ""; if (originator.name == "qperpage") { baseURL = "/dspam-quarantine.php?page=" + document.iform.qpage.value; elementName = "qperpage"; } else { baseURL = "/dspam-history.php?page=" + document.iform.hpage.value; elementName = "hperpage"; } for (var i = 0; i < 2; i++) { document.getElementsByName(elementName)[i].value = originator.value; } if (originator.name == "qperpage") window.location.href = baseURL + "&qperpage=" + originator.value; else window.location.href = baseURL + "&hperpage=" + originator.value; } '; break; case 5: $scriptstr = ' /* applicable for dspam-settings.php */ function fadeTableRow(rowid, fadeType, opts){ if(!opts){ opts = {}; } var row = $(rowid); var cells= row.childNodes; for(i=0;i