io_webdav/rfc4791/calendar/
create.rs

1//! `create-calendar` coroutine: `MKCALENDAR` (RFC 4791 §5.3.1) against
2//! the calendar home-set URL.
3//!
4//! # Example
5//!
6//! ```rust,no_run
7//! use std::{
8//!     io::{Read, Write},
9//!     net::TcpStream,
10//! };
11//!
12//! use io_webdav::{
13//!     coroutine::{WebdavCoroutine, WebdavCoroutineState, WebdavYield},
14//!     rfc4791::calendar::{Calendar, create::CreateCalendar},
15//!     rfc4918::WebdavAuth,
16//! };
17//! use url::Url;
18//!
19//! // Ready stream needed (TCP-connected, TLS-negociated)
20//! let mut stream = TcpStream::connect("dav.example.org:443").unwrap();
21//! let mut buf = [0u8; 4096];
22//!
23//! let base_url: Url = "https://dav.example.org/".parse().unwrap();
24//! let auth = WebdavAuth::None;
25//! let calendar = Calendar {
26//!     id: "personal".into(),
27//!     display_name: Some("Personal".into()),
28//!     ..Default::default()
29//! };
30//! let mut coroutine =
31//!     CreateCalendar::new(&base_url, &auth, "io-webdav", "/dav/calendars/", &calendar);
32//! let mut arg = None;
33//!
34//! loop {
35//!     match coroutine.resume(arg.take()) {
36//!         WebdavCoroutineState::Yielded(WebdavYield::WantsWrite(bytes)) => {
37//!             stream.write_all(&bytes).unwrap();
38//!         }
39//!         WebdavCoroutineState::Yielded(WebdavYield::WantsRead) => {
40//!             let n = stream.read(&mut buf).unwrap();
41//!             arg = Some(&buf[..n]);
42//!         }
43//!         WebdavCoroutineState::Complete(Ok(_)) => break,
44//!         WebdavCoroutineState::Complete(Err(err)) => panic!("{err}"),
45//!     }
46//! }
47//! ```
48
49use log::trace;
50use url::Url;
51
52use crate::{
53    coroutine::*,
54    rfc4791::calendar::{Calendar, join_path, mkcalendar_body, property_set},
55    rfc4918::{
56        WebdavAuth,
57        request::WebdavRequest,
58        send::{SendError, SendRaw},
59    },
60    webdav_try,
61};
62
63/// Coroutine that creates a calendar collection.
64#[derive(Debug)]
65pub struct CreateCalendar {
66    state: State,
67}
68
69impl CreateCalendar {
70    /// Builds a new `create-calendar` coroutine targeting
71    /// `home_set_path` joined with `calendar.id`.
72    pub fn new(
73        base_url: &Url,
74        auth: &WebdavAuth,
75        user_agent: &str,
76        home_set_path: &str,
77        calendar: &Calendar,
78    ) -> Self {
79        let path = join_path(home_set_path, &calendar.id);
80        let set = property_set(calendar);
81        let request = WebdavRequest::new(base_url, auth, user_agent, "MKCALENDAR", &path)
82            .content_type_xml()
83            .body(mkcalendar_body(&set));
84        Self {
85            state: State::Send(SendRaw::new(request)),
86        }
87    }
88}
89
90impl WebdavCoroutine for CreateCalendar {
91    type Yield = WebdavYield;
92    type Return = Result<(), SendError>;
93
94    fn resume(&mut self, arg: Option<&[u8]>) -> WebdavCoroutineState<Self::Yield, Self::Return> {
95        trace!("sending request");
96        match &mut self.state {
97            State::Send(send) => {
98                webdav_try!(send, arg);
99                WebdavCoroutineState::Complete(Ok(()))
100            }
101        }
102    }
103}
104
105#[derive(Debug)]
106enum State {
107    Send(SendRaw),
108}
io_webdav/rfc4791/calendar/create.rs

io_webdav/rfc4791/calendar/
create.rs
