import time


def url_dir(request):
    return u'/'.join(request.url_parts.path.split(u'/')[:-1]) + u'/'


def stash_write(request, key, value):
    """Write to the stash, overwriting any previous value"""
    request.server.stash.take(key, url_dir(request))
    request.server.stash.put(key, value, url_dir(request))


def main(request, response):
    stateKey = request.GET.first(b"stateKey", b"")
    abortKey = request.GET.first(b"abortKey", b"")

    if stateKey:
        stash_write(request, stateKey, 'open')

    response.headers.set(b"Content-type", b"text/plain")
    response.write_status_headers()

    # Writing an initial 2k so browsers realise it's there. *shrug*
    response.writer.write(b"." * 2048)

    while True:
        if not response.writer.write(b"."):
            break
        if abortKey and request.server.stash.take(abortKey, url_dir(request)):
            break
        time.sleep(0.01)

    if stateKey:
        stash_write(request, stateKey, 'closed')