src/routes/nodeinfo.rs

   1 use actix_web::{body::Body, error::ErrorBadRequest, *};
   2 use anyhow::anyhow;
   3 use lemmy_api::version;
   4 use lemmy_db_views::site_view::SiteView;
   5 use lemmy_structs::blocking;
   6 use lemmy_utils::{settings::Settings, LemmyError};
   7 use lemmy_websocket::LemmyContext;
   8 use serde::{Deserialize, Serialize};
   9 use url::Url;
  10
  11 pub fn config(cfg: &mut web::ServiceConfig) {
  12   cfg
  13     .route("/nodeinfo/2.0.json", web::get().to(node_info))
  14     .route("/.well-known/nodeinfo", web::get().to(node_info_well_known));
  15 }
  16
  17 async fn node_info_well_known() -> Result<HttpResponse<Body>, LemmyError> {
  18   let node_info = NodeInfoWellKnown {
  19     links: NodeInfoWellKnownLinks {
  20       rel: Url::parse("http://nodeinfo.diaspora.software/ns/schema/2.0")?,
  21       href: Url::parse(&format!(
  22         "{}/nodeinfo/2.0.json",
  23         Settings::get().get_protocol_and_hostname()
  24       ))?,
  25     },
  26   };
  27   Ok(HttpResponse::Ok().json(node_info))
  28 }
  29
  30 async fn node_info(context: web::Data<LemmyContext>) -> Result<HttpResponse, Error> {
  31   let site_view = blocking(context.pool(), SiteView::read)
  32     .await?
  33     .map_err(|_| ErrorBadRequest(LemmyError::from(anyhow!("not_found"))))?;
  34
  35   let protocols = if Settings::get().federation.enabled {
  36     vec!["activitypub".to_string()]
  37   } else {
  38     vec![]
  39   };
  40
  41   let json = NodeInfo {
  42     version: "2.0".to_string(),
  43     software: NodeInfoSoftware {
  44       name: "lemmy".to_string(),
  45       version: version::VERSION.to_string(),
  46     },
  47     protocols,
  48     usage: NodeInfoUsage {
  49       users: NodeInfoUsers {
  50         total: site_view.counts.users,
  51         active_halfyear: site_view.counts.users_active_half_year,
  52         active_month: site_view.counts.users_active_month,
  53       },
  54       local_posts: site_view.counts.posts,
  55       local_comments: site_view.counts.comments,
  56     },
  57     open_registrations: site_view.site.open_registration,
  58   };
  59
  60   Ok(HttpResponse::Ok().json(json))
  61 }
  62
  63 #[derive(Serialize, Deserialize, Debug)]
  64 struct NodeInfoWellKnown {
  65   pub links: NodeInfoWellKnownLinks,
  66 }
  67
  68 #[derive(Serialize, Deserialize, Debug)]
  69 struct NodeInfoWellKnownLinks {
  70   pub rel: Url,
  71   pub href: Url,
  72 }
  73
  74 #[derive(Serialize, Deserialize, Debug)]
  75 #[serde(rename_all = "camelCase")]
  76 struct NodeInfo {
  77   pub version: String,
  78   pub software: NodeInfoSoftware,
  79   pub protocols: Vec<String>,
  80   pub usage: NodeInfoUsage,
  81   pub open_registrations: bool,
  82 }
  83
  84 #[derive(Serialize, Deserialize, Debug)]
  85 struct NodeInfoSoftware {
  86   pub name: String,
  87   pub version: String,
  88 }
  89
  90 #[derive(Serialize, Deserialize, Debug)]
  91 #[serde(rename_all = "camelCase")]
  92 struct NodeInfoUsage {
  93   pub users: NodeInfoUsers,
  94   pub local_posts: i64,
  95   pub local_comments: i64,
  96 }
  97
  98 #[derive(Serialize, Deserialize, Debug)]
  99 #[serde(rename_all = "camelCase")]
 100 struct NodeInfoUsers {
 101   pub total: i64,
 102   pub active_halfyear: i64,
 103   pub active_month: i64,
 104 }