wrangler 1.21.0

Command-line interface for all things Cloudflare Workers
Documentation 
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

use crate::http;
use crate::settings::global_user::GlobalUser;

use anyhow::Result;

#[derive(Clone, Debug, PartialEq)]
pub struct ScheduleTarget {
    pub account_id: String,
    pub script_name: String,
    pub crons: Vec<String>,
}

impl ScheduleTarget {
    pub fn deploy(&self, user: &GlobalUser) -> Result<Vec<String>> {
        log::info!("publishing schedules");
        let schedule_worker_addr = format!(
            "https://api.cloudflare.com/client/v4/accounts/{}/workers/scripts/{}/schedules",
            self.account_id, self.script_name,
        );

        let client = http::legacy_auth_client(user);

        log::info!("Pushing {} schedule(s)...", self.crons.len());
        let res = client
            .put(&schedule_worker_addr)
            .header("Content-Type", "application/json")
            .body(build_schedules_request(&self.crons))
            .send()?;

        let status = res.status();
        let text = res.text()?;
        if !status.is_success() {
            anyhow::bail!(crate::format_api_errors(text))
        }

        Ok(self.crons.clone())
    }
}

fn build_schedules_request(crons: &[String]) -> String {
    let values = crons
        .iter()
        .map(|s| serde_json::json!({ "cron": s }))
        .collect();
    serde_json::Value::Array(values).to_string()
}