anchor.diff:                   Body}).
   
   reply_json(Req, Body) ->
  -    Req:ok({"application/json", mochijson2:encode(Body)}).
  +    Req:ok({"application/json", 
  +            [{"Server", "NorthScale menelaus_server %TODO gitversion%"}],
  +            mochijson2:encode(Body)}).
   
   handle_pools(Req) ->
       reply_json(Req, {struct, [
  
positive.code:                              {stats, {struct, [{uri, <<"/buckets/4/stats?really_for_pool=2">>}]}},
                               {name, <<"Another Pool">>}]}
            end,
      HRes:write_chunk(mochijson2:encode(Res)),
      handle_pool_info_streaming(Id, HRes, 1000).
  
  handle_pool_info_streaming(Id, HRes, Wait) ->
      receive
      after Wait ->
          %%Msg = io_lib:format("Chunk for id ~s\n", [Path]),
          Msg = io_lib:format("Called with wait ~w.~n", [Wait]),
          HRes:write_chunk(Msg)
      end,
      handle_pool_info_streaming(Id, HRes, 1000).
  
  
  handle_bucket_info(Id, Req) ->
  
negative.code:     reply_json(Req, Res).
  
  handle_pool_info_streaming(Id, Req) ->
      %% TODO: this shouldn't be timer driven, but rather should register a callback based on some state change in the Erlang OS
      HTTPRes = Req:ok({"application/json; charset=utf-8",
                    [{"Server", "NorthScale menelaus_server %TODO gitversion%"}],
                    chunked}),
      Res = case Id of
                "default" -> {struct, [{nodes, [{struct, [{ipAddress, <<"10.0.1.20">>},
  