Adapt tests to the community edition

Author: Nao-ris

tests/database_tests.rs

@@ -48,6 +48,7 @@ fn delete_file() {
     let tmp_dir = TempDir::new("cbl_rust").expect("create temp dir");
     let cfg = DatabaseConfiguration {
         directory: tmp_dir.path(),
+        #[cfg(feature = "enterprise")]
         encryption_key: None,
     };
     if let Err(_) = Database::open(DB_NAME, Some(cfg)) {
@@ -70,6 +71,7 @@ fn copy_file() {
     let tmp_dir = TempDir::new("cbl_rust").expect("create temp dir");
     let cfg = DatabaseConfiguration {
         directory: tmp_dir.path(),
+        #[cfg(feature = "enterprise")]
         encryption_key: None,
     };
     match Database::open(DB_NAME, Some(cfg.clone())) {
@@ -143,16 +145,19 @@ fn db_properties() {
 }
 
 #[test]
+#[cfg(feature = "enterprise")]
 fn db_encryption_key() {
     let tmp_dir = TempDir::new("cbl_rust").expect("create temp dir");
     let cfg_no_encryption = DatabaseConfiguration {
         directory: tmp_dir.path(),
+        #[cfg(feature = "enterprise")]
         encryption_key: None,
     };
     let encryption_key =
         EncryptionKey::new_from_password(EncryptionAlgorithm::None, "password1").unwrap();
     let cfg_encryption1 = DatabaseConfiguration {
         directory: tmp_dir.path(),
+        #[cfg(feature = "enterprise")]
         encryption_key: Some(encryption_key.clone()),
     };
 

tests/document_tests.rs

@@ -234,6 +234,7 @@ fn database_add_document_change_listener() {
 }
 
 #[test]
+#[cfg(feature = "enterprise")]
 fn database_delete_document() {
     let (sender, receiver) = std::sync::mpsc::channel();
 

tests/replicator_tests.rs

@@ -17,15 +17,19 @@
 
 extern crate couchbase_lite;
 
+#[cfg(feature = "enterprise")]
 use self::couchbase_lite::*;
+#[cfg(feature = "enterprise")]
 use encryptable::Encryptable;
+#[cfg(feature = "enterprise")]
 use std::{time::Duration, thread};
 
 pub mod utils;
 
 //////// TESTS:
 
 #[test]
+#[cfg(feature = "enterprise")]
 fn push_replication() {
     let mut tester = utils::ReplicationTwoDbsTester::new(
         utils::ReplicationTestConfiguration::default(),
@@ -45,6 +49,7 @@ fn push_replication() {
 }
 
 #[test]
+#[cfg(feature = "enterprise")]
 fn pull_replication() {
     let mut tester = utils::ReplicationTwoDbsTester::new(
         utils::ReplicationTestConfiguration::default(),
@@ -64,6 +69,7 @@ fn pull_replication() {
 }
 
 #[test]
+#[cfg(feature = "enterprise")]
 fn push_pull_replication() {
     let mut tester = utils::ReplicationThreeDbsTester::new(
         utils::ReplicationTestConfiguration::default(),
@@ -91,6 +97,7 @@ fn push_pull_replication() {
 }
 
 #[test]
+#[cfg(feature = "enterprise")]
 fn pull_type_not_pushing() {
     let config = utils::ReplicationTestConfiguration {
         replicator_type: ReplicatorType::Pull,
@@ -115,6 +122,7 @@ fn pull_type_not_pushing() {
 }
 
 #[test]
+#[cfg(feature = "enterprise")]
 fn push_type_not_pulling() {
     let config = utils::ReplicationTestConfiguration {
         replicator_type: ReplicatorType::Push,
@@ -139,6 +147,7 @@ fn push_type_not_pulling() {
 }
 
 #[test]
+#[cfg(feature = "enterprise")]
 fn document_ids() {
     let mut document_ids = MutableArray::new();
     document_ids.append().put_string("foo");
@@ -172,6 +181,7 @@ fn document_ids() {
 }
 
 #[test]
+#[cfg(feature = "enterprise")]
 fn push_and_pull_filter() {
     let context1 = ReplicationConfigurationContext {
         push_filter: Some(Box::new(|document, _is_deleted, _is_access_removed| {
@@ -227,6 +237,7 @@ fn push_and_pull_filter() {
 }
 
 #[test]
+#[cfg(feature = "enterprise")]
 fn conflict_resolver() {
     let (sender, receiver) = std::sync::mpsc::channel();
 
@@ -316,6 +327,7 @@ fn conflict_resolver() {
 }
 
 #[test]
+#[cfg(feature = "enterprise")]
 fn conflict_resolver_save_keep_local() {
     let mut tester = utils::ReplicationTwoDbsTester::new(
         utils::ReplicationTestConfiguration::default(),
@@ -397,6 +409,7 @@ fn conflict_resolver_save_keep_local() {
 }
 
 #[test]
+#[cfg(feature = "enterprise")]
 fn conflict_resolver_save_keep_remote() {
     let mut tester = utils::ReplicationTwoDbsTester::new(
         utils::ReplicationTestConfiguration::default(),
@@ -479,6 +492,7 @@ fn conflict_resolver_save_keep_remote() {
 
 // Encryption/Decryption
 
+#[cfg(feature = "enterprise")]
 fn encryptor(
     _document_id: Option<String>,
     _properties: Dict,
@@ -490,6 +504,7 @@ fn encryptor(
 ) -> std::result::Result<Vec<u8>, EncryptionError> {
     Ok(input.iter().map(|u| u ^ 48).collect())
 }
+#[cfg(feature = "enterprise")]
 fn decryptor(
     _document_id: Option<String>,
     _properties: Dict,
@@ -501,6 +516,7 @@ fn decryptor(
 ) -> std::result::Result<Vec<u8>, EncryptionError> {
     Ok(input.iter().map(|u| u ^ 48).collect())
 }
+#[cfg(feature = "enterprise")]
 fn encryptor_err_temporary(
     _document_id: Option<String>,
     _properties: Dict,
@@ -512,6 +528,7 @@ fn encryptor_err_temporary(
 ) -> std::result::Result<Vec<u8>, EncryptionError> {
     Err(EncryptionError::Temporary)
 }
+#[cfg(feature = "enterprise")]
 fn decryptor_err_temporary(
     _document_id: Option<String>,
     _properties: Dict,
@@ -523,6 +540,7 @@ fn decryptor_err_temporary(
 ) -> std::result::Result<Vec<u8>, EncryptionError> {
     Err(EncryptionError::Temporary)
 }
+#[cfg(feature = "enterprise")]
 fn encryptor_err_permanent(
     _document_id: Option<String>,
     _properties: Dict,
@@ -534,6 +552,7 @@ fn encryptor_err_permanent(
 ) -> std::result::Result<Vec<u8>, EncryptionError> {
     Err(EncryptionError::Permanent)
 }
+#[cfg(feature = "enterprise")]
 fn decryptor_err_permanent(
     _document_id: Option<String>,
     _properties: Dict,
@@ -547,6 +566,7 @@ fn decryptor_err_permanent(
 }
 
 #[test]
+#[cfg(feature = "enterprise")]
 fn encryption_ok_decryption_ok() {
     let context1 = ReplicationConfigurationContext {
         default_collection_property_encryptor: Some(encryptor),
@@ -612,6 +632,7 @@ fn encryption_ok_decryption_ok() {
 }
 
 #[test]
+#[cfg(feature = "enterprise")]
 fn encryption_error_temporary() {
     let config = utils::ReplicationTestConfiguration {
         continuous: false,
@@ -674,6 +695,7 @@ fn encryption_error_temporary() {
 }
 
 #[test]
+#[cfg(feature = "enterprise")]
 fn decryption_error_temporary() {
     let config = utils::ReplicationTestConfiguration {
         continuous: false,
@@ -736,6 +758,7 @@ fn decryption_error_temporary() {
 }
 
 #[test]
+#[cfg(feature = "enterprise")]
 fn encryption_error_permanent() {
     let config = utils::ReplicationTestConfiguration {
         continuous: false,
@@ -818,6 +841,7 @@ fn encryption_error_permanent() {
 }
 
 #[test]
+#[cfg(feature = "enterprise")]
 fn decryption_error_permanent() {
     let config = utils::ReplicationTestConfiguration {
         continuous: false,
@@ -904,6 +928,7 @@ mod unsafe_test {
     use super::*;
 
     #[test]
+    #[cfg(feature = "enterprise")]
     fn continuous() {
         let config = utils::ReplicationTestConfiguration {
             continuous: false,

tests/utils.rs

@@ -5,10 +5,11 @@ use self::couchbase_lite::*;
 use self::tempdir::TempDir;
 
 use std::{
-    collections::HashMap,
     sync::{Arc, Mutex, MutexGuard},
     thread, time,
 };
+#[cfg(feature = "enterprise")]
+use std::collections::HashMap;
 
 // Enables check for leaks of native CBL objects after `with_db()` finishes.
 // WARNING: These checks only work if one test method runs at a time, i.e. testing is single
@@ -46,6 +47,7 @@ where
     let tmp_dir = TempDir::new("cbl_rust").expect("create temp dir");
     let cfg = DatabaseConfiguration {
         directory: tmp_dir.path(),
+        #[cfg(feature = "enterprise")]
         encryption_key: None,
     };
     let mut db = Database::open(DB_NAME, Some(cfg)).expect("open db");
@@ -90,6 +92,7 @@ impl Default for ReplicationTestConfiguration {
     }
 }
 
+#[cfg(feature = "enterprise")]
 fn generate_replication_configuration(
     local_db: &Database,
     central_db: &Database,
@@ -116,6 +119,7 @@ fn generate_replication_configuration(
     }
 }
 
+#[cfg(feature = "enterprise")]
 pub struct ReplicationTwoDbsTester {
     _tmp_dir: TempDir,
     pub local_database: Database,
@@ -124,6 +128,7 @@ pub struct ReplicationTwoDbsTester {
     replicator_continuous: bool,
 }
 
+#[cfg(feature = "enterprise")]
 impl ReplicationTwoDbsTester {
     pub fn new(
         replication_configuration: ReplicationTestConfiguration,
@@ -227,6 +232,7 @@ impl ReplicationTwoDbsTester {
     }
 }
 
+#[cfg(feature = "enterprise")]
 impl Drop for ReplicationTwoDbsTester {
     fn drop(&mut self) {
         self.stop_replicator();
@@ -236,6 +242,7 @@ impl Drop for ReplicationTwoDbsTester {
     }
 }
 
+#[cfg(feature = "enterprise")]
 pub struct ReplicationThreeDbsTester {
     _tmp_dir: TempDir,
     local_database_1: Database,
@@ -247,6 +254,7 @@ pub struct ReplicationThreeDbsTester {
     replicator_2_continuous: bool,
 }
 
+#[cfg(feature = "enterprise")]
 impl ReplicationThreeDbsTester {
     pub fn new(
         replication_configuration_1: ReplicationTestConfiguration,
@@ -408,6 +416,7 @@ impl ReplicationThreeDbsTester {
     }
 }
 
+#[cfg(feature = "enterprise")]
 impl Drop for ReplicationThreeDbsTester {
     fn drop(&mut self) {
         self.stop_replicators();