From ced6bd8e696211b18a11fa05dcac20ed6fe1cc45 Mon Sep 17 00:00:00 2001
From: nextel <rm.nextel@gmail.com>
Date: Thu, 19 Sep 2019 17:57:50 +0300
Subject: [PATCH 1/7] add get user profile photos  template struct

---
 src/core/requests/get_user_profile_photos.rs | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

diff --git a/src/core/requests/get_user_profile_photos.rs b/src/core/requests/get_user_profile_photos.rs
index 2dfed773..fb69133f 100644
--- a/src/core/requests/get_user_profile_photos.rs
+++ b/src/core/requests/get_user_profile_photos.rs
@@ -1,8 +1,16 @@
 use crate::core::requests::RequestContext;
-//TODO:: need implementation
 
+
+//TODO: complete implementation after user_profile_fotos will be added to types/mod.rs
+///Use this method to get a list of profile pictures for a user. Returns a UserProfilePhotos object.
 #[derive(Debug, Clone, Serialize)]
 struct GetUserProfilePhotos<'a> {
     #[serde(skip_serializing)]
     ctx: RequestContext<'a>,
+    /// Unique identifier of the target user
+    user_id: i32,
+    /// Sequential number of the first photo to be returned. By default, all photos are returned.
+    offset: Option<i64>,
+    ///Limits the number of photos to be retrieved. Values between 1—100 are accepted. Defaults to 100.
+    limit: Option<i64>,
 }

From ccbfee24b83eba5fd8062a08755c3e0bd34ef6f7 Mon Sep 17 00:00:00 2001
From: Mr-Andersen <andrew-anderson.neo@yandex.ru>
Date: Thu, 19 Sep 2019 18:24:11 +0300
Subject: [PATCH 2/7] +Message::text(&self); message_kind->kind;
 IncomingMessage->CommonMessage

---
 src/core/types/message.rs | 17 +++++++++++++++--
 1 file changed, 15 insertions(+), 2 deletions(-)

