support _design and _doc_ids filters.

1 files changed, 31 insertions, 1 deletions

diff --git a/apps/couch/src/couch_changes.erl b/apps/couch/src/couch_changes.erl
index 8d5eae70..44d0ad46 100644
--- a/apps/couch/src/couch_changes.erl
+++ b/apps/couch/src/couch_changes.erl
@@ -177,6 +177,17 @@ configure_filter(Filter, Style, Req, Db) when is_list(Filter) ->
         #doc{body={Props}} = DDoc,
         couch_util:get_nested_json_value({Props}, [<<"filters">>, FName]),
         {custom, Style, {Db, JsonReq, DDoc, FName}};
+    [<<"_doc_ids">>] ->
+        DocIds = ?JSON_DECODE(couch_httpd:qs_value(Req, "doc_ids", "null")),
+        case is_list(DocIds) of
+            true -> ok;
+            false -> throw({bad_request, "`doc_ids` filter parameter is not a list."})
+        end,
+        {builtin, Style, {doc_ids, DocIds}};
+    [<<"_design">>] ->
+        {builtin, Style, design};
+    [<<"_", _/binary>>] ->
+        throw({bad_request, "unknown builtin filter name"});
     _Else ->
         throw({bad_request,
             "filter parameter must be of the form `designname/filtername`"})
@@ -191,7 +202,11 @@ filter(#doc_info{revs=Revs}, all_docs) ->
 filter(#doc_info{id=Id, revs=RevInfos}, {custom, main_only, Acc}) ->
     custom_filter(Id, [(hd(RevInfos))#rev_info.rev], Acc);
 filter(#doc_info{id=Id, revs=RevInfos}, {custom, all_docs, Acc}) ->
-    custom_filter(Id, [R || #rev_info{rev=R} <- RevInfos], Acc).
+    custom_filter(Id, [R || #rev_info{rev=R} <- RevInfos], Acc);
+filter(#doc_info{id=Id, revs=RevInfos}, {builtin, main_only, Acc}) ->
+    builtin_filter(Id, [(hd(RevInfos))#rev_info.rev], Acc);
+filter(#doc_info{id=Id, revs=RevInfos}, {builtin, all_docs, Acc}) ->
+    builtin_filter(Id, [R || #rev_info{rev=R} <- RevInfos], Acc).
 
 custom_filter(Id, Revs, {Db, JsonReq, DDoc, Filter}) ->
     {ok, Results} = fabric:open_revs(Db, Id, Revs, [deleted, conflicts]),
@@ -203,6 +218,21 @@ custom_filter(Id, Revs, {Db, JsonReq, DDoc, Filter}) ->
         || {Pass, #doc{revs={RevPos,[RevId|_]}}}
         <- lists:zip(Passes, Docs), Pass == true].
 
+builtin_filter(Id, Revs, design) ->
+    case Id of
+        <<"_design", _/binary>> ->
+            [{[{<<"rev">>, couch_doc:rev_to_str(Rev)}]} || Rev <- Revs];
+        _ ->
+            []
+    end;
+builtin_filter(Id, Revs, {doc_ids, DocIds}) ->
+    case lists:member(Id, DocIds) of
+        true ->
+            [{[{<<"rev">>, couch_doc:rev_to_str(Rev)}]} || Rev <- Revs];
+        false ->
+            []
+    end.
+
 get_changes_timeout(Args, Callback) ->
     #changes_args{
         heartbeat = Heartbeat,