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
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

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

use crate::CoreBlockStorage;
use cid::Cid;
use co_primitives::{Link, OptionLink, ReducerAction};

/// COre execution context.
pub trait Context {
	/// Storage instance.
	fn storage(&self) -> &CoreBlockStorage;

	/// Get runtime payload.
	fn payload(&self) -> Vec<u8>;

	/// Get action to apply to the state.
	fn event(&self) -> Cid;

	/// Get current COre state.
	/// Returns [`None`] if no prior state.
	fn state(&self) -> Option<Cid>;

	/// Set next COre state.
	fn set_state(&mut self, cid: Cid);

	/// Write diagnostic block.
	fn write_diagnostic(&mut self, cid: Cid);
}

#[allow(async_fn_in_trait)]
pub trait Reducer<A>
where
	Self: Sized,
	A: Clone,
{
	async fn reduce(
		state: OptionLink<Self>,
		event: Link<ReducerAction<A>>,
		storage: &CoreBlockStorage,
	) -> Result<Link<Self>, anyhow::Error>;
}