register spdz connected endpoint info 2 gateway (#112)

* register spdz connected endpoint info 2 gateway

* fix agency id not load bug

Author: ywy2090

cpp/ppc-framework/protocol/Constant.h

@@ -26,5 +26,6 @@ namespace ppc::protocol
 {
 const static std::string PSI_SERVICE_TYPE = "PSI";
 const static std::string MPC_SERVICE_TYPE = "MPC";
+const static std::string SPDZ_SERVICE_TYPE = "SPDZ";
 const static size_t LARGE_MSG_THRESHOLD = 30 * 1024 * 1024;
 }  // namespace ppc::protocol

cpp/wedpr-helper/ppc-tools/src/config/MPCConfig.h

@@ -30,5 +30,8 @@ struct MPCConfig
     std::string mpcRootPathNoGateway;
     uint64_t readPerBatchLines;
     int threadPoolSize;
+
+    std::string spdzConnectedIP;
+    int spdzConnectedPort;
 };
 }  // namespace ppc::tools

cpp/wedpr-helper/ppc-tools/src/config/PPCConfig.cpp

@@ -653,10 +653,24 @@ void PPCConfig::loadCEMConfig(boost::property_tree::ptree const& _pt)
 
 void PPCConfig::loadMPCConfig(boost::property_tree::ptree const& _pt)
 {
+    // the agencyID
+    m_agencyID = _pt.get<std::string>("agency.id", "");
+    if (m_agencyID.empty())
+    {
+        BOOST_THROW_EXCEPTION(InvalidConfig() << errinfo_comment("Must set agency.id"));
+    }
+
+    PPCConfig_LOG(INFO) << LOG_DESC("load agency id") << LOG_KV("agencyID", m_agencyID);
+
     m_mpcConfig.jobPath = _pt.get<std::string>("mpc.job_path", "./");
     m_mpcConfig.mpcRootPath = _pt.get<std::string>("mpc.mpc_root_path", "./");
     m_mpcConfig.mpcRootPathNoGateway = _pt.get<std::string>("mpc.mpc_root_path_no_gateway", "./");
     m_mpcConfig.readPerBatchLines = _pt.get<std::uint64_t>("mpc.read_per_batch_lines", 100000);
+    m_mpcConfig.spdzConnectedPort = _pt.get<int>("spdz.connected_port", 5894);
+    m_mpcConfig.spdzConnectedIP = _pt.get<std::string>("transport.host_ip", "");
+    
+    PPCConfig_LOG(INFO) << LOG_DESC("spdzConnectedPort") << LOG_KV("spdzConnectedIP", m_mpcConfig.spdzConnectedIP) << LOG_KV("spdzConnectedPort", m_mpcConfig.spdzConnectedPort);
+
     m_mpcConfig.threadPoolSize = _pt.get<int>("mpc.async_thread_pool_size", -1);
     if (m_mpcConfig.threadPoolSize < 0)
     {

cpp/wedpr-helper/ppc-tools/src/config/PPCConfig.h

@@ -249,6 +249,11 @@ class PPCConfig
         return m_frontConfig->selfEndPoint().host() + ":" + std::to_string(m_rpcConfig.listenPort);
     }
 
+    std::string spdzConnectedEndPoint() const // for mpc
+    {
+        return m_mpcConfig.spdzConnectedIP + ":" + std::to_string(m_mpcConfig.spdzConnectedPort);
+    }
+
     // load the front config
     virtual void loadFrontConfig(bool requireTransport,
         ppc::front::FrontConfigBuilder::Ptr const& frontConfigBuilder,

cpp/wedpr-main/mpc-node/MPCInitializer.cpp

@@ -90,10 +90,16 @@ void MPCInitializer::initTransport(boost::property_tree::ptree const& property)
 
     // add the service meta
     ServiceConfigBuilder serviceConfigBuilder;
-    auto entryPoint = serviceConfigBuilder.buildEntryPoint(
-        getServiceName(m_config->agencyID(), MPC_SERVICE_TYPE), m_config->accessEntrypoint());
     auto serviceConfig = serviceConfigBuilder.buildServiceConfig();
-    serviceConfig.addEntryPoint(entryPoint);
+    
+    auto mpcEntryPoint =
+    serviceConfigBuilder.buildEntryPoint(getServiceName(m_config->agencyID(), MPC_SERVICE_TYPE), m_config->accessEntrypoint());
+    serviceConfig.addEntryPoint(mpcEntryPoint);
+
+    auto spdzEntryPoint =
+    serviceConfigBuilder.buildEntryPoint(getServiceName(m_config->agencyID(), SPDZ_SERVICE_TYPE), m_config->spdzConnectedEndPoint());
+    serviceConfig.addEntryPoint(spdzEntryPoint);
+
     auto serviceMeta = serviceConfig.encode();
     m_config->frontConfig()->setMeta(serviceMeta);
     INIT_LOG(INFO) << LOG_DESC("initTransport: register serviceMeta")