February 2016 - tor-commits - lists.torproject.org

[gettor/master] Merge pull request #11 from aagbsn/prune_stale_uploads
by ilv＠torproject.org 15 Feb '16

15 Feb '16

1 0

[gettor/master] Merge pull request #14 from DonnchaC/github-new
by ilv＠torproject.org 15 Feb '16

15 Feb '16

commit 645104175972a6be7b1933e0a5edc75103056791 Merge: 4103139 cfde870 Author: Israel Leiva <ilv(a)users.noreply.github.com> Date: Fri Feb 12 20:49:40 2016 +0000 Merge pull request #14 from DonnchaC/github-new Host TBB bundles on Github Releases gettor/utils.py | 86 ++++++++++----------- upload/bundles2github.py | 192 ++++++++++++++++++++++++----------------------- upload/github.cfg | 8 ++ 3 files changed, 144 insertions(+), 142 deletions(-)

1 0

[gettor/master] Merge pull request #12 from aagbsn/update_tbb_key
by ilv＠torproject.org 15 Feb '16

15 Feb '16

commit 09ea264f984c581d847d40260cfa960c91c78bad Merge: 4e6e580 102dc39 Author: Israel Leiva <ilv(a)users.noreply.github.com> Date: Mon Feb 8 22:39:44 2016 +0000 Merge pull request #12 from aagbsn/update_tbb_key Update tbb key upload/torbrowser-key.asc | Bin 193819 -> 25381 bytes 1 file changed, 0 insertions(+), 0 deletions(-)

1 0

[gettor/master] Merge pull request #13 from aagbsn/deduplicate_utility_methods
by ilv＠torproject.org 15 Feb '16

15 Feb '16

commit 41031394261d544680f5d69ff64aba4bf29caa73 Merge: 09ea264 d8a9d30 Author: Israel Leiva <ilv(a)users.noreply.github.com> Date: Mon Feb 8 22:41:19 2016 +0000 Merge pull request #13 from aagbsn/deduplicate_utility_methods Deduplicate utility methods gettor/utils.py | 92 ++++++++++++++++++++++++++++++++++++++++ upload/bundles2drive.py | 105 ++-------------------------------------------- upload/bundles2dropbox.py | 104 ++------------------------------------------- upload/bundles2github.py | 58 +------------------------ 4 files changed, 102 insertions(+), 257 deletions(-)

1 0

[gettor/master] Merge branch 'develop'
by ilv＠torproject.org 15 Feb '16

15 Feb '16

commit 7b052ebac1ed2f73014df126be93eb60a44aafd9 Merge: 6451041 7735f5b Author: ilv <ilv(a)users.noreply.github.com> Date: Mon Feb 15 17:09:02 2016 -0300 Merge branch 'develop' gettor/core.py | 22 +- gettor/http.py | 506 ++++++++++++++++++++++++++++++++++++ gettor/smtp.py | 8 +- lang/smtp/i18n/en/LC_MESSAGES/en.po | 36 +-- process_http.py | 14 + report.py | 129 +++++++++ scripts/create_api_mirror.py | 305 ++++++++++++++++++++++ scripts/sample-htaccess-api-mirror | 21 ++ 8 files changed, 1009 insertions(+), 32 deletions(-)

1 0

[gettor/master] Check SSL certificates at API requests
by ilv＠torproject.org 15 Feb '16

15 Feb '16

