@@ -19,74 +19,74 @@ discard block |
||
| 19 | 19 | $user = username(); |
| 20 | 20 | |
| 21 | 21 | $opts = getopt('f:t:'); |
| 22 | -if ( isset($opts['f']) ) { |
|
| 22 | +if (isset($opts['f'])) { |
|
| 23 | 23 | $filetemplate = $opts['f']; |
| 24 | -} else { |
|
| 24 | +}else { |
|
| 25 | 25 | print "\nNo option for '-f' given.\n"; |
| 26 | - exit ( usage() ); |
|
| 26 | + exit (usage()); |
|
| 27 | 27 | } |
| 28 | 28 | |
| 29 | -if ( isset($opts['t']) ) { |
|
| 29 | +if (isset($opts['t'])) { |
|
| 30 | 30 | $tablename = $opts['t']; |
| 31 | -} else { |
|
| 31 | +}else { |
|
| 32 | 32 | print "\nNo option for '-t' given.\n"; |
| 33 | - exit ( usage() ); |
|
| 33 | + exit (usage()); |
|
| 34 | 34 | } |
| 35 | 35 | |
| 36 | -if ( ($typedescN = array_search( $tablename, array_column($tables, 'name'))) === FALSE ) { |
|
| 36 | +if (($typedescN = array_search($tablename, array_column($tables, 'name'))) === FALSE) { |
|
| 37 | 37 | print "\nDB <$tablename> doesn't exist!\n"; |
| 38 | - syslog (LOG_EMERG, "$user: DB <$tablename> doesn't exist!"); |
|
| 39 | - exit ( usage() ); |
|
| 38 | + syslog(LOG_EMERG, "$user: DB <$tablename> doesn't exist!"); |
|
| 39 | + exit (usage()); |
|
| 40 | 40 | } |
| 41 | 41 | $typedesc = array_keys($tables)[$typedescN]; |
| 42 | 42 | |
| 43 | -if (! file_exists($filetemplate) ) { |
|
| 43 | +if (!file_exists($filetemplate)) { |
|
| 44 | 44 | print "\nFile <$filetemplate> doesn't exists!\n"; |
| 45 | - syslog (LOG_EMERG, "$user: File <$filetemplate> doesn't exist!"); |
|
| 46 | - exit ( usage() ); |
|
| 45 | + syslog(LOG_EMERG, "$user: File <$filetemplate> doesn't exist!"); |
|
| 46 | + exit (usage()); |
|
| 47 | 47 | } |
| 48 | 48 | |
| 49 | -if (! in_array( $typedesc, array_keys($tables) ) ) { |
|
| 49 | +if (!in_array($typedesc, array_keys($tables))) { |
|
| 50 | 50 | print "\nUnknown list <$typedesc>. Please provide an existent list name.\n"; |
| 51 | - exit ( usage() ); |
|
| 51 | + exit (usage()); |
|
| 52 | 52 | } |
| 53 | 53 | |
| 54 | -if (! $tables["$typedesc"]['active'] ) { |
|
| 54 | +if (!$tables["$typedesc"]['active']) { |
|
| 55 | 55 | print "\nList <$typedesc> is not active. Please provide an active list name.\n"; |
| 56 | - exit ( usage() ); |
|
| 56 | + exit (usage()); |
|
| 57 | 57 | } |
| 58 | 58 | |
| 59 | 59 | |
| 60 | 60 | |
| 61 | -$now=new DateTime('NOW'); |
|
| 61 | +$now = new DateTime('NOW'); |
|
| 62 | 62 | $timeunix = $now->format('U'); |
| 63 | 63 | $dateRFC822 = $now->format('r'); |
| 64 | 64 | $year = $now->format('Y'); |
| 65 | -$rbltype= ($tables["$typedesc"]['bl']) ? 'Blocklist' : 'Whitelist'; |
|
| 65 | +$rbltype = ($tables["$typedesc"]['bl']) ? 'Blocklist' : 'Whitelist'; |
|
| 66 | 66 | |
| 67 | 67 | |
| 68 | 68 | $tmpl = file_get_contents($filetemplate); |
| 69 | -$arr_tpl_vars = array('{rblname}','{rbltype}','{date822}','{year}','{unixtimestamp}','{rblname64}','{hostname}'); |
|
| 70 | -$arr_tpl_data = array($typedesc,$rbltype,$dateRFC822,$year,$timeunix,base64_encode($typedesc),gethostname()); |
|
| 69 | +$arr_tpl_vars = array('{rblname}', '{rbltype}', '{date822}', '{year}', '{unixtimestamp}', '{rblname64}', '{hostname}'); |
|
| 70 | +$arr_tpl_data = array($typedesc, $rbltype, $dateRFC822, $year, $timeunix, base64_encode($typedesc), gethostname()); |
|
| 71 | 71 | $headerList = str_replace($arr_tpl_vars, $arr_tpl_data, $tmpl); |
| 72 | 72 | |
| 73 | 73 | |
| 74 | 74 | $mysqli = new mysqli($dbhost, $userdb, $pwd, $db, $dbport); |
| 75 | 75 | if ($mysqli->connect_error) { |
| 76 | - syslog (LOG_EMERG, $user.': Connect Error (' . $mysqli->connect_errno . ') ' |
|
| 76 | + syslog(LOG_EMERG, $user.': Connect Error ('.$mysqli->connect_errno.') ' |
|
| 77 | 77 | . $mysqli->connect_error); |
| 78 | - exit ($user.': Connect Error (' . $mysqli->connect_errno . ') ' |
|
| 78 | + exit ($user.': Connect Error ('.$mysqli->connect_errno.') ' |
|
| 79 | 79 | . $mysqli->connect_error); |
| 80 | 80 | } |
| 81 | 81 | |
| 82 | -syslog(LOG_INFO, $user.': Successfully mysql connected to ' . $mysqli->host_info) ; |
|
| 82 | +syslog(LOG_INFO, $user.': Successfully mysql connected to '.$mysqli->host_info); |
|
| 83 | 83 | |
| 84 | -$result = searchentry ($mysqli,'ALL',$tables["$typedesc"]); |
|
| 84 | +$result = searchentry($mysqli, 'ALL', $tables["$typedesc"]); |
|
| 85 | 85 | if ($result->num_rows) { |
| 86 | 86 | $element = array(); |
| 87 | 87 | while ($riga = $result->fetch_array(MYSQLI_ASSOC)) { |
| 88 | 88 | if (isListed($riga)) { |
| 89 | - switch ( $tables["$typedesc"]['field'] ) { |
|
| 89 | + switch ($tables["$typedesc"]['field']) { |
|
| 90 | 90 | case 'ip': |
| 91 | 91 | $element[] = long2ip($riga['ip']); |
| 92 | 92 | break; |
@@ -104,6 +104,6 @@ discard block |
||
| 104 | 104 | $mysqli->close(); |
| 105 | 105 | |
| 106 | 106 | /* Print to file */ |
| 107 | -file_put_contents( $tables["$typedesc"]['name'], $headerList . implode("\n",$element) ); |
|
| 107 | +file_put_contents($tables["$typedesc"]['name'], $headerList.implode("\n", $element)); |
|
| 108 | 108 | closelog(); |
| 109 | 109 | ?> |
@@ -1,8 +1,9 @@ |
||
| 1 | 1 | #!/usr/bin/php |
| 2 | 2 | <?php |
| 3 | 3 | |
| 4 | -if (PHP_SAPI != "cli") |
|
| 4 | +if (PHP_SAPI != "cli") { |
|
| 5 | 5 | exit; |
| 6 | +} |
|
| 6 | 7 | |
| 7 | 8 | $home = '/var/www/html/RBL'; |
| 8 | 9 | require_once($home.'/config.php'); |
@@ -2,7 +2,7 @@ discard block |
||
| 2 | 2 | <?php |
| 3 | 3 | |
| 4 | 4 | if (PHP_SAPI != "cli") |
| 5 | - exit; |
|
| 5 | + exit; |
|
| 6 | 6 | |
| 7 | 7 | $home = '/var/www/html/RBL'; |
| 8 | 8 | require_once($home.'/config.php'); |
@@ -20,30 +20,30 @@ discard block |
||
| 20 | 20 | |
| 21 | 21 | $opts = getopt('f:t:'); |
| 22 | 22 | if ( isset($opts['f']) ) { |
| 23 | - $filetemplate = $opts['f']; |
|
| 23 | + $filetemplate = $opts['f']; |
|
| 24 | 24 | } else { |
| 25 | 25 | print "\nNo option for '-f' given.\n"; |
| 26 | - exit ( usage() ); |
|
| 26 | + exit ( usage() ); |
|
| 27 | 27 | } |
| 28 | 28 | |
| 29 | 29 | if ( isset($opts['t']) ) { |
| 30 | - $tablename = $opts['t']; |
|
| 30 | + $tablename = $opts['t']; |
|
| 31 | 31 | } else { |
| 32 | 32 | print "\nNo option for '-t' given.\n"; |
| 33 | - exit ( usage() ); |
|
| 33 | + exit ( usage() ); |
|
| 34 | 34 | } |
| 35 | 35 | |
| 36 | 36 | if ( ($typedescN = array_search( $tablename, array_column($tables, 'name'))) === FALSE ) { |
| 37 | - print "\nDB <$tablename> doesn't exist!\n"; |
|
| 38 | - syslog (LOG_EMERG, "$user: DB <$tablename> doesn't exist!"); |
|
| 39 | - exit ( usage() ); |
|
| 37 | + print "\nDB <$tablename> doesn't exist!\n"; |
|
| 38 | + syslog (LOG_EMERG, "$user: DB <$tablename> doesn't exist!"); |
|
| 39 | + exit ( usage() ); |
|
| 40 | 40 | } |
| 41 | 41 | $typedesc = array_keys($tables)[$typedescN]; |
| 42 | 42 | |
| 43 | 43 | if (! file_exists($filetemplate) ) { |
| 44 | - print "\nFile <$filetemplate> doesn't exists!\n"; |
|
| 44 | + print "\nFile <$filetemplate> doesn't exists!\n"; |
|
| 45 | 45 | syslog (LOG_EMERG, "$user: File <$filetemplate> doesn't exist!"); |
| 46 | - exit ( usage() ); |
|
| 46 | + exit ( usage() ); |
|
| 47 | 47 | } |
| 48 | 48 | |
| 49 | 49 | if (! in_array( $typedesc, array_keys($tables) ) ) { |
@@ -53,7 +53,7 @@ discard block |
||
| 53 | 53 | |
| 54 | 54 | if (! $tables["$typedesc"]['active'] ) { |
| 55 | 55 | print "\nList <$typedesc> is not active. Please provide an active list name.\n"; |
| 56 | - exit ( usage() ); |
|
| 56 | + exit ( usage() ); |
|
| 57 | 57 | } |
| 58 | 58 | |
| 59 | 59 | |
@@ -73,10 +73,10 @@ discard block |
||
| 73 | 73 | |
| 74 | 74 | $mysqli = new mysqli($dbhost, $userdb, $pwd, $db, $dbport); |
| 75 | 75 | if ($mysqli->connect_error) { |
| 76 | - syslog (LOG_EMERG, $user.': Connect Error (' . $mysqli->connect_errno . ') ' |
|
| 77 | - . $mysqli->connect_error); |
|
| 78 | - exit ($user.': Connect Error (' . $mysqli->connect_errno . ') ' |
|
| 79 | - . $mysqli->connect_error); |
|
| 76 | + syslog (LOG_EMERG, $user.': Connect Error (' . $mysqli->connect_errno . ') ' |
|
| 77 | + . $mysqli->connect_error); |
|
| 78 | + exit ($user.': Connect Error (' . $mysqli->connect_errno . ') ' |
|
| 79 | + . $mysqli->connect_error); |
|
| 80 | 80 | } |
| 81 | 81 | |
| 82 | 82 | syslog(LOG_INFO, $user.': Successfully mysql connected to ' . $mysqli->host_info) ; |
@@ -87,15 +87,15 @@ discard block |
||
| 87 | 87 | while ($riga = $result->fetch_array(MYSQLI_ASSOC)) { |
| 88 | 88 | if (isListed($riga)) { |
| 89 | 89 | switch ( $tables["$typedesc"]['field'] ) { |
| 90 | - case 'ip': |
|
| 91 | - $element[] = long2ip($riga['ip']); |
|
| 92 | - break; |
|
| 93 | - case 'network': |
|
| 94 | - $element[] = long2ip($riga['network']).'/'.long2ip($riga['netmask']); |
|
| 95 | - break; |
|
| 96 | - default: |
|
| 90 | + case 'ip': |
|
| 91 | + $element[] = long2ip($riga['ip']); |
|
| 92 | + break; |
|
| 93 | + case 'network': |
|
| 94 | + $element[] = long2ip($riga['network']).'/'.long2ip($riga['netmask']); |
|
| 95 | + break; |
|
| 96 | + default: |
|
| 97 | 97 | $type = $tables["$typedesc"]['field']; |
| 98 | - $element[] = $riga["$type"]; |
|
| 98 | + $element[] = $riga["$type"]; |
|
| 99 | 99 | } |
| 100 | 100 | } |
| 101 | 101 | } |
@@ -7,7 +7,7 @@ |
||
| 7 | 7 | print '<p>List of available Reports for '.date('l, d M Y', strtotime($theDate)).'</p><ul>'; |
| 8 | 8 | foreach($dir as $file) |
| 9 | 9 | { |
| 10 | - if ( basename($file) != basename(__FILE__) ) { |
|
| 10 | + if ( basename($file) != basename(__FILE__) ) { |
|
| 11 | 11 | $modalDiv = 'openModal'.basename($file); |
| 12 | 12 | echo '<li><a href="#'.$modalDiv.'">'.str_replace("-$theDate.html",'',basename($file)).'</a></li>'; |
| 13 | 13 | # echo '<li><pre><a href="'.basename($file).'" title="'.str_replace("-$theDate.html",'',basename($file))." of $theDate".'" onClick="Modalbox.show(this.href, {title: this.title, height: 600}); return false;">'.str_replace("-$theDate.html",'',basename($file)).'</a></pre></li>'; |
@@ -5,11 +5,11 @@ |
||
| 5 | 5 | |
| 6 | 6 | |
| 7 | 7 | print '<p>List of available Reports for '.date('l, d M Y', strtotime($theDate)).'</p><ul>'; |
| 8 | -foreach($dir as $file) |
|
| 8 | +foreach ($dir as $file) |
|
| 9 | 9 | { |
| 10 | - if ( basename($file) != basename(__FILE__) ) { |
|
| 10 | + if (basename($file) != basename(__FILE__)) { |
|
| 11 | 11 | $modalDiv = 'openModal'.basename($file); |
| 12 | - echo '<li><a href="#'.$modalDiv.'">'.str_replace("-$theDate.html",'',basename($file)).'</a></li>'; |
|
| 12 | + echo '<li><a href="#'.$modalDiv.'">'.str_replace("-$theDate.html", '', basename($file)).'</a></li>'; |
|
| 13 | 13 | # echo '<li><pre><a href="'.basename($file).'" title="'.str_replace("-$theDate.html",'',basename($file))." of $theDate".'" onClick="Modalbox.show(this.href, {title: this.title, height: 600}); return false;">'.str_replace("-$theDate.html",'',basename($file)).'</a></pre></li>'; |
| 14 | 14 | print <<<MODAL |
| 15 | 15 | <div id="$modalDiv" class="overlay"> |
@@ -5,10 +5,10 @@ discard block |
||
| 5 | 5 | include_once($path.'config.php'); |
| 6 | 6 | require_once($path.'function.php'); |
| 7 | 7 | if ( !isset($version) ) { |
| 8 | - openlog('myRBLemergency', LOG_PID, LOG_LOCAL0); |
|
| 9 | - syslog (LOG_EMERG, 'unknown: I can\'t read the config files. Do you have configured the $path in getip.php?'); |
|
| 10 | - closelog(); |
|
| 11 | - exit(255); |
|
| 8 | + openlog('myRBLemergency', LOG_PID, LOG_LOCAL0); |
|
| 9 | + syslog (LOG_EMERG, 'unknown: I can\'t read the config files. Do you have configured the $path in getip.php?'); |
|
| 10 | + closelog(); |
|
| 11 | + exit(255); |
|
| 12 | 12 | } |
| 13 | 13 | include_once(dirname(__FILE__) . '/function.php'); |
| 14 | 14 | $conf = parse_ini_file($confImap_file); |
@@ -35,12 +35,12 @@ discard block |
||
| 35 | 35 | |
| 36 | 36 | /* check you select a right list */ |
| 37 | 37 | if ( !$tables[$conf['list']['spam']]['bl'] ) { |
| 38 | - syslog(LOG_EMERG, $conf['user'].': <'.$conf['list']['spam'].'> is not a blocklist. Are you stupid? Do you want to whitelist a spammer? I refuse to continue.'); |
|
| 39 | - exit (254); |
|
| 38 | + syslog(LOG_EMERG, $conf['user'].': <'.$conf['list']['spam'].'> is not a blocklist. Are you stupid? Do you want to whitelist a spammer? I refuse to continue.'); |
|
| 39 | + exit (254); |
|
| 40 | 40 | } |
| 41 | 41 | if ( $tables[$conf['list']['ham']]['bl'] ) { |
| 42 | - syslog(LOG_EMERG, $conf['user'].': <'.$conf['list']['ham'].'> is a blocklist. Are you stupid? Do you want to block a legitimate sender? I refuse to continue.'); |
|
| 43 | - exit (254); |
|
| 42 | + syslog(LOG_EMERG, $conf['user'].': <'.$conf['list']['ham'].'> is a blocklist. Are you stupid? Do you want to block a legitimate sender? I refuse to continue.'); |
|
| 43 | + exit (254); |
|
| 44 | 44 | } |
| 45 | 45 | |
| 46 | 46 | /* Make MYSQL connection Array */ |
@@ -51,9 +51,7 @@ |
||
| 51 | 51 | 'db' => $db, |
| 52 | 52 | 'dbport' => $dbport |
| 53 | 53 | ); |
| 54 | -} |
|
| 55 | - |
|
| 56 | -else { |
|
| 54 | +} else { |
|
| 57 | 55 | $mysqlconf = NULL; |
| 58 | 56 | syslog(LOG_INFO, $conf['user'].': Report only, no listing activated in configuration.') ; |
| 59 | 57 | } |
@@ -1,16 +1,16 @@ discard block |
||
| 1 | 1 | #!/usr/bin/php |
| 2 | 2 | <?php |
| 3 | 3 | /* Config */ |
| 4 | -$path='/var/www/html/RBL/'; |
|
| 4 | +$path = '/var/www/html/RBL/'; |
|
| 5 | 5 | include_once($path.'config.php'); |
| 6 | 6 | require_once($path.'function.php'); |
| 7 | -if ( !isset($version) ) { |
|
| 7 | +if (!isset($version)) { |
|
| 8 | 8 | openlog('myRBLemergency', LOG_PID, LOG_LOCAL0); |
| 9 | - syslog (LOG_EMERG, 'unknown: I can\'t read the config files. Do you have configured the $path in getip.php?'); |
|
| 9 | + syslog(LOG_EMERG, 'unknown: I can\'t read the config files. Do you have configured the $path in getip.php?'); |
|
| 10 | 10 | closelog(); |
| 11 | 11 | exit(255); |
| 12 | 12 | } |
| 13 | -include_once(dirname(__FILE__) . '/function.php'); |
|
| 13 | +include_once(dirname(__FILE__).'/function.php'); |
|
| 14 | 14 | $conf = parse_ini_file($confImap_file); |
| 15 | 15 | |
| 16 | 16 | |
@@ -19,8 +19,8 @@ discard block |
||
| 19 | 19 | openlog($tag, LOG_PID, $fac); |
| 20 | 20 | |
| 21 | 21 | |
| 22 | -if ( !$imapListActive ) { |
|
| 23 | - syslog (LOG_INFO, $conf['user'].': This plugin isn\'t active.'); |
|
| 22 | +if (!$imapListActive) { |
|
| 23 | + syslog(LOG_INFO, $conf['user'].': This plugin isn\'t active.'); |
|
| 24 | 24 | closelog(); |
| 25 | 25 | exit(255); |
| 26 | 26 | } |
@@ -31,20 +31,20 @@ discard block |
||
| 31 | 31 | $arr_tpl_data = array(date("Y-m-d", time())); |
| 32 | 32 | |
| 33 | 33 | |
| 34 | -if ( !$conf['onlyReport'] ) { |
|
| 34 | +if (!$conf['onlyReport']) { |
|
| 35 | 35 | |
| 36 | 36 | /* check you select a right list */ |
| 37 | - if ( !$tables[$conf['list']['spam']]['bl'] ) { |
|
| 37 | + if (!$tables[$conf['list']['spam']]['bl']) { |
|
| 38 | 38 | syslog(LOG_EMERG, $conf['user'].': <'.$conf['list']['spam'].'> is not a blocklist. Are you stupid? Do you want to whitelist a spammer? I refuse to continue.'); |
| 39 | 39 | exit (254); |
| 40 | 40 | } |
| 41 | - if ( $tables[$conf['list']['ham']]['bl'] ) { |
|
| 41 | + if ($tables[$conf['list']['ham']]['bl']) { |
|
| 42 | 42 | syslog(LOG_EMERG, $conf['user'].': <'.$conf['list']['ham'].'> is a blocklist. Are you stupid? Do you want to block a legitimate sender? I refuse to continue.'); |
| 43 | 43 | exit (254); |
| 44 | 44 | } |
| 45 | 45 | |
| 46 | 46 | /* Make MYSQL connection Array */ |
| 47 | - $mysqlconf= array( |
|
| 47 | + $mysqlconf = array( |
|
| 48 | 48 | 'dbhost' => $dbhost, |
| 49 | 49 | 'userdb' => $userdb, |
| 50 | 50 | 'pwd' => $pwd, |
@@ -55,7 +55,7 @@ discard block |
||
| 55 | 55 | |
| 56 | 56 | else { |
| 57 | 57 | $mysqlconf = NULL; |
| 58 | - syslog(LOG_INFO, $conf['user'].': Report only, no listing activated in configuration.') ; |
|
| 58 | + syslog(LOG_INFO, $conf['user'].': Report only, no listing activated in configuration.'); |
|
| 59 | 59 | } |
| 60 | 60 | |
| 61 | 61 | |
@@ -67,16 +67,16 @@ discard block |
||
| 67 | 67 | |
| 68 | 68 | |
| 69 | 69 | /* The hard work has hidden in imapReport */ |
| 70 | -$learnfromArray = array('ham','spam'); |
|
| 71 | -foreach ( $learnfromArray as $learnfrom ) { |
|
| 70 | +$learnfromArray = array('ham', 'spam'); |
|
| 71 | +foreach ($learnfromArray as $learnfrom) { |
|
| 72 | 72 | $conf['reportFile']["$learnfrom"] = str_replace($arr_tpl_vars, $arr_tpl_data, $conf['reportFile']["$learnfrom"]); |
| 73 | 73 | $conf['badreportFile']["$learnfrom"] = str_replace($arr_tpl_vars, $arr_tpl_data, $conf['badreportFile']["$learnfrom"]); |
| 74 | - imapReport ($conf,$mysqlconf,$splservice,$tables,$learnfrom); |
|
| 74 | + imapReport($conf, $mysqlconf, $splservice, $tables, $learnfrom); |
|
| 75 | 75 | } |
| 76 | 76 | |
| 77 | -if ( !$conf['onlyReport'] ) { |
|
| 77 | +if (!$conf['onlyReport']) { |
|
| 78 | 78 | /* Close connection */ |
| 79 | - syslog (LOG_INFO, $conf['user'].': Successfully end of session.'); |
|
| 79 | + syslog(LOG_INFO, $conf['user'].': Successfully end of session.'); |
|
| 80 | 80 | } |
| 81 | 81 | closelog(); |
| 82 | 82 | ?> |
@@ -15,10 +15,10 @@ |
||
| 15 | 15 | openlog($tag, LOG_PID, $fac); |
| 16 | 16 | $mysqli = new mysqli($dbhost, $userdb, $pwd, $db, $dbport); |
| 17 | 17 | if ($mysqli->connect_error) { |
| 18 | - syslog (LOG_EMERG, $user.': Connect Error (' . $mysqli->connect_errno . ') ' |
|
| 19 | - . $mysqli->connect_error); |
|
| 20 | - die($user.': Connect Error (' . $mysqli->connect_errno . ') ' |
|
| 21 | - . $mysqli->connect_error); |
|
| 18 | + syslog (LOG_EMERG, $user.': Connect Error (' . $mysqli->connect_errno . ') ' |
|
| 19 | + . $mysqli->connect_error); |
|
| 20 | + die($user.': Connect Error (' . $mysqli->connect_errno . ') ' |
|
| 21 | + . $mysqli->connect_error); |
|
| 22 | 22 | } |
| 23 | 23 | |
| 24 | 24 | syslog (LOG_INFO, $user.': Successfully connected to ' . $mysqli->host_info ); |
@@ -15,15 +15,15 @@ |
||
| 15 | 15 | openlog($tag, LOG_PID, $fac); |
| 16 | 16 | $mysqli = new mysqli($dbhost, $userdb, $pwd, $db, $dbport); |
| 17 | 17 | if ($mysqli->connect_error) { |
| 18 | - syslog (LOG_EMERG, $user.': Connect Error (' . $mysqli->connect_errno . ') ' |
|
| 18 | + syslog(LOG_EMERG, $user.': Connect Error ('.$mysqli->connect_errno.') ' |
|
| 19 | 19 | . $mysqli->connect_error); |
| 20 | - die($user.': Connect Error (' . $mysqli->connect_errno . ') ' |
|
| 20 | + die($user.': Connect Error ('.$mysqli->connect_errno.') ' |
|
| 21 | 21 | . $mysqli->connect_error); |
| 22 | 22 | } |
| 23 | 23 | |
| 24 | -syslog (LOG_INFO, $user.': Successfully connected to ' . $mysqli->host_info ); |
|
| 24 | +syslog(LOG_INFO, $user.': Successfully connected to '.$mysqli->host_info); |
|
| 25 | 25 | |
| 26 | -expire($mysqli,$user,$tables,$expireTime); |
|
| 26 | +expire($mysqli, $user, $tables, $expireTime); |
|
| 27 | 27 | $mysqli->close(); |
| 28 | 28 | closelog(); |
| 29 | 29 | ?> |
@@ -11,7 +11,7 @@ |
||
| 11 | 11 | <h1> DNSBL Lookup</h1> |
| 12 | 12 | <?php |
| 13 | 13 | |
| 14 | -$_POST['Value'] = str_replace('_','.',array_keys($_GET)[0]); |
|
| 14 | +$_POST['Value'] = str_replace('_', '.', array_keys($_GET)[0]); |
|
| 15 | 15 | $_POST['genere'] = 'Spam IP'; |
| 16 | 16 | require_once('result.php'); |
| 17 | 17 | ?> |
@@ -1,4 +1,7 @@ discard block |
||
| 1 | 1 | <?php |
| 2 | +/** |
|
| 3 | + * @param string $header |
|
| 4 | + */ |
|
| 2 | 5 | function getIP($header,$mxserver,$msa) { |
| 3 | 6 | /* Get submission server's IP from header's mail */ |
| 4 | 7 | /* Each line must end with /r/n */ |
@@ -28,11 +31,24 @@ discard block |
||
| 28 | 31 | return array($ip,$host,$dateR,$dateC['date'],$mid['mid']); |
| 29 | 32 | } |
| 30 | 33 | |
| 34 | +/** |
|
| 35 | + * @param string|false $ip |
|
| 36 | + * @param string $hostname |
|
| 37 | + * @param string $dateC |
|
| 38 | + * @param string|null $msgid |
|
| 39 | + * @param string|false $dateL |
|
| 40 | + */ |
|
| 31 | 41 | function updateReport ($ip,$uid,$ipcount,$uidcount,$hostname,$dateC,$msgid,$dateL) { |
| 32 | 42 | |
| 33 | 43 | return sprintf ('<tr><td nowrap>%s</td><td nowrap>%s</td><td>%s</td><td>%s</td><td>%u</td><td>%u</td><td>%s</td><td>%s</td></tr>'."\n",$dateL,$dateC,$uid,$ip,$uidcount,$ipcount,$hostname,htmlentities($msgid) ); |
| 34 | 44 | } |
| 35 | 45 | |
| 46 | +/** |
|
| 47 | + * @param string $dateC |
|
| 48 | + * @param string|null $msgid |
|
| 49 | + * @param false|string $dateL |
|
| 50 | + * @param string $text |
|
| 51 | + */ |
|
| 36 | 52 | function updatebadReport ( $uid,$dateC,$msgid,$dateL,$text ) { |
| 37 | 53 | return sprintf ('<tr><td nowrap>%s</td><td nowrap>%s</td><td>%s</td><td>%s</td><td nowrap>%s</td></tr>'."\n",$dateL,$dateC,$uid,htmlentities($msgid),$text ); |
| 38 | 54 | } |
@@ -84,6 +100,9 @@ discard block |
||
| 84 | 100 | } |
| 85 | 101 | |
| 86 | 102 | |
| 103 | +/** |
|
| 104 | + * @param null|mysqli $myconn |
|
| 105 | + */ |
|
| 87 | 106 | function summaryReportAndList ($cf,$myconn,$tables,$category,$ipvet) { |
| 88 | 107 | $nips = $ipvet['count']; |
| 89 | 108 | |
@@ -154,6 +173,10 @@ discard block |
||
| 154 | 173 | } |
| 155 | 174 | |
| 156 | 175 | |
| 176 | +/** |
|
| 177 | + * @param string $message_id |
|
| 178 | + * @param string $date |
|
| 179 | + */ |
|
| 157 | 180 | function splunksearch ($service,$message_id,$date) { |
| 158 | 181 | |
| 159 | 182 | // Run a blocking search |
@@ -12,14 +12,14 @@ discard block |
||
| 12 | 12 | # print "Examine ".$received[0][$i]."\n"; |
| 13 | 13 | if ( preg_match($msa,$received['host'][$i]) ) |
| 14 | 14 | $dateR = $received['date'][$i]; |
| 15 | - foreach ($mxserver as $mx) { |
|
| 16 | - if (!$ip) |
|
| 15 | + foreach ($mxserver as $mx) { |
|
| 16 | + if (!$ip) |
|
| 17 | 17 | if ($mx == $received['host'][$i]) { |
| 18 | 18 | $host = $received['host'][$i]; |
| 19 | 19 | $ip = $received['ip'][$i]; |
| 20 | - } |
|
| 21 | - } |
|
| 22 | - } |
|
| 20 | + } |
|
| 21 | + } |
|
| 22 | + } |
|
| 23 | 23 | } |
| 24 | 24 | if ( preg_match ('/\r\nDate:\s(?P<date>.*)\r\n/',$header,$dateC) != 1) |
| 25 | 25 | $dateC['date'] = 'Not found'; |
@@ -39,15 +39,15 @@ discard block |
||
| 39 | 39 | |
| 40 | 40 | |
| 41 | 41 | function summaryBadReport ($uidvet) { |
| 42 | - $nuid = $uidvet['count']; |
|
| 43 | - if ( empty($uidvet) ) return NULL; |
|
| 44 | - $return = '<hr><h3>Statistics by UID</h3><table><tr><th>UID</th><th>Learned times</th></tr>'."\n"; |
|
| 42 | + $nuid = $uidvet['count']; |
|
| 43 | + if ( empty($uidvet) ) return NULL; |
|
| 44 | + $return = '<hr><h3>Statistics by UID</h3><table><tr><th>UID</th><th>Learned times</th></tr>'."\n"; |
|
| 45 | 45 | |
| 46 | - /* Remove count index */ |
|
| 47 | - $uids = array_keys($uidvet['uid']); |
|
| 46 | + /* Remove count index */ |
|
| 47 | + $uids = array_keys($uidvet['uid']); |
|
| 48 | 48 | $totlearn = 0; |
| 49 | 49 | |
| 50 | - foreach ( $uids as $uid ) { |
|
| 50 | + foreach ( $uids as $uid ) { |
|
| 51 | 51 | $totlearn += $uidvet['uid']["$uid"]['count'];; |
| 52 | 52 | $return .= sprintf ('<tr><td>%s</td><td>%u</td></tr>',$uid,$uidvet['uid']["$uid"]['count']); |
| 53 | 53 | } |
@@ -60,26 +60,26 @@ discard block |
||
| 60 | 60 | |
| 61 | 61 | function array_msort($array, $cols) |
| 62 | 62 | { |
| 63 | - $colarr = array(); |
|
| 64 | - foreach ($cols as $col => $order) { |
|
| 65 | - $colarr[$col] = array(); |
|
| 66 | - foreach ($array as $k => $row) { $colarr[$col]['_'.$k] = strtolower($row[$col]); } |
|
| 67 | - } |
|
| 68 | - $eval = 'array_multisort('; |
|
| 69 | - foreach ($cols as $col => $order) { |
|
| 70 | - $eval .= '$colarr[\''.$col.'\'],'.$order.','; |
|
| 71 | - } |
|
| 72 | - $eval = substr($eval,0,-1).');'; |
|
| 73 | - eval($eval); |
|
| 74 | - $ret = array(); |
|
| 75 | - foreach ($colarr as $col => $arr) { |
|
| 76 | - foreach ($arr as $k => $v) { |
|
| 77 | - $k = substr($k,1); |
|
| 78 | - if (!isset($ret[$k])) $ret[$k] = $array[$k]; |
|
| 79 | - if (isset ($array[$k][$col])) $ret[$k][$col] = $array[$k][$col]; |
|
| 80 | - } |
|
| 81 | - } |
|
| 82 | - return $ret; |
|
| 63 | + $colarr = array(); |
|
| 64 | + foreach ($cols as $col => $order) { |
|
| 65 | + $colarr[$col] = array(); |
|
| 66 | + foreach ($array as $k => $row) { $colarr[$col]['_'.$k] = strtolower($row[$col]); } |
|
| 67 | + } |
|
| 68 | + $eval = 'array_multisort('; |
|
| 69 | + foreach ($cols as $col => $order) { |
|
| 70 | + $eval .= '$colarr[\''.$col.'\'],'.$order.','; |
|
| 71 | + } |
|
| 72 | + $eval = substr($eval,0,-1).');'; |
|
| 73 | + eval($eval); |
|
| 74 | + $ret = array(); |
|
| 75 | + foreach ($colarr as $col => $arr) { |
|
| 76 | + foreach ($arr as $k => $v) { |
|
| 77 | + $k = substr($k,1); |
|
| 78 | + if (!isset($ret[$k])) $ret[$k] = $array[$k]; |
|
| 79 | + if (isset ($array[$k][$col])) $ret[$k][$col] = $array[$k][$col]; |
|
| 80 | + } |
|
| 81 | + } |
|
| 82 | + return $ret; |
|
| 83 | 83 | |
| 84 | 84 | } |
| 85 | 85 | |
@@ -94,8 +94,8 @@ discard block |
||
| 94 | 94 | |
| 95 | 95 | foreach ( $ips as $ip ) { |
| 96 | 96 | if ( $ip == 'count' ) continue; |
| 97 | - $nlearn = $ipvet['ip']["$ip"]['count']; |
|
| 98 | - unset($ipvet['ip']["$ip"]['count']); |
|
| 97 | + $nlearn = $ipvet['ip']["$ip"]['count']; |
|
| 98 | + unset($ipvet['ip']["$ip"]['count']); |
|
| 99 | 99 | $quantity = $cf['quantity']["$category"]; /* In searchAndList this value is passed by reference and modified */ |
| 100 | 100 | $nuid = count($ipvet['ip']["$ip"]); |
| 101 | 101 | if ( !$cf['onlyReport'] ) { |
@@ -123,9 +123,9 @@ discard block |
||
| 123 | 123 | $return .='<tr><td rowspan="'.$nuid.'">'.$ip.'</td>'; |
| 124 | 124 | $return .= sprintf ('<td>%s</td><td rowspan="'.$nuid.'">%u</td><td rowspan="'.$nuid.'" '.$nowlist["$listed"]['style'].'>%s</td></tr>',$ipvet['ip']["$ip"][0],$nlearn,$nowlist["$listed"]['name']); |
| 125 | 125 | $rowuid=NULL; |
| 126 | - for ($j=1;$j<$nuid;$j++) $rowuid .= '<tr><td>%s</td></tr>'; |
|
| 126 | + for ($j=1;$j<$nuid;$j++) $rowuid .= '<tr><td>%s</td></tr>'; |
|
| 127 | 127 | array_shift($ipvet['ip']["$ip"]); |
| 128 | - $return .= vsprintf ($rowuid,$ipvet['ip']["$ip"]); |
|
| 128 | + $return .= vsprintf ($rowuid,$ipvet['ip']["$ip"]); |
|
| 129 | 129 | |
| 130 | 130 | } |
| 131 | 131 | $return .= sprintf ('<tr><th title="unique ips">%u</th><th title="unique uids">%u</th><th>%u</th></table>',$ipvet['ip']['count'],$ipvet['uid']['count'],$nips); |
@@ -135,20 +135,20 @@ discard block |
||
| 135 | 135 | /* Not used for listing purpose, but useful to you! */ |
| 136 | 136 | $return .= '<h3>Statistics by UID</h3><table><tr><th>UID</th><th>IP learned</th><th>Learned times</th></tr>'."\n"; |
| 137 | 137 | $uids = array_keys($ipvet['uid']); |
| 138 | - foreach ( $uids as $uid ) { |
|
| 138 | + foreach ( $uids as $uid ) { |
|
| 139 | 139 | if ( $uid == 'count' ) continue; |
| 140 | - $nlearn = $ipvet['uid']["$uid"]['count']; |
|
| 141 | - unset ( $ipvet['uid']["$uid"]['count'] ); |
|
| 140 | + $nlearn = $ipvet['uid']["$uid"]['count']; |
|
| 141 | + unset ( $ipvet['uid']["$uid"]['count'] ); |
|
| 142 | 142 | $nip = count($ipvet['uid']["$uid"]); |
| 143 | 143 | $return .='<tr><td rowspan="'.$nip.'">'.$uid.'</td>'; |
| 144 | 144 | $return .= sprintf ('<td>%s</td><td rowspan="'.$nip.'">%u</td></tr>',$ipvet['uid']["$uid"][0],$nlearn); |
| 145 | - $rowuid=NULL; |
|
| 146 | - for ($j=1;$j<$nip;$j++) $rowuid .= '<tr><td>%s</td></tr>'; |
|
| 147 | - array_shift($ipvet['uid']["$uid"]); |
|
| 148 | - $return .= vsprintf ($rowuid,$ipvet['uid']["$uid"]); |
|
| 145 | + $rowuid=NULL; |
|
| 146 | + for ($j=1;$j<$nip;$j++) $rowuid .= '<tr><td>%s</td></tr>'; |
|
| 147 | + array_shift($ipvet['uid']["$uid"]); |
|
| 148 | + $return .= vsprintf ($rowuid,$ipvet['uid']["$uid"]); |
|
| 149 | 149 | |
| 150 | - } |
|
| 151 | - $return .= sprintf ('<tr><th title="unique uids">%u</th><th title="unique ips">%u</th><th>%u</th></table>',$ipvet['uid']['count'],$ipvet['ip']['count'],$nips); |
|
| 150 | + } |
|
| 151 | + $return .= sprintf ('<tr><th title="unique uids">%u</th><th title="unique ips">%u</th><th>%u</th></table>',$ipvet['uid']['count'],$ipvet['ip']['count'],$nips); |
|
| 152 | 152 | |
| 153 | 153 | |
| 154 | 154 | return $return; |
@@ -176,50 +176,50 @@ discard block |
||
| 176 | 176 | */ |
| 177 | 177 | |
| 178 | 178 | // A one shot search |
| 179 | - $searchParams = array( |
|
| 180 | - 'earliest_time' => date("c",strtotime ($date)-120), |
|
| 181 | - 'latest_time' => date("c",strtotime ($date)+60) |
|
| 182 | - ); |
|
| 179 | + $searchParams = array( |
|
| 180 | + 'earliest_time' => date("c",strtotime ($date)-120), |
|
| 181 | + 'latest_time' => date("c",strtotime ($date)+60) |
|
| 182 | + ); |
|
| 183 | 183 | |
| 184 | - // Run a oneshot search that returns the job's results |
|
| 185 | - $resultsStream = $service->oneshotSearch($searchQueryBlocking, $searchParams); |
|
| 186 | - $resultSearch = new Splunk_ResultsReader($resultsStream); |
|
| 184 | + // Run a oneshot search that returns the job's results |
|
| 185 | + $resultsStream = $service->oneshotSearch($searchQueryBlocking, $searchParams); |
|
| 186 | + $resultSearch = new Splunk_ResultsReader($resultsStream); |
|
| 187 | 187 | |
| 188 | 188 | // Use the built-in XML parser to display the job results |
| 189 | 189 | foreach ($resultSearch as $result) |
| 190 | 190 | { |
| 191 | - if ($result instanceof Splunk_ResultsFieldOrder) |
|
| 192 | - { |
|
| 193 | - // More than one field attribute returned by search |
|
| 194 | - // You must redefine the search |
|
| 195 | - if ( count($result->getFieldNames()) > 1 ) return FALSE; |
|
| 196 | - } |
|
| 197 | - else if ($result instanceof Splunk_ResultsMessage) |
|
| 198 | - { |
|
| 199 | - // I don't want messages in my search |
|
| 200 | - return FALSE; |
|
| 201 | - } |
|
| 202 | - else if (is_array($result)) |
|
| 203 | - { |
|
| 204 | - // Process a row |
|
| 205 | - foreach ($result as $key => $valueOrValues) |
|
| 206 | - { |
|
| 207 | - if (is_array($valueOrValues)) |
|
| 208 | - { |
|
| 209 | - return FALSE; |
|
| 210 | - } |
|
| 211 | - else |
|
| 212 | - { |
|
| 213 | - return $valueOrValues; |
|
| 214 | - #print " {$key} => {$value}\r\n"; |
|
| 215 | - } |
|
| 216 | - } |
|
| 217 | - } |
|
| 218 | - else |
|
| 219 | - { |
|
| 220 | - #print "Unknow result type"; |
|
| 221 | - return FALSE; |
|
| 222 | - } |
|
| 191 | + if ($result instanceof Splunk_ResultsFieldOrder) |
|
| 192 | + { |
|
| 193 | + // More than one field attribute returned by search |
|
| 194 | + // You must redefine the search |
|
| 195 | + if ( count($result->getFieldNames()) > 1 ) return FALSE; |
|
| 196 | + } |
|
| 197 | + else if ($result instanceof Splunk_ResultsMessage) |
|
| 198 | + { |
|
| 199 | + // I don't want messages in my search |
|
| 200 | + return FALSE; |
|
| 201 | + } |
|
| 202 | + else if (is_array($result)) |
|
| 203 | + { |
|
| 204 | + // Process a row |
|
| 205 | + foreach ($result as $key => $valueOrValues) |
|
| 206 | + { |
|
| 207 | + if (is_array($valueOrValues)) |
|
| 208 | + { |
|
| 209 | + return FALSE; |
|
| 210 | + } |
|
| 211 | + else |
|
| 212 | + { |
|
| 213 | + return $valueOrValues; |
|
| 214 | + #print " {$key} => {$value}\r\n"; |
|
| 215 | + } |
|
| 216 | + } |
|
| 217 | + } |
|
| 218 | + else |
|
| 219 | + { |
|
| 220 | + #print "Unknow result type"; |
|
| 221 | + return FALSE; |
|
| 222 | + } |
|
| 223 | 223 | } |
| 224 | 224 | } |
| 225 | 225 | |
@@ -228,26 +228,26 @@ discard block |
||
| 228 | 228 | $file = dirname(__FILE__) . '/' . $cf['reportFile']["$type"]; |
| 229 | 229 | $fileb= dirname(__FILE__) . '/' . $cf['badreportFile']["$type"]; |
| 230 | 230 | $m_mail = imap_open('{'.$cf['mailhost'].':143/imap/novalidate-cert/authuser='.$cf['authuser'].'}'.$cf['folder']["$type"], $cf['account'],$cf['authpassword'], OP_READONLY) |
| 231 | - or syslog (LOG_EMERG, $cf['user'].': Error in IMAP connection to <'.$cf['mailhost'].'>: ' . imap_last_error()); |
|
| 231 | + or syslog (LOG_EMERG, $cf['user'].': Error in IMAP connection to <'.$cf['mailhost'].'>: ' . imap_last_error()); |
|
| 232 | 232 | if ( !$m_mail ) exit(254); |
| 233 | 233 | |
| 234 | 234 | |
| 235 | 235 | syslog (LOG_INFO,$cf['user'].': Successfully connected to <'.$cf['mailhost'].">; Reading $type messages of last ".$cf['oldestday'].' days...'); |
| 236 | 236 | //get all messages |
| 237 | 237 | $dateTh = date ( "d-M-Y", strToTime ( '-'.$cf['oldestday'].' days' ) ); |
| 238 | - $dateN = date ( "d-M-Y", strToTime ( "now" ) ); |
|
| 239 | - $m_search=imap_search ($m_mail, "SINCE \"$dateTh\" BEFORE \"$dateN\"" ); |
|
| 238 | + $dateN = date ( "d-M-Y", strToTime ( "now" ) ); |
|
| 239 | + $m_search=imap_search ($m_mail, "SINCE \"$dateTh\" BEFORE \"$dateN\"" ); |
|
| 240 | 240 | |
| 241 | 241 | |
| 242 | 242 | // Order results starting from newest message |
| 243 | 243 | if ( empty($m_search) ) { |
| 244 | 244 | syslog (LOG_INFO,$cf['user'].": No mail found in $type folder. No reports written for $type."); |
| 245 | - if ( $ierr = imap_errors() ) |
|
| 246 | - foreach ( $ierr as $thiserr ) |
|
| 247 | - syslog (LOG_ERR, $cf['user'].": IMAP Error: $thiserr"); |
|
| 248 | - if ( $ierr = imap_alerts() ) |
|
| 249 | - foreach ( $ierr as $thiserr ) |
|
| 250 | - syslog (LOG_ALERT, $cf['user'].": IMAP Alert: $thiserr"); |
|
| 245 | + if ( $ierr = imap_errors() ) |
|
| 246 | + foreach ( $ierr as $thiserr ) |
|
| 247 | + syslog (LOG_ERR, $cf['user'].": IMAP Error: $thiserr"); |
|
| 248 | + if ( $ierr = imap_alerts() ) |
|
| 249 | + foreach ( $ierr as $thiserr ) |
|
| 250 | + syslog (LOG_ALERT, $cf['user'].": IMAP Alert: $thiserr"); |
|
| 251 | 251 | imap_close( $m_mail ); |
| 252 | 252 | if ( file_exists( $file ) ) unlink ($file); |
| 253 | 253 | if ( file_exists( $fileb ) ) unlink ($fileb); |
@@ -280,16 +280,16 @@ discard block |
||
| 280 | 280 | $uidbad['count'] = 0; |
| 281 | 281 | $uidbad['uid'] = array(); |
| 282 | 282 | |
| 283 | - // loop for each message |
|
| 283 | + // loop for each message |
|
| 284 | 284 | foreach ($m_search as $onem) { |
| 285 | 285 | |
| 286 | - //get imap header info for obj thang |
|
| 287 | - //$headers = imap_headerinfo($m_mail, $onem); |
|
| 288 | - //$head = imap_fetchheader($m_mail, $headers->Msgno); |
|
| 286 | + //get imap header info for obj thang |
|
| 287 | + //$headers = imap_headerinfo($m_mail, $onem); |
|
| 288 | + //$head = imap_fetchheader($m_mail, $headers->Msgno); |
|
| 289 | 289 | $head = imap_fetchheader($m_mail, $onem ); |
| 290 | - //$obj = imap_rfc822_parse_headers( $head); |
|
| 290 | + //$obj = imap_rfc822_parse_headers( $head); |
|
| 291 | 291 | |
| 292 | - list ($ip,$host,$dateReceived,$dateClient,$mid) = getIP( $head,$cf['mx'],$cf['msalearn'] ); |
|
| 292 | + list ($ip,$host,$dateReceived,$dateClient,$mid) = getIP( $head,$cf['mx'],$cf['msalearn'] ); |
|
| 293 | 293 | if (empty($mid)) { |
| 294 | 294 | $uid='NA'; |
| 295 | 295 | syslog (LOG_ERR, $cf['user'].": Error retrieving data for empty Message-ID."); |
@@ -304,11 +304,11 @@ discard block |
||
| 304 | 304 | } |
| 305 | 305 | } |
| 306 | 306 | |
| 307 | - /* Update count of each ip */ |
|
| 308 | - if ($host and ($uid!='NA') and ($uid!='unauthenticated') and ($uid!='unknown')) { /* IP is received by MX servers and learned by valid uid */ |
|
| 307 | + /* Update count of each ip */ |
|
| 308 | + if ($host and ($uid!='NA') and ($uid!='unauthenticated') and ($uid!='unknown')) { /* IP is received by MX servers and learned by valid uid */ |
|
| 309 | 309 | $ipuid['count']++; //number of right messages |
| 310 | 310 | |
| 311 | - if (in_array($uid,array_keys($ipuid['uid']))) { |
|
| 311 | + if (in_array($uid,array_keys($ipuid['uid']))) { |
|
| 312 | 312 | $ipuid['uid']["$uid"]['count']++; //number of learn by this uid |
| 313 | 313 | if (!in_array($ip,$ipuid['uid']["$uid"])) |
| 314 | 314 | $ipuid['uid']["$uid"][]=$ip; //ips learned by this uid |
@@ -319,29 +319,29 @@ discard block |
||
| 319 | 319 | $ipuid['uid']['count']++; //number of unique uids |
| 320 | 320 | } |
| 321 | 321 | |
| 322 | - if (in_array($ip,array_keys($ipuid['ip']))) { |
|
| 323 | - $ipuid['ip']["$ip"]['count']++; //number of time this ip appears in different messages |
|
| 322 | + if (in_array($ip,array_keys($ipuid['ip']))) { |
|
| 323 | + $ipuid['ip']["$ip"]['count']++; //number of time this ip appears in different messages |
|
| 324 | 324 | if (!in_array($uid,$ipuid['ip']["$ip"])) |
| 325 | 325 | $ipuid['ip']["$ip"][]=$uid; //uids that learned this ip |
| 326 | 326 | } |
| 327 | - else { |
|
| 328 | - $ipuid['ip']["$ip"]['count'] = 1; |
|
| 327 | + else { |
|
| 328 | + $ipuid['ip']["$ip"]['count'] = 1; |
|
| 329 | 329 | $ipuid['ip']["$ip"][]=$uid; |
| 330 | 330 | $ipuid['ip']['count']++; //number of unique ips |
| 331 | - } |
|
| 331 | + } |
|
| 332 | 332 | |
| 333 | - /* Update HTML report */ |
|
| 334 | - fwrite($fp,updateReport ( $ip,$uid,$ipuid['ip']["$ip"]['count'],$ipuid['uid']["$uid"]['count'],$host,$dateClient,$mid,$dateReceived) ); |
|
| 333 | + /* Update HTML report */ |
|
| 334 | + fwrite($fp,updateReport ( $ip,$uid,$ipuid['ip']["$ip"]['count'],$ipuid['uid']["$uid"]['count'],$host,$dateClient,$mid,$dateReceived) ); |
|
| 335 | 335 | } |
| 336 | - else { /* Bad learn */ |
|
| 336 | + else { /* Bad learn */ |
|
| 337 | 337 | |
| 338 | - if (in_array($uid,array_keys($uidbad['uid']))) |
|
| 339 | - $uidbad['uid']["$uid"]['count']++; //number of bad learn by this uid |
|
| 340 | - else { |
|
| 341 | - $uidbad['uid']["$uid"]['count'] = 1; |
|
| 338 | + if (in_array($uid,array_keys($uidbad['uid']))) |
|
| 339 | + $uidbad['uid']["$uid"]['count']++; //number of bad learn by this uid |
|
| 340 | + else { |
|
| 341 | + $uidbad['uid']["$uid"]['count'] = 1; |
|
| 342 | 342 | $uidbad['uid']["$uid"][]=$uid; |
| 343 | - $uidbad['count']++; //numeber of unique bad uids |
|
| 344 | - } |
|
| 343 | + $uidbad['count']++; //numeber of unique bad uids |
|
| 344 | + } |
|
| 345 | 345 | /* The reason of bad report */ |
| 346 | 346 | if ($host === FALSE) $reason = 'This mail was not received by recognized MX host'; |
| 347 | 347 | if ($dateReceived === FALSE) $reason = 'This mail was not submitted to recognized MSA for learn'; |
@@ -363,17 +363,17 @@ discard block |
||
| 363 | 363 | fwrite($fp, '</table>'); |
| 364 | 364 | fwrite($fp, '<hr><h2>Summary Report</h2><h5>Listing policy: ip must be learned at least '.$cf['thresholdip']["$type"].' times from at least '.$cf['thresholduid']["$type"].' different valid uids.</h5>' ); |
| 365 | 365 | |
| 366 | - /* Make MYSQL connection */ |
|
| 366 | + /* Make MYSQL connection */ |
|
| 367 | 367 | if ( $cf['onlyReport'] ) |
| 368 | 368 | $mysqli = NULL; |
| 369 | 369 | else { |
| 370 | - $mysqli = new mysqli($myconnArray['dbhost'], $myconnArray['userdb'], $myconnArray['pwd'], $myconnArray['db'], $myconnArray['dbport']); |
|
| 371 | - if ($mysqli->connect_error) { |
|
| 372 | - syslog (LOG_EMERG, $cf['user'].': Connect Error (' . $mysqli->connect_errno . ') ' |
|
| 373 | - . $mysqli->connect_error); |
|
| 374 | - exit (254); |
|
| 375 | - } |
|
| 376 | - syslog(LOG_INFO, $cf['user'].': Successfully mysql connected to ' . $mysqli->host_info) ; |
|
| 370 | + $mysqli = new mysqli($myconnArray['dbhost'], $myconnArray['userdb'], $myconnArray['pwd'], $myconnArray['db'], $myconnArray['dbport']); |
|
| 371 | + if ($mysqli->connect_error) { |
|
| 372 | + syslog (LOG_EMERG, $cf['user'].': Connect Error (' . $mysqli->connect_errno . ') ' |
|
| 373 | + . $mysqli->connect_error); |
|
| 374 | + exit (254); |
|
| 375 | + } |
|
| 376 | + syslog(LOG_INFO, $cf['user'].': Successfully mysql connected to ' . $mysqli->host_info) ; |
|
| 377 | 377 | } |
| 378 | 378 | /***********************/ |
| 379 | 379 | |
@@ -393,8 +393,8 @@ discard block |
||
| 393 | 393 | foreach ( $ierr as $thiserr ) |
| 394 | 394 | syslog (LOG_ERR, $cf['user'].": IMAP Error: $thiserr"); |
| 395 | 395 | if ( $ierr = imap_alerts() ) |
| 396 | - foreach ( $ierr as $thiserr ) |
|
| 397 | - syslog (LOG_ALERT, $cf['user'].": IMAP Alert: $thiserr"); |
|
| 396 | + foreach ( $ierr as $thiserr ) |
|
| 397 | + syslog (LOG_ALERT, $cf['user'].": IMAP Alert: $thiserr"); |
|
| 398 | 398 | imap_close($m_mail); |
| 399 | 399 | } |
| 400 | 400 | ?> |
@@ -1,5 +1,5 @@ discard block |
||
| 1 | 1 | <?php |
| 2 | -function getIP($header,$mxserver,$msa) { |
|
| 2 | +function getIP($header, $mxserver, $msa) { |
|
| 3 | 3 | /* Get submission server's IP from header's mail */ |
| 4 | 4 | /* Each line must end with /r/n */ |
| 5 | 5 | /* IP is the first one written by your mxserver */ |
@@ -7,10 +7,10 @@ discard block |
||
| 7 | 7 | $ip = FALSE; |
| 8 | 8 | $host = FALSE; |
| 9 | 9 | $dateR = FALSE; |
| 10 | - if ( preg_match_all('/^Received:\sfrom(?:.|\r\n\s)*?[\[\(]\s*(?P<ip>\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3})[\]\)](?:.|\r\n\s)+\s+by(?:\s|\r\n\s+)(?P<host>\S+).*(?:\s|\r\n\s\s)+.*;\s+(?P<date>.*)/m',$header,$received) ) { |
|
| 11 | - for ($i = count($received[0])-1;$i>=0;$i--) { |
|
| 10 | + if (preg_match_all('/^Received:\sfrom(?:.|\r\n\s)*?[\[\(]\s*(?P<ip>\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3})[\]\)](?:.|\r\n\s)+\s+by(?:\s|\r\n\s+)(?P<host>\S+).*(?:\s|\r\n\s\s)+.*;\s+(?P<date>.*)/m', $header, $received)) { |
|
| 11 | + for ($i = count($received[0])-1; $i>=0; $i--) { |
|
| 12 | 12 | # print "Examine ".$received[0][$i]."\n"; |
| 13 | - if ( preg_match($msa,$received['host'][$i]) ) |
|
| 13 | + if (preg_match($msa, $received['host'][$i])) |
|
| 14 | 14 | $dateR = $received['date'][$i]; |
| 15 | 15 | foreach ($mxserver as $mx) { |
| 16 | 16 | if (!$ip) |
@@ -21,38 +21,38 @@ discard block |
||
| 21 | 21 | } |
| 22 | 22 | } |
| 23 | 23 | } |
| 24 | - if ( preg_match ('/\r\nDate:\s(?P<date>.*)\r\n/',$header,$dateC) != 1) |
|
| 24 | + if (preg_match('/\r\nDate:\s(?P<date>.*)\r\n/', $header, $dateC) != 1) |
|
| 25 | 25 | $dateC['date'] = 'Not found'; |
| 26 | - if ( preg_match ('/\r\nMessage\-I(?:D|d):\s(?P<mid>.*)\r\n/',$header,$mid) != 1) |
|
| 26 | + if (preg_match('/\r\nMessage\-I(?:D|d):\s(?P<mid>.*)\r\n/', $header, $mid) != 1) |
|
| 27 | 27 | $mid['mid'] = NULL; |
| 28 | - return array($ip,$host,$dateR,$dateC['date'],$mid['mid']); |
|
| 28 | + return array($ip, $host, $dateR, $dateC['date'], $mid['mid']); |
|
| 29 | 29 | } |
| 30 | 30 | |
| 31 | -function updateReport ($ip,$uid,$ipcount,$uidcount,$hostname,$dateC,$msgid,$dateL) { |
|
| 31 | +function updateReport($ip, $uid, $ipcount, $uidcount, $hostname, $dateC, $msgid, $dateL) { |
|
| 32 | 32 | |
| 33 | - return sprintf ('<tr><td nowrap>%s</td><td nowrap>%s</td><td>%s</td><td>%s</td><td>%u</td><td>%u</td><td>%s</td><td>%s</td></tr>'."\n",$dateL,$dateC,$uid,$ip,$uidcount,$ipcount,$hostname,htmlentities($msgid) ); |
|
| 33 | + return sprintf('<tr><td nowrap>%s</td><td nowrap>%s</td><td>%s</td><td>%s</td><td>%u</td><td>%u</td><td>%s</td><td>%s</td></tr>'."\n", $dateL, $dateC, $uid, $ip, $uidcount, $ipcount, $hostname, htmlentities($msgid)); |
|
| 34 | 34 | } |
| 35 | 35 | |
| 36 | -function updatebadReport ( $uid,$dateC,$msgid,$dateL,$text ) { |
|
| 37 | - return sprintf ('<tr><td nowrap>%s</td><td nowrap>%s</td><td>%s</td><td>%s</td><td nowrap>%s</td></tr>'."\n",$dateL,$dateC,$uid,htmlentities($msgid),$text ); |
|
| 36 | +function updatebadReport($uid, $dateC, $msgid, $dateL, $text) { |
|
| 37 | + return sprintf('<tr><td nowrap>%s</td><td nowrap>%s</td><td>%s</td><td>%s</td><td nowrap>%s</td></tr>'."\n", $dateL, $dateC, $uid, htmlentities($msgid), $text); |
|
| 38 | 38 | } |
| 39 | 39 | |
| 40 | 40 | |
| 41 | -function summaryBadReport ($uidvet) { |
|
| 41 | +function summaryBadReport($uidvet) { |
|
| 42 | 42 | $nuid = $uidvet['count']; |
| 43 | - if ( empty($uidvet) ) return NULL; |
|
| 43 | + if (empty($uidvet)) return NULL; |
|
| 44 | 44 | $return = '<hr><h3>Statistics by UID</h3><table><tr><th>UID</th><th>Learned times</th></tr>'."\n"; |
| 45 | 45 | |
| 46 | 46 | /* Remove count index */ |
| 47 | 47 | $uids = array_keys($uidvet['uid']); |
| 48 | 48 | $totlearn = 0; |
| 49 | 49 | |
| 50 | - foreach ( $uids as $uid ) { |
|
| 51 | - $totlearn += $uidvet['uid']["$uid"]['count'];; |
|
| 52 | - $return .= sprintf ('<tr><td>%s</td><td>%u</td></tr>',$uid,$uidvet['uid']["$uid"]['count']); |
|
| 50 | + foreach ($uids as $uid) { |
|
| 51 | + $totlearn += $uidvet['uid']["$uid"]['count']; ; |
|
| 52 | + $return .= sprintf('<tr><td>%s</td><td>%u</td></tr>', $uid, $uidvet['uid']["$uid"]['count']); |
|
| 53 | 53 | } |
| 54 | - $return .= sprintf ('<tr><th>%s</th><th>%u</th></tr></table>','TOT',$totlearn); |
|
| 55 | - $return .= sprintf ('<p>%s : %u</p>','Unique UID',$nuid); |
|
| 54 | + $return .= sprintf('<tr><th>%s</th><th>%u</th></tr></table>', 'TOT', $totlearn); |
|
| 55 | + $return .= sprintf('<p>%s : %u</p>', 'Unique UID', $nuid); |
|
| 56 | 56 | |
| 57 | 57 | return $return; |
| 58 | 58 | } |
@@ -69,12 +69,12 @@ discard block |
||
| 69 | 69 | foreach ($cols as $col => $order) { |
| 70 | 70 | $eval .= '$colarr[\''.$col.'\'],'.$order.','; |
| 71 | 71 | } |
| 72 | - $eval = substr($eval,0,-1).');'; |
|
| 72 | + $eval = substr($eval, 0, -1).');'; |
|
| 73 | 73 | eval($eval); |
| 74 | 74 | $ret = array(); |
| 75 | 75 | foreach ($colarr as $col => $arr) { |
| 76 | 76 | foreach ($arr as $k => $v) { |
| 77 | - $k = substr($k,1); |
|
| 77 | + $k = substr($k, 1); |
|
| 78 | 78 | if (!isset($ret[$k])) $ret[$k] = $array[$k]; |
| 79 | 79 | if (isset ($array[$k][$col])) $ret[$k][$col] = $array[$k][$col]; |
| 80 | 80 | } |
@@ -84,29 +84,29 @@ discard block |
||
| 84 | 84 | } |
| 85 | 85 | |
| 86 | 86 | |
| 87 | -function summaryReportAndList ($cf,$myconn,$tables,$category,$ipvet) { |
|
| 87 | +function summaryReportAndList($cf, $myconn, $tables, $category, $ipvet) { |
|
| 88 | 88 | $nips = $ipvet['count']; |
| 89 | 89 | |
| 90 | - if ( empty($ipvet) ) return NULL; |
|
| 90 | + if (empty($ipvet)) return NULL; |
|
| 91 | 91 | $return = '<h3>Statistics by IP</h3><table><tr><th>IP</th><th>Learned by</th><th>Learned times</th><th title="This field doesn\'t say if this ip is currently listed, but it says if this IP has listed now!">Listed Now</th></tr>'."\n"; |
| 92 | 92 | |
| 93 | 93 | $ips = array_keys($ipvet['ip']); |
| 94 | 94 | |
| 95 | - foreach ( $ips as $ip ) { |
|
| 96 | - if ( $ip == 'count' ) continue; |
|
| 95 | + foreach ($ips as $ip) { |
|
| 96 | + if ($ip == 'count') continue; |
|
| 97 | 97 | $nlearn = $ipvet['ip']["$ip"]['count']; |
| 98 | 98 | unset($ipvet['ip']["$ip"]['count']); |
| 99 | 99 | $quantity = $cf['quantity']["$category"]; /* In searchAndList this value is passed by reference and modified */ |
| 100 | 100 | $nuid = count($ipvet['ip']["$ip"]); |
| 101 | - if ( !$cf['onlyReport'] ) { |
|
| 102 | - if ( ($nlearn >= $cf['thresholdip']["$category"])&&($nuid >= $cf['thresholduid']["$category"]) ) { |
|
| 101 | + if (!$cf['onlyReport']) { |
|
| 102 | + if (($nlearn>=$cf['thresholdip']["$category"]) && ($nuid>=$cf['thresholduid']["$category"])) { |
|
| 103 | 103 | $reason = "The IP <$ip> has been listed because was marked $nlearn times as $category by $nuid different accounts during last ".$cf['oldestday'].' days.'; |
| 104 | - $listed = searchAndList ($myconn,$cf['user'],$tables,$cf['list']["$category"],$ip,$cf['unit']["$category"],$quantity,$reason); |
|
| 104 | + $listed = searchAndList($myconn, $cf['user'], $tables, $cf['list']["$category"], $ip, $cf['unit']["$category"], $quantity, $reason); |
|
| 105 | 105 | } |
| 106 | 106 | else $listed = FALSE; |
| 107 | 107 | } |
| 108 | 108 | else $listed = FALSE; |
| 109 | - $nowlist = array( TRUE => array( |
|
| 109 | + $nowlist = array(TRUE => array( |
|
| 110 | 110 | 'style' => 'id=\'ipfound\'', |
| 111 | 111 | 'name' => 'YES', |
| 112 | 112 | ), |
@@ -120,45 +120,45 @@ discard block |
||
| 120 | 120 | ) |
| 121 | 121 | ); |
| 122 | 122 | |
| 123 | - $return .='<tr><td rowspan="'.$nuid.'">'.$ip.'</td>'; |
|
| 124 | - $return .= sprintf ('<td>%s</td><td rowspan="'.$nuid.'">%u</td><td rowspan="'.$nuid.'" '.$nowlist["$listed"]['style'].'>%s</td></tr>',$ipvet['ip']["$ip"][0],$nlearn,$nowlist["$listed"]['name']); |
|
| 125 | - $rowuid=NULL; |
|
| 126 | - for ($j=1;$j<$nuid;$j++) $rowuid .= '<tr><td>%s</td></tr>'; |
|
| 123 | + $return .= '<tr><td rowspan="'.$nuid.'">'.$ip.'</td>'; |
|
| 124 | + $return .= sprintf('<td>%s</td><td rowspan="'.$nuid.'">%u</td><td rowspan="'.$nuid.'" '.$nowlist["$listed"]['style'].'>%s</td></tr>', $ipvet['ip']["$ip"][0], $nlearn, $nowlist["$listed"]['name']); |
|
| 125 | + $rowuid = NULL; |
|
| 126 | + for ($j = 1; $j<$nuid; $j++) $rowuid .= '<tr><td>%s</td></tr>'; |
|
| 127 | 127 | array_shift($ipvet['ip']["$ip"]); |
| 128 | - $return .= vsprintf ($rowuid,$ipvet['ip']["$ip"]); |
|
| 128 | + $return .= vsprintf($rowuid, $ipvet['ip']["$ip"]); |
|
| 129 | 129 | |
| 130 | 130 | } |
| 131 | - $return .= sprintf ('<tr><th title="unique ips">%u</th><th title="unique uids">%u</th><th>%u</th></table>',$ipvet['ip']['count'],$ipvet['uid']['count'],$nips); |
|
| 131 | + $return .= sprintf('<tr><th title="unique ips">%u</th><th title="unique uids">%u</th><th>%u</th></table>', $ipvet['ip']['count'], $ipvet['uid']['count'], $nips); |
|
| 132 | 132 | |
| 133 | 133 | |
| 134 | 134 | /* Statistics by UID */ |
| 135 | 135 | /* Not used for listing purpose, but useful to you! */ |
| 136 | 136 | $return .= '<h3>Statistics by UID</h3><table><tr><th>UID</th><th>IP learned</th><th>Learned times</th></tr>'."\n"; |
| 137 | 137 | $uids = array_keys($ipvet['uid']); |
| 138 | - foreach ( $uids as $uid ) { |
|
| 139 | - if ( $uid == 'count' ) continue; |
|
| 138 | + foreach ($uids as $uid) { |
|
| 139 | + if ($uid == 'count') continue; |
|
| 140 | 140 | $nlearn = $ipvet['uid']["$uid"]['count']; |
| 141 | - unset ( $ipvet['uid']["$uid"]['count'] ); |
|
| 141 | + unset ($ipvet['uid']["$uid"]['count']); |
|
| 142 | 142 | $nip = count($ipvet['uid']["$uid"]); |
| 143 | - $return .='<tr><td rowspan="'.$nip.'">'.$uid.'</td>'; |
|
| 144 | - $return .= sprintf ('<td>%s</td><td rowspan="'.$nip.'">%u</td></tr>',$ipvet['uid']["$uid"][0],$nlearn); |
|
| 145 | - $rowuid=NULL; |
|
| 146 | - for ($j=1;$j<$nip;$j++) $rowuid .= '<tr><td>%s</td></tr>'; |
|
| 143 | + $return .= '<tr><td rowspan="'.$nip.'">'.$uid.'</td>'; |
|
| 144 | + $return .= sprintf('<td>%s</td><td rowspan="'.$nip.'">%u</td></tr>', $ipvet['uid']["$uid"][0], $nlearn); |
|
| 145 | + $rowuid = NULL; |
|
| 146 | + for ($j = 1; $j<$nip; $j++) $rowuid .= '<tr><td>%s</td></tr>'; |
|
| 147 | 147 | array_shift($ipvet['uid']["$uid"]); |
| 148 | - $return .= vsprintf ($rowuid,$ipvet['uid']["$uid"]); |
|
| 148 | + $return .= vsprintf($rowuid, $ipvet['uid']["$uid"]); |
|
| 149 | 149 | |
| 150 | 150 | } |
| 151 | - $return .= sprintf ('<tr><th title="unique uids">%u</th><th title="unique ips">%u</th><th>%u</th></table>',$ipvet['uid']['count'],$ipvet['ip']['count'],$nips); |
|
| 151 | + $return .= sprintf('<tr><th title="unique uids">%u</th><th title="unique ips">%u</th><th>%u</th></table>', $ipvet['uid']['count'], $ipvet['ip']['count'], $nips); |
|
| 152 | 152 | |
| 153 | 153 | |
| 154 | 154 | return $return; |
| 155 | 155 | } |
| 156 | 156 | |
| 157 | 157 | |
| 158 | -function splunksearch ($service,$message_id,$date) { |
|
| 158 | +function splunksearch($service, $message_id, $date) { |
|
| 159 | 159 | |
| 160 | 160 | // Run a blocking search |
| 161 | - $searchQueryBlocking = 'search (message_id="'. addslashes( $message_id ) . |
|
| 161 | + $searchQueryBlocking = 'search (message_id="'.addslashes($message_id). |
|
| 162 | 162 | '" OR sasl_username) | transaction message_id queue_id maxspan=3m maxpause=2m | search sasl_username message_id=* | table sasl_username'; |
| 163 | 163 | |
| 164 | 164 | /* Doesn't work on Splunk 6.6 for HTTP exceptions |
@@ -177,8 +177,8 @@ discard block |
||
| 177 | 177 | |
| 178 | 178 | // A one shot search |
| 179 | 179 | $searchParams = array( |
| 180 | - 'earliest_time' => date("c",strtotime ($date)-120), |
|
| 181 | - 'latest_time' => date("c",strtotime ($date)+60) |
|
| 180 | + 'earliest_time' => date("c", strtotime($date)-120), |
|
| 181 | + 'latest_time' => date("c", strtotime($date)+60) |
|
| 182 | 182 | ); |
| 183 | 183 | |
| 184 | 184 | // Run a oneshot search that returns the job's results |
@@ -192,7 +192,7 @@ discard block |
||
| 192 | 192 | { |
| 193 | 193 | // More than one field attribute returned by search |
| 194 | 194 | // You must redefine the search |
| 195 | - if ( count($result->getFieldNames()) > 1 ) return FALSE; |
|
| 195 | + if (count($result->getFieldNames())>1) return FALSE; |
|
| 196 | 196 | } |
| 197 | 197 | else if ($result instanceof Splunk_ResultsMessage) |
| 198 | 198 | { |
@@ -224,51 +224,51 @@ discard block |
||
| 224 | 224 | } |
| 225 | 225 | |
| 226 | 226 | |
| 227 | -function imapReport ($cf,$myconnArray,$splunkconn,$tables,$type) { |
|
| 228 | - $file = dirname(__FILE__) . '/' . $cf['reportFile']["$type"]; |
|
| 229 | - $fileb= dirname(__FILE__) . '/' . $cf['badreportFile']["$type"]; |
|
| 230 | - $m_mail = imap_open('{'.$cf['mailhost'].':143/imap/novalidate-cert/authuser='.$cf['authuser'].'}'.$cf['folder']["$type"], $cf['account'],$cf['authpassword'], OP_READONLY) |
|
| 231 | - or syslog (LOG_EMERG, $cf['user'].': Error in IMAP connection to <'.$cf['mailhost'].'>: ' . imap_last_error()); |
|
| 232 | - if ( !$m_mail ) exit(254); |
|
| 227 | +function imapReport($cf, $myconnArray, $splunkconn, $tables, $type) { |
|
| 228 | + $file = dirname(__FILE__).'/'.$cf['reportFile']["$type"]; |
|
| 229 | + $fileb = dirname(__FILE__).'/'.$cf['badreportFile']["$type"]; |
|
| 230 | + $m_mail = imap_open('{'.$cf['mailhost'].':143/imap/novalidate-cert/authuser='.$cf['authuser'].'}'.$cf['folder']["$type"], $cf['account'], $cf['authpassword'], OP_READONLY) |
|
| 231 | + or syslog(LOG_EMERG, $cf['user'].': Error in IMAP connection to <'.$cf['mailhost'].'>: '.imap_last_error()); |
|
| 232 | + if (!$m_mail) exit(254); |
|
| 233 | 233 | |
| 234 | 234 | |
| 235 | - syslog (LOG_INFO,$cf['user'].': Successfully connected to <'.$cf['mailhost'].">; Reading $type messages of last ".$cf['oldestday'].' days...'); |
|
| 235 | + syslog(LOG_INFO, $cf['user'].': Successfully connected to <'.$cf['mailhost'].">; Reading $type messages of last ".$cf['oldestday'].' days...'); |
|
| 236 | 236 | //get all messages |
| 237 | - $dateTh = date ( "d-M-Y", strToTime ( '-'.$cf['oldestday'].' days' ) ); |
|
| 238 | - $dateN = date ( "d-M-Y", strToTime ( "now" ) ); |
|
| 239 | - $m_search=imap_search ($m_mail, "SINCE \"$dateTh\" BEFORE \"$dateN\"" ); |
|
| 237 | + $dateTh = date("d-M-Y", strToTime('-'.$cf['oldestday'].' days')); |
|
| 238 | + $dateN = date("d-M-Y", strToTime("now")); |
|
| 239 | + $m_search = imap_search($m_mail, "SINCE \"$dateTh\" BEFORE \"$dateN\""); |
|
| 240 | 240 | |
| 241 | 241 | |
| 242 | 242 | // Order results starting from newest message |
| 243 | - if ( empty($m_search) ) { |
|
| 244 | - syslog (LOG_INFO,$cf['user'].": No mail found in $type folder. No reports written for $type."); |
|
| 245 | - if ( $ierr = imap_errors() ) |
|
| 246 | - foreach ( $ierr as $thiserr ) |
|
| 247 | - syslog (LOG_ERR, $cf['user'].": IMAP Error: $thiserr"); |
|
| 248 | - if ( $ierr = imap_alerts() ) |
|
| 249 | - foreach ( $ierr as $thiserr ) |
|
| 250 | - syslog (LOG_ALERT, $cf['user'].": IMAP Alert: $thiserr"); |
|
| 251 | - imap_close( $m_mail ); |
|
| 252 | - if ( file_exists( $file ) ) unlink ($file); |
|
| 253 | - if ( file_exists( $fileb ) ) unlink ($fileb); |
|
| 243 | + if (empty($m_search)) { |
|
| 244 | + syslog(LOG_INFO, $cf['user'].": No mail found in $type folder. No reports written for $type."); |
|
| 245 | + if ($ierr = imap_errors()) |
|
| 246 | + foreach ($ierr as $thiserr) |
|
| 247 | + syslog(LOG_ERR, $cf['user'].": IMAP Error: $thiserr"); |
|
| 248 | + if ($ierr = imap_alerts()) |
|
| 249 | + foreach ($ierr as $thiserr) |
|
| 250 | + syslog(LOG_ALERT, $cf['user'].": IMAP Alert: $thiserr"); |
|
| 251 | + imap_close($m_mail); |
|
| 252 | + if (file_exists($file)) unlink($file); |
|
| 253 | + if (file_exists($fileb)) unlink($fileb); |
|
| 254 | 254 | return FALSE; |
| 255 | 255 | } |
| 256 | - $nmes = count ($m_search); |
|
| 257 | - syslog (LOG_INFO,$cf['user'].": Found $nmes mail in $type folder."); |
|
| 256 | + $nmes = count($m_search); |
|
| 257 | + syslog(LOG_INFO, $cf['user'].": Found $nmes mail in $type folder."); |
|
| 258 | 258 | if ($nmes>0) rsort($m_search); |
| 259 | 259 | |
| 260 | 260 | // Create report file |
| 261 | 261 | |
| 262 | 262 | $fp = fopen($file, 'w'); |
| 263 | - $fpb= fopen($fileb, 'w'); |
|
| 264 | - $lastup = "Last Update: " . date ("d F Y H:i", time()); |
|
| 265 | - fwrite( $fp, file_get_contents(dirname(__FILE__) . '/' . $cf['reportTemplateHeader']) ); |
|
| 266 | - fwrite( $fp,"<h1> Report of IP sending $type</h1><h5>$lastup</h5><h2>Detailed Report</h2>" ); |
|
| 267 | - if ($cf['onlyReport']) fwrite( $fp,'<p>None of the below IP has been listed because listing is not active in configuration.</p>'); |
|
| 268 | - fwrite( $fp,'<table><tr><th title="taken from Received header" nowrap>Date of Learn</th><th title="taken from Date header" nowrap>Date of Write</th><th nowrap>UID</th><th nowrap>IP</th><th title="How many times this uid learns">#UID</th><th title="Number of times this learned IP appears in different mails">#IP</th><th nowrap>Received by</th><th>Message-Id</th></tr>' ); |
|
| 269 | - fwrite( $fpb,file_get_contents(dirname(__FILE__) . '/' . $cf['reportTemplateHeader']) ); |
|
| 270 | - fwrite( $fpb,"<h1> Report of bad reported $type mails</h1><h5>$lastup</h5><h2>Detailed Report</h2>" ); |
|
| 271 | - fwrite( $fpb,'<table><tr><th title="taken from Received header" nowrap>Date Learn</th><th title="taken from Date header" nowrap>Date Received</th><th nowrap>UID</th><th>Message-Id</th><th title="Why is this a bad report?">Reason</th></tr>' ); |
|
| 263 | + $fpb = fopen($fileb, 'w'); |
|
| 264 | + $lastup = "Last Update: ".date("d F Y H:i", time()); |
|
| 265 | + fwrite($fp, file_get_contents(dirname(__FILE__).'/'.$cf['reportTemplateHeader'])); |
|
| 266 | + fwrite($fp, "<h1> Report of IP sending $type</h1><h5>$lastup</h5><h2>Detailed Report</h2>"); |
|
| 267 | + if ($cf['onlyReport']) fwrite($fp, '<p>None of the below IP has been listed because listing is not active in configuration.</p>'); |
|
| 268 | + fwrite($fp, '<table><tr><th title="taken from Received header" nowrap>Date of Learn</th><th title="taken from Date header" nowrap>Date of Write</th><th nowrap>UID</th><th nowrap>IP</th><th title="How many times this uid learns">#UID</th><th title="Number of times this learned IP appears in different mails">#IP</th><th nowrap>Received by</th><th>Message-Id</th></tr>'); |
|
| 269 | + fwrite($fpb, file_get_contents(dirname(__FILE__).'/'.$cf['reportTemplateHeader'])); |
|
| 270 | + fwrite($fpb, "<h1> Report of bad reported $type mails</h1><h5>$lastup</h5><h2>Detailed Report</h2>"); |
|
| 271 | + fwrite($fpb, '<table><tr><th title="taken from Received header" nowrap>Date Learn</th><th title="taken from Date header" nowrap>Date Received</th><th nowrap>UID</th><th>Message-Id</th><th title="Why is this a bad report?">Reason</th></tr>'); |
|
| 272 | 272 | |
| 273 | 273 | $ipuid = array(); |
| 274 | 274 | $ipuid['count'] = 0; |
@@ -286,69 +286,69 @@ discard block |
||
| 286 | 286 | //get imap header info for obj thang |
| 287 | 287 | //$headers = imap_headerinfo($m_mail, $onem); |
| 288 | 288 | //$head = imap_fetchheader($m_mail, $headers->Msgno); |
| 289 | - $head = imap_fetchheader($m_mail, $onem ); |
|
| 289 | + $head = imap_fetchheader($m_mail, $onem); |
|
| 290 | 290 | //$obj = imap_rfc822_parse_headers( $head); |
| 291 | 291 | |
| 292 | - list ($ip,$host,$dateReceived,$dateClient,$mid) = getIP( $head,$cf['mx'],$cf['msalearn'] ); |
|
| 292 | + list ($ip, $host, $dateReceived, $dateClient, $mid) = getIP($head, $cf['mx'], $cf['msalearn']); |
|
| 293 | 293 | if (empty($mid)) { |
| 294 | - $uid='NA'; |
|
| 295 | - syslog (LOG_ERR, $cf['user'].": Error retrieving data for empty Message-ID."); |
|
| 296 | - } else { |
|
| 294 | + $uid = 'NA'; |
|
| 295 | + syslog(LOG_ERR, $cf['user'].": Error retrieving data for empty Message-ID."); |
|
| 296 | + }else { |
|
| 297 | 297 | if ($dateReceived === FALSE) { |
| 298 | - $uid='unauthenticated'; |
|
| 299 | - syslog (LOG_ERR, $cf['user'].": Error retrieving date for $mid. Maybe this mail was not submitted to Learner MSA"); |
|
| 300 | - } else |
|
| 301 | - if ( !($uid = splunksearch ($splunkconn, trim($mid,'<>'), $dateReceived)) ) { |
|
| 302 | - syslog (LOG_ERR, $cf['user'].": Error retrieving uid from Splunk log for $mid."); |
|
| 303 | - $uid='unknown'; |
|
| 298 | + $uid = 'unauthenticated'; |
|
| 299 | + syslog(LOG_ERR, $cf['user'].": Error retrieving date for $mid. Maybe this mail was not submitted to Learner MSA"); |
|
| 300 | + }else |
|
| 301 | + if (!($uid = splunksearch($splunkconn, trim($mid, '<>'), $dateReceived))) { |
|
| 302 | + syslog(LOG_ERR, $cf['user'].": Error retrieving uid from Splunk log for $mid."); |
|
| 303 | + $uid = 'unknown'; |
|
| 304 | 304 | } |
| 305 | 305 | } |
| 306 | 306 | |
| 307 | 307 | /* Update count of each ip */ |
| 308 | - if ($host and ($uid!='NA') and ($uid!='unauthenticated') and ($uid!='unknown')) { /* IP is received by MX servers and learned by valid uid */ |
|
| 309 | - $ipuid['count']++; //number of right messages |
|
| 308 | + if ($host and ($uid != 'NA') and ($uid != 'unauthenticated') and ($uid != 'unknown')) { /* IP is received by MX servers and learned by valid uid */ |
|
| 309 | + $ipuid['count']++; //number of right messages |
|
| 310 | 310 | |
| 311 | - if (in_array($uid,array_keys($ipuid['uid']))) { |
|
| 312 | - $ipuid['uid']["$uid"]['count']++; //number of learn by this uid |
|
| 313 | - if (!in_array($ip,$ipuid['uid']["$uid"])) |
|
| 314 | - $ipuid['uid']["$uid"][]=$ip; //ips learned by this uid |
|
| 311 | + if (in_array($uid, array_keys($ipuid['uid']))) { |
|
| 312 | + $ipuid['uid']["$uid"]['count']++; //number of learn by this uid |
|
| 313 | + if (!in_array($ip, $ipuid['uid']["$uid"])) |
|
| 314 | + $ipuid['uid']["$uid"][] = $ip; //ips learned by this uid |
|
| 315 | 315 | } |
| 316 | 316 | else { |
| 317 | 317 | $ipuid['uid']["$uid"]['count'] = 1; |
| 318 | - $ipuid['uid']["$uid"][]=$ip; |
|
| 319 | - $ipuid['uid']['count']++; //number of unique uids |
|
| 318 | + $ipuid['uid']["$uid"][] = $ip; |
|
| 319 | + $ipuid['uid']['count']++; //number of unique uids |
|
| 320 | 320 | } |
| 321 | 321 | |
| 322 | - if (in_array($ip,array_keys($ipuid['ip']))) { |
|
| 323 | - $ipuid['ip']["$ip"]['count']++; //number of time this ip appears in different messages |
|
| 324 | - if (!in_array($uid,$ipuid['ip']["$ip"])) |
|
| 325 | - $ipuid['ip']["$ip"][]=$uid; //uids that learned this ip |
|
| 322 | + if (in_array($ip, array_keys($ipuid['ip']))) { |
|
| 323 | + $ipuid['ip']["$ip"]['count']++; //number of time this ip appears in different messages |
|
| 324 | + if (!in_array($uid, $ipuid['ip']["$ip"])) |
|
| 325 | + $ipuid['ip']["$ip"][] = $uid; //uids that learned this ip |
|
| 326 | 326 | } |
| 327 | 327 | else { |
| 328 | 328 | $ipuid['ip']["$ip"]['count'] = 1; |
| 329 | - $ipuid['ip']["$ip"][]=$uid; |
|
| 330 | - $ipuid['ip']['count']++; //number of unique ips |
|
| 329 | + $ipuid['ip']["$ip"][] = $uid; |
|
| 330 | + $ipuid['ip']['count']++; //number of unique ips |
|
| 331 | 331 | } |
| 332 | 332 | |
| 333 | 333 | /* Update HTML report */ |
| 334 | - fwrite($fp,updateReport ( $ip,$uid,$ipuid['ip']["$ip"]['count'],$ipuid['uid']["$uid"]['count'],$host,$dateClient,$mid,$dateReceived) ); |
|
| 334 | + fwrite($fp, updateReport($ip, $uid, $ipuid['ip']["$ip"]['count'], $ipuid['uid']["$uid"]['count'], $host, $dateClient, $mid, $dateReceived)); |
|
| 335 | 335 | } |
| 336 | 336 | else { /* Bad learn */ |
| 337 | 337 | |
| 338 | - if (in_array($uid,array_keys($uidbad['uid']))) |
|
| 339 | - $uidbad['uid']["$uid"]['count']++; //number of bad learn by this uid |
|
| 338 | + if (in_array($uid, array_keys($uidbad['uid']))) |
|
| 339 | + $uidbad['uid']["$uid"]['count']++; //number of bad learn by this uid |
|
| 340 | 340 | else { |
| 341 | 341 | $uidbad['uid']["$uid"]['count'] = 1; |
| 342 | - $uidbad['uid']["$uid"][]=$uid; |
|
| 343 | - $uidbad['count']++; //numeber of unique bad uids |
|
| 342 | + $uidbad['uid']["$uid"][] = $uid; |
|
| 343 | + $uidbad['count']++; //numeber of unique bad uids |
|
| 344 | 344 | } |
| 345 | 345 | /* The reason of bad report */ |
| 346 | 346 | if ($host === FALSE) $reason = 'This mail was not received by recognized MX host'; |
| 347 | 347 | if ($dateReceived === FALSE) $reason = 'This mail was not submitted to recognized MSA for learn'; |
| 348 | - if ($uid=='unknown') $reason = 'The uid of this mail was not found in splunk log'; |
|
| 348 | + if ($uid == 'unknown') $reason = 'The uid of this mail was not found in splunk log'; |
|
| 349 | 349 | if (!isset($reason)) $reason = '?'; |
| 350 | 350 | |
| 351 | - fwrite( $fpb,updatebadReport ( $uid,$dateClient,$mid,$dateReceived,$reason ) ); |
|
| 351 | + fwrite($fpb, updatebadReport($uid, $dateClient, $mid, $dateReceived, $reason)); |
|
| 352 | 352 | } |
| 353 | 353 | } |
| 354 | 354 | |
@@ -356,45 +356,45 @@ discard block |
||
| 356 | 356 | //close report file and mailbox |
| 357 | 357 | |
| 358 | 358 | /* Summary Report */ |
| 359 | - $ipuid['ip'] = array_msort( $ipuid['ip'], array('count'=>SORT_DESC) ); |
|
| 360 | - $ipuid['uid'] = array_msort( $ipuid['uid'], array('count'=>SORT_DESC) ); |
|
| 361 | - $uidbad['uid'] = array_msort( $uidbad['uid'], array('count'=>SORT_DESC) ); |
|
| 359 | + $ipuid['ip'] = array_msort($ipuid['ip'], array('count'=>SORT_DESC)); |
|
| 360 | + $ipuid['uid'] = array_msort($ipuid['uid'], array('count'=>SORT_DESC)); |
|
| 361 | + $uidbad['uid'] = array_msort($uidbad['uid'], array('count'=>SORT_DESC)); |
|
| 362 | 362 | |
| 363 | 363 | fwrite($fp, '</table>'); |
| 364 | - fwrite($fp, '<hr><h2>Summary Report</h2><h5>Listing policy: ip must be learned at least '.$cf['thresholdip']["$type"].' times from at least '.$cf['thresholduid']["$type"].' different valid uids.</h5>' ); |
|
| 364 | + fwrite($fp, '<hr><h2>Summary Report</h2><h5>Listing policy: ip must be learned at least '.$cf['thresholdip']["$type"].' times from at least '.$cf['thresholduid']["$type"].' different valid uids.</h5>'); |
|
| 365 | 365 | |
| 366 | 366 | /* Make MYSQL connection */ |
| 367 | - if ( $cf['onlyReport'] ) |
|
| 367 | + if ($cf['onlyReport']) |
|
| 368 | 368 | $mysqli = NULL; |
| 369 | 369 | else { |
| 370 | 370 | $mysqli = new mysqli($myconnArray['dbhost'], $myconnArray['userdb'], $myconnArray['pwd'], $myconnArray['db'], $myconnArray['dbport']); |
| 371 | 371 | if ($mysqli->connect_error) { |
| 372 | - syslog (LOG_EMERG, $cf['user'].': Connect Error (' . $mysqli->connect_errno . ') ' |
|
| 372 | + syslog(LOG_EMERG, $cf['user'].': Connect Error ('.$mysqli->connect_errno.') ' |
|
| 373 | 373 | . $mysqli->connect_error); |
| 374 | 374 | exit (254); |
| 375 | 375 | } |
| 376 | - syslog(LOG_INFO, $cf['user'].': Successfully mysql connected to ' . $mysqli->host_info) ; |
|
| 376 | + syslog(LOG_INFO, $cf['user'].': Successfully mysql connected to '.$mysqli->host_info); |
|
| 377 | 377 | } |
| 378 | 378 | /***********************/ |
| 379 | 379 | |
| 380 | - fwrite($fp, summaryReportAndList ($cf,$mysqli,$tables,$type,$ipuid) ); |
|
| 381 | - if ( !$cf['onlyReport'] ) |
|
| 380 | + fwrite($fp, summaryReportAndList($cf, $mysqli, $tables, $type, $ipuid)); |
|
| 381 | + if (!$cf['onlyReport']) |
|
| 382 | 382 | $mysqli->close(); |
| 383 | - fwrite($fp,file_get_contents(dirname(__FILE__) . '/' . $cf['reportTemplateFooter'])); |
|
| 383 | + fwrite($fp, file_get_contents(dirname(__FILE__).'/'.$cf['reportTemplateFooter'])); |
|
| 384 | 384 | fclose($fp); |
| 385 | 385 | |
| 386 | 386 | fwrite($fpb, '</table>'); |
| 387 | - fwrite( $fpb,summaryBadReport( $uidbad ) ); |
|
| 388 | - fwrite($fpb,file_get_contents(dirname(__FILE__) . '/' . $cf['reportTemplateFooter'])); |
|
| 387 | + fwrite($fpb, summaryBadReport($uidbad)); |
|
| 388 | + fwrite($fpb, file_get_contents(dirname(__FILE__).'/'.$cf['reportTemplateFooter'])); |
|
| 389 | 389 | fclose($fpb); |
| 390 | - syslog (LOG_INFO,$cf['user'].': Report files written. Listing job for '.$type.' terminated.'); |
|
| 391 | - |
|
| 392 | - if ( $ierr = imap_errors() ) |
|
| 393 | - foreach ( $ierr as $thiserr ) |
|
| 394 | - syslog (LOG_ERR, $cf['user'].": IMAP Error: $thiserr"); |
|
| 395 | - if ( $ierr = imap_alerts() ) |
|
| 396 | - foreach ( $ierr as $thiserr ) |
|
| 397 | - syslog (LOG_ALERT, $cf['user'].": IMAP Alert: $thiserr"); |
|
| 390 | + syslog(LOG_INFO, $cf['user'].': Report files written. Listing job for '.$type.' terminated.'); |
|
| 391 | + |
|
| 392 | + if ($ierr = imap_errors()) |
|
| 393 | + foreach ($ierr as $thiserr) |
|
| 394 | + syslog(LOG_ERR, $cf['user'].": IMAP Error: $thiserr"); |
|
| 395 | + if ($ierr = imap_alerts()) |
|
| 396 | + foreach ($ierr as $thiserr) |
|
| 397 | + syslog(LOG_ALERT, $cf['user'].": IMAP Alert: $thiserr"); |
|
| 398 | 398 | imap_close($m_mail); |
| 399 | 399 | } |
| 400 | 400 | ?> |
@@ -10,21 +10,25 @@ discard block |
||
| 10 | 10 | if ( preg_match_all('/^Received:\sfrom(?:.|\r\n\s)*?[\[\(]\s*(?P<ip>\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3})[\]\)](?:.|\r\n\s)+\s+by(?:\s|\r\n\s+)(?P<host>\S+).*(?:\s|\r\n\s\s)+.*;\s+(?P<date>.*)/m',$header,$received) ) { |
| 11 | 11 | for ($i = count($received[0])-1;$i>=0;$i--) { |
| 12 | 12 | # print "Examine ".$received[0][$i]."\n"; |
| 13 | - if ( preg_match($msa,$received['host'][$i]) ) |
|
| 14 | - $dateR = $received['date'][$i]; |
|
| 13 | + if ( preg_match($msa,$received['host'][$i]) ) { |
|
| 14 | + $dateR = $received['date'][$i]; |
|
| 15 | + } |
|
| 15 | 16 | foreach ($mxserver as $mx) { |
| 16 | - if (!$ip) |
|
| 17 | - if ($mx == $received['host'][$i]) { |
|
| 17 | + if (!$ip) { |
|
| 18 | + if ($mx == $received['host'][$i]) { |
|
| 18 | 19 | $host = $received['host'][$i]; |
| 20 | + } |
|
| 19 | 21 | $ip = $received['ip'][$i]; |
| 20 | 22 | } |
| 21 | 23 | } |
| 22 | 24 | } |
| 23 | 25 | } |
| 24 | - if ( preg_match ('/\r\nDate:\s(?P<date>.*)\r\n/',$header,$dateC) != 1) |
|
| 25 | - $dateC['date'] = 'Not found'; |
|
| 26 | - if ( preg_match ('/\r\nMessage\-I(?:D|d):\s(?P<mid>.*)\r\n/',$header,$mid) != 1) |
|
| 27 | - $mid['mid'] = NULL; |
|
| 26 | + if ( preg_match ('/\r\nDate:\s(?P<date>.*)\r\n/',$header,$dateC) != 1) { |
|
| 27 | + $dateC['date'] = 'Not found'; |
|
| 28 | + } |
|
| 29 | + if ( preg_match ('/\r\nMessage\-I(?:D|d):\s(?P<mid>.*)\r\n/',$header,$mid) != 1) { |
|
| 30 | + $mid['mid'] = NULL; |
|
| 31 | + } |
|
| 28 | 32 | return array($ip,$host,$dateR,$dateC['date'],$mid['mid']); |
| 29 | 33 | } |
| 30 | 34 | |
@@ -40,7 +44,9 @@ discard block |
||
| 40 | 44 | |
| 41 | 45 | function summaryBadReport ($uidvet) { |
| 42 | 46 | $nuid = $uidvet['count']; |
| 43 | - if ( empty($uidvet) ) return NULL; |
|
| 47 | + if ( empty($uidvet) ) { |
|
| 48 | + return NULL; |
|
| 49 | + } |
|
| 44 | 50 | $return = '<hr><h3>Statistics by UID</h3><table><tr><th>UID</th><th>Learned times</th></tr>'."\n"; |
| 45 | 51 | |
| 46 | 52 | /* Remove count index */ |
@@ -75,8 +81,12 @@ discard block |
||
| 75 | 81 | foreach ($colarr as $col => $arr) { |
| 76 | 82 | foreach ($arr as $k => $v) { |
| 77 | 83 | $k = substr($k,1); |
| 78 | - if (!isset($ret[$k])) $ret[$k] = $array[$k]; |
|
| 79 | - if (isset ($array[$k][$col])) $ret[$k][$col] = $array[$k][$col]; |
|
| 84 | + if (!isset($ret[$k])) { |
|
| 85 | + $ret[$k] = $array[$k]; |
|
| 86 | + } |
|
| 87 | + if (isset ($array[$k][$col])) { |
|
| 88 | + $ret[$k][$col] = $array[$k][$col]; |
|
| 89 | + } |
|
| 80 | 90 | } |
| 81 | 91 | } |
| 82 | 92 | return $ret; |
@@ -87,13 +97,17 @@ discard block |
||
| 87 | 97 | function summaryReportAndList ($cf,$myconn,$tables,$category,$ipvet) { |
| 88 | 98 | $nips = $ipvet['count']; |
| 89 | 99 | |
| 90 | - if ( empty($ipvet) ) return NULL; |
|
| 100 | + if ( empty($ipvet) ) { |
|
| 101 | + return NULL; |
|
| 102 | + } |
|
| 91 | 103 | $return = '<h3>Statistics by IP</h3><table><tr><th>IP</th><th>Learned by</th><th>Learned times</th><th title="This field doesn\'t say if this ip is currently listed, but it says if this IP has listed now!">Listed Now</th></tr>'."\n"; |
| 92 | 104 | |
| 93 | 105 | $ips = array_keys($ipvet['ip']); |
| 94 | 106 | |
| 95 | 107 | foreach ( $ips as $ip ) { |
| 96 | - if ( $ip == 'count' ) continue; |
|
| 108 | + if ( $ip == 'count' ) { |
|
| 109 | + continue; |
|
| 110 | + } |
|
| 97 | 111 | $nlearn = $ipvet['ip']["$ip"]['count']; |
| 98 | 112 | unset($ipvet['ip']["$ip"]['count']); |
| 99 | 113 | $quantity = $cf['quantity']["$category"]; /* In searchAndList this value is passed by reference and modified */ |
@@ -102,10 +116,12 @@ discard block |
||
| 102 | 116 | if ( ($nlearn >= $cf['thresholdip']["$category"])&&($nuid >= $cf['thresholduid']["$category"]) ) { |
| 103 | 117 | $reason = "The IP <$ip> has been listed because was marked $nlearn times as $category by $nuid different accounts during last ".$cf['oldestday'].' days.'; |
| 104 | 118 | $listed = searchAndList ($myconn,$cf['user'],$tables,$cf['list']["$category"],$ip,$cf['unit']["$category"],$quantity,$reason); |
| 119 | + } else { |
|
| 120 | + $listed = FALSE; |
|
| 105 | 121 | } |
| 106 | - else $listed = FALSE; |
|
| 122 | + } else { |
|
| 123 | + $listed = FALSE; |
|
| 107 | 124 | } |
| 108 | - else $listed = FALSE; |
|
| 109 | 125 | $nowlist = array( TRUE => array( |
| 110 | 126 | 'style' => 'id=\'ipfound\'', |
| 111 | 127 | 'name' => 'YES', |
@@ -123,7 +139,9 @@ discard block |
||
| 123 | 139 | $return .='<tr><td rowspan="'.$nuid.'">'.$ip.'</td>'; |
| 124 | 140 | $return .= sprintf ('<td>%s</td><td rowspan="'.$nuid.'">%u</td><td rowspan="'.$nuid.'" '.$nowlist["$listed"]['style'].'>%s</td></tr>',$ipvet['ip']["$ip"][0],$nlearn,$nowlist["$listed"]['name']); |
| 125 | 141 | $rowuid=NULL; |
| 126 | - for ($j=1;$j<$nuid;$j++) $rowuid .= '<tr><td>%s</td></tr>'; |
|
| 142 | + for ($j=1;$j<$nuid;$j++) { |
|
| 143 | + $rowuid .= '<tr><td>%s</td></tr>'; |
|
| 144 | + } |
|
| 127 | 145 | array_shift($ipvet['ip']["$ip"]); |
| 128 | 146 | $return .= vsprintf ($rowuid,$ipvet['ip']["$ip"]); |
| 129 | 147 | |
@@ -136,14 +154,18 @@ discard block |
||
| 136 | 154 | $return .= '<h3>Statistics by UID</h3><table><tr><th>UID</th><th>IP learned</th><th>Learned times</th></tr>'."\n"; |
| 137 | 155 | $uids = array_keys($ipvet['uid']); |
| 138 | 156 | foreach ( $uids as $uid ) { |
| 139 | - if ( $uid == 'count' ) continue; |
|
| 157 | + if ( $uid == 'count' ) { |
|
| 158 | + continue; |
|
| 159 | + } |
|
| 140 | 160 | $nlearn = $ipvet['uid']["$uid"]['count']; |
| 141 | 161 | unset ( $ipvet['uid']["$uid"]['count'] ); |
| 142 | 162 | $nip = count($ipvet['uid']["$uid"]); |
| 143 | 163 | $return .='<tr><td rowspan="'.$nip.'">'.$uid.'</td>'; |
| 144 | 164 | $return .= sprintf ('<td>%s</td><td rowspan="'.$nip.'">%u</td></tr>',$ipvet['uid']["$uid"][0],$nlearn); |
| 145 | 165 | $rowuid=NULL; |
| 146 | - for ($j=1;$j<$nip;$j++) $rowuid .= '<tr><td>%s</td></tr>'; |
|
| 166 | + for ($j=1;$j<$nip;$j++) { |
|
| 167 | + $rowuid .= '<tr><td>%s</td></tr>'; |
|
| 168 | + } |
|
| 147 | 169 | array_shift($ipvet['uid']["$uid"]); |
| 148 | 170 | $return .= vsprintf ($rowuid,$ipvet['uid']["$uid"]); |
| 149 | 171 | |
@@ -192,14 +214,14 @@ discard block |
||
| 192 | 214 | { |
| 193 | 215 | // More than one field attribute returned by search |
| 194 | 216 | // You must redefine the search |
| 195 | - if ( count($result->getFieldNames()) > 1 ) return FALSE; |
|
| 196 | - } |
|
| 197 | - else if ($result instanceof Splunk_ResultsMessage) |
|
| 217 | + if ( count($result->getFieldNames()) > 1 ) { |
|
| 218 | + return FALSE; |
|
| 219 | + } |
|
| 220 | + } else if ($result instanceof Splunk_ResultsMessage) |
|
| 198 | 221 | { |
| 199 | 222 | // I don't want messages in my search |
| 200 | 223 | return FALSE; |
| 201 | - } |
|
| 202 | - else if (is_array($result)) |
|
| 224 | + } else if (is_array($result)) |
|
| 203 | 225 | { |
| 204 | 226 | // Process a row |
| 205 | 227 | foreach ($result as $key => $valueOrValues) |
@@ -207,15 +229,13 @@ discard block |
||
| 207 | 229 | if (is_array($valueOrValues)) |
| 208 | 230 | { |
| 209 | 231 | return FALSE; |
| 210 | - } |
|
| 211 | - else |
|
| 232 | + } else |
|
| 212 | 233 | { |
| 213 | 234 | return $valueOrValues; |
| 214 | 235 | #print " {$key} => {$value}\r\n"; |
| 215 | 236 | } |
| 216 | 237 | } |
| 217 | - } |
|
| 218 | - else |
|
| 238 | + } else |
|
| 219 | 239 | { |
| 220 | 240 | #print "Unknow result type"; |
| 221 | 241 | return FALSE; |
@@ -229,7 +249,9 @@ discard block |
||
| 229 | 249 | $fileb= dirname(__FILE__) . '/' . $cf['badreportFile']["$type"]; |
| 230 | 250 | $m_mail = imap_open('{'.$cf['mailhost'].':143/imap/novalidate-cert/authuser='.$cf['authuser'].'}'.$cf['folder']["$type"], $cf['account'],$cf['authpassword'], OP_READONLY) |
| 231 | 251 | or syslog (LOG_EMERG, $cf['user'].': Error in IMAP connection to <'.$cf['mailhost'].'>: ' . imap_last_error()); |
| 232 | - if ( !$m_mail ) exit(254); |
|
| 252 | + if ( !$m_mail ) { |
|
| 253 | + exit(254); |
|
| 254 | + } |
|
| 233 | 255 | |
| 234 | 256 | |
| 235 | 257 | syslog (LOG_INFO,$cf['user'].': Successfully connected to <'.$cf['mailhost'].">; Reading $type messages of last ".$cf['oldestday'].' days...'); |
@@ -242,20 +264,28 @@ discard block |
||
| 242 | 264 | // Order results starting from newest message |
| 243 | 265 | if ( empty($m_search) ) { |
| 244 | 266 | syslog (LOG_INFO,$cf['user'].": No mail found in $type folder. No reports written for $type."); |
| 245 | - if ( $ierr = imap_errors() ) |
|
| 246 | - foreach ( $ierr as $thiserr ) |
|
| 267 | + if ( $ierr = imap_errors() ) { |
|
| 268 | + foreach ( $ierr as $thiserr ) |
|
| 247 | 269 | syslog (LOG_ERR, $cf['user'].": IMAP Error: $thiserr"); |
| 248 | - if ( $ierr = imap_alerts() ) |
|
| 249 | - foreach ( $ierr as $thiserr ) |
|
| 270 | + } |
|
| 271 | + if ( $ierr = imap_alerts() ) { |
|
| 272 | + foreach ( $ierr as $thiserr ) |
|
| 250 | 273 | syslog (LOG_ALERT, $cf['user'].": IMAP Alert: $thiserr"); |
| 274 | + } |
|
| 251 | 275 | imap_close( $m_mail ); |
| 252 | - if ( file_exists( $file ) ) unlink ($file); |
|
| 253 | - if ( file_exists( $fileb ) ) unlink ($fileb); |
|
| 276 | + if ( file_exists( $file ) ) { |
|
| 277 | + unlink ($file); |
|
| 278 | + } |
|
| 279 | + if ( file_exists( $fileb ) ) { |
|
| 280 | + unlink ($fileb); |
|
| 281 | + } |
|
| 254 | 282 | return FALSE; |
| 255 | 283 | } |
| 256 | 284 | $nmes = count ($m_search); |
| 257 | 285 | syslog (LOG_INFO,$cf['user'].": Found $nmes mail in $type folder."); |
| 258 | - if ($nmes>0) rsort($m_search); |
|
| 286 | + if ($nmes>0) { |
|
| 287 | + rsort($m_search); |
|
| 288 | + } |
|
| 259 | 289 | |
| 260 | 290 | // Create report file |
| 261 | 291 | |
@@ -264,7 +294,9 @@ discard block |
||
| 264 | 294 | $lastup = "Last Update: " . date ("d F Y H:i", time()); |
| 265 | 295 | fwrite( $fp, file_get_contents(dirname(__FILE__) . '/' . $cf['reportTemplateHeader']) ); |
| 266 | 296 | fwrite( $fp,"<h1> Report of IP sending $type</h1><h5>$lastup</h5><h2>Detailed Report</h2>" ); |
| 267 | - if ($cf['onlyReport']) fwrite( $fp,'<p>None of the below IP has been listed because listing is not active in configuration.</p>'); |
|
| 297 | + if ($cf['onlyReport']) { |
|
| 298 | + fwrite( $fp,'<p>None of the below IP has been listed because listing is not active in configuration.</p>'); |
|
| 299 | + } |
|
| 268 | 300 | fwrite( $fp,'<table><tr><th title="taken from Received header" nowrap>Date of Learn</th><th title="taken from Date header" nowrap>Date of Write</th><th nowrap>UID</th><th nowrap>IP</th><th title="How many times this uid learns">#UID</th><th title="Number of times this learned IP appears in different mails">#IP</th><th nowrap>Received by</th><th>Message-Id</th></tr>' ); |
| 269 | 301 | fwrite( $fpb,file_get_contents(dirname(__FILE__) . '/' . $cf['reportTemplateHeader']) ); |
| 270 | 302 | fwrite( $fpb,"<h1> Report of bad reported $type mails</h1><h5>$lastup</h5><h2>Detailed Report</h2>" ); |
@@ -310,10 +342,11 @@ discard block |
||
| 310 | 342 | |
| 311 | 343 | if (in_array($uid,array_keys($ipuid['uid']))) { |
| 312 | 344 | $ipuid['uid']["$uid"]['count']++; //number of learn by this uid |
| 313 | - if (!in_array($ip,$ipuid['uid']["$uid"])) |
|
| 314 | - $ipuid['uid']["$uid"][]=$ip; //ips learned by this uid |
|
| 315 | - } |
|
| 316 | - else { |
|
| 345 | + if (!in_array($ip,$ipuid['uid']["$uid"])) { |
|
| 346 | + $ipuid['uid']["$uid"][]=$ip; |
|
| 347 | + } |
|
| 348 | + //ips learned by this uid |
|
| 349 | + } else { |
|
| 317 | 350 | $ipuid['uid']["$uid"]['count'] = 1; |
| 318 | 351 | $ipuid['uid']["$uid"][]=$ip; |
| 319 | 352 | $ipuid['uid']['count']++; //number of unique uids |
@@ -321,10 +354,11 @@ discard block |
||
| 321 | 354 | |
| 322 | 355 | if (in_array($ip,array_keys($ipuid['ip']))) { |
| 323 | 356 | $ipuid['ip']["$ip"]['count']++; //number of time this ip appears in different messages |
| 324 | - if (!in_array($uid,$ipuid['ip']["$ip"])) |
|
| 325 | - $ipuid['ip']["$ip"][]=$uid; //uids that learned this ip |
|
| 326 | - } |
|
| 327 | - else { |
|
| 357 | + if (!in_array($uid,$ipuid['ip']["$ip"])) { |
|
| 358 | + $ipuid['ip']["$ip"][]=$uid; |
|
| 359 | + } |
|
| 360 | + //uids that learned this ip |
|
| 361 | + } else { |
|
| 328 | 362 | $ipuid['ip']["$ip"]['count'] = 1; |
| 329 | 363 | $ipuid['ip']["$ip"][]=$uid; |
| 330 | 364 | $ipuid['ip']['count']++; //number of unique ips |
@@ -332,21 +366,30 @@ discard block |
||
| 332 | 366 | |
| 333 | 367 | /* Update HTML report */ |
| 334 | 368 | fwrite($fp,updateReport ( $ip,$uid,$ipuid['ip']["$ip"]['count'],$ipuid['uid']["$uid"]['count'],$host,$dateClient,$mid,$dateReceived) ); |
| 335 | - } |
|
| 336 | - else { /* Bad learn */ |
|
| 369 | + } else { /* Bad learn */ |
|
| 337 | 370 | |
| 338 | - if (in_array($uid,array_keys($uidbad['uid']))) |
|
| 339 | - $uidbad['uid']["$uid"]['count']++; //number of bad learn by this uid |
|
| 371 | + if (in_array($uid,array_keys($uidbad['uid']))) { |
|
| 372 | + $uidbad['uid']["$uid"]['count']++; |
|
| 373 | + } |
|
| 374 | + //number of bad learn by this uid |
|
| 340 | 375 | else { |
| 341 | 376 | $uidbad['uid']["$uid"]['count'] = 1; |
| 342 | 377 | $uidbad['uid']["$uid"][]=$uid; |
| 343 | 378 | $uidbad['count']++; //numeber of unique bad uids |
| 344 | 379 | } |
| 345 | 380 | /* The reason of bad report */ |
| 346 | - if ($host === FALSE) $reason = 'This mail was not received by recognized MX host'; |
|
| 347 | - if ($dateReceived === FALSE) $reason = 'This mail was not submitted to recognized MSA for learn'; |
|
| 348 | - if ($uid=='unknown') $reason = 'The uid of this mail was not found in splunk log'; |
|
| 349 | - if (!isset($reason)) $reason = '?'; |
|
| 381 | + if ($host === FALSE) { |
|
| 382 | + $reason = 'This mail was not received by recognized MX host'; |
|
| 383 | + } |
|
| 384 | + if ($dateReceived === FALSE) { |
|
| 385 | + $reason = 'This mail was not submitted to recognized MSA for learn'; |
|
| 386 | + } |
|
| 387 | + if ($uid=='unknown') { |
|
| 388 | + $reason = 'The uid of this mail was not found in splunk log'; |
|
| 389 | + } |
|
| 390 | + if (!isset($reason)) { |
|
| 391 | + $reason = '?'; |
|
| 392 | + } |
|
| 350 | 393 | |
| 351 | 394 | fwrite( $fpb,updatebadReport ( $uid,$dateClient,$mid,$dateReceived,$reason ) ); |
| 352 | 395 | } |
@@ -364,9 +407,9 @@ discard block |
||
| 364 | 407 | fwrite($fp, '<hr><h2>Summary Report</h2><h5>Listing policy: ip must be learned at least '.$cf['thresholdip']["$type"].' times from at least '.$cf['thresholduid']["$type"].' different valid uids.</h5>' ); |
| 365 | 408 | |
| 366 | 409 | /* Make MYSQL connection */ |
| 367 | - if ( $cf['onlyReport'] ) |
|
| 368 | - $mysqli = NULL; |
|
| 369 | - else { |
|
| 410 | + if ( $cf['onlyReport'] ) { |
|
| 411 | + $mysqli = NULL; |
|
| 412 | + } else { |
|
| 370 | 413 | $mysqli = new mysqli($myconnArray['dbhost'], $myconnArray['userdb'], $myconnArray['pwd'], $myconnArray['db'], $myconnArray['dbport']); |
| 371 | 414 | if ($mysqli->connect_error) { |
| 372 | 415 | syslog (LOG_EMERG, $cf['user'].': Connect Error (' . $mysqli->connect_errno . ') ' |
@@ -378,8 +421,9 @@ discard block |
||
| 378 | 421 | /***********************/ |
| 379 | 422 | |
| 380 | 423 | fwrite($fp, summaryReportAndList ($cf,$mysqli,$tables,$type,$ipuid) ); |
| 381 | - if ( !$cf['onlyReport'] ) |
|
| 382 | - $mysqli->close(); |
|
| 424 | + if ( !$cf['onlyReport'] ) { |
|
| 425 | + $mysqli->close(); |
|
| 426 | + } |
|
| 383 | 427 | fwrite($fp,file_get_contents(dirname(__FILE__) . '/' . $cf['reportTemplateFooter'])); |
| 384 | 428 | fclose($fp); |
| 385 | 429 | |
@@ -389,12 +433,14 @@ discard block |
||
| 389 | 433 | fclose($fpb); |
| 390 | 434 | syslog (LOG_INFO,$cf['user'].': Report files written. Listing job for '.$type.' terminated.'); |
| 391 | 435 | |
| 392 | - if ( $ierr = imap_errors() ) |
|
| 393 | - foreach ( $ierr as $thiserr ) |
|
| 436 | + if ( $ierr = imap_errors() ) { |
|
| 437 | + foreach ( $ierr as $thiserr ) |
|
| 394 | 438 | syslog (LOG_ERR, $cf['user'].": IMAP Error: $thiserr"); |
| 395 | - if ( $ierr = imap_alerts() ) |
|
| 396 | - foreach ( $ierr as $thiserr ) |
|
| 439 | + } |
|
| 440 | + if ( $ierr = imap_alerts() ) { |
|
| 441 | + foreach ( $ierr as $thiserr ) |
|
| 397 | 442 | syslog (LOG_ALERT, $cf['user'].": IMAP Alert: $thiserr"); |
| 443 | + } |
|
| 398 | 444 | imap_close($m_mail); |
| 399 | 445 | } |
| 400 | 446 | ?> |
@@ -44,8 +44,8 @@ discard block |
||
| 44 | 44 | } |
| 45 | 45 | if (! empty($old) ) { |
| 46 | 46 | foreach ($old as $item) { |
| 47 | - if (! in_array($item, $new) ) { |
|
| 48 | - $values["$item"] = 'del'; |
|
| 47 | + if (! in_array($item, $new) ) { |
|
| 48 | + $values["$item"] = 'del'; |
|
| 49 | 49 | $logs[] = "<$item>: ". $values["$item"]; |
| 50 | 50 | } |
| 51 | 51 | } |
@@ -63,7 +63,7 @@ discard block |
||
| 63 | 63 | |
| 64 | 64 | /* Store new values */ |
| 65 | 65 | if ( ($mysqli = myConnect($dbhost, $userdb, $pwd, $db, $dbport, $tables, $typedesc, $user)) === FALSE ) |
| 66 | - exit ($user.': Connect Error (' . $mysqli->connect_errno . ') '. $mysqli->connect_error); |
|
| 66 | + exit ($user.': Connect Error (' . $mysqli->connect_errno . ') '. $mysqli->connect_error); |
|
| 67 | 67 | |
| 68 | 68 | if (changeMilter ($mysqli,$user,$values,$col,$_POST['miltId'])) |
| 69 | 69 | print 'OK milter setting changed.'; |
@@ -1,10 +1,10 @@ discard block |
||
| 1 | 1 | <?php |
| 2 | 2 | require_once('config.php'); |
| 3 | 3 | require_once('function.php'); |
| 4 | -$typedesc=$_POST['type']; |
|
| 4 | +$typedesc = $_POST['type']; |
|
| 5 | 5 | $type = $tables["$typedesc"]['field']; |
| 6 | 6 | $col = milterTable($type); |
| 7 | -if ( $col === FALSE ) |
|
| 7 | +if ($col === FALSE) |
|
| 8 | 8 | exit ("<p>Error in you config at field <b>$type</b>.</p>"); |
| 9 | 9 | ?> |
| 10 | 10 | <td colspan="10" style="text-align: center"> |
@@ -18,54 +18,54 @@ discard block |
||
| 18 | 18 | $new = $_POST['newvalues']; |
| 19 | 19 | else |
| 20 | 20 | $new = array(); |
| 21 | -if (! empty($_POST['oldvalues'])) |
|
| 21 | +if (!empty($_POST['oldvalues'])) |
|
| 22 | 22 | $old = explode(',', $_POST['oldvalues']); |
| 23 | 23 | else |
| 24 | - $old=array(); |
|
| 25 | -$values=array(); |
|
| 26 | -$logs=array(); |
|
| 24 | + $old = array(); |
|
| 25 | +$values = array(); |
|
| 26 | +$logs = array(); |
|
| 27 | 27 | |
| 28 | 28 | print '<pre>'; |
| 29 | 29 | /* Check need to disable all milters, removing unnecessary setting */ |
| 30 | -if ( in_array('DISABLE ALL', $new) ) |
|
| 30 | +if (in_array('DISABLE ALL', $new)) |
|
| 31 | 31 | $new = array('DISABLE ALL'); |
| 32 | 32 | |
| 33 | 33 | /* Compare the values determining what to do */ |
| 34 | 34 | if (count(array_diff(array_merge($new, $old), array_intersect($new, $old))) !== 0) { |
| 35 | 35 | /* New and old are different (we assume we don't have duplicate values) */ |
| 36 | - if (! empty($new) ) { |
|
| 36 | + if (!empty($new)) { |
|
| 37 | 37 | foreach ($new as $item) { |
| 38 | - if ( in_array($item, $old) ) |
|
| 38 | + if (in_array($item, $old)) |
|
| 39 | 39 | $values["$item"] = 'keep'; |
| 40 | 40 | else |
| 41 | 41 | $values["$item"] = 'add'; |
| 42 | - $logs[] = "<$item>: ". $values["$item"]; |
|
| 42 | + $logs[] = "<$item>: ".$values["$item"]; |
|
| 43 | 43 | } |
| 44 | 44 | } |
| 45 | - if (! empty($old) ) { |
|
| 45 | + if (!empty($old)) { |
|
| 46 | 46 | foreach ($old as $item) { |
| 47 | - if (! in_array($item, $new) ) { |
|
| 47 | + if (!in_array($item, $new)) { |
|
| 48 | 48 | $values["$item"] = 'del'; |
| 49 | - $logs[] = "<$item>: ". $values["$item"]; |
|
| 49 | + $logs[] = "<$item>: ".$values["$item"]; |
|
| 50 | 50 | } |
| 51 | 51 | } |
| 52 | 52 | } |
| 53 | 53 | } |
| 54 | 54 | |
| 55 | 55 | /* Logging */ |
| 56 | -if ( empty($values) ) |
|
| 56 | +if (empty($values)) |
|
| 57 | 57 | print 'No values to change.'; |
| 58 | 58 | else { |
| 59 | - $msg = sprintf('%s: Changing Milter setting on list <%s> for %s <%s>.',$user,$typedesc,$type, $_POST['object']); |
|
| 59 | + $msg = sprintf('%s: Changing Milter setting on list <%s> for %s <%s>.', $user, $typedesc, $type, $_POST['object']); |
|
| 60 | 60 | syslog(LOG_INFO, $msg); |
| 61 | 61 | foreach ($logs as $log) |
| 62 | 62 | syslog(LOG_INFO, "$user: milter $log"); |
| 63 | 63 | |
| 64 | 64 | /* Store new values */ |
| 65 | - if ( ($mysqli = myConnect($dbhost, $userdb, $pwd, $db, $dbport, $tables, $typedesc, $user)) === FALSE ) |
|
| 66 | - exit ($user.': Connect Error (' . $mysqli->connect_errno . ') '. $mysqli->connect_error); |
|
| 65 | + if (($mysqli = myConnect($dbhost, $userdb, $pwd, $db, $dbport, $tables, $typedesc, $user)) === FALSE) |
|
| 66 | + exit ($user.': Connect Error ('.$mysqli->connect_errno.') '.$mysqli->connect_error); |
|
| 67 | 67 | |
| 68 | - if (changeMilter ($mysqli,$user,$values,$col,$_POST['miltId'])) |
|
| 68 | + if (changeMilter($mysqli, $user, $values, $col, $_POST['miltId'])) |
|
| 69 | 69 | print 'OK milter setting changed.'; |
| 70 | 70 | else |
| 71 | 71 | print 'ERROR updating milter setting; check your syslog. No changes made.'; |
@@ -4,8 +4,9 @@ discard block |
||
| 4 | 4 | $typedesc=$_POST['type']; |
| 5 | 5 | $type = $tables["$typedesc"]['field']; |
| 6 | 6 | $col = milterTable($type); |
| 7 | -if ( $col === FALSE ) |
|
| 7 | +if ( $col === FALSE ) { |
|
| 8 | 8 | exit ("<p>Error in you config at field <b>$type</b>.</p>"); |
| 9 | +} |
|
| 9 | 10 | ?> |
| 10 | 11 | <td colspan="10" style="text-align: center"> |
| 11 | 12 | |
@@ -14,31 +15,35 @@ discard block |
||
| 14 | 15 | $user = $_POST['user']; |
| 15 | 16 | |
| 16 | 17 | /* Compare old values with new ones */ |
| 17 | -if (isset($_POST['newvalues'])) |
|
| 18 | +if (isset($_POST['newvalues'])) { |
|
| 18 | 19 | $new = $_POST['newvalues']; |
| 19 | -else |
|
| 20 | +} else { |
|
| 20 | 21 | $new = array(); |
| 21 | -if (! empty($_POST['oldvalues'])) |
|
| 22 | +} |
|
| 23 | +if (! empty($_POST['oldvalues'])) { |
|
| 22 | 24 | $old = explode(',', $_POST['oldvalues']); |
| 23 | -else |
|
| 25 | +} else { |
|
| 24 | 26 | $old=array(); |
| 27 | +} |
|
| 25 | 28 | $values=array(); |
| 26 | 29 | $logs=array(); |
| 27 | 30 | |
| 28 | 31 | print '<pre>'; |
| 29 | 32 | /* Check need to disable all milters, removing unnecessary setting */ |
| 30 | -if ( in_array('DISABLE ALL', $new) ) |
|
| 33 | +if ( in_array('DISABLE ALL', $new) ) { |
|
| 31 | 34 | $new = array('DISABLE ALL'); |
| 35 | +} |
|
| 32 | 36 | |
| 33 | 37 | /* Compare the values determining what to do */ |
| 34 | 38 | if (count(array_diff(array_merge($new, $old), array_intersect($new, $old))) !== 0) { |
| 35 | 39 | /* New and old are different (we assume we don't have duplicate values) */ |
| 36 | 40 | if (! empty($new) ) { |
| 37 | 41 | foreach ($new as $item) { |
| 38 | - if ( in_array($item, $old) ) |
|
| 39 | - $values["$item"] = 'keep'; |
|
| 40 | - else |
|
| 41 | - $values["$item"] = 'add'; |
|
| 42 | + if ( in_array($item, $old) ) { |
|
| 43 | + $values["$item"] = 'keep'; |
|
| 44 | + } else { |
|
| 45 | + $values["$item"] = 'add'; |
|
| 46 | + } |
|
| 42 | 47 | $logs[] = "<$item>: ". $values["$item"]; |
| 43 | 48 | } |
| 44 | 49 | } |
@@ -53,22 +58,25 @@ discard block |
||
| 53 | 58 | } |
| 54 | 59 | |
| 55 | 60 | /* Logging */ |
| 56 | -if ( empty($values) ) |
|
| 61 | +if ( empty($values) ) { |
|
| 57 | 62 | print 'No values to change.'; |
| 58 | -else { |
|
| 63 | +} else { |
|
| 59 | 64 | $msg = sprintf('%s: Changing Milter setting on list <%s> for %s <%s>.',$user,$typedesc,$type, $_POST['object']); |
| 60 | 65 | syslog(LOG_INFO, $msg); |
| 61 | - foreach ($logs as $log) |
|
| 62 | - syslog(LOG_INFO, "$user: milter $log"); |
|
| 66 | + foreach ($logs as $log) { |
|
| 67 | + syslog(LOG_INFO, "$user: milter $log"); |
|
| 68 | + } |
|
| 63 | 69 | |
| 64 | 70 | /* Store new values */ |
| 65 | - if ( ($mysqli = myConnect($dbhost, $userdb, $pwd, $db, $dbport, $tables, $typedesc, $user)) === FALSE ) |
|
| 66 | - exit ($user.': Connect Error (' . $mysqli->connect_errno . ') '. $mysqli->connect_error); |
|
| 71 | + if ( ($mysqli = myConnect($dbhost, $userdb, $pwd, $db, $dbport, $tables, $typedesc, $user)) === FALSE ) { |
|
| 72 | + exit ($user.': Connect Error (' . $mysqli->connect_errno . ') '. $mysqli->connect_error); |
|
| 73 | + } |
|
| 67 | 74 | |
| 68 | - if (changeMilter ($mysqli,$user,$values,$col,$_POST['miltId'])) |
|
| 69 | - print 'OK milter setting changed.'; |
|
| 70 | - else |
|
| 71 | - print 'ERROR updating milter setting; check your syslog. No changes made.'; |
|
| 75 | + if (changeMilter ($mysqli,$user,$values,$col,$_POST['miltId'])) { |
|
| 76 | + print 'OK milter setting changed.'; |
|
| 77 | + } else { |
|
| 78 | + print 'ERROR updating milter setting; check your syslog. No changes made.'; |
|
| 79 | + } |
|
| 72 | 80 | |
| 73 | 81 | $mysqli->close(); |
| 74 | 82 | } |
@@ -1,11 +1,14 @@ |
||
| 1 | 1 | <?php |
| 2 | -if (in_array($user,array_keys(array_filter($adm)))) $extopt = '<option value="MONTH">MONTHS</option><option value="YEAR">YEARS</option>'; |
|
| 3 | -else $extopt = NULL; |
|
| 2 | +if (in_array($user,array_keys(array_filter($adm)))) { |
|
| 3 | + $extopt = '<option value="MONTH">MONTHS</option><option value="YEAR">YEARS</option>'; |
|
| 4 | +} else { |
|
| 5 | + $extopt = NULL; |
|
| 6 | +} |
|
| 4 | 7 | |
| 5 | 8 | if ( $tables["$typedesc"]['milter'] ) { |
| 6 | - if ( checkMilterConf($tables["$typedesc"]) ) |
|
| 7 | - print '<p>This is a milter table. Please, first add your item as usual. Then you will be able to customize the milter settings.</p>'; |
|
| 8 | - else { |
|
| 9 | + if ( checkMilterConf($tables["$typedesc"]) ) { |
|
| 10 | + print '<p>This is a milter table. Please, first add your item as usual. Then you will be able to customize the milter settings.</p>'; |
|
| 11 | + } else { |
|
| 9 | 12 | $err = "Error in config about <$typedesc>. Check at your config.php."; |
| 10 | 13 | syslog (LOG_EMERG, $err); |
| 11 | 14 | printf ('<p>%s</p>', htmlspecialchars($err) ); |
@@ -1,14 +1,14 @@ discard block |
||
| 1 | 1 | <?php |
| 2 | -if (in_array($user,array_keys(array_filter($adm)))) $extopt = '<option value="MONTH">MONTHS</option><option value="YEAR">YEARS</option>'; |
|
| 2 | +if (in_array($user, array_keys(array_filter($adm)))) $extopt = '<option value="MONTH">MONTHS</option><option value="YEAR">YEARS</option>'; |
|
| 3 | 3 | else $extopt = NULL; |
| 4 | 4 | |
| 5 | -if ( $tables["$typedesc"]['milter'] ) { |
|
| 6 | - if ( checkMilterConf($tables["$typedesc"]) ) |
|
| 5 | +if ($tables["$typedesc"]['milter']) { |
|
| 6 | + if (checkMilterConf($tables["$typedesc"])) |
|
| 7 | 7 | print '<p>This is a milter table. Please, first add your item as usual. Then you will be able to customize the milter settings.</p>'; |
| 8 | 8 | else { |
| 9 | 9 | $err = "Error in config about <$typedesc>. Check at your config.php."; |
| 10 | - syslog (LOG_EMERG, $err); |
|
| 11 | - printf ('<p>%s</p>', htmlspecialchars($err) ); |
|
| 10 | + syslog(LOG_EMERG, $err); |
|
| 11 | + printf('<p>%s</p>', htmlspecialchars($err)); |
|
| 12 | 12 | } |
| 13 | 13 | } |
| 14 | 14 | |
@@ -16,4 +16,4 @@ discard block |
||
| 16 | 16 | <form style="margin:0; text-align: left;" name='ListButton<?php echo $type ?>' enctype="text/plain" method="post" target="_self" action="list.php" onSubmit="xmlhttpPost('list.php', 'ListButton<?php echo $type ?>', 'Risultato', '<img src=\'/include/pleasewait.gif\'>'); return false;" /> |
| 17 | 17 | |
| 18 | 18 | List <?php echo $typedesc.' <'.$value.'>'; ?> for <input name="type" type="hidden" value="<?php echo $typedesc; ?>" /><input name="value" type="hidden" class="input_text" value="<?php echo $value; ?>" /> |
| 19 | - <select name="quantity" class="input_text" size="1"><option value="1">1</option><option value="2">2</option><option value="3">3</option><option value="4">4</option><option value="5">5</option><option value="6">6</option><option value="20">20</option></select><select class="input_text" name="unit" size="1"><option value="DAY">DAYS</option><option value="WEEK">WEEKS</option><?php echo $extopt;?></select> Reason:<input maxlength="128" name="reason" size="30" type="text" class="input_text" /><input name="List" class="button" id="bwarn" type="submit" value="List"/></form> |
|
| 19 | + <select name="quantity" class="input_text" size="1"><option value="1">1</option><option value="2">2</option><option value="3">3</option><option value="4">4</option><option value="5">5</option><option value="6">6</option><option value="20">20</option></select><select class="input_text" name="unit" size="1"><option value="DAY">DAYS</option><option value="WEEK">WEEKS</option><?php echo $extopt; ?></select> Reason:<input maxlength="128" name="reason" size="30" type="text" class="input_text" /><input name="List" class="button" id="bwarn" type="submit" value="List"/></form> |
|
@@ -11,11 +11,11 @@ |
||
| 11 | 11 | openlog($tag, LOG_PID, $fac); |
| 12 | 12 | if (empty($_POST['reason'])) die ("Specify a reason, please!</td>"); |
| 13 | 13 | if (preg_match( '/[^\x20-\x7f]/', $_POST['reason'])) |
| 14 | - exit('ERROR: <'.htmlentities($_POST['reason'],ENT_COMPAT | ENT_HTML401, 'ISO-8859-1').'> contains NON ASCII chars.</td>'); |
|
| 14 | + exit('ERROR: <'.htmlentities($_POST['reason'],ENT_COMPAT | ENT_HTML401, 'ISO-8859-1').'> contains NON ASCII chars.</td>'); |
|
| 15 | 15 | $user = username(); |
| 16 | 16 | |
| 17 | 17 | if ( ($mysqli = myConnect($dbhost, $userdb, $pwd, $db, $dbport, $tables, $typedesc, $user)) === FALSE ) |
| 18 | - exit ($user.': Connect Error (' . $mysqli->connect_errno . ') '. $mysqli->connect_error); |
|
| 18 | + exit ($user.': Connect Error (' . $mysqli->connect_errno . ') '. $mysqli->connect_error); |
|
| 19 | 19 | |
| 20 | 20 | if (isFull($mysqli,$typedesc,$tables)) die("ERROR in relist: ".htmlspecialchars("$typedesc has reached maximum value of ".$tables["$typedesc"]['limit'].' listed items.') ); |
| 21 | 21 | if (relist ($mysqli,username(),$_POST['value'],$type,$table,$_POST['unit'],$_POST['quantity'],$_POST['reason'])) |
@@ -1,7 +1,7 @@ discard block |
||
| 1 | 1 | <?php |
| 2 | 2 | require_once('config.php'); |
| 3 | 3 | require_once('function.php'); |
| 4 | -$typedesc=$_POST['type']; |
|
| 4 | +$typedesc = $_POST['type']; |
|
| 5 | 5 | $type = $tables["$typedesc"]['field']; |
| 6 | 6 | $table = ($tables["$typedesc"]['milter']) ? milterTable($type) : $tables["$typedesc"]['name']; |
| 7 | 7 | $cl = ($tables["$typedesc"]['milter']) ? 10 : 9; |
@@ -10,15 +10,15 @@ discard block |
||
| 10 | 10 | <?php |
| 11 | 11 | openlog($tag, LOG_PID, $fac); |
| 12 | 12 | if (empty($_POST['reason'])) die ("Specify a reason, please!</td>"); |
| 13 | -if (preg_match( '/[^\x20-\x7f]/', $_POST['reason'])) |
|
| 14 | - exit('ERROR: <'.htmlentities($_POST['reason'],ENT_COMPAT | ENT_HTML401, 'ISO-8859-1').'> contains NON ASCII chars.</td>'); |
|
| 13 | +if (preg_match('/[^\x20-\x7f]/', $_POST['reason'])) |
|
| 14 | + exit('ERROR: <'.htmlentities($_POST['reason'], ENT_COMPAT | ENT_HTML401, 'ISO-8859-1').'> contains NON ASCII chars.</td>'); |
|
| 15 | 15 | $user = username(); |
| 16 | 16 | |
| 17 | -if ( ($mysqli = myConnect($dbhost, $userdb, $pwd, $db, $dbport, $tables, $typedesc, $user)) === FALSE ) |
|
| 18 | - exit ($user.': Connect Error (' . $mysqli->connect_errno . ') '. $mysqli->connect_error); |
|
| 17 | +if (($mysqli = myConnect($dbhost, $userdb, $pwd, $db, $dbport, $tables, $typedesc, $user)) === FALSE) |
|
| 18 | + exit ($user.': Connect Error ('.$mysqli->connect_errno.') '.$mysqli->connect_error); |
|
| 19 | 19 | |
| 20 | -if (isFull($mysqli,$typedesc,$tables)) die("ERROR in relist: ".htmlspecialchars("$typedesc has reached maximum value of ".$tables["$typedesc"]['limit'].' listed items.') ); |
|
| 21 | -if (relist ($mysqli,username(),$_POST['value'],$type,$table,$_POST['unit'],$_POST['quantity'],$_POST['reason'])) |
|
| 20 | +if (isFull($mysqli, $typedesc, $tables)) die("ERROR in relist: ".htmlspecialchars("$typedesc has reached maximum value of ".$tables["$typedesc"]['limit'].' listed items.')); |
|
| 21 | +if (relist($mysqli, username(), $_POST['value'], $type, $table, $_POST['unit'], $_POST['quantity'], $_POST['reason'])) |
|
| 22 | 22 | print 'OK '.$_POST["type"].' <'.$_POST['value'].'> relisted for '.$_POST['quantity'].$_POST['unit']; |
| 23 | 23 | else |
| 24 | 24 | print 'ERROR in relist; check log'; |
@@ -9,19 +9,26 @@ |
||
| 9 | 9 | <td colspan="<?php echo $cl; ?>" style="text-align: center"> |
| 10 | 10 | <?php |
| 11 | 11 | openlog($tag, LOG_PID, $fac); |
| 12 | -if (empty($_POST['reason'])) die ("Specify a reason, please!</td>"); |
|
| 13 | -if (preg_match( '/[^\x20-\x7f]/', $_POST['reason'])) |
|
| 12 | +if (empty($_POST['reason'])) { |
|
| 13 | + die ("Specify a reason, please!</td>"); |
|
| 14 | +} |
|
| 15 | +if (preg_match( '/[^\x20-\x7f]/', $_POST['reason'])) { |
|
| 14 | 16 | exit('ERROR: <'.htmlentities($_POST['reason'],ENT_COMPAT | ENT_HTML401, 'ISO-8859-1').'> contains NON ASCII chars.</td>'); |
| 17 | +} |
|
| 15 | 18 | $user = username(); |
| 16 | 19 | |
| 17 | -if ( ($mysqli = myConnect($dbhost, $userdb, $pwd, $db, $dbport, $tables, $typedesc, $user)) === FALSE ) |
|
| 20 | +if ( ($mysqli = myConnect($dbhost, $userdb, $pwd, $db, $dbport, $tables, $typedesc, $user)) === FALSE ) { |
|
| 18 | 21 | exit ($user.': Connect Error (' . $mysqli->connect_errno . ') '. $mysqli->connect_error); |
| 22 | +} |
|
| 19 | 23 | |
| 20 | -if (isFull($mysqli,$typedesc,$tables)) die("ERROR in relist: ".htmlspecialchars("$typedesc has reached maximum value of ".$tables["$typedesc"]['limit'].' listed items.') ); |
|
| 21 | -if (relist ($mysqli,username(),$_POST['value'],$type,$table,$_POST['unit'],$_POST['quantity'],$_POST['reason'])) |
|
| 24 | +if (isFull($mysqli,$typedesc,$tables)) { |
|
| 25 | + die("ERROR in relist: ".htmlspecialchars("$typedesc has reached maximum value of ".$tables["$typedesc"]['limit'].' listed items.') ); |
|
| 26 | +} |
|
| 27 | +if (relist ($mysqli,username(),$_POST['value'],$type,$table,$_POST['unit'],$_POST['quantity'],$_POST['reason'])) { |
|
| 22 | 28 | print 'OK '.$_POST["type"].' <'.$_POST['value'].'> relisted for '.$_POST['quantity'].$_POST['unit']; |
| 23 | -else |
|
| 29 | +} else { |
|
| 24 | 30 | print 'ERROR in relist; check log'; |
| 31 | +} |
|
| 25 | 32 | $mysqli->close(); |
| 26 | 33 | closelog(); |
| 27 | 34 | print '</td>'; |