use tempfile func (#71)

mosec/args.py

@@ -1,4 +1,6 @@
 import argparse
+import os
+import tempfile
 
 
 class ArgParser:
@@ -14,7 +16,7 @@ def parse(cls) -> argparse.Namespace:
             "--path",
             help="Unix Domain Socket address for internal Inter-Process Communication",
             type=str,
-            default="/tmp/mosec",
+            default=os.path.join(tempfile.gettempdir(), "mosec"),
         )
 
         parser.add_argument(

src/args.rs

@@ -3,10 +3,9 @@ use clap::{crate_version, AppSettings, Clap};
 #[derive(Clap, Debug)]
 #[clap(version = crate_version!())]
 #[clap(setting = AppSettings::ColoredHelp)]
-
 pub(crate) struct Opts {
     /// Unix domain socket directory path
-    #[clap(long, default_value = "/tmp/mosec")]
+    #[clap(long, default_value = "")]
     pub(crate) path: String,
 
     /// batch size for each stage

src/coordinator.rs

@@ -27,14 +27,24 @@ impl Coordinator {
         let (sender, receiver) = bounded(opts.capacity);
         let timeout = Duration::from_millis(opts.timeout);
         let wait_time = Duration::from_millis(opts.wait);
+        let path = if opts.path.len() > 0 {
+            opts.path.to_string()
+        } else {
+            // default IPC path
+            std::env::temp_dir()
+                .join(env!("CARGO_PKG_NAME"))
+                .into_os_string()
+                .into_string()
+                .unwrap()
+        };
         let task_manager = TaskManager::new(timeout, sender.clone());
         TASK_MANAGER.set(task_manager).unwrap();
         let metrics = Metrics::init_with_namespace(&opts.namespace, opts.timeout);
         METRICS.set(metrics).unwrap();
 
         Self {
             capacity: opts.capacity,
-            path: opts.path.to_string(),
+            path: path,
             batches: opts.batches.clone(),
             wait_time,
             timeout,

tests/test_coordinator.py

@@ -5,6 +5,7 @@
 import shutil
 import socket
 import struct
+import tempfile
 import time
 from contextlib import ContextDecorator
 from os.path import join
@@ -19,7 +20,7 @@
 from .mock_logger import MockLogger
 from .utils import imitate_controller_send
 
-socket_prefix = "/tmp/test-mosec/"
+socket_prefix = join(tempfile.gettempdir(), "test-mosec")
 stage = STAGE_INGRESS + STAGE_EGRESS