input-output-hk
diff --git a/‎.github/workflows/generate-allure-report.yml
+1-1 b/‎.github/workflows/generate-allure-report.yml
+1-1
diff --git a/‎Earthfile
+10 b/‎Earthfile
+10
diff --git a/‎catalyst-gateway/bin/src/cli.rs
+1-1 b/‎catalyst-gateway/bin/src/cli.rs
+1-1
diff --git a/‎catalyst-gateway/bin/src/event_db/error.rs
-4 b/‎catalyst-gateway/bin/src/event_db/error.rs
-4
diff --git a/‎catalyst-gateway/bin/src/event_db/mod.rs
+2-10 b/‎catalyst-gateway/bin/src/event_db/mod.rs
+2-10
diff --git a/‎catalyst-gateway/bin/src/service/api/cardano/date_time_to_slot_number_get.rs
+3-19 b/‎catalyst-gateway/bin/src/service/api/cardano/date_time_to_slot_number_get.rs
+3-19
diff --git a/‎catalyst-gateway/bin/src/service/api/cardano/registration_get.rs
+4-16 b/‎catalyst-gateway/bin/src/service/api/cardano/registration_get.rs
+4-16
diff --git a/‎catalyst-gateway/bin/src/service/api/cardano/staked_ada_get.rs
+3-16 b/‎catalyst-gateway/bin/src/service/api/cardano/staked_ada_get.rs
+3-16
diff --git a/‎catalyst-gateway/bin/src/service/api/cardano/sync_state_get.rs
+3-16 b/‎catalyst-gateway/bin/src/service/api/cardano/sync_state_get.rs
+3-16
diff --git a/‎catalyst-gateway/bin/src/service/api/health/ready_get.rs
+4-7 b/‎catalyst-gateway/bin/src/service/api/health/ready_get.rs
+4-7
diff --git a/‎catalyst-gateway/bin/src/service/mod.rs
-3 b/‎catalyst-gateway/bin/src/service/mod.rs
-3
diff --git a/‎catalyst-gateway/bin/src/service/utilities/middleware/schema_validation.rs
+2-5 b/‎catalyst-gateway/bin/src/service/utilities/middleware/schema_validation.rs
+2-5
@@ -67,7 +67,7 @@ jobs:
         with:
             earthfile: ./catalyst_voices/
             flags:
-            targets: test-unit
+            targets: test-report
             target_flags:
             runner_address: ${{ secrets.EARTHLY_SATELLITE_ADDRESS }}
             artifact: "false"
 
@@ -44,4 +44,14 @@ repo-catalyst-voices-packages:
     WORKDIR /repo
     COPY --dir catalyst_voices_packages .
 
+    SAVE ARTIFACT /repo repo
+
+# repo-catalyst-voices-all - Creates artifacts of all configuration files,
+# packages and folders related to catalyst_voices frontend.
+repo-catalyst-voices-all:
+    FROM scratch
+
+    WORKDIR /repo
+    COPY --dir catalyst_voices catalyst_voices_packages utilities melos.yaml pubspec.yaml  .
+
     SAVE ARTIFACT /repo repo
