anchor.diff:  end_per_testcase(changes_stream_closed_on_disconnection, Config) ->
       Workers = ?config(op_worker_nodes, Config),
       test_utils:mock_unload(Workers, changes_stream_handler),
  +    end_per_testcase(all, Config);
  +
  +end_per_testcase(unauthorized_request_should_fail, Config) ->
  +    UserId = <<"user1">>,
  +    [{SpaceId, _SpaceName} | _] = ?config({spaces, UserId}, Config),
  +    Workers = ?config(op_worker_nodes, Config),
  +    OldPrivs = ?config(old_privs, Config),
  +    initializer:testmaster_mock_space_user_privileges(Workers, SpaceId, <<"user1">>, OldPrivs),
       end_per_testcase(all, Config);
   
   end_per_testcase(_Case, Config) ->
  
positive.code: 
  -export([
      invalid_request_should_fail/1,
      changes_stream_file_meta_create_test/1,
      changes_stream_file_meta_change_test/1,
      changes_stream_xattr_test/1,
  
negative.code:         end),
      init_per_testcase(all, Config);
  
  init_per_testcase(unauthorized_request_should_fail, Config) ->
      Workers = [_, Worker] = ?config(op_worker_nodes, Config),
  
      UserId = <<"user1">>,
      [{SpaceId, _SpaceName} | _] = ?config({spaces, UserId}, Config),
  
      OldPrivs = rpc:call(Worker, initializer, node_get_mocked_space_user_privileges, [SpaceId, UserId]),
      NewPrivs = OldPrivs -- [?SPACE_VIEW_CHANGES_STREAM],
  
      initializer:testmaster_mock_space_user_privileges(Workers, SpaceId, UserId, NewPrivs),
  
      init_per_testcase(all, [{old_privs, OldPrivs} | Config]);
  
  init_per_testcase(_Case, Config) ->
      ct:timetrap({minutes, 5}),
      lfm_proxy:init(Config).
  