Look for 'deleted' and <<"deleted">> for compatibility
BugzID: 13780 Project: http://git-wip-us.apache.org/repos/asf/couchdb-mem3/repo Commit: http://git-wip-us.apache.org/repos/asf/couchdb-mem3/commit/33e5084f Tree: http://git-wip-us.apache.org/repos/asf/couchdb-mem3/tree/33e5084f Diff: http://git-wip-us.apache.org/repos/asf/couchdb-mem3/diff/33e5084f Branch: refs/heads/import Commit: 33e5084f228703e109dd114bfe0fb5eb10b22df8 Parents: 0ad9c87 Author: Adam Kocoloski <[email protected]> Authored: Mon Jun 4 11:11:36 2012 -0400 Committer: Adam Kocoloski <[email protected]> Committed: Mon Jun 4 11:11:36 2012 -0400 ---------------------------------------------------------------------- src/mem3_nodes.erl | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/couchdb-mem3/blob/33e5084f/src/mem3_nodes.erl ---------------------------------------------------------------------- diff --git a/src/mem3_nodes.erl b/src/mem3_nodes.erl index a3d841e..94bc291 100644 --- a/src/mem3_nodes.erl +++ b/src/mem3_nodes.erl @@ -138,7 +138,7 @@ changes_callback({stop, EndSeq}, _) -> changes_callback({change, {Change}, _}, _) -> Node = couch_util:get_value(<<"id">>, Change), case Node of <<"_design/", _/binary>> -> ok; _ -> - case couch_util:get_value(<<"deleted">>, Change, false) of + case is_deleted(Change) of false -> {Props} = couch_util:get_value(doc, Change), gen_server:call(?MODULE, {add_node, mem3_util:to_atom(Node), Props}); @@ -149,3 +149,12 @@ changes_callback({change, {Change}, _}, _) -> {ok, couch_util:get_value(<<"seq">>, Change)}; changes_callback(timeout, _) -> {ok, nil}. + +is_deleted(Change) -> + case couch_util:get_value(<<"deleted">>, Change) of + undefined -> + % keep backwards compatibility for a while + couch_util:get_value(deleted, Change, false); + Else -> + Else + end.
