anchor.diff:  -spec start(amoc_scenario:user_id(), amoc_scenario:state()) -> any().
   start(Id, Settings) ->
       Client = connect_amoc_user(Id, Settings),
  -    case get_role(Id) of
  -        coordinator -> start_coordinator(Client, Settings);
  -        user -> start_user(Client, Settings)
  -    end.
  +    start_user(Client, Settings).
   
   init_metrics() ->
       Counters = [message,
  
positive.code: -define(NODE_CREATION_THROTTLING, node_creation).
  -define(PUBLICATION_THROTTLING, publication).
  
  -define(COORDINATOR_ID, 1).
  -define(COORDINATOR_TIMEOUT, 100000).
  
  -export([init/0, start/2]).
  
  
negative.code:     user_loop(Settings, Client, #{}).
  
  create_new_node(Client, Settings) ->
      amoc_throttle:send_and_wait(?NODE_CREATION_THROTTLING, create_node),
      create_pubsub_node(Client, Settings),
      amoc_coordinator:add(?MODULE, Client).
  
  user_loop(Settings, Client, Requests) ->
      IqTimeout = get_parameter(iq_timeout, Settings),
  