co-api 0.1.0

COKIT API to implement a Core.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

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

use co_primitives::{cid_to_raw, raw_to_cid, BlockSerializer, RawCid, Storage};
use serde::{de::DeserializeOwned, Serialize};

pub fn write_output_sync<T: Serialize>(storage: &mut impl Storage, value: &T, output: &mut RawCid) {
	let block = BlockSerializer::new().serialize(&value).expect("serialize output");
	let cid = *block.cid();
	storage.set(block);
	*output = cid_to_raw(&cid);
}

pub fn read_input_sync<T: DeserializeOwned>(storage: &impl Storage, input: &RawCid) -> T {
	let input_cid = raw_to_cid(input).expect("valid input CID");
	let input_block = storage.get(&input_cid);
	let reducer_input: T = BlockSerializer::new().deserialize(&input_block).expect("deserialize input");
	reducer_input
}