compile_thrift.py

#!/usr/bin/env python2

import os
import sys
import platform

'''
the default thrift generator
'''

thrift_description = [
    {
        "name": "deploy_svc", 
        "path": "src/dist/deployment_service",
        "include_fix": {
            "_types.h": {
                "add": ["<dsn/dist/cluster_scheduler.h>"],
                "remove": ["\"dsn_types.h\"", "\"dsn.layer2_types.h\""]
            }
        }
    },
    {
        "name": "fd", 
        "path": "src/dist/failure_detector", 
        "file_move": {
            ".types.h _types.h": "include/dsn/dist/failure_detector"
        },
        "include_fix": {
            "_types.h": {
                "add": ["<dsn/service_api_cpp.h>"],
                "remove": ["\"dsn_types.h\""]
            },
            "_types.cpp": {
                "add": ["<dsn/dist/failure_detector/fd_types.h>"],
                "remove": ["\"fd_types.h\""]
            },
            ".types.h": {
                "add": ["<dsn/dist/failure_detector/fd_types.h>"],
                "remove": ["\"fd_types.h\""]
            }
        }
    }, 
    {
        "name": "replication", 
        "path": "src/dist/replication", 
        "file_move": {
            ".types.h _types.h": "include/dsn/dist/replication",
            "_types.cpp": "src/dist/replication/client_lib"
        },
        "include_fix": {
            "_types.h": {
                "add": ["<dsn/cpp/serialization_helper/dsn.layer2_types.h>"],
                "remove": ["\"dsn_types.h\"", "\"dsn.layer2_types.h\""]
            },
            "_types.cpp": {
                "add": ["<dsn/dist/replication/replication_types.h>"],
                "remove": ["\"replication_types.h\""]
            },
            ".types.h": {
                "add": ["<dsn/dist/replication/replication_types.h>"],
                "remove": ["\"replication_types.h\""]
            }
        }
    }, 
    {
        "name": "simple_kv", 
        "path": "src/dist/replication/test/simple_kv"
    }, 
    {
        "name": "echo", 
        "path": "src/apps/echo"
    }, 
    {
        "name": "nfs", 
        "path": "src/apps/nfs",
        "file_move": {
            ".types.h _types.h": "include/dsn/tool/nfs"
        },
        "include_fix": {
            "_types.h": {
                "add": ["<dsn/service_api_cpp.h>"],
                "remove": ["\"dsn_types.h\""]
            },
            "_types.cpp": {
                "add": ["<dsn/tool/nfs.h>"],
                "remove": ["\"nfs_types.h\""]
            },
            ".types.h": {
                "add": ["<dsn/tool/nfs/nfs_types.h>"],
                "remove": ["\"nfs_types.h\""]
            }
        }
    }, 
    {
        "name": "simple_kv", 
        "path": "src/apps/skv"
    }, 
    {
        "name": "cli", 
        "path": "src/apps/cli",
        "file_move": {
            ".types.h _types.h": "include/dsn/tool/cli"
        },
        "include_fix": {
            "_types.h": {
                "remove": ["\"dsn_types.h\""]
            },
            "_types.cpp": {
                "add": ["<dsn/tool/cli.h>"],
                "remove": ["\"cli_types.h\""]
            },
            ".types.h": {
                "add": ["<dsn/tool/cli/cli_types.h>"],
                "remove": ["\"cli_types.h\""]
            }
        }
    }
]

env_tools = {
    "dsn_gentool": "",
    "thrift_exe": "",
    "root_dir": ""
}

class CompileError(Exception): 
    """ Raised when dealing with thrift idl have errors"""
    def __init__(self, msg):
        self.msg = msg
    def __str__(self):
        return self.msg

def init_env():
    if platform.system() == "Windows":
        env_tools["dsn_gentool"] = os.getcwd() + "/bin/dsn.cg.bat"
        env_tools["thrift_exe"] = os.getcwd() + "/bin/Windows/thrift.exe"
    else:
        env_tools["dsn_gentool"] = os.getcwd() + "/bin/dsn.cg.sh"
        env_tools["thrift_exe"] = os.getcwd() + "/bin/Linux/thrift"
    env_tools["root_dir"] = os.getcwd()

