| Index: appengine/monorail/framework/servlet.py
|
| diff --git a/appengine/monorail/framework/servlet.py b/appengine/monorail/framework/servlet.py
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..ce1e25e5c0cacc298e59fc0479ae3b1badce664c
|
| --- /dev/null
|
| +++ b/appengine/monorail/framework/servlet.py
|
| @@ -0,0 +1,909 @@
|
| +# Copyright 2016 The Chromium Authors. All rights reserved.
|
| +# Use of this source code is govered by a BSD-style
|
| +# license that can be found in the LICENSE file or at
|
| +# https://developers.google.com/open-source/licenses/bsd
|
| +
|
| +"""Base classes for Monorail servlets.
|
| +
|
| +This base class provides HTTP get() and post() methods that
|
| +conveniently drive the process of parsing the request, checking base
|
| +permissions, gathering common page information, gathering
|
| +page-specific information, and adding on-page debugging information
|
| +(when appropriate). Subclasses can simply implement the page-specific
|
| +logic.
|
| +
|
| +Summary of page classes:
|
| + Servlet: abstract base class for all Monorail servlets.
|
| + _ContextDebugItem: displays page_data elements for on-page debugging.
|
| +"""
|
| +
|
| +import httplib
|
| +import json
|
| +import logging
|
| +import os
|
| +import time
|
| +import urllib
|
| +
|
| +from third_party import ezt
|
| +
|
| +from google.appengine.api import users
|
| +
|
| +import webapp2
|
| +
|
| +import settings
|
| +from features import savedqueries_helpers
|
| +from framework import actionlimit
|
| +from framework import alerts
|
| +from framework import captcha
|
| +from framework import framework_bizobj
|
| +from framework import framework_constants
|
| +from framework import framework_helpers
|
| +from framework import monorailrequest
|
| +from framework import permissions
|
| +from framework import profiler
|
| +from framework import ratelimiter
|
| +from framework import servlet_helpers
|
| +from framework import template_helpers
|
| +from framework import urls
|
| +from framework import xsrf
|
| +from proto import project_pb2
|
| +from search import query2ast
|
| +from services import issue_svc
|
| +from services import project_svc
|
| +from services import secrets_svc
|
| +from services import user_svc
|
| +from tracker import tracker_views
|
| +
|
| +NONCE_LENGTH = 32
|
| +
|
| +if not settings.unit_test_mode:
|
| + import MySQLdb
|
| +
|
| +
|
| +class MethodNotSupportedError(NotImplementedError):
|
| + """An exception class for indicating that the method is not supported.
|
| +
|
| + Used by GatherPageData and ProcessFormData to indicate that GET and POST,
|
| + respectively, are not supported methods on the given Servlet.
|
| + """
|
| + pass
|
| +
|
| +
|
| +class Servlet(webapp2.RequestHandler):
|
| + """Base class for all Monorail servlets.
|
| +
|
| + Defines a framework of methods that build up parts of the EZT page data.
|
| +
|
| + Subclasses should override GatherPageData and/or ProcessFormData to
|
| + handle requests.
|
| + """
|
| +
|
| + _MAIN_TAB_MODE = None # Normally overriden in subclasses to be one of these:
|
| +
|
| + MAIN_TAB_NONE = 't0'
|
| + MAIN_TAB_DASHBOARD = 't1'
|
| + MAIN_TAB_ISSUES = 't2'
|
| + MAIN_TAB_PEOPLE = 't3'
|
| + MAIN_TAB_PROCESS = 't4'
|
| + MAIN_TAB_UPDATES = 't5'
|
| + MAIN_TAB_ADMIN = 't6'
|
| + PROCESS_TAB_SUMMARY = 'st1'
|
| + PROCESS_TAB_STATUSES = 'st3'
|
| + PROCESS_TAB_LABELS = 'st4'
|
| + PROCESS_TAB_RULES = 'st5'
|
| + PROCESS_TAB_TEMPLATES = 'st6'
|
| + PROCESS_TAB_COMPONENTS = 'st7'
|
| + PROCESS_TAB_VIEWS = 'st8'
|
| + ADMIN_TAB_META = 'st1'
|
| + ADMIN_TAB_ADVANCED = 'st9'
|
| +
|
| + # Most forms require a security token, however if a form is really
|
| + # just redirecting to a search GET request without writing any data,
|
| + # subclass can override this to allow anonymous use.
|
| + CHECK_SECURITY_TOKEN = True
|
| +
|
| + # Most forms just ignore fields that have value "". Subclasses can override
|
| + # if needed.
|
| + KEEP_BLANK_FORM_VALUES = False
|
| +
|
| + # Most forms use regular forms, but subclasses that accept attached files can
|
| + # override this to be True.
|
| + MULTIPART_POST_BODY = False
|
| +
|
| + # This value should not typically be overridden.
|
| + _TEMPLATE_PATH = framework_constants.TEMPLATE_PATH
|
| +
|
| + _PAGE_TEMPLATE = None # Normally overriden in subclasses.
|
| + _ELIMINATE_BLANK_LINES = False
|
| +
|
| + _CAPTCHA_ACTION_TYPES = [] # Override this in subclass to add captcha.
|
| +
|
| + _MISSING_PERMISSIONS_TEMPLATE = 'sitewide/403-page.ezt'
|
| +
|
| + def __init__(self, request, response, services=None,
|
| + content_type='text/html; charset=UTF-8'):
|
| + """Load and parse the template, saving it for later use."""
|
| + super(Servlet, self).__init__(request, response)
|
| + if self._PAGE_TEMPLATE: # specified in subclasses
|
| + template_path = self._TEMPLATE_PATH + self._PAGE_TEMPLATE
|
| + self.template = template_helpers.GetTemplate(
|
| + template_path, eliminate_blank_lines=self._ELIMINATE_BLANK_LINES)
|
| + else:
|
| + self.template = None
|
| +
|
| + self._missing_permissions_template = template_helpers.MonorailTemplate(
|
| + self._TEMPLATE_PATH + self._MISSING_PERMISSIONS_TEMPLATE)
|
| + self.services = services or self.app.config.get('services')
|
| + self.content_type = content_type
|
| + self.profiler = profiler.Profiler()
|
| + self.mr = None
|
| + self.ratelimiter = ratelimiter.RateLimiter()
|
| +
|
| + def dispatch(self):
|
| + """Do common stuff then dispatch the request to get() or put() methods."""
|
| + handler_start_time = time.time()
|
| +
|
| + logging.info('\n\n\nRequest handler: %r', self)
|
| +
|
| + self.mr = monorailrequest.MonorailRequest()
|
| +
|
| + self.ratelimiter.CheckStart(self.request)
|
| + self.response.headers.add('Strict-Transport-Security',
|
| + 'max-age=31536000; includeSubDomains')
|
| +
|
| + if self.services.cache_manager:
|
| + # TODO(jrobbins): don't do this step if invalidation_timestep was
|
| + # passed via the request and matches our last timestep
|
| + try:
|
| + with self.profiler.Phase('distributed invalidation'):
|
| + self.services.cache_manager.DoDistributedInvalidation(self.mr.cnxn)
|
| +
|
| + except MySQLdb.OperationalError as e:
|
| + logging.exception(e)
|
| + self.redirect('/database-maintenance', abort=True)
|
| +
|
| + try:
|
| + with self.profiler.Phase('parsing request and doing lookups'):
|
| + self.mr.ParseRequest(self.request, self.services, self.profiler)
|
| +
|
| + self.response.headers['X-Frame-Options'] = 'SAMEORIGIN'
|
| + webapp2.RequestHandler.dispatch(self)
|
| +
|
| + except user_svc.NoSuchUserException as e:
|
| + logging.warning('Trapped NoSuchUserException %s', e)
|
| + self.abort(404, 'user not found')
|
| +
|
| + except monorailrequest.InputException as e:
|
| + logging.info('Rejecting invalid input: %r', e)
|
| + self.response.status = httplib.BAD_REQUEST
|
| +
|
| + except project_svc.NoSuchProjectException as e:
|
| + logging.info('Rejecting invalid request: %r', e)
|
| + self.response.status = httplib.BAD_REQUEST
|
| +
|
| + except xsrf.TokenIncorrect as e:
|
| + logging.info('Bad XSRF token: %r', e.message)
|
| + self.response.status = httplib.BAD_REQUEST
|
| +
|
| + except AlreadySentResponseException:
|
| + # If servlet already sent response, then do nothing more. E.g.,
|
| + # when serving attachment content, we do not use templates.
|
| + pass
|
| +
|
| + except permissions.BannedUserException as e:
|
| + logging.warning('The user has been banned')
|
| + url = framework_helpers.FormatAbsoluteURL(
|
| + self.mr, urls.BANNED, include_project=False, copy_params=False)
|
| + self.redirect(url, abort=True)
|
| +
|
| + except actionlimit.ExcessiveActivityException:
|
| + logging.info('Excessive Activity Exception %r', self.mr.auth.user_id)
|
| + url = framework_helpers.FormatAbsoluteURL(
|
| + self.mr, urls.EXCESSIVE_ACTIVITY,
|
| + include_project=False, copy_params=False)
|
| + self.redirect(url, abort=True)
|
| +
|
| + except ratelimiter.RateLimitExceeded as e:
|
| + logging.info('RateLimitExceeded Exception %s', e)
|
| + self.response.status = httplib.BAD_REQUEST
|
| + self.response.body = 'Slow your roll.'
|
| +
|
| + finally:
|
| + self.mr.CleanUp()
|
| + self.ratelimiter.CheckEnd(self.request, time.time(), handler_start_time)
|
| +
|
| + total_processing_time = time.time() - handler_start_time
|
| + logging.warn('Processed request in %d ms',
|
| + int(total_processing_time * 1000))
|
| + if settings.enable_profiler_logging:
|
| + self.profiler.LogStats()
|
| +
|
| + def _AddHelpDebugPageData(self, page_data):
|
| + with self.profiler.Phase('help and debug data'):
|
| + page_data.update(self.GatherHelpData(self.mr, page_data))
|
| + page_data.update(self.GatherDebugData(self.mr, page_data))
|
| +
|
| + # pylint: disable=unused-argument
|
| + def get(self, **kwargs):
|
| + """Collect page-specific and generic info, then render the page.
|
| +
|
| + Args:
|
| + Any path components parsed by webapp2 will be in kwargs, but we do
|
| + our own parsing later anyway, so igore them for now.
|
| + """
|
| + page_data = {}
|
| + nonce = framework_helpers.MakeRandomKey(length=NONCE_LENGTH)
|
| + try:
|
| + csp_header = 'Content-Security-Policy'
|
| + csp_scheme = 'https:'
|
| + if settings.dev_mode:
|
| + csp_header = 'Content-Security-Policy-Report-Only'
|
| + csp_scheme = 'http:'
|
| + user_agent = self.mr.request.headers.get('User-Agent', '')
|
| + csp_supports_nonce = (
|
| + ('Chrome' in user_agent or 'Firefox' in user_agent) and
|
| + ('Edge' not in user_agent))
|
| + self.response.headers.add(csp_header,
|
| + ("default-src %(scheme)s ; "
|
| + "script-src"
|
| + " 'unsafe-inline'" # Only counts in browsers that lack CSP2.
|
| + " 'unsafe-dynamic'" # Allows <script nonce> to load more.
|
| + " https://www.gstatic.com/recaptcha/api2/"
|
| + " %(csp_self)s 'nonce-%(nonce)s'; "
|
| + "child-src https://www.google.com/recaptcha/; "
|
| + "frame-src https://www.google.com/recaptcha/; "
|
| + "img-src %(scheme)s data: blob: ; "
|
| + "style-src %(scheme)s 'unsafe-inline'; "
|
| + "object-src 'none'; "
|
| + "report-uri /csp.do" % {
|
| + 'nonce': nonce,
|
| + 'scheme': csp_scheme,
|
| + 'csp_self': '' if csp_supports_nonce else "'self'",
|
| + }))
|
| +
|
| + page_data.update(self._GatherFlagData(self.mr))
|
| +
|
| + # Page-specific work happens in this call.
|
| + page_data.update(self._DoPageProcessing(self.mr, nonce))
|
| +
|
| + self._AddHelpDebugPageData(page_data)
|
| +
|
| + with self.profiler.Phase('rendering template'):
|
| + self._RenderResponse(page_data)
|
| +
|
| + except (MethodNotSupportedError, NotImplementedError) as e:
|
| + # Instead of these pages throwing 500s display the 404 message and log.
|
| + # The motivation of this is to minimize 500s on the site to keep alerts
|
| + # meaningful during fuzzing. For more context see
|
| + # https://bugs.chromium.org/p/monorail/issues/detail?id=659
|
| + logging.warning('Trapped NotImplementedError %s', e)
|
| + self.abort(404, 'invalid page')
|
| + except query2ast.InvalidQueryError as e:
|
| + logging.warning('Trapped InvalidQueryError: %s', e)
|
| + logging.exception(e)
|
| + msg = e.message if e.message else 'invalid query'
|
| + self.abort(400, msg)
|
| + except permissions.PermissionException as e:
|
| + logging.warning('Trapped PermissionException %s', e)
|
| + if not self.mr.auth.user_id:
|
| + # If not logged in, let them log in
|
| + url = _SafeCreateLoginURL(self.mr)
|
| + self.redirect(url, abort=True)
|
| + else:
|
| + # Display the missing permissions template.
|
| + self.response.status = httplib.FORBIDDEN
|
| + page_data = {'reason': e.message}
|
| + with self.profiler.Phase('gather base data'):
|
| + page_data.update(self.GatherBaseData(self.mr, nonce))
|
| + self._AddHelpDebugPageData(page_data)
|
| + self._missing_permissions_template.WriteResponse(
|
| + self.response, page_data, content_type=self.content_type)
|
| +
|
| + def SetCacheHeaders(self, response):
|
| + """Set headers to allow the response to be cached."""
|
| + headers = framework_helpers.StaticCacheHeaders()
|
| + for name, value in headers:
|
| + response.headers[name] = value
|
| +
|
| + def GetTemplate(self, _page_data):
|
| + """Get the template to use for writing the http response.
|
| +
|
| + Defaults to self.template. This method can be overwritten in subclasses
|
| + to allow dynamic template selection based on page_data.
|
| +
|
| + Args:
|
| + _page_data: A dict of data for ezt rendering, containing base ezt
|
| + data, captcha data, page data, and debug data.
|
| +
|
| + Returns:
|
| + The template to be used for writing the http response.
|
| + """
|
| + return self.template
|
| +
|
| + def _GatherFlagData(self, mr):
|
| + page_data = {
|
| + 'recaptcha_public_key': secrets_svc.GetRecaptchaPublicKey(),
|
| + 'project_stars_enabled': ezt.boolean(
|
| + settings.enable_project_stars),
|
| + 'user_stars_enabled': ezt.boolean(settings.enable_user_stars),
|
| + 'can_create_project': ezt.boolean(
|
| + permissions.CanCreateProject(mr.perms)),
|
| + 'can_create_group': ezt.boolean(
|
| + permissions.CanCreateGroup(mr.perms)),
|
| + }
|
| +
|
| + return page_data
|
| +
|
| + def _RenderResponse(self, page_data):
|
| + logging.info('rendering response len(page_data) is %r', len(page_data))
|
| + self.GetTemplate(page_data).WriteResponse(
|
| + self.response, page_data, content_type=self.content_type)
|
| +
|
| + def ProcessFormData(self, mr, post_data):
|
| + """Handle form data and redirect appropriately.
|
| +
|
| + Args:
|
| + mr: commonly used info parsed from the request.
|
| + post_data: HTML form data from the request.
|
| +
|
| + Returns:
|
| + String URL to redirect the user to, or None if response was already sent.
|
| + """
|
| + raise MethodNotSupportedError()
|
| +
|
| + def post(self, **kwargs):
|
| + """Parse the request, check base perms, and call form-specific code."""
|
| + try:
|
| + # Page-specific work happens in this call.
|
| + self._DoFormProcessing(self.request, self.mr)
|
| +
|
| + except permissions.PermissionException as e:
|
| + logging.warning('Trapped permission-related exception "%s".', e)
|
| + # TODO(jrobbins): can we do better than an error page? not much.
|
| + self.response.status = httplib.BAD_REQUEST
|
| +
|
| + except issue_svc.MidAirCollisionException as e:
|
| + logging.info('Mid-air collision detected.')
|
| + collision_page_url = urls.ARTIFACT_COLLISION
|
| + url = framework_helpers.FormatAbsoluteURL(
|
| + self.mr, collision_page_url, copy_params=False,
|
| + name=e.name, continue_issue_id=e.continue_issue_id,
|
| + ts=int(time.time()))
|
| + self.redirect(url, abort=True)
|
| +
|
| + def _DoCommonRequestProcessing(self, request, mr):
|
| + """Do common processing dependent on having the user and project pbs."""
|
| + with self.profiler.Phase('basic processing'):
|
| + self._CheckForMovedProject(mr, request)
|
| + self.AssertBasePermission(mr)
|
| +
|
| + def _DoPageProcessing(self, mr, nonce):
|
| + """Do user lookups and gather page-specific ezt data."""
|
| + with self.profiler.Phase('common request data'):
|
| + self._DoCommonRequestProcessing(self.request, mr)
|
| + page_data = self.GatherBaseData(mr, nonce)
|
| + page_data.update(self.GatherCaptchaData(mr))
|
| +
|
| + with self.profiler.Phase('page processing'):
|
| + page_data.update(self.GatherPageData(mr))
|
| + page_data.update(mr.form_overrides)
|
| + template_helpers.ExpandLabels(page_data)
|
| +
|
| + return page_data
|
| +
|
| + def _DoFormProcessing(self, request, mr):
|
| + """Do user lookups and handle form data."""
|
| + self._DoCommonRequestProcessing(request, mr)
|
| +
|
| + if self.CHECK_SECURITY_TOKEN:
|
| + xsrf.ValidateToken(
|
| + request.POST.get('token'), mr.auth.user_id, request.path)
|
| +
|
| + redirect_url = self.ProcessFormData(mr, request.POST)
|
| +
|
| + # Most forms redirect the user to a new URL on success. If no
|
| + # redirect_url was returned, the form handler must have already
|
| + # sent a response. E.g., bounced the user back to the form with
|
| + # invalid form fields higlighted.
|
| + if redirect_url:
|
| + self.redirect(redirect_url, abort=True)
|
| + else:
|
| + assert self.response.body
|
| +
|
| + def _CheckForMovedProject(self, mr, request):
|
| + """If the project moved, redirect there or to an informational page."""
|
| + if not mr.project:
|
| + return # We are on a site-wide or user page.
|
| + if not mr.project.moved_to:
|
| + return # This project has not moved.
|
| + admin_url = '/p/%s%s' % (mr.project_name, urls.ADMIN_META)
|
| + if request.path.startswith(admin_url):
|
| + return # It moved, but we are near the page that can un-move it.
|
| +
|
| + logging.info('project %s has moved: %s', mr.project.project_name,
|
| + mr.project.moved_to)
|
| +
|
| + moved_to = mr.project.moved_to
|
| + if framework_bizobj.RE_PROJECT_NAME.match(moved_to):
|
| + # Use the redir query parameter to avoid redirect loops.
|
| + if mr.redir is None:
|
| + url = framework_helpers.FormatMovedProjectURL(mr, moved_to)
|
| + if '?' in url:
|
| + url += '&redir=1'
|
| + else:
|
| + url += '?redir=1'
|
| + logging.info('trusted move to a new project on our site')
|
| + self.redirect(url, abort=True)
|
| +
|
| + logging.info('not a trusted move, will display link to user to click')
|
| + # Attach the project name as a url param instead of generating a /p/
|
| + # link to the destination project.
|
| + url = framework_helpers.FormatAbsoluteURL(
|
| + mr, urls.PROJECT_MOVED,
|
| + include_project=False, copy_params=False, project=mr.project_name)
|
| + self.redirect(url, abort=True)
|
| +
|
| + def CheckPerm(self, mr, perm, art=None, granted_perms=None):
|
| + """Return True if the user can use the requested permission."""
|
| + return servlet_helpers.CheckPerm(
|
| + mr, perm, art=art, granted_perms=granted_perms)
|
| +
|
| + def MakePagePerms(self, mr, art, *perm_list, **kwargs):
|
| + """Make an EZTItem with a set of permissions needed in a given template.
|
| +
|
| + Args:
|
| + mr: commonly used info parsed from the request.
|
| + art: a project artifact, such as an issue.
|
| + *perm_list: any number of permission names that are referenced
|
| + in the EZT template.
|
| + **kwargs: dictionary that may include 'granted_perms' list of permissions
|
| + granted to the current user specifically on the current page.
|
| +
|
| + Returns:
|
| + An EZTItem with one attribute for each permission and the value
|
| + of each attribute being an ezt.boolean(). True if the user
|
| + is permitted to do that action on the given artifact, or
|
| + False if not.
|
| + """
|
| + granted_perms = kwargs.get('granted_perms')
|
| + page_perms = template_helpers.EZTItem()
|
| + for perm in perm_list:
|
| + setattr(
|
| + page_perms, perm,
|
| + ezt.boolean(self.CheckPerm(
|
| + mr, perm, art=art, granted_perms=granted_perms)))
|
| +
|
| + return page_perms
|
| +
|
| + def AssertBasePermission(self, mr):
|
| + """Make sure that the logged in user has permission to view this page.
|
| +
|
| + Subclasses should call super, then check additional permissions
|
| + and raise a PermissionException if the user is not authorized to
|
| + do something.
|
| +
|
| + Args:
|
| + mr: commonly used info parsed from the request.
|
| +
|
| + Raises:
|
| + PermissionException: If the user does not have permisssion to view
|
| + the current page.
|
| + """
|
| + servlet_helpers.AssertBasePermission(mr)
|
| +
|
| + def GatherBaseData(self, mr, nonce):
|
| + """Return a dict of info used on almost all pages."""
|
| + project = mr.project
|
| +
|
| + project_summary = ''
|
| + project_alert = None
|
| + project_read_only = False
|
| + project_home_page = ''
|
| + project_thumbnail_url = ''
|
| + if project:
|
| + project_summary = project.summary
|
| + project_alert = _CalcProjectAlert(project)
|
| + project_read_only = project.read_only_reason
|
| + project_home_page = project.home_page
|
| + project_thumbnail_url = tracker_views.LogoView(project).thumbnail_url
|
| +
|
| + # If we have both a project and a logged in user, we need to check if the
|
| + # user has starred that project.
|
| + with self.profiler.Phase('project star'):
|
| + is_project_starred = False
|
| + if mr.project and mr.auth.user_id:
|
| + is_project_starred = self.services.project_star.IsItemStarredBy(
|
| + mr.cnxn, mr.project_id, mr.auth.user_id)
|
| +
|
| + project_view = None
|
| + if mr.project:
|
| + # TODO(jrobbins): should this be a ProjectView?
|
| + project_view = template_helpers.PBProxy(mr.project)
|
| +
|
| + app_version = os.environ.get('CURRENT_VERSION_ID')
|
| +
|
| + viewed_username = None
|
| + if mr.viewed_user_auth.user_view:
|
| + viewed_username = mr.viewed_user_auth.user_view.username
|
| +
|
| + grid_x_attr = None
|
| + grid_y_attr = None
|
| + canned_query_views = []
|
| + issue_entry_url = 'entry'
|
| + if mr.project_id and self.services.config:
|
| + with self.profiler.Phase('getting config'):
|
| + config = self.services.config.GetProjectConfig(mr.cnxn, mr.project_id)
|
| + canned_queries = self.services.features.GetCannedQueriesByProjectID(
|
| + mr.cnxn, mr.project_id)
|
| + grid_x_attr = (mr.x or config.default_x_attr).lower()
|
| + grid_y_attr = (mr.y or config.default_y_attr).lower()
|
| + canned_query_views = [
|
| + savedqueries_helpers.SavedQueryView(sq, idx + 1, None, None)
|
| + for idx, sq in enumerate(canned_queries)]
|
| + issue_entry_url = _ComputeIssueEntryURL(mr, config)
|
| +
|
| + if mr.auth.user_id and self.services.features:
|
| + with self.profiler.Phase('getting saved queries'):
|
| + saved_queries = self.services.features.GetSavedQueriesByUserID(
|
| + mr.cnxn, mr.me_user_id)
|
| + saved_query_views = [
|
| + savedqueries_helpers.SavedQueryView(sq, idx + 1, None, None)
|
| + for idx, sq in enumerate(saved_queries)
|
| + if (mr.project_id in sq.executes_in_project_ids or
|
| + not mr.project_id)]
|
| + else:
|
| + saved_query_views = []
|
| +
|
| + viewing_self = mr.auth.user_id == mr.viewed_user_auth.user_id
|
| + offer_saved_queries_subtab = (
|
| + viewing_self or mr.auth.user_pb and mr.auth.user_pb.is_site_admin)
|
| +
|
| + login_url = _SafeCreateLoginURL(mr)
|
| + logout_url = _SafeCreateLogoutURL(mr)
|
| + logout_url_goto_home = users.create_logout_url('/')
|
| +
|
| + base_data = {
|
| + # EZT does not have constants for True and False, so we pass them in.
|
| + 'True': ezt.boolean(True),
|
| + 'False': ezt.boolean(False),
|
| +
|
| + 'site_name': settings.site_name,
|
| + 'show_search_metadata': ezt.boolean(False),
|
| + 'page_template': self._PAGE_TEMPLATE,
|
| + 'main_tab_mode': self._MAIN_TAB_MODE,
|
| + 'project_summary': project_summary,
|
| + 'project_home_page': project_home_page,
|
| + 'project_thumbnail_url': project_thumbnail_url,
|
| +
|
| + 'hostport': mr.request.host,
|
| + 'absolute_base_url': '%s://%s' % (mr.request.scheme, mr.request.host),
|
| + 'project_home_url': None,
|
| + 'link_rel_canonical': None, # For specifying <link rel="canonical">
|
| + 'projectname': mr.project_name,
|
| + 'project': project_view,
|
| + 'project_is_restricted': ezt.boolean(_ProjectIsRestricted(mr)),
|
| + 'offer_contributor_list': ezt.boolean(
|
| + permissions.CanViewContributorList(mr)),
|
| + 'logged_in_user': mr.auth.user_view,
|
| + 'form_token': None, # Set to a value below iff the user is logged in.
|
| + 'form_token_path': None,
|
| + 'token_expires_sec': None,
|
| + 'xhr_token': None, # Set to a value below iff the user is logged in.
|
| + 'flag_spam_token': None,
|
| + 'nonce': nonce,
|
| + 'perms': mr.perms,
|
| + 'warnings': mr.warnings,
|
| + 'errors': mr.errors,
|
| +
|
| + 'viewed_username': viewed_username,
|
| + 'viewed_user': mr.viewed_user_auth.user_view,
|
| + 'viewed_user_pb': template_helpers.PBProxy(
|
| + mr.viewed_user_auth.user_pb),
|
| + 'viewing_self': ezt.boolean(viewing_self),
|
| + 'viewed_user_id': mr.viewed_user_auth.user_id,
|
| + 'offer_saved_queries_subtab': ezt.boolean(offer_saved_queries_subtab),
|
| +
|
| + 'currentPageURL': mr.current_page_url,
|
| + 'currentPageURLEncoded': mr.current_page_url_encoded,
|
| + 'login_url': login_url,
|
| + 'logout_url': logout_url,
|
| + 'logout_url_goto_home': logout_url_goto_home,
|
| + 'continue_issue_id': mr.continue_issue_id,
|
| + 'feedback_email': settings.feedback_email,
|
| + 'category_css': None, # Used to specify a category of stylesheet
|
| + 'page_css': None, # Used to add a stylesheet to a specific page.
|
| +
|
| + 'can': mr.can,
|
| + 'query': mr.query,
|
| + 'colspec': None,
|
| + 'sortspec': mr.sort_spec,
|
| +
|
| + 'grid_x_attr': grid_x_attr,
|
| + 'grid_y_attr': grid_y_attr,
|
| + 'grid_cell_mode': mr.cells,
|
| + 'grid_mode': None,
|
| +
|
| + 'issue_entry_url': issue_entry_url,
|
| + 'canned_queries': canned_query_views,
|
| + 'saved_queries': saved_query_views,
|
| + 'is_cross_project': ezt.boolean(False),
|
| +
|
| + # for project search (some also used in issue search)
|
| + 'start': mr.start,
|
| + 'num': mr.num,
|
| + 'groupby': mr.group_by_spec,
|
| + 'q_field_size': (
|
| + min(framework_constants.MAX_ARTIFACT_SEARCH_FIELD_SIZE,
|
| + max(framework_constants.MIN_ARTIFACT_SEARCH_FIELD_SIZE,
|
| + len(mr.query) + framework_constants.AUTOSIZE_STEP))),
|
| + 'mode': None, # Display mode, e.g., grid mode.
|
| + 'ajah': mr.ajah,
|
| + 'table_title': mr.table_title,
|
| +
|
| + 'alerts': alerts.AlertsView(mr), # For alert.ezt
|
| + 'project_alert': project_alert,
|
| +
|
| + 'title': None, # First part of page title
|
| + 'title_summary': None, # Appended to title on artifact detail pages
|
| +
|
| + # TODO(jrobbins): make sure that the templates use
|
| + # project_read_only for project-mutative actions and if any
|
| + # uses of read_only remain.
|
| + 'project_read_only': ezt.boolean(project_read_only),
|
| + 'site_read_only': ezt.boolean(settings.read_only),
|
| + 'banner_time': servlet_helpers.GetBannerTime(settings.banner_time),
|
| + 'read_only': ezt.boolean(settings.read_only or project_read_only),
|
| + 'site_banner_message': settings.banner_message,
|
| + 'robots_no_index': None,
|
| + 'analytics_id': settings.analytics_id,
|
| +
|
| + 'is_project_starred': ezt.boolean(is_project_starred),
|
| +
|
| + 'app_version': app_version,
|
| + 'viewing_user_page': ezt.boolean(False),
|
| + }
|
| +
|
| + if mr.project:
|
| + base_data['project_home_url'] = '/p/%s' % mr.project_name
|
| +
|
| + # Always add an anti-xsrf token when the user is logged in.
|
| + if mr.auth.user_id:
|
| + form_token_path = self._FormHandlerURL(mr.request.path)
|
| + base_data['form_token'] = xsrf.GenerateToken(
|
| + mr.auth.user_id, form_token_path)
|
| + base_data['form_token_path'] = form_token_path
|
| + base_data['token_expires_sec'] = xsrf.TokenExpiresSec()
|
| + base_data['xhr_token'] = xsrf.GenerateToken(
|
| + mr.auth.user_id, xsrf.XHR_SERVLET_PATH)
|
| + base_data['flag_spam_token'] = xsrf.GenerateToken(
|
| + mr.auth.user_id, '/p/%s%s.do' % (
|
| + mr.project_name, urls.ISSUE_FLAGSPAM_JSON))
|
| +
|
| + return base_data
|
| +
|
| + def _FormHandlerURL(self, path):
|
| + """Return the form handler for the main form on a page."""
|
| + if path.endswith('/'):
|
| + return path + 'edit.do'
|
| + elif path.endswith('.do'):
|
| + return path # This happens as part of PleaseCorrect().
|
| + else:
|
| + return path + '.do'
|
| +
|
| + def GatherCaptchaData(self, mr):
|
| + """If this page needs a captcha, return captcha info for use in EZT."""
|
| + if (mr.project and
|
| + framework_bizobj.UserIsInProject(mr.project, mr.auth.effective_ids)):
|
| + # Don't show users CAPTCHAs within their own projects.
|
| + return {'show_captcha': ezt.boolean(False)}
|
| +
|
| + show_captcha = any(actionlimit.NeedCaptcha(mr.auth.user_pb, action_type)
|
| + for action_type in self._CAPTCHA_ACTION_TYPES)
|
| + return {'show_captcha': ezt.boolean(show_captcha)}
|
| +
|
| + def GatherPageData(self, mr):
|
| + """Return a dict of page-specific ezt data."""
|
| + raise MethodNotSupportedError()
|
| +
|
| + # pylint: disable=unused-argument
|
| + def GatherHelpData(self, mr, page_data):
|
| + """Return a dict of values to drive on-page user help.
|
| +
|
| + Args:
|
| + mr: common information parsed from the HTTP request.
|
| + page_data: Dictionary of base and page template data.
|
| +
|
| + Returns:
|
| + A dict of values to drive on-page user help, to be added to page_data.
|
| + """
|
| + return {
|
| + 'cue': None, # for cues.ezt
|
| + }
|
| +
|
| + def GatherDebugData(self, mr, page_data):
|
| + """Return debugging info for display at the very bottom of the page."""
|
| + if mr.debug_enabled:
|
| + debug = [_ContextDebugCollection('Page data', page_data)]
|
| + return {
|
| + 'dbg': 'on',
|
| + 'debug': debug,
|
| + 'profiler': self.profiler,
|
| + }
|
| + else:
|
| + if '?' in mr.current_page_url:
|
| + debug_url = mr.current_page_url + '&debug=1'
|
| + else:
|
| + debug_url = mr.current_page_url + '?debug=1'
|
| +
|
| + return {
|
| + 'debug_uri': debug_url,
|
| + 'dbg': 'off',
|
| + 'debug': [('none', 'recorded')],
|
| + }
|
| +
|
| + def CheckCaptcha(self, mr, post_data):
|
| + """Check the provided CAPTCHA solution and add an error if it is wrong."""
|
| + if (mr.project and
|
| + framework_bizobj.UserIsInProject(mr.project, mr.auth.effective_ids)):
|
| + return # Don't check a user's actions within their own projects.
|
| +
|
| + if not any(actionlimit.NeedCaptcha(mr.auth.user_pb, action_type)
|
| + for action_type in self._CAPTCHA_ACTION_TYPES):
|
| + return # no captcha was needed.
|
| +
|
| + remote_ip = mr.request.remote_addr
|
| + captcha_response = post_data.get('g-recaptcha-response')
|
| + correct, _msg = captcha.Verify(remote_ip, captcha_response)
|
| + if not correct:
|
| + logging.info('BZzzz! Bad captcha solution.')
|
| + mr.errors.captcha = 'Captcha check failed.'
|
| +
|
| + def CountRateLimitedActions(self, mr, action_counts):
|
| + """Count attempted actions against non-member's action limits.
|
| +
|
| + Note that users can take any number of actions in their own projects.
|
| +
|
| + Args:
|
| + mr: commonly used info parsed from the request.
|
| + action_counts: {action_type: delta, ... }
|
| + a dictionary mapping action type constants to the number of times
|
| + that action was performed during the current request (usually 1).
|
| + """
|
| + if (mr.project and
|
| + framework_bizobj.UserIsInProject(mr.project, mr.auth.effective_ids)):
|
| + # Don't count a user's actions within their own projects...
|
| + return
|
| +
|
| + for action_type in action_counts:
|
| + actionlimit.CountAction(
|
| + mr.auth.user_pb, action_type, delta=action_counts[action_type])
|
| +
|
| + self.services.user.UpdateUser(mr.cnxn, mr.auth.user_id, mr.auth.user_pb)
|
| +
|
| + def PleaseCorrect(self, mr, **echo_data):
|
| + """Show the same form again so that the user can correct their input."""
|
| + mr.PrepareForReentry(echo_data)
|
| + self.get()
|
| +
|
| +
|
| +def _CalcProjectAlert(project):
|
| + """Return a string to be shown as red text explaning the project state."""
|
| +
|
| + project_alert = None
|
| +
|
| + if project.read_only_reason:
|
| + project_alert = 'READ-ONLY: %s.' % project.read_only_reason
|
| + if project.moved_to:
|
| + project_alert = 'This project has moved to: %s.' % project.moved_to
|
| + elif project.delete_time:
|
| + delay_seconds = project.delete_time - time.time()
|
| + delay_days = delay_seconds // framework_constants.SECS_PER_DAY
|
| + if delay_days <= 0:
|
| + project_alert = 'Scheduled for deletion today.'
|
| + else:
|
| + days_word = 'day' if delay_days == 1 else 'days'
|
| + project_alert = (
|
| + 'Scheduled for deletion in %d %s.' % (delay_days, days_word))
|
| + elif project.state == project_pb2.ProjectState.ARCHIVED:
|
| + project_alert = 'Project is archived: read-only by members only.'
|
| +
|
| + return project_alert
|
| +
|
| +
|
| +class _ContextDebugItem(object):
|
| + """Wrapper class to generate on-screen debugging output."""
|
| +
|
| + def __init__(self, key, val):
|
| + """Store the key and generate a string for the value."""
|
| + self.key = key
|
| + if isinstance(val, list):
|
| + nested_debug_strs = [self.StringRep(v) for v in val]
|
| + self.val = '[%s]' % ', '.join(nested_debug_strs)
|
| + else:
|
| + self.val = self.StringRep(val)
|
| +
|
| + def StringRep(self, val):
|
| + """Make a useful string representation of the given value."""
|
| + try:
|
| + return val.DebugString()
|
| + except Exception:
|
| + try:
|
| + return str(val.__dict__)
|
| + except Exception:
|
| + return repr(val)
|
| +
|
| +
|
| +class _ContextDebugCollection(object):
|
| + """Attach a title to a dictionary for exporting as a table of debug info."""
|
| +
|
| + def __init__(self, title, collection):
|
| + self.title = title
|
| + self.collection = [_ContextDebugItem(key, collection[key])
|
| + for key in sorted(collection.iterkeys())]
|
| +
|
| +
|
| +def _ProjectIsRestricted(mr):
|
| + """Return True if the mr has a 'private' project."""
|
| + return (mr.project and
|
| + mr.project.access != project_pb2.ProjectAccess.ANYONE)
|
| +
|
| +
|
| +def _ComputeIssueEntryURL(mr, config):
|
| + """Compute the URL to use for the "New issue" subtab.
|
| +
|
| + Args:
|
| + mr: commonly used info parsed from the request.
|
| + config: ProjectIssueConfig for the current project.
|
| +
|
| + Returns:
|
| + A URL string to use. It will be simply "entry" in the non-customized
|
| + case. Otherewise it will be a fully qualified URL that includes some
|
| + query string parameters.
|
| + """
|
| + if not config.custom_issue_entry_url:
|
| + return 'entry'
|
| +
|
| + base_url = config.custom_issue_entry_url
|
| + sep = '&' if '?' in base_url else '?'
|
| + token = xsrf.GenerateToken(
|
| + mr.auth.user_id, '/p/%s%s%s' % (mr.project_name, urls.ISSUE_ENTRY, '.do'))
|
| + role_name = framework_helpers.GetRoleName(mr.auth.effective_ids, mr.project)
|
| +
|
| + continue_url = urllib.quote(framework_helpers.FormatAbsoluteURL(
|
| + mr, urls.ISSUE_ENTRY + '.do'))
|
| +
|
| + return '%s%stoken=%s&role=%s&continue=%s' % (
|
| + base_url, sep, urllib.quote(token),
|
| + urllib.quote(role_name or ''), continue_url)
|
| +
|
| +
|
| +def _SafeCreateLoginURL(mr):
|
| + """Make a login URL w/ a detailed continue URL, otherwise use a short one."""
|
| + try:
|
| + return users.create_login_url(mr.current_page_url)
|
| + except users.RedirectTooLongError:
|
| + if mr.project_name:
|
| + return users.create_login_url('/p/%s' % mr.project_name)
|
| + else:
|
| + return users.create_login_url('/')
|
| +
|
| +
|
| +def _SafeCreateLogoutURL(mr):
|
| + """Make a logout URL w/ a detailed continue URL, otherwise use a short one."""
|
| + try:
|
| + return users.create_logout_url(mr.current_page_url)
|
| + except users.RedirectTooLongError:
|
| + if mr.project_name:
|
| + return users.create_logout_url('/p/%s' % mr.project_name)
|
| + else:
|
| + return users.create_logout_url('/')
|
| +
|
| +
|
| +class Error(Exception):
|
| + """Base class for errors from this module."""
|
| + pass
|
| +
|
| +
|
| +class AlreadySentResponseException(Error):
|
| + """The servlet already responded, no need to render a page template."""
|
| + pass
|
|
|