Method put

crates/core/src/host/disk_storage.rs:52–69

(&self, value: &[u8])

    #[tracing::instrument(level = "trace", skip(self, value))]
    pub async fn put(&self, value: &[u8]) -> io::Result<Hash> {
        let h = hash_bytes(value);
        let path = self.object_path(&h);
        fs::create_dir_all(path.parent().expect("object path must have a parent")).await?;

        // to ensure it doesn't conflict with a concurrent call to put() - suffix with nanosecond timestamp
        let ts = std::time::UNIX_EPOCH.elapsed().unwrap().as_nanos();
        let tmp = path.with_extension(format!("tmp{ts}"));
        {
            let mut f = fs::File::options().write(true).create_new(true).open(&tmp).await?;
            f.write_all(value).await?;
            f.sync_data().await?;
        }

        fs::rename(tmp, path).await?;

        Ok(h)
    }

    #[tracing::instrument(level = "trace", skip(self))]
    pub async fn prune(&self, key: &Hash) -> anyhow::Result<()> {