A copyright violation detector running on Wikimedia Cloud Services https://tools.wmflabs.org/copyvios/
Nie możesz wybrać więcej, niż 25 tematów Tematy muszą się zaczynać od litery lub cyfry, mogą zawierać myślniki ('-') i mogą mieć do 35 znaków.

app.py 4.5 KiB

10 lat temu
10 lat temu
10 lat temu
10 lat temu
4 lat temu
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148
  1. #! /usr/bin/env python
  2. # -*- coding: utf-8 -*-
  3. from functools import wraps
  4. from hashlib import md5
  5. from json import dumps
  6. from logging import DEBUG, INFO, getLogger
  7. from logging.handlers import TimedRotatingFileHandler
  8. from os import path
  9. from time import asctime
  10. from traceback import format_exc
  11. from earwigbot.bot import Bot
  12. from earwigbot.wiki.copyvios import globalize
  13. from flask import Flask, g, make_response, request
  14. from flask_mako import MakoTemplates, render_template, TemplateError
  15. from copyvios.api import format_api_error, handle_api_request
  16. from copyvios.checker import do_check
  17. from copyvios.cookies import parse_cookies
  18. from copyvios.misc import cache, get_notice
  19. from copyvios.settings import process_settings
  20. from copyvios.sites import update_sites
  21. app = Flask(__name__)
  22. MakoTemplates(app)
  23. hand = TimedRotatingFileHandler("logs/app.log", when="midnight", backupCount=7)
  24. hand.setLevel(DEBUG)
  25. app.logger.addHandler(hand)
  26. app.logger.info(u"Flask server started " + asctime())
  27. app._hash_cache = {}
  28. def catch_errors(func):
  29. @wraps(func)
  30. def inner(*args, **kwargs):
  31. try:
  32. return func(*args, **kwargs)
  33. except TemplateError as exc:
  34. app.logger.error(u"Caught exception:\n{0}".format(exc.text))
  35. return render_template("error.mako", traceback=exc.text)
  36. except Exception:
  37. app.logger.exception(u"Caught exception:")
  38. return render_template("error.mako", traceback=format_exc())
  39. return inner
  40. @app.before_first_request
  41. def setup_app():
  42. cache.bot = Bot(".earwigbot", 100)
  43. cache.langs, cache.projects = [], []
  44. cache.last_sites_update = 0
  45. cache.background_data = {}
  46. cache.last_background_updates = {}
  47. globalize(num_workers=8)
  48. @app.before_request
  49. def prepare_request():
  50. g._db = None
  51. g.cookies = parse_cookies(
  52. request.script_root or "/", request.environ.get("HTTP_COOKIE"))
  53. g.new_cookies = []
  54. @app.after_request
  55. def add_new_cookies(response):
  56. for cookie in g.new_cookies:
  57. response.headers.add("Set-Cookie", cookie)
  58. return response
  59. @app.after_request
  60. def write_access_log(response):
  61. msg = u"%s %s %s %s -> %s"
  62. app.logger.debug(msg, asctime(), request.method, request.path,
  63. request.values.to_dict(), response.status_code)
  64. return response
  65. @app.teardown_appcontext
  66. def close_databases(error):
  67. if g._db:
  68. g._db.close()
  69. def external_url_handler(error, endpoint, values):
  70. if endpoint == "static" and "file" in values:
  71. fpath = path.join(app.static_folder, values["file"])
  72. mtime = path.getmtime(fpath)
  73. cache = app._hash_cache.get(fpath)
  74. if cache and cache[0] == mtime:
  75. hashstr = cache[1]
  76. else:
  77. with open(fpath, "rb") as f:
  78. hashstr = md5(f.read()).hexdigest()
  79. app._hash_cache[fpath] = (mtime, hashstr)
  80. return "/static/{0}?v={1}".format(values["file"], hashstr)
  81. raise error
  82. app.url_build_error_handlers.append(external_url_handler)
  83. @app.route("/")
  84. @catch_errors
  85. def index():
  86. notice = get_notice()
  87. update_sites()
  88. query = do_check()
  89. return render_template(
  90. "index.mako", notice=notice, query=query, result=query.result,
  91. turnitin_result=query.turnitin_result)
  92. @app.route("/settings", methods=["GET", "POST"])
  93. @catch_errors
  94. def settings():
  95. status = process_settings() if request.method == "POST" else None
  96. update_sites()
  97. default = cache.bot.wiki.get_site()
  98. kwargs = {"status": status, "default_lang": default.lang,
  99. "default_project": default.project}
  100. return render_template("settings.mako", **kwargs)
  101. @app.route("/api")
  102. @catch_errors
  103. def api():
  104. return render_template("api.mako", help=True)
  105. @app.route("/api.json")
  106. @catch_errors
  107. def api_json():
  108. if not request.args:
  109. return render_template("api.mako", help=True)
  110. format = request.args.get("format", "json")
  111. if format in ["json", "jsonfm"]:
  112. update_sites()
  113. try:
  114. result = handle_api_request()
  115. except Exception as exc:
  116. result = format_api_error("unhandled_exception", exc)
  117. else:
  118. errmsg = u"Unknown format: '{0}'".format(format)
  119. result = format_api_error("unknown_format", errmsg)
  120. if format == "jsonfm":
  121. return render_template("api.mako", help=False, result=result)
  122. resp = make_response(dumps(result))
  123. resp.mimetype = "application/json"
  124. resp.headers["Access-Control-Allow-Origin"] = "*"
  125. return resp
  126. if __name__ == '__main__':
  127. app.run()