commit cfde87075bf5a19da3fa8bfac7c7c2e157f1f0a3 Author: Donncha O'Cearbhaill <donncha(a)donncha.is> Date: Fri Feb 12 19:33:46 2016 +0000 Check SSL certificates at API requests --- upload/bundles2github.py | 27 +++++++++++++-------------- 1 file changed, 13 insertions(+), 14 deletions(-) diff --git a/upload/bundles2github.py b/upload/bundles2github.py index 1252163..d081ddd 100644 --- a/upload/bundles2github.py +++ b/upload/bundles2github.py @@ -11,23 +11,25 @@ # :license: This is Free Software. See LICENSE for license information. # +# Use pyopenssl to verify TLS certifcates +try: + import urllib3.contrib.pyopenssl + urllib3.contrib.pyopenssl.inject_into_urllib3() +except ImportError: + pass + import os -import re import sys import argparse import ConfigParser +import gnupg import github3 -import gnupg + import gettor.core from gettor.utils import (get_bundle_info, get_file_sha256, find_files_to_upload) -import urllib3 - -# Actually verify Github's cert! -urllib3.disable_warnings() - def upload_new_release(github_repo, version, upload_dir): """ @@ -144,13 +146,10 @@ if __name__ == '__main__': print("Creating links file") for asset in release.assets: - url = ("https://github.com/{user}/{repo}/releases/download/" - "v{tag}/{file}".format( - user=github_user, - repo=github_repo, - tag=version, - file=asset.name, - )) + url = asset.browser_download_url + if url.endswith('.asc'): + continue + osys, arch, lc = get_bundle_info(asset.name) sha256 = get_file_sha256( os.path.abspath(os.path.join(tb_path, asset.name))

1 0

[gettor/master] Improvement of links message. See #17424
by ilv＠torproject.org 15 Feb '16

15 Feb '16

commit 676ee2890ea9d078fc33ac8b990f2cf655b3a086 Author: ilv <ilv(a)users.noreply.github.com> Date: Fri Dec 11 10:18:25 2015 -0300 Improvement of links message. See #17424 --- gettor/core.py | 22 ++++++++++++++++------ gettor/smtp.py | 8 +++++++- lang/smtp/i18n/en/LC_MESSAGES/en.po | 37 ++++++++++++------------------------- 3 files changed, 35 insertions(+), 32 deletions(-) diff --git a/gettor/core.py b/gettor/core.py index 3d946c9..97f7ce3 100644 --- a/gettor/core.py +++ b/gettor/core.py @@ -253,43 +253,49 @@ class Core(object): t32, t64 = [t for t in providers[pname].split(",") if t] link, signature, chs32 = [l for l in t32.split("$") if l] + link = "%s: %s" % (pname, link) links32[link] = signature link, signature, chs64 = [l for l in t64.split("$") if l] + link = "%s: %s" % (pname, link.lstrip()) links64[link] = signature else: link, signature, chs32 = [l for l in providers[pname].split("$") if l] + link = "%s: %s" % (pname, link) links32[link] = signature #providers[pname] = providers[pname].replace(",", "") #providers[pname] = providers[pname].replace("$", "\n\n") + ### We will improve and add the verification section soon ### # all packages are signed with same key # (Tor Browser developers) - fingerprint = config.get('key', 'fingerprint') + # fingerprint = config.get('key', 'fingerprint') # for now, english messages only - fingerprint_msg = self._get_msg('fingerprint', 'en') - fingerprint_msg = fingerprint_msg % fingerprint + # fingerprint_msg = self._get_msg('fingerprint', 'en') + # fingerprint_msg = fingerprint_msg % fingerprint except ConfigParser.Error as e: raise InternalError("%s" % str(e)) # create the final links list with all providers all_links = [] - msg = "Tor Browser %s-bit:" % arch + msg = "Tor Browser %s-bit:\n" % arch for link in links32: msg = "%s\n%s" % (msg, link) all_links.append(msg) if osys == 'linux': - msg = "\n\n\nTor Browser 64-bit:" + msg = "\n\n\nTor Browser 64-bit:\n" for link in links64: msg = "%s\n%s" % (msg, link) all_links.append(msg) + ### We will improve and add the verification section soon ### + """ msg = "\n\n\nTor Browser's signature %s-bit:" %\ arch for link in links32: @@ -313,6 +319,9 @@ class Core(object): all_links.append(msg) """ + ### end verification ### + + """ for key in providers.keys(): # get more friendly description of the provider try: @@ -328,8 +337,9 @@ class Core(object): raise InternalError("%s" % str(e)) """ + ### We will improve and add the verification section soon ### # add fingerprint after the links - all_links.append(fingerprint_msg) + # all_links.append(fingerprint_msg) if all_links: return "".join(all_links) diff --git a/gettor/smtp.py b/gettor/smtp.py index ed6a4fc..1cc8db3 100644 --- a/gettor/smtp.py +++ b/gettor/smtp.py @@ -33,6 +33,12 @@ import blacklist """SMTP module for processing email requests.""" +OS = { + 'osx': 'Mac OS X', + 'linux': 'Linux', + 'windows': 'Windows' +} + class ConfigError(Exception): pass @@ -368,7 +374,7 @@ class SMTP(object): try: links_subject = self._get_msg('links_subject', 'en') links_msg = self._get_msg('links_msg', 'en') - links_msg = links_msg % (os, lc, links) + links_msg = links_msg % (os, links) self._send_email( from_addr, diff --git a/lang/smtp/i18n/en/LC_MESSAGES/en.po b/lang/smtp/i18n/en/LC_MESSAGES/en.po index ee6a24e..f987648 100644 --- a/lang/smtp/i18n/en/LC_MESSAGES/en.po +++ b/lang/smtp/i18n/en/LC_MESSAGES/en.po @@ -22,42 +22,29 @@ msgstr "The locale you requested '%s' is not supported." #: Links message msgid "links_msg" -msgstr "Hello there! this is the 'GetTor' robot.\n\ +msgstr "You requested Tor Browser for %s.\n\ \n\ -Below are the links for your request (Tor Browser for %s, %s package):\n\ +You will need only one of the links below to download the bundle. If a link\n\ +does not work for you, try the next one.\n\ \n\ %s\n\ \n\ -===========================================================================\n\ -Still need help? If you have any questions, trouble connecting to Tor\n\ -network, or need to talk to a human, please contact our support team at:\n\ \n\ - help(a)rt.torproject.org\n\ -\n\ -We are ready to answer your queries in English, Farsi, Chinese, Arabic,\n\ -French and Spanish." +All the best.\n\ +--\n\ +GetTor team" #: Mirrors message msgid "mirrors_msg" -msgstr "Hello there! this is the 'GetTor' robot.\n\ +msgstr "Hi! this is the GetTor robot.\n\ \n\ Thank you for your request. Attached to this email you will find\n\ -an updated list of mirrors of Tor Project's website.\n\ -\n\ -Still need help? If you have any questions, trouble connecting to Tor\n\ -network, or need to talk to a human, please contact our support team at:\n\ -\n\ - help(a)rt.torproject.org\n\ -\n\ -We are ready to answer your queries in English, Farsi, Chinese, Arabic,\n\ -French and Spanish." +an updated list of mirrors of Tor Project's website." #: Help message msgid "help_msg" -msgstr "Hello there! this is the 'GetTor' robot.\n\ -\n\ -Thank you for your request. I am here to help you download the latest\n\ -Tor Browser.\n\ +msgstr "Hi! This is the GetTor robot. I am here to help you download the\n\ +latest version of Tor Browser.\n\ \n\ Please reply to this message with one of the options below:\n\ \n\ @@ -66,6 +53,6 @@ Please reply to this message with one of the options below:\n\ osx\n\ mirrors\n\ \n\ -And I will send you the download/access instructions quickly.\n\ +I will then send you the download instructions.\n\ \n\ -Tip: Just send a blank reply to this message if you are not sure." +If you are unsure, just send a blank reply to this message."

