use activitypub_federation::{ config::{Data, FederationConfig, FederationMiddleware}, fetch::{object_id::ObjectId, webfinger::webfinger_resolve_actor}, http_signatures::generate_actor_keypair, traits::Actor, }; use activitystreams_kinds::public; use actix_web::{ get, http::KeepAlive, middleware, post, web, App, Error, HttpResponse, HttpServer, }; use actix_web_prom::PrometheusMetricsBuilder; use async_once::AsyncOnce; use chrono::{DateTime, Utc}; use clap::Parser; use database::Database; use entities::post; use http::{http_get_user, http_post_user_inbox, webfinger}; use objects::person::DbUser; use sea_orm::{ActiveModelTrait, DatabaseConnection, Set}; use serde::{Deserialize, Serialize}; use std::{ collections::HashMap, env, net::ToSocketAddrs, sync::{Arc, Mutex, OnceLock}, }; use tokio::signal; use tracing::{info, instrument::WithSubscriber}; use url::Url; use crate::entities::user; use crate::utils::generate_object_id; use crate::{ activities::create_post::CreatePost, database::{Config, State}, objects::post::{Mention, Note}, }; use lazy_static::lazy_static; mod activities; mod database; mod entities; mod error; mod http; mod objects; mod utils; #[derive(Debug, Serialize, Deserialize)] struct Response { health: bool, } #[derive(Parser, Debug)] #[clap(author = "April John", version, about)] /// Application configuration struct Args { /// whether to be verbose #[arg(short = 'v')] verbose: bool, /// optional parse arg for config file #[arg()] config_file: Option, } #[get("/")] async fn index(_: web::Data) -> actix_web::Result { Ok(HttpResponse::Ok().json(Response { health: true })) } #[get("/test/postmanually/{user}/{post}")] async fn post_manually( path: web::Path<(String, String)>, state: web::Data, ) -> actix_web::Result { let local_user = state.local_user().await?; let data = FEDERATION_CONFIG.get().unwrap(); let creator = webfinger_resolve_actor::(path.0.as_str(), &data.to_request_data()) .await?; let mention = Mention { href: Url::parse(&creator.id)?, kind: Default::default(), }; let id: ObjectId = generate_object_id(data.domain())?.into(); let note = Note { kind: Default::default(), id, sensitive: false, attributed_to: Url::parse(&data.local_user().await?.id).unwrap().into(), to: vec![public()], content: format!("{} {}", path.1, creator.name), tag: vec![mention], in_reply_to: None, }; CreatePost::send( note, creator.shared_inbox_or_inbox(), &data.to_request_data(), ) .await?; Ok(HttpResponse::Ok().json(Response { health: true })) } const DOMAIN_DEF: &str = "example.com"; const LOCAL_USER_NAME: &str = "example"; lazy_static! { static ref SERVER_URL: String = env::var("LISTEN").unwrap_or("127.0.0.1:8080".to_string()); static ref DATABASE_URL: String = env::var("DATABASE_URL").expect("DATABASE_URL must be set"); static ref USERNAME: String = env::var("LOCAL_USER_NAME").unwrap_or(LOCAL_USER_NAME.to_string()); static ref DOMAIN: String = env::var("FEDERATED_DOMAIN").unwrap_or(DOMAIN_DEF.to_string()); } static DB: OnceLock = OnceLock::new(); static FEDERATION_CONFIG: OnceLock> = OnceLock::new(); #[actix_web::main] async fn main() -> actix_web::Result<(), anyhow::Error> { env_logger::init_from_env(env_logger::Env::new().default_filter_or("info")); let ap_id = Url::parse(&format!( "https://{}/{}", DOMAIN.to_string(), &USERNAME.to_string() ))?; let inbox = Url::parse(&format!( "https://{}/{}/inbox", DOMAIN.to_string(), &USERNAME.to_string() ))?; let keypair = generate_actor_keypair()?; let user = entities::user::ActiveModel { id: Set(ap_id.clone().into()), username: Set(USERNAME.to_string()), name: Set("Test account <3".to_string()), inbox: Set(inbox.to_string()), public_key: Set(keypair.public_key.clone()), private_key: Set(Some(keypair.private_key.clone())), last_refreshed_at: Set(Utc::now()), follower_count: Set(0), following_count: Set(0), url: Set(ap_id.to_string()), local: Set(true), created_at: Set(Utc::now()), ..Default::default() }; let db = sea_orm::Database::connect(DATABASE_URL.to_string()).await?; info!("Connected to database: {:?}", db); DB.set(db) .expect("We were not able to save the DB conn into memory"); let db = DB.get().unwrap(); let user = user.insert(db).await; if let Err(err) = user { eprintln!("Error inserting user: {:?}", err); } else { info!("User inserted: {:?}", user.unwrap()); } let state: State = State { database_connection: Arc::new(db.clone()), }; let data = FederationConfig::builder() .domain(env::var("FEDERATED_DOMAIN").expect("FEDERATED_DOMAIN must be set")) .app_data(state.clone()) .http_signature_compat(true) .signed_fetch_actor(&state.local_user().await.unwrap()) .build() .await?; let _ = FEDERATION_CONFIG.set(data.clone()); let mut labels = HashMap::new(); labels.insert( "domain".to_string(), env::var("FEDERATED_DOMAIN") .expect("FEDERATED_DOMAIN must be set") .to_string(), ); labels.insert( "name".to_string(), env::var("LOCAL_USER_NAME") .expect("LOCAL_USER_NAME must be set") .to_string(), ); let prometheus = PrometheusMetricsBuilder::new("api") .endpoint("/metrics") .const_labels(labels) .build() .unwrap(); let http_server = HttpServer::new(move || { App::new() .app_data(web::Data::new(state.clone())) .wrap(middleware::Logger::default()) // enable logger .wrap(prometheus.clone()) .wrap(FederationMiddleware::new(data.clone())) .service(post_manually) .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)) .service(index) }) .bind(SERVER_URL.to_string())? .workers(num_cpus::get()) .shutdown_timeout(20) .keep_alive(KeepAlive::Os) .run(); tokio::spawn(http_server); match signal::ctrl_c().await { Ok(()) => {} Err(err) => { eprintln!("Unable to listen for shutdown signal: {}", err); // we also shut down in case of error } } info!("Main thread shutdown.."); Ok(()) }