apify-client 0.4.1

An official, but experimental, AI-generated and AI-maintained Rust client for the Apify API (https://apify.com).
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
47
48
49

//! Client for a single schedule (`/v2/schedules/{scheduleId}`).

use serde::Serialize;

use crate::clients::base::{
    delete_resource, get_raw, get_resource, update_resource, ResourceContext,
};
use crate::common::QueryParams;
use crate::error::ApifyClientResult;
use crate::http_client::HttpClient;
use crate::models::Schedule;

/// Client for a specific schedule.
#[derive(Debug, Clone)]
pub struct ScheduleClient {
    ctx: ResourceContext,
}

impl ScheduleClient {
    pub(crate) fn new(http: HttpClient, base_url: &str, id: &str) -> Self {
        Self {
            ctx: ResourceContext::single(http, base_url, "schedules", id),
        }
    }

    /// Fetches the schedule, or `None` if it does not exist.
    pub async fn get(&self) -> ApifyClientResult<Option<Schedule>> {
        get_resource(&self.ctx, None, &QueryParams::new()).await
    }

    /// Updates the schedule with the given fields.
    pub async fn update<T: Serialize>(&self, new_fields: &T) -> ApifyClientResult<Schedule> {
        update_resource(&self.ctx, None, new_fields).await
    }

    /// Deletes the schedule.
    pub async fn delete(&self) -> ApifyClientResult<()> {
        delete_resource(&self.ctx, None).await
    }

    /// Fetches the schedule's invocation log as text, or `None` if not available.
    pub async fn get_log(&self) -> ApifyClientResult<Option<String>> {
        let response = get_raw(&self.ctx, Some("log"), &QueryParams::new()).await?;
        match response {
            Some(r) => Ok(Some(String::from_utf8_lossy(&r.body).into_owned())),
            None => Ok(None),
        }
    }
}