[get_versions] add get_versions participant

Signed-off-by: David Greaves <david.greaves@jolla.com>

Author: lbt

conf/supervisor/get_versions.conf

@@ -0,0 +1,22 @@
+[program:get_userdata]
+command = /usr/bin/skynet_exo /etc/supervisor/conf.d/get_versions.conf
+process_name = %(program_name)s_%(process_num)s
+numprocs = 1
+user = bossmaintainer
+umask = 022
+autostart = true
+autorestart = true
+startsecs = 5
+startretries = 100
+stopwaitsecs = 10
+redirect_stderr = true
+stdout_logfile = /var/log/supervisor/%(program_name)s_%(process_num)s.log
+stderr_logfile = off
+environment = PYTHONUNBUFFERED=1,HOME="/home/bossmaintainer",USER="bossmaintainer"
+
+[participant]
+name = get_versions
+queue = get_versions
+regexp = get_versions
+code = /usr/share/boss-skynet/get_versions.py
+

participants/get_versions.py

@@ -0,0 +1,44 @@
+from rpmUtils.miscutils import splitFilename
+from boss.obs import BuildServiceParticipant, RepositoryMixin
+
+
+class ParticipantHandler(BuildServiceParticipant, RepositoryMixin):
+    """Participant class as defined in SkyNET API."""
+
+    def __init__(self):
+        """Initializator."""
+
+        BuildServiceParticipant.__init__(self)
+
+    def handle_wi_control(self, ctrl):
+        """Control job thread."""
+        pass
+
+    @BuildServiceParticipant.get_oscrc
+    def handle_lifecycle_control(self, ctrl):
+        """Control participant thread."""
+        pass
+
+    @BuildServiceParticipant.setup_obs
+    def handle_wi(self, wid):
+        """Handle workitem."""
+        if not wid.fields.versions:
+            return
+        versions = wid.fields.versions.as_dict()
+        for pkg, d in versions.items():
+            target = "%s/%s" % (d["repository"], d["arch"])
+
+            for binary in self.obs.getBinaryList(d["project"], target, pkg):
+                n, v, r, e, a = splitFilename(binary)
+                if n != d.get("binary", pkg):
+                    continue
+                bininfo = self.obs.getBinaryInfo(d["project"],
+                                                 target, pkg, binary)
+                versions[pkg].update({"version": v,
+                                      "release": r.split("."),
+                                      "epoch": e,
+                                      "arch": a,
+                                      "summary": bininfo["summary"],
+                                      "description": bininfo["description"]})
+
+        wid.fields.versions = versions

rpm/boss-standard-workflow.spec

@@ -414,6 +414,7 @@ if [ $1 -ge 1 ] ; then
         setup_build_trial
         remove_build_trial
         get_build_results
+        get_versions
         trigger_broken"
         skynet reload $PARTS || true
 fi
@@ -424,6 +425,7 @@ fi
 %{_datadir}/boss-skynet/do_revert_trial.py
 %{_datadir}/boss-skynet/get_build_trial_results.py
 %{_datadir}/boss-skynet/get_build_results.py
+%{_datadir}/boss-skynet/get_versions.py
 %{_datadir}/boss-skynet/trigger_broken.py
 %{_datadir}/boss-skynet/is_repo_published.py
 %{_datadir}/boss-skynet/setup_build_trial.py
@@ -432,6 +434,7 @@ fi
 %config(noreplace) %{svdir}/do_revert_trial.conf
 %config(noreplace) %{svdir}/get_build_trial_results.conf
 %config(noreplace) %{svdir}/get_build_results.conf
+%config(noreplace) %{svdir}/get_versions.conf
 %config(noreplace) %{svdir}/trigger_broken.conf
 %config(noreplace) %{svdir}/is_repo_published.conf
 %config(noreplace) %{svdir}/setup_build_trial.conf