diff --git a/src/core/types/message.rs b/src/core/types/message.rs
index ebc76355..2252f54f 100644
--- a/src/core/types/message.rs
+++ b/src/core/types/message.rs
@@ -11,13 +11,26 @@ pub struct Message {
     pub date: i32,
     pub chat: Chat,
     #[serde(flatten)]
-    pub message_kind: MessageKind,
+    pub kind: MessageKind,
+}
+
+impl Message {
+    fn text(&self) -> Option<&str> {
+        if let MessageKind::CommonMessage {
+                media_kind: MediaKind::Text {
+                    ref text, ..
+                }, .. } = self.kind {
+            Some(text)
+        } else {
+            None
+        }
+    }
 }
 
 #[derive(Debug, Deserialize, PartialEq, Clone)]
 #[serde(untagged)]
 pub enum MessageKind {
-    IncomingMessage {
+    CommonMessage {
         #[serde(flatten)]
         from: Sender,
         #[serde(flatten)]

From c395e24792d113dd8f67323cb08295e203a7bc4c Mon Sep 17 00:00:00 2001
From: P0lunin <polunindima2002@gmail.com>
Date: Thu, 19 Sep 2019 19:37:48 +0300
Subject: [PATCH 3/7] add enum ChatMemberStatus

---
 src/core/types/chat_member.rs           | 73 ++++++++++++++++++++++++-
 src/core/types/mod.rs                   |  2 +-
 src/core/types/not_implemented_types.rs |  3 -
 3 files changed, 73 insertions(+), 5 deletions(-)

diff --git a/src/core/types/chat_member.rs b/src/core/types/chat_member.rs
index 600b7e2e..cee60bc6 100644
--- a/src/core/types/chat_member.rs
+++ b/src/core/types/chat_member.rs
@@ -1,4 +1,4 @@
-use crate::core::types::{ChatMemberStatus, User};
+use crate::core::types::User;
 
 /// This object contains information about one member of the chat.
 #[derive(Debug, Deserialize, Hash, PartialEq, Eq, Clone)]
@@ -54,3 +54,74 @@ pub struct ChatMember {
     /// his messages, implies can_send_media_messages
     pub can_add_web_page_previews: Option<bool>,
 }
+
+#[derive(Deserialize, Debug, Hash, PartialEq, Eq, Clone)]
+#[serde(rename_all = "snake_case")]
+pub enum ChatMemberStatus {
+    Creator,
+    Administrator,
+    Member,
+    Restricted,
+    Left,
+    Kicked
+}
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+
+    #[test]
+    fn deserialize() {
+        let json = r#"{
+            "user":{
+                "id":12345,
+                "is_bot":false,
+                "first_name":"firstName"
+            },
+            "status":"creator",
+            "until_date":123456,
+            "can_be_edited":true,
+            "can_post_messages":true,
+            "can_edit_messages":true,
+            "can_delete_messages":true,
+            "can_restrict_members":true,
+            "can_promote_members":true,
+            "can_change_info":true,
+            "can_invite_users":true,
+            "can_pin_messages":true,
+            "is_member":true,
+            "can_send_messages":true,
+            "can_send_media_messages":true,
+            "can_send_polls":true,
+            "can_send_other_messages":true,
+            "can_add_web_page_previews":true
+        }"#;
+        let expected = ChatMember {
+            user: User {
+                id: 12345,
+                is_bot: false,
+                first_name: "firstName".to_string(),
+                last_name: None,
+                username: None,
+                language_code: None
+            },
+            status: ChatMemberStatus::Creator,
+            until_date: Some(123456),
+            can_be_edited: Some(true),
+            can_change_info: Some(true),
+            can_post_messages: Some(true),
+            can_edit_messages: Some(true),
+            can_delete_messages: Some(true),
+            can_invite_users: Some(true),
+            can_restrict_members: Some(true),
+            can_pin_messages: Some(true),
+            can_promote_members: Some(true),
+            can_send_messages: Some(true),
+            can_send_media_messages: Some(true),
+            can_send_other_messages: Some(true),
+            can_add_web_page_previews: Some(true)
+        };
+        let actual = serde_json::from_str::<ChatMember>(&json).unwrap();
+        assert_eq!(actual, expected)
+    }
+}
\ No newline at end of file
diff --git a/src/core/types/mod.rs b/src/core/types/mod.rs
index 42e9869a..27ba457b 100644
--- a/src/core/types/mod.rs
+++ b/src/core/types/mod.rs
@@ -4,7 +4,7 @@ pub use self::{
     audio::Audio,
     callback_query::CallbackQuery,
     chat::{Chat, ChatKind, NonPrivateChatKind},
-    chat_member::ChatMember,
+    chat_member::{ChatMember, ChatMemberStatus},
     chat_permissions::ChatPermissions,
     chat_photo::ChatPhoto,
     chosen_inline_result::ChosenInlineResult,
diff --git a/src/core/types/not_implemented_types.rs b/src/core/types/not_implemented_types.rs
index c2700b2d..c1e9d2ba 100644
--- a/src/core/types/not_implemented_types.rs
+++ b/src/core/types/not_implemented_types.rs
@@ -1,5 +1,2 @@
 #[derive(Debug, Deserialize, Eq, Hash, PartialEq, Serialize, Clone)]
 pub struct PassportData;
-
-#[derive(Debug, Deserialize, Eq, Hash, PartialEq, Serialize, Clone)]
-pub struct ChatMemberStatus;

From 7b638eb2c0a73b02b99d4ed04cb05a0e2cfe90a9 Mon Sep 17 00:00:00 2001
From: P0lunin <polunindima2002@gmail.com>
Date: Thu, 19 Sep 2019 19:38:07 +0300
Subject: [PATCH 4/7] add tests

---
 src/core/types/audio.rs          | 46 ++++++++++++++++++++++----
 src/core/types/callback_query.rs | 57 ++++++++++++++++++++++++--------
 src/core/types/user.rs           | 27 +++++++++++++++
 3 files changed, 110 insertions(+), 20 deletions(-)

diff --git a/src/core/types/audio.rs b/src/core/types/audio.rs
index 304d4946..66cc0878 100644
--- a/src/core/types/audio.rs
+++ b/src/core/types/audio.rs
@@ -1,17 +1,51 @@
 use crate::core::types::PhotoSize;
 
-#[derive(Debug, Deserialize, Eq, Hash, PartialEq, Serialize, Clone)]
+#[derive(Debug, Deserialize, Eq, Hash, PartialEq, Clone)]
 pub struct Audio {
     pub file_id: String,
     pub duration: u32,
-    #[serde(skip_serializing_if = "Option::is_none")]
     pub performer: Option<String>,
-    #[serde(skip_serializing_if = "Option::is_none")]
     pub title: Option<String>,
-    #[serde(skip_serializing_if = "Option::is_none")]
     pub mime_type: Option<String>,
-    #[serde(skip_serializing_if = "Option::is_none")]
     pub file_size: Option<u32>,
-    #[serde(skip_serializing_if = "Option::is_none")]
     pub thumb: Option<PhotoSize>,
 }
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+
+    #[test]
+    fn deserialize() {
+        let json = r#"{
+            "file_id":"id",
+            "duration":60,
+            "performer":"Performer",
+            "title":"Title",
+            "mime_type":"MimeType",
+            "file_size":123456,
+            "thumb":{
+                "file_id":"id",
+                "width":320,
+                "height":320,
+                "file_size":3452
+            }
+        }"#;
+        let expected = Audio {
+            file_id: "id".to_string(),
+            duration: 60,
+            performer: Some("Performer".to_string()),
+            title: Some("Title".to_string()),
+            mime_type: Some("MimeType".to_string()),
+            file_size: Some(123456),
+            thumb: Some(PhotoSize {
+                file_id: "id".to_string(),
+                width: 320,
+                height: 320,
+                file_size: Some(3452)
+            })
+        };
+        let actual = serde_json::from_str::<Audio>(&json).unwrap();
+        assert_eq!(actual, expected)
+    }
+}
diff --git a/src/core/types/callback_query.rs b/src/core/types/callback_query.rs
index edcbe996..3207bf02 100644
--- a/src/core/types/callback_query.rs
+++ b/src/core/types/callback_query.rs
@@ -1,22 +1,51 @@
 use crate::core::types::{Message, User};
 
