mirror of https://github.com/fail2ban/fail2ban
Merge pull request #2125 from jodlajodla/0.11 (rebased)
commit
d9b9bb5f40
|
@ -87,7 +87,7 @@ class FilterSystemd(JournalFilter): # pragma: systemd no cover
|
||||||
args['files'] = list(set(files))
|
args['files'] = list(set(files))
|
||||||
|
|
||||||
try:
|
try:
|
||||||
args['flags'] = kwargs.pop('journalflags')
|
args['flags'] = int(kwargs.pop('journalflags'))
|
||||||
except KeyError:
|
except KeyError:
|
||||||
pass
|
pass
|
||||||
|
|
||||||
|
|
|
@ -733,7 +733,7 @@ class Transmitter(TransmitterBase):
|
||||||
self.assertEqual(
|
self.assertEqual(
|
||||||
self.transm.proceed(["status", "INVALID", "COMMAND"])[0],1)
|
self.transm.proceed(["status", "INVALID", "COMMAND"])[0],1)
|
||||||
|
|
||||||
def testJournalMatch(self):
|
def testJournalMatch(self): # pragma: systemd no cover
|
||||||
if not filtersystemd: # pragma: no cover
|
if not filtersystemd: # pragma: no cover
|
||||||
raise unittest.SkipTest("systemd python interface not available")
|
raise unittest.SkipTest("systemd python interface not available")
|
||||||
jailName = "TestJail2"
|
jailName = "TestJail2"
|
||||||
|
@ -804,6 +804,28 @@ class Transmitter(TransmitterBase):
|
||||||
["set", jailName, "deljournalmatch", value])
|
["set", jailName, "deljournalmatch", value])
|
||||||
self.assertTrue(isinstance(result[1], ValueError))
|
self.assertTrue(isinstance(result[1], ValueError))
|
||||||
|
|
||||||
|
def testJournalFlagsMatch(self): # pragma: systemd no cover
|
||||||
|
if not filtersystemd: # pragma: no cover
|
||||||
|
raise unittest.SkipTest("systemd python interface not available")
|
||||||
|
self.assertTrue(True)
|
||||||
|
jailName = "TestJail3"
|
||||||
|
self.server.addJail(jailName, "systemd[journalflags=2]")
|
||||||
|
values = [
|
||||||
|
"_SYSTEMD_UNIT=sshd.service",
|
||||||
|
"TEST_FIELD1=ABC",
|
||||||
|
"_HOSTNAME=example.com",
|
||||||
|
]
|
||||||
|
for n, value in enumerate(values):
|
||||||
|
self.assertEqual(
|
||||||
|
self.transm.proceed(
|
||||||
|
["set", jailName, "addjournalmatch", value]),
|
||||||
|
(0, [[val] for val in values[:n+1]]))
|
||||||
|
for n, value in enumerate(values):
|
||||||
|
self.assertEqual(
|
||||||
|
self.transm.proceed(
|
||||||
|
["set", jailName, "deljournalmatch", value]),
|
||||||
|
(0, [[val] for val in values[n+1:]]))
|
||||||
|
|
||||||
|
|
||||||
class TransmitterLogging(TransmitterBase):
|
class TransmitterLogging(TransmitterBase):
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue