Added validate function to PgConfig and invoked it in finalize and pool initialization

martin/src/pg/config.rs

@@ -12,6 +12,7 @@ use crate::pg::builder::PgBuilder;
 use crate::pg::config_function::FuncInfoSources;
 use crate::pg::config_table::TableInfoSources;
 use crate::pg::utils::on_slow;
+use crate::pg::PgError;
 use crate::pg::PgResult;
 use crate::source::TileInfoSources;
 use crate::utils::{IdResolver, OptBoolObj, OptOneMany};
@@ -94,6 +95,23 @@ pub struct PgCfgPublishFuncs {
 
 impl PgConfig {
     /// Apply defaults to the config, and validate if there is a connection string
+    pub fn validate(&self) -> PgResult<()> {
+        if let Some(pool_size) = self.pool_size {
+            if pool_size < 1 {
+                return Err(PgError::ValidationError(
+                    "pool_size must be greater than or equal to 1.".to_string(),
+                ));
+            }
+        }
+        if self.connection_string.is_none() {
+            return Err(PgError::ValidationError(
+                "A connection string must be provided.".to_string(),
+            ));
+        }
+
+        Ok(())
+    }
+
     pub fn finalize(&mut self) -> PgResult<UnrecognizedValues> {
         let mut res = UnrecognizedValues::new();
         if let Some(ref ts) = self.tables {
@@ -110,10 +128,12 @@ impl PgConfig {
             self.auto_publish = OptBoolObj::Bool(true);
         }
 
+        self.validate()?;
         Ok(res)
     }
 
     pub async fn resolve(&mut self, id_resolver: IdResolver) -> MartinResult<TileInfoSources> {
+        self.validate()?;
         let pg = PgBuilder::new(self, id_resolver).await?;
         let inst_tables = on_slow(
             pg.instantiate_tables(),

martin/src/pg/errors.rs

@@ -69,4 +69,7 @@ pub enum PgError {
 
     #[error(r#"Unable to get tile {2:#} with {:?} params from {1}: {0}"#, query_to_json(.3.as_ref()))]
     GetTileWithQueryError(#[source] TokioPgError, String, TileCoord, Option<UrlQuery>),
+
+    #[error("Validation error: {0}")]
+    ValidationError(String),
 }

martin/src/pg/pool.rs

@@ -33,6 +33,8 @@ pub struct PgPool {
 
 impl PgPool {
     pub async fn new(config: &PgConfig) -> PgResult<Self> {
+        config.validate()?;
+
         let (id, mgr) = Self::parse_config(config)?;
 
         let pool = Pool::builder(mgr)