anchor.diff:          <<"triggered">> ->
               maybe_start_replication(State, DbName, DocId, JsonRepDoc);
           <<"completed">> ->
  -            replication_complete(DocId),
  +            replication_complete(DbName, DocId),
               State;
           <<"error">> ->
  -            case ets:lookup(?DOC_TO_REP, DocId) of
  +            case ets:lookup(?DOC_TO_REP, {DbName, DocId}) of
               [] ->
                   maybe_start_replication(State, DbName, DocId, JsonRepDoc);
               _ ->
  
positive.code:         #rep_state{} ->
              ok
          end,
          true = ets:delete(?DOC_TO_REP, DocId);
      _ ->
          ok
      end.
  
  
  rep_doc_deleted(DocId) ->
      case ets:lookup(?DOC_TO_REP, DocId) of
      [{DocId, RepId}] ->
          couch_replicator:cancel_replication(RepId),
          true = ets:delete(?REP_TO_STATE, RepId),
          true = ets:delete(?DOC_TO_REP, DocId),
          twig:log(notice, "Stopped replication `~s` because replication document `~s`"
              " was deleted", [pp_rep_id(RepId), DocId]);
      [] ->
  
negative.code: 
  maybe_retry_replication(#rep_state{retries_left = 0} = RepState, Error, State) ->
      #rep_state{
          dbname = DbName,
          rep = #rep{id = RepId, doc_id = DocId},
          max_retries = MaxRetries
      } = RepState,
      couch_replicator:cancel_replication(RepId),
      true = ets:delete(?REP_TO_STATE, RepId),
      true = ets:delete(?DOC_TO_REP, {DbName, DocId}),
      twig:log(error, "Error in replication `~s` (triggered by document `~s`): ~s"
          "~nReached maximum retry attempts (~p).",
          [pp_rep_id(RepId), DocId, to_binary(error_reason(Error)), MaxRetries]),
  