1 files changed, 95 insertions, 0 deletions
diff --git a/mobile/android/services/src/main/java/org/mozilla/gecko/sync/net/SyncStorageRecordRequest.java b/mobile/android/services/src/main/java/org/mozilla/gecko/sync/net/SyncStorageRecordRequest.java
new file mode 100644
index 000000000..c18c4fe15
--- /dev/null
+++ b/mobile/android/services/src/main/java/org/mozilla/gecko/sync/net/SyncStorageRecordRequest.java
@@ -0,0 +1,95 @@
+/* This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at http://mozilla.org/MPL/2.0/. */
+
+package org.mozilla.gecko.sync.net;
+
+import org.json.simple.JSONArray;
+import org.json.simple.JSONObject;
+import org.mozilla.gecko.sync.CryptoRecord;
+
+import java.io.UnsupportedEncodingException;
+import java.net.URI;
+import java.net.URISyntaxException;
+
+/**
+ * Resource class that implements expected headers and processing for Sync.
+ * Accepts a simplified delegate.
+ *
+ * Includes:
+ * * Basic Auth headers (via Resource)
+ * * Error responses:
+ *   * 401
+ *   * 503
+ * * Headers:
+ *   * Retry-After
+ *   * X-Weave-Backoff
+ *   * X-Backoff
+ *   * X-Weave-Records?
+ *   * ...
+ * * Timeouts
+ * * Network errors
+ * * application/newlines
+ * * JSON parsing
+ * * Content-Type and Content-Length validation.
+ */
+public class SyncStorageRecordRequest extends SyncStorageRequest {
+
+  public class SyncStorageRecordResourceDelegate extends SyncStorageResourceDelegate {
+    SyncStorageRecordResourceDelegate(SyncStorageRequest request) {
+      super(request);
+    }
+  }
+
+  public SyncStorageRecordRequest(URI uri) {
+    super(uri);
+  }
+
+  public SyncStorageRecordRequest(String url) throws URISyntaxException {
+    this(new URI(url));
+  }
+
+  @Override
+  protected BaseResourceDelegate makeResourceDelegate(SyncStorageRequest request) {
+    return new SyncStorageRecordResourceDelegate(request);
+  }
+
+  @SuppressWarnings("unchecked")
+  public void post(JSONObject body) {
+    // Let's do this the trivial way for now.
+    // Note that POSTs should be an array, so we wrap here.
+    final JSONArray toPOST = new JSONArray();
+    toPOST.add(body);
+    try {
+      this.resource.post(toPOST);
+    } catch (UnsupportedEncodingException e) {
+      this.delegate.handleRequestError(e);
+    }
+  }
+
+  public void post(JSONArray body) {
+    // Let's do this the trivial way for now.
+    try {
+      this.resource.post(body);
+    } catch (UnsupportedEncodingException e) {
+      this.delegate.handleRequestError(e);
+    }
+  }
+
+  public void put(JSONObject body) {
+    // Let's do this the trivial way for now.
+    try {
+      this.resource.put(body);
+    } catch (UnsupportedEncodingException e) {
+      this.delegate.handleRequestError(e);
+    }
+  }
+
+  public void post(CryptoRecord record) {
+    this.post(record.toJSONObject());
+  }
+
+  public void put(CryptoRecord record) {
+    this.put(record.toJSONObject());
+  }
+}