#!/usr/bin/python

import sys
sys.path = ["/usr/share/abrt-retrace"] + sys.path

from retrace import *
from tempfile import *

def application(environ, start_response):
    request = Request(environ)

    if request.scheme != "https":
        return response(start_response, "403 Forbidden", "You must use HTTPS.")

    if len(get_active_tasks()) >= CONFIG["MaxParallelTasks"]:
        return response(start_response, "503 Service Unavailable")

    if request.method != "POST":
        return response(start_response, "405 Method Not Allowed")

    if not request.content_type in HANDLE_ARCHIVE.keys():
        return response(start_response, "415 Unsupported Media Type")

    if not request.content_length:
        return response(start_response, "411 Length Required")

    if request.content_length > CONFIG["MaxPackedSize"] * 1048576:
        return response(start_response, "413 Request Entity Too Large")

    if CONFIG["UseWorkDir"]:
        workdir = CONFIG["WorkDir"]
    else:
        workdir = CONFIG["SaveDir"]

    if not os.path.isdir(workdir):
        try:
            os.makedirs(workdir)
        except:
            return response(start_response, "500 Internal Server Error", "Unable to create working directory")

    space = free_space(workdir)

    if not space:
        return response(start_response, "500 Internal Server Error", "Unable to obtain disk free space")

    if space - request.content_length < CONFIG["MinStorageLeft"] * 1048576:
        return response(start_response, "507 Insufficient Storage")

    try:
        archive = NamedTemporaryFile(mode="wb", delete=False, suffix=".tar.xz")
        archive.write(request.body)
        archive.close()
    except:
        return response(start_response, "500 Internal Server Error", "Unable to save archive")

    size = unpacked_size(archive.name, request.content_type)
    if not size:
        os.unlink(archive.name)
        return response(start_response, "500 Internal Server Error", "Unable to obtain unpacked size")

    if size > CONFIG["MaxUnpackedSize"] * 1048576:
        os.unlink(archive.name)
        return response(start_response, "413 Request Entity Too Large")

    if space - size < CONFIG["MinStorageLeft"] * 1048576:
        os.unlink(archive.name)
        return response(start_response, "507 Insufficient Storage")

    taskid, taskpass, taskdir = new_task()
    if not taskid or not taskpass or not taskdir:
        return response(start_response, "500 Internal Server Error", "Unable to create new task")

    try:
        os.mkdir("%s/crash/" % taskdir)
        os.chdir("%s/crash/" % taskdir)
        unpack_retcode = unpack(archive.name, request.content_type)
        os.unlink(archive.name)

        if unpack_retcode != 0:
            raise Exception
    except:
        os.chdir("/")
        Popen(["rm", "-rf", taskdir])
        return response(start_response, "500 Internal Server Error", "Unable to unpack archive")

    files = os.listdir(".")

    for required_file in REQUIRED_FILES:
        if not required_file in files:
            os.chdir("/")
            Popen(["rm", "-rf", taskdir])
            return response(start_response, "403 Forbidden", "Required file \"{0}\" is missing".format(required_file))

    Popen(["/usr/sbin/abrt-retrace-worker", "%d" % taskid])

    return response(start_response, "201 Created", "", [("X-Task-Id", "%d" % taskid), ("X-Task-Password", taskpass)])