fix: semver check added for redis version

Cargo.toml

@@ -10,7 +10,7 @@ members = [
 resolver = "2"
 
 [workspace.package]
-version = '0.8.3'
+version = '0.8.4'
 edition = "2021"
 authors = ["Glenn Gore <[email protected]>"]
 description = "Affinidi Messaging"
@@ -105,3 +105,4 @@ tui-logger = { version = "0.14", features = ["tracing-support"] }
 url = "2.5"
 uuid = { version = "1.11", features = ["v4", "fast-rng"] }
 varint = "0.9"
+semver = "1.0.24"

affinidi-messaging-mediator/Cargo.toml

@@ -49,6 +49,7 @@ tower-http.workspace = true
 tracing.workspace = true
 tracing-subscriber.workspace = true
 uuid.workspace = true
+semver.workspace = true
 
 [dev-dependencies]
 console.workspace = true

affinidi-messaging-mediator/src/database/handlers.rs

@@ -2,10 +2,11 @@ use super::DatabaseHandler;
 use crate::common::{config::Config, errors::MediatorError};
 use deadpool_redis::Connection;
 use redis::aio::PubSub;
+use semver::{Version, VersionReq};
 use std::{fs::read_to_string, thread::sleep, time::Duration};
 use tracing::{error, event, info, Level};
 
-const REDIS_VERSION: &str = "7.2"; // required Redis version
+const REDIS_VERSION_REQ: &str = ">=7.2, <8.0";
 
 impl DatabaseHandler {
     pub async fn new(config: &Config) -> Result<Self, MediatorError> {
@@ -156,19 +157,21 @@ async fn _check_server_version(database: &DatabaseHandler) -> Result<String, Med
         .next();
 
     if let Some(version) = server_version {
-        if version.starts_with(REDIS_VERSION) {
+        let semver_version = Version::parse(&version).unwrap();
+        let redis_version_req: VersionReq = VersionReq::parse(REDIS_VERSION_REQ).unwrap();
+        if redis_version_req.matches(&semver_version) {
             info!("Redis version is compatible: {}", version);
             Ok(version.to_owned())
         } else {
             error!(
-                "Redis version ({}) must be equal to major.minor: ({})",
-                version, REDIS_VERSION
+                "Redis version ({}) must match ({})",
+                version, REDIS_VERSION_REQ
             );
             Err(MediatorError::DatabaseError(
                 "NA".into(),
                 format!(
-                    "Redis version ({}) must be equal to major.minor: ({})",
-                    version, REDIS_VERSION
+                    "Redis version ({}) must match ({})",
+                    version, REDIS_VERSION_REQ
                 ),
             ))
         }