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
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
|
package it.niedermann.nextcloud.deck.remote.helpers.providers;
import com.nextcloud.android.sso.api.EmptyResponse;
import java.time.Instant;
import java.util.Collections;
import java.util.List;
import java.util.stream.Collectors;
import it.niedermann.nextcloud.deck.DeckLog;
import it.niedermann.nextcloud.deck.database.DataBaseAdapter;
import it.niedermann.nextcloud.deck.model.Card;
import it.niedermann.nextcloud.deck.model.ocs.projects.OcsProject;
import it.niedermann.nextcloud.deck.model.ocs.projects.OcsProjectList;
import it.niedermann.nextcloud.deck.model.ocs.projects.OcsProjectResource;
import it.niedermann.nextcloud.deck.remote.adapters.ServerAdapter;
import it.niedermann.nextcloud.deck.remote.api.ResponseCallback;
public class OcsProjectDataProvider extends AbstractSyncDataProvider<OcsProject> {
private final Card card;
public OcsProjectDataProvider(AbstractSyncDataProvider<?> parent, Card card) {
super(parent);
this.card = card;
}
@Override
public void getAllFromServer(ServerAdapter serverAdapter, long accountId, ResponseCallback<List<OcsProject>> responder, Instant lastSync) {
serverAdapter.getProjectsForCard(card.getId(), new ResponseCallback<>(responder.getAccount()) {
@Override
public void onResponse(OcsProjectList response) {
responder.onResponse(response.getProjects());
}
@Override
public void onError(Throwable throwable) {
super.onError(throwable);
// dont break the sync!
// TODO i got here HTTP 404 once, maybe this should be considered?
DeckLog.logError(throwable);
responder.onResponse(Collections.emptyList());
}
});
}
@Override
public OcsProject getSingleFromDB(DataBaseAdapter dataBaseAdapter, long accountId, OcsProject entity) {
return dataBaseAdapter.getProjectByRemoteIdDirectly(accountId, entity.getId());
}
@Override
public long createInDB(DataBaseAdapter dataBaseAdapter, long accountId, OcsProject entity) {
Long newId = dataBaseAdapter.createProjectDirectly(accountId, entity);
entity.setLocalId(newId);
updateResources(dataBaseAdapter, accountId, entity);
return newId;
}
@Override
public void updateInDB(DataBaseAdapter dataBaseAdapter, long accountId, OcsProject entity, boolean setStatus) {
dataBaseAdapter.updateProjectDirectly(accountId, entity);
dataBaseAdapter.deleteProjectResourcesForProjectIdDirectly(entity.getLocalId());
updateResources(dataBaseAdapter, accountId, entity);
}
@Override
public void deleteInDB(DataBaseAdapter dataBaseAdapter, long accountId, OcsProject ocsProject) {
if (ocsProject != null && ocsProject.getLocalId() != null) {
dataBaseAdapter.deleteProjectDirectly(ocsProject);
}
}
@Override
public void handleDeletes(ServerAdapter serverAdapter, DataBaseAdapter dataBaseAdapter, long accountId, List<OcsProject> entitiesFromServer) {
if (entitiesFromServer.isEmpty()){
dataBaseAdapter.deleteProjectResourcesByCardIdDirectly(card.getLocalId());
return;
}
List<Long> remoteProjectIDs = entitiesFromServer.stream()
.map(OcsProject::getId)
.collect(Collectors.toList());
if (!remoteProjectIDs.isEmpty()) {
dataBaseAdapter.deleteProjectResourcesByCardIdExceptGivenProjectIdsDirectly(accountId, card.getLocalId(), remoteProjectIDs);
}
}
private void updateResources(DataBaseAdapter dataBaseAdapter, Long accountId, OcsProject entity) {
if (entity.getResources() != null) {
for (OcsProjectResource resource : entity.getResources()) {
resource.setProjectId(entity.getLocalId());
resource.setLocalId(dataBaseAdapter.createProjectResourceDirectly(accountId, resource));
if ("deck-card".equals(resource.getType())) {
dataBaseAdapter.assignCardToProjectIfMissing(accountId, entity.getLocalId(), resource.getId());
}
}
}
}
@Override
public void createOnServer(ServerAdapter serverAdapter, DataBaseAdapter dataBaseAdapter, long accountId, ResponseCallback<OcsProject> responder, OcsProject entity) {
// Do Nothing
}
@Override
public void updateOnServer(ServerAdapter serverAdapter, DataBaseAdapter dataBaseAdapter, long accountId, ResponseCallback<OcsProject> callback, OcsProject entity) {
// Do Nothing
}
@Override
public void deleteOnServer(ServerAdapter serverAdapter, long accountId, ResponseCallback<EmptyResponse> callback, OcsProject entity, DataBaseAdapter dataBaseAdapter) {
// Do Nothing
}
@Override
public List<OcsProject> getAllChangedFromDB(DataBaseAdapter dataBaseAdapter, long accountId, Instant lastSync) {
return Collections.emptyList();
}
}
|
