alef 0.85.15

Opinionated polyglot binding generator for Rust libraries
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

use super::ZigStreamingAdapterMetadata;
use heck::ToSnakeCase;
use std::fmt::Write;

pub(super) fn render(out: &mut String, adapter: &ZigStreamingAdapterMetadata, module: &str, prefix: &str, args: &str) {
    let owner = adapter.owner_type.to_snake_case();
    let request = adapter.request_type.to_snake_case();
    let item = adapter.item_type.to_snake_case();
    let name = &adapter.adapter_name;
    let _ = writeln!(
        out,
        r#"    const _req_z = try std.heap.c_allocator.dupeZ(u8, {args});
    defer std.heap.c_allocator.free(_req_z);
    const _req_handle = {module}.c.{prefix}_{request}_from_json(_req_z.ptr);
    if (_req_handle == 0) return error.RequestConversionFailed;
    defer {module}.c.{prefix}_{request}_free(_req_handle);
    const _stream_handle = {module}.c.{prefix}_{owner}_{name}_start(_client._handle, _req_handle);
    defer {module}.c.{prefix}_{owner}_{name}_free(_stream_handle);
    const _stream_result: anyerror!void = stream_result: {{
        if (_stream_handle == 0) break :stream_result error.UnknownFfiError;
        while (true) {{
            const _chunk = {module}.c.{prefix}_{owner}_{name}_next(_stream_handle);
            if (_chunk == 0) {{
                if ({module}.c.{prefix}_last_error_code() != 0) break :stream_result error.UnknownFfiError;
                break :stream_result {{}};
            }}
            {module}.c.{prefix}_{item}_free(_chunk);
        }}
    }};
    if (_stream_result) |_| {{"#
    );
}