x/stackalytics
Code Issues Proposed changes

Change regexp to named placeholders

Browse Source 
Change-Id: Ib39c605c8071833a44de3398583f6160fec775c2
This commit is contained in:
Herman Narkaytis
2013-09-25 17:04:46 +04:00
parent 2ea04f368b
commit 8820e840cf
4 changed files with 16 additions and 35 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
dashboard/web.py
View File

@@ -912,7 +912,6 @@ def get_commit_report(records):
@exception_handler()
def blueprint_report(module, blueprint_name):
memory_storage_inst = get_vault()['memory_storage']
runtime_storage_inst = get_vault()['runtime_storage']
blueprint_id = module + ':' + blueprint_name
@@ -931,9 +930,6 @@ def blueprint_report(module, blueprint_name):
activity = []
for record in memory_storage_inst.get_records(record_ids):
_extend_record(record)
if record['record_type'] == 'email':
record['body'] = (runtime_storage_inst.get_by_key('email:%s' %
record['primary_key']))
activity.append(record)
activity.sort(key=lambda x: x['date'])

4
stackalytics/processor/main.py
View File

@@ -80,9 +80,9 @@ def process_repo(repo, runtime_storage_inst, record_processor_inst):
bp_iterator = lp.log(repo)
bp_iterator_typed = _record_typer(bp_iterator, 'bp')
processed_mail_iterator = record_processor_inst.process(
processed_bp_iterator = record_processor_inst.process(
bp_iterator_typed)
runtime_storage_inst.set_records(processed_mail_iterator)
runtime_storage_inst.set_records(processed_bp_iterator)
vcs_inst = vcs.get_vcs(repo, cfg.CONF.sources_root)
vcs_inst.fetch()

36
stackalytics/processor/mls.py
View File

@@ -33,11 +33,12 @@ EMAIL_HEADER_PATTERN = ('From \S+(?: at \S+)?\s+'
MAIL_BOX_PATTERN = re.compile(
'^' + EMAIL_HEADER_PATTERN +
'From: (\S+(?: at \S+))(?:\W+(\w+(?:\s\w+)*))?.*?\n'
'Date: (.*?)\n'
'Subject: (.*?)(?=\n\S+:)'
'.*?Message-ID: (\S+)\n'
'\n(.*?)\n'
'From: (?P<author_email>\S+(?: at \S+))'
'(?:\W+(?P<author_name>\w+(?:\s\w+)*))?.*?\n'
'Date: (?P<date>.*?)\n'
'Subject: (?P<subject>.*?)(?=\n\S+:)'
'.*?Message-ID: (?P<message_id>\S+)\n'
'\n(?P<body>.*?)\n'
'(?=' + EMAIL_HEADER_PATTERN + 'From: )',
flags=re.MULTILINE | re.DOTALL)
@@ -90,30 +91,17 @@ def _retrieve_mails(uri):
content += TRAILING_RECORD
for rec in re.finditer(MAIL_BOX_PATTERN, content):
author_email = rec.group(1).replace(' at ', '@', 1)
if not utils.check_email_validity(author_email):
email = rec.groupdict()
email['author_email'] = email['author_email'].replace(' at ', '@', 1)
if not utils.check_email_validity(email['author_email']):
continue
author_name = rec.group(2)
date = int(email_utils.mktime_tz(
email_utils.parsedate_tz(rec.group(3))))
subject = rec.group(4)
message_id = rec.group(5)
body = rec.group(6)
email = {
'message_id': message_id,
'author_name': author_name,
'author_email': author_email,
'subject': subject,
'date': date,
'body': body,
}
email['date'] = int(email_utils.mktime_tz(
email_utils.parsedate_tz(email['date'])))
for pattern_name, pattern in MESSAGE_PATTERNS.iteritems():
collection = set()
for item in re.finditer(pattern, body):
for item in re.finditer(pattern, email['body']):
groups = item.groupdict()
item_id = groups['id']
if 'module' in groups:

7
stackalytics/processor/record_processor.py
View File

@@ -282,11 +282,8 @@ class RecordProcessor(object):
self._update_record_and_user(record)
self._guess_module(record)
if record.get('blueprint_id'):
self.runtime_storage_inst.set_by_key(
'email:%s' % record['primary_key'], record['body'])
del record['body']
if not record.get('blueprint_id'):
del record['body']
yield record