chore(notifications): add sqlxmq boilerplate (#3974)

* chore(deps): bump rust deps

* chore(notifications): add sqlxmq boilerplate

* chore(deps): bump derive_builder

Cargo.toml

@@ -8,6 +8,7 @@ members = [
     "core/notifications",
     "lib/tracing-rs",
     "lib/es-entity-rs",
+    "lib/job-executor-rs",
 ]
 
 [workspace.dependencies]
@@ -16,21 +17,21 @@ async-graphql = { version = "6.0.11", default-features = false, features = ["tra
 async-graphql-axum = "6.0.11"
 axum = { version = "0.6.20", features = ["headers", "macros"] }
 jsonwebtoken = "9.2.0"
-clap = { version = "4.4.18", features = ["derive", "env"] }
-derive_builder = "0.12.0"
+clap = { version = "4.5", features = ["derive", "env"] }
+derive_builder = "0.13.0"
 serde = { version = "1.0.196", features = ["derive"] }
-tokio = { version = "1.33.0", features = ["full"] }
-reqwest = { version = "0.11.23", default-features = false, features = ["json", "rustls-tls"] }
+tokio = { version = "1.36", features = ["full"] }
+reqwest = { version = "0.11.24", default-features = false, features = ["json", "rustls-tls"] }
 thiserror = "1.0.56"
 serde_yaml = "0.9.31"
 serde_json = "1.0.111"
-chrono = { version = "0.4.32", features = ["clock", "serde"], default-features = false }
+chrono = { version = "0.4.33", features = ["clock", "serde"], default-features = false }
 futures = "0.3.30"
 sqlx = { version = "0.7.2", features = ["runtime-tokio-rustls", "postgres", "uuid", "chrono"] }
 mongodb = "2.8.0"
 uuid = { version = "1.7.0", features = ["serde", "v4"] }
 rand = "0.8.5"
-serde_with = "3.5.0"
+serde_with = "3.6.0"
 tracing = "0.1.37"
 tracing-subscriber = { version = "0.3.18", features = ["env-filter", "json"] }
 tracing-opentelemetry = "0.20.0"
@@ -45,4 +46,5 @@ tonic-health = "0.10.2"
 prost = "0.12"
 rust-i18n = "3"
 google-fcm1 = "5.0.3"
+sqlxmq = { version = "0.5", default-features = false, features = ["runtime-tokio-rustls"] }
 

core/api-keys/src/server/mod.rs

@@ -70,7 +70,7 @@ async fn check_handler(
     State((header, app)): State<(String, ApiKeysApp)>,
     headers: HeaderMap,
 ) -> Result<Json<CheckResponse>, ApplicationError> {
-    tracing::extract_tracing(&headers);
+    tracing::http::extract_tracing(&headers);
     let key = headers.get(header).ok_or(ApplicationError::MissingApiKey)?;
     let (id, sub, read_only) = app.lookup_authenticated_subject(key.to_str()?).await?;
     let scope = if read_only {