mkt-cli 0.2.0

Multi-platform marketing CLI
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
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112

//! Campaign command handlers.

use mkt_core::error::Result;
use mkt_core::models::{
    CampaignFilters, CampaignId, CampaignStatus, CreateCampaignInput, UpdateCampaignInput,
};
use mkt_core::output::{OutputFormat, format_output};
use mkt_core::provider::MarketingProvider;

use crate::cli::CampaignAction;

/// Execute a campaign action against the given provider.
pub async fn execute(
    action: &CampaignAction,
    provider: &impl MarketingProvider,
    output_format: OutputFormat,
    dry_run: bool,
) -> Result<String> {
    match action {
        CampaignAction::List {
            status,
            name,
            limit,
        } => {
            let filters = CampaignFilters {
                status: status.as_deref().map(parse_status),
                name_contains: name.clone(),
                limit: *limit,
                cursor: None,
            };
            let result = provider.list_campaigns(&filters).await?;
            format_output(&result.data, output_format)
        }
        CampaignAction::Get { id } => {
            let campaign = provider
                .get_campaign(&CampaignId::from(id.as_str()))
                .await?;
            format_output(&[campaign], output_format)
        }
        CampaignAction::Create {
            name,
            objective,
            status,
            daily_budget,
            extra,
            file: _,
        } => {
            if dry_run {
                return Ok(format!(
                    "[dry-run] Would create campaign: name={name}, objective={objective}"
                ));
            }
            let extra_json = extra
                .as_deref()
                .map(serde_json::from_str)
                .transpose()
                .map_err(
                    |e: serde_json::Error| mkt_core::error::MktError::ValidationError {
                        field: "extra".into(),
                        message: format!("invalid JSON: {e}"),
                    },
                )?;
            let input = CreateCampaignInput {
                name: name.clone(),
                objective: objective.clone(),
                status: status.as_deref().map(parse_status),
                budget: daily_budget.map(|amount| mkt_core::models::Budget {
                    amount,
                    currency: "USD".into(),
                    kind: mkt_core::models::BudgetKind::Daily,
                }),
                extra: extra_json,
            };
            let campaign = provider.create_campaign(&input).await?;
            format_output(&[campaign], output_format)
        }
        CampaignAction::Update { id, name, status } => {
            if dry_run {
                return Ok(format!("[dry-run] Would update campaign {id}"));
            }
            let input = UpdateCampaignInput {
                name: name.clone(),
                status: status.as_deref().map(parse_status),
                ..Default::default()
            };
            let campaign = provider
                .update_campaign(&CampaignId::from(id.as_str()), &input)
                .await?;
            format_output(&[campaign], output_format)
        }
        CampaignAction::Delete { id } => {
            if dry_run {
                return Ok(format!("[dry-run] Would delete campaign {id}"));
            }
            provider
                .delete_campaign(&CampaignId::from(id.as_str()))
                .await?;
            Ok(format!("Campaign {id} deleted."))
        }
    }
}

fn parse_status(s: &str) -> CampaignStatus {
    match s.to_lowercase().as_str() {
        "active" => CampaignStatus::Active,
        "paused" => CampaignStatus::Paused,
        "archived" => CampaignStatus::Archived,
        "draft" => CampaignStatus::Draft,
        "deleted" => CampaignStatus::Deleted,
        other => CampaignStatus::Other(other.to_string()),
    }
}