#![allow(unused_imports)]
use super::apply_variants::*;
use super::commands::*;
use super::destroy::*;
use super::lint::*;
use super::observe::*;
use super::plan::*;
use super::validate_resources::*;
use crate::core::types;
use std::path::PathBuf;
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn test_cov_apply_args_construct_all_fields() {
let args = ApplyArgs {
file: PathBuf::from("forjar.yaml"),
machine: Some("m1".to_string()),
resource: Some("web".to_string()),
tag: Some("prod".to_string()),
group: Some("web-group".to_string()),
force: true,
refresh: false,
force_tag: None,
dry_run: true,
no_tripwire: true,
params: vec!["KEY=VALUE".to_string()],
auto_commit: true,
timeout: Some(300),
state_dir: PathBuf::from("state"),
json: true,
env_file: Some(PathBuf::from("env.yaml")),
workspace: Some("dev".to_string()),
check: true,
report: true,
force_unlock: true,
output: Some("events".to_string()),
progress: true,
timing: true,
retry: 3,
yes: true,
parallel: true,
resource_timeout: Some(60),
rollback_on_failure: true,
max_parallel: Some(4),
notify: Some("https://hooks.example.com".to_string()),
subset: Some("web-*".to_string()),
confirm_destructive: true,
backup: true,
exclude: Some("old-*".to_string()),
sequential: true,
diff_only: true,
notify_slack: Some("https://slack.example.com".to_string()),
cost_limit: Some(100),
preview: true,
tag_filter: Some("web AND NOT staging".to_string()),
output_scripts: Some(PathBuf::from("/tmp/scripts")),
resume: true,
confirm: true,
max_failures: Some(5),
rate_limit: Some(10),
labels: vec!["env=prod".to_string()],
plan_file: Some(PathBuf::from("plan.json")),
notify_email: Some("admin@example.com".to_string()),
skip: Some("legacy".to_string()),
snapshot_before: Some("pre-deploy".to_string()),
concurrency: Some(8),
webhook_before: Some("https://before.example.com".to_string()),
rollback_snapshot: Some("snap1".to_string()),
retry_delay: Some(5),
tags: vec!["web".to_string(), "prod".to_string()],
log_file: Some(PathBuf::from("apply.log")),
comment: Some("deploy v1.2".to_string()),
only_changed: true,
pre_script: Some(PathBuf::from("pre.sh")),
dry_run_json: true,
notify_webhook: Some("https://webhook.example.com".to_string()),
post_script: Some(PathBuf::from("post.sh")),
approval_required: true,
canary_percent: Some(10),
schedule: Some("0 2 * * *".to_string()),
env_name: Some("production".to_string()),
dry_run_diff: true,
notify_pagerduty: Some("key123".to_string()),
batch_size: Some(50),
notify_teams: Some("https://teams.example.com".to_string()),
abort_on_drift: true,
dry_run_summary: true,
notify_discord: Some("https://discord.example.com".to_string()),
rollback_on_threshold: Some(3),
metrics_port: Some(9090),
notify_opsgenie: Some("key456".to_string()),
circuit_breaker: Some(5),
require_approval: Some("admin".to_string()),
notify_datadog: Some("key789".to_string()),
change_window: Some("0 2-4 * * *".to_string()),
canary_machine: Some("canary1".to_string()),
notify_newrelic: Some("keyabc".to_string()),
max_duration: Some(3600),
notify_grafana: Some("https://grafana.example.com".to_string()),
rate_limit_resources: Some(5),
checkpoint_interval: Some(300),
notify_victorops: Some("keydef".to_string()),
blue_green: Some("primary".to_string()),
dry_run_cost: true,
notify_msteams_adaptive: Some("https://msteams.example.com".to_string()),
progressive: Some(25),
approval_webhook: Some("https://approve.example.com".to_string()),
notify_incident: Some("incident123".to_string()),
sign_off: Some("cto".to_string()),
notify_sns: Some("arn:aws:sns:us-east-1:123:topic".to_string()),
telemetry_endpoint: Some("https://otel.example.com".to_string()),
runbook: Some("https://wiki.example.com/runbook".to_string()),
notify_pubsub: Some("projects/p/topics/t".to_string()),
fleet_strategy: Some("rolling".to_string()),
pre_check: Some("validate.sh".to_string()),
notify_eventbridge: Some("bus-arn".to_string()),
dry_run_graph: true,
post_check: Some("verify.sh".to_string()),
notify_kafka: Some("broker:9092".to_string()),
max_retries: Some(3),
rollback_window: Some("1h".to_string()),
notify_azure_servicebus: Some("conn-string".to_string()),
approval_timeout: Some("10m".to_string()),
pre_flight: Some("check.sh".to_string()),
notify_gcp_pubsub_v2: Some("project/topic".to_string()),
checkpoint: Some("cp1".to_string()),
post_flight: Some("cleanup.sh".to_string()),
notify_rabbitmq: Some("amqp://localhost".to_string()),
gate: Some("deploy-gate".to_string()),
notify_nats: Some("nats://localhost".to_string()),
dry_run_verbose: true,
explain: true,
notify_mqtt: Some("mqtt://localhost".to_string()),
confirmation_message: Some("Are you sure?".to_string()),
summary_only: true,
notify_redis: Some("redis://localhost".to_string()),
notify_amqp: Some("amqp://localhost/exchange".to_string()),
pre_apply_hook: Some("hook.sh".to_string()),
resource_filter: Some("web-*".to_string()),
notify_stomp: Some("stomp://localhost".to_string()),
post_apply_hook: Some("post-hook.sh".to_string()),
dry_run_shell: true,
notify_zeromq: Some("tcp://localhost:5555".to_string()),
canary_resource: Some("healthcheck".to_string()),
timeout_per_resource: Some(120),
notify_grpc: Some("localhost:50051".to_string()),
skip_unchanged: true,
retry_backoff: Some(2.0),
notify_sqs: Some("https://sqs.amazonaws.com/123/queue".to_string()),
plan_output_file: Some("plan.json".to_string()),
resource_priority: vec!["web=1".to_string()],
apply_window: Some(7200),
fail_fast_machine: true,
notify_mattermost: Some("https://mattermost.example.com".to_string()),
cooldown: Some(10),
exclude_machine: Some("staging".to_string()),
notify_ntfy: Some("https://ntfy.sh/topic".to_string()),
only_machine: Some("prod-01".to_string()),
notify_webhook_headers: Some(r#"{"Authorization":"Bearer token"}"#.to_string()),
notify_log: Some(PathBuf::from("notify.log")),
notify_exec: Some("notify-script.sh".to_string()),
notify_file: Some(PathBuf::from("status.txt")),
notify_json: true,
notify_slack_webhook: Some("https://slack-wh.example.com".to_string()),
notify_telegram: Some("bot123:chat456".to_string()),
notify_webhook_v2: Some("https://v2.example.com".to_string()),
notify_discord_webhook: Some("https://discord-wh.example.com".to_string()),
notify_teams_webhook: Some("https://teams-wh.example.com".to_string()),
notify_slack_blocks: Some("https://slack-blocks.example.com".to_string()),
notify_custom_template: Some("template.json".to_string()),
notify_custom_webhook: Some("https://custom.example.com".to_string()),
notify_custom_headers: Some(r#"{"X-Custom":"value"}"#.to_string()),
notify_custom_json: Some("payload.json".to_string()),
notify_custom_filter: Some("failed".to_string()),
notify_custom_retry: Some("3".to_string()),
notify_custom_transform: Some("transform.jq".to_string()),
notify_custom_batch: Some("10".to_string()),
notify_custom_deduplicate: Some("5m".to_string()),
notify_custom_throttle: Some("10/m".to_string()),
notify_custom_aggregate: Some("1m".to_string()),
notify_custom_priority: Some("high".to_string()),
notify_custom_routing: Some("type".to_string()),
notify_custom_dedup_window: Some("5m".to_string()),
notify_custom_rate_limit: Some("100/h".to_string()),
notify_custom_backoff: Some("2.0".to_string()),
notify_custom_circuit_breaker: Some("5".to_string()),
notify_custom_dead_letter: Some("dlq".to_string()),
notify_custom_escalation: Some("critical".to_string()),
notify_custom_correlation: Some("group".to_string()),
notify_custom_sampling: Some("0.1".to_string()),
notify_custom_digest: Some("1h".to_string()),
notify_custom_severity_filter: Some("error".to_string()),
policy_check: false,
policy_dir: PathBuf::from("policies"),
refresh_only: false,
encrypt_state: false,
operator: None,
trace: false,
};
let debug = format!("{args:?}");
assert!(debug.contains("ApplyArgs"));
assert!(debug.contains("forjar.yaml"));
}
#[test]
fn test_cov_apply_args_defaults() {
let args = ApplyArgs {
file: PathBuf::from("forjar.yaml"),
machine: None,
resource: None,
tag: None,
group: None,
force: false,
refresh: false,
force_tag: None,
dry_run: false,
no_tripwire: false,
params: vec![],
auto_commit: false,
timeout: None,
state_dir: PathBuf::from("state"),
json: false,
env_file: None,
workspace: None,
check: false,
report: false,
force_unlock: false,
output: None,
progress: false,
timing: false,
retry: 0,
yes: false,
parallel: false,
resource_timeout: None,
rollback_on_failure: false,
max_parallel: None,
trace: false,
notify: None,
subset: None,
confirm_destructive: false,
backup: false,
exclude: None,
sequential: false,
diff_only: false,
notify_slack: None,
cost_limit: None,
preview: false,
tag_filter: None,
output_scripts: None,
resume: false,
confirm: false,
max_failures: None,
rate_limit: None,
labels: vec![],
plan_file: None,
notify_email: None,
skip: None,
snapshot_before: None,
concurrency: None,
webhook_before: None,
rollback_snapshot: None,
retry_delay: None,
tags: vec![],
log_file: None,
comment: None,
only_changed: false,
pre_script: None,
dry_run_json: false,
notify_webhook: None,
post_script: None,
approval_required: false,
canary_percent: None,
schedule: None,
env_name: None,
dry_run_diff: false,
notify_pagerduty: None,
batch_size: None,
notify_teams: None,
abort_on_drift: false,
dry_run_summary: false,
notify_discord: None,
rollback_on_threshold: None,
metrics_port: None,
notify_opsgenie: None,
circuit_breaker: None,
require_approval: None,
notify_datadog: None,
change_window: None,
canary_machine: None,
notify_newrelic: None,
max_duration: None,
notify_grafana: None,
rate_limit_resources: None,
checkpoint_interval: None,
notify_victorops: None,
blue_green: None,
dry_run_cost: false,
notify_msteams_adaptive: None,
progressive: None,
approval_webhook: None,
notify_incident: None,
sign_off: None,
notify_sns: None,
telemetry_endpoint: None,
runbook: None,
notify_pubsub: None,
fleet_strategy: None,
pre_check: None,
notify_eventbridge: None,
dry_run_graph: false,
post_check: None,
notify_kafka: None,
max_retries: None,
rollback_window: None,
notify_azure_servicebus: None,
approval_timeout: None,
pre_flight: None,
notify_gcp_pubsub_v2: None,
checkpoint: None,
post_flight: None,
notify_rabbitmq: None,
gate: None,
notify_nats: None,
dry_run_verbose: false,
explain: false,
notify_mqtt: None,
confirmation_message: None,
summary_only: false,
notify_redis: None,
notify_amqp: None,
pre_apply_hook: None,
resource_filter: None,
notify_stomp: None,
post_apply_hook: None,
dry_run_shell: false,
notify_zeromq: None,
canary_resource: None,
timeout_per_resource: None,
notify_grpc: None,
skip_unchanged: false,
retry_backoff: None,
notify_sqs: None,
plan_output_file: None,
resource_priority: vec![],
apply_window: None,
fail_fast_machine: false,
notify_mattermost: None,
cooldown: None,
exclude_machine: None,
notify_ntfy: None,
only_machine: None,
notify_webhook_headers: None,
notify_log: None,
notify_exec: None,
notify_file: None,
notify_json: false,
notify_slack_webhook: None,
notify_telegram: None,
notify_webhook_v2: None,
notify_discord_webhook: None,
notify_teams_webhook: None,
notify_slack_blocks: None,
notify_custom_template: None,
notify_custom_webhook: None,
notify_custom_headers: None,
notify_custom_json: None,
notify_custom_filter: None,
notify_custom_retry: None,
notify_custom_transform: None,
notify_custom_batch: None,
notify_custom_deduplicate: None,
notify_custom_throttle: None,
notify_custom_aggregate: None,
notify_custom_priority: None,
notify_custom_routing: None,
notify_custom_dedup_window: None,
notify_custom_rate_limit: None,
notify_custom_backoff: None,
notify_custom_circuit_breaker: None,
notify_custom_dead_letter: None,
notify_custom_escalation: None,
notify_custom_correlation: None,
notify_custom_sampling: None,
notify_custom_digest: None,
notify_custom_severity_filter: None,
policy_check: false,
policy_dir: PathBuf::from("policies"),
refresh_only: false,
encrypt_state: false,
operator: None,
};
let debug = format!("{args:?}");
assert!(debug.contains("ApplyArgs"));
}
}