allframe-macros 0.1.28

Procedural macros for AllFrame framework
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
97
98
99
100

//! Integration tests for #[allframe_handler] attribute macro

use allframe_macros::allframe_handler;

// ─── Basic handlers ──────────────────────────────────────────────────────

#[allframe_handler]
async fn get_user() -> String {
    r#"{"name":"Alice"}"#.to_string()
}

#[allframe_handler]
async fn echo(input: String) -> String {
    input
}

#[allframe_handler]
pub async fn public_handler() -> String {
    "public".to_string()
}

#[tokio::test]
async fn test_basic_handler() {
    let result = get_user().await;
    assert_eq!(result, r#"{"name":"Alice"}"#);
}

#[tokio::test]
async fn test_handler_with_args() {
    let result = echo("hello".to_string()).await;
    assert_eq!(result, "hello");
}

#[tokio::test]
async fn test_public_handler() {
    let result = public_handler().await;
    assert_eq!(result, "public");
}

// ─── Sync handlers ─────────────────────────────────────────────────────

#[allframe_handler]
fn compute_sync() -> String {
    "sync_result".to_string()
}

#[allframe_handler]
fn sync_with_args(input: String) -> String {
    format!("sync:{input}")
}

#[test]
fn test_sync_handler() {
    assert_eq!(compute_sync(), "sync_result");
}

#[test]
fn test_sync_handler_with_args() {
    assert_eq!(sync_with_args("hello".to_string()), "sync:hello");
}

// ─── Streaming handlers ─────────────────────────────────────────────────

use allframe_core::router::StreamSender;

#[allframe_handler(streaming)]
async fn stream_data(tx: StreamSender) -> String {
    tx.send("chunk1".to_string()).await.ok();
    tx.send("chunk2".to_string()).await.ok();
    "done".to_string()
}

#[allframe_handler(streaming)]
async fn stream_with_args(prefix: String, tx: StreamSender) -> String {
    tx.send(format!("{prefix}-item")).await.ok();
    "complete".to_string()
}

// Verify streaming handlers compile and are callable
// (Full streaming tests require a Router, covered in allframe-tauri tests)

// ─── Combined with tauri_compat ──────────────────────────────────────────

use allframe_macros::tauri_compat;

#[allframe_handler]
#[tauri_compat]
async fn greet(name: String, age: u32) -> String {
    format!("Hello {}, age {}", name, age)
}

#[tokio::test]
async fn test_combined_with_tauri_compat() {
    let args = GreetArgs {
        name: "Bob".to_string(),
        age: 25,
    };
    let result = greet(args).await;
    assert_eq!(result, "Hello Bob, age 25");
}