def find_struct_define(line, enum_class_list):
    if len(line)<7 or line[0:7] != "struct ":
        return ""
    struct_name = line.strip().split()[1]
    if struct_name in enum_class_list:
        return struct_name
    return ""

def modify_struct_define(header_file, enum_class):
    tmp_result = header_file + ".swapfile"
    res_fd, src_fd = open(tmp_result, "w"), open(header_file, "r")

    in_enum_define = 0

    for line in src_fd:
        struct_name = find_struct_define(line, enum_class)
        if struct_name != "":
            res_fd.write("enum %s {\n"%(struct_name))
            in_enum_define = 1
        elif "enum type" in line and in_enum_define == 1:
            in_enum_define = 2
        elif line.strip() == "};" and in_enum_define == 2:
            in_enum_define = 1
        elif "VALUES_TO_NAMES" in line or "include \"dsn_types.h\"" in line:
            pass
        else:
            res_fd.write(line)
    
    src_fd.close()
    res_fd.close()

    os.system("rm %s"%(header_file))
    os.system("mv %s %s"%(tmp_result, header_file))

def remove_struct_impl(impl_file, enum_class):
    os.system("sed -i \'/VALUES_TO_NAMES/\'d %s"%(impl_file))

def replace_struct_usage(cpp_file, enum_class):
    sed_exp = "sed -i " + " ".join(["-e \'s/%s::type/%s/\'"%(i,i) for i in enum_class]) + " " + cpp_file
    os.system(sed_exp)

def fix_include_file(filename, fix_commands):
    tmp_result = filename + ".swapfile"
    from_fd, to_fd = open(filename, "r"), open(tmp_result, "w")

    add_ok = not "add" in fix_commands

    for line in from_fd:
        include_statement = False
        if len(line.strip())>0:
            stripped_line = line.strip()
            if stripped_line[0]=="#" and "include" in stripped_line:
                include_statement = True

        if include_statement==True and add_ok==False:
            add_includes = "\n".join(["#include %s"%(s) for s in fix_commands["add"]])
            to_fd.write(add_includes + "\n")
            add_ok = True

        if include_statement==True and ("remove" in fix_commands):
            if len(filter(lambda x: x in line, fix_commands["remove"]))==0:
                to_fd.write(line)
        else:
            to_fd.write(line)

    from_fd.close()
    to_fd.close()

    os.remove(filename)
    os.rename(tmp_result, filename)

def fix_include(thrift_name, include_fix_dict):
    # current dir is thrift file dir
    os.chdir("output")

    for pair in include_fix_dict.iteritems():
        filename = thrift_name + pair[0]
        fix_include_file(filename, pair[1])

    os.chdir("..")

def toggle_serialization_in_cpp(thrift_name):
    # current dir is thrift file dir
    os.chdir("output")
    cpp_file = thrift_name + "_types.cpp"
    new_file = cpp_file + ".swapfile"

    os.system("pwd")
    os.system("echo \"#ifdef DSN_USE_THRIFT_SERIALIZATION\" > %s"%(new_file) )
    os.system("cat %s >> %s"%(cpp_file, new_file))
    os.system("echo \"#endif\" >> %s"%(new_file) )

    os.remove(cpp_file)
    os.rename(new_file, cpp_file)
    os.chdir("..")

def compile_thrift_file(thrift_info):
    thrift_name = thrift_info["name"]
    print ">>>compiling thrift file %s.thrift ..."%(thrift_name)

    if "path" not in thrift_info:
        raise CompileError("can't find thrift file")

    os.chdir( env_tools["root_dir"] + "/" + thrift_info["path"])
    if os.path.isfile(thrift_name+".thrift") == False:
        raise CompileError("can't find thrift file")

    ## generate the files
    os.system("rm -rf output")
    os.system("mkdir output")
    #### first generate .types.h
    os.system("%s %s.thrift cpp build binary"%(env_tools["dsn_gentool"], thrift_name))

    os.system("cp build/%s.types.h output"%(thrift_name))
    os.system("cp build/%s_types.h output"%(thrift_name))
    os.system("cp build/%s_types.cpp output"%(thrift_name))
    os.system("rm -rf build")

    if "include_fix" in thrift_info:
        fix_include(thrift_name, thrift_info["include_fix"])

    if "hook" in thrift_info:
        os.chdir("output")
        for hook_func, args in thrift_info["hook"]:
            hook_func(args)
        os.chdir("..")

    if "file_move" in thrift_info:
        for pair in thrift_info["file_move"].iteritems():
            dest_path = env_tools["root_dir"] + "/" + pair[1]
            for postfix in pair[0].split():
                src_path = "output/%s%s"%(thrift_name, postfix)
                cmd = "mv %s %s"%(src_path, dest_path)
                os.system(cmd)

    if len(os.listdir("output"))>0:
        os.system("mv output/* ./")
    os.system("rm -rf output")

    os.chdir( env_tools["root_dir"] )

