Logo Search packages:      
Sourcecode: tailor version File versions  Download package


# -*- mode: python; coding: utf-8 -*-
# :Progetto: vcpx -- Updatable VC working directory
# :Creato:   mer 09 giu 2004 13:55:35 CEST
# :Autore:   Lele Gaifax <lele@nautilus.homeip.net>
# :Licenza:  GNU General Public License

Updatable sources are the simplest abstract wrappers around a working
directory under some kind of version control system.

__docformat__ = 'reStructuredText'

from workdir import WorkingDir

The changeset

caused conflicts on the following files:

 * %s

This is quite unusual, and most probably it means someone else has
changed the working dir, beyond tailor control, or maybe a tailor bug
is showing up.

Either abort the session with Ctrl-C, or manually correct the situation
with a Ctrl-Z, explore and correct, and coming back from the shell with

What would you like to do?

class GetUpstreamChangesetsFailure(Exception):
    "Failure getting upstream changes"

class ChangesetApplicationFailure(Exception):
    "Failure applying upstream changes"

class InvocationError(Exception):
    "Bad invocation, use --help for details"

00045 class UpdatableSourceWorkingDir(WorkingDir):
    This is an abstract working dir able to follow an upstream
    source of ``changesets``.

    It has three main functionalities:

        to query the upstream server about new changesets

        to apply them to the working directory

        to extract a new copy of the sources, actually initializing
        the mechanism.

    Subclasses MUST override at least the _underscoredMethods.

00065     def applyPendingChangesets(self, applyable=None, replayable=None,
                               replay=None, applied=None):
        Apply the collected upstream changes.

        Loop over the collected changesets, doing whatever is needed
        to apply each one to the working dir and if the changes do
        not raise conflicts call the `replay` function to mirror the
        changes on the target.

        Return a tuple of two elements:

        - the last applied changeset, if any
        - the sequence (potentially empty!) of conflicts.

        from time import sleep

        c = None
        last = None
        conflicts = []

            for c in self.state_file:
                # Give the opportunity to subclasses to stop the application
                # of the queue, before the application of the patch by the
                # source backend.
                if not self._willApplyChangeset(c, applyable):
                    self.log.debug('Stopping application at revisin %r',

                # Sometime is better to wait a little while before each
                # changeset, to avoid upstream server stress.
                if self.repository.delay_before_apply:

                    res = self._applyChangeset(c)
                except ChangesetApplicationFailure, e:
                    self.log.critical("Couldn't apply changeset")
                    self.log.debug("Reason: %s", str(e))
                    self.log.debug("Changeset: %s", c)
                except KeyboardInterrupt:
                    self.log.warning("INTERRUPTED BY THE USER!")
                    self.log.exception("Couldn't apply changeset\n%s", c)

                if res:
                    # Uh, we have a conflict: this should not ever
                    # happen, but the user may have manually tweaked
                    # the working directory. Give her a chance of
                    # fixing the situation, or abort with Ctrl-C, or
                    # whatever the subclasses decide.
                        self._handleConflict(c, conflicts, res)
                    except KeyboardInterrupt:
                        self.log.warning("INTERRUPTED BY THE USER!")

                # Give the opportunity to subclasses to skip the commit on
                # the target backend.
                if self._didApplyChangeset(c, replayable):
                    if replay:
                        except ChangesetApplicationFailure, e:
                            self.log.critical("Couldn't reply changeset")
                            self.log.debug("Reason: %s", str(e))
                            self.log.debug("Changeset: %s", c)
                            self.log.exception("Couldn't reply changeset\n%s",

                # Remember it for the finally clause and notify the state
                # file so that it gets removed from the queue
                last = c

                # Another hook (last==c here)
                if applied:
            # For whatever reason we exit the loop, save the last state

        return last, conflicts

00158     def _willApplyChangeset(self, changeset, applyable=None):
        This gets called just before applying each changeset.  The whole
        process will be stopped if this returns False.

        Subclasses may use this to stop the process on some conditions,
        or to do whatever before application.

        if applyable:
            return applyable(changeset)
            return True

00172     def _didApplyChangeset(self, changeset, replayable=None):
        This gets called right after changeset application.  The final
        commit on the target system won't be carried out if this
        returns False.

        Subclasses may use this to alter the changeset in any way, before
        committing its changes to the target system.

        if replayable:
            return replayable(changeset)
            return True

00187     def _handleConflict(self, changeset, conflicts, conflict):
        Handle the conflict raised by the application of the upstream changeset.

        This implementation just append a (changeset, conflict) to the
        list of all conflicts, and present a prompt to the user that
        may abort with Ctrl-C (that in turn generates a KeyboardInterrupt).

        conflicts.append((changeset, conflict))
        raw_input(CONFLICTS_PROMPT % (str(changeset), '\n * '.join(conflict)))

00199     def getPendingChangesets(self, sincerev=None):
        Load the pending changesets from the state file, or query the
        upstream repository if there's none. Return an iterator over
        pending changesets.

        if not self.state_file.pending():
            last = self.state_file.lastAppliedChangeset()
            if last:
                revision = last.revision
                revision = sincerev
            changesets = self._getUpstreamChangesets(revision)
        return self.state_file

00216     def _getUpstreamChangesets(self, sincerev):
        Query the upstream repository about what happened on the
        sources since last sync, returning a sequence of Changesets

        This method must be overridden by subclasses.

        raise "%s should override this method" % self.__class__

00227     def _applyChangeset(self, changeset):
        Do the actual work of applying the changeset to the working copy.

        Subclasses should reimplement this method performing the
        necessary steps to *merge* given `changeset`, returning a list
        with the conflicts, if any.

        raise "%s should override this method" % self.__class__

00238     def checkoutUpstreamRevision(self, revision):
        Extract a working copy of the given revision from a repository.

        Return the last applied changeset.

        last = self._checkoutUpstreamRevision(revision)
        # Notify the state file about latest applied changeset
        return last

00251     def _checkoutUpstreamRevision(self, revision):
        Concretely do the checkout of the upstream revision.

        raise "%s should override this method" % self.__class__

00258     def prepareSourceRepository(self):
        Do whatever is needed to setup or connect to the source


00266     def _prepareSourceRepository(self):
        Possibly connect to the source repository, when overriden
        by subclasses.

Generated by  Doxygen 1.6.0   Back to index