anchor.diff:              %% Session data found, and its user ID matches -> send OK status and update current connection state
               ?debug("User ~p assigned FUSE ID ~p to the connection (PID: ~p)", [UserKey, NewFuseId, self()]),
               {reply, {binary, encode_answer(ok, MsgId, Answer_type, Answer_decoder_name, #atom{value = ?VOK})}, Req,
  -                State#handler_state{fuse_id = NewFuseId, connection_id = ConnID, access_token = vcn_utils:ensure_binary(AccessToken), user_global_id = vcn_utils:ensure_binary(UserGID)}};
  +                        State#handler_state{fuse_id = NewFuseId, connection_id = ConnID, access_token = vcn_utils:ensure_binary(AccessToken), user_global_id = vcn_utils:ensure_binary(UserGID)}};
   
           {ok, #veil_document{record = #fuse_session{uid = OtherUID}}} ->
               %% Current user does not match session owner
  
positive.code:     {reply, {binary, encode_answer(ok, MsgId)}, Req, State};
  handle(Req, {pull, FuseID, CLM}, #handler_state{peer_type = provider, provider_id = ProviderId} = State) ->
      ?debug("Got pull msg: ~p from ~p", [CLM, FuseID]),
      handle(Req, CLM, State#handler_state{fuse_id = vcn_utils:ensure_list(fslogic_context:gen_global_fuse_id(ProviderId, FuseID))});
  handle(Req, {Synch, Task, Answer_decoder_name, ProtocolVersion, Msg, MsgId, Answer_type, {GlobalId, TokenHash}} = _CLM,
      #handler_state{peer_dn = DnString, dispatcher_timeout = DispatcherTimeout, fuse_id = FuseID,
          access_token = SessionAccessToken, user_global_id = SessionUserGID} = State) ->
      %% Check if received message requires FuseId
      MsgType = case Msg of
                    M0 when is_tuple(M0) -> erlang:element(1, M0); %% Record
  
negative.code:         token_hash = TokenHash, global_user_id = GlobalId} = DecodedBytes,
  
      {Decoder, DecodingFun, ModuleNameAtom} = try
        {list_to_existing_atom(Message_decoder_name ++ "_pb"), list_to_existing_atom("decode_" ++ Message_type), list_to_existing_atom(ModuleName)}
      catch
        _:_ -> throw({message_not_supported, MsgId})
      end,
  
      Msg =
          try
  