1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
|
-module(fabric_rpc).
-export([open_doc/3, open_doc/4, get_db_info/1, update_docs/3]).
-include_lib("eunit/include/eunit.hrl").
open_doc(DbName, DocId, Options) ->
io:format("~p ~p ~p ~p~n", [?MODULE, DbName, DocId, Options]),
with_db(DbName, {couch_db, open_doc_int, [DocId, Options]}).
%% rpc endpoints
%% call to with_db will supply your M:F with a #db{} and then remaining args
open_doc(DbName, DocId, Revs, Options) ->
with_db(DbName, {couch_api, open_doc, [DocId, Revs, Options]}).
get_db_info(DbName) ->
with_db(DbName, {couch_db, get_db_info, []}).
update_docs(DbName, Docs, Options) ->
with_db(DbName, {couch_db, update_docs, [Docs, Options]}).
%%
%% internal
%%
with_db(DbName, {M,F,A}) ->
case couch_db:open(DbName, []) of
{ok, Db} ->
rexi:reply(apply(M, F, [Db | A]));
Error ->
rexi:reply(Error)
end.
%%
%% helper funs
%%
|
