@@ -46,6 +46,7 @@ async fn main() {
46
46
let root_url = valk_utils:: get_var ( "ROOT_URL" ) ;
47
47
let root_url = root_url. trim_end_matches ( '/' ) . to_owned ( ) ;
48
48
let port: u16 = std:: env:: var ( "PORT" ) . map_or ( DEFAULT_PORT , |v| v. parse ( ) . unwrap ( ) ) ;
49
+
49
50
let mut default_headers = HeaderMap :: new ( ) ;
50
51
default_headers. insert ( "Accept" , "application/json" . parse ( ) . unwrap ( ) ) ;
51
52
let http_client = Client :: builder ( )
@@ -59,6 +60,7 @@ async fn main() {
59
60
. redirect ( Policy :: limited ( 100 ) )
60
61
. build ( )
61
62
. unwrap ( ) ;
63
+
62
64
let current_mcstatus: Arc < RwLock < ServicesResponse > > =
63
65
Arc :: new ( RwLock :: new ( get_mcstatus ( http_client. clone ( ) ) . await ) ) ;
64
66
tokio:: spawn ( refresh_mcstatus ( http_client, Arc :: clone ( & current_mcstatus) ) ) ;
@@ -96,6 +98,7 @@ async fn main() {
96
98
. layer ( axum:: middleware:: from_fn ( cache) ) ,
97
99
)
98
100
. with_state ( state) ;
101
+
99
102
let socket_address = SocketAddr :: from ( ( [ 0 , 0 , 0 , 0 ] , port) ) ;
100
103
let tcp = TcpListener :: bind ( socket_address) . await . unwrap ( ) ;
101
104
axum:: serve ( tcp, app)
@@ -355,7 +358,12 @@ impl<T: Serialize> IntoResponse for Json<T> {
355
358
. as_bytes ( )
356
359
. to_vec ( )
357
360
} ) ;
358
- ( [ ( CONTENT_TYPE , JSON_CTYPE . clone ( ) ) ] , body) . into_response ( )
361
+ (
362
+ StatusCode :: INTERNAL_SERVER_ERROR ,
363
+ [ ( CONTENT_TYPE , JSON_CTYPE . clone ( ) ) ] ,
364
+ body,
365
+ )
366
+ . into_response ( )
359
367
}
360
368
}
361
369
0 commit comments