noosphere-cli 0.17.0

Reference client and pedagogical tool to demonstrate the principles of the Noosphere protocol
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

//! Concrete implementations of subcommands related to running a Noosphere
//! gateway server

use crate::native::workspace::Workspace;
use anyhow::Result;
use noosphere_core::context::HasSphereContext;
use noosphere_gateway::{Gateway, SingleTenantGatewayManager};
use std::net::{IpAddr, TcpListener};
use url::Url;

/// Start a Noosphere gateway server
pub async fn serve(
    interface: IpAddr,
    port: u16,
    ipfs_api: Url,
    name_resolver_api: Url,
    cors_origin: Option<Url>,
    workspace: &mut Workspace,
) -> Result<()> {
    workspace.ensure_sphere_initialized()?;

    let listener = TcpListener::bind((interface, port))?;
    let counterpart = workspace.counterpart_identity().await?;
    let sphere_context = workspace.sphere_context().await?;
    let gateway_identity = sphere_context
        .sphere_context()
        .await?
        .author()
        .did()
        .await?;
    let manager = SingleTenantGatewayManager::new(sphere_context, counterpart.clone()).await?;

    let gateway = Gateway::new(manager, ipfs_api, name_resolver_api, cors_origin)?;

    info!(
        r#"A geist is summoned to manage local sphere {}

    It has bound a gateway to {:?}
    It awaits updates from sphere {}..."#,
        gateway_identity,
        listener
            .local_addr()
            .expect("Unexpected missing listener address"),
        counterpart
    );

    gateway.start(listener).await?;
    Ok(())
}