Make it possible to skip some tests when running on 3.13

some feature flags and exchange types won't be available
there, for instance.

Author: michaelklishin

src/api.rs

@@ -13,23 +13,14 @@
 // limitations under the License.
 #![allow(clippy::result_large_err)]
 
-use backtrace::Backtrace;
-use reqwest::{
-    header::{HeaderMap, HeaderValue},
-    Client as HttpClient, StatusCode,
-};
-use serde::Serialize;
-use serde_json::{json, Map, Value};
-use std::fmt;
-
 use crate::error::Error;
 use crate::error::Error::{ClientErrorResponse, NotFound, ServerErrorResponse};
 use crate::requests::{
     Amqp091ShovelParams, Amqp10ShovelParams, EmptyPayload, StreamParams, SHOVEL_COMPONENT,
 };
 use crate::responses::{
     DeprecatedFeatureList, FeatureFlag, FeatureFlagList, FeatureFlagStability, FeatureFlagState,
-    GetMessage, OAuthConfiguration, SchemaDefinitionSyncStatus, VirtualHostDefinitionSet,
+    GetMessage, OAuthConfiguration, Overview, SchemaDefinitionSyncStatus, VirtualHostDefinitionSet,
     WarmStandbyReplicationStatus,
 };
 use crate::{
@@ -41,6 +32,14 @@ use crate::{
     },
     responses::{self, BindingInfo, ClusterDefinitionSet},
 };
+use backtrace::Backtrace;
+use reqwest::{
+    header::{HeaderMap, HeaderValue},
+    Client as HttpClient, StatusCode,
+};
+use serde::Serialize;
+use serde_json::{json, Map, Value};
+use std::fmt;
 
 pub type HttpClientResponse = reqwest::Response;
 pub type HttpClientError = crate::error::HttpClientError;
@@ -1456,6 +1455,13 @@ where
         Ok(response)
     }
 
+    pub async fn server_version(&self) -> Result<String> {
+        let response = self.http_get("overview", None, None).await?;
+        let response: Overview = response.json().await?;
+
+        Ok(response.rabbitmq_version)
+    }
+
     //
     // Feature flags
     //

src/blocking_api.rs

@@ -1283,6 +1283,12 @@ where
         Ok(response)
     }
 
+    pub fn server_version(&self) -> Result<String> {
+        let response = self.http_get("overview", None, None)?;
+        let response: responses::Overview = response.json()?;
+        Ok(response.rabbitmq_version)
+    }
+
     //
     // Feature flags
     //

tests/async_deprecated_feature_tests.rs

@@ -15,7 +15,7 @@ use rabbitmq_http_client::responses::DeprecationPhase;
 use rabbitmq_http_client::{api::Client, commons::QueueType, requests::QueueParams};
 
 mod test_helpers;
