test: extend mango_database.exs

path
open_doc
delete_doc
ddoc_info
delete_index
bulk_delete

Author: hulkoba

test/elixir/test/support/mango_database.ex

@@ -17,6 +17,16 @@ defmodule MangoDatabase do
     "search" in resp.body["features"]
   end
 
+  def path(db, parts) do
+    parts_list =
+      case parts do
+        p when is_binary(p) -> [p]
+        p when is_list(p) -> p
+      end
+
+    Path.join(["/#{db}" | parts_list])
+  end
+
   def recreate(db, opts \\ []) do
     resp = Couch.get("/#{db}")
     if resp.status_code == 200 do
@@ -48,6 +58,23 @@ defmodule MangoDatabase do
     Couch.post("/#{db}/_bulk_docs", body: body)
   end
 
+  def open_doc(db, docid) do
+    response = Couch.get("/#{db}/#{docid}")
+    response.body
+  end
+
+  def delete_doc(db, docid) do
+    path = "/#{db}/#{URI.encode(docid)}"
+    doc = Couch.get(path)
+    original_rev = doc.body["_rev"]
+    Couch.delete(path, query: %{"rev" => original_rev})
+  end
+
+  def ddoc_info(db, ddocid) do
+    response = Couch.get("/#{db}/#{ddocid}/_info")
+    response.body
+  end
+
   # If a certain keyword like sort or field is passed in the options,
   # then it is added to the request body.
   defp put_if_set(map, key, opts, opts_key) do
@@ -157,6 +184,17 @@ defmodule MangoDatabase do
     end
   end
 
+  def delete_index(db, ddocid, name, idx_type \\ "json") do
+    path = Path.join(["_index", ddocid, idx_type, name])
+    Couch.delete("/#{db}/#{path}", params: %{"w" => "3"})
+  end
+
+  def bulk_delete(db, docs) do
+    body = %{"docids" => docs, "w" => 3}
+    resp = Couch.post("/#{db}/_index/_bulk_delete", body: body)
+    resp.body
+  end
+
   def find(db, selector, opts \\ []) do
     defaults = [
       use_index: nil,