nettika/geary
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Detect deleted (or moved) messages in open folder: #3793

Browse source 
This commit finishes the second half of #3793 by detecting when messages have been deleted
(or moved out of) an open folder and notifying the system of the change.  The nonblocking
synchronization primitives have been beefed up and may be broken out to a separate library
some day.

This commit also introduces the ReplayQueue, which replays events that occur on the server
locally.  This class will probably become much more important as time goes on, perhaps used
to store user events that are replayed on the server as well.
This commit is contained in:
Jim Nelson 2011-07-29 20:10:43 -07:00
parent d1208e8efe
commit 7442caf88e
21 changed files with 485 additions and 118 deletions
Download patch file Download diff file Expand all files Collapse all files

45
src/engine/sqlite/email/sqlite-message-location-table.vala
View file

@ -178,6 +178,27 @@ public class Geary.Sqlite.MessageLocationTable : Geary.Sqlite.Table {
folder_id, ordering, -1);
}
public async int fetch_position_async(int64 id, int64 folder_id, Cancellable? cancellable = null)
throws Error {
SQLHeavy.Query query = db.prepare(
"SELECT id FROM MessageLocationTable WHERE folder_id = ? ORDER BY ordering");
query.bind_int64(0, folder_id);
SQLHeavy.QueryResult results = yield query.execute_async(cancellable);
int position = 1;
while (!results.finished) {
if (results.fetch_int64(0) == id)
return position;
yield results.next_async(cancellable);
position++;
}
// not found
return -1;
}
public async int fetch_count_for_folder_async(int64 folder_id, Cancellable? cancellable = null)
throws Error {
SQLHeavy.Query query = db.prepare(
@ -219,14 +240,30 @@ public class Geary.Sqlite.MessageLocationTable : Geary.Sqlite.Table {
return (!result.finished) ? result.fetch_int64(0) : -1;
}
public async void remove_by_ordering_async(int64 folder_id, int64 ordering,
public async bool remove_by_position_async(int64 folder_id, int position,
Cancellable? cancellable = null) throws Error {
SQLHeavy.Query query = db.prepare(
"DELETE FROM MessageLocationTable WHERE folder_id = ? AND ordering = ?");
assert(position >= 1);
SQLHeavy.Transaction transaction = db.begin_transaction();
SQLHeavy.Query query = transaction.prepare(
"SELECT id FROM MessageLocationTable WHERE folder_id = ? ORDER BY ordering LIMIT 1 OFFSET ?");
query.bind_int64(0, folder_id);
query.bind_int64(1, ordering);
query.bind_int(1, position - 1);
SQLHeavy.QueryResult results = yield query.execute_async(cancellable);
if (results.finished)
return false;
query = transaction.prepare(
"DELETE FROM MessageLocationTable WHERE id = ?");
query.bind_int64(0, results.fetch_int(0));
yield query.execute_async(cancellable);
yield transaction.commit_async();
return true;
}
}