mirror of
https://github.com/librenms/librenms.git
synced 2024-10-07 16:52:45 +00:00
Merge pull request #3036 from Ultra2D/issue-3035
Linux syslog processing cleanup
This commit is contained in:
@ -88,13 +88,9 @@ function process_syslog($entry, $update) {
|
||||
// User_CommonName/123.213.132.231:39872 VERIFY OK: depth=1, /C=PL/ST=Malopolska/O=VLO/CN=v-lo.krakow.pl/emailAddress=root@v-lo.krakow.pl
|
||||
if ($entry['facility'] == 'daemon' and preg_match('#/([0-9]{1,3}\.) {3}[0-9]{1,3}:[0-9]{4,} ([A-Z]([A-Za-z])+( ?)) {2,}:#', $entry['msg'])) {
|
||||
$entry['program'] = 'OpenVPN';
|
||||
} //end if
|
||||
// POP3(username): Disconnected: Logged out top=0/0, retr=0/0, del=0/1, size=2802
|
||||
else if ($entry['facility'] == 'mail' and preg_match('#^(((pop3|imap)\-login)|((POP3|IMAP)\(.*\))):', $entry['msg'])) {
|
||||
$entry['program'] = 'Dovecot';
|
||||
} // pam_krb5(sshd:auth): authentication failure; logname=root uid=0 euid=0 tty=ssh ruser= rhost=123.213.132.231
|
||||
// pam_krb5[sshd:auth]: authentication failure; logname=root uid=0 euid=0 tty=ssh ruser= rhost=123.213.132.231
|
||||
else if (preg_match('#^(?P<program>(.*((\(|\[).*(\)|\])))):(?P<msg>.*)$#', $entry['msg'], $matches)) {
|
||||
else if (preg_match('#^(?P<program>([^(:]+\([^)]+\)|[^\[:]+\[[^\]]+\])) ?: ?(?P<msg>.*)$#', $entry['msg'], $matches)) {
|
||||
$entry['msg'] = $matches['msg'];
|
||||
$entry['program'] = $matches['program'];
|
||||
} // SYSLOG CONNECTION BROKEN; FD='6', SERVER='AF_INET(123.213.132.231:514)', time_reopen='60'
|
||||
@ -119,7 +115,6 @@ function process_syslog($entry, $update) {
|
||||
}
|
||||
|
||||
$entry['program'] = strtoupper($entry['program']);
|
||||
array_walk($entry, 'trim');
|
||||
|
||||
if ($update) {
|
||||
dbInsert(
|
||||
|
@ -79,6 +79,68 @@ class SyslogTest extends \PHPUnit_Framework_TestCase
|
||||
);
|
||||
|
||||
|
||||
// run tests
|
||||
foreach($testdata as $data) {
|
||||
$res = process_syslog($data['input'], 0);
|
||||
$this->assertEquals($data['result'], $res);
|
||||
}
|
||||
}
|
||||
public function testLinuxSyslog()
|
||||
{
|
||||
// populate fake $dev_cache and $config
|
||||
global $config, $dev_cache;
|
||||
$dev_cache['1.1.1.1'] = array('device_id' => 1, 'os' => 'linux', 'version' => 1);
|
||||
$config = array();
|
||||
$config['syslog_filter'] = array();
|
||||
|
||||
// populate test data
|
||||
$testdata = array();
|
||||
|
||||
// ---- PAM ----
|
||||
$testdata[] = $this->createData(
|
||||
"1.1.1.1||authpriv||info||info||56||2016-02-28 00:23:34||pam_unix(cron:session): session opened for user librenms by (uid=0)||CRON",
|
||||
array('device_id'=>1, 'program'=>'PAM_UNIX(CRON:SESSION)', 'msg'=>'session opened for user librenms by (uid=0)')
|
||||
);
|
||||
$testdata[] = $this->createData(
|
||||
"1.1.1.1||authpriv||info||info||55||2016-02-28 00:23:34||pam_unix(sudo:session): session opened for user librenms by root (uid=0)||sudo",
|
||||
array('device_id'=>1, 'program'=>'PAM_UNIX(SUDO:SESSION)', 'msg'=>'session opened for user librenms by root (uid=0)')
|
||||
);
|
||||
$testdata[] = $this->createData(
|
||||
"1.1.1.1||auth||info||info||0e||2016-02-28 00:23:34||pam_krb5(sshd:auth): authentication failure; logname=root uid=0 euid=0 tty=ssh ruser= rhost=123.213.132.231||sshd",
|
||||
array('device_id'=>1, 'program'=>'PAM_KRB5(SSHD:AUTH)', 'msg'=>'authentication failure; logname=root uid=0 euid=0 tty=ssh ruser= rhost=123.213.132.231')
|
||||
);
|
||||
$testdata[] = $this->createData(
|
||||
"1.1.1.1||auth||info||info||0e||2016-02-28 00:23:34||pam_krb5[sshd:auth]: authentication failure; logname=root uid=0 euid=0 tty=ssh ruser= rhost=123.213.132.231||sshd",
|
||||
array('device_id'=>1, 'program'=>'PAM_KRB5[SSHD:AUTH]', 'msg'=>'authentication failure; logname=root uid=0 euid=0 tty=ssh ruser= rhost=123.213.132.231')
|
||||
);
|
||||
|
||||
// ---- Postfix ----
|
||||
$testdata[] = $this->createData(
|
||||
"1.1.1.1||mail||info||info||16||2016-02-28 00:23:34||5C62E329EF: to=<admin@example.com>, relay=mail.example.com[127.0.0.1]:25, delay=0.11, delays=0.04/0.01/0/0.06, dsn=2.0.0, status=sent (250 2.0.0 Ok: queued as 5362E6A670E)||postfix/smtp",
|
||||
array('device_id'=>1, 'program'=>'POSTFIX/SMTP', 'msg'=>'5C62E329EF: to=<admin@example.com>, relay=mail.example.com[127.0.0.1]:25, delay=0.11, delays=0.04/0.01/0/0.06, dsn=2.0.0, status=sent (250 2.0.0 Ok: queued as 5362E6A670E)')
|
||||
);
|
||||
$testdata[] = $this->createData(
|
||||
"1.1.1.1||mail||info||info||16||2016-02-28 00:23:34||D7256400EF: from=<librenms@librenms.example.com>, size=882, nrcpt=1 (queue active)||postfix/qmgr",
|
||||
array('device_id'=>1, 'program'=>'POSTFIX/QMGR', 'msg'=>'D7256400EF: from=<librenms@librenms.example.com>, size=882, nrcpt=1 (queue active)')
|
||||
);
|
||||
|
||||
// ---- No program ----
|
||||
$testdata[] = $this->createData(
|
||||
"1.1.1.1||user||info||info||0e||2016-02-28 00:23:34||some random message||",
|
||||
array('device_id'=>1, 'program'=>'USER', 'msg'=>'some random message')
|
||||
);
|
||||
|
||||
// ---- Other ----
|
||||
$testdata[] = $this->createData(
|
||||
"1.1.1.1||cron||info||info||4e||2016-02-28 00:23:34||(librenms) CMD ( /opt/librenms/alerts.php >> /var/log/librenms_alert.log 2>&1)||CRON",
|
||||
array('device_id'=>1, 'program'=>'CRON', 'msg'=>'(librenms) CMD ( /opt/librenms/alerts.php >> /var/log/librenms_alert.log 2>&1)')
|
||||
);
|
||||
$testdata[] = $this->createData(
|
||||
"1.1.1.1||authpriv||notice||notice||55||2016-02-28 00:23:34|| root : TTY=pts/1 ; PWD=/opt/librenms ; USER=librenms ; COMMAND=/usr/bin/git status||sudo",
|
||||
array('device_id'=>1, 'program'=>'SUDO', 'msg'=>' root : TTY=pts/1 ; PWD=/opt/librenms ; USER=librenms ; COMMAND=/usr/bin/git status')
|
||||
);
|
||||
|
||||
|
||||
// run tests
|
||||
foreach($testdata as $data) {
|
||||
$res = process_syslog($data['input'], 0);
|
||||
|
Reference in New Issue
Block a user