mirror of https://github.com/tasks/tasks
Remember The Milk Background Synchronization.
- the synchronization process can either happen in the foreground with UI dialogs or in the background with logging to LogCat - UI and dialogs for setting up auto-sync - rename "SynchronizationService" => "SynchronizationProvider", created a service called "SynchronizationService"pull/14/head
Tim Su
17 years ago
parent
60af08f0b1
commit
655c839550
@ -0,0 +1,578 @@
|
|||||||
|
/*
|
||||||
|
* ASTRID: Android's Simple Task Recording Dashboard
|
||||||
|
*
|
||||||
|
* Copyright (c) 2009 Tim Su
|
||||||
|
*
|
||||||
|
* This program is free software; you can redistribute it and/or modify
|
||||||
|
* it under the terms of the GNU General Public License as published by
|
||||||
|
* the Free Software Foundation; either version 2 of the License, or
|
||||||
|
* (at your option) any later version.
|
||||||
|
*
|
||||||
|
* This program is distributed in the hope that it will be useful, but
|
||||||
|
* WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
|
||||||
|
* or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
|
||||||
|
* for more details.
|
||||||
|
*
|
||||||
|
* You should have received a copy of the GNU General Public License along
|
||||||
|
* with this program; if not, write to the Free Software Foundation, Inc.,
|
||||||
|
* 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
|
||||||
|
*/
|
||||||
|
package com.timsu.astrid.sync;
|
||||||
|
|
||||||
|
import java.io.IOException;
|
||||||
|
import java.util.HashMap;
|
||||||
|
import java.util.HashSet;
|
||||||
|
import java.util.LinkedList;
|
||||||
|
|
||||||
|
import android.app.Dialog;
|
||||||
|
import android.app.ProgressDialog;
|
||||||
|
import android.content.Context;
|
||||||
|
import android.content.DialogInterface;
|
||||||
|
import android.content.res.Resources;
|
||||||
|
import android.os.Handler;
|
||||||
|
import android.util.Log;
|
||||||
|
|
||||||
|
import com.timsu.astrid.R;
|
||||||
|
import com.timsu.astrid.data.alerts.AlertController;
|
||||||
|
import com.timsu.astrid.data.sync.SyncDataController;
|
||||||
|
import com.timsu.astrid.data.sync.SyncMapping;
|
||||||
|
import com.timsu.astrid.data.tag.TagController;
|
||||||
|
import com.timsu.astrid.data.tag.TagIdentifier;
|
||||||
|
import com.timsu.astrid.data.tag.TagModelForView;
|
||||||
|
import com.timsu.astrid.data.task.TaskController;
|
||||||
|
import com.timsu.astrid.data.task.TaskIdentifier;
|
||||||
|
import com.timsu.astrid.data.task.TaskModelForSync;
|
||||||
|
import com.timsu.astrid.utilities.DialogUtilities;
|
||||||
|
import com.timsu.astrid.utilities.Notifications;
|
||||||
|
import com.timsu.astrid.utilities.Preferences;
|
||||||
|
|
||||||
|
/** A service that synchronizes with Astrid
|
||||||
|
*
|
||||||
|
* @author timsu
|
||||||
|
*
|
||||||
|
*/
|
||||||
|
public abstract class SynchronizationProvider {
|
||||||
|
|
||||||
|
private int id;
|
||||||
|
static ProgressDialog progressDialog;
|
||||||
|
private Handler syncHandler;
|
||||||
|
private boolean backgroundSync;
|
||||||
|
|
||||||
|
public SynchronizationProvider(int id) {
|
||||||
|
this.id = id;
|
||||||
|
}
|
||||||
|
|
||||||
|
// called off the UI thread. does some setup
|
||||||
|
void synchronizeService(final Context activity, boolean isBackgroundSync) {
|
||||||
|
this.backgroundSync = isBackgroundSync;
|
||||||
|
|
||||||
|
if(!isBackgroundService()) {
|
||||||
|
syncHandler = new Handler();
|
||||||
|
SynchronizationProvider.progressDialog = new ProgressDialog(activity);
|
||||||
|
progressDialog.setIcon(android.R.drawable.ic_dialog_alert);
|
||||||
|
progressDialog.setTitle("Synchronization");
|
||||||
|
progressDialog.setProgressStyle(ProgressDialog.STYLE_HORIZONTAL);
|
||||||
|
progressDialog.setMax(100);
|
||||||
|
progressDialog.setMessage("Checking Authorization...");
|
||||||
|
progressDialog.setProgress(0);
|
||||||
|
progressDialog.setCancelable(false);
|
||||||
|
progressDialog.show();
|
||||||
|
}
|
||||||
|
|
||||||
|
synchronize(activity);
|
||||||
|
}
|
||||||
|
|
||||||
|
/** Synchronize with the service */
|
||||||
|
protected abstract void synchronize(Context activity);
|
||||||
|
|
||||||
|
/** Called when user requests a data clear */
|
||||||
|
abstract void clearPersonalData(Context activity);
|
||||||
|
|
||||||
|
/** Get this service's id */
|
||||||
|
public int getId() {
|
||||||
|
return id;
|
||||||
|
}
|
||||||
|
|
||||||
|
/** Gets this service's name */
|
||||||
|
abstract String getName();
|
||||||
|
|
||||||
|
// --- utilities
|
||||||
|
|
||||||
|
/** Check whether this synchronization request is running in the background
|
||||||
|
* @return true if it's running as a background service
|
||||||
|
*/
|
||||||
|
protected boolean isBackgroundService() {
|
||||||
|
return backgroundSync;
|
||||||
|
}
|
||||||
|
|
||||||
|
/** Utility method for showing synchronization errors. If message is null,
|
||||||
|
* the contents of the throwable is displayed.
|
||||||
|
*/
|
||||||
|
void showError(final Context context, Throwable e, String message) {
|
||||||
|
Log.e("astrid", "Synchronization Error", e);
|
||||||
|
|
||||||
|
if(isBackgroundService())
|
||||||
|
return;
|
||||||
|
|
||||||
|
Resources r = context.getResources();
|
||||||
|
final String messageToDisplay;
|
||||||
|
if(message == null) {
|
||||||
|
messageToDisplay = r.getString(R.string.sync_error) + " " +
|
||||||
|
e.toString() + " - " + e.getStackTrace()[1];
|
||||||
|
} else {
|
||||||
|
messageToDisplay = message;
|
||||||
|
}
|
||||||
|
syncHandler.post(new Runnable() {
|
||||||
|
public void run() {
|
||||||
|
if(progressDialog != null)
|
||||||
|
progressDialog.dismiss();
|
||||||
|
DialogUtilities.okDialog(context, messageToDisplay, null);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
/** Utility method to update the UI if we're an active sync, or output
|
||||||
|
* to console if we're a background sync.
|
||||||
|
*/
|
||||||
|
protected void postUpdate(Runnable updater) {
|
||||||
|
if(isBackgroundService()) {
|
||||||
|
// only run jobs if they can actually be processed
|
||||||
|
if(updater instanceof ProgressLabelUpdater)
|
||||||
|
updater.run();
|
||||||
|
} else {
|
||||||
|
syncHandler.post(updater);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// --- synchronization logic
|
||||||
|
|
||||||
|
/** interface to assist with synchronization */
|
||||||
|
protected interface SynchronizeHelper {
|
||||||
|
/** Push the given task to the remote server.
|
||||||
|
*
|
||||||
|
* @param task task proxy to push
|
||||||
|
* @param remoteTask remote task that we merged with, or null
|
||||||
|
* @param mapping local/remote mapping.
|
||||||
|
*/
|
||||||
|
void pushTask(TaskProxy task, TaskProxy remoteTask,
|
||||||
|
SyncMapping mapping) throws IOException;
|
||||||
|
|
||||||
|
/** Create a task on the remote server. This is followed by a call of
|
||||||
|
* pushTask on the id in question.
|
||||||
|
*
|
||||||
|
* @return task to create
|
||||||
|
* @return remote id
|
||||||
|
*/
|
||||||
|
String createTask(TaskModelForSync task) throws IOException;
|
||||||
|
|
||||||
|
/** Fetch remote task. Used to re-read merged tasks
|
||||||
|
*
|
||||||
|
* @param task TaskProxy of the original task
|
||||||
|
* @return new TaskProxy
|
||||||
|
*/
|
||||||
|
TaskProxy refetchTask(TaskProxy task) throws IOException;
|
||||||
|
|
||||||
|
/** Delete the task from the remote server
|
||||||
|
*
|
||||||
|
* @param mapping mapping to delete
|
||||||
|
*/
|
||||||
|
void deleteTask(SyncMapping mapping) throws IOException;
|
||||||
|
}
|
||||||
|
|
||||||
|
/** Helper to synchronize remote tasks with our local database.
|
||||||
|
*
|
||||||
|
* This initiates the following process:
|
||||||
|
* 1. local changes are read
|
||||||
|
* 2. remote changes are read
|
||||||
|
* 3. local tasks are merged with remote changes and pushed across
|
||||||
|
* 4. remote changes are then read in
|
||||||
|
*
|
||||||
|
* @param remoteTasks remote tasks that have been updated
|
||||||
|
* @return local tasks that need to be pushed across
|
||||||
|
*/
|
||||||
|
protected void synchronizeTasks(final Context context, LinkedList<TaskProxy>
|
||||||
|
remoteTasks, SynchronizeHelper helper) throws IOException {
|
||||||
|
final SyncStats stats = new SyncStats();
|
||||||
|
final StringBuilder log = new StringBuilder();
|
||||||
|
|
||||||
|
SyncDataController syncController = Synchronizer.getSyncController(context);
|
||||||
|
TaskController taskController = Synchronizer.getTaskController(context);
|
||||||
|
TagController tagController = Synchronizer.getTagController(context);
|
||||||
|
AlertController alertController = Synchronizer.getAlertController(context);
|
||||||
|
SyncData data = new SyncData(context, remoteTasks);
|
||||||
|
|
||||||
|
// 1. CREATE: grab tasks without a sync mapping and create them remotely
|
||||||
|
log.append(">> on remote server:\n");
|
||||||
|
for(TaskIdentifier taskId : data.newlyCreatedTasks) {
|
||||||
|
TaskModelForSync task = taskController.fetchTaskForSync(taskId);
|
||||||
|
postUpdate(new ProgressLabelUpdater("Sending local task: " +
|
||||||
|
task.getName()));
|
||||||
|
postUpdate(new ProgressUpdater(stats.remoteCreatedTasks,
|
||||||
|
data.newlyCreatedTasks.size()));
|
||||||
|
|
||||||
|
/* If there exists an incoming remote task with the same name and
|
||||||
|
* no mapping, we don't want to create this on the remote server.
|
||||||
|
* Instead, we create a mapping and do an update. */
|
||||||
|
if(data.newRemoteTasks.containsKey(task.getName())) {
|
||||||
|
TaskProxy remoteTask = data.newRemoteTasks.get(task.getName());
|
||||||
|
SyncMapping mapping = new SyncMapping(taskId, getId(),
|
||||||
|
remoteTask.getRemoteId());
|
||||||
|
syncController.saveSyncMapping(mapping);
|
||||||
|
data.localChanges.add(mapping);
|
||||||
|
data.remoteChangeMap.put(taskId, remoteTask);
|
||||||
|
data.localIdToSyncMapping.put(taskId, mapping);
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
String remoteId = helper.createTask(task);
|
||||||
|
SyncMapping mapping = new SyncMapping(taskId, getId(), remoteId);
|
||||||
|
syncController.saveSyncMapping(mapping);
|
||||||
|
data.localIdToSyncMapping.put(taskId, mapping);
|
||||||
|
|
||||||
|
TaskProxy localTask = new TaskProxy(getId(), remoteId, false);
|
||||||
|
localTask.readFromTaskModel(task);
|
||||||
|
localTask.readTagsFromController(taskId, tagController, data.tags);
|
||||||
|
helper.pushTask(localTask, null, mapping);
|
||||||
|
|
||||||
|
// update stats
|
||||||
|
log.append("added '" + task.getName() + "'\n");
|
||||||
|
stats.remoteCreatedTasks++;
|
||||||
|
}
|
||||||
|
|
||||||
|
// 2. DELETE: find deleted tasks and remove them from the list
|
||||||
|
postUpdate(new ProgressLabelUpdater("Sending locally deleted tasks"));
|
||||||
|
for(TaskIdentifier taskId : data.deletedTasks) {
|
||||||
|
SyncMapping mapping = data.localIdToSyncMapping.get(taskId);
|
||||||
|
syncController.deleteSyncMapping(mapping);
|
||||||
|
helper.deleteTask(mapping);
|
||||||
|
|
||||||
|
// remove it from data structures
|
||||||
|
data.localChanges.remove(mapping);
|
||||||
|
data.localIdToSyncMapping.remove(taskId);
|
||||||
|
data.remoteIdToSyncMapping.remove(mapping);
|
||||||
|
data.remoteChangeMap.remove(taskId);
|
||||||
|
|
||||||
|
// update stats
|
||||||
|
log.append("deleted id #" + taskId.getId() + "\n");
|
||||||
|
stats.remoteDeletedTasks++;
|
||||||
|
postUpdate(new ProgressUpdater(stats.remoteDeletedTasks,
|
||||||
|
data.deletedTasks.size()));
|
||||||
|
}
|
||||||
|
|
||||||
|
// 3. UPDATE: for each updated local task
|
||||||
|
for(SyncMapping mapping : data.localChanges) {
|
||||||
|
TaskProxy localTask = new TaskProxy(getId(), mapping.getRemoteId(),
|
||||||
|
false);
|
||||||
|
TaskModelForSync task = taskController.fetchTaskForSync(
|
||||||
|
mapping.getTask());
|
||||||
|
localTask.readFromTaskModel(task);
|
||||||
|
localTask.readTagsFromController(task.getTaskIdentifier(),
|
||||||
|
tagController, data.tags);
|
||||||
|
|
||||||
|
postUpdate(new ProgressLabelUpdater("Sending local task: " +
|
||||||
|
task.getName()));
|
||||||
|
postUpdate(new ProgressUpdater(stats.remoteUpdatedTasks,
|
||||||
|
data.localChanges.size()));
|
||||||
|
|
||||||
|
// if there is a conflict, merge
|
||||||
|
TaskProxy remoteConflict = null;
|
||||||
|
if(data.remoteChangeMap.containsKey(mapping.getTask())) {
|
||||||
|
remoteConflict = data.remoteChangeMap.get(mapping.getTask());
|
||||||
|
localTask.mergeWithOther(remoteConflict);
|
||||||
|
stats.mergedTasks++;
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
helper.pushTask(localTask, remoteConflict, mapping);
|
||||||
|
if(remoteConflict != null)
|
||||||
|
log.append("merged '" + task.getName() + "'\n");
|
||||||
|
else
|
||||||
|
log.append("updated '" + task.getName() + "'\n");
|
||||||
|
} catch (Exception e) {
|
||||||
|
Log.e("astrid", "Exception pushing task", e);
|
||||||
|
log.append("error sending '" + task.getName() + "'\n");
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
// re-fetch remote task
|
||||||
|
if(remoteConflict != null) {
|
||||||
|
TaskProxy newTask = helper.refetchTask(remoteConflict);
|
||||||
|
remoteTasks.remove(remoteConflict);
|
||||||
|
remoteTasks.add(newTask);
|
||||||
|
} else
|
||||||
|
stats.remoteUpdatedTasks++;
|
||||||
|
}
|
||||||
|
|
||||||
|
// 4. REMOTE SYNC load remote information
|
||||||
|
log.append("\n>> on astrid:\n");
|
||||||
|
postUpdate(new ProgressUpdater(0, 1));
|
||||||
|
for(TaskProxy remoteTask : remoteTasks) {
|
||||||
|
if(remoteTask.name != null)
|
||||||
|
postUpdate(new ProgressLabelUpdater("Updating local " +
|
||||||
|
"tasks: " + remoteTask.name));
|
||||||
|
else
|
||||||
|
postUpdate(new ProgressLabelUpdater("Updating local tasks"));
|
||||||
|
SyncMapping mapping = null;
|
||||||
|
TaskModelForSync task = null;
|
||||||
|
|
||||||
|
// if it's new, create a new task model
|
||||||
|
if(!data.remoteIdToSyncMapping.containsKey(remoteTask.getRemoteId())) {
|
||||||
|
// if it's new & deleted, forget about it
|
||||||
|
if(remoteTask.isDeleted()) {
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
task = taskController.searchForTaskForSync(remoteTask.name);
|
||||||
|
if(task == null) {
|
||||||
|
task = new TaskModelForSync();
|
||||||
|
setupTaskDefaults(context, task);
|
||||||
|
log.append("added " + remoteTask.name + "\n");
|
||||||
|
} else {
|
||||||
|
mapping = data.localIdToSyncMapping.get(task.getTaskIdentifier());
|
||||||
|
log.append("merged " + remoteTask.name + "\n");
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
mapping = data.remoteIdToSyncMapping.get(remoteTask.getRemoteId());
|
||||||
|
if(remoteTask.isDeleted()) {
|
||||||
|
taskController.deleteTask(mapping.getTask());
|
||||||
|
syncController.deleteSyncMapping(mapping);
|
||||||
|
log.append("deleted " + remoteTask.name + "\n");
|
||||||
|
stats.localDeletedTasks++;
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
log.append("updated '" + remoteTask.name + "'\n");
|
||||||
|
task = taskController.fetchTaskForSync(
|
||||||
|
mapping.getTask());
|
||||||
|
}
|
||||||
|
|
||||||
|
// save the data
|
||||||
|
remoteTask.writeToTaskModel(task);
|
||||||
|
taskController.saveTask(task);
|
||||||
|
|
||||||
|
// save tags
|
||||||
|
if(remoteTask.tags != null) {
|
||||||
|
LinkedList<TagIdentifier> taskTags = tagController.getTaskTags(task.getTaskIdentifier());
|
||||||
|
HashSet<TagIdentifier> tagsToAdd = new HashSet<TagIdentifier>();
|
||||||
|
for(String tag : remoteTask.tags) {
|
||||||
|
String tagLower = tag.toLowerCase();
|
||||||
|
if(!data.tagsByLCName.containsKey(tagLower)) {
|
||||||
|
TagIdentifier tagId = tagController.createTag(tag);
|
||||||
|
data.tagsByLCName.put(tagLower, tagId);
|
||||||
|
tagsToAdd.add(tagId);
|
||||||
|
} else
|
||||||
|
tagsToAdd.add(data.tagsByLCName.get(tagLower));
|
||||||
|
}
|
||||||
|
|
||||||
|
HashSet<TagIdentifier> tagsToDelete = new HashSet<TagIdentifier>(taskTags);
|
||||||
|
tagsToDelete.removeAll(tagsToAdd);
|
||||||
|
tagsToAdd.removeAll(taskTags);
|
||||||
|
|
||||||
|
for(TagIdentifier tagId : tagsToDelete)
|
||||||
|
tagController.removeTag(task.getTaskIdentifier(), tagId);
|
||||||
|
for(TagIdentifier tagId : tagsToAdd)
|
||||||
|
tagController.addTag(task.getTaskIdentifier(), tagId);
|
||||||
|
}
|
||||||
|
stats.localUpdatedTasks++;
|
||||||
|
|
||||||
|
// try looking for this task if it doesn't already have a mapping
|
||||||
|
if(mapping == null) {
|
||||||
|
mapping = data.localIdToSyncMapping.get(task.getTaskIdentifier());
|
||||||
|
if(mapping == null) {
|
||||||
|
try {
|
||||||
|
mapping = new SyncMapping(task.getTaskIdentifier(), remoteTask);
|
||||||
|
syncController.saveSyncMapping(mapping);
|
||||||
|
data.localIdToSyncMapping.put(task.getTaskIdentifier(),
|
||||||
|
mapping);
|
||||||
|
} catch (Exception e) {
|
||||||
|
// unique violation: ignore - it'll get merged later
|
||||||
|
Log.e("astrid-sync", "Exception creating mapping", e);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
stats.localCreatedTasks++;
|
||||||
|
}
|
||||||
|
|
||||||
|
Notifications.updateAlarm(context, taskController, alertController,
|
||||||
|
task);
|
||||||
|
postUpdate(new ProgressUpdater(stats.localUpdatedTasks,
|
||||||
|
remoteTasks.size()));
|
||||||
|
}
|
||||||
|
stats.localUpdatedTasks -= stats.localCreatedTasks;
|
||||||
|
|
||||||
|
syncController.clearUpdatedTaskList(getId());
|
||||||
|
postUpdate(new Runnable() {
|
||||||
|
public void run() {
|
||||||
|
stats.showDialog(context, log.toString());
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
/** Set up defaults from preferences for this task */
|
||||||
|
private void setupTaskDefaults(Context context, TaskModelForSync task) {
|
||||||
|
Integer reminder = Preferences.getDefaultReminder(context);
|
||||||
|
if(reminder != null)
|
||||||
|
task.setNotificationIntervalSeconds(24*3600*reminder);
|
||||||
|
}
|
||||||
|
|
||||||
|
// --- helper classes
|
||||||
|
|
||||||
|
/** data structure builder */
|
||||||
|
class SyncData {
|
||||||
|
HashSet<SyncMapping> mappings;
|
||||||
|
HashSet<TaskIdentifier> activeTasks;
|
||||||
|
HashSet<TaskIdentifier> allTasks;
|
||||||
|
|
||||||
|
HashMap<String, SyncMapping> remoteIdToSyncMapping;
|
||||||
|
HashMap<TaskIdentifier, SyncMapping> localIdToSyncMapping;
|
||||||
|
|
||||||
|
HashSet<SyncMapping> localChanges;
|
||||||
|
HashSet<TaskIdentifier> mappedTasks;
|
||||||
|
HashMap<TaskIdentifier, TaskProxy> remoteChangeMap;
|
||||||
|
HashMap<String, TaskProxy> newRemoteTasks;
|
||||||
|
|
||||||
|
HashMap<TagIdentifier, TagModelForView> tags;
|
||||||
|
HashMap<String, TagIdentifier> tagsByLCName;
|
||||||
|
|
||||||
|
HashSet<TaskIdentifier> newlyCreatedTasks;
|
||||||
|
HashSet<TaskIdentifier> deletedTasks;
|
||||||
|
|
||||||
|
public SyncData(Context context, LinkedList<TaskProxy> remoteTasks) {
|
||||||
|
// 1. get data out of the database
|
||||||
|
mappings = Synchronizer.getSyncController(context).getSyncMapping(getId());
|
||||||
|
activeTasks = Synchronizer.getTaskController(context).getActiveTaskIdentifiers();
|
||||||
|
allTasks = Synchronizer.getTaskController(context).getAllTaskIdentifiers();
|
||||||
|
tags = Synchronizer.getTagController(context).getAllTagsAsMap();
|
||||||
|
|
||||||
|
// 2. build helper data structures
|
||||||
|
remoteIdToSyncMapping = new HashMap<String, SyncMapping>();
|
||||||
|
localIdToSyncMapping = new HashMap<TaskIdentifier, SyncMapping>();
|
||||||
|
localChanges = new HashSet<SyncMapping>();
|
||||||
|
mappedTasks = new HashSet<TaskIdentifier>();
|
||||||
|
for(SyncMapping mapping : mappings) {
|
||||||
|
if(mapping.isUpdated())
|
||||||
|
localChanges.add(mapping);
|
||||||
|
remoteIdToSyncMapping.put(mapping.getRemoteId(), mapping);
|
||||||
|
localIdToSyncMapping.put(mapping.getTask(), mapping);
|
||||||
|
mappedTasks.add(mapping.getTask());
|
||||||
|
}
|
||||||
|
tagsByLCName = new HashMap<String, TagIdentifier>();
|
||||||
|
for(TagModelForView tag : tags.values())
|
||||||
|
tagsByLCName.put(tag.getName().toLowerCase(), tag.getTagIdentifier());
|
||||||
|
|
||||||
|
// 3. build map of remote tasks
|
||||||
|
remoteChangeMap = new HashMap<TaskIdentifier, TaskProxy>();
|
||||||
|
newRemoteTasks = new HashMap<String, TaskProxy>();
|
||||||
|
for(TaskProxy remoteTask : remoteTasks) {
|
||||||
|
if(remoteIdToSyncMapping.containsKey(remoteTask.getRemoteId())) {
|
||||||
|
SyncMapping mapping = remoteIdToSyncMapping.get(remoteTask.getRemoteId());
|
||||||
|
remoteChangeMap.put(mapping.getTask(), remoteTask);
|
||||||
|
} else if(remoteTask.name != null){
|
||||||
|
newRemoteTasks.put(remoteTask.name, remoteTask);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// 4. build data structures of things to do
|
||||||
|
newlyCreatedTasks = new HashSet<TaskIdentifier>(activeTasks);
|
||||||
|
newlyCreatedTasks.removeAll(mappedTasks);
|
||||||
|
deletedTasks = new HashSet<TaskIdentifier>(mappedTasks);
|
||||||
|
deletedTasks.removeAll(allTasks);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
/** statistics tracking and displaying */
|
||||||
|
protected class SyncStats {
|
||||||
|
int localCreatedTasks = 0;
|
||||||
|
int localUpdatedTasks = 0;
|
||||||
|
int localDeletedTasks = 0;
|
||||||
|
|
||||||
|
int mergedTasks = 0;
|
||||||
|
|
||||||
|
int remoteCreatedTasks = 0;
|
||||||
|
int remoteUpdatedTasks = 0;
|
||||||
|
int remoteDeletedTasks = 0;
|
||||||
|
|
||||||
|
/** Display a dialog with statistics */
|
||||||
|
public void showDialog(final Context context, String log) {
|
||||||
|
progressDialog.hide();
|
||||||
|
Resources r = context.getResources();
|
||||||
|
|
||||||
|
if(Preferences.shouldSuppressSyncDialogs(context))
|
||||||
|
return;
|
||||||
|
|
||||||
|
Dialog.OnClickListener finishListener = new Dialog.OnClickListener() {
|
||||||
|
public void onClick(DialogInterface dialog,
|
||||||
|
int which) {
|
||||||
|
Synchronizer.continueSynchronization(context);
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
// nothing updated
|
||||||
|
if(localCreatedTasks + localUpdatedTasks + localDeletedTasks +
|
||||||
|
mergedTasks + remoteCreatedTasks + remoteDeletedTasks +
|
||||||
|
remoteUpdatedTasks == 0) {
|
||||||
|
if(!isBackgroundService())
|
||||||
|
DialogUtilities.okDialog(context, "Sync: Up to date!", finishListener);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
StringBuilder sb = new StringBuilder();
|
||||||
|
sb.append(r.getString(R.string.sync_result_title, getName()));
|
||||||
|
sb.append("\n\n");
|
||||||
|
sb.append(log).append("\n");
|
||||||
|
if(localCreatedTasks + localUpdatedTasks + localDeletedTasks > 0)
|
||||||
|
sb.append(r.getString(R.string.sync_result_local)).append("\n");
|
||||||
|
if(localCreatedTasks > 0)
|
||||||
|
sb.append(r.getString(R.string.sync_result_created, localCreatedTasks)).append("\n");
|
||||||
|
if(localUpdatedTasks > 0)
|
||||||
|
sb.append(r.getString(R.string.sync_result_updated, localUpdatedTasks)).append("\n");
|
||||||
|
if(localDeletedTasks > 0)
|
||||||
|
sb.append(r.getString(R.string.sync_result_deleted, localDeletedTasks)).append("\n");
|
||||||
|
|
||||||
|
if(mergedTasks > 0)
|
||||||
|
sb.append("\n").append(r.getString(R.string.sync_result_merged, mergedTasks)).append("\n");
|
||||||
|
sb.append("\n");
|
||||||
|
|
||||||
|
if(remoteCreatedTasks + remoteDeletedTasks + remoteUpdatedTasks > 0)
|
||||||
|
sb.append(r.getString(R.string.sync_result_remote)).append("\n");
|
||||||
|
if(remoteCreatedTasks > 0)
|
||||||
|
sb.append(r.getString(R.string.sync_result_created, remoteCreatedTasks)).append("\n");
|
||||||
|
if(remoteUpdatedTasks > 0)
|
||||||
|
sb.append(r.getString(R.string.sync_result_updated, remoteUpdatedTasks)).append("\n");
|
||||||
|
if(remoteDeletedTasks > 0)
|
||||||
|
sb.append(r.getString(R.string.sync_result_deleted, remoteDeletedTasks)).append("\n");
|
||||||
|
|
||||||
|
sb.append("\n");
|
||||||
|
|
||||||
|
DialogUtilities.okDialog(context, sb.toString(), finishListener);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
protected class ProgressUpdater implements Runnable {
|
||||||
|
int step, outOf;
|
||||||
|
public ProgressUpdater(int step, int outOf) {
|
||||||
|
this.step = step;
|
||||||
|
this.outOf = outOf;
|
||||||
|
}
|
||||||
|
public void run() {
|
||||||
|
if(!isBackgroundService())
|
||||||
|
progressDialog.setProgress(100*step/outOf);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
protected class ProgressLabelUpdater implements Runnable {
|
||||||
|
String label;
|
||||||
|
public ProgressLabelUpdater(String label) {
|
||||||
|
this.label = label;
|
||||||
|
}
|
||||||
|
public void run() {
|
||||||
|
if(isBackgroundService()) {
|
||||||
|
Log.i("astrid-sync", label);
|
||||||
|
} else {
|
||||||
|
if(!progressDialog.isShowing())
|
||||||
|
progressDialog.show();
|
||||||
|
progressDialog.setMessage(label);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -1,542 +1,99 @@
|
|||||||
/*
|
|
||||||
* ASTRID: Android's Simple Task Recording Dashboard
|
|
||||||
*
|
|
||||||
* Copyright (c) 2009 Tim Su
|
|
||||||
*
|
|
||||||
* This program is free software; you can redistribute it and/or modify
|
|
||||||
* it under the terms of the GNU General Public License as published by
|
|
||||||
* the Free Software Foundation; either version 2 of the License, or
|
|
||||||
* (at your option) any later version.
|
|
||||||
*
|
|
||||||
* This program is distributed in the hope that it will be useful, but
|
|
||||||
* WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
|
|
||||||
* or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
|
|
||||||
* for more details.
|
|
||||||
*
|
|
||||||
* You should have received a copy of the GNU General Public License along
|
|
||||||
* with this program; if not, write to the Free Software Foundation, Inc.,
|
|
||||||
* 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
|
|
||||||
*/
|
|
||||||
package com.timsu.astrid.sync;
|
package com.timsu.astrid.sync;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.util.Date;
|
||||||
import java.util.HashMap;
|
import java.util.Timer;
|
||||||
import java.util.HashSet;
|
import java.util.TimerTask;
|
||||||
import java.util.LinkedList;
|
|
||||||
|
|
||||||
import android.app.Activity;
|
import android.app.Service;
|
||||||
import android.app.Dialog;
|
|
||||||
import android.app.ProgressDialog;
|
|
||||||
import android.content.Context;
|
import android.content.Context;
|
||||||
import android.content.DialogInterface;
|
import android.content.Intent;
|
||||||
import android.content.res.Resources;
|
import android.os.IBinder;
|
||||||
import android.os.Handler;
|
|
||||||
import android.util.Log;
|
import android.util.Log;
|
||||||
|
|
||||||
import com.timsu.astrid.R;
|
|
||||||
import com.timsu.astrid.data.alerts.AlertController;
|
|
||||||
import com.timsu.astrid.data.sync.SyncDataController;
|
|
||||||
import com.timsu.astrid.data.sync.SyncMapping;
|
|
||||||
import com.timsu.astrid.data.tag.TagController;
|
|
||||||
import com.timsu.astrid.data.tag.TagIdentifier;
|
|
||||||
import com.timsu.astrid.data.tag.TagModelForView;
|
|
||||||
import com.timsu.astrid.data.task.TaskController;
|
|
||||||
import com.timsu.astrid.data.task.TaskIdentifier;
|
|
||||||
import com.timsu.astrid.data.task.TaskModelForSync;
|
|
||||||
import com.timsu.astrid.utilities.DialogUtilities;
|
|
||||||
import com.timsu.astrid.utilities.Notifications;
|
|
||||||
import com.timsu.astrid.utilities.Preferences;
|
import com.timsu.astrid.utilities.Preferences;
|
||||||
|
|
||||||
/** A service that synchronizes with Astrid
|
public class SynchronizationService extends Service {
|
||||||
*
|
|
||||||
* @author timsu
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public abstract class SynchronizationService {
|
|
||||||
|
|
||||||
private int id;
|
/** Service timer */
|
||||||
static ProgressDialog progressDialog;
|
private Timer timer = new Timer();
|
||||||
protected Handler syncHandler;
|
|
||||||
public SynchronizationService(int id) {
|
|
||||||
this.id = id;
|
|
||||||
}
|
|
||||||
|
|
||||||
// called off the UI thread. does some setup
|
|
||||||
void synchronizeService(final Activity activity) {
|
|
||||||
syncHandler = new Handler();
|
|
||||||
SynchronizationService.progressDialog = new ProgressDialog(activity);
|
|
||||||
progressDialog.setIcon(android.R.drawable.ic_dialog_alert);
|
|
||||||
progressDialog.setTitle("Synchronization");
|
|
||||||
progressDialog.setProgressStyle(ProgressDialog.STYLE_HORIZONTAL);
|
|
||||||
progressDialog.setMax(100);
|
|
||||||
progressDialog.setMessage("Checking Authorization...");
|
|
||||||
progressDialog.setProgress(0);
|
|
||||||
progressDialog.setCancelable(false);
|
|
||||||
progressDialog.show();
|
|
||||||
|
|
||||||
synchronize(activity);
|
/** Service activity */
|
||||||
}
|
private static Context context;
|
||||||
|
|
||||||
/** Synchronize with the service */
|
/** Set the activity for this service */
|
||||||
protected abstract void synchronize(Activity activity);
|
public static void setContext(Context context) {
|
||||||
|
SynchronizationService.context = context;
|
||||||
|
}
|
||||||
|
|
||||||
/** Called when user requests a data clear */
|
@Override
|
||||||
abstract void clearPersonalData(Activity activity);
|
public IBinder onBind(Intent arg0) {
|
||||||
|
return null; // unused
|
||||||
/** Get this service's id */
|
|
||||||
public int getId() {
|
|
||||||
return id;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/** Gets this service's name */
|
@Override
|
||||||
abstract String getName();
|
public void onCreate() {
|
||||||
|
super.onCreate();
|
||||||
|
|
||||||
// --- utilities
|
// init the service here
|
||||||
|
startService();
|
||||||
|
|
||||||
/** Utility method for showing synchronization errors. If message is null,
|
|
||||||
* the contents of the throwable is displayed.
|
|
||||||
*/
|
|
||||||
void showError(final Context context, Throwable e, String message) {
|
|
||||||
Log.e("astrid", "Synchronization Error", e);
|
|
||||||
Resources r = context.getResources();
|
|
||||||
final String messageToDisplay;
|
|
||||||
if(message == null) {
|
|
||||||
messageToDisplay = r.getString(R.string.sync_error) + " " +
|
|
||||||
e.toString() + " - " + e.getStackTrace()[1];
|
|
||||||
} else {
|
|
||||||
messageToDisplay = message;
|
|
||||||
}
|
|
||||||
syncHandler.post(new Runnable() {
|
|
||||||
public void run() {
|
|
||||||
if(progressDialog != null)
|
|
||||||
progressDialog.dismiss();
|
|
||||||
DialogUtilities.okDialog(context, messageToDisplay, null);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// --- synchronization logic
|
@Override
|
||||||
|
public void onDestroy() {
|
||||||
|
super.onDestroy();
|
||||||
|
|
||||||
/** interface to assist with synchronization */
|
shutdownService();
|
||||||
protected interface SynchronizeHelper {
|
|
||||||
/** Push the given task to the remote server.
|
|
||||||
*
|
|
||||||
* @param task task proxy to push
|
|
||||||
* @param remoteTask remote task that we merged with, or null
|
|
||||||
* @param mapping local/remote mapping.
|
|
||||||
*/
|
|
||||||
void pushTask(TaskProxy task, TaskProxy remoteTask,
|
|
||||||
SyncMapping mapping) throws IOException;
|
|
||||||
|
|
||||||
/** Create a task on the remote server. This is followed by a call of
|
|
||||||
* pushTask on the id in question.
|
|
||||||
*
|
|
||||||
* @return task to create
|
|
||||||
* @return remote id
|
|
||||||
*/
|
|
||||||
String createTask(TaskModelForSync task) throws IOException;
|
|
||||||
|
|
||||||
/** Fetch remote task. Used to re-read merged tasks
|
|
||||||
*
|
|
||||||
* @param task TaskProxy of the original task
|
|
||||||
* @return new TaskProxy
|
|
||||||
*/
|
|
||||||
TaskProxy refetchTask(TaskProxy task) throws IOException;
|
|
||||||
|
|
||||||
/** Delete the task from the remote server
|
|
||||||
*
|
|
||||||
* @param mapping mapping to delete
|
|
||||||
*/
|
|
||||||
void deleteTask(SyncMapping mapping) throws IOException;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/** Helper to synchronize remote tasks with our local database.
|
/** Start the timer that runs the service */
|
||||||
*
|
private void startService() {
|
||||||
* This initiates the following process:
|
// figure out synchronization frequency
|
||||||
* 1. local changes are read
|
Integer syncFrequencySeconds = Preferences.getSyncAutoSyncFrequency(context);
|
||||||
* 2. remote changes are read
|
if(syncFrequencySeconds == null) {
|
||||||
* 3. local tasks are merged with remote changes and pushed across
|
shutdownService();
|
||||||
* 4. remote changes are then read in
|
return;
|
||||||
*
|
}
|
||||||
* @param remoteTasks remote tasks that have been updated
|
|
||||||
* @return local tasks that need to be pushed across
|
long interval = 1000L * syncFrequencySeconds;
|
||||||
*/
|
|
||||||
protected void synchronizeTasks(final Activity activity, LinkedList<TaskProxy>
|
// figure out last synchronize time
|
||||||
remoteTasks, SynchronizeHelper helper) throws IOException {
|
Date lastSyncDate = Preferences.getSyncLastSync(context);
|
||||||
final SyncStats stats = new SyncStats();
|
Date lastAutoSyncDate = Preferences.getSyncLastSyncAttempt(context);
|
||||||
final StringBuilder log = new StringBuilder();
|
long latestSyncMillis = 0;
|
||||||
|
if(lastSyncDate != null)
|
||||||
SyncDataController syncController = Synchronizer.getSyncController(activity);
|
latestSyncMillis = lastSyncDate.getTime();
|
||||||
TaskController taskController = Synchronizer.getTaskController(activity);
|
if(lastAutoSyncDate != null && lastAutoSyncDate.getTime() > latestSyncMillis)
|
||||||
TagController tagController = Synchronizer.getTagController(activity);
|
latestSyncMillis = lastAutoSyncDate.getTime();
|
||||||
AlertController alertController = Synchronizer.getAlertController(activity);
|
long offset = 0;
|
||||||
SyncData data = new SyncData(activity, remoteTasks);
|
if(latestSyncMillis != 0)
|
||||||
|
offset = Math.max(0, latestSyncMillis + interval - System.currentTimeMillis());
|
||||||
// 1. CREATE: grab tasks without a sync mapping and create them remotely
|
|
||||||
log.append(">> on remote server:\n");
|
timer.scheduleAtFixedRate(new TimerTask() {
|
||||||
for(TaskIdentifier taskId : data.newlyCreatedTasks) {
|
@Override
|
||||||
TaskModelForSync task = taskController.fetchTaskForSync(taskId);
|
public void run() {
|
||||||
syncHandler.post(new ProgressLabelUpdater("Sending local task: " +
|
performSynchronization();
|
||||||
task.getName()));
|
|
||||||
syncHandler.post(new ProgressUpdater(stats.remoteCreatedTasks,
|
|
||||||
data.newlyCreatedTasks.size()));
|
|
||||||
|
|
||||||
/* If there exists an incoming remote task with the same name and
|
|
||||||
* no mapping, we don't want to create this on the remote server.
|
|
||||||
* Instead, we create a mapping and do an update. */
|
|
||||||
if(data.newRemoteTasks.containsKey(task.getName())) {
|
|
||||||
TaskProxy remoteTask = data.newRemoteTasks.get(task.getName());
|
|
||||||
SyncMapping mapping = new SyncMapping(taskId, getId(),
|
|
||||||
remoteTask.getRemoteId());
|
|
||||||
syncController.saveSyncMapping(mapping);
|
|
||||||
data.localChanges.add(mapping);
|
|
||||||
data.remoteChangeMap.put(taskId, remoteTask);
|
|
||||||
data.localIdToSyncMapping.put(taskId, mapping);
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
|
|
||||||
String remoteId = helper.createTask(task);
|
|
||||||
SyncMapping mapping = new SyncMapping(taskId, getId(), remoteId);
|
|
||||||
syncController.saveSyncMapping(mapping);
|
|
||||||
data.localIdToSyncMapping.put(taskId, mapping);
|
|
||||||
|
|
||||||
TaskProxy localTask = new TaskProxy(getId(), remoteId, false);
|
|
||||||
localTask.readFromTaskModel(task);
|
|
||||||
localTask.readTagsFromController(activity, taskId, tagController, data.tags);
|
|
||||||
helper.pushTask(localTask, null, mapping);
|
|
||||||
|
|
||||||
// update stats
|
|
||||||
log.append("added '" + task.getName() + "'\n");
|
|
||||||
stats.remoteCreatedTasks++;
|
|
||||||
}
|
|
||||||
|
|
||||||
// 2. DELETE: find deleted tasks and remove them from the list
|
|
||||||
syncHandler.post(new ProgressLabelUpdater("Sending locally deleted tasks"));
|
|
||||||
for(TaskIdentifier taskId : data.deletedTasks) {
|
|
||||||
SyncMapping mapping = data.localIdToSyncMapping.get(taskId);
|
|
||||||
syncController.deleteSyncMapping(mapping);
|
|
||||||
helper.deleteTask(mapping);
|
|
||||||
|
|
||||||
// remove it from data structures
|
|
||||||
data.localChanges.remove(mapping);
|
|
||||||
data.localIdToSyncMapping.remove(taskId);
|
|
||||||
data.remoteIdToSyncMapping.remove(mapping);
|
|
||||||
data.remoteChangeMap.remove(taskId);
|
|
||||||
|
|
||||||
// update stats
|
|
||||||
log.append("deleted id #" + taskId.getId() + "\n");
|
|
||||||
stats.remoteDeletedTasks++;
|
|
||||||
syncHandler.post(new ProgressUpdater(stats.remoteDeletedTasks,
|
|
||||||
data.deletedTasks.size()));
|
|
||||||
}
|
|
||||||
|
|
||||||
// 3. UPDATE: for each updated local task
|
|
||||||
for(SyncMapping mapping : data.localChanges) {
|
|
||||||
TaskProxy localTask = new TaskProxy(getId(), mapping.getRemoteId(),
|
|
||||||
false);
|
|
||||||
TaskModelForSync task = taskController.fetchTaskForSync(
|
|
||||||
mapping.getTask());
|
|
||||||
localTask.readFromTaskModel(task);
|
|
||||||
localTask.readTagsFromController(activity, task.getTaskIdentifier(),
|
|
||||||
tagController, data.tags);
|
|
||||||
|
|
||||||
syncHandler.post(new ProgressLabelUpdater("Sending local task: " +
|
|
||||||
task.getName()));
|
|
||||||
syncHandler.post(new ProgressUpdater(stats.remoteUpdatedTasks,
|
|
||||||
data.localChanges.size()));
|
|
||||||
|
|
||||||
// if there is a conflict, merge
|
|
||||||
TaskProxy remoteConflict = null;
|
|
||||||
if(data.remoteChangeMap.containsKey(mapping.getTask())) {
|
|
||||||
remoteConflict = data.remoteChangeMap.get(mapping.getTask());
|
|
||||||
localTask.mergeWithOther(remoteConflict);
|
|
||||||
stats.mergedTasks++;
|
|
||||||
}
|
|
||||||
|
|
||||||
try {
|
|
||||||
helper.pushTask(localTask, remoteConflict, mapping);
|
|
||||||
if(remoteConflict != null)
|
|
||||||
log.append("merged '" + task.getName() + "'\n");
|
|
||||||
else
|
|
||||||
log.append("updated '" + task.getName() + "'\n");
|
|
||||||
} catch (Exception e) {
|
|
||||||
Log.e("astrid", "Exception pushing task", e);
|
|
||||||
log.append("error sending '" + task.getName() + "'\n");
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
|
|
||||||
// re-fetch remote task
|
|
||||||
if(remoteConflict != null) {
|
|
||||||
TaskProxy newTask = helper.refetchTask(remoteConflict);
|
|
||||||
remoteTasks.remove(remoteConflict);
|
|
||||||
remoteTasks.add(newTask);
|
|
||||||
} else
|
|
||||||
stats.remoteUpdatedTasks++;
|
|
||||||
}
|
|
||||||
|
|
||||||
// 4. REMOTE SYNC load remote information
|
|
||||||
log.append("\n>> on astrid:\n");
|
|
||||||
syncHandler.post(new ProgressUpdater(0, 1));
|
|
||||||
for(TaskProxy remoteTask : remoteTasks) {
|
|
||||||
if(remoteTask.name != null)
|
|
||||||
syncHandler.post(new ProgressLabelUpdater("Updating local " +
|
|
||||||
"tasks: " + remoteTask.name));
|
|
||||||
else
|
|
||||||
syncHandler.post(new ProgressLabelUpdater("Updating local tasks"));
|
|
||||||
SyncMapping mapping = null;
|
|
||||||
TaskModelForSync task = null;
|
|
||||||
|
|
||||||
// if it's new, create a new task model
|
|
||||||
if(!data.remoteIdToSyncMapping.containsKey(remoteTask.getRemoteId())) {
|
|
||||||
// if it's new & deleted, forget about it
|
|
||||||
if(remoteTask.isDeleted()) {
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
|
|
||||||
task = taskController.searchForTaskForSync(remoteTask.name);
|
|
||||||
if(task == null) {
|
|
||||||
task = new TaskModelForSync();
|
|
||||||
setupTaskDefaults(activity, task);
|
|
||||||
log.append("added " + remoteTask.name + "\n");
|
|
||||||
} else {
|
|
||||||
mapping = data.localIdToSyncMapping.get(task.getTaskIdentifier());
|
|
||||||
log.append("merged " + remoteTask.name + "\n");
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
mapping = data.remoteIdToSyncMapping.get(remoteTask.getRemoteId());
|
|
||||||
if(remoteTask.isDeleted()) {
|
|
||||||
taskController.deleteTask(mapping.getTask());
|
|
||||||
syncController.deleteSyncMapping(mapping);
|
|
||||||
log.append("deleted " + remoteTask.name + "\n");
|
|
||||||
stats.localDeletedTasks++;
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
|
|
||||||
log.append("updated '" + remoteTask.name + "'\n");
|
|
||||||
task = taskController.fetchTaskForSync(
|
|
||||||
mapping.getTask());
|
|
||||||
}
|
|
||||||
|
|
||||||
// save the data
|
|
||||||
remoteTask.writeToTaskModel(task);
|
|
||||||
taskController.saveTask(task);
|
|
||||||
|
|
||||||
// save tags
|
|
||||||
if(remoteTask.tags != null) {
|
|
||||||
LinkedList<TagIdentifier> taskTags = tagController.getTaskTags(activity, task.getTaskIdentifier());
|
|
||||||
HashSet<TagIdentifier> tagsToAdd = new HashSet<TagIdentifier>();
|
|
||||||
for(String tag : remoteTask.tags) {
|
|
||||||
String tagLower = tag.toLowerCase();
|
|
||||||
if(!data.tagsByLCName.containsKey(tagLower)) {
|
|
||||||
TagIdentifier tagId = tagController.createTag(tag);
|
|
||||||
data.tagsByLCName.put(tagLower, tagId);
|
|
||||||
tagsToAdd.add(tagId);
|
|
||||||
} else
|
|
||||||
tagsToAdd.add(data.tagsByLCName.get(tagLower));
|
|
||||||
}
|
|
||||||
|
|
||||||
HashSet<TagIdentifier> tagsToDelete = new HashSet<TagIdentifier>(taskTags);
|
|
||||||
tagsToDelete.removeAll(tagsToAdd);
|
|
||||||
tagsToAdd.removeAll(taskTags);
|
|
||||||
|
|
||||||
for(TagIdentifier tagId : tagsToDelete)
|
|
||||||
tagController.removeTag(task.getTaskIdentifier(), tagId);
|
|
||||||
for(TagIdentifier tagId : tagsToAdd)
|
|
||||||
tagController.addTag(task.getTaskIdentifier(), tagId);
|
|
||||||
}
|
}
|
||||||
stats.localUpdatedTasks++;
|
}, offset, interval);
|
||||||
|
Log.i("astrid", "Synchronization Service Started, Offset: " + offset/1000 +
|
||||||
// try looking for this task if it doesn't already have a mapping
|
"s Interval: " + interval/1000);
|
||||||
if(mapping == null) {
|
|
||||||
mapping = data.localIdToSyncMapping.get(task.getTaskIdentifier());
|
|
||||||
if(mapping == null) {
|
|
||||||
try {
|
|
||||||
mapping = new SyncMapping(task.getTaskIdentifier(), remoteTask);
|
|
||||||
syncController.saveSyncMapping(mapping);
|
|
||||||
data.localIdToSyncMapping.put(task.getTaskIdentifier(),
|
|
||||||
mapping);
|
|
||||||
} catch (Exception e) {
|
|
||||||
// unique violation: ignore - it'll get merged later
|
|
||||||
Log.e("astrid-sync", "Exception creating mapping", e);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
stats.localCreatedTasks++;
|
|
||||||
}
|
|
||||||
|
|
||||||
Notifications.updateAlarm(activity, taskController, alertController,
|
|
||||||
task);
|
|
||||||
syncHandler.post(new ProgressUpdater(stats.localUpdatedTasks,
|
|
||||||
remoteTasks.size()));
|
|
||||||
}
|
|
||||||
stats.localUpdatedTasks -= stats.localCreatedTasks;
|
|
||||||
|
|
||||||
syncController.clearUpdatedTaskList(getId());
|
|
||||||
syncHandler.post(new Runnable() {
|
|
||||||
public void run() {
|
|
||||||
stats.showDialog(activity, log.toString());
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/** Set up defaults from preferences for this task */
|
/** Stop the timer that runs the service */
|
||||||
private void setupTaskDefaults(Activity activity, TaskModelForSync task) {
|
private void shutdownService() {
|
||||||
Integer reminder = Preferences.getDefaultReminder(activity);
|
if (timer != null)
|
||||||
if(reminder != null)
|
timer.cancel();
|
||||||
task.setNotificationIntervalSeconds(24*3600*reminder);
|
Log.i("astrid", "Synchronization Service Stopped");
|
||||||
}
|
}
|
||||||
|
|
||||||
// --- helper classes
|
/** Perform the actual synchronization */
|
||||||
|
private void performSynchronization() {
|
||||||
/** data structure builder */
|
if(context == null || context.getResources() == null)
|
||||||
class SyncData {
|
return;
|
||||||
HashSet<SyncMapping> mappings;
|
|
||||||
HashSet<TaskIdentifier> activeTasks;
|
|
||||||
HashSet<TaskIdentifier> allTasks;
|
|
||||||
|
|
||||||
HashMap<String, SyncMapping> remoteIdToSyncMapping;
|
|
||||||
HashMap<TaskIdentifier, SyncMapping> localIdToSyncMapping;
|
|
||||||
|
|
||||||
HashSet<SyncMapping> localChanges;
|
|
||||||
HashSet<TaskIdentifier> mappedTasks;
|
|
||||||
HashMap<TaskIdentifier, TaskProxy> remoteChangeMap;
|
|
||||||
HashMap<String, TaskProxy> newRemoteTasks;
|
|
||||||
|
|
||||||
HashMap<TagIdentifier, TagModelForView> tags;
|
|
||||||
HashMap<String, TagIdentifier> tagsByLCName;
|
|
||||||
|
|
||||||
HashSet<TaskIdentifier> newlyCreatedTasks;
|
|
||||||
HashSet<TaskIdentifier> deletedTasks;
|
|
||||||
|
|
||||||
public SyncData(Activity activity, LinkedList<TaskProxy> remoteTasks) {
|
|
||||||
// 1. get data out of the database
|
|
||||||
mappings = Synchronizer.getSyncController(activity).getSyncMapping(getId());
|
|
||||||
activeTasks = Synchronizer.getTaskController(activity).getActiveTaskIdentifiers();
|
|
||||||
allTasks = Synchronizer.getTaskController(activity).getAllTaskIdentifiers();
|
|
||||||
tags = Synchronizer.getTagController(activity).getAllTagsAsMap(activity);
|
|
||||||
|
|
||||||
// 2. build helper data structures
|
|
||||||
remoteIdToSyncMapping = new HashMap<String, SyncMapping>();
|
|
||||||
localIdToSyncMapping = new HashMap<TaskIdentifier, SyncMapping>();
|
|
||||||
localChanges = new HashSet<SyncMapping>();
|
|
||||||
mappedTasks = new HashSet<TaskIdentifier>();
|
|
||||||
for(SyncMapping mapping : mappings) {
|
|
||||||
if(mapping.isUpdated())
|
|
||||||
localChanges.add(mapping);
|
|
||||||
remoteIdToSyncMapping.put(mapping.getRemoteId(), mapping);
|
|
||||||
localIdToSyncMapping.put(mapping.getTask(), mapping);
|
|
||||||
mappedTasks.add(mapping.getTask());
|
|
||||||
}
|
|
||||||
tagsByLCName = new HashMap<String, TagIdentifier>();
|
|
||||||
for(TagModelForView tag : tags.values())
|
|
||||||
tagsByLCName.put(tag.getName().toLowerCase(), tag.getTagIdentifier());
|
|
||||||
|
|
||||||
// 3. build map of remote tasks
|
|
||||||
remoteChangeMap = new HashMap<TaskIdentifier, TaskProxy>();
|
|
||||||
newRemoteTasks = new HashMap<String, TaskProxy>();
|
|
||||||
for(TaskProxy remoteTask : remoteTasks) {
|
|
||||||
if(remoteIdToSyncMapping.containsKey(remoteTask.getRemoteId())) {
|
|
||||||
SyncMapping mapping = remoteIdToSyncMapping.get(remoteTask.getRemoteId());
|
|
||||||
remoteChangeMap.put(mapping.getTask(), remoteTask);
|
|
||||||
} else if(remoteTask.name != null){
|
|
||||||
newRemoteTasks.put(remoteTask.name, remoteTask);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// 4. build data structures of things to do
|
|
||||||
newlyCreatedTasks = new HashSet<TaskIdentifier>(activeTasks);
|
|
||||||
newlyCreatedTasks.removeAll(mappedTasks);
|
|
||||||
deletedTasks = new HashSet<TaskIdentifier>(mappedTasks);
|
|
||||||
deletedTasks.removeAll(allTasks);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
|
Log.i("astrid", "Automatic Synchronize Initiated.");
|
||||||
|
Preferences.setSyncLastSyncAttempt(context, new Date());
|
||||||
|
|
||||||
/** statistics tracking and displaying */
|
Synchronizer.synchronize(context, true, null);
|
||||||
protected class SyncStats {
|
|
||||||
int localCreatedTasks = 0;
|
|
||||||
int localUpdatedTasks = 0;
|
|
||||||
int localDeletedTasks = 0;
|
|
||||||
|
|
||||||
int mergedTasks = 0;
|
|
||||||
|
|
||||||
int remoteCreatedTasks = 0;
|
|
||||||
int remoteUpdatedTasks = 0;
|
|
||||||
int remoteDeletedTasks = 0;
|
|
||||||
|
|
||||||
/** Display a dialog with statistics */
|
|
||||||
public void showDialog(final Activity activity, String log) {
|
|
||||||
progressDialog.hide();
|
|
||||||
|
|
||||||
if(Preferences.shouldSuppressSyncDialogs(activity))
|
|
||||||
return;
|
|
||||||
|
|
||||||
Dialog.OnClickListener finishListener = new Dialog.OnClickListener() {
|
|
||||||
public void onClick(DialogInterface dialog,
|
|
||||||
int which) {
|
|
||||||
Synchronizer.continueSynchronization(activity);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
// nothing updated
|
|
||||||
if(localCreatedTasks + localUpdatedTasks + localDeletedTasks +
|
|
||||||
mergedTasks + remoteCreatedTasks + remoteDeletedTasks +
|
|
||||||
remoteUpdatedTasks == 0) {
|
|
||||||
if(!Synchronizer.isAutoSync())
|
|
||||||
DialogUtilities.okDialog(activity, "Sync: Up to date!", finishListener);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
StringBuilder sb = new StringBuilder();
|
|
||||||
sb.append(getName()).append(" Results:"); // TODO i18n
|
|
||||||
sb.append("\n\n");
|
|
||||||
sb.append(log);
|
|
||||||
if(localCreatedTasks + localUpdatedTasks + localDeletedTasks > 0)
|
|
||||||
sb.append("\nSummary - Astrid Tasks:");
|
|
||||||
if(localCreatedTasks > 0)
|
|
||||||
sb.append("\nCreated: " + localCreatedTasks);
|
|
||||||
if(localUpdatedTasks > 0)
|
|
||||||
sb.append("\nUpdated: " + localUpdatedTasks);
|
|
||||||
if(localDeletedTasks > 0)
|
|
||||||
sb.append("\nDeleted: " + localDeletedTasks);
|
|
||||||
|
|
||||||
if(mergedTasks > 0)
|
|
||||||
sb.append("\n\nMerged: " + mergedTasks);
|
|
||||||
|
|
||||||
if(remoteCreatedTasks + remoteDeletedTasks + remoteUpdatedTasks > 0)
|
|
||||||
sb.append("\n\nSummary - Remote Server:");
|
|
||||||
if(remoteCreatedTasks > 0)
|
|
||||||
sb.append("\nCreated: " + remoteCreatedTasks);
|
|
||||||
if(remoteUpdatedTasks > 0)
|
|
||||||
sb.append("\nUpdated: " + remoteUpdatedTasks);
|
|
||||||
if(remoteDeletedTasks > 0)
|
|
||||||
sb.append("\nDeleted: " + remoteDeletedTasks);
|
|
||||||
|
|
||||||
sb.append("\n");
|
|
||||||
|
|
||||||
DialogUtilities.okDialog(activity, sb.toString(), finishListener);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
protected static class ProgressUpdater implements Runnable {
|
|
||||||
int step, outOf;
|
|
||||||
public ProgressUpdater(int step, int outOf) {
|
|
||||||
this.step = step;
|
|
||||||
this.outOf = outOf;
|
|
||||||
}
|
|
||||||
public void run() {
|
|
||||||
progressDialog.setProgress(100*step/outOf);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
protected static class ProgressLabelUpdater implements Runnable {
|
|
||||||
String label;
|
|
||||||
public ProgressLabelUpdater(String label) {
|
|
||||||
this.label = label;
|
|
||||||
}
|
|
||||||
public void run() {
|
|
||||||
if(!progressDialog.isShowing())
|
|
||||||
progressDialog.show();
|
|
||||||
progressDialog.setMessage(label);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
Reference in New Issue