co-js 0.1.0

COKIT primitives for the browser using WebAssembly.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

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

use crate::{
	js::{from_js_value, to_js_value},
	JsBlockStorage,
};
use co_primitives::unixfs_add;
use futures::{io::Cursor, StreamExt, TryStreamExt};
use wasm_bindgen::prelude::*;
use web_sys::js_sys::Uint8Array;

/// Add stream as unixfs file to storage.
/// The last CID in the result is the root.
#[wasm_bindgen(js_name = "unixfsAdd", unchecked_return_type = "Promise<Uint8Array[]>")]
pub async fn js_unixfs_add(storage: &JsBlockStorage, stream: web_sys::ReadableStream) -> Result<JsValue, JsValue> {
	let mut async_stream = wasm_streams::ReadableStream::from_raw(stream)
		.try_into_stream()
		.map_err(|err| format!("Error converting stream: {:?}", err))?
		.map_err(|err| futures::io::Error::other(format!("{:?}", err)))
		.map(|v| from_js_value::<Vec<u8>>(v?).map_err(|err| futures::io::Error::other(format!("{:?}", err))))
		.into_async_read();
	let cids = unixfs_add(storage, &mut async_stream)
		.await
		.map_err(|err| format!("unixfs add failed: {:?}", err))?;
	to_js_value(&cids)
}

/// Add stream as unixfs file to storage.
/// Instead of stream give complete binary data.
/// The last CID in the result is the root.
#[wasm_bindgen(js_name = "unixfsAddBinary", unchecked_return_type = "Promise<Uint8Array[]>")]
pub async fn js_unixfs_add_binary(storage: &JsBlockStorage, js_binary: Uint8Array) -> Result<JsValue, JsValue> {
	let binary: Vec<u8> = from_js_value(js_binary.into())?;
	let mut stream = Cursor::new(binary);
	let cids = unixfs_add(storage, &mut stream)
		.await
		.map_err(|err| format!("unixfs add failed: {:?}", err))?;
	to_js_value(&cids)
}