feat: add sync_id to recon conversations

ceramicnetwork · Apr 12, 2024 · 281aca4 · 281aca4
1 parent 8727cb8
commit 281aca4
Show file tree

Hide file tree

Showing 4 changed files with 153 additions and 49 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/recon/Cargo.toml b/recon/Cargo.toml
@@ -24,6 +24,7 @@ serde.workspace = true
 serde_json.workspace = true
 tokio.workspace = true
 tracing.workspace = true
+uuid = { version = "1.8.0", features = ["v4"] }
 void.workspace = true
 
 [dev-dependencies]

diff --git a/recon/src/metrics.rs b/recon/src/metrics.rs
@@ -12,7 +12,7 @@ use prometheus_client::{
 };
 
 use crate::{
-    protocol::{InitiatorMessage, ResponderMessage},
+    protocol::{InitiatorMessage, ReconMessage, ResponderMessage},
     AssociativeHash, Key,
 };
 
@@ -36,12 +36,12 @@ pub struct Metrics {
 
 #[derive(Clone, Debug, Hash, PartialEq, Eq, EncodeLabelSet)]
 pub(crate) struct MessageLabels {
-    message_type: &'static str,
+    pub(crate) message_type: &'static str,
 }
 
-impl<K: Key, H: AssociativeHash> From<&InitiatorMessage<K, H>> for MessageLabels {
-    fn from(value: &InitiatorMessage<K, H>) -> Self {
-        match value {
+impl<K: Key, H: AssociativeHash> From<&ReconMessage<InitiatorMessage<K, H>>> for MessageLabels {
+    fn from(value: &ReconMessage<InitiatorMessage<K, H>>) -> Self {
+        match value.body {
             InitiatorMessage::ValueRequest(_) => Self {
                 message_type: "ValueRequest",
             },
@@ -64,9 +64,9 @@ impl<K: Key, H: AssociativeHash> From<&InitiatorMessage<K, H>> for MessageLabels
     }
 }
 
-impl<K: Key, H: AssociativeHash> From<&ResponderMessage<K, H>> for MessageLabels {
-    fn from(value: &ResponderMessage<K, H>) -> Self {
-        match value {
+impl<K: Key, H: AssociativeHash> From<&ReconMessage<ResponderMessage<K, H>>> for MessageLabels {
+    fn from(value: &ReconMessage<ResponderMessage<K, H>>) -> Self {
+        match value.body {
             ResponderMessage::ValueRequest(_) => Self {
                 message_type: "ValueRequest",
             },