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
|
package it.niedermann.nextcloud.deck.remote.helpers.providers;
import android.annotation.SuppressLint;
import android.net.Uri;
import com.nextcloud.android.sso.api.EmptyResponse;
import java.io.File;
import java.io.IOException;
import java.time.Instant;
import java.util.List;
import it.niedermann.nextcloud.deck.DeckLog;
import it.niedermann.nextcloud.deck.database.DataBaseAdapter;
import it.niedermann.nextcloud.deck.model.Attachment;
import it.niedermann.nextcloud.deck.model.Board;
import it.niedermann.nextcloud.deck.model.Stack;
import it.niedermann.nextcloud.deck.model.full.FullCard;
import it.niedermann.nextcloud.deck.remote.adapters.ServerAdapter;
import it.niedermann.nextcloud.deck.remote.api.ResponseCallback;
public class AttachmentDataProvider extends AbstractSyncDataProvider<Attachment> {
private FullCard card;
private Board board;
private Stack stack;
private List<Attachment> attachments;
public AttachmentDataProvider(AbstractSyncDataProvider<?> parent, Board board, Stack stack, FullCard card, List<Attachment> attachments) {
super(parent);
this.board = board;
this.stack = stack;
this.card = card;
this.attachments = attachments;
}
@Override
public void getAllFromServer(ServerAdapter serverAdapter, long accountId, ResponseCallback<List<Attachment>> responder, Instant lastSync) {
responder.onResponse(attachments);
}
@Override
public Attachment getSingleFromDB(DataBaseAdapter dataBaseAdapter, long accountId, Attachment entity) {
return dataBaseAdapter.getAttachmentByRemoteIdDirectly(accountId, entity.getId());
}
@Override
public long createInDB(DataBaseAdapter dataBaseAdapter, long accountId, Attachment attachment) {
attachment.setCardId(card.getLocalId());
return dataBaseAdapter.createAttachment(accountId, attachment);
}
@Override
public void updateInDB(DataBaseAdapter dataBaseAdapter, long accountId, Attachment attachment, boolean setStatus) {
attachment.setCardId(card.getLocalId());
dataBaseAdapter.updateAttachment(accountId, attachment, setStatus);
}
@Override
public void updateInDB(DataBaseAdapter dataBaseAdapter, long accountId, Attachment entity) {
updateInDB(dataBaseAdapter, accountId, entity, false);
}
@Override
public void deleteInDB(DataBaseAdapter dataBaseAdapter, long accountId, Attachment attachment) {
dataBaseAdapter.deleteAttachment(accountId, attachment, false);
}
@Override
public void createOnServer(ServerAdapter serverAdapter, DataBaseAdapter dataBaseAdapter, long accountId, ResponseCallback<Attachment> responder, Attachment entity) {
File file = new File(entity.getLocalPath());
serverAdapter.uploadAttachment(board.getId(), stack.getId(), card.getId(), file, new ResponseCallback<>(responder.getAccount()) {
@Override
public void onResponse(Attachment response) {
if (file.delete()) {
responder.onResponse(response);
} else {
responder.onError(new IOException("Could not delete local file after successful upload: " + file.getAbsolutePath()));
}
}
@SuppressLint("MissingSuperCall")
@Override
public void onError(Throwable throwable) {
if (!file.delete()) {
DeckLog.error("Could not delete local file:", file.getAbsolutePath());
}
// if (HandledServerErrors.ATTACHMENTS_FILE_ALREADY_EXISTS == HandledServerErrors.fromThrowable(throwable)) {
dataBaseAdapter.deleteAttachment(accountId, entity, false);
// }
responder.onError(throwable);
}
});
}
@Override
public void updateOnServer(ServerAdapter serverAdapter, DataBaseAdapter dataBaseAdapter, long accountId, ResponseCallback<Attachment> callback, Attachment entity) {
Uri uri = Uri.fromFile(new File(entity.getLocalPath()));
String type = dataBaseAdapter.getContext().getContentResolver().getType(uri);
serverAdapter.updateAttachment(board.getId(), stack.getId(), card.getId(), entity.getId(), type, uri, callback);
}
@Override
public void deleteOnServer(ServerAdapter serverAdapter, long accountId, ResponseCallback<EmptyResponse> callback, Attachment entity, DataBaseAdapter dataBaseAdapter) {
serverAdapter.deleteAttachment(board.getId(), stack.getId(), card.getId(), entity, callback);
}
@Override
public List<Attachment> getAllChangedFromDB(DataBaseAdapter dataBaseAdapter, long accountId, Instant lastSync) {
return dataBaseAdapter.getLocallyChangedAttachmentsByLocalCardIdDirectly(accountId, card.getLocalId());
}
@Override
public void handleDeletes(ServerAdapter serverAdapter, DataBaseAdapter dataBaseAdapter, long accountId, List<Attachment> entitiesFromServer) {
List<Attachment> localAttachments = dataBaseAdapter.getAttachmentsForLocalCardIdDirectly(accountId, card.getLocalId());
List<Attachment> delta = findDelta(entitiesFromServer, localAttachments);
for (Attachment attachment : delta) {
if (attachment.getId() == null) {
// not pushed up yet so:
continue;
}
dataBaseAdapter.deleteAttachment(accountId, attachment, false);
}
for (Attachment attachment : entitiesFromServer) {
if (attachment.getDeletedAt() != null && attachment.getDeletedAt().toEpochMilli() != 0) {
Attachment toDelete = dataBaseAdapter.getAttachmentByRemoteIdDirectly(accountId, attachment.getId());
if (toDelete != null) {
dataBaseAdapter.deleteAttachment(accountId, toDelete, false);
}
}
}
}
}
|
