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
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
//! Rule-based event processing and webhook configuration models.
use crate::id::*;
use chrono::{DateTime, Utc};
use serde::{Deserialize, Serialize};
use serde_json::Value;
use std::collections::HashMap;
use utoipa::ToSchema;
/// Configuration for an external webhook integration.
#[derive(Debug, Serialize, Deserialize, Clone, sqlx::FromRow, ToSchema)]
pub struct WebhookConfig {
/// Unique identifier for the webhook configuration.
pub id: WebhookId,
/// Descriptive name for the webhook.
pub name: String,
/// Optional detailed description.
pub description: Option<String>,
/// System generating the webhook (e.g., 'github', 'generic').
pub source_type: String, // 'github', 'generic', etc.
/// Secret token used to validate incoming requests.
pub secret_token: Option<String>,
/// Whether the webhook is actively receiving events.
pub is_active: bool,
/// Optional custom CA certificate for mTLS.
pub ca_cert: Option<String>,
/// Optional client certificate for mTLS.
pub client_cert: Option<String>,
/// Optional client private key for mTLS.
pub client_key: Option<String>,
/// Timestamp when the webhook was created.
pub created_at: DateTime<Utc>,
/// Timestamp when the webhook was last updated.
pub updated_at: DateTime<Utc>,
}
/// Defines a rule for triggering workflows based on incoming events.
#[derive(Debug, Serialize, Deserialize, Clone, sqlx::FromRow, ToSchema)]
pub struct EventRule {
/// Unique identifier for the event rule.
pub id: RuleId,
/// Name of the event rule.
pub name: String,
/// Optional description of the rule's behavior.
pub description: Option<String>,
/// Optional ID of the webhook this rule applies to.
pub webhook_id: Option<WebhookId>,
/// Pattern matching the type of event to handle.
pub event_type_pattern: String,
/// CEL expression used to filter matching events.
pub condition_expr: Option<String>,
/// Name of the workflow to trigger when the rule matches.
pub workflow_name: String,
/// Git repository URL containing the workflow.
pub repo_url: String,
/// Path to the workflow file within the repository.
pub workflow_path: String,
/// Git reference (branch, tag, or commit) to execute.
pub git_ref: String,
/// JSON mapping of workflow inputs to CEL expressions evaluated against the event.
pub input_mappings: Value, // Map of name -> CEL expr
/// Whether this rule is actively being evaluated.
pub is_active: bool,
/// Timestamp when the rule was created.
pub created_at: DateTime<Utc>,
/// Timestamp when the rule was last updated.
pub updated_at: DateTime<Utc>,
}
impl EventRule {
/// Returns the parsed input mappings as a hash map of string keys to CEL expressions.
pub fn get_input_mappings(&self) -> HashMap<String, String> {
serde_json::from_value(self.input_mappings.clone()).unwrap_or_default()
}
}