@@ -19,7 +19,7 @@ |
||
| 19 | 19 | <?php |
| 20 | 20 | $reports = array(); |
| 21 | 21 | foreach (glob("*.{htm,html}", GLOB_BRACE) as $filename) { |
| 22 | - $reports[$filename] = filemtime($filename); |
|
| 22 | + $reports[$filename] = filemtime($filename); |
|
| 23 | 23 | } |
| 24 | 24 | arsort($reports); |
| 25 | 25 | $newest = new DateTime('@'.array_shift($reports)); |
@@ -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,23 @@ discard block |
||
| 28 | 31 | return array($ip,$host,$dateR,$dateC['date'],$mid['mid']); |
| 29 | 32 | } |
| 30 | 33 | |
| 34 | +/** |
|
| 35 | + * @param string $hostname |
|
| 36 | + * @param string $dateC |
|
| 37 | + * @param string|null $msgid |
|
| 38 | + * @param string|false $dateL |
|
| 39 | + */ |
|
| 31 | 40 | function updateReport ($ip,$uid,$ipcount,$uidcount,$hostname,$dateC,$msgid,$dateL) { |
| 32 | 41 | |
| 33 | 42 | 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 | 43 | } |
| 35 | 44 | |
| 45 | +/** |
|
| 46 | + * @param string $dateC |
|
| 47 | + * @param string|null $msgid |
|
| 48 | + * @param false|string $dateL |
|
| 49 | + * @param string $text |
|
| 50 | + */ |
|
| 36 | 51 | function updatebadReport ( $uid,$dateC,$msgid,$dateL,$text ) { |
| 37 | 52 | 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 | 53 | } |
@@ -84,6 +99,10 @@ discard block |
||
| 84 | 99 | } |
| 85 | 100 | |
| 86 | 101 | |
| 102 | +/** |
|
| 103 | + * @param null|mysqli $myconn |
|
| 104 | + * @param string $key |
|
| 105 | + */ |
|
| 87 | 106 | function summaryReportAndList ($cf,$myconn,$tables,$category,$vet,$key) { |
| 88 | 107 | $nk = $vet['count']; |
| 89 | 108 | |
@@ -160,6 +179,10 @@ discard block |
||
| 160 | 179 | } |
| 161 | 180 | |
| 162 | 181 | |
| 182 | +/** |
|
| 183 | + * @param string $message_id |
|
| 184 | + * @param string $date |
|
| 185 | + */ |
|
| 163 | 186 | function splunksearch ($service,$message_id,$date) { |
| 164 | 187 | |
| 165 | 188 | // Run a blocking search |
@@ -272,6 +295,9 @@ discard block |
||
| 272 | 295 | } |
| 273 | 296 | /***********************************/ |
| 274 | 297 | |
| 298 | +/** |
|
| 299 | + * @param string $text |
|
| 300 | + */ |
|
| 275 | 301 | function getDomains ($text) { |
| 276 | 302 | $pattern = '~[a-z]+://\S+~'; |
| 277 | 303 | $ret = array(); |
@@ -324,6 +350,9 @@ discard block |
||
| 324 | 350 | return array(); |
| 325 | 351 | } |
| 326 | 352 | |
| 353 | +/** |
|
| 354 | + * @return string |
|
| 355 | + */ |
|
| 327 | 356 | function humanKey($key) { |
| 328 | 357 | switch($key) { |
| 329 | 358 | case 'ip': |
@@ -334,6 +363,11 @@ discard block |
||
| 334 | 363 | return $key; |
| 335 | 364 | } |
| 336 | 365 | |
| 366 | +/** |
|
| 367 | + * @param resource $f |
|
| 368 | + * @param string $key |
|
| 369 | + * @param string $rtime |
|
| 370 | + */ |
|
| 337 | 371 | function writeFileHeader($f,$conf,$key,$type,$rtime) { |
| 338 | 372 | fwrite( $f, file_get_contents(dirname(__FILE__) . '/' . $conf['report']['reportTemplateHeader']) ); |
| 339 | 373 | fwrite( $f,sprintf('<h1> Report of %s %s</h1><h5>%s</h5><h2>Detailed Report</h2>',$type, strtoupper(humanKey($key)),$rtime) ); |
@@ -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 | |
@@ -95,8 +95,8 @@ discard block |
||
| 95 | 95 | |
| 96 | 96 | foreach ( $values as $value ) { |
| 97 | 97 | if ( $value == 'count' ) continue; |
| 98 | - $nlearn = $vet["$key"]["$value"]['count']; |
|
| 99 | - unset($vet["$key"]["$value"]['count']); |
|
| 98 | + $nlearn = $vet["$key"]["$value"]['count']; |
|
| 99 | + unset($vet["$key"]["$value"]['count']); |
|
| 100 | 100 | $quantity = $cf["listing$key"]['quantity']["$category"]; /* In searchAndList this value is |
| 101 | 101 | passed by reference and modified */ |
| 102 | 102 | $nuid = count($vet["$key"]["$value"]); |
@@ -127,9 +127,9 @@ discard block |
||
| 127 | 127 | $return .='<tr><td rowspan="'.$nuid.'">'.$value.'</td>'; |
| 128 | 128 | $return .= sprintf ('<td>%s</td><td rowspan="'.$nuid.'">%u</td><td rowspan="'.$nuid.'" '.$nowlist["$listed"]['style'].'>%s</td></tr>',$vet["$key"]["$value"][0],$nlearn,$nowlist["$listed"]['name']); |
| 129 | 129 | $rowuid=NULL; |
| 130 | - for ($j=1;$j<$nuid;$j++) $rowuid .= '<tr><td>%s</td></tr>'; |
|
| 130 | + for ($j=1;$j<$nuid;$j++) $rowuid .= '<tr><td>%s</td></tr>'; |
|
| 131 | 131 | array_shift($vet["$key"]["$value"]); |
| 132 | - $return .= vsprintf ($rowuid,$vet["$key"]["$value"]); |
|
| 132 | + $return .= vsprintf ($rowuid,$vet["$key"]["$value"]); |
|
| 133 | 133 | |
| 134 | 134 | } |
| 135 | 135 | $return .= sprintf ('<tr><th title="unique %s">%u</th><th title="unique uids">%u</th><th>%u</th></table>',$key,$vet["$key"]['count'],$vet['uid']['count'],$nk); |
@@ -139,20 +139,20 @@ discard block |
||
| 139 | 139 | /* Not used for listing purpose, but useful to you! */ |
| 140 | 140 | $return .= sprintf('<h3>Statistics by UID</h3><table><tr><th>UID</th><th>%s learned</th><th>Learned times</th></tr>'."\n",$key); |
| 141 | 141 | $uids = array_keys($vet['uid']); |
| 142 | - foreach ( $uids as $uid ) { |
|
| 142 | + foreach ( $uids as $uid ) { |
|
| 143 | 143 | if ( $uid == 'count' ) continue; |
| 144 | - $nlearn = $vet['uid']["$uid"]['count']; |
|
| 145 | - unset ( $vet['uid']["$uid"]['count'] ); |
|
| 144 | + $nlearn = $vet['uid']["$uid"]['count']; |
|
| 145 | + unset ( $vet['uid']["$uid"]['count'] ); |
|
| 146 | 146 | $nip = count($vet['uid']["$uid"]); |
| 147 | 147 | $return .='<tr><td rowspan="'.$nip.'">'.$uid.'</td>'; |
| 148 | 148 | $return .= sprintf ('<td>%s</td><td rowspan="'.$nip.'">%u</td></tr>',$vet['uid']["$uid"][0],$nlearn); |
| 149 | - $rowuid=NULL; |
|
| 150 | - for ($j=1;$j<$nip;$j++) $rowuid .= '<tr><td>%s</td></tr>'; |
|
| 151 | - array_shift($vet['uid']["$uid"]); |
|
| 152 | - $return .= vsprintf ($rowuid,$vet['uid']["$uid"]); |
|
| 149 | + $rowuid=NULL; |
|
| 150 | + for ($j=1;$j<$nip;$j++) $rowuid .= '<tr><td>%s</td></tr>'; |
|
| 151 | + array_shift($vet['uid']["$uid"]); |
|
| 152 | + $return .= vsprintf ($rowuid,$vet['uid']["$uid"]); |
|
| 153 | 153 | |
| 154 | - } |
|
| 155 | - $return .= sprintf ('<tr><th title="unique uids">%u</th><th title="unique %s">%u</th><th>%u</th></table>', |
|
| 154 | + } |
|
| 155 | + $return .= sprintf ('<tr><th title="unique uids">%u</th><th title="unique %s">%u</th><th>%u</th></table>', |
|
| 156 | 156 | $vet['uid']['count'],$key,$vet["$key"]['count'],$nk); |
| 157 | 157 | |
| 158 | 158 | |
@@ -181,50 +181,50 @@ discard block |
||
| 181 | 181 | */ |
| 182 | 182 | |
| 183 | 183 | // A one shot search |
| 184 | - $searchParams = array( |
|
| 185 | - 'earliest_time' => date("c",strtotime ($date)-120), |
|
| 186 | - 'latest_time' => date("c",strtotime ($date)+60) |
|
| 187 | - ); |
|
| 184 | + $searchParams = array( |
|
| 185 | + 'earliest_time' => date("c",strtotime ($date)-120), |
|
| 186 | + 'latest_time' => date("c",strtotime ($date)+60) |
|
| 187 | + ); |
|
| 188 | 188 | |
| 189 | - // Run a oneshot search that returns the job's results |
|
| 190 | - $resultsStream = $service->oneshotSearch($searchQueryBlocking, $searchParams); |
|
| 191 | - $resultSearch = new Splunk_ResultsReader($resultsStream); |
|
| 189 | + // Run a oneshot search that returns the job's results |
|
| 190 | + $resultsStream = $service->oneshotSearch($searchQueryBlocking, $searchParams); |
|
| 191 | + $resultSearch = new Splunk_ResultsReader($resultsStream); |
|
| 192 | 192 | |
| 193 | 193 | // Use the built-in XML parser to display the job results |
| 194 | 194 | foreach ($resultSearch as $result) |
| 195 | 195 | { |
| 196 | - if ($result instanceof Splunk_ResultsFieldOrder) |
|
| 197 | - { |
|
| 198 | - // More than one field attribute returned by search |
|
| 199 | - // You must redefine the search |
|
| 200 | - if ( count($result->getFieldNames()) > 1 ) return FALSE; |
|
| 201 | - } |
|
| 202 | - else if ($result instanceof Splunk_ResultsMessage) |
|
| 203 | - { |
|
| 204 | - // I don't want messages in my search |
|
| 205 | - return FALSE; |
|
| 206 | - } |
|
| 207 | - else if (is_array($result)) |
|
| 208 | - { |
|
| 209 | - // Process a row |
|
| 210 | - foreach ($result as $key => $valueOrValues) |
|
| 211 | - { |
|
| 212 | - if (is_array($valueOrValues)) |
|
| 213 | - { |
|
| 214 | - return FALSE; |
|
| 215 | - } |
|
| 216 | - else |
|
| 217 | - { |
|
| 218 | - return $valueOrValues; |
|
| 219 | - #print " {$key} => {$value}\r\n"; |
|
| 220 | - } |
|
| 221 | - } |
|
| 222 | - } |
|
| 223 | - else |
|
| 224 | - { |
|
| 225 | - #print "Unknow result type"; |
|
| 226 | - return FALSE; |
|
| 227 | - } |
|
| 196 | + if ($result instanceof Splunk_ResultsFieldOrder) |
|
| 197 | + { |
|
| 198 | + // More than one field attribute returned by search |
|
| 199 | + // You must redefine the search |
|
| 200 | + if ( count($result->getFieldNames()) > 1 ) return FALSE; |
|
| 201 | + } |
|
| 202 | + else if ($result instanceof Splunk_ResultsMessage) |
|
| 203 | + { |
|
| 204 | + // I don't want messages in my search |
|
| 205 | + return FALSE; |
|
| 206 | + } |
|
| 207 | + else if (is_array($result)) |
|
| 208 | + { |
|
| 209 | + // Process a row |
|
| 210 | + foreach ($result as $key => $valueOrValues) |
|
| 211 | + { |
|
| 212 | + if (is_array($valueOrValues)) |
|
| 213 | + { |
|
| 214 | + return FALSE; |
|
| 215 | + } |
|
| 216 | + else |
|
| 217 | + { |
|
| 218 | + return $valueOrValues; |
|
| 219 | + #print " {$key} => {$value}\r\n"; |
|
| 220 | + } |
|
| 221 | + } |
|
| 222 | + } |
|
| 223 | + else |
|
| 224 | + { |
|
| 225 | + #print "Unknow result type"; |
|
| 226 | + return FALSE; |
|
| 227 | + } |
|
| 228 | 228 | } |
| 229 | 229 | } |
| 230 | 230 | |
@@ -235,38 +235,38 @@ discard block |
||
| 235 | 235 | |
| 236 | 236 | function flattenParts($messageParts, $flattenedParts = array(), $prefix = '', $index = 1, $fullPrefix = true) { |
| 237 | 237 | |
| 238 | - foreach($messageParts as $part) { |
|
| 239 | - $flattenedParts[$prefix.$index] = $part; |
|
| 240 | - if(isset($part->parts)) { |
|
| 241 | - if($part->type == 2) { |
|
| 242 | - $flattenedParts = flattenParts($part->parts, $flattenedParts, $prefix.$index.'.', 0, false); |
|
| 243 | - } |
|
| 244 | - elseif($fullPrefix) { |
|
| 245 | - $flattenedParts = flattenParts($part->parts, $flattenedParts, $prefix.$index.'.'); |
|
| 246 | - } |
|
| 247 | - else { |
|
| 248 | - $flattenedParts = flattenParts($part->parts, $flattenedParts, $prefix); |
|
| 249 | - } |
|
| 250 | - unset($flattenedParts[$prefix.$index]->parts); |
|
| 251 | - } |
|
| 252 | - $index++; |
|
| 253 | - } |
|
| 254 | - |
|
| 255 | - return $flattenedParts; |
|
| 238 | + foreach($messageParts as $part) { |
|
| 239 | + $flattenedParts[$prefix.$index] = $part; |
|
| 240 | + if(isset($part->parts)) { |
|
| 241 | + if($part->type == 2) { |
|
| 242 | + $flattenedParts = flattenParts($part->parts, $flattenedParts, $prefix.$index.'.', 0, false); |
|
| 243 | + } |
|
| 244 | + elseif($fullPrefix) { |
|
| 245 | + $flattenedParts = flattenParts($part->parts, $flattenedParts, $prefix.$index.'.'); |
|
| 246 | + } |
|
| 247 | + else { |
|
| 248 | + $flattenedParts = flattenParts($part->parts, $flattenedParts, $prefix); |
|
| 249 | + } |
|
| 250 | + unset($flattenedParts[$prefix.$index]->parts); |
|
| 251 | + } |
|
| 252 | + $index++; |
|
| 253 | + } |
|
| 254 | + |
|
| 255 | + return $flattenedParts; |
|
| 256 | 256 | |
| 257 | 257 | } |
| 258 | 258 | |
| 259 | 259 | function getPart($connection, $messageNumber, $partNumber, $encoding) { |
| 260 | 260 | |
| 261 | - $data = imap_fetchbody($connection, $messageNumber, $partNumber); |
|
| 262 | - switch($encoding) { |
|
| 263 | - case 0: return $data; // 7BIT |
|
| 264 | - case 1: return $data; // 8BIT |
|
| 265 | - case 2: return $data; // BINARY |
|
| 266 | - case 3: return base64_decode($data); // BASE64 |
|
| 267 | - case 4: return quoted_printable_decode($data); // QUOTED_PRINTABLE |
|
| 268 | - case 5: return $data; // OTHER |
|
| 269 | - } |
|
| 261 | + $data = imap_fetchbody($connection, $messageNumber, $partNumber); |
|
| 262 | + switch($encoding) { |
|
| 263 | + case 0: return $data; // 7BIT |
|
| 264 | + case 1: return $data; // 8BIT |
|
| 265 | + case 2: return $data; // BINARY |
|
| 266 | + case 3: return base64_decode($data); // BASE64 |
|
| 267 | + case 4: return quoted_printable_decode($data); // QUOTED_PRINTABLE |
|
| 268 | + case 5: return $data; // OTHER |
|
| 269 | + } |
|
| 270 | 270 | |
| 271 | 271 | |
| 272 | 272 | } |
@@ -335,16 +335,16 @@ discard block |
||
| 335 | 335 | } |
| 336 | 336 | |
| 337 | 337 | function writeFileHeader($f,$conf,$key,$type,$rtime) { |
| 338 | - fwrite( $f, file_get_contents(dirname(__FILE__) . '/' . $conf['report']['reportTemplateHeader']) ); |
|
| 339 | - fwrite( $f,sprintf('<h1> Report of %s %s</h1><h5>%s</h5><h2>Detailed Report</h2>',$type, strtoupper(humanKey($key)),$rtime) ); |
|
| 340 | - if ($conf["listing$key"]['onlyReport']["$type"]) { |
|
| 341 | - fwrite( $f,sprintf('<p>None of the below %s have been listed because listing is not active in configuration.</p>', |
|
| 338 | + fwrite( $f, file_get_contents(dirname(__FILE__) . '/' . $conf['report']['reportTemplateHeader']) ); |
|
| 339 | + fwrite( $f,sprintf('<h1> Report of %s %s</h1><h5>%s</h5><h2>Detailed Report</h2>',$type, strtoupper(humanKey($key)),$rtime) ); |
|
| 340 | + if ($conf["listing$key"]['onlyReport']["$type"]) { |
|
| 341 | + fwrite( $f,sprintf('<p>None of the below %s have been listed because listing is not active in configuration.</p>', |
|
| 342 | 342 | strtoupper(humanKey($key))) ); |
| 343 | 343 | syslog(LOG_INFO, sprintf('%s: Report only for %s %s: no listing activated in configuration.', |
| 344 | 344 | $conf['syslog']['user'],$type,humanKey($key)) |
| 345 | 345 | ); |
| 346 | 346 | } |
| 347 | - fwrite( $f,sprintf('<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>%s</th><th title="How many times this uid learns">#UID</th><th title="Number of times this learned %s appears in different mails">#%s</th><th nowrap>Received by</th><th>Message-Id</th></tr>', |
|
| 347 | + fwrite( $f,sprintf('<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>%s</th><th title="How many times this uid learns">#UID</th><th title="Number of times this learned %s appears in different mails">#%s</th><th nowrap>Received by</th><th>Message-Id</th></tr>', |
|
| 348 | 348 | strtoupper($key),strtoupper($key),strtoupper($key)) ); |
| 349 | 349 | } |
| 350 | 350 | |
@@ -354,25 +354,25 @@ discard block |
||
| 354 | 354 | $filed = dirname(__FILE__) . '/' . $cf['report']['reportDomFile']["$type"]; |
| 355 | 355 | $fileb= dirname(__FILE__) . '/' . $cf['report']['badreportFile']["$type"]; |
| 356 | 356 | $m_mail = imap_open('{'.$cf['imap']['mailhost'].':143/imap/novalidate-cert/authuser='.$cf['imap']['authuser'].'}'.$cf['imap']['folder']["$type"], $cf['imap']['account'],$cf['imap']['authpassword'], OP_READONLY) |
| 357 | - or syslog (LOG_EMERG, $cf['syslog']['user'].': Error in IMAP connection to <'.$cf['imap']['mailhost'].'>: ' . imap_last_error()); |
|
| 357 | + or syslog (LOG_EMERG, $cf['syslog']['user'].': Error in IMAP connection to <'.$cf['imap']['mailhost'].'>: ' . imap_last_error()); |
|
| 358 | 358 | if ( !$m_mail ) exit(254); |
| 359 | 359 | |
| 360 | 360 | |
| 361 | 361 | syslog (LOG_INFO,$cf['syslog']['user'].': Successfully connected to <'.$cf['imap']['mailhost'].">; Reading $type messages of last ".$cf['imap']['oldestday'].' days...'); |
| 362 | 362 | //get all messages |
| 363 | 363 | $dateTh = date ( "d-M-Y", strToTime ( '-'.$cf['imap']['oldestday'].' days' ) ); |
| 364 | - $dateN = date ( "d-M-Y", strToTime ( "now" ) ); |
|
| 365 | - $m_search=imap_search ($m_mail, "SINCE \"$dateTh\" BEFORE \"$dateN\"" ); |
|
| 364 | + $dateN = date ( "d-M-Y", strToTime ( "now" ) ); |
|
| 365 | + $m_search=imap_search ($m_mail, "SINCE \"$dateTh\" BEFORE \"$dateN\"" ); |
|
| 366 | 366 | |
| 367 | 367 | // Order results starting from newest message |
| 368 | 368 | if ( empty($m_search) ) { |
| 369 | 369 | syslog (LOG_INFO,$cf['syslog']['user'].": No mail found in $type folder. No reports written for $type."); |
| 370 | - if ( $ierr = imap_errors() ) |
|
| 371 | - foreach ( $ierr as $thiserr ) |
|
| 372 | - syslog (LOG_ERR, $cf['syslog']['user'].": IMAP Error: $thiserr"); |
|
| 373 | - if ( $ierr = imap_alerts() ) |
|
| 374 | - foreach ( $ierr as $thiserr ) |
|
| 375 | - syslog (LOG_ALERT, $cf['syslog']['user'].": IMAP Alert: $thiserr"); |
|
| 370 | + if ( $ierr = imap_errors() ) |
|
| 371 | + foreach ( $ierr as $thiserr ) |
|
| 372 | + syslog (LOG_ERR, $cf['syslog']['user'].": IMAP Error: $thiserr"); |
|
| 373 | + if ( $ierr = imap_alerts() ) |
|
| 374 | + foreach ( $ierr as $thiserr ) |
|
| 375 | + syslog (LOG_ALERT, $cf['syslog']['user'].": IMAP Alert: $thiserr"); |
|
| 376 | 376 | imap_close( $m_mail ); |
| 377 | 377 | if ( file_exists( $file ) ) unlink ($file); |
| 378 | 378 | if ( file_exists( $filed ) ) unlink ($filed); |
@@ -412,16 +412,16 @@ discard block |
||
| 412 | 412 | $uidbad['count'] = 0; |
| 413 | 413 | $uidbad['uid'] = array(); |
| 414 | 414 | |
| 415 | - // loop for each message |
|
| 415 | + // loop for each message |
|
| 416 | 416 | foreach ($m_search as $onem) { |
| 417 | 417 | |
| 418 | - //get imap header info for obj thang |
|
| 419 | - //$headers = imap_headerinfo($m_mail, $onem); |
|
| 420 | - //$head = imap_fetchheader($m_mail, $headers->Msgno); |
|
| 418 | + //get imap header info for obj thang |
|
| 419 | + //$headers = imap_headerinfo($m_mail, $onem); |
|
| 420 | + //$head = imap_fetchheader($m_mail, $headers->Msgno); |
|
| 421 | 421 | $head = imap_fetchheader($m_mail, $onem ); |
| 422 | - //$obj = imap_rfc822_parse_headers( $head); |
|
| 422 | + //$obj = imap_rfc822_parse_headers( $head); |
|
| 423 | 423 | |
| 424 | - list ($ip,$host,$dateReceived,$dateClient,$mid) = getIP( $head,$cf['mx_hostname']['mx'],$cf['msa']['msalearn'] ); |
|
| 424 | + list ($ip,$host,$dateReceived,$dateClient,$mid) = getIP( $head,$cf['mx_hostname']['mx'],$cf['msa']['msalearn'] ); |
|
| 425 | 425 | if (empty($mid)) { |
| 426 | 426 | $uid='NA'; |
| 427 | 427 | syslog (LOG_ERR, $cf['syslog']['user'].": Error retrieving data for empty Message-ID."); |
@@ -439,11 +439,11 @@ discard block |
||
| 439 | 439 | /* Extract domains url in body */ |
| 440 | 440 | $domains = parseURL ($m_mail,$onem); |
| 441 | 441 | |
| 442 | - /* Update count of each ip */ |
|
| 443 | - if ($host and ($uid!='NA') and ($uid!='unauthenticated') and ($uid!='unknown')) { /* IP is received by MX servers and learned by valid uid */ |
|
| 442 | + /* Update count of each ip */ |
|
| 443 | + if ($host and ($uid!='NA') and ($uid!='unauthenticated') and ($uid!='unknown')) { /* IP is received by MX servers and learned by valid uid */ |
|
| 444 | 444 | $ipuid['count']++; //number of right messages |
| 445 | 445 | |
| 446 | - if (in_array($uid,array_keys($ipuid['uid']))) { |
|
| 446 | + if (in_array($uid,array_keys($ipuid['uid']))) { |
|
| 447 | 447 | $ipuid['uid']["$uid"]['count']++; //number of learn by this uid |
| 448 | 448 | if (!in_array($ip,$ipuid['uid']["$uid"])) |
| 449 | 449 | $ipuid['uid']["$uid"][]=$ip; //ips learned by this uid |
@@ -454,16 +454,16 @@ discard block |
||
| 454 | 454 | $ipuid['uid']['count']++; //number of unique uids |
| 455 | 455 | } |
| 456 | 456 | |
| 457 | - if (in_array($ip,array_keys($ipuid['ip']))) { |
|
| 458 | - $ipuid['ip']["$ip"]['count']++; //number of time this ip appears in different messages |
|
| 457 | + if (in_array($ip,array_keys($ipuid['ip']))) { |
|
| 458 | + $ipuid['ip']["$ip"]['count']++; //number of time this ip appears in different messages |
|
| 459 | 459 | if (!in_array($uid,$ipuid['ip']["$ip"])) |
| 460 | 460 | $ipuid['ip']["$ip"][]=$uid; //uids that learned this ip |
| 461 | 461 | } |
| 462 | - else { |
|
| 463 | - $ipuid['ip']["$ip"]['count'] = 1; |
|
| 462 | + else { |
|
| 463 | + $ipuid['ip']["$ip"]['count'] = 1; |
|
| 464 | 464 | $ipuid['ip']["$ip"][]=$uid; |
| 465 | 465 | $ipuid['ip']['count']++; //number of unique ips |
| 466 | - } |
|
| 466 | + } |
|
| 467 | 467 | |
| 468 | 468 | foreach ($domains as $dom) { |
| 469 | 469 | $domuid['count']++; |
@@ -498,18 +498,18 @@ discard block |
||
| 498 | 498 | ); |
| 499 | 499 | } |
| 500 | 500 | |
| 501 | - /* Update HTML report */ |
|
| 502 | - fwrite($fp,updateReport ( $ip,$uid,$ipuid['ip']["$ip"]['count'],$ipuid['uid']["$uid"]['count'],$host,$dateClient,$mid,$dateReceived) ); |
|
| 501 | + /* Update HTML report */ |
|
| 502 | + fwrite($fp,updateReport ( $ip,$uid,$ipuid['ip']["$ip"]['count'],$ipuid['uid']["$uid"]['count'],$host,$dateClient,$mid,$dateReceived) ); |
|
| 503 | 503 | } |
| 504 | - else { /* Bad learn */ |
|
| 504 | + else { /* Bad learn */ |
|
| 505 | 505 | |
| 506 | - if (in_array($uid,array_keys($uidbad['uid']))) |
|
| 507 | - $uidbad['uid']["$uid"]['count']++; //number of bad learn by this uid |
|
| 508 | - else { |
|
| 509 | - $uidbad['uid']["$uid"]['count'] = 1; |
|
| 506 | + if (in_array($uid,array_keys($uidbad['uid']))) |
|
| 507 | + $uidbad['uid']["$uid"]['count']++; //number of bad learn by this uid |
|
| 508 | + else { |
|
| 509 | + $uidbad['uid']["$uid"]['count'] = 1; |
|
| 510 | 510 | $uidbad['uid']["$uid"][]=$uid; |
| 511 | - $uidbad['count']++; //numeber of unique bad uids |
|
| 512 | - } |
|
| 511 | + $uidbad['count']++; //numeber of unique bad uids |
|
| 512 | + } |
|
| 513 | 513 | /* The reason of bad report */ |
| 514 | 514 | if ($host === FALSE) $reason = 'This mail was not received by recognized MX host'; |
| 515 | 515 | if ($dateReceived === FALSE) $reason = 'This mail was not submitted to recognized MSA for learn'; |
@@ -535,17 +535,17 @@ discard block |
||
| 535 | 535 | fwrite($fp, '<hr><h2>Summary Report</h2><h5>Listing policy: ip must be learned at least '.$cf['listingip']['threshold']["$type"].' times from at least '.$cf['listingip']['thresholduid']["$type"].' different valid uids.</h5>' ); |
| 536 | 536 | fwrite($fpd, '<hr><h2>Summary Report</h2><h5>Listing policy: domains must be learned at least '.$cf['listingdom']['threshold']["$type"].' times from at least '.$cf['listingdom']['thresholduid']["$type"].' different valid uids.</h5>' ); |
| 537 | 537 | |
| 538 | - /* Make MYSQL connection */ |
|
| 538 | + /* Make MYSQL connection */ |
|
| 539 | 539 | if ( $cf['listingip']['onlyReport']["$type"] && $cf['listingdom']['onlyReport']["$type"] ) |
| 540 | 540 | $mysqli = NULL; |
| 541 | 541 | else { |
| 542 | - $mysqli = new mysqli($myconnArray['dbhost'], $myconnArray['userdb'], $myconnArray['pwd'], $myconnArray['db'], $myconnArray['dbport']); |
|
| 543 | - if ($mysqli->connect_error) { |
|
| 544 | - syslog (LOG_EMERG, $cf['syslog']['user'].': Connect Error (' . $mysqli->connect_errno . ') ' |
|
| 545 | - . $mysqli->connect_error); |
|
| 546 | - exit (254); |
|
| 547 | - } |
|
| 548 | - syslog(LOG_INFO, $cf['syslog']['user'].': Successfully mysql connected to ' . $mysqli->host_info) ; |
|
| 542 | + $mysqli = new mysqli($myconnArray['dbhost'], $myconnArray['userdb'], $myconnArray['pwd'], $myconnArray['db'], $myconnArray['dbport']); |
|
| 543 | + if ($mysqli->connect_error) { |
|
| 544 | + syslog (LOG_EMERG, $cf['syslog']['user'].': Connect Error (' . $mysqli->connect_errno . ') ' |
|
| 545 | + . $mysqli->connect_error); |
|
| 546 | + exit (254); |
|
| 547 | + } |
|
| 548 | + syslog(LOG_INFO, $cf['syslog']['user'].': Successfully mysql connected to ' . $mysqli->host_info) ; |
|
| 549 | 549 | } |
| 550 | 550 | /***********************/ |
| 551 | 551 | |
@@ -570,8 +570,8 @@ discard block |
||
| 570 | 570 | foreach ( $ierr as $thiserr ) |
| 571 | 571 | syslog (LOG_ERR, $cf['syslog']['user'].": IMAP Error: $thiserr"); |
| 572 | 572 | if ( $ierr = imap_alerts() ) |
| 573 | - foreach ( $ierr as $thiserr ) |
|
| 574 | - syslog (LOG_ALERT, $cf['syslog']['user'].": IMAP Alert: $thiserr"); |
|
| 573 | + foreach ( $ierr as $thiserr ) |
|
| 574 | + syslog (LOG_ALERT, $cf['syslog']['user'].": IMAP Alert: $thiserr"); |
|
| 575 | 575 | imap_close($m_mail); |
| 576 | 576 | } |
| 577 | 577 | ?> |
@@ -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,33 +84,33 @@ discard block |
||
| 84 | 84 | } |
| 85 | 85 | |
| 86 | 86 | |
| 87 | -function summaryReportAndList ($cf,$myconn,$tables,$category,$vet,$key) { |
|
| 87 | +function summaryReportAndList($cf, $myconn, $tables, $category, $vet, $key) { |
|
| 88 | 88 | $nk = $vet['count']; |
| 89 | 89 | |
| 90 | - if ( empty($vet) ) return NULL; |
|
| 90 | + if (empty($vet)) return NULL; |
|
| 91 | 91 | |
| 92 | - $return = sprintf('<h3>Statistics by %s</h3><table><tr><th>%s</th><th>Learned by</th><th>Learned times</th><th title="This field doesn\'t say if this %s is currently listed, but it says if this %s has listed now!">Listed Now</th></tr>'."\n", strtoupper($key),strtoupper($key),$key,$key); |
|
| 92 | + $return = sprintf('<h3>Statistics by %s</h3><table><tr><th>%s</th><th>Learned by</th><th>Learned times</th><th title="This field doesn\'t say if this %s is currently listed, but it says if this %s has listed now!">Listed Now</th></tr>'."\n", strtoupper($key), strtoupper($key), $key, $key); |
|
| 93 | 93 | |
| 94 | 94 | $values = array_keys($vet["$key"]); |
| 95 | 95 | |
| 96 | - foreach ( $values as $value ) { |
|
| 97 | - if ( $value == 'count' ) continue; |
|
| 96 | + foreach ($values as $value) { |
|
| 97 | + if ($value == 'count') continue; |
|
| 98 | 98 | $nlearn = $vet["$key"]["$value"]['count']; |
| 99 | 99 | unset($vet["$key"]["$value"]['count']); |
| 100 | 100 | $quantity = $cf["listing$key"]['quantity']["$category"]; /* In searchAndList this value is |
| 101 | 101 | passed by reference and modified */ |
| 102 | 102 | $nuid = count($vet["$key"]["$value"]); |
| 103 | - if ( !$cf["listing$key"]['onlyReport']["$category"] ) { |
|
| 104 | - if ( ($nlearn >= $cf["listing$key"]['threshold']["$category"])&&($nuid >= $cf["listing$key"]['thresholduid']["$category"]) ) { |
|
| 103 | + if (!$cf["listing$key"]['onlyReport']["$category"]) { |
|
| 104 | + if (($nlearn>=$cf["listing$key"]['threshold']["$category"]) && ($nuid>=$cf["listing$key"]['thresholduid']["$category"])) { |
|
| 105 | 105 | $reason = sprintf( |
| 106 | 106 | 'The %s <%s> has been listed because was marked %u times as %s by %u different accounts during last %u days.', |
| 107 | - strtoupper($key),$value,$nlearn,$category,$nuid,$cf['imap']['oldestday']); |
|
| 108 | - $listed = searchAndList ($myconn,$cf['syslog']['user'],$tables,$cf["listing$key"]['list']["$category"],$value,$cf["listing$key"]['unit']["$category"],$quantity,$reason); |
|
| 107 | + strtoupper($key), $value, $nlearn, $category, $nuid, $cf['imap']['oldestday']); |
|
| 108 | + $listed = searchAndList($myconn, $cf['syslog']['user'], $tables, $cf["listing$key"]['list']["$category"], $value, $cf["listing$key"]['unit']["$category"], $quantity, $reason); |
|
| 109 | 109 | } |
| 110 | 110 | else $listed = FALSE; |
| 111 | 111 | } |
| 112 | 112 | else $listed = FALSE; |
| 113 | - $nowlist = array( TRUE => array( |
|
| 113 | + $nowlist = array(TRUE => array( |
|
| 114 | 114 | 'style' => 'id=\'ipfound\'', |
| 115 | 115 | 'name' => 'YES', |
| 116 | 116 | ), |
@@ -124,46 +124,46 @@ discard block |
||
| 124 | 124 | ) |
| 125 | 125 | ); |
| 126 | 126 | |
| 127 | - $return .='<tr><td rowspan="'.$nuid.'">'.$value.'</td>'; |
|
| 128 | - $return .= sprintf ('<td>%s</td><td rowspan="'.$nuid.'">%u</td><td rowspan="'.$nuid.'" '.$nowlist["$listed"]['style'].'>%s</td></tr>',$vet["$key"]["$value"][0],$nlearn,$nowlist["$listed"]['name']); |
|
| 129 | - $rowuid=NULL; |
|
| 130 | - for ($j=1;$j<$nuid;$j++) $rowuid .= '<tr><td>%s</td></tr>'; |
|
| 127 | + $return .= '<tr><td rowspan="'.$nuid.'">'.$value.'</td>'; |
|
| 128 | + $return .= sprintf('<td>%s</td><td rowspan="'.$nuid.'">%u</td><td rowspan="'.$nuid.'" '.$nowlist["$listed"]['style'].'>%s</td></tr>', $vet["$key"]["$value"][0], $nlearn, $nowlist["$listed"]['name']); |
|
| 129 | + $rowuid = NULL; |
|
| 130 | + for ($j = 1; $j<$nuid; $j++) $rowuid .= '<tr><td>%s</td></tr>'; |
|
| 131 | 131 | array_shift($vet["$key"]["$value"]); |
| 132 | - $return .= vsprintf ($rowuid,$vet["$key"]["$value"]); |
|
| 132 | + $return .= vsprintf($rowuid, $vet["$key"]["$value"]); |
|
| 133 | 133 | |
| 134 | 134 | } |
| 135 | - $return .= sprintf ('<tr><th title="unique %s">%u</th><th title="unique uids">%u</th><th>%u</th></table>',$key,$vet["$key"]['count'],$vet['uid']['count'],$nk); |
|
| 135 | + $return .= sprintf('<tr><th title="unique %s">%u</th><th title="unique uids">%u</th><th>%u</th></table>', $key, $vet["$key"]['count'], $vet['uid']['count'], $nk); |
|
| 136 | 136 | |
| 137 | 137 | |
| 138 | 138 | /* Statistics by UID */ |
| 139 | 139 | /* Not used for listing purpose, but useful to you! */ |
| 140 | - $return .= sprintf('<h3>Statistics by UID</h3><table><tr><th>UID</th><th>%s learned</th><th>Learned times</th></tr>'."\n",$key); |
|
| 140 | + $return .= sprintf('<h3>Statistics by UID</h3><table><tr><th>UID</th><th>%s learned</th><th>Learned times</th></tr>'."\n", $key); |
|
| 141 | 141 | $uids = array_keys($vet['uid']); |
| 142 | - foreach ( $uids as $uid ) { |
|
| 143 | - if ( $uid == 'count' ) continue; |
|
| 142 | + foreach ($uids as $uid) { |
|
| 143 | + if ($uid == 'count') continue; |
|
| 144 | 144 | $nlearn = $vet['uid']["$uid"]['count']; |
| 145 | - unset ( $vet['uid']["$uid"]['count'] ); |
|
| 145 | + unset ($vet['uid']["$uid"]['count']); |
|
| 146 | 146 | $nip = count($vet['uid']["$uid"]); |
| 147 | - $return .='<tr><td rowspan="'.$nip.'">'.$uid.'</td>'; |
|
| 148 | - $return .= sprintf ('<td>%s</td><td rowspan="'.$nip.'">%u</td></tr>',$vet['uid']["$uid"][0],$nlearn); |
|
| 149 | - $rowuid=NULL; |
|
| 150 | - for ($j=1;$j<$nip;$j++) $rowuid .= '<tr><td>%s</td></tr>'; |
|
| 147 | + $return .= '<tr><td rowspan="'.$nip.'">'.$uid.'</td>'; |
|
| 148 | + $return .= sprintf('<td>%s</td><td rowspan="'.$nip.'">%u</td></tr>', $vet['uid']["$uid"][0], $nlearn); |
|
| 149 | + $rowuid = NULL; |
|
| 150 | + for ($j = 1; $j<$nip; $j++) $rowuid .= '<tr><td>%s</td></tr>'; |
|
| 151 | 151 | array_shift($vet['uid']["$uid"]); |
| 152 | - $return .= vsprintf ($rowuid,$vet['uid']["$uid"]); |
|
| 152 | + $return .= vsprintf($rowuid, $vet['uid']["$uid"]); |
|
| 153 | 153 | |
| 154 | 154 | } |
| 155 | - $return .= sprintf ('<tr><th title="unique uids">%u</th><th title="unique %s">%u</th><th>%u</th></table>', |
|
| 156 | - $vet['uid']['count'],$key,$vet["$key"]['count'],$nk); |
|
| 155 | + $return .= sprintf('<tr><th title="unique uids">%u</th><th title="unique %s">%u</th><th>%u</th></table>', |
|
| 156 | + $vet['uid']['count'], $key, $vet["$key"]['count'], $nk); |
|
| 157 | 157 | |
| 158 | 158 | |
| 159 | 159 | return $return; |
| 160 | 160 | } |
| 161 | 161 | |
| 162 | 162 | |
| 163 | -function splunksearch ($service,$message_id,$date) { |
|
| 163 | +function splunksearch($service, $message_id, $date) { |
|
| 164 | 164 | |
| 165 | 165 | // Run a blocking search |
| 166 | - $searchQueryBlocking = 'search (message_id="'. addslashes( $message_id ) . |
|
| 166 | + $searchQueryBlocking = 'search (message_id="'.addslashes($message_id). |
|
| 167 | 167 | '" OR sasl_username) | transaction message_id queue_id maxspan=3m maxpause=2m | search sasl_username message_id=* | table sasl_username'; |
| 168 | 168 | |
| 169 | 169 | /* Doesn't work on Splunk 6.6 for HTTP exceptions |
@@ -182,8 +182,8 @@ discard block |
||
| 182 | 182 | |
| 183 | 183 | // A one shot search |
| 184 | 184 | $searchParams = array( |
| 185 | - 'earliest_time' => date("c",strtotime ($date)-120), |
|
| 186 | - 'latest_time' => date("c",strtotime ($date)+60) |
|
| 185 | + 'earliest_time' => date("c", strtotime($date)-120), |
|
| 186 | + 'latest_time' => date("c", strtotime($date)+60) |
|
| 187 | 187 | ); |
| 188 | 188 | |
| 189 | 189 | // Run a oneshot search that returns the job's results |
@@ -197,7 +197,7 @@ discard block |
||
| 197 | 197 | { |
| 198 | 198 | // More than one field attribute returned by search |
| 199 | 199 | // You must redefine the search |
| 200 | - if ( count($result->getFieldNames()) > 1 ) return FALSE; |
|
| 200 | + if (count($result->getFieldNames())>1) return FALSE; |
|
| 201 | 201 | } |
| 202 | 202 | else if ($result instanceof Splunk_ResultsMessage) |
| 203 | 203 | { |
@@ -235,13 +235,13 @@ discard block |
||
| 235 | 235 | |
| 236 | 236 | function flattenParts($messageParts, $flattenedParts = array(), $prefix = '', $index = 1, $fullPrefix = true) { |
| 237 | 237 | |
| 238 | - foreach($messageParts as $part) { |
|
| 238 | + foreach ($messageParts as $part) { |
|
| 239 | 239 | $flattenedParts[$prefix.$index] = $part; |
| 240 | - if(isset($part->parts)) { |
|
| 241 | - if($part->type == 2) { |
|
| 240 | + if (isset($part->parts)) { |
|
| 241 | + if ($part->type == 2) { |
|
| 242 | 242 | $flattenedParts = flattenParts($part->parts, $flattenedParts, $prefix.$index.'.', 0, false); |
| 243 | 243 | } |
| 244 | - elseif($fullPrefix) { |
|
| 244 | + elseif ($fullPrefix) { |
|
| 245 | 245 | $flattenedParts = flattenParts($part->parts, $flattenedParts, $prefix.$index.'.'); |
| 246 | 246 | } |
| 247 | 247 | else { |
@@ -259,7 +259,7 @@ discard block |
||
| 259 | 259 | function getPart($connection, $messageNumber, $partNumber, $encoding) { |
| 260 | 260 | |
| 261 | 261 | $data = imap_fetchbody($connection, $messageNumber, $partNumber); |
| 262 | - switch($encoding) { |
|
| 262 | + switch ($encoding) { |
|
| 263 | 263 | case 0: return $data; // 7BIT |
| 264 | 264 | case 1: return $data; // 8BIT |
| 265 | 265 | case 2: return $data; // BINARY |
@@ -272,25 +272,25 @@ discard block |
||
| 272 | 272 | } |
| 273 | 273 | /***********************************/ |
| 274 | 274 | |
| 275 | -function getDomains ($text) { |
|
| 275 | +function getDomains($text) { |
|
| 276 | 276 | $pattern = '~[a-z]+://\S+~'; |
| 277 | 277 | $ret = array(); |
| 278 | 278 | $num_found = preg_match_all($pattern, $text, $out); |
| 279 | - if ( ($num_found !== FALSE) && ($num_found>0) ) { |
|
| 279 | + if (($num_found !== FALSE) && ($num_found>0)) { |
|
| 280 | 280 | foreach ($out[0] as $url) |
| 281 | 281 | $ret[] = parse_url($url, PHP_URL_HOST); |
| 282 | 282 | } |
| 283 | 283 | return array_values(array_unique($ret)); |
| 284 | 284 | } |
| 285 | 285 | |
| 286 | -function parseURL ($connection,$messageNumber) { |
|
| 286 | +function parseURL($connection, $messageNumber) { |
|
| 287 | 287 | $message = ''; |
| 288 | 288 | $structure = imap_fetchstructure($connection, $messageNumber); |
| 289 | 289 | if (isset($structure->parts)) { |
| 290 | 290 | $flattenedParts = flattenParts($structure->parts); |
| 291 | - foreach($flattenedParts as $partNumber => $part) { |
|
| 291 | + foreach ($flattenedParts as $partNumber => $part) { |
|
| 292 | 292 | |
| 293 | - switch($part->type) { |
|
| 293 | + switch ($part->type) { |
|
| 294 | 294 | |
| 295 | 295 | case 0: |
| 296 | 296 | // the HTML or plain text part of the email |
@@ -319,13 +319,13 @@ discard block |
||
| 319 | 319 | else |
| 320 | 320 | $message = getPart($connection, $messageNumber, 1, $structure->encoding); |
| 321 | 321 | |
| 322 | - if ( !empty($message) ) |
|
| 322 | + if (!empty($message)) |
|
| 323 | 323 | return getDomains($message); |
| 324 | 324 | return array(); |
| 325 | 325 | } |
| 326 | 326 | |
| 327 | 327 | function humanKey($key) { |
| 328 | - switch($key) { |
|
| 328 | + switch ($key) { |
|
| 329 | 329 | case 'ip': |
| 330 | 330 | return 'ips'; |
| 331 | 331 | case 'dom': |
@@ -334,67 +334,67 @@ discard block |
||
| 334 | 334 | return $key; |
| 335 | 335 | } |
| 336 | 336 | |
| 337 | -function writeFileHeader($f,$conf,$key,$type,$rtime) { |
|
| 338 | - fwrite( $f, file_get_contents(dirname(__FILE__) . '/' . $conf['report']['reportTemplateHeader']) ); |
|
| 339 | - fwrite( $f,sprintf('<h1> Report of %s %s</h1><h5>%s</h5><h2>Detailed Report</h2>',$type, strtoupper(humanKey($key)),$rtime) ); |
|
| 337 | +function writeFileHeader($f, $conf, $key, $type, $rtime) { |
|
| 338 | + fwrite($f, file_get_contents(dirname(__FILE__).'/'.$conf['report']['reportTemplateHeader'])); |
|
| 339 | + fwrite($f, sprintf('<h1> Report of %s %s</h1><h5>%s</h5><h2>Detailed Report</h2>', $type, strtoupper(humanKey($key)), $rtime)); |
|
| 340 | 340 | if ($conf["listing$key"]['onlyReport']["$type"]) { |
| 341 | - fwrite( $f,sprintf('<p>None of the below %s have been listed because listing is not active in configuration.</p>', |
|
| 342 | - strtoupper(humanKey($key))) ); |
|
| 341 | + fwrite($f, sprintf('<p>None of the below %s have been listed because listing is not active in configuration.</p>', |
|
| 342 | + strtoupper(humanKey($key)))); |
|
| 343 | 343 | syslog(LOG_INFO, sprintf('%s: Report only for %s %s: no listing activated in configuration.', |
| 344 | - $conf['syslog']['user'],$type,humanKey($key)) |
|
| 344 | + $conf['syslog']['user'], $type, humanKey($key)) |
|
| 345 | 345 | ); |
| 346 | 346 | } |
| 347 | - fwrite( $f,sprintf('<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>%s</th><th title="How many times this uid learns">#UID</th><th title="Number of times this learned %s appears in different mails">#%s</th><th nowrap>Received by</th><th>Message-Id</th></tr>', |
|
| 348 | - strtoupper($key),strtoupper($key),strtoupper($key)) ); |
|
| 347 | + fwrite($f, sprintf('<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>%s</th><th title="How many times this uid learns">#UID</th><th title="Number of times this learned %s appears in different mails">#%s</th><th nowrap>Received by</th><th>Message-Id</th></tr>', |
|
| 348 | + strtoupper($key), strtoupper($key), strtoupper($key))); |
|
| 349 | 349 | } |
| 350 | 350 | |
| 351 | 351 | |
| 352 | -function imapReport ($cf,$myconnArray,$splunkconn,$tables,$type) { |
|
| 353 | - $file = dirname(__FILE__) . '/' . $cf['report']['reportFile']["$type"]; |
|
| 354 | - $filed = dirname(__FILE__) . '/' . $cf['report']['reportDomFile']["$type"]; |
|
| 355 | - $fileb= dirname(__FILE__) . '/' . $cf['report']['badreportFile']["$type"]; |
|
| 356 | - $m_mail = imap_open('{'.$cf['imap']['mailhost'].':143/imap/novalidate-cert/authuser='.$cf['imap']['authuser'].'}'.$cf['imap']['folder']["$type"], $cf['imap']['account'],$cf['imap']['authpassword'], OP_READONLY) |
|
| 357 | - or syslog (LOG_EMERG, $cf['syslog']['user'].': Error in IMAP connection to <'.$cf['imap']['mailhost'].'>: ' . imap_last_error()); |
|
| 358 | - if ( !$m_mail ) exit(254); |
|
| 352 | +function imapReport($cf, $myconnArray, $splunkconn, $tables, $type) { |
|
| 353 | + $file = dirname(__FILE__).'/'.$cf['report']['reportFile']["$type"]; |
|
| 354 | + $filed = dirname(__FILE__).'/'.$cf['report']['reportDomFile']["$type"]; |
|
| 355 | + $fileb = dirname(__FILE__).'/'.$cf['report']['badreportFile']["$type"]; |
|
| 356 | + $m_mail = imap_open('{'.$cf['imap']['mailhost'].':143/imap/novalidate-cert/authuser='.$cf['imap']['authuser'].'}'.$cf['imap']['folder']["$type"], $cf['imap']['account'], $cf['imap']['authpassword'], OP_READONLY) |
|
| 357 | + or syslog(LOG_EMERG, $cf['syslog']['user'].': Error in IMAP connection to <'.$cf['imap']['mailhost'].'>: '.imap_last_error()); |
|
| 358 | + if (!$m_mail) exit(254); |
|
| 359 | 359 | |
| 360 | 360 | |
| 361 | - syslog (LOG_INFO,$cf['syslog']['user'].': Successfully connected to <'.$cf['imap']['mailhost'].">; Reading $type messages of last ".$cf['imap']['oldestday'].' days...'); |
|
| 361 | + syslog(LOG_INFO, $cf['syslog']['user'].': Successfully connected to <'.$cf['imap']['mailhost'].">; Reading $type messages of last ".$cf['imap']['oldestday'].' days...'); |
|
| 362 | 362 | //get all messages |
| 363 | - $dateTh = date ( "d-M-Y", strToTime ( '-'.$cf['imap']['oldestday'].' days' ) ); |
|
| 364 | - $dateN = date ( "d-M-Y", strToTime ( "now" ) ); |
|
| 365 | - $m_search=imap_search ($m_mail, "SINCE \"$dateTh\" BEFORE \"$dateN\"" ); |
|
| 363 | + $dateTh = date("d-M-Y", strToTime('-'.$cf['imap']['oldestday'].' days')); |
|
| 364 | + $dateN = date("d-M-Y", strToTime("now")); |
|
| 365 | + $m_search = imap_search($m_mail, "SINCE \"$dateTh\" BEFORE \"$dateN\""); |
|
| 366 | 366 | |
| 367 | 367 | // Order results starting from newest message |
| 368 | - if ( empty($m_search) ) { |
|
| 369 | - syslog (LOG_INFO,$cf['syslog']['user'].": No mail found in $type folder. No reports written for $type."); |
|
| 370 | - if ( $ierr = imap_errors() ) |
|
| 371 | - foreach ( $ierr as $thiserr ) |
|
| 372 | - syslog (LOG_ERR, $cf['syslog']['user'].": IMAP Error: $thiserr"); |
|
| 373 | - if ( $ierr = imap_alerts() ) |
|
| 374 | - foreach ( $ierr as $thiserr ) |
|
| 375 | - syslog (LOG_ALERT, $cf['syslog']['user'].": IMAP Alert: $thiserr"); |
|
| 376 | - imap_close( $m_mail ); |
|
| 377 | - if ( file_exists( $file ) ) unlink ($file); |
|
| 378 | - if ( file_exists( $filed ) ) unlink ($filed); |
|
| 379 | - if ( file_exists( $fileb ) ) unlink ($fileb); |
|
| 368 | + if (empty($m_search)) { |
|
| 369 | + syslog(LOG_INFO, $cf['syslog']['user'].": No mail found in $type folder. No reports written for $type."); |
|
| 370 | + if ($ierr = imap_errors()) |
|
| 371 | + foreach ($ierr as $thiserr) |
|
| 372 | + syslog(LOG_ERR, $cf['syslog']['user'].": IMAP Error: $thiserr"); |
|
| 373 | + if ($ierr = imap_alerts()) |
|
| 374 | + foreach ($ierr as $thiserr) |
|
| 375 | + syslog(LOG_ALERT, $cf['syslog']['user'].": IMAP Alert: $thiserr"); |
|
| 376 | + imap_close($m_mail); |
|
| 377 | + if (file_exists($file)) unlink($file); |
|
| 378 | + if (file_exists($filed)) unlink($filed); |
|
| 379 | + if (file_exists($fileb)) unlink($fileb); |
|
| 380 | 380 | return FALSE; |
| 381 | 381 | } |
| 382 | - $nmes = count ($m_search); |
|
| 383 | - syslog (LOG_INFO,$cf['syslog']['user'].": Found $nmes mail in $type folder."); |
|
| 382 | + $nmes = count($m_search); |
|
| 383 | + syslog(LOG_INFO, $cf['syslog']['user'].": Found $nmes mail in $type folder."); |
|
| 384 | 384 | if ($nmes>0) rsort($m_search); |
| 385 | 385 | |
| 386 | 386 | // Create report file |
| 387 | 387 | |
| 388 | 388 | $fp = fopen($file, 'w'); |
| 389 | - $fpd= fopen($filed, 'w'); |
|
| 390 | - $fpb= fopen($fileb, 'w'); |
|
| 391 | - $lastup = "Last Update: " . date ("d F Y H:i", time()); |
|
| 392 | - writeFileHeader($fp,$cf,'ip',$type,$lastup); |
|
| 393 | - writeFileHeader($fpd,$cf,'dom',$type,$lastup); |
|
| 389 | + $fpd = fopen($filed, 'w'); |
|
| 390 | + $fpb = fopen($fileb, 'w'); |
|
| 391 | + $lastup = "Last Update: ".date("d F Y H:i", time()); |
|
| 392 | + writeFileHeader($fp, $cf, 'ip', $type, $lastup); |
|
| 393 | + writeFileHeader($fpd, $cf, 'dom', $type, $lastup); |
|
| 394 | 394 | |
| 395 | - fwrite( $fpb,file_get_contents(dirname(__FILE__) . '/' . $cf['report']['reportTemplateHeader']) ); |
|
| 396 | - fwrite( $fpb,"<h1> Report of bad reported $type mails</h1><h5>$lastup</h5><h2>Detailed Report</h2>" ); |
|
| 397 | - 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>' ); |
|
| 395 | + fwrite($fpb, file_get_contents(dirname(__FILE__).'/'.$cf['report']['reportTemplateHeader'])); |
|
| 396 | + fwrite($fpb, "<h1> Report of bad reported $type mails</h1><h5>$lastup</h5><h2>Detailed Report</h2>"); |
|
| 397 | + 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>'); |
|
| 398 | 398 | |
| 399 | 399 | $ipuid = array(); |
| 400 | 400 | $ipuid['count'] = 0; |
@@ -418,105 +418,105 @@ discard block |
||
| 418 | 418 | //get imap header info for obj thang |
| 419 | 419 | //$headers = imap_headerinfo($m_mail, $onem); |
| 420 | 420 | //$head = imap_fetchheader($m_mail, $headers->Msgno); |
| 421 | - $head = imap_fetchheader($m_mail, $onem ); |
|
| 421 | + $head = imap_fetchheader($m_mail, $onem); |
|
| 422 | 422 | //$obj = imap_rfc822_parse_headers( $head); |
| 423 | 423 | |
| 424 | - list ($ip,$host,$dateReceived,$dateClient,$mid) = getIP( $head,$cf['mx_hostname']['mx'],$cf['msa']['msalearn'] ); |
|
| 424 | + list ($ip, $host, $dateReceived, $dateClient, $mid) = getIP($head, $cf['mx_hostname']['mx'], $cf['msa']['msalearn']); |
|
| 425 | 425 | if (empty($mid)) { |
| 426 | - $uid='NA'; |
|
| 427 | - syslog (LOG_ERR, $cf['syslog']['user'].": Error retrieving data for empty Message-ID."); |
|
| 428 | - } else { |
|
| 426 | + $uid = 'NA'; |
|
| 427 | + syslog(LOG_ERR, $cf['syslog']['user'].": Error retrieving data for empty Message-ID."); |
|
| 428 | + }else { |
|
| 429 | 429 | if ($dateReceived === FALSE) { |
| 430 | - $uid='unauthenticated'; |
|
| 431 | - syslog (LOG_ERR, $cf['syslog']['user'].": Error retrieving date for $mid. Maybe this mail was not submitted to Learner MSA"); |
|
| 432 | - } else |
|
| 433 | - if ( !($uid = splunksearch ($splunkconn, trim($mid,'<>'), $dateReceived)) ) { |
|
| 434 | - syslog (LOG_ERR, $cf['syslog']['user'].": Error retrieving uid from Splunk log for $mid."); |
|
| 435 | - $uid='unknown'; |
|
| 430 | + $uid = 'unauthenticated'; |
|
| 431 | + syslog(LOG_ERR, $cf['syslog']['user'].": Error retrieving date for $mid. Maybe this mail was not submitted to Learner MSA"); |
|
| 432 | + }else |
|
| 433 | + if (!($uid = splunksearch($splunkconn, trim($mid, '<>'), $dateReceived))) { |
|
| 434 | + syslog(LOG_ERR, $cf['syslog']['user'].": Error retrieving uid from Splunk log for $mid."); |
|
| 435 | + $uid = 'unknown'; |
|
| 436 | 436 | } |
| 437 | 437 | } |
| 438 | 438 | |
| 439 | 439 | /* Extract domains url in body */ |
| 440 | - $domains = parseURL ($m_mail,$onem); |
|
| 440 | + $domains = parseURL($m_mail, $onem); |
|
| 441 | 441 | |
| 442 | 442 | /* Update count of each ip */ |
| 443 | - if ($host and ($uid!='NA') and ($uid!='unauthenticated') and ($uid!='unknown')) { /* IP is received by MX servers and learned by valid uid */ |
|
| 444 | - $ipuid['count']++; //number of right messages |
|
| 443 | + if ($host and ($uid != 'NA') and ($uid != 'unauthenticated') and ($uid != 'unknown')) { /* IP is received by MX servers and learned by valid uid */ |
|
| 444 | + $ipuid['count']++; //number of right messages |
|
| 445 | 445 | |
| 446 | - if (in_array($uid,array_keys($ipuid['uid']))) { |
|
| 447 | - $ipuid['uid']["$uid"]['count']++; //number of learn by this uid |
|
| 448 | - if (!in_array($ip,$ipuid['uid']["$uid"])) |
|
| 449 | - $ipuid['uid']["$uid"][]=$ip; //ips learned by this uid |
|
| 446 | + if (in_array($uid, array_keys($ipuid['uid']))) { |
|
| 447 | + $ipuid['uid']["$uid"]['count']++; //number of learn by this uid |
|
| 448 | + if (!in_array($ip, $ipuid['uid']["$uid"])) |
|
| 449 | + $ipuid['uid']["$uid"][] = $ip; //ips learned by this uid |
|
| 450 | 450 | } |
| 451 | 451 | else { |
| 452 | 452 | $ipuid['uid']["$uid"]['count'] = 1; |
| 453 | - $ipuid['uid']["$uid"][]=$ip; |
|
| 454 | - $ipuid['uid']['count']++; //number of unique uids |
|
| 453 | + $ipuid['uid']["$uid"][] = $ip; |
|
| 454 | + $ipuid['uid']['count']++; //number of unique uids |
|
| 455 | 455 | } |
| 456 | 456 | |
| 457 | - if (in_array($ip,array_keys($ipuid['ip']))) { |
|
| 458 | - $ipuid['ip']["$ip"]['count']++; //number of time this ip appears in different messages |
|
| 459 | - if (!in_array($uid,$ipuid['ip']["$ip"])) |
|
| 460 | - $ipuid['ip']["$ip"][]=$uid; //uids that learned this ip |
|
| 457 | + if (in_array($ip, array_keys($ipuid['ip']))) { |
|
| 458 | + $ipuid['ip']["$ip"]['count']++; //number of time this ip appears in different messages |
|
| 459 | + if (!in_array($uid, $ipuid['ip']["$ip"])) |
|
| 460 | + $ipuid['ip']["$ip"][] = $uid; //uids that learned this ip |
|
| 461 | 461 | } |
| 462 | 462 | else { |
| 463 | 463 | $ipuid['ip']["$ip"]['count'] = 1; |
| 464 | - $ipuid['ip']["$ip"][]=$uid; |
|
| 465 | - $ipuid['ip']['count']++; //number of unique ips |
|
| 464 | + $ipuid['ip']["$ip"][] = $uid; |
|
| 465 | + $ipuid['ip']['count']++; //number of unique ips |
|
| 466 | 466 | } |
| 467 | 467 | |
| 468 | 468 | foreach ($domains as $dom) { |
| 469 | 469 | $domuid['count']++; |
| 470 | - if (in_array($uid,array_keys($domuid['uid']))) { |
|
| 471 | - $domuid['uid']["$uid"]['count']++; //number of learn by this uid |
|
| 472 | - if (!in_array($dom,$domuid['uid']["$uid"])) |
|
| 473 | - $domuid['uid']["$uid"][]=$dom; //domains learned by this uid |
|
| 470 | + if (in_array($uid, array_keys($domuid['uid']))) { |
|
| 471 | + $domuid['uid']["$uid"]['count']++; //number of learn by this uid |
|
| 472 | + if (!in_array($dom, $domuid['uid']["$uid"])) |
|
| 473 | + $domuid['uid']["$uid"][] = $dom; //domains learned by this uid |
|
| 474 | 474 | } |
| 475 | 475 | else { |
| 476 | 476 | $domuid['uid']["$uid"]['count'] = 1; |
| 477 | - $domuid['uid']["$uid"][]=$dom; |
|
| 478 | - $domuid['uid']['count']++; //number of unique uids |
|
| 477 | + $domuid['uid']["$uid"][] = $dom; |
|
| 478 | + $domuid['uid']['count']++; //number of unique uids |
|
| 479 | 479 | } |
| 480 | 480 | |
| 481 | - if (in_array($dom,array_keys($domuid['dom']))) { |
|
| 482 | - $domuid['dom']["$dom"]['count']++; //number of learn with this domain |
|
| 483 | - if (!in_array($uid,$domuid['dom']["$dom"])) |
|
| 484 | - $domuid['dom']["$dom"][]=$uid; //uids that learned this domain |
|
| 481 | + if (in_array($dom, array_keys($domuid['dom']))) { |
|
| 482 | + $domuid['dom']["$dom"]['count']++; //number of learn with this domain |
|
| 483 | + if (!in_array($uid, $domuid['dom']["$dom"])) |
|
| 484 | + $domuid['dom']["$dom"][] = $uid; //uids that learned this domain |
|
| 485 | 485 | } |
| 486 | 486 | else { |
| 487 | 487 | $domuid['dom']["$dom"]['count'] = 1; |
| 488 | - $domuid['dom']["$dom"][]=$uid; |
|
| 489 | - $domuid['dom']['count']++; //number of unique domains |
|
| 488 | + $domuid['dom']["$dom"][] = $uid; |
|
| 489 | + $domuid['dom']['count']++; //number of unique domains |
|
| 490 | 490 | } |
| 491 | 491 | |
| 492 | 492 | fwrite($fpd, |
| 493 | - updateReport ( |
|
| 494 | - $dom,$uid,$domuid['dom']["$dom"]['count'], |
|
| 495 | - $domuid['uid']["$uid"]['count'],$host, |
|
| 496 | - $dateClient,$mid,$dateReceived |
|
| 493 | + updateReport( |
|
| 494 | + $dom, $uid, $domuid['dom']["$dom"]['count'], |
|
| 495 | + $domuid['uid']["$uid"]['count'], $host, |
|
| 496 | + $dateClient, $mid, $dateReceived |
|
| 497 | 497 | ) |
| 498 | 498 | ); |
| 499 | 499 | } |
| 500 | 500 | |
| 501 | 501 | /* Update HTML report */ |
| 502 | - fwrite($fp,updateReport ( $ip,$uid,$ipuid['ip']["$ip"]['count'],$ipuid['uid']["$uid"]['count'],$host,$dateClient,$mid,$dateReceived) ); |
|
| 502 | + fwrite($fp, updateReport($ip, $uid, $ipuid['ip']["$ip"]['count'], $ipuid['uid']["$uid"]['count'], $host, $dateClient, $mid, $dateReceived)); |
|
| 503 | 503 | } |
| 504 | 504 | else { /* Bad learn */ |
| 505 | 505 | |
| 506 | - if (in_array($uid,array_keys($uidbad['uid']))) |
|
| 507 | - $uidbad['uid']["$uid"]['count']++; //number of bad learn by this uid |
|
| 506 | + if (in_array($uid, array_keys($uidbad['uid']))) |
|
| 507 | + $uidbad['uid']["$uid"]['count']++; //number of bad learn by this uid |
|
| 508 | 508 | else { |
| 509 | 509 | $uidbad['uid']["$uid"]['count'] = 1; |
| 510 | - $uidbad['uid']["$uid"][]=$uid; |
|
| 511 | - $uidbad['count']++; //numeber of unique bad uids |
|
| 510 | + $uidbad['uid']["$uid"][] = $uid; |
|
| 511 | + $uidbad['count']++; //numeber of unique bad uids |
|
| 512 | 512 | } |
| 513 | 513 | /* The reason of bad report */ |
| 514 | 514 | if ($host === FALSE) $reason = 'This mail was not received by recognized MX host'; |
| 515 | 515 | if ($dateReceived === FALSE) $reason = 'This mail was not submitted to recognized MSA for learn'; |
| 516 | - if ($uid=='unknown') $reason = 'The uid of this mail was not found in splunk log'; |
|
| 516 | + if ($uid == 'unknown') $reason = 'The uid of this mail was not found in splunk log'; |
|
| 517 | 517 | if (!isset($reason)) $reason = '?'; |
| 518 | 518 | |
| 519 | - fwrite( $fpb,updatebadReport ( $uid,$dateClient,$mid,$dateReceived,$reason ) ); |
|
| 519 | + fwrite($fpb, updatebadReport($uid, $dateClient, $mid, $dateReceived, $reason)); |
|
| 520 | 520 | } |
| 521 | 521 | } |
| 522 | 522 | |
@@ -524,54 +524,54 @@ discard block |
||
| 524 | 524 | //close report file and mailbox |
| 525 | 525 | |
| 526 | 526 | /* Summary Report */ |
| 527 | - $ipuid['ip'] = array_msort( $ipuid['ip'], array('count'=>SORT_DESC) ); |
|
| 528 | - $ipuid['uid'] = array_msort( $ipuid['uid'], array('count'=>SORT_DESC) ); |
|
| 529 | - $domuid['dom'] = array_msort( $domuid['dom'], array('count'=>SORT_DESC) ); |
|
| 530 | - $domuid['uid'] = array_msort( $domuid['uid'], array('count'=>SORT_DESC) ); |
|
| 531 | - $uidbad['uid'] = array_msort( $uidbad['uid'], array('count'=>SORT_DESC) ); |
|
| 527 | + $ipuid['ip'] = array_msort($ipuid['ip'], array('count'=>SORT_DESC)); |
|
| 528 | + $ipuid['uid'] = array_msort($ipuid['uid'], array('count'=>SORT_DESC)); |
|
| 529 | + $domuid['dom'] = array_msort($domuid['dom'], array('count'=>SORT_DESC)); |
|
| 530 | + $domuid['uid'] = array_msort($domuid['uid'], array('count'=>SORT_DESC)); |
|
| 531 | + $uidbad['uid'] = array_msort($uidbad['uid'], array('count'=>SORT_DESC)); |
|
| 532 | 532 | |
| 533 | 533 | fwrite($fp, '</table>'); |
| 534 | 534 | fwrite($fpd, '</table>'); |
| 535 | - fwrite($fp, '<hr><h2>Summary Report</h2><h5>Listing policy: ip must be learned at least '.$cf['listingip']['threshold']["$type"].' times from at least '.$cf['listingip']['thresholduid']["$type"].' different valid uids.</h5>' ); |
|
| 536 | - fwrite($fpd, '<hr><h2>Summary Report</h2><h5>Listing policy: domains must be learned at least '.$cf['listingdom']['threshold']["$type"].' times from at least '.$cf['listingdom']['thresholduid']["$type"].' different valid uids.</h5>' ); |
|
| 535 | + fwrite($fp, '<hr><h2>Summary Report</h2><h5>Listing policy: ip must be learned at least '.$cf['listingip']['threshold']["$type"].' times from at least '.$cf['listingip']['thresholduid']["$type"].' different valid uids.</h5>'); |
|
| 536 | + fwrite($fpd, '<hr><h2>Summary Report</h2><h5>Listing policy: domains must be learned at least '.$cf['listingdom']['threshold']["$type"].' times from at least '.$cf['listingdom']['thresholduid']["$type"].' different valid uids.</h5>'); |
|
| 537 | 537 | |
| 538 | 538 | /* Make MYSQL connection */ |
| 539 | - if ( $cf['listingip']['onlyReport']["$type"] && $cf['listingdom']['onlyReport']["$type"] ) |
|
| 539 | + if ($cf['listingip']['onlyReport']["$type"] && $cf['listingdom']['onlyReport']["$type"]) |
|
| 540 | 540 | $mysqli = NULL; |
| 541 | 541 | else { |
| 542 | 542 | $mysqli = new mysqli($myconnArray['dbhost'], $myconnArray['userdb'], $myconnArray['pwd'], $myconnArray['db'], $myconnArray['dbport']); |
| 543 | 543 | if ($mysqli->connect_error) { |
| 544 | - syslog (LOG_EMERG, $cf['syslog']['user'].': Connect Error (' . $mysqli->connect_errno . ') ' |
|
| 544 | + syslog(LOG_EMERG, $cf['syslog']['user'].': Connect Error ('.$mysqli->connect_errno.') ' |
|
| 545 | 545 | . $mysqli->connect_error); |
| 546 | 546 | exit (254); |
| 547 | 547 | } |
| 548 | - syslog(LOG_INFO, $cf['syslog']['user'].': Successfully mysql connected to ' . $mysqli->host_info) ; |
|
| 548 | + syslog(LOG_INFO, $cf['syslog']['user'].': Successfully mysql connected to '.$mysqli->host_info); |
|
| 549 | 549 | } |
| 550 | 550 | /***********************/ |
| 551 | 551 | |
| 552 | - fwrite($fp, summaryReportAndList ($cf,$mysqli,$tables,$type,$ipuid, 'ip') ); |
|
| 553 | - fwrite($fp,file_get_contents(dirname(__FILE__) . '/' . $cf['report']['reportTemplateFooter'])); |
|
| 552 | + fwrite($fp, summaryReportAndList($cf, $mysqli, $tables, $type, $ipuid, 'ip')); |
|
| 553 | + fwrite($fp, file_get_contents(dirname(__FILE__).'/'.$cf['report']['reportTemplateFooter'])); |
|
| 554 | 554 | fclose($fp); |
| 555 | 555 | |
| 556 | - fwrite($fpd, summaryReportAndList ($cf,$mysqli,$tables,$type,$domuid, 'dom') ); |
|
| 557 | - fwrite($fpd,file_get_contents(dirname(__FILE__) . '/' . $cf['report']['reportTemplateFooter'])); |
|
| 556 | + fwrite($fpd, summaryReportAndList($cf, $mysqli, $tables, $type, $domuid, 'dom')); |
|
| 557 | + fwrite($fpd, file_get_contents(dirname(__FILE__).'/'.$cf['report']['reportTemplateFooter'])); |
|
| 558 | 558 | fclose($fpd); |
| 559 | 559 | |
| 560 | - if ( !($cf['listingip']['onlyReport']["$type"] && $cf['listingdom']['onlyReport']["$type"]) ) |
|
| 560 | + if (!($cf['listingip']['onlyReport']["$type"] && $cf['listingdom']['onlyReport']["$type"])) |
|
| 561 | 561 | $mysqli->close(); |
| 562 | 562 | |
| 563 | 563 | fwrite($fpb, '</table>'); |
| 564 | - fwrite( $fpb,summaryBadReport( $uidbad ) ); |
|
| 565 | - fwrite($fpb,file_get_contents(dirname(__FILE__) . '/' . $cf['report']['reportTemplateFooter'])); |
|
| 564 | + fwrite($fpb, summaryBadReport($uidbad)); |
|
| 565 | + fwrite($fpb, file_get_contents(dirname(__FILE__).'/'.$cf['report']['reportTemplateFooter'])); |
|
| 566 | 566 | fclose($fpb); |
| 567 | - syslog (LOG_INFO,$cf['syslog']['user'].': Report files written. Listing job for '.$type.' terminated.'); |
|
| 568 | - |
|
| 569 | - if ( $ierr = imap_errors() ) |
|
| 570 | - foreach ( $ierr as $thiserr ) |
|
| 571 | - syslog (LOG_ERR, $cf['syslog']['user'].": IMAP Error: $thiserr"); |
|
| 572 | - if ( $ierr = imap_alerts() ) |
|
| 573 | - foreach ( $ierr as $thiserr ) |
|
| 574 | - syslog (LOG_ALERT, $cf['syslog']['user'].": IMAP Alert: $thiserr"); |
|
| 567 | + syslog(LOG_INFO, $cf['syslog']['user'].': Report files written. Listing job for '.$type.' terminated.'); |
|
| 568 | + |
|
| 569 | + if ($ierr = imap_errors()) |
|
| 570 | + foreach ($ierr as $thiserr) |
|
| 571 | + syslog(LOG_ERR, $cf['syslog']['user'].": IMAP Error: $thiserr"); |
|
| 572 | + if ($ierr = imap_alerts()) |
|
| 573 | + foreach ($ierr as $thiserr) |
|
| 574 | + syslog(LOG_ALERT, $cf['syslog']['user'].": IMAP Alert: $thiserr"); |
|
| 575 | 575 | imap_close($m_mail); |
| 576 | 576 | } |
| 577 | 577 | ?> |
@@ -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,14 +97,18 @@ discard block |
||
| 87 | 97 | function summaryReportAndList ($cf,$myconn,$tables,$category,$vet,$key) { |
| 88 | 98 | $nk = $vet['count']; |
| 89 | 99 | |
| 90 | - if ( empty($vet) ) return NULL; |
|
| 100 | + if ( empty($vet) ) { |
|
| 101 | + return NULL; |
|
| 102 | + } |
|
| 91 | 103 | |
| 92 | 104 | $return = sprintf('<h3>Statistics by %s</h3><table><tr><th>%s</th><th>Learned by</th><th>Learned times</th><th title="This field doesn\'t say if this %s is currently listed, but it says if this %s has listed now!">Listed Now</th></tr>'."\n", strtoupper($key),strtoupper($key),$key,$key); |
| 93 | 105 | |
| 94 | 106 | $values = array_keys($vet["$key"]); |
| 95 | 107 | |
| 96 | 108 | foreach ( $values as $value ) { |
| 97 | - if ( $value == 'count' ) continue; |
|
| 109 | + if ( $value == 'count' ) { |
|
| 110 | + continue; |
|
| 111 | + } |
|
| 98 | 112 | $nlearn = $vet["$key"]["$value"]['count']; |
| 99 | 113 | unset($vet["$key"]["$value"]['count']); |
| 100 | 114 | $quantity = $cf["listing$key"]['quantity']["$category"]; /* In searchAndList this value is |
@@ -106,10 +120,12 @@ discard block |
||
| 106 | 120 | 'The %s <%s> has been listed because was marked %u times as %s by %u different accounts during last %u days.', |
| 107 | 121 | strtoupper($key),$value,$nlearn,$category,$nuid,$cf['imap']['oldestday']); |
| 108 | 122 | $listed = searchAndList ($myconn,$cf['syslog']['user'],$tables,$cf["listing$key"]['list']["$category"],$value,$cf["listing$key"]['unit']["$category"],$quantity,$reason); |
| 123 | + } else { |
|
| 124 | + $listed = FALSE; |
|
| 109 | 125 | } |
| 110 | - else $listed = FALSE; |
|
| 126 | + } else { |
|
| 127 | + $listed = FALSE; |
|
| 111 | 128 | } |
| 112 | - else $listed = FALSE; |
|
| 113 | 129 | $nowlist = array( TRUE => array( |
| 114 | 130 | 'style' => 'id=\'ipfound\'', |
| 115 | 131 | 'name' => 'YES', |
@@ -127,7 +143,9 @@ discard block |
||
| 127 | 143 | $return .='<tr><td rowspan="'.$nuid.'">'.$value.'</td>'; |
| 128 | 144 | $return .= sprintf ('<td>%s</td><td rowspan="'.$nuid.'">%u</td><td rowspan="'.$nuid.'" '.$nowlist["$listed"]['style'].'>%s</td></tr>',$vet["$key"]["$value"][0],$nlearn,$nowlist["$listed"]['name']); |
| 129 | 145 | $rowuid=NULL; |
| 130 | - for ($j=1;$j<$nuid;$j++) $rowuid .= '<tr><td>%s</td></tr>'; |
|
| 146 | + for ($j=1;$j<$nuid;$j++) { |
|
| 147 | + $rowuid .= '<tr><td>%s</td></tr>'; |
|
| 148 | + } |
|
| 131 | 149 | array_shift($vet["$key"]["$value"]); |
| 132 | 150 | $return .= vsprintf ($rowuid,$vet["$key"]["$value"]); |
| 133 | 151 | |
@@ -140,14 +158,18 @@ discard block |
||
| 140 | 158 | $return .= sprintf('<h3>Statistics by UID</h3><table><tr><th>UID</th><th>%s learned</th><th>Learned times</th></tr>'."\n",$key); |
| 141 | 159 | $uids = array_keys($vet['uid']); |
| 142 | 160 | foreach ( $uids as $uid ) { |
| 143 | - if ( $uid == 'count' ) continue; |
|
| 161 | + if ( $uid == 'count' ) { |
|
| 162 | + continue; |
|
| 163 | + } |
|
| 144 | 164 | $nlearn = $vet['uid']["$uid"]['count']; |
| 145 | 165 | unset ( $vet['uid']["$uid"]['count'] ); |
| 146 | 166 | $nip = count($vet['uid']["$uid"]); |
| 147 | 167 | $return .='<tr><td rowspan="'.$nip.'">'.$uid.'</td>'; |
| 148 | 168 | $return .= sprintf ('<td>%s</td><td rowspan="'.$nip.'">%u</td></tr>',$vet['uid']["$uid"][0],$nlearn); |
| 149 | 169 | $rowuid=NULL; |
| 150 | - for ($j=1;$j<$nip;$j++) $rowuid .= '<tr><td>%s</td></tr>'; |
|
| 170 | + for ($j=1;$j<$nip;$j++) { |
|
| 171 | + $rowuid .= '<tr><td>%s</td></tr>'; |
|
| 172 | + } |
|
| 151 | 173 | array_shift($vet['uid']["$uid"]); |
| 152 | 174 | $return .= vsprintf ($rowuid,$vet['uid']["$uid"]); |
| 153 | 175 | |
@@ -197,14 +219,14 @@ discard block |
||
| 197 | 219 | { |
| 198 | 220 | // More than one field attribute returned by search |
| 199 | 221 | // You must redefine the search |
| 200 | - if ( count($result->getFieldNames()) > 1 ) return FALSE; |
|
| 201 | - } |
|
| 202 | - else if ($result instanceof Splunk_ResultsMessage) |
|
| 222 | + if ( count($result->getFieldNames()) > 1 ) { |
|
| 223 | + return FALSE; |
|
| 224 | + } |
|
| 225 | + } else if ($result instanceof Splunk_ResultsMessage) |
|
| 203 | 226 | { |
| 204 | 227 | // I don't want messages in my search |
| 205 | 228 | return FALSE; |
| 206 | - } |
|
| 207 | - else if (is_array($result)) |
|
| 229 | + } else if (is_array($result)) |
|
| 208 | 230 | { |
| 209 | 231 | // Process a row |
| 210 | 232 | foreach ($result as $key => $valueOrValues) |
@@ -212,15 +234,13 @@ discard block |
||
| 212 | 234 | if (is_array($valueOrValues)) |
| 213 | 235 | { |
| 214 | 236 | return FALSE; |
| 215 | - } |
|
| 216 | - else |
|
| 237 | + } else |
|
| 217 | 238 | { |
| 218 | 239 | return $valueOrValues; |
| 219 | 240 | #print " {$key} => {$value}\r\n"; |
| 220 | 241 | } |
| 221 | 242 | } |
| 222 | - } |
|
| 223 | - else |
|
| 243 | + } else |
|
| 224 | 244 | { |
| 225 | 245 | #print "Unknow result type"; |
| 226 | 246 | return FALSE; |
@@ -240,11 +260,9 @@ discard block |
||
| 240 | 260 | if(isset($part->parts)) { |
| 241 | 261 | if($part->type == 2) { |
| 242 | 262 | $flattenedParts = flattenParts($part->parts, $flattenedParts, $prefix.$index.'.', 0, false); |
| 243 | - } |
|
| 244 | - elseif($fullPrefix) { |
|
| 263 | + } elseif($fullPrefix) { |
|
| 245 | 264 | $flattenedParts = flattenParts($part->parts, $flattenedParts, $prefix.$index.'.'); |
| 246 | - } |
|
| 247 | - else { |
|
| 265 | + } else { |
|
| 248 | 266 | $flattenedParts = flattenParts($part->parts, $flattenedParts, $prefix); |
| 249 | 267 | } |
| 250 | 268 | unset($flattenedParts[$prefix.$index]->parts); |
@@ -277,8 +295,9 @@ discard block |
||
| 277 | 295 | $ret = array(); |
| 278 | 296 | $num_found = preg_match_all($pattern, $text, $out); |
| 279 | 297 | if ( ($num_found !== FALSE) && ($num_found>0) ) { |
| 280 | - foreach ($out[0] as $url) |
|
| 281 | - $ret[] = parse_url($url, PHP_URL_HOST); |
|
| 298 | + foreach ($out[0] as $url) { |
|
| 299 | + $ret[] = parse_url($url, PHP_URL_HOST); |
|
| 300 | + } |
|
| 282 | 301 | } |
| 283 | 302 | return array_values(array_unique($ret)); |
| 284 | 303 | } |
@@ -315,12 +334,13 @@ discard block |
||
| 315 | 334 | } |
| 316 | 335 | |
| 317 | 336 | } |
| 337 | + } else { |
|
| 338 | + $message = getPart($connection, $messageNumber, 1, $structure->encoding); |
|
| 318 | 339 | } |
| 319 | - else |
|
| 320 | - $message = getPart($connection, $messageNumber, 1, $structure->encoding); |
|
| 321 | 340 | |
| 322 | - if ( !empty($message) ) |
|
| 323 | - return getDomains($message); |
|
| 341 | + if ( !empty($message) ) { |
|
| 342 | + return getDomains($message); |
|
| 343 | + } |
|
| 324 | 344 | return array(); |
| 325 | 345 | } |
| 326 | 346 | |
@@ -355,7 +375,9 @@ discard block |
||
| 355 | 375 | $fileb= dirname(__FILE__) . '/' . $cf['report']['badreportFile']["$type"]; |
| 356 | 376 | $m_mail = imap_open('{'.$cf['imap']['mailhost'].':143/imap/novalidate-cert/authuser='.$cf['imap']['authuser'].'}'.$cf['imap']['folder']["$type"], $cf['imap']['account'],$cf['imap']['authpassword'], OP_READONLY) |
| 357 | 377 | or syslog (LOG_EMERG, $cf['syslog']['user'].': Error in IMAP connection to <'.$cf['imap']['mailhost'].'>: ' . imap_last_error()); |
| 358 | - if ( !$m_mail ) exit(254); |
|
| 378 | + if ( !$m_mail ) { |
|
| 379 | + exit(254); |
|
| 380 | + } |
|
| 359 | 381 | |
| 360 | 382 | |
| 361 | 383 | syslog (LOG_INFO,$cf['syslog']['user'].': Successfully connected to <'.$cf['imap']['mailhost'].">; Reading $type messages of last ".$cf['imap']['oldestday'].' days...'); |
@@ -367,21 +389,31 @@ discard block |
||
| 367 | 389 | // Order results starting from newest message |
| 368 | 390 | if ( empty($m_search) ) { |
| 369 | 391 | syslog (LOG_INFO,$cf['syslog']['user'].": No mail found in $type folder. No reports written for $type."); |
| 370 | - if ( $ierr = imap_errors() ) |
|
| 371 | - foreach ( $ierr as $thiserr ) |
|
| 392 | + if ( $ierr = imap_errors() ) { |
|
| 393 | + foreach ( $ierr as $thiserr ) |
|
| 372 | 394 | syslog (LOG_ERR, $cf['syslog']['user'].": IMAP Error: $thiserr"); |
| 373 | - if ( $ierr = imap_alerts() ) |
|
| 374 | - foreach ( $ierr as $thiserr ) |
|
| 395 | + } |
|
| 396 | + if ( $ierr = imap_alerts() ) { |
|
| 397 | + foreach ( $ierr as $thiserr ) |
|
| 375 | 398 | syslog (LOG_ALERT, $cf['syslog']['user'].": IMAP Alert: $thiserr"); |
| 399 | + } |
|
| 376 | 400 | imap_close( $m_mail ); |
| 377 | - if ( file_exists( $file ) ) unlink ($file); |
|
| 378 | - if ( file_exists( $filed ) ) unlink ($filed); |
|
| 379 | - if ( file_exists( $fileb ) ) unlink ($fileb); |
|
| 401 | + if ( file_exists( $file ) ) { |
|
| 402 | + unlink ($file); |
|
| 403 | + } |
|
| 404 | + if ( file_exists( $filed ) ) { |
|
| 405 | + unlink ($filed); |
|
| 406 | + } |
|
| 407 | + if ( file_exists( $fileb ) ) { |
|
| 408 | + unlink ($fileb); |
|
| 409 | + } |
|
| 380 | 410 | return FALSE; |
| 381 | 411 | } |
| 382 | 412 | $nmes = count ($m_search); |
| 383 | 413 | syslog (LOG_INFO,$cf['syslog']['user'].": Found $nmes mail in $type folder."); |
| 384 | - if ($nmes>0) rsort($m_search); |
|
| 414 | + if ($nmes>0) { |
|
| 415 | + rsort($m_search); |
|
| 416 | + } |
|
| 385 | 417 | |
| 386 | 418 | // Create report file |
| 387 | 419 | |
@@ -445,10 +477,11 @@ discard block |
||
| 445 | 477 | |
| 446 | 478 | if (in_array($uid,array_keys($ipuid['uid']))) { |
| 447 | 479 | $ipuid['uid']["$uid"]['count']++; //number of learn by this uid |
| 448 | - if (!in_array($ip,$ipuid['uid']["$uid"])) |
|
| 449 | - $ipuid['uid']["$uid"][]=$ip; //ips learned by this uid |
|
| 450 | - } |
|
| 451 | - else { |
|
| 480 | + if (!in_array($ip,$ipuid['uid']["$uid"])) { |
|
| 481 | + $ipuid['uid']["$uid"][]=$ip; |
|
| 482 | + } |
|
| 483 | + //ips learned by this uid |
|
| 484 | + } else { |
|
| 452 | 485 | $ipuid['uid']["$uid"]['count'] = 1; |
| 453 | 486 | $ipuid['uid']["$uid"][]=$ip; |
| 454 | 487 | $ipuid['uid']['count']++; //number of unique uids |
@@ -456,10 +489,11 @@ discard block |
||
| 456 | 489 | |
| 457 | 490 | if (in_array($ip,array_keys($ipuid['ip']))) { |
| 458 | 491 | $ipuid['ip']["$ip"]['count']++; //number of time this ip appears in different messages |
| 459 | - if (!in_array($uid,$ipuid['ip']["$ip"])) |
|
| 460 | - $ipuid['ip']["$ip"][]=$uid; //uids that learned this ip |
|
| 461 | - } |
|
| 462 | - else { |
|
| 492 | + if (!in_array($uid,$ipuid['ip']["$ip"])) { |
|
| 493 | + $ipuid['ip']["$ip"][]=$uid; |
|
| 494 | + } |
|
| 495 | + //uids that learned this ip |
|
| 496 | + } else { |
|
| 463 | 497 | $ipuid['ip']["$ip"]['count'] = 1; |
| 464 | 498 | $ipuid['ip']["$ip"][]=$uid; |
| 465 | 499 | $ipuid['ip']['count']++; //number of unique ips |
@@ -469,10 +503,11 @@ discard block |
||
| 469 | 503 | $domuid['count']++; |
| 470 | 504 | if (in_array($uid,array_keys($domuid['uid']))) { |
| 471 | 505 | $domuid['uid']["$uid"]['count']++; //number of learn by this uid |
| 472 | - if (!in_array($dom,$domuid['uid']["$uid"])) |
|
| 473 | - $domuid['uid']["$uid"][]=$dom; //domains learned by this uid |
|
| 474 | - } |
|
| 475 | - else { |
|
| 506 | + if (!in_array($dom,$domuid['uid']["$uid"])) { |
|
| 507 | + $domuid['uid']["$uid"][]=$dom; |
|
| 508 | + } |
|
| 509 | + //domains learned by this uid |
|
| 510 | + } else { |
|
| 476 | 511 | $domuid['uid']["$uid"]['count'] = 1; |
| 477 | 512 | $domuid['uid']["$uid"][]=$dom; |
| 478 | 513 | $domuid['uid']['count']++; //number of unique uids |
@@ -480,10 +515,11 @@ discard block |
||
| 480 | 515 | |
| 481 | 516 | if (in_array($dom,array_keys($domuid['dom']))) { |
| 482 | 517 | $domuid['dom']["$dom"]['count']++; //number of learn with this domain |
| 483 | - if (!in_array($uid,$domuid['dom']["$dom"])) |
|
| 484 | - $domuid['dom']["$dom"][]=$uid; //uids that learned this domain |
|
| 485 | - } |
|
| 486 | - else { |
|
| 518 | + if (!in_array($uid,$domuid['dom']["$dom"])) { |
|
| 519 | + $domuid['dom']["$dom"][]=$uid; |
|
| 520 | + } |
|
| 521 | + //uids that learned this domain |
|
| 522 | + } else { |
|
| 487 | 523 | $domuid['dom']["$dom"]['count'] = 1; |
| 488 | 524 | $domuid['dom']["$dom"][]=$uid; |
| 489 | 525 | $domuid['dom']['count']++; //number of unique domains |
@@ -500,21 +536,30 @@ discard block |
||
| 500 | 536 | |
| 501 | 537 | /* Update HTML report */ |
| 502 | 538 | fwrite($fp,updateReport ( $ip,$uid,$ipuid['ip']["$ip"]['count'],$ipuid['uid']["$uid"]['count'],$host,$dateClient,$mid,$dateReceived) ); |
| 503 | - } |
|
| 504 | - else { /* Bad learn */ |
|
| 539 | + } else { /* Bad learn */ |
|
| 505 | 540 | |
| 506 | - if (in_array($uid,array_keys($uidbad['uid']))) |
|
| 507 | - $uidbad['uid']["$uid"]['count']++; //number of bad learn by this uid |
|
| 541 | + if (in_array($uid,array_keys($uidbad['uid']))) { |
|
| 542 | + $uidbad['uid']["$uid"]['count']++; |
|
| 543 | + } |
|
| 544 | + //number of bad learn by this uid |
|
| 508 | 545 | else { |
| 509 | 546 | $uidbad['uid']["$uid"]['count'] = 1; |
| 510 | 547 | $uidbad['uid']["$uid"][]=$uid; |
| 511 | 548 | $uidbad['count']++; //numeber of unique bad uids |
| 512 | 549 | } |
| 513 | 550 | /* The reason of bad report */ |
| 514 | - if ($host === FALSE) $reason = 'This mail was not received by recognized MX host'; |
|
| 515 | - if ($dateReceived === FALSE) $reason = 'This mail was not submitted to recognized MSA for learn'; |
|
| 516 | - if ($uid=='unknown') $reason = 'The uid of this mail was not found in splunk log'; |
|
| 517 | - if (!isset($reason)) $reason = '?'; |
|
| 551 | + if ($host === FALSE) { |
|
| 552 | + $reason = 'This mail was not received by recognized MX host'; |
|
| 553 | + } |
|
| 554 | + if ($dateReceived === FALSE) { |
|
| 555 | + $reason = 'This mail was not submitted to recognized MSA for learn'; |
|
| 556 | + } |
|
| 557 | + if ($uid=='unknown') { |
|
| 558 | + $reason = 'The uid of this mail was not found in splunk log'; |
|
| 559 | + } |
|
| 560 | + if (!isset($reason)) { |
|
| 561 | + $reason = '?'; |
|
| 562 | + } |
|
| 518 | 563 | |
| 519 | 564 | fwrite( $fpb,updatebadReport ( $uid,$dateClient,$mid,$dateReceived,$reason ) ); |
| 520 | 565 | } |
@@ -536,9 +581,9 @@ discard block |
||
| 536 | 581 | fwrite($fpd, '<hr><h2>Summary Report</h2><h5>Listing policy: domains must be learned at least '.$cf['listingdom']['threshold']["$type"].' times from at least '.$cf['listingdom']['thresholduid']["$type"].' different valid uids.</h5>' ); |
| 537 | 582 | |
| 538 | 583 | /* Make MYSQL connection */ |
| 539 | - if ( $cf['listingip']['onlyReport']["$type"] && $cf['listingdom']['onlyReport']["$type"] ) |
|
| 540 | - $mysqli = NULL; |
|
| 541 | - else { |
|
| 584 | + if ( $cf['listingip']['onlyReport']["$type"] && $cf['listingdom']['onlyReport']["$type"] ) { |
|
| 585 | + $mysqli = NULL; |
|
| 586 | + } else { |
|
| 542 | 587 | $mysqli = new mysqli($myconnArray['dbhost'], $myconnArray['userdb'], $myconnArray['pwd'], $myconnArray['db'], $myconnArray['dbport']); |
| 543 | 588 | if ($mysqli->connect_error) { |
| 544 | 589 | syslog (LOG_EMERG, $cf['syslog']['user'].': Connect Error (' . $mysqli->connect_errno . ') ' |
@@ -557,8 +602,9 @@ discard block |
||
| 557 | 602 | fwrite($fpd,file_get_contents(dirname(__FILE__) . '/' . $cf['report']['reportTemplateFooter'])); |
| 558 | 603 | fclose($fpd); |
| 559 | 604 | |
| 560 | - if ( !($cf['listingip']['onlyReport']["$type"] && $cf['listingdom']['onlyReport']["$type"]) ) |
|
| 561 | - $mysqli->close(); |
|
| 605 | + if ( !($cf['listingip']['onlyReport']["$type"] && $cf['listingdom']['onlyReport']["$type"]) ) { |
|
| 606 | + $mysqli->close(); |
|
| 607 | + } |
|
| 562 | 608 | |
| 563 | 609 | fwrite($fpb, '</table>'); |
| 564 | 610 | fwrite( $fpb,summaryBadReport( $uidbad ) ); |
@@ -566,12 +612,14 @@ discard block |
||
| 566 | 612 | fclose($fpb); |
| 567 | 613 | syslog (LOG_INFO,$cf['syslog']['user'].': Report files written. Listing job for '.$type.' terminated.'); |
| 568 | 614 | |
| 569 | - if ( $ierr = imap_errors() ) |
|
| 570 | - foreach ( $ierr as $thiserr ) |
|
| 615 | + if ( $ierr = imap_errors() ) { |
|
| 616 | + foreach ( $ierr as $thiserr ) |
|
| 571 | 617 | syslog (LOG_ERR, $cf['syslog']['user'].": IMAP Error: $thiserr"); |
| 572 | - if ( $ierr = imap_alerts() ) |
|
| 573 | - foreach ( $ierr as $thiserr ) |
|
| 618 | + } |
|
| 619 | + if ( $ierr = imap_alerts() ) { |
|
| 620 | + foreach ( $ierr as $thiserr ) |
|
| 574 | 621 | syslog (LOG_ALERT, $cf['syslog']['user'].": IMAP Alert: $thiserr"); |
| 622 | + } |
|
| 575 | 623 | imap_close($m_mail); |
| 576 | 624 | } |
| 577 | 625 | ?> |
@@ -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, TRUE, INI_SCANNER_TYPED); |
@@ -35,50 +35,50 @@ discard block |
||
| 35 | 35 | |
| 36 | 36 | /* check you select a right list */ |
| 37 | 37 | if ( !$tables[$conf['listingip']['list']['spam']]['bl'] ) { |
| 38 | - syslog(LOG_EMERG, $conf['syslog']['user'].': <'.$conf['listingip']['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['syslog']['user'].': <'.$conf['listingip']['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['listingip']['list']['spam']]['active'] ) { |
| 42 | 42 | syslog(LOG_EMERG, $conf['syslog']['user'].': <'.$conf['listingip']['list']['spam'].'> is not active. Please, activate it to continue with this process.'); |
| 43 | 43 | exit (254); |
| 44 | - } |
|
| 44 | + } |
|
| 45 | 45 | } |
| 46 | 46 | |
| 47 | 47 | if ( !$conf['listingip']['onlyReport']['ham'] ) { |
| 48 | 48 | if ( $tables[$conf['listingip']['list']['ham']]['bl'] ) { |
| 49 | - syslog(LOG_EMERG, $conf['syslog']['user'].': <'.$conf['listingip']['list']['ham'].'> is a blocklist. Are you stupid? Do you want to block a legitimate sender? I refuse to continue.'); |
|
| 50 | - exit (254); |
|
| 49 | + syslog(LOG_EMERG, $conf['syslog']['user'].': <'.$conf['listingip']['list']['ham'].'> is a blocklist. Are you stupid? Do you want to block a legitimate sender? I refuse to continue.'); |
|
| 50 | + exit (254); |
|
| 51 | 51 | } |
| 52 | - if ( !$tables[$conf['listingip']['list']['ham']]['active'] ) { |
|
| 53 | - syslog(LOG_EMERG, $conf['syslog']['user'].': <'.$conf['listingip']['list']['ham'].'> is not active. Please, activate it |
|
| 52 | + if ( !$tables[$conf['listingip']['list']['ham']]['active'] ) { |
|
| 53 | + syslog(LOG_EMERG, $conf['syslog']['user'].': <'.$conf['listingip']['list']['ham'].'> is not active. Please, activate it |
|
| 54 | 54 | to continue with this process.'); |
| 55 | - exit (254); |
|
| 56 | - } |
|
| 55 | + exit (254); |
|
| 56 | + } |
|
| 57 | 57 | } |
| 58 | 58 | |
| 59 | 59 | if ( !$conf['listingdom']['onlyReport']['spam'] ) { |
| 60 | 60 | |
| 61 | - /* check you select a right list */ |
|
| 62 | - if ( !$tables[$conf['listingdom']['list']['spam']]['bl'] ) { |
|
| 63 | - syslog(LOG_EMERG, $conf['syslog']['user'].': <'.$conf['listingdom']['list']['spam'].'> is not a blocklist. Are you stupid? Do you want to whitelist a spam domain? I refuse to continue.'); |
|
| 64 | - exit (254); |
|
| 65 | - } |
|
| 66 | - if ( !$tables[$conf['listingdom']['list']['spam']]['active'] ) { |
|
| 67 | - syslog(LOG_EMERG, $conf['syslog']['user'].': <'.$conf['listingdom']['list']['spam'].'> is not active. Please, activate it to continue with this process.'); |
|
| 68 | - exit (254); |
|
| 69 | - } |
|
| 61 | + /* check you select a right list */ |
|
| 62 | + if ( !$tables[$conf['listingdom']['list']['spam']]['bl'] ) { |
|
| 63 | + syslog(LOG_EMERG, $conf['syslog']['user'].': <'.$conf['listingdom']['list']['spam'].'> is not a blocklist. Are you stupid? Do you want to whitelist a spam domain? I refuse to continue.'); |
|
| 64 | + exit (254); |
|
| 65 | + } |
|
| 66 | + if ( !$tables[$conf['listingdom']['list']['spam']]['active'] ) { |
|
| 67 | + syslog(LOG_EMERG, $conf['syslog']['user'].': <'.$conf['listingdom']['list']['spam'].'> is not active. Please, activate it to continue with this process.'); |
|
| 68 | + exit (254); |
|
| 69 | + } |
|
| 70 | 70 | } |
| 71 | 71 | |
| 72 | 72 | if ( !$conf['listingdom']['onlyReport']['ham'] ) { |
| 73 | - if ( $tables[$conf['listingdom']['list']['ham']]['bl'] ) { |
|
| 74 | - syslog(LOG_EMERG, $conf['syslog']['user'].': <'.$conf['listingdom']['list']['ham'].'> is a blocklist. Are you stupid? Do you want to block a legitimate sender? I refuse to continue.'); |
|
| 75 | - exit (254); |
|
| 76 | - } |
|
| 77 | - if ( !$tables[$conf['listingdom']['list']['ham']]['active'] ) { |
|
| 78 | - syslog(LOG_EMERG, $conf['syslog']['user'].': <'.$conf['listingdom']['list']['ham'].'> is not active. Please, activate it |
|
| 73 | + if ( $tables[$conf['listingdom']['list']['ham']]['bl'] ) { |
|
| 74 | + syslog(LOG_EMERG, $conf['syslog']['user'].': <'.$conf['listingdom']['list']['ham'].'> is a blocklist. Are you stupid? Do you want to block a legitimate sender? I refuse to continue.'); |
|
| 75 | + exit (254); |
|
| 76 | + } |
|
| 77 | + if ( !$tables[$conf['listingdom']['list']['ham']]['active'] ) { |
|
| 78 | + syslog(LOG_EMERG, $conf['syslog']['user'].': <'.$conf['listingdom']['list']['ham'].'> is not active. Please, activate it |
|
| 79 | 79 | to continue with this process.'); |
| 80 | - exit (254); |
|
| 81 | - } |
|
| 80 | + exit (254); |
|
| 81 | + } |
|
| 82 | 82 | |
| 83 | 83 | } |
| 84 | 84 | /* End of check list */ |
@@ -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, TRUE, INI_SCANNER_TYPED); |
| 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['syslog']['user'].': This plugin isn\'t active.'); |
|
| 22 | +if (!$imapListActive) { |
|
| 23 | + syslog(LOG_INFO, $conf['syslog']['user'].': This plugin isn\'t active.'); |
|
| 24 | 24 | closelog(); |
| 25 | 25 | exit(255); |
| 26 | 26 | } |
@@ -31,50 +31,50 @@ discard block |
||
| 31 | 31 | $arr_tpl_data = array(date("Y-m-d", time())); |
| 32 | 32 | |
| 33 | 33 | /* Start of check list */ |
| 34 | -if ( !$conf['listingip']['onlyReport']['spam'] ) { |
|
| 34 | +if (!$conf['listingip']['onlyReport']['spam']) { |
|
| 35 | 35 | |
| 36 | 36 | /* check you select a right list */ |
| 37 | - if ( !$tables[$conf['listingip']['list']['spam']]['bl'] ) { |
|
| 37 | + if (!$tables[$conf['listingip']['list']['spam']]['bl']) { |
|
| 38 | 38 | syslog(LOG_EMERG, $conf['syslog']['user'].': <'.$conf['listingip']['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['listingip']['list']['spam']]['active'] ) { |
|
| 41 | + if (!$tables[$conf['listingip']['list']['spam']]['active']) { |
|
| 42 | 42 | syslog(LOG_EMERG, $conf['syslog']['user'].': <'.$conf['listingip']['list']['spam'].'> is not active. Please, activate it to continue with this process.'); |
| 43 | 43 | exit (254); |
| 44 | 44 | } |
| 45 | 45 | } |
| 46 | 46 | |
| 47 | -if ( !$conf['listingip']['onlyReport']['ham'] ) { |
|
| 48 | - if ( $tables[$conf['listingip']['list']['ham']]['bl'] ) { |
|
| 47 | +if (!$conf['listingip']['onlyReport']['ham']) { |
|
| 48 | + if ($tables[$conf['listingip']['list']['ham']]['bl']) { |
|
| 49 | 49 | syslog(LOG_EMERG, $conf['syslog']['user'].': <'.$conf['listingip']['list']['ham'].'> is a blocklist. Are you stupid? Do you want to block a legitimate sender? I refuse to continue.'); |
| 50 | 50 | exit (254); |
| 51 | 51 | } |
| 52 | - if ( !$tables[$conf['listingip']['list']['ham']]['active'] ) { |
|
| 52 | + if (!$tables[$conf['listingip']['list']['ham']]['active']) { |
|
| 53 | 53 | syslog(LOG_EMERG, $conf['syslog']['user'].': <'.$conf['listingip']['list']['ham'].'> is not active. Please, activate it |
| 54 | 54 | to continue with this process.'); |
| 55 | 55 | exit (254); |
| 56 | 56 | } |
| 57 | 57 | } |
| 58 | 58 | |
| 59 | -if ( !$conf['listingdom']['onlyReport']['spam'] ) { |
|
| 59 | +if (!$conf['listingdom']['onlyReport']['spam']) { |
|
| 60 | 60 | |
| 61 | 61 | /* check you select a right list */ |
| 62 | - if ( !$tables[$conf['listingdom']['list']['spam']]['bl'] ) { |
|
| 62 | + if (!$tables[$conf['listingdom']['list']['spam']]['bl']) { |
|
| 63 | 63 | syslog(LOG_EMERG, $conf['syslog']['user'].': <'.$conf['listingdom']['list']['spam'].'> is not a blocklist. Are you stupid? Do you want to whitelist a spam domain? I refuse to continue.'); |
| 64 | 64 | exit (254); |
| 65 | 65 | } |
| 66 | - if ( !$tables[$conf['listingdom']['list']['spam']]['active'] ) { |
|
| 66 | + if (!$tables[$conf['listingdom']['list']['spam']]['active']) { |
|
| 67 | 67 | syslog(LOG_EMERG, $conf['syslog']['user'].': <'.$conf['listingdom']['list']['spam'].'> is not active. Please, activate it to continue with this process.'); |
| 68 | 68 | exit (254); |
| 69 | 69 | } |
| 70 | 70 | } |
| 71 | 71 | |
| 72 | -if ( !$conf['listingdom']['onlyReport']['ham'] ) { |
|
| 73 | - if ( $tables[$conf['listingdom']['list']['ham']]['bl'] ) { |
|
| 72 | +if (!$conf['listingdom']['onlyReport']['ham']) { |
|
| 73 | + if ($tables[$conf['listingdom']['list']['ham']]['bl']) { |
|
| 74 | 74 | syslog(LOG_EMERG, $conf['syslog']['user'].': <'.$conf['listingdom']['list']['ham'].'> is a blocklist. Are you stupid? Do you want to block a legitimate sender? I refuse to continue.'); |
| 75 | 75 | exit (254); |
| 76 | 76 | } |
| 77 | - if ( !$tables[$conf['listingdom']['list']['ham']]['active'] ) { |
|
| 77 | + if (!$tables[$conf['listingdom']['list']['ham']]['active']) { |
|
| 78 | 78 | syslog(LOG_EMERG, $conf['syslog']['user'].': <'.$conf['listingdom']['list']['ham'].'> is not active. Please, activate it |
| 79 | 79 | to continue with this process.'); |
| 80 | 80 | exit (254); |
@@ -84,7 +84,7 @@ discard block |
||
| 84 | 84 | /* End of check list */ |
| 85 | 85 | |
| 86 | 86 | /* Make MYSQL connection Array */ |
| 87 | -$mysqlconf= array( |
|
| 87 | +$mysqlconf = array( |
|
| 88 | 88 | 'dbhost' => $dbhost, |
| 89 | 89 | 'userdb' => $userdb, |
| 90 | 90 | 'pwd' => $pwd, |
@@ -101,14 +101,14 @@ discard block |
||
| 101 | 101 | |
| 102 | 102 | |
| 103 | 103 | /* The hard work has hidden in imapReport */ |
| 104 | -$learnfromArray = array('ham','spam'); |
|
| 105 | -foreach ( $learnfromArray as $learnfrom ) { |
|
| 104 | +$learnfromArray = array('ham', 'spam'); |
|
| 105 | +foreach ($learnfromArray as $learnfrom) { |
|
| 106 | 106 | $conf['report']['reportFile']["$learnfrom"] = str_replace($arr_tpl_vars, $arr_tpl_data, $conf['report']['reportFile']["$learnfrom"]); |
| 107 | 107 | $conf['report']['badreportFile']["$learnfrom"] = str_replace($arr_tpl_vars, $arr_tpl_data, $conf['report']['badreportFile']["$learnfrom"]); |
| 108 | 108 | $conf['report']['reportDomFile']["$learnfrom"] = str_replace($arr_tpl_vars, $arr_tpl_data, $conf['report']['reportDomFile']["$learnfrom"]); |
| 109 | - imapReport ($conf,$mysqlconf,$splservice,$tables,$learnfrom); |
|
| 109 | + imapReport($conf, $mysqlconf, $splservice, $tables, $learnfrom); |
|
| 110 | 110 | } |
| 111 | 111 | |
| 112 | -syslog (LOG_INFO, $conf['syslog']['user'].': End of session.'); |
|
| 112 | +syslog(LOG_INFO, $conf['syslog']['user'].': End of session.'); |
|
| 113 | 113 | closelog(); |
| 114 | 114 | ?> |