Struct TaskManager 

pub struct TaskManager {
    pub cache_service: Arc<CacheService>,
    /* private fields */
}

Fields

cache_service: Arc<CacheService>

Implementations

impl TaskManager

pub fn new( db: &DbHandle, cache_service: Arc<CacheService>, cookie_service: Option<Arc<CacheService>>, config: Arc<RwLock<Config>>, ) -> Self

Creates a task manager with repository, factory, and module assembler wiring. Narrowed dependencies: only a DB handle + cache / cookies / config are needed (it used to take the entire Arc<State> — refactor Phase 2). With db = None (or without the store feature) it enters no-DB mode, synthesizing tasks from the in-memory module registry.

pub async fn add_module(&self, work: Arc<dyn ModuleTrait>)

Registers one module implementation.

pub async fn add_modules(&self, works: Vec<Arc<dyn ModuleTrait>>)

Registers multiple module implementations.

pub async fn exists_module(&self, name: &str) -> bool

Returns true when module name is registered.

pub async fn remove_work(&self, name: &str)

Unregisters module by name.

pub async fn remove_by_origin(&self, origin: &Path)

Removes all modules loaded from a given origin path.

pub async fn module_names(&self) -> Vec<String>

Returns all registered module names.

pub async fn set_origin(&self, names: &[String], origin: &Path)

Tags module names with origin path for hot-reload bookkeeping.

pub async fn load_with_model(&self, task_model: &TaskEvent) -> Result<Task>

Loads task from TaskModel and synchronizes initial state.

pub async fn load_parser(&self, parser_model: &TaskParserEvent) -> Result<Task>

Loads task from ParserTaskModel with historical state restoration.

pub async fn load_error(&self, error_model: &TaskErrorEvent) -> Result<Task>

Loads task from ErrorTaskModel and applies error accounting.

pub async fn load_with_response(&self, response: &Response) -> Result<Task>

Loads task context from response metadata.

pub async fn load_module_with_response( &self, response: &Response, ) -> Result<(Arc<Module>, Option<LoginInfo>)>

Loads resolved module and optional login info for parser flow.

pub async fn clear_factory_cache(&self)

Clears internal factory caches.

pub async fn get_all_modules(&self) -> Vec<Arc<dyn ModuleTrait>>

Returns all registered module implementations.