openapi-nexus 0.2.3

OpenAPI 3.x multi-language code generator
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

//! Hardcoded Rust runtime source files for aioduct.

use crate::codegen::traits::file_writer::FileInfo;
use crate::generators::rust::aioduct::config::{AioductFeatureConfig, AioductTls};
use crate::generators::rust::common::project_files::with_header;
use crate::generators::rust::common::runtime::render_api_call_error;
use sigil_stitch::type_name::TypeName;

const CLIENT_RS_TEMPLATE: &str = include_str!("runtime/client.rs.txt");
const ERROR_RS: &str = include_str!("runtime/error.rs.txt");
const AUTH_RS: &str = include_str!("runtime/auth.rs.txt");
const MOD_RS: &str = include_str!("runtime/mod.rs.txt");
const UPLOAD_FILE_RS: &str = include_str!("runtime/upload_file.rs.txt");

/// Returns runtime files ready to write.
pub fn runtime_files(
    header: &str,
    aioduct_cfg: &AioductFeatureConfig,
    include_api_call_error: bool,
    include_upload_file: bool,
) -> Vec<FileInfo> {
    let client_rs = render_client_rs(aioduct_cfg);
    let mut mod_rs = MOD_RS.to_string();
    let mut error_rs = ERROR_RS.to_string();
    if include_api_call_error {
        error_rs.push('\n');
        error_rs.push_str(
            &render_api_call_error(TypeName::qualified("aioduct", "HeaderMap"))
                .expect("aioduct ApiCallError runtime renders"),
        );
    }
    let mut files = vec![
        FileInfo::runtime("client.rs".to_string(), with_header(header, &client_rs)),
        FileInfo::runtime("error.rs".to_string(), with_header(header, &error_rs)),
        FileInfo::runtime("auth.rs".to_string(), with_header(header, AUTH_RS)),
    ];
    if include_upload_file {
        mod_rs.push_str(
            "mod upload_file;\npub use upload_file::{multipart_header_value, UploadFile};\n",
        );
        files.push(FileInfo::runtime(
            "upload_file.rs".to_string(),
            with_header(header, UPLOAD_FILE_RS),
        ));
    }
    files.push(FileInfo::runtime(
        "mod.rs".to_string(),
        with_header(header, &mod_rs),
    ));
    files
}

fn render_client_rs(cfg: &AioductFeatureConfig) -> String {
    let has_http3 = cfg
        .features
        .as_ref()
        .is_some_and(|f| f.contains(&"http3".to_string()));
    let tls = cfg.tls.as_ref().unwrap_or(&AioductTls::RustlsRing);

    let constructor = match (tls, has_http3) {
        (AioductTls::RustlsRing | AioductTls::RustlsAwsLcRs, true) => {
            "aioduct::HttpEngineSend::<R, C>::with_http3().expect(\"aioduct HTTP/3 client build\")"
        }
        (AioductTls::RustlsRing | AioductTls::RustlsAwsLcRs, false) => {
            "aioduct::HttpEngineSend::<R, C>::with_rustls()"
        }
        (AioductTls::Disabled, _) => "aioduct::HttpEngineSend::<R, C>::new()",
    };

    CLIENT_RS_TEMPLATE.replace("{{CLIENT_CONSTRUCTOR}}", constructor)
}