FateWithShellmiaoComment/Fate/python/federatedml/protobuf/model_migrate/converter/tree_model_converter.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-
#
#  Copyright 2019 The FATE Authors. All Rights Reserved.
#
#  Licensed under the Apache License, Version 2.0 (the "License");
#  you may not use this file except in compliance with the License.
#  You may obtain a copy of the License at
#
#      http://www.apache.org/licenses/LICENSE-2.0
#
#  Unless required by applicable law or agreed to in writing, software
#  distributed under the License is distributed on an "AS IS" BASIS,
#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
#  See the License for the specific language governing permissions and
#  limitations under the License.


from typing import Dict
from federatedml.util import consts
from federatedml.protobuf.generated.boosting_tree_model_meta_pb2 import BoostingTreeModelMeta
from federatedml.protobuf.generated.boosting_tree_model_param_pb2 import BoostingTreeModelParam
from federatedml.protobuf.model_migrate.converter.converter_base import AutoReplace
from federatedml.protobuf.model_migrate.converter.converter_base import ProtoConverterBase


class HeteroSBTConverter(ProtoConverterBase):

    def convert(self, param: BoostingTreeModelParam, meta: BoostingTreeModelMeta,
                guest_id_mapping: Dict,
                host_id_mapping: Dict,
                arbiter_id_mapping: Dict,
                tree_plan_delimiter='_'
                ):

        feat_importance_list = list(param.feature_importances)
        fid_feature_mapping = dict(param.feature_name_fid_mapping)
        feature_fid_mapping = {v: k for k, v in fid_feature_mapping.items()}
        tree_list = list(param.trees_)
        tree_plan = list(param.tree_plan)
        replacer = AutoReplace(guest_id_mapping, host_id_mapping, arbiter_id_mapping)

        # fp == feature importance
        for fp in feat_importance_list:
            fp.sitename = replacer.replace(fp.sitename)
            if fp.fullname not in feature_fid_mapping:
                fp.fullname = replacer.migrate_anonymous_header(fp.fullname)

        for tree in tree_list:
            tree_nodes = list(tree.tree_)
            for node in tree_nodes:
                node.sitename = replacer.replace(node.sitename)

        new_tree_plan = []
        for str_tuple in tree_plan:
            param.tree_plan.remove(str_tuple)
            tree_mode, party_id = str_tuple.split(tree_plan_delimiter)
            if int(party_id) != -1:
                new_party_id = replacer.plain_replace(party_id, role=consts.HOST)
            else:
                new_party_id = party_id
            new_tree_plan.append(tree_mode + tree_plan_delimiter + new_party_id)
        param.tree_plan.extend(new_tree_plan)

        return param, meta