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
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

//! Integration tests for the schedule resource.

mod common;

use serde_json::json;

/// Simple GET: listing schedules.
#[tokio::test(flavor = "multi_thread")]
async fn list_schedules() {
    let client = require_client!();
    let page = client
        .schedules()
        .list(Default::default())
        .await
        .expect("listing schedules should succeed");
    assert!(page.total >= 0);
}

fn schedule_definition(name: &str) -> serde_json::Value {
    json!({
        "name": name,
        "cronExpression": "0 0 * * *",
        "isEnabled": false,
        "isExclusive": true,
        "actions": []
    })
}

/// Simple GET: fetch a single schedule by ID.
#[tokio::test(flavor = "multi_thread")]
async fn get_schedule() {
    let client = require_client!();
    let name = common::unique_name("schedule-get");
    let schedule = client
        .schedules()
        .create(&schedule_definition(&name))
        .await
        .expect("create schedule");

    let cleanup_client = client.clone();
    let id = schedule.id.clone();
    let _guard = common::Cleanup::new(move || async move {
        let _ = cleanup_client.schedule(&id).delete().await;
    });

    let fetched = client
        .schedule(&schedule.id)
        .get()
        .await
        .expect("get schedule by id")
        .expect("schedule should exist");
    assert_eq!(fetched.id, schedule.id);
}

/// Complex flow: create -> get -> update -> delete a schedule.
#[tokio::test(flavor = "multi_thread")]
async fn schedule_crud_flow() {
    let client = require_client!();
    let name = common::unique_name("schedule");

    let schedule = client
        .schedules()
        .create(&schedule_definition(&name))
        .await
        .expect("create schedule");
    assert_eq!(schedule.name.as_deref(), Some(name.as_str()));

    let cleanup_client = client.clone();
    let cleanup_id = schedule.id.clone();
    let _guard = common::Cleanup::new(move || async move {
        let _ = cleanup_client.schedule(&cleanup_id).delete().await;
    });

    let schedule_client = client.schedule(&schedule.id);

    // Get.
    assert!(schedule_client.get().await.expect("get schedule").is_some());

    // Update (change cron expression).
    let updated = schedule_client
        .update(&json!({ "cronExpression": "0 12 * * *" }))
        .await
        .expect("update schedule");
    assert_eq!(updated.cron_expression.as_deref(), Some("0 12 * * *"));

    // Fetch the schedule's invocation log (simple GET; may be empty for a new schedule).
    let _log = schedule_client.get_log().await.expect("get schedule log");

    // Delete.
    schedule_client.delete().await.expect("delete schedule");
    assert!(schedule_client
        .get()
        .await
        .expect("get after delete")
        .is_none());
}