rsky-relay: add tree inversion

Author: utkarshgupta137

rsky-relay/Cargo.toml

@@ -34,6 +34,7 @@ serde_bytes = "0.11"
 serde_cbor = "0.11"
 serde_ipld_dagcbor = "0.6"
 serde_json = { version = "1", features = ["raw_value"] }
+sha2 = "0.10"
 signal-hook = { version = "0.3", features = ["extended-siginfo"] }
 sled = { version = "0.34", features = ["compression"] }
 thingbuf = "0.1"

rsky-relay/src/validator/event.rs

@@ -1,4 +1,5 @@
 use std::borrow::Cow;
+use std::cmp::Ordering;
 use std::convert::Infallible;
 use std::io::Write;
 use std::{fmt, io};
@@ -76,7 +77,38 @@ pub enum SubscribeReposCommitOperation {
     Delete { path: String, prev_data: Option<Cid> },
 }
 
+impl PartialEq for SubscribeReposCommitOperation {
+    #[inline]
+    fn eq(&self, other: &Self) -> bool {
+        self.path().eq(other.path())
+    }
+}
+
+impl Eq for SubscribeReposCommitOperation {}
+
+impl PartialOrd for SubscribeReposCommitOperation {
+    #[inline]
+    fn partial_cmp(&self, other: &Self) -> Option<Ordering> {
+        Some(self.cmp(other))
+    }
+}
+
+impl Ord for SubscribeReposCommitOperation {
+    #[inline]
+    fn cmp(&self, other: &Self) -> Ordering {
+        self.path().cmp(other.path())
+    }
+}
+
 impl SubscribeReposCommitOperation {
+    fn path(&self) -> &String {
+        match self {
+            Self::Create { path, .. } => path,
+            Self::Update { path, .. } => path,
+            Self::Delete { path, .. } => path,
+        }
+    }
+
     pub const fn is_valid(&self) -> bool {
         match self {
             Self::Create { .. } => true,

rsky-relay/src/validator/resolver.rs

@@ -166,7 +166,7 @@ impl Resolver {
         let (req, hostname) = if let Some(hostname) = hostname {
             (self.client.get(format!("https://{hostname}/{DOC_PATH}")), Some(hostname.to_owned()))
         } else if let Some(after) = self.after.take() {
-            tracing::debug!("fetching after: {after}");
+            tracing::trace!("fetching after: {after}");
             self.last = Instant::now();
             (self.client.get(format!("{PLC_URL}={after}")), None)
         } else {