Add tests

Cargo.toml

@@ -34,13 +34,13 @@ serde_qs = "0.12"
 signal-hook = "0.3"
 signal-hook-tokio = { version = "0.3", features = ["futures-v0_3"] }
 sqlx = { version = "0.6", features = ["offline", "postgres", "macros", "uuid", "chrono", "json", "bigdecimal", "runtime-tokio-native-tls"] }
-svc-agent = { version = "0.20", features = ["sqlx", "queue-counter"] }
+svc-agent = { version = "0.21", features = ["sqlx", "queue-counter"] }
 svc-authn = { version = "0.8", features = ["jose", "sqlx"] }
 svc-authz = { version = "0.12" }
-svc-error = { version = "0.5", features = ["sqlx", "svc-agent", "svc-authn", "svc-authz", "sentry-extension"] }
-svc-utils = { version = "0.7", features = ["authn-extractor", "cors-middleware", "log-middleware"] }
-svc-nats-client = "0.5"
-svc-events = "0.9"
+svc-error = { version = "0.6", features = ["sqlx", "svc-agent", "svc-authn", "svc-authz", "sentry-extension"] }
+svc-utils = { version = "0.8", features = ["authn-extractor", "cors-middleware", "log-middleware"] }
+svc-nats-client = "0.8"
+svc-events = "0.11"
 tokio = { version = "1.28", features = ["full"] }
 tower = "0.4"
 tower-http = { version = "0.4", features = ["trace", "cors"] }

src/app/context.rs

@@ -34,7 +34,7 @@ pub trait GlobalContext {
     fn metrics(&self) -> Arc<Metrics>;
     fn s3_client(&self) -> Option<S3Client>;
     fn broker_client(&self) -> &dyn BrokerClient;
-    fn nats_client(&self) -> Option<&dyn NatsClient>;
+    fn nats_client(&self) -> Option<Arc<dyn NatsClient>>;
 
     async fn get_conn(&self) -> Result<PoolConnection<Postgres>, AppError> {
         self.db()
@@ -121,8 +121,8 @@ impl GlobalContext for AppContext {
         self.broker_client.as_ref()
     }
 
-    fn nats_client(&self) -> Option<&dyn NatsClient> {
-        self.nats_client.as_deref()
+    fn nats_client(&self) -> Option<Arc<dyn NatsClient>> {
+        self.nats_client.clone()
     }
 }
 
@@ -183,7 +183,7 @@ impl<'a, C: GlobalContext> GlobalContext for AppMessageContext<'a, C> {
         self.global_context.broker_client()
     }
 
-    fn nats_client(&self) -> Option<&dyn NatsClient> {
+    fn nats_client(&self) -> Option<Arc<dyn NatsClient>> {
         self.global_context.nats_client()
     }
 }