anchor.diff:                                    Path :: binary(),
                                     MaxLeaseTime :: integer(),
                                     WorkerPort :: port(),
  -                                  From :: pid(),
  +                                  From :: {pid(), _},
                                     Timeout :: integer(),
                                     Token :: binary(),
                                     Public :: binary(),
  
positive.code:                                                     when SubmissionData :: payload_submission_data(),
                                                           Secret :: binary(),
                                                           WorkerPort :: port(),
                                                           From :: pid(),
                                                           Timeout :: integer().
  p_submit_payload({LeaseToken, Payload, Digest, HeaderSize}, Secret, WorkerPort, From, Timeout) ->
      Req1 = jsx:encode(#{<<"token">> => LeaseToken, <<"secret">> => Secret}),
  
negative.code:                                              OldRootHash :: binary(),
                                               NewRootHash :: binary(),
                                               RepoTag :: cvmfs_common_types:repository_tag(),
                                               From :: {pid(), _},
                                               Timeout :: integer().
  p_commit(WorkerPort, LeasePath, OldRootHash, NewRootHash, RepoTag, From, Timeout) ->
      {TagName, TagChannel, TagDescription} = RepoTag,
  