wymiller/my-website-v2
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

commented out rate limiter

Browse Source
This commit is contained in:
Wyatt J. Miller 2024-10-04 07:21:24 -04:00
parent 3c78ed5ae3
commit 1a480b3cf9
1 changed files with 21 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
backend/public/src/main.rs
View File

@ -56,23 +56,23 @@ async fn main() {
.init(); .init();
// if std::env::var("RUST_ENV").unwrap_or_else(|_| "development".to_string()) != "development" { // if std::env::var("RUST_ENV").unwrap_or_else(|_| "development".to_string()) != "development" {
println!("we're not in development, starting up the rate limiter"); //println!("we're not in development, starting up the rate limiter");
let governor_conf = Arc::new( //let governor_conf = Arc::new(
GovernorConfigBuilder::default() // GovernorConfigBuilder::default()
.per_second(2) // .per_second(2)
.burst_size(5) // .burst_size(5)
.finish() // .finish()
.unwrap(), // .unwrap(),
); //);
//
let governor_limiter = governor_conf.limiter().clone(); //let governor_limiter = governor_conf.limiter().clone();
let interval = Duration::from_secs(60); //let interval = Duration::from_secs(60);
// a separate background task to clean up //// a separate background task to clean up
std::thread::spawn(move || loop { //std::thread::spawn(move || loop {
std::thread::sleep(interval); // std::thread::sleep(interval);
tracing::info!("rate limiting storage size: {}", governor_limiter.len()); // tracing::info!("rate limiting storage size: {}", governor_limiter.len());
governor_limiter.retain_recent(); // governor_limiter.retain_recent();
}); //});
// } // }
// grabbing the database url from our env variables // grabbing the database url from our env variables
@ -105,10 +105,10 @@ async fn main() {
TraceLayer::new_for_http() TraceLayer::new_for_http()
.make_span_with(trace::DefaultMakeSpan::new().level(tracing::Level::INFO)) .make_span_with(trace::DefaultMakeSpan::new().level(tracing::Level::INFO))
.on_response(trace::DefaultOnResponse::new().level(tracing::Level::INFO)), .on_response(trace::DefaultOnResponse::new().level(tracing::Level::INFO)),
) );
.layer(GovernorLayer { //.layer(GovernorLayer {
config: governor_conf, // config: governor_conf,
}); //});
// run it with hyper // run it with hyper
let listener = TcpListener::bind("0.0.0.0:3000").await.unwrap(); let listener = TcpListener::bind("0.0.0.0:3000").await.unwrap();