| Index: sitescripts/filterhits/web/query.py |
| =================================================================== |
| deleted file mode 100644 |
| --- a/sitescripts/filterhits/web/query.py |
| +++ /dev/null |
| @@ -1,86 +0,0 @@ |
| -# coding: utf-8 |
| - |
| -# This file is part of the Adblock Plus web scripts, |
| -# Copyright (C) 2006-2016 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 json |
| -import os |
| -import traceback |
| -from urlparse import parse_qsl |
| - |
| -import MySQLdb |
| - |
| -from sitescripts.web import url_handler |
| -from sitescripts.utils import cached, setupStderr |
| -from sitescripts.filterhits import db |
| -from sitescripts.filterhits.web import common |
| - |
| - |
| -def query(domain=None, filter=None, skip=0, take=20, order="DESC", order_by="frequency", **_): |
| - """ |
| - Returns the SQL and parameters needed to perform a query of the filterhits data. |
| - """ |
| - sql = """SELECT SQL_CALC_FOUND_ROWS domain, filter, frequency |
| - FROM frequencies as freq |
| - LEFT JOIN filters as f ON f.sha1=freq.filter_sha1 |
| - %s |
| - ORDER BY %s |
| - LIMIT %%s, %%s""" |
| - |
| - where = zip(*[("%s LIKE %%s" % s, "%%%s%%" % p) for s, p in (("domain", domain), |
| - ("filter", filter)) if p]) |
| - if where: |
| - where_fields, params = where |
| - where_sql = "WHERE " + " AND ".join(where_fields) |
| - else: |
| - where_sql = "" |
| - params = [] |
| - |
| - order = order.upper() if order.upper() in ("ASC", "DESC") else "ASC" |
| - if order_by not in ["filter", "domain", "frequency"]: |
| - order_by = "frequency" |
| - order_by_sql = "`%s` %s" % (order_by, order) |
| - |
| - params = list(params) + [int(skip), int(take)] |
| - return [sql % (where_sql, order_by_sql)] + params |
| - |
| - |
| -@url_handler("/query") |
| -def query_handler(environ, start_response): |
| - setupStderr(environ["wsgi.errors"]) |
| - params = dict(parse_qsl(environ.get("QUERY_STRING", ""))) |
| - |
| - try: |
| - db_connection = db.connect() |
| - try: |
| - results = db.query(db_connection, *query(**params), dict_result=True) |
| - total = db.query(db_connection, "SELECT FOUND_ROWS()")[0][0] |
| - finally: |
| - db_connection.close() |
| - except MySQLdb.Error: |
| - traceback.print_exc() |
| - return common.show_error("Failed to query database!", start_response, |
| - "500 Database error") |
| - |
| - try: |
| - echo = int(params["echo"]) |
| - except (ValueError, KeyError): |
| - echo = 0 |
| - |
| - response_headers = [("Content-type", "application/json; charset=utf-8")] |
| - start_response("200 OK", response_headers) |
| - return [json.dumps({"results": results, "echo": echo, |
| - "total": total, "count": len(results)}, |
| - ensure_ascii=False).encode("utf-8")] |