github
/
fail2ban
mirror of https://github.com/fail2ban/fail2ban
1
0
Fork 0
Code Issues Releases Wiki Activity

Merge python-3.12--asyncore: python 3.12 support, see gh-3487

Browse Source
test-3.13.0-alpha.2
sebres 12 months ago
parent 7076af637f 340d45ca88
commit 4e326cb5cb
5 changed files with 163 additions and 152 deletions
Show Stats Download Patch File Download Diff File

9
.github/workflows/main.yml vendored
Unescape View File

@ -22,7 +22,7 @@ jobs:
runs-on: ubuntu-20.04 runs-on: ubuntu-20.04
strategy: strategy:
matrix: matrix:
python-version: [3.6, 3.7, 3.8, 3.9, '3.10', '3.11', pypy3.10] python-version: [3.6, 3.7, 3.8, 3.9, '3.10', '3.11', '3.12', pypy3.10]
fail-fast: false fail-fast: false
# Steps represent a sequence of tasks that will be executed as part of the job # Steps represent a sequence of tasks that will be executed as part of the job
steps: steps:
@ -59,6 +59,13 @@ jobs:
python -m pip install systemd-python || echo 'systemd not available' python -m pip install systemd-python || echo 'systemd not available'
#readline if available as module: #readline if available as module:
python -c 'import readline' 2> /dev/null || python -m pip install readline || echo 'readline not available' python -c 'import readline' 2> /dev/null || python -m pip install readline || echo 'readline not available'
# asyncore/asynchat:
if dpkg --compare-versions "$F2B_PYV" ge 3.12; then
#sudo apt-get -y install python${F2B_PY/2/}-setuptools || echo 'setuptools not unavailable'
python -m pip install setuptools || echo "can't install setuptools"
python -m pip install pyasynchat || echo "can't install pyasynchat";
python -m pip install pyasyncore || echo "can't install pyasyncore";
fi
- name: Before scripts - name: Before scripts
run: | run: |

2
fail2ban/helpers.py
Unescape View File

@ -284,7 +284,7 @@ def splitwords(s):
""" """
if not s: if not s:
return [] return []
return list(filter(bool, [v.strip() for v in re.split('[\s,]+', s)])) return list(filter(bool, [v.strip() for v in re.split(r'[\s,]+', s)]))
def _merge_dicts(x, y): def _merge_dicts(x, y):
"""Helper to merge dicts. """Helper to merge dicts.

264
fail2ban/tests/action_d/test_smtp.py
Unescape View File