def find_desc_from_path(path):
    ans = []
    for i in thrift_description:
        if i["path"] == path:
            ans.append(i)
    return ans

# special hooks for thrift, all these are executed in the output dir
def constructor_hook(args):
    generated_fname = args[0]
    class_name = args[1]
    add_code = args[2]

    target_fname = generated_fname + ".swapfile"
    src_fd, dst_fd = open(generated_fname, "r"), open(target_fname, "w")

    in_class = 0
    for line in src_fd:
        if in_class == 1:
            if "public:" in line:
                line = line + add_code + "\n"
            elif "bool operator <" in line:
                line = ""
            # this may not be right
            elif line.startswith("};"):
                in_class = 2
        elif in_class == 0 and line.startswith("class " + class_name + " {"):
            in_class = 1
        dst_fd.write(line)

    src_fd.close()
    dst_fd.close()

    os.remove(generated_fname)
    os.rename(target_fname, generated_fname)

def remove_all_enums_define_hook(args):
    generated_fname = args[0]
    target_fname = generated_fname + ".swapfile"
    src_fd, dst_fd = open(generated_fname, "r"), open(target_fname, "w")

    in_enums = False
    for line in src_fd:
        if in_enums:
            if line.strip().startswith("};"):
                in_enums = False
            line = ""
        else:
            tokens = line.strip().split()
            if len(tokens)>1 and tokens[0]=="enum":
                in_enums = True
                line = ""
        dst_fd.write(line)

    src_fd.close()
    dst_fd.close()

    os.remove(generated_fname)
    os.rename(target_fname, generated_fname)

def remove_struct_define_hook(args):
    generated_fname = args[0]
    struct_defines = ["struct "+name+" {" for name in args[1:]]

    target_fname = generated_fname + ".swapfile"
    src_fd, dst_fd = open(generated_fname, "r"), open(target_fname, "w")

    in_class = 0
    for line in src_fd:
        if in_class==0 and line.strip() in struct_defines:
            in_class = 1
        if in_class==0:
            dst_fd.write(line)
        if in_class==1 and line.startswith("};"):
            in_class = 0

    src_fd.close()
    dst_fd.close()
    
    os.remove(generated_fname)
    os.rename(target_fname, generated_fname)

def add_hook(name, path, func, args):
    for i in thrift_description:
        if name == i["name"] and path == i["path"]:
            if "hook" not in i:
                i["hook"] = [(func, args)]
            else:
                i["hook"].append((func, args))

if __name__ == "__main__":
    init_env()

    ctor_kv_pair = "  kv_pair(const std::string& _key, const std::string& _val): key(_key), value(_val) {\n  }"
    ctor_configuration_proposal_action = "  configuration_proposal_action(::dsn::rpc_address t, ::dsn::rpc_address n, config_type::type tp): target(t), node(n), type(tp) {}"
    add_hook("deploy_svc", "src/dist/deployment_service", remove_struct_define_hook, ["deploy_svc_types.h", "cluster_type", "service_status"])
    add_hook("simple_kv", "src/apps/skv", constructor_hook, ["simple_kv_types.h", "kv_pair", ctor_kv_pair])
    add_hook("replication", "src/dist/replication", constructor_hook, ["replication_types.h", "configuration_proposal_action", ctor_configuration_proposal_action])

    if len(sys.argv)>1:
        for i in sys.argv[1:]:
            for desc in find_desc_from_path(i):
                compile_thrift_file(desc)
    else:
        for i in thrift_description:
            compile_thrift_file(i)