use crate::helix::{parse_json, HelixRequestPatchError};
use super::*;
use helix::RequestPatch;
#[derive(PartialEq, typed_builder::TypedBuilder, Deserialize, Serialize, Clone, Debug)]
#[non_exhaustive]
pub struct UpdateChatSettingsRequest {
#[builder(setter(into))]
pub broadcaster_id: types::UserId,
#[builder(setter(into))]
pub moderator_id: types::UserId,
}
#[derive(PartialEq, typed_builder::TypedBuilder, Deserialize, Serialize, Clone, Debug)]
#[non_exhaustive]
pub struct UpdateChatSettingsBody {
#[builder(default, setter(into))]
pub emote_mode: Option<bool>,
#[builder(default, setter(into))]
pub follower_mode: Option<bool>,
#[builder(default, setter(into))]
pub follower_mode_duration: Option<u64>,
#[builder(default, setter(into))]
pub non_moderator_chat_delay: Option<bool>,
#[builder(default, setter(into))]
pub non_moderator_chat_delay_duration: Option<u64>,
#[builder(default, setter(into))]
pub slow_mode: Option<bool>,
#[builder(default, setter(into))]
pub slow_mode_wait_time: Option<u64>,
#[builder(default, setter(into))]
pub subscriber_mode: Option<bool>,
#[builder(default, setter(into))]
pub unique_chat_mode: Option<bool>,
}
impl helix::private::SealedSerialize for UpdateChatSettingsBody {}
pub type UpdateChatSettingsResponse = ChatSettings;
impl Request for UpdateChatSettingsRequest {
type Response = ChatSettings;
const PATH: &'static str = "chat/settings";
#[cfg(feature = "twitch_oauth2")]
const SCOPE: &'static [twitch_oauth2::Scope] =
&[twitch_oauth2::Scope::ModeratorManageChatSettings];
}
impl RequestPatch for UpdateChatSettingsRequest {
type Body = UpdateChatSettingsBody;
fn parse_inner_response(
request: Option<Self>,
uri: &http::Uri,
response: &str,
status: http::StatusCode,
) -> Result<helix::Response<Self, Self::Response>, helix::HelixRequestPatchError>
where
Self: Sized,
{
let resp = match status {
http::StatusCode::OK => {
let resp: helix::InnerResponse<Vec<ChatSettings>> = parse_json(response, true)
.map_err(|e| {
HelixRequestPatchError::DeserializeError(
response.to_string(),
e,
uri.clone(),
status,
)
})?;
resp.data.into_iter().next().ok_or(
helix::HelixRequestPatchError::InvalidResponse {
reason: "expected at least one element in data",
response: response.to_string(),
status,
uri: uri.clone(),
},
)?
}
_ => {
return Err(helix::HelixRequestPatchError::InvalidResponse {
reason: "unexpected status code",
response: response.to_string(),
status,
uri: uri.clone(),
})
}
};
Ok(helix::Response {
data: resp,
pagination: None,
request,
total: None,
other: None,
})
}
}
#[cfg(test)]
#[test]
fn test_request() {
use helix::*;
let req = UpdateChatSettingsRequest::builder()
.broadcaster_id("1234")
.moderator_id("5678")
.build();
let body = UpdateChatSettingsBody::builder()
.slow_mode(true)
.slow_mode_wait_time(10)
.build();
dbg!(req.create_request(body, "token", "clientid").unwrap());
let data = br##"
{
"data": [
{
"broadcaster_id": "1234",
"moderator_id": "5678",
"slow_mode": true,
"slow_mode_wait_time": 10,
"follower_mode": false,
"follower_mode_duration": null,
"subscriber_mode": false,
"emote_mode": false,
"unique_chat_mode": false,
"non_moderator_chat_delay": false,
"non_moderator_chat_delay_duration": null
}
]
}"##
.to_vec();
let http_response = http::Response::builder().status(200).body(data).unwrap();
let uri = req.get_uri().unwrap();
assert_eq!(
uri.to_string(),
"https://api.twitch.tv/helix/chat/settings?broadcaster_id=1234&moderator_id=5678"
);
dbg!(UpdateChatSettingsRequest::parse_response(Some(req), &uri, http_response).unwrap());
}