use crate::app::App;
use crate::app::reload_state::{get_mtime, snapshot_include_dir_mtimes, snapshot_include_mtimes};
#[derive(Clone)]
pub struct FormBaseline {
pub alias: String,
pub hostname: String,
pub user: String,
pub port: String,
pub identity_file: String,
pub proxy_jump: String,
pub askpass: String,
pub vault_ssh: String,
pub vault_addr: String,
pub tags: String,
}
#[derive(Clone)]
pub struct TunnelFormBaseline {
pub tunnel_type: crate::tunnel::TunnelType,
pub bind_port: String,
pub remote_host: String,
pub remote_port: String,
pub bind_address: String,
}
#[derive(Clone)]
pub struct SnippetFormBaseline {
pub name: String,
pub command: String,
pub description: String,
}
#[derive(Clone)]
pub struct ProviderFormBaseline {
pub url: String,
pub token: String,
pub profile: String,
pub project: String,
pub compartment: String,
pub regions: String,
pub alias_prefix: String,
pub user: String,
pub identity_file: String,
pub verify_tls: bool,
pub auto_sync: bool,
pub vault_role: String,
pub vault_addr: String,
}
impl App {
pub fn clear_form_mtime(&mut self) {
self.conflict.form_mtime = None;
self.conflict.form_include_mtimes.clear();
self.conflict.form_include_dir_mtimes.clear();
self.conflict.provider_form_mtime = None;
}
pub fn capture_form_mtime(&mut self) {
self.conflict.form_mtime = get_mtime(&self.reload.config_path);
self.conflict.form_include_mtimes = snapshot_include_mtimes(&self.hosts_state.ssh_config);
self.conflict.form_include_dir_mtimes =
snapshot_include_dir_mtimes(&self.hosts_state.ssh_config);
}
pub fn capture_provider_form_mtime(&mut self) {
let path = dirs::home_dir().map(|h| h.join(".purple/providers"));
self.conflict.provider_form_mtime = path.as_ref().and_then(|p| get_mtime(p));
}
pub fn capture_form_baseline(&mut self) {
self.forms.host_baseline = Some(FormBaseline {
alias: self.forms.host.alias.clone(),
hostname: self.forms.host.hostname.clone(),
user: self.forms.host.user.clone(),
port: self.forms.host.port.clone(),
identity_file: self.forms.host.identity_file.clone(),
proxy_jump: self.forms.host.proxy_jump.clone(),
askpass: self.forms.host.askpass.clone(),
vault_ssh: self.forms.host.vault_ssh.clone(),
vault_addr: self.forms.host.vault_addr.clone(),
tags: self.forms.host.tags.clone(),
});
}
pub fn host_form_is_dirty(&self) -> bool {
match &self.forms.host_baseline {
Some(b) => {
self.forms.host.alias != b.alias
|| self.forms.host.hostname != b.hostname
|| self.forms.host.user != b.user
|| self.forms.host.port != b.port
|| self.forms.host.identity_file != b.identity_file
|| self.forms.host.proxy_jump != b.proxy_jump
|| self.forms.host.askpass != b.askpass
|| self.forms.host.vault_ssh != b.vault_ssh
|| self.forms.host.vault_addr != b.vault_addr
|| self.forms.host.tags != b.tags
}
None => false,
}
}
pub fn capture_tunnel_form_baseline(&mut self) {
self.tunnels.form_baseline = Some(TunnelFormBaseline {
tunnel_type: self.tunnels.form.tunnel_type,
bind_port: self.tunnels.form.bind_port.clone(),
remote_host: self.tunnels.form.remote_host.clone(),
remote_port: self.tunnels.form.remote_port.clone(),
bind_address: self.tunnels.form.bind_address.clone(),
});
}
pub fn tunnel_form_is_dirty(&self) -> bool {
match &self.tunnels.form_baseline {
Some(b) => {
self.tunnels.form.tunnel_type != b.tunnel_type
|| self.tunnels.form.bind_port != b.bind_port
|| self.tunnels.form.remote_host != b.remote_host
|| self.tunnels.form.remote_port != b.remote_port
|| self.tunnels.form.bind_address != b.bind_address
}
None => false,
}
}
pub fn capture_snippet_form_baseline(&mut self) {
self.snippets.form_baseline = Some(SnippetFormBaseline {
name: self.snippets.form.name.clone(),
command: self.snippets.form.command.clone(),
description: self.snippets.form.description.clone(),
});
}
pub fn snippet_form_is_dirty(&self) -> bool {
match &self.snippets.form_baseline {
Some(b) => {
self.snippets.form.name != b.name
|| self.snippets.form.command != b.command
|| self.snippets.form.description != b.description
}
None => false,
}
}
pub fn capture_provider_form_baseline(&mut self) {
self.providers.form_baseline = Some(ProviderFormBaseline {
url: self.providers.form.url.clone(),
token: self.providers.form.token.clone(),
profile: self.providers.form.profile.clone(),
project: self.providers.form.project.clone(),
compartment: self.providers.form.compartment.clone(),
regions: self.providers.form.regions.clone(),
alias_prefix: self.providers.form.alias_prefix.clone(),
user: self.providers.form.user.clone(),
identity_file: self.providers.form.identity_file.clone(),
verify_tls: self.providers.form.verify_tls,
auto_sync: self.providers.form.auto_sync,
vault_role: self.providers.form.vault_role.clone(),
vault_addr: self.providers.form.vault_addr.clone(),
});
}
pub fn provider_form_is_dirty(&self) -> bool {
match &self.providers.form_baseline {
Some(b) => {
self.providers.form.url != b.url
|| self.providers.form.token != b.token
|| self.providers.form.profile != b.profile
|| self.providers.form.project != b.project
|| self.providers.form.compartment != b.compartment
|| self.providers.form.regions != b.regions
|| self.providers.form.alias_prefix != b.alias_prefix
|| self.providers.form.user != b.user
|| self.providers.form.identity_file != b.identity_file
|| self.providers.form.verify_tls != b.verify_tls
|| self.providers.form.auto_sync != b.auto_sync
|| self.providers.form.vault_role != b.vault_role
|| self.providers.form.vault_addr != b.vault_addr
}
None => false,
}
}
pub fn config_changed_since_form_open(&self) -> bool {
match self.conflict.form_mtime {
Some(open_mtime) => {
if get_mtime(&self.reload.config_path) != Some(open_mtime) {
return true;
}
self.conflict
.form_include_mtimes
.iter()
.any(|(path, old_mtime)| get_mtime(path) != *old_mtime)
|| self
.conflict
.form_include_dir_mtimes
.iter()
.any(|(path, old_mtime)| get_mtime(path) != *old_mtime)
}
None => false,
}
}
pub fn provider_config_changed_since_form_open(&self) -> bool {
let path = dirs::home_dir().map(|h| h.join(".purple/providers"));
let current_mtime = path.as_ref().and_then(|p| get_mtime(p));
self.conflict.provider_form_mtime != current_mtime
}
}