@ -18,7 +18,6 @@
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. # Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
import os import os
import smtpd
import threading import threading
import unittest import unittest
import re import re
@ -29,134 +28,139 @@ else:
import imp import imp
from ..dummyjail import DummyJail from ..dummyjail import DummyJail
from ..utils import CONFIG_DIR, asyncserver, Utils, uni_decode from ..utils import CONFIG_DIR, asyncserver, Utils, uni_decode
class TestSMTPServer(smtpd.SMTPServer): try:
import smtpd
def __init__(self, *args):
smtpd.SMTPServer.__init__(self, *args) class TestSMTPServer(smtpd.SMTPServer):
self.ready = False
def __init__(self, *args):
def process_message(self, peer, mailfrom, rcpttos, data, **kwargs): smtpd.SMTPServer.__init__(self, *args)
self.peer = peer self.ready = False
self.mailfrom = mailfrom
self.rcpttos = rcpttos def process_message(self, peer, mailfrom, rcpttos, data, **kwargs):
self.org_data = data self.peer = peer
# replace new line (with tab or space) for possible mime translations (word wrap), self.mailfrom = mailfrom
self.data = re.sub(r"\n[\t ]", " ", uni_decode(data)) self.rcpttos = rcpttos
self.ready = True self.org_data = data
# replace new line (with tab or space) for possible mime translations (word wrap),
self.data = re.sub(r"\n[\t ]", " ", uni_decode(data))
class SMTPActionTest(unittest.TestCase): self.ready = True
def setUp(self):
"""Call before every test case.""" class SMTPActionTest(unittest.TestCase):
unittest.F2B.SkipIfCfgMissing(action='smtp.py')
super(SMTPActionTest, self).setUp() def setUp(self):
self.jail = DummyJail() """Call before every test case."""
pythonModule = os.path.join(CONFIG_DIR, "action.d", "smtp.py") unittest.F2B.SkipIfCfgMissing(action='smtp.py')
pythonModuleName = os.path.basename(pythonModule.rstrip(".py")) super(SMTPActionTest, self).setUp()
if sys.version_info >= (3, 3): self.jail = DummyJail()
customActionModule = importlib.machinery.SourceFileLoader( pythonModule = os.path.join(CONFIG_DIR, "action.d", "smtp.py")
pythonModuleName, pythonModule).load_module() pythonModuleName = os.path.basename(pythonModule.rstrip(".py"))
else: if sys.version_info >= (3, 3):
customActionModule = imp.load_source( customActionModule = importlib.machinery.SourceFileLoader(
pythonModuleName, pythonModule) pythonModuleName, pythonModule).load_module()
else:
self.smtpd = TestSMTPServer(("localhost", 0), None) customActionModule = imp.load_source(
port = self.smtpd.socket.getsockname()[1] pythonModuleName, pythonModule)
self.action = customActionModule.Action( self.smtpd = TestSMTPServer(("localhost", 0), None)
self.jail, "test", host="localhost:%i" % port) port = self.smtpd.socket.getsockname()[1]
## because of bug in loop (see loop in asyncserver.py) use it's loop instead of asyncore.loop: self.action = customActionModule.Action(
self._active = True self.jail, "test", host="localhost:%i" % port)
self._loop_thread = threading.Thread(
target=asyncserver.loop, kwargs={'active': lambda: self._active}) ## because of bug in loop (see loop in asyncserver.py) use it's loop instead of asyncore.loop:
self._loop_thread.daemon = True self._active = True
self._loop_thread.start() self._loop_thread = threading.Thread(
target=asyncserver.loop, kwargs={'active': lambda: self._active})
def tearDown(self): self._loop_thread.daemon = True
"""Call after every test case.""" self._loop_thread.start()
self.smtpd.close()
self._active = False def tearDown(self):
self._loop_thread.join() """Call after every test case."""
super(SMTPActionTest, self).tearDown() self.smtpd.close()
self._active = False
def _exec_and_wait(self, doaction, timeout=3, short=False): self._loop_thread.join()
if short: timeout /= 25 super(SMTPActionTest, self).tearDown()
self.smtpd.ready = False
doaction() def _exec_and_wait(self, doaction, timeout=3, short=False):
Utils.wait_for(lambda: self.smtpd.ready, timeout) if short: timeout /= 25
self.smtpd.ready = False
def testStart(self): doaction()
self._exec_and_wait(self.action.start) Utils.wait_for(lambda: self.smtpd.ready, timeout)
self.assertEqual(self.smtpd.mailfrom, "fail2ban")
self.assertEqual(self.smtpd.rcpttos, ["root"]) def testStart(self):
self.assertTrue( self._exec_and_wait(self.action.start)
"Subject: [Fail2Ban] %s: started" % self.jail.name self.assertEqual(self.smtpd.mailfrom, "fail2ban")
in self.smtpd.data) self.assertEqual(self.smtpd.rcpttos, ["root"])
self.assertTrue(
def testStop(self): "Subject: [Fail2Ban] %s: started" % self.jail.name
self._exec_and_wait(self.action.stop) in self.smtpd.data)
self.assertEqual(self.smtpd.mailfrom, "fail2ban")
self.assertEqual(self.smtpd.rcpttos, ["root"]) def testStop(self):
self.assertTrue( self._exec_and_wait(self.action.stop)
"Subject: [Fail2Ban] %s: stopped" % self.assertEqual(self.smtpd.mailfrom, "fail2ban")
self.jail.name in self.smtpd.data) self.assertEqual(self.smtpd.rcpttos, ["root"])
self.assertTrue(
def _testBan(self, restored=False): "Subject: [Fail2Ban] %s: stopped" %
aInfo = { self.jail.name in self.smtpd.data)
'ip': "127.0.0.2",
'failures': 3, def _testBan(self, restored=False):
'matches': "Test fail 1\n", aInfo = {
'ipjailmatches': "Test fail 1\nTest Fail2\n", 'ip': "127.0.0.2",
'ipmatches': "Test fail 1\nTest Fail2\nTest Fail3\n", 'failures': 3,
} 'matches': "Test fail 1\n",
if restored: 'ipjailmatches': "Test fail 1\nTest Fail2\n",
aInfo['restored'] = 1 'ipmatches': "Test fail 1\nTest Fail2\nTest Fail3\n",
}
self._exec_and_wait(lambda: self.action.ban(aInfo), short=restored) if restored:
if restored: # no mail, should raises attribute error: aInfo['restored'] = 1
self.assertRaises(AttributeError, lambda: self.smtpd.mailfrom)
return self._exec_and_wait(lambda: self.action.ban(aInfo), short=restored)
self.assertEqual(self.smtpd.mailfrom, "fail2ban") if restored: # no mail, should raises attribute error:
self.assertEqual(self.smtpd.rcpttos, ["root"]) self.assertRaises(AttributeError, lambda: self.smtpd.mailfrom)
subject = "Subject: [Fail2Ban] %s: banned %s" % ( return
self.jail.name, aInfo['ip']) self.assertEqual(self.smtpd.mailfrom, "fail2ban")
self.assertIn(subject, self.smtpd.data) self.assertEqual(self.smtpd.rcpttos, ["root"])
self.assertIn( subject = "Subject: [Fail2Ban] %s: banned %s" % (
"%i attempts" % aInfo['failures'], self.smtpd.data) self.jail.name, aInfo['ip'])
self.assertIn(subject, self.smtpd.data)
self.action.matches = "matches" self.assertIn(
self._exec_and_wait(lambda: self.action.ban(aInfo)) "%i attempts" % aInfo['failures'], self.smtpd.data)
self.assertIn(aInfo['matches'], self.smtpd.data)
self.action.matches = "matches"
self.action.matches = "ipjailmatches" self._exec_and_wait(lambda: self.action.ban(aInfo))
self._exec_and_wait(lambda: self.action.ban(aInfo)) self.assertIn(aInfo['matches'], self.smtpd.data)
self.assertIn(aInfo['ipjailmatches'], self.smtpd.data)
self.action.matches = "ipjailmatches"
self.action.matches = "ipmatches" self._exec_and_wait(lambda: self.action.ban(aInfo))
self._exec_and_wait(lambda: self.action.ban(aInfo)) self.assertIn(aInfo['ipjailmatches'], self.smtpd.data)
self.assertIn(aInfo['ipmatches'], self.smtpd.data)
self.action.matches = "ipmatches"
def testBan(self): self._exec_and_wait(lambda: self.action.ban(aInfo))
self._testBan() self.assertIn(aInfo['ipmatches'], self.smtpd.data)
def testNOPByRestored(self): def testBan(self):
self._testBan(restored=True) self._testBan()
def testOptions(self): def testNOPByRestored(self):
self._exec_and_wait(self.action.start) self._testBan(restored=True)
self.assertEqual(self.smtpd.mailfrom, "fail2ban")
self.assertEqual(self.smtpd.rcpttos, ["root"]) def testOptions(self):
self._exec_and_wait(self.action.start)
self.action.fromname = "Test" self.assertEqual(self.smtpd.mailfrom, "fail2ban")
self.action.fromaddr = "test@example.com" self.assertEqual(self.smtpd.rcpttos, ["root"])
self.action.toaddr = "test@example.com, test2@example.com"
self._exec_and_wait(self.action.start) self.action.fromname = "Test"
self.assertEqual(self.smtpd.mailfrom, "test@example.com") self.action.fromaddr = "test@example.com"
self.assertTrue("From: %s <%s>" % self.action.toaddr = "test@example.com, test2@example.com"
(self.action.fromname, self.action.fromaddr) in self.smtpd.data) self._exec_and_wait(self.action.start)
self.assertEqual(set(self.smtpd.rcpttos), set(["test@example.com", "test2@example.com"])) self.assertEqual(self.smtpd.mailfrom, "test@example.com")
self.assertTrue("From: %s <%s>" %
(self.action.fromname, self.action.fromaddr) in self.smtpd.data)
self.assertEqual(set(self.smtpd.rcpttos), set(["test@example.com", "test2@example.com"]))
except ImportError as e:
print("I: Skipping smtp tests: %s" % e)

