13487327017

Committed 23 Feb 2025 10:05PM UTC coverage: 35.736% (-0.9%) from 36.597%

Build # 13487327017

Build Type

push

github

Committed by

dariusbakunas

Commit Message

feat: add connection plugin loader

Coverage Stats

0 of 55 new or added lines in 5 files covered. (0.0%)

714 of 1998 relevant lines covered (35.74%)

1.2 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/cogrs-core/src/executor/task_executor.rs

use crate::executor::task_result::TaskResult;
use crate::executor::worker_message::WorkerMessage;
use crate::inventory::host::Host;
use crate::playbook::task::Task;
use crate::vars::variable::Variable;
use anyhow::Result;
use indexmap::IndexMap;
use log::debug;
use std::collections::HashMap;
use tokio::sync::mpsc;

pub struct TaskExecutor;

impl TaskExecutor {
    pub fn new() -> Self {
        Self {}
    }

    pub async fn run(
        &self,
        host: &Host,
        task: &Task,
        task_vars: IndexMap<String, Variable>,
        sender: &mpsc::Sender<WorkerMessage>,
    ) -> Result<TaskResult> {
        debug!(
            "executor run() - task {}, host: {}",
            task.uuid(),
            host.name()
        );

        // TODO: handle conditionals

        let result = TaskResult::new(host.name(), task.uuid());
        // TODO: handle with_*
        // TODO: get connection plugin
        let plugin_loader = cogrs_plugins::plugin_loader::PluginLoader::instance();
        let loader = plugin_loader.lock().await;

        let connection_plugin = loader.get_connection_plugin(task.connection()).await?;

        Ok(result)
    }

    fn get_connection(current_connection: &str) {}
}

1	use crate::executor::task_result::TaskResult;
2	use crate::executor::worker_message::WorkerMessage;
3	use crate::inventory::host::Host;
4	use crate::playbook::task::Task;
5	use crate::vars::variable::Variable;
6	use anyhow::Result;
7	use indexmap::IndexMap;
8	use log::debug;
9	use std::collections::HashMap;
10	use tokio::sync::mpsc;
11
12	pub struct TaskExecutor;
13
14	impl TaskExecutor {
15	pub fn new() -> Self {
16	Self {}
17	}
18
NEW 19	pub async fn run(	×
20	&self,
21	host: &Host,
22	task: &Task,
23	task_vars: IndexMap<String, Variable>,
24	sender: &mpsc::Sender<WorkerMessage>,
25	) -> Result<TaskResult> {
26	debug!(	×
27	"executor run() - task {}, host: {}",
28	task.uuid(),
29	host.name()
30	);
31
32	// TODO: handle conditionals
33
34	let result = TaskResult::new(host.name(), task.uuid());	×
35	// TODO: handle with_*
36	// TODO: get connection plugin
NEW 37	let plugin_loader = cogrs_plugins::plugin_loader::PluginLoader::instance();	×
NEW 38	let loader = plugin_loader.lock().await;	×
39
NEW 40	let connection_plugin = loader.get_connection_plugin(task.connection()).await?;	×
41
42	Ok(result)	×
43	}
44
45	fn get_connection(current_connection: &str) {}	×
46	}

dariusbakunas / cogrs / 13487327017

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous