use super::RequestReactionType;
use crate::{
client::Client,
error::Error,
request::{Request, TryIntoRequest},
response::{marker::ListBody, Response, ResponseFuture},
routing::Route,
};
use std::future::IntoFuture;
use twilight_model::{
id::{
marker::{ChannelMarker, MessageMarker, UserMarker},
Id,
},
user::User,
};
use twilight_validate::request::{
get_reactions_limit as validate_get_reactions_limit, ValidationError,
};
struct GetReactionsFields {
after: Option<Id<UserMarker>>,
limit: Option<u16>,
}
#[must_use = "requests must be configured and executed"]
pub struct GetReactions<'a> {
channel_id: Id<ChannelMarker>,
emoji: &'a RequestReactionType<'a>,
fields: GetReactionsFields,
http: &'a Client,
message_id: Id<MessageMarker>,
}
impl<'a> GetReactions<'a> {
pub(crate) const fn new(
http: &'a Client,
channel_id: Id<ChannelMarker>,
message_id: Id<MessageMarker>,
emoji: &'a RequestReactionType<'a>,
) -> Self {
Self {
channel_id,
emoji,
fields: GetReactionsFields {
after: None,
limit: None,
},
http,
message_id,
}
}
pub const fn after(mut self, after: Id<UserMarker>) -> Self {
self.fields.after = Some(after);
self
}
pub const fn limit(mut self, limit: u16) -> Result<Self, ValidationError> {
#[allow(clippy::question_mark)]
if let Err(source) = validate_get_reactions_limit(limit) {
return Err(source);
}
self.fields.limit = Some(limit);
Ok(self)
}
#[deprecated(since = "0.15.1", note = "use `.await` or `into_future` instead")]
pub fn exec(self) -> ResponseFuture<ListBody<User>> {
self.into_future()
}
}
impl IntoFuture for GetReactions<'_> {
type Output = Result<Response<ListBody<User>>, Error>;
type IntoFuture = ResponseFuture<ListBody<User>>;
fn into_future(self) -> Self::IntoFuture {
let http = self.http;
match self.try_into_request() {
Ok(request) => http.request(request),
Err(source) => ResponseFuture::error(source),
}
}
}
impl TryIntoRequest for GetReactions<'_> {
fn try_into_request(self) -> Result<Request, Error> {
Ok(Request::from_route(&Route::GetReactionUsers {
after: self.fields.after.map(Id::get),
channel_id: self.channel_id.get(),
emoji: self.emoji,
limit: self.fields.limit,
message_id: self.message_id.get(),
}))
}
}