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
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
|
package it.niedermann.nextcloud.deck.remote.helpers;
import androidx.annotation.NonNull;
import androidx.annotation.Nullable;
import java.util.concurrent.ExecutorService;
import java.util.function.BiConsumer;
import it.niedermann.nextcloud.deck.database.DataBaseAdapter;
import it.niedermann.nextcloud.deck.model.Account;
import it.niedermann.nextcloud.deck.model.enums.DBStatus;
import it.niedermann.nextcloud.deck.model.interfaces.IRemoteEntity;
import it.niedermann.nextcloud.deck.remote.adapters.ServerAdapter;
import it.niedermann.nextcloud.deck.remote.api.ResponseCallback;
import it.niedermann.nextcloud.deck.remote.helpers.providers.AbstractSyncDataProvider;
public class DataPropagationHelper {
@NonNull
private final ServerAdapter serverAdapter;
@NonNull
private final DataBaseAdapter dataBaseAdapter;
@NonNull
private final ExecutorService executor;
public DataPropagationHelper(@NonNull ServerAdapter serverAdapter, @NonNull DataBaseAdapter dataBaseAdapter, @NonNull ExecutorService executor) {
this.serverAdapter = serverAdapter;
this.dataBaseAdapter = dataBaseAdapter;
this.executor = executor;
}
public <T extends IRemoteEntity> void createEntity(@NonNull final AbstractSyncDataProvider<T> provider, @NonNull T entity, ResponseCallback<T> callback){
createEntity(provider, entity, callback, null);
}
public <T extends IRemoteEntity> void createEntity(@NonNull final AbstractSyncDataProvider<T> provider, @NonNull T entity, ResponseCallback<T> callback, @Nullable BiConsumer<T, T> actionOnResponse){
final long accountId = callback.getAccount().getId();
entity.setStatus(DBStatus.LOCAL_EDITED.getId());
long newID;
try {
newID = provider.createInDB(dataBaseAdapter, accountId, entity);
} catch (Throwable t) {
callback.onError(t);
return;
}
entity.setLocalId(newID);
if (serverAdapter.hasInternetConnection()) {
try {
provider.createOnServer(serverAdapter, dataBaseAdapter, accountId, new ResponseCallback<>(callback.getAccount()) {
@Override
public void onResponse(T response) {
executor.submit(() -> {
response.setAccountId(accountId);
response.setLocalId(newID);
if (actionOnResponse != null) {
actionOnResponse.accept(entity, response);
}
response.setStatus(DBStatus.UP_TO_DATE.getId());
provider.updateInDB(dataBaseAdapter, accountId, response, false);
callback.onResponse(response);
});
}
@Override
public void onError(Throwable throwable) {
super.onError(throwable);
executor.submit(() -> callback.onError(throwable));
}
}, entity);
} catch (Throwable t) {
callback.onError(t);
}
} else {
callback.onResponse(entity);
}
}
public <T extends IRemoteEntity> void updateEntity(@NonNull final AbstractSyncDataProvider<T> provider, @NonNull T entity, @NonNull ResponseCallback<T> callback){
final long accountId = callback.getAccount().getId();
entity.setStatus(DBStatus.LOCAL_EDITED.getId());
try {
provider.updateInDB(dataBaseAdapter, accountId, entity);
} catch (Throwable t) {
callback.onError(t);
return;
}
if (entity.getId() != null && serverAdapter.hasInternetConnection()) {
try {
provider.updateOnServer(serverAdapter, dataBaseAdapter, accountId, new ResponseCallback<>(new Account(accountId)) {
@Override
public void onResponse(T response) {
executor.submit(() -> {
entity.setStatus(DBStatus.UP_TO_DATE.getId());
provider.updateInDB(dataBaseAdapter, accountId, entity, false);
callback.onResponse(entity);
});
}
@Override
public void onError(Throwable throwable) {
super.onError(throwable);
executor.submit(() -> callback.onError(throwable));
}
}, entity);
} catch (Throwable t) {
callback.onError(t);
}
} else {
callback.onResponse(entity);
}
}
public <T extends IRemoteEntity> void deleteEntity(@NonNull final AbstractSyncDataProvider<T> provider, @NonNull T entity, @NonNull ResponseCallback<Void> callback){
final long accountId = callback.getAccount().getId();
// known to server?
if (entity.getId() != null) {
provider.deleteInDB(dataBaseAdapter, accountId, entity);
} else {
// junk, bye.
provider.deletePhysicallyInDB(dataBaseAdapter, accountId, entity);
}
if (entity.getId() != null && serverAdapter.hasInternetConnection()) {
try {
provider.deleteOnServer(serverAdapter, accountId, new ResponseCallback<>(new Account(accountId)) {
@Override
public void onResponse(Void response) {
executor.submit(() -> {
provider.deletePhysicallyInDB(dataBaseAdapter, accountId, entity);
callback.onResponse(null);
});
}
@Override
public void onError(Throwable throwable) {
super.onError(throwable);
executor.submit(() -> callback.onError(throwable));
}
}, entity, dataBaseAdapter);
} catch (Throwable t) {
callback.onError(t);
}
} else {
callback.onResponse(null);
}
}
}
|
