Index: sitescripts/extensions/web/downloads.py |
=================================================================== |
new file mode 100644 |
--- /dev/null |
+++ b/sitescripts/extensions/web/downloads.py |
@@ -0,0 +1,66 @@ |
+# 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): |
+ 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].encode("utf-8"))]) |
+ 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 links, last_update |
+ while not update_queue.empty(): |
+ links = update_queue.get() |
+ |
+ now = time.time() |
+ 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() |