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
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
|
package it.niedermann.owncloud.notes.persistence;
import android.content.Context;
import android.content.pm.PackageInfo;
import android.util.Log;
import androidx.annotation.NonNull;
import androidx.annotation.Nullable;
import androidx.annotation.WorkerThread;
import com.nextcloud.android.sso.aidl.NextcloudRequest;
import com.nextcloud.android.sso.api.AidlNetworkRequest;
import com.nextcloud.android.sso.api.Response;
import com.nextcloud.android.sso.exceptions.NextcloudFilesAppNotSupportedException;
import com.nextcloud.android.sso.model.SingleSignOnAccount;
import org.json.JSONObject;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.util.Collections;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import it.niedermann.owncloud.notes.model.ApiVersion;
import it.niedermann.owncloud.notes.model.CloudNote;
import it.niedermann.owncloud.notes.util.ServerResponse.NoteResponse;
import it.niedermann.owncloud.notes.util.ServerResponse.NotesResponse;
@SuppressWarnings("WeakerAccess")
@WorkerThread
public abstract class NotesClient {
final static int MIN_NEXTCLOUD_FILES_APP_VERSION_CODE = 30090000;
private static final String TAG = NotesClient.class.getSimpleName();
protected final Context appContext;
protected static final String GET_PARAM_KEY_PRUNE_BEFORE = "pruneBefore";
protected static final String HEADER_KEY_ETAG = "ETag";
protected static final String HEADER_KEY_LAST_MODIFIED = "Last-Modified";
protected static final String HEADER_KEY_CONTENT_TYPE = "Content-Type";
protected static final String HEADER_KEY_IF_NONE_MATCH = "If-None-Match";
protected static final String HEADER_KEY_X_NOTES_API_VERSIONS = "X-Notes-API-Versions";
protected static final String HEADER_VALUE_APPLICATION_JSON = "application/json";
protected static final String METHOD_GET = "GET";
protected static final String METHOD_PUT = "PUT";
protected static final String METHOD_POST = "POST";
protected static final String METHOD_DELETE = "DELETE";
public static final String JSON_ID = "id";
public static final String JSON_TITLE = "title";
public static final String JSON_CONTENT = "content";
public static final String JSON_FAVORITE = "favorite";
public static final String JSON_CATEGORY = "category";
public static final String JSON_ETAG = "etag";
public static final String JSON_MODIFIED = "modified";
public static final ApiVersion[] SUPPORTED_API_VERSIONS = new ApiVersion[]{
new ApiVersion(1, 0),
new ApiVersion(0, 2)
};
public static NotesClient newInstance(@Nullable ApiVersion preferredApiVersion,
@NonNull Context appContext) {
if (preferredApiVersion == null) {
Log.i(TAG, "apiVersion is null, using " + NotesClientV02.class.getSimpleName());
return new NotesClientV02(appContext);
} else if (preferredApiVersion.compareTo(SUPPORTED_API_VERSIONS[0]) == 0) {
Log.i(TAG, "Using " + NotesClientV1.class.getSimpleName());
return new NotesClientV1(appContext);
} else if (preferredApiVersion.compareTo(SUPPORTED_API_VERSIONS[1]) == 0) {
Log.i(TAG, "Using " + NotesClientV02.class.getSimpleName());
return new NotesClientV02(appContext);
}
Log.w(TAG, "Unsupported API version " + preferredApiVersion + " - try using " + NotesClientV02.class.getSimpleName());
return new NotesClientV02(appContext);
}
@SuppressWarnings("WeakerAccess")
public NotesClient(@NonNull Context appContext) {
this.appContext = appContext;
}
abstract NotesResponse getNotes(SingleSignOnAccount ssoAccount, long lastModified, String lastETag) throws Exception;
abstract NoteResponse createNote(SingleSignOnAccount ssoAccount, CloudNote note) throws Exception;
abstract NoteResponse editNote(SingleSignOnAccount ssoAccount, CloudNote note) throws Exception;
abstract void deleteNote(SingleSignOnAccount ssoAccount, long noteId) throws Exception;
/**
* This entity class is used to return relevant data of the HTTP reponse.
*/
public static class ResponseData {
private final String content;
private final String etag;
private final String supportedApiVersions;
private final long lastModified;
ResponseData(@NonNull String content, String etag, long lastModified, @Nullable String supportedApiVersions) {
this.content = content;
this.etag = etag;
this.lastModified = lastModified;
this.supportedApiVersions = supportedApiVersions;
}
public String getContent() {
return content;
}
public String getETag() {
return etag;
}
public long getLastModified() {
return lastModified;
}
public String getSupportedApiVersions() {
return this.supportedApiVersions;
}
}
abstract protected String getApiPath();
/**
* Request-Method for POST, PUT with or without JSON-Object-Parameter
*
* @param target Filepath to the wanted function
* @param method GET, POST, DELETE or PUT
* @param parameter optional headers to be sent
* @param requestBody JSON Object which shall be transferred to the server.
* @param lastETag optional ETag of last response
* @return Body of answer
*/
protected ResponseData requestServer(SingleSignOnAccount ssoAccount, String target, String method, Map<String, String> parameter, JSONObject requestBody, String lastETag) throws Exception {
final NextcloudRequest.Builder requestBuilder = new NextcloudRequest.Builder()
.setMethod(method)
.setUrl(getApiPath() + target);
if (parameter != null) {
requestBuilder.setParameter(parameter);
}
final Map<String, List<String>> header = new HashMap<>();
if (requestBody != null) {
header.put(HEADER_KEY_CONTENT_TYPE, Collections.singletonList(HEADER_VALUE_APPLICATION_JSON));
requestBuilder.setRequestBody(requestBody.toString());
}
if (lastETag != null && !lastETag.isEmpty() && METHOD_GET.equals(method)) {
header.put(HEADER_KEY_IF_NONE_MATCH, Collections.singletonList('"' + lastETag + '"'));
requestBuilder.setHeader(header);
}
final NextcloudRequest nextcloudRequest = requestBuilder.build();
final StringBuilder result = new StringBuilder();
try {
Log.v(TAG, ssoAccount.name + " → " + nextcloudRequest.getMethod() + " " + nextcloudRequest.getUrl() + " ");
final Response response = SSOClient.requestFilesApp(appContext, ssoAccount, nextcloudRequest);
Log.v(TAG, "NextcloudRequest: " + nextcloudRequest.toString());
final BufferedReader rd = new BufferedReader(new InputStreamReader(response.getBody()));
String line;
while ((line = rd.readLine()) != null) {
result.append(line);
}
response.getBody().close();
String etag = "";
final AidlNetworkRequest.PlainHeader eTagHeader = response.getPlainHeader(HEADER_KEY_ETAG);
if (eTagHeader != null) {
etag = Objects.requireNonNull(eTagHeader.getValue()).replace("\"", "");
}
long lastModified = 0;
final AidlNetworkRequest.PlainHeader lastModifiedHeader = response.getPlainHeader(HEADER_KEY_LAST_MODIFIED);
if (lastModifiedHeader != null)
lastModified = new Date(lastModifiedHeader.getValue()).getTime() / 1000;
Log.d(TAG, "ETag: " + etag + "; Last-Modified: " + lastModified + " (" + lastModified + ")");
String supportedApiVersions = null;
final AidlNetworkRequest.PlainHeader supportedApiVersionsHeader = response.getPlainHeader(HEADER_KEY_X_NOTES_API_VERSIONS);
if (supportedApiVersionsHeader != null) {
supportedApiVersions = Objects.requireNonNull(supportedApiVersionsHeader.getValue()).replace("\"", "");
}
// return these header fields since they should only be saved after successful processing the result!
return new ResponseData(result.toString(), etag, lastModified, supportedApiVersions);
} catch (NullPointerException e) {
final PackageInfo pInfo = appContext.getPackageManager().getPackageInfo("com.nextcloud.client", 0);
if (pInfo.versionCode < MIN_NEXTCLOUD_FILES_APP_VERSION_CODE) {
throw new NextcloudFilesAppNotSupportedException();
} else {
throw e;
}
}
}
}
|
