[feat] db code?

This commit is contained in:
aprilthepink 2024-04-18 03:41:52 +02:00
parent 8469b236a7
commit 4d4e3ed794
8 changed files with 106 additions and 92 deletions

View file

@ -1,9 +1,5 @@
use crate::{ use crate::{
database::DatabaseHandle, database::StateHandle, entities::{post, user}, error::Error, objects::{person::DbUser, post::{DbPost, Note}}, utils::generate_object_id
error::Error,
objects::post::DbPost,
objects::{person::DbUser, post::Note},
utils::generate_object_id,
}; };
use activitypub_federation::{ use activitypub_federation::{
activity_sending::SendActivityTask, activity_sending::SendActivityTask,
@ -19,7 +15,7 @@ use url::Url;
#[derive(Deserialize, Serialize, Debug)] #[derive(Deserialize, Serialize, Debug)]
#[serde(rename_all = "camelCase")] #[serde(rename_all = "camelCase")]
pub struct CreatePost { pub struct CreatePost {
pub(crate) actor: ObjectId<DbUser>, pub(crate) actor: ObjectId<user::Model>,
#[serde(deserialize_with = "deserialize_one_or_many")] #[serde(deserialize_with = "deserialize_one_or_many")]
pub(crate) to: Vec<Url>, pub(crate) to: Vec<Url>,
pub(crate) object: Note, pub(crate) object: Note,
@ -29,7 +25,7 @@ pub struct CreatePost {
} }
impl CreatePost { impl CreatePost {
pub async fn send(note: Note, inbox: Url, data: &Data<DatabaseHandle>) -> Result<(), Error> { pub async fn send(note: Note, inbox: Url, data: &Data<StateHandle>) -> Result<(), Error> {
print!("Sending reply to {}", &note.attributed_to); print!("Sending reply to {}", &note.attributed_to);
let create = CreatePost { let create = CreatePost {
actor: note.attributed_to.clone(), actor: note.attributed_to.clone(),
@ -40,7 +36,7 @@ impl CreatePost {
}; };
let create_with_context = WithContext::new_default(create); let create_with_context = WithContext::new_default(create);
let sends = let sends =
SendActivityTask::prepare(&create_with_context, &data.local_user(), vec![inbox], data) SendActivityTask::prepare(&create_with_context, &data.local_user().await?, vec![inbox], data)
.await?; .await?;
for send in sends { for send in sends {
send.sign_and_send(data).await?; send.sign_and_send(data).await?;
@ -51,7 +47,7 @@ impl CreatePost {
#[async_trait::async_trait] #[async_trait::async_trait]
impl ActivityHandler for CreatePost { impl ActivityHandler for CreatePost {
type DataType = DatabaseHandle; type DataType = StateHandle;
type Error = crate::error::Error; type Error = crate::error::Error;
fn id(&self) -> &Url { fn id(&self) -> &Url {
@ -63,12 +59,12 @@ impl ActivityHandler for CreatePost {
} }
async fn verify(&self, data: &Data<Self::DataType>) -> Result<(), Self::Error> { async fn verify(&self, data: &Data<Self::DataType>) -> Result<(), Self::Error> {
DbPost::verify(&self.object, &self.id, data).await?; post::Model::verify(&self.object, &self.id, data).await?;
Ok(()) Ok(())
} }
async fn receive(self, data: &Data<Self::DataType>) -> Result<(), Self::Error> { async fn receive(self, data: &Data<Self::DataType>) -> Result<(), Self::Error> {
DbPost::from_json(self.object, data).await?; post::Model::from_json(self.object, data).await?;
Ok(()) Ok(())
} }
} }

View file

@ -1,9 +1,20 @@
use crate::{error::Error, objects::person::DbUser}; use crate::{entities::user, error::Error, objects::person::DbUser};
use anyhow::anyhow; use anyhow::anyhow;
use sea_orm::{DatabaseConnection, EntityTrait};
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
use std::sync::{Arc, Mutex}; use std::sync::{Arc, Mutex};
use super::entities::prelude::User;
pub type DatabaseHandle = Arc<Database>; #[derive(Debug, Clone)]
pub struct Config {}
#[derive(Debug, Clone)]
pub struct State {
pub database_connection: Arc<DatabaseConnection>,
pub config: Arc<Config>,
}
pub type StateHandle = Arc<State>;
/// Our "database" which contains all known users (local and federated) /// Our "database" which contains all known users (local and federated)
#[derive(Debug)] #[derive(Debug)]
@ -11,15 +22,15 @@ pub struct Database {
pub users: Mutex<Vec<DbUser>>, pub users: Mutex<Vec<DbUser>>,
} }
impl Database { impl State {
pub fn local_user(&self) -> DbUser { pub async fn local_user(&self) -> Result<user::Model, Error> {
let lock = self.users.lock().unwrap(); let user = User::find().one(self.database_connection.as_ref()).await?.unwrap();
lock.first().unwrap().clone() Ok(user.clone())
} }
pub fn read_user(&self, name: &str) -> Result<DbUser, Error> { pub async fn read_user(&self, name: &str) -> Result<user::Model, Error> {
let db_user = self.local_user(); let db_user = self.local_user().await?;
if name == db_user.name { if name == db_user.username {
Ok(db_user) Ok(db_user)
} else { } else {
Err(anyhow!("Invalid user {name}").into()) Err(anyhow!("Invalid user {name}").into())

View file

@ -1,5 +1,6 @@
//! `SeaORM` Entity. Generated by sea-orm-codegen 0.12.10 //! `SeaORM` Entity. Generated by sea-orm-codegen 0.12.10
use chrono::Utc;
use sea_orm::entity::prelude::*; use sea_orm::entity::prelude::*;
#[derive(Clone, Debug, PartialEq, DeriveEntityModel, Eq)] #[derive(Clone, Debug, PartialEq, DeriveEntityModel, Eq)]
@ -10,9 +11,12 @@ pub struct Model {
pub title: Option<String>, pub title: Option<String>,
pub content: String, pub content: String,
pub local: bool, pub local: bool,
pub created_at: String, #[sea_orm(column_type = "Timestamp")]
pub updated_at: Option<String>, pub created_at: chrono::DateTime<Utc>,
pub reblog_id: Option<String>, #[sea_orm(column_type = "Timestamp")]
pub updated_at: Option<chrono::DateTime<Utc>>,
#[sea_orm(column_type = "Timestamp")]
pub reblog_id: Option<chrono::DateTime<Utc>>,
pub content_type: String, pub content_type: String,
pub visibility: String, pub visibility: String,
pub reply_id: Option<String>, pub reply_id: Option<String>,

View file

@ -1,5 +1,6 @@
//! `SeaORM` Entity. Generated by sea-orm-codegen 0.12.10 //! `SeaORM` Entity. Generated by sea-orm-codegen 0.12.10
use chrono::Utc;
use sea_orm::entity::prelude::*; use sea_orm::entity::prelude::*;
#[derive(Clone, Debug, PartialEq, DeriveEntityModel, Eq)] #[derive(Clone, Debug, PartialEq, DeriveEntityModel, Eq)]
@ -13,12 +14,15 @@ pub struct Model {
pub url: String, pub url: String,
pub public_key: String, pub public_key: String,
pub private_key: Option<String>, pub private_key: Option<String>,
pub last_refreshed_at: String, #[sea_orm(column_type = "Timestamp")]
pub last_refreshed_at: chrono::DateTime<Utc>,
pub local: bool, pub local: bool,
pub follower_count: i32, pub follower_count: i32,
pub following_count: i32, pub following_count: i32,
pub created_at: String, #[sea_orm(column_type = "Timestamp")]
pub updated_at: Option<String>, pub created_at: chrono::DateTime<Utc>,
#[sea_orm(column_type = "Timestamp")]
pub updated_at: Option<chrono::DateTime<Utc>>,
pub following: Option<String>, pub following: Option<String>,
pub followers: Option<String>, pub followers: Option<String>,
pub inbox: String, pub inbox: String,

View file

@ -1,7 +1,5 @@
use crate::{ use crate::{
database::DatabaseHandle, database::StateHandle, entities::user, error::Error, objects::person::{DbUser, PersonAcceptedActivities}
error::Error,
objects::person::{DbUser, PersonAcceptedActivities},
}; };
use activitypub_federation::{ use activitypub_federation::{
actix_web::{inbox::receive_activity, signing_actor}, actix_web::{inbox::receive_activity, signing_actor},
@ -15,8 +13,9 @@ use actix_web::{web, web::Bytes, App, HttpRequest, HttpResponse, HttpServer};
use anyhow::anyhow; use anyhow::anyhow;
use serde::Deserialize; use serde::Deserialize;
use tracing::info; use tracing::info;
use url::Url;
pub fn listen(config: &FederationConfig<DatabaseHandle>) -> Result<(), Error> { pub fn listen(config: &FederationConfig<StateHandle>) -> Result<(), Error> {
let hostname = config.domain(); let hostname = config.domain();
info!("Listening with actix-web on {hostname}"); info!("Listening with actix-web on {hostname}");
let config = config.clone(); let config = config.clone();
@ -46,7 +45,7 @@ pub fn listen(config: &FederationConfig<DatabaseHandle>) -> Result<(), Error> {
pub async fn http_get_user( pub async fn http_get_user(
request: HttpRequest, request: HttpRequest,
user_name: web::Path<String>, user_name: web::Path<String>,
data: Data<DatabaseHandle>, data: Data<StateHandle>,
) -> Result<HttpResponse, Error> { ) -> Result<HttpResponse, Error> {
//let signed_by = signing_actor::<DbUser>(&request, None, &data).await?; //let signed_by = signing_actor::<DbUser>(&request, None, &data).await?;
// here, checks can be made on the actor or the domain to which // here, checks can be made on the actor or the domain to which
@ -56,8 +55,8 @@ pub async fn http_get_user(
// signed_by.id() // signed_by.id()
//); //);
let db_user = data.local_user(); let db_user = data.local_user().await?;
if user_name.into_inner() == db_user.name { if user_name.into_inner() == db_user.username {
let json_user = db_user.into_json(&data).await?; let json_user = db_user.into_json(&data).await?;
Ok(HttpResponse::Ok() Ok(HttpResponse::Ok()
.content_type(FEDERATION_CONTENT_TYPE) .content_type(FEDERATION_CONTENT_TYPE)
@ -71,9 +70,9 @@ pub async fn http_get_user(
pub async fn http_post_user_inbox( pub async fn http_post_user_inbox(
request: HttpRequest, request: HttpRequest,
body: Bytes, body: Bytes,
data: Data<DatabaseHandle>, data: Data<StateHandle>,
) -> Result<HttpResponse, Error> { ) -> Result<HttpResponse, Error> {
receive_activity::<WithContext<PersonAcceptedActivities>, DbUser, DatabaseHandle>( receive_activity::<WithContext<PersonAcceptedActivities>, user::Model, StateHandle>(
request, body, &data, request, body, &data,
) )
.await .await
@ -86,12 +85,12 @@ pub struct WebfingerQuery {
pub async fn webfinger( pub async fn webfinger(
query: web::Query<WebfingerQuery>, query: web::Query<WebfingerQuery>,
data: Data<DatabaseHandle>, data: Data<StateHandle>,
) -> Result<HttpResponse, Error> { ) -> Result<HttpResponse, Error> {
let name = extract_webfinger_name(&query.resource, &data)?; let name = extract_webfinger_name(&query.resource, &data)?;
let db_user = data.read_user(name)?; let db_user = data.read_user(name).await?;
Ok(HttpResponse::Ok().json(build_webfinger_response( Ok(HttpResponse::Ok().json(build_webfinger_response(
query.resource.clone(), query.resource.clone(),
db_user.ap_id.into_inner(), Url::parse(&db_user.id)?,
))) )))
} }

View file

@ -5,6 +5,7 @@ use clap::Parser;
use database::Database; use database::Database;
use http::{http_get_user, http_post_user_inbox, webfinger}; use http::{http_get_user, http_post_user_inbox, webfinger};
use objects::person::DbUser; use objects::person::DbUser;
use sea_orm::DatabaseConnection;
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
use std::{ use std::{
collections::HashMap, collections::HashMap,
@ -15,6 +16,8 @@ use std::{
use tokio::signal; use tokio::signal;
use tracing::info; use tracing::info;
use crate::database::{Config, State};
mod entities; mod entities;
mod activities; mod activities;
mod database; mod database;
@ -23,15 +26,6 @@ mod http;
mod objects; mod objects;
mod utils; mod utils;
#[derive(Debug, Clone)]
struct Config {}
#[derive(Debug, Clone)]
struct State {
database: Arc<Database>,
config: Arc<Config>,
}
#[derive(Debug, Serialize, Deserialize)] #[derive(Debug, Serialize, Deserialize)]
struct Response { struct Response {
health: bool, health: bool,
@ -63,6 +57,7 @@ async fn main() -> actix_web::Result<(), anyhow::Error> {
env_logger::init_from_env(env_logger::Env::new().default_filter_or("info")); env_logger::init_from_env(env_logger::Env::new().default_filter_or("info"));
let server_url = env::var("LISTEN").unwrap_or("127.0.0.1:8080".to_string()); let server_url = env::var("LISTEN").unwrap_or("127.0.0.1:8080".to_string());
let database_url = env::var("DATABASE_URL").expect("DATABASE_URL must be set");
let local_user = DbUser::new( let local_user = DbUser::new(
env::var("FEDERATED_DOMAIN") env::var("FEDERATED_DOMAIN")
@ -78,16 +73,18 @@ async fn main() -> actix_web::Result<(), anyhow::Error> {
users: Mutex::new(vec![local_user]), users: Mutex::new(vec![local_user]),
}); });
let db = sea_orm::Database::connect(database_url).await?;
let config = Config {}; let config = Config {};
let state: State = State { let state: State = State {
database: new_database, database_connection: db.into(),
config: Arc::new(config), config: Arc::new(config),
}; };
let data = FederationConfig::builder() let data = FederationConfig::builder()
.domain(env::var("FEDERATED_DOMAIN").expect("FEDERATED_DOMAIN must be set")) .domain(env::var("FEDERATED_DOMAIN").expect("FEDERATED_DOMAIN must be set"))
.app_data(state.clone().database) .app_data(state.clone())
.build() .build()
.await?; .await?;

View file

@ -1,4 +1,4 @@
use crate::{activities::create_post::CreatePost, database::DatabaseHandle, error::Error}; use crate::{activities::create_post::CreatePost, database::{State, StateHandle}, entities::{self, user}, error::Error};
use activitypub_federation::{ use activitypub_federation::{
config::Data, config::Data,
fetch::object_id::ObjectId, fetch::object_id::ObjectId,
@ -7,7 +7,8 @@ use activitypub_federation::{
protocol::{public_key::PublicKey, verification::verify_domains_match}, protocol::{public_key::PublicKey, verification::verify_domains_match},
traits::{ActivityHandler, Actor, Object}, traits::{ActivityHandler, Actor, Object},
}; };
use chrono::{DateTime, Utc}; use chrono::{prelude, DateTime, Utc};
use sea_orm::{ActiveModelTrait, ColumnTrait, EntityTrait, QueryFilter, Set};
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
use std::fmt::Debug; use std::fmt::Debug;
use url::Url; use url::Url;
@ -15,7 +16,7 @@ use url::Url;
#[derive(Debug, Clone)] #[derive(Debug, Clone)]
pub struct DbUser { pub struct DbUser {
pub name: String, pub name: String,
pub ap_id: ObjectId<DbUser>, pub ap_id: ObjectId<user::Model>,
pub inbox: Url, pub inbox: Url,
// exists for all users (necessary to verify http signatures) // exists for all users (necessary to verify http signatures)
pub public_key: String, pub public_key: String,
@ -58,14 +59,14 @@ pub struct Person {
#[serde(rename = "type")] #[serde(rename = "type")]
kind: PersonType, kind: PersonType,
preferred_username: String, preferred_username: String,
id: ObjectId<DbUser>, id: ObjectId<user::Model>,
inbox: Url, inbox: Url,
public_key: PublicKey, public_key: PublicKey,
} }
#[async_trait::async_trait] #[async_trait::async_trait]
impl Object for DbUser { impl Object for user::Model {
type DataType = DatabaseHandle; type DataType = StateHandle;
type Kind = Person; type Kind = Person;
type Error = Error; type Error = Error;
@ -77,20 +78,19 @@ impl Object for DbUser {
object_id: Url, object_id: Url,
data: &Data<Self::DataType>, data: &Data<Self::DataType>,
) -> Result<Option<Self>, Self::Error> { ) -> Result<Option<Self>, Self::Error> {
let users = data.users.lock().unwrap(); let res = entities::prelude::User::find()
let res = users .filter(entities::user::Column::Id.eq(object_id.as_str()))
.clone() .one(data.database_connection.as_ref())
.into_iter() .await?;
.find(|u| u.ap_id.inner() == &object_id);
Ok(res) Ok(res)
} }
async fn into_json(self, _data: &Data<Self::DataType>) -> Result<Self::Kind, Self::Error> { async fn into_json(self, _data: &Data<Self::DataType>) -> Result<Self::Kind, Self::Error> {
Ok(Person { Ok(Person {
preferred_username: self.name.clone(), preferred_username: self.username.clone(),
kind: Default::default(), kind: Default::default(),
id: self.ap_id.clone(), id: Url::parse(&self.id).unwrap().into(),
inbox: self.inbox.clone(), inbox: Url::parse(&self.inbox).unwrap(),
public_key: self.public_key(), public_key: self.public_key(),
}) })
} }
@ -108,22 +108,22 @@ impl Object for DbUser {
json: Self::Kind, json: Self::Kind,
_data: &Data<Self::DataType>, _data: &Data<Self::DataType>,
) -> Result<Self, Self::Error> { ) -> Result<Self, Self::Error> {
Ok(DbUser { let model = user::ActiveModel {
name: json.preferred_username, id: Set(json.id.to_string()),
ap_id: json.id, username: Set(json.preferred_username),
inbox: json.inbox, inbox: Set(json.inbox.to_string()),
public_key: json.public_key.public_key_pem, public_key: Set(json.public_key.public_key_pem),
private_key: None, local: Set(false),
last_refreshed_at: Utc::now(), ..Default::default()
followers: vec![], };
local: false, let model = model.insert(_data.database_connection.as_ref()).await?;
}) Ok(model)
} }
} }
impl Actor for DbUser { impl Actor for user::Model {
fn id(&self) -> Url { fn id(&self) -> Url {
self.ap_id.inner().clone() Url::parse(&self.id).unwrap()
} }
fn public_key_pem(&self) -> &str { fn public_key_pem(&self) -> &str {
@ -135,6 +135,6 @@ impl Actor for DbUser {
} }
fn inbox(&self) -> Url { fn inbox(&self) -> Url {
self.inbox.clone() Url::parse(&self.inbox).unwrap()
} }
} }

View file

@ -1,6 +1,5 @@
use crate::{ use crate::{
activities::create_post::CreatePost, database::DatabaseHandle, error::Error, activities::create_post::CreatePost, database::StateHandle, entities::{post, user}, error::Error, objects::person::DbUser, utils::generate_object_id
objects::person::DbUser, utils::generate_object_id,
}; };
use activitypub_federation::{ use activitypub_federation::{
config::Data, config::Data,
@ -10,14 +9,15 @@ use activitypub_federation::{
traits::{Actor, Object}, traits::{Actor, Object},
}; };
use activitystreams_kinds::link::MentionType; use activitystreams_kinds::link::MentionType;
use sea_orm::{ActiveModelTrait, Set};
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
use url::Url; use url::Url;
#[derive(Clone, Debug, Serialize, Deserialize)] #[derive(Clone, Debug, Serialize, Deserialize)]
pub struct DbPost { pub struct DbPost {
pub text: String, pub text: String,
pub ap_id: ObjectId<DbPost>, pub ap_id: ObjectId<post::Model>,
pub creator: ObjectId<DbUser>, pub creator: ObjectId<user::Model>,
pub local: bool, pub local: bool,
} }
@ -26,12 +26,12 @@ pub struct DbPost {
pub struct Note { pub struct Note {
#[serde(rename = "type")] #[serde(rename = "type")]
kind: NoteType, kind: NoteType,
id: ObjectId<DbPost>, id: ObjectId<post::Model>,
pub(crate) attributed_to: ObjectId<DbUser>, pub(crate) attributed_to: ObjectId<user::Model>,
#[serde(deserialize_with = "deserialize_one_or_many")] #[serde(deserialize_with = "deserialize_one_or_many")]
pub(crate) to: Vec<Url>, pub(crate) to: Vec<Url>,
content: String, content: String,
in_reply_to: Option<ObjectId<DbPost>>, in_reply_to: Option<ObjectId<post::Model>>,
tag: Vec<Mention>, tag: Vec<Mention>,
} }
@ -43,8 +43,8 @@ pub struct Mention {
} }
#[async_trait::async_trait] #[async_trait::async_trait]
impl Object for DbPost { impl Object for post::Model {
type DataType = DatabaseHandle; type DataType = StateHandle;
type Kind = Note; type Kind = Note;
type Error = Error; type Error = Error;
@ -74,21 +74,24 @@ impl Object for DbPost {
&json.content, &json.id &json.content, &json.id
); );
let creator = json.attributed_to.dereference(data).await?; let creator = json.attributed_to.dereference(data).await?;
let post = DbPost { let post: post::ActiveModel = post::ActiveModel {
text: json.content, content: Set(json.content.clone()),
ap_id: json.id.clone(), id: Set(json.id.to_string()),
creator: json.attributed_to.clone(), creator: Set(creator.id.to_string()),
local: false, local: Set(false),
..Default::default()
}; };
let post = post.insert(data.app_data().database_connection.clone().as_ref())
.await?;
let mention = Mention { let mention = Mention {
href: creator.ap_id.clone().into_inner(), href: Url::parse(&creator.id)?,
kind: Default::default(), kind: Default::default(),
}; };
let note = Note { let note = Note {
kind: Default::default(), kind: Default::default(),
id: generate_object_id(data.domain())?.into(), id: generate_object_id(data.domain())?.into(),
attributed_to: data.local_user().ap_id, attributed_to: Url::parse(&data.local_user().await?.id).unwrap().into(),
to: vec![public()], to: vec![public()],
content: format!("Hello {}", creator.name), content: format!("Hello {}", creator.name),
in_reply_to: Some(json.id.clone()), in_reply_to: Some(json.id.clone()),