@@ -13,10 +13,13 @@ use axum::{
1313 routing:: get,
1414 routing:: post,
1515} ;
16+ #[ cfg( not( coverage) ) ]
1617use std:: net:: SocketAddr ;
1718use tower_http:: limit:: RequestBodyLimitLayer ;
1819use tracing:: { info, instrument, warn} ;
19- use trogon_nats:: jetstream:: { JetStreamContext , JetStreamPublisher , NatsJetStreamClient } ;
20+ use trogon_nats:: jetstream:: { JetStreamContext , JetStreamPublisher } ;
21+ #[ cfg( not( coverage) ) ]
22+ use trogon_nats:: jetstream:: NatsJetStreamClient ;
2023
2124#[ derive( Debug ) ]
2225pub enum ServeError {
@@ -125,6 +128,7 @@ pub async fn provision<C: JetStreamContext>(
125128 Ok ( ( ) )
126129}
127130
131+ #[ cfg( not( coverage) ) ]
128132pub fn router ( config : & GithubConfig , nats : async_nats:: Client ) -> Router {
129133 let js = NatsJetStreamClient :: new ( async_nats:: jetstream:: new ( nats) ) ;
130134
@@ -142,6 +146,7 @@ pub fn router(config: &GithubConfig, nats: async_nats::Client) -> Router {
142146 . with_state ( state)
143147}
144148
149+ #[ cfg( not( coverage) ) ]
145150pub async fn serve ( config : GithubConfig , nats : async_nats:: Client ) -> Result < ( ) , ServeError > {
146151 let js = NatsJetStreamClient :: new ( async_nats:: jetstream:: new ( nats. clone ( ) ) ) ;
147152 provision ( & js, & config) . await . map_err ( ServeError :: Provision ) ?;
@@ -160,6 +165,7 @@ pub async fn serve(config: GithubConfig, nats: async_nats::Client) -> Result<(),
160165 Ok ( ( ) )
161166}
162167
168+ #[ cfg( not( coverage) ) ]
163169async fn shutdown_signal ( ) {
164170 use tokio:: signal:: unix:: { SignalKind , signal} ;
165171
0 commit comments