Merged futon-async branch back into trunk.
git-svn-id: https://svn.apache.org/repos/asf/incubator/couchdb/trunk@648074 13f79535-47bb-0310-9956-ffa450edef68
diff --git a/jquery.couch.js b/jquery.couch.js
new file mode 100644
index 0000000..de1cddc
--- /dev/null
+++ b/jquery.couch.js
@@ -0,0 +1,271 @@
+// Licensed under the Apache License, Version 2.0 (the "License"); you may not
+// use this file except in compliance with the License. You may obtain a copy
+// of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+// WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+// License for the specific language governing permissions and limitations under
+// the License.
+
+(function($) {
+ $.couch = $.couch || {}
+ $.fn.extend($.couch, {
+
+ allDbs: function(options) {
+ $.ajax({
+ type: "GET", url: "/_all_dbs",
+ complete: function(req) {
+ var resp = $.httpData(req, "json");
+ if (req.status == 200 && options.success) {
+ options.success(resp);
+ } else if (options.error) {
+ options.error(req.status, resp.error, resp.reason);
+ } else {
+ alert("An error occurred retrieving the list of all databases: " +
+ resp.reason);
+ }
+ }
+ });
+ },
+
+ db: function(name) {
+ return {
+ name: name,
+ uri: "/" + encodeURIComponent(name) + "/",
+
+ compact: function(options) {
+ $.ajax({
+ type: "POST", url: this.uri + "_compact", dataType: "json",
+ complete: function(req) {
+ var resp = $.httpData(req, "json");
+ if (req.status == 202 && options.success) {
+ options.success(resp);
+ } else if (options.error) {
+ options.error(req.status, resp.error, resp.reason);
+ } else {
+ alert("The database could not be compacted: " + resp.reason);
+ }
+ }
+ });
+ },
+ create: function(options) {
+ $.ajax({
+ type: "PUT", url: this.uri, dataType: "json",
+ complete: function(req) {
+ var resp = $.httpData(req, "json");
+ if (req.status == 201 && options.success) {
+ options.success(resp);
+ } else if (options.error) {
+ options.error(req.status, resp.error, resp.reason);
+ } else {
+ alert("The database could not be created: " + resp.reason);
+ }
+ }
+ });
+ },
+ drop: function(options) {
+ $.ajax({
+ type: "DELETE", url: this.uri, dataType: "json",
+ complete: function(req) {
+ var resp = $.httpData(req, "json");
+ if (req.status == 202 && options.success) {
+ options.success(resp);
+ } else if (options.error) {
+ options.error(req.status, resp.error, resp.reason);
+ } else {
+ alert("The database could not be deleted: " + resp.reason);
+ }
+ }
+ });
+ },
+ info: function(options) {
+ $.ajax({
+ type: "GET", url: this.uri, dataType: "json",
+ complete: function(req) {
+ var resp = $.httpData(req, "json");
+ if (req.status == 200 && options.success) {
+ options.success(resp);
+ } else if (options.error) {
+ options.error(req.status, resp.error, resp.reason);
+ } else {
+ alert("Database information could not be retrieved: " +
+ resp.reason);
+ }
+ }
+ });
+ },
+ allDocs: function(options) {
+ $.ajax({
+ type: "GET", url: this.uri + "_all_docs" + encodeOptions(options),
+ dataType: "json",
+ complete: function(req) {
+ var resp = $.httpData(req, "json");
+ if (req.status == 200 && options.success) {
+ options.success(resp);
+ } else if (options.error) {
+ options.error(req.status, resp.error, resp.reason);
+ } else {
+ alert("An error occurred retrieving a list of all documents: " +
+ resp.reason);
+ }
+ },
+ });
+ },
+ openDoc: function(docId, options) {
+ $.ajax({
+ type: "GET",
+ url: this.uri + encodeURIComponent(docId) + encodeOptions(options),
+ dataType: "json",
+ complete: function(req) {
+ var resp = $.httpData(req, "json");
+ if (req.status == 200 && options.success) {
+ options.success(resp);
+ } else if (options.error) {
+ options.error(req.status, resp.error, resp.reason);
+ } else {
+ alert("The document could not be retrieved: " + resp.reason);
+ }
+ }
+ });
+ },
+ saveDoc: function(doc, options) {
+ if (doc._id === undefined) {
+ var method = "POST";
+ var uri = this.uri;
+ } else {
+ var method = "PUT";
+ var uri = this.uri + encodeURIComponent(doc._id);
+ }
+ $.ajax({
+ type: method, url: uri + encodeOptions(options),
+ dataType: "json", data: toJSON(doc),
+ contentType: "application/json",
+ complete: function(req) {
+ var resp = $.httpData(req, "json")
+ doc._id = resp.id;
+ doc._rev = resp.rev;
+ if (req.status == 201 && options.success) {
+ options.success(resp);
+ } else if (options.error) {
+ options.error(req.status, resp.error, resp.reason);
+ } else {
+ alert("The document could not be saved: " + resp.reason);
+ }
+ }
+ });
+ },
+ removeDoc: function(doc, options) {
+ $.ajax({
+ type: "DELETE",
+ url: this.uri + encodeURIComponent(doc._id) + encodeOptions({rev: doc._rev}),
+ dataType: "json",
+ complete: function(req) {
+ var resp = $.httpData(req, "json");
+ if (req.status == 202 && options.success) {
+ options.success(resp);
+ } else if (options.error) {
+ options.error(req.status, resp.error, resp.reason);
+ } else {
+ alert("The document could not be deleted: " + resp.reason);
+ }
+ }
+ });
+ },
+ query: function(fun, options) {
+ if (typeof(fun) != "string")
+ fun = fun.toSource ? fun.toSource() : "(" + fun.toString() + ")";
+ $.ajax({
+ type: "POST", url: this.uri + "_temp_view" + encodeOptions(options),
+ contentType: "text/javascript", data: fun, dataType: "json",
+ complete: function(req) {
+ var resp = $.httpData(req, "json");
+ if (req.status == 200 && options.success) {
+ options.success(resp);
+ } else if (options.error) {
+ options.error(req.status, resp.error, resp.reason);
+ } else {
+ alert("An error occurred querying the database: " + resp.reason);
+ }
+ }
+ });
+ },
+ view: function(name, options) {
+ $.ajax({
+ type: "GET", url: this.uri + "_view/" + name + encodeOptions(options),
+ dataType: "json",
+ complete: function(req) {
+ var resp = $.httpData(req, "json");
+ if (req.status == 200 && options.success) {
+ options.success(resp);
+ } else if (options.error) {
+ options.error(req.status, resp.error, resp.reason);
+ } else {
+ alert("An error occurred accessing the view: " + resp.reason);
+ }
+ }
+ });
+ }
+ };
+ },
+
+ info: function(options) {
+ $.ajax({
+ type: "GET", url: "/", dataType: "json",
+ complete: function(req) {
+ var resp = $.httpData(req, "json");
+ if (req.status == 200 && options.success) {
+ options.success(resp);
+ } else if (options.error) {
+ options.error(req.status, resp.error, resp.reason);
+ } else {
+ alert("Server information could not be retrieved: " + resp.reason);
+ }
+ }
+ });
+ },
+
+ replicate: function(source, target, options) {
+ $.ajax({
+ type: "POST", url: "/_replicate", dataType: "json",
+ data: JSON.stringify({source: source, target: target}),
+ contentType: "application/json",
+ complete: function(req) {
+ var resp = $.httpData(req, "json");
+ if (req.status == 200 && options.success) {
+ options.success(resp);
+ } else if (options.error) {
+ options.error(req.status, resp.error, resp.reason);
+ } else {
+ alert("Replication failed: " + resp.reason);
+ }
+ }
+ });
+ }
+
+ });
+
+ // Convert a options object to an url query string.
+ // ex: {key:'value',key2:'value2'} becomes '?key="value"&key2="value2"'
+ function encodeOptions(options) {
+ var buf = []
+ if (typeof(options) == "object" && options !== null) {
+ for (var name in options) {
+ if (name == "error" || name == "success") continue;
+ var value = options[name];
+ if (name == "key" || name == "startkey" || name == "endkey") {
+ value = toJSON(value);
+ }
+ buf.push(encodeURIComponent(name) + "=" + encodeURIComponent(value));
+ }
+ }
+ return buf.length ? "?" + buf.join("&") : "";
+ }
+
+ function toJSON(obj) {
+ return obj !== null ? JSON.stringify(obj) : null;
+ }
+
+})(jQuery);
