1
1
// main.rs
2
2
mod database;
3
3
mod persistent_queue;
4
- use actix_web:: { App , HttpResponse , HttpServer , Responder , middleware :: Logger , post , web } ;
4
+ use actix_web:: { middleware :: Logger , post , web , App , HttpResponse , HttpServer , Responder } ;
5
5
use database:: Database ;
6
6
use dotenv:: dotenv;
7
7
use futures:: TryFutureExt ;
8
8
use serde:: Deserialize ;
9
9
use std:: { env, sync:: Arc } ;
10
- use tokio:: time:: { Duration , sleep } ;
10
+ use tokio:: time:: { sleep , Duration } ;
11
11
use tokio_util:: sync:: CancellationToken ;
12
12
use tracing:: { error, info} ;
13
13
use tracing_subscriber:: EnvFilter ;
@@ -49,9 +49,7 @@ async fn register_project(req: web::Json<RegisterProjectRequest>, db: web::Data<
49
49
async fn main ( ) -> anyhow:: Result < ( ) > {
50
50
// Initialize environment and logging
51
51
dotenv ( ) . ok ( ) ;
52
- tracing_subscriber:: fmt ( )
53
- . with_env_filter ( EnvFilter :: try_from_default_env ( ) . unwrap_or_else ( |_| EnvFilter :: new ( "timefusion=debug,pgwire=trace,datafusion=debug" ) ) )
54
- . init ( ) ;
52
+ tracing_subscriber:: fmt ( ) . with_env_filter ( EnvFilter :: from_default_env ( ) ) . init ( ) ;
55
53
56
54
info ! ( "Starting TimeFusion application" ) ;
57
55
@@ -75,15 +73,18 @@ async fn main() -> anyhow::Result<()> {
75
73
// Start PGWire server
76
74
let pgwire_port_var = env:: var ( "PGWIRE_PORT" ) ;
77
75
info ! ( "PGWIRE_PORT environment variable: {:?}" , pgwire_port_var) ;
78
-
79
- let pg_port = pgwire_port_var. unwrap_or_else ( |_| {
80
- info ! ( "PGWIRE_PORT not set, using default port 5432" ) ;
81
- "5432" . to_string ( )
82
- } ) . parse :: < u16 > ( ) . unwrap_or_else ( |e| {
83
- error ! ( "Failed to parse PGWIRE_PORT value: {:?}, using default 5432" , e) ;
84
- 5432
85
- } ) ;
86
-
76
+
77
+ let pg_port = pgwire_port_var
78
+ . unwrap_or_else ( |_| {
79
+ info ! ( "PGWIRE_PORT not set, using default port 5432" ) ;
80
+ "5432" . to_string ( )
81
+ } )
82
+ . parse :: < u16 > ( )
83
+ . unwrap_or_else ( |e| {
84
+ error ! ( "Failed to parse PGWIRE_PORT value: {:?}, using default 5432" , e) ;
85
+ 5432
86
+ } ) ;
87
+
87
88
info ! ( "Starting PGWire server on port: {}" , pg_port) ;
88
89
let pg_server = db. start_pgwire_server ( session_context, pg_port, shutdown_token. clone ( ) ) . await ?;
89
90
0 commit comments