Merge pull request #5 from sopaco/v2

Remove unused imports and simplify directory creation logic

Author: sopaco

crates/cowork-core/src/pipeline/mod.rs

@@ -52,10 +52,9 @@ pub fn create_cowork_pipeline(config: &ModelConfig) -> Result<Arc<dyn Agent>> {
 /// This function intelligently determines which stage to resume from
 /// by checking what data files already exist.
 pub fn create_resume_pipeline(config: &ModelConfig) -> Result<Arc<dyn Agent>> {
-    use crate::storage::*;
     use std::path::Path;
 
-    let llm = create_llm_client(&config.llm)?;
+    let _llm = create_llm_client(&config.llm)?;
 
     // Determine which stage to start from based on existing data
     let start_stage = if Path::new(".cowork/artifacts/delivery_report.md").exists() {

crates/cowork-core/src/storage/mod.rs

@@ -12,16 +12,16 @@ const COWORK_DIR: &str = ".cowork";
 /// Get the .cowork directory path, create if not exists
 pub fn get_cowork_dir() -> Result<PathBuf> {
     let path = PathBuf::from(COWORK_DIR);
-    if !path.exists() {
-        fs::create_dir_all(&path)
-            .with_context(|| format!("Failed to create .cowork directory at {:?}", path))?;
-        
-        // Create subdirectories
-        fs::create_dir_all(path.join("data"))?;
-        fs::create_dir_all(path.join("artifacts"))?;
-        fs::create_dir_all(path.join("session"))?;
-        fs::create_dir_all(path.join("logs"))?;
-    }
+    
+    // Create main directory and subdirectories (create_dir_all is idempotent and safe for concurrent calls)
+    // We don't need to check if it exists first - create_dir_all handles that
+    fs::create_dir_all(&path)
+        .with_context(|| format!("Failed to create .cowork directory at {:?}", path))?;
+    fs::create_dir_all(path.join("data"))?;
+    fs::create_dir_all(path.join("artifacts"))?;
+    fs::create_dir_all(path.join("session"))?;
+    fs::create_dir_all(path.join("logs"))?;
+    
     Ok(path)
 }
 

crates/cowork-core/src/storage/storage_test.rs

@@ -1,7 +1,6 @@
 #[cfg(test)]
 mod tests {
     use crate::storage::*;
-    use crate::data::*;
     use tempfile::TempDir;
     use std::env;