mirror of https://github.com/fail2ban/fail2ban
Merge pull request #172 from kwirk/minor
Minor tweaks -- removing duplication and improving testingpull/145/merge
commit
12f1398ec1
|
@ -14,5 +14,5 @@ install:
|
||||||
script:
|
script:
|
||||||
- if [[ $TRAVIS_PYTHON_VERSION == 2.7 ]]; then export PYTHONPATH="$PYTHONPATH:/usr/share/pyshared:/usr/lib/pyshared/python2.7"; fi
|
- if [[ $TRAVIS_PYTHON_VERSION == 2.7 ]]; then export PYTHONPATH="$PYTHONPATH:/usr/share/pyshared:/usr/lib/pyshared/python2.7"; fi
|
||||||
- if [[ $TRAVIS_PYTHON_VERSION == 2.7 ]]; then coverage run --rcfile=.travis_coveragerc fail2ban-testcases; else python ./fail2ban-testcases; fi
|
- if [[ $TRAVIS_PYTHON_VERSION == 2.7 ]]; then coverage run --rcfile=.travis_coveragerc fail2ban-testcases; else python ./fail2ban-testcases; fi
|
||||||
after_script:
|
after_success:
|
||||||
- if [[ $TRAVIS_PYTHON_VERSION == 2.7 ]]; then coveralls; fi
|
- if [[ $TRAVIS_PYTHON_VERSION == 2.7 ]]; then coveralls; fi
|
||||||
|
|
|
@ -297,10 +297,8 @@ class Action:
|
||||||
if not Action.executeCmd(checkCmd):
|
if not Action.executeCmd(checkCmd):
|
||||||
logSys.error("Invariant check failed. Trying to restore a sane" +
|
logSys.error("Invariant check failed. Trying to restore a sane" +
|
||||||
" environment")
|
" environment")
|
||||||
stopCmd = Action.replaceTag(self.__actionStop, self.__cInfo)
|
self.execActionStop()
|
||||||
Action.executeCmd(stopCmd)
|
self.execActionStart()
|
||||||
startCmd = Action.replaceTag(self.__actionStart, self.__cInfo)
|
|
||||||
Action.executeCmd(startCmd)
|
|
||||||
if not Action.executeCmd(checkCmd):
|
if not Action.executeCmd(checkCmd):
|
||||||
logSys.fatal("Unable to restore environment")
|
logSys.fatal("Unable to restore environment")
|
||||||
return False
|
return False
|
||||||
|
|
|
@ -66,7 +66,7 @@ class Server:
|
||||||
|
|
||||||
# First set the mask to only allow access to owner
|
# First set the mask to only allow access to owner
|
||||||
os.umask(0077)
|
os.umask(0077)
|
||||||
if self.__daemon:
|
if self.__daemon: # pragma: no cover
|
||||||
logSys.info("Starting in daemon mode")
|
logSys.info("Starting in daemon mode")
|
||||||
ret = self.__createDaemon()
|
ret = self.__createDaemon()
|
||||||
if ret:
|
if ret:
|
||||||
|
@ -379,7 +379,7 @@ class Server:
|
||||||
try:
|
try:
|
||||||
handler.flush()
|
handler.flush()
|
||||||
handler.close()
|
handler.close()
|
||||||
except (ValueError, KeyError):
|
except (ValueError, KeyError): # pragma: no cover
|
||||||
if sys.version_info >= (2,6):
|
if sys.version_info >= (2,6):
|
||||||
raise
|
raise
|
||||||
# is known to be thrown after logging was shutdown once
|
# is known to be thrown after logging was shutdown once
|
||||||
|
@ -404,7 +404,7 @@ class Server:
|
||||||
finally:
|
finally:
|
||||||
self.__loggingLock.release()
|
self.__loggingLock.release()
|
||||||
|
|
||||||
def __createDaemon(self):
|
def __createDaemon(self): # pragma: no cover
|
||||||
""" Detach a process from the controlling terminal and run it in the
|
""" Detach a process from the controlling terminal and run it in the
|
||||||
background as a daemon.
|
background as a daemon.
|
||||||
|
|
||||||
|
|
|
@ -61,6 +61,23 @@ class ExecuteAction(unittest.TestCase):
|
||||||
def _is_logged(self, s):
|
def _is_logged(self, s):
|
||||||
return s in self._log.getvalue()
|
return s in self._log.getvalue()
|
||||||
|
|
||||||
|
def testReplaceTag(self):
|
||||||
|
aInfo = {
|
||||||
|
'HOST': "192.0.2.0",
|
||||||
|
'ABC': "123",
|
||||||
|
'xyz': "890",
|
||||||
|
}
|
||||||
|
self.assertEqual(
|
||||||
|
self.__action.replaceTag("Text <HOST> text", aInfo),
|
||||||
|
"Text 192.0.2.0 text")
|
||||||
|
self.assertEqual(
|
||||||
|
self.__action.replaceTag("Text <xyz> text <ABC> ABC", aInfo),
|
||||||
|
"Text 890 text 123 ABC")
|
||||||
|
self.assertEqual(
|
||||||
|
self.__action.replaceTag("<matches>",
|
||||||
|
{'matches': "some >char< should \< be[ escap}ed&"}),
|
||||||
|
r"some \>char\< should \\\< be\[ escap\}ed\&")
|
||||||
|
|
||||||
def testExecuteActionBan(self):
|
def testExecuteActionBan(self):
|
||||||
self.__action.setActionStart("touch /tmp/fail2ban.test")
|
self.__action.setActionStart("touch /tmp/fail2ban.test")
|
||||||
self.__action.setActionStop("rm -f /tmp/fail2ban.test")
|
self.__action.setActionStop("rm -f /tmp/fail2ban.test")
|
||||||
|
|
|
@ -504,7 +504,9 @@ class TransmitterLogging(TransmitterBase):
|
||||||
|
|
||||||
def testLogLevel(self):
|
def testLogLevel(self):
|
||||||
self.setGetTest("loglevel", "4", 4)
|
self.setGetTest("loglevel", "4", 4)
|
||||||
|
self.setGetTest("loglevel", "3", 3)
|
||||||
self.setGetTest("loglevel", "2", 2)
|
self.setGetTest("loglevel", "2", 2)
|
||||||
|
self.setGetTest("loglevel", "1", 1)
|
||||||
self.setGetTest("loglevel", "-1", -1)
|
self.setGetTest("loglevel", "-1", -1)
|
||||||
self.setGetTest("loglevel", "0", 0)
|
self.setGetTest("loglevel", "0", 0)
|
||||||
self.setGetTestNOK("loglevel", "Bird")
|
self.setGetTestNOK("loglevel", "Bird")
|
||||||
|
|
Loading…
Reference in New Issue