Config

def initiate(
    self,
    root: Optional[str] = None,
    alias: Optional[str] = DEFAULT_NODE_ALIAS,
) -> NodeConfig:
    """Initiates the Node component

    Args:
        root (str, optional): Root directory for the component. If None, uses the default.
        alias (str, optional): Alias for the component, used to identify the component in the configuration.

    Returns:
        NodeConfig: The configuration object for the Node component.
    """
    config = super().initiate(root=root, alias=alias)
    config.write()
    node_data_path = os.path.join(config.root, NODE_DATA_FOLDER)
    os.makedirs(node_data_path, exist_ok=True)
    node_dynamic_data_path = os.path.join(config.root, NODE_DYNAMIC_DATA_FOLDER)
    os.makedirs(node_dynamic_data_path, exist_ok=True)
    return config

def add_parameters(self):
    """Generate `Node` config"""

    self._cfg["default"]["name"] = self._component_alias

    # Security variables
    self._cfg[NODE_CONFIG_SECURITY_SECTION] = {
        key: os.getenv(field.get("env", ""), str(field["default"]))
        for key, field in NODE_CONFIG_SECURITY_FIELDS.items()
    }
    # Generate self-signed certificates
    key_file, pem_file = generate_certificate(
        root=self.root,
        component_id=self._cfg["default"]["id"],
        prefix=DEFAULT_CERT_NAME,
    )

    self._cfg["certificate"] = {
        "private_key": os.path.relpath(key_file, os.path.join(self.root, "etc")),
        "public_key": os.path.relpath(pem_file, os.path.join(self.root, "etc")),
    }

    # gRPC server host and port
    self._cfg["researcher"] = {
        "ip": os.getenv("FBM_RESEARCHER_IP", "localhost"),
        "port": os.getenv("FBM_RESEARCHER_PORT", "50051"),
    }

def migrate(self):
    """Please add migrated parameters for the new version.

    See [`Config.migrate`][fedbiomed.common.config.Config.migrate] for more information
    """
    if not self._cfg.has_option("default", "name"):
        logger.warning(
            "DEPRECATION: You are using an old configuration file for the node. "
            "Please add 'name' value in `default` section "
            "of the node configuration to define a name."
        )

        self._cfg["default"].update({"name": "Migrated Node Name"})

    if not self._cfg.has_option("security", "allow_preproc"):
        logger.warning(
            "DEPRECATION: You are using an old configuration file for the node. "
            "Please add 'allow_preproc' value in `security` section "
            "of the node configuration to define whether preprocessing is allowed."
        )

        self._cfg["security"].update({"allow_preproc": "True"})

    if not self._cfg.has_option("security", "allow_federated_analytics"):
        logger.warning(
            "DEPRECATION: You are using an old configuration file for the node. "
            "Please add 'allow_federated_analytics' value in `security` section "
            "of the node configuration to define whether federated analytics is allowed."
        )

        self._cfg["security"].update({"allow_federated_analytics": "True"})

    if not self._cfg.has_option("security", "minimum_samples"):
        logger.warning(
            "DEPRECATION: You are using an old configuration file for the node. "
            "Please add 'minimum_samples' value in `security` section "
            "of the node configuration to define the minimum number of samples required for a dataset."
        )
        self._cfg["security"].update({"minimum_samples": "0"})

    if not self._cfg.has_section("syslog"):
        logger.warning(
            "DEPRECATION: You are using an old configuration file for the node. "
            "Please add 'enable' value in `syslog` section "
            "of the node configuration to define whether syslog is enabled."
        )
        self._cfg.add_section("syslog")
        self._cfg["syslog"].update({"enable": "False"})
        self._cfg["syslog"].update({"host": "localhost"})
        self._cfg["syslog"].update({"port": "514"})
        self._cfg["syslog"].update({"protocol": "udp"})
        self._cfg["syslog"].update({"facility": "user"})
        self._cfg["syslog"].update({"level": "INFO"})