anchor.diff:      end.
   
   bucket_type_status([TypeStr]) ->
  -    Type = list_to_binary(TypeStr),
  +    Type = unicode:characters_to_binary(TypeStr, utf8),
       bucket_type_print_status(Type, riak_core_bucket_type:status(Type)),
       bucket_type_print_props(bucket_type_raw_props(Type)).
   
  
positive.code:             ErlProps = [riak_kv_wm_utils:erlify_bucket_prop(P) || P <- Props],
              bucket_type_print_update_result(Type, riak_core_bucket_type:update(Type, ErlProps));
          _ ->
              io:format("Cannot create bucket type ~s: no props field found in json~n", [Type]),
              error
      end;
  bucket_type_update(Type, _) ->
      io:format("Cannot update bucket type: ~s: invalid json~n", [Type]),
      error.
  
  bucket_type_print_update_result(Type, ok) ->
      io:format("~s updated~n", [Type]);
  bucket_type_print_update_result(Type, {error, Reason}) ->
      io:format("Error updating bucket type ~s: ~p~n", [Type, Reason]),
      error.
  
  bucket_type_reset([TypeStr]) ->
      Type = list_to_binary(TypeStr),
      bucket_type_print_reset_result(Type, riak_core_bucket_type:reset(Type)).
  
  bucket_type_print_reset_result(Type, ok) ->
      io:format("~s reset~n", [Type]);
  bucket_type_print_reset_result(Type, {error, Reason}) ->
      io:format("Error updating bucket type ~s: ~p~n", [Type, Reason]),
      error.
  
  bucket_type_list([]) ->
  
negative.code:             ErlProps = [riak_kv_wm_utils:erlify_bucket_prop(P) || P <- Props],
              bucket_type_print_create_result(Type, riak_core_bucket_type:create(Type, ErlProps));
          _ ->
              io:setopts([{encoding, unicode}]),
              io:format("Cannot create bucket type ~ts: no props field found in json~n", [Type]),
              error
      end;
  bucket_type_create(Type, _) ->
      io:setopts([{encoding, unicode}]),
      io:format("Cannot create bucket type ~ts: invalid json~n", [Type]),
      error.
  
  bucket_type_print_create_result(Type, ok) ->
      io:setopts([{encoding, unicode}]),
      io:format("~ts created~n", [Type]),
      case bucket_type_is_first() of
          true ->
              io:format("~n"),
              io:format("WARNING: After activating ~ts, nodes in this cluster~n"
                        "can no longer be downgraded to a version of Riak "
                        "prior to 2.0~n", [Type]);
          false ->
              ok
      end;
  bucket_type_print_create_result(Type, {error, Reason}) ->
      io:setopts([{encoding, unicode}]),
      io:format("Error creating bucket type ~ts: ~p~n", [Type, Reason]),
      error.
  
  bucket_type_update([TypeStr, PropsStr]) ->
      Type = unicode:characters_to_binary(TypeStr, utf8),
      bucket_type_update(Type, catch mochijson2:decode(PropsStr)).
  
  bucket_type_update(Type, {struct, Fields}) ->
  