anchor.diff:  -author("Michal Zmuda").
   
   -include("registered_names.hrl").
  +-include("subscriptions/subscriptions.hrl").
   -include("datastore/oz_datastore_models_def.hrl").
   -include_lib("ctool/include/test/test_utils.hrl").
   -include_lib("ctool/include/logging.hrl").
  
positive.code:     multiple_updates_test/1,
      updates_for_added_user_test/1,
      updates_for_added_user_have_revisions_test/1,
      updates_have_revisions_test/1
  ]).
  
  -define(MESSAGES_WAIT_TIMEOUT, timer:seconds(2)).
  -define(MESSAGES_RECEIVE_ATTEMPTS, 30).
  
  %% helper record for maintaining subscription progress between message receives
  
negative.code:     call_worker(Node, {add_connection, P1, self()}),
  
      % when
      Context1 = init_messages(Node, P1, [<<"u1">>]),
      Context = flush_messages(Context1, group_expectation(<<"g1">>, <<"g1">>)),
      update_document(Node, user_group, <<"g1">>, #{name => <<"updated">>}),
  
      % then
  