Bugfix - Fetch ca cert via ssl package (#440)

scaleoutsystems · Oct 31, 2022 · 608d4f1 · 608d4f1
1 parent 827515c
commit 608d4f1
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/fedn/fedn/client.py b/fedn/fedn/client.py
@@ -4,6 +4,7 @@
 import os
 import queue
 import re
+import ssl
 import sys
 import tempfile
 import threading
@@ -267,8 +268,9 @@ def _connect(self, client_config):
         elif self.config['secure']:
             secure = True
             print("CLIENT: using CA certificate for GRPC channel")
+            cert = ssl.get_server_certificate((host, port))
 
-            credentials = grpc.ssl_channel_credentials()
+            credentials = grpc.ssl_channel_credentials(cert.encode('utf-8'))
             channel = grpc.secure_channel("{}:{}".format(host, str(port)), credentials)
         else:
             print("CLIENT: using insecure GRPC channel")