diff --git a/plume-models/src/search/actor.rs b/plume-models/src/search/actor.rs index 9a939f93..881d0284 100644 --- a/plume-models/src/search/actor.rs +++ b/plume-models/src/search/actor.rs @@ -1,6 +1,6 @@ use super::Searcher; -use crate::{db_conn::DbPool, posts::PostEvent, POST_CHAN}; -use riker::actors::{Actor, ActorFactoryArgs, Context, Sender, Subscribe, Tell}; +use crate::{db_conn::DbPool, posts::PostEvent, ACTOR_SYS, POST_CHAN}; +use riker::actors::{Actor, ActorFactoryArgs, ActorRefFactory, Context, Sender, Subscribe, Tell}; use std::sync::Arc; use tracing::error; @@ -9,6 +9,12 @@ pub struct SearchActor { conn: DbPool, } +impl SearchActor { + pub fn init(searcher: Arc, conn: DbPool) { + ACTOR_SYS.actor_of_args::("search", (searcher, conn)).expect("Failed to initialize searcher actor"); + } +} + impl Actor for SearchActor { type Msg = PostEvent;