Fix warg update

This inserts "/package-logs/" into the package logs path, fixing
iteration of the logs.

crates/client/src/storage/fs.rs

@@ -26,6 +26,7 @@ use warg_protocol::{
 const TEMP_DIRECTORY: &str = "temp";
 const PENDING_PUBLISH_FILE: &str = "pending-publish.json";
 const LOCK_FILE_NAME: &str = ".lock";
+const PACKAGE_LOGS_DIR: &str = "package-logs";
 
 /// Represents a package storage using the local file system.
 pub struct FileSystemRegistryStorage {
@@ -70,7 +71,7 @@ impl FileSystemRegistryStorage {
     }
 
     fn package_path(&self, id: &PackageId) -> PathBuf {
-        self.base_dir.join(
+        self.base_dir.join(PACKAGE_LOGS_DIR).join(
             LogId::package_log::<Sha256>(id)
                 .to_string()
                 .replace(':', "/"),
@@ -95,11 +96,12 @@ impl RegistryStorage for FileSystemRegistryStorage {
     async fn load_packages(&self) -> Result<Vec<PackageInfo>> {
         let mut packages = Vec::new();
 
-        for entry in WalkDir::new(&self.base_dir) {
+        let packages_dir = self.base_dir.join(PACKAGE_LOGS_DIR);
+        for entry in WalkDir::new(&packages_dir) {
             let entry = entry.with_context(|| {
                 anyhow!(
                     "failed to walk directory `{path}`",
-                    path = self.base_dir.display()
+                    path = packages_dir.display()
                 )
             })?;
 

tests/client.rs

@@ -83,6 +83,10 @@ async fn client_incrementally_fetches() -> Result<()> {
     // Fetch the package log
     client.upsert([&id]).await?;
 
+    // Ensure that the package is in the packages list
+    let packages = client.registry().load_packages().await?;
+    assert_eq!(packages[0].id.as_ref(), PACKAGE_ID);
+
     // Ensure the package log exists and has releases with all with the same digest
     let package = client
         .registry()