rust/hyperswitch
1
0
Fork 0
mirror of https://github.com/juspay/hyperswitch.git synced 2025-11-02 04:04:43 +08:00
Code Issues Packages Projects Releases Wiki Activity

build: bump MSRV to 1.76.0 (#5586)

Browse Source
This commit is contained in:
Sanchith Hegde
2024-08-12 15:30:05 +05:30
committed by GitHub
parent 7718800e1f
commit 59b36a054c
90 changed files with 255 additions and 260 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
crates/drainer/src/handler.rs
View File

@ -193,10 +193,7 @@ async fn drainer_handler(
let output = store.make_stream_available(flag_stream_name.as_str()).await;
active_tasks.fetch_sub(1, atomic::Ordering::Release);
output.map_err(|err| {
logger::error!(operation = "unlock_stream", err=?err);
err
})
output.inspect_err(|err| logger::error!(operation = "unlock_stream", err=?err))
}
#[instrument(skip_all, fields(global_id, request_id, session_id))]

5
crates/drainer/src/main.rs
View File

@ -25,8 +25,11 @@ async fn main() -> DrainerResult<()> {
stores.insert(tenant_name.clone(), store);
}
#[allow(clippy::print_stdout)] // The logger has not yet been initialized
#[cfg(feature = "vergen")]
println!("Starting drainer (Version: {})", router_env::git_tag!());
{
println!("Starting drainer (Version: {})", router_env::git_tag!());
}
let _guard = router_env::setup(
&conf.log,

16
crates/drainer/src/settings.rs
View File

@ -273,6 +273,8 @@ impl Settings<SecuredSecret> {
)
.build()?;
// The logger may not yet be initialized when constructing the application configuration
#[allow(clippy::print_stderr)]
serde_path_to_error::deserialize(config).map_err(|error| {
logger::error!(%error, "Unable to deserialize application configuration");
eprintln!("Unable to deserialize application configuration: {error}");
@ -283,20 +285,28 @@ impl Settings<SecuredSecret> {
pub fn validate(&self) -> Result<(), errors::DrainerError> {
self.server.validate()?;
self.master_database.get_inner().validate()?;
// The logger may not yet be initialized when validating the application configuration
#[allow(clippy::print_stderr)]
self.redis.validate().map_err(|error| {
println!("{error}");
eprintln!("{error}");
errors::DrainerError::ConfigParsingError("invalid Redis configuration".into())
})?;
self.drainer.validate()?;
// The logger may not yet be initialized when validating the application configuration
#[allow(clippy::print_stderr)]
self.secrets_management.validate().map_err(|error| {
println!("{error}");
eprintln!("{error}");
errors::DrainerError::ConfigParsingError(
"invalid secrets management configuration".into(),
)
})?;
// The logger may not yet be initialized when validating the application configuration
#[allow(clippy::print_stderr)]
self.encryption_management.validate().map_err(|error| {
println!("{error}");
eprintln!("{error}");
errors::DrainerError::ConfigParsingError(
"invalid encryption management configuration".into(),
)