@@ -58,7 +58,7 @@ impl Cli {
                 let machine_id = settings.follower_settings.machine_uid;
 
                 let state = Arc::new(State::new(Some(settings.database_url)).await?);
-                let event_db = state.event_db()?;
+                let event_db = state.event_db();
 
                 tokio::spawn(async move {
                     match service::run(&settings.docs_settings, state.clone()).await {
 
@@ -1,5 +1,4 @@
 //! Database Errors
-use std::env::VarError;
 
 use bb8::RunError;
 
@@ -26,9 +25,6 @@ pub(crate) enum Error {
     /// Unknown error
     #[error("error: {0}")]
     Unknown(String),
-    /// Variable error
-    #[error(transparent)]
-    VarErr(#[from] VarError),
     /// No config
     #[error("No config")]
     NoConfig,
 
@@ -54,9 +54,7 @@ pub(crate) struct EventDB {
 ///
 /// The env var "`DATABASE_URL`" can be set directly as an anv var, or in a
 /// `.env` file.
-pub(crate) async fn establish_connection(
-    url: Option<String>, do_schema_check: bool,
-) -> Result<EventDB, Error> {
+pub(crate) async fn establish_connection(url: Option<String>) -> Result<EventDB, Error> {
     // Support env vars in a `.env` file,  doesn't need to exist.
     dotenv().ok();
 
@@ -72,11 +70,5 @@ pub(crate) async fn establish_connection(
 
     let pool = Pool::builder().build(pg_mgr).await?;
 
-    let db = EventDB { pool };
-
-    if do_schema_check {
-        db.schema_version_check().await?;
-    }
-
-    Ok(db)
+    Ok(EventDB { pool })
 }
@@ -1,13 +1,9 @@
 //! Implementation of the GET `/date_time_to_slot_number` endpoint
 
-use poem_extensions::{
-    response,
-    UniResponse::{T200, T503},
-};
+use poem_extensions::{response, UniResponse::T200};
 use poem_openapi::payload::Json;
 
 use crate::{
-    cli::Error,
     event_db::{
         error::Error as DBError,
         follower::{DateTime, SlotInfoQueryType},
@@ -23,7 +19,7 @@ use crate::{
             resp_5xx::{server_error_response, ServerError, ServiceUnavailable},
         },
     },
-    state::{SchemaVersionStatus, State},
+    state::State,
 };
 
 /// # All Responses
@@ -39,19 +35,7 @@ pub(crate) type AllResponses = response! {
 pub(crate) async fn endpoint(
     state: &State, date_time: Option<DateTime>, network: Option<Network>,
 ) -> AllResponses {
-    let event_db = match state.event_db() {
-        Ok(event_db) => event_db,
-        Err(Error::EventDb(DBError::MismatchedSchema { was, expected })) => {
-            tracing::error!(
-                expected = expected,
-                current = was,
-                "DB schema version status mismatch"
-            );
-            state.set_schema_version_status(SchemaVersionStatus::Mismatch);
-            return T503(ServiceUnavailable);
-        },
-        Err(err) => return server_error_response!("{err}"),
-    };
+    let event_db = state.event_db();
 
     let date_time = date_time.unwrap_or_else(chrono::Utc::now);
     let network = network.unwrap_or(Network::Mainnet);
 
@@ -2,12 +2,11 @@
 
 use poem_extensions::{
     response,
-    UniResponse::{T200, T400, T404, T503},
+    UniResponse::{T200, T400, T404},
 };
 use poem_openapi::payload::Json;
 
 use crate::{
-    cli::Error,
     event_db::{error::Error as DBError, follower::SlotNumber},
     service::{
         common::{
@@ -22,7 +21,7 @@ use crate::{
         },
         utilities::check_network,
     },
-    state::{SchemaVersionStatus, State},
+    state::State,
 };
 
 /// # All Responses
@@ -40,19 +39,8 @@ pub(crate) async fn endpoint(
     state: &State, stake_address: StakeAddress, provided_network: Option<Network>,
     slot_num: Option<SlotNumber>,
 ) -> AllResponses {
-    let event_db = match state.event_db() {
-        Ok(event_db) => event_db,
-        Err(Error::EventDb(DBError::MismatchedSchema { was, expected })) => {
-            tracing::error!(
-                expected = expected,
-                current = was,
-                "DB schema version status mismatch"
-            );
-            state.set_schema_version_status(SchemaVersionStatus::Mismatch);
-            return T503(ServiceUnavailable);
-        },
-        Err(err) => return server_error_response!("{err}"),
-    };
+    let event_db = state.event_db();
+
     let date_time = slot_num.unwrap_or(SlotNumber::MAX);
     let stake_credential = stake_address.payload().as_hash().to_vec();
     let network = match check_network(stake_address.network(), provided_network) {
 
@@ -2,12 +2,11 @@
 
 use poem_extensions::{
     response,
-    UniResponse::{T200, T400, T404, T503},
+    UniResponse::{T200, T400, T404},
 };
 use poem_openapi::payload::Json;
 
 use crate::{
-    cli::Error,
     event_db::{error::Error as DBError, follower::SlotNumber},
     service::{
         common::{
@@ -22,7 +21,7 @@ use crate::{
         },
         utilities::check_network,
     },
-    state::{SchemaVersionStatus, State},
+    state::State,
 };
 
 /// # All Responses
@@ -39,19 +38,7 @@ pub(crate) async fn endpoint(
     state: &State, stake_address: StakeAddress, provided_network: Option<Network>,
     slot_num: Option<SlotNumber>,
 ) -> AllResponses {
-    let event_db = match state.event_db() {
-        Ok(event_db) => event_db,
-        Err(Error::EventDb(DBError::MismatchedSchema { was, expected })) => {
-            tracing::error!(
-                expected = expected,
-                current = was,
-                "DB schema version status mismatch"
-            );
-            state.set_schema_version_status(SchemaVersionStatus::Mismatch);
-            return T503(ServiceUnavailable);
-        },
-        Err(err) => return server_error_response!("{err}"),
-    };
+    let event_db = state.event_db();
 
     let date_time = slot_num.unwrap_or(SlotNumber::MAX);
     let stake_credential = stake_address.payload().as_hash().to_vec();
 
@@ -2,12 +2,11 @@
 
 use poem_extensions::{
     response,
-    UniResponse::{T200, T404, T503},
+    UniResponse::{T200, T404},
 };
 use poem_openapi::payload::Json;
 
 use crate::{
-    cli::Error,
     event_db::error::Error as DBError,
     service::common::{
         objects::cardano::{network::Network, sync_state::SyncState},
@@ -17,7 +16,7 @@ use crate::{
             resp_5xx::{server_error_response, ServerError, ServiceUnavailable},
         },
     },
-    state::{SchemaVersionStatus, State},
+    state::State,
 };
 
 /// # All Responses
@@ -32,19 +31,7 @@ pub(crate) type AllResponses = response! {
 /// # GET `/sync_state`
 #[allow(clippy::unused_async)]
 pub(crate) async fn endpoint(state: &State, network: Option<Network>) -> AllResponses {
-    let event_db = match state.event_db() {
-        Ok(event_db) => event_db,
-        Err(Error::EventDb(DBError::MismatchedSchema { was, expected })) => {
-            tracing::error!(
-                expected = expected,
-                current = was,
-                "DB schema version status mismatch"
-            );
-            state.set_schema_version_status(SchemaVersionStatus::Mismatch);
-            return T503(ServiceUnavailable);
-        },
-        Err(err) => return server_error_response!("{err}"),
-    };
+    let event_db = state.event_db();
 
     let network = network.unwrap_or(Network::Mainnet);
 
 
@@ -9,14 +9,13 @@ use poem_extensions::{
 };
 
 use crate::{
-    cli::Error,
     event_db::error::Error as DBError,
     service::common::responses::{
         resp_2xx::NoContent,
         resp_4xx::ApiValidationError,
         resp_5xx::{server_error_response, ServerError, ServiceUnavailable},
     },
-    state::{SchemaVersionStatus, State},
+    state::State,
 };
 
 /// All responses
@@ -53,22 +52,20 @@ pub(crate) type AllResponses = response! {
 ///   but unlikely)
 /// * 503 Service Unavailable - Service is not ready, do not send other requests.
 pub(crate) async fn endpoint(state: Data<&Arc<State>>) -> AllResponses {
-    match state.schema_version_check().await {
+    match state.event_db().schema_version_check().await {
         Ok(_) => {
             tracing::debug!("DB schema version status ok");
-            state.set_schema_version_status(SchemaVersionStatus::Ok);
             T204(NoContent)
         },
-        Err(Error::EventDb(DBError::MismatchedSchema { was, expected })) => {
+        Err(DBError::MismatchedSchema { was, expected }) => {
             tracing::error!(
                 expected = expected,
                 current = was,
                 "DB schema version status mismatch"
             );
-            state.set_schema_version_status(SchemaVersionStatus::Mismatch);
             T503(ServiceUnavailable)
         },
-        Err(Error::EventDb(DBError::TimedOut)) => T503(ServiceUnavailable),
+        Err(DBError::TimedOut) => T503(ServiceUnavailable),
         Err(err) => server_error_response!("{err}"),
     }
 }
@@ -23,9 +23,6 @@ pub(crate) enum Error {
     /// An IO error has occurred
     #[error(transparent)]
     Io(#[from] std::io::Error),
-    /// A mismatch in the expected `EventDB` schema version
-    #[error("expected schema version mismatch")]
-    SchemaVersionMismatch,
 }
 
 /// # Run Catalyst Gateway Service.
 
@@ -11,10 +11,7 @@ use std::sync::Arc;
 
 use poem::{web::Data, Endpoint, EndpointExt, Middleware, Request, Result};
 
-use crate::{
-    service::common::responses::resp_5xx::ServiceUnavailable,
-    state::{SchemaVersionStatus, State},
-};
+use crate::{service::common::responses::resp_5xx::ServiceUnavailable, state::State};
 
 /// A middleware that raises an error  with `ServiceUnavailable` and 503 status code
 /// if a DB schema version mismatch is found the existing `State`.
@@ -44,7 +41,7 @@ impl<E: Endpoint> Endpoint for SchemaVersionValidationImpl<E> {
             // if so, return the `ServiceUnavailable` error, which implements
             // `ResponseError`, with status code `503`.
             // Otherwise, return the endpoint as usual.
-            if state.is_schema_version_status(&SchemaVersionStatus::Mismatch) {
+            if state.event_db().schema_version_check().await.is_err() {
                 return Err(ServiceUnavailable.into());
             }
         }
Original file line number	Diff line number	Diff line change
`@@ -23,9 +23,6 @@ pub(crate) enum Error {`
`23`	`23`	`/// An IO error has occurred`
`24`	`24`	`#[error(transparent)]`
`25`	`25`	`Io(#[from] std::io::Error),`
`26`		- /// A mismatch in the expected `EventDB` schema version
`27`		`- #[error("expected schema version mismatch")]`
`28`		`- SchemaVersionMismatch,`
`29`	`26`	`}`
`30`	`27`
`31`	`28`	`/// # Run Catalyst Gateway Service.`