Add server version validation during module loading

Signed-off-by: VanessaTang <[email protected]>

Author: YueTang-Vanessa

src/configs.rs

@@ -30,6 +30,11 @@ pub const BLOOM_USE_RANDOM_SEED_DEFAULT: bool = true;
 
 pub const BLOOM_DEFRAG_DEAFULT: bool = true;
 
+/// Minimal Valkey version that supports Bloom Module
+pub const BLOOM_MIN_MAJOR_VERSION: i64 = 8;
+pub const BLOOM_MIN_MINOR_VERSION: i64 = 0;
+pub const BLOOM_MIN_PATCH_VERSION: i64 = 0;
+
 // Max Memory usage allowed overall within a bloom object (128MB).
 // Beyond this threshold, a bloom object is classified as large.
 // Write operations that result in bloom object allocation larger than this size will be rejected.

src/lib.rs

@@ -9,12 +9,29 @@ pub mod metrics;
 pub mod wrapper;
 use crate::bloom::command_handler;
 use crate::bloom::data_type::BLOOM_TYPE;
+use configs::{BLOOM_MIN_MAJOR_VERSION, BLOOM_MIN_MINOR_VERSION, BLOOM_MIN_PATCH_VERSION};
 use valkey_module_macros::info_command_handler;
 
 pub const MODULE_NAME: &str = "bf";
 
-fn initialize(_ctx: &Context, _args: &[ValkeyString]) -> Status {
-    Status::Ok
+fn initialize(ctx: &Context, _args: &[ValkeyString]) -> Status {
+    let ver = ctx
+        .get_redis_version()
+        .expect("Unable to get server version!");
+    let server_version: Vec<i64> = vec![ver.major.into(), ver.minor.into(), ver.patch.into()];
+    let min_support_version: Vec<i64> = vec![
+        BLOOM_MIN_MAJOR_VERSION,
+        BLOOM_MIN_MINOR_VERSION,
+        BLOOM_MIN_PATCH_VERSION,
+    ];
+    if server_version < min_support_version {
+        ctx.log_warning(
+            "Current server version doesn't satisfy minimal required version for bloom module!",
+        );
+        Status::Err
+    } else {
+        Status::Ok
+    }
 }
 
 fn deinitialize(_ctx: &Context) -> Status {