chore(examples): remove actix-web code

examples/local_federation/actix_web/http.rs

@@ -1,97 +0,0 @@
-use crate::{
-    error::Error,
-    instance::DatabaseHandle,
-    objects::person::{DbUser, PersonAcceptedActivities},
-};
-use activitypub_federation::{
-    actix_web::{inbox::receive_activity, signing_actor},
-    config::{Data, FederationConfig, FederationMiddleware},
-    fetch::webfinger::{build_webfinger_response, extract_webfinger_name},
-    protocol::context::WithContext,
-    traits::{Actor, Object},
-    FEDERATION_CONTENT_TYPE,
-};
-use actix_web::{web, web::Bytes, App, HttpRequest, HttpResponse, HttpServer};
-use anyhow::anyhow;
-use serde::Deserialize;
-use tracing::info;
-
-pub fn listen(config: &FederationConfig<DatabaseHandle>) -> Result<(), Error> {
-    let hostname = config.domain();
-    info!("Listening with actix-web on {hostname}");
-    let config = config.clone();
-    let server = HttpServer::new(move || {
-        App::new()
-            .wrap(FederationMiddleware::new(config.clone()))
-            .route("/", web::get().to(http_get_system_user))
-            .route("/{user}", web::get().to(http_get_user))
-            .route("/{user}/inbox", web::post().to(http_post_user_inbox))
-            .route("/.well-known/webfinger", web::get().to(webfinger))
-    })
-    .bind(hostname)?
-    .run();
-    tokio::spawn(server);
-    Ok(())
-}
-
-/// Handles requests to fetch system user json over HTTP
-pub async fn http_get_system_user(data: Data<DatabaseHandle>) -> Result<HttpResponse, Error> {
-    let json_user = data.system_user.clone().into_json(&data).await?;
-    Ok(HttpResponse::Ok()
-        .content_type(FEDERATION_CONTENT_TYPE)
-        .json(WithContext::new_default(json_user)))
-}
-
-/// Handles requests to fetch user json over HTTP
-pub async fn http_get_user(
-    request: HttpRequest,
-    user_name: web::Path<String>,
-    data: Data<DatabaseHandle>,
-) -> Result<HttpResponse, Error> {
-    let signed_by = signing_actor::<DbUser>(&request, None, &data).await?;
-    // here, checks can be made on the actor or the domain to which
-    // it belongs, to verify whether it is allowed to access this resource
-    info!(
-        "Fetch user request is signed by system account {}",
-        signed_by.id()
-    );
-
-    let db_user = data.local_user();
-    if user_name.into_inner() == db_user.name {
-        let json_user = db_user.into_json(&data).await?;
-        Ok(HttpResponse::Ok()
-            .content_type(FEDERATION_CONTENT_TYPE)
-            .json(WithContext::new_default(json_user)))
-    } else {
-        Err(anyhow!("Invalid user").into())
-    }
-}
-
-/// Handles messages received in user inbox
-pub async fn http_post_user_inbox(
-    request: HttpRequest,
-    body: Bytes,
-    data: Data<DatabaseHandle>,
-) -> Result<HttpResponse, Error> {
-    receive_activity::<WithContext<PersonAcceptedActivities>, DbUser, DatabaseHandle>(
-        request, body, &data,
-    )
-    .await
-}
-
-#[derive(Deserialize)]
-pub struct WebfingerQuery {
-    resource: String,
-}
-
-pub async fn webfinger(
-    query: web::Query<WebfingerQuery>,
-    data: Data<DatabaseHandle>,
-) -> Result<HttpResponse, Error> {
-    let name = extract_webfinger_name(&query.resource, &data)?;
-    let db_user = data.read_user(name)?;
-    Ok(HttpResponse::Ok().json(build_webfinger_response(
-        query.resource.clone(),
-        db_user.ap_id.into_inner(),
-    )))
-}

examples/local_federation/actix_web/mod.rs

@@ -1,6 +0,0 @@
-use crate::error::Error;
-use actix_web::ResponseError;
-
-pub(crate) mod http;
-
-impl ResponseError for Error {}

examples/local_federation/instance.rs

@@ -82,7 +82,6 @@ pub async fn listen(
 ) -> Result<(), Error> {
     match webserver {
         Webserver::Axum => crate::axum::http::listen(config).await?,
-        // Webserver::ActixWeb => crate::actix_web::http::listen(config)?,
     }
     Ok(())
 }