create unix socket and qauld-ctl binary

rust/Cargo.toml

@@ -6,6 +6,7 @@ members = [
     # binaries
     "clients/cli",
     "clients/qauld",
+    "clients/qauld-ctl",
 
     # libp2p modules
     "libp2p_modules/qaul_info",

rust/clients/qauld-ctl/Cargo.toml

@@ -0,0 +1,8 @@
+[package]
+name = "qauld-ctl"
+version = "0.1.0"
+edition = "2021"
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]

rust/clients/qauld-ctl/src/main.rs

@@ -0,0 +1,20 @@
+use std::os::unix::net::UnixStream;
+use std::io::{Read, Write};
+mod socket;
+fn main() {
+    socket::run_socket();
+    let mut stream = UnixStream::connect("/tmp/qauld.sock").expect("Unable to connect to Unix socket");
+    let request = "some request".as_bytes();
+    match stream.write(request) {
+        Ok(_) => {
+            let mut buffer = [0; 1024];
+            match stream.read(&mut buffer) {
+                Ok(_) => {
+                    // handle the response
+                }
+                Err(e) => println!("Error reading from socket: {}", e),
+            }
+        }
+        Err(e) => println!("Error writing to socket: {}", e),
+    }
+}

rust/clients/qauld-ctl/src/socket.rs

@@ -0,0 +1,31 @@
+use std::os::unix::net::UnixListener;
+use std::os::unix::net::UnixStream;
+use std::io::{Read, Write};
+use std::fs::{self, Permissions};
+use std::os::unix::fs::PermissionsExt;
+
+pub fn run_socket() {
+
+    let socket_dir = "/tmp/";
+    let socket_file = "/tmp/qauld.sock";
+    // 0700 (read, write, execute for owner only)
+    fs::set_permissions(socket_dir, Permissions::from_mode(0o700));
+    // 0600 (read, write for owner only)
+    fs::set_permissions(socket_file, Permissions::from_mode(0o600));
+
+    let listener = UnixListener::bind(socket_file).expect("Unable to bind to Unix socket");
+    for stream in listener.incoming() {
+        match stream {
+            Ok(mut stream) => {
+                let mut buffer = [0; 1024];
+                match stream.read(&mut buffer) {
+                    Ok(_) => {
+                        // handle the request
+                    }
+                    Err(e) => println!("Error reading from socket: {}", e),
+                }
+            }
+            Err(e) => println!("Error accepting incoming connection: {}", e),
+        }
+    }
+}