diff options
Diffstat (limited to 'src/storage.erl')
| -rw-r--r-- | src/storage.erl | 13 |
1 files changed, 3 insertions, 10 deletions
diff --git a/src/storage.erl b/src/storage.erl index 8136308..e632a8e 100644 --- a/src/storage.erl +++ b/src/storage.erl @@ -20,7 +20,7 @@ request(post, "ct/storage/sendentry", Input) -> TreeLeafHash = base64:decode(proplists:get_value(<<"treeleafhash">>, PropList)), ok = db:add(TreeLeafHash, LogEntry), - ok = index:addlast(newentries_path(), TreeLeafHash), + ok = storagedb:add(TreeLeafHash), success({[{result, <<"ok">>}]}) end; request(post, "ct/storage/entrycommitted", Input) -> @@ -34,7 +34,8 @@ request(post, "ct/storage/entrycommitted", Input) -> success({[{result, <<"ok">>}]}) end; request(get, "ct/storage/fetchnewentries", _Input) -> - NewHashes = fetchnewhashes(0), + NewHashes = storagedb:fetchnewhashes(0), + % XXX send only hashes, implement getentry Entries = lists:map(fun(LeafHash) -> {[{hash, base64:encode(LeafHash)}, {entry, base64:encode(db:entry_for_leafhash(LeafHash))}]} @@ -42,14 +43,6 @@ request(get, "ct/storage/fetchnewentries", _Input) -> success({[{result, <<"ok">>}, {entries, Entries}]}). -fetchnewhashes(Index) -> - case index:indexsize(newentries_path()) of - 0 -> - []; - Size -> - index:getrange(newentries_path(), Index, Size - 1) - end. - %% Private functions. html(Text, Input) -> {400, [{"Content-Type", "text/html"}], |