-/// This object represents an incoming callback query from a callback button in
-/// an inline keyboard.
 #[derive(Debug, Deserialize, PartialEq, Clone)]
 pub struct CallbackQuery {
-    /// Unique identifier for this query
     pub id: String,
-    /// Sender
     pub from: User,
-    /// Message with the callback button that originated the query.
-    /// Note that message content and message date will not be available if the
-    /// message is too old
-    pub message: Message,
-    /// Global identifier, uniquely corresponding to the chat to which the
-    /// message with the callback button was sent. Useful for high scores
-    /// in games.
     pub chat_instance: String,
-    /// Data associated with the callback button. Be aware that a bad client
-    /// can send arbitrary data in this field.
-    pub data: String,
+    pub message: Option<Message>,
+    pub inline_message_id: Option<String>,
+    pub data: Option<String>,
+    pub game_short_name: Option<String>
+}
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+
+    #[test]
+    fn deserialize() {
+        let json = r#"{
+            "id":"id",
+            "from":{
+                "id":12345,
+                "is_bot":false,
+                "first_name":"firstName"
+            },
+            "inline_message_id":"i_m_id",
+            "chat_instance":"123456",
+            "data":"some_data",
+            "game_short_name":"game_name"
+        }"#;
+        let expected = CallbackQuery {
+            id: "id".to_string(),
+            from: User {
+                id: 12345,
+                is_bot: false,
+                first_name: "firstName".to_string(),
+                last_name: None,
+                username: None,
+                language_code: None
+            },
+            chat_instance: "123456".to_string(),
+            message: None,
+            inline_message_id: Some("i_m_id".to_string()),
+            data: Some("some_data".to_string()),
+            game_short_name: Some("game_name".to_string())
+        };
+        let actual = serde_json::from_str::<CallbackQuery>(json).unwrap();
+        assert_eq!(actual, expected);
+    }
 }
diff --git a/src/core/types/user.rs b/src/core/types/user.rs
index 953e1a23..a163b059 100644
--- a/src/core/types/user.rs
+++ b/src/core/types/user.rs
@@ -7,3 +7,30 @@ pub struct User {
     pub username: Option<String>,
     pub language_code: Option<String>,
 }
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+
+    #[test]
+    fn deserialize() {
+        let json = r#"{
+            "id":12345,
+            "is_bot":false,
+            "first_name":"firstName",
+            "last_name":"lastName",
+            "username":"Username",
+            "language_code":"languageCode"
+        }"#;
+        let expected = User {
+            id: 12345,
+            is_bot: false,
+            first_name: "firstName".to_string(),
+            last_name: Some("lastName".to_string()),
+            username: Some("Username".to_string()),
+            language_code: Some("languageCode".to_string())
+        };
+        let actual = serde_json::from_str::<User>(&json).unwrap();
+        assert_eq!(actual, expected)
+    }
+}

