@@ -10,7 +10,7 @@ discard block |
||
10 | 10 | exit ('<pre><'.$_POST['Value'].'> is NOT a valid email address.</pre>'); |
11 | 11 | |
12 | 12 | if ( ($tables["$_"]['field']=='domain') AND ($_POST['Value']!='ALL') ) |
13 | - if (!(filter_var(gethostbyname($_POST['Value']), FILTER_VALIDATE_IP))) |
|
13 | + if (!(filter_var(gethostbyname($_POST['Value']), FILTER_VALIDATE_IP))) |
|
14 | 14 | exit ('<pre><'.$_POST['Value'].'> is NOT a valid domain.</pre>'); |
15 | 15 | |
16 | 16 | if ( ($tables["$_"]['field']=='ip') AND ($_POST['Value']!='ALL') ) |
@@ -26,8 +26,8 @@ discard block |
||
26 | 26 | } |
27 | 27 | |
28 | 28 | if ( ($tables["$_"]['field']=='username') AND ($_POST['Value']!='ALL') ) { |
29 | - if ( preg_match( '/[^\x20-\x7f]/', $_POST['Value']) ) |
|
30 | - exit('<pre><'.$_POST['Value'].'> contains NON ASCII chars.</pre>'); |
|
29 | + if ( preg_match( '/[^\x20-\x7f]/', $_POST['Value']) ) |
|
30 | + exit('<pre><'.$_POST['Value'].'> contains NON ASCII chars.</pre>'); |
|
31 | 31 | if ( preg_match( '/[$~=#*+%,{}()\/\\<>;:\"`\[\]&?\s]/', $_POST['Value']) ) |
32 | 32 | exit('<pre><'.$_POST['Value'].'> contains invalid ASCII chars.</pre>'); |
33 | 33 | switch ( $_POST['Value'] ) { |
@@ -49,10 +49,10 @@ discard block |
||
49 | 49 | |
50 | 50 | $mysqli = new mysqli($dbhost, $userdb, $pwd, $db, $dbport); |
51 | 51 | if ($mysqli->connect_error) { |
52 | - syslog (LOG_EMERG, $user.': Connect Error (' . $mysqli->connect_errno . ') ' |
|
53 | - . $mysqli->connect_error); |
|
54 | - exit ($user.': Connect Error (' . $mysqli->connect_errno . ') ' |
|
55 | - . $mysqli->connect_error); |
|
52 | + syslog (LOG_EMERG, $user.': Connect Error (' . $mysqli->connect_errno . ') ' |
|
53 | + . $mysqli->connect_error); |
|
54 | + exit ($user.': Connect Error (' . $mysqli->connect_errno . ') ' |
|
55 | + . $mysqli->connect_error); |
|
56 | 56 | } |
57 | 57 | |
58 | 58 | syslog(LOG_INFO, $user.': Successfully mysql connected to ' . $mysqli->host_info) ; |
@@ -4,8 +4,8 @@ discard block |
||
4 | 4 | |
5 | 5 | function username() { |
6 | 6 | if (isset ($_SERVER['REMOTE_USER'])) $user = $_SERVER['REMOTE_USER']; |
7 | - else if (isset ($_SERVER['USER'])) $user = $_SERVER['USER']; |
|
8 | - else $user='unknown'; |
|
7 | + else if (isset ($_SERVER['USER'])) $user = $_SERVER['USER']; |
|
8 | + else $user='unknown'; |
|
9 | 9 | return $user; |
10 | 10 | } |
11 | 11 | |
@@ -34,7 +34,7 @@ discard block |
||
34 | 34 | |
35 | 35 | case 'network': |
36 | 36 | list($sub['net'],$sub['mask'])=explode('/',$value); |
37 | - $query= sprintf("INSERT INTO `$table` ( |
|
37 | + $query= sprintf("INSERT INTO `$table` ( |
|
38 | 38 | `$type` , |
39 | 39 | `netmask`, |
40 | 40 | `date` , |
@@ -47,10 +47,10 @@ discard block |
||
47 | 47 | INET_ATON( '%s' ) , INET_ATON( '%s' ) , |
48 | 48 | CURRENT_TIMESTAMP , TIMESTAMPADD(%s,%d,CURRENT_TIMESTAMP), '1', '%s', '%s' |
49 | 49 | )" ,$sub['net'],$sub['mask'],$expUnit,$expQ,$user,$myreason); |
50 | - break; |
|
50 | + break; |
|
51 | 51 | |
52 | 52 | default: |
53 | - $query= sprintf("INSERT INTO `$table` ( |
|
53 | + $query= sprintf("INSERT INTO `$table` ( |
|
54 | 54 | `$type` , |
55 | 55 | `date` , |
56 | 56 | `exp` , |
@@ -65,8 +65,8 @@ discard block |
||
65 | 65 | } |
66 | 66 | |
67 | 67 | if ($myconn->query($query) === TRUE) { |
68 | - syslog(LOG_INFO, "$user: $type <$value> successfully listed on <$table> for $expQ $expUnit."); |
|
69 | - $result=TRUE; |
|
68 | + syslog(LOG_INFO, "$user: $type <$value> successfully listed on <$table> for $expQ $expUnit."); |
|
69 | + $result=TRUE; |
|
70 | 70 | } |
71 | 71 | else syslog(LOG_ERR, "$user: Error: ".$myconn->error); |
72 | 72 | return $result; |
@@ -76,9 +76,9 @@ discard block |
||
76 | 76 | |
77 | 77 | $result=FALSE; |
78 | 78 | |
79 | - switch ($type) { |
|
79 | + switch ($type) { |
|
80 | 80 | case 'ip': |
81 | - $query= sprintf("UPDATE `$table` SET |
|
81 | + $query= sprintf("UPDATE `$table` SET |
|
82 | 82 | `active` = '1', |
83 | 83 | `user` = '%s', |
84 | 84 | `exp` = TIMESTAMPADD(%s,%d,CURRENT_TIMESTAMP), |
@@ -86,9 +86,9 @@ discard block |
||
86 | 86 | `reason` = '%s' |
87 | 87 | WHERE `$table`.`$type` = INET_ATON('%s') LIMIT 1" ,$user,$expUnit,$expQ,$myreason,$value); |
88 | 88 | break; |
89 | - case 'network': |
|
89 | + case 'network': |
|
90 | 90 | list($sub['net'],$sub['mask'])=explode('/',$value); |
91 | - $query= sprintf("UPDATE `$table` SET |
|
91 | + $query= sprintf("UPDATE `$table` SET |
|
92 | 92 | `active` = '1', |
93 | 93 | `user` = '%s', |
94 | 94 | `exp` = TIMESTAMPADD(%s,%d,CURRENT_TIMESTAMP), |
@@ -97,7 +97,7 @@ discard block |
||
97 | 97 | WHERE (`$table`.`$type` = INET_ATON('%s') AND `$table`.`netmask` = INET_ATON('%s')) LIMIT 1" ,$user,$expUnit,$expQ,$myreason,$sub['net'],$sub['mask']); |
98 | 98 | break; |
99 | 99 | default: |
100 | - $query= sprintf("UPDATE `$table` SET |
|
100 | + $query= sprintf("UPDATE `$table` SET |
|
101 | 101 | `active` = '1', |
102 | 102 | `user` = '%s', |
103 | 103 | `exp` = TIMESTAMPADD(%s,%d,CURRENT_TIMESTAMP), |
@@ -106,19 +106,19 @@ discard block |
||
106 | 106 | WHERE `$table`.`$type` = '%s' LIMIT 1" ,$user,$expUnit,$expQ,$myreason,$value); |
107 | 107 | } |
108 | 108 | |
109 | - if ($myconn->query($query) === TRUE) { |
|
110 | - syslog(LOG_INFO, "$user: relist $type <$value> on <$table> for $expQ $expUnit."); |
|
109 | + if ($myconn->query($query) === TRUE) { |
|
110 | + syslog(LOG_INFO, "$user: relist $type <$value> on <$table> for $expQ $expUnit."); |
|
111 | 111 | $result=TRUE; |
112 | - } |
|
113 | - else syslog (LOG_ERR, "$user: Error: ". $myconn->error); |
|
112 | + } |
|
113 | + else syslog (LOG_ERR, "$user: Error: ". $myconn->error); |
|
114 | 114 | return $result; |
115 | 115 | } |
116 | 116 | |
117 | 117 | function remove ($myconn,$user,$value,$type,$table) { |
118 | - $result=FALSE; |
|
118 | + $result=FALSE; |
|
119 | 119 | |
120 | - switch ($type) { |
|
121 | - case 'ip': |
|
120 | + switch ($type) { |
|
121 | + case 'ip': |
|
122 | 122 | $query = sprintf("DELETE FROM `$table` WHERE |
123 | 123 | `$table`.`$type` = INET_ATON('%s') LIMIT 1", $value); |
124 | 124 | break; |
@@ -134,18 +134,18 @@ discard block |
||
134 | 134 | } |
135 | 135 | |
136 | 136 | |
137 | - if ($return=$myconn->query($query) === TRUE) |
|
138 | - syslog(LOG_INFO, "$user: permanently DELETED $type <$value> from <$table>."); |
|
139 | - else syslog(LOG_ERR, "$user: Error: ". $myconn->error); |
|
137 | + if ($return=$myconn->query($query) === TRUE) |
|
138 | + syslog(LOG_INFO, "$user: permanently DELETED $type <$value> from <$table>."); |
|
139 | + else syslog(LOG_ERR, "$user: Error: ". $myconn->error); |
|
140 | 140 | |
141 | - return $return; |
|
141 | + return $return; |
|
142 | 142 | } |
143 | 143 | |
144 | 144 | |
145 | 145 | function changestatus ($myconn,$user,$value,$status,$type,$table) { |
146 | 146 | |
147 | 147 | switch ($type) { |
148 | - case 'ip': |
|
148 | + case 'ip': |
|
149 | 149 | $query= sprintf("UPDATE `$table` SET `active` = '$status', `user` = '%s' WHERE `$table`.`$type` = INET_ATON('%s') LIMIT 1" ,$user, $value); |
150 | 150 | break; |
151 | 151 | case 'network': |
@@ -156,16 +156,16 @@ discard block |
||
156 | 156 | $query= sprintf("UPDATE `$table` SET `active` = '$status', `user` = '%s' WHERE `$table`.`$type` = '%s' LIMIT 1" ,$user, $value); |
157 | 157 | } |
158 | 158 | |
159 | - if ($return=$myconn->query($query) === TRUE) { |
|
160 | - syslog(LOG_INFO, "$user: change status of $type <$value>. The status is now <$status>"); |
|
161 | - } |
|
162 | - else syslog(LOG_ERR, "$user: Error: ". $myconn->error); |
|
159 | + if ($return=$myconn->query($query) === TRUE) { |
|
160 | + syslog(LOG_INFO, "$user: change status of $type <$value>. The status is now <$status>"); |
|
161 | + } |
|
162 | + else syslog(LOG_ERR, "$user: Error: ". $myconn->error); |
|
163 | 163 | return $return; |
164 | 164 | } |
165 | 165 | |
166 | 166 | |
167 | 167 | function expire ($myconn,$user,$tables,$expireTime) { |
168 | - $return=TRUE; |
|
168 | + $return=TRUE; |
|
169 | 169 | $desc = array_keys($tables); |
170 | 170 | foreach ($desc as $tdesc) { |
171 | 171 | /* QUERY */ |
@@ -174,11 +174,11 @@ discard block |
||
174 | 174 | /* END OF QUERY */ |
175 | 175 | $log[0] = 'expired for'; |
176 | 176 | $log[1] = 'disabled for'; |
177 | - if ($myconn->multi_query($query)) { |
|
177 | + if ($myconn->multi_query($query)) { |
|
178 | 178 | $j = 0; |
179 | 179 | do { |
180 | - $numdel = $myconn->affected_rows; |
|
181 | - syslog(LOG_INFO, "Expire job - <$user> Permanently DELETED $numdel records ".$log[$j]." $expireTime YEARS from <".$tables["$tdesc"]['name'].'>.'); |
|
180 | + $numdel = $myconn->affected_rows; |
|
181 | + syslog(LOG_INFO, "Expire job - <$user> Permanently DELETED $numdel records ".$log[$j]." $expireTime YEARS from <".$tables["$tdesc"]['name'].'>.'); |
|
182 | 182 | $j++; |
183 | 183 | |
184 | 184 | } while ($myconn->next_result()); |
@@ -190,7 +190,7 @@ discard block |
||
190 | 190 | } |
191 | 191 | if ( !($return) ) syslog(LOG_EMERG, 'End of Expire job with error. See above logs. SQL Connection terminated'); |
192 | 192 | else syslog(LOG_INFO, 'Successfully End of Expire job. SQL Connection successfully terminated.'); |
193 | - return $return; |
|
193 | + return $return; |
|
194 | 194 | } |
195 | 195 | |
196 | 196 | |
@@ -231,7 +231,7 @@ discard block |
||
231 | 231 | if ( $entry->num_rows ) { |
232 | 232 | if ( $entry->num_rows == 1 ) { |
233 | 233 | $riga = $entry->fetch_array(MYSQLI_ASSOC); |
234 | - if (isListed($riga)) { |
|
234 | + if (isListed($riga)) { |
|
235 | 235 | $warn = "<$value> is already present in <$listdep> list!"; |
236 | 236 | $entry->free(); |
237 | 237 | return FALSE; |
@@ -248,28 +248,28 @@ discard block |
||
248 | 248 | function searchentry ($myconn,$value,$tablelist) { |
249 | 249 | /* Make a MYSQL query and return result */ |
250 | 250 | |
251 | - $type = $tablelist['field']; |
|
252 | - $table = $tablelist['name']; |
|
253 | - |
|
254 | - if ($value == 'ALL') $query = 'select * from '.$table; |
|
255 | - else { |
|
256 | - switch ($type) { |
|
257 | - case 'ip': |
|
258 | - $query= "select * from $table where $type = INET_ATON('$value')"; |
|
259 | - break; |
|
260 | - case 'network': |
|
261 | - list($sub['net'],$sub['mask'])=explode('/',$value); |
|
262 | - $query= 'select * from '.$table.' where (((inet_aton(\''.$sub['net'].'\') | (~ inet_aton(\''.$sub['mask'].'\'))) & netmask) = network)'; |
|
263 | - break; |
|
264 | - default: |
|
265 | - $query= "select * from $table where $type = '$value'"; |
|
266 | - } |
|
267 | - } |
|
251 | + $type = $tablelist['field']; |
|
252 | + $table = $tablelist['name']; |
|
253 | + |
|
254 | + if ($value == 'ALL') $query = 'select * from '.$table; |
|
255 | + else { |
|
256 | + switch ($type) { |
|
257 | + case 'ip': |
|
258 | + $query= "select * from $table where $type = INET_ATON('$value')"; |
|
259 | + break; |
|
260 | + case 'network': |
|
261 | + list($sub['net'],$sub['mask'])=explode('/',$value); |
|
262 | + $query= 'select * from '.$table.' where (((inet_aton(\''.$sub['net'].'\') | (~ inet_aton(\''.$sub['mask'].'\'))) & netmask) = network)'; |
|
263 | + break; |
|
264 | + default: |
|
265 | + $query= "select * from $table where $type = '$value'"; |
|
266 | + } |
|
267 | + } |
|
268 | 268 | |
269 | 269 | $result = $myconn->query($query); |
270 | 270 | if($result === false) |
271 | 271 | syslog(LOG_EMERG, "ALERT: Query <$query> failed: ".$myconn->error); |
272 | - return $result; |
|
272 | + return $result; |
|
273 | 273 | } |
274 | 274 | |
275 | 275 | function countListed ($myconn,$table) { |
@@ -285,10 +285,10 @@ discard block |
||
285 | 285 | |
286 | 286 | |
287 | 287 | function isFull($myconn,$typedesc,$alltables) { |
288 | - if (isset($alltables["$typedesc"]['limit'])) { |
|
289 | - if ( countListed($myconn,$alltables["$typedesc"]['name']) >= $alltables["$typedesc"]['limit'] ) |
|
290 | - return TRUE; |
|
291 | - } |
|
288 | + if (isset($alltables["$typedesc"]['limit'])) { |
|
289 | + if ( countListed($myconn,$alltables["$typedesc"]['name']) >= $alltables["$typedesc"]['limit'] ) |
|
290 | + return TRUE; |
|
291 | + } |
|
292 | 292 | return FALSE; |
293 | 293 | } |
294 | 294 | |
@@ -301,14 +301,14 @@ discard block |
||
301 | 301 | if ($result) { |
302 | 302 | printf("<pre>Your request for $type <$value> returned %d items.\n</pre>", $result->num_rows); |
303 | 303 | |
304 | - /* Check for limit in number of listed items */ |
|
304 | + /* Check for limit in number of listed items */ |
|
305 | 305 | $full = isFull($myconn,$typedesc,$tables); |
306 | 306 | if ($full) print '<p>'.htmlspecialchars("$typedesc has reached maximum value of ".$tables["$typedesc"]['limit'].' listed items.').'</p>'; |
307 | 307 | |
308 | 308 | if ($result->num_rows) { |
309 | 309 | print '<table><thead><tr><th>'.$type.'</th><th title="The date this object has been listed for the first time">DateAdd</th><th>DateMod</th><th>Exp</th><th>Status</th><th title="Number of times this object has been listed">#List</th><th>Authored by</th><th width="250">Reason</th><th>Action</th></tr></thead><tfoot><tr></tr></tfoot><tbody>'."\n"; |
310 | 310 | $i=0; |
311 | - while ($riga = $result->fetch_array(MYSQLI_ASSOC)) { |
|
311 | + while ($riga = $result->fetch_array(MYSQLI_ASSOC)) { |
|
312 | 312 | if (isListed($riga)) { |
313 | 313 | if ($tables["$typedesc"]['bl']) $listed='Listed'; |
314 | 314 | else $listed='WhiteListed'; |
@@ -327,9 +327,9 @@ discard block |
||
327 | 327 | $element = $riga["$type"]; |
328 | 328 | } |
329 | 329 | |
330 | - printf ("<tr id=id$i><td id='status$listed'>%s</td><td id='status$listed'>%s</td><td id='status$listed'>%s</td><td id='status$listed'>%s</td><td id='status$listed'>%s</td><td id='status$listed'>%s</td><td id='status$listed'>%s</td><td id='status$listed'>%s</td><td>%s</td></tr>\n", $element, $riga['date'], $riga['datemod'], $riga['exp'], $riga['active'], $riga['nlist'], $riga['user'],htmlspecialchars($riga['reason']),ask($myconn,$i,$listed,$tables,$typedesc,$element,$full,$user,$adm)); |
|
330 | + printf ("<tr id=id$i><td id='status$listed'>%s</td><td id='status$listed'>%s</td><td id='status$listed'>%s</td><td id='status$listed'>%s</td><td id='status$listed'>%s</td><td id='status$listed'>%s</td><td id='status$listed'>%s</td><td id='status$listed'>%s</td><td>%s</td></tr>\n", $element, $riga['date'], $riga['datemod'], $riga['exp'], $riga['active'], $riga['nlist'], $riga['user'],htmlspecialchars($riga['reason']),ask($myconn,$i,$listed,$tables,$typedesc,$element,$full,$user,$adm)); |
|
331 | 331 | $i++; |
332 | - } |
|
332 | + } |
|
333 | 333 | print '</tbody></table>'; |
334 | 334 | } |
335 | 335 | else { |
@@ -347,15 +347,15 @@ discard block |
||
347 | 347 | |
348 | 348 | function sendEmailWarn($tplf,$from,$to,$sbj,$emailListed,$intervalToExpire,$detail) { |
349 | 349 | $now = time(); |
350 | - setlocale (LC_TIME, 'it_IT'); |
|
351 | - $date = date("r",$now); |
|
350 | + setlocale (LC_TIME, 'it_IT'); |
|
351 | + $date = date("r",$now); |
|
352 | 352 | $messageID = md5(uniqid($now,1)) . '@' . $_SERVER["HOSTNAME"]; |
353 | 353 | $mua = 'PHP/' . phpversion(); |
354 | 354 | |
355 | 355 | /* Parsing headers */ |
356 | 356 | if (!file_exists($tplf['header'])) { |
357 | - syslog(LOG_ERR, 'Sending email... template file <'.$tplf['header'].'> not found!'); |
|
358 | - exit; |
|
357 | + syslog(LOG_ERR, 'Sending email... template file <'.$tplf['header'].'> not found!'); |
|
358 | + exit; |
|
359 | 359 | } |
360 | 360 | |
361 | 361 | $head_tmpl = file_get_contents($tplf['header']); |
@@ -364,36 +364,36 @@ discard block |
||
364 | 364 | $headers = str_replace($arr_tpl_vars, $arr_tpl_data, $head_tmpl); |
365 | 365 | $headers = preg_replace( '/\r|\n/', "\r\n", $headers ); |
366 | 366 | |
367 | - /* Parsing body */ |
|
367 | + /* Parsing body */ |
|
368 | 368 | |
369 | - if (!file_exists($tplf['body'])) { |
|
370 | - syslog(LOG_ERR, 'Sending email... template file <'.$tplf['body'].'> not found!'); |
|
371 | - exit; |
|
372 | - } |
|
369 | + if (!file_exists($tplf['body'])) { |
|
370 | + syslog(LOG_ERR, 'Sending email... template file <'.$tplf['body'].'> not found!'); |
|
371 | + exit; |
|
372 | + } |
|
373 | 373 | |
374 | - $body_tmpl = file_get_contents($tplf['body']); |
|
375 | - $arr_tpl_vars = array('{emailListed}','{expInterval}','{reason}'); |
|
376 | - $arr_tpl_data = array($emailListed,$intervalToExpire,$detail); |
|
377 | - $body = str_replace($arr_tpl_vars, $arr_tpl_data, $body_tmpl); |
|
378 | - $body = preg_replace( "/\r|\n/", "\r\n", $body ); |
|
374 | + $body_tmpl = file_get_contents($tplf['body']); |
|
375 | + $arr_tpl_vars = array('{emailListed}','{expInterval}','{reason}'); |
|
376 | + $arr_tpl_data = array($emailListed,$intervalToExpire,$detail); |
|
377 | + $body = str_replace($arr_tpl_vars, $arr_tpl_data, $body_tmpl); |
|
378 | + $body = preg_replace( "/\r|\n/", "\r\n", $body ); |
|
379 | 379 | $body = wordwrap ( $body, 75 , "\r\n" ); |
380 | 380 | |
381 | 381 | /* Send the mail! */ |
382 | 382 | $params = NULL; |
383 | - if ( strlen(ini_get("safe_mode"))< 1) { |
|
384 | - $old_mailfrom = ini_get("sendmail_from"); |
|
385 | - ini_set("sendmail_from", $from); |
|
386 | - $params = sprintf("-oi -f %s", '<>'); |
|
387 | - if (!(mail($to,$sbj, $body,$headers,$params))) $flag=FALSE; |
|
388 | - else $flag=TRUE; |
|
389 | - if (isset($old_mailfrom)) |
|
390 | - ini_set("sendmail_from", $old_mailfrom); |
|
391 | - } |
|
392 | - else { |
|
393 | - if (!(mail($to,$sbj, $body,$headers))) $flag=FALSE; |
|
394 | - else $flag=TRUE; |
|
395 | - } |
|
396 | - return $flag; |
|
383 | + if ( strlen(ini_get("safe_mode"))< 1) { |
|
384 | + $old_mailfrom = ini_get("sendmail_from"); |
|
385 | + ini_set("sendmail_from", $from); |
|
386 | + $params = sprintf("-oi -f %s", '<>'); |
|
387 | + if (!(mail($to,$sbj, $body,$headers,$params))) $flag=FALSE; |
|
388 | + else $flag=TRUE; |
|
389 | + if (isset($old_mailfrom)) |
|
390 | + ini_set("sendmail_from", $old_mailfrom); |
|
391 | + } |
|
392 | + else { |
|
393 | + if (!(mail($to,$sbj, $body,$headers))) $flag=FALSE; |
|
394 | + else $flag=TRUE; |
|
395 | + } |
|
396 | + return $flag; |
|
397 | 397 | } |
398 | 398 | |
399 | 399 | function emailToNotify($notify_file,$dom) { |
@@ -407,59 +407,59 @@ discard block |
||
407 | 407 | function searchAndList ($myconn,$loguser,$tables,$typedesc,$value,$unit,&$quantity,$reason) { |
408 | 408 | |
409 | 409 | /* Search and list value */ |
410 | - $type = $tables["$typedesc"]['field']; |
|
411 | - $table = $tables["$typedesc"]['name']; |
|
412 | - $result = searchentry ($myconn,$value,$tables["$typedesc"]); |
|
413 | - |
|
414 | - /* Manage abnormal conditions */ |
|
415 | - /* Value already present in db more than once. This is absurd. Panic! */ |
|
416 | - if ($result->num_rows > 1) { |
|
417 | - syslog(LOG_EMERG,"$loguser: PANIC! Select for $type '$value' returned ". $result->num_rows ." items instead of one. Abnormal. Contact a sysadmin or a developer."); |
|
418 | - $result->free(); |
|
419 | - return FALSE; |
|
420 | - } |
|
421 | - |
|
422 | - /* Value already present in db or not present: to list anyway */ |
|
423 | - if ($result->num_rows >= 0) { |
|
424 | - /* First, check for limit in number of listed items */ |
|
425 | - if (isFull($myconn,$typedesc,$tables)) { |
|
426 | - syslog(LOG_EMERG,"$loguser: $typedesc has reached maximum value of ".$tables["$typedesc"]['limit'].' listed items. Abnormal exit.'); |
|
427 | - $result->free(); |
|
428 | - return FALSE; |
|
429 | - } |
|
430 | - /* Second, check if the (re)list would be consistent now */ |
|
431 | - if (! consistentListing($myconn,$tables,$typedesc,$value,$whynot) ) { |
|
432 | - syslog(LOG_ERR, $loguser.': '.$whynot); |
|
433 | - $result->free(); |
|
434 | - return FALSE; |
|
435 | - } |
|
436 | - } |
|
437 | - /* End of abnormal conditions */ |
|
438 | - |
|
439 | - |
|
440 | - /* Finally, here I can list the value! */ |
|
410 | + $type = $tables["$typedesc"]['field']; |
|
411 | + $table = $tables["$typedesc"]['name']; |
|
412 | + $result = searchentry ($myconn,$value,$tables["$typedesc"]); |
|
413 | + |
|
414 | + /* Manage abnormal conditions */ |
|
415 | + /* Value already present in db more than once. This is absurd. Panic! */ |
|
416 | + if ($result->num_rows > 1) { |
|
417 | + syslog(LOG_EMERG,"$loguser: PANIC! Select for $type '$value' returned ". $result->num_rows ." items instead of one. Abnormal. Contact a sysadmin or a developer."); |
|
418 | + $result->free(); |
|
419 | + return FALSE; |
|
420 | + } |
|
421 | + |
|
422 | + /* Value already present in db or not present: to list anyway */ |
|
423 | + if ($result->num_rows >= 0) { |
|
424 | + /* First, check for limit in number of listed items */ |
|
425 | + if (isFull($myconn,$typedesc,$tables)) { |
|
426 | + syslog(LOG_EMERG,"$loguser: $typedesc has reached maximum value of ".$tables["$typedesc"]['limit'].' listed items. Abnormal exit.'); |
|
427 | + $result->free(); |
|
428 | + return FALSE; |
|
429 | + } |
|
430 | + /* Second, check if the (re)list would be consistent now */ |
|
431 | + if (! consistentListing($myconn,$tables,$typedesc,$value,$whynot) ) { |
|
432 | + syslog(LOG_ERR, $loguser.': '.$whynot); |
|
433 | + $result->free(); |
|
434 | + return FALSE; |
|
435 | + } |
|
436 | + } |
|
437 | + /* End of abnormal conditions */ |
|
438 | + |
|
439 | + |
|
440 | + /* Finally, here I can list the value! */ |
|
441 | 441 | $thisentry = $result->fetch_array(MYSQLI_ASSOC); |
442 | - switch ($result->num_rows) { |
|
443 | - /* Relist value if already present */ |
|
444 | - case 1: |
|
445 | - /* Entry already listed */ |
|
446 | - if ( isListed($thisentry) ) { |
|
447 | - syslog(LOG_INFO, $loguser.': '.$value.' already listed. Nothing to do.'); |
|
448 | - $result->free(); |
|
449 | - return FALSE; |
|
450 | - } |
|
451 | - |
|
452 | - /* Entry delisted */ |
|
453 | - $result->free(); |
|
442 | + switch ($result->num_rows) { |
|
443 | + /* Relist value if already present */ |
|
444 | + case 1: |
|
445 | + /* Entry already listed */ |
|
446 | + if ( isListed($thisentry) ) { |
|
447 | + syslog(LOG_INFO, $loguser.': '.$value.' already listed. Nothing to do.'); |
|
448 | + $result->free(); |
|
449 | + return FALSE; |
|
450 | + } |
|
451 | + |
|
452 | + /* Entry delisted */ |
|
453 | + $result->free(); |
|
454 | 454 | $quantity *= $thisentry['nlist']; |
455 | - return relist ($myconn,$loguser,$value,$type,$table,$unit,$quantity,$reason); |
|
455 | + return relist ($myconn,$loguser,$value,$type,$table,$unit,$quantity,$reason); |
|
456 | 456 | |
457 | 457 | |
458 | - /* First time list value */ |
|
459 | - case 0: |
|
460 | - $result->free(); |
|
461 | - return addtolist ($myconn,$loguser,$value,$type,$table,$unit,$quantity,$reason); |
|
462 | - } |
|
458 | + /* First time list value */ |
|
459 | + case 0: |
|
460 | + $result->free(); |
|
461 | + return addtolist ($myconn,$loguser,$value,$type,$table,$unit,$quantity,$reason); |
|
462 | + } |
|
463 | 463 | } |
464 | 464 | |
465 | 465 |
@@ -10,9 +10,9 @@ |
||
10 | 10 | $mysqli = new mysqli($dbhost, $userdb, $pwd, $db, $dbport); |
11 | 11 | if ($mysqli->connect_error) { |
12 | 12 | syslog (LOG_EMERG, $user.': Connect Error (' . $mysqli->connect_errno . ') ' |
13 | - . $mysqli->connect_error); |
|
14 | - die($user.': Connect Error (' . $mysqli->connect_errno . ') ' |
|
15 | - . $mysqli->connect_error); |
|
13 | + . $mysqli->connect_error); |
|
14 | + die($user.': Connect Error (' . $mysqli->connect_errno . ') ' |
|
15 | + . $mysqli->connect_error); |
|
16 | 16 | } |
17 | 17 | syslog (LOG_INFO, $user.': Successfully connected to ' . $mysqli->host_info ); |
18 | 18 |
@@ -12,12 +12,12 @@ |
||
12 | 12 | $user = username(); |
13 | 13 | |
14 | 14 | $mysqli = new mysqli($dbhost, $userdb, $pwd, $db, $dbport); |
15 | - if ($mysqli->connect_error) { |
|
16 | - syslog (LOG_EMERG, $user.': Connect Error (' . $mysqli->connect_errno . ') ' |
|
17 | - . $mysqli->connect_error); |
|
18 | - die($user.': Connect Error (' . $mysqli->connect_errno . ') ' |
|
19 | - . $mysqli->connect_error); |
|
20 | - } |
|
15 | + if ($mysqli->connect_error) { |
|
16 | + syslog (LOG_EMERG, $user.': Connect Error (' . $mysqli->connect_errno . ') ' |
|
17 | + . $mysqli->connect_error); |
|
18 | + die($user.': Connect Error (' . $mysqli->connect_errno . ') ' |
|
19 | + . $mysqli->connect_error); |
|
20 | + } |
|
21 | 21 | syslog (LOG_INFO, $user.': Successfully connected to ' . $mysqli->host_info ); |
22 | 22 | |
23 | 23 | if (addtolist ($mysqli,username(),$_POST['value'],$type,$table,$_POST['unit'],$_POST['quantity'],$_POST['reason'])) |
@@ -2,23 +2,23 @@ |
||
2 | 2 | require_once('config.php'); |
3 | 3 | require_once('function.php'); |
4 | 4 | $typedesc=$_POST['type']; |
5 | - $type = $tables["$typedesc"]['field']; |
|
6 | - $table = $tables["$typedesc"]['name']; |
|
5 | + $type = $tables["$typedesc"]['field']; |
|
6 | + $table = $tables["$typedesc"]['name']; |
|
7 | 7 | ?> |
8 | 8 | <td colspan="9" style="text-align: center"> |
9 | 9 | <?php |
10 | 10 | openlog($tag, LOG_PID, $fac); |
11 | 11 | if (empty($_POST['reason'])) die ("Specify a reason, please!</td>"); |
12 | 12 | if (preg_match( '/[^\x20-\x7f]/', $_POST['reason'])) |
13 | - exit('ERROR: <'.htmlentities($_POST['reason'],ENT_COMPAT | ENT_HTML401, 'ISO-8859-1').'> contains NON ASCII chars.</td>'); |
|
13 | + exit('ERROR: <'.htmlentities($_POST['reason'],ENT_COMPAT | ENT_HTML401, 'ISO-8859-1').'> contains NON ASCII chars.</td>'); |
|
14 | 14 | $user = username(); |
15 | 15 | |
16 | 16 | $mysqli = new mysqli($dbhost, $userdb, $pwd, $db, $dbport); |
17 | 17 | if ($mysqli->connect_error) { |
18 | 18 | syslog (LOG_EMERG, $user.': Connect Error (' . $mysqli->connect_errno . ') ' |
19 | - . $mysqli->connect_error); |
|
20 | - exit ($user.': Connect Error (' . $mysqli->connect_errno . ') ' |
|
21 | - . $mysqli->connect_error); |
|
19 | + . $mysqli->connect_error); |
|
20 | + exit ($user.': Connect Error (' . $mysqli->connect_errno . ') ' |
|
21 | + . $mysqli->connect_error); |
|
22 | 22 | } |
23 | 23 | syslog(LOG_INFO, $user.': Successfully connected to ' . $mysqli->host_info) ; |
24 | 24 |
@@ -48,8 +48,8 @@ discard block |
||
48 | 48 | |
49 | 49 | /* check you select a blocklist */ |
50 | 50 | if ( !$tables["$typedesc"]['bl'] ) { |
51 | - syslog(LOG_EMERG,"$user: <$typedesc> is not a blocklist. Are you stupid? Do you want to whitelist a spammer? I refuse to continue."); |
|
52 | - exit (254); |
|
51 | + syslog(LOG_EMERG,"$user: <$typedesc> is not a blocklist. Are you stupid? Do you want to whitelist a spammer? I refuse to continue."); |
|
52 | + exit (254); |
|
53 | 53 | } |
54 | 54 | |
55 | 55 | |
@@ -69,33 +69,33 @@ discard block |
||
69 | 69 | $tolist = array(); |
70 | 70 | |
71 | 71 | if ( !file_exists($splfile) ) { |
72 | - syslog(LOG_ERR,"$user: File <$splfile> not found! Exit."); |
|
73 | - exit (254); |
|
72 | + syslog(LOG_ERR,"$user: File <$splfile> not found! Exit."); |
|
73 | + exit (254); |
|
74 | 74 | } |
75 | 75 | |
76 | 76 | if (($handle = gzopen($splfile, 'r')) !== FALSE) { |
77 | - $row = -1; |
|
78 | - while (($data = fgetcsv($handle, 500, ',')) !== FALSE) { |
|
79 | - $row++; |
|
80 | - if ($row == 0) continue; /* Skip heading line */ |
|
81 | - $thisVal = $data[1]; |
|
82 | - unset($data[1]); |
|
83 | - $data = array_values($data); |
|
84 | - if ( !in_array($thisVal,array_keys($tolist)) ) |
|
85 | - $tolist["$thisVal"] = $data; |
|
86 | - else if ($data[3]>$tolist[$thisVal][3]) |
|
87 | - $tolist["$thisVal"] = $data; |
|
88 | - } |
|
89 | - fclose($handle); |
|
77 | + $row = -1; |
|
78 | + while (($data = fgetcsv($handle, 500, ',')) !== FALSE) { |
|
79 | + $row++; |
|
80 | + if ($row == 0) continue; /* Skip heading line */ |
|
81 | + $thisVal = $data[1]; |
|
82 | + unset($data[1]); |
|
83 | + $data = array_values($data); |
|
84 | + if ( !in_array($thisVal,array_keys($tolist)) ) |
|
85 | + $tolist["$thisVal"] = $data; |
|
86 | + else if ($data[3]>$tolist[$thisVal][3]) |
|
87 | + $tolist["$thisVal"] = $data; |
|
88 | + } |
|
89 | + fclose($handle); |
|
90 | 90 | } |
91 | 91 | |
92 | 92 | /* Make MYSQL connection */ |
93 | 93 | |
94 | 94 | $mysqli = new mysqli($dbhost, $userdb, $pwd, $db, $dbport); |
95 | 95 | if ($mysqli->connect_error) { |
96 | - syslog (LOG_EMERG, $user.': Connect Error (' . $mysqli->connect_errno . ') ' |
|
97 | - . $mysqli->connect_error); |
|
98 | - exit (254); |
|
96 | + syslog (LOG_EMERG, $user.': Connect Error (' . $mysqli->connect_errno . ') ' |
|
97 | + . $mysqli->connect_error); |
|
98 | + exit (254); |
|
99 | 99 | |
100 | 100 | } |
101 | 101 | |
@@ -103,28 +103,28 @@ discard block |
||
103 | 103 | |
104 | 104 | foreach ( array_keys($tolist) as $value) { |
105 | 105 | $reason = 'On ['.$tolist["$value"][0]."] <$value> sent ".$tolist["$value"][1].' messages to '.$tolist["$value"][2].' recipients.'; |
106 | - if ( $tolist["$value"][3] >= $threshold ) { |
|
107 | - if ( searchAndList ($mysqli,$user,$tables,$typedesc,$value,$unit,$quantity,$reason) ) { |
|
108 | - syslog (LOG_INFO, "$user: ".'Listing reason: '.$reason); |
|
109 | - /* Send a email to domain admin if you list an email */ |
|
110 | - if ( ( $tables["$typedesc"]['field'] == 'email' ) OR ( $tables["$typedesc"]['field'] == 'username' ) ) { |
|
106 | + if ( $tolist["$value"][3] >= $threshold ) { |
|
107 | + if ( searchAndList ($mysqli,$user,$tables,$typedesc,$value,$unit,$quantity,$reason) ) { |
|
108 | + syslog (LOG_INFO, "$user: ".'Listing reason: '.$reason); |
|
109 | + /* Send a email to domain admin if you list an email */ |
|
110 | + if ( ( $tables["$typedesc"]['field'] == 'email' ) OR ( $tables["$typedesc"]['field'] == 'username' ) ) { |
|
111 | 111 | /* Sometime uid are in the form of <user>@<domain> ... */ |
112 | 112 | if ( strpos($value, '@') !== FALSE ) { |
113 | - $domain = array_pop(explode('@',$value,2)); |
|
113 | + $domain = array_pop(explode('@',$value,2)); |
|
114 | 114 | if ( strpos($domain, '@') === FALSE ) { |
115 | - $recip = emailToNotify($domainNotify_file,$domain); |
|
116 | - $subject = sprintf('%s <%s> is now blocked because exceedes limits on outgoing emails', |
|
115 | + $recip = emailToNotify($domainNotify_file,$domain); |
|
116 | + $subject = sprintf('%s <%s> is now blocked because exceedes limits on outgoing emails', |
|
117 | 117 | $tables["$typedesc"]['field'], $value); |
118 | - if (!empty($recip)) |
|
119 | - if ( sendEmailWarn($tplfile,'[email protected]',$recip, |
|
118 | + if (!empty($recip)) |
|
119 | + if ( sendEmailWarn($tplfile,'[email protected]',$recip, |
|
120 | 120 | $subject,$value,"$quantity $unit",$reason) ) |
121 | - syslog(LOG_INFO, "$user: \"$recip\" was notified about the \"$value\" abuse."); |
|
121 | + syslog(LOG_INFO, "$user: \"$recip\" was notified about the \"$value\" abuse."); |
|
122 | 122 | } |
123 | 123 | else syslog(LOG_ERR,"$user: <$domain> contains the '@' char. Notification cannot be sent."); |
124 | 124 | } |
125 | - } |
|
126 | - } |
|
127 | - } |
|
125 | + } |
|
126 | + } |
|
127 | + } |
|
128 | 128 | else { |
129 | 129 | $reason .= " But it has NOT been listed because it doesn't apply to the trigger condition."; |
130 | 130 | syslog (LOG_INFO, "$user: ".$reason); |
@@ -2,7 +2,7 @@ discard block |
||
2 | 2 | <?php |
3 | 3 | |
4 | 4 | if (PHP_SAPI != "cli") |
5 | - exit; |
|
5 | + exit; |
|
6 | 6 | |
7 | 7 | $home = '/var/www/html/RBL'; |
8 | 8 | require_once($home.'/config.php'); |
@@ -20,30 +20,30 @@ discard block |
||
20 | 20 | |
21 | 21 | $opts = getopt('f:t:'); |
22 | 22 | if ( isset($opts['f']) ) { |
23 | - $filetemplate = $opts['f']; |
|
23 | + $filetemplate = $opts['f']; |
|
24 | 24 | } else { |
25 | 25 | print "\nNo option for '-f' given.\n"; |
26 | - exit ( usage() ); |
|
26 | + exit ( usage() ); |
|
27 | 27 | } |
28 | 28 | |
29 | 29 | if ( isset($opts['t']) ) { |
30 | - $tablename = $opts['t']; |
|
30 | + $tablename = $opts['t']; |
|
31 | 31 | } else { |
32 | 32 | print "\nNo option for '-t' given.\n"; |
33 | - exit ( usage() ); |
|
33 | + exit ( usage() ); |
|
34 | 34 | } |
35 | 35 | |
36 | 36 | if ( ($typedescN = array_search( $tablename, array_column($tables, 'name'))) === FALSE ) { |
37 | - print "\nDB <$tablename> doesn't exist!\n"; |
|
38 | - syslog (LOG_EMERG, "$user: DB <$tablename> doesn't exist!"); |
|
39 | - exit ( usage() ); |
|
37 | + print "\nDB <$tablename> doesn't exist!\n"; |
|
38 | + syslog (LOG_EMERG, "$user: DB <$tablename> doesn't exist!"); |
|
39 | + exit ( usage() ); |
|
40 | 40 | } |
41 | 41 | $typedesc = array_keys($tables)[$typedescN]; |
42 | 42 | |
43 | 43 | if (! file_exists($filetemplate) ) { |
44 | - print "\nFile <$filetemplate> doesn't exists!\n"; |
|
44 | + print "\nFile <$filetemplate> doesn't exists!\n"; |
|
45 | 45 | syslog (LOG_EMERG, "$user: File <$filetemplate> doesn't exist!"); |
46 | - exit ( usage() ); |
|
46 | + exit ( usage() ); |
|
47 | 47 | } |
48 | 48 | |
49 | 49 | if (! in_array( $typedesc, array_keys($tables) ) ) { |
@@ -53,7 +53,7 @@ discard block |
||
53 | 53 | |
54 | 54 | if (! $tables["$typedesc"]['active'] ) { |
55 | 55 | print "\nList <$typedesc> is not active. Please provide an active list name.\n"; |
56 | - exit ( usage() ); |
|
56 | + exit ( usage() ); |
|
57 | 57 | } |
58 | 58 | |
59 | 59 | |
@@ -73,10 +73,10 @@ discard block |
||
73 | 73 | |
74 | 74 | $mysqli = new mysqli($dbhost, $userdb, $pwd, $db, $dbport); |
75 | 75 | if ($mysqli->connect_error) { |
76 | - syslog (LOG_EMERG, $user.': Connect Error (' . $mysqli->connect_errno . ') ' |
|
77 | - . $mysqli->connect_error); |
|
78 | - exit ($user.': Connect Error (' . $mysqli->connect_errno . ') ' |
|
79 | - . $mysqli->connect_error); |
|
76 | + syslog (LOG_EMERG, $user.': Connect Error (' . $mysqli->connect_errno . ') ' |
|
77 | + . $mysqli->connect_error); |
|
78 | + exit ($user.': Connect Error (' . $mysqli->connect_errno . ') ' |
|
79 | + . $mysqli->connect_error); |
|
80 | 80 | } |
81 | 81 | |
82 | 82 | syslog(LOG_INFO, $user.': Successfully mysql connected to ' . $mysqli->host_info) ; |
@@ -87,14 +87,14 @@ discard block |
||
87 | 87 | while ($riga = $result->fetch_array(MYSQLI_ASSOC)) { |
88 | 88 | if (isListed($riga)) { |
89 | 89 | switch ( $tables["$typedesc"]['field'] ) { |
90 | - case 'ip': |
|
91 | - $element[] = long2ip($riga['ip']); |
|
92 | - break; |
|
93 | - case 'network': |
|
94 | - $element[] = long2ip($riga['network']).'/'.long2ip($riga['netmask']); |
|
95 | - break; |
|
96 | - default: |
|
97 | - $element[] = $riga["$type"]; |
|
90 | + case 'ip': |
|
91 | + $element[] = long2ip($riga['ip']); |
|
92 | + break; |
|
93 | + case 'network': |
|
94 | + $element[] = long2ip($riga['network']).'/'.long2ip($riga['netmask']); |
|
95 | + break; |
|
96 | + default: |
|
97 | + $element[] = $riga["$type"]; |
|
98 | 98 | } |
99 | 99 | } |
100 | 100 | } |
@@ -12,14 +12,14 @@ discard block |
||
12 | 12 | # print "Examine ".$received[0][$i]."\n"; |
13 | 13 | if ( preg_match($msa,$received['host'][$i]) ) |
14 | 14 | $dateR = $received['date'][$i]; |
15 | - foreach ($mxserver as $mx) { |
|
16 | - if (!$ip) |
|
15 | + foreach ($mxserver as $mx) { |
|
16 | + if (!$ip) |
|
17 | 17 | if ($mx == $received['host'][$i]) { |
18 | 18 | $host = $received['host'][$i]; |
19 | 19 | $ip = $received['ip'][$i]; |
20 | - } |
|
21 | - } |
|
22 | - } |
|
20 | + } |
|
21 | + } |
|
22 | + } |
|
23 | 23 | } |
24 | 24 | if ( preg_match ('/\r\nDate:\s(?P<date>.*)\r\n/',$header,$dateC) != 1) |
25 | 25 | $dateC['date'] = 'Not found'; |
@@ -39,15 +39,15 @@ discard block |
||
39 | 39 | |
40 | 40 | |
41 | 41 | function summaryBadReport ($uidvet) { |
42 | - $nuid = $uidvet['count']; |
|
43 | - if ( empty($uidvet) ) return NULL; |
|
44 | - $return = '<hr><h3>Statistics by UID</h3><table><tr><th>UID</th><th>Learned times</th></tr>'."\n"; |
|
42 | + $nuid = $uidvet['count']; |
|
43 | + if ( empty($uidvet) ) return NULL; |
|
44 | + $return = '<hr><h3>Statistics by UID</h3><table><tr><th>UID</th><th>Learned times</th></tr>'."\n"; |
|
45 | 45 | |
46 | - /* Remove count index */ |
|
47 | - $uids = array_keys($uidvet['uid']); |
|
46 | + /* Remove count index */ |
|
47 | + $uids = array_keys($uidvet['uid']); |
|
48 | 48 | $totlearn = 0; |
49 | 49 | |
50 | - foreach ( $uids as $uid ) { |
|
50 | + foreach ( $uids as $uid ) { |
|
51 | 51 | $totlearn += $uidvet['uid']["$uid"]['count'];; |
52 | 52 | $return .= sprintf ('<tr><td>%s</td><td>%u</td></tr>',$uid,$uidvet['uid']["$uid"]['count']); |
53 | 53 | } |
@@ -60,26 +60,26 @@ discard block |
||
60 | 60 | |
61 | 61 | function array_msort($array, $cols) |
62 | 62 | { |
63 | - $colarr = array(); |
|
64 | - foreach ($cols as $col => $order) { |
|
65 | - $colarr[$col] = array(); |
|
66 | - foreach ($array as $k => $row) { $colarr[$col]['_'.$k] = strtolower($row[$col]); } |
|
67 | - } |
|
68 | - $eval = 'array_multisort('; |
|
69 | - foreach ($cols as $col => $order) { |
|
70 | - $eval .= '$colarr[\''.$col.'\'],'.$order.','; |
|
71 | - } |
|
72 | - $eval = substr($eval,0,-1).');'; |
|
73 | - eval($eval); |
|
74 | - $ret = array(); |
|
75 | - foreach ($colarr as $col => $arr) { |
|
76 | - foreach ($arr as $k => $v) { |
|
77 | - $k = substr($k,1); |
|
78 | - if (!isset($ret[$k])) $ret[$k] = $array[$k]; |
|
79 | - if (isset ($array[$k][$col])) $ret[$k][$col] = $array[$k][$col]; |
|
80 | - } |
|
81 | - } |
|
82 | - return $ret; |
|
63 | + $colarr = array(); |
|
64 | + foreach ($cols as $col => $order) { |
|
65 | + $colarr[$col] = array(); |
|
66 | + foreach ($array as $k => $row) { $colarr[$col]['_'.$k] = strtolower($row[$col]); } |
|
67 | + } |
|
68 | + $eval = 'array_multisort('; |
|
69 | + foreach ($cols as $col => $order) { |
|
70 | + $eval .= '$colarr[\''.$col.'\'],'.$order.','; |
|
71 | + } |
|
72 | + $eval = substr($eval,0,-1).');'; |
|
73 | + eval($eval); |
|
74 | + $ret = array(); |
|
75 | + foreach ($colarr as $col => $arr) { |
|
76 | + foreach ($arr as $k => $v) { |
|
77 | + $k = substr($k,1); |
|
78 | + if (!isset($ret[$k])) $ret[$k] = $array[$k]; |
|
79 | + if (isset ($array[$k][$col])) $ret[$k][$col] = $array[$k][$col]; |
|
80 | + } |
|
81 | + } |
|
82 | + return $ret; |
|
83 | 83 | |
84 | 84 | } |
85 | 85 | |
@@ -94,8 +94,8 @@ discard block |
||
94 | 94 | |
95 | 95 | foreach ( $ips as $ip ) { |
96 | 96 | if ( $ip == 'count' ) continue; |
97 | - $nlearn = $ipvet['ip']["$ip"]['count']; |
|
98 | - unset($ipvet['ip']["$ip"]['count']); |
|
97 | + $nlearn = $ipvet['ip']["$ip"]['count']; |
|
98 | + unset($ipvet['ip']["$ip"]['count']); |
|
99 | 99 | $nuid = count($ipvet['ip']["$ip"]); |
100 | 100 | if ( !$cf['onlyReport'] ) { |
101 | 101 | if ( ($nlearn >= $cf['thresholdip']["$category"])AND($nuid >= $cf['thresholduid']["$category"]) ) { |
@@ -122,9 +122,9 @@ discard block |
||
122 | 122 | $return .='<tr><td rowspan="'.$nuid.'">'.$ip.'</td>'; |
123 | 123 | $return .= sprintf ('<td>%s</td><td rowspan="'.$nuid.'">%u</td><td rowspan="'.$nuid.'" '.$nowlist["$listed"]['style'].'>%s</td></tr>',$ipvet['ip']["$ip"][0],$nlearn,$nowlist["$listed"]['name']); |
124 | 124 | $rowuid=NULL; |
125 | - for ($j=1;$j<$nuid;$j++) $rowuid .= '<tr><td>%s</td></tr>'; |
|
125 | + for ($j=1;$j<$nuid;$j++) $rowuid .= '<tr><td>%s</td></tr>'; |
|
126 | 126 | array_shift($ipvet['ip']["$ip"]); |
127 | - $return .= vsprintf ($rowuid,$ipvet['ip']["$ip"]); |
|
127 | + $return .= vsprintf ($rowuid,$ipvet['ip']["$ip"]); |
|
128 | 128 | |
129 | 129 | } |
130 | 130 | $return .= sprintf ('<tr><th title="unique ips">%u</th><th title="unique uids">%u</th><th>%u</th></table>',$ipvet['ip']['count'],$ipvet['uid']['count'],$nips); |
@@ -134,20 +134,20 @@ discard block |
||
134 | 134 | /* Not used for listing purpose, but useful to you! */ |
135 | 135 | $return .= '<h3>Statistics by UID</h3><table><tr><th>UID</th><th>IP learned</th><th>Learned times</th></tr>'."\n"; |
136 | 136 | $uids = array_keys($ipvet['uid']); |
137 | - foreach ( $uids as $uid ) { |
|
137 | + foreach ( $uids as $uid ) { |
|
138 | 138 | if ( $uid == 'count' ) continue; |
139 | - $nlearn = $ipvet['uid']["$uid"]['count']; |
|
140 | - unset ( $ipvet['uid']["$uid"]['count'] ); |
|
139 | + $nlearn = $ipvet['uid']["$uid"]['count']; |
|
140 | + unset ( $ipvet['uid']["$uid"]['count'] ); |
|
141 | 141 | $nip = count($ipvet['uid']["$uid"]); |
142 | 142 | $return .='<tr><td rowspan="'.$nip.'">'.$uid.'</td>'; |
143 | 143 | $return .= sprintf ('<td>%s</td><td rowspan="'.$nip.'">%u</td></tr>',$ipvet['uid']["$uid"][0],$nlearn); |
144 | - $rowuid=NULL; |
|
145 | - for ($j=1;$j<$nip;$j++) $rowuid .= '<tr><td>%s</td></tr>'; |
|
146 | - array_shift($ipvet['uid']["$uid"]); |
|
147 | - $return .= vsprintf ($rowuid,$ipvet['uid']["$uid"]); |
|
144 | + $rowuid=NULL; |
|
145 | + for ($j=1;$j<$nip;$j++) $rowuid .= '<tr><td>%s</td></tr>'; |
|
146 | + array_shift($ipvet['uid']["$uid"]); |
|
147 | + $return .= vsprintf ($rowuid,$ipvet['uid']["$uid"]); |
|
148 | 148 | |
149 | - } |
|
150 | - $return .= sprintf ('<tr><th title="unique uids">%u</th><th title="unique ips">%u</th><th>%u</th></table>',$ipvet['uid']['count'],$ipvet['ip']['count'],$nips); |
|
149 | + } |
|
150 | + $return .= sprintf ('<tr><th title="unique uids">%u</th><th title="unique ips">%u</th><th>%u</th></table>',$ipvet['uid']['count'],$ipvet['ip']['count'],$nips); |
|
151 | 151 | |
152 | 152 | |
153 | 153 | return $return; |
@@ -164,9 +164,9 @@ discard block |
||
164 | 164 | // A blocking search returns the job when the search is done |
165 | 165 | /* Wait to finish */ |
166 | 166 | $job = $service->getJobs()->create($searchQueryBlocking, array( |
167 | - 'exec_mode' => 'blocking', |
|
168 | - 'earliest_time' => date("c",strtotime ($date)-120), |
|
169 | - 'latest_time' => date("c",strtotime ($date)+60) |
|
167 | + 'exec_mode' => 'blocking', |
|
168 | + 'earliest_time' => date("c",strtotime ($date)-120), |
|
169 | + 'latest_time' => date("c",strtotime ($date)+60) |
|
170 | 170 | )); |
171 | 171 | |
172 | 172 | /* |
@@ -190,38 +190,38 @@ discard block |
||
190 | 190 | // Use the built-in XML parser to display the job results |
191 | 191 | foreach ($resultSearch as $result) |
192 | 192 | { |
193 | - if ($result instanceof Splunk_ResultsFieldOrder) |
|
194 | - { |
|
195 | - // More than one field attribute returned by search |
|
196 | - // You must redefine the search |
|
197 | - if ( count($result->getFieldNames()) > 1 ) return FALSE; |
|
198 | - } |
|
199 | - else if ($result instanceof Splunk_ResultsMessage) |
|
200 | - { |
|
201 | - // I don't want messages in my search |
|
202 | - return FALSE; |
|
203 | - } |
|
204 | - else if (is_array($result)) |
|
205 | - { |
|
206 | - // Process a row |
|
207 | - foreach ($result as $key => $valueOrValues) |
|
208 | - { |
|
209 | - if (is_array($valueOrValues)) |
|
210 | - { |
|
211 | - return FALSE; |
|
212 | - } |
|
213 | - else |
|
214 | - { |
|
215 | - return $valueOrValues; |
|
216 | - #print " {$key} => {$value}\r\n"; |
|
217 | - } |
|
218 | - } |
|
219 | - } |
|
220 | - else |
|
221 | - { |
|
222 | - #print "Unknow result type"; |
|
223 | - return FALSE; |
|
224 | - } |
|
193 | + if ($result instanceof Splunk_ResultsFieldOrder) |
|
194 | + { |
|
195 | + // More than one field attribute returned by search |
|
196 | + // You must redefine the search |
|
197 | + if ( count($result->getFieldNames()) > 1 ) return FALSE; |
|
198 | + } |
|
199 | + else if ($result instanceof Splunk_ResultsMessage) |
|
200 | + { |
|
201 | + // I don't want messages in my search |
|
202 | + return FALSE; |
|
203 | + } |
|
204 | + else if (is_array($result)) |
|
205 | + { |
|
206 | + // Process a row |
|
207 | + foreach ($result as $key => $valueOrValues) |
|
208 | + { |
|
209 | + if (is_array($valueOrValues)) |
|
210 | + { |
|
211 | + return FALSE; |
|
212 | + } |
|
213 | + else |
|
214 | + { |
|
215 | + return $valueOrValues; |
|
216 | + #print " {$key} => {$value}\r\n"; |
|
217 | + } |
|
218 | + } |
|
219 | + } |
|
220 | + else |
|
221 | + { |
|
222 | + #print "Unknow result type"; |
|
223 | + return FALSE; |
|
224 | + } |
|
225 | 225 | } |
226 | 226 | } |
227 | 227 | |
@@ -230,26 +230,26 @@ discard block |
||
230 | 230 | $file = dirname(__FILE__) . '/' . $cf['reportFile']["$type"]; |
231 | 231 | $fileb= dirname(__FILE__) . '/' . $cf['badreportFile']["$type"]; |
232 | 232 | $m_mail = imap_open('{'.$cf['mailhost'].':143/imap/novalidate-cert/authuser='.$cf['authuser'].'}'.$cf['folder']["$type"], $cf['account'],$cf['authpassword'], OP_READONLY) |
233 | - or syslog (LOG_EMERG, $cf['user'].': Error in IMAP connection to <'.$cf['mailhost'].'>: ' . imap_last_error()); |
|
233 | + or syslog (LOG_EMERG, $cf['user'].': Error in IMAP connection to <'.$cf['mailhost'].'>: ' . imap_last_error()); |
|
234 | 234 | if ( !$m_mail ) exit(254); |
235 | 235 | |
236 | 236 | |
237 | 237 | syslog (LOG_INFO,$cf['user'].': Successfully connected to <'.$cf['mailhost'].">; Reading $type messages of last ".$cf['oldestday'].' days...'); |
238 | 238 | //get all messages |
239 | 239 | $dateTh = date ( "d-M-Y", strToTime ( '-'.$cf['oldestday'].' days' ) ); |
240 | - $dateN = date ( "d-M-Y", strToTime ( "now" ) ); |
|
241 | - $m_search=imap_search ($m_mail, "SINCE \"$dateTh\" BEFORE \"$dateN\"" ); |
|
240 | + $dateN = date ( "d-M-Y", strToTime ( "now" ) ); |
|
241 | + $m_search=imap_search ($m_mail, "SINCE \"$dateTh\" BEFORE \"$dateN\"" ); |
|
242 | 242 | |
243 | 243 | |
244 | 244 | // Order results starting from newest message |
245 | 245 | if (!$m_search) { |
246 | 246 | syslog (LOG_INFO,$cf['user'].": No mail found in $type folder. No reports written for $type."); |
247 | - if ( $ierr = imap_errors() ) |
|
248 | - foreach ( $ierr as $thiserr ) |
|
249 | - syslog (LOG_ERR, $cf['user'].": IMAP Error: $thiserr"); |
|
250 | - if ( $ierr = imap_alerts() ) |
|
251 | - foreach ( $ierr as $thiserr ) |
|
252 | - syslog (LOG_ALERT, $cf['user'].": IMAP Alert: $thiserr"); |
|
247 | + if ( $ierr = imap_errors() ) |
|
248 | + foreach ( $ierr as $thiserr ) |
|
249 | + syslog (LOG_ERR, $cf['user'].": IMAP Error: $thiserr"); |
|
250 | + if ( $ierr = imap_alerts() ) |
|
251 | + foreach ( $ierr as $thiserr ) |
|
252 | + syslog (LOG_ALERT, $cf['user'].": IMAP Alert: $thiserr"); |
|
253 | 253 | imap_close( $m_mail ); |
254 | 254 | if ( file_exists( $file ) ) unlink ($file); |
255 | 255 | if ( file_exists( $fileb ) ) unlink ($fileb); |
@@ -280,16 +280,16 @@ discard block |
||
280 | 280 | $uidbad['count'] = 0; |
281 | 281 | $uidbad['uid'] = array(); |
282 | 282 | |
283 | - // loop for each message |
|
283 | + // loop for each message |
|
284 | 284 | foreach ($m_search as $onem) { |
285 | 285 | |
286 | - //get imap header info for obj thang |
|
287 | - //$headers = imap_headerinfo($m_mail, $onem); |
|
288 | - //$head = imap_fetchheader($m_mail, $headers->Msgno); |
|
286 | + //get imap header info for obj thang |
|
287 | + //$headers = imap_headerinfo($m_mail, $onem); |
|
288 | + //$head = imap_fetchheader($m_mail, $headers->Msgno); |
|
289 | 289 | $head = imap_fetchheader($m_mail, $onem ); |
290 | - //$obj = imap_rfc822_parse_headers( $head); |
|
290 | + //$obj = imap_rfc822_parse_headers( $head); |
|
291 | 291 | |
292 | - list ($ip,$host,$dateReceived,$dateClient,$mid) = getIP( $head,$cf['mx'],$cf['msalearn'] ); |
|
292 | + list ($ip,$host,$dateReceived,$dateClient,$mid) = getIP( $head,$cf['mx'],$cf['msalearn'] ); |
|
293 | 293 | if (empty($mid)) { |
294 | 294 | $uid='NA'; |
295 | 295 | syslog (LOG_ERR, $cf['user'].": Error retrieving data for empty Message-ID."); |
@@ -304,11 +304,11 @@ discard block |
||
304 | 304 | } |
305 | 305 | } |
306 | 306 | |
307 | - /* Update count of each ip */ |
|
308 | - if ($host and ($uid!='NA') and ($uid!='unauthenticated') and ($uid!='unknown')) { /* IP is received by MX servers and learned by valid uid */ |
|
307 | + /* Update count of each ip */ |
|
308 | + if ($host and ($uid!='NA') and ($uid!='unauthenticated') and ($uid!='unknown')) { /* IP is received by MX servers and learned by valid uid */ |
|
309 | 309 | $ipuid['count']++; //number of right messages |
310 | 310 | |
311 | - if (in_array($uid,array_keys($ipuid['uid']))) { |
|
311 | + if (in_array($uid,array_keys($ipuid['uid']))) { |
|
312 | 312 | $ipuid['uid']["$uid"]['count']++; //number of learn by this uid |
313 | 313 | if (!in_array($ip,$ipuid['uid']["$uid"])) |
314 | 314 | $ipuid['uid']["$uid"][]=$ip; //ips learned by this uid |
@@ -319,29 +319,29 @@ discard block |
||
319 | 319 | $ipuid['uid']['count']++; //number of unique uids |
320 | 320 | } |
321 | 321 | |
322 | - if (in_array($ip,array_keys($ipuid['ip']))) { |
|
323 | - $ipuid['ip']["$ip"]['count']++; //number of time this ip appears in different messages |
|
322 | + if (in_array($ip,array_keys($ipuid['ip']))) { |
|
323 | + $ipuid['ip']["$ip"]['count']++; //number of time this ip appears in different messages |
|
324 | 324 | if (!in_array($uid,$ipuid['ip']["$ip"])) |
325 | 325 | $ipuid['ip']["$ip"][]=$uid; //uids that learned this ip |
326 | 326 | } |
327 | - else { |
|
328 | - $ipuid['ip']["$ip"]['count'] = 1; |
|
327 | + else { |
|
328 | + $ipuid['ip']["$ip"]['count'] = 1; |
|
329 | 329 | $ipuid['ip']["$ip"][]=$uid; |
330 | 330 | $ipuid['ip']['count']++; //number of unique ips |
331 | - } |
|
331 | + } |
|
332 | 332 | |
333 | - /* Update HTML report */ |
|
334 | - fwrite($fp,updateReport ( $ip,$uid,$ipuid['ip']["$ip"]['count'],$ipuid['uid']["$uid"]['count'],$host,$dateClient,$mid,$dateReceived) ); |
|
333 | + /* Update HTML report */ |
|
334 | + fwrite($fp,updateReport ( $ip,$uid,$ipuid['ip']["$ip"]['count'],$ipuid['uid']["$uid"]['count'],$host,$dateClient,$mid,$dateReceived) ); |
|
335 | 335 | } |
336 | - else { /* Bad learn */ |
|
336 | + else { /* Bad learn */ |
|
337 | 337 | |
338 | - if (in_array($uid,array_keys($uidbad['uid']))) |
|
339 | - $uidbad['uid']["$uid"]['count']++; //number of bad learn by this uid |
|
340 | - else { |
|
341 | - $uidbad['uid']["$uid"]['count'] = 1; |
|
338 | + if (in_array($uid,array_keys($uidbad['uid']))) |
|
339 | + $uidbad['uid']["$uid"]['count']++; //number of bad learn by this uid |
|
340 | + else { |
|
341 | + $uidbad['uid']["$uid"]['count'] = 1; |
|
342 | 342 | $uidbad['uid']["$uid"][]=$uid; |
343 | - $uidbad['count']++; //numeber of unique bad uids |
|
344 | - } |
|
343 | + $uidbad['count']++; //numeber of unique bad uids |
|
344 | + } |
|
345 | 345 | /* The reason of bad report */ |
346 | 346 | if (!$host) $reason = 'This mail was not received by recognized MX host'; |
347 | 347 | if (!$dateReceived) $reason = 'This mail was not submitted to recognized MSA for learn'; |
@@ -363,17 +363,17 @@ discard block |
||
363 | 363 | fwrite($fp, '</table>'); |
364 | 364 | fwrite($fp, '<hr><h2>Summary Report</h2><h5>Listing policy: ip must be learned at least '.$cf['thresholdip']["$type"].' times from at least '.$cf['thresholduid']["$type"].' different valid uids.</h5>' ); |
365 | 365 | |
366 | - /* Make MYSQL connection */ |
|
366 | + /* Make MYSQL connection */ |
|
367 | 367 | if ( $cf['onlyReport'] ) |
368 | 368 | $mysqli = NULL; |
369 | 369 | else { |
370 | - $mysqli = new mysqli($myconnArray['dbhost'], $myconnArray['userdb'], $myconnArray['pwd'], $myconnArray['db'], $myconnArray['dbport']); |
|
371 | - if ($mysqli->connect_error) { |
|
372 | - syslog (LOG_EMERG, $cf['user'].': Connect Error (' . $mysqli->connect_errno . ') ' |
|
373 | - . $mysqli->connect_error); |
|
374 | - exit (254); |
|
375 | - } |
|
376 | - syslog(LOG_INFO, $cf['user'].': Successfully mysql connected to ' . $mysqli->host_info) ; |
|
370 | + $mysqli = new mysqli($myconnArray['dbhost'], $myconnArray['userdb'], $myconnArray['pwd'], $myconnArray['db'], $myconnArray['dbport']); |
|
371 | + if ($mysqli->connect_error) { |
|
372 | + syslog (LOG_EMERG, $cf['user'].': Connect Error (' . $mysqli->connect_errno . ') ' |
|
373 | + . $mysqli->connect_error); |
|
374 | + exit (254); |
|
375 | + } |
|
376 | + syslog(LOG_INFO, $cf['user'].': Successfully mysql connected to ' . $mysqli->host_info) ; |
|
377 | 377 | } |
378 | 378 | /***********************/ |
379 | 379 | |
@@ -393,8 +393,8 @@ discard block |
||
393 | 393 | foreach ( $ierr as $thiserr ) |
394 | 394 | syslog (LOG_ERR, $cf['user'].": IMAP Error: $thiserr"); |
395 | 395 | if ( $ierr = imap_alerts() ) |
396 | - foreach ( $ierr as $thiserr ) |
|
397 | - syslog (LOG_ALERT, $cf['user'].": IMAP Alert: $thiserr"); |
|
396 | + foreach ( $ierr as $thiserr ) |
|
397 | + syslog (LOG_ALERT, $cf['user'].": IMAP Alert: $thiserr"); |
|
398 | 398 | imap_close($m_mail); |
399 | 399 | } |
400 | 400 | ?> |
@@ -7,7 +7,7 @@ |
||
7 | 7 | print '<p>List of available Reports for '.date('l, d M Y', strtotime($theDate)).'</p><ul>'; |
8 | 8 | foreach($dir as $file) |
9 | 9 | { |
10 | - if ( basename($file) != basename(__FILE__) ) { |
|
10 | + if ( basename($file) != basename(__FILE__) ) { |
|
11 | 11 | $modalDiv = 'openModal'.basename($file); |
12 | 12 | echo '<li><a href="#'.$modalDiv.'">'.str_replace("-$theDate.html",'',basename($file)).'</a></li>'; |
13 | 13 | # echo '<li><pre><a href="'.basename($file).'" title="'.str_replace("-$theDate.html",'',basename($file))." of $theDate".'" onClick="Modalbox.show(this.href, {title: this.title, height: 600}); return false;">'.str_replace("-$theDate.html",'',basename($file)).'</a></pre></li>'; |