| OLD | NEW |
| 1 # This file is part of the Adblock Plus web scripts, | 1 # This file is part of the Adblock Plus web scripts, |
| 2 # Copyright (C) 2006-2016 Eyeo GmbH | 2 # Copyright (C) 2006-2016 Eyeo GmbH |
| 3 # | 3 # |
| 4 # Adblock Plus is free software: you can redistribute it and/or modify | 4 # Adblock Plus is free software: you can redistribute it and/or modify |
| 5 # it under the terms of the GNU General Public License version 3 as | 5 # it under the terms of the GNU General Public License version 3 as |
| 6 # published by the Free Software Foundation. | 6 # published by the Free Software Foundation. |
| 7 # | 7 # |
| 8 # Adblock Plus is distributed in the hope that it will be useful, | 8 # Adblock Plus is distributed in the hope that it will be useful, |
| 9 # but WITHOUT ANY WARRANTY; without even the implied warranty of | 9 # but WITHOUT ANY WARRANTY; without even the implied warranty of |
| 10 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | 10 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
| 11 # GNU General Public License for more details. | 11 # GNU General Public License for more details. |
| 12 # | 12 # |
| 13 # You should have received a copy of the GNU General Public License | 13 # You should have received a copy of the GNU General Public License |
| 14 # along with Adblock Plus. If not, see <http://www.gnu.org/licenses/>. | 14 # along with Adblock Plus. If not, see <http://www.gnu.org/licenses/>. |
| 15 | 15 |
| 16 import os | 16 import os |
| 17 import subprocess | 17 import subprocess |
| 18 import codecs | 18 import codecs |
| 19 import contextlib |
| 19 import urllib2 | 20 import urllib2 |
| 20 import zipfile | 21 import zipfile |
| 21 import tempfile | 22 import tempfile |
| 22 import shutil | 23 import shutil |
| 23 import sys | 24 import sys |
| 24 from StringIO import StringIO | 25 from StringIO import StringIO |
| 25 from sitescripts.utils import get_config | 26 from sitescripts.utils import get_config |
| 26 | 27 |
| 27 | 28 |
| 28 FILTERLIST_HEADER = '''[Adblock Plus 1.1] | 29 FILTERLIST_HEADER = '''[Adblock Plus 1.1] |
| 29 ! This is a list of malware domains generated from malwaredomains.com data. | 30 ! This is a list of malware domains generated from malwaredomains.com data. |
| 30 ! Homepage: http://malwaredomains.com/?page_id=2 | 31 ! Homepage: http://malwaredomains.com/?page_id=2 |
| 31 ! Last modified: %timestamp% | 32 ! Last modified: %timestamp% |
| 32 ! Expires: 1d | 33 ! Expires: 1d |
| 33 !''' | 34 !''' |
| 34 | 35 |
| 35 MALWAREDOMAINS_PATH = '/files/justdomains.zip' | 36 MALWAREDOMAINS_PATH = '/files/justdomains.zip' |
| 36 | 37 |
| 37 | 38 |
| 38 def try_mirror(mirror): | 39 def try_mirror(mirror): |
| 40 url = mirror + MALWAREDOMAINS_PATH |
| 39 try: | 41 try: |
| 40 response = urllib2.urlopen(mirror + MALWAREDOMAINS_PATH) | 42 with contextlib.closing(urllib2.urlopen(url)) as response: |
| 41 return response.read() | 43 return None, response.read() |
| 42 except urllib2.HTTPError: | 44 except urllib2.HTTPError as exc: |
| 43 return None | 45 exc.close() |
| 46 except urllib2.URLError as exc: |
| 47 pass |
| 48 return 'Failed to fetch {}: {}'.format(url, exc), None |
| 44 | 49 |
| 45 | 50 |
| 46 if __name__ == '__main__': | 51 def main(): |
| 47 config = get_config() | 52 config = get_config() |
| 48 section = 'subscriptionDownloads' | 53 section = 'subscriptionDownloads' |
| 49 repository = config.get(section, 'malwaredomains_repository') | 54 repository = config.get(section, 'malwaredomains_repository') |
| 50 mirrors = config.get(section, 'malwaredomains_mirrors').split() | 55 mirrors = config.get(section, 'malwaredomains_mirrors').split() |
| 51 | 56 |
| 52 tempdir = tempfile.mkdtemp(prefix='malwaredomains') | 57 tempdir = tempfile.mkdtemp(prefix='malwaredomains') |
| 53 try: | 58 try: |
| 54 subprocess.check_call(['hg', '-q', 'clone', '-U', repository, tempdir]) | 59 subprocess.check_call(['hg', '-q', 'clone', '-U', repository, tempdir]) |
| 55 subprocess.check_call(['hg', '-q', 'up', '-R', tempdir, '-r', 'default']
) | 60 subprocess.check_call(['hg', '-q', 'up', '-R', tempdir, '-r', 'default']
) |
| 56 | 61 |
| 57 path = os.path.join(tempdir, 'malwaredomains_full.txt') | 62 path = os.path.join(tempdir, 'malwaredomains_full.txt') |
| 58 file = codecs.open(path, 'wb', encoding='utf-8') | 63 file = codecs.open(path, 'wb', encoding='utf-8') |
| 59 | 64 |
| 60 print >>file, FILTERLIST_HEADER | 65 print >>file, FILTERLIST_HEADER |
| 61 | 66 |
| 67 error_report = ['Unable to fetch malware domains list', 'Errors:'] |
| 62 for mirror in mirrors: | 68 for mirror in mirrors: |
| 63 data = try_mirror(mirror) | 69 error_message, data = try_mirror(mirror) |
| 64 if data is not None: | 70 if data is not None: |
| 65 break | 71 break |
| 72 error_report.append(error_message) |
| 66 else: | 73 else: |
| 67 sys.exit('Unable to fetch malware domains list.') | 74 sys.exit('\n'.join(error_report)) |
| 68 | 75 |
| 69 zip = zipfile.ZipFile(StringIO(data), 'r') | 76 zf = zipfile.ZipFile(StringIO(data), 'r') |
| 70 info = zip.infolist()[0] | 77 info = zf.infolist()[0] |
| 71 for line in str(zip.read(info.filename)).splitlines(): | 78 for line in str(zf.read(info.filename)).splitlines(): |
| 72 domain = line.strip() | 79 domain = line.strip() |
| 73 if not domain: | 80 if not domain: |
| 74 continue | 81 continue |
| 75 | 82 |
| 76 print >>file, '||%s^' % domain.decode('idna') | 83 print >>file, '||%s^' % domain.decode('idna') |
| 77 file.close() | 84 file.close() |
| 78 | 85 |
| 79 if subprocess.check_output(['hg', 'stat', '-R', tempdir]) != '': | 86 if subprocess.check_output(['hg', 'stat', '-R', tempdir]) != '': |
| 80 subprocess.check_call(['hg', '-q', 'commit', '-R', tempdir, '-A', '-
u', 'hgbot', '-m', 'Updated malwaredomains.com data']) | 87 subprocess.check_call(['hg', '-q', 'commit', '-R', tempdir, '-A', '-
u', 'hgbot', '-m', 'Updated malwaredomains.com data']) |
| 81 subprocess.check_call(['hg', '-q', 'push', '-R', tempdir]) | 88 subprocess.check_call(['hg', '-q', 'push', '-R', tempdir]) |
| 82 finally: | 89 finally: |
| 83 shutil.rmtree(tempdir, ignore_errors=True) | 90 shutil.rmtree(tempdir, ignore_errors=True) |
| 91 |
| 92 |
| 93 if __name__ == '__main__': |
| 94 main() |
| OLD | NEW |