anchor.diff:                  true
           end,
   
  +    ok = dbsync_utils:validate_space_access(From, SpaceId),
  +    MessageOrigin = lists:last(ExclProviders),
  +
       ?debug("DBSync request (ignored: ~p) from ~p ~p", [Ignore, From, BaseRequest]),
   
       case Ignore of
           false ->
  -            try handle_broadcast(From, Request, BaseRequest) of
  +            try handle_broadcast(MessageOrigin, Request, BaseRequest) of
   %%                ok -> ok; %% This case should be safely ignored but is not used right now.
                   reemit ->
                       case worker_proxy:cast(dbsync_worker, {reemit, BaseRequest}) of
  
positive.code:         _ ->
              {LSync, RSync} = lists:split(crypto:rand_uniform(0, length(SyncWith1)), SyncWith1),
              ExclProviders = [oneprovider:get_provider_id() | BaseRequest#tree_broadcast.excluded_providers],
              NewBaseRequest = BaseRequest#tree_broadcast{excluded_providers = lists:usort(ExclProviders), space_id = SpaceId},
              do_emit_tree_broadcast(LSync, Request, NewBaseRequest, Attempts),
              do_emit_tree_broadcast(RSync, Request, NewBaseRequest, Attempts)
      end.
  
negative.code: %%--------------------------------------------------------------------
  -spec handle_impl(From :: oneprovider:id(), #tree_broadcast{} | #changes_request{} | #batch_update{}) ->
      ok | {error, Reason :: term()} | no_return().
  handle_impl(From, #tree_broadcast{message_body = Request, request_id = ReqId, space_id = SpaceId,
                                      excluded_providers = ExclProviders} = BaseRequest) ->
      Ignore =
          case dbsync_utils:temp_get({request, ReqId}) of
              undefined ->
  