geph4-client 4.9.3

Geph client
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

use std::{ops::Deref, sync::Arc, time::Duration};

use crate::{
    config::{get_conninfo_store, Opt, CONFIG},
    conninfo_store::ConnInfoStore,
};

static CONNINFO_STORE: async_once_cell::OnceCell<Arc<ConnInfoStore>> =
    async_once_cell::OnceCell::new();

pub async fn global_conninfo_store() -> Arc<ConnInfoStore> {
    CONNINFO_STORE
        .get_or_init(async {
            let (common, auth, exit_host) = match CONFIG.deref() {
                Opt::Connect(c) => (
                    &c.common,
                    &c.auth,
                    c.exit_server.clone().unwrap_or_default(),
                ),
                _ => panic!(),
            };

            loop {
                match get_conninfo_store(common, auth, &exit_host).await {
                    Ok(store) => {
                        log::info!(
                            "successfully created conninfo store with user_info: {:?}",
                            store.user_info()
                        );
                        return Arc::new(store);
                    }
                    Err(err) => log::warn!("could not get conninfo store: {:?}", err),
                }
                smol::Timer::after(Duration::from_secs(1)).await;
            }
        })
        .await
        .clone()
}

// /// The configured binder client
// static CONNINFO_STORE: Lazy<Arc<ConnInfoStore>> = Lazy::new(|| {
//     Arc::new({
//         let (common, auth, exit_host) = match CONFIG.deref() {
//             Opt::Connect(c) => (
//                 &c.common,
//                 &c.auth,
//                 c.exit_server.clone().unwrap_or_default(),
//             ),
//             _ => panic!(),
//         };
//         log::debug!("about to construct the global conninfo");
//         smol::future::block_on(async move {
//             loop {
//                 log::debug!("inside the blocked-on future for conninfo");
//                 match get_conninfo_store(common, auth, &exit_host).await {
//                     Ok(store) => {
//                         log::info!(
//                             "successfully created conninfo store with user_info: {:?}",
//                             store.user_info()
//                         );
//                         return store;
//                     }
//                     Err(err) => log::warn!("could not get conninfo store: {:?}", err),
//                 }
//                 smol::Timer::after(Duration::from_secs(1)).await;
//             }
//         })
//     })
// });