feat: define get receiver

kimika/src/main.rs

@@ -1,6 +1,5 @@
 mod config;
 mod receive;
-mod request;
 mod send;
 mod utils;
 

kimika/src/send/remote_http.rs

@@ -1,7 +1,9 @@
 use super::SendArgs;
+use crate::utils::request::get_receivers;
 use crate::{config, utils::handle, utils::select};
 use crossterm::style::Stylize;
 use std::{fs, path::PathBuf};
+use tokio::{sync::mpsc, time};
 
 pub struct Content {
     pub message: Option<String>,
@@ -52,5 +54,30 @@ pub async fn remote_send(
         return Ok(());
     };
 
+    let (tx, mut rx) = mpsc::channel::<Vec<select::SelectItem<String>>>(1);
+
+    #[warn(while_true)]
+    loop {
+        let res = get_receivers(&address).await.expect("");
+        let receiver_iter = res.receivers.iter().map(|receiver| select::SelectItem {
+            id: receiver.id.clone(),
+            label: receiver.alias.clone(),
+        });
+        let result = tx.send(receiver_iter.collect()).await;
+        if result.is_err() {
+            break;
+        }
+        time::sleep(time::Duration::from_secs(1)).await;
+    }
+
+    let selected_receiver_id = if let Some(id) = select::receiver_select(&mut rx)
+        .await
+        .expect("select receiver failed")
+    {
+        id
+    } else {
+        return Ok(());
+    };
+
     Ok(())
 }

kimika/src/utils/mod.rs

@@ -1,5 +1,6 @@
 pub mod clap;
 pub mod crossterm;
 pub mod handle;
+pub mod request;
 pub mod select;
 pub mod udp;

kimika/src/utils/request.rs

@@ -0,0 +1,25 @@
+use reqwest::{Client, Url};
+use serde::{Deserialize, Serialize};
+use std::net::SocketAddr;
+
+#[derive(Deserialize)]
+pub struct Receiver {
+    pub id: String,
+    pub alias: String,
+}
+
+fn into_url(address: &SocketAddr) -> Url {
+    let url_string = format!("http://{}", address);
+    Url::parse(&url_string).expect("invalid address")
+}
+
+#[derive(Deserialize)]
+pub struct GetReceiversRes {
+    pub receivers: Vec<Receiver>,
+    message: String,
+}
+
+pub async fn get_receivers(address: &SocketAddr) -> Result<GetReceiversRes, reqwest::Error> {
+    let result = Client::new().get(into_url(address)).send().await?;
+    Ok(result.json().await.unwrap())
+}