anchor.diff:      DecodedBody = json_utils:decode(Body),
       ?assertEqual(
           [
  -            [{<<"provider">>, domain(WorkerP2)}, {<<"blocks">>, [[0,4]]}],
  -            [{<<"provider">>, domain(WorkerP1)}, {<<"blocks">>, [[0,4]]}]
  +            [{<<"providerId">>, domain(WorkerP2)}, {<<"blocks">>, [[0,4]]}],
  +            [{<<"providerId">>, domain(WorkerP1)}, {<<"blocks">>, [[0,4]]}]
           ], DecodedBody).
   
   replicate_dir(Config) ->
  
positive.code:     DecodedBody2 = json_utils:decode(Body2),
      DecodedBody3 = json_utils:decode(Body3),
      Distribution = [
          [{<<"provider">>, domain(WorkerP2)}, {<<"blocks">>, [[0,4]]}],
          [{<<"provider">>, domain(WorkerP1)}, {<<"blocks">>, [[0,4]]}]
      ],
      ?assertEqual(Distribution, DecodedBody1),
      ?assertEqual(Distribution, DecodedBody2),
  
negative.code:     DecodedBody = json_utils:decode(Body),
      ?assertEqual(
          [
              [{<<"providerId">>, domain(WorkerP2)}, {<<"blocks">>, [[0,4]]}],
              [{<<"providerId">>, domain(WorkerP1)}, {<<"blocks">>, [[0,4]]}]
          ], DecodedBody).
  
  changes_stream_file_meta_test(Config) ->
  