From d53644ea1f962b6557cc4b31ec6530044e23fc71 Mon Sep 17 00:00:00 2001 From: alemi Date: Thu, 21 Mar 2024 20:36:28 +0100 Subject: [PATCH] chore: moved faker in its own file --- src/main.rs | 2 +- src/model/faker.rs | 74 ++++++++++++++++++++++++++++++++++++++++++++++ src/model/mod.rs | 69 +----------------------------------------- 3 files changed, 76 insertions(+), 69 deletions(-) create mode 100644 src/model/faker.rs diff --git a/src/main.rs b/src/main.rs index 6ca4926..d9e940f 100644 --- a/src/main.rs +++ b/src/main.rs @@ -76,7 +76,7 @@ async fn main() { CliCommand::Migrate => migrations::Migrator::up(&db, None) .await.expect("error applying migrations"), - CliCommand::Faker => model::faker(&db, args.domain) + CliCommand::Faker => model::faker::faker(&db, args.domain) .await.expect("error creating fake entities"), CliCommand::Fetch { uri, save } => fetch(&db, &uri, save) diff --git a/src/model/faker.rs b/src/model/faker.rs new file mode 100644 index 0000000..f63e421 --- /dev/null +++ b/src/model/faker.rs @@ -0,0 +1,74 @@ +use crate::{activitypub::PUBLIC_TARGET, activitystream::object::actor::Actor}; +use super::{activity, object, user, Audience}; +use sea_orm::IntoActiveModel; + +pub async fn faker(db: &sea_orm::DatabaseConnection, domain: String) -> Result<(), sea_orm::DbErr> { + use sea_orm::{EntityTrait, Set}; + + let root = super::user::Model { + id: format!("{domain}/users/root"), + name: Some("μpub".into()), + domain: crate::activitypub::domain(&domain), + preferred_username: "root".to_string(), + summary: Some("hello world! i'm manually generated but served dynamically from db! check progress at https://git.alemi.dev/upub.git".to_string()), + following: None, + followers: None, + icon: Some("https://cdn.alemi.dev/social/circle-square.png".to_string()), + image: Some("https://cdn.alemi.dev/social/someriver-xs.jpg".to_string()), + inbox: None, + shared_inbox: None, + outbox: None, + actor_type: crate::activitystream::object::actor::ActorType::Person, + created: chrono::Utc::now(), + updated: chrono::Utc::now(), + private_key: None, + // TODO generate a fresh one every time + public_key: "-----BEGIN PUBLIC KEY----- +MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEA01IkF1A8t7zUS7x3ZqIx +NvG/X43JEJTdgPOFufOKMBTK48uMqrODK3wflaK6cSOMWkoOYHyWNhw10vL53GR9 +iOOGUHTaU7aoV7KBb5Fbh/tN9ZyN/S6FdCfpXze93CzpKQGNJa4SZ4FAFw2Ji1JJ +pdT7r+vaa5TkYTQuIgeHFisVEQAhmlz9xPbfPRPxSskroK7OnJSLMZ+aJvJHc9uX +kOq9wKgagV/I5ka7H3rRLTG1mBC97lrSfNdXfPRF//S4mFs095s+Pbnj0Hajf+qf +1Dryarmn6EmQi+diyhxFD3E8PWtMSBHrK+nmsiE58zjR/gd7G8SrXr4jtW+jcI6n +UQIDAQAB +-----END PUBLIC KEY-----".into() + }; + + user::Entity::insert(root.clone().into_active_model()).exec(db).await?; + + let context = uuid::Uuid::new_v4().to_string(); + + for i in (0..100).rev() { + let oid = uuid::Uuid::new_v4(); + let aid = uuid::Uuid::new_v4(); + object::Entity::insert(object::ActiveModel { + id: Set(format!("{domain}/objects/{oid}")), + name: Set(None), + object_type: Set(crate::activitystream::object::ObjectType::Note), + attributed_to: Set(Some(format!("{domain}/users/root"))), + summary: Set(None), + context: Set(Some(context.clone())), + content: Set(Some(format!("[{i}] Tic(k). Quasiparticle of intensive multiplicity. Tics (or ticks) are intrinsically several components of autonomously numbering anorganic populations, propagating by contagion between segmentary divisions in the order of nature. Ticks - as nonqualitative differentially-decomposable counting marks - each designate a multitude comprehended as a singular variation in tic(k)-density."))), + published: Set(chrono::Utc::now() - std::time::Duration::from_secs(60*i)), + to: Set(Audience(vec![PUBLIC_TARGET.to_string()])), + bto: Set(Audience::default()), + cc: Set(Audience(vec![root.followers().id().unwrap_or("").to_string()])), + bcc: Set(Audience::default()), + }).exec(db).await?; + + activity::Entity::insert(activity::ActiveModel { + id: Set(format!("{domain}/activities/{aid}")), + activity_type: Set(crate::activitystream::object::activity::ActivityType::Create), + actor: Set(format!("{domain}/users/root")), + object: Set(Some(format!("{domain}/objects/{oid}"))), + target: Set(None), + published: Set(chrono::Utc::now() - std::time::Duration::from_secs(60*i)), + to: Set(Audience(vec![PUBLIC_TARGET.to_string()])), + bto: Set(Audience::default()), + cc: Set(Audience(vec![root.followers().id().unwrap_or("").to_string()])), + bcc: Set(Audience::default()), + }).exec(db).await?; + } + + Ok(()) +} diff --git a/src/model/mod.rs b/src/model/mod.rs index a176183..0647130 100644 --- a/src/model/mod.rs +++ b/src/model/mod.rs @@ -1,78 +1,11 @@ -use sea_orm::IntoActiveModel; - -use crate::{activitypub::PUBLIC_TARGET, activitystream::object::actor::Actor, model::activity::Audience}; - pub mod user; pub mod object; pub mod activity; +pub mod faker; #[derive(Debug, Clone, thiserror::Error)] #[error("missing required field: '{0}'")] pub struct FieldError(pub &'static str); -pub async fn faker(db: &sea_orm::DatabaseConnection, domain: String) -> Result<(), sea_orm::DbErr> { - use sea_orm::{EntityTrait, Set}; - - let root = user::Model { - id: format!("{domain}/users/root"), - name: Some("μpub".into()), - domain: crate::activitypub::domain(&domain), - preferred_username: "root".to_string(), - summary: Some("hello world! i'm manually generated but served dynamically from db! check progress at https://git.alemi.dev/upub.git".to_string()), - following: None, - followers: None, - icon: Some("https://cdn.alemi.dev/social/circle-square.png".to_string()), - image: Some("https://cdn.alemi.dev/social/someriver-xs.jpg".to_string()), - inbox: None, - shared_inbox: None, - outbox: None, - actor_type: super::activitystream::object::actor::ActorType::Person, - created: chrono::Utc::now(), - updated: chrono::Utc::now(), - private_key: None, - // TODO generate a fresh one every time - public_key: "-----BEGIN PUBLIC KEY----- -MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEA01IkF1A8t7zUS7x3ZqIx -NvG/X43JEJTdgPOFufOKMBTK48uMqrODK3wflaK6cSOMWkoOYHyWNhw10vL53GR9 -iOOGUHTaU7aoV7KBb5Fbh/tN9ZyN/S6FdCfpXze93CzpKQGNJa4SZ4FAFw2Ji1JJ -pdT7r+vaa5TkYTQuIgeHFisVEQAhmlz9xPbfPRPxSskroK7OnJSLMZ+aJvJHc9uX -kOq9wKgagV/I5ka7H3rRLTG1mBC97lrSfNdXfPRF//S4mFs095s+Pbnj0Hajf+qf -1Dryarmn6EmQi+diyhxFD3E8PWtMSBHrK+nmsiE58zjR/gd7G8SrXr4jtW+jcI6n -UQIDAQAB ------END PUBLIC KEY-----".into() - }; - - user::Entity::insert(root.clone().into_active_model()).exec(db).await?; - - let context = uuid::Uuid::new_v4().to_string(); - - for i in (0..100).rev() { - let oid = uuid::Uuid::new_v4(); - let aid = uuid::Uuid::new_v4(); - object::Entity::insert(object::ActiveModel { - id: Set(format!("{domain}/objects/{oid}")), - name: Set(None), - object_type: Set(crate::activitystream::object::ObjectType::Note), - attributed_to: Set(Some(format!("{domain}/users/root"))), - summary: Set(None), - context: Set(Some(context.clone())), - content: Set(Some(format!("[{i}] Tic(k). Quasiparticle of intensive multiplicity. Tics (or ticks) are intrinsically several components of autonomously numbering anorganic populations, propagating by contagion between segmentary divisions in the order of nature. Ticks - as nonqualitative differentially-decomposable counting marks - each designate a multitude comprehended as a singular variation in tic(k)-density."))), - published: Set(chrono::Utc::now() - std::time::Duration::from_secs(60*i)), - }).exec(db).await?; - - activity::Entity::insert(activity::ActiveModel { - id: Set(format!("{domain}/activities/{aid}")), - activity_type: Set(crate::activitystream::object::activity::ActivityType::Create), - actor: Set(format!("{domain}/users/root")), - object: Set(Some(format!("{domain}/objects/{oid}"))), - target: Set(None), - published: Set(chrono::Utc::now() - std::time::Duration::from_secs(60*i)), - to: Set(Audience(vec![PUBLIC_TARGET.to_string()])), - bto: Set(Audience::default()), - cc: Set(Audience(vec![root.followers().id().unwrap_or("").to_string()])), - bcc: Set(Audience::default()), - }).exec(db).await?; } - - Ok(()) }