import json

from osc import oscerr
from osc.core import delete_project
from osc.core import show_package_meta
        
from osclib.select_command import SelectCommand
from osclib.request_finder import RequestFinder
from xml.etree import cElementTree as ET

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 get_devel_project(self, project, package):
        m = show_package_meta(self.api.apiurl, project, package)
        node = ET.fromstring(''.join(m)).find('devel')
        if node is None:
            return None
        else:
            return node.get('project')

    def create_new_adi(self, wanted_requests, by_dp=False):
        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
            if len(wanted_requests):
                source_project = 'wanted'
            else:
                source = action.find('source')
                if source is not None:
                    source_project = source.get('project')
                else:
                    source_project = 'none'

            # do not process the rest request type than submit
            if action.get('type') != 'submit':
                continue

            target_package = action.find('target').get('package')
            source_package = action.find('source').get('package')

            if not self.api.ring_packages.get(target_package):
                non_ring_packages.append(target_package)
                if by_dp is True:
                    devel_project = self.get_devel_project(source_project, source_package)
                    if devel_project is not None:
                        source_project = devel_project

                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, move=False, by_dp=False):
        """
        Perform the list command
        """
        if len(packages):
            requests = set()
            if move:
                items = RequestFinder.find_staged_sr(packages, self.api).items()
                print items
                for request, request_project in items:
                    staging_project = request_project['staging']
                    self.api.rm_from_prj(staging_project, request_id=request)
                    self.api.add_review(request, by_group=self.api.cstaging_group, msg='Please recheck')
            else:
                items = RequestFinder.find_sr(packages, self.api).items()

            for request, request_project in items:
                requests.add(request)
            self.create_new_adi(requests)
        else:
            self.check_adi_projects() 
            if self.api.is_user_member_of(self.api.user, 'factory-staging'):
                self.create_new_adi((), by_dp)