assay-lua 0.20.14

General-purpose enhanced Lua runtime. Batteries-included scripting, automation, and web services.
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

//! The live smoke test for `assay.apify`. It runs only when `APIFY_TOKEN` is
//! set and skips otherwise, so the suite stays green everywhere; with a token
//! it proves the half a fixture cannot — that the profile actor still answers
//! in the shape the reader was written against, and that the run reports a
//! cost. Capped at a few cents per run.

use super::common::run_lua;

fn token_or_skip() -> Option<String> {
    match std::env::var("APIFY_TOKEN")
        .ok()
        .filter(|v| !v.trim().is_empty())
    {
        Some(v) => Some(v),
        None => {
            eprintln!("skipped: APIFY_TOKEN not set");
            None
        }
    }
}

/// The profile read is a public publisher's account: a smoke test must not
/// spend credits reading a private individual, or put one in a CI log.
#[tokio::test]
async fn instagram_profiles_answer_in_the_shape_the_reader_expects() {
    let Some(token) = token_or_skip() else {
        return;
    };
    run_lua(&format!(
        r#"
        local apify = require("assay.apify")
        local c = apify.client({{ token = "{token}" }})
        local r, reason = c:instagram_profiles({{ "natgeo" }}, {{ max_total_charge_usd = 0.05, wait_s = 5 }})
        assert.not_nil(r, "run did not succeed: " .. tostring(reason))
        assert.eq(#r.profiles, 1)
        local p = r.profiles[1]
        assert.eq(p.error, nil)
        assert.eq(p.username, "natgeo")
        assert.eq(type(p.followers), "number")
        assert.gt(p.followers, 1000000)
        assert.eq(type(p.latest_posts), "table")
        assert.eq(p.provenance.provider, "apify")
        assert.eq(r.run.succeeded, true)
        assert.eq(type(r.run.usage_total_usd), "number")
        assert.not_nil(r.run.usage_cents)
        log.info("apify smoke: " .. p.username .. " " .. p.followers .. " followers, run " .. r.run.id .. " cost " .. r.run.usage_total_usd)
    "#
    ))
    .await
    .unwrap();
}

/// The contact scraper against a public company site. The actor refuses a cap
/// below fifty cents, so the page budget is what keeps this cheap: two pages
/// at a fifth of a cent each.
#[tokio::test]
async fn contact_details_answer_in_the_shape_the_reader_expects() {
    let Some(token) = token_or_skip() else {
        return;
    };
    run_lua(&format!(
        r#"
        local apify = require("assay.apify")
        local c = apify.client({{ token = "{token}" }})
        local r, reason = c:contact_details({{ "https://apify.com" }},
          {{ max_total_charge_usd = 0.5, max_pages = 2, wait_s = 5 }})
        assert.not_nil(r, "run did not succeed: " .. tostring(reason))
        assert.eq(#r.sites, 1)
        local s = r.sites[1]
        assert.eq(s.domain, "apify.com")
        assert.eq(s.url, "https://apify.com")
        assert.gt(#s.emails, 0)
        assert.contains(s.emails[1], "@")
        assert.eq(s.emails[1], s.emails[1]:lower())
        assert.gt(s.pages_visited, 0)
        assert.eq(type(s.linkedins), "table")
        assert.eq(s.provenance.provider, "apify")
        assert.eq(r.run.succeeded, true)
        assert.gt(r.run.usage_cents, -1)
        log.info("apify smoke: " .. s.domain .. " " .. #s.emails .. " emails over " .. s.pages_visited
          .. " pages, run " .. r.run.id .. " cost " .. r.run.usage_total_usd)
    "#
    ))
    .await
    .unwrap();
}