try: import pysvn missing = False except: missing = True import Bcfg2.Server.Plugin class Svn2(Bcfg2.Server.Plugin.Plugin, Bcfg2.Server.Plugin.Version): """Svn is a version plugin for dealing with Bcfg2 repos.""" name = 'Svn2' __version__ = '$Id$' __author__ = 'bcfg-dev@mcs.anl.gov' conflicts = ['Svn'] experimental = True __rmi__ = Bcfg2.Server.Plugin.Plugin.__rmi__ + ['Update','Commit'] def __init__(self, core, datastore): Bcfg2.Server.Plugin.Plugin.__init__(self, core, datastore) if missing: self.logger.error("Svn2: Missing PySvn") raise Bcfg2.Server.Plugin.PluginInitError self.client = pysvn.Client() self.core = core self.datastore = datastore self.svn_root = None self.revision = None # Read revision from bcfg2 repo revision = self.get_revision() if not self.revision: raise Bcfg2.Server.Plugin.PluginInitError self.logger.debug("Initialized svn plugin with svn root %s at revision %s" % (self.svn_root, revision)) def get_revision(self): """Read svn revision information for the Bcfg2 repository.""" try: info = self.client.info(self.datastore) self.revision = info.revision self.svn_root = info.url return str(self.revision.number) except: self.logger.error("Svn2: Failed to get revision", exc_info=1) self.revision = None return str(-1) def commit_data(self, file_list, comment=None): """Commit changes into the repository""" if not comment: comment = 'Svn2: autocommit' # First try to update if not self.Update(): self.logger.error("Failed to update svn repository, refusing to commit changes") return #FIXME - look for conflicts? for fname in file_list: stat = self.client.status(fname) self.client.add([f.path for f in stat \ if f.text_status == pysvn.wc_status_kind.unversioned]) try: self.revision = self.client.checkin([self.datastore], comment, recurse=True) self.revision = self.client.update(self.datastore, recurse=True)[0] self.logger.info("Svn2: Commited changes. At %s" % self.revision.number) except Exception, err: # try to be smart about the error we got back details = None if "callback_ssl_server_trust_prompt" in err.message: details = "SVN server certificate is not trusted" elif "callback_get_login" in err.message: details = "SVN credentials not cached" if details is None: self.logger.error("Svn2: Failed to commit changes", exc_info=1) else: self.logger.error("Svn2: Failed to commit changes: %s" % details) def Update(self): '''Svn2.Update() => True|False\nUpdate svn working copy\n''' try: old_revision = self.revision.number self.revision = self.client.update(self.datastore, recurse=True)[0] except Exception, err: # try to be smart about the error we got back details = None if "callback_ssl_server_trust_prompt" in err.message: details = "SVN server certificate is not trusted" elif "callback_get_login" in err.message: details = "SVN credentials not cached" if details is None: self.logger.error("Svn2: Failed to update server repository", exc_info=1) else: self.logger.error("Svn2: Failed to update server repository: %s" % details) return False if old_revision == self.revision.number: self.logger.debug("repository is current") else: self.logger.info("Updated %s from revision %s to %s" % \ (self.datastore, old_revision, self.revision.number)) return True def Commit(self): """Svn2.Commit() => True|False\nCommit svn repository\n""" try: self.commit_changes([]) return True except: return False