Add Search and Redis configuration, add /heartbeat, panic + cors hand…

…lers

crates/config/BUILD.bazel

@@ -22,6 +22,7 @@ rust_project(
     deps = [
         "//crates/common:charted_common",
         "@crate_index//:aws-sdk-s3",
+        "@crate_index//:base64",
         "@crate_index//:clap",
         "@crate_index//:eyre",
         "@crate_index//:lazy_static",

crates/config/Cargo.toml

@@ -37,3 +37,4 @@ remi-s3 = { version = "0.2.1", features = ["serde"] }
 aws-sdk-s3 = "0.28.0"
 paste = "1.0.13"
 merge-struct = "0.1.0"
+base64 = "0.21.2"

crates/config/src/redis.rs

@@ -12,3 +12,75 @@
 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 // See the License for the specific language governing permissions and
 // limitations under the License.
+
+use crate::{make_config, var, SecureSetting, SecureSettingError};
+use charted_common::TRUTHY_REGEX;
+
+make_config! {
+    /// Configuration to create a Redis connection pool
+    RedisConfig {
+        #[serde(default, skip_serializing_if = "Option::is_none")]
+        master_name: Option<String> {
+            default: None;
+            env_value: var!("CHARTED_REDIS_SENTINEL_MASTER_NAME", is_optional: true);
+        };
+
+        #[serde(default, skip_serializing_if = "Option::is_none")]
+        password: Option<String> {
+            default: None;
+            env_value: var!("CHARTED_REDIS_PASSWORDS", is_optional: true);
+        };
+
+        #[serde(default, skip_serializing_if = "Vec::is_empty")]
+        pub hosts: Vec<String> {
+            default: default_redis_hosts();
+            env_value: var!("CHARTED_REDIS_HOSTS", {
+                or_else: default_redis_hosts();
+                mapper: |val| val.split(',').map(|f| f.to_string()).collect::<Vec<_>>();
+            });
+        };
+
+        #[serde(default = "default_tls")]
+        pub tls: bool {
+            default: default_tls();
+            env_value: var!("CHARTED_REDIS_TLS_ENABLE", {
+                or_else: default_tls();
+                mapper: |val| TRUTHY_REGEX.is_match(val.as_str());
+            });
+        };
+
+        #[serde(default = "default_db")]
+        pub db: u8 {
+            default: default_db();
+            env_value: var!("CHARTED_REDIS_DB", to: u8, or_else: default_db());
+        };
+    }
+}
+
+impl RedisConfig {
+    pub fn password(&self) -> Result<Option<String>, SecureSettingError> {
+        match self.password.clone() {
+            Some(password) => SecureSetting::new("redis.password".into()).load_optional(password.as_str()),
+            None => Ok(None),
+        }
+    }
+
+    pub fn master_name(&self) -> Result<Option<String>, SecureSettingError> {
+        match self.password.clone() {
+            Some(password) => SecureSetting::new("redis.master_name".into()).load_optional(password.as_str()),
+            None => Ok(None),
+        }
+    }
+}
+
+fn default_redis_hosts() -> Vec<String> {
+    vec!["redis://localhost:6379".into()]
+}
+
+fn default_tls() -> bool {
+    false
+}
+
+fn default_db() -> u8 {
+    2
+}