ADRN/Plume
1
0
Fork 0
forked from Plume/Plume
Code Issues Pull requests Projects Releases Wiki Activity

Remove trailing 07 in remote_fetch_actor.rs

Browse source
This commit is contained in:
Kitaiti Makoto 2022-05-03 00:57:19 +09:00
parent 1b32fa1e34
commit fc99d2b7a0
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
plume-models/src/remote_fetch_actor.rs
View file

@ -6,11 +6,11 @@ use crate::{
ACTOR_SYS, CONFIG, USER_CHAN, ACTOR_SYS, CONFIG, USER_CHAN,
}; };
use activitystreams::{ use activitystreams::{
activity::{ActorAndObjectRef, Create as Create07}, activity::{ActorAndObjectRef, Create},
base::AnyBase, base::AnyBase,
object::kind::ArticleType, object::kind::ArticleType,
}; };
use plume_common::activity_pub::{inbox::FromId, LicensedArticle as LicensedArticle07}; use plume_common::activity_pub::{inbox::FromId, LicensedArticle};
use riker::actors::{Actor, ActorFactoryArgs, ActorRefFactory, Context, Sender, Subscribe, Tell}; use riker::actors::{Actor, ActorFactoryArgs, ActorRefFactory, Context, Sender, Subscribe, Tell};
use std::sync::Arc; use std::sync::Arc;
use tracing::{error, info, warn}; use tracing::{error, info, warn};
@ -68,7 +68,7 @@ impl ActorFactoryArgs<DbPool> for RemoteFetchActor {
} }
fn fetch_and_cache_articles(user: &Arc<User>, conn: &DbConn) { fn fetch_and_cache_articles(user: &Arc<User>, conn: &DbConn) {
let create_acts = user.fetch_outbox07::<Create07>(); let create_acts = user.fetch_outbox07::<Create>();
match create_acts { match create_acts {
Ok(create_acts) => { Ok(create_acts) => {
for create_act in create_acts { for create_act in create_acts {
@ -77,7 +77,7 @@ fn fetch_and_cache_articles(user: &Arc<User>, conn: &DbConn) {
.as_single_base() .as_single_base()
.and_then(|base| { .and_then(|base| {
let any_base = AnyBase::from_base(base.clone()); // FIXME: Don't clone() let any_base = AnyBase::from_base(base.clone()); // FIXME: Don't clone()
any_base.extend::<LicensedArticle07, ArticleType>().ok() any_base.extend::<LicensedArticle, ArticleType>().ok()
}) { }) {
Some(Some(article)) => { Some(Some(article)) => {
Post::from_activity07(conn, article) Post::from_activity07(conn, article)