co-storage 0.1.0

COKIT content addressed block storage implementations.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

// SPDX-License-Identifier: AGPL-3.0-only
// Copyright (C) 2026 1io BRANDGUARDIAN GmbH

use crate::StorageError;
use anyhow::{anyhow, Context};
use cid::Cid;
use co_primitives::{unixfs_add, AnyBlockStorage};
use std::path::Path;
use tokio_util::compat::TokioAsyncReadCompatExt;

/// Store file to storage and return the (root) CID.
pub async fn unixfs_add_file(storage: &impl AnyBlockStorage, file: impl AsRef<Path>) -> Result<Cid, anyhow::Error> {
	let mut handle = tokio::fs::File::open(file.as_ref())
		.await
		.with_context(|| format!("open file: {:?}", file.as_ref()))?
		.compat();
	Ok(unixfs_add(storage, &mut handle)
		.await?
		.last()
		.ok_or(StorageError::InvalidArgument(anyhow!("No CID generated: {:?}", file.as_ref())))? // we should have at least an empty block
		.to_owned())
}