support for rhnpush

docs/rhnpush-support.txt

@@ -0,0 +1,79 @@
+= Using rhnpush support in mrepo
+Andreas Thienemann <[email protected]>
+0.8.7, 11 April 2013
+
+// Please send me improvements to this document.
+
+This document describes how to set up a mrepo so that downloaded packages
+are automatically pushed into a local Red Hat Satellite or a Spacewalk
+server.
+
+
+== Requirements
+For rhnpush support to work, you need to have the rhnpush client installed.
+
+
+== Overview
+rhnpush support is handled as a metadata handler in mrepo similar to repomd
+or repoview.
+It will push files downloaded by mrepo through whatever supported means into
+channels on a spacewalk server.
+
+
+== Channel names
+mrepo will build the channel name it pushes files to based on the user-
+configurable rhnpushprefix, the architecture, the distribution name and the
+release version.
+
+The channel name is build in the following manner:
+%{rhnpushprefix}-%{arch}-%{distribution-name}-%{release}.
+
+
+== mrepo configuration
+To have files pushed to to your local server you need to configure the server
+and a user and password combination which is allowed to push files to the
+server.
+
+This can be set either globally in /etc/mrepo.conf or more finegrained in a
+included file in the /etc/mrepo.conf.d/ directory:
+
+---
+[main]
+rhnpush-server = https://localhost/APP
+rhnpush-user = spacewalk
+rhnpush-password = spacewalk
+---
+
+To actually use rhnpush, configure it as the sole or an additional metadata
+handler as done in the example below.
+
+---
+[rhel-server-6]
+name = Red Hat Enterprise Linux Server $release ($arch)
+release = 6
+arch = x86_64
+metadata = rhnpush
+rhnpushprefix = rhel
+
+server = rhns:///rhel-$arch-server-6
+server-fastrack = rhns:///rhel-$arch-server-fastrack-6
+---
+
+The example above will mirror two RHN channels, the server and the server-
+fastrack channel.
+
+These two distributions will then be pushed to the channels
+rhel-x86_64-server-6 and rhel-x86_64-server-fastrack-6 respectively based
+on the channel naming rules described above.
+
+These channels need to be manually created before running mrepo.
+
+There is an option of skipping certain channels.
+
+---
+rhnpushskip = all
+---
+
+This would skip pushing the mrepo generated .all channel to the server.
+Skipping the "all" channel is activated by default but can be overwritten
+by the user.

mrepo

@@ -226,6 +226,7 @@ class Config:
         self.cmd['repoview'] = self.getoption('main', 'repoviewcmd', '/usr/bin/repoview')
         self.cmd['reposync'] = self.getoption('main', 'reposynccmd', '/usr/bin/reposync')
         self.cmd['rhnget'] = self.getoption('main', 'rhngetcmd', '/usr/bin/rhnget')
+        self.cmd['rhnpush'] = self.getoption('main', 'rhnpushcmd', '/usr/bin/rhnpush')
         self.cmd['rsync'] = self.getoption('main', 'rsynccmd', '/usr/bin/rsync')
         self.cmd['unionfs'] = self.getoption('main', 'unionfscmd', '/usr/bin/unionfs')
         self.cmd['umount'] = self.getoption('main', 'umountcmd', '/bin/umount')
@@ -257,6 +258,13 @@ class Config:
         self.rhngetcleanup = self.getoption('main', 'rhnget-cleanup', 'yes') not in disable
         self.rhngetdownloadall = self.getoption('main', 'rhnget-download-all', 'no') not in disable
 
+        self.rhnpushoptions = self.getoption('main', 'rhnpush-options', '')
+        self.rhnpushuser = self.getoption('main', 'rhnpush-user', None)
+        self.rhnpushpassword = self.getoption('main', 'rhnpush-password', None)
+        self.rhnpushserver = self.getoption('main', 'rhnpush-server', None)
+        self.rhnpushprefix = self.getoption('main', 'rhnpushprefix', None)
+        self.rhnpushskip = self.getoption('main', 'rhnpushskip', 'all')
+
         self.rsyncbwlimit = self.getoption('main', 'rsync-bandwidth-limit', None)
         self.rsynccleanup = self.getoption('main', 'rsync-cleanup', 'yes') not in disable
         self.rsyncexcldebug = self.getoption('main', 'rsync-exclude-debug', 'yes') not in disable
