par_term_config/
profile.rs

1//! Profile configuration types.
2//!
3//! Defines configuration types for profile management including
4//! dynamic profile sources.
5
6use serde::{Deserialize, Serialize};
7use std::collections::HashMap;
8
9// ── Serde default helpers ──────────────────────────────────────────────
10
11fn default_refresh_interval_secs() -> u64 {
12    1800
13}
14
15fn default_max_size_bytes() -> usize {
16    1_048_576
17}
18
19fn default_fetch_timeout_secs() -> u64 {
20    10
21}
22
23fn default_true() -> bool {
24    true
25}
26
27/// How to resolve conflicts when a remote profile has the same ID as a local one
28#[derive(Debug, Clone, Default, Serialize, Deserialize, PartialEq)]
29#[serde(rename_all = "snake_case")]
30pub enum ConflictResolution {
31    /// Local profile takes precedence over remote
32    #[default]
33    LocalWins,
34    /// Remote profile takes precedence over local
35    RemoteWins,
36}
37
38impl ConflictResolution {
39    /// Returns all variants of `ConflictResolution`
40    pub fn variants() -> &'static [ConflictResolution] {
41        &[
42            ConflictResolution::LocalWins,
43            ConflictResolution::RemoteWins,
44        ]
45    }
46
47    /// Returns a human-readable display name for this variant
48    pub fn display_name(&self) -> &'static str {
49        match self {
50            ConflictResolution::LocalWins => "Local Wins",
51            ConflictResolution::RemoteWins => "Remote Wins",
52        }
53    }
54}
55
56/// A remote profile source configuration stored in the main config file
57#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
58pub struct DynamicProfileSource {
59    /// URL to fetch profiles YAML from
60    pub url: String,
61
62    /// Custom HTTP headers to include in the fetch request (e.g., Authorization)
63    #[serde(default, skip_serializing_if = "HashMap::is_empty")]
64    pub headers: HashMap<String, String>,
65
66    /// How often to re-fetch profiles, in seconds (default: 1800 = 30 min)
67    #[serde(default = "default_refresh_interval_secs")]
68    pub refresh_interval_secs: u64,
69
70    /// Maximum allowed response size in bytes (default: 1 MB)
71    #[serde(default = "default_max_size_bytes")]
72    pub max_size_bytes: usize,
73
74    /// Timeout for the HTTP fetch request, in seconds (default: 10)
75    #[serde(default = "default_fetch_timeout_secs")]
76    pub fetch_timeout_secs: u64,
77
78    /// Whether this source is enabled (default: true)
79    #[serde(default = "default_true")]
80    pub enabled: bool,
81
82    /// How to resolve conflicts when a remote profile ID matches a local one
83    #[serde(default)]
84    pub conflict_resolution: ConflictResolution,
85}
86
87impl Default for DynamicProfileSource {
88    fn default() -> Self {
89        Self {
90            url: String::new(),
91            headers: HashMap::new(),
92            refresh_interval_secs: default_refresh_interval_secs(),
93            max_size_bytes: default_max_size_bytes(),
94            fetch_timeout_secs: default_fetch_timeout_secs(),
95            enabled: true,
96            conflict_resolution: ConflictResolution::default(),
97        }
98    }
99}
100
101#[cfg(test)]
102mod tests {
103    use super::*;
104
105    #[test]
106    fn test_default_source() {
107        let source = DynamicProfileSource::default();
108
109        assert_eq!(source.url, "");
110        assert!(source.headers.is_empty());
111        assert_eq!(source.refresh_interval_secs, 1800);
112        assert_eq!(source.max_size_bytes, 1_048_576);
113        assert_eq!(source.fetch_timeout_secs, 10);
114        assert!(source.enabled);
115        assert_eq!(source.conflict_resolution, ConflictResolution::LocalWins);
116    }
117
118    #[test]
119    fn test_serialize_deserialize_roundtrip() {
120        let mut headers = HashMap::new();
121        headers.insert("Authorization".to_string(), "Bearer tok123".to_string());
122        headers.insert("X-Custom".to_string(), "value".to_string());
123
124        let source = DynamicProfileSource {
125            url: "https://example.com/profiles.yaml".to_string(),
126            headers,
127            refresh_interval_secs: 900,
128            max_size_bytes: 512_000,
129            fetch_timeout_secs: 15,
130            enabled: false,
131            conflict_resolution: ConflictResolution::RemoteWins,
132        };
133
134        let yaml = serde_yaml::to_string(&source).expect("serialize");
135        let deserialized: DynamicProfileSource = serde_yaml::from_str(&yaml).expect("deserialize");
136
137        assert_eq!(deserialized.url, source.url);
138        assert_eq!(deserialized.headers, source.headers);
139        assert_eq!(
140            deserialized.refresh_interval_secs,
141            source.refresh_interval_secs
142        );
143        assert_eq!(deserialized.max_size_bytes, source.max_size_bytes);
144        assert_eq!(deserialized.fetch_timeout_secs, source.fetch_timeout_secs);
145        assert_eq!(deserialized.enabled, source.enabled);
146        assert_eq!(deserialized.conflict_resolution, source.conflict_resolution);
147    }
148
149    #[test]
150    fn test_deserialize_minimal_yaml() {
151        let yaml = "url: https://example.com/profiles.yaml\n";
152        let source: DynamicProfileSource = serde_yaml::from_str(yaml).expect("deserialize minimal");
153
154        assert_eq!(source.url, "https://example.com/profiles.yaml");
155        assert!(source.headers.is_empty());
156        assert_eq!(source.refresh_interval_secs, 1800);
157        assert_eq!(source.max_size_bytes, 1_048_576);
158        assert_eq!(source.fetch_timeout_secs, 10);
159        assert!(source.enabled);
160        assert_eq!(source.conflict_resolution, ConflictResolution::LocalWins);
161    }
162
163    #[test]
164    fn test_conflict_resolution_display() {
165        assert_eq!(ConflictResolution::LocalWins.display_name(), "Local Wins");
166        assert_eq!(ConflictResolution::RemoteWins.display_name(), "Remote Wins");
167    }
168
169    #[test]
170    fn test_conflict_resolution_variants() {
171        let variants = ConflictResolution::variants();
172        assert_eq!(variants.len(), 2);
173        assert_eq!(variants[0], ConflictResolution::LocalWins);
174        assert_eq!(variants[1], ConflictResolution::RemoteWins);
175    }
176}
par_term_config/profile.rs

par_term_config/
profile.rs