-use crate::test_helpers::{endpoint, PASSWORD, USERNAME};
+use crate::test_helpers::{async_testing_against_3_13_x, endpoint, PASSWORD, USERNAME};
 
 #[tokio::test]
 async fn test_async_list_all_deprecated_features() {
@@ -35,6 +35,11 @@ async fn test_async_list_all_deprecated_features() {
 async fn test_async_list_deprecated_features_in_use() {
     let endpoint = endpoint();
     let rc = Client::new(&endpoint, USERNAME, PASSWORD);
+
+    if async_testing_against_3_13_x().await {
+        return;
+    }
+
     let vh = "/";
     let q = "test_list_deprecated_features_in_use";
 

tests/async_dynamic_shovel_tests.rs

@@ -20,14 +20,19 @@ use rabbitmq_http_client::{api::Client, requests::VirtualHostParams};
 
 mod test_helpers;
 use crate::test_helpers::{
-    amqp_endpoint_with_vhost, await_metric_emission, endpoint, PASSWORD, USERNAME,
+    amqp_endpoint_with_vhost, async_testing_against_3_13_x, await_metric_emission, endpoint,
+    PASSWORD, USERNAME,
 };
 
 #[tokio::test]
 async fn test_async_declare_a_dynamic_amqp091_shovel() {
     let endpoint = endpoint();
     let rc = Client::new(&endpoint, USERNAME, PASSWORD);
 
+    if async_testing_against_3_13_x().await {
+        return;
+    }
+
     let vh = "rust.http.api.async.test_declare_a_dynamic_amqp091_shovel";
     let sh = "test_declare_a_dynamic_amqp091_shovel";
 
@@ -62,6 +67,10 @@ async fn test_async_declare_a_dynamic_amqp10_shovel() {
     let endpoint = endpoint();
     let rc = Client::new(&endpoint, USERNAME, PASSWORD);
 
+    if async_testing_against_3_13_x().await {
+        return;
+    }
+
     let vh = "rust.http.api.async.test_async_declare_a_dynamic_amqp10_shovel";
     let sh = "test_async_declare_a_dynamic_amqp10_shovel";
 
@@ -104,6 +113,10 @@ async fn test_async_declare_a_dynamic_amqp091_shovel_with_predeclared_source_top
     let endpoint = endpoint();
     let rc = Client::new(&endpoint, USERNAME, PASSWORD);
 
+    if async_testing_against_3_13_x().await {
+        return;
+    }
+
     let vh = "rust.http.api.blocking.test_declare_a_dynamic_amqp091_shovel_with_predeclared_source_topology";
     let sh = "test_declare_a_dynamic_amqp091_shovel_with_predeclared_source_topology";
 
@@ -142,6 +155,10 @@ async fn test_async_declare_a_dynamic_amqp091_shovel_with_predeclared_destinatio
     let endpoint = endpoint();
     let rc = Client::new(&endpoint, USERNAME, PASSWORD);
 
+    if async_testing_against_3_13_x().await {
+        return;
+    }
+
     let vh = "rust.http.api.blocking.test_declare_a_dynamic_amqp091_shovel_with_predeclared_destination_topology";
     let sh = "test_declare_a_dynamic_amqp091_shovel_with_predeclared_destination_topology";
 
@@ -183,6 +200,10 @@ async fn test_async_delete_a_dynamic_amqp091_shovel() {
     let endpoint = endpoint();
     let rc = Client::new(&endpoint, USERNAME, PASSWORD);
 
+    if async_testing_against_3_13_x().await {
+        return;
+    }
+
     let vh = "rust.http.api.async.test_delete_a_dynamic_amqp091_shovel";
     let sh = "test_delete_a_dynamic_amqp091_shovel";
 

tests/async_exchange_tests.rs

@@ -15,7 +15,7 @@ use rabbitmq_http_client::{api::Client, error::Error as APIClientError, requests
 use serde_json::{json, Map, Value};
 
 mod test_helpers;
-use crate::test_helpers::{endpoint, PASSWORD, USERNAME};
+use crate::test_helpers::{async_testing_against_3_13_x, endpoint, PASSWORD, USERNAME};
 
 use rabbitmq_http_client::commons::ExchangeType;
 
@@ -44,6 +44,10 @@ async fn test_async_declare_a_durable_headers_exchange() {
 
 #[tokio::test]
 async fn test_async_declare_a_durable_local_random_exchange() {
+    if async_testing_against_3_13_x().await {
+        return;
+    }
+
     test_async_declare_a_durable_exchange_of_type(
         "rust.tests.local-rnd.1",
         ExchangeType::LocalRandom,
@@ -53,6 +57,10 @@ async fn test_async_declare_a_durable_local_random_exchange() {
 
 #[tokio::test]
 async fn test_async_declare_a_durable_custom_exchange_type() {
+    if async_testing_against_3_13_x().await {
+        return;
+    }
+
     // This is a core type that's not in the AMQP 0-9-1 spec,
     // using it requiring additional plugins on the node
     test_async_declare_a_durable_exchange_of_type(

tests/async_feature_flag_tests.rs

@@ -17,14 +17,18 @@ use rabbitmq_http_client::{
 };
 
 mod test_helpers;
-use crate::test_helpers::{endpoint, PASSWORD, USERNAME};
+use crate::test_helpers::{async_testing_against_3_13_x, endpoint, PASSWORD, USERNAME};
 
 #[tokio::test]
 async fn test_async_list_feature_flags() {
     let endpoint = endpoint();
     let rc = Client::new(&endpoint, USERNAME, PASSWORD);
-    let result = rc.list_feature_flags().await;
 
+    if async_testing_against_3_13_x().await {
+        return;
+    }
+
+    let result = rc.list_feature_flags().await;
     assert!(result.is_ok());
     let vec = result.unwrap();
     assert!(vec
@@ -37,8 +41,12 @@ async fn test_async_list_feature_flags() {
 async fn test_async_enable_a_feature_flag() {
     let endpoint = endpoint();
     let rc = Client::new(&endpoint, USERNAME, PASSWORD);
-    let ff_name = "detailed_queues_endpoint";
 
+    if async_testing_against_3_13_x().await {
+        return;
+    }
+
+    let ff_name = "detailed_queues_endpoint";
     let result1 = rc.enable_feature_flag(ff_name).await;
     assert!(result1.is_ok());
 
@@ -56,8 +64,12 @@ async fn test_async_enable_a_feature_flag() {
 async fn test_async_enable_all_stable_feature_flags() {
     let endpoint = endpoint();
     let rc = Client::new(&endpoint, USERNAME, PASSWORD);
-    let ff_name = "rabbitmq_4.0.0";
 
+    if async_testing_against_3_13_x().await {
+        return;
+    }
+
+    let ff_name = "rabbitmq_4.0.0";
     let result1 = rc.enable_all_stable_feature_flags().await;
     assert!(result1.is_ok());
 

tests/blocking_deprecated_feature_tests.rs

@@ -15,7 +15,7 @@ use rabbitmq_http_client::responses::DeprecationPhase;
 use rabbitmq_http_client::{blocking_api::Client, commons::QueueType, requests::QueueParams};
 
 mod test_helpers;
-use crate::test_helpers::{endpoint, PASSWORD, USERNAME};
+use crate::test_helpers::{endpoint, testing_against_3_13_x, PASSWORD, USERNAME};
 
 #[test]
 fn test_blocking_list_all_deprecated_features() {
@@ -35,6 +35,11 @@ fn test_blocking_list_all_deprecated_features() {
 fn test_blocking_list_deprecated_features_in_use() {
     let endpoint = endpoint();
     let rc = Client::new(&endpoint, USERNAME, PASSWORD);
+
+    if testing_against_3_13_x() {
+        return;
+    }
+
     let vh = "/";
     let q = "test_list_deprecated_features_in_use";
 

tests/blocking_dynamic_shovel_tests.rs

@@ -20,14 +20,19 @@ use rabbitmq_http_client::{blocking_api::Client, requests::VirtualHostParams};
 
 mod test_helpers;
 use crate::test_helpers::{
-    amqp_endpoint_with_vhost, await_metric_emission, endpoint, PASSWORD, USERNAME,
+    amqp_endpoint_with_vhost, await_metric_emission, endpoint, testing_against_3_13_x, PASSWORD,
+    USERNAME,
 };
 
 #[test]
 fn test_blocking_declare_a_dynamic_amqp091_shovel() {
     let endpoint = endpoint();
     let rc = Client::new(&endpoint, USERNAME, PASSWORD);
 
+    if testing_against_3_13_x() {
+        return;
+    }
+
     let vh = "rust.http.api.blocking.test_declare_a_dynamic_amqp091_shovel";
     let sh = "test_declare_a_dynamic_amqp091_shovel";
 
@@ -62,6 +67,10 @@ fn test_blocking_declare_a_dynamic_amqp10_shovel() {
     let endpoint = endpoint();
     let rc = Client::new(&endpoint, USERNAME, PASSWORD);
 
+    if testing_against_3_13_x() {
+        return;
+    }
+
     let vh = "rust.http.api.blocking.test_blocking_declare_a_dynamic_amqp10_shovel";
     let sh = "test_async_declare_a_dynamic_amqp10_shovel";
 
@@ -104,6 +113,10 @@ fn test_blocking_declare_a_dynamic_amqp091_shovel_with_predeclared_source_topolo
     let endpoint = endpoint();
     let rc = Client::new(&endpoint, USERNAME, PASSWORD);
 
+    if testing_against_3_13_x() {
+        return;
+    }
+
     let vh = "rust.http.api.blocking.test_declare_a_dynamic_amqp091_shovel_with_predeclared_source_topology";
     let sh = "test_declare_a_dynamic_amqp091_shovel_with_predeclared_source_topology";
 
@@ -142,6 +155,10 @@ fn test_blocking_declare_a_dynamic_amqp091_shovel_with_predeclared_destination_t
     let endpoint = endpoint();
     let rc = Client::new(&endpoint, USERNAME, PASSWORD);
 
+    if testing_against_3_13_x() {
+        return;
+    }
+
     let vh = "rust.http.api.blocking.test_declare_a_dynamic_amqp091_shovel_with_predeclared_destination_topology";
     let sh = "test_declare_a_dynamic_amqp091_shovel_with_predeclared_destination_topology";
 
@@ -183,6 +200,10 @@ fn test_blocking_delete_a_dynamic_amqp091_shovel() {
     let endpoint = endpoint();
     let rc = Client::new(&endpoint, USERNAME, PASSWORD);
 
+    if testing_against_3_13_x() {
+        return;
+    }
+
     let vh = "rust.http.api.blocking.test_delete_a_dynamic_amqp091_shovel";
     let sh = "test_delete_a_dynamic_amqp091_shovel";
 

tests/blocking_exchange_tests.rs

@@ -17,7 +17,7 @@ use rabbitmq_http_client::{
 use serde_json::{json, Map, Value};
 
 mod test_helpers;
-use crate::test_helpers::{endpoint, PASSWORD, USERNAME};
+use crate::test_helpers::{endpoint, testing_against_3_13_x, PASSWORD, USERNAME};
 
 use rabbitmq_http_client::commons::ExchangeType;
 
@@ -43,11 +43,19 @@ fn test_blocking_declare_a_durable_headers_exchange() {
 
 #[test]
 fn test_blocking_declare_a_durable_local_random_exchange() {
+    if testing_against_3_13_x() {
+        return;
+    }
+
     test_declare_a_durable_exchange_of_type("rust.tests.local-rnd.1", ExchangeType::LocalRandom);
 }
 
 #[test]
 fn test_blocking_declare_a_durable_custom_exchange_type() {
+    if testing_against_3_13_x() {
+        return;
+    }
+
     // This is a core type that's not in the AMQP 0-9-1 spec,
     // using it requiring additional plugins on the node
     test_declare_a_durable_exchange_of_type(

tests/blocking_feature_flag_tests.rs

@@ -17,14 +17,18 @@ use rabbitmq_http_client::{
 };
 
 mod test_helpers;
-use crate::test_helpers::{endpoint, PASSWORD, USERNAME};
+use crate::test_helpers::{endpoint, testing_against_3_13_x, PASSWORD, USERNAME};
 
 #[test]
 fn test_blocking_list_feature_flags() {
     let endpoint = endpoint();
     let rc = Client::new(&endpoint, USERNAME, PASSWORD);
-    let result = rc.list_feature_flags();
 
+    if testing_against_3_13_x() {
+        return;
+    }
+
+    let result = rc.list_feature_flags();
     assert!(result.is_ok());
     let vec = result.unwrap();
     assert!(vec
@@ -37,8 +41,12 @@ fn test_blocking_list_feature_flags() {
 fn test_blocking_enable_a_feature_flag() {
     let endpoint = endpoint();
     let rc = Client::new(&endpoint, USERNAME, PASSWORD);
-    let ff_name = "detailed_queues_endpoint";
 
+    if testing_against_3_13_x() {
+        return;
+    }
+
+    let ff_name = "detailed_queues_endpoint";
     let result1 = rc.enable_feature_flag(ff_name);
     assert!(result1.is_ok());
 
@@ -56,8 +64,12 @@ fn test_blocking_enable_a_feature_flag() {
 fn test_blocking_enable_all_stable_feature_flags() {
     let endpoint = endpoint();
     let rc = Client::new(&endpoint, USERNAME, PASSWORD);
-    let ff_name = "rabbitmq_4.0.0";
 
+    if testing_against_3_13_x() {
+        return;
+    }
+
+    let ff_name = "rabbitmq_4.0.0";
     let result1 = rc.enable_all_stable_feature_flags();
     assert!(result1.is_ok());