Struct SetResponse

Source

pub struct SetResponse<O: SetObject> { /* private fields */ }

Implementations§

Source §

pub fn created(&mut self, id: &str) -> Result<O>

Examples found in repository ?

examples/websocket.rs (line 66)

25async fn websocket() {
26    // Connect to the JMAP server using Basic authentication
27
28    use jmap_client::PushObject;
29
30    let client = Client::new()
31        .credentials(("john@example.org", "secret"))
32        .connect("https://jmap.example.org")
33        .await
34        .unwrap();
35
36    // Connect to the WebSocket endpoint
37    let mut ws_stream = client.connect_ws().await.unwrap();
38
39    // Read WS messages on a separate thread
40    let (stream_tx, mut stream_rx) = mpsc::channel::<WebSocketMessage>(100);
41    tokio::spawn(async move {
42        while let Some(change) = ws_stream.next().await {
43            stream_tx.send(change.unwrap()).await.unwrap();
44        }
45    });
46
47    // Create a mailbox over WS
48    let mut request = client.build();
49    let create_id = request
50        .set_mailbox()
51        .create()
52        .name("WebSocket Test")
53        .create_id()
54        .unwrap();
55    let request_id = request.send_ws().await.unwrap();
56
57    // Read response from WS stream
58    let mailbox_id = if let Some(WebSocketMessage::Response(mut response)) = stream_rx.recv().await
59    {
60        assert_eq!(request_id, response.request_id().unwrap());
61        response
62            .pop_method_response()
63            .unwrap()
64            .unwrap_set_mailbox()
65            .unwrap()
66            .created(&create_id)
67            .unwrap()
68            .take_id()
69    } else {
70        unreachable!()
71    };
72
73    // Enable push notifications over WS
74    client
75        .enable_push_ws(None::<Vec<_>>, None::<&str>)
76        .await
77        .unwrap();
78
79    // Make changes over standard HTTP and expect a push notification via WS
80    client
81        .mailbox_update_sort_order(&mailbox_id, 1)
82        .await
83        .unwrap();
84    if let Some(WebSocketMessage::PushNotification(PushObject::StateChange { changed })) =
85        stream_rx.recv().await
86    {
87        println!("Received changes: {:?}", changed);
88    } else {
89        unreachable!()
90    }
91}

Source

pub fn updated(&mut self, id: &str) -> Result<Option<O>>

Source

pub fn destroyed(&mut self, id: &str) -> Result<()>

Source

pub fn created_ids(&self) -> Option<impl Iterator<Item = &String>>

Source

pub fn updated_ids(&self) -> Option<impl Iterator<Item = &String>>

Source

pub fn take_updated_ids(&mut self) -> Option<Vec<String>>

Source

pub fn destroyed_ids(&self) -> Option<impl Iterator<Item = &String>>

Source

pub fn take_destroyed_ids(&mut self) -> Option<Vec<String>>

Examples found in repository ?

examples/result_reference.rs (line 47)

20async fn result_reference() {
21    // Connect to the JMAP server using Basic authentication
22    let client = Client::new()
23        .credentials(("john@example.org", "secret"))
24        .connect("https://jmap.example.org")
25        .await
26        .unwrap();
27
28    // Delete e-mails matching a filter
29    let mut request = client.build();
30    let result_ref = request
31        .query_email()
32        .filter(query::Filter::and([
33            email::query::Filter::has_keyword("$draft"),
34            email::query::Filter::from("bill"),
35        ]))
36        .result_reference();
37    request.set_email().destroy_ref(result_ref);
38    let _destroyed_ids = request
39        .send()
40        .await
41        .unwrap()
42        .unwrap_method_responses()
43        .pop()
44        .unwrap()
45        .unwrap_set_email()
46        .unwrap()
47        .take_destroyed_ids();
48
49    // Fetch mailboxes matching a filter
50    let mut request = client.build();
51    let query_result = request
52        .query_mailbox()
53        .filter(query::Filter::and([
54            mailbox::query::Filter::has_any_role(false),
55            mailbox::query::Filter::is_subscribed(true),
56        ]))
57        .result_reference();
58    request.get_mailbox().ids_ref(query_result).properties([
59        mailbox::Property::Id,
60        mailbox::Property::Name,
61        mailbox::Property::ParentId,
62        mailbox::Property::TotalEmails,
63        mailbox::Property::UnreadEmails,
64    ]);
65    let _mailboxes = request
66        .send()
67        .await
68        .unwrap()
69        .unwrap_method_responses()
70        .pop()
71        .unwrap()
72        .unwrap_get_mailbox()
73        .unwrap()
74        .take_list();
75
76    // Fetch only the updated properties of all mailboxes that changed
77    // since a state.
78    let mut request = client.build();
79    let changes_request = request.changes_mailbox("n").max_changes(0);
80    let properties_ref = changes_request.updated_properties_reference();
81    let updated_ref = changes_request.updated_reference();
82    request
83        .get_mailbox()
84        .ids_ref(updated_ref)
85        .properties_ref(properties_ref);
86    for mailbox in request
87        .send()
88        .await
89        .unwrap()
90        .unwrap_method_responses()
91        .pop()
92        .unwrap()
93        .unwrap_get_mailbox()
94        .unwrap()
95        .take_list()
96    {
97        println!("Changed mailbox: {:#?}", mailbox);
98    }
99}