Added ability to specify save match criterion beyond just matching on uuid in MakeChanges

pull/14/head
Sam Bosley 13 years ago
parent a2f4a24ac0
commit d044095d02

@ -64,13 +64,16 @@ public class MakeChanges<TYPE extends RemoteModel> extends ServerToClientMessage
return model; return model;
} }
public static <T extends RemoteModel> void saveOrUpdateModelAfterChanges(RemoteModelDao<T> dao, T model, String oldUuid, String uuid) { private static <T extends RemoteModel> void saveOrUpdateModelAfterChanges(RemoteModelDao<T> dao, T model, String oldUuid, String uuid, Criterion orCriterion) {
Criterion uuidCriterion; Criterion uuidCriterion;
if (oldUuid == null) if (oldUuid == null)
uuidCriterion = RemoteModel.UUID_PROPERTY.eq(uuid); uuidCriterion = RemoteModel.UUID_PROPERTY.eq(uuid);
else else
uuidCriterion = RemoteModel.UUID_PROPERTY.eq(oldUuid); uuidCriterion = RemoteModel.UUID_PROPERTY.eq(oldUuid);
if (orCriterion != null)
uuidCriterion = Criterion.or(uuidCriterion, orCriterion);
if (model.getSetValues() != null && model.getSetValues().size() > 0) { if (model.getSetValues() != null && model.getSetValues().size() > 0) {
model.putTransitory(SyncFlags.ACTFM_SUPPRESS_OUTSTANDING_ENTRIES, true); model.putTransitory(SyncFlags.ACTFM_SUPPRESS_OUTSTANDING_ENTRIES, true);
if (dao.update(uuidCriterion, model) <= 0) { // If update doesn't update rows. create a new model if (dao.update(uuidCriterion, model) <= 0) { // If update doesn't update rows. create a new model
@ -101,7 +104,7 @@ public class MakeChanges<TYPE extends RemoteModel> extends ServerToClientMessage
if (model.getSetValues() != null && !model.getSetValues().containsKey(uuidProperty.name)) if (model.getSetValues() != null && !model.getSetValues().containsKey(uuidProperty.name))
model.setValue(uuidProperty, uuid); model.setValue(uuidProperty, uuid);
saveOrUpdateModelAfterChanges(dao, model, oldUuid, uuid); saveOrUpdateModelAfterChanges(dao, model, oldUuid, uuid, getMatchCriterion(model));
afterSaveChanges(changes, model, uuid, oldUuid); afterSaveChanges(changes, model, uuid, oldUuid);
} catch (IllegalAccessException e) { } catch (IllegalAccessException e) {
@ -113,6 +116,13 @@ public class MakeChanges<TYPE extends RemoteModel> extends ServerToClientMessage
} }
} }
private Criterion getMatchCriterion(TYPE model) {
if (NameMaps.TABLE_ID_TASK_LIST_METADATA.equals(table) && model.getSetValues().containsKey(TaskListMetadata.FILTER.name)) {
return TaskListMetadata.FILTER.eq(model.getSetValues().getAsString(TaskListMetadata.FILTER.name));
}
return null;
}
private void beforeSaveChanges(JSONObject changes, TYPE model, String uuid) { private void beforeSaveChanges(JSONObject changes, TYPE model, String uuid) {
ChangeHooks beforeSaveChanges = null; ChangeHooks beforeSaveChanges = null;
if (NameMaps.TABLE_ID_TASKS.equals(table)) if (NameMaps.TABLE_ID_TASKS.equals(table))

Loading…
Cancel
Save