add source field to mutation events

jesseditson · Dec 19, 2024 · 9472a8f · 9472a8f
1 parent 5030178
commit 9472a8f
Show file tree

Hide file tree

Showing 4 changed files with 14 additions and 0 deletions.
diff --git a/src/binary/command/import.rs b/src/binary/command/import.rs
@@ -370,6 +370,7 @@ impl Command {
                                 object: object.to_string(),
                                 filename: f.to_string(),
                                 path: current_path.to_owned(),
+                                source: None,
                             }),
                             None,
                         )
@@ -419,6 +420,7 @@ impl Command {
                                 path: current_path.clone(),
                                 value: Some(value),
                                 field: name.to_string(),
+                                source: None,
                             }),
                             None,
                         )
@@ -456,6 +458,7 @@ impl Command {
                                     path: current_path.clone().concat(col_path),
                                     value: Some(value),
                                     field: col_field,
+                                    source: None,
                                 }),
                                 None,
                             )

diff --git a/src/binary/command/upload.rs b/src/binary/command/upload.rs
@@ -191,6 +191,7 @@ impl BinaryCommand for Command {
                 path: ValuePath::empty(),
                 value: Some(field_data.clone()),
                 field: field.to_string(),
+                source: None,
             }),
             None,
         )?;

diff --git a/src/events.rs b/src/events.rs
@@ -29,20 +29,23 @@ pub struct EditFieldEvent {
     pub path: ValuePath,
     pub field: String,
     pub value: Option<FieldValue>,
+    pub source: Option<String>,
 }
 #[derive(Debug, Clone, Serialize, Deserialize)]
 #[cfg_attr(feature = "typescript", derive(TypeDef))]
 pub struct EditOrderEvent {
     pub object: String,
     pub filename: String,
     pub order: i32,
+    pub source: Option<String>,
 }
 
 #[derive(Debug, Clone, Serialize, Deserialize)]
 #[cfg_attr(feature = "typescript", derive(TypeDef))]
 pub struct DeleteObjectEvent {
     pub object: String,
     pub filename: String,
+    pub source: Option<String>,
 }
 
 #[derive(Debug, Clone, Serialize, Deserialize)]
@@ -67,6 +70,7 @@ pub struct ChildEvent {
     pub object: String,
     pub filename: String,
     pub path: ValuePath,
+    pub source: Option<String>,
 }
 
 #[cfg(test)]

diff --git a/src/lib.rs b/src/lib.rs
@@ -317,6 +317,7 @@ impl<F: FileSystemAPI + Clone + Debug> Archival<F> {
         }
         Ok(r)
     }
+
     // Internal
     fn add_object(&self, event: AddObjectEvent) -> Result<ArchivalEventResponse, Box<dyn Error>> {
         let obj_def = self
@@ -584,6 +585,7 @@ mod lib {
                 path: ValuePath::empty(),
                 field: "name".to_string(),
                 value: Some(FieldValue::String("This is the new name".to_string())),
+                source: None,
             }),
             Some(BuildOptions::default()),
         )?;
@@ -607,6 +609,7 @@ mod lib {
             ArchivalEvent::DeleteObject(DeleteObjectEvent {
                 object: "section".to_string(),
                 filename: "first".to_string(),
+                source: None,
             }),
             Some(BuildOptions::default()),
         )?;
@@ -648,6 +651,7 @@ mod lib {
                 object: "section".to_string(),
                 filename: "first".to_string(),
                 order: 12,
+                source: None,
             }),
             Some(BuildOptions::default()),
         )?;
@@ -692,6 +696,7 @@ mod lib {
                     object: "post".to_string(),
                     filename: "a-post".to_string(),
                     path: ValuePath::default().append(ValuePathComponent::key("links")),
+                    source: None,
                 }),
                 Some(BuildOptions::default()),
             )
@@ -744,6 +749,7 @@ mod lib {
                     path: ValuePath::default()
                         .append(ValuePathComponent::key("links"))
                         .append(ValuePathComponent::Index(0)),
+                    source: None,
                 }),
                 Some(BuildOptions::default()),
             )