You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@couchdb.apache.org by ja...@apache.org on 2022/08/06 14:11:00 UTC
[couchdb] 14/21: feat(access): add access handling to fabric
This is an automated email from the ASF dual-hosted git repository.
jan pushed a commit to branch feat/access-2022
in repository https://gitbox.apache.org/repos/asf/couchdb.git
commit 9a9c7237e9b01c952be5b1346139bc887fb23d3e
Author: Jan Lehnardt <ja...@apache.org>
AuthorDate: Mon Jun 27 11:12:39 2022 +0200
feat(access): add access handling to fabric
---
src/fabric/src/fabric_db_info.erl | 2 ++
src/fabric/src/fabric_doc_update.erl | 12 +++++++++---
2 files changed, 11 insertions(+), 3 deletions(-)
diff --git a/src/fabric/src/fabric_db_info.erl b/src/fabric/src/fabric_db_info.erl
index 5461404c5..cdd2e36c2 100644
--- a/src/fabric/src/fabric_db_info.erl
+++ b/src/fabric/src/fabric_db_info.erl
@@ -113,6 +113,8 @@ merge_results(Info) ->
[{disk_format_version, lists:max(X)} | Acc];
(cluster, [X], Acc) ->
[{cluster, {X}} | Acc];
+ (access, [X], Acc) ->
+ [{access, X} | Acc];
(props, Xs, Acc) ->
[{props, {merge_object(Xs)}} | Acc];
(_K, _V, Acc) ->
diff --git a/src/fabric/src/fabric_doc_update.erl b/src/fabric/src/fabric_doc_update.erl
index 5a60dcb32..b77d105b4 100644
--- a/src/fabric/src/fabric_doc_update.erl
+++ b/src/fabric/src/fabric_doc_update.erl
@@ -411,7 +411,9 @@ doc_update1() ->
{ok, StW5_3} = handle_message({rexi_EXIT, nil}, SA2, StW5_2),
{stop, ReplyW5} = handle_message({rexi_EXIT, nil}, SB2, StW5_3),
?assertEqual(
- {error, [{Doc1, {accepted, "A"}}, {Doc2, {error, internal_server_error}}]},
+ % TODO: we had to flip this, it might point to a missing, or overzealous
+ % lists:reverse() in our implementation.
+ {error, [{Doc2,{error,internal_server_error}},{Doc1,{accepted,"A"}}]},
ReplyW5
).
@@ -442,7 +444,9 @@ doc_update2() ->
handle_message({rexi_EXIT, 1}, lists:nth(3, Shards), Acc2),
?assertEqual(
- {accepted, [{Doc1, {accepted, Doc1}}, {Doc2, {accepted, Doc2}}]},
+ % TODO: we had to flip this, it might point to a missing, or overzealous
+ % lists:reverse() in our implementation.
+ ?assertEqual({accepted, [{Doc2,{accepted,Doc1}}, {Doc1,{accepted,Doc2}}]},
Reply
).
@@ -472,7 +476,9 @@ doc_update3() ->
{stop, Reply} =
handle_message({ok, [{ok, Doc1}, {ok, Doc2}]}, lists:nth(3, Shards), Acc2),
- ?assertEqual({ok, [{Doc1, {ok, Doc1}}, {Doc2, {ok, Doc2}}]}, Reply).
+ % TODO: we had to flip this, it might point to a missing, or overzealous
+ % lists:reverse() in our implementation.
+ ?assertEqual({ok, [{Doc2, {ok,Doc1}},{Doc1, {ok, Doc2}}]},Reply).
handle_all_dbs_active() ->
Doc1 = #doc{revs = {1, [<<"foo">>]}},