From 7920dc62e6361f532a07706838ea357c2f079cda Mon Sep 17 00:00:00 2001
From: bitfl0wer <florian@pro-weber.com>
Date: Sat, 6 May 2023 22:24:23 +0200
Subject: [PATCH] Implement message sending (without attachments)

---
 src/api/channels/messages.rs | 98 +++++++++++++++++++++++++++++++++---
 1 file changed, 91 insertions(+), 7 deletions(-)

diff --git a/src/api/channels/messages.rs b/src/api/channels/messages.rs
index 80481f5..1fa840a 100644
--- a/src/api/channels/messages.rs
+++ b/src/api/channels/messages.rs
@@ -1,4 +1,7 @@
 pub mod messages {
+    use reqwest::Client;
+    use serde_json::to_string;
+
     use crate::api::limits::Limits;
     use crate::api::types::{Message, PartialDiscordFileAttachment, User};
     use crate::limit::LimitedRequester;
@@ -18,14 +21,35 @@ pub mod messages {
 
         pub async fn send<'a>(
             url_api: &String,
+            channel_id: &String,
             message: &mut crate::api::schemas::MessageSendSchema,
             files: Option<Vec<PartialDiscordFileAttachment>>,
             token: &String,
             user: &mut User<'a>,
-            requester: &mut LimitedRequester,
-        ) {
-            let user_limits = &mut user.limits;
-            let instance_limits = &mut user.belongs_to.limits;
+        ) -> Result<reqwest::Response, crate::errors::InstanceServerError> {
+            let mut requester = LimitedRequester::new().await;
+            let user_rate_limits = &mut user.limits;
+            let instance_rate_limits = &mut user.belongs_to.limits;
+
+            if files.is_none() {
+                let message_request = Client::new()
+                    .post(format!("{}/channels/{}/messages/", url_api, channel_id))
+                    .bearer_auth(token)
+                    .body(to_string(message).unwrap());
+                requester
+                    .send_request(
+                        message_request,
+                        crate::api::limits::LimitType::Channel,
+                        instance_rate_limits,
+                        user_rate_limits,
+                    )
+                    .await
+            } else {
+                return Err(crate::errors::InstanceServerError::InvalidFormBodyError {
+                    error_type: "Not implemented".to_string(),
+                    error: "Not implemented".to_string(),
+                });
+            }
         }
     }
 
@@ -33,18 +57,78 @@ pub mod messages {
         pub async fn send_message(
             &mut self,
             mut message: &mut crate::api::schemas::MessageSendSchema,
+            channel_id: &String,
             files: Option<Vec<PartialDiscordFileAttachment>>,
-        ) {
+        ) -> Result<reqwest::Response, crate::errors::InstanceServerError> {
             let token = self.token().clone();
             Message::send(
                 &self.belongs_to.urls.get_api().to_string(),
+                channel_id,
                 &mut message,
                 files,
                 &token,
                 self,
-                &mut LimitedRequester::new().await,
             )
-            .await;
+            .await
         }
     }
 }
+
+#[cfg(test)]
+mod test {
+    use crate::{
+        api::{AuthUsername, LoginSchema, MessageSendSchema, UserObject},
+        instance::Instance,
+        limit::LimitedRequester,
+    };
+
+    use super::*;
+
+    #[tokio::test]
+    async fn send_message() {
+        let channel_id = "1104413094102290492".to_string();
+        let mut message = crate::api::schemas::MessageSendSchema::new(
+            None,
+            Some("ashjkdhjksdfgjsdfzjkhsdvhjksdf".to_string()),
+            None,
+            None,
+            None,
+            None,
+            None,
+            None,
+            None,
+            None,
+            None,
+        );
+        let mut instance = Instance::new(
+            crate::URLBundle {
+                api: "http://localhost:3001/api".to_string(),
+                wss: "ws://localhost:3001/".to_string(),
+                cdn: "http://localhost:3001".to_string(),
+            },
+            LimitedRequester::new().await,
+        )
+        .await
+        .unwrap();
+        let login_schema: LoginSchema = LoginSchema::new(
+            AuthUsername::new("user1@gmail.com".to_string()).unwrap(),
+            "user".to_string(),
+            None,
+            None,
+            None,
+            None,
+        )
+        .unwrap();
+        let login_result = instance.login_account(&login_schema).await.unwrap();
+        let token = login_result.token;
+        let settings = login_result.settings;
+        let limits = instance.limits.clone();
+        let mut user =
+            crate::api::types::User::new(true, &mut instance, token, limits, settings, None);
+        let response = user
+            .send_message(&mut message, &channel_id, None)
+            .await
+            .unwrap();
+        println!("{:?}", response);
+    }
+}