outpost 0.0.8

A command-line application for managing outpost
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

use anyhow::{Context, Result};
use axum::Router;
use clap::Parser;
use config::ServiceConfig;
use outpost::PortMapping;
use std::{collections::HashMap, process::ExitCode};
use tokio::net::TcpListener;

pub mod config;

#[cfg(feature = "cloudflare")]
pub mod cloudflare;

#[cfg(feature = "aws")]
pub mod aws;

#[derive(Parser, Debug)]
#[clap(author, version, about, long_about = None)]
struct CommandLine {}

#[tokio::main]
async fn main() -> Result<ExitCode> {
    let _args = CommandLine::parse();
    tracing_subscriber::fmt()
        .with_env_filter(tracing_subscriber::EnvFilter::from_default_env())
        .init();

    // Load config
    let config: HashMap<String, ServiceConfig> = serde_json::from_str(
        &std::env::var("OUTPOST_CONFIG").context("get config from environment")?,
    )?;

    for (fqdn, service_config) in config.into_iter() {
        match service_config {
            #[cfg(feature = "cloudflare")]
            ServiceConfig::Cloudflare { service, ports } => {
                let ports: Vec<PortMapping> = PortMapping::from_vec(ports)?;
                tokio::spawn(async {
                    crate::cloudflare::CloudflareProxy::new(service, fqdn, ports)
                        .await
                        .unwrap()
                        .process
                        .wait()
                        .await
                        .unwrap();
                });
            }
            #[cfg(feature = "aws")]
            ServiceConfig::Aws { service, ports } => {
                let ports: Vec<PortMapping> = PortMapping::from_vec(ports)?;
                todo!();
            }
        }
    }

    let app = Router::new();
    // .route("/", get(crate::api::index));

    let listener = TcpListener::bind("0.0.0.0:3000").await?;
    axum::serve(listener, app).await?;
    Ok(ExitCode::SUCCESS)
}