diff --git a/mithril-aggregator/src/http_server/routes/statistics_routes.rs b/mithril-aggregator/src/http_server/routes/statistics_routes.rs index 6647314bed..1b2dc21b15 100644 --- a/mithril-aggregator/src/http_server/routes/statistics_routes.rs +++ b/mithril-aggregator/src/http_server/routes/statistics_routes.rs @@ -34,7 +34,6 @@ fn post_cardano_database_immutable_files_restored( .and(warp::post()) .and(warp::body::json()) .and(middlewares::with_logger(router_state)) - .and(middlewares::with_event_transmitter(router_state)) .and(middlewares::with_metrics_service(router_state)) .and_then(handlers::post_cardano_database_immutable_files_restored) } @@ -45,9 +44,7 @@ fn post_cardano_database_ancillary_files_restored( ) -> impl Filter + Clone { warp::path!("statistics" / "cardano-database" / "ancillary-files-restored") .and(warp::post()) - .and(warp::body::json()) .and(middlewares::with_logger(router_state)) - .and(middlewares::with_event_transmitter(router_state)) .and(middlewares::with_metrics_service(router_state)) .and_then(handlers::post_cardano_database_ancillary_files_restored) } @@ -58,9 +55,7 @@ fn post_cardano_database_complete_restoration( ) -> impl Filter + Clone { warp::path!("statistics" / "cardano-database" / "complete-restoration") .and(warp::post()) - .and(warp::body::json()) .and(middlewares::with_logger(router_state)) - .and(middlewares::with_event_transmitter(router_state)) .and(middlewares::with_metrics_service(router_state)) .and_then(handlers::post_cardano_database_complete_restoration) } @@ -71,23 +66,18 @@ fn post_cardano_database_partial_restoration( ) -> impl Filter + Clone { warp::path!("statistics" / "cardano-database" / "partial-restoration") .and(warp::post()) - .and(warp::body::json()) .and(middlewares::with_logger(router_state)) - .and(middlewares::with_event_transmitter(router_state)) .and(middlewares::with_metrics_service(router_state)) .and_then(handlers::post_cardano_database_partial_restoration) } mod handlers { - use serde::Serialize; use slog::warn; use std::{convert::Infallible, sync::Arc}; use warp::http::StatusCode; use mithril_common::messages::{ - CardanoDatabaseAncillaryFilesRestoredMessage, CardanoDatabaseCompleteRestorationMessage, - CardanoDatabaseImmutableFilesRestoredMessage, CardanoDatabasePartialRestorationMessage, - SnapshotDownloadMessage, + CardanoDatabaseImmutableFilesRestoredMessage, SnapshotDownloadMessage, }; use crate::event_store::{EventMessage, TransmitterService}; @@ -124,97 +114,47 @@ mod handlers { pub async fn post_cardano_database_immutable_files_restored( message: CardanoDatabaseImmutableFilesRestoredMessage, - logger: slog::Logger, - event_transmitter: Arc>, + _logger: slog::Logger, metrics_service: Arc, ) -> Result { metrics_service .get_cardano_database_immutable_files_restored() .increment_by(message.nb_immutable_files); - transmit_event_message( - message, - logger, - event_transmitter, - "cardano_database_immutable_files_restored", - ) - .await + Ok(reply::empty(StatusCode::CREATED)) } pub async fn post_cardano_database_ancillary_files_restored( - message: CardanoDatabaseAncillaryFilesRestoredMessage, - logger: slog::Logger, - event_transmitter: Arc>, + _logger: slog::Logger, metrics_service: Arc, ) -> Result { metrics_service .get_cardano_database_ancillary_files_restored() - .increment_by(message.nb_ancillary_files); - - transmit_event_message( - message, - logger, - event_transmitter, - "cardano_database_ancillary_files_restored", - ) - .await + .increment(); + + Ok(reply::empty(StatusCode::CREATED)) } pub async fn post_cardano_database_complete_restoration( - message: CardanoDatabaseCompleteRestorationMessage, - logger: slog::Logger, - event_transmitter: Arc>, + _logger: slog::Logger, metrics_service: Arc, ) -> Result { metrics_service .get_cardano_database_complete_restoration() - .increment_by(message.nb_complete_restoration); - - transmit_event_message( - message, - logger, - event_transmitter, - "cardano_database_complete_restoration", - ) - .await + .increment(); + + Ok(reply::empty(StatusCode::CREATED)) } pub async fn post_cardano_database_partial_restoration( - message: CardanoDatabasePartialRestorationMessage, - logger: slog::Logger, - event_transmitter: Arc>, + _logger: slog::Logger, metrics_service: Arc, ) -> Result { metrics_service .get_cardano_database_partial_restoration() - .increment_by(message.nb_partial_restoration); - - transmit_event_message( - message, - logger, - event_transmitter, - "cardano_database_partial_restoration", - ) - .await - } - - async fn transmit_event_message( - message: T, - logger: slog::Logger, - event_transmitter: Arc>, - action: &str, - ) -> Result { - let headers: Vec<(&str, &str)> = Vec::new(); - - let message = EventMessage::new("HTTP::statistics", action, &message, headers); + .increment(); - match event_transmitter.try_send(message.clone()) { - Err(e) => { - warn!(logger, "Event message error"; "error" => ?e); - Ok(reply::internal_server_error(e)) - } - Ok(_) => Ok(reply::empty(StatusCode::CREATED)), - } + Ok(reply::empty(StatusCode::CREATED)) } } @@ -237,6 +177,8 @@ mod tests { dependency_injection::DependenciesBuilder, initialize_dependencies, Configuration, }; + use serde_json::Value; + fn setup_router( state: RouterState, ) -> impl Filter + Clone { @@ -310,35 +252,21 @@ mod tests { ); } - mod restoration { - use mithril_metric::CounterValue; - use serde::Serialize; - use tokio::sync::mpsc::UnboundedReceiver; - - use crate::{event_store::EventMessage, DependencyContainer, MetricsService}; - + mod post_cardano_database_immutable_files_restored { use super::*; - async fn setup_dependencies() -> (Arc, UnboundedReceiver) - { - let config = Configuration::new_sample(); - let mut builder = DependenciesBuilder::new_with_stdout_logger(config); - let rx = builder.get_event_transmitter_receiver().await.unwrap(); - let dependency_manager = Arc::new(builder.build_dependency_container().await.unwrap()); - (dependency_manager, rx) - } + const HTTP_METHOD: Method = Method::POST; + const PATH: &str = "/statistics/cardano-database/immutable-files-restored"; - async fn check_conform_to_open_api_when_created( - method: Method, - path: &str, - message: &impl Serialize, - ) { - let (dependency_manager, _rx) = setup_dependencies().await; + #[tokio::test] + async fn conform_to_open_api_when_created() { + let message = CardanoDatabaseImmutableFilesRestoredMessage::dummy(); + let dependency_manager = Arc::new(initialize_dependencies().await); let response = request() - .method(method.as_str()) - .json(message) - .path(path) + .method(HTTP_METHOD.as_str()) + .json(&message) + .path(PATH) .reply(&setup_router(RouterState::new_with_dummy_config( dependency_manager.clone(), ))) @@ -346,10 +274,10 @@ mod tests { let result = APISpec::verify_conformity( APISpec::get_all_spec_files(), - method.as_str(), - path, + HTTP_METHOD.as_str(), + PATH, "application/json", - message, + &message, &response, &StatusCode::CREATED, ); @@ -357,273 +285,187 @@ mod tests { result.unwrap(); } - async fn check_conform_to_open_api_when_server_error( - method: Method, - path: &str, - message: &impl Serialize, - ) { - let (dependency_manager, mut rx) = setup_dependencies().await; - rx.close(); + #[tokio::test] + async fn increments_metric() { + let dependency_manager = Arc::new(initialize_dependencies().await); + let metric_counter = dependency_manager + .metrics_service + .get_cardano_database_immutable_files_restored(); + let message = CardanoDatabaseImmutableFilesRestoredMessage { + nb_immutable_files: 3, + }; - let response = request() - .method(method.as_str()) - .json(message) - .path(path) + let initial_counter_value = metric_counter.get(); + + request() + .method(HTTP_METHOD.as_str()) + .json(&message) + .path(PATH) .reply(&setup_router(RouterState::new_with_dummy_config( dependency_manager.clone(), ))) .await; - APISpec::verify_conformity( - APISpec::get_all_spec_files(), - method.as_str(), - path, - "application/json", - &message, - &response, - &StatusCode::INTERNAL_SERVER_ERROR, - ) - .unwrap(); + assert_eq!(initial_counter_value + 3, metric_counter.get()); } + } - async fn check_should_send_event(method: Method, path: &str, message: &impl Serialize) { - let (dependency_manager, mut rx) = setup_dependencies().await; + mod post_cardano_database_ancillary_files_restored { + use super::*; - request() - .method(method.as_str()) - .json(message) - .path(path) + const HTTP_METHOD: Method = Method::POST; + const PATH: &str = "/statistics/cardano-database/ancillary-files-restored"; + + #[tokio::test] + async fn conform_to_open_api_when_created() { + let dependency_manager = Arc::new(initialize_dependencies().await); + let response = request() + .method(HTTP_METHOD.as_str()) + .json(&Value::Null) + .path(PATH) .reply(&setup_router(RouterState::new_with_dummy_config( dependency_manager.clone(), ))) .await; - let _ = rx.try_recv().unwrap(); + let result = APISpec::verify_conformity( + APISpec::get_all_spec_files(), + HTTP_METHOD.as_str(), + PATH, + "application/json", + &Value::Null, + &response, + &StatusCode::CREATED, + ); + + result.unwrap(); } - async fn check_increments_metric( - method: Method, - path: &str, - message: &impl Serialize, - expected_increment: u32, - get_metric_value: &dyn Fn(Arc) -> CounterValue, - ) { - let (dependency_manager, _rx) = setup_dependencies().await; + #[tokio::test] + async fn increments_metric() { + let dependency_manager = Arc::new(initialize_dependencies().await); + let metric_counter = dependency_manager + .metrics_service + .get_cardano_database_ancillary_files_restored(); - let initial_counter_value = - get_metric_value(dependency_manager.metrics_service.clone()); + let initial_counter_value = metric_counter.get(); request() - .method(method.as_str()) - .json(message) - .path(path) + .method(HTTP_METHOD.as_str()) + .json(&Value::Null) + .path(PATH) .reply(&setup_router(RouterState::new_with_dummy_config( dependency_manager.clone(), ))) .await; - assert_eq!( - initial_counter_value + expected_increment, - get_metric_value(dependency_manager.metrics_service.clone()) - ); + assert_eq!(initial_counter_value + 1, metric_counter.get()); } + } - mod post_cardano_database_immutable_files_restored { - use super::*; - - const HTTP_METHOD: Method = Method::POST; - const PATH: &str = "/statistics/cardano-database/immutable-files-restored"; - - #[tokio::test] - async fn conform_to_open_api_when_created() { - let message = CardanoDatabaseImmutableFilesRestoredMessage::dummy(); - - check_conform_to_open_api_when_created(HTTP_METHOD, PATH, &message).await; - } - - #[tokio::test] - async fn conform_to_open_api_when_server_error() { - let message = CardanoDatabaseImmutableFilesRestoredMessage::dummy(); - - check_conform_to_open_api_when_server_error(HTTP_METHOD, PATH, &message).await; - } - - #[tokio::test] - async fn should_send_event() { - let message = CardanoDatabaseImmutableFilesRestoredMessage::dummy(); + mod post_cardano_database_complete_restoration { + use super::*; - check_should_send_event(HTTP_METHOD, PATH, &message).await; - } + const HTTP_METHOD: Method = Method::POST; + const PATH: &str = "/statistics/cardano-database/complete-restoration"; - #[tokio::test] - async fn increments_metric() { - let message = CardanoDatabaseImmutableFilesRestoredMessage { - nb_immutable_files: 3, - }; - - check_increments_metric( - HTTP_METHOD, - PATH, - &message, - message.nb_immutable_files, - &|metrics_service: Arc| { - metrics_service - .get_cardano_database_immutable_files_restored() - .get() - }, - ) + #[tokio::test] + async fn conform_to_open_api_when_created() { + let dependency_manager = Arc::new(initialize_dependencies().await); + let response = request() + .method(HTTP_METHOD.as_str()) + .json(&Value::Null) + .path(PATH) + .reply(&setup_router(RouterState::new_with_dummy_config( + dependency_manager.clone(), + ))) .await; - } - } - - mod post_cardano_database_ancillary_files_restored { - use mithril_common::messages::CardanoDatabaseAncillaryFilesRestoredMessage; - - use super::*; - - const HTTP_METHOD: Method = Method::POST; - const PATH: &str = "/statistics/cardano-database/ancillary-files-restored"; - - #[tokio::test] - async fn conform_to_open_api_when_created() { - let message = CardanoDatabaseAncillaryFilesRestoredMessage::dummy(); - - check_conform_to_open_api_when_created(HTTP_METHOD, PATH, &message).await; - } - - #[tokio::test] - async fn conform_to_open_api_when_server_error() { - let message = CardanoDatabaseAncillaryFilesRestoredMessage::dummy(); - - check_conform_to_open_api_when_server_error(HTTP_METHOD, PATH, &message).await; - } - - #[tokio::test] - async fn should_send_event() { - let message = CardanoDatabaseAncillaryFilesRestoredMessage::dummy(); - check_should_send_event(HTTP_METHOD, PATH, &message).await; - } + let result = APISpec::verify_conformity( + APISpec::get_all_spec_files(), + HTTP_METHOD.as_str(), + PATH, + "application/json", + &Value::Null, + &response, + &StatusCode::CREATED, + ); - #[tokio::test] - async fn increments_metric() { - let message = CardanoDatabaseAncillaryFilesRestoredMessage { - nb_ancillary_files: 3, - }; - - check_increments_metric( - HTTP_METHOD, - PATH, - &message, - message.nb_ancillary_files, - &|metrics_service: Arc| { - metrics_service - .get_cardano_database_ancillary_files_restored() - .get() - }, - ) - .await; - } + result.unwrap(); } - mod post_cardano_database_complete_restoration { - use mithril_common::messages::CardanoDatabaseCompleteRestorationMessage; - - use super::*; - - const HTTP_METHOD: Method = Method::POST; - const PATH: &str = "/statistics/cardano-database/complete-restoration"; - - #[tokio::test] - async fn conform_to_open_api_when_created() { - let message = CardanoDatabaseCompleteRestorationMessage::dummy(); - - check_conform_to_open_api_when_created(HTTP_METHOD, PATH, &message).await; - } - - #[tokio::test] - async fn conform_to_open_api_when_server_error() { - let message = CardanoDatabaseCompleteRestorationMessage::dummy(); - - check_conform_to_open_api_when_server_error(HTTP_METHOD, PATH, &message).await; - } - - #[tokio::test] - async fn should_send_event() { - let message = CardanoDatabaseCompleteRestorationMessage::dummy(); + #[tokio::test] + async fn increments_metric() { + let dependency_manager = Arc::new(initialize_dependencies().await); + let metric_counter = dependency_manager + .metrics_service + .get_cardano_database_complete_restoration(); - check_should_send_event(HTTP_METHOD, PATH, &message).await; - } + let initial_counter_value = metric_counter.get(); - #[tokio::test] - async fn increments_metric() { - let message = CardanoDatabaseCompleteRestorationMessage { - nb_complete_restoration: 3, - }; - - check_increments_metric( - HTTP_METHOD, - PATH, - &message, - message.nb_complete_restoration, - &|metrics_service: Arc| { - metrics_service - .get_cardano_database_complete_restoration() - .get() - }, - ) + request() + .method(HTTP_METHOD.as_str()) + .json(&Value::Null) + .path(PATH) + .reply(&setup_router(RouterState::new_with_dummy_config( + dependency_manager.clone(), + ))) .await; - } - } - mod post_cardano_database_partial_restoration { - use mithril_common::messages::CardanoDatabasePartialRestorationMessage; - - use super::*; + assert_eq!(initial_counter_value + 1, metric_counter.get()); + } + } - const HTTP_METHOD: Method = Method::POST; - const PATH: &str = "/statistics/cardano-database/partial-restoration"; + mod post_cardano_database_partial_restoration { + use super::*; - #[tokio::test] - async fn conform_to_open_api_when_created() { - let message = CardanoDatabasePartialRestorationMessage::dummy(); + const HTTP_METHOD: Method = Method::POST; + const PATH: &str = "/statistics/cardano-database/partial-restoration"; - check_conform_to_open_api_when_created(HTTP_METHOD, PATH, &message).await; - } + #[tokio::test] + async fn conform_to_open_api_when_created() { + let dependency_manager = Arc::new(initialize_dependencies().await); + let response = request() + .method(HTTP_METHOD.as_str()) + .json(&Value::Null) + .path(PATH) + .reply(&setup_router(RouterState::new_with_dummy_config( + dependency_manager.clone(), + ))) + .await; - #[tokio::test] - async fn conform_to_open_api_when_server_error() { - let message = CardanoDatabasePartialRestorationMessage::dummy(); + let result = APISpec::verify_conformity( + APISpec::get_all_spec_files(), + HTTP_METHOD.as_str(), + PATH, + "application/json", + &Value::Null, + &response, + &StatusCode::CREATED, + ); - check_conform_to_open_api_when_server_error(HTTP_METHOD, PATH, &message).await; - } + result.unwrap(); + } - #[tokio::test] - async fn should_send_event() { - let message = CardanoDatabasePartialRestorationMessage::dummy(); + #[tokio::test] + async fn increments_metric() { + let dependency_manager = Arc::new(initialize_dependencies().await); + let metric_counter = dependency_manager + .metrics_service + .get_cardano_database_partial_restoration(); - check_should_send_event(HTTP_METHOD, PATH, &message).await; - } + let initial_counter_value = metric_counter.get(); - #[tokio::test] - async fn increments_metric() { - let message = CardanoDatabasePartialRestorationMessage { - nb_partial_restoration: 3, - }; - - check_increments_metric( - HTTP_METHOD, - PATH, - &message, - message.nb_partial_restoration, - &|metrics_service: Arc| { - metrics_service - .get_cardano_database_partial_restoration() - .get() - }, - ) + request() + .method(HTTP_METHOD.as_str()) + .json(&Value::Null) + .path(PATH) + .reply(&setup_router(RouterState::new_with_dummy_config( + dependency_manager.clone(), + ))) .await; - } + + assert_eq!(initial_counter_value + 1, metric_counter.get()); } } } diff --git a/mithril-common/src/messages/cardano_database_ancillary_files_restored.rs b/mithril-common/src/messages/cardano_database_ancillary_files_restored.rs deleted file mode 100644 index 5e4ee796a7..0000000000 --- a/mithril-common/src/messages/cardano_database_ancillary_files_restored.rs +++ /dev/null @@ -1,41 +0,0 @@ -use serde::{Deserialize, Serialize}; - -/// Message structure of an ancillary files restoration -#[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize)] -pub struct CardanoDatabaseAncillaryFilesRestoredMessage { - /// Number of ancillary files restored. - pub nb_ancillary_files: u32, -} - -impl CardanoDatabaseAncillaryFilesRestoredMessage { - /// Return a dummy test entity (test-only). - pub fn dummy() -> Self { - Self { - nb_ancillary_files: 34, - } - } -} - -#[cfg(test)] -mod tests { - use super::*; - - const CURRENT_JSON: &str = r#"{ - "nb_ancillary_files": 62 - }"#; - - fn golden_message_current() -> CardanoDatabaseAncillaryFilesRestoredMessage { - CardanoDatabaseAncillaryFilesRestoredMessage { - nb_ancillary_files: 62, - } - } - - #[test] - fn test_current_json_deserialized_into_current_message() { - let json = CURRENT_JSON; - let message: CardanoDatabaseAncillaryFilesRestoredMessage = - serde_json::from_str(json).unwrap(); - - assert_eq!(golden_message_current(), message); - } -} diff --git a/mithril-common/src/messages/cardano_database_complete_restoration.rs b/mithril-common/src/messages/cardano_database_complete_restoration.rs deleted file mode 100644 index 6bf3ad76fe..0000000000 --- a/mithril-common/src/messages/cardano_database_complete_restoration.rs +++ /dev/null @@ -1,41 +0,0 @@ -use serde::{Deserialize, Serialize}; - -/// Message structure of a complete Cardano database restoration -#[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize)] -pub struct CardanoDatabaseCompleteRestorationMessage { - /// Number of complete restoration. - pub nb_complete_restoration: u32, -} - -impl CardanoDatabaseCompleteRestorationMessage { - /// Return a dummy test entity (test-only). - pub fn dummy() -> Self { - Self { - nb_complete_restoration: 34, - } - } -} - -#[cfg(test)] -mod tests { - use super::*; - - const CURRENT_JSON: &str = r#"{ - "nb_complete_restoration": 62 - }"#; - - fn golden_message_current() -> CardanoDatabaseCompleteRestorationMessage { - CardanoDatabaseCompleteRestorationMessage { - nb_complete_restoration: 62, - } - } - - #[test] - fn test_current_json_deserialized_into_current_message() { - let json = CURRENT_JSON; - let message: CardanoDatabaseCompleteRestorationMessage = - serde_json::from_str(json).unwrap(); - - assert_eq!(golden_message_current(), message); - } -} diff --git a/mithril-common/src/messages/cardano_database_partial_restoration.rs b/mithril-common/src/messages/cardano_database_partial_restoration.rs deleted file mode 100644 index acdff010f2..0000000000 --- a/mithril-common/src/messages/cardano_database_partial_restoration.rs +++ /dev/null @@ -1,40 +0,0 @@ -use serde::{Deserialize, Serialize}; - -/// Message structure of a partial Cardano database restoration -#[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize)] -pub struct CardanoDatabasePartialRestorationMessage { - /// Number of partial restoration. - pub nb_partial_restoration: u32, -} - -impl CardanoDatabasePartialRestorationMessage { - /// Return a dummy test entity (test-only). - pub fn dummy() -> Self { - Self { - nb_partial_restoration: 34, - } - } -} - -#[cfg(test)] -mod tests { - use super::*; - - const CURRENT_JSON: &str = r#"{ - "nb_partial_restoration": 62 - }"#; - - fn golden_message_current() -> CardanoDatabasePartialRestorationMessage { - CardanoDatabasePartialRestorationMessage { - nb_partial_restoration: 62, - } - } - - #[test] - fn test_current_json_deserialized_into_current_message() { - let json = CURRENT_JSON; - let message: CardanoDatabasePartialRestorationMessage = serde_json::from_str(json).unwrap(); - - assert_eq!(golden_message_current(), message); - } -} diff --git a/mithril-common/src/messages/mod.rs b/mithril-common/src/messages/mod.rs index d4da4c8989..2270f05185 100644 --- a/mithril-common/src/messages/mod.rs +++ b/mithril-common/src/messages/mod.rs @@ -3,12 +3,9 @@ mod aggregator_features; mod aggregator_status; mod cardano_database; -mod cardano_database_ancillary_files_restored; -mod cardano_database_complete_restoration; mod cardano_database_digest_list; mod cardano_database_immutable_files_restored; mod cardano_database_list; -mod cardano_database_partial_restoration; mod cardano_stake_distribution; mod cardano_stake_distribution_list; mod cardano_transaction_snapshot; @@ -33,8 +30,6 @@ pub use aggregator_features::{ }; pub use aggregator_status::AggregatorStatusMessage; pub use cardano_database::{ArtifactsLocationsMessagePart, CardanoDatabaseSnapshotMessage}; -pub use cardano_database_ancillary_files_restored::CardanoDatabaseAncillaryFilesRestoredMessage; -pub use cardano_database_complete_restoration::CardanoDatabaseCompleteRestorationMessage; pub use cardano_database_digest_list::{ CardanoDatabaseDigestListItemMessage, CardanoDatabaseDigestListMessage, }; @@ -42,7 +37,6 @@ pub use cardano_database_immutable_files_restored::CardanoDatabaseImmutableFiles pub use cardano_database_list::{ CardanoDatabaseSnapshotListItemMessage, CardanoDatabaseSnapshotListMessage, }; -pub use cardano_database_partial_restoration::CardanoDatabasePartialRestorationMessage; pub use cardano_stake_distribution::CardanoStakeDistributionMessage; pub use cardano_stake_distribution_list::{ CardanoStakeDistributionListItemMessage, CardanoStakeDistributionListMessage, diff --git a/openapi.yaml b/openapi.yaml index 614b349b37..78efca0f77 100644 --- a/openapi.yaml +++ b/openapi.yaml @@ -771,13 +771,6 @@ paths: post: summary: Records ancillary files restored event description: Records ancillary files restored event - requestBody: - description: Ancillary files restored message - required: true - content: - application/json: - schema: - $ref: "#/components/schemas/CardanoDatabaseAncillaryFilesRestoredMessage" responses: "201": description: Event successfully recorded @@ -792,13 +785,6 @@ paths: post: summary: Records complete restoration event description: Records complete restoration event - requestBody: - description: Complete restoration message - required: true - content: - application/json: - schema: - $ref: "#/components/schemas/CardanoDatabaseCompleteRestorationMessage" responses: "201": description: Event successfully recorded @@ -813,13 +799,6 @@ paths: post: summary: Records partial restoration event description: Records partial restoration event - requestBody: - description: Partial restoration message - required: true - content: - application/json: - schema: - $ref: "#/components/schemas/CardanoDatabasePartialRestorationMessage" responses: "201": description: Event successfully recorded @@ -1977,45 +1956,6 @@ components: examples: - { "nb_immutable_files": 15 } - CardanoDatabaseAncillaryFilesRestoredMessage: - description: CardanoDatabaseAncillaryFilesRestoredMessage represents a Cardano database Ancillary files restored event - type: object - additionalProperties: false - required: - - nb_ancillary_files - properties: - nb_ancillary_files: - description: Number of ancillary files restored - type: integer - examples: - - { "nb_ancillary_files": 15 } - - CardanoDatabaseCompleteRestorationMessage: - description: CardanoDatabaseCompleteRestorationMessage represents a Cardano database complete restoration event - type: object - additionalProperties: false - required: - - nb_complete_restoration - properties: - nb_complete_restoration: - description: Number of complete restoration - type: integer - examples: - - { "nb_complete_restoration": 15 } - - CardanoDatabasePartialRestorationMessage: - description: CardanoDatabasePartialRestorationMessage represents a Cardano database partial restoration event - type: object - additionalProperties: false - required: - - nb_partial_restoration - properties: - nb_partial_restoration: - description: Number of partial restoration - type: integer - examples: - - { "nb_partial_restoration": 15 } - CardanoDatabaseArtifactsLocationsMessagePart: description: CardanoDatabaseArtifactsLocationsMessagePart represents the locations of the Cardano database artifacts type: object