Fix directories functions for other platforms

shared/platform/linux/directories.rs

@@ -7,12 +7,16 @@ use users::{get_current_uid, get_user_by_uid};
 pub fn get_unix_socket_path() -> Result<String> {
     // Get the user and their username
     let user = get_user_by_uid(get_current_uid())
-        .ok_or(anyhow!("Couldn't find username for current user"))?;
+        .ok_or_else(|| anyhow!("Couldn't find username for current user"))?;
     let username = user.name().to_string_lossy();
 
-    // Create the socket in the default /tmp/ directory
-    let path = Path::new("/tmp/").join(format!("pueue_{}.socket", username));
-    Ok(path.to_string_lossy().into())
+    // Create the socket in the default pueue path
+    let pueue_path = PathBuf::from(default_pueue_path()?);
+    let path = pueue_path.join(format!("pueue_{}.socket", username));
+    Ok(path
+        .to_str()
+        .ok_or_else(|| anyhow!("Failed to parse log path (Weird characters?)"))?
+        .to_string())
 }
 
 fn get_home_dir() -> Result<PathBuf> {
@@ -35,25 +39,25 @@ pub fn default_pueue_path() -> Result<String> {
     let path = get_home_dir()?.join(".local/share/pueue");
     Ok(path
         .to_str()
-        .ok_or(anyhow!("Failed to parse log path (Weird characters?)"))?
+        .ok_or_else(|| anyhow!("Failed to parse log path (Weird characters?)"))?
         .to_string())
 }
 
 #[cfg(test)]
 mod tests {
     use super::*;
 
-    use std::fs::{remove_file, File};
+    use std::fs::{create_dir_all, remove_file, File};
     use std::io::prelude::*;
 
     use anyhow::Result;
 
     #[test]
     fn test_create_unix_socket() -> Result<()> {
         let path = get_unix_socket_path()?;
+        create_dir_all(default_pueue_path()?)?;
 
-        // If pueue is currently running on the system,
-        // simply accept that we found the correct path
+        // If pueue is currently running on the system, simply accept that we found the correct path
         if PathBuf::from(&path).exists() {
             return Ok(());
         }

shared/platform/macos/directories.rs

@@ -1,6 +1,23 @@
 use std::path::{Path, PathBuf};
 
 use anyhow::{anyhow, Result};
+use users::{get_current_uid, get_user_by_uid};
+
+/// Get the default unix socket path for the current user
+pub fn get_unix_socket_path() -> Result<String> {
+    // Get the user and their username
+    let user = get_user_by_uid(get_current_uid())
+        .ok_or(anyhow!("Couldn't find username for current user"))?;
+    let username = user.name().to_string_lossy();
+
+    // Create the socket in the default pueue path
+    let pueue_path = PathBuf::from(default_pueue_path()?);
+    let path = pueue_path.join(format!("pueue_{}.socket", username));
+    Ok(path
+        .to_str()
+        .ok_or(anyhow!("Failed to parse log path (Weird characters?)"))?
+        .to_string())
+}
 
 fn get_home_dir() -> Result<PathBuf> {
     dirs::home_dir().ok_or_else(|| anyhow!("Couldn't resolve home dir"))

shared/platform/unix/socket.rs

@@ -16,15 +16,15 @@ pub trait GenericListener: Sync + Send {
 impl GenericListener for TcpListener {
     async fn accept<'a>(&'a self) -> Result<Box<dyn GenericSocket>> {
         let (socket, _) = self.accept().await?;
-        Ok((Box::new(socket)))
+        Ok(Box::new(socket))
     }
 }
 
 #[async_trait]
 impl GenericListener for UnixListener {
     async fn accept<'a>(&'a self) -> Result<Box<dyn GenericSocket>> {
         let (socket, _) = self.accept().await?;
-        Ok((Box::new(socket)))
+        Ok(Box::new(socket))
     }
 }
 

shared/platform/windows/directories.rs

@@ -2,6 +2,17 @@ use std::path::{Path, PathBuf};
 
 use anyhow::{anyhow, Result};
 
+/// Get the default unix socket path for the current user
+pub fn get_unix_socket_path() -> Result<String> {
+    // Create the socket in the default pueue path
+    let pueue_path = PathBuf::from(default_pueue_path()?);
+    let path = pueue_path.join("pueue.socket");
+    Ok(path
+        .to_str()
+        .ok_or(anyhow!("Failed to parse log path (Weird characters?)"))?
+        .to_string())
+}
+
 fn get_home_dir() -> Result<PathBuf> {
     dirs::home_dir().ok_or_else(|| anyhow!("Couldn't resolve home dir"))
 }

shared/platform/windows/socket.rs

@@ -15,7 +15,7 @@ pub trait GenericListener: Sync + Send {
 impl GenericListener for TcpListener {
     async fn accept<'a>(&'a self) -> Result<Box<dyn GenericSocket>> {
         let (socket, _) = self.accept().await?;
-        Ok((Box::new(socket)))
+        Ok(Box::new(socket))
     }
 }