16
fail2ban/tests/fail2banregextestcase.py
Unescape View File

@ -221,7 +221,7 @@ class Fail2banRegexTest(LogCaptureTestCase):
self.pruneLog() self.pruneLog()
self.assertTrue(_test_exec( self.assertTrue(_test_exec(
"-d", "^Epoch", "-d", "^Epoch",
"1490349000 test failed.dns.ch", "^\s*test <F-ID>\S+</F-ID>" "1490349000 test failed.dns.ch", r"^\s*test <F-ID>\S+</F-ID>"
)) ))
self.assertLogged('Lines: 1 lines, 0 ignored, 1 matched, 0 missed', all=True) self.assertLogged('Lines: 1 lines, 0 ignored, 1 matched, 0 missed', all=True)
self.assertNotLogged('Unable to find a corresponding IP address') self.assertNotLogged('Unable to find a corresponding IP address')
@ -229,7 +229,7 @@ class Fail2banRegexTest(LogCaptureTestCase):
self.pruneLog() self.pruneLog()
self.assertTrue(_test_exec( self.assertTrue(_test_exec(
"-d", "^Epoch", "-o", "id", "-d", "^Epoch", "-o", "id",
"1490349000 test this/is/some/path/32", "^\s*test <F-ID>\S+</F-ID>" "1490349000 test this/is/some/path/32", r"^\s*test <F-ID>\S+</F-ID>"
)) ))
self.assertLogged('this/is/some/path/32', all=True) self.assertLogged('this/is/some/path/32', all=True)
@ -439,23 +439,23 @@ class Fail2banRegexTest(LogCaptureTestCase):
# with different ID/IP from failregex (ID/User from first, IP from second message): # with different ID/IP from failregex (ID/User from first, IP from second message):
self.assertTrue(_test('-o', 'ID:"<fid>" | IP:<ip> | U:<F-USER>', log, self.assertTrue(_test('-o', 'ID:"<fid>" | IP:<ip> | U:<F-USER>', log,
flt+'[failregex="' flt+'[failregex="'
'^'+prefix+'<F-ID>User <F-USER>\S+</F-USER></F-ID> not allowed\n' '^'+prefix+r'<F-ID>User <F-USER>\S+</F-USER></F-ID> not allowed'+'\n'
'^'+prefix+'Received disconnect from <ADDR>' '^'+prefix+r'Received disconnect from <ADDR>'
'"]')) '"]'))
self.assertLogged('ID:"User root" | IP:192.0.2.76 | U:root') self.assertLogged('ID:"User root" | IP:192.0.2.76 | U:root')
self.pruneLog() self.pruneLog()
# with different ID/IP from failregex (User from first, ID and IP from second message): # with different ID/IP from failregex (User from first, ID and IP from second message):
self.assertTrue(_test('-o', 'ID:"<fid>" | IP:<ip> | U:<F-USER>', log, self.assertTrue(_test('-o', 'ID:"<fid>" | IP:<ip> | U:<F-USER>', log,
flt+'[failregex="' flt+'[failregex="'
'^'+prefix+'User <F-USER>\S+</F-USER> not allowed\n' '^'+prefix+r'User <F-USER>\S+</F-USER> not allowed'+'\n'
'^'+prefix+'Received disconnect from <F-ID><ADDR> port \d+</F-ID>' '^'+prefix+r'Received disconnect from <F-ID><ADDR> port \d+</F-ID>'
'"]')) '"]'))
self.assertLogged('ID:"192.0.2.76 port 58846" | IP:192.0.2.76 | U:root') self.assertLogged('ID:"192.0.2.76 port 58846" | IP:192.0.2.76 | U:root')
self.pruneLog() self.pruneLog()
# first with sshd and prefregex: # first with sshd and prefregex:
_test_variants() _test_variants()
# the same without prefregex and MLFID directly in failregex (no merge with prefregex groups): # the same without prefregex and MLFID directly in failregex (no merge with prefregex groups):
_test_variants('common', prefix="\s*\S+ sshd\[<F-MLFID>\d+</F-MLFID>\]:\s+") _test_variants('common', prefix=r"\s*\S+ sshd\[<F-MLFID>\d+</F-MLFID>\]:\s+")
def testNoDateTime(self): def testNoDateTime(self):
# datepattern doesn't match: # datepattern doesn't match:
@ -541,7 +541,7 @@ class Fail2banRegexTest(LogCaptureTestCase):
'svc[2] connect started 192.0.2.4\n' 'svc[2] connect started 192.0.2.4\n'
'svc[2] connect authorized 192.0.2.4\n' 'svc[2] connect authorized 192.0.2.4\n'
'svc[2] connect finished 192.0.2.4\n', 'svc[2] connect finished 192.0.2.4\n',
'common[prefregex="^svc\[<F-MLFID>\d+</F-MLFID>\] connect <F-CONTENT>.+</F-CONTENT>$"' r'common[prefregex="^svc\[<F-MLFID>\d+</F-MLFID>\] connect <F-CONTENT>.+</F-CONTENT>$"'
', failregex="' ', failregex="'
'^started\n' '^started\n'
'^<F-NOFAIL><F-MLFFORGET>finished</F-MLFFORGET></F-NOFAIL> <ADDR>\n' '^<F-NOFAIL><F-MLFFORGET>finished</F-MLFFORGET></F-NOFAIL> <ADDR>\n'

