100 lines
3.7 KiB
Python
100 lines
3.7 KiB
Python
import json
|
|
|
|
from osc import oscerr
|
|
from osc.core import delete_project
|
|
|
|
from osclib.select_command import SelectCommand
|
|
from osclib.request_finder import RequestFinder
|
|
|
|
class AdiCommand:
|
|
def __init__(self, api):
|
|
self.api = api
|
|
|
|
def check_adi_project(self, project):
|
|
query_project = 'adi:' + project.split(':adi:')[1]
|
|
query = {'format': 'json'}
|
|
url = self.api.makeurl(('project', 'staging_projects', self.api.project,
|
|
query_project), query=query)
|
|
info = json.load(self.api.retried_GET(url))
|
|
if len(info['building_repositories']):
|
|
print project, "still building"
|
|
return
|
|
if len(info['broken_packages']):
|
|
print "https://build.opensuse.org/project/show/{}".format(project), "has broken packages"
|
|
return
|
|
for review in info['missing_reviews']:
|
|
print project, "has at least one missing review by", review['by'], "in", review['request']
|
|
return
|
|
if len(info['untracked_requests']) or len(info['obsolete_requests']):
|
|
print project, "has inconsistent requests"
|
|
return
|
|
print project, "is ready"
|
|
for req in info['selected_requests']:
|
|
print req['id']
|
|
self.api.rm_from_prj(project, request_id=req['id'], msg='ready to accept')
|
|
delete_project(self.api.apiurl, project)
|
|
|
|
def check_adi_projects(self):
|
|
for p in self.api.get_adi_projects():
|
|
self.check_adi_project(p)
|
|
|
|
def create_new_adi(self, wanted_requests):
|
|
all_requests = self.api.get_open_requests()
|
|
|
|
non_ring_packages = []
|
|
non_ring_requests = dict()
|
|
|
|
for request in all_requests:
|
|
# Consolidate all data from request
|
|
request_id = int(request.get('id'))
|
|
if len(wanted_requests) and request_id not in wanted_requests:
|
|
continue
|
|
action = request.findall('action')
|
|
if not action:
|
|
msg = 'Request {} has no action'.format(request_id)
|
|
raise oscerr.WrongArgs(msg)
|
|
# we care only about first action
|
|
action = action[0]
|
|
|
|
# Where are we targeting the package
|
|
source_project = action.find('source').get('project')
|
|
if len(wanted_requests):
|
|
source_project = 'wanted'
|
|
target_package = action.find('target').get('package')
|
|
|
|
if not self.api.ring_packages.get(target_package):
|
|
non_ring_packages.append(target_package)
|
|
|
|
if not source_project in non_ring_requests:
|
|
non_ring_requests[source_project] = []
|
|
non_ring_requests[source_project].append(request_id)
|
|
|
|
if len(non_ring_packages):
|
|
print "Not in a ring:", ' '.join(sorted(non_ring_packages))
|
|
else:
|
|
return
|
|
|
|
for source_project, requests in non_ring_requests.items():
|
|
name = self.api.create_adi_project(None)
|
|
|
|
for request in requests:
|
|
if not self.api.rq_to_prj(request, name):
|
|
return False
|
|
|
|
# Notify everybody about the changes
|
|
self.api.update_status_comments(name, 'select')
|
|
|
|
def perform(self, packages):
|
|
"""
|
|
Perform the list command
|
|
"""
|
|
if len(packages):
|
|
requests = set()
|
|
for request, request_project in RequestFinder.find_sr(packages,
|
|
self.api).items():
|
|
requests.add(request)
|
|
self.create_new_adi(requests)
|
|
else:
|
|
self.check_adi_projects()
|
|
self.create_new_adi(())
|