Add patch

Author: ansys-akarcher

pyproject.toml

@@ -5,7 +5,7 @@ requires = ["setuptools>=61.0.0", "wheel"]
 [project]
 # Check https://setuptools.pypa.io/en/stable/userguide/quickstart.html for all available sections
 name = "ansys-dpf-core"
-version = "0.13.8"
+version = "0.13.9"
 description = "Data Processing Framework - Python Core "
 readme = "README.md"
 requires-python = ">=3.9, <4"

src/ansys/dpf/core/runtime_config.py

@@ -137,6 +137,22 @@ def return_arrays(self):
     def return_arrays(self, value):
         self._data_tree.add(return_arrays=int(value))
 
+    @property
+    def grpc_mode(self):
+        return str(self._data_tree.get_as("grpc_mode", types.string))
+
+    @grpc_mode.setter
+    def grpc_mode(self, value: str):
+        self._data_tree.add(grpc_mode=str(value))
+
+    @property
+    def grpc_certs_dir(self):
+        return str(self._data_tree.get_as("grpc_certs_dir", types.string))
+
+    @grpc_certs_dir.setter
+    def grpc_certs_dir(self, value: str):
+        self._data_tree.add(grpc_certs_dir=str(value))
+
     def copy_config(self, config):
         """Add config to data tree."""
         config._data_tree.add(self._data_tree.to_dict())

src/ansys/dpf/core/server.py

@@ -45,6 +45,7 @@
     CommunicationProtocols,
     ServerConfig,
     ServerFactory,
+    GrpcMode
 )
 from ansys.dpf.core.server_types import DPF_DEFAULT_PORT, LOCALHOST, RUNNING_DOCKER, BaseServer
 
@@ -252,6 +253,11 @@ def start_local_server(
                 "ip" in server_init_signature.parameters.keys()
                 and "port" in server_init_signature.parameters.keys()
             ):
+                grpc_mode=GrpcMode.mTLS
+                certs_dir=""
+                if config is not None:
+                    grpc_mode = config.grpc_mode
+                    certs_dir = config.certificates_dir
                 server = server_type(
                     ansys_path,
                     ip,
@@ -263,6 +269,8 @@ def start_local_server(
                     timeout=timeout,
                     use_pypim=use_pypim,
                     context=context,
+                    grpc_mode=grpc_mode,
+                    certificates_dir=certs_dir
                 )
             else:
                 server = server_type(
@@ -361,13 +369,20 @@ def connect():
             "ip" in server_init_signature.parameters.keys()
             and "port" in server_init_signature.parameters.keys()
         ):
+            grpc_mode=GrpcMode.mTLS
+            certs_dir=""
+            if config is not None:
+                grpc_mode = config.grpc_mode
+                certs_dir = config.certificates_dir
             server = server_type(
                 ip=ip,
                 port=port,
                 as_global=as_global,
                 launch_server=False,
                 context=context,
                 timeout=timeout,
+                grpc_mode=grpc_mode,
+                certificates_dir=certs_dir
             )
         else:
             server = server_type(as_global=as_global, context=context)

src/ansys/dpf/core/server_factory.py

@@ -33,6 +33,8 @@
 import subprocess
 import time
 
+from pathlib import Path
+
 from ansys.dpf.gate.load_api import (
     _find_outdated_ansys_version,
     _get_path_in_install,
@@ -54,9 +56,14 @@ class CommunicationProtocols:
     gRPC = "gRPC"
     InProcess = "InProcess"
 
+class GrpcMode:
+    Insecure = "insecure"
+    mTLS = "mtls"
+
 
 DEFAULT_COMMUNICATION_PROTOCOL = CommunicationProtocols.InProcess
 DEFAULT_LEGACY = False
+DEFAULT_GRPC_MODE=GrpcMode.mTLS
 
 
 class DockerConfig:
@@ -297,13 +304,21 @@ def __init__(
         self,
         protocol: str = DEFAULT_COMMUNICATION_PROTOCOL,
         legacy: bool = DEFAULT_LEGACY,
+        grpc_mode: str = DEFAULT_GRPC_MODE,
+        certificates_dir: Path = None
     ):
         self.legacy = legacy
         if not protocol:
             self.protocol = CommunicationProtocols.InProcess
         else:
             self.protocol = protocol
 
+        if not grpc_mode:
+            self.grpc_mode = DEFAULT_GRPC_MODE
+        else:
+            self.grpc_mode = grpc_mode
+        self.certificates_dir = certificates_dir
+
     def __str__(self):
         """Return a string representation of the ServerConfig instance.
 
@@ -337,7 +352,12 @@ def __eq__(self, other: "ServerConfig"):
             True if the instances have the same protocol and legacy status, False otherwise.
         """
         if isinstance(other, ServerConfig):
-            return self.legacy == other.legacy and self.protocol == other.protocol
+            return (
+                    self.legacy == other.legacy
+                and self.protocol == other.protocol
+                and self.grpc_mode == other.grpc_mode
+                and self.certificates_dir == other.certificates_dir
+                )
         return False
 
     def __ne__(self, other):
@@ -453,6 +473,8 @@ class AvailableServerConfigs:
     LegacyGrpcServer = ServerConfig(CommunicationProtocols.gRPC, legacy=True)
     InProcessServer = ServerConfig(CommunicationProtocols.InProcess, legacy=False)
     GrpcServer = ServerConfig(CommunicationProtocols.gRPC, legacy=False)
+    InsecureGrpcServer = ServerConfig(CommunicationProtocols.gRPC, legacy=False, grpc_mode=GrpcMode.Insecure)
+    InsecureLegacyGrpcServer = ServerConfig(CommunicationProtocols.gRPC, legacy=True, grpc_mode=GrpcMode.Insecure)
 
 
 class RunningDockerConfig: