caretta-sync-core 0.0.2

A local-first application framework for lazy person
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

use async_trait::async_trait;
use iroh::discovery::dns::DnsDiscovery;
use sea_orm_migration::MigratorTrait;

use crate::{
    config::{IrohConfig, RpcConfig, StorageConfig},
    error::Error,
    global::{IROH_ENDPOINT, LOCAL_DATABASE_CONNECTION},
};

#[async_trait]
pub trait ServerTrait: Send + Sync {
    async fn init_database<C, M>(config: &C) -> Result<(), Error>
    where
        C: AsRef<StorageConfig> + Send + Sync,
        M: MigratorTrait,
    {
        let _ = LOCAL_DATABASE_CONNECTION
            .get_or_try_init::<_, M>(&config.as_ref().get_local_database_path())
            .await?;
        Ok(())
    }

    async fn serve_p2p<T>(config: &T) -> Result<(), Error>
    where
        T: AsRef<IrohConfig> + Send + Sync,
    {
        let endpoint = iroh::Endpoint::builder()
            .discovery(DnsDiscovery::n0_dns())
            .bind()
            .await?;
        let _ = IROH_ENDPOINT.get_or_init(&endpoint);
        Ok(())
    }
    async fn serve_rpc<T>(config: &T) -> Result<(), Error>
    where
        T: AsRef<RpcConfig> + Send + Sync;
    async fn serve<C, M>(config: &C) -> Result<(), Error>
    where
        C: AsRef<IrohConfig> + AsRef<RpcConfig> + AsRef<StorageConfig> + Send + Sync,
        M: MigratorTrait,
    {
        Self::init_database::<_, M>(config).await?;
        tokio::try_join!(Self::serve_p2p(config), Self::serve_rpc(config))?;
        Ok(())
    }
}