Index: sitescripts/subscriptions/bin/updateMalwareDomainsList.py |
=================================================================== |
--- a/sitescripts/subscriptions/bin/updateMalwareDomainsList.py |
+++ b/sitescripts/subscriptions/bin/updateMalwareDomainsList.py |
@@ -11,16 +11,17 @@ |
# GNU General Public License for more details. |
# |
# You should have received a copy of the GNU General Public License |
# along with Adblock Plus. If not, see <http://www.gnu.org/licenses/>. |
import os |
import subprocess |
import codecs |
+import contextlib |
import urllib2 |
import zipfile |
import tempfile |
import shutil |
import sys |
from StringIO import StringIO |
from sitescripts.utils import get_config |
@@ -31,53 +32,63 @@ |
! Last modified: %timestamp% |
! Expires: 1d |
!''' |
MALWAREDOMAINS_PATH = '/files/justdomains.zip' |
def try_mirror(mirror): |
+ url = mirror + MALWAREDOMAINS_PATH |
try: |
- response = urllib2.urlopen(mirror + MALWAREDOMAINS_PATH) |
- return response.read() |
- except urllib2.HTTPError: |
- return None |
+ with contextlib.closing(urllib2.urlopen(url)) as response: |
+ return None, response.read() |
+ except urllib2.URLError as exc: |
+ error_message = 'Failed to fetch {}: {}'.format(url, exc) |
+ if hasattr(exc, 'close'): |
Vasily Kuznetsov
2017/01/19 16:34:08
I tried to do it with two separate except clauses
Sebastian Noack
2017/01/19 17:13:33
I don't see how that creates any duplication.
t
Vasily Kuznetsov
2017/01/20 13:44:49
Yeah, this is better. Thanks.
|
+ exc.close() |
+ return error_message, None |
-if __name__ == '__main__': |
+def main(): |
config = get_config() |
section = 'subscriptionDownloads' |
repository = config.get(section, 'malwaredomains_repository') |
mirrors = config.get(section, 'malwaredomains_mirrors').split() |
tempdir = tempfile.mkdtemp(prefix='malwaredomains') |
try: |
subprocess.check_call(['hg', '-q', 'clone', '-U', repository, tempdir]) |
subprocess.check_call(['hg', '-q', 'up', '-R', tempdir, '-r', 'default']) |
path = os.path.join(tempdir, 'malwaredomains_full.txt') |
file = codecs.open(path, 'wb', encoding='utf-8') |
print >>file, FILTERLIST_HEADER |
+ error_report = ['Unable to fetch malware domains list', 'Errors:'] |
for mirror in mirrors: |
- data = try_mirror(mirror) |
+ error_message, data = try_mirror(mirror) |
if data is not None: |
break |
+ error_report.append(error_message) |
else: |
- sys.exit('Unable to fetch malware domains list.') |
+ sys.exit('\n'.join(error_report)) |
- zip = zipfile.ZipFile(StringIO(data), 'r') |
- info = zip.infolist()[0] |
- for line in str(zip.read(info.filename)).splitlines(): |
+ zf = zipfile.ZipFile(StringIO(data), 'r') |
+ info = zf.infolist()[0] |
+ for line in str(zf.read(info.filename)).splitlines(): |
domain = line.strip() |
if not domain: |
continue |
print >>file, '||%s^' % domain.decode('idna') |
file.close() |
if subprocess.check_output(['hg', 'stat', '-R', tempdir]) != '': |
subprocess.check_call(['hg', '-q', 'commit', '-R', tempdir, '-A', '-u', 'hgbot', '-m', 'Updated malwaredomains.com data']) |
subprocess.check_call(['hg', '-q', 'push', '-R', tempdir]) |
finally: |
shutil.rmtree(tempdir, ignore_errors=True) |
+ |
+ |
+if __name__ == '__main__': |
+ main() |