| Index: my_activity.py
|
| diff --git a/my_activity.py b/my_activity.py
|
| index fa08a0c9c83db517e5d70258b193485e660d0f17..33694eba48ef50c364159257385cce52393c9083 100755
|
| --- a/my_activity.py
|
| +++ b/my_activity.py
|
| @@ -21,7 +21,6 @@ Example:
|
| # This means that query time scales mostly with (today() - begin).
|
|
|
| import cookielib
|
| -import csv
|
| import datetime
|
| from datetime import datetime
|
| from datetime import timedelta
|
| @@ -29,7 +28,6 @@ from functools import partial
|
| import json
|
| import optparse
|
| import os
|
| -import re
|
| import subprocess
|
| import sys
|
| import urllib
|
| @@ -39,9 +37,6 @@ import gerrit_util
|
| import rietveld
|
| from third_party import upload
|
|
|
| -# Imported later, once options are set.
|
| -webkitpy = None
|
| -
|
| try:
|
| from dateutil.relativedelta import relativedelta # pylint: disable=F0401
|
| except ImportError:
|
| @@ -54,38 +49,6 @@ try:
|
| except ImportError:
|
| print 'Consider installing python-keyring'
|
|
|
| -def webkit_account(user):
|
| - if not webkitpy:
|
| - return None
|
| - committer_list = webkitpy.common.config.committers.CommitterList()
|
| - email = user + "@chromium.org"
|
| - return committer_list.account_by_email(email)
|
| -
|
| -def user_to_webkit_email(user):
|
| - account = webkit_account(user)
|
| - if not account:
|
| - return None
|
| - return account.emails[0]
|
| -
|
| -def user_to_webkit_owner_search(user):
|
| - account = webkit_account(user)
|
| - if not account:
|
| - return ['--author=%s@chromium.org' % user]
|
| - search = []
|
| - for email in account.emails:
|
| - search.append('--author=' + email)
|
| - # commit-bot is author for contributors who are not committers.
|
| - search.append('--grep=Patch by ' + account.full_name)
|
| - return search
|
| -
|
| -def user_to_webkit_reviewer_search(user):
|
| - committer_list = webkitpy.common.config.committers.CommitterList()
|
| - email = user + "@chromium.org"
|
| - account = committer_list.reviewer_by_email(email)
|
| - if not account:
|
| - return []
|
| - return ['--grep=Reviewed by ' + account.full_name]
|
| -
|
| rietveld_instances = [
|
| {
|
| 'url': 'codereview.chromium.org',
|
| @@ -157,29 +120,6 @@ google_code_projects = [
|
| },
|
| ]
|
|
|
| -bugzilla_instances = [
|
| - {
|
| - 'search_url': 'http://bugs.webkit.org/buglist.cgi',
|
| - 'url': 'wkb.ug',
|
| - 'user_func': user_to_webkit_email,
|
| - },
|
| -]
|
| -
|
| -git_instances = [
|
| - {
|
| - 'option': 'webkit_repo',
|
| - 'change_re':
|
| - r'git-svn-id: http://svn\.webkit\.org/repository/webkit/trunk@(\d*)',
|
| - 'change_url': 'trac.webkit.org/changeset',
|
| - 'review_re': r'https://bugs\.webkit\.org/show_bug\.cgi\?id\=(\d*)',
|
| - 'review_url': 'wkb.ug',
|
| - 'review_prop': 'webkit_bug_id',
|
| -
|
| - 'owner_search_func': user_to_webkit_owner_search,
|
| - 'reviewer_search_func': user_to_webkit_reviewer_search,
|
| - },
|
| -]
|
| -
|
| # Uses ClientLogin to authenticate the user for Google Code issue trackers.
|
| def get_auth_token(email):
|
| # KeyringCreds will use the system keyring on the first try, and prompt for
|
| @@ -269,9 +209,6 @@ class MyActivity(object):
|
| self.issues = []
|
| self.check_cookies()
|
| self.google_code_auth_token = None
|
| - self.webkit_repo = options.webkit_repo
|
| - if self.webkit_repo:
|
| - self.setup_webkit_info()
|
|
|
| # Check the codereview cookie jar to determine which Rietveld instances to
|
| # authenticate to.
|
| @@ -608,195 +545,6 @@ class MyActivity(object):
|
| ret.append(e)
|
| return ret
|
|
|
| - @staticmethod
|
| - def git_cmd(repo, *args):
|
| - cmd = ['git', '--git-dir=%s/.git' % repo]
|
| - cmd.extend(args)
|
| - [stdout, _] = subprocess.Popen(cmd, stdout=subprocess.PIPE,
|
| - stderr=subprocess.PIPE).communicate()
|
| - lines = str(stdout).split('\n')[:-1]
|
| - return lines
|
| -
|
| - def git_search(self, instance, owner=None, reviewer=None):
|
| - repo = getattr(self, instance['option'])
|
| - if not repo:
|
| - return []
|
| -
|
| - search = []
|
| - if owner:
|
| - search.extend(instance['owner_search_func'](owner))
|
| - if reviewer:
|
| - search.extend(instance['reviewer_search_func'](reviewer))
|
| - if not len(search):
|
| - return []
|
| -
|
| - self.git_cmd(repo, 'fetch', 'origin')
|
| -
|
| - time_format = '%Y-%m-%d %H:%M:%S'
|
| - log_args = [
|
| - '--after=' + self.modified_after.strftime(time_format),
|
| - '--before=' + self.modified_before.strftime(time_format),
|
| - '--format=%H'
|
| - ]
|
| - commits = set()
|
| - for query in search:
|
| - query_args = [query]
|
| - query_args.extend(log_args)
|
| - commits |= set(self.git_cmd(repo, 'log', 'origin/master', *query_args))
|
| -
|
| - ret = []
|
| - for commit in commits:
|
| - output = self.git_cmd(repo, 'log', commit + "^!", "--format=%cn%n%cd%n%B")
|
| - author = output[0]
|
| - date = datetime.strptime(output[1], "%a %b %d %H:%M:%S %Y +0000")
|
| - processed = self.process_git_commit(instance, author, date, output[2:])
|
| - if processed:
|
| - ret.append(processed)
|
| -
|
| - ret = sorted(ret, key=lambda i: i['modified'], reverse=True)
|
| - return ret
|
| -
|
| - @staticmethod
|
| - def process_git_commit(instance, author, date, log):
|
| - ret = {}
|
| - ret['owner'] = author
|
| - ret['author'] = author
|
| - ret['modified'] = date
|
| - ret['created'] = date
|
| - ret['header'] = log[0]
|
| -
|
| - reviews = []
|
| - reviewers = []
|
| - changes = []
|
| -
|
| - for line in log:
|
| - match = re.match(r'Reviewed by ([^.]*)', line)
|
| - if match:
|
| - reviewers.append(match.group(1))
|
| - if instance['review_re']:
|
| - match = re.match(instance['review_re'], line)
|
| - if match:
|
| - reviews.append(int(match.group(1)))
|
| - if instance['change_re']:
|
| - match = re.match(instance['change_re'], line)
|
| - if match:
|
| - changes.append(int(match.group(1)))
|
| -
|
| - committer_list = webkitpy.common.config.committers.CommitterList()
|
| - ret['reviewers'] = set(
|
| - (committer_list.contributor_by_name(r).emails[0] for r in reviewers))
|
| -
|
| - # Reviews more useful than change link itself, but tricky if multiple
|
| - # Reviews == bugs for WebKit changes
|
| - if len(reviews) == 1:
|
| - url = 'http://%s/%d' % (instance['review_url'], reviews[0])
|
| - if instance['review_prop']:
|
| - ret[instance['review_prop']] = reviews[0]
|
| - elif len(changes) == 1:
|
| - url = 'http://%s/%d' % (instance['change_url'], changes[0])
|
| - else:
|
| - # Couldn't find anything.
|
| - return None
|
| - ret['review_url'] = url
|
| -
|
| - return ret
|
| -
|
| - def bugzilla_issues(self, instance, user):
|
| - if instance['user_func']:
|
| - user = instance['user_func'](user)
|
| - if not user:
|
| - return []
|
| -
|
| - # This search is a little iffy, as it returns any bug that has been
|
| - # modified over a time period in any way and that a user has ever commented
|
| - # on, but that's the best that Bugzilla can get us. Oops.
|
| - commented = { 'emaillongdesc1': 1 }
|
| - issues = self.bugzilla_search(instance, user, commented)
|
| - issues = filter(lambda issue: issue['owner'] != user, issues)
|
| -
|
| - reported = { 'emailreporter1': 1, 'chfield': '[Bug creation]' }
|
| - issues.extend(self.bugzilla_search(instance, user, reported))
|
| -
|
| - # Remove duplicates by bug id
|
| - seen = {}
|
| - pruned = []
|
| - for issue in issues:
|
| - bug_id = issue['webkit_bug_id']
|
| - if bug_id in seen:
|
| - continue
|
| - seen[bug_id] = True
|
| - pruned.append(issue)
|
| -
|
| - # Bugzilla has no modified time, so sort by id?
|
| - pruned = sorted(pruned, key=lambda i: i['webkit_bug_id'])
|
| - return issues
|
| -
|
| - def bugzilla_search(self, instance, user, params):
|
| - time_format = '%Y-%m-%d'
|
| - values = {
|
| - 'chfieldfrom': self.modified_after.strftime(time_format),
|
| - 'chfieldto': self.modified_before.strftime(time_format),
|
| - 'ctype': 'csv',
|
| - 'emailtype1': 'substring',
|
| - 'email1': '%s' % user,
|
| - }
|
| - values.update(params)
|
| -
|
| - # Must be GET not POST
|
| - data = urllib.urlencode(values)
|
| - req = urllib2.Request("%s?%s" % (instance['search_url'], data))
|
| - response = urllib2.urlopen(req)
|
| - reader = csv.reader(response)
|
| - reader.next() # skip the header line
|
| -
|
| - issues = map(partial(self.process_bugzilla_issue, instance), reader)
|
| - return issues
|
| -
|
| - @staticmethod
|
| - def process_bugzilla_issue(instance, issue):
|
| - bug_id, owner, desc = int(issue[0]), issue[4], issue[7]
|
| -
|
| - ret = {}
|
| - ret['owner'] = owner
|
| - ret['author'] = owner
|
| - ret['review_url'] = 'http://%s/%d' % (instance['url'], bug_id)
|
| - ret['url'] = ret['review_url']
|
| - ret['header'] = desc
|
| - ret['webkit_bug_id'] = bug_id
|
| - return ret
|
| -
|
| - def setup_webkit_info(self):
|
| - assert(self.webkit_repo)
|
| - git_dir = os.path.normpath(self.webkit_repo + "/.git")
|
| - if not os.path.exists(git_dir):
|
| - print "%s doesn't exist, skipping WebKit checks." % git_dir
|
| - self.webkit_repo = None
|
| - return
|
| -
|
| - try:
|
| - self.git_cmd(self.webkit_repo, "fetch", "origin")
|
| - except subprocess.CalledProcessError:
|
| - print "Failed to update WebKit repo, skipping WebKit checks."
|
| - self.webkit_repo = None
|
| - return
|
| -
|
| - path = "Tools/Scripts"
|
| - full_path = os.path.normpath("%s/%s" % (self.options.webkit_repo, path))
|
| - sys.path.append(full_path)
|
| -
|
| - try:
|
| - global webkitpy
|
| - webkitpy = __import__('webkitpy.common.config.committers')
|
| - except ImportError:
|
| - print "Failed to import WebKit committer list, skipping WebKit checks."
|
| - self.webkit_repo = None
|
| - return
|
| -
|
| - if not webkit_account(self.user):
|
| - email = self.user + "@chromium.org"
|
| - print "No %s in committers.py, skipping WebKit checks." % email
|
| - self.webkit_repo = None
|
| -
|
| def print_heading(self, heading):
|
| print
|
| print self.options.output_format_heading.format(heading=heading)
|
| @@ -893,9 +641,6 @@ class MyActivity(object):
|
| for instance in gerrit_instances:
|
| self.changes += self.gerrit_search(instance, owner=self.user)
|
|
|
| - for instance in git_instances:
|
| - self.changes += self.git_search(instance, owner=self.user)
|
| -
|
| def print_changes(self):
|
| if self.changes:
|
| self.print_heading('Changes')
|
| @@ -911,9 +656,6 @@ class MyActivity(object):
|
| reviews = filter(lambda r: not username(r['owner']) == self.user, reviews)
|
| self.reviews += reviews
|
|
|
| - for instance in git_instances:
|
| - self.reviews += self.git_search(instance, reviewer=self.user)
|
| -
|
| def print_reviews(self):
|
| if self.reviews:
|
| self.print_heading('Reviews')
|
| @@ -924,29 +666,12 @@ class MyActivity(object):
|
| for project in google_code_projects:
|
| self.issues += self.google_code_issue_search(project)
|
|
|
| - for instance in bugzilla_instances:
|
| - self.issues += self.bugzilla_issues(instance, self.user)
|
| -
|
| def print_issues(self):
|
| if self.issues:
|
| self.print_heading('Issues')
|
| for issue in self.issues:
|
| self.print_issue(issue)
|
|
|
| - def process_activities(self):
|
| - # If a webkit bug was a review, don't list it as an issue.
|
| - ids = {}
|
| - for review in self.reviews + self.changes:
|
| - if 'webkit_bug_id' in review:
|
| - ids[review['webkit_bug_id']] = True
|
| -
|
| - def duplicate_issue(issue):
|
| - if 'webkit_bug_id' not in issue:
|
| - return False
|
| - return issue['webkit_bug_id'] in ids
|
| -
|
| - self.issues = filter(lambda issue: not duplicate_issue(issue), self.issues)
|
| -
|
| def print_activity(self):
|
| self.print_changes()
|
| self.print_reviews()
|
| @@ -963,10 +688,6 @@ def main():
|
| default=os.environ.get('USER'),
|
| help='Filter on user, default=%default')
|
| parser.add_option(
|
| - '--webkit_repo', metavar='<dir>',
|
| - default='%s' % os.environ.get('WEBKIT_DIR'),
|
| - help='Local path to WebKit repository, default=%default')
|
| - parser.add_option(
|
| '-b', '--begin', metavar='<date>',
|
| help='Filter issues created after the date')
|
| parser.add_option(
|
| @@ -1107,8 +828,6 @@ def main():
|
| if options.issues:
|
| my_activity.get_issues()
|
|
|
| - my_activity.process_activities()
|
| -
|
| print '\n\n\n'
|
|
|
| my_activity.print_changes()
|
|
|