@@ -322,8 +330,10 @@ class Config:
                     dist.fuseiso = True
                     dist.unionfs = True
                     dist.systemid = None
+                    dist.rhnpushprefix = self.rhnpushprefix
+                    dist.rhnpushskip = self.rhnpushskip
                     for option in self.cfg.options(section):
-                        if option in ('iso', 'name', 'release', 'repo', 'rhnrelease'):
+                        if option in ('iso', 'name', 'release', 'repo', 'rhnrelease', 'rhnpushprefix', 'rhnpushskip'):
                             setattr(dist, option, self.cfg.get(section, option))
                         elif option in ('arch', 'dist'):
                             pass
@@ -844,7 +854,7 @@ class Repo:
             error(0, '%s: Lockfile %s does not exist. Cannot unlock. Something fishy here ?' % (self.dist.nick, lockfile))
 
     def createmd(self):
-        metadata = ('apt', 'createrepo', 'repomd', 'repoview', 'yum')
+        metadata = ('apt', 'createrepo', 'repomd', 'repoview', 'rhnpush', 'yum')
         index = ('repoview',)
 
         if not self.changed and not op.force:
@@ -859,6 +869,8 @@ class Repo:
                     self.yum()
                 elif md in ('apt',):
                     self.apt()
+                elif md in ('rhnpush',):
+                    self.rhnpush()
                 elif md not in index:
                     error(0, 'The %s metadata is unknown.' % md)
 
@@ -995,6 +1007,46 @@ class Repo:
         if ret:
             raise(mrepoGenerateException('%s failed with return code: %s' % (cf.cmd['genbasedir'], ret)))
 
+    def rhnpush(self):
+        "Do rhnpush to spacewalk/Satellite Server"
+
+        # Build the Channelname to push to
+        channelname = '%s-%s-%s-%s' % (self.dist.rhnpushprefix, self.dist.arch, self.name, self.dist.release)
+
+        if not cf.cmd['rhnpush']:
+            raise mrepoGenerateException('Command rhnpush is not found. Skipping.')
+
+        if not cf.rhnpushserver:
+            raise mrepoGenerateException('No server to rhnpush to configured. Skipping.')
+
+        if not cf.rhnpushuser:
+            raise mrepoGenerateException('No user for rhnpush configured. Skipping.')
+
+        if not cf.rhnpushpassword:
+            raise mrepoGenerateException('No password for rhnpush configured. Skipping.')
+
+        if not self.dist.rhnpushprefix:
+            raise mrepoGenerateException('No rhnpushprefox configured. Skipping.')
+
+        if self.name in self.dist.rhnpushskip.split():
+            info(2, '%s: Pushing packages to RHN Server skipped for channel %s.' % (self.dist.nick, channelname))
+            return
+
+        opts = ' ' + cf.rhnpushoptions
+        opts = ' --server=%s --username=%s --password=%s' % (cf.rhnpushserver, cf.rhnpushuser, cf.rhnpushpassword) + opts
+        if op.force:
+            # opts = ' --force' + opts
+            pass
+        if op.verbose >= 4:
+           opts = ' -v -v -v -v' + opts
+        if op.dryrun:
+            opts = opts + ' --test'
+        if os.path.isdir(self.wwwdir):
+            info(2, '%s: Pushing packages to RHN Server channel %s' % (self.dist.nick, channelname))
+            ret = run('%s %s --channel=%s --dir=%s' % (cf.cmd['rhnpush'], opts, channelname, self.wwwdir))
+            if ret:
+                raise(mrepoGenerateException('%s failed with return code: %s' % (cf.cmd['rhnpush'], ret)))
+
     def repoview(self):
         "Create a repoview index"
         if not self.changed and not op.force: