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
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
|
package it.niedermann.nextcloud.deck.persistence.sync.helpers.providers;
import java.util.ArrayList;
import java.util.List;
import it.niedermann.nextcloud.deck.api.IResponseCallback;
import it.niedermann.nextcloud.deck.model.Board;
import it.niedermann.nextcloud.deck.model.Card;
import it.niedermann.nextcloud.deck.model.User;
import it.niedermann.nextcloud.deck.model.full.FullCard;
import it.niedermann.nextcloud.deck.model.full.FullStack;
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 CardDataProvider implements IDataProvider<FullCard> {
private Board board;
private FullStack stack;
public CardDataProvider(Board board, FullStack stack) {
this.board = board;
this.stack = stack;
}
@Override
public void getAllFromServer(ServerAdapter serverAdapter, long accountId, IResponseCallback<List<FullCard>> responder) {
List<FullCard> result = new ArrayList<>();
if (stack.getCards() == null || stack.getCards().isEmpty()){
responder.onResponse(result);
}
for (Card card : stack.getCards()) {
serverAdapter.getCard(board.getId(), stack.getId(), card.getId(), new IResponseCallback<FullCard>(responder.getAccount()) {
@Override
public void onResponse(FullCard response) {
result.add(response);
if (result.size() == stack.getCards().size()) {
responder.onResponse(result);
}
}
@Override
public void onError(Throwable throwable) {
responder.onError(throwable);
}
});
}
}
@Override
public FullCard getSingleFromDB(DataBaseAdapter dataBaseAdapter, long accountId, long remoteId) {
return dataBaseAdapter.getFullCardByRemoteIdDirectly(accountId, remoteId);
}
@Override
public void createInDB(DataBaseAdapter dataBaseAdapter, long accountId, FullCard entity) {
fixRelations(dataBaseAdapter, accountId, entity);
dataBaseAdapter.createCard(accountId, entity.getCard());
}
private void fixRelations(DataBaseAdapter dataBaseAdapter, long accountId, FullCard entity) {
entity.getCard().setStackId(stack.getLocalId());
if (entity.getOwner() != null && !entity.getOwner().isEmpty()){
User user = entity.getOwner().get(0);
User u = dataBaseAdapter.getUserByUidDirectly(accountId, user.getUid());
if (u == null){
dataBaseAdapter.createUser(accountId, user);
} else {
user.setLocalId(u.getLocalId());
dataBaseAdapter.updateUser(accountId, user);
}
u = dataBaseAdapter.getUserByUidDirectly(accountId, user.getUid());
user.setLocalId(u.getLocalId());
entity.getCard().setUserId(u.getLocalId());
}
}
@Override
public void updateInDB(DataBaseAdapter dataBaseAdapter, long accountId, FullCard entity) {
fixRelations(dataBaseAdapter, accountId, entity);
dataBaseAdapter.updateCard(entity.getCard());
}
@Override
public void goDeeper(SyncHelper syncHelper, FullCard existingEntity, FullCard entityFromServer) {
existingEntity.setLabels(entityFromServer.getLabels());
existingEntity.setAssignedUsers(entityFromServer.getAssignedUsers());
syncHelper.doSyncFor(new LabelDataProvider(entityFromServer.getLabels()));
syncHelper.fixRelations(new CardLabelRelationshipProvider(existingEntity.getCard(), existingEntity.getLabels()));
syncHelper.doSyncFor(new UserDataProvider(board, stack, existingEntity, existingEntity.getAssignedUsers()));
syncHelper.fixRelations(new CardUserRelationshipProvider(existingEntity.getCard(), existingEntity.getAssignedUsers()));
// syncHelper.doSyncFor(new UserDataProvider(board, stack, existingEntity, existingEntity.getOwner()));
}
}
|
