use super::*;
use helix::RequestGet;
#[derive(PartialEq, Eq, Deserialize, Serialize, Clone, Debug)]
#[cfg_attr(feature = "typed-builder", derive(typed_builder::TypedBuilder))]
#[non_exhaustive]
#[deprecated(
note = "this endpoint has been deprecated, see https://discuss.dev.twitch.tv/t/follows-endpoints-and-eventsub-subscription-type-are-now-available-in-open-beta/43322"
)]
pub struct GetUsersFollowsRequest<'a> {
#[cfg_attr(feature = "typed-builder", builder(default))]
#[cfg_attr(feature = "deser_borrow", serde(borrow = "'a"))]
pub after: Option<Cow<'a, helix::CursorRef>>,
#[cfg_attr(feature = "typed-builder", builder(default, setter(into)))]
pub first: Option<usize>,
#[cfg_attr(feature = "typed-builder", builder(default, setter(into)))]
#[cfg_attr(feature = "deser_borrow", serde(borrow = "'a"))]
pub from_id: Option<Cow<'a, types::UserIdRef>>,
#[cfg_attr(feature = "typed-builder", builder(default, setter(into)))]
#[cfg_attr(feature = "deser_borrow", serde(borrow = "'a"))]
pub to_id: Option<Cow<'a, types::UserIdRef>>,
}
impl<'a> GetUsersFollowsRequest<'a> {
pub fn following(from_id: impl types::IntoCow<'a, types::UserIdRef> + 'a) -> Self {
Self {
from_id: Some(from_id.into_cow()),
..Self::empty()
}
}
pub fn followers(to_id: impl types::IntoCow<'a, types::UserIdRef> + 'a) -> Self {
Self {
to_id: Some(to_id.into_cow()),
..Self::empty()
}
}
pub fn follows(
user_id: impl types::IntoCow<'a, types::UserIdRef> + 'a,
broadcaster_id: impl types::IntoCow<'a, types::UserIdRef> + 'a,
) -> Self {
Self {
from_id: Some(user_id.into_cow()),
to_id: Some(broadcaster_id.into_cow()),
..Self::empty()
}
}
pub const fn empty() -> Self {
Self {
after: None,
first: None,
from_id: None,
to_id: None,
}
}
}
#[derive(PartialEq, Eq, Deserialize, Serialize, Debug, Clone)]
#[cfg_attr(feature = "deny_unknown_fields", serde(deny_unknown_fields))]
#[non_exhaustive]
#[deprecated(
note = "this endpoint has been deprecated, see https://discuss.dev.twitch.tv/t/follows-endpoints-and-eventsub-subscription-type-are-now-available-in-open-beta/43322"
)]
pub struct UsersFollows {
pub total: i64,
pub follow_relationships: Vec<FollowRelationship>,
}
#[derive(PartialEq, Eq, Deserialize, Serialize, Debug, Clone)]
#[cfg_attr(feature = "deny_unknown_fields", serde(deny_unknown_fields))]
#[non_exhaustive]
pub struct FollowRelationship {
pub followed_at: types::Timestamp,
pub from_id: types::UserId,
pub from_name: types::DisplayName,
pub from_login: types::UserName,
pub to_id: types::UserId,
pub to_name: types::DisplayName,
pub to_login: types::UserName,
}
impl Request for GetUsersFollowsRequest<'_> {
type Response = UsersFollows;
#[cfg(feature = "twitch_oauth2")]
const OPT_SCOPE: &'static [twitch_oauth2::Scope] = &[];
const PATH: &'static str = "users/follows";
#[cfg(feature = "twitch_oauth2")]
const SCOPE: twitch_oauth2::Validator = twitch_oauth2::validator![];
}
impl RequestGet for GetUsersFollowsRequest<'_> {
fn parse_inner_response(
request: Option<Self>,
uri: &http::Uri,
response: &str,
status: http::StatusCode,
) -> Result<helix::Response<Self, Self::Response>, helix::HelixRequestGetError>
where
Self: Sized,
{
#[derive(PartialEq, Deserialize, Debug, Clone)]
struct InnerResponse {
data: Vec<FollowRelationship>,
total: i64,
#[serde(default)]
pagination: helix::Pagination,
}
let response: InnerResponse = helix::parse_json(response, true).map_err(|e| {
helix::HelixRequestGetError::DeserializeError(
response.to_string(),
e,
uri.clone(),
status,
)
})?;
Ok(helix::Response::new(
UsersFollows {
total: response.total,
follow_relationships: response.data,
},
response.pagination.cursor,
request,
Some(response.total),
None,
))
}
}
impl helix::Paginated for GetUsersFollowsRequest<'_> {
fn set_pagination(&mut self, cursor: Option<helix::Cursor>) {
self.after = cursor.map(|c| c.into_cow())
}
}
#[cfg(test)]
#[test]
fn test_request() {
use helix::*;
let req = GetUsersFollowsRequest::followers("23161357");
let data = br#"
{
"total": 12345,
"data":
[
{
"from_id": "171003792",
"from_login": "iiisutha067iii",
"from_name": "IIIsutha067III",
"to_id": "23161357",
"to_name": "LIRIK",
"to_login": "lirik",
"followed_at": "2017-08-22T22:55:24Z"
},
{
"from_id": "113627897",
"from_login": "birdman616",
"from_name": "Birdman616",
"to_id": "23161357",
"to_name": "LIRIK",
"to_login": "lirik",
"followed_at": "2017-08-22T22:55:04Z"
}
],
"pagination":{
"cursor": "eyJiIjpudWxsLCJhIjoiMTUwMzQ0MTc3NjQyNDQyMjAwMCJ9"
}
}
"#
.to_vec();
let http_response = http::Response::builder().body(data).unwrap();
let uri = req.get_uri().unwrap();
assert_eq!(
uri.to_string(),
"https://api.twitch.tv/helix/users/follows?to_id=23161357"
);
dbg!(GetUsersFollowsRequest::parse_response(Some(req), &uri, http_response).unwrap());
}