| Index: sitescripts/extensions/web/downloads.py |
| =================================================================== |
| new file mode 100644 |
| --- /dev/null |
| +++ b/sitescripts/extensions/web/downloads.py |
| @@ -0,0 +1,63 @@ |
| +# coding: utf-8 |
| + |
| +# This file is part of the Adblock Plus web scripts, |
| +# Copyright (C) 2006-2014 Eyeo GmbH |
| +# |
| +# Adblock Plus is free software: you can redistribute it and/or modify |
| +# it under the terms of the GNU General Public License version 3 as |
| +# published by the Free Software Foundation. |
| +# |
| +# Adblock Plus is distributed in the hope that it will be useful, |
| +# but WITHOUT ANY WARRANTY; without even the implied warranty of |
| +# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
| +# 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 re |
| +import time |
| +import posixpath |
| +import urlparse |
| +import multiprocessing |
| +import threading |
| +from ConfigParser import SafeConfigParser |
| +from sitescripts.web import url_handler |
| +from sitescripts.extensions.utils import getDownloadLinks |
| + |
| +links = {} |
| +UPDATE_INTERVAL = 10 * 60 # 10 minutes |
| + |
| +@url_handler('/latest/') |
| +def handle_request(environ, start_response): |
| + request = urlparse.urlparse(environ.get('REQUEST_URI', '')) |
| + basename = posixpath.splitext(posixpath.basename(request.path))[0] |
| + if basename in links: |
| + start_response('302 Found', [('Location', links[basename].encode("utf-8"))]) |
| + else: |
| + start_response('404 Not Found', []) |
| + return [] |
| + |
| +def update_links(): |
|
Sebastian Noack
2014/09/17 13:32:11
Since you are apparently fine with keeping a threa
Wladimir Palant
2014/09/17 17:45:44
That was the idea originally. However, https://sta
Sebastian Noack
2014/09/17 17:53:42
That is correct, but IMO not an issue here:
1. Th
Sebastian Noack
2014/09/17 18:13:53
Note that CPU time is distributed across all threa
|
| + try: |
| + pool = multiprocessing.Pool(1) |
| + pool.apply_async(_update_links, callback=_set_links) |
| + pool.close() |
| + finally: |
| + t = threading.Timer(UPDATE_INTERVAL, update_links) |
| + t.daemon = True |
| + t.start() |
| + |
| +def _update_links(): |
| + parser = SafeConfigParser() |
| + getDownloadLinks(parser) |
| + result = {} |
| + for section in parser.sections(): |
| + result[section] = parser.get(section, "downloadURL") |
| + return result |
| + |
| +def _set_links(newlinks): |
| + global links |
| + links = newlinks |
| + |
| +update_links() |