nik/chorus
1
0
Fork 0
mirror of https://github.com/mikedilger/chorus.git synced 2026-08-31 07:31:01 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Serve NIP-11

Browse Source
This commit is contained in:
Mike Dilger 2023-11-23 10:45:07 +13:00
parent 6cb037986e
commit b683bc16e0
3 changed files with 68 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/globals.rs
View File

@ -9,6 +9,7 @@ pub struct Globals {
pub config: RwLock<Config>, pub config: RwLock<Config>,
pub store: OnceLock<Store>, pub store: OnceLock<Store>,
pub http_server: Http, pub http_server: Http,
pub rid: OnceLock<String>,
} }
lazy_static! { lazy_static! {
@ -21,6 +22,7 @@ lazy_static! {
config: RwLock::new(Config::default()), config: RwLock::new(Config::default()),
store: OnceLock::new(), store: OnceLock::new(),
http_server, http_server,
rid: OnceLock::new(),
} }
}; };
} }

11
src/main.rs
View File

@ -109,6 +109,15 @@ async fn serve(stream: MaybeTlsStream<TcpStream>, peer_addr: SocketAddr) -> Resu
Ok(()) Ok(())
} }
async fn handle_request(_request: Request<Body>) -> Result<Response<Body>, Error> { async fn handle_request(request: Request<Body>) -> Result<Response<Body>, Error> {
// check for Accept header of application/nostr+json
if let Some(accept) = request.headers().get("Accept") {
if let Ok(s) = accept.to_str() {
if s == "application/nostr+json" {
return web::serve_nip11().await;
}
}
}
web::serve_http().await web::serve_http().await
} }

56
src/web.rs
View File

@ -1,4 +1,6 @@
use crate::config::Config;
use crate::error::Error; use crate::error::Error;
use crate::globals::GLOBALS;
use hyper::{Body, Response, StatusCode}; use hyper::{Body, Response, StatusCode};
pub async fn serve_http() -> Result<Response<Body>, Error> { pub async fn serve_http() -> Result<Response<Body>, Error> {
@ -10,3 +12,57 @@ pub async fn serve_http() -> Result<Response<Body>, Error> {
.body("This is a nostr relay. Please use a nostr client to connect.".into())?; .body("This is a nostr relay. Please use a nostr client to connect.".into())?;
Ok(response) Ok(response)
} }
pub async fn serve_nip11() -> Result<Response<Body>, Error> {
let rid = {
let config = GLOBALS.config.read().await;
GLOBALS.rid.get_or_init(|| build_rid(&config))
};
let response = Response::builder()
.header("Access-Control-Allow-Origin", "*")
.header("Access-Control-Allow-Headers", "*")
.header("Access-Control-Allow-Methods", "*")
.header("Content-Type", "application/nostr+json")
.status(StatusCode::OK)
.body(rid.clone().into())?;
Ok(response)
}
fn build_rid(config: &Config) -> String {
let mut rid: String = String::with_capacity(255);
rid.push_str("{\"supported_nips\":[11],");
let software = env!("CARGO_PKG_NAME");
rid.push_str("\"software\":\"");
rid.push_str(software);
rid.push('\"');
let version = env!("CARGO_PKG_VERSION");
rid.push(',');
rid.push_str("\"version\":\"");
rid.push_str(version);
rid.push('\"');
if let Some(name) = &config.name {
rid.push(',');
rid.push_str("\"name\":\"");
rid.push_str(name);
rid.push('\"');
}
if let Some(description) = &config.description {
rid.push(',');
rid.push_str("\"description\":\"");
rid.push_str(description);
rid.push('\"');
}
if let Some(pubkeyhex) = &config.public_key_hex {
rid.push(',');
rid.push_str("\"pubkey\":\"");
rid.push_str(pubkeyhex);
rid.push('\"');
}
rid.push('}');
rid
}