nolgia 0.1.0

Official Rust SDK for the Nolgia API: image, video, audio and agent generation, generated from the OpenAPI spec
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

//! The blocking client, against a mock server (feature `blocking`).
#![cfg(feature = "blocking")]

use nolgia::{RetryPolicy, Typed, json};
use uuid::Uuid;
use wiremock::{
    Mock, MockServer, ResponseTemplate,
    matchers::{method, path},
};

#[test]
fn blocking_client_runs_generated_and_helper_calls() {
    // The mock server lives on its own runtime; the blocking client brings its own.
    let runtime = tokio::runtime::Runtime::new().unwrap();
    let id = Uuid::new_v4();
    let server = runtime.block_on(async {
        let server = MockServer::start().await;
        Mock::given(method("GET"))
            .and(path("/v1/health"))
            .respond_with(ResponseTemplate::new(200).set_body_json(json!({"status": "ok", "version": "t"})))
            .mount(&server)
            .await;
        Mock::given(method("GET"))
            .and(path(format!("/v1/jobs/{id}/wait")))
            .respond_with(ResponseTemplate::new(200).set_body_json(json!({
                "id": id, "user_id": Uuid::nil(), "modality": "image", "model": "m", "status": "succeeded",
                "created_at": "2026-10-08T00:00:00Z", "updated_at": "2026-10-08T00:00:00Z"
            })))
            .mount(&server)
            .await;
        server
    });
    let nolgia = nolgia::blocking::Client::from_async(
        nolgia::Client::builder()
            .api_key("nol_test")
            .base_url(server.uri())
            .retry(RetryPolicy::none())
            .build()
            .unwrap(),
    )
    .unwrap();
    let health = nolgia
        .block_on(nolgia.api().get_health().send().typed())
        .unwrap();
    assert_eq!(health.version, "t");
    let job = nolgia.wait_job(id, Default::default()).unwrap();
    assert_eq!(job.status, "succeeded");
}