#

# nosslverify

#     Specifies that the calling program should _not_ verify the certificate (if

#     the URL specified begins with https). This can be used in conjunction with

#     the self-signed certificates.

#

from urllib import quote

import subprocess

import mercurial.node

def call_program(program, arguments, url):

    """

    Calls the specified program, passing it the arguments. The URL is passed

    through stdin to the program.

    Arguments:

    program - Binary that should be called.

    arguments - Arguments that should be passed to the program.

    process = subprocess.Popen(arguments, stdin=subprocess.PIPE, stdout=subprocess.PIPE, stderr=subprocess.PIPE)

    # curl expects slightly different format when reading URL from stdin.

    if program == "curl":

        url = "url=%s" % url

    # Obtain the contents of stdout and stderr.

    stdout, stderr = process.communicate(url)

    # Return the exit code of process, and message that should be shown to user.

    return process.returncode, stdout, stderr

def extract_report(repo, context):

    """

    Extract the commit report from provided context.

    Arguments:

    repo - Mercurial repository object.

    context - Mercurial commit context for which the report should be extracted.

    files_changed_status = []

    for f in files_changed[0]:

        files_changed_status.append("U %s" % f)

    for f in files_changed[1]:

        files_changed_status.append("A %s" % f)

    for f in files_changed[2]:

        files_changed_status.append("D %s" % f)

    report['changed'] = "\n".join(files_changed_status)

    # Finally return the report.

    return report

def submit_report(commit, repo, ui, program, program_params, base_url, project_id, passkey):

    """

    Submits report to TBG for a single commit.

    Arguments:

    commit - Mercurial commit identifier.

    repo - Mercurial repository object.

    ui - Mercurial user interface object.

        # Strip out the whitespaces and newlines from the end, and make sure we

        # have a single final newline.

        stderr.rstrip()

        stderr += "\n"

        ui.warn(stderr)

    else:

        # Strip out the whitespaces and newlines from the end, and make sure we

        # have a single final newline.

        stdout.rstrip()

        stdout += "\n"

        ui.warn(stdout)

def hook(ui, repo, hooktype, node=None, url=None, **kwargs):

    """

    Commit and changegroup hook for Mercurial.

    Arguments:

    ui - Mercurial user interface object.

    repo - Mercurial repository object.

    node - Mercurial revision ID.

    url - Mercurial path/URL.

    kwargs - Additional keyword arguments.

    """

    # Read the configuration options.

    config = dict((param, value) for param, value in ui.configitems('buggenie'))

    # Make sure the required settings were specified.

        ui.warn("TBG HG Hook: No program was specified. Check your settings.\n")

        return

        ui.warn("TBG HG Hook: No base URL was specified. Check your settings.\n")

        return

        ui.warn("TBG HG Hook: No project ID was specified. Check your settings.\n")

        return

        ui.warn("TBG HG Hook: No passkey was specified. Check your settings.\n")

        return

    # Set-up parameters to be passed onto program.

    if config["program"] == "wget":

        # Use dots for progress, output to stdout, read link from stdin.

        program_params = ["--progress=dot", "-O", "-", "-i", "-"]

        if config.get("nosslverify") == "true":

            program_params.append("--no-check-certificate")

    elif config["program"] == "curl":

        # Quiet, but show errors, fail on server error, and read link from stdin.

        program_params = ["-s", "-S", "-f", "-K", "-"]

    else:

        ui.warn("TBG HG Hook: Specified program '%s' is not supported. Check your settings.\n")

        return

    # Get the node hash.

    node_hash = mercurial.node.bin(node)

    # If the hook is called as a changegroup hook, process all related commits.

    if hooktype == "changegroup":

        start = repo.changelog.rev(node_hash)

        end = len(repo.changelog)

    # If the hook is called as a commit, hook, process just the single commit.

    elif hooktype == "commit":