mirror of https://github.com/fail2ban/fail2ban
normalizing time config entries: use time abbreviation (str2seconds) for all time options such 'dbpurgeage', 'bantime', 'findtime', ex.: default '1d' instead '86400';
code review and test case extended;pull/1346/head
parent
dad4234beb
commit
d22b2498d4
|
@ -66,4 +66,4 @@ dbfile = /var/lib/fail2ban/fail2ban.sqlite3
|
||||||
# Options: dbpurgeage
|
# Options: dbpurgeage
|
||||||
# Notes.: Sets age at which bans should be purged from the database
|
# Notes.: Sets age at which bans should be purged from the database
|
||||||
# Values: [ SECONDS ] Default: 86400 (24hours)
|
# Values: [ SECONDS ] Default: 86400 (24hours)
|
||||||
dbpurgeage = 86400
|
dbpurgeage = 1d
|
||||||
|
|
|
@ -18,7 +18,7 @@
|
||||||
# See man 5 jail.conf for details.
|
# See man 5 jail.conf for details.
|
||||||
#
|
#
|
||||||
# [DEFAULT]
|
# [DEFAULT]
|
||||||
# bantime = 3600
|
# bantime = 1h
|
||||||
#
|
#
|
||||||
# [sshd]
|
# [sshd]
|
||||||
# enabled = true
|
# enabled = true
|
||||||
|
@ -56,11 +56,11 @@ ignoreip = 127.0.0.1/8
|
||||||
ignorecommand =
|
ignorecommand =
|
||||||
|
|
||||||
# "bantime" is the number of seconds that a host is banned.
|
# "bantime" is the number of seconds that a host is banned.
|
||||||
bantime = 600
|
bantime = 10m
|
||||||
|
|
||||||
# A host is banned if it has generated "maxretry" during the last "findtime"
|
# A host is banned if it has generated "maxretry" during the last "findtime"
|
||||||
# seconds.
|
# seconds.
|
||||||
findtime = 600
|
findtime = 10m
|
||||||
|
|
||||||
# "maxretry" is the number of failures before a host get banned.
|
# "maxretry" is the number of failures before a host get banned.
|
||||||
maxretry = 5
|
maxretry = 5
|
||||||
|
@ -258,7 +258,7 @@ logpath = %(apache_error_log)s
|
||||||
# for email addresses. The mail outputs are buffered.
|
# for email addresses. The mail outputs are buffered.
|
||||||
port = http,https
|
port = http,https
|
||||||
logpath = %(apache_access_log)s
|
logpath = %(apache_access_log)s
|
||||||
bantime = 172800
|
bantime = 48h
|
||||||
maxretry = 1
|
maxretry = 1
|
||||||
|
|
||||||
|
|
||||||
|
@ -738,8 +738,8 @@ maxretry = 5
|
||||||
|
|
||||||
logpath = /var/log/fail2ban.log
|
logpath = /var/log/fail2ban.log
|
||||||
banaction = %(banaction_allports)s
|
banaction = %(banaction_allports)s
|
||||||
bantime = 604800 ; 1 week
|
bantime = 1w
|
||||||
findtime = 86400 ; 1 day
|
findtime = 1d
|
||||||
maxretry = 5
|
maxretry = 5
|
||||||
|
|
||||||
|
|
||||||
|
@ -818,7 +818,7 @@ filter = apache-pass
|
||||||
logpath = %(apache_access_log)s
|
logpath = %(apache_access_log)s
|
||||||
blocktype = RETURN
|
blocktype = RETURN
|
||||||
returntype = DROP
|
returntype = DROP
|
||||||
bantime = 3600
|
bantime = 1h
|
||||||
maxretry = 1
|
maxretry = 1
|
||||||
findtime = 1
|
findtime = 1
|
||||||
|
|
||||||
|
|
|
@ -49,7 +49,7 @@ class Fail2banReader(ConfigReader):
|
||||||
["string", "logtarget", "STDERR"],
|
["string", "logtarget", "STDERR"],
|
||||||
["string", "syslogsocket", "auto"],
|
["string", "syslogsocket", "auto"],
|
||||||
["string", "dbfile", "/var/lib/fail2ban/fail2ban.sqlite3"],
|
["string", "dbfile", "/var/lib/fail2ban/fail2ban.sqlite3"],
|
||||||
["int", "dbpurgeage", 86400]]
|
["string", "dbpurgeage", "1d"]]
|
||||||
self.__opts = ConfigReader.getOptions(self, "Definition", opts)
|
self.__opts = ConfigReader.getOptions(self, "Definition", opts)
|
||||||
|
|
||||||
def convert(self):
|
def convert(self):
|
||||||
|
|
|
@ -97,9 +97,9 @@ class JailReader(ConfigReader):
|
||||||
["string", "logpath", None],
|
["string", "logpath", None],
|
||||||
["string", "logencoding", None],
|
["string", "logencoding", None],
|
||||||
["string", "backend", "auto"],
|
["string", "backend", "auto"],
|
||||||
["int", "maxretry", None],
|
["int", "maxretry", None],
|
||||||
["int", "findtime", None],
|
["string", "findtime", None],
|
||||||
["int", "bantime", None],
|
["string", "bantime", None],
|
||||||
["string", "usedns", None],
|
["string", "usedns", None],
|
||||||
["string", "failregex", None],
|
["string", "failregex", None],
|
||||||
["string", "ignoreregex", None],
|
["string", "ignoreregex", None],
|
||||||
|
|
|
@ -218,7 +218,7 @@ class Fail2BanDb(object):
|
||||||
|
|
||||||
@purgeage.setter
|
@purgeage.setter
|
||||||
def purgeage(self, value):
|
def purgeage(self, value):
|
||||||
self._purgeAge = int(value)
|
self._purgeAge = MyTime.str2seconds(value)
|
||||||
|
|
||||||
@commitandrollback
|
@commitandrollback
|
||||||
def createDb(self, cur):
|
def createDb(self, cur):
|
||||||
|
|
|
@ -116,8 +116,11 @@ class MyTime:
|
||||||
#
|
#
|
||||||
# @returns number (calculated seconds from expression "val")
|
# @returns number (calculated seconds from expression "val")
|
||||||
|
|
||||||
#@staticmethod
|
@staticmethod
|
||||||
def str2seconds(val):
|
def str2seconds(val):
|
||||||
|
# replace together standing abbreviations, example '1d12h' -> '1d 12h':
|
||||||
|
val = re.sub(r"(?i)(?<=[a-z])(\d)", r" \1", val)
|
||||||
|
# replace abbreviation with expression:
|
||||||
for rexp, rpl in (
|
for rexp, rpl in (
|
||||||
(r"days?|da|dd?", 24*60*60), (r"week?|wee?|ww?", 7*24*60*60), (r"months?|mon?", (365*3+366)*24*60*60/4/12), (r"years?|yea?|yy?", (365*3+366)*24*60*60/4),
|
(r"days?|da|dd?", 24*60*60), (r"week?|wee?|ww?", 7*24*60*60), (r"months?|mon?", (365*3+366)*24*60*60/4/12), (r"years?|yea?|yy?", (365*3+366)*24*60*60/4),
|
||||||
(r"seconds?|sec?|ss?", 1), (r"minutes?|min?|mm?", 60), (r"hours?|ho|hh?", 60*60),
|
(r"seconds?|sec?|ss?", 1), (r"minutes?|min?|mm?", 60), (r"hours?|ho|hh?", 60*60),
|
||||||
|
@ -125,4 +128,3 @@ class MyTime:
|
||||||
val = re.sub(r"(?i)(?<=[\d\s])(%s)\b" % rexp, "*"+str(rpl), val)
|
val = re.sub(r"(?i)(?<=[\d\s])(%s)\b" % rexp, "*"+str(rpl), val)
|
||||||
val = re.sub(r"(\d)\s+(\d)", r"\1+\2", val);
|
val = re.sub(r"(\d)\s+(\d)", r"\1+\2", val);
|
||||||
return eval(val)
|
return eval(val)
|
||||||
str2seconds = staticmethod(str2seconds)
|
|
||||||
|
|
|
@ -216,7 +216,7 @@ class Transmitter:
|
||||||
return self.__server.getUseDns(name)
|
return self.__server.getUseDns(name)
|
||||||
elif command[1] == "findtime":
|
elif command[1] == "findtime":
|
||||||
value = command[2]
|
value = command[2]
|
||||||
self.__server.setFindTime(name, int(value))
|
self.__server.setFindTime(name, value)
|
||||||
return self.__server.getFindTime(name)
|
return self.__server.getFindTime(name)
|
||||||
elif command[1] == "datepattern":
|
elif command[1] == "datepattern":
|
||||||
value = command[2]
|
value = command[2]
|
||||||
|
@ -233,7 +233,7 @@ class Transmitter:
|
||||||
# command
|
# command
|
||||||
elif command[1] == "bantime":
|
elif command[1] == "bantime":
|
||||||
value = command[2]
|
value = command[2]
|
||||||
self.__server.setBanTime(name, int(value))
|
self.__server.setBanTime(name, value)
|
||||||
return self.__server.getBanTime(name)
|
return self.__server.getBanTime(name)
|
||||||
elif command[1] == "banip":
|
elif command[1] == "banip":
|
||||||
value = command[2]
|
value = command[2]
|
||||||
|
|
|
@ -668,7 +668,7 @@ class JailsReaderTest(LogCaptureTestCase):
|
||||||
self.assertEqual(sorted(commands),
|
self.assertEqual(sorted(commands),
|
||||||
[['set', 'dbfile',
|
[['set', 'dbfile',
|
||||||
'/var/lib/fail2ban/fail2ban.sqlite3'],
|
'/var/lib/fail2ban/fail2ban.sqlite3'],
|
||||||
['set', 'dbpurgeage', 86400],
|
['set', 'dbpurgeage', '1d'],
|
||||||
['set', 'loglevel', "INFO"],
|
['set', 'loglevel', "INFO"],
|
||||||
['set', 'logtarget', '/var/log/fail2ban.log'],
|
['set', 'logtarget', '/var/log/fail2ban.log'],
|
||||||
['set', 'syslogsocket', 'auto']])
|
['set', 'syslogsocket', 'auto']])
|
||||||
|
|
|
@ -70,6 +70,15 @@ class DatabaseTest(LogCaptureTestCase):
|
||||||
return
|
return
|
||||||
self.assertEqual(self.dbFilename, self.db.filename)
|
self.assertEqual(self.dbFilename, self.db.filename)
|
||||||
|
|
||||||
|
def testPurgeAge(self):
|
||||||
|
if Fail2BanDb is None: # pragma: no cover
|
||||||
|
return
|
||||||
|
self.assertEqual(self.db.purgeage, 86400)
|
||||||
|
self.db.purgeage = '1y6mon15d5h30m'
|
||||||
|
self.assertEqual(self.db.purgeage, 48652200)
|
||||||
|
self.db.purgeage = '2y 12mon 30d 10h 60m'
|
||||||
|
self.assertEqual(self.db.purgeage, 48652200*2)
|
||||||
|
|
||||||
def testCreateInvalidPath(self):
|
def testCreateInvalidPath(self):
|
||||||
if Fail2BanDb is None: # pragma: no cover
|
if Fail2BanDb is None: # pragma: no cover
|
||||||
return
|
return
|
||||||
|
|
|
@ -259,6 +259,7 @@ class Transmitter(TransmitterBase):
|
||||||
def testJailFindTime(self):
|
def testJailFindTime(self):
|
||||||
self.setGetTest("findtime", "120", 120, jail=self.jailName)
|
self.setGetTest("findtime", "120", 120, jail=self.jailName)
|
||||||
self.setGetTest("findtime", "60", 60, jail=self.jailName)
|
self.setGetTest("findtime", "60", 60, jail=self.jailName)
|
||||||
|
self.setGetTest("findtime", "30m", 30*60, jail=self.jailName)
|
||||||
self.setGetTest("findtime", "-60", -60, jail=self.jailName)
|
self.setGetTest("findtime", "-60", -60, jail=self.jailName)
|
||||||
self.setGetTestNOK("findtime", "Dog", jail=self.jailName)
|
self.setGetTestNOK("findtime", "Dog", jail=self.jailName)
|
||||||
|
|
||||||
|
@ -266,6 +267,7 @@ class Transmitter(TransmitterBase):
|
||||||
self.setGetTest("bantime", "600", 600, jail=self.jailName)
|
self.setGetTest("bantime", "600", 600, jail=self.jailName)
|
||||||
self.setGetTest("bantime", "50", 50, jail=self.jailName)
|
self.setGetTest("bantime", "50", 50, jail=self.jailName)
|
||||||
self.setGetTest("bantime", "-50", -50, jail=self.jailName)
|
self.setGetTest("bantime", "-50", -50, jail=self.jailName)
|
||||||
|
self.setGetTest("bantime", "15d 5h 30m", 1315800, jail=self.jailName)
|
||||||
self.setGetTestNOK("bantime", "Cat", jail=self.jailName)
|
self.setGetTestNOK("bantime", "Cat", jail=self.jailName)
|
||||||
|
|
||||||
def testDatePattern(self):
|
def testDatePattern(self):
|
||||||
|
|
Loading…
Reference in New Issue