1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
|
package it.niedermann.nextcloud.deck.persistence.sync.helpers.providers;
import java.util.List;
import it.niedermann.nextcloud.deck.api.IResponseCallback;
import it.niedermann.nextcloud.deck.model.User;
import it.niedermann.nextcloud.deck.model.full.FullBoard;
import it.niedermann.nextcloud.deck.persistence.sync.adapters.ServerAdapter;
import it.niedermann.nextcloud.deck.persistence.sync.adapters.db.DataBaseAdapter;
import it.niedermann.nextcloud.deck.persistence.sync.helpers.SyncHelper;
public class BoardDataProvider implements IDataProvider<FullBoard> {
@Override
public void getAllFromServer(ServerAdapter serverAdapter, long accountId, IResponseCallback<List<FullBoard>> responder) {
serverAdapter.getBoards(responder);
}
@Override
public FullBoard getSingleFromDB(DataBaseAdapter dataBaseAdapter, long accountId, long remoteId) {
return dataBaseAdapter.getFullBoardByRemoteIdDirectly(accountId, remoteId);
}
@Override
public void createInDB(DataBaseAdapter dataBaseAdapter, long accountId, FullBoard entity) {
handleOwner(dataBaseAdapter, accountId, entity);
dataBaseAdapter.createBoardDirectly(accountId, entity.getBoard());
}
private void handleOwner(DataBaseAdapter dataBaseAdapter, long accountId, FullBoard entity) {
if (entity.getOwner()!=null && entity.getOwner().size() == 1) {
User remoteOwner = entity.getOwner().get(0);
User owner = dataBaseAdapter.getUserByUidDirectly(accountId, remoteOwner.getUid());
if (owner == null){
dataBaseAdapter.createUser(accountId, remoteOwner);
} else {
dataBaseAdapter.updateUser(accountId, remoteOwner);
}
owner = dataBaseAdapter.getUserByUidDirectly(accountId, remoteOwner.getUid());
entity.getBoard().setOwnerId(owner.getLocalId());
}
}
@Override
public void updateInDB(DataBaseAdapter dataBaseAdapter, long accountId, FullBoard entity) {
handleOwner(dataBaseAdapter, accountId, entity);
dataBaseAdapter.updateBoard(entity.getBoard());
}
@Override
public void goDeeper(SyncHelper syncHelper, FullBoard existingEntity, FullBoard entityFromServer) {
syncHelper.doSyncFor(new LabelDataProvider(entityFromServer.getLabels()));
syncHelper.fixRelations(new BoardLabelRelationshipProvider(existingEntity.getBoard(), entityFromServer.getLabels()));
syncHelper.doSyncFor(new StackDataProvider(existingEntity));
}
@Override
public void doneAll(IResponseCallback<Boolean> responseCallback, boolean syncChangedSomething) {
responseCallback.onResponse(syncChangedSomething);
}
}
|
