chore(notifications): add sqlxmq boilerplate

Cargo.toml

@@ -8,6 +8,7 @@ members = [
     "core/notifications",
     "lib/tracing-rs",
     "lib/es-entity-rs",
+    "lib/job-executor-rs",
 ]
 
 [workspace.dependencies]
@@ -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 {

core/notifications/BUCK

@@ -43,6 +43,7 @@ galoy_rust_bin(
     deps = [
         "//lib/tracing-rs:tracing",
         "//lib/es-entity-rs:es-entity",
+        "//lib/job-executor-rs:job-executor",
         "//third-party/rust:tokio",
         "//third-party/rust:anyhow",
         "//third-party/rust:async-graphql",
@@ -59,6 +60,7 @@ galoy_rust_bin(
         "//third-party/rust:chrono",
         "//third-party/rust:futures",
         "//third-party/rust:sqlx",
+        "//third-party/rust:sqlxmq",
         "//third-party/rust:mongodb",
         "//third-party/rust:rand",
         "//third-party/rust:uuid",
@@ -72,6 +74,7 @@ galoy_rust_bin(
     extra_tests = [
         "//lib/tracing-rs:tracing",
         "//lib/es-entity-rs:es-entity",
+        "//lib/job-executor-rs:job-executor",
     ],
     protos = ["proto/notifications.proto"],
     env = {

core/notifications/migrations/20210316025847_setup.down.sql

@@ -0,0 +1,12 @@
+DROP FUNCTION mq_checkpoint;
+DROP FUNCTION mq_keep_alive;
+DROP FUNCTION mq_delete;
+DROP FUNCTION mq_commit;
+DROP FUNCTION mq_insert;
+DROP FUNCTION mq_poll;
+DROP FUNCTION mq_active_channels;
+DROP FUNCTION mq_latest_message;
+DROP TABLE mq_payloads;
+DROP TABLE mq_msgs;
+DROP FUNCTION mq_uuid_exists;
+DROP TYPE mq_new_t;