/brz/remove-bazaar

To get this branch, use:
bzr branch http://gegoxaren.bato24.eu/bzr/brz/remove-bazaar

« back to all changes in this revision

Viewing changes to breezy/repository.py

  • Committer: Jelmer Vernooij
  • Date: 2018-03-25 00:39:16 UTC
  • mfrom: (6926 work)
  • mto: This revision was merged to the branch mainline in revision 6928.
  • Revision ID: jelmer@jelmer.uk-20180325003916-mqa5uj4uq55hrjq9
merge trunk

Show diffs side-by-side

added added

removed removed

Lines of Context:
887
887
 
888
888
    def store_revision_signature(self, gpg_strategy, plaintext, revision_id):
889
889
        with self.lock_write():
890
 
            signature = gpg_strategy.sign(plaintext)
 
890
            signature = gpg_strategy.sign(plaintext, gpg.MODE_CLEAR)
891
891
            self.add_signature_text(revision_id, signature)
892
892
 
893
893
    def add_signature_text(self, revision_id, signature):
1104
1104
                return gpg.SIGNATURE_NOT_SIGNED, None
1105
1105
            signature = self.get_signature_text(revision_id)
1106
1106
 
1107
 
            testament = _mod_testament.Testament.from_revision(
1108
 
                    self, revision_id)
1109
 
            plaintext = testament.as_short_text()
 
1107
            testament = _mod_testament.Testament.from_revision(self, revision_id)
1110
1108
 
1111
 
            return gpg_strategy.verify(signature, plaintext)
 
1109
            (status, key, signed_plaintext) = gpg_strategy.verify(signature)
 
1110
            if testament.as_short_text() != signed_plaintext:
 
1111
                return gpg.SIGNATURE_NOT_VALID, None
 
1112
            return (status, key)
1112
1113
 
1113
1114
    def verify_revision_signatures(self, revision_ids, gpg_strategy):
1114
1115
        """Verify revision signatures for a number of revisions.
1579
1580
        :param to_convert: The disk object to convert.
1580
1581
        :param pb: a progress bar to use for progress information.
1581
1582
        """
1582
 
        pb = ui.ui_factory.nested_progress_bar()
1583
 
        self.count = 0
1584
 
        self.total = 4
1585
 
        # this is only useful with metadir layouts - separated repo content.
1586
 
        # trigger an assertion if not such
1587
 
        repo._format.get_format_string()
1588
 
        self.repo_dir = repo.controldir
1589
 
        pb.update(gettext('Moving repository to repository.backup'))
1590
 
        self.repo_dir.transport.move('repository', 'repository.backup')
1591
 
        backup_transport =  self.repo_dir.transport.clone('repository.backup')
1592
 
        repo._format.check_conversion_target(self.target_format)
1593
 
        self.source_repo = repo._format.open(self.repo_dir,
1594
 
            _found=True,
1595
 
            _override_transport=backup_transport)
1596
 
        pb.update(gettext('Creating new repository'))
1597
 
        converted = self.target_format.initialize(self.repo_dir,
1598
 
                                                  self.source_repo.is_shared())
1599
 
        converted.lock_write()
1600
 
        try:
1601
 
            pb.update(gettext('Copying content'))
1602
 
            self.source_repo.copy_content_into(converted)
1603
 
        finally:
1604
 
            converted.unlock()
1605
 
        pb.update(gettext('Deleting old repository content'))
1606
 
        self.repo_dir.transport.delete_tree('repository.backup')
1607
 
        ui.ui_factory.note(gettext('repository converted'))
1608
 
        pb.finished()
 
1583
        with ui.ui_factory.nested_progress_bar() as pb:
 
1584
            self.count = 0
 
1585
            self.total = 4
 
1586
            # this is only useful with metadir layouts - separated repo content.
 
1587
            # trigger an assertion if not such
 
1588
            repo._format.get_format_string()
 
1589
            self.repo_dir = repo.controldir
 
1590
            pb.update(gettext('Moving repository to repository.backup'))
 
1591
            self.repo_dir.transport.move('repository', 'repository.backup')
 
1592
            backup_transport =  self.repo_dir.transport.clone('repository.backup')
 
1593
            repo._format.check_conversion_target(self.target_format)
 
1594
            self.source_repo = repo._format.open(self.repo_dir,
 
1595
                _found=True,
 
1596
                _override_transport=backup_transport)
 
1597
            pb.update(gettext('Creating new repository'))
 
1598
            converted = self.target_format.initialize(self.repo_dir,
 
1599
                                                      self.source_repo.is_shared())
 
1600
            converted.lock_write()
 
1601
            try:
 
1602
                pb.update(gettext('Copying content'))
 
1603
                self.source_repo.copy_content_into(converted)
 
1604
            finally:
 
1605
                converted.unlock()
 
1606
            pb.update(gettext('Deleting old repository content'))
 
1607
            self.repo_dir.transport.delete_tree('repository.backup')
 
1608
            ui.ui_factory.note(gettext('repository converted'))
1609
1609
 
1610
1610
 
1611
1611
def _strip_NULL_ghosts(revision_graph):