checkpoint

minrk · minrk · commit fe2f398ea322 · 2021-09-08T09:36:52.000+02:00
diff --git a/ipyparallel/controller/app.py b/ipyparallel/controller/app.py
@@ -290,6 +290,23 @@ def _ensure_curve_keypair(self):
         """,
     )
 
+    curve_key_file = Unicode(
+        config=True,
+        help="""The zmq Curve certificate file to store credentials.
+    If specified, read curve credentials from this file.
+    """,
+    )
+
+    @observe("curve_certificate")
+    def curve_certificate_dir_changed(self, change):
+        if change.new:
+            path = change.new
+            name = f"ipcontroller-{self.cluster_id}".rstrip("-")
+            if os.path.exists(path):
+                pass
+
+    session_key = Bytes()
+
     @validate("curve_publickey", "curve_secretkey")
     def _cast_bytes(self, proposal):
         if isinstance(proposal.value, str):
diff --git a/ipyparallel/util.py b/ipyparallel/util.py
@@ -377,18 +377,6 @@ def terminate_children(sig, frame):
         signal(sig, terminate_children)
 
 
-def generate_exec_key(keyfile):
-    import uuid
-
-    newkey = str(uuid.uuid4())
-    with open(keyfile, 'w') as f:
-        # f.write('ipython-key ')
-        f.write(newkey + '\n')
-    # set user-only RW permissions (0600)
-    # this will have no effect on Windows
-    os.chmod(keyfile, stat.S_IRUSR | stat.S_IWUSR)
-
-
 def integer_loglevel(loglevel):
     try:
         loglevel = int(loglevel)
