use std::{
future::{Future, IntoFuture},
pin::Pin,
};
use serde::Serialize;
use crate::{
api::API,
entities::{
input_paid_media::InputPaidMedia,
message::Message,
message_entity::MessageEntity,
misc::{
chat_id::ChatId,
input_file::{GetFiles, InputFile},
reply_markup::ReplyMarkup,
},
reply_parameters::ReplyParameters,
},
errors::ConogramError,
impl_into_future_multipart,
request::RequestT,
utils::deserialize_utils::is_false,
};
#[derive(Debug, Clone, Serialize)]
pub struct SendPaidMediaParams {
#[serde(skip_serializing_if = "Option::is_none")]
pub business_connection_id: Option<String>,
pub chat_id: ChatId,
pub star_count: i64,
pub media: Vec<InputPaidMedia>,
#[serde(skip_serializing_if = "Option::is_none")]
pub payload: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub caption: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub parse_mode: Option<String>,
#[serde(skip_serializing_if = "Vec::is_empty")]
pub caption_entities: Vec<MessageEntity>,
#[serde(default, skip_serializing_if = "is_false")]
pub show_caption_above_media: bool,
#[serde(default, skip_serializing_if = "is_false")]
pub disable_notification: bool,
#[serde(default, skip_serializing_if = "is_false")]
pub protect_content: bool,
#[serde(default, skip_serializing_if = "is_false")]
pub allow_paid_broadcast: bool,
#[serde(skip_serializing_if = "Option::is_none")]
pub reply_parameters: Option<ReplyParameters>,
#[serde(skip_serializing_if = "Option::is_none")]
pub reply_markup: Option<ReplyMarkup>,
}
impl GetFiles for SendPaidMediaParams {
fn get_files(&self) -> Vec<&InputFile> {
let mut vec = Vec::with_capacity(3);
for media in &self.media {
vec.extend(media.get_files());
}
vec
}
}
impl_into_future_multipart!(SendPaidMediaRequest<'a>);
#[derive(Clone)]
pub struct SendPaidMediaRequest<'a> {
api: &'a API,
params: SendPaidMediaParams,
}
impl<'a> RequestT for SendPaidMediaRequest<'a> {
type ParamsType = SendPaidMediaParams;
type ReturnType = Message;
fn get_name() -> &'static str {
"sendPaidMedia"
}
fn get_api_ref(&self) -> &API {
self.api
}
fn get_params_ref(&self) -> &Self::ParamsType {
&self.params
}
fn is_multipart() -> bool {
true
}
}
impl<'a> SendPaidMediaRequest<'a> {
pub fn new(
api: &'a API,
chat_id: impl Into<ChatId>,
star_count: impl Into<i64>,
media: impl IntoIterator<Item = impl Into<InputPaidMedia>>,
) -> Self {
Self {
api,
params: SendPaidMediaParams {
chat_id: chat_id.into(),
star_count: star_count.into(),
media: media.into_iter().map(Into::into).collect(),
business_connection_id: Option::default(),
payload: Option::default(),
caption: Option::default(),
parse_mode: Option::default(),
caption_entities: Vec::default(),
show_caption_above_media: bool::default(),
disable_notification: bool::default(),
protect_content: bool::default(),
allow_paid_broadcast: bool::default(),
reply_parameters: Option::default(),
reply_markup: Option::default(),
},
}
}
#[must_use]
pub fn business_connection_id(mut self, business_connection_id: impl Into<String>) -> Self {
self.params.business_connection_id = Some(business_connection_id.into());
self
}
#[must_use]
pub fn chat_id(mut self, chat_id: impl Into<ChatId>) -> Self {
self.params.chat_id = chat_id.into();
self
}
#[must_use]
pub fn star_count(mut self, star_count: impl Into<i64>) -> Self {
self.params.star_count = star_count.into();
self
}
#[must_use]
pub fn media(mut self, media: impl IntoIterator<Item = impl Into<InputPaidMedia>>) -> Self {
self.params.media = media.into_iter().map(Into::into).collect();
self
}
#[must_use]
pub fn payload(mut self, payload: impl Into<String>) -> Self {
self.params.payload = Some(payload.into());
self
}
#[must_use]
pub fn caption(mut self, caption: impl Into<String>) -> Self {
self.params.caption = Some(caption.into());
self
}
#[must_use]
pub fn parse_mode(mut self, parse_mode: impl Into<String>) -> Self {
self.params.parse_mode = Some(parse_mode.into());
self
}
#[must_use]
pub fn caption_entities(
mut self,
caption_entities: impl IntoIterator<Item = impl Into<MessageEntity>>,
) -> Self {
self.params.caption_entities = caption_entities.into_iter().map(Into::into).collect();
self
}
#[must_use]
pub fn show_caption_above_media(mut self, show_caption_above_media: impl Into<bool>) -> Self {
self.params.show_caption_above_media = show_caption_above_media.into();
self
}
#[must_use]
pub fn disable_notification(mut self, disable_notification: impl Into<bool>) -> Self {
self.params.disable_notification = disable_notification.into();
self
}
#[must_use]
pub fn protect_content(mut self, protect_content: impl Into<bool>) -> Self {
self.params.protect_content = protect_content.into();
self
}
#[must_use]
pub fn allow_paid_broadcast(mut self, allow_paid_broadcast: impl Into<bool>) -> Self {
self.params.allow_paid_broadcast = allow_paid_broadcast.into();
self
}
#[must_use]
pub fn reply_parameters(mut self, reply_parameters: impl Into<ReplyParameters>) -> Self {
self.params.reply_parameters = Some(reply_parameters.into());
self
}
#[must_use]
pub fn reply_markup(mut self, reply_markup: impl Into<ReplyMarkup>) -> Self {
self.params.reply_markup = Some(reply_markup.into());
self
}
}
impl API {
pub fn send_paid_media(
&self,
chat_id: impl Into<ChatId>,
star_count: impl Into<i64>,
media: impl IntoIterator<Item = impl Into<InputPaidMedia>>,
) -> SendPaidMediaRequest {
SendPaidMediaRequest::new(self, chat_id, star_count, media)
}
}