uxar 0.1.3

Opinionated Rust web framework built on Axum for Postgres-backed JSON APIs
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


#[derive(Clone, Debug, Serialize, Deserialize)]
pub struct EventTopic(u64);

pub enum Event<T>{
    Wait(EventTopic),
    Done(T)
}

#[derive(JsonSchema, Serialize, Deserialize, Debug, Clone)]
struct Order{
    id: i64
}

struct Payment{

}

struct Invoice{

}

struct InvoiceResult{

}

struct Shipment{

}

struct ShipmentResult{

}

struct AdminApproval{

}

fn after_order(o: Payment)->SampleFlow{
    return SampleFlow::Invoice(Invoice{}, Shipment{})
}

fn after_payment(p: Payment)->SampleFlow{
    return SampleFlow::Start(Order{id: 1})
}

fn after_invoice(i: InvoiceResult, s: ShipmentResult)->SampleFlow{
    return SampleFlow::Approval(Event::Wait(EventTopic(0)))
}

fn after_approval(a: AdminApproval)->SampleFlow{
    return SampleFlow::Done
}


#[event]
fn order_created(o: AdminApproval)->EventTopic{
    println!("Order created: {:?}", o);
    return EventTopic(0);
}

#[task]
fn handle_invoice(inv: Invoice)->InvoiceResult{
    println!("Handling invoice: {:?}", inv);
    InvoiceResult{}
}

#[task]
fn handle_shipment(ship: Shipment)->ShipmentResult{
    println!("Handling shipment: {:?}", ship);
    ShipmentResult{}
}


#[task]
fn handle_order(o: Order)->Payment{
    println!("Handling order: {:?}", o);
    Payment{}
}



pub enum SampleFlow{
    #[flow(start, then=after_order)]
    Start(Order),
    #[flow(then=after_payment)]
    Payment(Payment),
    #[flow(then=after_invoice)]
    Invoice(Invoice, Shipment),
    #[flow(then=after_approval)]
    Approval(Event<AdminApproval>),
    Done // unit variant means end of flow
}

#[flow]
fn start_payment_flow(o: Order)->SampleFlow{
    return SampleFlow::Start(o);
}