24
fail2ban/tests/servertestcase.py
Unescape View File

@ -1372,12 +1372,12 @@ class ServerConfigReaderTests(LogCaptureTestCase):
"`{ nft flush set inet f2b-table addr6-set-j-w-nft-mp 2> /dev/null; } || ", "`{ nft flush set inet f2b-table addr6-set-j-w-nft-mp 2> /dev/null; } || ",
), ),
'stop': ( 'stop': (
"`{ nft -a list chain inet f2b-table f2b-chain | grep -oP '@addr-set-j-w-nft-mp\s+.*\s+\Khandle\s+(\d+)$'; } | while read -r hdl; do`", r"`{ nft -a list chain inet f2b-table f2b-chain | grep -oP '@addr-set-j-w-nft-mp\s+.*\s+\Khandle\s+(\d+)$'; } | while read -r hdl; do`",
"`nft delete rule inet f2b-table f2b-chain $hdl; done`", r"`nft delete rule inet f2b-table f2b-chain $hdl; done`",
"`nft delete set inet f2b-table addr-set-j-w-nft-mp`", r"`nft delete set inet f2b-table addr-set-j-w-nft-mp`",
"`{ nft -a list chain inet f2b-table f2b-chain | grep -oP '@addr6-set-j-w-nft-mp\s+.*\s+\Khandle\s+(\d+)$'; } | while read -r hdl; do`", r"`{ nft -a list chain inet f2b-table f2b-chain | grep -oP '@addr6-set-j-w-nft-mp\s+.*\s+\Khandle\s+(\d+)$'; } | while read -r hdl; do`",
"`nft delete rule inet f2b-table f2b-chain $hdl; done`", r"`nft delete rule inet f2b-table f2b-chain $hdl; done`",
"`nft delete set inet f2b-table addr6-set-j-w-nft-mp`", r"`nft delete set inet f2b-table addr6-set-j-w-nft-mp`",
), ),
'ip4-check': ( 'ip4-check': (
r"`nft list chain inet f2b-table f2b-chain | grep -q '@addr-set-j-w-nft-mp[ \t]'`", r"`nft list chain inet f2b-table f2b-chain | grep -q '@addr-set-j-w-nft-mp[ \t]'`",
@ -1418,12 +1418,12 @@ class ServerConfigReaderTests(LogCaptureTestCase):
"`{ nft flush set inet f2b-table addr6-set-j-w-nft-ap 2> /dev/null; } || ", "`{ nft flush set inet f2b-table addr6-set-j-w-nft-ap 2> /dev/null; } || ",
), ),
'stop': ( 'stop': (
"`{ nft -a list chain inet f2b-table f2b-chain | grep -oP '@addr-set-j-w-nft-ap\s+.*\s+\Khandle\s+(\d+)$'; } | while read -r hdl; do`", r"`{ nft -a list chain inet f2b-table f2b-chain | grep -oP '@addr-set-j-w-nft-ap\s+.*\s+\Khandle\s+(\d+)$'; } | while read -r hdl; do`",
"`nft delete rule inet f2b-table f2b-chain $hdl; done`", r"`nft delete rule inet f2b-table f2b-chain $hdl; done`",
"`nft delete set inet f2b-table addr-set-j-w-nft-ap`", r"`nft delete set inet f2b-table addr-set-j-w-nft-ap`",
"`{ nft -a list chain inet f2b-table f2b-chain | grep -oP '@addr6-set-j-w-nft-ap\s+.*\s+\Khandle\s+(\d+)$'; } | while read -r hdl; do`", r"`{ nft -a list chain inet f2b-table f2b-chain | grep -oP '@addr6-set-j-w-nft-ap\s+.*\s+\Khandle\s+(\d+)$'; } | while read -r hdl; do`",
"`nft delete rule inet f2b-table f2b-chain $hdl; done`", r"`nft delete rule inet f2b-table f2b-chain $hdl; done`",
"`nft delete set inet f2b-table addr6-set-j-w-nft-ap`", r"`nft delete set inet f2b-table addr6-set-j-w-nft-ap`",
), ),
'ip4-check': ( 'ip4-check': (
r"""`nft list chain inet f2b-table f2b-chain | grep -q '@addr-set-j-w-nft-ap[ \t]'`""", r"""`nft list chain inet f2b-table f2b-chain | grep -q '@addr-set-j-w-nft-ap[ \t]'`""",

Write Preview
Loading…
Cancel
Save