partner_chains_plutus_data/
lib.rs1#![deny(missing_docs)]
3use cardano_serialization_lib::{PlutusData, PlutusList};
4
5pub mod d_param;
6pub mod governed_map;
7pub mod permissioned_candidates;
8pub mod registered_candidates;
9pub mod reserve;
10pub mod version_oracle;
11
12#[derive(Debug, PartialEq, thiserror::Error)]
13#[error("Could not decode {datum:?} to {to}: {msg}")]
14pub struct DataDecodingError {
16 datum: PlutusData,
17 to: String,
18 msg: String,
19}
20
21type DecodingResult<T> = std::result::Result<T, DataDecodingError>;
22
23pub trait PlutusDataExtensions {
25 fn as_u64(&self) -> Option<u64>;
27 fn as_u32(&self) -> Option<u32>;
29 fn as_u16(&self) -> Option<u16>;
31}
32
33impl PlutusDataExtensions for PlutusData {
34 fn as_u64(&self) -> Option<u64> {
35 self.as_integer()?.as_u64().map(u64::from)
36 }
37 fn as_u32(&self) -> Option<u32> {
38 u32::try_from(self.as_integer()?.as_u64()?).ok()
39 }
40 fn as_u16(&self) -> Option<u16> {
41 u16::try_from(self.as_u32()?).ok()
42 }
43}
44
45pub(crate) trait VersionedDatum: Sized {
60 const NAME: &str;
61
62 fn decode(data: &PlutusData) -> DecodingResult<Self>;
64}
65
66pub(crate) trait VersionedDatumWithLegacy: Sized {
70 const NAME: &str;
71
72 fn decode_legacy(data: &PlutusData) -> Result<Self, String>;
74
75 fn decode_versioned(
82 version: u64,
83 datum: &PlutusData,
84 appendix: &PlutusData,
85 ) -> Result<Self, String>;
86}
87
88impl<T: VersionedDatumWithLegacy> VersionedDatum for T {
89 const NAME: &str = <Self as VersionedDatumWithLegacy>::NAME;
90
91 fn decode(data: &PlutusData) -> DecodingResult<Self> {
92 (match plutus_data_version_and_payload(data) {
93 None => Self::decode_legacy(data),
94 Some(VersionedGenericDatum { datum, appendix, version }) => {
95 Self::decode_versioned(version, &datum, &appendix)
96 },
97 })
98 .map_err(|msg| decoding_error_and_log(data, Self::NAME, &msg))
99 }
100}
101
102fn plutus_data_version_and_payload(data: &PlutusData) -> Option<VersionedGenericDatum> {
103 let fields = data.as_list().filter(|outer_list| outer_list.len() == 3)?;
104
105 Some(VersionedGenericDatum {
106 datum: fields.get(0),
107 appendix: fields.get(1),
108 version: fields.get(2).as_u64()?,
109 })
110}
111
112fn decoding_error_and_log(data: &PlutusData, to: &str, msg: &str) -> DataDecodingError {
113 log::error!("Could not decode {data:?} to {to}: {msg}");
114 DataDecodingError { datum: data.clone(), to: to.to_string(), msg: msg.to_string() }
115}
116
117pub(crate) struct VersionedGenericDatum {
121 pub datum: PlutusData,
122 pub appendix: PlutusData,
123 pub version: u64,
124}
125
126impl From<VersionedGenericDatum> for PlutusData {
127 fn from(value: VersionedGenericDatum) -> Self {
128 let mut list = PlutusList::new();
129 list.add(&value.datum);
130 list.add(&value.appendix);
131 list.add(&PlutusData::new_integer(&value.version.into()));
132 PlutusData::new_list(&list)
133 }
134}
135
136#[cfg(test)]
137pub(crate) mod test_helpers {
138 use cardano_serialization_lib::PlutusData;
139 macro_rules! test_plutus_data {
140 ($json:tt) => {
141 cardano_serialization_lib::encode_json_value_to_plutus_datum(
142 serde_json::json!($json),
143 cardano_serialization_lib::PlutusDatumSchema::DetailedSchema,
144 )
145 .expect("test data is valid")
146 };
147 }
148 pub(crate) use test_plutus_data;
149
150 pub(crate) fn json_to_plutus_data(json: serde_json::Value) -> PlutusData {
151 cardano_serialization_lib::encode_json_value_to_plutus_datum(
152 json,
153 cardano_serialization_lib::PlutusDatumSchema::DetailedSchema,
154 )
155 .expect("test data is valid")
156 }
157
158 pub(crate) fn plutus_data_to_json(data: PlutusData) -> serde_json::Value {
159 cardano_serialization_lib::decode_plutus_datum_to_json_value(
160 &data,
161 cardano_serialization_lib::PlutusDatumSchema::DetailedSchema,
162 )
163 .expect("test data is valid")
164 }
165}