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
use atproto_identity::key::{KeyType, generate_key, identify_key};
use std::path::PathBuf;
use tracing_subscriber::EnvFilter;
fn env(name: &str) -> Option<String> {
std::env::var(name).ok().filter(|value| !value.is_empty())
}
fn did_web(base_url: &str) -> anyhow::Result<String> {
let url = reqwest::Url::parse(base_url)?;
let host = url
.host_str()
.ok_or_else(|| anyhow::anyhow!("ZKWID_BASE_URL has no host"))?;
Ok(match url.port() {
Some(port) => format!("did:web:{host}%3A{port}"),
None => format!("did:web:{host}"),
})
}
#[tokio::main]
async fn main() -> anyhow::Result<()> {
tracing_subscriber::fmt()
.with_env_filter(
EnvFilter::try_from_default_env().unwrap_or_else(|_| EnvFilter::new("info")),
)
.init();
let base_url = env("ZKWID_BASE_URL").unwrap_or_else(|| "https://zkwid.test".into());
let base_url = base_url.trim_end_matches('/').to_string();
let did = match env("ZKWID_DID") {
Some(did) => did,
None => did_web(&base_url)?,
};
let signing_key = match env("ZKWID_SIGNING_KEY") {
Some(key) => identify_key(&key)?,
None => {
let key = generate_key(KeyType::P256Private)?;
println!("ZKWID_SIGNING_KEY={key}");
key
}
};
let config = zkwid_n::Config {
base_url,
did,
signing_key,
db_path: PathBuf::from(env("ZKWID_DB").unwrap_or_else(|| "zkwid.db".into())),
plc_url: env("ZKWID_PLC_URL").unwrap_or_else(|| "https://plc.directory".into()),
};
let bind = env("ZKWID_BIND").unwrap_or_else(|| "127.0.0.1:8080".into());
let state = zkwid_n::state(config).await?;
let listener = tokio::net::TcpListener::bind(&bind).await?;
tracing::info!(bind = %bind, did = %state.config.did, "zkwid-n listening");
zkwid_n::serve(state, listener).await
}
