From 3b7eb5e7c7ac866f92d4a3a405227fa87616185f Mon Sep 17 00:00:00 2001 From: Pierre-Yves Chibon Date: May 18 2017 09:07:41 +0000 Subject: Adjust the pagure-ci service to save the push log in the DB --- diff --git a/pagure-mirror/pagure_ci_server.py b/pagure-mirror/pagure_ci_server.py index 47a09ed..6c6a73c 100644 --- a/pagure-mirror/pagure_ci_server.py +++ b/pagure-mirror/pagure_ci_server.py @@ -244,7 +244,7 @@ def setup_mirroring(project, session, dbobj): @trollius.coroutine -def mirror_project(repo, dbobj): +def mirror_project(repo, session, dbobj): ''' Does the actual mirroring of the specified project/repo. ''' plugin = pagure.lib.plugins.get_plugin('Mirroring') @@ -271,6 +271,9 @@ def mirror_project(repo, dbobj): for idx, remote in enumerate(remotes): lines = pagure.lib.git.read_git_lines( ['push', '%s_%s' % (public_key_name, idx)], abspath) + dbobj.last_log = '\n'.join(lines) + session.add(dbobj) + session.commit() if pagure.APP.config.get('HOOK_DEBUG', False): print '\n'.join(lines) @@ -359,7 +362,7 @@ def handle_messages(): topic = data.get('topic') if topic == 'pagure.mirror.postcommit': - yield trollius.From(mirror_project(repo, dbobj)) + yield trollius.From(mirror_project(repo, session, dbobj)) elif topic == 'pagure.mirror.setup': yield trollius.From(setup_mirroring(repo, session, dbobj)) elif topic == 'pagure.mirror.teardown':