diff options
Diffstat (limited to 'src/frontend.erl')
| -rw-r--r-- | src/frontend.erl | 27 |
1 files changed, 15 insertions, 12 deletions
diff --git a/src/frontend.erl b/src/frontend.erl index a7ca153..60f588a 100644 --- a/src/frontend.erl +++ b/src/frontend.erl @@ -5,9 +5,12 @@ -module(frontend). %% API (URL) --export([request/3]). +-export([request/4]). -request(post, "plop/v1/frontend/sendentry", Input) -> +-define(APPURL_PLOP_FRONTEND, "plop/v1/frontend"). +-define(APPURL_PLOP_MERGE, "plop/v1/merge"). + +request(post, ?APPURL_PLOP_FRONTEND, "sendentry", Input) -> case (catch mochijson2:decode(Input)) of {error, E} -> html("sendentry: bad input:", E); @@ -19,7 +22,7 @@ request(post, "plop/v1/frontend/sendentry", Input) -> success({[{result, <<"ok">>}]}) end; -request(post, "plop/v1/frontend/sendlog", Input) -> +request(post, ?APPURL_PLOP_FRONTEND, "sendlog", Input) -> case (catch mochijson2:decode(Input)) of {error, E} -> html("sendentry: bad input:", E); @@ -29,7 +32,7 @@ request(post, "plop/v1/frontend/sendlog", Input) -> write_or_verify_index(Start, Hashes) end; -request(post, "plop/v1/frontend/sendsth", Input) -> +request(post, ?APPURL_PLOP_FRONTEND, "sendsth", Input) -> case (catch mochijson2:decode(Input)) of {error, E} -> html("sendentry: bad input:", E); @@ -66,12 +69,12 @@ request(post, "plop/v1/frontend/sendsth", Input) -> end; -request(get, "plop/v1/frontend/currentposition", _Query) -> +request(get, ?APPURL_PLOP_FRONTEND, "currentposition", _Query) -> Size = db:size(), success({[{result, <<"ok">>}, {position, Size}]}); -request(get, "plop/v1/frontend/missingentries", _Query) -> +request(get, ?APPURL_PLOP_FRONTEND, "missingentries", _Query) -> Size = db:size(), Missing = fetchmissingentries(Size, 100000), lager:debug("missingentries: ~p", [Missing]), @@ -79,7 +82,7 @@ request(get, "plop/v1/frontend/missingentries", _Query) -> {entries, lists:map(fun (Entry) -> base64:encode(Entry) end, Missing)}]}); -request(post, "plop/v1/merge/sendentry", Input) -> +request(post, ?APPURL_PLOP_MERGE, "sendentry", Input) -> case (catch mochijson2:decode(Input)) of {error, E} -> html("sendentry: bad input:", E); @@ -99,7 +102,7 @@ request(post, "plop/v1/merge/sendentry", Input) -> success({[{result, <<"ok">>}]}) end; -request(post, "plop/v1/merge/sendlog", Input) -> +request(post, ?APPURL_PLOP_MERGE, "sendlog", Input) -> case (catch mochijson2:decode(Input)) of {error, E} -> html("sendentry: bad input:", E); @@ -109,7 +112,7 @@ request(post, "plop/v1/merge/sendlog", Input) -> write_or_verify_index(Start, Hashes) end; -request(post, "plop/v1/merge/verifyroot", Input) -> +request(post, ?APPURL_PLOP_MERGE, "verifyroot", Input) -> case (catch mochijson2:decode(Input)) of {error, E} -> html("sendentry: bad input:", E); @@ -139,12 +142,12 @@ request(post, "plop/v1/merge/verifyroot", Input) -> end end; -request(get, "plop/v1/merge/verifiedsize", _Query) -> +request(get, ?APPURL_PLOP_MERGE, "verifiedsize", _Query) -> Size = db:verifiedsize(), success({[{result, <<"ok">>}, {size, Size}]}); -request(post, "plop/v1/merge/setverifiedsize", Input) -> +request(post, ?APPURL_PLOP_MERGE, "setverifiedsize", Input) -> case (catch mochijson2:decode(Input)) of {error, E} -> html("setverifiedsize: bad input:", E); @@ -165,7 +168,7 @@ request(post, "plop/v1/merge/setverifiedsize", Input) -> end; -request(get, "plop/v1/merge/missingentries", _Query) -> +request(get, ?APPURL_PLOP_MERGE, "missingentries", _Query) -> Size = db:verifiedsize(), Missing = fetchmissingentries(Size, 100000), lager:debug("missingentries: ~p", [Missing]), |