README.md

@@ -89,8 +89,8 @@ service:
   # Domani can serve the domains. All records given must route to this Domani
   # instance.
   #
-  # A CNAME record with the interface_domain of this server is automatically
-  # included, if it's not null itself.
+  # A CNAME record with the primary_domain of this server is automatically
+  # included.
   dns_records:
     #- kind: A
     #  addr: 127.0.0.1
@@ -105,9 +105,7 @@ service:
   # The domain name which will be used to serve the web interface of Domani. If
   # service.http.https_addr is enabled then an HTTPS certificate for this domain
   # will be retrieved automatically.
-  #
-  # This can be set to null to disable the web interface entirely.
-  #interface_domain: "localhost"
+  #primary_domain: "localhost"
 
   #http:
 

config.yml.tpl

@@ -13,6 +13,7 @@ domain:
       public: true
 service:
   passphrase: foobar
+  primary_domain: localhost
   dns_records:
     - kind: A
       addr: 127.0.0.1

src/domain/checker.rs

@@ -32,12 +32,14 @@ pub struct DNSChecker {
     // TODO we should use some kind of connection pool here, I suppose
     client: tokio::sync::Mutex<AsyncClient>,
     token_store: Box<dyn token::Store + Send + Sync>,
+    service_primary_domain: domain::Name,
 }
 
 impl DNSChecker {
     pub async fn new<TokenStore>(
         token_store: TokenStore,
         config: &domain::ConfigDNS,
+        service_primary_domain: domain::Name,
     ) -> Result<Self, unexpected::Error>
     where
         TokenStore: token::Store + Send + Sync + 'static,
@@ -50,6 +52,7 @@ impl DNSChecker {
         Ok(Self {
             token_store: Box::from(token_store),
             client: tokio::sync::Mutex::new(client),
+            service_primary_domain,
         })
     }
 
@@ -108,7 +111,7 @@ impl DNSChecker {
 
         let body = match reqwest::get(format!(
             "http://{}/.well-known/domani-challenge",
-            domain.as_str(),
+            self.service_primary_domain.as_str()
         ))
         .await
         {

src/domain/manager.rs

@@ -139,9 +139,7 @@ impl From<store::SetError> for SyncWithSettingsError {
 
 pub type GetAcmeHttp01ChallengeKeyError = acme::manager::GetHttp01ChallengeKeyError;
 
-pub type StoredDomain = domain::store::StoredDomain;
-
-#[mockall::automock]
+//#[mockall::automock]
 pub trait Manager: Sync + Send {
     fn get_settings(&self, domain: &domain::Name) -> Result<GetSettingsResult, GetSettingsError>;
 
@@ -167,7 +165,7 @@ pub trait Manager: Sync + Send {
         domain: &domain::Name,
     ) -> unexpected::Result<Option<String>>;
 
-    fn all_domains(&self) -> Result<Vec<StoredDomain>, unexpected::Error>;
+    fn all_domains(&self) -> Result<Vec<domain::Name>, unexpected::Error>;
 }
 
 pub struct ManagerImpl {
@@ -249,13 +247,13 @@ impl ManagerImpl {
         }
         .into_iter();
 
-        for StoredDomain { domain, .. } in domains {
+        for domain in domains {
             log::info!("Syncing domain {}", &domain);
 
             let get_res = match self.domain_store.get(&domain) {
                 Ok(get_res) => get_res,
                 Err(err) => {
-                    log::error!("Failed to fetch settings for domain {domain}: {err}");
+                    log::error!("Error syncing {domain}: {err}");
                     return;
                 }
             };
@@ -336,7 +334,7 @@ impl Manager for ManagerImpl {
         self.domain_checker.get_challenge_token(domain)
     }
 
-    fn all_domains(&self) -> Result<Vec<StoredDomain>, unexpected::Error> {
+    fn all_domains(&self) -> Result<Vec<domain::Name>, unexpected::Error> {
         self.domain_store.all_domains()
     }
 }

src/domain/store.rs

@@ -1,19 +1,13 @@
-use std::{collections, fs, io, path};
+use std::{collections, fs, io, path, str::FromStr};
 
 use crate::domain;
 use crate::error::unexpected::{self, Intoable, Mappable};
 
-#[derive(Debug, PartialEq)]
-/// Extra information about a domain which is related to how its stored.
-pub struct Metadata {
-    pub builtin: bool,
-    pub public: bool,
-}
-
 #[derive(Debug, PartialEq)]
 pub struct GetResult {
     pub settings: domain::Settings,
-    pub metadata: Metadata,
+    pub builtin: bool,
+    pub public: bool,
 }
 
 #[derive(thiserror::Error, Debug)]
@@ -34,16 +28,11 @@ pub enum SetError {
     Unexpected(#[from] unexpected::Error),
 }
 
-pub struct StoredDomain {
-    pub domain: domain::Name,
-    pub metadata: Metadata,
-}
-
 #[mockall::automock]
 pub trait Store {
     fn get(&self, domain: &domain::Name) -> Result<GetResult, GetError>;
     fn set(&self, domain: &domain::Name, settings: &domain::Settings) -> Result<(), SetError>;
-    fn all_domains(&self) -> Result<Vec<StoredDomain>, unexpected::Error>;
+    fn all_domains(&self) -> Result<Vec<domain::Name>, unexpected::Error>;
 }
 
 pub struct FSStore {
@@ -82,10 +71,8 @@ impl Store for FSStore {
 
         Ok(GetResult {
             settings,
-            metadata: Metadata {
             public: true,
             builtin: false,
-            },
         })
     }
 
@@ -104,23 +91,18 @@ impl Store for FSStore {
         Ok(())
     }
 
-    fn all_domains(&self) -> Result<Vec<StoredDomain>, unexpected::Error> {
+    fn all_domains(&self) -> Result<Vec<domain::Name>, unexpected::Error> {
         fs::read_dir(&self.dir_path)
             .or_unexpected()?
             .map(
-                |dir_entry_res: io::Result<fs::DirEntry>| -> Result<StoredDomain, unexpected::Error> {
+                |dir_entry_res: io::Result<fs::DirEntry>| -> Result<domain::Name, unexpected::Error> {
                     let domain = dir_entry_res.or_unexpected()?.file_name();
                     let domain = domain.to_str().ok_or(unexpected::Error::from(
                         "couldn't convert os string to &str",
                     ))?;
 
-                    Ok(StoredDomain{
-                        domain: domain.parse().map_unexpected_while(|| format!("parsing {domain} as domain name"))?,
-                        metadata: Metadata{
-                            public: true,
-                            builtin: false,
-                        },
-                    })
+                    domain::Name::from_str(domain)
+                        .map_unexpected_while(|| format!("parsing {domain} as domain name"))
                 },
             )
             .try_collect()
@@ -149,10 +131,8 @@ impl<S: Store> Store for StoreWithBuiltin<S> {
         if let Some(domain) = self.domains.get(domain) {
             return Ok(GetResult {
                 settings: domain.settings.clone(),
-                metadata: Metadata {
                 public: domain.public,
                 builtin: true,
-                },
             });
         }
         self.inner.get(domain)
@@ -165,18 +145,13 @@ impl<S: Store> Store for StoreWithBuiltin<S> {
         self.inner.set(domain, settings)
     }
 
-    fn all_domains(&self) -> Result<Vec<StoredDomain>, unexpected::Error> {
+    fn all_domains(&self) -> Result<Vec<domain::Name>, unexpected::Error> {
         let inner_domains = self.inner.all_domains()?;
-        let mut domains: Vec<StoredDomain> = self
+        let mut domains: Vec<domain::Name> = self
             .domains
             .iter()
-            .map(|(domain, v)| StoredDomain {
-                domain: domain.clone(),
-                metadata: Metadata {
-                    public: v.public,
-                    builtin: true,
-                },
-            })
+            .filter(|(_, v)| v.public)
+            .map(|(k, _)| k.clone())
             .collect();
         domains.extend(inner_domains);
         Ok(domains)
@@ -218,11 +193,9 @@ mod tests {
         assert_eq!(
             GetResult {
                 settings,
-                metadata: Metadata {
                 public: true,
                 builtin: false,
             },
-            },
             store.get(&domain).expect("settings retrieved")
         );
 
@@ -238,11 +211,9 @@ mod tests {
         assert_eq!(
             GetResult {
                 settings: new_settings,
-                metadata: Metadata {
                 public: true,
                 builtin: false,
             },
-            },
             store.get(&domain).expect("settings retrieved")
         );
     }

src/main.rs

@@ -56,25 +56,26 @@ async fn main() {
             })
         };
 
-        // inteface_cname is a CNAME record which points to the interface domain of the service.
-        // Since the interface domain _must_ point to the service (otherwise it wouldn't work) it's
+        // primary_cname is a CNAME record which points to the primary domain of the service. Since
+        // the primary domain _must_ point to the service (otherwise HTTPS wouldn't work) it's
         // reasonable to assume that a CNAME on any domain would suffice to point that domain to
         // the service.
-        if let Some(ref interface_domain) = config.service.interface_domain {
-            let interface_cname = domani::service::ConfigDNSRecord::CNAME {
-                name: interface_domain.clone(),
+        let primary_cname = domani::service::ConfigDNSRecord::CNAME {
+            name: config.service.primary_domain.clone(),
         };
 
-            let dns_records_have_interface_cname = config
+        let dns_records_have_primary_cname = config
             .service
             .dns_records
             .iter()
-                .any(|r| r == &interface_cname);
+            .any(|r| r == &primary_cname);
 
-            if !dns_records_have_interface_cname {
-                log::info!("Adding 'CNAME {interface_domain}' to service.dns_records");
-                config.service.dns_records.push(interface_cname);
-            }
+        if !dns_records_have_primary_cname {
+            log::info!(
+                "Adding 'CNAME {}' to service.dns_records",
+                &config.service.primary_domain
+            );
+            config.service.dns_records.push(primary_cname);
         }
 
         config
@@ -94,6 +95,7 @@ async fn main() {
     let domain_checker = domani::domain::checker::DNSChecker::new(
         domani::token::MemStore::new(),
         &config.domain.dns,
+        config.service.primary_domain.clone(),
     )
     .await
     .expect("domain checker initialization failed");

src/service/config.rs

@@ -2,8 +2,8 @@ use crate::{domain, service};
 use serde::{Deserialize, Serialize};
 use std::{net, str::FromStr};
 
-fn default_interface_domain() -> Option<domain::Name> {
-    Some(domain::Name::from_str("localhost").unwrap())
+fn default_primary_domain() -> domain::Name {
+    domain::Name::from_str("localhost").unwrap()
 }
 
 #[derive(Serialize, Deserialize, Clone, PartialEq)]
@@ -28,13 +28,10 @@ impl From<ConfigDNSRecord> for domain::checker::DNSRecord {
 pub struct Config {
     pub passphrase: String,
     pub dns_records: Vec<ConfigDNSRecord>,
-
-    #[serde(default = "default_interface_domain")]
-    pub interface_domain: Option<domain::Name>,
-
+    #[serde(default = "default_primary_domain")]
+    pub primary_domain: domain::Name,
     #[serde(default)]
     pub http: service::http::Config,
-
     #[serde(default)]
     pub gemini: service::gemini::Config,
 }

src/service/gemini.rs

@@ -196,7 +196,11 @@ async fn listen(
             .with_cert_resolver(service.cert_resolver.clone()),
     );
 
-    log::info!("Listening on gemini://{}", addr);
+    log::info!(
+        "Listening on gemini://{}:{}",
+        &service.config.primary_domain.clone(),
+        addr,
+    );
 
     let listener = tokio::net::TcpListener::bind(addr)
         .await

src/service/http.rs

@@ -10,6 +10,7 @@ use http::request::Parts;
 use hyper::{Body, Method, Request, Response};
 use serde::{Deserialize, Serialize};
 
+use std::str::FromStr;
 use std::{future, net, sync};
 
 use crate::error::unexpected;
@@ -163,7 +164,7 @@ impl Service {
         match self.domain_manager.get_file(&domain, &path) {
             Ok(f) => self.serve(200, &path, Body::wrap_stream(f)),
             Err(domain::manager::GetFileError::DomainNotFound) => {
-                return self.render_error_page(404, "Unknown domain name")
+                return self.render_error_page(404, "Domain not found")
             }
             Err(domain::manager::GetFileError::FileNotFound) => {
                 self.render_error_page(404, "File not found")
@@ -209,8 +210,6 @@ impl Service {
     }
 
     fn domain(&self, args: DomainArgs) -> Response<Body> {
-        use domain::store::Metadata;
-
         #[derive(Serialize)]
         struct Data {
             domain: domain::Name,
@@ -218,32 +217,14 @@ impl Service {
         }
 
         let settings = match self.domain_manager.get_settings(&args.domain) {
-            Ok(domain::manager::GetSettingsResult {
-                metadata:
-                    Metadata {
-                        public: false,
-                        builtin: _,
-                    },
-                ..
-            }) => None,
-
             Ok(domain::manager::GetSettingsResult {
                 settings,
-                metadata:
-                    Metadata {
-                        public: true,
-                        builtin: false,
-                    },
-            }) => Some(settings),
-
-            Ok(domain::manager::GetSettingsResult {
-                metadata:
-                    Metadata {
-                        public: true,
-                        builtin: true,
-                    },
-                ..
-            }) => {
+                public,
+                builtin,
+            }) => match (public, builtin) {
+                (false, _) => None,
+                (true, false) => Some(settings),
+                (true, true) => {
                     return self.render_error_page(
                         403,
                         format!(
@@ -253,7 +234,7 @@ impl Service {
                         .as_str(),
                     )
                 }
-
+            },
             Err(domain::manager::GetSettingsError::NotFound) => None,
             Err(domain::manager::GetSettingsError::Unexpected(e)) => {
                 return self.internal_error(
@@ -386,8 +367,7 @@ impl Service {
 
         let mut domains: Vec<String> = domains
             .into_iter()
-            .filter(|d| d.metadata.public)
-            .map(|d| d.domain.as_str().to_string())
+            .map(|domain| domain.as_str().to_string())
             .collect();
 
         domains.sort();
@@ -395,7 +375,83 @@ impl Service {
         self.render_page("/domains.html", Response { domains })
     }
 
-    async fn serve_interface(&self, req: Request<Body>) -> Response<Body> {
+    async fn handle_request(
+        &self,
+        client_ip: net::IpAddr,
+        req: Request<Body>,
+        req_is_https: bool,
+    ) -> Response<Body> {
+        let maybe_host = match (
+            req.headers()
+                .get("Host")
+                .and_then(|v| v.to_str().ok())
+                .map(strip_port),
+            req.uri().host().map(strip_port),
+        ) {
+            (Some(h), _) if h != self.config.primary_domain.as_str() => Some(h),
+            (_, Some(h)) if h != self.config.primary_domain.as_str() => Some(h),
+            _ => None,
+        }
+        .and_then(|h| domain::Name::from_str(h).ok());
+
+        {
+            let path = req.uri().path();
+
+            // Serving acme challenges always takes priority. We serve them from the same store no
+            // matter the domain, presumably they are cryptographically random enough that it doesn't
+            // matter.
+            if req.method() == Method::GET && path.starts_with("/.well-known/acme-challenge/") {
+                let token = path.trim_start_matches("/.well-known/acme-challenge/");
+
+                if let Ok(key) = self.domain_manager.get_acme_http01_challenge_key(token) {
+                    return self.serve(200, "token.txt", key.into());
+                }
+            }
+
+            // Serving domani challenges similarly takes priority.
+            if req.method() == Method::GET && path == "/.well-known/domani-challenge" {
+                if let Some(ref domain) = maybe_host {
+                    match self
+                        .domain_manager
+                        .get_domain_checker_challenge_token(domain)
+                    {
+                        Ok(Some(token)) => return self.serve(200, "token.txt", token.into()),
+                        Ok(None) => return self.render_error_page(404, "Token not found"),
+                        Err(e) => {
+                            return self.internal_error(
+                                format!("failed to get token for domain {}: {e}", domain).as_str(),
+                            )
+                        }
+                    }
+                }
+            }
+        }
+
+        // If a managed domain was given then serve that from its origin or a proxy.
+        if let Some(domain) = maybe_host {
+            if let Some(proxied_domain_config) = self.config.http.proxied_domains.get(&domain) {
+                return service::http::proxy::serve_http_request(
+                    proxied_domain_config,
+                    client_ip,
+                    req,
+                    req_is_https,
+                )
+                .await
+                .unwrap_or_else(|e| {
+                    self.internal_error(
+                        format!(
+                            "serving {domain} via proxy {}: {e}",
+                            proxied_domain_config.url.as_ref()
+                        )
+                        .as_str(),
+                    )
+                });
+            }
+
+            return self.serve_origin(domain, req).await;
+        }
+
+        // Serve main domani site
         let (req, body) = req.into_parts();
         let path = req.uri.path();
 
@@ -432,86 +488,6 @@ impl Service {
             ),
         }
     }
-
-    fn domain_from_req(req: &Request<Body>) -> Option<domain::Name> {
-        let host_header = req
-            .headers()
-            .get("Host")
-            .and_then(|v| v.to_str().ok())
-            .map(strip_port);
-
-        host_header
-            // if host_header isn't present, try the host from the URI
-            .or_else(|| req.uri().host().map(strip_port))
-            .and_then(|h| h.parse().ok())
-    }
-
-    async fn handle_request(
-        &self,
-        client_ip: net::IpAddr,
-        req: Request<Body>,
-        req_is_https: bool,
-    ) -> Response<Body> {
-        let domain = match Self::domain_from_req(&req) {
-            Some(domain) => domain,
-            None => return self.render_error_page(400, "Cannot serve page without domain"),
-        };
-
-        let method = req.method();
-        let path = req.uri().path();
-
-        // Serving acme challenges always takes priority. We serve them from the same store no
-        // matter the domain, presumably they are cryptographically random enough that it doesn't
-        // matter.
-        if method == Method::GET && path.starts_with("/.well-known/acme-challenge/") {
-            let token = path.trim_start_matches("/.well-known/acme-challenge/");
-
-            if let Ok(key) = self.domain_manager.get_acme_http01_challenge_key(token) {
-                return self.serve(200, "token.txt", key.into());
-            }
-        }
-
-        // Serving domani challenges similarly takes priority.
-        if method == Method::GET && path == "/.well-known/domani-challenge" {
-            match self
-                .domain_manager
-                .get_domain_checker_challenge_token(&domain)
-            {
-                Ok(Some(token)) => return self.serve(200, "token.txt", token.into()),
-                Ok(None) => return self.render_error_page(404, "Token not found"),
-                Err(e) => {
-                    return self.internal_error(
-                        format!("failed to get token for domain {}: {e}", domain).as_str(),
-                    )
-                }
-            }
-        }
-
-        if let Some(proxied_domain_config) = self.config.http.proxied_domains.get(&domain) {
-            return service::http::proxy::serve_http_request(
-                proxied_domain_config,
-                client_ip,
-                req,
-                req_is_https,
-            )
-            .await
-            .unwrap_or_else(|e| {
-                self.internal_error(
-                    format!(
-                        "serving {domain} via proxy {}: {e}",
-                        proxied_domain_config.url.as_ref()
-                    )
-                    .as_str(),
-                )
-            });
-        }
-
-        if Some(&domain) == self.config.interface_domain.as_ref() {
-            return self.serve_interface(req).await;
-        }
-
-        self.serve_origin(domain, req).await
-    }
 }
 
 fn strip_port(host: &str) -> &str {

src/service/http/tasks.rs

@@ -13,13 +13,7 @@ pub async fn listen_http(
     canceller: CancellationToken,
 ) -> Result<(), unexpected::Error> {
     let addr = service.config.http.http_addr.clone();
-
-    // only used for logging
-    let listen_host = service
-        .config
-        .interface_domain
-        .clone()
-        .map_or(addr.ip().to_string(), |ref d| d.as_str().to_string());
+    let primary_domain = service.config.primary_domain.clone();
 
     let make_service = hyper::service::make_service_fn(move |conn: &AddrStream| {
         let service = service.clone();
@@ -37,7 +31,11 @@ pub async fn listen_http(
         async move { Ok::<_, convert::Infallible>(hyper_service) }
     });
 
-    log::info!("Listening on http://{}:{}", listen_host, addr.port(),);
+    log::info!(
+        "Listening on http://{}:{}",
+        primary_domain.as_str(),
+        addr.port(),
+    );
     let server = hyper::Server::bind(&addr).serve(make_service);
 
     let graceful = server.with_graceful_shutdown(async {
@@ -53,13 +51,7 @@ pub async fn listen_https(
 ) -> Result<(), unexpected::Error> {
     let cert_resolver = service.cert_resolver.clone();
     let addr = service.config.http.https_addr.unwrap().clone();
-
-    // only used for logging
-    let listen_host = service
-        .config
-        .interface_domain
-        .clone()
-        .map_or(addr.ip().to_string(), |ref d| d.as_str().to_string());
+    let primary_domain = service.config.primary_domain.clone();
 
     let make_service = hyper::service::make_service_fn(move |conn: &TlsStream<AddrStream>| {
         let service = service.clone();
@@ -99,7 +91,11 @@ pub async fn listen_https(
 
     let incoming = hyper::server::accept::from_stream(incoming);
 
-    log::info!("Listening on https://{}:{}", listen_host, addr.port());
+    log::info!(
+        "Listening on https://{}:{}",
+        primary_domain.as_str(),
+        addr.port()
+    );
 
     let server = hyper::Server::builder(incoming).serve(make_service);