[couchdb] branch add-shard-sync-api updated: Fix timeout in chttpd_purge_tests

[wo...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

wohali pushed a commit to branch add-shard-sync-api
in repository https://gitbox.apache.org/repos/asf/couchdb.git


The following commit(s) were added to refs/heads/add-shard-sync-api by this push:
     new 0f833fd  Fix timeout in chttpd_purge_tests
     new c25fd2e  Merge branch 'master' into add-shard-sync-api
0f833fd is described below

commit 0f833fd0c20ba0227028776c398ccd8cd13b93b3
Author: Paul J. Davis <pa...@gmail.com>
AuthorDate: Fri Jan 18 10:52:24 2019 -0600

    Fix timeout in chttpd_purge_tests
---
 src/chttpd/test/chttpd_purge_tests.erl | 36 +++++++++++++++++++++++-----------
 1 file changed, 25 insertions(+), 11 deletions(-)

diff --git a/src/chttpd/test/chttpd_purge_tests.erl b/src/chttpd/test/chttpd_purge_tests.erl
index 50f7e18..dbd73de 100644
--- a/src/chttpd/test/chttpd_purge_tests.erl
+++ b/src/chttpd/test/chttpd_purge_tests.erl
@@ -52,6 +52,11 @@ create_doc(Url, Id, Content) ->
         [?CONTENT_JSON, ?AUTH], "{\"mr\": \"" ++ Content ++ "\"}").
 
 
+create_docs(Url, Docs) ->
+    test_request:post(Url ++ "/_bulk_docs",
+        [?CONTENT_JSON, ?AUTH], ?JSON_ENCODE({[{docs, Docs}]})).
+
+
 delete_db(Url) ->
     {ok, 200, _, _} = test_request:delete(Url, [?AUTH]).
 
@@ -141,20 +146,29 @@ test_ok_purge_request(Url) ->
 test_ok_purge_request_with_101_docid(Url) ->
     ?_test(begin
         PurgedDocsNum = 101,
-        IdsRevsEJson = lists:foldl(fun(I, CIdRevs) ->
+        Docs = lists:foldl(fun(I, Acc) ->
             Id = list_to_binary(integer_to_list(I)),
-            {ok, _, _, Body} = create_doc(Url, Id),
-            {Json} = ?JSON_DECODE(Body),
-            Rev = couch_util:get_value(<<"rev">>, Json, undefined),
-            [{Id, [Rev]} | CIdRevs]
-         end, [], lists:seq(1, PurgedDocsNum)),
+            Doc = {[{<<"_id">>, Id}, {value, I}]},
+            [Doc | Acc]
+        end, [], lists:seq(1, PurgedDocsNum)),
+
+        {ok, _, _, Body} = create_docs(Url, Docs),
+        BodyJson = ?JSON_DECODE(Body),
+
+        PurgeBody = lists:map(fun({DocResp}) ->
+            Id = couch_util:get_value(<<"id">>, DocResp, undefined),
+            Rev = couch_util:get_value(<<"rev">>, DocResp, undefined),
+            {Id, [Rev]}
+        end, BodyJson),
 
-        IdsRevs = binary_to_list(?JSON_ENCODE({IdsRevsEJson})),
         ok = config:set("purge", "max_document_id_number", "101"),
-        {ok, Status, _, _} = test_request:post(Url ++ "/_purge/",
-            [?CONTENT_JSON, ?AUTH], IdsRevs),
-        ok = config:delete("purge", "max_document_id_number"),
-        ?assert(Status =:= 201 orelse Status =:= 202)
+        try
+            {ok, Status, _, _} = test_request:post(Url ++ "/_purge/",
+                [?CONTENT_JSON, ?AUTH], ?JSON_ENCODE({PurgeBody})),
+            ?assert(Status =:= 201 orelse Status =:= 202)
+        after
+            ok = config:delete("purge", "max_document_id_number")
+        end
     end).