feat: add JSONPath subscription (#883)

* feat: jsonpath subscribe

* fix: add comments and optimize the algorithm

* chore: changeset

* refactor: simplify the code

Author: zxch3n

.changeset/strong-spoons-promise.md

@@ -0,0 +1,6 @@
+---
+"loro-crdt": patch
+"loro-crdt-map": patch
+---
+
+feat: add JSONPath subscription #883

crates/loro-internal/examples/event.rs

@@ -1,9 +1,10 @@
 use std::sync::Arc;
 
 use loro_internal::{
+    cursor::PosType,
     event::Diff,
     handler::{Handler, ValueOrHandler},
-    cursor::PosType, ListHandler, LoroDoc, MapHandler, TextHandler, ToJson, TreeHandler,
+    ListHandler, LoroDoc, MapHandler, TextHandler, ToJson, TreeHandler,
 };
 
 fn main() {

crates/loro-internal/src/container/richtext/richtext_state.rs

@@ -1302,11 +1302,7 @@ impl RichtextState {
             .unwrap_or(false)
     }
 
-    pub(crate) fn range_has_style_key(
-        &mut self,
-        range: Range<usize>,
-        key: &StyleKey,
-    ) -> bool {
+    pub(crate) fn range_has_style_key(&mut self, range: Range<usize>, key: &StyleKey) -> bool {
         self.check_cache();
         let result = match self.style_ranges.as_ref() {
             Some(s) => s.range_contains_key(range, key),

crates/loro-internal/src/cursor.rs

@@ -94,4 +94,4 @@ pub enum PosType {
     Event,
     /// The index is based on the entity index.
     Entity,
-}
+}

crates/loro-internal/src/jsonpath/ast.rs

@@ -2,12 +2,12 @@ use crate::jsonpath::errors::JSONPathError;
 use crate::jsonpath::JSONPathParser;
 use std::fmt::{self, Write};
 
-#[derive(Debug)]
+#[derive(Debug, Clone)]
 pub struct Query {
     pub segments: Segment,
 }
 
-#[derive(Debug)]
+#[derive(Debug, Clone)]
 pub enum Segment {
     Root {},
     Child {
@@ -20,7 +20,7 @@ pub enum Segment {
     },
 }
 
-#[derive(Debug)]
+#[derive(Debug, Clone)]
 pub enum Selector {
     Name {
         name: String,
@@ -39,7 +39,7 @@ pub enum Selector {
     },
 }
 
-#[derive(Debug)]
+#[derive(Debug, Clone)]
 pub enum FilterExpression {
     True_ {},
     False_ {},
@@ -81,13 +81,13 @@ pub enum FilterExpression {
     },
 }
 
-#[derive(Debug)]
+#[derive(Debug, Clone)]
 pub enum LogicalOperator {
     And,
     Or,
 }
 
-#[derive(Debug)]
+#[derive(Debug, Clone)]
 pub enum ComparisonOperator {
     Eq,
     Ne,

crates/loro-internal/src/jsonpath/mod.rs

@@ -1,6 +1,9 @@
 pub mod ast;
 pub mod errors;
 pub mod jsonpath_impl;
+pub mod subscription;
+
+pub use subscription::SubscribeJsonPathCallback;
 pub mod parser;
 
 pub use ast::Query;