deeplx 2.2.6

A Rust package for unlimited DeepL translation
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105

use std::net::SocketAddr;
use std::{future::IntoFuture, sync::Arc};

use deeplx::{Config, DeepLX};
use tokio::sync::watch;
use tower_http::trace::TraceLayer;
use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt};

use crate::server::{biz, conf, data, pkgs::exit::shutdown_signal, routes};
use crate::{Bootstrap, Result, error::Error};

pub fn run(args: Bootstrap) -> Result<()> {
    let manager = conf::Manager::new(args.conf.as_str());
    let config = manager.config();
    let conf::Config {
        debug,
        bind,
        concurrent,
        proxy,
        ..
    } = config
        .read()
        .expect("Config lock poisoned - this is a critical error")
        .clone();

    tracing_subscriber::registry()
        .with(
            tracing_subscriber::EnvFilter::try_from_default_env().unwrap_or_else(|_| {
                format!(
                    "{}={}",
                    env!("CARGO_CRATE_NAME"),
                    if debug { "trace" } else { "info" }
                )
                .into()
            }),
        )
        .with(tracing_subscriber::fmt::layer())
        .init();

    let cpus = std::thread::available_parallelism()?;

    tracing::info!("OS: {}", std::env::consts::OS);
    tracing::info!("Arch: {}", std::env::consts::ARCH);
    tracing::info!("CPUs: {}", cpus);
    tracing::info!("Concurrent: {}", concurrent);

    let runtime = tokio::runtime::Builder::new_multi_thread()
        .enable_all()
        .worker_threads(cpus.into())
        .build()?;

    runtime.block_on(async move {
        let translator = Arc::new(DeepLX::new(Config {
            proxy,
            ..Config::default()
        }));
        let translate_repo = Arc::new(data::translate::TranslateRepo::new(translator));
        let translate_uc = Arc::new(biz::translate::TranslateUsecase::new(translate_repo));
        let state = routes::AppState {
            translate_uc,
            config,
        };
        let app = routes::router(state).layer(TraceLayer::new_for_http());

        let socket = match bind {
            SocketAddr::V4(_) => tokio::net::TcpSocket::new_v4()?,
            SocketAddr::V6(_) => tokio::net::TcpSocket::new_v6()?,
        };

        socket.set_reuseaddr(true)?;
        socket.bind(bind)?;

        let listener = socket.listen(concurrent)?;

        tracing::info!("listening on {}", listener.local_addr()?);

        let (tx, rx) = watch::channel(());
        let tx = Arc::new(tx);

        tokio::pin! {
            let serve_fut = axum::serve(listener, app)
                .with_graceful_shutdown(shutdown_signal(Arc::clone(&tx)))
                .into_future();

            let manager_fut = manager
                .with_watcher(shutdown_signal(Arc::clone(&tx)))
                .into_future();
        }

        tokio::select! {
            _ = &mut serve_fut => {
                drop(rx);
                let _ = &mut manager_fut.await;
            },
            _ = &mut manager_fut => {
                drop(rx);
                let _ = &mut serve_fut.await;
            },
        }

        Ok::<(), Error>(())
    })?;

    Ok(())
}