anchor.diff:  
   % public API
   -export([replication_started/1, replication_completed/2, replication_error/2]).
  +-export([owner/1]).
   
   -export([before_doc_update/2, after_doc_read/2]).
   
  
positive.code:     {_, true} ->
          rep_doc_deleted(DbName, DocId),
          State;
      {false, false} ->
          State;
      {true, false} ->
          case get_json_value(<<"_replication_state">>, RepProps) of
          undefined ->
              maybe_start_replication(State, DbName, DocId, JsonRepDoc);
  
negative.code:         live = Live
      }}.
  
  handle_call({owner, RepId}, _From, State) ->
      case rep_state(RepId) of
      nil ->
          false;
      #rep_state{dbname = DbName, rep = #rep{doc_id = DocId}} ->
          {reply, owner(DbName, DocId, State#state.live), State}
      end;
  
  handle_call({rep_db_update, DbName, {ChangeProps} = Change}, _From, State) ->
      NewState = try
  