generic document data

app_flowy/packages/flowy_editor/lib/src/model/heuristic/rule.dart

@@ -43,7 +43,7 @@ class Rules {
     const FormatLinkAtCaretPositionRule(),
     const ResolveLineFormatRule(),
     const ResolveInlineFormatRule(),
-    // const InsertEmbedsRule(),
+    const InsertEmbedsRule(),
     // const ForceNewlineForInsertsAroundEmbedRule(),
     const AutoExitBlockRule(),
     const PreserveBlockStyleOnInsertRule(),

rust-lib/flowy-ot/src/client/document/data.rs

@@ -0,0 +1,19 @@
+use crate::{client::DocumentData, errors::OTError};
+use serde::{Deserialize, Serialize};
+use serde_json::Error;
+
+impl<T: AsRef<str>> DocumentData for T {
+    fn into_string(self) -> Result<String, OTError> { Ok(self.as_ref().to_string()) }
+}
+
+#[derive(Serialize, Deserialize, Debug)]
+pub struct ImageData {
+    image: String,
+}
+
+impl DocumentData for ImageData {
+    fn into_string(self) -> Result<String, OTError> {
+        let s = serde_json::to_string(&self)?;
+        Ok(s)
+    }
+}

rust-lib/flowy-ot/src/client/document.rs → rust-lib/flowy-ot/src/client/document/document.rs

@@ -1,10 +1,12 @@
 use crate::{
-    client::{view::View, History, RevId, UndoResult},
+    client::{view::View, History, RevId, UndoResult, RECORD_THRESHOLD},
     core::*,
     errors::{ErrorBuilder, OTError, OTErrorCode, OTErrorCode::*},
 };
 
-pub const RECORD_THRESHOLD: usize = 400; // in milliseconds
+pub trait DocumentData {
+    fn into_string(self) -> Result<String, OTError>;
+}
 
 pub struct Document {
     delta: Delta,
@@ -30,10 +32,12 @@ impl Document {
         }
     }
 
-    pub fn insert(&mut self, index: usize, text: &str) -> Result<Delta, OTError> {
+    pub fn insert<T: DocumentData>(&mut self, index: usize, data: T) -> Result<Delta, OTError> {
         let interval = Interval::new(index, index);
         let _ = validate_interval(&self.delta, &interval)?;
-        let delta = self.view.insert(&self.delta, text, interval)?;
+
+        let text = data.into_string()?;
+        let delta = self.view.insert(&self.delta, &text, interval)?;
         log::debug!("👉 receive change: {}", delta);
         self.add_delta(&delta)?;
         Ok(delta)
@@ -63,11 +67,16 @@ impl Document {
         Ok(())
     }
 
-    pub fn replace(&mut self, interval: Interval, text: &str) -> Result<Delta, OTError> {
+    pub fn replace<T: DocumentData>(
+        &mut self,
+        interval: Interval,
+        data: T,
+    ) -> Result<Delta, OTError> {
         let _ = validate_interval(&self.delta, &interval)?;
         let mut delta = Delta::default();
+        let text = data.into_string()?;
         if !text.is_empty() {
-            delta = self.view.insert(&self.delta, text, interval)?;
+            delta = self.view.insert(&self.delta, &text, interval)?;
             log::debug!("👉 receive change: {}", delta);
             self.add_delta(&delta)?;
         }

rust-lib/flowy-ot/src/client/document/mod.rs

@@ -0,0 +1,5 @@
+mod data;
+mod document;
+
+pub use data::*;
+pub use document::*;

rust-lib/flowy-ot/src/client/view.rs

@@ -4,6 +4,8 @@ use crate::{
     errors::{ErrorBuilder, OTError, OTErrorCode},
 };
 
+pub const RECORD_THRESHOLD: usize = 400; // in milliseconds
+
 pub struct View {
     insert_exts: Vec<InsertExtension>,
     format_exts: Vec<FormatExtension>,

rust-lib/flowy-ot/src/errors.rs

@@ -23,6 +23,14 @@ impl Error for OTError {
     fn source(&self) -> Option<&(dyn Error + 'static)> { None }
 }
 
+impl std::convert::From<serde_json::Error> for OTError {
+    fn from(error: serde_json::Error) -> Self {
+        ErrorBuilder::new(OTErrorCode::SerdeError)
+            .error(error)
+            .build()
+    }
+}
+
 #[derive(Debug, Clone)]
 pub enum OTErrorCode {
     IncompatibleLength,
@@ -33,6 +41,7 @@ pub enum OTErrorCode {
     IntervalOutOfBound,
     UndoFail,
     RedoFail,
+    SerdeError,
 }
 
 pub struct ErrorBuilder {