feat(metric): add forest version to prometheus (#4535)

src/metrics/mod.rs

@@ -53,7 +53,9 @@ where
         warn!("Failed to register process metrics: {err}");
     }
 
-    // Add the DBCollector to the registry
+    DEFAULT_REGISTRY.write().register_collector(Box::new(
+        crate::utils::version::ForestVersionCollector::new(),
+    ));
     DEFAULT_REGISTRY
         .write()
         .register_collector(Box::new(crate::metrics::db::DBCollector::new(db_directory)));

src/utils/version/mod.rs

@@ -3,6 +3,11 @@
 
 use git_version::git_version;
 use once_cell::sync::Lazy;
+use prometheus_client::{
+    collector::Collector,
+    encoding::{DescriptorEncoder, EncodeMetric},
+    metrics::info::Info,
+};
 
 /// Current git commit hash of the Forest repository.
 pub const GIT_HASH: &str =
@@ -15,3 +20,28 @@ pub static FOREST_VERSION_STRING: Lazy<String> =
 
 pub static FOREST_VERSION: Lazy<semver::Version> =
     Lazy::new(|| semver::Version::parse(env!("CARGO_PKG_VERSION")).expect("Invalid version"));
+
+#[derive(Debug)]
+pub struct ForestVersionCollector {
+    version: Info<Vec<(&'static str, &'static str)>>,
+}
+
+impl ForestVersionCollector {
+    pub fn new() -> Self {
+        let version = Info::new(vec![("version", FOREST_VERSION_STRING.as_str())]);
+        Self { version }
+    }
+}
+
+impl Collector for ForestVersionCollector {
+    fn encode(&self, mut encoder: DescriptorEncoder) -> Result<(), std::fmt::Error> {
+        let metric_encoder = encoder.encode_descriptor(
+            "forest_version",
+            "semantic version of the forest binary",
+            None,
+            self.version.metric_type(),
+        )?;
+        self.version.encode(metric_encoder)?;
+        Ok(())
+    }
+}