feat(drive)!: multiple IN clauses on consecutive index properties in document queries

packages/rs-drive-abci/src/execution/platform_events/fee_pool_outwards_distribution/fetch_reward_shares_list_for_masternode/v0/mod.rs

@@ -47,7 +47,7 @@ impl<C> Platform<C> {
             internal_clauses: InternalClauses {
                 primary_key_in_clause: None,
                 primary_key_equal_clause: None,
-                in_clause: None,
+                in_clauses: Vec::new(),
                 range_clause: None,
                 equal_clauses: BTreeMap::from([(
                     "$ownerId".to_string(),

packages/rs-drive-abci/src/execution/platform_events/protocol_upgrade/perform_events_on_first_block_of_protocol_change/v0/mod.rs

@@ -1327,6 +1327,7 @@ mod tests {
             "select * from profile",
             &dashpay_v2_fetch_info.contract,
             Some(&platform.config.drive),
+            PlatformVersion::get(14).expect("expected platform version 14"),
         )
         .expect("expected a document query");
         let query_results = platform

packages/rs-drive-abci/src/execution/validation/state_transition/state_transitions/batch/data_triggers/triggers/dpns/v0/mod.rs

@@ -221,7 +221,7 @@ pub(super) fn create_domain_data_trigger_v0(
             internal_clauses: InternalClauses {
                 primary_key_in_clause: None,
                 primary_key_equal_clause: None,
-                in_clause: None,
+                in_clauses: Vec::new(),
                 range_clause: None,
                 equal_clauses: BTreeMap::from([
                     (
@@ -322,7 +322,7 @@ pub(super) fn create_domain_data_trigger_v0(
         internal_clauses: InternalClauses {
             primary_key_in_clause: None,
             primary_key_equal_clause: None,
-            in_clause: None,
+            in_clauses: Vec::new(),
             range_clause: None,
             equal_clauses: BTreeMap::from([(
                 "saltedDomainHash".to_string(),

packages/rs-drive-abci/src/execution/validation/state_transition/state_transitions/batch/data_triggers/triggers/dpns/v1/mod.rs

@@ -214,7 +214,7 @@ pub(super) fn create_domain_data_trigger_v1(
             internal_clauses: InternalClauses {
                 primary_key_in_clause: None,
                 primary_key_equal_clause: None,
-                in_clause: None,
+                in_clauses: Vec::new(),
                 range_clause: None,
                 equal_clauses: BTreeMap::from([
                     (
@@ -337,7 +337,7 @@ pub(super) fn create_domain_data_trigger_v1(
         internal_clauses: InternalClauses {
             primary_key_in_clause: None,
             primary_key_equal_clause: None,
-            in_clause: None,
+            in_clauses: Vec::new(),
             range_clause: None,
             equal_clauses: BTreeMap::from([(
                 "saltedDomainHash".to_string(),

packages/rs-drive-abci/src/execution/validation/state_transition/state_transitions/batch/data_triggers/triggers/withdrawals/v0/mod.rs

@@ -67,7 +67,7 @@ pub(super) fn delete_withdrawal_data_trigger_v0(
                 operator: WhereOperator::Equal,
                 value: Value::Identifier(dt_delete.base().id().to_buffer()),
             }),
-            in_clause: None,
+            in_clauses: Vec::new(),
             range_clause: None,
             equal_clauses: BTreeMap::default(),
         },

packages/rs-drive-abci/src/execution/validation/state_transition/state_transitions/batch/data_triggers/triggers/withdrawals/v1/mod.rs

@@ -61,7 +61,7 @@ pub(super) fn delete_withdrawal_data_trigger_v1(
                 operator: WhereOperator::Equal,
                 value: Value::Identifier(dt_delete.base().id().to_buffer()),
             }),
-            in_clause: None,
+            in_clauses: Vec::new(),
             range_clause: None,
             equal_clauses: BTreeMap::default(),
         },

packages/rs-drive-abci/src/execution/validation/state_transition/state_transitions/batch/state/v0/fetch_documents.rs

@@ -112,7 +112,7 @@ fn fetch_documents_for_transitions_knowing_contract_and_document_type_v0(
                 value: Value::Array(ids),
             }),
             primary_key_equal_clause: None,
-            in_clause: None,
+            in_clauses: Vec::new(),
             range_clause: None,
             equal_clauses: Default::default(),
         },
@@ -172,7 +172,7 @@ fn fetch_documents_for_transitions_knowing_contract_and_document_type_v1(
                 value: Value::Array(ids),
             }),
             primary_key_equal_clause: None,
-            in_clause: None,
+            in_clauses: Vec::new(),
             range_clause: None,
             equal_clauses: Default::default(),
         },
@@ -297,7 +297,7 @@ fn fetch_document_with_id_v0(
                 operator: WhereOperator::Equal,
                 value: Value::Identifier(id.to_buffer()),
             }),
-            in_clause: None,
+            in_clauses: Vec::new(),
             range_clause: None,
             equal_clauses: Default::default(),
         },
@@ -359,7 +359,7 @@ fn fetch_document_with_id_v1(
                 operator: WhereOperator::Equal,
                 value: Value::Identifier(id.to_buffer()),
             }),
-            in_clause: None,
+            in_clauses: Vec::new(),
             range_clause: None,
             equal_clauses: Default::default(),
         },

packages/rs-drive-abci/src/execution/validation/state_transition/state_transitions/batch/tests/document/dpns.rs

@@ -442,7 +442,7 @@ mod dpns_tests {
             internal_clauses: InternalClauses {
                 primary_key_in_clause: None,
                 primary_key_equal_clause: None,
-                in_clause: None,
+                in_clauses: Vec::new(),
                 range_clause: Some(WhereClause {
                     field: "records.identity".to_string(),
                     operator: WhereOperator::LessThanOrEquals,
@@ -486,7 +486,7 @@ mod dpns_tests {
             internal_clauses: InternalClauses {
                 primary_key_in_clause: None,
                 primary_key_equal_clause: None,
-                in_clause: None,
+                in_clauses: Vec::new(),
                 range_clause: None,
                 equal_clauses: BTreeMap::from([(
                     "records.identity".to_string(),
@@ -897,7 +897,7 @@ mod dpns_tests {
             internal_clauses: InternalClauses {
                 primary_key_in_clause: None,
                 primary_key_equal_clause: None,
-                in_clause: None,
+                in_clauses: Vec::new(),
                 range_clause: Some(WhereClause {
                     field: "records.identity".to_string(),
                     operator: WhereOperator::LessThanOrEquals,
@@ -928,7 +928,7 @@ mod dpns_tests {
             internal_clauses: InternalClauses {
                 primary_key_in_clause: None,
                 primary_key_equal_clause: None,
-                in_clause: None,
+                in_clauses: Vec::new(),
                 range_clause: None,
                 equal_clauses: BTreeMap::from([(
                     "records.identity".to_string(),
@@ -1161,7 +1161,7 @@ mod dpns_username_transfer_tests {
             internal_clauses: InternalClauses {
                 primary_key_in_clause: None,
                 primary_key_equal_clause: None,
-                in_clause: None,
+                in_clauses: Vec::new(),
                 range_clause: None,
                 equal_clauses: BTreeMap::from([(
                     "records.identity".to_string(),
@@ -1399,7 +1399,7 @@ mod dpns_username_transfer_tests {
             internal_clauses: InternalClauses {
                 primary_key_in_clause: None,
                 primary_key_equal_clause: None,
-                in_clause: None,
+                in_clauses: Vec::new(),
                 range_clause: None,
                 equal_clauses: BTreeMap::from([
                     (

packages/rs-drive-abci/src/execution/validation/state_transition/state_transitions/batch/tests/document/nft.rs

@@ -92,6 +92,7 @@ mod nft_tests {
             sender_documents_sql_string.as_str(),
             &contract,
             Some(&platform.config.drive),
+            platform_version,
         )
         .expect("expected document query");
 
@@ -275,6 +276,7 @@ mod nft_tests {
             sender_documents_sql_string.as_str(),
             &contract,
             Some(&platform.config.drive),
+            platform_version,
         )
         .expect("expected document query");
 
@@ -285,6 +287,7 @@ mod nft_tests {
             receiver_documents_sql_string.as_str(),
             &contract,
             Some(&platform.config.drive),
+            platform_version,
         )
         .expect("expected document query");
 
@@ -552,6 +555,7 @@ mod nft_tests {
             sender_documents_sql_string.as_str(),
             &contract,
             Some(&platform.config.drive),
+            platform_version,
         )
         .expect("expected document query");
 
@@ -562,6 +566,7 @@ mod nft_tests {
             receiver_documents_sql_string.as_str(),
             &contract,
             Some(&platform.config.drive),
+            platform_version,
         )
         .expect("expected document query");
 
@@ -993,6 +998,7 @@ mod nft_tests {
             sender_documents_sql_string.as_str(),
             &contract,
             Some(&platform.config.drive),
+            platform_version,
         )
         .expect("expected document query");
 
@@ -1003,6 +1009,7 @@ mod nft_tests {
             receiver_documents_sql_string.as_str(),
             &contract,
             Some(&platform.config.drive),
+            platform_version,
         )
         .expect("expected document query");
 
@@ -1553,6 +1560,7 @@ mod nft_tests {
             sender_documents_sql_string.as_str(),
             &contract,
             Some(&platform.config.drive),
+            platform_version,
         )
         .expect("expected document query");
 
@@ -1563,6 +1571,7 @@ mod nft_tests {
             receiver_documents_sql_string.as_str(),
             &contract,
             Some(&platform.config.drive),
+            platform_version,
         )
         .expect("expected document query");
 
@@ -2459,6 +2468,7 @@ mod nft_tests {
             sender_documents_sql_string.as_str(),
             &contract,
             Some(&platform.config.drive),
+            platform_version,
         )
         .expect("expected document query");
 
@@ -2469,6 +2479,7 @@ mod nft_tests {
             receiver_documents_sql_string.as_str(),
             &contract,
             Some(&platform.config.drive),
+            platform_version,
         )
         .expect("expected document query");
 
@@ -2713,6 +2724,7 @@ mod nft_tests {
             sender_documents_sql_string.as_str(),
             &contract,
             Some(&platform.config.drive),
+            platform_version,
         )
         .expect("expected document query");
 
@@ -2723,6 +2735,7 @@ mod nft_tests {
             receiver_documents_sql_string.as_str(),
             &contract,
             Some(&platform.config.drive),
+            platform_version,
         )
         .expect("expected document query");
 
@@ -3091,6 +3104,7 @@ mod nft_tests {
             sender_documents_sql_string.as_str(),
             &contract,
             Some(&platform.config.drive),
+            platform_version,
         )
         .expect("expected document query");
 
@@ -3256,6 +3270,7 @@ mod nft_tests {
             sender_documents_sql_string.as_str(),
             &contract,
             Some(&platform.config.drive),
+            platform_version,
         )
         .expect("expected document query");
 
@@ -3266,6 +3281,7 @@ mod nft_tests {
             receiver_documents_sql_string.as_str(),
             &contract,
             Some(&platform.config.drive),
+            platform_version,
         )
         .expect("expected document query");
 
@@ -3792,6 +3808,7 @@ mod nft_tests {
             buyer_documents_sql_string.as_str(),
             &contract,
             Some(&platform.config.drive),
+            platform_version,
         )
         .expect("expected document query");
 
@@ -4006,6 +4023,7 @@ mod nft_tests {
             creator_documents_sql_string.as_str(),
             &contract,
             Some(&platform.config.drive),
+            platform_version,
         )
         .expect("expected document query");
 
@@ -4024,6 +4042,7 @@ mod nft_tests {
             creator_id_documents_sql_string.as_str(),
             &contract,
             Some(&platform.config.drive),
+            platform_version,
         )
         .expect("expected document query");
 
@@ -4625,6 +4644,7 @@ mod nft_tests {
             buyer1_documents_sql_string.as_str(),
             &contract,
             Some(&platform.config.drive),
+            platform_version,
         )
         .expect("expected document query");
 
@@ -4642,6 +4662,7 @@ mod nft_tests {
             buyer2_documents_sql_string.as_str(),
             &contract,
             Some(&platform.config.drive),
+            platform_version,
         )
         .expect("expected document query");
 

packages/rs-drive-abci/src/execution/validation/state_transition/state_transitions/batch/tests/document/replacement.rs

@@ -1402,6 +1402,7 @@ mod replacement_tests {
             sender_documents_sql_string.as_str(),
             &contract,
             Some(&platform.config.drive),
+            platform_version,
         )
         .expect("expected document query");
 
@@ -1412,6 +1413,7 @@ mod replacement_tests {
             receiver_documents_sql_string.as_str(),
             &contract,
             Some(&platform.config.drive),
+            platform_version,
         )
         .expect("expected document query");
 
@@ -1765,6 +1767,7 @@ mod replacement_tests {
             receiver_documents_sql_string.as_str(),
             &dashpay,
             Some(&platform.config.drive),
+            platform_version,
         )
         .expect("expected document query");
 
@@ -1988,6 +1991,7 @@ mod replacement_tests {
             receiver_documents_sql_string.as_str(),
             &dashpay,
             Some(&platform.config.drive),
+            platform_version,
         )
         .expect("expected document query");
 
@@ -2252,6 +2256,7 @@ mod replacement_tests {
             receiver_documents_sql_string.as_str(),
             &dashpay,
             Some(&platform.config.drive),
+            platform_version,
         )
         .expect("expected document query");
 
@@ -2520,6 +2525,7 @@ mod replacement_tests {
             receiver_documents_sql_string.as_str(),
             &dashpay,
             Some(&platform.config.drive),
+            platform_version,
         )
         .expect("expected document query");