diff --git a/ruma-client-api/src/r0/state/send_state_event.rs b/ruma-client-api/src/r0/state/send_state_event.rs index 550029d7..bc668028 100644 --- a/ruma-client-api/src/r0/state/send_state_event.rs +++ b/ruma-client-api/src/r0/state/send_state_event.rs @@ -1,9 +1,10 @@ //! [PUT /_matrix/client/r0/rooms/{roomId}/state/{eventType}/{stateKey}](https://matrix.org/docs/spec/client_server/r0.6.1#put-matrix-client-r0-rooms-roomid-state-eventtype-statekey) -use ruma_api::ruma_api; +use bytes::BufMut; +use ruma_api::{ruma_api, SendAccessToken}; use ruma_events::{AnyStateEventContent, EventContent as _}; use ruma_identifiers::{EventId, RoomId}; -use ruma_serde::Raw; +use ruma_serde::{Outgoing, Raw}; ruma_api! { metadata: { @@ -15,24 +16,6 @@ ruma_api! { authentication: AccessToken, } - request: { - /// The room to set the state in. - #[ruma_api(path)] - pub room_id: &'a RoomId, - - /// The type of event to send. - #[ruma_api(path)] - pub event_type: &'a str, - - /// The state_key for the state to send. - #[ruma_api(path)] - pub state_key: &'a str, - - /// The event content to send. - #[ruma_api(body)] - pub body: Raw, - } - response: { /// A unique identifier for the event. pub event_id: EventId, @@ -41,6 +24,26 @@ ruma_api! { error: crate::Error } +/// Data for a request to the `send_state_event` API endpoint. +/// +/// Send a state event to a room associated with a given state key. +#[derive(Clone, Debug, Outgoing)] +#[cfg_attr(not(feature = "unstable-exhaustive-types"), non_exhaustive)] +#[incoming_derive(!Deserialize)] +pub struct Request<'a> { + /// The room to set the state in. + pub room_id: &'a RoomId, + + /// The type of event to send. + pub event_type: &'a str, + + /// The state_key for the state to send. + pub state_key: &'a str, + + /// The event content to send. + pub body: Raw, +} + impl<'a> Request<'a> { /// Creates a new `Request` with the given room id, state key and event content. pub fn new(room_id: &'a RoomId, state_key: &'a str, content: &'a AnyStateEventContent) -> Self { @@ -64,3 +67,91 @@ impl Response { Self { event_id } } } + +#[cfg(feature = "client")] +impl<'a> ruma_api::OutgoingRequest for Request<'a> { + type EndpointError = crate::Error; + type IncomingResponse = Response; + + const METADATA: ruma_api::Metadata = METADATA; + + fn try_into_http_request( + self, + base_url: &str, + access_token: SendAccessToken<'_>, + ) -> Result, ruma_api::error::IntoHttpError> { + use std::borrow::Cow; + + use http::header::{self, HeaderValue}; + use percent_encoding::{utf8_percent_encode, NON_ALPHANUMERIC}; + + let mut url = format!( + "{}/_matrix/client/r0/rooms/{}/state/{}", + base_url.strip_suffix('/').unwrap_or(base_url), + utf8_percent_encode(self.room_id.as_str(), NON_ALPHANUMERIC), + utf8_percent_encode(self.event_type, NON_ALPHANUMERIC), + ); + + // Last URL segment is optional, that is why this trait impl is not generated. + if !self.state_key.is_empty() { + url.push('/'); + url.push_str(&Cow::from(utf8_percent_encode(&self.state_key, NON_ALPHANUMERIC))); + } + + let http_request = http::Request::builder() + .method(http::Method::PUT) + .uri(url) + .header(header::CONTENT_TYPE, "application/json") + .header( + header::AUTHORIZATION, + HeaderValue::from_str(&format!( + "Bearer {}", + access_token + .get_required_for_endpoint() + .ok_or(ruma_api::error::IntoHttpError::NeedsAuthentication)? + ))?, + ) + .body(ruma_serde::json_to_buf(&self.body)?)?; + + Ok(http_request) + } +} + +#[cfg(feature = "server")] +impl ruma_api::IncomingRequest for IncomingRequest { + type EndpointError = crate::Error; + type OutgoingResponse = Response; + + const METADATA: ruma_api::Metadata = METADATA; + + fn try_from_http_request>( + request: http::Request, + ) -> Result { + use std::{borrow::Cow, convert::TryFrom}; + + let path_segments: Vec<&str> = request.uri().path()[1..].split('/').collect(); + + let room_id = { + let decoded = + percent_encoding::percent_decode(path_segments[4].as_bytes()).decode_utf8()?; + + RoomId::try_from(&*decoded)? + }; + + let event_type = percent_encoding::percent_decode(path_segments[6].as_bytes()) + .decode_utf8()? + .into_owned(); + + let state_key = path_segments + .get(7) + .map(|segment| percent_encoding::percent_decode(segment.as_bytes()).decode_utf8()) + .transpose()? + // Last URL segment is optional, but not present is the same semantically as empty + .unwrap_or(Cow::Borrowed("")) + .into_owned(); + + let body = serde_json::from_slice(request.body().as_ref())?; + + Ok(Self { room_id, event_type, state_key, body }) + } +}