rivetkit-core 2.3.0-rc.12

Core runtime primitives for RivetKit actor hosts
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

use anyhow::{Context, Result};
use vbare::OwnedVersionedData;

pub(crate) fn encode_latest_with_embedded_version<T>(
	latest: T::Latest,
	version: u16,
	label: &str,
) -> Result<Vec<u8>>
where
	T: OwnedVersionedData,
{
	T::wrap_latest(latest)
		.serialize_with_embedded_version(version)
		.with_context(|| format!("encode {label} versioned bare payload"))
}

pub(crate) fn decode_latest_with_embedded_version<T>(
	payload: &[u8],
	label: &str,
) -> Result<T::Latest>
where
	T: OwnedVersionedData,
{
	<T as OwnedVersionedData>::deserialize_with_embedded_version(payload)
		.with_context(|| format!("decode {label} versioned bare payload"))
}