#!/usr/bin/env python
#pylint: disable=line-too-long
#
#  License: GPLv3
#
#  Initial Author: Bonnie King <bonniek@fnal.gov>
#         Updates:
#                  Pat Riehecky <riehecky@fnal.gov>
#
'''Get list of repos from pagure, to grab CentOS sources'''

# for python3 compat
from __future__ import unicode_literals
from __future__ import absolute_import
from __future__ import print_function

import logging
import sys
import json
import textwrap
import time

sys.setrecursionlimit(500)

try:
    from argparse import ArgumentParser
except ImportError:  # pragma: no cover
    print("Please install argparse - rpm: python-argparse", file=sys.stderr)
    raise

try:
    import requests
except ImportError:  # pragma: no cover
    print("Please install requests - rpm: python-requests", file=sys.stderr)
    raise


def setup_args():
    '''
        Setup the argparse object.

        Make sure all fields have defaults so we could use this as an object
    '''
    parser = ArgumentParser(description=textwrap.dedent(__doc__))

    parser.add_argument('--debug', action='store_true', default=False,
                        help='Print debugging information')
    parser.add_argument('--hostname', default='git.centos.org',
                        type=str, help='What host should we query?')
    parser.add_argument('--apiver', default='0',
                        type=str, help='What api version is the host?')
    parser.add_argument('--namespace', default='rpms',
                        type=str, help='What project namespace?')
    parser.add_argument('--show-forks', action='store_true', default=False,
                        help='Should we also show project forks?')

    return parser

def run_query(hostname, api, namespace, forks):
    '''
        Actually call the API version
    '''
    list_of_urls = []
    if str(api) == '0':
        query = 'https://{hostname}/api/0/projects?per_page=50&namespace={namespace}'.format(hostname=hostname, namespace=namespace)
        if forks:
            query = query + '&forks=1'
        else:
            query = query + '&forks=0'

        fetch_prefix = 'https://{hostname}/'.format(hostname=hostname)

        fetch_next_v0(query, fetch_prefix, list_of_urls)
    else:
        raise NotImplementedError("Unknown API version %s", api)

    list_of_urls.sort()
    return list_of_urls

def fetch_next_v0(page, fetch_prefix, list_of_urls):
    '''
        Recursively fetch the page until we are done
    '''
    logging.debug('Trying to fetch %s', page)
    try:
        req = requests.get(page)
    except requests.exceptions.RequestException as err_msg:
        print(err_msg, file=sys.stderr)
        raise

    try:
        message = json.loads(req.text)
    except ValueError as err_msg:
        print(page, file=sys.stderr)
        print(req.text, file=sys.stderr)
        print(err_msg, file=sys.stderr)
        raise

    for project in message['projects']:
        list_of_urls.append(fetch_prefix + project['fullname'])

    if 'next' in message['pagination']:
        if message['pagination']['next']:
            time.sleep(0.25) # Add a smallish delay to help with load
            fetch_next_v0(message['pagination']['next'], fetch_prefix, list_of_urls)

if __name__ == '__main__':

    PARSER = setup_args()
    ARGS = PARSER.parse_args()

    if ARGS.debug:
        logging.basicConfig(level=logging.DEBUG)

    URLS = run_query(ARGS.hostname, ARGS.apiver, ARGS.namespace, ARGS.show_forks)

    for URL in URLS:
        print(URL)