| Index: sitescripts/extensions/web/downloads.py |
| =================================================================== |
| new file mode 100644 |
| --- /dev/null |
| +++ b/sitescripts/extensions/web/downloads.py |
| @@ -0,0 +1,67 @@ |
| +# 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 |
| +from ConfigParser import SafeConfigParser |
| +from sitescripts.web import url_handler |
| +from sitescripts.extensions.utils import getDownloadLinks |
| + |
| +links = {} |
| + |
| +@url_handler('/latest/') |
| +def handle_request(environ, start_response): |
| + global links |
| + update_links() |
| + |
| + 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])]) |
| + else: |
| + start_response('404 Not Found', []) |
| + return [] |
| + |
| +UPDATE_INTERVAL = 10 * 60 # 10 minutes |
| +update_queue = multiprocessing.Queue() |
| +last_update = -float('Inf') |
| + |
| +def update_links(): |
| + global UPDATE_INTERVAL, update_queue, links, last_update |
| + while not update_queue.empty(): |
| + links = update_queue.get() |
| + |
| + now = time.clock() |
| + if now - last_update > UPDATE_INTERVAL: |
| + last_update = now |
| + |
| + process = multiprocessing.Process(target=_update_links, args=(update_queue,)) |
| + process.daemon = True |
| + process.start() |
| + |
| +def _update_links(queue): |
| + parser = SafeConfigParser() |
| + getDownloadLinks(parser) |
| + result = {} |
| + for section in parser.sections(): |
| + result[section] = parser.get(section, "downloadURL") |
| + queue.put(result) |
| + |
| +update_links() |