lib

decode.rs (5261B)

---

 #[cfg(not(feature = "std"))]
 use alloc::{string::String, vec::Vec};
 
 use radroots_event::{
     farm::crdt::{FarmCrdtChange, KIND_FARM_CRDT_CHANGE, RADROOTS_FARM_CRDT_TAG},
     farm::workspace::KIND_FARM_WORKSPACE_MANIFEST,
     tag::name::{TAG_A, TAG_D, TAG_H, TAG_P, TAG_T},
 };
 
 use crate::d_tag::validate_d_tag_tag;
 use crate::error::EventParseError;
 use crate::farm_crdt::encode::validate_change;
 use crate::field_helpers::{
     optional_tag_value, parse_address_tag_with_kind, required_tag_value, tag_values,
     validate_non_empty_tag_value,
 };
 use crate::parsed::{RadrootsParsedData, RadrootsParsedEvent};
 
 const EXPECTED_KIND: &str = "78";
 
 pub fn farm_crdt_change_from_event(
     kind: u32,
     tags: &[Vec<String>],
     content: &str,
 ) -> Result<FarmCrdtChange, EventParseError> {
     farm_crdt_change_from_event_inner(kind, tags, content, None)
 }
 
 pub fn farm_crdt_change_from_event_with_author(
     kind: u32,
     tags: &[Vec<String>],
     content: &str,
     author_pubkey: &str,
 ) -> Result<FarmCrdtChange, EventParseError> {
     validate_non_empty_tag_value(author_pubkey, TAG_P)?;
     farm_crdt_change_from_event_inner(kind, tags, content, Some(author_pubkey))
 }
 
 pub fn data_from_event(
     id: String,
     author: String,
     published_at: u64,
     kind: u32,
     content: String,
     tags: Vec<Vec<String>>,
 ) -> Result<RadrootsParsedData<FarmCrdtChange>, EventParseError> {
     let change = farm_crdt_change_from_event_with_author(kind, &tags, &content, &author)?;
     Ok(RadrootsParsedData::new(
         id,
         author,
         published_at,
         kind,
         change,
     ))
 }
 
 pub fn parsed_from_event(
     id: String,
     author: String,
     published_at: u64,
     kind: u32,
     content: String,
     tags: Vec<Vec<String>>,
     sig: String,
 ) -> Result<RadrootsParsedEvent<FarmCrdtChange>, EventParseError> {
     let data = data_from_event(
         id.clone(),
         author.clone(),
         published_at,
         kind,
         content.clone(),
         tags.clone(),
     )?;
     RadrootsParsedEvent::from_event_parts(id, author, published_at, kind, content, tags, sig, data)
 }
 
 fn farm_crdt_change_from_event_inner(
     kind: u32,
     tags: &[Vec<String>],
     content: &str,
     author_pubkey: Option<&str>,
 ) -> Result<FarmCrdtChange, EventParseError> {
     if kind != KIND_FARM_CRDT_CHANGE {
         return Err(EventParseError::InvalidKind {
             expected: EXPECTED_KIND,
             got: kind,
         });
     }
     if content.trim().is_empty() {
         return Err(EventParseError::InvalidJson("content"));
     }
 
     let farm_group_id = required_tag_value(tags, TAG_H)?;
     let document_id = required_tag_value(tags, TAG_D)?;
     validate_d_tag_tag(&document_id, TAG_D)?;
     let workspace_address = required_tag_value(tags, TAG_A)?;
     let workspace =
         parse_address_tag_with_kind(&workspace_address, KIND_FARM_WORKSPACE_MANIFEST, TAG_A)?;
     let marker_tags = tag_values(tags, TAG_T)?;
     if !marker_tags
         .iter()
         .any(|value| value == RADROOTS_FARM_CRDT_TAG)
     {
         return Err(EventParseError::MissingTag(TAG_T));
     }
     if let Some(tag_author) = optional_tag_value(tags, TAG_P)?
         && let Some(author_pubkey) = author_pubkey
         && tag_author != author_pubkey
     {
         return Err(EventParseError::InvalidTag(TAG_P));
     }
 
     let change: FarmCrdtChange =
         serde_json::from_str(content).map_err(|_| EventParseError::InvalidJson("content"))?;
     validate_change(&change).map_err(encode_error_to_parse_error)?;
     if change.farm_group_id != farm_group_id {
         return Err(EventParseError::InvalidTag(TAG_H));
     }
     if change.document_id != document_id {
         return Err(EventParseError::InvalidTag(TAG_D));
     }
     if change.workspace.pubkey != workspace.pubkey || change.workspace.d_tag != workspace.d_tag {
         return Err(EventParseError::InvalidTag(TAG_A));
     }
     Ok(change)
 }
 
 fn encode_error_to_parse_error(error: crate::error::EventEncodeError) -> EventParseError {
     match error {
         crate::error::EventEncodeError::InvalidKind(kind) => EventParseError::InvalidKind {
             expected: EXPECTED_KIND,
             got: kind,
         },
         crate::error::EventEncodeError::EmptyRequiredField(field)
         | crate::error::EventEncodeError::InvalidField(field) => match field {
             "farm_group_id" => EventParseError::InvalidTag(TAG_H),
             "document_id" => EventParseError::InvalidTag(TAG_D),
             "workspace.pubkey" | "workspace.d_tag" => EventParseError::InvalidTag(TAG_A),
             _ => EventParseError::InvalidJson(field),
         },
         crate::error::EventEncodeError::Json => EventParseError::InvalidJson("content"),
     }
 }
 
 #[cfg(test)]
 mod tests {
     use super::*;
     use crate::error::EventEncodeError;
 
     #[test]
     fn encode_error_mapper_covers_kind_and_json_edges() {
         assert!(matches!(
             encode_error_to_parse_error(EventEncodeError::InvalidKind(1)),
             EventParseError::InvalidKind {
                 expected: EXPECTED_KIND,
                 got: 1
             }
         ));
         assert!(matches!(
             encode_error_to_parse_error(EventEncodeError::Json),
             EventParseError::InvalidJson("content")
         ));
     }
 }