121 lines
5.1 KiB
Python
121 lines
5.1 KiB
Python
# Copyright (C) 2015 SUSE Linux Products GmbH
|
|
#
|
|
# This program is free software; you can redistribute it and/or modify
|
|
# it under the terms of the GNU General Public License as published by
|
|
# the Free Software Foundation; either version 2 of the License, or
|
|
# (at your option) any later version.
|
|
#
|
|
# This program is distributed in the hope that it will be useful,
|
|
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
# GNU General Public License for more details.
|
|
#
|
|
# You should have received a copy of the GNU General Public License along
|
|
# with this program; if not, write to the Free Software Foundation, Inc.,
|
|
# 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
|
|
|
|
from osc import cmdln
|
|
import osc.core
|
|
|
|
|
|
@cmdln.option('--push', action='store_true',
|
|
help="Push changed packages to their parents")
|
|
@cmdln.option('-m', "--message",
|
|
help='Specify submit message')
|
|
def do_pcheck(self, subcmd, opts, project):
|
|
"""${cmd_name}: Show changed packages (packages that have a diff)
|
|
|
|
Examples:
|
|
osc pcheck <prj> # shows changed packages etc. for <prj>
|
|
|
|
--push Create submit requests for packages with a diff (if none exists yet)
|
|
-m Specify submit message (defaut: "Scripted push of project <prj>")
|
|
|
|
"""
|
|
apiurl = self.get_api_url()
|
|
sinfos = osc.core.get_project_sourceinfo(apiurl, project, True)
|
|
todo = {}
|
|
errors = {}
|
|
md5s = {}
|
|
pmap = {}
|
|
changed = []
|
|
changeSRed = {}
|
|
api = oscapi(apiurl)
|
|
for pkg, sinfo in sinfos.items():
|
|
if sinfo.find('error'):
|
|
errors[pkg] = sinfo.find('error').text
|
|
continue
|
|
elif sinfo.find('originpackage') is not None:
|
|
# This is a package created from a _multibuild
|
|
# Status will be checked by the main one (which
|
|
# has no originpackage.) so let's not continue further
|
|
continue
|
|
elif sinfo.find('linked') is not None:
|
|
elm = sinfo.find('linked')
|
|
key = '%s/%s' % (elm.get('project'), elm.get('package'))
|
|
pmap.setdefault(key, []).append(pkg)
|
|
todo.setdefault(elm.get('project'), []).append(elm.get('package'))
|
|
md5s[pkg] = sinfo.get('verifymd5')
|
|
for prj, pkgs in todo.items():
|
|
sinfos = osc.core.get_project_sourceinfo(apiurl, prj, True, *pkgs)
|
|
for pkg, sinfo in sinfos.items():
|
|
key = '%s/%s' % (prj, pkg)
|
|
for p in pmap[key]:
|
|
vmd5 = md5s.pop(p)
|
|
if vmd5 == sinfo.get('verifymd5'):
|
|
continue
|
|
# Is there already an SR outgoing for this package?
|
|
SRid = int(api.sr_for_package(project, p))
|
|
if SRid > 0:
|
|
changeSRed[p] = SRid
|
|
else:
|
|
changed.append(p)
|
|
if opts.push:
|
|
if opts.message:
|
|
message = opts.message
|
|
else:
|
|
message = "Scripted push from {project}".format(project=project)
|
|
api.create(project=project, package=p, target=prj, message=message)
|
|
|
|
overview = 'Overview of project {}'.format(project)
|
|
print()
|
|
print(overview)
|
|
print('=' * len(overview))
|
|
print('Changed & unsubmitted packages: %d' % len(changed))
|
|
print(', '.join(changed))
|
|
print()
|
|
print('Changed & submitted packages: %d' % len(changeSRed.keys()))
|
|
print(', '.join(['%s(%s)' % (pkg, SR) for pkg, SR in changeSRed.items()]))
|
|
print()
|
|
print('Packages without link: %d' % len(md5s.keys()))
|
|
print(', '.join(md5s.keys()))
|
|
print()
|
|
print('Packages with errors: %d' % len(errors.keys()))
|
|
print('\n'.join(['%s: %s' % (p, err) for p, err in errors.items()]))
|
|
|
|
|
|
class oscapi:
|
|
def __init__(self, apiurl):
|
|
self.apiurl = apiurl
|
|
|
|
def sr_for_package(self, project, package):
|
|
query = "(state/@name='new' or state/@name='review') and " \
|
|
"(action/source/@project='{project}' or submit/source/@project='{project}') and " \
|
|
"(action/source/@package='{package}' or submit/source/@package='Packafe')".format(project=project, package=package)
|
|
result = osc.core.search(self.apiurl, request=query)
|
|
collection = result['request']
|
|
for root in collection.findall('request'):
|
|
return root.get('id')
|
|
return 0
|
|
|
|
def create(self, project, package, target, message):
|
|
currev = osc.core.get_source_rev(self.apiurl, project, package)['rev']
|
|
print("Creating a request from {project}/{package}".format(project=project, package=package))
|
|
query = {'cmd': 'create'}
|
|
url = osc.core.makeurl(self.apiurl, ['request'], query=query)
|
|
|
|
data = '<request type="submit"><submit><source project="{project}" package="{package}" rev="{rev}"/>' \
|
|
'<target project="{target}" package="{package}"/></submit><state name="new"/><description>{message}</description>' \
|
|
'</request>'.format(project=project, package=package, target=target, rev=currev, message=message)
|
|
osc.core.http_POST(url, data=data)
|