From cb5ea4a5b79e1336af1b948ae08b8e1c53c6693d Mon Sep 17 00:00:00 2001
From: Temirkhan Myrzamadi <gymmasssorla@gmail.com>
Date: Fri, 20 Sep 2019 06:24:08 +0600
Subject: [PATCH 5/7] Simplify src/core/network/mod.rs

---
 src/core/network/mod.rs | 62 ++++++++++++++++++-----------------------
 1 file changed, 27 insertions(+), 35 deletions(-)

diff --git a/src/core/network/mod.rs b/src/core/network/mod.rs
index 244c6d63..83a3e166 100644
--- a/src/core/network/mod.rs
+++ b/src/core/network/mod.rs
@@ -5,7 +5,7 @@ use crate::core::{
 
 use apply::Apply;
 use reqwest::{
-    r#async::{multipart::Form, Client},
+    r#async::{multipart::Form, Client, Response},
     StatusCode,
 };
 use serde::{de::DeserializeOwned, Serialize};
@@ -42,33 +42,18 @@ pub async fn request_multipart<T: DeserializeOwned>(
     method_name: &str,
     params: Option<Form>,
 ) -> ResponseResult<T> {
-    let mut response = client
-        .post(&method_url(TELEGRAM_API_URL, token, method_name))
-        .apply(|request_builder| match params {
-            Some(params) => request_builder.multipart(params),
-            None => request_builder,
-        })
-        .send()
-        .await
-        .map_err(RequestError::NetworkError)?;
-
-    let response = serde_json::from_str::<TelegramResponse<T>>(
-        &response.text().await.map_err(RequestError::NetworkError)?,
+    process_response(
+        client
+            .post(&method_url(TELEGRAM_API_URL, token, method_name))
+            .apply(|request_builder| match params {
+                Some(params) => request_builder.multipart(params),
+                None => request_builder,
+            })
+            .send()
+            .await
+            .map_err(RequestError::NetworkError)?,
     )
-    .map_err(RequestError::InvalidJson)?;
-
-    match response {
-        TelegramResponse::Ok { result, .. } => Ok(result),
-        TelegramResponse::Err {
-            description,
-            error_code,
-            response_parameters: _,
-            ..
-        } => Err(RequestError::ApiError {
-            description,
-            status_code: StatusCode::from_u16(error_code).unwrap(),
-        }),
-    }
+    .await
 }
 
 pub async fn request_json<T: DeserializeOwned, P: Serialize>(
@@ -77,13 +62,20 @@ pub async fn request_json<T: DeserializeOwned, P: Serialize>(
     method_name: &str,
     params: &P,
 ) -> ResponseResult<T> {
-    let mut response = client
-        .post(&method_url(TELEGRAM_API_URL, token, method_name))
-        .json(params)
-        .send()
-        .await
-        .map_err(RequestError::NetworkError)?;
+    process_response(
+        client
+            .post(&method_url(TELEGRAM_API_URL, token, method_name))
+            .json(params)
+            .send()
+            .await
+            .map_err(RequestError::NetworkError)?,
+    )
+    .await
+}
 
+async fn process_response<T: DeserializeOwned>(
+    mut response: Response,
+) -> ResponseResult<T> {
     let response = serde_json::from_str::<TelegramResponse<T>>(
         &response.text().await.map_err(RequestError::NetworkError)?,
     )
@@ -107,14 +99,14 @@ pub async fn request_json<T: DeserializeOwned, P: Serialize>(
 #[serde(untagged)]
 enum TelegramResponse<R> {
     Ok {
-        /// Dummy field. Used for deserialization.
+        /// A dummy field. Used only for deserialization.
         #[allow(dead_code)]
         ok: bool, // TODO: True type
 
         result: R,
     },
     Err {
-        /// Dummy field. Used for deserialization.
+        /// A dummy field. Used only for deserialization.
         #[allow(dead_code)]
         ok: bool, // TODO: False type
 

From f4b9e9344726e6e6304af71708b982f12b0108be Mon Sep 17 00:00:00 2001
From: nextel <rm.nextel@gmail.com>
Date: Fri, 20 Sep 2019 17:42:24 +0300
Subject: [PATCH 6/7] cargo fmt for requests/*

---
 src/core/requests/get_user_profile_photos.rs | 13 ++++++++-----
 src/core/requests/kick_chat_member.rs        |  6 +++++-
 2 files changed, 13 insertions(+), 6 deletions(-)

diff --git a/src/core/requests/get_user_profile_photos.rs b/src/core/requests/get_user_profile_photos.rs
index fb69133f..0c6311ec 100644
--- a/src/core/requests/get_user_profile_photos.rs
+++ b/src/core/requests/get_user_profile_photos.rs
@@ -1,16 +1,19 @@
 use crate::core::requests::RequestContext;
 
-
-//TODO: complete implementation after user_profile_fotos will be added to types/mod.rs
-///Use this method to get a list of profile pictures for a user. Returns a UserProfilePhotos object.
+//TODO: complete implementation after user_profile_fotos will be added to
+// types/mod.rs
+///Use this method to get a list of profile pictures for a user. Returns a
+/// UserProfilePhotos object.
 #[derive(Debug, Clone, Serialize)]
 struct GetUserProfilePhotos<'a> {
     #[serde(skip_serializing)]
     ctx: RequestContext<'a>,
     /// Unique identifier of the target user
     user_id: i32,
-    /// Sequential number of the first photo to be returned. By default, all photos are returned.
+    /// Sequential number of the first photo to be returned. By default, all
+    /// photos are returned.
     offset: Option<i64>,
-    ///Limits the number of photos to be retrieved. Values between 1—100 are accepted. Defaults to 100.
+    ///Limits the number of photos to be retrieved. Values between 1—100 are
+    /// accepted. Defaults to 100.
     limit: Option<i64>,
 }
diff --git a/src/core/requests/kick_chat_member.rs b/src/core/requests/kick_chat_member.rs
index 69c158a8..41d6dbc5 100644
--- a/src/core/requests/kick_chat_member.rs
+++ b/src/core/requests/kick_chat_member.rs
@@ -1,6 +1,10 @@
 use crate::core::requests::RequestContext;
 //TODO:: need implementation
-
+/// Use this method to kick a user from a group, a supergroup or a channel. In
+/// the case of supergroups and channels, the user will not be able to return to
+/// the group on their own using invite links, etc., unless unbanned first. The
+/// bot must be an administrator in the chat for this to work and must have the
+/// appropriate admin rights. Returns True on success.
 #[derive(Debug, Clone, Serialize)]
 struct KickChatMember<'a> {
     #[serde(skip_serializing)]

From 2b23136e2fd6f4997390e36cd4610059a78426e4 Mon Sep 17 00:00:00 2001
From: Temirkhan Myrzamadi <gymmasssorla@gmail.com>
Date: Sat, 21 Sep 2019 02:05:56 +0600
Subject: [PATCH 7/7] CommonMessage -> Common, PinnedMessage -> Pinned

---
 src/core/types/message.rs | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/core/types/message.rs b/src/core/types/message.rs
index 2252f54f..8caf1fea 100644
--- a/src/core/types/message.rs
+++ b/src/core/types/message.rs
@@ -16,7 +16,7 @@ pub struct Message {
 
 impl Message {
     fn text(&self) -> Option<&str> {
-        if let MessageKind::CommonMessage {
+        if let MessageKind::Common {
                 media_kind: MediaKind::Text {
                     ref text, ..
                 }, .. } = self.kind {
@@ -30,7 +30,7 @@ impl Message {
 #[derive(Debug, Deserialize, PartialEq, Clone)]
 #[serde(untagged)]
 pub enum MessageKind {
-    CommonMessage {
+    Common {
         #[serde(flatten)]
         from: Sender,
         #[serde(flatten)]
@@ -68,8 +68,8 @@ pub enum MessageKind {
         migrate_to_chat_id: i64,
         migrate_from_chat_id: i64,
     },
-    PinnedMessage {
-        pinned_message: Box<Message>,
+    Pinned {
+        pinned: Box<Message>,
     },
     Invoice {
         invoice: Invoice,