ttsselfhoster/ttsselfhoster.py

#!/usr/bin/env python3

def main():
    import os
    import json
    import re
    import sys
    from urllib.parse import urlparse
    p = parser()
    args = p.parse_args()
    if args.input_file == "-":
        args.input_file = "/dev/stdin"
    with open(args.input_file) as fd:
        js = json.load(fd)
    jsgen = dict_generator(js)
    url_regex = re.compile("^https?://")
    for it in jsgen:
        val = it[-1]
        if type(val)==str and url_regex.match(val):
            # print(it, file=sys.stderr)
            if args.server_dir:
                sha_f = cache_file(val, args.server_dir, force=args.no_cache)
                # print(sha_f, file=sys.stderr)
            if args.url and sha_f:
                newurl = args.url
                newurl = newurl._replace(path=os.path.join(newurl.path,"blocks", sha_f))
                dict_set(js, it[:-1], newurl.geturl())

    if args.output_file == None:
        if "SaveName" in js:
            args.output_file = os.path.join(args.server_dir, safe_name(js["SaveName"]) + ".json")
        else:
            if args.input_file[:4] == "/dev":
                args.output_file = os.path.join(args.server_dir , os.path.basename(args.input_file))
            else:
                args.output_file = "-"
    if args.output_file == "-":
        args.output_file = "/dev/stdout"
    with open(args.output_file, "w") as fd:
        json.dump(js, fd, indent=4)


def parser():
    import argparse
    from urllib.parse import urlparse
    p = argparse.ArgumentParser()
    p.add_argument("-i","--input_file", default="-")
    p.add_argument("-o","--output_file", default=None)
    p.add_argument("-s","--server_dir", default="repo")
    p.add_argument("-n","--no_cache", action="store_true")
    p.add_argument("-u","--url", type=urlparse, default=None)
    return p

def dict_set(dic , path, val):
    iter_dic = dic
    for p in path:
        last_dic = iter_dic
        iter_dic = iter_dic[p]
    last_dic[p] = val

def safe_name(fname):
    import re
    fname = fname.replace(" ","_")
    return re.sub("[^a-zA-Z0-9_]+", "", fname)


def cache_file(url, cache_dir, force=False):
    import os
    import hashlib
    import json
    import sys
    sha_url = hashlib.sha512()
    sha_url.update(url.encode())
    sha_url = sha_url.hexdigest()
    sha_dir = os.path.join(cache_dir, "sha")
    sha_file = os.path.join(sha_dir, sha_url)
    url_file = os.path.join(cache_dir, "urls.txt")

    if not os.path.isdir(sha_dir):
        os.makedirs(sha_dir)
    sha_f = None
    if force or (not os.path.isfile(sha_file)):
        sha_f = get_file(url, cache_dir, sha_file)
        if sha_f:
            with open(url_file, "w+") as fd:
                for line in fd.readlines():
                    if json.loads(line)["sha_f"] == sha_f:
                        return sha_f
                new_line = json.dumps({"url":url,"sha_f":sha_f,"sha_url":sha_url})+"\n"
                print(new_line, file=sys.stderr)
                fd.write(new_line)
        else:
            print("Download Error:", url, file=sys.stderr)
    else:
        try:
            # print("Trying Cache:", sha_file, file=sys.stderr)
            sha_f = open(sha_file).read()
        except Exception as ex:
            print(ex, file=sys.stderr)
            sha_f = None



    return sha_f

def get_file(url, cache_dir, sha_file):
    from urllib.request import urlopen
    from urllib.error import HTTPError
    import hashlib
    import sys
    import os
    import uuid
    blocks_dir = os.path.join(cache_dir,"blocks")
    if not os.path.isdir(blocks_dir):
        os.makedirs(blocks_dir)

    tmpfile = os.path.join(blocks_dir, uuid.uuid4().hex)
    sha_f = hashlib.sha512()
    try:
        with urlopen(url) as req:
            with open(tmpfile,"wb") as fd:
                BUF = True
                while BUF:
                    BUF = req.read()
                    fd.write(BUF)
                    sha_f.update(BUF)
    except HTTPError as ex:
        print(ex, file=sys.stderr)
        try:
            os.unlink(tmpfile)
            os.unlink(sha_file)
        except:
            pass
        return None
    sha_f = sha_f.hexdigest()
    cachefile = os.path.join(blocks_dir, sha_f)
    os.rename(tmpfile, cachefile)
    with open(sha_file, "w") as fd:
        fd.write(sha_f)
    return sha_f

def dict_generator(indict, pre=None):
    pre = pre[:] if pre else []
    if isinstance(indict, dict):
        for key, value in indict.items():
            if isinstance(value, dict):
                for d in dict_generator(value, pre + [key]):
                    yield d
            elif isinstance(value, list) or isinstance(value, tuple):
                i = 0
                for v in value:
                    for d in dict_generator(v, pre + [key,i]):
                        yield d
                    i += 1
            else:
                yield pre + [key, value]
    else:
        yield pre + [indict]

if __name__ == "__main__":
    main()