cosmicus 0.1.9

Cosmicus Client and Server to make the runner better
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49

use super::CosmicusServer;
use crate::types::{CancelWorkflowRun, RegisterRunner, RunWorkflowConfig};
use coodev_runner::WorkflowMessage;

pub trait ServerPlugin: Send + Sync {
  fn on_init(&self, _server: &CosmicusServer) {}
  fn on_event(&self, _event: &WorkflowMessage) {}
  fn on_runner_registered(&self, _runner: &RegisterRunner) {}
  fn on_run_workflow(&self, _options: &RunWorkflowConfig) {}
  fn on_cancel_workflow_run(&self, _options: &CancelWorkflowRun) {}
}

pub struct ServerPluginManager {
  plugins: Vec<Box<dyn ServerPlugin>>,
}

impl ServerPluginManager {
  pub fn new() -> Self {
    ServerPluginManager { plugins: vec![] }
  }

  pub fn register(&mut self, plugin: Box<dyn ServerPlugin>) {
    self.plugins.push(plugin);
  }

  pub fn on_event(&self, event: &WorkflowMessage) {
    for plugin in &self.plugins {
      plugin.on_event(event);
    }
  }

  pub fn on_runner_registered(&self, runner: &RegisterRunner) {
    for plugin in &self.plugins {
      plugin.on_runner_registered(runner);
    }
  }

  pub fn on_run_workflow(&self, options: &RunWorkflowConfig) {
    for plugin in &self.plugins {
      plugin.on_run_workflow(options);
    }
  }

  pub fn on_cancel_workflow_run(&self, options: &CancelWorkflowRun) {
    for plugin in &self.plugins {
      plugin.on_cancel_workflow_run(options);
    }
  }
}