<reponame>baajur/Anakin
#! /usr/bin/env python
# -*- coding: utf-8 -*-

from utils.net.net_io import NetProtoIO

class NetHolder(object):
    """
    Net holder.
    """
    def __init__(self, config):
        """
        Init the net holder.
        """
        assert 'NET' in config.DebugConfig.keys()
        self.config = config.DebugConfig['NET']
        self.load_list = self.config['LoadPaths']
        self.save_format = self.config['SaveFormat']
        self.net_merged = NetProtoIO()
        self.net_ins = dict()
        self.load()

    def __str__(self):
        """
        Help you by printing the object.
        """
        return self.net_merged.net_proto.__str__()

    def parse(self):
        """
        Parse the net.
        """
        for path in self.net_ins.keys():
            net_io = self.net_ins[path]
            node_parser = NetParser(net_io, self.config)
            node_parser.net_reset_nodes()
            self.net_merged.merge_from_io(net_io)
        parser = NetParser(self.net_merged, self.config)
        parser.nets_slice()
        parser.save_funcs()

    def load(self):
        """
        Load the net.
        """
        for path in self.load_list:
            assert path not in self.net_ins.keys()
            net_io = NetProtoIO()
            net_io.parse_from_string(path)
            self.net_ins[path] = net_io

    def __call__(self):
        """
        Return the net.
        """
        return self.net_merged


class NetParser(object):
    """
    Net parser object.
    """
    def __init__(self, net_io, config):
        # reset node in funcs
        self.config = config
        self.net_io_in = net_io
        self.graph_io = self.net_io_in.graph_io()
        self.func_io_list = self.net_io_in.func_io_list()
        # funcs slice
        self.nets_io_out = list()
        self.funcs = dict()
        self.save_path = self.config['SavePath']

    def _clear_graph(self):
        """
        Clear the graph.
        """
        self.net_io_in.clear_graph()

    def _funcs_dict(self):
        """
        The dict of funcs.
        """
        for func_io in self.func_io_list:
            func_type = func_io.get_type()
            if func_type not in self.funcs.keys():
                self.funcs[func_type] = list()
            self.funcs[func_type].append(func_io)

    def net_reset_nodes(self):
        """
        Reset the nodes of net.
        """
        for func_io in self.func_io_list:
            func_name = func_io.get_name()
            node_io = self.graph_io.get_node_io(func_name)
            func_io.reset_node_io(node_io)
        self._clear_graph()
        return self.net_io_in

    def nets_slice(self):
        """
        Slice the nets.
        """
        self.nets_io_out = list()
        self._funcs_dict()
        for func_type in self.funcs.keys():
            net = NetProtoIO()
            net.set_name(func_type)
            funcs_list = self.funcs[func_type]
            for func in funcs_list:
                net.add_func(func())
            self.nets_io_out.append(net)
        return self.nets_io_out

    def save_funcs(self):
        """
        Save funcs.
        """
        for net_io_out in self.nets_io_out:
            net_io_out.save(self.save_path)


#! /usr/bin/env python
# -*- coding: utf-8 -*-

from utils.net.net_io import NetProtoIO

class NetHolder(object):
    """
    Net holder.
    """
    def __init__(self, config):
        """
        Init the net holder.
        """
        assert 'NET' in config.DebugConfig.keys()
        self.config = config.DebugConfig['NET']
        self.load_list = self.config['LoadPaths']
        self.save_format = self.config['SaveFormat']
        self.net_merged = NetProtoIO()
        self.net_ins = dict()
        self.load()

    def __str__(self):
        """
        Help you by printing the object.
        """
        return self.net_merged.net_proto.__str__()

    def parse(self):
        """
        Parse the net.
        """
        for path in self.net_ins.keys():
            net_io = self.net_ins[path]
            node_parser = NetParser(net_io, self.config)
            node_parser.net_reset_nodes()
            self.net_merged.merge_from_io(net_io)
        parser = NetParser(self.net_merged, self.config)
        parser.nets_slice()
        parser.save_funcs()

    def load(self):
        """
        Load the net.
        """
        for path in self.load_list:
            assert path not in self.net_ins.keys()
            net_io = NetProtoIO()
            net_io.parse_from_string(path)
            self.net_ins[path] = net_io

    def __call__(self):
        """
        Return the net.
        """
        return self.net_merged


class NetParser(object):
    """
    Net parser object.
    """
    def __init__(self, net_io, config):
        # reset node in funcs
        self.config = config
        self.net_io_in = net_io
        self.graph_io = self.net_io_in.graph_io()
        self.func_io_list = self.net_io_in.func_io_list()
        # funcs slice
        self.nets_io_out = list()
        self.funcs = dict()
        self.save_path = self.config['SavePath']

    def _clear_graph(self):
        """
        Clear the graph.
        """
        self.net_io_in.clear_graph()

    def _funcs_dict(self):
        """
        The dict of funcs.
        """
        for func_io in self.func_io_list:
            func_type = func_io.get_type()
            if func_type not in self.funcs.keys():
                self.funcs[func_type] = list()
            self.funcs[func_type].append(func_io)

    def net_reset_nodes(self):
        """
        Reset the nodes of net.
        """
        for func_io in self.func_io_list:
            func_name = func_io.get_name()
            node_io = self.graph_io.get_node_io(func_name)
            func_io.reset_node_io(node_io)
        self._clear_graph()
        return self.net_io_in

    def nets_slice(self):
        """
        Slice the nets.
        """
        self.nets_io_out = list()
        self._funcs_dict()
        for func_type in self.funcs.keys():
            net = NetProtoIO()
            net.set_name(func_type)
            funcs_list = self.funcs[func_type]
            for func in funcs_list:
                net.add_func(func())
            self.nets_io_out.append(net)
        return self.nets_io_out

    def save_funcs(self):
        """
        Save funcs.
        """
        for net_io_out in self.nets_io_out:
            net_io_out.save(self.save_path)
#! /usr/bin/env python # -*- coding: utf-8 -*- Net holder. Init the net holder. Help you by printing the object. Parse the net. Load the net. Return the net. Net parser object. # reset node in funcs # funcs slice Clear the graph. The dict of funcs. Reset the nodes of net. Slice the nets. Save funcs.