Luwak inspection

luwak_file_iterate.erl

Fun = fun(C, File) ->
                  {ok, TLObj} = C:get(<<"luwak_tld">>, File, 2),
                  {_, TLVal} = hd(riak_object:get_contents(TLObj)),
                  FileRoot = proplists:get_value(root, TLVal),
                  {ok, RootObj} = C:get(<<"luwak_node">>, FileRoot),
                  {_, RootVal} = hd(riak_object:get_contents(RootObj)),
                  {_, _, ChunkKeys} = RootVal,
                  [begin
                       case C:get(<<"luwak_node">>, K) of
                           {ok, _} ->

                               ok;
                           {error, notfound} ->
                               io:format("Chunk ~p of file ~p was not found~n", [K, File])
                       end
                   end || {K, _} <- ChunkKeys]
          end.

f(C).
f(Client).
f(File).
f(Files).
f(TLObj).
f(TLVal).
f(FileRoot).
f(RootObj).
f(RootVal).
f(ChunkKeys).
{ok, Client} = riak:local_client().
{ok, Files} = Client:list_keys(<<"luwak_tld">>).
[Fun(Client, File) || File <- Files].

luwak_queries.erl

%% Get local riak connection
{ok, C} = riak:local_client().

%% List the keys in the top-level document bucket
%% These should be the file names
{ok, Files} = C:list_keys(<<"luwak_tld">>).

%% Get the keys of the chunks for a file
{ok, TLObj} = C:get(<<"luwak_tld">>, <<"filename_from_list_keys">>, 2).
{_, TLVal} = hd(riak_object:get_contents(TLObj)).
FileRoot = proplists:get_value(root, TLVal).
{ok, RootObj} = C:get(<<"luwak_node">>, FileRoot).
{_, RootVal} = hd(riak_object:get_contents(RootObj)).
{_, _, ChunkKeys} = RootVal.

%% Iterate over the list of chunk keys and try to fetch the object
[begin
  case C:get(<<"luwak_node">>, K) of
      {ok, _} ->
          ok;
      {error, notfound} ->
          io:format("Chunk ~p was not found~n", [K])
  end
 end || {K, _} <- ChunkKeys].

%% Verify any missing chunks cannot be fetched.
%% Substitute MISSING_CHUNK_HERE with the output 
%% from the above statement. Should look something
%% like <<"abababababaabababa">>.
C:get(<<"luwak_node">>, MISSING_CHUNK_HERE).


%% Note: Variables in erlang are immutable so if you make a mistake
%% or want to reuse a variable name you can forget the value with
%% f(VarName). Also erlang statements must end with a '.'