1 0

[gettor/master] Add script for generating automatic reports (#17588)
by ilv＠torproject.org 15 Feb '16

15 Feb '16

commit 35d304c9c0426946c17313ecc0e24f777e582b4a Author: Sukhbir Singh <sukhbir(a)torproject.org> Date: Tue Dec 8 00:40:38 2015 -0500 Add script for generating automatic reports (#17588) --- report.py | 129 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 129 insertions(+) diff --git a/report.py b/report.py new file mode 100644 index 0000000..b75d7c8 --- /dev/null +++ b/report.py @@ -0,0 +1,129 @@ +#!/usr/bin/env python + +# This file is part of GetTor, a Tor Browser distribution system. + +# :authors: Sukhbir Singh <sukhbir(a)torproject.org> +# see also AUTHORS file +# +# :copyright: (c) 2008-2015, The Tor Project, Inc. + +# To read the log files and populate the db, run the script with `--logs' once +# every day and then clear the log files. To generate the report, run it with +# `--report', once (or twice?) a month. + +# TODO: Logging? argparse? + +import os +import sys +import ConfigParser +from datetime import datetime as dt + +import sqlite3 + +CORE_CFG = "core.cfg" + +CHANNELS = ["smtp", "xmpp", "twitter"] +LOG_FILES = [channel + ".log" for channel in CHANNELS] + +DB = "gettor2.db" + +OUTPUT = "report.log" + +REPORT = """@ GetTor Report for {} + +We received a total of {} requests in {}, with a peak of {} requests on {}. + +[*] Request +{} + +[*] OS +{} + +[*] Language +{} + +[*] Channel +{} + +""" + + +class Report(object): + def __init__(self): + self.config = ConfigParser.ConfigParser() + self.config.read(CORE_CFG) + + self.log_dir = self.config.get("log", "dir") + # This is defined in the sample log file. + self.log_format = ["date", "request", "os", "locale"] + + self.conn = sqlite3.connect(DB) + + def db_write(self): + self.cursor = self.conn.cursor() + for each in self.logs: + self.cursor.execute("""INSERT INTO requests + (date, request, os, locale, channel) VALUES + (:date, :request, :os, :locale, :channel)""", + each) + self.conn.commit() + self.conn.close() + + def get_logs(self): + self.logs = [] + for each in LOG_FILES: + with open(os.path.join(self.log_dir, each)) as f: + for line in f: + if line.startswith("[INFO] "): + # The "7" here is for the "[INFO] " text. + logs = [log.strip() for log in line[7:].split(";")] + log_data = {key: value for key, value in + zip(self.log_format, logs)} + # We also need the channel. + log_data["channel"] = each.split(".")[0] + self.logs.append(log_data) + self.db_write() + self.conn.close() + + def generate_report(self): + self.cursor = self.conn.cursor() + self.requests = [] + + self.cursor.execute("SELECT COUNT(*) FROM requests") + self.requests.append(self.cursor.fetchone()) + + self.cursor.execute("""SELECT date, COUNT(*) FROM requests +GROUP BY date +ORDER BY COUNT(date) +DESC""") + self.requests.append(self.cursor.fetchone()) + + self.columns = ["request", "os", "locale", "channel"] + for each in self.columns: + self.cursor.execute("""SELECT {0}, COUNT(*) FROM requests +GROUP BY {0} +ORDER BY COUNT({0}) +DESC""".format(each)) + result = "\n".join(["{0:>16}: {1}".format(each[0], each[1]) + for each in self.cursor.fetchall() + if not each[0] == "none"]) + self.requests.append(result) + + with open(OUTPUT, "a") as f: + f.write(REPORT.format(dt.now().strftime("%B %Y"), + self.requests[0][0], + dt.now().strftime("%B"), + self.requests[1][1], + dt.strptime(self.requests[1][0], "%Y-%m-%d") + .strftime("%B %-d"), + *self.requests[2:])) + self.conn.close() + +if __name__ == "__main__": + try: + if sys.argv[1] == "--logs": + Report().get_logs() + if sys.argv[1] == "--report": + Report().generate_report() + except IndexError: + sys.exit("You need either `--logs' or `--report.'")

1 0

[gettor/master] Merge branch 'develop' of ssh://git-rw.torproject.org/gettor into develop
by ilv＠torproject.org 15 Feb '16

15 Feb '16

commit b0261b785ec3bab2cc0324900036c5114590fab9 Merge: 3cc92b1 b2b07f3 Author: ilv <ilv(a)users.noreply.github.com> Date: Thu Dec 31 17:18:57 2015 -0300 Merge branch 'develop' of ssh://git-rw.torproject.org/gettor into develop lang/smtp/i18n/en/LC_MESSAGES/en.po | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-)

1 0

[gettor/master] RESTful API
by ilv＠torproject.org 15 Feb '16

15 Feb '16

commit 6b12e964082feb9ffc1d5b7da84ead87378b8ae9 Author: ilv <ilv(a)users.noreply.github.com> Date: Wed Dec 16 16:55:25 2015 -0300 RESTful API --- gettor/http.py | 493 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++ process_http.py | 13 ++ 2 files changed, 506 insertions(+) diff --git a/gettor/http.py b/gettor/http.py new file mode 100644 index 0000000..c1441c6 --- /dev/null +++ b/gettor/http.py @@ -0,0 +1,493 @@ +# -*- coding: utf-8 -*- +# +# This file is part of GetTor. +# +# :authors: Israel Leiva <ilv(a)torproject.org> +# see also AUTHORS file +# +# :copyright: (c) 2008-2015, The Tor Project, Inc. +# (c) 2015, Israel Leiva +# +# :license: This is Free Software. See LICENSE for license information. + +import os +import re +import json +import codecs +import urllib2 +import ConfigParser + +from time import gmtime, strftime + +from flask import Flask +from flask_restful import Api, Resource, reqparse + +import core +import utils + +"""GetTor RESTful API""" + +# currently supported locales for Tor Browser +LC = ['ar', 'de', 'en-US', 'es-ES', 'fa', 'fr', 'it', 'ko', 'nl', 'pl', + 'pt-PT', 'ru', 'tr', 'vi', 'zh-CN'] + +# https://gitweb.tpo/tor-browser-spec.git/tree/processes/VersionNumbers +# does not say anything about operating systems, so it's possible the +# notation might change in the future. We should always use the same three +# strings though: linux, windows, osx. +OS = { + 'Linux': 'linux', + 'Windows': 'windows', + 'MacOS': 'osx' +} + +# based on +# https://gitweb.tpo.org/tor-browser-spec.git/tree/processes/VersionNumbers +# except for the first one, which is based on current RecommendedTBBVersions +RE = { + 'os': '(.*)-(\w+)', + 'alpha': '\d\.\d(\.\d)*a\d+', + 'beta': '\d\.\d(\.\d)*b\d+', + 'stable': '\d\.\d(\.\d)*' +} + +# strings to build names of packages depending on OS. +PKG = { + 'windows': 'torbrowser-install-%s_%s.exe', + 'linux': 'tor-browser-linux%s-%s_%s.tar.xz', + 'osx': 'TorBrowser-%s-osx64_%s.dmg' +} + +# bin and asc are used to build the download links for each version, os and lc +URL = { + 'version': 'https://www.torproject.org/projects/torbrowser/RecommendedTBBVersions', + 'bin': 'https://www.torproject.org/dist/torbrowser/%s/%s', + 'asc': 'https://www.torproject.org/dist/torbrowser/%s/%s.asc' +} + +# filters for API resources +parser = reqparse.RequestParser() +parser.add_argument('os', type=str, help='Operating System') +parser.add_argument('lc', type=str, help='Locale') + + +class ConfigError(Exception): + pass + + +class InternalError(Exception): + pass + + +class HTTP(object): + """ Provide useful resources via RESTful API. """ + def __init__(self, cfg=None): + """ Create new object by reading a configuration file. + + :param: cfg (string) path of the configuration file. + + """ + default_cfg = 'http.cfg' + config = ConfigParser.ConfigParser() + + if cfg is None or not os.path.isfile(cfg): + cfg = default_cfg + + try: + with open(cfg) as f: + config.readfp(f) + except IOError: + raise ConfigError("File %s not found!" % cfg) + + try: + # server that provides the RESTful API + self.server = config.get('general', 'server') + # path to the links files + self.links_path = config.get('general', 'links') + # path to mirrors in json + self.mirrors_path = config.get('general', 'mirrors') + + # we will ask gettor.core for the links + core_cfg = config.get('general', 'core') + self.core = core.Core(core_cfg) + + except ConfigParser.Error as e: + raise ConfigError("Configuration error: %s" % str(e)) + except core.ConfigError as e: + raise InternalError("HTTP error: %s" % str(e)) + + def _is_json(self, my_json): + """ Check if json generated is valid. + + :param: my_json (string) data to ve verified. + + :return: (bool) true if data is json-valid, false otherwise. + + """ + try: + json_object = json.loads(my_json) + except ValueError, e: + return False + return True + + def _get_provider_name(self, p): + """ Return simplified version of provider's name. + + :param: p (string) provider's name. + + :return: (string) provider's name in lowercase and without spaces. + + """ + p = p.replace(' ', '-') + return p.lower() + + def _add_links(self, lv, release, version, os): + """ Add link for all locales in LC depending on given OS. + + :param: lv (dict) latest version data structure. + :param: release (string) release to which add the links. + :param: version (string) version obtained from tpo. + :param: os (string) operating system. + + """ + for lc in LC: + if os == 'linux': + pkg32 = PKG['linux'] % ('32', version, lc) + link_bin32 = URL['bin'] % (version, pkg32) + link_asc32 = URL['asc'] % (version, pkg32) + + pkg64 = PKG['linux'] % ('64', version, lc) + link_bin64 = URL['bin'] % (version, pkg64) + link_asc64 = URL['asc'] % (version, pkg64) + + lv[release]['downloads'][os][lc] = { + 'binary32': link_bin32, + 'signature32': link_asc32, + 'binary64': link_bin64, + 'signature64': link_asc64, + } + else: + if os == 'windows': + pkg = PKG['windows'] % (version, lc) + + elif os == 'osx': + pkg = PKG['osx'] % (version, lc) + + else: + continue + + link_bin = URL['bin'] % (version, pkg) + link_asc = URL['asc'] % (version, pkg) + lv[release]['downloads'][os][lc] = { + 'binary': link_bin, + 'signature': link_asc + } + + def _load_latest_version(self): + """ Load latest version data. """ + response = urllib2.urlopen(URL['version']) + json_response = json.load(response) + + lv = { + 'stable': { + 'latest_version': '', + 'downloads': {} + }, + 'alpha': { + 'latest_version': '', + 'downloads': {} + }, + 'beta': { + 'latest_version': '', + 'downloads': {} + } + } + + self.releases = { + 'alpha': '%s/latest/alpha' % self.server, + 'beta': '%s/latest/beta' % self.server, + 'stable': '%s/latest/stable' % self.server, + 'updated_at': strftime("%Y-%m-%d %H:%M:%S", gmtime()) + } + + # one iteration to find the latest version for each release + for v in json_response: + # latest version for each release + if not re.match(RE['os'], v): + if re.match(RE['alpha'], v): + if v > lv['alpha']['latest_version']: + # we'll use the latest one + lv['alpha']['latest_version'] = v + + elif re.match(RE['beta'], v): + if v > lv['beta']['latest_version']: + # we'll use the latest one + lv['beta']['latest_version'] = v + + elif re.match(RE['stable'], v): + if v > lv['stable']['latest_version']: + # we'll use the latest one + lv['stable']['latest_version'] = v + + latest_alpha = lv['alpha']['latest_version'] + latest_beta = lv['beta']['latest_version'] + latest_stable = lv['stable']['latest_version'] + + # another iteration to add the links + for v in json_response: + # based on current RecommendedTBBVersions scheme + # for each release and for each os we build links for all locales + if re.match(RE['os'], v): + m = re.match(RE['os'], v) + version = m.group(1) + osys = m.group(2) + + if osys in OS: + if latest_alpha and version == latest_alpha \ + and re.match(RE['alpha'], version): + lv['alpha']['downloads'][OS[osys]] = {} + self._add_links(lv, 'alpha', version, OS[osys]) + + elif latest_beta and version == latest_beta \ + and re.match(RE['beta'], version): + lv['beta']['downloads'][OS[osys]] = {} + self._add_links(lv, 'beta', version, OS[osys]) + + elif latest_stable and version == latest_stable \ + and re.match(RE['stable'], version): + lv['stable']['downloads'][OS[osys]] = {} + self._add_links(lv, 'stable', version, OS[osys]) + + lv['updated_at'] = strftime("%Y-%m-%d %H:%M:%S", gmtime()) + self.lv = lv + + def _load_links(self): + """ Load links and providers data. """ + links_files = [] + + # look for files ending with .links in links_path + p = re.compile('.*\.links$') + for name in os.listdir(self.links_path): + path = os.path.abspath(os.path.join(self.links_path, name)) + if os.path.isfile(path) and p.match(path): + links_files.append(path) + + links = {} + providers = {} + supported_os = self.core.get_supported_os() + supported_lc = self.core.get_supported_lc() + + for name in links_files: + config = ConfigParser.ConfigParser() + try: + with open(name) as f: + config.readfp(f) + except IOError: + raise InternalError("File %s not found!" % name) + + try: + pname = config.get('provider', 'name') + pname = self._get_provider_name(pname) + + # build providers dict + providers[pname] = '%s/providers/%s' % (self.server, pname) + providers['updated_at'] = strftime( + "%Y-%m-%d %H:%M:%S", gmtime() + ) + + self.providers = providers + links[pname] = {} + + # build links data. + for osys in supported_os: + links[pname][osys] = {} + for lc in supported_lc: + links[pname][osys][lc] = {} + + for osys in supported_os: + for lc in supported_lc: + l_str = config.get(osys, lc) + + # linux has 32 and 64 bit packages + if osys == 'linux': + l32_str, l64_str = l_str.split(',') + + link32, sig32, sha32 = [ + l for l in l32_str.split("$") if l + ] + + link64, sig64, sha64 = [ + l for l in l64_str.split("$") if l + ] + link64 = link64.lstrip() + + links[pname][osys][lc]['binary32'] = link32 + links[pname][osys][lc]['signature32'] = sig32 + links[pname][osys][lc]['sha256-32'] = sha32 + links[pname][osys][lc]['binary64'] = link64 + links[pname][osys][lc]['signature64'] = sig64 + links[pname][osys][lc]['sha256-64'] = sha64 + + else: + link, sig, sha = [l for l in l_str.split("$") if l] + links[pname][osys][lc]['binary'] = link + links[pname][osys][lc]['signature'] = sig + links[pname][osys][lc]['sha256'] = sha + + except ConfigParser.Error as e: + raise InternalError("%s" % str(e)) + + links['updated_at'] = strftime("%Y-%m-%d %H:%M:%S", gmtime()) + self.links = links + + def _load_mirrors(self): + """ Load mirrors data. """ + mirrors = [] + + # json of mirrors should be obtained from get_mirrors.py + json_data = open(self.mirrors_path).read() + mirrors = json.loads(json_data) + + self.mirrors = mirrors + + def _load_resources(self): + """ Load available resources data. """ + + self.resources = { + 'providers': '%s/providers' % self.server, + 'mirrors': '%s/mirrors' % self.server, + 'latest_version': '%s/latest' % self.server, + 'updated_at': strftime("%Y-%m-%d %H:%M:%S", gmtime()) + } + + def load_data(self): + """ Load all data. + + Since data is not frequently updated, we load all data before + running the RESTful API. Every time the links/mirrors/version + data is updated we should restart the API. + + """ + self._load_links() + self._load_mirrors() + self._load_resources() + self._load_latest_version() + + def run(self): + """ Run RESTful API. """ + app = Flask(__name__) + api = Api(app) + + api.add_resource( + AvailableResources, + '/', + resource_class_kwargs={ + 'resources': self.resources + } + ) + + api.add_resource( + Providers, + '/providers', + '/providers/<string:provider>', + resource_class_kwargs={ + 'links': self.links, + 'providers': self.providers + } + ) + + api.add_resource( + LatestVersion, + '/latest', + '/latest/<string:release>', + resource_class_kwargs={ + 'latest_version': self.lv, + 'releases': self.releases + } + ) + + api.add_resource( + Mirrors, + '/mirrors', + resource_class_kwargs={ + 'mirrors': self.mirrors + } + ) + + app.run(debug=True) + + +class AvailableResources(Resource): + def __init__(self, resources): + """ Set initial data. """ + self.resources = resources + + def get(self): + """ Return available resources on the API. """ + return self.resources + + +class Providers(Resource): + def __init__(self, providers, links): + """ Set initial data. """ + self.providers = providers + self.links = links + + def get(self, provider=None): + """ Return providers and links data. """ + + # we use arg to filter results by os and lc (in that order) + arg = parser.parse_args() + + if provider: + if arg['os']: + if arg['lc']: + # links by provider, os, and lc (in that order) + return self.links[provider][arg['os']][arg['lc']] + else: + # links by provider and os (in that order) + return self.links[provider][arg['os']] + else: + # links by provider + return self.links[provider] + else: + # list of providers + return self.providers + + +class LatestVersion(Resource): + def __init__(self, latest_version, releases): + """ Set initial data. """ + self.lv = latest_version + self.releases = releases + + def get(self, release=None): + """ Return latest version data. """ + + # we use arg to filter results by os and lc (in that order) + arg = parser.parse_args() + + if release: + if arg['os']: + if arg['lc']: + # tpo links by release, os and lc (in that order) + return self.lv[release]['downloads'][arg['os']][arg['lc']] + else: + # tpo links by release and os (in that order) + return self.lv[release]['downloads'][arg['os']] + else: + # version and tpo links by release + return self.lv[release] + else: + # list of releases + return self.releases + + +class Mirrors(Resource): + def __init__(self, mirrors): + """ Set initial data. """ + self.mirrors = mirrors + + def get(self): + """ Return mirrors data. """ + return self.mirrors diff --git a/process_http.py b/process_http.py new file mode 100644 index 0000000..31475f1 --- /dev/null +++ b/process_http.py @@ -0,0 +1,13 @@ +#!/usr/bin/env python +# -*- coding: utf-8 -*- + +import gettor.http + + +def main(): + api = gettor.http.HTTP('http.cfg') + api.load_data() + api.run() + +if __name__ == '__main__': + main()

1 0