ttygroup
/
boartty
Code Issues Proposed changes

Sync starred changes regardless of subscription 

This is nearly exactly the same as syncing own changes, so make
that task more generic and re-use it.

Change-Id: I952ede3057b3a7caf779401be01e97261bec31d9
This commit is contained in:
James E. Blair 2015-03-27 15:57:52 -07:00
parent caac2d18fe
commit 7e162dd3c1
1 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
gertty/sync.py
View File

@ -240,7 +240,10 @@ class SyncSubscribedProjectsTask(Task):
t = SyncProjectTask(keys[i:i+10], self.priority)
self.tasks.append(t)
sync.submitTask(t)
t = SyncOwnChangesTask(self.priority)
t = SyncQueriedChangesTask('owner', 'is:owner', self.priority)
self.tasks.append(t)
sync.submitTask(t)
t = SyncQueriedChangesTask('starred', 'is:starred', self.priority)
self.tasks.append(t)
sync.submitTask(t)
@ -314,18 +317,21 @@ class SetProjectUpdatedTask(Task):
project = session.getProject(self.project_key)
project.updated = self.updated
class SyncOwnChangesTask(Task):
query_name = 'owner'
class SyncQueriedChangesTask(Task):
def __init__(self, query_name, query, priority=NORMAL_PRIORITY):
super(SyncQueriedChangesTask, self).__init__(priority)
self.query_name = query_name
self.query = query
def __repr__(self):
return '<SyncOwnChangesTask>'
return '<SyncQueriedChangesTask %s>' % self.query_name
def run(self, sync):
app = sync.app
now = datetime.datetime.utcnow()
with app.db.getSession() as session:
sync_query = session.getSyncQueryByName(self.query_name)
query = 'q=is:owner'
query = 'q=%s' % self.query
if sync_query.updated:
# Allow 4 seconds for request time, etc.
query += ' -age:%ss' % (int(math.ceil((now-sync_query.updated).total_seconds())) + 4,)