NexVeridian/ark-invest-api-rust
1
0
Fork 0
mirror of https://github.com/NexVeridian/ark-invest-api-rust.git synced 2025-09-02 09:59:11 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

update dependencies

Browse source
This commit is contained in:
Elijah McMorris 2024-12-17 14:16:47 -08:00
parent 95669ff2c9
commit f2bc6ff33b
Signed by: NexVeridian
SSH key fingerprint: SHA256:bsA1SKZxuEcEVHAy3gY1HUeM5ykRJl0U0kQHQn0hMg8
4 changed files with 879 additions and 559 deletions
Download patch file Download diff file Expand all files Collapse all files

33
src/main.rs
View file

@ -13,7 +13,7 @@ use axum::{
BoxError, Extension, Json,
};
use lazy_static::lazy_static;
use std::{env, net::SocketAddr, time::Duration};
use std::{env, net::SocketAddr, sync::Arc, time::Duration};
use tower::{buffer::BufferLayer, limit::RateLimitLayer, ServiceBuilder};
use tower_governor::{
governor::GovernorConfigBuilder, key_extractor::SmartIpKeyExtractor, GovernorLayer,
@ -67,7 +67,7 @@ async fn main() {
};
let rate_limit_ip = || {
let config = Box::new(
let config = Arc::new(
GovernorConfigBuilder::default()
.per_millisecond(500)
.burst_size(25)
@ -77,11 +77,7 @@ async fn main() {
.unwrap(),
);
ServiceBuilder::new()
.layer(error_handler())
.layer(GovernorLayer {
config: Box::leak(config),
})
ServiceBuilder::new().layer(GovernorLayer { config })
};
let cors = || {
@ -124,8 +120,8 @@ async fn main() {
let mut api = OpenApi {
info: Info {
summary: Some(
"A REST API for ARK Invest holdings data, writen in rust using [axum](https://github.com/tokio-rs/axum),
Redoc/Swagger through [Aide](https://github.com/tamasfe/aide),
"A REST API for ARK Invest holdings data, writen in rust using [axum](https://github.com/tokio-rs/axum),
Redoc/Swagger through [Aide](https://github.com/tamasfe/aide),
and parquet using [polars](https://github.com/pola-rs/polars)\n\nNot affiliated with Ark Invest
".to_owned(),
),
@ -139,13 +135,14 @@ async fn main() {
let addr = SocketAddr::from(([0, 0, 0, 0], 3000));
println!("listening on {}", addr);
axum::Server::bind(&addr)
.serve(
app.finish_api(&mut api)
.layer(Extension(api))
.layer(CompressionLayer::new().zstd(true))
.into_make_service(),
)
.await
.unwrap();
let listener = tokio::net::TcpListener::bind("0.0.0.0:3000").await.unwrap();
axum::serve(
listener,
app.finish_api(&mut api)
.layer(Extension(api))
.layer(CompressionLayer::new().zstd(true))
.into_make_service(),
)
.await
.unwrap();
}